TF-1083: merge one request when drag email when searching

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

@@ -5,6 +5,7 @@ import 'package:core/core.dart';
 import 'package:dartz/dartz.dart';
 import 'package:dio/dio.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/model.dart';
 import 'package:tmail_ui_user/features/composer/domain/model/email_request.dart';

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

@@ -5,6 +5,7 @@ import 'package:core/core.dart';
 import 'package:dartz/dartz.dart';
 import 'package:dio/dio.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/model.dart';
 import 'package:tmail_ui_user/features/composer/domain/model/email_request.dart';

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

@@ -9,6 +9,8 @@ import 'package:external_path/external_path.dart';
 import 'package:flutter_downloader/flutter_downloader.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/capability/capability_identifier.dart';
+import 'package:jmap_dart_client/jmap/core/capability/core_capability.dart';
 import 'package:jmap_dart_client/jmap/core/patch_object.dart';
 import 'package:jmap_dart_client/jmap/core/properties/properties.dart';
 import 'package:jmap_dart_client/jmap/core/reference_id.dart';
@@ -38,6 +40,7 @@ import 'package:model/extensions/email_extension.dart';
 import 'package:model/extensions/keyword_identifier_extension.dart';
 import 'package:model/extensions/list_email_id_extension.dart';
 import 'package:model/extensions/mailbox_id_extension.dart';
+import 'package:model/extensions/session_extension.dart';
 import 'package:model/oidc/token.dart';
 import 'package:path_provider/path_provider.dart';
 import 'package:tmail_ui_user/features/composer/domain/model/email_request.dart';
@@ -45,6 +48,7 @@ import 'package:tmail_ui_user/features/email/domain/model/move_to_mailbox_reques
 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/main/error/capability_validator.dart';
 
 class EmailAPI {
 
@@ -302,33 +306,74 @@ class EmailAPI {
   }
 
   Future<List<EmailId>> moveToMailbox(AccountId accountId, MoveToMailboxRequest moveRequest) async {
-    final setEmailMethod = SetEmailMethod(accountId)
-      ..addUpdates(moveRequest.emailIds
-          .generateMapUpdateObjectMoveToMailbox(moveRequest.currentMailboxId, moveRequest.destinationMailboxId));
 
-    final requestBuilder = JmapRequestBuilder(_httpClient, ProcessingInvocation());
+    requireCapability(moveRequest.session, accountId, [CapabilityIdentifier.jmapCore, CapabilityIdentifier.jmapMail]);
 
-    final setEmailInvocation = requestBuilder.invocation(setEmailMethod);
+    final coreCapability = moveRequest.session.getCapabilityProperties<CoreCapability>(
+        accountId, CapabilityIdentifier.jmapCore);
+    final maxMethodCount = coreCapability.maxCallsInRequest.value.toInt();
 
-    final response = await (requestBuilder
-        ..usings(setEmailMethod.requiredCapabilities))
-      .build()
-      .execute();
+    var start = 0;
+    var end = 0;
 
-    final setEmailResponse = response.parse<SetEmailResponse>(
-        setEmailInvocation.methodCallId,
-        SetEmailResponse.deserialize);
+    final List<EmailId> listEmailIdResult = List.empty(growable: true);
+    final listCurrentMailboxesEntries = moveRequest.currentMailboxes.entries.toList();
 
-    return Future.sync(() async {
-      final mapUpdated = setEmailResponse!.updated!;
-      return moveRequest.emailIds
-        .where((emailId) => mapUpdated.containsKey(emailId.id))
-        .toList();
-    }).catchError((error) {
-      throw error;
-    });
+    while (end < moveRequest.currentMailboxes.length) {
+      start = end;
+      if (moveRequest.currentMailboxes.length - start >= maxMethodCount) {
+        end = maxMethodCount;
+      } else {
+        end = moveRequest.currentMailboxes.length;
+      }
+      log('EmailAPI::moveToMailbox(): move from $start to $end / ${listCurrentMailboxesEntries.length}');
+      final currentExecuteList = listCurrentMailboxesEntries.sublist(start, end);
+
+      final requestBuilder = JmapRequestBuilder(_httpClient, ProcessingInvocation());
+      final currentSetEmailInvocations = currentExecuteList.map((currentItem) {
+        return SetEmailMethod(accountId)
+          ..addUpdates(currentItem.value.generateMapUpdateObjectMoveToMailbox(currentItem.key, moveRequest.destinationMailboxId));
+      }).map(requestBuilder.invocation).toList();
+
+      final response = await (requestBuilder..usings({CapabilityIdentifier.jmapCore, CapabilityIdentifier.jmapMail}))
+        .build()
+        .execute();
+
+      Future.sync(() async {
+        final listSetEmailResponse = currentSetEmailInvocations
+          .map((currentInvocation) => response.parse(currentInvocation.methodCallId, SetEmailResponse.deserialize))
+          .toList();
+
+        listEmailIdResult.addAll(_getListEmailIdUpdatedFormSetEmailResponse(listSetEmailResponse, moveRequest));
+
+      }).catchError((error) {
+        throw error;
+      });
+    }
+
+    return listEmailIdResult;
   }
 
+  List<EmailId> _getListEmailIdUpdatedFormSetEmailResponse(List<SetEmailResponse?> listSetEmailResponse, MoveToMailboxRequest moveRequest) {
+    final List<EmailId> listEmailIdResult = List.empty(growable: true);
+    final listUpdated = listSetEmailResponse.map((e) => e!.updated!.keys).toList();
+
+    for (final listEmailId in listUpdated) {
+      List<EmailId> listEmailIdRequest = List.empty(growable: true);
+      for (var itemEmailIdMoveRequest in moveRequest.currentMailboxes.values) {
+        listEmailIdRequest.addAll(itemEmailIdMoveRequest);
+      }
+
+      listEmailIdResult.addAll(listEmailIdRequest
+        .where((emailId) => listEmailId.toList().contains(emailId.id))
+        .toList(),
+      );
+    }
+
+    return listEmailIdResult;
+  }
+
+
   Future<List<Email>> markAsStar(AccountId accountId, List<Email> emails, MarkStarAction markStarAction) async {
     final emailIds = emails.map((email) => email.id).toList();
 

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

@@ -6,6 +6,7 @@ import 'package:core/core.dart';
 import 'package:dartz/dartz.dart';
 import 'package:dio/dio.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/core/state.dart' as jmap;
 import 'package:jmap_dart_client/jmap/mail/email/email.dart';
 import 'package:model/model.dart';

lib/features/email/domain/model/move_to_mailbox_request.dart

@@ -1,5 +1,6 @@
 
 import 'package:equatable/equatable.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/mailbox/mailbox.dart';
 import 'package:model/model.dart';
@@ -7,26 +8,25 @@ import 'package:tmail_ui_user/features/email/domain/model/move_action.dart';
 
 class MoveToMailboxRequest with EquatableMixin {
 
-  final List<EmailId> emailIds;
-  final MailboxId currentMailboxId;
+  final Map<MailboxId,List<EmailId>> currentMailboxes;
   final MailboxId destinationMailboxId;
   final MoveAction moveAction;
   final EmailActionType emailActionType;
   final String? destinationPath;
+  final Session session;
 
   MoveToMailboxRequest(
-    this.emailIds,
-    this.currentMailboxId,
+    this.currentMailboxes,
     this.destinationMailboxId,
     this.moveAction,
-    this.emailActionType,
-    {this.destinationPath}
-  );
+    this.session,
+    this.emailActionType,{
+    this.destinationPath,
+  });
 
   @override
   List<Object?> get props => [
-    emailIds,
-    currentMailboxId,
+    currentMailboxes,
     destinationMailboxId,
     moveAction,
     emailActionType,

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

@@ -5,6 +5,7 @@ import 'package:core/core.dart';
 import 'package:dartz/dartz.dart';
 import 'package:dio/dio.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:jmap_dart_client/jmap/core/state.dart' as jmap;
 import 'package:model/model.dart';

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

@@ -26,7 +26,7 @@ class MoveToMailboxInteractor {
       if (result.isNotEmpty) {
         yield Right(MoveToMailboxSuccess(
           result.first,
-          moveRequest.currentMailboxId,
+          moveRequest.currentMailboxes.keys.first,
           moveRequest.destinationMailboxId,
           moveRequest.moveAction,
           moveRequest.emailActionType,

lib/features/email/presentation/email_controller.dart

@@ -505,27 +505,27 @@ class EmailController extends BaseController with AppLoaderMixin {
         arguments: DestinationPickerArguments(accountId, MailboxActions.moveEmail)
       );
 
-      if (destinationMailbox != null && destinationMailbox is PresentationMailbox) {
+      if (destinationMailbox != null && destinationMailbox is PresentationMailbox && mailboxDashBoardController.sessionCurrent != null) {
         if (destinationMailbox.isTrash) {
           _moveToTrashAction(context, accountId, MoveToMailboxRequest(
-              [email.id],
-              currentMailbox.id,
+              {currentMailbox.id: [email.id]},
               destinationMailbox.id,
               MoveAction.moving,
+              mailboxDashBoardController.sessionCurrent!,
               EmailActionType.moveToTrash));
         } else if (destinationMailbox.isSpam) {
           _moveToSpamAction(context, accountId, MoveToMailboxRequest(
-              [email.id],
-              currentMailbox.id,
+              {currentMailbox.id: [email.id]},
               destinationMailbox.id,
               MoveAction.moving,
+              mailboxDashBoardController.sessionCurrent!,
               EmailActionType.moveToSpam));
         } else {
           _moveToMailbox(accountId, MoveToMailboxRequest(
-              [email.id],
-              currentMailbox.id,
+              {currentMailbox.id: [email.id]},
               destinationMailbox.id,
               MoveAction.moving,
+              mailboxDashBoardController.sessionCurrent!,
               EmailActionType.moveToMailbox,
               destinationPath: destinationMailbox.mailboxPath));
         }
@@ -547,10 +547,10 @@ class EmailController extends BaseController with AppLoaderMixin {
         actionName: AppLocalizations.of(currentContext!).undo,
         onActionClick: () {
           _revertedToOriginalMailbox(MoveToMailboxRequest(
-              [success.emailId],
-              success.destinationMailboxId,
+              {success.destinationMailboxId: [success.emailId]},
               success.currentMailboxId,
               MoveAction.undo,
+              mailboxDashBoardController.sessionCurrent!,
               success.emailActionType));
         },
         leadingIcon: SvgPicture.asset(
@@ -582,10 +582,10 @@ class EmailController extends BaseController with AppLoaderMixin {
 
     if (accountId != null && currentMailbox != null && trashMailboxId != null) {
       _moveToTrashAction(context, accountId, MoveToMailboxRequest(
-        [email.id],
-        currentMailbox.id,
+        {currentMailbox.id: [email.id]},
         trashMailboxId,
         MoveAction.moving,
+        mailboxDashBoardController.sessionCurrent!,
         EmailActionType.moveToTrash)
       );
     }
@@ -603,10 +603,10 @@ class EmailController extends BaseController with AppLoaderMixin {
 
     if (accountId != null && currentMailbox != null && spamMailboxId != null) {
       _moveToSpamAction(context, accountId, MoveToMailboxRequest(
-          [email.id],
-          currentMailbox.id,
+          {currentMailbox.id: [email.id]},
           spamMailboxId,
           MoveAction.moving,
+          mailboxDashBoardController.sessionCurrent!,
           EmailActionType.moveToSpam)
       );
     }
@@ -619,10 +619,10 @@ class EmailController extends BaseController with AppLoaderMixin {
 
     if (accountId != null && spamMailboxId != null && inboxMailboxId != null) {
       _moveToSpamAction(context, accountId, MoveToMailboxRequest(
-          [email.id],
-          spamMailboxId,
+          {spamMailboxId: [email.id]},
           inboxMailboxId,
           MoveAction.moving,
+          mailboxDashBoardController.sessionCurrent!,
           EmailActionType.unSpam)
       );
     }