TF-3804 Thread Detail Load selected email in parallel

lib/features/email/presentation/action/email_ui_action.dart

@@ -1,5 +1,6 @@
 
 import 'package:jmap_dart_client/jmap/core/state.dart' as jmap;
+import 'package:jmap_dart_client/jmap/mail/email/email.dart';
 import 'package:model/email/email_action_type.dart';
 import 'package:model/email/presentation_email.dart';
 import 'package:tmail_ui_user/features/base/action/ui_action.dart';
@@ -58,4 +59,13 @@ class RefreshThreadDetailAction extends EmailUIAction {
 
   @override
   List<Object?> get props => [emailChangeResponse];
+}
+
+class DisposePreviousExpandedEmailAction extends EmailUIAction {
+  DisposePreviousExpandedEmailAction(this.emailId);
+
+  final EmailId emailId;
+
+  @override
+  List<Object?> get props => [emailId];
 }

lib/features/email/presentation/controller/single_email_controller.dart

@@ -125,6 +125,7 @@ import 'package:tmail_ui_user/features/manage_account/domain/usecases/create_new
 import 'package:tmail_ui_user/features/manage_account/domain/usecases/get_all_identities_interactor.dart';
 import 'package:tmail_ui_user/features/manage_account/presentation/extensions/datetime_extension.dart';
 import 'package:tmail_ui_user/features/search/email/presentation/search_email_controller.dart';
+import 'package:tmail_ui_user/features/thread_detail/presentation/action/thread_detail_ui_action.dart';
 import 'package:tmail_ui_user/features/thread_detail/presentation/extension/close_thread_detail_action.dart';
 import 'package:tmail_ui_user/features/thread_detail/presentation/extension/focus_thread_detail_expanded_email.dart';
 import 'package:tmail_ui_user/features/thread_detail/presentation/extension/mark_collapsed_email_unread_success.dart';
@@ -399,6 +400,12 @@ class SingleEmailController extends BaseController with AppLoaderMixin {
           action.emailActionType,
           action.presentationEmail,
         );
+      } else if (action is DisposePreviousExpandedEmailAction) {
+        if (_currentEmailId == null || _currentEmailId != action.emailId) return;
+        for (var worker in obxListeners) {
+          worker.dispose();
+        }
+        Get.delete<SingleEmailController>(tag: action.emailId.id.value);
       } else if (action is CloseEmailInThreadDetailAction) {
         if (_currentEmailId == null) return;
         closeEmailView(context: currentContext);
@@ -664,6 +671,13 @@ class SingleEmailController extends BaseController with AppLoaderMixin {
         emailUnsubscribe.value = null;
       }
     }
+    if (currentEmail?.threadId != null) {
+      mailboxDashBoardController.dispatchThreadDetailUIAction(
+        LoadThreadDetailAfterSelectedEmailAction(
+          currentEmail!.threadId!,
+        )
+      );
+    }
   }
 
   void _getEmailContentSuccess(GetEmailContentSuccess success) {
@@ -729,6 +743,13 @@ class SingleEmailController extends BaseController with AppLoaderMixin {
     if ((_threadDetailController?.emailIdsPresentation.keys.length ?? 0) > 1 == true) {
       _jumpScrollViewToTopOfEmail();
     }
+    if (currentEmail?.threadId != null) {
+      mailboxDashBoardController.dispatchThreadDetailUIAction(
+        LoadThreadDetailAfterSelectedEmailAction(
+          currentEmail!.threadId!,
+        )
+      );
+    }
   }
 
   void _jumpScrollViewToTopOfEmail() {

lib/features/thread_detail/domain/state/get_emails_by_ids_state.dart

@@ -24,6 +24,10 @@ class GetEmailsByIdsSuccess extends UIState {
   List<Object?> get props => [presentationEmails, updateCurrentThreadDetail];
 }
 
+class PreloadEmailsByIdsSuccess extends GetEmailsByIdsSuccess {
+  PreloadEmailsByIdsSuccess(super.presentationEmails);
+}
+
 class GetEmailsByIdsFailure extends FeatureFailure {
   GetEmailsByIdsFailure({
     super.exception,

lib/features/thread_detail/domain/state/get_thread_by_id_state.dart

@@ -21,6 +21,10 @@ class GetThreadByIdSuccess extends UIState {
   List<Object> get props => [emailIds, updateCurrentThreadDetail];
 }
 
+class PreloadEmailIdsInThreadSuccess extends GetThreadByIdSuccess {
+  PreloadEmailIdsInThreadSuccess(super.emailIds);
+}
+
 class GetThreadByIdFailure extends FeatureFailure {
   GetThreadByIdFailure({
     super.exception,

lib/features/thread_detail/presentation/action/thread_detail_ui_action.dart

@@ -38,4 +38,13 @@ class EmailMovedAction extends ThreadDetailUIAction {
 
   @override
   List<Object?> get props => [emailId, originalMailboxId, targetMailboxId];
+}
+
+class LoadThreadDetailAfterSelectedEmailAction extends ThreadDetailUIAction {
+  LoadThreadDetailAfterSelectedEmailAction(this.threadId);
+
+  final ThreadId threadId;
+
+  @override
+  List<Object?> get props => [threadId];
 }

lib/features/thread_detail/presentation/extension/handle_get_email_ids_by_thread_id_success.dart

@@ -1,36 +1,34 @@
-import 'package:jmap_dart_client/jmap/mail/email/email.dart';
 import 'package:tmail_ui_user/features/thread_detail/domain/state/get_thread_by_id_state.dart';
 import 'package:tmail_ui_user/features/thread_detail/presentation/thread_detail_controller.dart';
 
 extension HandleGetEmailIdsByThreadIdSuccess on ThreadDetailController {
   void handleGetEmailIdsByThreadIdSuccess(
     GetThreadByIdSuccess success,
   ) {
-    final newEmailsInThreadDetail = <EmailId>[];
-    if (success.emailIds.isNotEmpty) {
-      if (success.updateCurrentThreadDetail) {
-        newEmailsInThreadDetail.addAll(success
-          .emailIds
-          .where(
-            (emailId) => !emailIdsPresentation.keys.contains(emailId),
-          )
+    if (success.emailIds.isEmpty) {
+      return;
+    }
+
+    final allEmailIds = success.emailIds;
+    if (success.updateCurrentThreadDetail) {
+      final newEmailIds = allEmailIds.where(
+        (emailId) => !emailIdsPresentation.keys.contains(emailId),
+      );
+      emailIdsPresentation
+        ..removeWhere((key, _) => !allEmailIds.contains(key))
+        ..addEntries(
+          newEmailIds.map((emailId) => MapEntry(emailId, null)),
         );
-        emailIdsPresentation
-          ..removeWhere(
-            (key, value) => !success.emailIds.contains(key),
-          )
-          ..addAll(Map.fromEntries(
-            newEmailsInThreadDetail.map((emailId) => MapEntry(emailId, null)),
-          ));
-      } else {
-        emailIdsPresentation.value = Map.fromEntries(success.emailIds.map(
-          (emailId) => MapEntry(emailId, null),
-        ));
-      }
-    } else if (mailboxDashBoardController.selectedEmail.value?.id != null) {
-      emailIdsPresentation.value = {
-        mailboxDashBoardController.selectedEmail.value!.id!: null,
-      };
+      return;
     }
+
+    final selectedEmail = mailboxDashBoardController.selectedEmail.value;
+    final selectedEmailId = selectedEmail?.id;
+    emailIdsPresentation.value = {
+      for (final id in allEmailIds)
+        id: id == selectedEmailId
+            ? emailIdsPresentation[id] ?? selectedEmail
+            : null,
+    };
   }
 }

lib/features/thread_detail/presentation/extension/handle_get_emails_by_ids_success.dart

@@ -38,7 +38,7 @@ extension HandleGetEmailsByIdsSuccess on ThreadDetailController {
       );
     }
 
-    if (!isLoadMore) return;
+    if (_skipScrollJump(isLoadMore)) return;
 
     final currentExpandedEmailIndex = currentExpandedEmailId.value == null
       ? -1
@@ -72,4 +72,7 @@ extension HandleGetEmailsByIdsSuccess on ThreadDetailController {
       });
     }
   }
+
+  bool _skipScrollJump(bool isLoadMore) =>
+      !isLoadMore || emailIdsPresentation.length == 1;
 }

lib/features/thread_detail/presentation/extension/initialize_thread_detail_emails.dart

@@ -9,17 +9,13 @@ import 'package:tmail_ui_user/features/thread_detail/presentation/utils/thread_d
 
 extension InitializeThreadDetailEmails on ThreadDetailController {
   void initializeThreadDetailEmails(GetThreadByIdSuccess success) {
-    final threadDetailEnabled = isThreadDetailEnabled;
-    final selectedEmail = mailboxDashBoardController.selectedEmail.value;
-    if (!threadDetailEnabled &&
-        selectedEmail != null &&
-        !success.updateCurrentThreadDetail) {
-      consumeState(Stream.value(Right(GetEmailsByIdsSuccess([selectedEmail]))));
-      return;
-    }
+    final selectedEmailId = mailboxDashBoardController.selectedEmail.value?.id;
+    if (skipLoadThreadMetaData(
+      selectedEmailId: selectedEmailId,
+      updateCurrentThreadDetail: success.updateCurrentThreadDetail,
+    )) return;
 
     final existingEmailIds = emailIdsPresentation.keys.toList();
-    final selectedEmailId = mailboxDashBoardController.selectedEmail.value?.id;
 
     List<EmailId> emailIdsToLoadMetaData = [];
     if (success.updateCurrentThreadDetail) {
@@ -36,6 +32,7 @@ extension InitializeThreadDetailEmails on ThreadDetailController {
         existingEmailIds,
         selectedEmailId: selectedEmailId,
       );
+      emailIdsToLoadMetaData.remove(selectedEmailId);
     }
 
     if (accountId == null || session == null) {
@@ -45,6 +42,8 @@ extension InitializeThreadDetailEmails on ThreadDetailController {
       ))));
       return;
     }
+    if (_currentThreadOnlyContainsSelectedEmail(selectedEmailId)) return;
+
     consumeState(getEmailsByIdsInteractor.execute(
       session!,
       accountId!,
@@ -56,4 +55,18 @@ extension InitializeThreadDetailEmails on ThreadDetailController {
       updateCurrentThreadDetail: success.updateCurrentThreadDetail,
     ));
   }
+
+  bool _currentThreadOnlyContainsSelectedEmail(EmailId? selectedEmailId) {
+    return selectedEmailId != null &&
+        emailIdsPresentation.length == 1 &&
+        emailIdsPresentation.keys.contains(selectedEmailId);
+  }
+
+  bool skipLoadThreadMetaData({
+    EmailId? selectedEmailId,
+    bool updateCurrentThreadDetail = false,
+  }) {
+    return selectedEmailId == null ||
+        (!isThreadDetailEnabled && !updateCurrentThreadDetail);
+  }
 }

lib/features/thread_detail/presentation/extension/thread_detail_on_selected_email_updated.dart

@@ -0,0 +1,39 @@
+import 'package:dartz/dartz.dart';
+import 'package:flutter/widgets.dart';
+import 'package:model/email/presentation_email.dart';
+import 'package:tmail_ui_user/features/email/presentation/action/email_ui_action.dart';
+import 'package:tmail_ui_user/features/thread_detail/domain/state/get_emails_by_ids_state.dart';
+import 'package:tmail_ui_user/features/thread_detail/domain/state/get_thread_by_id_state.dart';
+import 'package:tmail_ui_user/features/thread_detail/domain/usecases/get_thread_by_id_interactor.dart';
+import 'package:tmail_ui_user/features/thread_detail/presentation/extension/close_thread_detail_action.dart';
+import 'package:tmail_ui_user/features/thread_detail/presentation/thread_detail_controller.dart';
+
+extension ThreadDetailOnSelectedEmailUpdated on ThreadDetailController {
+  void onSelectedEmailUpdated(
+    PresentationEmail? selectedEmail,
+    GetThreadByIdInteractor getThreadByIdInteractor,
+    BuildContext? context,
+  ) {
+    if (selectedEmail?.id == null) {
+      closeThreadDetailAction(context);
+      return;
+    }
+
+    if (currentExpandedEmailId.value != null) {
+      mailboxDashBoardController.dispatchEmailUIAction(
+        DisposePreviousExpandedEmailAction(
+          currentExpandedEmailId.value!,
+        ),
+      );
+    }
+
+    _preloadSelectedEmail(selectedEmail!);
+  }
+
+  void _preloadSelectedEmail(PresentationEmail selectedEmail) {
+    consumeState(Stream.fromIterable([
+      Right(PreloadEmailIdsInThreadSuccess([selectedEmail.id!])),
+      Right(PreloadEmailsByIdsSuccess([selectedEmail])),
+    ]));
+  }
+}

lib/features/thread_detail/presentation/thread_detail_controller.dart

@@ -41,14 +41,14 @@ import 'package:tmail_ui_user/features/thread_detail/domain/usecases/get_thread_
 import 'package:tmail_ui_user/features/thread_detail/domain/usecases/get_emails_by_ids_interactor.dart';
 import 'package:tmail_ui_user/features/thread_detail/presentation/action/thread_detail_ui_action.dart';
 import 'package:tmail_ui_user/features/thread_detail/domain/usecases/get_thread_detail_status_interactor.dart';
-import 'package:tmail_ui_user/features/thread_detail/presentation/extension/close_thread_detail_action.dart';
 import 'package:tmail_ui_user/features/thread_detail/presentation/extension/handle_email_moved_action.dart';
 import 'package:tmail_ui_user/features/thread_detail/presentation/extension/handle_get_email_ids_by_thread_id_success.dart';
 import 'package:tmail_ui_user/features/thread_detail/presentation/extension/handle_get_emails_by_ids_success.dart';
 import 'package:tmail_ui_user/features/thread_detail/presentation/extension/handle_get_thread_by_id_failure.dart';
 import 'package:tmail_ui_user/features/thread_detail/presentation/extension/handle_refresh_thread_detail_action.dart';
 import 'package:tmail_ui_user/features/thread_detail/presentation/extension/initialize_thread_detail_emails.dart';
 import 'package:tmail_ui_user/features/thread_detail/presentation/extension/refresh_thread_detail_on_setting_changed.dart';
+import 'package:tmail_ui_user/features/thread_detail/presentation/extension/thread_detail_on_selected_email_updated.dart';
 import 'package:tmail_ui_user/features/thread_detail/presentation/model/thread_detail_setting_status.dart';
 import 'package:tmail_ui_user/main/localizations/app_localizations.dart';
 import 'package:tmail_ui_user/main/routes/route_navigation.dart';
@@ -146,32 +146,11 @@ class ThreadDetailController extends BaseController {
     });
     downloadProgressState.stream.listen(handleDownloadProgressState);
     ever(mailboxDashBoardController.selectedEmail, (presentationEmail) async {
-      if (presentationEmail?.threadId == null) {
-        closeThreadDetailAction(currentContext);
-        return;
-      }
-
-      if (!isThreadDetailEnabled && presentationEmail?.id != null) {
-        consumeState(Stream.value(Right(GetThreadByIdSuccess([
-          presentationEmail!.id!,
-        ]))));
-        return;
-      }
-
-      if (session != null &&
-          accountId != null &&
-          sentMailboxId != null &&
-          ownEmailAddress != null) {
-        scrollController = ScrollController();
-        consumeState(_getEmailIdsByThreadIdInteractor.execute(
-          presentationEmail!.threadId!,
-          session!,
-          accountId!,
-          sentMailboxId!,
-          ownEmailAddress!,
-          selectedEmailId: presentationEmail.id,
-        ));
-      }
+      onSelectedEmailUpdated(
+        presentationEmail,
+        _getEmailIdsByThreadIdInteractor,
+        currentContext,
+      );
     });
     ever(mailboxDashBoardController.threadDetailUIAction, (action) {
       if (action is UpdatedEmailKeywordsAction) {
@@ -191,6 +170,24 @@ class ThreadDetailController extends BaseController {
         consumeState(_getThreadDetailStatusInteractor.execute());
       } else if (action is EmailMovedAction) {
         handleEmailMovedAction(action);
+      } else if (action is LoadThreadDetailAfterSelectedEmailAction) {
+        if (mailboxDashBoardController.selectedEmail.value?.threadId != null &&
+            action.threadId == mailboxDashBoardController.selectedEmail.value?.threadId &&
+            session != null &&
+            accountId != null &&
+            sentMailboxId != null &&
+            ownEmailAddress != null &&
+            isThreadDetailEnabled) {
+          scrollController = ScrollController();
+          consumeState(_getEmailIdsByThreadIdInteractor.execute(
+            action.threadId,
+            session!,
+            accountId!,
+            sentMailboxId!,
+            ownEmailAddress!,
+            selectedEmailId: mailboxDashBoardController.selectedEmail.value?.id,
+          ));
+        }
       }
       // Reset [threadDetailUIAction] to original value
       mailboxDashBoardController.dispatchThreadDetailUIAction(

lib/features/thread_detail/presentation/thread_detail_view.dart

@@ -164,6 +164,7 @@ class ThreadDetailView extends GetWidget<ThreadDetailController> {
 
     return Obx(() {
       if (showLoadingView(controller.viewState.value) &&
+          controller.emailIdsPresentation.isEmpty &&
           controller.responsiveUtils.isTabletLarge(context)) {
         return controller.getThreadDetailLoadingView(
           isResponsiveDesktop: false,