TF-3235 Create seach emails in thread API, datasource and repository

lib/features/thread/data/datasource/thread_datasource.dart

@@ -14,6 +14,7 @@ import 'package:model/email/presentation_email.dart';
 import 'package:tmail_ui_user/features/thread/data/model/email_change_response.dart';
 import 'package:tmail_ui_user/features/thread/domain/model/email_response.dart';
 import 'package:tmail_ui_user/features/thread/domain/model/filter_message_option.dart';
+import 'package:tmail_ui_user/features/thread/domain/model/search_emails_response.dart';
 
 abstract class ThreadDataSource {
   Future<EmailsResponse> getAllEmail(
@@ -28,6 +29,18 @@ abstract class ThreadDataSource {
     }
   );
 
+  Future<SearchEmailsResponse> searchEmails(
+    Session session,
+    AccountId accountId,
+    {
+      UnsignedInt? limit,
+      int? position,
+      Set<Comparator>? sort,
+      Filter? filter,
+      Properties? properties
+    }
+  );
+
   Future<EmailChangeResponse> getChanges(
     Session session,
     AccountId accountId,

lib/features/thread/data/datasource_impl/local_thread_datasource_impl.dart

@@ -16,6 +16,7 @@ import 'package:tmail_ui_user/features/thread/data/local/email_cache_manager.dar
 import 'package:tmail_ui_user/features/thread/data/model/email_change_response.dart';
 import 'package:tmail_ui_user/features/thread/domain/model/email_response.dart';
 import 'package:tmail_ui_user/features/thread/domain/model/filter_message_option.dart';
+import 'package:tmail_ui_user/features/thread/domain/model/search_emails_response.dart';
 import 'package:tmail_ui_user/main/exceptions/exception_thrower.dart';
 
 class LocalThreadDataSourceImpl extends ThreadDataSource {
@@ -40,6 +41,21 @@ class LocalThreadDataSourceImpl extends ThreadDataSource {
     throw UnimplementedError();
   }
 
+  @override
+  Future<SearchEmailsResponse> searchEmails(
+    Session session,
+    AccountId accountId,
+    {
+      UnsignedInt? limit,
+      int? position,
+      Set<Comparator>? sort,
+      Filter? filter,
+      Properties? properties
+    }
+  ) {
+    throw UnimplementedError();
+  }
+
   @override
   Future<EmailChangeResponse> getChanges(
     Session session,

lib/features/thread/data/datasource_impl/thread_datasource_impl.dart

@@ -18,6 +18,7 @@ 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/features/thread/domain/model/email_response.dart';
 import 'package:tmail_ui_user/features/thread/domain/model/filter_message_option.dart';
+import 'package:tmail_ui_user/features/thread/domain/model/search_emails_response.dart';
 import 'package:tmail_ui_user/main/exceptions/exception_thrower.dart';
 
 class ThreadDataSourceImpl extends ThreadDataSource {
@@ -56,6 +57,30 @@ class ThreadDataSourceImpl extends ThreadDataSource {
     }).catchError(_exceptionThrower.throwException);
   }
 
+  @override
+  Future<SearchEmailsResponse> searchEmails(
+    Session session,
+    AccountId accountId,
+    {
+      UnsignedInt? limit,
+      int? position,
+      Set<Comparator>? sort,
+      Filter? filter,
+      Properties? properties,
+    }
+  ) {
+    return Future.sync(() async {
+      return await threadAPI.searchEmails(
+        session,
+        accountId,
+        limit: limit,
+        position: position,
+        sort: sort,
+        filter: filter,
+        properties: properties);
+    }).catchError(_exceptionThrower.throwException);
+  }
+
   @override
   Future<EmailChangeResponse> getChanges(
     Session session,

lib/features/thread/data/network/thread_api.dart

@@ -6,6 +6,8 @@ import 'package:jmap_dart_client/jmap/account_id.dart';
 import 'package:jmap_dart_client/jmap/core/filter/filter.dart';
 import 'package:jmap_dart_client/jmap/core/properties/properties.dart';
 import 'package:jmap_dart_client/jmap/core/request/reference_path.dart';
+import 'package:jmap_dart_client/jmap/core/request/request_invocation.dart';
+import 'package:jmap_dart_client/jmap/core/response/response_object.dart';
 import 'package:jmap_dart_client/jmap/core/session/session.dart';
 import 'package:jmap_dart_client/jmap/core/sort/comparator.dart';
 import 'package:jmap_dart_client/jmap/core/state.dart';
@@ -20,8 +22,12 @@ import 'package:jmap_dart_client/jmap/mail/email/query/query_email_method.dart';
 import 'package:jmap_dart_client/jmap/mail/email/query/query_email_response.dart';
 import 'package:model/extensions/list_email_extension.dart';
 import 'package:tmail_ui_user/features/thread/data/extensions/list_email_extension.dart';
+import 'package:jmap_dart_client/jmap/mail/email/search_snippet/search_snippet.dart';
+import 'package:jmap_dart_client/jmap/mail/email/search_snippet/search_snippet_get_method.dart';
+import 'package:jmap_dart_client/jmap/mail/email/search_snippet/search_snippet_get_response.dart';
 import 'package:tmail_ui_user/features/thread/data/model/email_change_response.dart';
 import 'package:tmail_ui_user/features/thread/domain/model/email_response.dart';
+import 'package:tmail_ui_user/features/thread/domain/model/search_emails_response.dart';
 import 'package:tmail_ui_user/main/error/capability_validator.dart';
 
 class ThreadAPI {
@@ -103,6 +109,103 @@ class ThreadAPI {
     );
   }
 
+  Future<SearchEmailsResponse> searchEmails(
+    Session session,
+    AccountId accountId,
+    {
+      UnsignedInt? limit,
+      int? position,
+      Set<Comparator>? sort,
+      Filter? filter,
+      Properties? properties
+    }
+  ) async {
+    final processingInvocation = ProcessingInvocation();
+
+    final jmapRequestBuilder = JmapRequestBuilder(httpClient, processingInvocation);
+
+    // Email/query
+    final queryEmailMethod = QueryEmailMethod(accountId);
+
+    if (limit != null) queryEmailMethod.addLimit(limit);
+
+    if (position != null) queryEmailMethod.addPosition(position);
+
+    if (sort != null) queryEmailMethod.addSorts(sort);
+
+    if (filter != null) queryEmailMethod.addFilters(filter);
+
+    final queryEmailInvocation = jmapRequestBuilder.invocation(queryEmailMethod);
+
+    // SearchSnippet/get
+    final getSearchSnippetMethod = SearchSnippetGetMethod(accountId);
+    if (filter != null) getSearchSnippetMethod.addFilters(filter);
+    getSearchSnippetMethod.addReferenceEmailIds(
+      processingInvocation.createResultReference(
+        queryEmailInvocation.methodCallId,
+        ReferencePath.idsPath));
+    final getSearchSnippetInvocation = jmapRequestBuilder.invocation(
+      getSearchSnippetMethod);
+
+    // Email/get
+    final getEmailMethod = GetEmailMethod(accountId);
+
+    if (properties != null) getEmailMethod.addProperties(properties);
+
+    getEmailMethod.addReferenceIds(processingInvocation.createResultReference(
+      queryEmailInvocation.methodCallId,
+      ReferencePath.idsPath));
+
+    final getEmailInvocation = jmapRequestBuilder.invocation(getEmailMethod);
+
+    final capabilities = getEmailMethod.requiredCapabilities
+      .toCapabilitiesSupportTeamMailboxes(session, accountId);
+
+    final result = await (jmapRequestBuilder
+        ..usings(capabilities))
+      .build()
+      .execute();
+
+    final emailResultList = result.parse<GetEmailResponse>(
+        getEmailInvocation.methodCallId, GetEmailResponse.deserialize);
+    final responseOfQueryEmailMethod = result.parse<QueryEmailResponse>(
+      queryEmailInvocation.methodCallId,
+      QueryEmailResponse.deserialize);
+
+    List<Email>? sortedEmailList;
+
+    if (emailResultList?.list.isNotEmpty == true &&
+        responseOfQueryEmailMethod?.ids.isNotEmpty == true) {
+      sortedEmailList = emailResultList!.list
+        .sortingByOrderOfIdList(responseOfQueryEmailMethod!.ids.toList());
+    } else {
+      sortedEmailList = emailResultList?.list;
+    }
+
+    final searchSnippets = _getSearchSnippetsFromResponse(
+      result,
+      getSearchSnippetMethodCallId: getSearchSnippetInvocation.methodCallId,
+    );
+    return SearchEmailsResponse(
+        emailList: sortedEmailList,
+        state: emailResultList?.state,
+        searchSnippets: searchSnippets);
+  }
+
+  List<SearchSnippet>? _getSearchSnippetsFromResponse(
+    ResponseObject response,
+    {required MethodCallId getSearchSnippetMethodCallId}
+  ) {
+    try {
+      return response.parse<SearchSnippetGetResponse>(
+          getSearchSnippetMethodCallId,
+          SearchSnippetGetResponse.fromJson)?.list;
+    } catch (e) {
+      logError('ThreadAPI::searchEmails:getSearchSnippetsFromResponse: Exception = $e');
+      return null;
+    }
+  }
+
   Future<EmailChangeResponse> getChanges(
     Session session,
     AccountId accountId,

lib/features/thread/data/repository/thread_repository_impl.dart

@@ -24,6 +24,7 @@ import 'package:tmail_ui_user/features/thread/domain/model/email_filter.dart';
 import 'package:tmail_ui_user/features/thread/domain/model/email_response.dart';
 import 'package:tmail_ui_user/features/thread/domain/model/filter_message_option.dart';
 import 'package:tmail_ui_user/features/thread/domain/model/get_email_request.dart';
+import 'package:tmail_ui_user/features/thread/domain/model/search_email.dart';
 import 'package:tmail_ui_user/features/thread/domain/repository/thread_repository.dart';
 
 class ThreadRepositoryImpl extends ThreadRepository {
@@ -287,7 +288,7 @@ class ThreadRepositoryImpl extends ThreadRepository {
   }
 
   @override
-  Future<List<Email>> searchEmails(
+  Future<List<SearchEmail>> searchEmails(
     Session session,
     AccountId accountId,
     {
@@ -298,7 +299,7 @@ class ThreadRepositoryImpl extends ThreadRepository {
       Properties? properties
     }
   ) async {
-    final emailResponse = await mapDataSource[DataSourceType.network]!.getAllEmail(
+    final searchEmailsResponse = await mapDataSource[DataSourceType.network]!.searchEmails(
       session,
       accountId,
       limit: limit,
@@ -307,7 +308,7 @@ class ThreadRepositoryImpl extends ThreadRepository {
       filter: filter,
       properties: properties);
 
-    return emailResponse.emailList ?? List.empty();
+    return searchEmailsResponse.toSearchEmails ?? [];
   }
 
   @override