Add StoriesFeedUpdatedEvent test

Author: renefloor

packages/stream_feeds/CHANGELOG.md

@@ -1,5 +1,6 @@
 ## unreleased
 - Update follower and following counts on the feed state when receiving follow websocket events.
+- Improvement for stories and minor updates to other AggregatedActivity state updates.
 
 ## 0.3.1
 - Update API client with renaming `addReaction` to `addActivityReaction` and `deleteReaction` to `deleteActivityReaction`.

packages/stream_feeds/test/state/feed_test.dart

@@ -513,5 +513,72 @@ void main() {
       expect(feed.state.aggregatedActivities.length, 2);
       expect(feed.state.aggregatedActivities.last.activities.length, 1);
     });
+
+    test('StoriesFeedUpdatedEvent should update aggregated activities',
+        () async {
+      const feedId = FeedId(group: 'stories', id: 'target');
+
+      final activity1 = createDefaultActivityResponse()
+          .activity
+          .copyWith(id: 'storyActivityId1');
+
+      final activity2 = createDefaultActivityResponse()
+          .activity
+          .copyWith(id: 'storyActivityId2');
+
+      when(
+        () => feedsApi.getOrCreateFeed(
+          feedGroupId: feedId.group,
+          feedId: feedId.id,
+          getOrCreateFeedRequest: any(named: 'getOrCreateFeedRequest'),
+        ),
+      ).thenAnswer(
+        (_) async => Result.success(
+          createDefaultGetOrCreateFeedResponse(
+            aggregatedActivities: [
+              createDefaultAggregatedActivityResponse(
+                group: 'group1',
+                activities: [activity1],
+              ),
+            ],
+          ),
+        ),
+      );
+
+      final feed = client.feedFromId(feedId);
+
+      final result = await feed.getOrCreate();
+      result.getOrThrow();
+      expect(feed.state.aggregatedActivities.length, 1);
+      expect(feed.state.aggregatedActivities.first.activities.length, 1);
+
+      feed.notifier.stream.listen(
+        expectAsync1(
+          (event) {
+            expect(event, isA<FeedState>());
+
+            expect(event.aggregatedActivities.length, 1);
+            expect(event.aggregatedActivities.first.activities.length, 2);
+          },
+        ),
+      );
+
+      wsStreamController.add(
+        jsonEncode(
+          StoriesFeedUpdatedEvent(
+            type: EventTypes.storiesFeedUpdated,
+            createdAt: DateTime.now(),
+            custom: const {},
+            fid: feedId.toString(),
+            aggregatedActivities: [
+              createDefaultAggregatedActivityResponse(
+                group: 'group1',
+                activities: [activity1, activity2],
+              ),
+            ],
+          ),
+        ),
+      );
+    });
   });
 }

packages/stream_feeds/test/test_utils/event_types.dart

@@ -9,4 +9,6 @@ class EventTypes {
   static const String pollDeleted = 'feeds.poll.deleted';
   static const String pollVoteCasted = 'feeds.poll.vote_casted';
   static const String pollVoteRemoved = 'feeds.poll.vote_removed';
+
+  static const String storiesFeedUpdated = 'feeds.stories_feed.updated';
 }