test: add tests for queryModerationConfigs and handle success/failure cases

Author: xsahil03x

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

@@ -1,8 +1,9 @@
 import 'package:stream_core/stream_core.dart';
 
-import '../../stream_feeds.dart' show ModerationConfigsQuery;
 import '../generated/api/api.dart' as api;
+import '../models.dart' show ModerationConfigData, PaginationResult;
 import '../repository/moderation_repository.dart';
+import '../state.dart' show ModerationConfigsQuery;
 
 /// Controller exposing moderation functionalities.
 ///
@@ -160,8 +161,9 @@ class ModerationClient {
   ///
   /// Retrieves moderation configurations using the specified [queryModerationConfigsRequest] filters and pagination.
   ///
-  /// Returns a [Result] containing a [api.QueryModerationConfigsResponse] or an error.
-  Future<void> queryModerationConfigs({
+  /// Returns a [Result] containing a [PaginationResult] of [ModerationConfigData] or an error.
+  Future<Result<PaginationResult<ModerationConfigData>>>
+      queryModerationConfigs({
     required ModerationConfigsQuery queryModerationConfigsRequest,
   }) {
     return _moderationRepository

packages/stream_feeds/test/client/moderation_client_test.dart

@@ -520,4 +520,68 @@ void main() {
       },
     );
   });
+
+  group('queryModerationConfigs', () {
+    setUpAll(() {
+      registerFallbackValue(const QueryModerationConfigsRequest());
+    });
+
+    moderationClientTest(
+      'should query moderation configs successfully',
+      body: (tester) async {
+        const query = ModerationConfigsQuery(limit: 10);
+        final request = query.toRequest();
+
+        tester.mockApi(
+          (api) => api.queryModerationConfigs(
+            queryModerationConfigsRequest: request,
+          ),
+          result: createDefaultQueryModerationConfigsResponse(
+            configs: [createDefaultConfigResponse()],
+          ),
+        );
+
+        final result = await tester.moderation.queryModerationConfigs(
+          queryModerationConfigsRequest: query,
+        );
+
+        expect(result.isSuccess, isTrue);
+        final paginationResult = result.getOrThrow();
+        expect(paginationResult.items, isNotEmpty);
+
+        tester.verifyApi(
+          (api) => api.queryModerationConfigs(
+            queryModerationConfigsRequest: request,
+          ),
+        );
+      },
+    );
+
+    moderationClientTest(
+      'should handle query moderation configs failure',
+      body: (tester) async {
+        const query = ModerationConfigsQuery(limit: 10);
+        final request = query.toRequest();
+
+        tester.mockApiFailure(
+          (api) => api.queryModerationConfigs(
+            queryModerationConfigsRequest: request,
+          ),
+          error: Exception('Failed to query configs'),
+        );
+
+        final result = await tester.moderation.queryModerationConfigs(
+          queryModerationConfigsRequest: query,
+        );
+
+        expect(result.isFailure, isTrue);
+
+        tester.verifyApi(
+          (api) => api.queryModerationConfigs(
+            queryModerationConfigsRequest: request,
+          ),
+        );
+      },
+    );
+  });
 }

packages/stream_feeds_test/lib/src/helpers/test_data.dart

@@ -885,6 +885,20 @@ QueryModerationConfigsResponse createDefaultQueryModerationConfigsResponse({
   );
 }
 
+ConfigResponse createDefaultConfigResponse({
+  String key = 'default-config',
+  String team = 'default-team',
+}) {
+  return ConfigResponse(
+    key: key,
+    team: team,
+    async: true,
+    createdAt: DateTime(2021, 1, 1),
+    updatedAt: DateTime(2021, 2, 1),
+    supportedVideoCallHarmTypes: const [],
+  );
+}
+
 BanResponse createDefaultBanResponse() {
   return const BanResponse(duration: '10ms');
 }