diff --git a/internal/rpc/msg/seq.go b/internal/rpc/msg/seq.go index dfc2ad0b1..a01db2c86 100644 --- a/internal/rpc/msg/seq.go +++ b/internal/rpc/msg/seq.go @@ -16,6 +16,7 @@ package msg import ( "context" + "github.com/OpenIMSDK/tools/log" pbmsg "github.com/OpenIMSDK/protocol/msg" ) @@ -32,10 +33,12 @@ func (m *msgServer) GetConversationMaxSeq( } func (m *msgServer) GetMaxSeqs(ctx context.Context, req *pbmsg.GetMaxSeqsReq) (*pbmsg.SeqsInfoResp, error) { + log.ZDebug(ctx, "GetMaxSeqsServer", "seqs", req) maxSeqs, err := m.MsgDatabase.GetMaxSeqs(ctx, req.ConversationIDs) if err != nil { return nil, err } + log.ZDebug(ctx, "GetMaxSeqsServer", "maxSeqs", maxSeqs) return &pbmsg.SeqsInfoResp{MaxSeqs: maxSeqs}, nil } diff --git a/pkg/rpcclient/msg.go b/pkg/rpcclient/msg.go index 506731ce6..0a14de03e 100644 --- a/pkg/rpcclient/msg.go +++ b/pkg/rpcclient/msg.go @@ -156,6 +156,7 @@ func (m *MessageRpcClient) GetMaxSeq(ctx context.Context, req *sdkws.GetMaxSeqRe } func (m *MessageRpcClient) GetMaxSeqs(ctx context.Context, conversationIDs []string) (map[string]int64, error) { + log.ZDebug(ctx, "GetMaxSeqs", "seqs", "conversations", conversationIDs) resp, err := m.Client.GetMaxSeqs(ctx, &msg.GetMaxSeqsReq{ ConversationIDs: conversationIDs, })