planning_repository_impl.dart

Go to the documentation of this file.

import 'package:dartz/dartz.dart';
 
import '../../../../core/error/exceptipns/server_exception.dart';
import '../../../../core/error/failures.dart';
import '../../../../core/ui/theme/color_palette.dart';
import '../../domain/entities/req/req_create_routing_entity.dart';
import '../../domain/entities/req/req_create_driver_collection_entity.dart';
import '../../domain/entities/res/res_weekly_collection_entity.dart';
import '../../domain/entities/res/res_create_routing_entity.dart';
import '../../domain/entities/res/res_collection_to_schedule_entity.dart';
import '../../domain/repositories/planning_repository.dart';
import '../datasources/planning_remote_datasource.dart';
import '../models/req/req_create_routing_model.dart';
import '../models/req/req_create_driver_collection_model.dart';
 
class PlanningRepositoryImpl implements PlanningRepository {
  final PlanningRemoteDataSource remoteDataSource;
 
  PlanningRepositoryImpl({required this.remoteDataSource});
 
  @override
  Future<Either<Failure, List<ResWeeklyCollectionEntity>>> getWeeklyCollections({
    required int userId,
    required String startDate,
    required String endDate,
  }) async {
    try {
      final result = await remoteDataSource.getWeeklyCollections(
        userId: userId,
        startDate: startDate,
        endDate: endDate,
      );
      return Right(result);
    } on ServerException catch (e) {
      return left(ServerFailure(message: e.message, color: ColorPalette.red));
    } catch (e) {
      return left(ServerFailure(message: e.toString(), color: ColorPalette.red));
    }
  }
 
  @override
  Future<Either<Failure, ResCreateRoutingEntity>> createRouting(ReqCreateRoutingEntity request) async {
    try {
      final model = ReqCreateRoutingModel.fromEntity(request);
      final result = await remoteDataSource.createRouting(model);
      return Right(result);
    } on ServerException catch (e) {
      return left(ServerFailure(message: e.message, color: ColorPalette.red));
    } catch (e) {
      return left(ServerFailure(message: e.toString(), color: ColorPalette.red));
    }
  }
 
  @override
  Future<Either<Failure, void>> validateScheduler({
    required String timeStringValue,
    required int driverId,
  }) async {
    try {
      await remoteDataSource.validateScheduler(
        timeStringValue: timeStringValue,
        driverId: driverId,
      );
      return const Right(null);
    } on ServerException catch (e) {
      return left(ServerFailure(message: e.message, color: ColorPalette.red));
    } catch (e) {
      return left(
          ServerFailure(message: e.toString(), color: ColorPalette.red));
    }
  }
 
  @override
  Future<Either<Failure, bool>> createDriverCollection(
    ReqCreateDriverCollectionEntity request,
  ) async {
    try {
      final model = ReqCreateDriverCollectionModel.fromEntity(request);
      final result = await remoteDataSource.createDriverCollection(model);
      return Right(result);
    } on ServerException catch (e) {
      return left(ServerFailure(message: e.message, color: ColorPalette.red));
    } catch (e) {
      return left(ServerFailure(message: e.toString(), color: ColorPalette.red));
    }
  }
 
  @override
  Future<Either<Failure, List<ResCollectionToScheduleEntity>>> getCollectionsToSchedule({
    required String startDate,
    required String endDate,
    required int driverId,
  }) async {
    try {
      final result = await remoteDataSource.getCollectionsToSchedule(
        startDate: startDate,
        endDate: endDate,
        driverId: driverId,
      );
      return Right(result);
    } on ServerException catch (e) {
      return left(ServerFailure(message: e.message, color: ColorPalette.red));
    } catch (e) {
      return left(ServerFailure(message: e.toString(), color: ColorPalette.red));
    }
  }
}