feat(llc, samples): basic stories implementation (#50)

Author: renefloor

packages/stream_feeds/CHANGELOG.md

@@ -1,6 +1,7 @@
 ## unreleased
 - Update follower and following counts on the feed state when receiving follow websocket events.
 - Fix FeedsReactionData id for updating reactions in the feed state.
+- 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/lib/src/models/activity_data.dart

@@ -38,6 +38,7 @@ class ActivityData with _$ActivityData {
     this.filterTags = const [],
     required this.id,
     this.interestTags = const [],
+    this.isWatched,
     this.latestReactions = const [],
     this.location,
     this.mentionedUsers = const [],
@@ -114,6 +115,10 @@ class ActivityData with _$ActivityData {
   @override
   final List<String> interestTags;
 
+  /// Whether the activity was watched by the current user. Relevant for stories.
+  @override
+  final bool? isWatched;
+
   /// The most recent reactions added to the activity.
   @override
   final List<FeedsReactionData> latestReactions;
@@ -254,6 +259,7 @@ extension ActivityResponseMapper on ActivityResponse {
       filterTags: filterTags,
       id: id,
       interestTags: interestTags,
+      isWatched: isWatched,
       latestReactions: [...latestReactions.map((r) => r.toModel())],
       location: location,
       mentionedUsers: [...mentionedUsers.map((u) => u.toModel())],

packages/stream_feeds/lib/src/models/activity_data.freezed.dart

@@ -204,6 +204,14 @@ class FeedEventHandler with FeedCapabilitiesMixin implements StateEventHandler {
     if (event is api.FeedMemberRemovedEvent) return;
     if (event is api.FeedMemberUpdatedEvent) return;
 
+    if (event is api.StoriesFeedUpdatedEvent) {
+      if (event.fid != fid.rawValue) return;
+
+      return state.onAggregatedActivitiesUpdated(
+        event.aggregatedActivities?.map((it) => it.toModel()).toList(),
+      );
+    }
+
     // Handle other events if necessary
   }
 }

packages/stream_feeds/lib/src/state/event/feed_event_handler.dart

@@ -451,6 +451,7 @@ class Feed with Disposable {
       (feedData) {
         _stateNotifier.onQueryMoreActivities(
           feedData.activities,
+          feedData.aggregatedActivities,
           feedData.activitiesQueryConfig,
         );
 

packages/stream_feeds/lib/src/state/feed.dart

@@ -83,21 +83,27 @@ class FeedStateNotifier extends StateNotifier<FeedState> {
 
   /// Handles the result of a query for more activities.
   void onQueryMoreActivities(
-    PaginationResult<ActivityData> result,
+    PaginationResult<ActivityData> activities,
+    List<AggregatedActivityData> aggregatedActivities,
     QueryConfiguration<ActivityData> queryConfig,
   ) {
     _activitiesQueryConfig = queryConfig;
 
     // Merge the new activities with the existing ones
     final updatedActivities = state.activities.merge(
-      result.items,
+      activities.items,
       key: (it) => it.id,
       compare: activitiesSort.compare,
     );
+    final updatedAggregatedActivities = state.aggregatedActivities.merge(
+      aggregatedActivities,
+      key: (it) => it.group,
+    );
 
     state = state.copyWith(
       activities: updatedActivities,
-      activitiesPagination: result.pagination,
+      aggregatedActivities: updatedAggregatedActivities,
+      activitiesPagination: activities.pagination,
     );
   }
 
@@ -188,6 +194,8 @@ class FeedStateNotifier extends StateNotifier<FeedState> {
       markRead: (read) => _markRead(read, state),
       // If markSeen contains specific IDs, mark those as seen
       markSeen: (seen) => _markSeen(seen, state),
+      // If markWatched contains specific IDs, mark those as watched
+      markWatched: (watched) => _markWatched(watched, state),
       // For other cases, return the current state without changes
       orElse: (MarkActivityData data) => state,
     );
@@ -199,14 +207,27 @@ class FeedStateNotifier extends StateNotifier<FeedState> {
     NotificationStatusResponse? notificationStatus,
   ) {
     // Update the aggregated activities and notification status in the state
-    final updatedAggregatedActivities = [...?aggregatedActivities];
+    final updatedAggregatedActivities = state.aggregatedActivities.merge(
+      aggregatedActivities ?? [],
+      key: (it) => it.group,
+    );
 
     state = state.copyWith(
       aggregatedActivities: updatedAggregatedActivities,
       notificationStatus: notificationStatus,
     );
   }
 
+  void onAggregatedActivitiesUpdated(
+    List<AggregatedActivityData>? aggregatedActivities,
+  ) {
+    final updatedAggregatedActivities = state.aggregatedActivities.merge(
+      aggregatedActivities ?? [],
+      key: (it) => it.group,
+    );
+    state = state.copyWith(aggregatedActivities: updatedAggregatedActivities);
+  }
+
   /// Handles updates to the feed state when a bookmark is added or removed.
   void onBookmarkAdded(BookmarkData bookmark) {
     // Add or update the bookmark in the activity
@@ -477,6 +498,37 @@ class FeedStateNotifier extends StateNotifier<FeedState> {
     return state.copyWith(notificationStatus: updatedNotificationStatus);
   }
 
+  FeedState _markWatched(Set<String> watchedIds, FeedState state) {
+    final activities = _markWatchedActivities(watchedIds, state.activities);
+
+    final aggregatedActivities =
+        state.aggregatedActivities.map((aggregatedActivity) {
+      return aggregatedActivity.copyWith(
+        activities: _markWatchedActivities(
+          watchedIds,
+          aggregatedActivity.activities,
+        ),
+      );
+    }).toList();
+
+    return state.copyWith(
+      activities: activities,
+      aggregatedActivities: aggregatedActivities,
+    );
+  }
+
+  List<ActivityData> _markWatchedActivities(
+    Set<String> watchedIds,
+    List<ActivityData> activities,
+  ) {
+    return activities.map((activity) {
+      if (watchedIds.contains(activity.id)) {
+        return activity.copyWith(isWatched: true);
+      }
+      return activity;
+    }).toList();
+  }
+
   @override
   void dispose() {
     _removeMemberListListener?.call();
@@ -549,7 +601,7 @@ class FeedState with _$FeedState {
   @override
   final NotificationStatusResponse? notificationStatus;
 
-  /// Pagination information for activities queries.
+  /// Pagination information for [activities] and [aggregatedActivities] queries.
   @override
   final PaginationData? activitiesPagination;