Fix countrries and languages uncomplete list in the con,tent managment

lib/content_management/bloc/create_headline/create_headline_bloc.dart

@@ -1,4 +1,5 @@
 import 'package:bloc/bloc.dart';
+import 'package:bloc_concurrency/bloc_concurrency.dart';
 import 'package:core/core.dart';
 import 'package:data_repository/data_repository.dart';
 import 'package:equatable/equatable.dart';
@@ -8,6 +9,8 @@ import 'package:uuid/uuid.dart';
 part 'create_headline_event.dart';
 part 'create_headline_state.dart';
 
+const _searchDebounceDuration = Duration(milliseconds: 300);
+
 /// A BLoC to manage the state of creating a new headline.
 class CreateHeadlineBloc
     extends Bloc<CreateHeadlineEvent, CreateHeadlineState> {
@@ -32,6 +35,12 @@ class CreateHeadlineBloc
     on<CreateHeadlineCountryChanged>(_onCountryChanged);
     on<CreateHeadlineStatusChanged>(_onStatusChanged);
     on<CreateHeadlineSubmitted>(_onSubmitted);
+    on<CreateHeadlineCountrySearchChanged>(
+      _onCountrySearchChanged,
+      transformer: restartable(),
+    );
+    on<CreateHeadlineLoadMoreCountriesRequested>(
+        _onLoadMoreCountriesRequested);
   }
 
   final DataRepository<Headline> _headlinesRepository;
@@ -46,33 +55,30 @@ class CreateHeadlineBloc
   ) async {
     emit(state.copyWith(status: CreateHeadlineStatus.loading));
     try {
-      final [
-        sourcesResponse,
-        topicsResponse,
-        countriesResponse,
-      ] = await Future.wait([
+      final [sourcesResponse, topicsResponse] = await Future.wait([
         _sourcesRepository.readAll(
           sort: [const SortOption('updatedAt', SortOrder.desc)],
         ),
         _topicsRepository.readAll(
           sort: [const SortOption('updatedAt', SortOrder.desc)],
         ),
-        _countriesRepository.readAll(
-          sort: [const SortOption('name', SortOrder.asc)],
-        ),
       ]);
 
       final sources = (sourcesResponse as PaginatedResponse<Source>).items;
       final topics = (topicsResponse as PaginatedResponse<Topic>).items;
-      final countries =
-          (countriesResponse as PaginatedResponse<Country>).items;
+
+      final countriesResponse = await _countriesRepository.readAll(
+        sort: [const SortOption('name', SortOrder.asc)],
+      );
 
       emit(
         state.copyWith(
           status: CreateHeadlineStatus.initial,
           sources: sources,
           topics: topics,
-          countries: countries,
+          countries: countriesResponse.items,
+          countriesCursor: countriesResponse.cursor,
+          countriesHasMore: countriesResponse.hasMore,
         ),
       );
     } on HttpException catch (e) {
@@ -189,4 +195,72 @@ class CreateHeadlineBloc
       );
     }
   }
+
+  Future<void> _onCountrySearchChanged(
+    CreateHeadlineCountrySearchChanged event,
+    Emitter<CreateHeadlineState> emit,
+  ) async {
+    await Future<void>.delayed(_searchDebounceDuration);
+    emit(state.copyWith(countrySearchTerm: event.searchTerm));
+    try {
+      final countriesResponse = await _countriesRepository.readAll(
+        filter:
+            event.searchTerm.isNotEmpty ? {'name': event.searchTerm} : null,
+        sort: [const SortOption('name', SortOrder.asc)],
+      );
+
+      emit(
+        state.copyWith(
+          countries: countriesResponse.items,
+          countriesCursor: countriesResponse.cursor,
+          countriesHasMore: countriesResponse.hasMore,
+        ),
+      );
+    } on HttpException catch (e) {
+      emit(state.copyWith(status: CreateHeadlineStatus.failure, exception: e));
+    } catch (e) {
+      emit(
+        state.copyWith(
+          status: CreateHeadlineStatus.failure,
+          exception: UnknownException('An unexpected error occurred: $e'),
+        ),
+      );
+    }
+  }
+
+  Future<void> _onLoadMoreCountriesRequested(
+    CreateHeadlineLoadMoreCountriesRequested event,
+    Emitter<CreateHeadlineState> emit,
+  ) async {
+    if (!state.countriesHasMore) return;
+
+    try {
+      final countriesResponse = await _countriesRepository.readAll(
+        pagination: state.countriesCursor != null
+            ? PaginationOptions(cursor: state.countriesCursor)
+            : null,
+        filter: state.countrySearchTerm.isNotEmpty
+            ? {'name': state.countrySearchTerm}
+            : null,
+        sort: [const SortOption('name', SortOrder.asc)],
+      );
+
+      emit(
+        state.copyWith(
+          countries: List.of(state.countries)..addAll(countriesResponse.items),
+          countriesCursor: countriesResponse.cursor,
+          countriesHasMore: countriesResponse.hasMore,
+        ),
+      );
+    } on HttpException catch (e) {
+      emit(state.copyWith(status: CreateHeadlineStatus.failure, exception: e));
+    } catch (e) {
+      emit(
+        state.copyWith(
+          status: CreateHeadlineStatus.failure,
+          exception: UnknownException('An unexpected error occurred: $e'),
+        ),
+      );
+    }
+  }
 }

lib/content_management/bloc/create_headline/create_headline_event.dart

@@ -83,3 +83,17 @@ final class CreateHeadlineStatusChanged extends CreateHeadlineEvent {
 final class CreateHeadlineSubmitted extends CreateHeadlineEvent {
   const CreateHeadlineSubmitted();
 }
+
+/// Event for when the country search term is changed.
+final class CreateHeadlineCountrySearchChanged extends CreateHeadlineEvent {
+  const CreateHeadlineCountrySearchChanged(this.searchTerm);
+  final String searchTerm;
+  @override
+  List<Object?> get props => [searchTerm];
+}
+
+/// Event to request loading more countries.
+final class CreateHeadlineLoadMoreCountriesRequested
+    extends CreateHeadlineEvent {
+  const CreateHeadlineLoadMoreCountriesRequested();
+}

lib/content_management/bloc/create_headline/create_headline_state.dart

@@ -32,6 +32,9 @@ final class CreateHeadlineState extends Equatable {
     this.sources = const [],
     this.topics = const [],
     this.countries = const [],
+    this.countriesHasMore = true,
+    this.countriesCursor,
+    this.countrySearchTerm = '',
     this.contentStatus = ContentStatus.active,
     this.exception,
     this.createdHeadline,
@@ -48,6 +51,9 @@ final class CreateHeadlineState extends Equatable {
   final List<Source> sources;
   final List<Topic> topics;
   final List<Country> countries;
+  final bool countriesHasMore;
+  final String? countriesCursor;
+  final String countrySearchTerm;
   final ContentStatus contentStatus;
   final HttpException? exception;
   final Headline? createdHeadline;
@@ -74,6 +80,9 @@ final class CreateHeadlineState extends Equatable {
     List<Source>? sources,
     List<Topic>? topics,
     List<Country>? countries,
+    bool? countriesHasMore,
+    String? countriesCursor,
+    String? countrySearchTerm,
     ContentStatus? contentStatus,
     HttpException? exception,
     Headline? createdHeadline,
@@ -90,6 +99,9 @@ final class CreateHeadlineState extends Equatable {
       sources: sources ?? this.sources,
       topics: topics ?? this.topics,
       countries: countries ?? this.countries,
+      countriesHasMore: countriesHasMore ?? this.countriesHasMore,
+      countriesCursor: countriesCursor ?? this.countriesCursor,
+      countrySearchTerm: countrySearchTerm ?? this.countrySearchTerm,
       contentStatus: contentStatus ?? this.contentStatus,
       exception: exception,
       createdHeadline: createdHeadline ?? this.createdHeadline,
@@ -109,6 +121,9 @@ final class CreateHeadlineState extends Equatable {
     sources,
     topics,
     countries,
+    countriesHasMore,
+    countriesCursor,
+    countrySearchTerm,
     contentStatus,
     exception,
     createdHeadline,