Add basic unit tests for activity

Author: renefloor

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

@@ -65,6 +65,8 @@ class StreamFeedsClientImpl implements StreamFeedsClient {
     NetworkStateProvider? networkStateProvider,
     AppLifecycleStateProvider? appLifecycleStateProvider,
     List<AutomaticReconnectionPolicy>? reconnectionPolicies,
+    WebSocketProvider? wsProvider,
+    api.DefaultApi? feedsRestApi,
   }) {
     // TODO: Make this configurable
     const endpointConfig = EndpointConfig.production;
@@ -105,6 +107,7 @@ class StreamFeedsClientImpl implements StreamFeedsClient {
         event_resolvers.pollAnswerCastedFeedEventResolver,
         event_resolvers.pollAnswerRemovedFeedEventResolver,
       ],
+      wsProvider: wsProvider,
     );
 
     _connectionRecoveryHandler = ConnectionRecoveryHandler(
@@ -152,7 +155,7 @@ class StreamFeedsClientImpl implements StreamFeedsClient {
     _cdnClient = config.cdnClient ?? FeedsCdnClient(CdnApi(httpClient));
     attachmentUploader = StreamAttachmentUploader(cdn: _cdnClient);
 
-    final feedsApi = api.DefaultApi(httpClient);
+    final feedsApi = feedsRestApi ?? api.DefaultApi(httpClient);
 
     _activitiesRepository = ActivitiesRepository(feedsApi, attachmentUploader);
     _appRepository = AppRepository(feedsApi);

packages/stream_feeds/pubspec.yaml

@@ -41,4 +41,5 @@ dev_dependencies:
   json_serializable: ^6.9.5
   mocktail: ^1.0.4
   retrofit_generator: ^9.6.0
-  test: ^1.26.3
+  test: ^1.26.3
+  web_socket_channel: ^3.0.3

packages/stream_feeds/test/client/feeds_client_impl_test.dart

@@ -2,8 +2,8 @@ import 'package:stream_feeds/src/client/feeds_client_impl.dart';
 import 'package:stream_feeds/stream_feeds.dart';
 import 'package:test/test.dart';
 
-const testToken =
-    'eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1c2VyX2lkIjoibHVrZV9za3l3YWxrZXIifQ.hZ59SWtp_zLKVV9ShkqkTsCGi_jdPHly7XNCf5T_Ev0';
+import '../mocks.dart';
+
 void main() {
   test('Create a feeds client', () {
     final client = StreamFeedsClient(

packages/stream_feeds/test/mocks.dart

@@ -1,14 +1,21 @@
 import 'package:mocktail/mocktail.dart';
+import 'package:stream_core/stream_core.dart';
 import 'package:stream_feeds/src/client/feeds_client_impl.dart';
 import 'package:stream_feeds/src/repository/feeds_repository.dart';
 import 'package:stream_feeds/stream_feeds.dart';
+import 'package:stream_feeds/stream_feeds.dart' as api;
+import 'package:web_socket_channel/web_socket_channel.dart';
 
 class MockFeedsRepository extends Mock implements FeedsRepository {}
 
 class MockFeedsClient extends Mock implements StreamFeedsClient {}
 
 class MockWebSocketClient extends Mock implements StreamWebSocketClient {}
 
+class MockDefaultApi extends Mock implements api.DefaultApi {}
+
+class MockWebSocketChannel extends Mock implements WebSocketChannel {}
+
 class FakeFeedsClient extends Fake implements StreamFeedsClientImpl {
   FakeFeedsClient({
     User? user,
@@ -25,3 +32,6 @@ const fakeUser = User(
   id: 'user_id',
   name: 'user_name',
 );
+
+const testToken =
+    'eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1c2VyX2lkIjoibHVrZV9za3l3YWxrZXIifQ.hZ59SWtp_zLKVV9ShkqkTsCGi_jdPHly7XNCf5T_Ev0';

packages/stream_feeds/test/state/activity_test.dart

@@ -0,0 +1,120 @@
+// ignore_for_file: avoid_redundant_argument_values
+
+import 'package:mocktail/mocktail.dart';
+import 'package:stream_feeds/src/client/feeds_client_impl.dart';
+import 'package:stream_feeds/stream_feeds.dart';
+import 'package:test/test.dart';
+
+import '../mocks.dart';
+
+void main() {
+  late StreamFeedsClientImpl client;
+  late MockDefaultApi feedsApi;
+  late MockWebSocketChannel webSocketChannel;
+
+  setUp(() {
+    feedsApi = MockDefaultApi();
+    webSocketChannel = MockWebSocketChannel();
+
+    client = StreamFeedsClientImpl(
+      apiKey: 'apiKey',
+      user: const User(id: 'userId'),
+      tokenProvider: TokenProvider.static(UserToken(testToken)),
+      feedsRestApi: feedsApi,
+      wsProvider: (options) => webSocketChannel,
+    );
+  });
+
+  tearDown(() {
+    client.disconnect();
+  });
+
+  group('Getting an activity', () {
+    test('fetch activity and comments', () async {
+      const activityId = 'id';
+      when(() => feedsApi.getActivity(id: activityId)).thenAnswer(
+        (_) async => Result.success(defaultActivityResponse),
+      );
+      when(
+        () => feedsApi.getComments(
+          objectId: activityId,
+          objectType: 'activity',
+          depth: 3,
+        ),
+      ).thenAnswer(
+        (_) async => const Result.success(defaultCommentsResponse),
+      );
+
+      final activity = client.activity(
+        activityId: activityId,
+        fid: const FeedId(group: 'group', id: 'id'),
+      );
+
+      expect(activity, isA<Activity>());
+      expect(activity.activityId, 'id');
+
+      verifyNever(() => feedsApi.getActivity(id: 'id'));
+
+      final result = await activity.get();
+
+      verify(() => feedsApi.getActivity(id: 'id')).called(1);
+      expect(result, isA<Result<ActivityData>>());
+      expect(result.getOrNull()?.id, 'id');
+    });
+  });
+}
+
+const defaultCommentsResponse = GetCommentsResponse(
+  comments: [],
+  next: null,
+  prev: null,
+  duration: 'duration',
+);
+
+final defaultActivityResponse = GetActivityResponse(
+  activity: ActivityResponse(
+    id: 'id',
+    attachments: const [],
+    bookmarkCount: 0,
+    commentCount: 0,
+    comments: const [],
+    createdAt: DateTime(2021, 1, 1),
+    custom: const {},
+    feeds: const [],
+    filterTags: const [],
+    interestTags: const [],
+    latestReactions: const [],
+    mentionedUsers: const [],
+    moderation: null,
+    notificationContext: null,
+    ownBookmarks: const [],
+    ownReactions: const [],
+    parent: null,
+    poll: null,
+    popularity: 0,
+    reactionCount: 0,
+    reactionGroups: const {},
+    score: 0,
+    searchData: const {},
+    shareCount: 0,
+    text: null,
+    type: 'type',
+    updatedAt: DateTime(2021, 2, 1),
+    user: UserResponse(
+      id: 'id',
+      name: 'name',
+      banned: false,
+      blockedUserIds: const [],
+      createdAt: DateTime(2021, 1, 1),
+      custom: const {},
+      language: 'language',
+      online: false,
+      role: 'role',
+      teams: const [],
+      updatedAt: DateTime(2021, 2, 1),
+    ),
+    visibility: ActivityResponseVisibility.public,
+    visibilityTag: null,
+  ),
+  duration: 'duration',
+);