unloading_repository_impl.dart

Go to the documentation of this file.

import 'package:dartz/dartz.dart';
import 'package:geolocator/geolocator.dart';
 
import '../../../../core/api/api_client.dart';
import '../../../../core/api/api_endpoints.dart';
import '../../../../core/error/exceptipns/server_exception.dart';
import '../../../../core/error/failures.dart';
import '../../../../core/services/offline_sync_service.dart';
import '../../../../core/services/service_locator.dart';
import '../../../../core/ui/theme/color_palette.dart';
import '../../domain/entities/unloading_collection_entity.dart';
import '../../domain/entities/unloading_history_entity.dart';
import '../../domain/entities/warehouse_responsible_entity.dart';
import '../../domain/repositories/unloading_repository.dart';
import '../datasources/unloading_remote_datasource.dart';
import '../models/unloading_request_model.dart';
 
class UnloadingRepositoryImpl implements UnloadingRepository {
 
  final UnloadingRemoteDatasource remoteDataSource;
  final _apiClient = sl<ApiClient>();
  
  UnloadingRepositoryImpl({required this.remoteDataSource});
 
  @override
  Future<Either<Failure, List<UnloadingCollectionEntity>>> getPendingUnloadingCollections(int userId) async {
    try{
      final OfflineSyncService offlineSyncService = OfflineSyncService();
      await offlineSyncService.syncPendingOperations();
      final collections = await remoteDataSource.getPendingUnloadingCollections(userId: userId);
      return right(collections);
    } 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<UnloadingHistoryEntity>>> getHistoryUnloading(int userId) async {
    try {
      final history = await remoteDataSource.getHistoryUnloading(userId: userId);
      return right(history);
    } 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<WarehouseResponsibleEntity>>> getWarehouseResponsibleList(int userId) async {
    try {
      final warehouseResponsibles = await remoteDataSource.getWarehouseResponsibleList(userId: userId);
      return right(warehouseResponsibles);
    } on ServerException catch (e) {
      return left(ServerFailure(message: e.message, color: ColorPalette.red));
    } catch (e) {
      return left(ServerFailure(message: e.toString(), color: ColorPalette.red));
    }
  }
 
  Future<bool> _sendLocationToServer({
    required int driverId,
    required double latitude,
    required double longitude,
    int? poId,
    String? poStatus,
  }) async {
    try {
      final data = {
        "driverId": driverId,
        "lag": latitude.toString(),
        "longitude": longitude.toString(),
        "poId": poId,
        "poStatus": poStatus,
      };
 
      final response = await _apiClient.post(
        url: ApiEndpoints.sendGeoLocation,
        data: data,
      );
 
      return response.isNotEmpty;
    } catch (e) {
      return false;
    }
  }
 
  @override
  Future<Either<Failure, bool>> sendUnloading(UnloadingRequestModel unloadingRequestModel) async {
    try {
      Position position = await Geolocator.getCurrentPosition(
        locationSettings: const LocationSettings(
          accuracy: LocationAccuracy.high,
        ),
      );
      
      await _sendLocationToServer(
        driverId: unloadingRequestModel.userId,
        latitude: position.latitude,
        longitude: position.longitude,
        poStatus: "end",
      );
      
      await remoteDataSource.sendUnloading(unloadingRequestModel: unloadingRequestModel);
      return right(true);
    } on ServerException catch (e) {
      return left(ServerFailure(message: e.message, color: ColorPalette.red));
    } catch (e) {
      return left(ServerFailure(message: e.toString(), color: ColorPalette.red));
    }
  }
}