after
This commit is contained in:
@@ -33,7 +33,10 @@ class ServiceBloc extends Bloc<ServiceEvent, ServiceState> {
|
||||
on<LoadServicesHistoryForUser>(_onLoadServicesHistoryForUser);
|
||||
on<LoadServicesHistoryForProfessional>(
|
||||
_onLoadServicesHistoryForProfessional);
|
||||
on<LoadPendingServicesForProfessional>(
|
||||
_onLoadPendingServicesForProfessional);
|
||||
on<UpdateProfessionalScored>(_onUpdateProfessionalScored);
|
||||
on<UpdateUserScored>(_onUpdateUserScored);
|
||||
}
|
||||
|
||||
void _onCreateService(CreateService event, Emitter<ServiceState> emit) async {
|
||||
@@ -224,6 +227,40 @@ class ServiceBloc extends Bloc<ServiceEvent, ServiceState> {
|
||||
}
|
||||
}
|
||||
|
||||
void _onLoadPendingServicesForProfessional(
|
||||
LoadPendingServicesForProfessional event,
|
||||
Emitter<ServiceState> emit) async {
|
||||
try {
|
||||
final servicesStream =
|
||||
_serviceRepository.getPendingServicesForProfessional(event.userId);
|
||||
|
||||
await for (var services in servicesStream) {
|
||||
if (services.isEmpty) {
|
||||
emit(const ServicesForUserLoaded([]));
|
||||
return;
|
||||
}
|
||||
final userIds = services.map((e) => e.userId);
|
||||
|
||||
final List<MyUser> users =
|
||||
await _userRepository.getUsersFromIds(userIds);
|
||||
|
||||
final usersDir = {for (var e in users) e.id: e};
|
||||
|
||||
final servicesInfo = services.map((e) {
|
||||
return ServiceInfoUI(
|
||||
service: e,
|
||||
user: usersDir[e.userId]!,
|
||||
);
|
||||
}).toList();
|
||||
|
||||
emit(ServicesForUserLoaded(servicesInfo));
|
||||
}
|
||||
} catch (e) {
|
||||
log(e.toString());
|
||||
emit(CreateServiceFailure());
|
||||
}
|
||||
}
|
||||
|
||||
void _onUpdateServiceStatus(
|
||||
UpdateServiceStatus event, Emitter<ServiceState> emit) async {
|
||||
try {
|
||||
@@ -242,7 +279,19 @@ class ServiceBloc extends Bloc<ServiceEvent, ServiceState> {
|
||||
try {
|
||||
emit(CreateServiceLoading());
|
||||
await _serviceRepository.setProfessionalScored(event.serviceId);
|
||||
emit(ProfessionalScoredUpdated());
|
||||
emit(ScoredUpdated());
|
||||
} catch (e) {
|
||||
log(e.toString());
|
||||
emit(CreateServiceFailure());
|
||||
}
|
||||
}
|
||||
|
||||
void _onUpdateUserScored(
|
||||
UpdateUserScored event, Emitter<ServiceState> emit) async {
|
||||
try {
|
||||
emit(CreateServiceLoading());
|
||||
await _serviceRepository.setUserScored(event.serviceId);
|
||||
emit(ScoredUpdated());
|
||||
} catch (e) {
|
||||
log(e.toString());
|
||||
emit(CreateServiceFailure());
|
||||
|
||||
Reference in New Issue
Block a user