TF-1362: [Domain] Get unreadSpamEmail in Usecase

lib/features/mailbox_dashboard/data/datasource/spam_report_datasource.dart

@@ -1,7 +1,20 @@
+import 'package:jmap_dart_client/jmap/account_id.dart';
+import 'package:jmap_dart_client/jmap/core/unsigned_int.dart';
+import 'package:jmap_dart_client/jmap/mail/mailbox/mailbox_filter_condition.dart';
+import 'package:tmail_ui_user/features/mailbox_dashboard/domain/model/unread_spam_emails_response.dart';
+
 abstract class SpamReportDataSource {
-  Future<void> storeLastTimeDismissedSpamReported(DateTime lastTimeDismissedSpamReported);
+  Future<bool> storeLastTimeDismissedSpamReported(DateTime lastTimeDismissedSpamReported);
 
   Future<DateTime> getLastTimeDismissedSpamReported();
 
-  Future<void> deleteLastTimeDismissedSpamReported();
+  Future<bool> deleteLastTimeDismissedSpamReported();
+
+  Future<UnreadSpamEmailsResponse> findNumberOfUnreadSpamEmails(
+    AccountId accountId,
+    {
+      MailboxFilterCondition? mailboxFilterCondition,
+      UnsignedInt? limit
+    }
+  );
 }

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

@@ -1,16 +1,20 @@
+import 'package:jmap_dart_client/jmap/account_id.dart';
+import 'package:jmap_dart_client/jmap/core/unsigned_int.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/spam_report_cache_manager.dart';
+import 'package:tmail_ui_user/features/mailbox_dashboard/data/local/share_preference_spam_report_data_source.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 LocalSpamReportDataSourceImpl extends SpamReportDataSource {
-  final SpamReportCacheManager _spamReportCacheManager;
+  final SharePreferenceSpamReportDataSource _sharePreferenceSpamReportDataSource;
   final ExceptionThrower _exceptionThrower;
 
-  LocalSpamReportDataSourceImpl(this._spamReportCacheManager, this._exceptionThrower);
+  LocalSpamReportDataSourceImpl(this._sharePreferenceSpamReportDataSource, this._exceptionThrower);
   @override
   Future<DateTime> getLastTimeDismissedSpamReported() async {
     return Future.sync(() async {
-      return await _spamReportCacheManager.getlastTimeDismissedSpamReported();
+      return await _sharePreferenceSpamReportDataSource.getLastTimeDismissedSpamReported();
     }).catchError((error) {
       _exceptionThrower.throwException(error);
     });
@@ -19,7 +23,7 @@ class LocalSpamReportDataSourceImpl extends SpamReportDataSource {
   @override
   Future<bool> storeLastTimeDismissedSpamReported(DateTime lastTimeDismissedSpamReported) async {
     return Future.sync(() async {
-      return await _spamReportCacheManager.storelastTimeDismissedSpamReported(lastTimeDismissedSpamReported);
+      return await _sharePreferenceSpamReportDataSource.storeLastTimeDismissedSpamReported(lastTimeDismissedSpamReported);
     }).catchError((error) {
       _exceptionThrower.throwException(error);
     });
@@ -28,9 +32,20 @@ class LocalSpamReportDataSourceImpl extends SpamReportDataSource {
   @override
   Future<bool> deleteLastTimeDismissedSpamReported() {
     return Future.sync(() async {
-      return await _spamReportCacheManager.deleteLastTimeDismissedSpamReported();
+      return await _sharePreferenceSpamReportDataSource.deleteLastTimeDismissedSpamReported();
     }).catchError((error) {
       _exceptionThrower.throwException(error);
     });
   }
+
+  @override
+  Future<UnreadSpamEmailsResponse> findNumberOfUnreadSpamEmails(
+    AccountId accountId,
+    {
+      MailboxFilterCondition? mailboxFilterCondition,
+      UnsignedInt? limit
+    }
+  ) {
+    throw UnimplementedError();
+  }
 }

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

@@ -0,0 +1,48 @@
+
+import 'package:jmap_dart_client/jmap/account_id.dart';
+import 'package:jmap_dart_client/jmap/core/unsigned_int.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';
+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 SpamReportDataSourceImpl extends SpamReportDataSource {
+  final SpamReportApi _spamReportApi;
+  final ExceptionThrower _exceptionThrower;
+
+  SpamReportDataSourceImpl(this._spamReportApi, this._exceptionThrower);
+
+  @override
+  Future<bool> deleteLastTimeDismissedSpamReported() {
+    throw UnimplementedError();
+  }
+
+  @override
+  Future<UnreadSpamEmailsResponse> findNumberOfUnreadSpamEmails(
+    AccountId accountId,
+    {
+      MailboxFilterCondition? mailboxFilterCondition,
+      UnsignedInt? limit
+    }
+  ) {
+     return Future.sync(() async {
+      final _unreadSpamEmailsResponse = await _spamReportApi.findNumberOfUnreadSpamEmails(
+        accountId, mailboxFilterCondition: mailboxFilterCondition, limit: limit);
+      return _unreadSpamEmailsResponse;
+    }).catchError((error) {
+      _exceptionThrower.throwException(error);
+    });
+  }
+
+  @override
+  Future<DateTime> getLastTimeDismissedSpamReported() {
+    throw UnimplementedError();
+  }
+
+  @override
+  Future<bool> storeLastTimeDismissedSpamReported(DateTime lastTimeDismissedSpamReported) {
+    throw UnimplementedError();
+  }
+
+}

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

@@ -0,0 +1,42 @@
+import 'package:jmap_dart_client/jmap/account_id.dart';
+import 'package:jmap_dart_client/jmap/core/unsigned_int.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';
+import 'package:tmail_ui_user/features/mailbox_dashboard/domain/model/unread_spam_emails_response.dart';
+import 'package:tmail_ui_user/features/mailbox_dashboard/utils/mailbox_dashboard_constant.dart';
+
+class SharePreferenceSpamReportDataSource extends SpamReportDataSource {
+  final SharedPreferences _sharedPreferences;
+
+  SharePreferenceSpamReportDataSource(this._sharedPreferences);
+
+  @override
+  Future<DateTime> getLastTimeDismissedSpamReported() async {
+    final _timeStamp = _sharedPreferences.getInt(MailboxDashboardConstant.keyLastTimeDismissedSpamReported) ?? 0;
+    final _lastTimeDismissedSpamReported =  DateTime.fromMillisecondsSinceEpoch(_timeStamp);
+    return _lastTimeDismissedSpamReported;
+  }
+  
+  @override
+  Future<bool> storeLastTimeDismissedSpamReported(DateTime lastTimeDismissedSpamReported) async {
+    final _timeStamp = lastTimeDismissedSpamReported.microsecondsSinceEpoch;
+    return await _sharedPreferences.setInt(MailboxDashboardConstant.keyLastTimeDismissedSpamReported,_timeStamp);
+  }
+
+  @override
+  Future<bool> deleteLastTimeDismissedSpamReported() async {
+    return await _sharedPreferences.remove(MailboxDashboardConstant.keyLastTimeDismissedSpamReported);
+  }
+
+  @override
+  Future<UnreadSpamEmailsResponse> findNumberOfUnreadSpamEmails(
+    AccountId accountId,
+    {
+      MailboxFilterCondition? mailboxFilterCondition,
+      UnsignedInt? limit
+    }
+  ) {
+    throw UnimplementedError();
+  }
+}

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

@@ -1,23 +0,0 @@
-import 'package:shared_preferences/shared_preferences.dart';
-import 'package:tmail_ui_user/features/mailbox_dashboard/utils/mailbox_dashboard_constant.dart';
-
-class SpamReportCacheManager {
-  final SharedPreferences _sharedPreferences;
-
-  SpamReportCacheManager(this._sharedPreferences);
-
-  Future<DateTime> getlastTimeDismissedSpamReported() async {
-    final _timeStamp = _sharedPreferences.getInt(MailboxDashboardConstant.keyLastTimeDismissedSpamReported) ?? 0;
-    final _lastTimeDismissedSpamReported =  DateTime.fromMillisecondsSinceEpoch(_timeStamp);
-    return _lastTimeDismissedSpamReported;
-  }
-
-  Future<bool> storelastTimeDismissedSpamReported(DateTime lastTimeDismissedSpamReported) async {
-   final _timeStamp = lastTimeDismissedSpamReported.microsecondsSinceEpoch;
-   return await _sharedPreferences.setInt(MailboxDashboardConstant.keyLastTimeDismissedSpamReported,_timeStamp);
-  }
-
-  Future<bool> deleteLastTimeDismissedSpamReported() async {
-   return await _sharedPreferences.remove(MailboxDashboardConstant.keyLastTimeDismissedSpamReported);
-  }
-}

lib/features/mailbox_dashboard/data/network/spam_report_api.dart

@@ -0,0 +1,54 @@
+
+import 'package:jmap_dart_client/http/http_client.dart';
+import 'package:jmap_dart_client/jmap/account_id.dart';
+import 'package:jmap_dart_client/jmap/core/request/reference_path.dart';
+import 'package:jmap_dart_client/jmap/core/unsigned_int.dart';
+import 'package:jmap_dart_client/jmap/jmap_request.dart';
+import 'package:jmap_dart_client/jmap/mail/mailbox/get/get_mailbox_method.dart';
+import 'package:jmap_dart_client/jmap/mail/mailbox/get/get_mailbox_response.dart';
+import 'package:jmap_dart_client/jmap/mail/mailbox/mailbox_filter_condition.dart';
+import 'package:jmap_dart_client/jmap/mail/mailbox/query/query_mailbox_method.dart';
+import 'package:tmail_ui_user/features/mailbox_dashboard/domain/model/unread_spam_emails_response.dart';
+
+class SpamReportApi {
+  final HttpClient _httpClient;
+
+  SpamReportApi(this._httpClient);
+
+  Future<UnreadSpamEmailsResponse> findNumberOfUnreadSpamEmails(
+    AccountId accountId,
+    {
+      MailboxFilterCondition? mailboxFilterCondition,
+      UnsignedInt? limit
+    }
+  ) async {
+    final processingInvocation = ProcessingInvocation();
+    final requestBuilder = JmapRequestBuilder(_httpClient, processingInvocation);
+
+    final spamReportQueryMethod = QueryMailboxMethod(accountId)..addLimit(limit ?? UnsignedInt(1));
+
+    final spamReportQueryMethodInvocation = requestBuilder.invocation(spamReportQueryMethod);
+
+    final getMailBoxMethod = GetMailboxMethod(accountId)
+        ..addReferenceIds(processingInvocation.createResultReference(
+          spamReportQueryMethodInvocation.methodCallId,
+          ReferencePath.idsPath,
+        ));
+    final getMailboxInvocation = requestBuilder.invocation(getMailBoxMethod);
+    final result = await (requestBuilder
+            ..usings(getMailBoxMethod.requiredCapabilities))
+          .build()
+          .execute();
+
+    final _mailboxResponse = result
+        .parse<GetMailboxResponse>(getMailboxInvocation.methodCallId, GetMailboxResponse.deserialize);
+    
+    final _unreadSpamEmailNumber = _mailboxResponse?.list.first.unreadEmails?.value.value.toInt();
+
+     return Future.sync(() async {
+      return UnreadSpamEmailsResponse(unreadSpamEmailNumber: _unreadSpamEmailNumber);
+    }).catchError((error) {
+      throw error;
+    });
+  }
+}

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

@@ -1,8 +1,12 @@
 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/unsigned_int.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/unread_spam_emails_response.dart';
 import 'package:tmail_ui_user/features/mailbox_dashboard/domain/repository/spam_report_repository.dart';
 
-class SpamReportRepositoryImpl extends StoreLastTimeDismissedSpamReportInteractor {
+class SpamReportRepositoryImpl extends SpamReportRepository {
   final Map<DataSourceType, SpamReportDataSource> mapDataSource;
 
   SpamReportRepositoryImpl(this.mapDataSource);
@@ -21,4 +25,16 @@ class SpamReportRepositoryImpl extends StoreLastTimeDismissedSpamReportInteracto
   Future<void> deleteLastTimeDismissedSpamReported() {
     return mapDataSource[DataSourceType.local]!.deleteLastTimeDismissedSpamReported();
   }
+
+  @override
+  Future<UnreadSpamEmailsResponse> findNumberOfUnreadSpamEmails(
+    AccountId accountId,
+    {
+      MailboxFilterCondition? mailboxFilterCondition,
+      UnsignedInt? limit
+    }
+  ) {
+    return mapDataSource[DataSourceType.network]!.findNumberOfUnreadSpamEmails(
+      accountId, mailboxFilterCondition: mailboxFilterCondition, limit: limit);
+  }
 }