TF-1667 Implement GetSpamMailboxCached interactor

(cherry picked from commit ffe62c58aa46526ea34536bac17862b5c16aa9ac)

lib/features/mailbox_dashboard/data/datasource_impl/share_preference_spam_report_data_source_impl.dart

@@ -1,6 +1,7 @@
 import 'package:jmap_dart_client/jmap/account_id.dart';
 import 'package:jmap_dart_client/jmap/core/session/session.dart';
 import 'package:jmap_dart_client/jmap/core/unsigned_int.dart';
+import 'package:jmap_dart_client/jmap/mail/mailbox/mailbox.dart';
 import 'package:jmap_dart_client/jmap/mail/mailbox/mailbox_filter_condition.dart';
 import 'package:tmail_ui_user/features/mailbox_dashboard/data/datasource/spam_report_datasource.dart';
 import 'package:tmail_ui_user/features/mailbox_dashboard/data/local/share_preference_spam_report_data_source.dart';
@@ -13,6 +14,7 @@ class SharePreferenceSpamReportDataSourceImpl extends SpamReportDataSource {
   final ExceptionThrower _exceptionThrower;
 
   SharePreferenceSpamReportDataSourceImpl(this._sharePreferenceSpamReportDataSource, this._exceptionThrower);
+
   @override
   Future<DateTime> getLastTimeDismissedSpamReported() async {
     return Future.sync(() async {
@@ -66,4 +68,9 @@ class SharePreferenceSpamReportDataSourceImpl extends SpamReportDataSource {
       return await _sharePreferenceSpamReportDataSource.storeSpamReportState(spamReportState);
     }).catchError(_exceptionThrower.throwException);
   }
+
+  @override
+  Future<Mailbox> getSpamMailboxCached() {
+    throw UnimplementedError();
+  }
 }

lib/features/mailbox_dashboard/data/datasource_impl/spam_report_cache_datasource_impl.dart

@@ -0,0 +1,60 @@
+
+import 'package:jmap_dart_client/jmap/account_id.dart';
+import 'package:jmap_dart_client/jmap/core/session/session.dart';
+import 'package:jmap_dart_client/jmap/core/unsigned_int.dart';
+import 'package:jmap_dart_client/jmap/mail/mailbox/mailbox.dart';
+import 'package:jmap_dart_client/jmap/mail/mailbox/mailbox_filter_condition.dart';
+import 'package:tmail_ui_user/features/mailbox/data/local/mailbox_cache_manager.dart';
+import 'package:tmail_ui_user/features/mailbox_dashboard/data/datasource/spam_report_datasource.dart';
+import 'package:tmail_ui_user/features/mailbox_dashboard/domain/model/spam_report_state.dart';
+import 'package:tmail_ui_user/features/mailbox_dashboard/domain/model/unread_spam_emails_response.dart';
+import 'package:tmail_ui_user/main/exceptions/exception_thrower.dart';
+
+class SpamReportCacheDataSourceImpl extends SpamReportDataSource {
+  final MailboxCacheManager _mailboxCacheManager;
+  final ExceptionThrower _exceptionThrower;
+
+  SpamReportCacheDataSourceImpl(this._mailboxCacheManager, this._exceptionThrower);
+
+  @override
+  Future<bool> deleteLastTimeDismissedSpamReported() {
+    throw UnimplementedError();
+  }
+
+  @override
+  Future<void> deleteSpamReportState() {
+    throw UnimplementedError();
+  }
+
+  @override
+  Future<UnreadSpamEmailsResponse> findNumberOfUnreadSpamEmails(Session session, AccountId accountId, {MailboxFilterCondition? mailboxFilterCondition, UnsignedInt? limit}) {
+    throw UnimplementedError();
+  }
+
+  @override
+  Future<DateTime> getLastTimeDismissedSpamReported() {
+    throw UnimplementedError();
+  }
+
+  @override
+  Future<Mailbox> getSpamMailboxCached() {
+    return Future.sync(() async {
+      return await _mailboxCacheManager.getSpamMailbox();
+    }).catchError(_exceptionThrower.throwException);
+  }
+
+  @override
+  Future<SpamReportState> getSpamReportState() {
+    throw UnimplementedError();
+  }
+
+  @override
+  Future<bool> storeLastTimeDismissedSpamReported(DateTime lastTimeDismissedSpamReported) {
+    throw UnimplementedError();
+  }
+
+  @override
+  Future<void> storeSpamReportState(SpamReportState spamReportState) {
+    throw UnimplementedError();
+  }
+}

lib/features/mailbox_dashboard/data/datasource_impl/spam_report_datasource_impl.dart

@@ -2,6 +2,7 @@
 import 'package:jmap_dart_client/jmap/account_id.dart';
 import 'package:jmap_dart_client/jmap/core/session/session.dart';
 import 'package:jmap_dart_client/jmap/core/unsigned_int.dart';
+import 'package:jmap_dart_client/jmap/mail/mailbox/mailbox.dart';
 import 'package:jmap_dart_client/jmap/mail/mailbox/mailbox_filter_condition.dart';
 import 'package:tmail_ui_user/features/mailbox_dashboard/data/datasource/spam_report_datasource.dart';
 import 'package:tmail_ui_user/features/mailbox_dashboard/data/network/spam_report_api.dart';
@@ -64,4 +65,8 @@ class SpamReportDataSourceImpl extends SpamReportDataSource {
     throw UnimplementedError();
   }
 
+  @override
+  Future<Mailbox> getSpamMailboxCached() {
+    throw UnimplementedError();
+  }
 }

lib/features/mailbox_dashboard/data/local/share_preference_spam_report_data_source.dart

@@ -1,6 +1,7 @@
 import 'package:jmap_dart_client/jmap/account_id.dart';
 import 'package:jmap_dart_client/jmap/core/session/session.dart';
 import 'package:jmap_dart_client/jmap/core/unsigned_int.dart';
+import 'package:jmap_dart_client/jmap/mail/mailbox/mailbox.dart';
 import 'package:jmap_dart_client/jmap/mail/mailbox/mailbox_filter_condition.dart';
 import 'package:shared_preferences/shared_preferences.dart';
 import 'package:tmail_ui_user/features/mailbox_dashboard/data/datasource/spam_report_datasource.dart';
@@ -59,4 +60,9 @@ class SharePreferenceSpamReportDataSource extends SpamReportDataSource {
     final spamReportState0 = spamReportState.keyValue;
     return await _sharedPreferences.setString(MailboxDashboardConstant.keySpamReportState, spamReportState0);
   }
+
+  @override
+  Future<Mailbox> getSpamMailboxCached() {
+    throw UnimplementedError();
+  }
 }

lib/features/mailbox_dashboard/data/repository/spam_report_repository_impl.dart

@@ -2,6 +2,7 @@ import 'package:core/data/model/source_type/data_source_type.dart';
 import 'package:jmap_dart_client/jmap/account_id.dart';
 import 'package:jmap_dart_client/jmap/core/session/session.dart';
 import 'package:jmap_dart_client/jmap/core/unsigned_int.dart';
+import 'package:jmap_dart_client/jmap/mail/mailbox/mailbox.dart';
 import 'package:jmap_dart_client/jmap/mail/mailbox/mailbox_filter_condition.dart';
 import 'package:tmail_ui_user/features/mailbox_dashboard/data/datasource/spam_report_datasource.dart';
 import 'package:tmail_ui_user/features/mailbox_dashboard/domain/model/spam_report_state.dart';
@@ -58,4 +59,9 @@ class SpamReportRepositoryImpl extends SpamReportRepository {
   Future<void> deleteSpamReportState() {
     return mapDataSource[DataSourceType.local]!.deleteSpamReportState();
   }
+
+  @override
+  Future<Mailbox> getSpamMailboxCached() {
+    return mapDataSource[DataSourceType.cache]!.getSpamMailboxCached();
+  }
 }

lib/features/mailbox_dashboard/domain/state/get_spam_mailbox_cached_state.dart

@@ -0,0 +1,23 @@
+import 'package:core/presentation/state/failure.dart';
+import 'package:core/presentation/state/success.dart';
+import 'package:jmap_dart_client/jmap/mail/mailbox/mailbox.dart';
+
+class GetSpamMailboxCachedLoading extends UIState {}
+
+class GetSpamMailboxCachedSuccess extends UIState {
+
+  final Mailbox spamMailbox;
+
+  GetSpamMailboxCachedSuccess(this.spamMailbox);
+
+  @override
+  List<Object> get props => [spamMailbox];
+}
+
+class GetSpamMailboxCachedFailure extends FeatureFailure {
+
+  GetSpamMailboxCachedFailure(exception) : super(exception: exception);
+
+  @override
+  List<Object?> get props => [exception];
+}

lib/features/mailbox_dashboard/domain/usecases/get_spam_mailbox_cached_interactor.dart

@@ -0,0 +1,38 @@
+
+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_number_of_unread_spam_emails_state.dart';
+import 'package:tmail_ui_user/features/mailbox_dashboard/domain/state/get_spam_mailbox_cached_state.dart';
+import 'package:tmail_ui_user/features/mailbox_dashboard/utils/mailbox_dashboard_constant.dart';
+
+class GetSpamMailboxCachedInteractor {
+  final SpamReportRepository _spamReportRepository;
+
+  GetSpamMailboxCachedInteractor(this._spamReportRepository);
+
+   Stream<Either<Failure, Success>> execute() async* {
+    try {
+      yield Right<Failure, Success>(GetSpamMailboxCachedLoading());
+
+      final lastTimeDismissedSpamReported = await _spamReportRepository.getLastTimeDismissedSpamReported();
+      final timeLast = DateTime.now().difference(lastTimeDismissedSpamReported);
+      final checkTimeCondition = timeLast.inHours > MailboxDashboardConstant.spamReportBannerDisplayTimeOut;
+
+      if (checkTimeCondition) {
+        final spamMailbox =  await _spamReportRepository.getSpamMailboxCached();
+        final countUnreadSpamMailbox = spamMailbox.unreadEmails?.value.value.toInt() ?? 0;
+        if (countUnreadSpamMailbox > 0) {
+          yield Right<Failure, Success>(GetSpamMailboxCachedSuccess(spamMailbox));
+        } else {
+          yield Left<Failure, Success>(InvalidSpamReportCondition());
+        }
+      } else {
+        yield Left<Failure, Success>(InvalidSpamReportCondition());
+      }
+    } catch (e) {
+      yield Left<Failure, Success>(GetSpamMailboxCachedFailure(e));
+    }
+  }
+}

lib/features/mailbox_dashboard/utils/mailbox_dashboard_constant.dart

@@ -1,5 +1,6 @@
+
 class MailboxDashboardConstant {
   static const String keyLastTimeDismissedSpamReported = 'KEY_LAST_TIME_DISMISSED_SPAM_REPORTED';
-  
   static const String keySpamReportState = 'KEY_SPAM_REPORT_STATE';
+  static const int spamReportBannerDisplayTimeOut = 4;
 }