history_repository_impl.dart

Go to the documentation of this file.

 
import 'package:dartz/dartz.dart';
import 'package:internet_connection_checker_plus/internet_connection_checker_plus.dart';
 
import '../../../../core/error/exceptipns/server_exception.dart';
import '../../../../core/error/failures.dart';
import '../../../../core/ui/theme/color_palette.dart';
import '../../../../core/common/entities/collection_entity.dart';
import '../../domain/repositories/history_repository.dart';
import '../datasources/history_local_datasource.dart';
import '../datasources/history_remote_datasource.dart';
 
class HistoryRepositoryImpl extends HistoryRepository{
  final HistoryRemoteDatasource remoteDataSource;
  final HistoryLocalDatasource localDataSource;
 
  HistoryRepositoryImpl({
    required this.remoteDataSource,
    required this.localDataSource,
  });
 
  @override
  Future<Either<Failure, List<CollectionEntity>>> getPendingCollections({
    required int userId
  }) async {
    try {
      List<CollectionEntity> result;
      bool hasInternetConnection = await InternetConnection().hasInternetAccess;
      if (hasInternetConnection) {
        result = await remoteDataSource.getPendingCollections(userId: userId);
      } else {
        result = await localDataSource.getPendingCollections();
      }
      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<CollectionEntity>>> getHistoryCollections({
    required int userId,
    required String? period,
    DateTime? dateStart,
    DateTime? dateEnd,
  }) async {
    try {
      List<CollectionEntity> result;
      bool hasInternetConnection = await InternetConnection().hasInternetAccess;
      if (hasInternetConnection){
        result = await remoteDataSource.getHistoryCollections(
          userId: userId,
          period: period,
          dateStart: dateStart,
          dateEnd: dateEnd,
        );
      } else {
        if (period == 'week') {
          result = await localDataSource.getThisWeekHistoryCollections();
        } else {
          result = await localDataSource.getThisMonthHistoryCollections();
        }
      }
      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));
    }
  }
  
}