workavia-mail-front/lib/features/sending_queue/presentation/sending_queue_controller.dart

import 'package:core/presentation/state/success.dart';
import 'package:core/utils/app_logger.dart';
import 'package:core/utils/platform_info.dart';
import 'package:flutter/material.dart';
import 'package:get/get.dart';
import 'package:jmap_dart_client/jmap/account_id.dart';
import 'package:jmap_dart_client/jmap/core/id.dart';
import 'package:jmap_dart_client/jmap/core/user_name.dart';
import 'package:model/mailbox/select_mode.dart';
import 'package:tmail_ui_user/features/base/base_controller.dart';
import 'package:tmail_ui_user/features/base/mixin/message_dialog_action_manager.dart';
import 'package:tmail_ui_user/features/caching/utils/cache_utils.dart';
import 'package:tmail_ui_user/features/email/domain/state/delete_sending_email_state.dart';
import 'package:tmail_ui_user/features/email/presentation/model/composer_arguments.dart';
import 'package:tmail_ui_user/features/mailbox/domain/model/create_new_mailbox_request.dart';
import 'package:tmail_ui_user/features/mailbox_dashboard/presentation/controller/mailbox_dashboard_controller.dart';
import 'package:tmail_ui_user/features/mailbox_dashboard/presentation/extensions/open_and_close_composer_extension.dart';
import 'package:tmail_ui_user/features/offline_mode/model/sending_state.dart';
import 'package:tmail_ui_user/features/sending_queue/domain/extensions/list_sending_email_extension.dart';
import 'package:tmail_ui_user/features/sending_queue/domain/extensions/sending_email_extension.dart';
import 'package:tmail_ui_user/features/sending_queue/domain/model/sending_email.dart';
import 'package:tmail_ui_user/features/sending_queue/domain/state/delete_multiple_sending_email_state.dart';
import 'package:tmail_ui_user/features/sending_queue/domain/state/get_stored_sending_email_state.dart';
import 'package:tmail_ui_user/features/sending_queue/domain/state/update_multiple_sending_email_state.dart';
import 'package:tmail_ui_user/features/sending_queue/domain/state/update_sending_email_state.dart';
import 'package:tmail_ui_user/features/sending_queue/domain/usecases/delete_multiple_sending_email_interactor.dart';
import 'package:tmail_ui_user/features/sending_queue/domain/usecases/delete_sending_email_interactor.dart';
import 'package:tmail_ui_user/features/sending_queue/domain/usecases/get_stored_sending_email_interactor.dart';
import 'package:tmail_ui_user/features/sending_queue/domain/usecases/update_sending_email_interactor.dart';
import 'package:tmail_ui_user/features/sending_queue/presentation/extensions/list_sending_email_extension.dart';
import 'package:tmail_ui_user/features/sending_queue/presentation/model/sending_email_action_type.dart';
import 'package:tmail_ui_user/features/sending_queue/presentation/model/sending_email_arguments.dart';
import 'package:tmail_ui_user/features/sending_queue/presentation/utils/sending_queue_isolate_manager.dart';
import 'package:tmail_ui_user/main/localizations/app_localizations.dart';
import 'package:tmail_ui_user/main/routes/route_navigation.dart';

class SendingQueueController extends BaseController {

  final DeleteMultipleSendingEmailInteractor _deleteMultipleSendingEmailInteractor;
  final UpdateSendingEmailInteractor _updateSendingEmailInteractor;
  final DeleteSendingEmailInteractor _deleteSendingEmailInteractor;
  final GetStoredSendingEmailInteractor _getStoredSendingEmailInteractor;

  final dashboardController = Get.find<MailboxDashBoardController>();
  final _sendingQueueIsolateManager = getBinding<SendingQueueIsolateManager>();

  final listSendingEmailController = ScrollController();

  final selectionState = Rx<SelectMode>(SelectMode.INACTIVE);

  SendingQueueController(
    this._deleteMultipleSendingEmailInteractor,
    this._updateSendingEmailInteractor,
    this._deleteSendingEmailInteractor,
    this._getStoredSendingEmailInteractor,
  );

  @override
  void onInit() {
    super.onInit();
    _sendingQueueIsolateManager?.initial(
      onData: _handleSendingQueueEvent,
      onError: (error, stackTrace) {
        logError('SendingQueueController::onInit():onError:error: $error | stackTrace: $stackTrace');
      }
    );
  }

  void _handleSendingQueueEvent(Object? event) async {
    log('SendingQueueController::_handleSendingQueueEvent():event: $event');
    try {
      if (event is String) {
        final tupleKey = TupleKey.fromString(event);
        log('SendingQueueController::_handleSendingQueueEvent():tupleKey: $tupleKey');
        if (tupleKey.parts.length >= 2) {
          final sendingId = tupleKey.parts[0];
          final sendingState = SendingState.values.firstWhere((state) => state.name == tupleKey.parts[1]);
          if (tupleKey.parts.length >= 4) {
            final accountId = AccountId(Id(tupleKey.parts[2]));
            final userName = UserName(tupleKey.parts[3]);
            _updatingSendingStateAction(
              sendingId: sendingId,
              newState: sendingState,
              accountId: accountId,
              userName: userName
            );
          } else {
            _updatingSendingStateAction(sendingId: sendingId, newState: sendingState);
          }
        }
      }
    } catch (e) {
      logError('SendingQueueController::_handleSendingQueueEvent(): EXCEPTION: $e');
    }
  }

  void _updatingSendingStateAction({
    required String sendingId,
    required SendingState newState,
    AccountId? accountId,
    UserName? userName
  }) async {
    log('SendingQueueController::_updatingSendingStateAction():sendingId: $sendingId | newState: $newState');
    switch(newState) {
      case SendingState.waiting:
      case SendingState.running:
        final listSendingEmails = dashboardController.listSendingEmails
          .map((sendingEmail) => sendingEmail.sendingId == sendingId
            ? sendingEmail.updatingSendingState(newState)
            : sendingEmail)
          .toList();

        dashboardController.listSendingEmails.value = listSendingEmails;
        break;
      case SendingState.canceled:
      case SendingState.error:
        if (accountId != null && userName != null) {
          final matchedSendingEmail = dashboardController.listSendingEmails.firstWhereOrNull((sendingEmail) => sendingEmail.sendingId == sendingId);
          if (matchedSendingEmail != null) {
            _updateSendingEmailAction(
              newSendingEmail: matchedSendingEmail.updatingSendingState(newState),
              accountId: accountId,
              userName: userName
            );
          } else {
            _getStoredSendingEmailAction(sendingId, accountId, userName, newState);
          }
        }
        break;
      case SendingState.success:
        if (accountId != null && userName != null) {
          _deleteSendingEmailAction(sendingId, accountId, userName);
        }
        break;
    }
  }

  void handleOnLongPressAction(SendingEmail sendingEmail) {
    final newListSendingEmail = dashboardController.listSendingEmails.toggleSelection(sendingEmailSelected: sendingEmail);
    dashboardController.listSendingEmails.value = newListSendingEmail;

    selectionState.value = newListSendingEmail.isAllUnSelected()
      ? SelectMode.INACTIVE
      : SelectMode.ACTIVE;
  }

  void toggleSelectionSendingEmail(SendingEmail sendingEmail) {
    final newListSendingEmail = dashboardController.listSendingEmails.toggleSelection(sendingEmailSelected: sendingEmail);
    dashboardController.listSendingEmails.value = newListSendingEmail;

    selectionState.value = newListSendingEmail.isAllUnSelected()
      ? SelectMode.INACTIVE
      : SelectMode.ACTIVE;
  }

  bool get isAllUnSelected => dashboardController.listSendingEmails.isAllUnSelected();

  void refreshSendingQueue() {
    dashboardController.getAllSendingEmails();
  }

  void openMailboxMenu() {
    dashboardController.openMailboxMenuDrawer();
  }

  void disableSelectionMode() {
    final newListSendingEmail = dashboardController.listSendingEmails.unAllSelected();
    dashboardController.listSendingEmails.value = newListSendingEmail;
    selectionState.value = SelectMode.INACTIVE;
  }

  void handleSendingEmailActionType(
    BuildContext context,
    SendingEmailActionType actionType,
    List<SendingEmail> listSendingEmails
  ) {
    switch(actionType) {
      case SendingEmailActionType.delete:
        _deleteListSendingEmailAction(context, listSendingEmails);
        break;
      case SendingEmailActionType.edit:
        _editSendingEmailAction(listSendingEmails.first);
        break;
      case SendingEmailActionType.create:
        break;
      case SendingEmailActionType.resend:
        _resendSendingEmailAction(listSendingEmails);
        break;
    }
  }

  void _deleteListSendingEmailAction(BuildContext context, List<SendingEmail> listSendingEmails) {
    final appLocalizations = AppLocalizations.of(context);
    MessageDialogActionManager().showConfirmDialogAction(
      context,
      appLocalizations.messageDialogDeleteSendingEmail,
      appLocalizations.delete,
      title: appLocalizations.deleteOfflineEmail,
      alignCenter: true,
      cancelTitle: appLocalizations.cancel,
      onConfirmAction: () => _handleDeleteListSendingEmail(listSendingEmails),
    );
  }

  void _handleDeleteListSendingEmail(List<SendingEmail> listSendingEmails) async {
    disableSelectionMode();

    final accountId = dashboardController.accountId.value;
    final session = dashboardController.sessionCurrent;
    if (accountId != null && session != null) {
      consumeState(
        _deleteMultipleSendingEmailInteractor.execute(
          accountId,
          session.username,
          listSendingEmails.sendingIds
        )
      );
    }
  }

  void _handleDeleteListSendingEmailSuccess(DeleteMultipleSendingEmailSuccess success) async {
    if (currentContext != null && currentOverlayContext != null) {
      appToast.showToastSuccessMessage(
        currentOverlayContext!,
        AppLocalizations.of(currentContext!).messageHaveBeenDeletedSuccessfully);
    }

    refreshSendingQueue();
  }

  void _editSendingEmailAction(SendingEmail sendingEmail) {
    disableSelectionMode();
    dashboardController.openComposer(ComposerArguments.fromSendingEmail(sendingEmail));
  }

  void _resendSendingEmailAction(List<SendingEmail> listSendingEmails) async {
    disableSelectionMode();

    final accountId = dashboardController.accountId.value;
    final session = dashboardController.sessionCurrent;
    if (accountId == null || session == null) {
      return;
    }

    if (PlatformInfo.isMobile && listSendingEmails.isNotEmpty) {
      final sendingEmailRunning = listSendingEmails.first.updatingSendingState(SendingState.running);
      _updateSendingEmailAction(
        newSendingEmail: sendingEmailRunning,
        accountId: accountId,
        userName: session.username
      );
      dashboardController.handleSendEmailAction(
        SendingEmailArguments(
          session,
          accountId,
          sendingEmailRunning.toEmailRequest(),
          _getMailboxRequest(sendingEmailRunning),
        )
      );
    }
  }

  CreateNewMailboxRequest? _getMailboxRequest(SendingEmail sendingEmail) {
    if (sendingEmail.mailboxNameRequest != null) {
      return CreateNewMailboxRequest(
        sendingEmail.mailboxNameRequest!
      );
    } else {
      return null;
    }
  }

  void _handleResendSendingEmailSuccess(List<SendingEmail> newListSendingEmails) async {
    if (currentContext != null && currentOverlayContext != null) {
      appToast.showToastSuccessMessage(
        currentOverlayContext!,
        AppLocalizations.of(currentContext!).messagesHaveBeenResent);
    }
    refreshSendingQueue();
  }

  void _updateSendingEmailAction({
    required SendingEmail newSendingEmail,
    required AccountId accountId,
    required UserName userName
  }) {
    consumeState(_updateSendingEmailInteractor.execute(accountId, userName, newSendingEmail));
  }

  void _deleteSendingEmailAction(String sendingId, AccountId accountId, UserName userName) {
    consumeState(_deleteSendingEmailInteractor.execute(accountId, userName, sendingId));
  }

  void _handleUpdateSendingEmailSuccess(UpdateSendingEmailSuccess success) async {
    refreshSendingQueue();
  }

  void _getStoredSendingEmailAction(
    String sendingId,
    AccountId accountId,
    UserName userName,
    SendingState sendingState
  ) {
    consumeState(
      _getStoredSendingEmailInteractor.execute(
        accountId,
        userName,
        sendingId,
        sendingState
      )
    );
  }

  @override
  void handleSuccessViewState(Success success) {
    super.handleSuccessViewState(success);
    if (success is DeleteMultipleSendingEmailSuccess) {
      _handleDeleteListSendingEmailSuccess(success);
    } else if (success is UpdateMultipleSendingEmailAllSuccess) {
      _handleResendSendingEmailSuccess(success.newSendingEmails);
    } else if (success is UpdateMultipleSendingEmailHasSomeSuccess) {
      _handleResendSendingEmailSuccess(success.newSendingEmails);
    } else if (success is UpdateSendingEmailSuccess) {
      _handleUpdateSendingEmailSuccess(success);
    } else if (success is DeleteSendingEmailSuccess) {
      refreshSendingQueue();
    } else if (success is GetStoredSendingEmailSuccess) {
      _updateSendingEmailAction(
        newSendingEmail: success.sendingEmail.updatingSendingState(success.sendingState),
        accountId: success.accountId,
        userName: success.userName
      );
    }
  }

  @override
  void onClose() {
    listSendingEmailController.dispose();
    _sendingQueueIsolateManager?.release();
    super.onClose();
  }
}