IM/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2026-04-28 14:29:19 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: write msg to redis (#2836)

Browse Source
This commit is contained in:
icey-yu
2024-11-05 15:33:15 +08:00
committed by OpenIM-Robot
parent 404a9048e2
commit 0ac6668a50
2 changed files with 10 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/common/storage/controller/msg.go
+10
View File
@@ -443,6 +443,11 @@ func (db *commonMsgDatabase) GetMsgBySeqsRange(ctx context.Context, userID strin
return 0, 0, nil, err
}
successMsgs = append(mongoMsgs, successMsgs...)
_, err = db.msg.SetMessagesToCache(ctx, conversationID, mongoMsgs)
if err != nil {
return 0, 0, nil, err
}
}
return minSeq, maxSeq, successMsgs, nil
@@ -500,6 +505,11 @@ func (db *commonMsgDatabase) GetMsgBySeqs(ctx context.Context, userID string, co
}
successMsgs = append(successMsgs, mongoMsgs...)
_, err = db.msg.SetMessagesToCache(ctx, conversationID, mongoMsgs)
if err != nil {
return 0, 0, nil, err
}
}
return minSeq, maxSeq, successMsgs, nil
}