unloading_bloc.dart

Go to the documentation of this file.

import 'package:flutter_bloc/flutter_bloc.dart';
 
import '../../../../core/services/service_locator.dart';
import '../../domain/usecases/get_history_unloading_usecase.dart';
import '../../domain/usecases/get_pending_unloading_collections_usecase.dart';
import '../../domain/usecases/get_warehouse_responsible_list_usecase.dart';
import '../../domain/usecases/send_unloading_usecase.dart';
import 'unloading_event.dart';
import 'unloading_state.dart';
 
class UnloadingBloc extends Bloc<UnloadingEvent, UnloadingState> {
  final GetPendingUnloadingCollectionsUseCase getPendingUnloadingCollectionsUseCase = sl<GetPendingUnloadingCollectionsUseCase>();
  final GetHistoryUnloadingUseCase getHistoryUnloadingUseCase = sl<GetHistoryUnloadingUseCase>();
  final GetWarehouseResponsibleListUseCase getWarehouseResponsibleListUseCase = sl<GetWarehouseResponsibleListUseCase>();
  final SendUnloadingUsecase sendUnloadingUsecase = sl<SendUnloadingUsecase>();
 
  UnloadingBloc() : super(UnloadingInitial()) { 
    on<GetPendingUnloadingCollectionsEvent>(_onGetPendingUnloadingCollections);
    on<GetHistoryUnloadingEvent>(_onGetHistoryUnloading);
    on<GetWarehouseResponsibleListEvent>(_onGetWarehouseResponsibleList);
    on<SendUnloadingEvent>(_onSendUnloading);
  }
 
  Future<void> _onGetPendingUnloadingCollections(
    GetPendingUnloadingCollectionsEvent event,
    Emitter<UnloadingState> emit,
  ) async {
    emit(UnloadingLoading());
    final result = await getPendingUnloadingCollectionsUseCase(event.userId);
    result.fold(
      (failure) => emit(UnloadingError(message: failure.message)),
      (collections) => emit(PendingUnloadingCollectionsLoaded(collections: collections)),
    );
  }
 
  Future<void> _onGetHistoryUnloading(
    GetHistoryUnloadingEvent event,
    Emitter<UnloadingState> emit,
  ) async {
    emit(UnloadingLoading());
    final result = await getHistoryUnloadingUseCase(event.userId);
    result.fold(
      (failure) => emit(UnloadingError(message: failure.message)),
      (history) => emit(HistoryUnloadingLoaded(history: history)),
    );
  }
 
  Future<void> _onGetWarehouseResponsibleList(
    GetWarehouseResponsibleListEvent event,
    Emitter<UnloadingState> emit,
  ) async {
    emit(GetWarehouseResponsibleLoading());
    final result = await getWarehouseResponsibleListUseCase(event.userId);
    result.fold(
      (failure) => emit(GetWarehouseResponsibleError(message: failure.message)),
      (warehouseResponsible) => emit(GetWarehouseResponsibleLoaded(
        warehouseResponsibleList: warehouseResponsible,
      )),
    );
  }
 
  Future<void> _onSendUnloading(
    SendUnloadingEvent event,
    Emitter<UnloadingState> emit,
  ) async {
    emit(SendUnloadingLoading());
    final result = await sendUnloadingUsecase(
      SendUnloadingParams(
        warehouseResponsibleId: event.warehouseResponsibleId,
        firstWeight: event.firstWeight,
        userId: event.userId,
        collectionVouchers: event.collectionVouchers,
      ),
    );
    result.fold(
      (failure) => emit(UnloadingError(message: failure.message)),
      (success) => emit(SendUnloadingSuccess()),
    );
  }
}