user: Add UserStore.isUserMuted, with event updates

Co-authored-by: Chris Bobbe <[email protected]>

Author: sm-sayedi

lib/model/store.dart

@@ -645,6 +645,10 @@ class PerAccountStore extends PerAccountStoreBase with ChangeNotifier, EmojiStor
   @override
   Iterable<User> get allUsers => _users.allUsers;
 
+  @override
+  bool isUserMuted(int userId, {MutedUsersEvent? event}) =>
+    _users.isUserMuted(userId, event: event);
+
   final UserStoreImpl _users;
 
   final TypingStatus typingStatus;
@@ -950,8 +954,9 @@ class PerAccountStore extends PerAccountStoreBase with ChangeNotifier, EmojiStor
         _messages.handleReactionEvent(event);
 
       case MutedUsersEvent():
-        // TODO handle
-        break;
+        assert(debugLog("server event: muted_users"));
+        _users.handleMutedUsersEvent(event);
+        notifyListeners();
 
       case UnexpectedEvent():
         assert(debugLog("server event: ${jsonEncode(event.toJson())}")); // TODO log better

lib/model/user.dart

@@ -66,6 +66,12 @@ mixin UserStore on PerAccountStoreBase {
     return getUser(message.senderId)?.fullName
       ?? message.senderFullName;
   }
+
+  /// Whether the user with [userId] is muted by the self-user.
+  ///
+  /// Looks for [userId] in a private [Set],
+  /// or in [event.mutedUsers] instead if event is non-null.
+  bool isUserMuted(int userId, {MutedUsersEvent? event});
 }
 
 /// The implementation of [UserStore] that does the work.
@@ -81,7 +87,8 @@ class UserStoreImpl extends PerAccountStoreBase with UserStore {
          initialSnapshot.realmUsers
          .followedBy(initialSnapshot.realmNonActiveUsers)
          .followedBy(initialSnapshot.crossRealmBots)
-         .map((user) => MapEntry(user.userId, user)));
+         .map((user) => MapEntry(user.userId, user))),
+       _mutedUsers = Set.from(initialSnapshot.mutedUsers.map((item) => item.id));
 
   final Map<int, User> _users;
 
@@ -91,6 +98,13 @@ class UserStoreImpl extends PerAccountStoreBase with UserStore {
   @override
   Iterable<User> get allUsers => _users.values;
 
+  final Set<int> _mutedUsers;
+
+  @override
+  bool isUserMuted(int userId, {MutedUsersEvent? event}) {
+    return (event?.mutedUsers.map((item) => item.id) ?? _mutedUsers).contains(userId);
+  }
+
   void handleRealmUserEvent(RealmUserEvent event) {
     switch (event) {
       case RealmUserAddEvent():
@@ -129,4 +143,9 @@ class UserStoreImpl extends PerAccountStoreBase with UserStore {
         }
     }
   }
+
+  void handleMutedUsersEvent(MutedUsersEvent event) {
+    _mutedUsers.clear();
+    _mutedUsers.addAll(event.mutedUsers.map((item) => item.id));
+  }
 }

test/model/user_test.dart

@@ -79,4 +79,27 @@ void main() {
       check(getUser()).deliveryEmail.equals('[email protected]');
     });
   });
+
+  testWidgets('MutedUsersEvent', (tester) async {
+    final user1 = eg.user(userId: 1);
+    final user2 = eg.user(userId: 2);
+    final user3 = eg.user(userId: 3);
+
+    final store = eg.store(initialSnapshot: eg.initialSnapshot(
+      realmUsers: [user1, user2, user3],
+      mutedUsers: [MutedUserItem(id: 2), MutedUserItem(id: 1)]));
+    check(store.isUserMuted(1)).isTrue();
+    check(store.isUserMuted(2)).isTrue();
+    check(store.isUserMuted(3)).isFalse();
+
+    await store.handleEvent(eg.mutedUsersEvent([2, 1, 3]));
+    check(store.isUserMuted(1)).isTrue();
+    check(store.isUserMuted(2)).isTrue();
+    check(store.isUserMuted(3)).isTrue();
+
+    await store.handleEvent(eg.mutedUsersEvent([2, 3]));
+    check(store.isUserMuted(1)).isFalse();
+    check(store.isUserMuted(2)).isTrue();
+    check(store.isUserMuted(3)).isTrue();
+  });
 }