From 45f161c95f53267e5a2acce8a46465d516aaaa62 Mon Sep 17 00:00:00 2001 From: luhaoling <2198702716@qq.com> Date: Sat, 23 Dec 2023 18:26:59 +0800 Subject: [PATCH] fix: find the error --- internal/rpc/msg/seq.go | 3 +++ pkg/rpcclient/msg.go | 1 + 2 files changed, 4 insertions(+) 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, })