Skip to content

Commit 716e06f

Browse files
pb (#2958) (#2961)
Co-authored-by: chao <[email protected]>
1 parent 3fe2053 commit 716e06f

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

internal/rpc/msg/delete.go

+8-1
Original file line numberDiff line numberDiff line change
@@ -138,9 +138,16 @@ func (m *msgServer) clearConversation(ctx context.Context, conversationIDs []str
138138
}
139139
isSyncSelf, isSyncOther := m.validateDeleteSyncOpt(deleteSyncOpt)
140140
if !isSyncOther {
141-
if err := m.MsgDatabase.SetUserConversationsMinSeqs(ctx, userID, m.getMinSeqs(maxSeqs)); err != nil {
141+
setSeqs := m.getMinSeqs(maxSeqs)
142+
if err := m.MsgDatabase.SetUserConversationsMinSeqs(ctx, userID, setSeqs); err != nil {
142143
return err
143144
}
145+
ownerUserIDs := []string{userID}
146+
for conversationID, seq := range setSeqs {
147+
if err := m.Conversation.SetConversationMinSeq(ctx, ownerUserIDs, conversationID, seq); err != nil {
148+
return err
149+
}
150+
}
144151
// notification 2 self
145152
if isSyncSelf {
146153
tips := &sdkws.ClearConversationTips{UserID: userID, ConversationIDs: existConversationIDs}

0 commit comments

Comments
 (0)