fix conversation del empty cache

pull/458/head
wangchuxiao 2 years ago
parent 676076e95b
commit d84530458a

@ -171,6 +171,7 @@ func (c *conversationDatabase) SetUserConversations(ctx context.Context, ownerUs
var conversationIDs []string var conversationIDs []string
for _, conversation := range conversations { for _, conversation := range conversations {
conversationIDs = append(conversationIDs, conversation.ConversationID) conversationIDs = append(conversationIDs, conversation.ConversationID)
cache = cache.DelConvsersations(conversation.OwnerUserID, conversation.ConversationID)
} }
conversationTx := c.conversationDB.NewTx(tx) conversationTx := c.conversationDB.NewTx(tx)
existConversations, err := conversationTx.Find(ctx, ownerUserID, conversationIDs) existConversations, err := conversationTx.Find(ctx, ownerUserID, conversationIDs)
@ -194,7 +195,6 @@ func (c *conversationDatabase) SetUserConversations(ctx context.Context, ownerUs
for _, conversation := range conversations { for _, conversation := range conversations {
if !utils.IsContain(conversation.ConversationID, existConversationIDs) { if !utils.IsContain(conversation.ConversationID, existConversationIDs) {
notExistConversations = append(notExistConversations, conversation) notExistConversations = append(notExistConversations, conversation)
cache = cache.DelConvsersations(ownerUserID, conversation.ConversationID)
} }
} }
if len(notExistConversations) > 0 { if len(notExistConversations) > 0 {
@ -204,7 +204,6 @@ func (c *conversationDatabase) SetUserConversations(ctx context.Context, ownerUs
} }
cache = cache.DelConversationIDs(ownerUserID).DelUserConversationIDsHash(ownerUserID) cache = cache.DelConversationIDs(ownerUserID).DelUserConversationIDsHash(ownerUserID)
} }
cache = cache.DelConvsersations(ownerUserID, existConversationIDs...)
return nil return nil
}); err != nil { }); err != nil {
return err return err

Loading…
Cancel
Save