TF-2667 Show sending message dialog when click send button

2024-03-05 22:57:51 +07:00
parent 016b75aa51
commit e232514f6b
37 changed files with 953 additions and 141 deletions
@@ -0,0 +1,128 @@
+import 'package:core/presentation/state/failure.dart';
+import 'package:core/presentation/state/success.dart';
+import 'package:core/utils/app_logger.dart';
+import 'package:dartz/dartz.dart' as dartz;
+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';
+import 'package:jmap_dart_client/jmap/mail/email/email.dart';
+import 'package:tmail_ui_user/features/composer/domain/repository/composer_repository.dart';
+import 'package:tmail_ui_user/features/composer/domain/state/generate_email_state.dart';
+import 'package:tmail_ui_user/features/composer/domain/state/send_email_state.dart';
+import 'package:tmail_ui_user/features/composer/presentation/extensions/create_email_request_extension.dart';
+import 'package:tmail_ui_user/features/composer/presentation/model/create_email_request.dart';
+import 'package:tmail_ui_user/features/email/domain/exceptions/email_exceptions.dart';
+import 'package:tmail_ui_user/features/email/domain/repository/email_repository.dart';
+import 'package:tmail_ui_user/features/mailbox/domain/repository/mailbox_repository.dart';
+import 'package:tmail_ui_user/features/sending_queue/presentation/model/sending_email_arguments.dart';
+
+class CreateNewAndSendEmailInteractor {
+  final EmailRepository _emailRepository;
+  final MailboxRepository _mailboxRepository;
+  final ComposerRepository _composerRepository;
+
+  CreateNewAndSendEmailInteractor(
+    this._emailRepository,
+    this._mailboxRepository,
+    this._composerRepository,
+  );
+
+  Stream<dartz.Either<Failure, Success>> execute(CreateEmailRequest createEmailRequest) async* {
+    SendingEmailArguments? sendingEmailArguments;
+    try {
+      yield dartz.Right<Failure, Success>(GenerateEmailLoading());
+
+      final listCurrentState = await _getStoredCurrentState(
+        session: createEmailRequest.session,
+        accountId: createEmailRequest.accountId
+      );
+
+      sendingEmailArguments = await _createEmailObject(createEmailRequest);
+
+      if (sendingEmailArguments != null) {
+        yield dartz.Right<Failure, Success>(SendEmailLoading());
+
+        await _emailRepository.sendEmail(
+          sendingEmailArguments.session,
+          sendingEmailArguments.accountId,
+          sendingEmailArguments.emailRequest,
+          mailboxRequest: sendingEmailArguments.mailboxRequest
+        );
+
+        if (sendingEmailArguments.emailRequest.emailIdDestroyed != null) {
+          await _deleteOldDraftsEmail(
+            session: sendingEmailArguments.session,
+            accountId: sendingEmailArguments.accountId,
+            draftEmailId: sendingEmailArguments.emailRequest.emailIdDestroyed!
+          );
+        }
+
+        yield dartz.Right<Failure, Success>(
+          SendEmailSuccess(
+            currentMailboxState: listCurrentState?.value1,
+            currentEmailState: listCurrentState?.value2,
+            emailRequest: sendingEmailArguments.emailRequest
+          )
+        );
+      } else {
+        yield dartz.Left<Failure, Success>(GenerateEmailFailure(CannotCreateEmailObjectException()));
+      }
+    } catch (e) {
+      logError('CreateNewAndSendEmailInteractor::execute: Exception: $e');
+      yield dartz.Left<Failure, Success>(SendEmailFailure(
+        exception: e,
+        session: sendingEmailArguments?.session,
+        accountId: sendingEmailArguments?.accountId,
+        emailRequest: sendingEmailArguments?.emailRequest,
+        mailboxRequest: sendingEmailArguments?.mailboxRequest,
+      ));
+    }
+  }
+
+  Future<SendingEmailArguments?> _createEmailObject(CreateEmailRequest createEmailRequest) async {
+    try {
+      final emailCreated = await _composerRepository.generateEmail(createEmailRequest);
+      final sendingEmailArgument = createEmailRequest.toSendingEmailArguments(emailObject: emailCreated);
+      return sendingEmailArgument;
+    } catch (e) {
+      logError('CreateNewAndSendEmailInteractor::_createEmailObject: Exception: $e');
+      return null;
+    }
+  }
+
+  Future<dartz.Tuple2<State?, State?>?> _getStoredCurrentState({
+    required Session session,
+    required AccountId accountId
+  }) async {
+    try {
+      final listState = await Future.wait([
+        _mailboxRepository.getMailboxState(session, accountId),
+        _emailRepository.getEmailState(session, accountId),
+      ]);
+
+      final mailboxState = listState.first;
+      final emailState = listState.last;
+
+      return dartz.Tuple2(mailboxState, emailState);
+    } catch (e) {
+      logError('CreateNewAndSendEmailInteractor::_getStoredCurrentState: Exception: $e');
+      return null;
+    }
+  }
+
+  Future<void> _deleteOldDraftsEmail({
+    required Session session,
+    required AccountId accountId,
+    required EmailId draftEmailId
+  }) async {
+    try {
+      await _emailRepository.deleteEmailPermanently(
+        session,
+        accountId,
+        draftEmailId
+      );
+    } catch (e) {
+      logError('CreateNewAndSendEmailInteractor::_deleteOldDraftsEmail: Exception: $e');
+    }
+  }
+}
@@ -38,34 +38,24 @@ class SendEmailInteractor {
      final currentMailboxState = listState.first;
      final currentEmailState = listState.last;

-      final result = await _emailRepository.sendEmail(
+      await _emailRepository.sendEmail(
        session,
        accountId,
        emailRequest,
        mailboxRequest: mailboxRequest
      );

-      if (result) {
-        if (emailRequest.emailIdDestroyed != null) {
-          await _emailRepository.deleteEmailPermanently(session, accountId, emailRequest.emailIdDestroyed!);
-        }
-
-        yield Right<Failure, Success>(
-          SendEmailSuccess(
-            currentEmailState: currentEmailState,
-            currentMailboxState: currentMailboxState,
-            emailRequest: emailRequest
-          )
-        );
-      } else {
-        yield Left<Failure, Success>(SendEmailFailure(
-          session: session,
-          accountId: accountId,
-          emailRequest: emailRequest,
-          mailboxRequest: mailboxRequest,
-          sendingEmailActionType: sendingEmailActionType,
-        ));
+      if (emailRequest.emailIdDestroyed != null) {
+        await _emailRepository.deleteEmailPermanently(session, accountId, emailRequest.emailIdDestroyed!);
      }
+
+      yield Right<Failure, Success>(
+        SendEmailSuccess(
+          currentEmailState: currentEmailState,
+          currentMailboxState: currentMailboxState,
+          emailRequest: emailRequest
+        )
+      );
    } catch (e) {
      yield Left<Failure, Success>(SendEmailFailure(
        exception: e,