blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-12-03 10:52:33 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: fix the err not wrap

Browse Source
This commit is contained in:
luhaoling 2023-12-27 16:09:10 +08:00
parent f36129d01b
commit 54f29e820e
2 changed files with 1 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/rpc/msg/seq.go
View File

@ -16,8 +16,6 @@ package msg
import ( import (
"context" "context"
"github.com/OpenIMSDK/tools/log"
pbmsg "github.com/OpenIMSDK/protocol/msg" pbmsg "github.com/OpenIMSDK/protocol/msg"
) )
@ -33,12 +31,10 @@ func (m *msgServer) GetConversationMaxSeq(
} }
func (m *msgServer) GetMaxSeqs(ctx context.Context, req *pbmsg.GetMaxSeqsReq) (*pbmsg.SeqsInfoResp, error) { 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) maxSeqs, err := m.MsgDatabase.GetMaxSeqs(ctx, req.ConversationIDs)
if err != nil { if err != nil {
return nil, err return nil, err
} }
log.ZDebug(ctx, "GetMaxSeqsServer", "maxSeqs", maxSeqs)
return &pbmsg.SeqsInfoResp{MaxSeqs: maxSeqs}, nil return &pbmsg.SeqsInfoResp{MaxSeqs: maxSeqs}, nil
} }

2
pkg/common/db/controller/msg.go
View File

@ -1063,7 +1063,7 @@ func (db *commonMsgDatabase) FindOneByDocIDs(ctx context.Context, conversationID
docID := conversationID + ":" + fmt.Sprintf("%d", seq) docID := conversationID + ":" + fmt.Sprintf("%d", seq)
msgs, err := db.msgDocDatabase.FindOneByDocID(ctx, docID) msgs, err := db.msgDocDatabase.FindOneByDocID(ctx, docID)
if err != nil { if err != nil {
return nil, err return nil, errs.ErrRecordNotFound.Wrap(err.Error())
} }
totalMsgs[conversationID] = convert.MsgDB2Pb(msgs.Msg[index].Msg) totalMsgs[conversationID] = convert.MsgDB2Pb(msgs.Msg[index].Msg)
} }