Add activity data mapping test

Author: renefloor

packages/stream_feeds/lib/src/feeds_client.dart

@@ -17,11 +17,15 @@ class FeedsClient {
     TokenProvider? userTokenProvider,
     this.config = const FeedsConfig(),
     FeedsClientEnvironment environment = const FeedsClientEnvironment(),
-  }) {
+  }) : assert(
+          userToken != null || userTokenProvider != null,
+          'Provide either a user token or a user token provider, or both',
+        ) {
     tokenManager = userTokenProvider != null
         ? TokenManager.provider(
             user: user,
             provider: userTokenProvider,
+            token: userToken,
           )
         : TokenManager.static(user: user, token: userToken ?? '');
 

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

@@ -58,7 +58,7 @@ class ActivityData implements Identifiable {
     }
 
     return copyWith(
-      reactionCount: reactionGroups.totalCount,
+      reactionCount: newReactionGroups.totalCount,
       latestReactions: List.unmodifiable(newLatestReactions),
       ownReactions: List.unmodifiable(newOwnReactions),
       reactionGroups: Map.unmodifiable(newReactionGroups),
@@ -83,7 +83,7 @@ class ActivityData implements Identifiable {
     }
 
     return copyWith(
-      reactionCount: reactionGroups.totalCount,
+      reactionCount: newReactionGroups.totalCount,
       latestReactions: List.unmodifiable(newLatestReactions),
       ownReactions: List.unmodifiable(newOwnReactions),
       reactionGroups: Map.unmodifiable(newReactionGroups),

packages/stream_feeds/lib/src/state_layer/feed_ws_handler.dart

@@ -17,7 +17,7 @@ class FeedWsHandler {
   String get currentUserId => client.user.id;
 
   void _onEvent(FeedsWsEvent event) {
-    switch (event.event) {
+    switch (event.apiEvent) {
       case final WSClientEventActivityReactionAddedEvent wsEvent:
         stateNotifier.onReactionAdded(
           wsEvent.activityReactionAddedEvent.reaction.toModel(),

packages/stream_feeds/lib/src/ws/feeds_ws_event.dart

@@ -7,9 +7,9 @@ import 'package:stream_core/stream_core.dart' as core;
 import '../generated/api/api.dart' as api;
 
 class FeedsWsEvent extends core.WsEvent {
-  const FeedsWsEvent(this.event);
+  const FeedsWsEvent(this.apiEvent);
 
-  final api.WSClientEvent? event;
+  final api.WSClientEvent? apiEvent;
 
   static core.WsEvent fromEventObject(Object message) {
     try {

packages/stream_feeds/test/feeds_client_test.dart

@@ -186,7 +186,7 @@ void main() {
         expect(events, hasLength(1));
         expect(events[0], isA<FeedsWsEvent>());
         expect(
-          (events[0] as FeedsWsEvent).event,
+          (events[0] as FeedsWsEvent).apiEvent,
           isA<api.WSClientEventCommentAddedEvent>(),
         );
 

packages/stream_feeds/test/models/activity_data_test.dart

@@ -0,0 +1,93 @@
+import 'package:stream_feeds/stream_feeds.dart';
+import 'package:test/test.dart';
+
+void main() {
+  test(
+      'Add reaction to activityData should create a new instance with updated reaction count',
+      () {
+    final activityData = createActivityData();
+
+    final updatedActivityData = activityData.addReaction(
+      FeedsReactionData(
+        activityId: '1',
+        type: 'like',
+        user: const UserData(id: 'testUser'),
+        createdAt: DateTime.now(),
+        updatedAt: DateTime.now(),
+        customData: const {},
+      ),
+      currentUserId: 'testUser',
+    );
+
+    expect(updatedActivityData.reactionCount, 1);
+    expect(updatedActivityData, isNot(activityData));
+  });
+
+  test(
+      'Remove reaction from activityData should create a new instance with updated reaction count',
+      () {
+    final activityData = createActivityData(
+      reactionCount: 2,
+      latestReactions: [
+        FeedsReactionData(
+          activityId: '1',
+          type: 'like',
+          user: const UserData(id: 'testUser'),
+          createdAt: DateTime.now().subtract(const Duration(days: 1)),
+          updatedAt: DateTime.now(),
+          customData: const {},
+        ),
+        FeedsReactionData(
+          activityId: '1',
+          type: 'like',
+          user: const UserData(id: 'testUser2'),
+          createdAt: DateTime.now(),
+          updatedAt: DateTime.now(),
+          customData: const {},
+        ),
+      ],
+      reactionGroups: {
+        'like': ReactionGroupData(
+          count: 2,
+          firstReactionAt: DateTime.now().subtract(const Duration(days: 7)),
+          lastReactionAt: DateTime.now(),
+        ),
+      },
+    );
+
+    expect(activityData.reactionCount, 2);
+    final updatedActivityData = activityData.removeReaction(
+      FeedsReactionData(
+        activityId: '1',
+        type: 'like',
+        user: const UserData(id: 'testUser'),
+        createdAt: DateTime.now().subtract(const Duration(days: 1)),
+        updatedAt: DateTime.now(),
+        customData: const {},
+      ),
+      currentUserId: 'testUser',
+    );
+
+    expect(updatedActivityData.reactionCount, 1);
+    expect(updatedActivityData, isNot(activityData));
+  });
+}
+
+ActivityData createActivityData({
+  String? id,
+  UserData? user,
+  String? text,
+  int? reactionCount,
+  List<FeedsReactionData>? latestReactions,
+  List<FeedsReactionData>? ownReactions,
+  Map<String, ReactionGroupData>? reactionGroups,
+}) =>
+    ActivityData(
+      id: id ?? '1',
+      user: user ?? const UserData(id: 'testUser'),
+      text: text ?? 'test message',
+      reactionCount: reactionCount ?? 0,
+      latestReactions: latestReactions ?? [],
+      ownReactions: ownReactions ?? [],
+      reactionGroups: reactionGroups ?? {},
+    );