Aggregated Feed: Paginated Activities

packages/stream_feed/lib/src/client/aggregated_feed.dart

@@ -1,6 +1,7 @@
 import 'package:stream_feed/src/client/feed.dart';
 import 'package:stream_feed/src/core/api/feed_api.dart';
 import 'package:stream_feed/src/core/index.dart';
+import 'package:stream_feed/src/core/models/paginated_activities_group.dart';
 import 'package:stream_feed/src/core/util/default.dart';
 import 'package:stream_feed/src/core/util/token_helper.dart';
 
@@ -96,4 +97,25 @@ class AggregatedFeed extends Feed {
         .toList(growable: false);
     return data;
   }
+
+  Future<PaginatedActivitiesGroup<A, Ob, T, Or>>
+      getPaginatedActivities<A, Ob, T, Or>({
+    int? limit,
+    int? offset,
+    String? session,
+    Filter? filter,
+    ActivityMarker? marker,
+    EnrichmentFlags? flags,
+  }) async {
+    final options = {
+      'limit': limit ?? Default.limit,
+      'offset': offset ?? Default.offset,
+      ...filter?.params ?? Default.filter.params,
+      ...marker?.params ?? Default.marker.params,
+      ...flags?.params ?? Default.enrichmentFlags.params,
+    };
+    final token = userToken ??
+        TokenHelper.buildFeedToken(secret!, TokenAction.read, feedId);
+    return feed.paginatedActivitiesGroup(token, feedId, options);
+  }
 }

packages/stream_feed/lib/src/core/api/feed_api.dart

@@ -7,6 +7,7 @@ import 'package:stream_feed/src/core/models/feed_id.dart';
 import 'package:stream_feed/src/core/models/follow.dart';
 import 'package:stream_feed/src/core/models/follow_stats.dart';
 import 'package:stream_feed/src/core/models/paginated_activities.dart';
+import 'package:stream_feed/src/core/models/paginated_activities_group.dart';
 import 'package:stream_feed/src/core/models/personalized_feed.dart';
 import 'package:stream_feed/src/core/util/default.dart';
 import 'package:stream_feed/src/core/util/extension.dart';
@@ -105,6 +106,22 @@ class FeedAPI {
         response.data as Map<String, dynamic>);
   }
 
+  /// Retrieve paginated activities
+  Future<PaginatedActivitiesGroup<A, Ob, T, Or>>
+      paginatedActivitiesGroup<A, Ob, T, Or>(
+    Token token,
+    FeedId feed,
+    Map<String, Object?> options,
+  ) async {
+    final response = await _client.get<Map>(
+      Routes.buildEnrichedFeedUrl(feed),
+      headers: {'Authorization': '$token'},
+      queryParameters: options,
+    );
+    return PaginatedActivitiesGroup<A, Ob, T, Or>.fromJson(
+        response.data as Map<String, dynamic>);
+  }
+
   /// Retrieve the number of followers and following feed stats of the current
   /// feed.
   ///

packages/stream_feed/lib/src/core/models/paginated_activities.dart

@@ -19,7 +19,7 @@ class PaginatedActivities<A, Ob, T, Or>
     String? duration,
   }) : super(next, results, duration);
 
-  /// Deserialize json to [PaginatedReactions]
+  /// Deserialize json to [PaginatedActivities]
   factory PaginatedActivities.fromJson(
     Map<String, dynamic> json, [
     A Function(Object? json)? fromJsonA,

packages/stream_feed/lib/src/core/models/paginated_activities_group.dart

@@ -0,0 +1,70 @@
+import 'package:json_annotation/json_annotation.dart';
+import 'package:stream_feed/src/core/models/activity.dart';
+import 'package:stream_feed/src/core/models/collection_entry.dart';
+import 'package:stream_feed/src/core/models/enriched_activity.dart';
+import 'package:stream_feed/src/core/models/group.dart';
+import 'package:stream_feed/src/core/models/paginated.dart';
+import 'package:stream_feed/src/core/models/reaction.dart';
+import 'package:stream_feed/src/core/models/user.dart';
+
+part 'paginated_activities_group.g.dart';
+
+/// Paginated activities group feed
+@JsonSerializable(createToJson: true, genericArgumentFactories: true)
+class PaginatedActivitiesGroup<A, Ob, T, Or>
+    extends Paginated<Group<GenericEnrichedActivity<A, Ob, T, Or>>> {
+  /// Builds a [PaginatedActivitiesGroup].
+  const PaginatedActivitiesGroup({
+    String? next,
+    List<Group<GenericEnrichedActivity<A, Ob, T, Or>>>? results,
+    String? duration,
+  }) : super(next, results, duration);
+
+  /// Deserialize json to [PaginatedActivitiesGroup]
+  factory PaginatedActivitiesGroup.fromJson(
+    Map<String, dynamic> json, [
+    A Function(Object? json)? fromJsonA,
+    Ob Function(Object? json)? fromJsonOb,
+    T Function(Object? json)? fromJsonT,
+    Or Function(Object? json)? fromJsonOr,
+  ]) =>
+      _$PaginatedActivitiesGroupFromJson<A, Ob, T, Or>(
+        json,
+        fromJsonA ??
+            (jsonA) => (A == User)
+                ? User.fromJson(jsonA! as Map<String, dynamic>) as A
+                : jsonA as A,
+        fromJsonOb ??
+            (jsonOb) => (Ob == CollectionEntry)
+                ? CollectionEntry.fromJson(jsonOb! as Map<String, dynamic>)
+                    as Ob
+                : jsonOb as Ob,
+        fromJsonT ??
+            (jsonT) => (T == Activity)
+                ? Activity.fromJson(jsonT! as Map<String, dynamic>) as T
+                : jsonT as T,
+        fromJsonOr ??
+            (jsonOr) {
+              if (Or == User) {
+                return User.fromJson(jsonOr! as Map<String, dynamic>) as Or;
+              } else if (Or == Reaction) {
+                return Reaction.fromJson(jsonOr! as Map<String, dynamic>) as Or;
+              } else {
+                return jsonOr as Or;
+              }
+            },
+      );
+
+  @override
+  List<Object?> get props => [...super.props];
+
+  /// Serialize to json
+  Map<String, dynamic> toJson(
+    Object? Function(A value) toJsonA,
+    Object? Function(Ob value) toJsonOb,
+    Object? Function(T value) toJsonT,
+    Object? Function(Or value) toJsonOr,
+  ) =>
+      _$PaginatedActivitiesGroupToJson(
+          this, toJsonA, toJsonOb, toJsonT, toJsonOr);
+}