model: Prevent duplicate flags when processing update_message_flags.

Fixes #1986.

Author: sarafarajnasardi

lib/model/message.dart

@@ -736,7 +736,9 @@ class MessageStoreImpl extends HasChannelStore with MessageStore, _OutboxMessage
 
     if (isAdd && (event as UpdateMessageFlagsAddEvent).all) {
       for (final message in messages.values) {
-        message.flags.add(event.flag);
+        if (!message.flags.contains(event.flag)) {
+          message.flags.add(event.flag);
+        }
       }
 
       for (final view in _messageListViews) {
@@ -750,9 +752,13 @@ class MessageStoreImpl extends HasChannelStore with MessageStore, _OutboxMessage
         if (message == null) continue; // a message we don't know about yet
         anyMessageFound = true;
 
-        isAdd
-          ? message.flags.add(event.flag)
-          : message.flags.remove(event.flag);
+        if (isAdd) {
+          if (!message.flags.contains(event.flag)) {
+            message.flags.add(event.flag);
+          }
+        } else {
+          message.flags.remove(event.flag);
+        }
       }
       if (anyMessageFound) {
         // TODO(#818): Support MentionsNarrow live-updates when handling

test/model/message_test.dart

@@ -1702,6 +1702,33 @@ void main() {
         check(store).messages.values
           .single.flags.deepEquals([MessageFlag.starred, MessageFlag.read]);
       });
+
+      test('avoid duplicate flags', () async {
+        // Regression test for https://github.com/zulip/zulip-flutter/issues/1986
+        await prepare();
+        final message = eg.streamMessage(flags: [MessageFlag.read]);
+        await prepareMessages([message]);
+
+        await store.handleEvent(mkAddEvent(MessageFlag.read, [message.id]));
+        check(store).messages.values.single.flags.deepEquals([MessageFlag.read]);
+      });
+
+      test('handle update_message_flags: add flag "all" is idempotent', () async {
+        await prepare();
+        final m1 = eg.streamMessage(flags: [MessageFlag.read]);
+        final m2 = eg.streamMessage(flags: []);
+        await prepareMessages([m1, m2]);
+
+        await store.handleEvent(UpdateMessageFlagsAddEvent(
+          id: 1,
+          all: true,
+          flag: MessageFlag.read,
+          messages: [],
+        ));
+
+        check(store.messages[m1.id]!.flags).deepEquals([MessageFlag.read]);
+        check(store.messages[m2.id]!.flags).deepEquals([MessageFlag.read]);
+      });
     });
 
     group('remove flag', () {