Add unit test to mark activity watched

Author: renefloor

packages/stream_feeds/test/state/feed_test.dart

@@ -345,4 +345,100 @@ void main() {
       );
     });
   });
+
+  group('Story events', () {
+    late StreamController<Object> wsStreamController;
+    late MockWebSocketSink webSocketSink;
+
+    setUp(() async {
+      wsStreamController = StreamController<Object>();
+      webSocketSink = MockWebSocketSink();
+      WsTestConnection(
+        wsStreamController: wsStreamController,
+        webSocketSink: webSocketSink,
+        webSocketChannel: webSocketChannel,
+      ).setUp();
+
+      await client.connect();
+    });
+
+    tearDown(() async {
+      await webSocketSink.close();
+      await wsStreamController.close();
+    });
+
+    test('Watch story should update isWatched', () async {
+      const feedId = FeedId(group: 'stories', id: 'target');
+      final activity1 = createDefaultActivityResponse().activity.copyWith(
+            isWatched: false,
+            id: 'storyActivityId1',
+          );
+
+      final activity2 = createDefaultActivityResponse().activity.copyWith(
+            isWatched: false,
+            id: 'storyActivityId2',
+          );
+
+      when(
+        () => feedsApi.getOrCreateFeed(
+          feedGroupId: feedId.group,
+          feedId: feedId.id,
+          getOrCreateFeedRequest: any(named: 'getOrCreateFeedRequest'),
+        ),
+      ).thenAnswer(
+        (_) async => Result.success(
+          createDefaultGetOrCreateFeedResponse(
+            aggregatedActivities: [
+              createDefaultAggregatedActivityResponse(
+                activities: [activity1, activity2],
+              ),
+            ],
+          ),
+        ),
+      );
+
+      final feed = client.feedFromId(feedId);
+
+      final result = await feed.getOrCreate();
+      result.getOrThrow();
+
+      expect(feed.state.aggregatedActivities.length, 1);
+      expect(
+        feed.state.aggregatedActivities.first.activities.first.isWatched,
+        false,
+      );
+      expect(
+        feed.state.aggregatedActivities.first.activities[1].isWatched,
+        false,
+      );
+
+      feed.notifier.stream.listen(
+        expectAsync1(
+          (event) {
+            expect(event, isA<FeedState>());
+            expect(
+              event.aggregatedActivities.first.activities.first.isWatched,
+              true,
+            );
+            expect(
+              event.aggregatedActivities.first.activities[1].isWatched,
+              false,
+            );
+          },
+        ),
+      );
+
+      wsStreamController.add(
+        jsonEncode(
+          ActivityMarkEvent(
+            type: EventTypes.activityMarked,
+            createdAt: DateTime.now(),
+            custom: const {},
+            fid: feedId.toString(),
+            markWatched: [activity1.id],
+          ),
+        ),
+      );
+    });
+  });
 }

packages/stream_feeds/test/test_utils/event_types.dart

@@ -1,4 +1,6 @@
 class EventTypes {
+  static const String activityMarked = 'feeds.activity.marked';
+
   static const String followCreated = 'feeds.follow.created';
   static const String followDeleted = 'feeds.follow.deleted';
   static const String followUpdated = 'feeds.follow.updated';

packages/stream_feeds/test/test_utils/fakes.dart

@@ -102,14 +102,16 @@ PollResponseData createDefaultPollResponseData({
 GetOrCreateFeedResponse createDefaultGetOrCreateFeedResponse({
   int followerCount = 0,
   int followingCount = 0,
+  List<AggregatedActivityResponse> aggregatedActivities = const [],
+  List<ActivityResponse> activities = const [],
 }) =>
     GetOrCreateFeedResponse(
       feed: createDefaultFeedResponse(
         followerCount: followerCount,
         followingCount: followingCount,
       ),
-      activities: const [],
-      aggregatedActivities: const [],
+      activities: activities,
+      aggregatedActivities: aggregatedActivities,
       created: true,
       duration: '',
       followers: const [],
@@ -151,3 +153,20 @@ FeedResponse createDefaultFeedResponse({
       pinCount: 0,
       updatedAt: DateTime.now(),
     );
+
+AggregatedActivityResponse createDefaultAggregatedActivityResponse({
+  List<ActivityResponse>? activities,
+}) =>
+    AggregatedActivityResponse(
+      activities: activities ??
+          [
+            createDefaultActivityResponse().activity,
+          ],
+      activityCount: activities?.length ?? 1,
+      createdAt: DateTime(2021, 2, 1),
+      group: 'group',
+      score: 0,
+      updatedAt: DateTime(2021, 2, 1),
+      userCount: 1,
+      userCountTruncated: false,
+    );