diff --git a/internal/msggateway/message_handler.go b/internal/msggateway/message_handler.go index a8f331240..b79e99946 100644 --- a/internal/msggateway/message_handler.go +++ b/internal/msggateway/message_handler.go @@ -2,6 +2,7 @@ package msggateway import ( "context" + "github.com/OpenIMSDK/Open-IM-Server/pkg/proto/msg" "github.com/OpenIMSDK/Open-IM-Server/pkg/proto/sdkws" "github.com/OpenIMSDK/Open-IM-Server/pkg/rpcclient/notification" @@ -61,7 +62,7 @@ func (g GrpcHandler) GetSeq(context context.Context, data Req) ([]byte, error) { if err := proto.Unmarshal(data.Data, &req); err != nil { return nil, err } - if err := g.validate.Struct(req); err != nil { + if err := g.validate.Struct(&req); err != nil { return nil, err } resp, err := g.notification.Msg.GetMaxAndMinSeq(context, &req) @@ -100,7 +101,7 @@ func (g GrpcHandler) SendSignalMessage(context context.Context, data Req) ([]byt if err := proto.Unmarshal(data.Data, &signalReq); err != nil { return nil, err } - if err := g.validate.Struct(signalReq); err != nil { + if err := g.validate.Struct(&signalReq); err != nil { return nil, err } //req := pbRtc.SignalMessageAssembleReq{SignalReq: &signalReq, OperationID: "111"} diff --git a/pkg/common/db/controller/conversation.go b/pkg/common/db/controller/conversation.go index dd8597125..204bfd811 100644 --- a/pkg/common/db/controller/conversation.go +++ b/pkg/common/db/controller/conversation.go @@ -168,6 +168,7 @@ func (c *ConversationDataBase) SetUserConversations(ctx context.Context, ownerUs return err } if len(existConversations) > 0 { + log.ZDebug(ctx, "SetUserConversations", "existConversations", existConversations) err = conversationTx.Update(ctx, conversations) if err != nil { return err