feat(llc): add onNewActivity callback to Feed (#65)

Author: xsahil03x

packages/stream_feeds/CHANGELOG.md

@@ -3,6 +3,9 @@
 - [BREAKING] Renamed `ActivitiesFilterField.type` to `ActivitiesFilterField.activityType`.
 - [BREAKING] Changed `ActivityData.location` field type from `ActivityLocation?` to `LocationCoordinate?`.
 - Add support for `enforceUnique` parameter while adding reactions.
+- [BREAKING] Changed default behavior for `ActivityAddedEvent` in feeds: activities from other users
+  are now ignored by default. Only activities from the current user matching the feed's filter are
+  added. Add `onNewActivity` callback to `feed`, `feedFromId`, or `feedFromQuery` to customize.
 - Add location filtering support for activities with `ActivitiesFilterField.near` and `ActivitiesFilterField.withinBounds` filter fields.
 - Add new activity filter fields: `ActivitiesFilterField.feed` and `ActivitiesFilterField.interestTags`.
 

packages/stream_feeds/lib/src/client/feeds_client_impl.dart

@@ -31,6 +31,7 @@ import '../state/bookmark_list.dart';
 import '../state/comment_list.dart';
 import '../state/comment_reaction_list.dart';
 import '../state/comment_reply_list.dart';
+import '../state/event/on_activity_added.dart';
 import '../state/feed.dart';
 import '../state/feed_list.dart';
 import '../state/follow_list.dart';
@@ -267,10 +268,14 @@ class StreamFeedsClientImpl implements StreamFeedsClient {
   }
 
   @override
-  Feed feedFromQuery(FeedQuery query) {
+  Feed feedFromQuery(
+    FeedQuery query, {
+    OnNewActivity onNewActivity = defaultOnNewActivity,
+  }) {
     return Feed(
       query: query,
       currentUserId: user.id,
+      onNewActivity: onNewActivity,
       activitiesRepository: _activitiesRepository,
       bookmarksRepository: _bookmarksRepository,
       commentsRepository: _commentsRepository,

packages/stream_feeds/lib/src/feeds_client.dart

@@ -18,6 +18,7 @@ import 'state/bookmark_list.dart';
 import 'state/comment_list.dart';
 import 'state/comment_reaction_list.dart';
 import 'state/comment_reply_list.dart';
+import 'state/event/on_activity_added.dart';
 import 'state/feed.dart';
 import 'state/feed_list.dart';
 import 'state/follow_list.dart';
@@ -223,6 +224,11 @@ abstract interface class StreamFeedsClient {
   /// Creates a [Feed] object using a [FeedQuery] that can include additional
   /// configuration such as activity filters, limits, and feed data for creation.
   ///
+  /// When [onNewActivity] is provided, it customizes how new activities received
+  /// via real-time events are inserted into the feed. When null, uses the default
+  /// behavior which adds activities created by the current user to the start of
+  /// the feed if they match the feed's filter.
+  ///
   /// Example:
   /// ```dart
   /// final feed = client.feedFromQuery(FeedQuery(
@@ -236,7 +242,10 @@ abstract interface class StreamFeedsClient {
   /// ```
   ///
   /// Returns a [Feed] instance that can be used to interact with the specified feed.
-  Feed feedFromQuery(FeedQuery query);
+  Feed feedFromQuery(
+    FeedQuery query, {
+    OnNewActivity onNewActivity,
+  });
 
   /// Creates a feed list instance based on the provided [query].
   ///
@@ -764,6 +773,11 @@ extension StreamFeedsClientHelpers on StreamFeedsClient {
   /// Creates a [Feed] object that represents a specific feed.
   /// The feed can be used to fetch activities, manage follows, and receive real-time updates.
   ///
+  /// When [onNewActivity] is provided, it customizes how new activities received
+  /// via real-time events are inserted into the feed. Defaults to [defaultOnNewActivity],
+  /// which adds activities created by the current user to the start of the feed
+  /// if they match the feed's filter.
+  ///
   /// Example:
   /// ```dart
   /// final userFeed = client.feed('user', 'john');
@@ -783,16 +797,25 @@ extension StreamFeedsClientHelpers on StreamFeedsClient {
   /// ```
   ///
   /// Returns a [Feed] instance that can be used to interact with the specified feed.
-  Feed feed({required String group, required String id}) {
+  Feed feed({
+    required String group,
+    required String id,
+    OnNewActivity onNewActivity = defaultOnNewActivity,
+  }) {
     final fid = FeedId(group: group, id: id);
-    return feedFromId(fid);
+    return feedFromId(fid, onNewActivity: onNewActivity);
   }
 
   /// Creates a feed instance for the specified [fid].
   ///
   /// Creates a [Feed] object that represents a specific feed.
   /// The feed can be used to fetch activities, manage follows, and receive real-time updates.
   ///
+  /// When [onNewActivity] is provided, it customizes how new activities received
+  /// via real-time events are inserted into the feed. Defaults to [defaultOnNewActivity],
+  /// which adds activities created by the current user to the start of the feed
+  /// if they match the feed's filter.
+  ///
   /// Example:
   /// ```dart
   /// final feedId = FeedId(group: 'user', id: 'john');
@@ -802,8 +825,11 @@ extension StreamFeedsClientHelpers on StreamFeedsClient {
   /// ```
   ///
   /// Returns a [Feed] instance that can be used to interact with the specified feed.
-  Feed feedFromId(FeedId fid) {
+  Feed feedFromId(
+    FeedId fid, {
+    OnNewActivity onNewActivity = defaultOnNewActivity,
+  }) {
     final query = FeedQuery(fid: fid);
-    return feedFromQuery(query);
+    return feedFromQuery(query, onNewActivity: onNewActivity);
   }
 }

packages/stream_feeds/lib/src/state.dart

@@ -20,6 +20,7 @@ export 'state/feed_list_state.dart';
 export 'state/feed_state.dart';
 export 'state/follow_list.dart';
 export 'state/follow_list_state.dart';
+export 'state/insertion_action.dart';
 export 'state/poll_list.dart';
 export 'state/poll_list_state.dart';
 export 'state/poll_vote_list.dart';

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

@@ -20,7 +20,7 @@ import '../repository/comments_repository.dart';
 import '../repository/polls_repository.dart';
 import 'activity_comment_list.dart';
 import 'activity_state.dart';
-import 'event/activity_event_handler.dart';
+import 'event/handler/activity_event_handler.dart';
 import 'query/activity_comments_query.dart';
 import 'state_notifier_extentions.dart';
 

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

@@ -7,7 +7,7 @@ import 'package:stream_core/stream_core.dart';
 import '../models/comment_data.dart';
 import '../repository/comments_repository.dart';
 import 'activity_comment_list_state.dart';
-import 'event/activity_comment_list_event_handler.dart';
+import 'event/handler/activity_comment_list_event_handler.dart';
 import 'query/activity_comments_query.dart';
 import 'state_notifier_extentions.dart';
 

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

@@ -9,7 +9,7 @@ import '../models/query_configuration.dart';
 import '../repository/activities_repository.dart';
 import '../repository/capabilities_repository.dart';
 import 'activity_list_state.dart';
-import 'event/activity_list_event_handler.dart';
+import 'event/handler/activity_list_event_handler.dart';
 import 'query/activities_query.dart';
 import 'state_notifier_extentions.dart';
 

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

@@ -8,7 +8,7 @@ import '../models/feeds_reaction_data.dart';
 import '../models/query_configuration.dart';
 import '../repository/activities_repository.dart';
 import 'activity_reaction_list_state.dart';
-import 'event/activity_reaction_list_event_handler.dart';
+import 'event/handler/activity_reaction_list_event_handler.dart';
 import 'query/activity_reactions_query.dart';
 import 'state_notifier_extentions.dart';
 

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

@@ -8,7 +8,7 @@ import '../models/bookmark_folder_data.dart';
 import '../models/query_configuration.dart';
 import '../repository/bookmarks_repository.dart';
 import 'bookmark_folder_list_state.dart';
-import 'event/bookmark_folder_list_event_handler.dart';
+import 'event/handler/bookmark_folder_list_event_handler.dart';
 import 'query/bookmark_folders_query.dart';
 import 'state_notifier_extentions.dart';
 

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

@@ -8,7 +8,7 @@ import '../models/bookmark_data.dart';
 import '../models/query_configuration.dart';
 import '../repository/bookmarks_repository.dart';
 import 'bookmark_list_state.dart';
-import 'event/bookmark_list_event_handler.dart';
+import 'event/handler/bookmark_list_event_handler.dart';
 import 'query/bookmarks_query.dart';
 import 'state_notifier_extentions.dart';