diff --git a/lib/features/login/data/local/authentication_info_cache_manager.dart b/lib/features/login/data/local/authentication_info_cache_manager.dart index e200a361a..7c8cc9d9d 100644 --- a/lib/features/login/data/local/authentication_info_cache_manager.dart +++ b/lib/features/login/data/local/authentication_info_cache_manager.dart @@ -12,8 +12,8 @@ class AuthenticationInfoCacheManager { authenticationInfoCache); } - Future getAuthenticationInfoStored() { - return _authenticationInfoCacheClient.getItem(AuthenticationInfoCache.keyCacheValue); + Future getAuthenticationInfoStored({bool needToReopen = false}) { + return _authenticationInfoCacheClient.getItem(AuthenticationInfoCache.keyCacheValue, needToReopen: needToReopen); } Future removeAuthenticationInfo() { diff --git a/lib/features/login/data/repository/credential_repository_impl.dart b/lib/features/login/data/repository/credential_repository_impl.dart index 13973ee97..709fb5eb5 100644 --- a/lib/features/login/data/repository/credential_repository_impl.dart +++ b/lib/features/login/data/repository/credential_repository_impl.dart @@ -36,8 +36,8 @@ class CredentialRepositoryImpl extends CredentialRepository { } @override - Future getAuthenticationInfoStored() { - return _authenticationInfoCacheManager.getAuthenticationInfoStored(); + Future getAuthenticationInfoStored({bool needToReopen = false}) { + return _authenticationInfoCacheManager.getAuthenticationInfoStored(needToReopen: needToReopen); } @override diff --git a/lib/features/login/domain/repository/credential_repository.dart b/lib/features/login/domain/repository/credential_repository.dart index 805e70379..21c7a08d5 100644 --- a/lib/features/login/domain/repository/credential_repository.dart +++ b/lib/features/login/domain/repository/credential_repository.dart @@ -9,7 +9,7 @@ abstract class CredentialRepository { Future storeAuthenticationInfo(AuthenticationInfoCache authenticationInfoCache); - Future getAuthenticationInfoStored(); + Future getAuthenticationInfoStored({bool needToReopen = false}); Future removeAuthenticationInfo(); } \ No newline at end of file diff --git a/lib/features/login/domain/usecases/get_authenticated_account_interactor.dart b/lib/features/login/domain/usecases/get_authenticated_account_interactor.dart index de2eab1b7..ea3179fc1 100644 --- a/lib/features/login/domain/usecases/get_authenticated_account_interactor.dart +++ b/lib/features/login/domain/usecases/get_authenticated_account_interactor.dart @@ -20,7 +20,7 @@ class GetAuthenticatedAccountInteractor { this._getStoredTokenOidcInteractor ); - Stream> execute() async* { + Stream> execute({bool needToReopen = false}) async* { try { yield Right(LoadingState()); final account = await _accountRepository.getCurrentAccount(); @@ -29,7 +29,7 @@ class GetAuthenticatedAccountInteractor { if (account.authenticationType == AuthenticationType.oidc) { yield* _getStoredTokenOidcInteractor.execute(account.id); } else { - yield await _getCredentialInteractor.execute(); + yield await _getCredentialInteractor.execute(needToReopen: needToReopen); } } catch (e) { logError('GetAuthenticatedAccountInteractor::execute(): $e'); diff --git a/lib/features/login/domain/usecases/get_credential_interactor.dart b/lib/features/login/domain/usecases/get_credential_interactor.dart index b2dd3f903..40ff8f8be 100644 --- a/lib/features/login/domain/usecases/get_credential_interactor.dart +++ b/lib/features/login/domain/usecases/get_credential_interactor.dart @@ -15,10 +15,10 @@ class GetCredentialInteractor { GetCredentialInteractor(this.credentialRepository); - Future> execute() async { + Future> execute({bool needToReopen = false}) async { try { final baseUrl = await credentialRepository.getBaseUrl(); - final authenticationInfo = await credentialRepository.getAuthenticationInfoStored(); + final authenticationInfo = await credentialRepository.getAuthenticationInfoStored(needToReopen: needToReopen); if (isCredentialValid(baseUrl) && authenticationInfo != null) { return Right(GetCredentialViewState( baseUrl, diff --git a/lib/features/offline_mode/biding/sending_email_biding.dart b/lib/features/offline_mode/biding/sending_email_biding.dart new file mode 100644 index 000000000..5fce40b6c --- /dev/null +++ b/lib/features/offline_mode/biding/sending_email_biding.dart @@ -0,0 +1,109 @@ +import 'package:core/data/model/source_type/data_source_type.dart'; +import 'package:core/data/network/dio_client.dart'; +import 'package:core/utils/file_utils.dart'; +import 'package:get/get.dart'; +import 'package:tmail_ui_user/features/base/interactors_bindings.dart'; +import 'package:tmail_ui_user/features/caching/clients/state_cache_client.dart'; +import 'package:tmail_ui_user/features/composer/domain/usecases/send_email_interactor.dart'; +import 'package:tmail_ui_user/features/email/data/datasource/email_datasource.dart'; +import 'package:tmail_ui_user/features/email/data/datasource/html_datasource.dart'; +import 'package:tmail_ui_user/features/email/data/datasource_impl/email_datasource_impl.dart'; +import 'package:tmail_ui_user/features/email/data/datasource_impl/email_hive_cache_datasource_impl.dart'; +import 'package:tmail_ui_user/features/email/data/datasource_impl/html_datasource_impl.dart'; +import 'package:tmail_ui_user/features/email/data/local/html_analyzer.dart'; +import 'package:tmail_ui_user/features/email/data/network/email_api.dart'; +import 'package:tmail_ui_user/features/email/data/repository/email_repository_impl.dart'; +import 'package:tmail_ui_user/features/email/domain/repository/email_repository.dart'; +import 'package:tmail_ui_user/features/mailbox/data/datasource/mailbox_datasource.dart'; +import 'package:tmail_ui_user/features/mailbox/data/datasource/state_datasource.dart'; +import 'package:tmail_ui_user/features/mailbox/data/datasource_impl/mailbox_cache_datasource_impl.dart'; +import 'package:tmail_ui_user/features/mailbox/data/datasource_impl/mailbox_datasource_impl.dart'; +import 'package:tmail_ui_user/features/mailbox/data/datasource_impl/state_datasource_impl.dart'; +import 'package:tmail_ui_user/features/mailbox/data/local/mailbox_cache_manager.dart'; +import 'package:tmail_ui_user/features/mailbox/data/network/mailbox_api.dart'; +import 'package:tmail_ui_user/features/mailbox/data/network/mailbox_isolate_worker.dart'; +import 'package:tmail_ui_user/features/mailbox/data/repository/mailbox_repository_impl.dart'; +import 'package:tmail_ui_user/features/mailbox/domain/repository/mailbox_repository.dart'; +import 'package:tmail_ui_user/features/offline_mode/manager/detailed_email_cache_manager.dart'; +import 'package:tmail_ui_user/features/offline_mode/manager/detailed_email_cache_worker_queue.dart'; +import 'package:tmail_ui_user/features/offline_mode/manager/opened_email_cache_manager.dart'; +import 'package:tmail_ui_user/features/offline_mode/manager/opened_email_cache_worker_queue.dart'; +import 'package:tmail_ui_user/features/offline_mode/manager/sending_email_cache_manager.dart'; +import 'package:tmail_ui_user/features/thread/data/local/email_cache_manager.dart'; +import 'package:tmail_ui_user/main/exceptions/cache_exception_thrower.dart'; +import 'package:tmail_ui_user/main/exceptions/remote_exception_thrower.dart'; + +class SendingEmailBindings extends InteractorsBindings { + + @override + void bindingsDataSource() { + Get.lazyPut(() => Get.find()); + Get.lazyPut(() => Get.find()); + Get.lazyPut(() => Get.find()); + Get.lazyPut(() => Get.find()); + } + + @override + void bindingsDataSourceImpl() { + Get.lazyPut(() => EmailDataSourceImpl( + Get.find(), + Get.find())); + Get.lazyPut(() => MailboxDataSourceImpl( + Get.find(), + Get.find(), + Get.find())); + Get.lazyPut(() => MailboxCacheDataSourceImpl( + Get.find(), + Get.find())); + Get.lazyPut(() => HtmlDataSourceImpl( + Get.find(), + Get.find(), + Get.find())); + Get.lazyPut(() => StateDataSourceImpl( + Get.find(), + Get.find())); + Get.lazyPut(() => EmailHiveCacheDataSourceImpl( + Get.find(), + Get.find(), + Get.find(), + Get.find(), + Get.find(), + Get.find(), + Get.find(), + Get.find())); + } + + @override + void bindingsInteractor() { + Get.lazyPut(() => SendEmailInteractor( + Get.find(), + Get.find() + )); + } + + @override + void bindingsRepository() { + Get.lazyPut(() => Get.find()); + Get.lazyPut(() => Get.find()); + } + + @override + void bindingsRepositoryImpl() { + Get.lazyPut(() => EmailRepositoryImpl( + { + DataSourceType.network: Get.find(), + DataSourceType.hiveCache: Get.find() + }, + Get.find(), + Get.find(), + )); + Get.lazyPut(() => MailboxRepositoryImpl( + { + DataSourceType.network: Get.find(), + DataSourceType.local: Get.find() + }, + Get.find(), + )); + } + +} \ No newline at end of file diff --git a/lib/features/offline_mode/observer/sending_email_observer.dart b/lib/features/offline_mode/observer/sending_email_observer.dart index d0bb7ac9e..cc924002c 100644 --- a/lib/features/offline_mode/observer/sending_email_observer.dart +++ b/lib/features/offline_mode/observer/sending_email_observer.dart @@ -1,9 +1,50 @@ - +import 'package:core/data/network/config/dynamic_url_interceptors.dart'; +import 'package:core/presentation/extensions/uri_extension.dart'; +import 'package:core/presentation/resources/image_paths.dart'; +import 'package:core/presentation/state/failure.dart'; +import 'package:core/presentation/state/success.dart'; +import 'package:core/presentation/utils/app_toast.dart'; import 'package:core/utils/app_logger.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/user_name.dart'; +import 'package:model/oidc/token_oidc.dart'; +import 'package:tmail_ui_user/features/caching/config/hive_cache_config.dart'; +import 'package:tmail_ui_user/features/composer/domain/extensions/sending_email_extension.dart'; +import 'package:tmail_ui_user/features/composer/domain/model/sending_email.dart'; +import 'package:tmail_ui_user/features/composer/domain/state/send_email_state.dart'; +import 'package:tmail_ui_user/features/composer/domain/usecases/send_email_interactor.dart'; +import 'package:tmail_ui_user/features/home/presentation/home_bindings.dart'; +import 'package:tmail_ui_user/features/login/data/network/config/authorization_interceptors.dart'; +import 'package:tmail_ui_user/features/login/domain/state/get_authenticated_account_state.dart'; +import 'package:tmail_ui_user/features/login/domain/state/get_credential_state.dart'; +import 'package:tmail_ui_user/features/login/domain/state/get_stored_token_oidc_state.dart'; +import 'package:tmail_ui_user/features/login/domain/usecases/get_authenticated_account_interactor.dart'; +import 'package:tmail_ui_user/features/mailbox/domain/model/create_new_mailbox_request.dart'; +import 'package:tmail_ui_user/features/mailbox_dashboard/presentation/bindings/mailbox_dashboard_bindings.dart'; +import 'package:tmail_ui_user/features/offline_mode/biding/sending_email_biding.dart'; import 'package:tmail_ui_user/features/offline_mode/observer/work_observer.dart'; +import 'package:tmail_ui_user/features/session/domain/state/get_session_state.dart'; +import 'package:tmail_ui_user/features/session/domain/usecases/get_session_interactor.dart'; +import 'package:tmail_ui_user/main/bindings/main_bindings.dart'; +import 'package:tmail_ui_user/main/localizations/app_localizations.dart'; +import 'package:tmail_ui_user/main/routes/route_navigation.dart'; class SendingEmailObserver extends WorkObserver { + AccountId? _currentAccountId; + Session? _currentSession; + UserName? _userName; + Map? _inputData; + + AppToast? _appToast; + ImagePaths? _imagePaths; + SendEmailInteractor? _sendEmailInteractor; + GetAuthenticatedAccountInteractor? _getAuthenticatedAccountInteractor; + DynamicUrlInterceptors? _dynamicUrlInterceptors; + AuthorizationInterceptors? _authorizationInterceptors; + GetSessionInteractor? _getSessionInteractor; + static SendingEmailObserver? _instance; SendingEmailObserver._(); @@ -13,12 +54,159 @@ class SendingEmailObserver extends WorkObserver { @override Future observe(String taskId, Map inputData) async { log('SendingEmailObserver::observe():taskId: $taskId | inputData: $inputData'); + _inputData = inputData; + _getAuthenticatedAccount(); return Future.value(); } @override Future bindDI() async { - log('SendingEmailObserver::bindDI(): '); - return Future.value(); + return await _initialAppConfig(); + } + + + Future _initialAppConfig() async { + await Future.wait([ + MainBindings().dependencies(), + HiveCacheConfig().setUp() + ]); + + await Future.sync(() { + HomeBindings().dependencies(); + MailboxDashBoardBindings().dependencies(); + SendingEmailBindings().dependencies(); + }); + + return await _getInteractorBindings(); + } + + @override + void handleFailureViewState(Failure failure) { + _clearDataQueue(); + log('SendingEmailObserver::_handleFailureViewState(): $failure'); + } + + + @override + void handleSuccessViewState(Success success) { + if (success is GetAuthenticatedAccountSuccess) { + _handleGetAuthenticatedAccountSuccess(success); + } else if (success is GetSessionSuccess) { + _handleGetSessionSuccess(success); + } else if (success is GetStoredTokenOidcSuccess) { + _handleGetAccountByOidcSuccess(success); + } else if (success is GetCredentialViewState) { + _handleGetAccountByBasicAuthSuccess(success); + } else if (success is SendEmailSuccess) { + if (currentOverlayContext != null && currentContext != null) { + _appToast?.showToastSuccessMessage( + currentOverlayContext!, + AppLocalizations.of(currentContext!).message_has_been_sent_successfully, + leadingSVGIcon: _imagePaths?.icSendSuccessToast); + } + } + } + + Future _getInteractorBindings() { + try { + _getAuthenticatedAccountInteractor = getBinding(); + _dynamicUrlInterceptors = getBinding(); + _authorizationInterceptors = getBinding(); + _getSessionInteractor = getBinding(); + _appToast = getBinding(); + _imagePaths = getBinding(); + _sendEmailInteractor = getBinding(); + } catch (e) { + logError('SendingEmailObserver::_getInteractorBindings(): ${e.toString()}'); + } + return Future.value(null); + } + + void _handleGetAuthenticatedAccountSuccess(GetAuthenticatedAccountSuccess success) { + _currentAccountId = success.account.accountId; + _userName = success.account.userName; + _dynamicUrlInterceptors?.changeBaseUrl(success.account.apiUrl); + log('SendingEmailObserver::_handleGetAuthenticatedAccountSuccess():_currentAccountId: $_currentAccountId | _userName: $_userName'); + } + + void _getSessionAction() { + if (_getSessionInteractor != null) { + consumeState(_getSessionInteractor!.execute()); + } else { + _clearDataQueue(); + logError('SendingEmailObserver::_getSessionAction():_getSessionInteractor is null'); + } + } + + void _getAuthenticatedAccount() { + if (_getAuthenticatedAccountInteractor != null) { + consumeState(_getAuthenticatedAccountInteractor!.execute(needToReopen: true)); + } else { + _clearDataQueue(); + logError('SendingEmailObserver::_getAuthenticatedAccount():_getAuthenticatedAccountInteractor is null'); + } + } + + void _handleGetSessionSuccess(GetSessionSuccess success) { + _currentSession = success.session; + _userName = success.session.username; + final jmapUrl = _dynamicUrlInterceptors?.jmapUrl; + final apiUrl = jmapUrl != null + ? success.session.apiUrl.toQualifiedUrl(baseUrl: Uri.parse(jmapUrl)).toString() + : success.session.apiUrl.toString(); + log('SendingEmailObserver::_handleGetSessionSuccess():jmapUrl: $jmapUrl | apiUrl: $apiUrl'); + if (apiUrl.isNotEmpty) { + _dynamicUrlInterceptors?.changeBaseUrl(apiUrl); + _sendEmailAction(); + } else { + _clearDataQueue(); + logError('SendingEmailObserver::_handleGetSessionSuccess():apiUrl is null'); + } + } + + void _handleGetAccountByBasicAuthSuccess(GetCredentialViewState credentialViewState) { + log('SendingEmailObserver::_handleGetAccountByBasicAuthSuccess()'); + _dynamicUrlInterceptors?.setJmapUrl(credentialViewState.baseUrl.toString()); + _authorizationInterceptors?.setBasicAuthorization( + credentialViewState.userName.value, + credentialViewState.password.value, + ); + _dynamicUrlInterceptors?.changeBaseUrl(credentialViewState.baseUrl.toString()); + _getSessionAction(); + } + + void _sendEmailAction() { + log('SendingEmailObserver::_sendEmailAction()'); + if (_sendEmailInteractor != null && _inputData != null && _currentSession != null && _currentAccountId != null) { + final sendingEmail = SendingEmail.fromJson(_inputData!); + consumeState(_sendEmailInteractor!.execute( + _currentSession!, + _currentAccountId!, + sendingEmail.toEmailRequest(), + mailboxRequest: CreateNewMailboxRequest( + sendingEmail.creationIdRequest!, + sendingEmail.mailboxNameRequest!, + isSubscribed: true, + ) + )); + } else { + logError('SendingEmailObserver::_sendEmailAction():_sendEmailInteractor is null'); + } + } + + void _handleGetAccountByOidcSuccess(GetStoredTokenOidcSuccess storedTokenOidcSuccess) { + log('FcmMessageController::_handleGetAccountByOidcSuccess():'); + _dynamicUrlInterceptors?.setJmapUrl(storedTokenOidcSuccess.baseUrl.toString()); + _authorizationInterceptors?.setTokenAndAuthorityOidc( + newToken: storedTokenOidcSuccess.tokenOidc.toToken(), + newConfig: storedTokenOidcSuccess.oidcConfiguration + ); + + _dynamicUrlInterceptors?.changeBaseUrl(storedTokenOidcSuccess.baseUrl.toString()); + _getSessionAction(); + } + + void _clearDataQueue() { + _inputData = null; } } \ No newline at end of file