lamnguyen17 / flutter_clean_architecture Goto Github PK

class PhotoRemoteDataSourceImpl implements PhotoRemoteDataSource {
  final RestApiGateway _restApiGateway;

  PhotoRemoteDataSourceImpl(this._restApiGateway);

  @override
  Future<PhotosResponse> getPhoto(RequestPhoto? reqParams) async {
    final response = await _restApiGateway.dio.get(
        "?key=${API_KEY}&q=${reqParams?.query}&page=${reqParams?.page}&per_page=20");
    if (response.statusCode == 200) {
      return PhotosResponse.fromJson(response.data);
    } else {
      throw const ServerFailure('Lỗi xảy ra');
    }
  }
}

class PhotoRepositoryImpl implements PhotoRepository {
  final PhotoRemoteDataSource _dataSource;

  PhotoRepositoryImpl(this._dataSource);

  @override
  Future<Either<Failure, Photos>> getPhoto(RequestPhoto? reqParams) async {
    try {
      var response = await _dataSource.getPhoto(reqParams);
      return Right(response.toEntity());
    } on DioException catch (e) {
      return Left(ServerFailure(e.message ?? 'Lỗi hệ thống'));
    }
  }
}

class GetPhotoUseCase implements BaseUseCase<Photos, RequestPhoto> {
  final PhotoRepository repository;

  GetPhotoUseCase(this.repository);

  @override
  Future<Either<Failure, Photos>> execute(RequestPhoto? reqParams) async {
    return await repository.getPhoto(reqParams);
  }
}

class PhotoBloc {
  /// Input
  final Sink<String?> search;
  final Function0<void> dispose;
  final Function0<void> onLoadMore;
  final Function0<void> onRefresh;

  /// Output
  final Stream<PhotoState?> results$;

  factory PhotoCubit(final GetPhotoUseCase getPhoto) {
    final currentPage = BehaviorSubject<int>.seeded(1);
    final onLoadMore = BehaviorSubject<void>();
    final onRefresh = BehaviorSubject<void>();
    final textChangesS = BehaviorSubject<String>();
    final List<Hits> appendPhotos = [];

    final loadMore$ = onLoadMore.doOnData((event) {
      var nextPage = currentPage.value + 1;
      currentPage.add(nextPage);
    }).withLatestFrom(textChangesS, (_, s) => textChangesS.value);

    final refresh$ = onRefresh.doOnData((event) {
      currentPage.add(1);
    }).withLatestFrom(textChangesS, (_, s) => textChangesS.value);

    final search$ = textChangesS.doOnData((event) {
      currentPage.add(1);
    });

    final results = Rx.merge([refresh$, search$, loadMore$])
        .debounceTime(const Duration(milliseconds: 350))
        .switchMap((String keyword) {
      if (keyword.isEmpty) {
        return Stream.value(null);
      } else {
        return Stream.fromFuture(getPhoto
            .execute(RequestPhoto(query: keyword, page: currentPage.value)))
            .flatMap((either) =>
            either.fold((error) {
              return Stream<PhotoState?>.value(
                  PhotoError(error.message.toString()));
            }, (data) {
              FocusManager.instance.primaryFocus?.unfocus();
              if (currentPage.value == 1) {
                appendPhotos.clear();
              }
              appendPhotos.addAll(data.hits as List<Hits>);
              return Stream<PhotoState?>.value(PhotoLoaded(
                  data: appendPhotos,
                  currentPage: currentPage.value,
                  hasReachedMax: appendPhotos.length < data?.totalHits));
            }))
            .startWith(const PhotoLoading())
            .onErrorReturnWith(
                (error, _) => const PhotoError("Đã có lỗi xảy ra"));
      }
    });
    return PhotoBloc._(
      search: textChangesS.sink,
      onLoadMore: () => onLoadMore.add(null),
      onRefresh: () => onRefresh.add(null),
      results$: results,
      dispose: () {
        textChangesS.close();
        currentPage.close();
        onLoadMore.close();
        onRefresh.close();
      },
    );
  }

  PhotoBloc._({
    required this.search,
    required this.onRefresh,
    required this.onLoadMore,
    required this.results$,
    required this.dispose,
  });
}