fix bug: multiple gateway kick user

internal/msggateway/hub_server.go

@@ -185,7 +185,7 @@ func (s *Server) KickUserOffline(
 				if err != nil {
 					return nil, err
 				}
-				s.LongConnServer.UnRegister(client)
+				// s.LongConnServer.UnRegister(client)
 			}
 		} else {
 			log.ZInfo(ctx, "conn not exist", nil, "userID", v, "platformID", req.PlatformID)

internal/rpc/auth/auth.go

@@ -130,7 +130,9 @@ func (s *authServer) forceKickOff(ctx context.Context, userID string, platformID
 	if err != nil {
 		return err
 	}
-	log.ZDebug(ctx, "forceKickOff", "conns", conns)
+	for _, v := range conns {
+		log.ZDebug(ctx, "forceKickOff", "conn", v.(*grpc.ClientConn).Target())
+	}
 	for _, v := range conns {
 		client := msggateway.NewMsgGatewayClient(v)
 		kickReq := &msggateway.KickUserOfflineReq{KickUserIDList: []string{userID}, PlatformID: platformID}

pkg/proto/msg/msg.go

@@ -126,6 +126,11 @@ func (x *MarkMsgsAsReadReq) Check() error {
 	if x.UserID == "" {
 		return errs.ErrArgs.Wrap("userID is empty")
 	}
+	for _, seq := range x.Seqs {
+		if seq == 0 {
+			return errs.ErrArgs.Wrap("seqs has 0 value is invalid")
+		}
+	}
 	return nil
 }
 
@@ -139,6 +144,11 @@ func (x *MarkConversationAsReadReq) Check() error {
 	if x.HasReadSeq < 1 {
 		return errs.ErrArgs.Wrap("hasReadSeq is invalid")
 	}
+	for _, seq := range x.Seqs {
+		if seq == 0 {
+			return errs.ErrArgs.Wrap("seqs has 0 value is invalid")
+		}
+	}
 	return nil
 }