TF-1362: [Domain] Store and Get lastTimeDismissedSpamRepirt in UseCase

This commit is contained in:
HuyNguyen
2023-01-06 23:57:23 +07:00
committed by Dat Vu
parent 39cea0c079
commit dadd7d005a
6 changed files with 114 additions and 6 deletions
+23 -6
View File
@@ -1,6 +1,23 @@
FIREBASE_ANDROID_API_KEY=example
FIREBASE_ANDROID_APP_ID=example
FIREBASE_ANDROID_MESSAGING_SENDER_ID=example
FIREBASE_ANDROID_PROJECT_ID=example
FIREBASE_ANDROID_DATABASE_URL=https://example.com
FIREBASE_ANDROID_STORAGE_BUCKET=example.com
FIREBASE_ANDROID_API_KEY=AIzaSyDPn3T4BMShrcedtqzA-8Lh3Fsm1EGB7S8
FIREBASE_ANDROID_APP_ID=1:611786135906:android:6fa64d94eb8f8603e3743b
FIREBASE_ANDROID_MESSAGING_SENDER_ID=611786135906
FIREBASE_ANDROID_PROJECT_ID=fir-jmap-poc
FIREBASE_ANDROID_DATABASE_URL=https://fir-jmap-poc-default-rtdb.asia-southeast1.firebasedatabase.app
FIREBASE_ANDROID_STORAGE_BUCKET=fir-jmap-poc.appspot.com
FIREBASE_IOS_API_KEY=AIzaSyA_fAC-6rVLsQtj8AXxRRYjwsOHCKPTm6w
FIREBASE_IOS_APP_ID=1:611786135906:ios:d8b0899dc058dd2ae3743b
FIREBASE_IOS_MESSAGING_SENDER_ID=611786135906
FIREBASE_IOS_PROJECT_ID=fir-jmap-poc
FIREBASE_IOS_DATABASE_URL=https://fir-jmap-poc-default-rtdb.asia-southeast1.firebasedatabase.app
FIREBASE_IOS_STORAGE_BUCKET=fir-jmap-poc.appspot.com
FIREBASE_IOS_CLIENT_ID=611786135906-2nqn5c537eer6c95rcujmlfmldbkqfqb.apps.googleusercontent.com
FIREBASE_IOS_BUNDLE_ID=com.linagora.ios.teammail
FIREBASE_WEB_API_KEY=AIzaSyABpxntIXA2u_uFFMT4wvHYMgVm7UZPMrM
FIREBASE_WEB_APP_ID=1:611786135906:web:22d98cfd47b4fddde3743b
FIREBASE_WEB_MESSAGING_SENDER_ID=611786135906
FIREBASE_WEB_PROJECT_ID=fir-jmap-poc
FIREBASE_WEB_DATABASE_URL=https://fir-jmap-poc-default-rtdb.asia-southeast1.firebasedatabase.app
FIREBASE_WEB_STORAGE_BUCKET=fir-jmap-poc.appspot.com
FIREBASE_WEB_AUTH_DOMAIN=fir-jmap-poc.firebaseapp.com
@@ -54,4 +54,8 @@ abstract class ThreadRepository {
);
Future<PresentationEmail> getEmailById(AccountId accountId, EmailId emailId, {Properties? properties});
Future<void> storelastTimeDismissedSpamReport(DateTime lastTimeDismissedSpamReport);
Future<DateTime> getlastTimeDismissedSpamReport();
}
@@ -0,0 +1,22 @@
import 'package:core/presentation/state/failure.dart';
import 'package:core/presentation/state/success.dart';
class GetLastTimeDismissedSpamReportLoading extends UIState {}
class GetLastTimeDismissedSpamReportSuccess extends UIState {
final DateTime lastTimeDismissedSpamReport;
GetLastTimeDismissedSpamReportSuccess(this.lastTimeDismissedSpamReport);
@override
List<Object> get props => [];
}
class GetLastTimeDismissedSpamReportFailure extends FeatureFailure {
final dynamic exception;
GetLastTimeDismissedSpamReportFailure(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 StoreLastTimeDismissedSpamReportLoading extends UIState {}
class StoreLastTimeDismissedSpamReportSuccess extends UIState {
StoreLastTimeDismissedSpamReportSuccess();
@override
List<Object> get props => [];
}
class StoreLastTimeDismissedSpamReportFailure extends FeatureFailure {
final dynamic exception;
StoreLastTimeDismissedSpamReportFailure(this.exception);
@override
List<Object> get props => [exception];
}
@@ -0,0 +1,23 @@
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/thread/domain/repository/thread_repository.dart';
import 'package:tmail_ui_user/features/thread/domain/state/get_last_time_dismissed_spam_reported_state.dart';
class GetLastTimeDismissedSpamReportInteractor {
final ThreadRepository _threadRepository;
GetLastTimeDismissedSpamReportInteractor(this._threadRepository);
Stream<Either<Failure, Success>> execute(
DateTime lastTimeDismissedSpamReport) async* {
try {
yield Right<Failure, Success>(GetLastTimeDismissedSpamReportLoading());
final lastTimeDismissedSpamReport = await _threadRepository.getlastTimeDismissedSpamReport();
yield Right<Failure, Success>(
GetLastTimeDismissedSpamReportSuccess(lastTimeDismissedSpamReport));
} catch (e) {
yield Left<Failure, Success>(GetLastTimeDismissedSpamReportFailure(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/thread/domain/repository/thread_repository.dart';
import 'package:tmail_ui_user/features/thread/domain/state/store_last_time_dismissed_spam_report_state.dart';
class StoreLastTimeDismissedSpamReportInteractor {
final ThreadRepository _threadRepository;
StoreLastTimeDismissedSpamReportInteractor(this._threadRepository);
Stream<Either<Failure, Success>> execute(DateTime lastTimeDismissedSpamReport) async* {
try {
yield Right<Failure, Success>(StoreLastTimeDismissedSpamReportLoading());
await _threadRepository.storelastTimeDismissedSpamReport(lastTimeDismissedSpamReport);
yield Right<Failure, Success>(StoreLastTimeDismissedSpamReportSuccess());
} catch (e) {
yield Left<Failure, Success>(StoreLastTimeDismissedSpamReportFailure(e));
}
}
}