collection_repository_impl.dart

Go to the documentation of this file.

import 'dart:developer';
import 'package:dartz/dartz.dart';
 
import '../../../../core/errors/exception_failure_adapter.dart';
import '../../../../core/errors/failures.dart';
import '../../domain/entities/collection_entity.dart';
import '../../domain/entities/create_collection_req_entity.dart';
import '../../domain/entities/update_collection_req_entity.dart';
import '../../domain/repository/collection_repository.dart';
import '../data_sources/remote_datasource/collections_remote_datasource.dart';
import '../models/collection_model.dart';
import '../models/create_collection_model.dart';
 
class CollectionsRepositoryImpl extends CollectionsRepository {
  final CollectionsRemoteDataSource remoteDataSource;
  CollectionsRepositoryImpl({required this.remoteDataSource});
 
  @override
  Future<Either<Failure, List<ProposedTimeEntity>>>
      loadCollectionTimes() async {
    try {
      final results = await remoteDataSource.fetchCollectionTimes();
      return right(results.map((e) => ProposedTimeModel.fromJson(e)).toList());
    } catch (e) {
      return left(ExceptionFailureAdapter.adapt(e));
    }
  }
 
  @override
  Future<Either<Failure, List<CollectionEntity>>> loadOnGoingCollectionRequets({
    required String partnerId,
  }) async {
    try {
      final results = await remoteDataSource.fetchOnGoingCollectionRequests(
        param: partnerId,
      );
      return right(results.map((e) => CollectionModel.fromJson(e)).toList());
    } catch (e) {
      return left(ExceptionFailureAdapter.adapt(e));
    }
  }
 
  @override
  Future<Either<Failure, List<CollectionEntity>>>
      loadCompletedCollectionRequests({
    required String partnerId,
  }) async {
    try {
      final results = await remoteDataSource.fetchCompletedCollectionRequests(
        param: partnerId,
      );
      return right(results.map((e) => CollectionModel.fromJson(e)).toList());
    } catch (e) {
      return left(ExceptionFailureAdapter.adapt(e));
    }
  }
 
  @override
  Future<Either<Failure, void>> createCollectionRequest({
    required CreateCollectionRequestEntity collection,
  }) async {
    try {
      await remoteDataSource.createCollectionRequest(
        body: CreateCollectionModel.fromEntity(collection).toJson(),
      );
      return right(null);
    } catch (e) {
      log(CreateCollectionModel.fromEntity(collection).toJson().toString());
      log(e.toString());
      return left(ExceptionFailureAdapter.adapt(e));
    }
  }
 
  @override
  Future<Either<Failure, dynamic>> updateCollectionRequest({
    required UpdateCollectionReqEntity updatedCollection,
  }) async {
    try {
      await remoteDataSource.updateCollectionRequest(
        body: updatedCollection.toJson(),
      );
      return right(null);
    } catch (e) {
      log(e.toString());
      return left(ExceptionFailureAdapter.adapt(e));
    }
  }
}