TF-1810 Implement store detailed email to cache

(cherry picked from commit 6be6d69ad8e5fb05d839e2649b1f444613eea6d1)

lib/features/caching/utils/caching_constants.dart

@@ -1,6 +1,4 @@
 
-import 'package:tmail_ui_user/main/utils/app_constants.dart';
-
 class CachingConstants {
   static const int MAILBOX_CACHE_IDENTIFY = 1;
   static const int MAILBOX_RIGHTS_CACHE_IDENTIFY = 2;
@@ -22,9 +20,7 @@ class CachingConstants {
 
   static const String fcmCacheBoxName = 'fcm_cache_box';
   static const String detailedEmailCacheBoxName = 'detailed_email_cache_box';
+  static const String emailContentFolderName = 'email_content';
 
-  static const int maxNumberRecentEmails = 10;
+  static const int maxNumberNewEmailsForOffline = 10;
-
-  static const String appFolderName = AppConstants.applicationName;
-  static const String emailContentFolderName = 'EmailContent';
 }

lib/features/composer/presentation/composer_bindings.dart

@@ -46,6 +46,7 @@ import 'package:tmail_ui_user/features/manage_account/domain/usecases/get_all_id
 import 'package:tmail_ui_user/features/manage_account/presentation/profiles/identities/identity_interactors_bindings.dart';
 import 'package:tmail_ui_user/features/offline_mode/manager/detailed_email_cache_manager.dart';
 import 'package:tmail_ui_user/features/offline_mode/manager/detailed_email_cache_worker_queue.dart';
+import 'package:tmail_ui_user/features/thread/data/local/email_cache_manager.dart';
 import 'package:tmail_ui_user/features/upload/data/datasource/attachment_upload_datasource.dart';
 import 'package:tmail_ui_user/features/upload/data/datasource_impl/attachment_upload_datasource_impl.dart';
 import 'package:tmail_ui_user/features/upload/data/network/file_uploader.dart';
@@ -96,6 +97,7 @@ class ComposerBindings extends BaseBindings {
     Get.lazyPut(() => EmailHiveCacheDataSourceImpl(
       Get.find<DetailedEmailCacheManager>(),
       Get.find<DetailedEmailCacheWorkerQueue>(),
+      Get.find<EmailCacheManager>(),
       Get.find<FileUtils>(),
       Get.find<CacheExceptionThrower>()));
   }

lib/features/email/data/datasource/email_datasource.dart

@@ -74,7 +74,9 @@ abstract class EmailDataSource {
 
   Future<bool> deleteEmailPermanently(Session session, AccountId accountId, EmailId emailId);
 
-  Future<void> storeDetailedEmailToCache(Session session, AccountId accountId, DetailedEmail detailedEmail);
+  Future<void> storeDetailedEmail(Session session, AccountId accountId, DetailedEmail detailedEmail);
 
   Future<Email> getDetailedEmailById(Session session, AccountId accountId, EmailId emailId);
+
+  Future<void> storeEmail(Session session, AccountId accountId, Email email);
 }

lib/features/email/data/datasource_impl/email_datasource_impl.dart

@@ -151,7 +151,7 @@ class EmailDataSourceImpl extends EmailDataSource {
   }
 
   @override
-  Future<void> storeDetailedEmailToCache(Session session, AccountId accountId, DetailedEmail detailedEmail) {
+  Future<void> storeDetailedEmail(Session session, AccountId accountId, DetailedEmail detailedEmail) {
     throw UnimplementedError();
   }
 
@@ -161,4 +161,9 @@ class EmailDataSourceImpl extends EmailDataSource {
       return await emailAPI.getDetailedEmailById(session, accountId, emailId);
     }).catchError(_exceptionThrower.throwException);
   }
+
+  @override
+  Future<void> storeEmail(Session session, AccountId accountId, Email email) {
+    throw UnimplementedError();
+  }
 }

lib/features/email/data/datasource_impl/email_hive_cache_datasource_impl.dart

@@ -28,18 +28,22 @@ import 'package:tmail_ui_user/features/mailbox/domain/model/create_new_mailbox_r
 import 'package:tmail_ui_user/features/offline_mode/manager/detailed_email_cache_manager.dart';
 import 'package:tmail_ui_user/features/offline_mode/manager/detailed_email_cache_worker_queue.dart';
 import 'package:tmail_ui_user/features/offline_mode/worker/hive_task.dart';
+import 'package:tmail_ui_user/features/thread/data/extensions/email_extension.dart';
+import 'package:tmail_ui_user/features/thread/data/local/email_cache_manager.dart';
 import 'package:tmail_ui_user/main/exceptions/exception_thrower.dart';
 
 class EmailHiveCacheDataSourceImpl extends EmailDataSource {
 
-  final DetailedEmailCacheManager _emailCacheManager;
+  final DetailedEmailCacheManager _detailedEmailCacheManager;
   final DetailedEmailCacheWorkerQueue _cacheWorkerQueue;
+  final EmailCacheManager _emailCacheManager;
   final FileUtils _fileUtils;
   final ExceptionThrower _exceptionThrower;
 
   EmailHiveCacheDataSourceImpl(
-    this._emailCacheManager,
+    this._detailedEmailCacheManager,
     this._cacheWorkerQueue,
+    this._emailCacheManager,
     this._fileUtils,
     this._exceptionThrower
   );
@@ -105,7 +109,7 @@ class EmailHiveCacheDataSourceImpl extends EmailDataSource {
   }
 
   @override
-  Future<void> storeDetailedEmailToCache(Session session, AccountId accountId, DetailedEmail detailedEmail) {
+  Future<void> storeDetailedEmail(Session session, AccountId accountId, DetailedEmail detailedEmail) {
     return Future.sync(() async {
       final task = HiveTask(
         runnable: () async {
@@ -118,7 +122,7 @@ class EmailHiveCacheDataSourceImpl extends EmailDataSource {
           log('EmailHiveCacheDataSourceImpl::storeDetailedEmailToCache():fileSavedPath: ${fileSaved.path}');
           final detailedEmailSaved = detailedEmail.fromEmailContentPath(fileSaved.path);
 
-          final detailedEmailCache = await _emailCacheManager.handleStoreDetailedEmailToCache(
+          final detailedEmailCache = await _detailedEmailCacheManager.handleStoreDetailedEmail(
             accountId,
             session.username,
             detailedEmailSaved.toHiveCache());
@@ -138,4 +142,11 @@ class EmailHiveCacheDataSourceImpl extends EmailDataSource {
   Future<Email> getDetailedEmailById(Session session, AccountId accountId, EmailId emailId) {
     throw UnimplementedError();
   }
+
+  @override
+  Future<void> storeEmail(Session session, AccountId accountId, Email email) {
+    return Future.sync(() async {
+      return await _emailCacheManager.storeEmail(accountId, session.username, email.toEmailCache());
+    }).catchError(_exceptionThrower.throwException);
+  }
 }

lib/features/email/data/repository/email_repository_impl.dart

@@ -186,11 +186,16 @@ class EmailRepositoryImpl extends EmailRepository {
 
   @override
   Future<void> storeDetailedEmailToCache(Session session, AccountId accountId, DetailedEmail detailedEmail) {
-    return emailDataSource[DataSourceType.hiveCache]!.storeDetailedEmailToCache(session, accountId, detailedEmail);
+    return emailDataSource[DataSourceType.hiveCache]!.storeDetailedEmail(session, accountId, detailedEmail);
   }
 
   @override
   Future<Email> getDetailedEmailById(Session session, AccountId accountId, EmailId emailId) {
     return emailDataSource[DataSourceType.network]!.getDetailedEmailById(session, accountId, emailId);
   }
+
+  @override
+  Future<void> storeEmailToCache(Session session, AccountId accountId, Email email) {
+    return emailDataSource[DataSourceType.hiveCache]!.storeEmail(session, accountId, email);
+  }
 }

lib/features/email/domain/extensions/detailed_email_extension.dart

@@ -17,7 +17,7 @@ extension DetailedEmailExtension on DetailedEmail {
     );
   }
 
-  String get folderPath => '${CachingConstants.appFolderName}/${CachingConstants.emailContentFolderName}';
+  String get folderPath => CachingConstants.emailContentFolderName;
 
   DetailedEmail fromEmailContentPath(String path) {
     return DetailedEmail(

lib/features/email/domain/repository/email_repository.dart

@@ -91,4 +91,6 @@ abstract class EmailRepository {
   Future<void> storeDetailedEmailToCache(Session session, AccountId accountId, DetailedEmail detailedEmail);
 
   Future<Email> getDetailedEmailById(Session session, AccountId accountId, EmailId emailId);
+
+  Future<void> storeEmailToCache(Session session, AccountId accountId, Email email);
 }

lib/features/email/domain/state/get_detailed_email_by_id_state.dart

@@ -1,19 +1,23 @@
 import 'package:core/presentation/state/failure.dart';
 import 'package:core/presentation/state/success.dart';
-import 'package:model/email/presentation_email.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/mail/email/email.dart';
 import 'package:tmail_ui_user/features/email/domain/model/detailed_email.dart';
 
 class GetDetailedEmailByIdLoading extends UIState {}
 
 class GetDetailedEmailByIdSuccess extends UIState {
 
-  final PresentationEmail presentationEmail;
+  final Email email;
   final DetailedEmail detailedEmail;
+  final AccountId accountId;
+  final Session session;
 
-  GetDetailedEmailByIdSuccess(this.presentationEmail, this.detailedEmail);
+  GetDetailedEmailByIdSuccess(this.email, this.detailedEmail, this.accountId, this.session);
 
   @override
-  List<Object?> get props => [presentationEmail, detailedEmail];
+  List<Object?> get props => [email, detailedEmail, accountId, session];
 }
 
 class GetDetailedEmailByIdFailure extends FeatureFailure {

lib/features/email/domain/usecases/get_detailed_email_by_id_interator.dart

@@ -4,7 +4,6 @@ import 'package:dartz/dartz.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/mail/email/email.dart';
-import 'package:model/email/presentation_email.dart';
 import 'package:model/extensions/email_extension.dart';
 import 'package:model/extensions/list_attachment_extension.dart';
 import 'package:model/extensions/list_email_content_extension.dart';
@@ -31,13 +30,18 @@ class GetDetailedEmailByIdInteractor {
 
       final parsedEmail = await _parsingEmailToDetailedEmail(accountId, email, baseDownloadUrl);
 
-      yield Right<Failure, Success>(GetDetailedEmailByIdSuccess(parsedEmail.value1, parsedEmail.value2));
+      yield Right<Failure, Success>(GetDetailedEmailByIdSuccess(
+        parsedEmail.value1,
+        parsedEmail.value2,
+        accountId,
+        session,
+      ));
     } catch (e) {
       yield Left<Failure, Success>(GetDetailedEmailByIdFailure(e));
     }
   }
 
-  Future<Tuple2<PresentationEmail, DetailedEmail>> _parsingEmailToDetailedEmail(
+  Future<Tuple2<Email, DetailedEmail>> _parsingEmailToDetailedEmail(
     AccountId accountId,
     Email email,
     String? baseDownloadUrl
@@ -56,8 +60,7 @@ class GetDetailedEmailByIdInteractor {
     }
 
     final detailedEmail = email.toDetailedEmail(htmlEmailContent: htmlEmailContent);
-    final presentationEmail = email.toPresentationEmail();
 
-    return Tuple2(presentationEmail, detailedEmail);
+    return Tuple2(email, detailedEmail);
   }
 }

lib/features/email/domain/usecases/store_detailed_email_to_cache_interator.dart

@@ -3,6 +3,7 @@ import 'package:core/presentation/state/success.dart';
 import 'package:dartz/dartz.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/mail/email/email.dart';
 import 'package:tmail_ui_user/features/email/domain/model/detailed_email.dart';
 import 'package:tmail_ui_user/features/email/domain/repository/email_repository.dart';
 import 'package:tmail_ui_user/features/email/domain/state/store_detailed_email_to_cache_state.dart';
@@ -12,10 +13,18 @@ class StoreDetailedEmailToCacheInteractor {
 
   StoreDetailedEmailToCacheInteractor(this._emailRepository);
 
-  Stream<Either<Failure, Success>> execute(Session session, AccountId accountId, DetailedEmail detailedEmail) async* {
+  Stream<Either<Failure, Success>> execute(
+    Session session,
+    AccountId accountId,
+    Email email,
+    DetailedEmail detailedEmail
+  ) async* {
     try {
       yield Right<Failure, Success>(StoreDetailedEmailToCacheLoading());
-      await _emailRepository.storeDetailedEmailToCache(session, accountId, detailedEmail);
+      await Future.wait([
+        _emailRepository.storeEmailToCache(session, accountId, email),
+        _emailRepository.storeDetailedEmailToCache(session, accountId, detailedEmail),
+      ]);
       yield Right<Failure, Success>(StoreDetailedEmailToCacheSuccess());
     } catch (e) {
       yield Left<Failure, Success>(StoreDetailedEmailToCacheFailure(e));

lib/features/email/presentation/email_bindings.dart

@@ -44,6 +44,7 @@ import 'package:tmail_ui_user/features/manage_account/domain/usecases/get_all_id
 import 'package:tmail_ui_user/features/manage_account/presentation/profiles/identities/identity_interactors_bindings.dart';
 import 'package:tmail_ui_user/features/offline_mode/manager/detailed_email_cache_manager.dart';
 import 'package:tmail_ui_user/features/offline_mode/manager/detailed_email_cache_worker_queue.dart';
+import 'package:tmail_ui_user/features/thread/data/local/email_cache_manager.dart';
 import 'package:tmail_ui_user/main/exceptions/cache_exception_thrower.dart';
 import 'package:tmail_ui_user/main/exceptions/remote_exception_thrower.dart';
 
@@ -97,6 +98,7 @@ class EmailBindings extends BaseBindings {
     Get.lazyPut(() => EmailHiveCacheDataSourceImpl(
       Get.find<DetailedEmailCacheManager>(),
       Get.find<DetailedEmailCacheWorkerQueue>(),
+      Get.find<EmailCacheManager>(),
       Get.find<FileUtils>(),
       Get.find<CacheExceptionThrower>()));
   }

lib/features/mailbox_dashboard/presentation/bindings/mailbox_dashboard_bindings.dart

@@ -234,6 +234,7 @@ class MailboxDashBoardBindings extends BaseBindings {
     Get.lazyPut(() => EmailHiveCacheDataSourceImpl(
       Get.find<DetailedEmailCacheManager>(),
       Get.find<DetailedEmailCacheWorkerQueue>(),
+      Get.find<EmailCacheManager>(),
       Get.find<FileUtils>(),
       Get.find<CacheExceptionThrower>()));
   }

lib/features/offline_mode/manager/detailed_email_cache_manager.dart

@@ -15,16 +15,16 @@ class DetailedEmailCacheManager {
 
   DetailedEmailCacheManager(this._cacheClient);
 
-  Future<DetailedEmailHiveCache> handleStoreDetailedEmailToCache(
+  Future<DetailedEmailHiveCache> handleStoreDetailedEmail(
     AccountId accountId,
     UserName userName,
     DetailedEmailHiveCache detailedEmailCache
   ) async {
     final listDetailedEmails = await getAllDetailedEmails(accountId, userName);
 
-    if (listDetailedEmails.length >= CachingConstants.maxNumberRecentEmails) {
+    if (listDetailedEmails.length >= CachingConstants.maxNumberNewEmailsForOffline) {
       final latestEmail = listDetailedEmails.last;
-      log('DetailedEmailCacheManager::handleStoreDetailedEmailToCache():latestEmail: $latestEmail');
+      log('DetailedEmailCacheManager::handleStoreDetailedEmail():latestEmail: $latestEmail');
       await removeDetailedEmail(accountId, userName, latestEmail.emailId);
     }
     await insertDetailedEmail(accountId, userName, detailedEmailCache);
@@ -38,7 +38,7 @@ class DetailedEmailCacheManager {
     DetailedEmailHiveCache detailedEmailCache
   ) {
     final keyCache = TupleKey(detailedEmailCache.emailId, accountId.asString, userName.value).encodeKey;
-    log('DetailedEmailCacheManager::storeDetailedEmail(): $keyCache');
+    log('DetailedEmailCacheManager::insertDetailedEmail(): $keyCache');
     return _cacheClient.insertItem(keyCache, detailedEmailCache);
   }
 

lib/features/push_notification/domain/state/get_new_receive_email_from_notification_state.dart

@@ -9,7 +9,7 @@ class GetNewReceiveEmailFromNotificationLoading extends UIState {}
 
 class GetNewReceiveEmailFromNotificationSuccess extends UIState {
 
-  final List<EmailId> emailIds;
+  final Set<EmailId> emailIds;
   final AccountId accountId;
   final Session? session;
 

lib/features/push_notification/domain/usecases/get_new_receive_email_from_notification_interactor.dart

@@ -32,7 +32,7 @@ class GetNewReceiveEmailFromNotificationInteractor {
           accountId,
           currentState);
 
-        yield Right<Failure, Success>(GetNewReceiveEmailFromNotificationSuccess(accountId, session, listEmailIds));
+        yield Right<Failure, Success>(GetNewReceiveEmailFromNotificationSuccess(accountId, session, listEmailIds.toSet()));
       } else {
         yield Left<Failure, Success>(GetNewReceiveEmailFromNotificationFailure(EmailStateNoChangeException()));
       }

lib/features/push_notification/presentation/bindings/fcm_interactor_bindings.dart

@@ -14,6 +14,7 @@ import 'package:tmail_ui_user/features/email/data/network/email_api.dart';
 import 'package:tmail_ui_user/features/email/data/repository/email_repository_impl.dart';
 import 'package:tmail_ui_user/features/email/domain/repository/email_repository.dart';
 import 'package:tmail_ui_user/features/email/domain/usecases/get_detailed_email_by_id_interator.dart';
+import 'package:tmail_ui_user/features/email/domain/usecases/store_detailed_email_to_cache_interator.dart';
 import 'package:tmail_ui_user/features/mailbox/data/datasource/mailbox_datasource.dart';
 import 'package:tmail_ui_user/features/mailbox/data/datasource/state_datasource.dart';
 import 'package:tmail_ui_user/features/mailbox/data/datasource_impl/mailbox_cache_datasource_impl.dart';
@@ -49,6 +50,7 @@ import 'package:tmail_ui_user/features/push_notification/domain/usecases/store_m
 import 'package:tmail_ui_user/features/push_notification/domain/usecases/store_subscription_interator.dart';
 import 'package:tmail_ui_user/features/thread/data/datasource/thread_datasource.dart';
 import 'package:tmail_ui_user/features/thread/data/datasource_impl/thread_datasource_impl.dart';
+import 'package:tmail_ui_user/features/thread/data/local/email_cache_manager.dart';
 import 'package:tmail_ui_user/features/thread/data/network/thread_api.dart';
 import 'package:tmail_ui_user/features/thread/data/network/thread_isolate_worker.dart';
 import 'package:tmail_ui_user/main/exceptions/cache_exception_thrower.dart';
@@ -101,6 +103,7 @@ class FcmInteractorBindings extends InteractorsBindings {
     Get.lazyPut(() => EmailHiveCacheDataSourceImpl(
       Get.find<DetailedEmailCacheManager>(),
       Get.find<DetailedEmailCacheWorkerQueue>(),
+      Get.find<EmailCacheManager>(),
       Get.find<FileUtils>(),
       Get.find<CacheExceptionThrower>()));
   }
@@ -128,6 +131,7 @@ class FcmInteractorBindings extends InteractorsBindings {
       Get.find<FCMRepositoryImpl>(),
       Get.find<EmailRepository>()));
     Get.lazyPut(() => GetDetailedEmailByIdInteractor(Get.find<EmailRepository>()));
+    Get.lazyPut(() => StoreDetailedEmailToCacheInteractor(Get.find<EmailRepository>()));
   }
 
   @override

lib/features/push_notification/presentation/listener/email_change_listener.dart

@@ -24,6 +24,7 @@ import 'package:tmail_ui_user/features/email/domain/state/get_detailed_email_by_
 import 'package:tmail_ui_user/features/email/domain/state/get_stored_state_email_state.dart';
 import 'package:tmail_ui_user/features/email/domain/usecases/get_detailed_email_by_id_interator.dart';
 import 'package:tmail_ui_user/features/email/domain/usecases/get_stored_email_state_interactor.dart';
+import 'package:tmail_ui_user/features/email/domain/usecases/store_detailed_email_to_cache_interator.dart';
 import 'package:tmail_ui_user/features/email/presentation/action/email_ui_action.dart';
 import 'package:tmail_ui_user/features/mailbox_dashboard/presentation/controller/mailbox_dashboard_controller.dart';
 import 'package:tmail_ui_user/features/push_notification/domain/exceptions/fcm_exception.dart';
@@ -61,6 +62,7 @@ class EmailChangeListener extends ChangeListener {
   GetNewReceiveEmailFromNotificationInteractor? _getNewReceiveEmailFromNotificationInteractor;
   GetDetailedEmailByIdInteractor? _getDetailedEmailByIdInteractor;
   DynamicUrlInterceptors? _dynamicUrlInterceptors;
+  StoreDetailedEmailToCacheInteractor? _storeDetailedEmailToCacheInteractor;
 
   jmap.State? _newStateEmailDelivery;
   AccountId? _accountId;
@@ -81,6 +83,7 @@ class EmailChangeListener extends ChangeListener {
       _getNewReceiveEmailFromNotificationInteractor = getBinding<GetNewReceiveEmailFromNotificationInteractor>();
       _getDetailedEmailByIdInteractor = getBinding<GetDetailedEmailByIdInteractor>();
       _dynamicUrlInterceptors = getBinding<DynamicUrlInterceptors>();
+      _storeDetailedEmailToCacheInteractor = getBinding<StoreDetailedEmailToCacheInteractor>();
     } catch (e) {
       logError('EmailChangeListener::_internal(): IS NOT REGISTERED: ${e.toString()}');
     }
@@ -99,7 +102,9 @@ class EmailChangeListener extends ChangeListener {
           _handleRemoveNotificationWhenEmailMarkAsRead(action.newState, action.accountId, action.session);
         }
         _synchronizeEmailOnForegroundAction(action.newState);
-        _getNewReceiveEmailFromNotificationAction(action.session, action.accountId, action.newState);
+        if (!BuildUtils.isWeb) {
+          _getNewReceiveEmailFromNotificationAction(action.session, action.accountId, action.newState);
+        }
       } else if (action is PushNotificationAction) {
         _pushNotificationAction(action.newState, action.accountId, action.userName, action.session);
       } else if (action is StoreEmailStateToRefreshAction) {
@@ -240,7 +245,11 @@ class EmailChangeListener extends ChangeListener {
     } else if (success is GetNewReceiveEmailFromNotificationSuccess) {
       _handleGetNewReceiveEmailFromNotificationSuccess(success.session, success.accountId, success.emailIds);
     } else if (success is GetDetailedEmailByIdSuccess) {
-      _handleGetDetailedEmailByIdActionSuccess(success.presentationEmail, success.detailedEmail);
+      _handleGetDetailedEmailByIdActionSuccess(
+        success.session,
+        success.accountId,
+        success.email,
+        success.detailedEmail);
     }
   }
 
@@ -307,7 +316,7 @@ class EmailChangeListener extends ChangeListener {
     }
   }
 
-  void _handleGetNewReceiveEmailFromNotificationSuccess(Session? session, AccountId accountId, List<EmailId> emailIds) {
+  void _handleGetNewReceiveEmailFromNotificationSuccess(Session? session, AccountId accountId, Set<EmailId> emailIds) {
     log('EmailChangeListener::_handleGetNewReceiveEmailFromNotificationSuccess():emailIds: $emailIds');
     for (var emailId in emailIds) {
       _getDetailedEmailByIdAction(session, accountId, emailId);
@@ -328,7 +337,20 @@ class EmailChangeListener extends ChangeListener {
     }
   }
 
-  void _handleGetDetailedEmailByIdActionSuccess(PresentationEmail presentationEmail, DetailedEmail detailedEmail) {
+  void _handleGetDetailedEmailByIdActionSuccess(
-    log('EmailChangeListener::_handleGetDetailedEmailByIdActionSuccess():emailID: ${presentationEmail.id} | Content: ${detailedEmail.htmlEmailContent}');
+    Session session,
+    AccountId accountId,
+    Email email,
+    DetailedEmail detailedEmail
+  ) {
+    log('EmailChangeListener::_handleGetDetailedEmailByIdActionSuccess():emailId: ${email.id}');
+    if (_storeDetailedEmailToCacheInteractor != null) {
+      consumeState(_storeDetailedEmailToCacheInteractor!.execute(
+        session,
+        accountId,
+        email,
+        detailedEmail
+      ));
+    }
   }
 }

lib/features/thread/data/local/email_cache_manager.dart

@@ -5,6 +5,7 @@ import 'package:model/model.dart';
 import 'package:jmap_dart_client/jmap/mail/email/email.dart';
 import 'package:jmap_dart_client/jmap/mail/mailbox/mailbox.dart';
 import 'package:tmail_ui_user/features/caching/clients/email_cache_client.dart';
+import 'package:tmail_ui_user/features/caching/utils/cache_utils.dart';
 import 'package:tmail_ui_user/features/cleanup/domain/model/email_cleanup_rule.dart';
 import 'package:tmail_ui_user/features/thread/data/extensions/email_cache_extension.dart';
 import 'package:tmail_ui_user/features/thread/data/extensions/email_extension.dart';
@@ -12,6 +13,7 @@ import 'package:tmail_ui_user/features/thread/data/extensions/list_email_cache_e
 import 'package:tmail_ui_user/features/thread/data/extensions/list_email_extension.dart';
 import 'package:tmail_ui_user/features/thread/data/extensions/list_email_id_extension.dart';
 import 'package:jmap_dart_client/jmap/core/sort/comparator.dart';
+import 'package:tmail_ui_user/features/thread/data/model/email_cache.dart';
 import 'package:tmail_ui_user/features/thread/domain/model/filter_message_option.dart';
 
 class EmailCacheManager {
@@ -89,4 +91,9 @@ class EmailCacheManager {
       await _emailCacheClient.deleteMultipleItem(listEmailIdCacheExpire);
     }
   }
+
+  Future<void> storeEmail(AccountId accountId, UserName userName, EmailCache emailCache) {
+    final keyCache = TupleKey(emailCache.id, accountId.asString, userName.value).encodeKey;
+    return _emailCacheClient.insertItem(keyCache, emailCache);
+  }
 }

lib/main/utils/app_constants.dart

@@ -1,5 +1,4 @@
 
 class AppConstants {
   static const int limitCharToStartSearch = 3;
-  static const String applicationName = 'TeamMail';
 }