Add test for pagination

Author: renefloor

packages/stream_feeds/test/state/feed_test.dart

@@ -440,5 +440,78 @@ void main() {
         ),
       );
     });
+
+    test('Pagination should load more aggregated activities', () async {
+      const feedId = FeedId(group: 'stories', id: 'target');
+      const nextPagination = 'next';
+      const prevPagination = 'prev';
+
+      final activity1 = createDefaultActivityResponse()
+          .activity
+          .copyWith(id: 'storyActivityId1');
+
+      final activity2 = createDefaultActivityResponse()
+          .activity
+          .copyWith(id: 'storyActivityId2');
+
+      final activity3 = createDefaultActivityResponse()
+          .activity
+          .copyWith(id: 'storyActivityId3');
+
+      when(
+        () => feedsApi.getOrCreateFeed(
+          feedGroupId: feedId.group,
+          feedId: feedId.id,
+          getOrCreateFeedRequest: any(named: 'getOrCreateFeedRequest'),
+        ),
+      ).thenAnswer(
+        (invocation) async {
+          final request =
+              invocation.namedArguments[const Symbol('getOrCreateFeedRequest')]
+                  as GetOrCreateFeedRequest;
+
+          if (request.next == null) {
+            return Result.success(
+              createDefaultGetOrCreateFeedResponse(
+                nextPagination: nextPagination,
+                aggregatedActivities: [
+                  createDefaultAggregatedActivityResponse(
+                    group: 'group1',
+                    activities: [activity1, activity2],
+                  ),
+                ],
+              ),
+            );
+          }
+          if (request.next == nextPagination) {
+            return Result.success(
+              createDefaultGetOrCreateFeedResponse(
+                prevPagination: prevPagination,
+                aggregatedActivities: [
+                  createDefaultAggregatedActivityResponse(
+                    group: 'group2',
+                    activities: [activity3],
+                  ),
+                ],
+              ),
+            );
+          }
+          throw Exception('Unexpected request');
+        },
+      );
+
+      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, 2);
+
+      await feed.queryMoreActivities();
+
+      expect(feed.state.aggregatedActivities.length, 2);
+      expect(feed.state.aggregatedActivities.last.activities.length, 1);
+    });
   });
 }

packages/stream_feeds/test/test_utils/fakes.dart

@@ -104,6 +104,8 @@ GetOrCreateFeedResponse createDefaultGetOrCreateFeedResponse({
   int followingCount = 0,
   List<AggregatedActivityResponse> aggregatedActivities = const [],
   List<ActivityResponse> activities = const [],
+  String? prevPagination,
+  String? nextPagination,
 }) =>
     GetOrCreateFeedResponse(
       feed: createDefaultFeedResponse(
@@ -118,6 +120,8 @@ GetOrCreateFeedResponse createDefaultGetOrCreateFeedResponse({
       following: const [],
       members: const [],
       pinnedActivities: const [],
+      next: nextPagination,
+      prev: prevPagination,
     );
 
 FeedResponse createDefaultFeedResponse({
@@ -156,6 +160,7 @@ FeedResponse createDefaultFeedResponse({
 
 AggregatedActivityResponse createDefaultAggregatedActivityResponse({
   List<ActivityResponse>? activities,
+  String group = 'group',
 }) =>
     AggregatedActivityResponse(
       activities: activities ??
@@ -164,7 +169,7 @@ AggregatedActivityResponse createDefaultAggregatedActivityResponse({
           ],
       activityCount: activities?.length ?? 1,
       createdAt: DateTime(2021, 2, 1),
-      group: 'group',
+      group: group,
       score: 0,
       updatedAt: DateTime(2021, 2, 1),
       userCount: 1,