feat(llc): Filter realtime events based on query

Pass the `query` object to all `EventHandler` instances instead of individual properties like `fid`.

This allows event handlers to access the query's filter conditions. When a real-time "updated" event is received, the handler now checks if the updated item still matches the filter. If it no longer matches, the item is removed from the local state, ensuring the UI stays consistent with the query's criteria.

Author: xsahil03x

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

@@ -37,6 +37,7 @@ class ActivityList with Disposable {
 
     // Attach event handlers for real-time updates
     final handler = ActivityListEventHandler(
+      query: query,
       state: _stateNotifier,
       capabilitiesRepository: capabilitiesRepository,
     );

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

@@ -32,7 +32,10 @@ class BookmarkFolderList extends Disposable {
     );
 
     // Attach event handlers for real-time updates
-    final handler = BookmarkFolderListEventHandler(state: _stateNotifier);
+    final handler = BookmarkFolderListEventHandler(
+      query: query,
+      state: _stateNotifier,
+    );
 
     _eventsSubscription = eventsEmitter.listen(handler.handleEvent);
   }

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

@@ -32,7 +32,11 @@ class BookmarkList with Disposable {
     );
 
     // Attach event handlers for real-time updates
-    final handler = BookmarkListEventHandler(state: _stateNotifier);
+    final handler = BookmarkListEventHandler(
+      query: query,
+      state: _stateNotifier,
+    );
+
     _eventsSubscription = eventsEmitter.listen(handler.handleEvent);
   }
 

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

@@ -75,6 +75,15 @@ class BookmarkListStateNotifier extends StateNotifier<BookmarkListState> {
 
     state = state.copyWith(bookmarks: updatedBookmarks);
   }
+
+  /// Handles the removal of a bookmark by ID.
+  void onBookmarkRemoved(String bookmarkId) {
+    final updatedBookmarks = state.bookmarks.where((it) {
+      return it.id != bookmarkId;
+    }).toList();
+
+    state = state.copyWith(bookmarks: updatedBookmarks);
+  }
 }
 
 /// An observable state object that manages the current state of a bookmark list.

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

@@ -31,7 +31,11 @@ class CommentList extends Disposable {
     );
 
     // Attach event handlers for real-time updates
-    final handler = CommentListEventHandler(state: _stateNotifier);
+    final handler = CommentListEventHandler(
+      query: query,
+      state: _stateNotifier,
+    );
+
     _eventsSubscription = eventsEmitter.listen(handler.handleEvent);
   }
 

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

@@ -7,6 +7,7 @@ import '../../models/comment_data.dart';
 import '../../models/feeds_reaction_data.dart';
 import '../../repository/capabilities_repository.dart';
 import '../activity_list_state.dart';
+import '../query/activities_query.dart';
 import 'feed_capabilities_mixin.dart';
 import 'state_event_handler.dart';
 
@@ -18,24 +19,37 @@ class ActivityListEventHandler
     with FeedCapabilitiesMixin
     implements StateEventHandler {
   const ActivityListEventHandler({
+    required this.query,
     required this.state,
     required this.capabilitiesRepository,
   });
 
+  final ActivitiesQuery query;
   final ActivityListStateNotifier state;
+
   @override
   final CapabilitiesRepository capabilitiesRepository;
 
   @override
   Future<void> handleEvent(WsEvent event) async {
+    bool matchesQueryFilter(ActivityData activity) {
+      final filter = query.filter;
+      if (filter == null) return true;
+      return filter.matches(activity);
+    }
+
     if (event is api.ActivityUpdatedEvent) {
       final activity = event.activity.toModel();
+      if (!matchesQueryFilter(activity)) {
+        // If the updated activity no longer matches the filter, remove it
+        return state.onActivityRemoved(activity);
+      }
+
       state.onActivityUpdated(activity);
 
       final updatedActivity = await withUpdatedFeedCapabilities(activity);
-      if (updatedActivity != null) {
-        state.onActivityUpdated(updatedActivity);
-      }
+      if (updatedActivity != null) state.onActivityUpdated(updatedActivity);
+
       return;
     }
 
@@ -44,26 +58,57 @@ class ActivityListEventHandler
     }
 
     if (event is api.ActivityReactionAddedEvent) {
+      final activity = event.activity.toModel();
+      if (!matchesQueryFilter(activity)) {
+        // If the reaction's activity no longer matches the filter, remove it
+        return state.onActivityRemoved(activity);
+      }
+
       return state.onReactionAdded(event.reaction.toModel());
     }
 
     if (event is api.ActivityReactionDeletedEvent) {
+      final activity = event.activity.toModel();
+      if (!matchesQueryFilter(activity)) {
+        // If the reaction's activity no longer matches the filter, remove it
+        return state.onActivityRemoved(activity);
+      }
+
       return state.onReactionRemoved(event.reaction.toModel());
     }
 
     if (event is api.BookmarkAddedEvent) {
+      final activity = event.bookmark.activity.toModel();
+      if (!matchesQueryFilter(activity)) {
+        // If the bookmark's activity no longer matches the filter, remove it
+        return state.onActivityRemoved(activity);
+      }
+
       return state.onBookmarkAdded(event.bookmark.toModel());
     }
 
     if (event is api.BookmarkDeletedEvent) {
+      final activity = event.bookmark.activity.toModel();
+      if (!matchesQueryFilter(activity)) {
+        // If the bookmark's activity no longer matches the filter, remove it
+        return state.onActivityRemoved(activity);
+      }
+
       return state.onBookmarkRemoved(event.bookmark.toModel());
     }
 
     if (event is api.CommentAddedEvent) {
+      final activity = event.activity.toModel();
+      if (!matchesQueryFilter(activity)) {
+        // If the comment's activity no longer matches the filter, remove it
+        return state.onActivityRemoved(activity);
+      }
+
       return state.onCommentAdded(event.comment.toModel());
     }
 
     if (event is api.CommentDeletedEvent) {
+      // TODO: Match event activity against filter once available in the event
       return state.onCommentRemoved(event.comment.toModel());
     }
 

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

@@ -3,6 +3,7 @@ import 'package:stream_core/stream_core.dart';
 import '../../generated/api/models.dart' as api;
 import '../../models/bookmark_folder_data.dart';
 import '../bookmark_folder_list_state.dart';
+import '../query/bookmark_folders_query.dart';
 import 'state_event_handler.dart';
 
 /// Event handler for bookmark folder list real-time updates.
@@ -11,19 +12,33 @@ import 'state_event_handler.dart';
 /// and updates the bookmark folder list state accordingly.
 class BookmarkFolderListEventHandler implements StateEventHandler {
   const BookmarkFolderListEventHandler({
+    required this.query,
     required this.state,
   });
 
+  final BookmarkFoldersQuery query;
   final BookmarkFolderListStateNotifier state;
 
   @override
   void handleEvent(WsEvent event) {
+    bool matchesQueryFilter(BookmarkFolderData bookmarkFolder) {
+      final filter = query.filter;
+      if (filter == null) return true;
+      return filter.matches(bookmarkFolder);
+    }
+
     if (event is api.BookmarkFolderDeletedEvent) {
       return state.onBookmarkFolderRemoved(event.bookmarkFolder.id);
     }
 
     if (event is api.BookmarkFolderUpdatedEvent) {
-      return state.onBookmarkFolderUpdated(event.bookmarkFolder.toModel());
+      final bookmarkFolder = event.bookmarkFolder.toModel();
+      if (!matchesQueryFilter(bookmarkFolder)) {
+        // If the updated bookmark folder no longer matches the filter, remove it
+        return state.onBookmarkFolderRemoved(bookmarkFolder.id);
+      }
+
+      return state.onBookmarkFolderUpdated(bookmarkFolder);
     }
 
     // Handle other bookmark folder list events if needed

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

@@ -4,6 +4,7 @@ import '../../generated/api/models.dart' as api;
 import '../../models/bookmark_data.dart';
 import '../../models/bookmark_folder_data.dart';
 import '../bookmark_list_state.dart';
+import '../query/bookmarks_query.dart';
 import 'state_event_handler.dart';
 
 /// Event handler for bookmark list real-time updates.
@@ -12,13 +13,21 @@ import 'state_event_handler.dart';
 /// and updates the bookmark list state accordingly.
 class BookmarkListEventHandler implements StateEventHandler {
   const BookmarkListEventHandler({
+    required this.query,
     required this.state,
   });
 
+  final BookmarksQuery query;
   final BookmarkListStateNotifier state;
 
   @override
   void handleEvent(WsEvent event) {
+    bool matchesQueryFilter(BookmarkData bookmark) {
+      final filter = query.filter;
+      if (filter == null) return true;
+      return filter.matches(bookmark);
+    }
+
     if (event is api.BookmarkFolderDeletedEvent) {
       return state.onBookmarkFolderRemoved(event.bookmarkFolder.id);
     }
@@ -28,7 +37,13 @@ class BookmarkListEventHandler implements StateEventHandler {
     }
 
     if (event is api.BookmarkUpdatedEvent) {
-      return state.onBookmarkUpdated(event.bookmark.toModel());
+      final bookmark = event.bookmark.toModel();
+      if (!matchesQueryFilter(bookmark)) {
+        // If the updated bookmark no longer matches the filter, remove it
+        return state.onBookmarkRemoved(bookmark.id);
+      }
+
+      return state.onBookmarkUpdated(bookmark);
     }
 
     // Handle other bookmark list events if needed

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

@@ -4,22 +4,37 @@ import '../../generated/api/models.dart' as api;
 
 import '../../models/comment_data.dart';
 import '../comment_list_state.dart';
+import '../query/comments_query.dart';
 import 'state_event_handler.dart';
 
 /// Event handler for comment list real-time updates.
 ///
 /// Processes WebSocket events and updates the comment list state accordingly.
 class CommentListEventHandler implements StateEventHandler {
   const CommentListEventHandler({
+    required this.query,
     required this.state,
   });
 
+  final CommentsQuery query;
   final CommentListStateNotifier state;
 
   @override
   void handleEvent(WsEvent event) {
+    bool matchesQueryFilter(CommentData comment) {
+      final filter = query.filter;
+      if (filter == null) return true;
+      return filter.matches(comment);
+    }
+
     if (event is api.CommentUpdatedEvent) {
-      return state.onCommentUpdated(event.comment.toModel());
+      final comment = event.comment.toModel();
+      if (!matchesQueryFilter(comment)) {
+        // If the updated comment no longer matches the filter, remove it
+        return state.onCommentRemoved(comment.id);
+      }
+
+      return state.onCommentUpdated(comment);
     }
 
     if (event is api.CommentDeletedEvent) {