TF-1362: [Data] Implement store and get LastTimeDismissedSpamReport in repository and datasource

This commit is contained in:
HuyNguyen
2023-01-07 00:52:29 +07:00
committed by Dat Vu
parent dadd7d005a
commit 6030aec159
19 changed files with 222 additions and 114 deletions
@@ -0,0 +1,2 @@
class NotFoundLastTimeDismissedSpamReportException implements Exception {}
@@ -0,0 +1,11 @@
import 'package:equatable/equatable.dart';
class SpamReport with EquatableMixin {
final DateTime lastTimeDismissedSpamReported;
SpamReport(this.lastTimeDismissedSpamReported);
@override
List<Object?> get props => [lastTimeDismissedSpamReported];
}
@@ -0,0 +1,7 @@
abstract class SpamReportRepository {
Future<void> storeLastTimeDismissedSpamReported(DateTime lastTimeDismissedSpamReported);
Future<DateTime> getLastTimeDismissedSpamReported();
Future<void> deleteLastTimeDismissedSpamReported();
}
@@ -0,0 +1,22 @@
import 'package:core/presentation/state/failure.dart';
import 'package:core/presentation/state/success.dart';
class GetLastTimeDismissedSpamReportedLoading extends UIState {}
class GetLastTimeDismissedSpamReportedSuccess extends UIState {
final DateTime lastTimeDismissedSpamReported;
GetLastTimeDismissedSpamReportedSuccess(this.lastTimeDismissedSpamReported);
@override
List<Object> get props => [];
}
class GetLastTimeDismissedSpamReportedFailure extends FeatureFailure {
final dynamic exception;
GetLastTimeDismissedSpamReportedFailure(this.exception);
@override
List<Object> get props => [exception];
}
@@ -0,0 +1,21 @@
import 'package:core/presentation/state/failure.dart';
import 'package:core/presentation/state/success.dart';
class StoreSpamReportLoading extends UIState {}
class StoreSpamReportSuccess extends UIState {
StoreSpamReportSuccess();
@override
List<Object> get props => [];
}
class StoreSpamReportFailure extends FeatureFailure {
final dynamic exception;
StoreSpamReportFailure(this.exception);
@override
List<Object> get props => [exception];
}
@@ -0,0 +1,22 @@
import 'package:core/presentation/state/failure.dart';
import 'package:core/presentation/state/success.dart';
import 'package:dartz/dartz.dart';
import 'package:tmail_ui_user/features/mailbox_dashboard/domain/repository/spam_report_repository.dart';
import 'package:tmail_ui_user/features/mailbox_dashboard/domain/state/get_last_time_dismissed_spam_reported_state.dart';
class GetSpamReportInteractor {
final SpamReportRepository _spamReportRepository;
GetSpamReportInteractor(this._spamReportRepository);
Stream<Either<Failure, Success>> execute() async* {
try {
yield Right<Failure, Success>(GetLastTimeDismissedSpamReportedLoading());
final _lastTimeDismissedSpamReported = await _spamReportRepository.getLastTimeDismissedSpamReported();
yield Right<Failure, Success>(GetLastTimeDismissedSpamReportedSuccess(_lastTimeDismissedSpamReported));
} catch (e) {
yield Left<Failure, Success>(GetLastTimeDismissedSpamReportedFailure(e));
}
}
}
@@ -0,0 +1,21 @@
import 'package:core/presentation/state/failure.dart';
import 'package:core/presentation/state/success.dart';
import 'package:dartz/dartz.dart';
import 'package:tmail_ui_user/features/mailbox_dashboard/domain/repository/spam_report_repository.dart';
import 'package:tmail_ui_user/features/mailbox_dashboard/domain/state/store_spam_report_state.dart';
class StoreSpamReportInteractor {
final SpamReportRepository _spamReportRepository;
StoreSpamReportInteractor(this._spamReportRepository);
Stream<Either<Failure, Success>> execute(DateTime lastTimeDismissedSpamReported) async* {
try {
yield Right<Failure, Success>(StoreSpamReportLoading());
await _spamReportRepository.storeLastTimeDismissedSpamReported(lastTimeDismissedSpamReported);
yield Right<Failure, Success>(StoreSpamReportSuccess());
} catch (e) {
yield Left<Failure, Success>(StoreSpamReportFailure(e));
}
}
}