From 5ae56fc449af46420caa08e5b9e620e9d1cb0529 Mon Sep 17 00:00:00 2001
From: Gordon <1432970085@qq.com>
Date: Wed, 14 Jun 2023 14:20:02 +0800
Subject: [PATCH 1/2] refactor: kick user

---
 internal/msggateway/n_ws_server.go | 1 -
 1 file changed, 1 deletion(-)

diff --git a/internal/msggateway/n_ws_server.go b/internal/msggateway/n_ws_server.go
index de2788cb0..32b2a7283 100644
--- a/internal/msggateway/n_ws_server.go
+++ b/internal/msggateway/n_ws_server.go
@@ -232,7 +232,6 @@ func (ws *WsServer) unregisterClient(client *Client) {
 }
 
 func (ws *WsServer) wsHandler(w http.ResponseWriter, r *http.Request) {
-	defer log.ZInfo(context.Background(), "wsHandler", "remote addr", "url", r.URL.String())
 	connContext := newContext(w, r)
 	if ws.onlineUserConnNum >= ws.wsMaxConnNum {
 		httpError(connContext, errs.ErrConnOverMaxNumLimit)

From 61a7c0f09a95f876195c02d6ccf4b34d45bf5a98 Mon Sep 17 00:00:00 2001
From: Gordon <1432970085@qq.com>
Date: Wed, 14 Jun 2023 14:23:55 +0800
Subject: [PATCH 2/2] refactor: add rpc func

---
 internal/rpc/msg/server.go | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/internal/rpc/msg/server.go b/internal/rpc/msg/server.go
index c2b30191e..94510771c 100644
--- a/internal/rpc/msg/server.go
+++ b/internal/rpc/msg/server.go
@@ -34,6 +34,11 @@ type msgServer struct {
 	notificationSender     *rpcclient.NotificationSender
 }
 
+func (m *msgServer) SetConversationHasReadSeq(ctx context.Context, req *msg.SetConversationHasReadSeqReq) (*msg.SetConversationHasReadSeqResp, error) {
+	//TODO implement me
+	panic("implement me")
+}
+
 func (m *msgServer) addInterceptorHandler(interceptorFunc ...MessageInterceptorFunc) {
 	m.Handlers = append(m.Handlers, interceptorFunc...)
 }