TF-1810 Add GetDetailedEmailByIdInteractor to get detailed email

(cherry picked from commit 765cebec00ae26458fe7f5e17ec6026f82f1fd0f)

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

@@ -75,4 +75,6 @@ abstract class EmailDataSource {
   Future<bool> deleteEmailPermanently(Session session, AccountId accountId, EmailId emailId);
 
   Future<void> storeDetailedEmailToCache(Session session, AccountId accountId, DetailedEmail detailedEmail);
+
+  Future<Email> getDetailedEmailById(Session session, AccountId accountId, EmailId emailId);
 }

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

@@ -154,4 +154,11 @@ class EmailDataSourceImpl extends EmailDataSource {
   Future<void> storeDetailedEmailToCache(Session session, AccountId accountId, DetailedEmail detailedEmail) {
     throw UnimplementedError();
   }
+
+  @override
+  Future<Email> getDetailedEmailById(Session session, AccountId accountId, EmailId emailId) {
+    return Future.sync(() async {
+      return await emailAPI.getDetailedEmailById(session, accountId, emailId);
+    }).catchError(_exceptionThrower.throwException);
+  }
 }

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

@@ -133,4 +133,9 @@ class EmailHiveCacheDataSourceImpl extends EmailDataSource {
   Future<Email> updateEmailDrafts(Session session, AccountId accountId, Email newEmail) {
     throw UnimplementedError();
   }
+
+  @override
+  Future<Email> getDetailedEmailById(Session session, AccountId accountId, EmailId emailId) {
+    throw UnimplementedError();
+  }
 }

lib/features/email/data/network/email_api.dart

@@ -40,7 +40,6 @@ import 'package:model/account/account_request.dart';
 import 'package:model/account/authentication_type.dart';
 import 'package:model/download/download_task_id.dart';
 import 'package:model/email/attachment.dart';
-import 'package:model/email/email_property.dart';
 import 'package:model/email/mark_star_action.dart';
 import 'package:model/email/read_actions.dart';
 import 'package:model/extensions/email_extension.dart';
@@ -54,10 +53,12 @@ import 'package:path_provider/path_provider.dart';
 import 'package:tmail_ui_user/features/base/mixin/handle_error_mixin.dart';
 import 'package:tmail_ui_user/features/composer/domain/exceptions/set_email_method_exception.dart';
 import 'package:tmail_ui_user/features/composer/domain/model/email_request.dart';
+import 'package:tmail_ui_user/features/email/domain/exceptions/email_exceptions.dart';
 import 'package:tmail_ui_user/features/email/domain/model/move_to_mailbox_request.dart';
 import 'package:tmail_ui_user/features/email/domain/state/download_attachment_for_web_state.dart';
 import 'package:tmail_ui_user/features/login/domain/exceptions/authentication_exception.dart';
 import 'package:tmail_ui_user/features/mailbox/domain/model/create_new_mailbox_request.dart';
+import 'package:tmail_ui_user/features/thread/domain/constants/thread_constants.dart';
 import 'package:tmail_ui_user/main/error/capability_validator.dart';
 import 'package:uuid/uuid.dart';
 
@@ -77,14 +78,7 @@ class EmailAPI with HandleSetErrorMixin {
 
     final getEmailMethod = GetEmailMethod(accountId)
       ..addIds({emailId.id})
-      ..addProperties(Properties({
+      ..addProperties(ThreadConstants.propertiesGetEmailContent)
-        EmailProperty.bodyValues,
-        EmailProperty.htmlBody,
-        EmailProperty.attachments,
-        EmailProperty.headers,
-        EmailProperty.keywords,
-        EmailProperty.mailboxIds,
-      }))
       ..addFetchHTMLBodyValues(true);
 
     final getEmailInvocation = jmapRequestBuilder.invocation(getEmailMethod);
@@ -633,4 +627,32 @@ class EmailAPI with HandleSetErrorMixin {
 
     return setEmailResponse?.destroyed?.contains(emailId.id) == true;
   }
+
+  Future<Email> getDetailedEmailById(Session session, AccountId accountId, EmailId emailId) async {
+    final jmapRequestBuilder = JmapRequestBuilder(_httpClient, ProcessingInvocation());
+
+    final getEmailMethod = GetEmailMethod(accountId)
+      ..addIds({emailId.id})
+      ..addProperties(ThreadConstants.propertiesGetDetailedEmail)
+      ..addFetchHTMLBodyValues(true);
+
+    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);
+
+    if (resultList?.list.isNotEmpty == true) {
+      return resultList!.list.first;
+    } else {
+      throw NotFoundEmailException();
+    }
+  }
 }

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

@@ -188,4 +188,9 @@ class EmailRepositoryImpl extends EmailRepository {
   Future<void> storeDetailedEmailToCache(Session session, AccountId accountId, DetailedEmail detailedEmail) {
     return emailDataSource[DataSourceType.hiveCache]!.storeDetailedEmailToCache(session, accountId, detailedEmail);
   }
+
+  @override
+  Future<Email> getDetailedEmailById(Session session, AccountId accountId, EmailId emailId) {
+    return emailDataSource[DataSourceType.network]!.getDetailedEmailById(session, accountId, emailId);
+  }
 }

lib/features/email/domain/exceptions/email_exceptions.dart

@@ -1,2 +1,4 @@
 
 class CannotDeleteOldEmailException implements Exception {}
+
+class NotFoundEmailException implements Exception {}

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

@@ -0,0 +1,15 @@
+
+import 'package:jmap_dart_client/jmap/mail/email/email.dart';
+import 'package:model/extensions/email_extension.dart';
+import 'package:tmail_ui_user/features/email/domain/model/detailed_email.dart';
+
+extension EmailExtension on Email {
+  DetailedEmail toDetailedEmail({String? htmlEmailContent}) {
+    return DetailedEmail(
+      emailId: id!,
+      attachments: allAttachments,
+      headers: headers?.toList(),
+      htmlEmailContent: htmlEmailContent
+    );
+  }
+}

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

@@ -89,4 +89,6 @@ abstract class EmailRepository {
   Future<jmap.State?> getEmailState(Session session, AccountId accountId);
 
   Future<void> storeDetailedEmailToCache(Session session, AccountId accountId, DetailedEmail detailedEmail);
+
+  Future<Email> getDetailedEmailById(Session session, AccountId accountId, EmailId emailId);
 }

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

@@ -0,0 +1,25 @@
+import 'package:core/presentation/state/failure.dart';
+import 'package:core/presentation/state/success.dart';
+import 'package:model/email/presentation_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 DetailedEmail detailedEmail;
+
+  GetDetailedEmailByIdSuccess(this.presentationEmail, this.detailedEmail);
+
+  @override
+  List<Object?> get props => [presentationEmail, detailedEmail];
+}
+
+class GetDetailedEmailByIdFailure extends FeatureFailure {
+
+  GetDetailedEmailByIdFailure(dynamic exception) : super(exception: exception);
+
+  @override
+  List<Object?> get props => [exception];
+}

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

@@ -0,0 +1,63 @@
+import 'package:core/presentation/state/failure.dart';
+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: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';
+import 'package:tmail_ui_user/features/email/domain/extensions/email_extension.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/get_detailed_email_by_id_state.dart';
+
+class GetDetailedEmailByIdInteractor {
+  final EmailRepository _emailRepository;
+
+  GetDetailedEmailByIdInteractor(this._emailRepository);
+
+  Stream<Either<Failure, Success>> execute(
+    Session session,
+    AccountId accountId,
+    EmailId emailId,
+    String? baseDownloadUrl
+  ) async* {
+    try {
+      yield Right<Failure, Success>(GetDetailedEmailByIdLoading());
+
+      final email = await _emailRepository.getDetailedEmailById(session, accountId, emailId);
+
+      final parsedEmail = await _parsingEmailToDetailedEmail(accountId, email, baseDownloadUrl);
+
+      yield Right<Failure, Success>(GetDetailedEmailByIdSuccess(parsedEmail.value1, parsedEmail.value2));
+    } catch (e) {
+      yield Left<Failure, Success>(GetDetailedEmailByIdFailure(e));
+    }
+  }
+
+  Future<Tuple2<PresentationEmail, DetailedEmail>> _parsingEmailToDetailedEmail(
+    AccountId accountId,
+    Email email,
+    String? baseDownloadUrl
+  ) async {
+    String? htmlEmailContent;
+
+    final listEmailContent = email.emailContentList;
+    if (listEmailContent.isNotEmpty) {
+      final newEmailContents = await _emailRepository.transformEmailContent(
+        listEmailContent,
+        email.allAttachments.listAttachmentsDisplayedInContent,
+        baseDownloadUrl,
+        accountId);
+
+      htmlEmailContent = newEmailContents.asHtmlString;
+    }
+
+    final detailedEmail = email.toDetailedEmail(htmlEmailContent: htmlEmailContent);
+    final presentationEmail = email.toPresentationEmail();
+
+    return Tuple2(presentationEmail, detailedEmail);
+  }
+}

lib/features/thread/domain/constants/thread_constants.dart

@@ -37,4 +37,34 @@ class ThreadConstants {
     EmailProperty.hasAttachment,
     EmailProperty.mailboxIds,
   });
+
+  static final propertiesGetEmailContent = Properties({
+    EmailProperty.bodyValues,
+    EmailProperty.htmlBody,
+    EmailProperty.attachments,
+    EmailProperty.headers,
+    EmailProperty.keywords,
+    EmailProperty.mailboxIds
+  });
+
+  static final propertiesGetDetailedEmail = Properties({
+    EmailProperty.id,
+    EmailProperty.subject,
+    EmailProperty.from,
+    EmailProperty.to,
+    EmailProperty.cc,
+    EmailProperty.bcc,
+    EmailProperty.keywords,
+    EmailProperty.size,
+    EmailProperty.receivedAt,
+    EmailProperty.sentAt,
+    EmailProperty.preview,
+    EmailProperty.hasAttachment,
+    EmailProperty.replyTo,
+    EmailProperty.mailboxIds,
+    EmailProperty.bodyValues,
+    EmailProperty.htmlBody,
+    EmailProperty.attachments,
+    EmailProperty.headers
+  });
 }