TF-3643 Thread Detail get emails meta data method

TF-3643 Thread Detail cache email with thread id TF-3643 Thread Detail view thread detail TF-3643 Thread Detail [Part 2 fixup] remove ThreadDetailController dependency from MailboxDashboardController TF-3643 Thread Detail [Part 2 fixup] remove EmailSupervisorController dependency from ThreadDetailController TF-3643 Thread Detail [Part 2 fixup] move isSearchRunning check into ThreadDetailController TF-3643 Thread Detail [Part 2 fixup] ensure GetEmailsByIdsInteractor performance TF-3643 Thread Detail [Part 2 fixup] unit test loadMoreThreadDetailEmails TF-3643 Thread Detail [Part 2 fixup] unit test getEmailIdsToLoad TF-3643 Thread Detail [Part 2 fixup] optimize ThreadDetailBinding bindingsDataSource TF-3643 Thread Detail [Part 2 fixup] optimize getThreadDetailLoadingView TF-3643 Thread Detail [Part 2 fixup] readd unique ValueKey for HtmlContentViewerOnWebWidget TF-3643 Thread Detail [Part 2 fixup] unit test initializeThreadDetailEmails TF-3643 Thread Detail [Part 3 fixup] Update private action button methods TF-3643 Thread Detail [Part 4 fixup] Collapsed email preview 65 characters max TF-3643 Thread Detail [Part 4 fixup] Remove personal scripts TF-3643 Thread Detail move EmailInThreadStatus into PresentationEmail TF-3643 Thread Detail refactor toggle collapse expand TF-3643 Thread Detail EmailViewAppBarWidget required parameters TF-3643 Thread Detail tap avatar toggle expansion TF-3643 Thread Detail fix cannot open single email TF-3643 Thread Detail fix open thread first time blank view TF-3643 Thread Detail fix thread detail UI TF-3643 Thread Detail fix round bottom view TF-3643 Thread Detail fix round bottom view TF-3643 Thread Detail bottom actions depend on current expanded email TF-3643 Thread Detail hide next previous actions TF-3643 Thread Detail fix load more show initial loading view TF-3643 Thread Detail fix cannot view single email TF-3643 Thread Detail fix bottom place holder not aligned TF-3643 Thread Detail fix back to search view TF-3643 Thread Detail fix display 65 character preview collapsed email TF-3643 Thread Detail fix search not work TF-3643 Thread Detail fix bottom place holder UI TF-3643 Thread Detail fix expand view TF-3643 Thread Detail jump to top of last email view TF-3643 Thread Detail remove toMe condition of filtering thread TF-3643 Thread Detail fix sort thread detail TF-3643 Thread Detail fix assert not work in release TF-3643 Thread Detail add load more test case <20 TF-3643 Thread Detail remove the use of currentThreadId TF-3643 Thread Detail remove the use of selectedEmail in SingleEmailController TF-3643 Thread Detail fix unit test SingleEmailController calendar TF-3643 Thread Detail disable 2 way scroll control TF-3643 Thread Detail allow thread to load sent email incase thread only contains 1 email TF-3643 Thread Detail disable single email page view TF-3643 Thread Detail update emailsNotLoadedCount name TF-3643 Thread Detail remove collapsed email char limit TF-3643 Thread Detail fix CI TF-3643 Thread Detail unit test handleGetEmailIdsByThreadIdSuccess TF-3643 Thread Detail make _currentEmailId private TF-3643 Thread Detail fix search click users TF-3643 Thread Detail fix scroll jump TF-3643 Thread Detail fix scroll jump TF-3643 Thread Detail fix web back action TF-3643 Thread Detail round bottom actions TF-3643 Thread Detail fix tablet large empty email TF-3643 Thread Detail fix email subject selectable TF-3643 Thread Detail fix email single view with top divider TF-3643 Thread Detail fix email cache threadId missing TF-3643 Thread Detail fix filter sent email in thread details TF-3643 Thread Detail fix select text TF-3643 Thread Detail fix subject alignment TF-3643 Thread Detail fix subject alignment TF-3643 Thread Detail fix tablet large empty email TF-3643 Thread Detail add nullcheck for _jumpScrollViewToTopOfEmail TF-3643 Thread Detail decouple ThreadDetailController from SingleEmailController TF-3643 Thread Detail combine emailIds to emailIdsPresentation TF-3643 Thread Detail remove currentEmailLoaded obx listener of SingleEmailController TF-3643 Thread Detail replace threadAction with an email ui action TF-3643 Thread Detail fix top and bottom bar delay displaying TF-3643 Thread Detail update ReplyForwardBottomBarAction to PerformEmailActionInThreadDetailAction TF-3643 Thread Detail use getOwnEmailAddress in ThreadDetailAppBar TF-3643 Thread Detail add TextOverflow.ellipsis to EmailSubjectWidget TF-3643 Thread Detail fix round border threadDetailLoadingView
2025-05-12 15:22:29 +07:00
parent 7c3af832e4
commit 58a576adeb
84 changed files with 2845 additions and 558 deletions
@@ -1,4 +1,6 @@
 import 'package:jmap_dart_client/jmap/account_id.dart';
+import 'package:jmap_dart_client/jmap/core/properties/properties.dart';
+import 'package:jmap_dart_client/jmap/core/session/session.dart';
 import 'package:jmap_dart_client/jmap/mail/email/email.dart';

 abstract class ThreadDetailDataSource {
@@ -6,4 +8,11 @@ abstract class ThreadDetailDataSource {
    ThreadId threadId,
    AccountId accountId,
  );
+
+  Future<List<Email>> getEmailsByIds(
+    Session session,
+    AccountId accountId,
+    List<EmailId> emailIds, {
+    Properties? properties,
+  });
 }
@@ -1,4 +1,6 @@
 import 'package:jmap_dart_client/jmap/account_id.dart';
+import 'package:jmap_dart_client/jmap/core/properties/properties.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/thread_detail/data/data_source/thread_detail_data_source.dart';
 import 'package:tmail_ui_user/features/thread_detail/data/network/thread_detail_api.dart';
@@ -22,4 +24,21 @@ class ThreadDetailRemoteDataSourceImpl implements ThreadDetailDataSource {
      return threadDetailApi.getThreadById(threadId, accountId);
    }).catchError(exceptionThrower.throwException);
  }
+
+  @override
+  Future<List<Email>> getEmailsByIds(
+    Session session,
+    AccountId accountId,
+    List<EmailId> emailIds, {
+    Properties? properties,
+  }) {
+    return Future.sync(() async {
+      return threadDetailApi.getEmailsByIds(
+        session,
+        accountId,
+        emailIds,
+        properties: properties,
+      );
+    }).catchError(exceptionThrower.throwException);
+  }
 }
@@ -1,10 +1,18 @@
+import 'package:core/presentation/extensions/list_extensions.dart';
 import 'package:get/get_utils/get_utils.dart';
 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/properties/properties.dart';
+import 'package:jmap_dart_client/jmap/core/session/session.dart';
 import 'package:jmap_dart_client/jmap/jmap_request.dart';
 import 'package:jmap_dart_client/jmap/mail/email/email.dart';
+import 'package:jmap_dart_client/jmap/mail/email/get/get_email_method.dart';
+import 'package:jmap_dart_client/jmap/mail/email/get/get_email_response.dart';
 import 'package:jmap_dart_client/jmap/thread/get/get_thread_method.dart';
 import 'package:jmap_dart_client/jmap/thread/get/get_thread_response.dart';
+import 'package:model/extensions/session_extension.dart';
+import 'package:tmail_ui_user/features/thread/domain/constants/thread_constants.dart';
+import 'package:tmail_ui_user/main/error/capability_validator.dart';

 class ThreadDetailApi {
  const ThreadDetailApi(this._httpClient);
@@ -34,4 +42,49 @@ class ThreadDetailApi {
      (thread) => thread.id == threadId,
    )!.emailIds;
  }
+
+  Future<List<Email>> getEmailsByIds(
+    Session session,
+    AccountId accountId,
+    List<EmailId> emailIds, {
+    Properties? properties,
+  }) async {
+    final jmapRequestBuilder = JmapRequestBuilder(
+      _httpClient,
+      ProcessingInvocation(),
+    );
+    final getLimit = session.getMaxObjectsInGet(accountId)
+      ?? ThreadConstants.defaultLimit;
+
+    final listOfListEmails = await Future.wait(
+      emailIds.chunks(getLimit.value.toInt()).map((chunkEmailIds) async {
+        final getEmailMethod = GetEmailMethod(accountId)
+          ..addIds(chunkEmailIds.map((emailId) => emailId.id).toSet());
+
+        if (properties != null) {
+          getEmailMethod.addProperties(properties);
+        }
+
+        final getEmailInvocation = jmapRequestBuilder.invocation(getEmailMethod);
+
+        final capabilities = getEmailMethod.requiredCapabilities
+          .toCapabilitiesSupportTeamMailboxes(session, accountId);
+
+        final result = await (jmapRequestBuilder
+            ..usings(capabilities))
+          .build()
+          .execute();
+
+        final resultList = result.parse<GetEmailResponse>(
+          getEmailInvocation.methodCallId,
+          GetEmailResponse.deserialize);
+
+        return resultList!.list;
+      })
+    );
+
+    return listOfListEmails.reduce(
+      (listAllEmails, nextListEmails) => listAllEmails..addAll(nextListEmails),
+    );
+  }
 }
@@ -1,7 +1,17 @@
 import 'package:core/data/model/source_type/data_source_type.dart';
+import 'package:core/presentation/extensions/list_extensions.dart';
 import 'package:jmap_dart_client/jmap/account_id.dart';
+import 'package:jmap_dart_client/jmap/core/properties/properties.dart';
+import 'package:jmap_dart_client/jmap/core/session/session.dart';
 import 'package:jmap_dart_client/jmap/mail/email/email.dart';
+import 'package:jmap_dart_client/jmap/mail/email/email_comparator.dart';
+import 'package:jmap_dart_client/jmap/mail/email/email_comparator_property.dart';
+import 'package:jmap_dart_client/jmap/mail/mailbox/mailbox.dart';
+import 'package:model/email/email_property.dart';
+import 'package:model/extensions/list_email_extension.dart';
+import 'package:tmail_ui_user/features/email/presentation/extensions/email_extension.dart';
 import 'package:tmail_ui_user/features/thread_detail/data/data_source/thread_detail_data_source.dart';
+import 'package:tmail_ui_user/features/thread_detail/domain/exceptions/empty_thread_detail_exception.dart';
 import 'package:tmail_ui_user/features/thread_detail/domain/repository/thread_detail_repository.dart';

 class ThreadDetailRepositoryImpl implements ThreadDetailRepository {
@@ -12,9 +22,100 @@ class ThreadDetailRepositoryImpl implements ThreadDetailRepository {
  @override
  Future<List<EmailId>> getThreadById(
    ThreadId threadId,
-    AccountId accountId
-  ) {
-    return threadDetailDataSource[DataSourceType.network]!
+    Session session,
+    AccountId accountId,
+    MailboxId sentMailboxId,
+    String ownEmailAddress,
+  ) async {
+    final originalEmailIds = await threadDetailDataSource[DataSourceType.network]!
      .getThreadById(threadId, accountId);
+
+    if (originalEmailIds.isEmpty) {
+      throw EmptyThreadDetailException();
+    }
+    
+    final filteredEmailIds = await Future.wait(
+      originalEmailIds
+        .chunks(20)
+        .map((emailIds) => _filterBadEmails(
+          session,
+          accountId,
+          emailIds,
+          sentMailboxId,
+          ownEmailAddress,
+        ))
+    );
+
+    return filteredEmailIds
+      .reduce((prev, curr) => prev + curr)
+      .sortWithResult(EmailComparator(
+        EmailComparatorProperty.receivedAt
+      )..setIsAscending(true))
+      .map((e) => e.id!)
+      .toList();
+  }
+
+  Future<List<Email>> _filterBadEmails(
+    Session session,
+    AccountId accountId,
+    List<EmailId> emailIds,
+    MailboxId sentMailboxId,
+    String ownEmailAddress,
+  ) async {
+    int retry = 3;
+    while (retry > 0) {
+      try {
+        final emails = await threadDetailDataSource[DataSourceType.network]!
+          .getEmailsByIds(
+            session,
+            accountId,
+            emailIds,
+            properties: Properties({
+              EmailProperty.id,
+              EmailProperty.mailboxIds,
+              EmailProperty.from,
+              EmailProperty.to,
+              EmailProperty.cc,
+              EmailProperty.bcc,
+              EmailProperty.receivedAt,
+            }),
+          );
+        return emails
+          .where((email) => checkEmailValidForThreadDetail(
+            email,
+            sentMailboxId,
+            ownEmailAddress,
+          ))
+          .toList();
+      } catch (e) {
+        retry--;
+
+        if (retry <= 0) rethrow;
+      }
+    }
+    return [];
+  }
+
+  bool checkEmailValidForThreadDetail(
+    Email email,
+    MailboxId sentMailboxId,
+    String ownEmailAddress,
+  ) {
+    return email.id != null && (
+      !email.inSentMailbox(sentMailboxId)
+      || !email.fromMe(ownEmailAddress)
+      || !email.recipientsHasMe(ownEmailAddress)
+    );
+  }
+
+  @override
+  Future<List<Email>> getEmailsByIds(
+    Session session,
+    AccountId accountId,
+    List<EmailId> emailIds, {
+    Properties? properties,
+  }) {
+    return threadDetailDataSource[DataSourceType.network]!
+      .getEmailsByIds(session, accountId, emailIds, properties: properties);
  }
 }