fix: import del cache (#2492)

4 months ago · 9b32c630dc
parent 56e6da12c3
commit 9b32c630dc
1 changed files with 1 additions and 0 deletions
--- a/pkg/common/storage/controller/friend.go
+++ b/pkg/common/storage/controller/friend.go
@ -192,6 +192,7 @@ func (f *friendDatabase) BecomeFriends(ctx context.Context, ownerUserID string,
 		if err != nil {
 			return err
 		}
+		cache = cache.DelFriendIDs(ownerUserID).DelMaxFriendVersion(ownerUserID)
 		if len(newMyFriendIDs) > 0 {
 			cache = cache.DelFriendIDs(newMyFriendIDs...)
 			cache = cache.DelFriends(ownerUserID, newMyFriendIDs).DelMaxFriendVersion(newMyFriendIDs...)