TF-3416 Implement parse email by blob id interactor

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

@@ -185,4 +185,6 @@ abstract class EmailDataSource {
     Session session,
     AccountId accountId,
     List<EmailId> emailIds);
+
+  Future<List<Email>> parseEmailByBlobIds(AccountId accountId, Set<Id> blobIds);
 }

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

@@ -378,4 +378,11 @@ class EmailDataSourceImpl extends EmailDataSource {
   Future<void> markAsForwarded(Session session, AccountId accountId, List<EmailId> emailIds) {
     throw UnimplementedError();
   }
+
+  @override
+  Future<List<Email>> parseEmailByBlobIds(AccountId accountId, Set<Id> blobIds) {
+    return Future.sync(() async {
+      return await emailAPI.parseEmailByBlobIds(accountId, blobIds);
+    }).catchError(_exceptionThrower.throwException);
+  }
 }

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

@@ -526,4 +526,9 @@ class EmailHiveCacheDataSourceImpl extends EmailDataSource {
 
     return Future.value();
   }
+
+  @override
+  Future<List<Email>> parseEmailByBlobIds(AccountId accountId, Set<Id> blobIds) {
+    throw UnimplementedError();
+  }
 }

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

@@ -31,6 +31,8 @@ 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/mail/email/keyword_identifier.dart';
+import 'package:jmap_dart_client/jmap/mail/email/parse/parse_email_method.dart';
+import 'package:jmap_dart_client/jmap/mail/email/parse/parse_email_response.dart';
 import 'package:jmap_dart_client/jmap/mail/email/set/set_email_method.dart';
 import 'package:jmap_dart_client/jmap/mail/email/set/set_email_response.dart';
 import 'package:jmap_dart_client/jmap/mail/email/submission/address.dart';
@@ -897,4 +899,29 @@ class EmailAPI with HandleSetErrorMixin {
       throw SetMethodException(mapErrors);
     }
   }
+
+  Future<List<Email>> parseEmailByBlobIds(AccountId accountId, Set<Id> blobIds) async {
+    final requestBuilder = JmapRequestBuilder(_httpClient, ProcessingInvocation());
+    final parseEmailMethod = ParseEmailMethod(accountId, blobIds);
+    final parseEmailInvocation = requestBuilder.invocation(parseEmailMethod);
+
+    final response = await (requestBuilder
+        ..usings(parseEmailMethod.requiredCapabilities))
+      .build()
+      .execute();
+
+    final parseEmailResponse = response.parse<ParseEmailResponse>(
+      parseEmailInvocation.methodCallId,
+      ParseEmailResponse.deserialize);
+
+    if (parseEmailResponse?.parsed?.isNotEmpty == true) {
+      return parseEmailResponse!.parsed!.values.toList();
+    } else if (parseEmailResponse?.notParsable?.isNotEmpty == true) {
+      throw NotParsableBlobIdToEmailException(ids: parseEmailResponse!.notParsable!);
+    } else if (parseEmailResponse?.notFound?.isNotEmpty == true) {
+      throw NotFoundBlobIdException(parseEmailResponse!.notFound!);
+    } else {
+      throw NotParsableBlobIdToEmailException();
+    }
+  }
 }

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

@@ -483,4 +483,9 @@ class EmailRepositoryImpl extends EmailRepository {
       emailId,
       eventActionType);
   }
+
+  @override
+  Future<List<Email>> parseEmailByBlobIds(AccountId accountId, Set<Id> blobIds) {
+    throw UnimplementedError();
+  }
 }