Add test for comment reactions

Author: renefloor

packages/stream_feeds/test/state/comment_list_test.dart

@@ -1,3 +1,5 @@
+// ignore_for_file: avoid_redundant_argument_values
+
 import 'dart:async';
 import 'dart:convert';
 
@@ -59,7 +61,17 @@ void main() {
             comments: [
               createDefaultCommentResponse(id: 'comment-1', objectId: 'obj-1'),
               createDefaultCommentResponse(id: 'comment-2', objectId: 'obj-1'),
-              createDefaultCommentResponse(id: 'comment-3', objectId: 'obj-1'),
+              createDefaultCommentResponse(
+                id: 'comment-3',
+                objectId: 'obj-1',
+                reactionGroups: {
+                  'like': ReactionGroupResponse(
+                    count: 1,
+                    firstReactionAt: DateTime(2025, 1, 1),
+                    lastReactionAt: DateTime(2025, 1, 1),
+                  ),
+                },
+              ),
             ],
           ),
         ),
@@ -136,5 +148,90 @@ void main() {
         expect(commentList.state.comments, hasLength(3));
       },
     );
+
+    test('comment reaction added', () async {
+      final commentList = client.commentList(
+        CommentsQuery(
+          filter: Filter.equal(CommentsFilterField.status, 'active'),
+        ),
+      );
+      await commentList.get();
+      expect(commentList.state.comments, hasLength(3));
+      expect(commentList.state.comments[1].reactionCount, 0);
+      expect(commentList.state.comments[1].reactionGroups.length, 0);
+
+      wsStreamController.add(
+        jsonEncode(
+          CommentReactionAddedEvent(
+            type: EventTypes.commentReactionAdded,
+            activity: createDefaultActivityResponse().activity,
+            comment: createDefaultCommentResponse(
+              id: 'comment-2',
+              objectId: 'obj-1',
+            ),
+            createdAt: DateTime.now(),
+            custom: const {},
+            fid: 'user:id',
+            reaction: FeedsReactionResponse(
+              activityId: 'obj-1',
+              commentId: 'comment-2',
+              type: 'like',
+              createdAt: DateTime.now(),
+              updatedAt: DateTime.now(),
+              user: createDefaultUserResponse(),
+            ),
+          ),
+        ),
+      );
+
+      await Future<Object?>.delayed(Duration.zero);
+
+      expect(commentList.state.comments, hasLength(3));
+      expect(commentList.state.comments[1].reactionCount, 1);
+      expect(commentList.state.comments[1].reactionGroups.length, 1);
+      expect(commentList.state.comments[1].reactionGroups['like']?.count, 1);
+    });
+
+    test('comment reaction deleted', () async {
+      final commentList = client.commentList(
+        CommentsQuery(
+          filter: Filter.equal(CommentsFilterField.status, 'active'),
+        ),
+      );
+      await commentList.get();
+      expect(commentList.state.comments, hasLength(3));
+      expect(commentList.state.comments[2].reactionCount, 1);
+      expect(commentList.state.comments[2].reactionGroups.length, 1);
+      expect(commentList.state.comments[2].reactionGroups['like']?.count, 1);
+
+      wsStreamController.add(
+        jsonEncode(
+          CommentReactionDeletedEvent(
+            type: EventTypes.commentReactionDeleted,
+            createdAt: DateTime.now(),
+            custom: const {},
+            fid: 'user:id',
+            comment: createDefaultCommentResponse(
+              id: 'comment-3',
+              objectId: 'obj-1',
+            ),
+            reaction: FeedsReactionResponse(
+              activityId: 'obj-1',
+              commentId: 'comment-3',
+              type: 'like',
+              createdAt: DateTime(2025, 1, 1),
+              updatedAt: DateTime.now(),
+              user: createDefaultUserResponse(),
+            ),
+          ),
+        ),
+      );
+
+      await Future<Object?>.delayed(Duration.zero);
+
+      expect(commentList.state.comments, hasLength(3));
+      expect(commentList.state.comments[2].reactionCount, 0);
+      expect(commentList.state.comments[2].reactionGroups.length, 0);
+    });
   });
 }

packages/stream_feeds/test/test_utils/fakes.dart

@@ -165,6 +165,7 @@ CommentResponse createDefaultCommentResponse({
   required String objectId,
   String objectType = 'activity',
   String? text,
+  Map<String, ReactionGroupResponse> reactionGroups = const {},
 }) {
   return CommentResponse(
     id: id,
@@ -176,7 +177,8 @@ CommentResponse createDefaultCommentResponse({
     objectId: objectId,
     objectType: objectType,
     ownReactions: const [],
-    reactionCount: 0,
+    reactionCount: reactionGroups.values.fold(0, (v, e) => v + e.count),
+    reactionGroups: reactionGroups,
     replyCount: 0,
     score: 0,
     status: 'status',