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) 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...) }