feat(llc): add activity feedback support

This commit introduces the ability to submit feedback for activities, such as marking an activity as hidden. It adds an `activityFeedback` method to the `Activity` and `Feed` classes and handles real-time state updates via WebSocket events.

Key changes:
- **API**: Added `activityFeedback` method to `ActivitiesRepository`, `Activity`, and `Feed` to allow submitting feedback (e.g., hide/unhide).
- **State Management**: Implemented `onActivityHidden` handlers in `ActivityState`, `ActivityListState`, and `FeedState` to update the `hidden` status of activities in response to `ActivityFeedbackEvent` from WebSockets.
- **Event Handling**: `ActivityEventHandler`, `ActivityListEventHandler`, and `FeedEventHandler` now process `ActivityFeedbackEvent` to trigger state updates, ensuring the UI reflects whether an activity is hidden.
- **Testing**:
    - Introduced a new suite of test utilities (`BaseTester`, `ActivityTester`, `FeedTester`, `ActivityListTester`, `ApiMockerMixin`) to streamline testing of stateful objects with API and WebSocket interactions.
    - Added comprehensive tests for the new activity feedback functionality, covering both API calls and real-time event handling.
- **Refactor**: Minor refactoring in test helpers (`fakes.dart`) to improve consistency.

Author: xsahil03x

packages/stream_feeds/CHANGELOG.md

@@ -1,6 +1,7 @@
 ## unreleased
 - [BREAKING] Change `queryFollowSuggestions` return type to `List<FeedSuggestionData>`.
 - [BREAKING] Remove `activitySelectorOptions` from `FeedQuery`.
+- Add `activityFeedback` method to `Feed` and `Activity` for submitting activity feedback.
 - Add `hidden` and `preview` fields to `ActivityData`.
 - Update follower and following counts on the feed state when receiving follow websocket events.
 - Fix FeedsReactionData id for updating reactions in the feed state.

packages/stream_feeds/dart_test.yaml

@@ -0,0 +1,4 @@
+tags:
+  feed:
+  activity:
+  activity-list:

packages/stream_feeds/lib/src/repository/activities_repository.dart

@@ -248,4 +248,20 @@ class ActivitiesRepository {
       return PaginationResult(items: reactions, pagination: pagination);
     });
   }
+
+  /// Submits activity feedback.
+  ///
+  /// Submits feedback for the activity with the specified [activityId] using
+  /// the provided [request].
+  ///
+  /// Returns a [Result] containing void or an error.
+  Future<Result<void>> activityFeedback(
+    String activityId,
+    api.ActivityFeedbackRequest request,
+  ) {
+    return _api.activityFeedback(
+      activityId: activityId,
+      activityFeedbackRequest: request,
+    );
+  }
 }

packages/stream_feeds/lib/src/state.dart

@@ -1,5 +1,6 @@
 export 'state/activity.dart';
 export 'state/activity_comment_list.dart';
+export 'state/activity_list.dart';
 export 'state/comment_list.dart';
 export 'state/comment_reaction_list.dart';
 export 'state/comment_reply_list.dart';

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

@@ -68,7 +68,13 @@ class Activity with Disposable {
     );
 
     // Attach event handlers for real-time updates
-    final handler = ActivityEventHandler(fid: fid, state: _stateNotifier);
+    final handler = ActivityEventHandler(
+      fid: fid,
+      state: _stateNotifier,
+      activityId: activityId,
+      currentUserId: currentUserId,
+    );
+
     _eventsSubscription = eventsEmitter.listen(handler.handleEvent);
   }
 
@@ -117,6 +123,20 @@ class Activity with Disposable {
     return result;
   }
 
+  /// Submits feedback for this activity.
+  ///
+  /// Submits feedback for this activity using the provided [request].
+  ///
+  /// Returns a [Result] indicating success or failure of the operation.
+  Future<Result<void>> activityFeedback({
+    required api.ActivityFeedbackRequest activityFeedbackRequest,
+  }) {
+    return activitiesRepository.activityFeedback(
+      activityId,
+      activityFeedbackRequest,
+    );
+  }
+
   /// Queries the comments for this activity.
   ///
   /// Returns a [Result] containing a list of [ThreadedCommentData] or an error.

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

@@ -39,8 +39,10 @@ class ActivityList with Disposable {
     final handler = ActivityListEventHandler(
       query: query,
       state: _stateNotifier,
+      currentUserId: currentUserId,
       capabilitiesRepository: capabilitiesRepository,
     );
+
     _eventsSubscription = eventsEmitter.listen(handler.handleEvent);
   }
 

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

@@ -69,6 +69,20 @@ class ActivityListStateNotifier extends StateNotifier<ActivityListState> {
     state = state.copyWith(activities: updatedActivities);
   }
 
+  /// Handles updates to the activity list state when an activity is hidden.
+  void onActivityHidden({
+    required String activityId,
+    required bool hidden,
+  }) {
+    final updatedActivities = state.activities.map((activity) {
+      if (activity.id != activityId) return activity;
+      // Update the hidden status of the activity
+      return activity.copyWith(hidden: hidden);
+    }).toList();
+
+    state = state.copyWith(activities: updatedActivities);
+  }
+
   /// Handles the addition of a bookmark.
   void onBookmarkAdded(BookmarkData bookmark) {
     final updatedActivities = state.activities.map((activity) {

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

@@ -47,6 +47,16 @@ class ActivityStateNotifier extends StateNotifier<ActivityState> {
     );
   }
 
+  /// Handles updates to the activity's hidden status.
+  void onActivityHidden({
+    required bool hidden,
+  }) {
+    final currentActivity = state.activity;
+    final updatedActivity = currentActivity?.copyWith(hidden: hidden);
+
+    state = state.copyWith(activity: updatedActivity);
+  }
+
   /// Handles when a poll is closed.
   void onPollClosed(PollData poll) {
     if (state.poll?.id != poll.id) return;

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

@@ -17,10 +17,14 @@ class ActivityEventHandler implements StateEventHandler {
   const ActivityEventHandler({
     required this.fid,
     required this.state,
+    required this.activityId,
+    required this.currentUserId,
   });
 
   final FeedId fid;
   final ActivityStateNotifier state;
+  final String activityId;
+  final String currentUserId;
 
   @override
   void handleEvent(WsEvent event) {
@@ -68,6 +72,21 @@ class ActivityEventHandler implements StateEventHandler {
       return state.onPollVoteRemoved(vote, poll);
     }
 
+    if (event is api.ActivityFeedbackEvent) {
+      final payload = event.activityFeedback;
+
+      // Only process events for this activity and current user
+      if (payload.activityId != activityId) return;
+      if (payload.user.id != currentUserId) return;
+
+      // Only handle hide action for now
+      if (payload.action == api.ActivityFeedbackEventPayloadAction.hide) {
+        return state.onActivityHidden(
+          hidden: payload.value == 'true',
+        );
+      }
+    }
+
     // Handle other activity events here as needed
   }
 }

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

@@ -21,11 +21,13 @@ class ActivityListEventHandler
   const ActivityListEventHandler({
     required this.query,
     required this.state,
+    required this.currentUserId,
     required this.capabilitiesRepository,
   });
 
   final ActivitiesQuery query;
   final ActivityListStateNotifier state;
+  final String currentUserId;
 
   @override
   final CapabilitiesRepository capabilitiesRepository;
@@ -112,6 +114,21 @@ class ActivityListEventHandler
       return state.onCommentRemoved(event.comment.toModel());
     }
 
+    if (event is api.ActivityFeedbackEvent) {
+      final payload = event.activityFeedback;
+
+      // Only process events for the current user
+      if (payload.user.id != currentUserId) return;
+
+      // Only handle hide action for now
+      if (payload.action == api.ActivityFeedbackEventPayloadAction.hide) {
+        return state.onActivityHidden(
+          activityId: payload.activityId,
+          hidden: payload.value == 'true',
+        );
+      }
+    }
+
     // Handle other activity list events here as needed
   }
 }