collections_to_schedule_bloc.dart

Go to the documentation of this file.

import 'package:bloc/bloc.dart';
import 'package:equatable/equatable.dart';
 
import '../../../../../core/error/failures.dart';
import '../../../../../core/services/service_locator.dart';
import '../../../domain/entities/req/req_create_driver_collection_entity.dart';
import '../../../domain/entities/res/res_collection_to_schedule_entity.dart';
import '../../../domain/usecases/create_driver_collection_usecase.dart';
import '../../../domain/usecases/get_collections_to_schedule_usecase.dart';
 
part 'collections_to_schedule_event.dart';
part 'collections_to_schedule_state.dart';
 
class CollectionsToScheduleBloc
    extends Bloc<CollectionsToScheduleEvent, CollectionsToScheduleState> {
  final CreateDriverCollectionUseCase createDriverCollectionUseCase = sl<CreateDriverCollectionUseCase>();
  final GetCollectionsToScheduleUseCase getCollectionsToScheduleUseCase = sl<GetCollectionsToScheduleUseCase>();
 
  CollectionsToScheduleBloc() : super(CollectionsToScheduleInitial()) {
    on<CreateDriverCollectionEvent>(_onCreateDriverCollection);
    on<GetCollectionsToScheduleEvent>(_onGetCollectionsToSchedule);
  }
 
  Future<void> _onCreateDriverCollection(
    CreateDriverCollectionEvent event,
    Emitter<CollectionsToScheduleState> emit,
  ) async {
    emit(CollectionsToScheduleLoading());
 
    final result = await createDriverCollectionUseCase(event.request);
 
    result.fold(
      (failure) => emit(CollectionsToScheduleError(failure: failure)),
      (success) {
        // After successful creation, automatically fetch collections to schedule
        add(GetCollectionsToScheduleEvent(
          startDate: event.startDate,
          endDate: event.endDate,
          driverId: event.driverId,
        ));
      },
    );
  }
 
  Future<void> _onGetCollectionsToSchedule(
    GetCollectionsToScheduleEvent event,
    Emitter<CollectionsToScheduleState> emit,
  ) async {
    if (state is! CollectionsToScheduleLoading) {
      emit(CollectionsToScheduleLoading());
    }
 
    final result = await getCollectionsToScheduleUseCase(
      startDate: event.startDate,
      endDate: event.endDate,
      driverId: event.driverId,
    );
 
    result.fold(
      (failure) => emit(CollectionsToScheduleError(failure: failure)),
      (collections) => emit(CollectionsToScheduleLoaded(collections: collections)),
    );
  }
}