chore(llc): improve test coverage for activity (#41)

Author: renefloor

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

@@ -67,6 +67,8 @@ class StreamFeedsClientImpl implements StreamFeedsClient {
     NetworkStateProvider? networkStateProvider,
     LifecycleStateProvider? lifecycleStateProvider,
     List<AutomaticReconnectionPolicy>? reconnectionPolicies,
+    WebSocketProvider? wsProvider,
+    api.DefaultApi? feedsRestApi,
   }) {
     // TODO: Make this configurable
     const endpointConfig = EndpointConfig.production;
@@ -107,6 +109,7 @@ class StreamFeedsClientImpl implements StreamFeedsClient {
         event_resolvers.pollAnswerCastedFeedEventResolver,
         event_resolvers.pollAnswerRemovedFeedEventResolver,
       ],
+      wsProvider: wsProvider,
     );
 
     _connectionRecoveryHandler = ConnectionRecoveryHandler(
@@ -154,7 +157,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

@@ -2,13 +2,21 @@ import 'package:mocktail/mocktail.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 MockWebSocketSink extends Mock implements WebSocketSink {}
+
 class FakeFeedsClient extends Fake implements StreamFeedsClientImpl {
   FakeFeedsClient({
     User? user,
@@ -25,3 +33,6 @@ const fakeUser = User(
   id: 'user_id',
   name: 'user_name',
 );
+
+const testToken =
+    'eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1c2VyX2lkIjoibHVrZV9za3l3YWxrZXIifQ.hZ59SWtp_zLKVV9ShkqkTsCGi_jdPHly7XNCf5T_Ev0';