refactor(sources): Filter sources locally

- Remove _FetchFilteredSourcesRequested
- Filter in bloc using helper method
- Use initial capsule selections

Author: fulleni

lib/headlines-feed/bloc/sources_filter_bloc.dart

@@ -18,11 +18,11 @@ class SourcesFilterBloc extends Bloc<SourcesFilterEvent, SourcesFilterState> {
        super(const SourcesFilterState()) {
     on<LoadSourceFilterData>(_onLoadSourceFilterData);
     on<CountryCapsuleToggled>(_onCountryCapsuleToggled);
-    on<AllSourceTypesCapsuleToggled>(_onAllSourceTypesCapsuleToggled); // Added
+    on<AllSourceTypesCapsuleToggled>(_onAllSourceTypesCapsuleToggled);
     on<SourceTypeCapsuleToggled>(_onSourceTypeCapsuleToggled);
     on<SourceCheckboxToggled>(_onSourceCheckboxToggled);
     on<ClearSourceFiltersRequested>(_onClearSourceFiltersRequested);
-    on<_FetchFilteredSourcesRequested>(_onFetchFilteredSourcesRequested);
+    // Removed _FetchFilteredSourcesRequested event listener
   }
 
   final HtDataRepository<Source> _sourcesRepository;
@@ -40,32 +40,35 @@ class SourcesFilterBloc extends Bloc<SourcesFilterEvent, SourcesFilterState> {
       final initialSelectedSourceIds =
           event.initialSelectedSources.map((s) => s.id).toSet();
 
-      // Initialize selected capsules based on initialSelectedSources
-      final initialSelectedCountryIsoCodes = <String>{};
-      final initialSelectedSourceTypes = <SourceType>{};
-
-      if (event.initialSelectedSources.isNotEmpty) {
-        for (final source in event.initialSelectedSources) {
-          if (source.headquarters?.isoCode != null) {
-            initialSelectedCountryIsoCodes.add(source.headquarters!.isoCode);
-          }
-          if (source.sourceType != null) {
-            initialSelectedSourceTypes.add(source.sourceType!);
-          }
-        }
-      }
+      // Use the passed-in initial capsule selections directly
+      final initialSelectedCountryIsoCodes =
+          event.initialSelectedCountryIsoCodes;
+      final initialSelectedSourceTypes = event.initialSelectedSourceTypes;
+
+      final allSourcesResponse = await _sourcesRepository.readAll();
+      final allAvailableSources = allSourcesResponse.items;
+
+      // Initially, display all sources. Capsules are visually set but don't filter the list yet.
+      // Filtering will occur if a capsule is manually toggled.
+      // However, if initial capsule filters ARE provided, we should respect them for the initial display.
+      final displayableSources = _getFilteredSources(
+        allSources: allAvailableSources,
+        selectedCountries: initialSelectedCountryIsoCodes, // Use event's data
+        selectedTypes: initialSelectedSourceTypes, // Use event's data
+      );
 
       emit(
         state.copyWith(
           availableCountries: availableCountries.items,
+          allAvailableSources: allAvailableSources,
+          displayableSources: displayableSources, // Now correctly filtered if initial capsules were set
           finallySelectedSourceIds: initialSelectedSourceIds,
-          selectedCountryIsoCodes: initialSelectedCountryIsoCodes,
-          selectedSourceTypes: initialSelectedSourceTypes,
-          // Keep loading status until sources are fetched
+          selectedCountryIsoCodes: initialSelectedCountryIsoCodes, // Use event's data
+          selectedSourceTypes: initialSelectedSourceTypes, // Use event's data
+          dataLoadingStatus: SourceFilterDataLoadingStatus.success,
+          clearErrorMessage: true,
         ),
       );
-      // Trigger initial fetch of displayable sources
-      add(const _FetchFilteredSourcesRequested());
     } catch (e) {
       emit(
         state.copyWith(
@@ -95,34 +98,57 @@ class SourcesFilterBloc extends Bloc<SourcesFilterEvent, SourcesFilterState> {
         currentSelected.add(event.countryIsoCode);
       }
     }
-    emit(state.copyWith(selectedCountryIsoCodes: currentSelected));
-    add(const _FetchFilteredSourcesRequested());
+    final newDisplayableSources = _getFilteredSources(
+      allSources: state.allAvailableSources,
+      selectedCountries: currentSelected,
+      selectedTypes: state.selectedSourceTypes,
+    );
+    emit(
+      state.copyWith(
+        selectedCountryIsoCodes: currentSelected,
+        displayableSources: newDisplayableSources,
+      ),
+    );
   }
 
-  Future<void> _onAllSourceTypesCapsuleToggled(
+  void _onAllSourceTypesCapsuleToggled(
     AllSourceTypesCapsuleToggled event,
     Emitter<SourcesFilterState> emit,
-  ) async {
-    // Toggling "All" for source types means clearing any specific selections.
-    // If already clear, it remains clear.
-    emit(state.copyWith(selectedSourceTypes: {}));
-    add(const _FetchFilteredSourcesRequested());
+  ) {
+    final newDisplayableSources = _getFilteredSources(
+      allSources: state.allAvailableSources,
+      selectedCountries: state.selectedCountryIsoCodes,
+      selectedTypes: {}, // Cleared source types
+    );
+    emit(
+      state.copyWith(
+        selectedSourceTypes: {},
+        displayableSources: newDisplayableSources,
+      ),
+    );
   }
 
-  Future<void> _onSourceTypeCapsuleToggled(
+  void _onSourceTypeCapsuleToggled(
     SourceTypeCapsuleToggled event,
     Emitter<SourcesFilterState> emit,
-  ) async {
+  ) {
     final currentSelected = Set<SourceType>.from(state.selectedSourceTypes);
     if (currentSelected.contains(event.sourceType)) {
       currentSelected.remove(event.sourceType);
     } else {
       currentSelected.add(event.sourceType);
     }
-    // If specific types are selected, "All" is no longer true.
-    // The UI will derive "All" state from selectedSourceTypes.isEmpty
-    emit(state.copyWith(selectedSourceTypes: currentSelected));
-    add(const _FetchFilteredSourcesRequested());
+    final newDisplayableSources = _getFilteredSources(
+      allSources: state.allAvailableSources,
+      selectedCountries: state.selectedCountryIsoCodes,
+      selectedTypes: currentSelected,
+    );
+    emit(
+      state.copyWith(
+        selectedSourceTypes: currentSelected,
+        displayableSources: newDisplayableSources,
+      ),
+    );
   }
 
   void _onSourceCheckboxToggled(
@@ -147,55 +173,31 @@ class SourcesFilterBloc extends Bloc<SourcesFilterEvent, SourcesFilterState> {
         selectedCountryIsoCodes: {},
         selectedSourceTypes: {},
         finallySelectedSourceIds: {},
-        // Keep availableCountries and availableSourceTypes
-      ),
-    );
-    add(const _FetchFilteredSourcesRequested());
-  }
-
-  Future<void> _onFetchFilteredSourcesRequested(
-    _FetchFilteredSourcesRequested event,
-    Emitter<SourcesFilterState> emit,
-  ) async {
-    emit(
-      state.copyWith(
-        dataLoadingStatus: SourceFilterDataLoadingStatus.loading,
-        displayableSources: [], // Clear previous sources
+        displayableSources: List.from(state.allAvailableSources), // Reset
+        dataLoadingStatus: SourceFilterDataLoadingStatus.success,
         clearErrorMessage: true,
       ),
     );
-    try {
-      final queryParameters = <String, dynamic>{};
-      if (state.selectedCountryIsoCodes.isNotEmpty) {
-        queryParameters['countries'] = state.selectedCountryIsoCodes.join(',');
-      }
-      if (state.selectedSourceTypes.isNotEmpty) {
-        queryParameters['sourceTypes'] = state.selectedSourceTypes
-            .map((st) => st.name)
-            .join(',');
-      }
+  }
 
-      final response = await _sourcesRepository.readAllByQuery(queryParameters);
-      emit(
-        state.copyWith(
-          displayableSources: response.items,
-          dataLoadingStatus: SourceFilterDataLoadingStatus.success,
-        ),
-      );
-    } on HtHttpException catch (e) {
-      emit(
-        state.copyWith(
-          dataLoadingStatus: SourceFilterDataLoadingStatus.failure,
-          errorMessage: e.message,
-        ),
-      );
-    } catch (e) {
-      emit(
-        state.copyWith(
-          dataLoadingStatus: SourceFilterDataLoadingStatus.failure,
-          errorMessage: 'An unexpected error occurred while fetching sources.',
-        ),
-      );
+  // Helper method to filter sources based on selected countries and types
+  List<Source> _getFilteredSources({
+    required List<Source> allSources,
+    required Set<String> selectedCountries,
+    required Set<SourceType> selectedTypes,
+  }) {
+    if (selectedCountries.isEmpty && selectedTypes.isEmpty) {
+      return List.from(allSources); // Return all if no filters
     }
+
+    return allSources.where((source) {
+      final matchesCountry = selectedCountries.isEmpty ||
+          (source.headquarters != null &&
+              selectedCountries.contains(source.headquarters!.isoCode));
+      final matchesType = selectedTypes.isEmpty ||
+          (source.sourceType != null &&
+              selectedTypes.contains(source.sourceType!));
+      return matchesCountry && matchesType;
+    }).toList();
   }
 }