actions_test: Create updateMessageFlagsStartingFromAnchor test group

Author: Khader-1

test/widgets/actions_test.dart

@@ -24,27 +24,27 @@ import 'test_app.dart';
 void main() {
   TestZulipBinding.ensureInitialized();
 
-  group('markNarrowAsRead', () {
-    late PerAccountStore store;
-    late FakeApiConnection connection;
-    late BuildContext context;
+  late PerAccountStore store;
+  late FakeApiConnection connection;
+  late BuildContext context;
 
-    Future<void> prepare(WidgetTester tester, {
-      UnreadMessagesSnapshot? unreadMsgs,
-    }) async {
-      addTearDown(testBinding.reset);
-      await testBinding.globalStore.add(eg.selfAccount, eg.initialSnapshot(
-        unreadMsgs: unreadMsgs));
-      store = await testBinding.globalStore.perAccount(eg.selfAccount.id);
-      connection = store.connection as FakeApiConnection;
+  Future<void> prepare(WidgetTester tester, {
+    UnreadMessagesSnapshot? unreadMsgs,
+  }) async {
+    addTearDown(testBinding.reset);
+    await testBinding.globalStore.add(eg.selfAccount, eg.initialSnapshot(
+      unreadMsgs: unreadMsgs));
+    store = await testBinding.globalStore.perAccount(eg.selfAccount.id);
+    connection = store.connection as FakeApiConnection;
 
-      await tester.pumpWidget(TestZulipApp(accountId: eg.selfAccount.id,
-        child: const Scaffold(body: Placeholder())));
-      // global store, per-account store get loaded
-      await tester.pumpAndSettle();
-      context = tester.element(find.byType(Placeholder));
-    }
+    await tester.pumpWidget(TestZulipApp(accountId: eg.selfAccount.id,
+      child: const Scaffold(body: Placeholder())));
+    // global store, per-account store get loaded
+    await tester.pumpAndSettle();
+    context = tester.element(find.byType(Placeholder));
+  }
 
+  group('markNarrowAsRead', () {
     testWidgets('smoke test on modern server', (tester) async {
       final narrow = TopicNarrow.ofMessage(eg.streamMessage());
       await prepare(tester);
@@ -290,4 +290,38 @@ void main() {
         expectedMessage: 'NetworkException: Oops (ClientException: Oops)');
     });
   });
+
+  group('updateMessageFlagsStartingFromAnchor', () {
+    String onCompletedMessage(int count) => 'onCompletedMessage($count)';
+    const progressMessage = 'progressMessage';
+    const onFailedTitle = 'onFailedTitle';
+
+    testWidgets('smoke test', (tester) async {
+      final narrow = TopicNarrow.ofMessage(eg.streamMessage());
+      final apiNarrow = narrow.apiEncode()..add(ApiNarrowIsUnread());
+      await prepare(tester);
+      connection.prepare(json: UpdateMessageFlagsForNarrowResult(
+        processedCount: 11, updatedCount: 3,
+        firstProcessedId: 1, lastProcessedId: 1980,
+        foundOldest: true, foundNewest: true).toJson());
+      final didPass = updateMessageFlagsStartingFromAnchor(
+        context: context, apiNarrow: apiNarrow, op: UpdateMessageFlagsOp.add, flag: MessageFlag.read,
+        includeAnchor: false, startingAnchor: AnchorCode.oldest, onCompletedMessage: onCompletedMessage,
+        onFailedTitle: onFailedTitle, progressMessage: progressMessage);
+      await tester.pump(Duration.zero);
+      check(connection.lastRequest).isA<http.Request>()
+        ..method.equals('POST')
+        ..url.path.equals('/api/v1/messages/flags/narrow')
+        ..bodyFields.deepEquals({
+            'anchor': 'oldest',
+            'include_anchor': 'false',
+            'num_before': '0',
+            'num_after': '1000',
+            'narrow': jsonEncode(apiNarrow),
+            'op': 'add',
+            'flag': 'read',
+          });
+      check(await didPass).isTrue();
+    });
+  });
 }