import 'package:core/data/network/config/dynamic_url_interceptors.dart'; 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'; import 'package:get/get.dart'; import 'package:jmap_dart_client/jmap/core/session/session.dart'; import 'package:model/account/authentication_type.dart'; import 'package:model/oidc/token_oidc.dart'; import 'package:tmail_ui_user/features/base/base_controller.dart'; import 'package:tmail_ui_user/features/caching/caching_manager.dart'; import 'package:tmail_ui_user/features/caching/config/hive_cache_config.dart'; import 'package:tmail_ui_user/features/login/data/network/config/authorization_interceptors.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/delete_authority_oidc_interactor.dart'; import 'package:tmail_ui_user/features/login/domain/usecases/delete_credential_interactor.dart'; import 'package:tmail_ui_user/features/login/domain/usecases/get_authenticated_account_interactor.dart'; import 'package:tmail_ui_user/features/login/presentation/login_form_type.dart'; import 'package:tmail_ui_user/features/login/presentation/model/login_arguments.dart'; import 'package:tmail_ui_user/features/mailbox_dashboard/presentation/bindings/autocomplete_bindings.dart'; import 'package:tmail_ui_user/features/manage_account/data/local/language_cache_manager.dart'; import 'package:tmail_ui_user/features/manage_account/domain/state/log_out_oidc_state.dart'; import 'package:tmail_ui_user/features/manage_account/domain/usecases/log_out_oidc_interactor.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/routes/app_routes.dart'; import 'package:tmail_ui_user/main/routes/route_navigation.dart'; abstract class ReloadableController extends BaseController { final DynamicUrlInterceptors _dynamicUrlInterceptors = Get.find(); final AuthorizationInterceptors _authorizationInterceptors = Get.find(); final GetSessionInteractor _getSessionInteractor = Get.find(); final DeleteCredentialInteractor _deleteCredentialInteractor = Get.find(); final CachingManager _cachingManager = Get.find(); final _languageCacheManager = Get.find(); final LogoutOidcInteractor _logoutOidcInteractor; final DeleteAuthorityOidcInteractor _deleteAuthorityOidcInteractor; final GetAuthenticatedAccountInteractor _getAuthenticatedAccountInteractor; ReloadableController( this._logoutOidcInteractor, this._deleteAuthorityOidcInteractor, this._getAuthenticatedAccountInteractor, ); @override void onData(Either newState) { super.onData(newState); viewState.value.fold( (failure) { if (failure is GetCredentialFailure) { _goToLogin(arguments: LoginArguments(LoginFormType.credentialForm)); } else if (failure is GetSessionFailure) { _handleGetSessionFailure(); } else if (failure is LogoutOidcFailure) { log('ReloadableController::onData(): LogoutOidcFailure: $failure'); } else if (failure is GetStoredTokenOidcFailure) { _goToLogin(arguments: LoginArguments(LoginFormType.ssoForm)); } }, (success) { if (success is GetCredentialViewState) { _handleGetCredentialSuccess(success); } else if (success is GetSessionSuccess) { _handleGetSessionSuccess(success); } else if (success is LogoutOidcSuccess) { handleLogoutOidcSuccess(success); } else if (success is GetStoredTokenOidcSuccess) { _handleGetStoredTokenOIDCSuccess(success); } } ); } /* * trigger reload by getting Credential again then setting up Interceptor and retrieving session * */ void reload() { _getAuthenticatedAccountAction(); } void _getAuthenticatedAccountAction() { consumeState(_getAuthenticatedAccountInteractor.execute()); } void _goToLogin({LoginArguments? arguments}) { pushAndPopAll(AppRoutes.LOGIN, arguments: arguments); } void _setUpInterceptors(GetCredentialViewState credentialViewState) { _dynamicUrlInterceptors.changeBaseUrl(credentialViewState.baseUrl.origin); _authorizationInterceptors.setBasicAuthorization( credentialViewState.userName.userName, credentialViewState.password.value, ); } void _handleGetCredentialSuccess(GetCredentialViewState credentialViewState) { _setUpInterceptors(credentialViewState); _getSessionAction(); } void _getSessionAction() { consumeState(_getSessionInteractor.execute().asStream()); } void _handleGetSessionFailure() async { await Future.wait([ _deleteCredentialInteractor.execute(), _deleteAuthorityOidcInteractor.execute(), _cachingManager.clearAll(), _languageCacheManager.removeLanguage(), ]); final authenticationType = _authorizationInterceptors.authenticationType; if (authenticationType == AuthenticationType.oidc) { _goToLogin(arguments: LoginArguments(LoginFormType.ssoForm)); } else { _goToLogin(arguments: LoginArguments(LoginFormType.credentialForm)); } } void _handleGetSessionSuccess(GetSessionSuccess success) { handleReloaded(success.session); } void handleReloaded(Session session) {} void logoutAction() async { final authenticationType = _authorizationInterceptors.authenticationType; if (authenticationType == AuthenticationType.oidc) { consumeState(_logoutOidcInteractor.execute()); } else { await Future.wait([ _deleteCredentialInteractor.execute(), _cachingManager.clearAll(), _languageCacheManager.removeLanguage(), ]); _authorizationInterceptors.clear(); await HiveCacheConfig().closeHive(); _goToLogin(arguments: LoginArguments(LoginFormType.credentialForm)); } } void handleLogoutOidcSuccess(LogoutOidcSuccess success) async { log('ReloadableController::handleLogoutOidcSuccess(): $success'); await Future.wait([ _deleteCredentialInteractor.execute(), _deleteAuthorityOidcInteractor.execute(), _cachingManager.clearAll(), _languageCacheManager.removeLanguage(), ]); _authorizationInterceptors.clear(); await HiveCacheConfig().closeHive(); _goToLogin(arguments: LoginArguments(LoginFormType.ssoForm)); } void _handleGetStoredTokenOIDCSuccess(GetStoredTokenOidcSuccess tokenOidcSuccess) { _setUpInterceptorsOidc(tokenOidcSuccess); _getSessionAction(); } void _setUpInterceptorsOidc(GetStoredTokenOidcSuccess tokenOidcSuccess) { _dynamicUrlInterceptors.changeBaseUrl(tokenOidcSuccess.baseUrl.toString()); _authorizationInterceptors.setTokenAndAuthorityOidc( newToken: tokenOidcSuccess.tokenOidc.toToken(), newConfig: tokenOidcSuccess.oidcConfiguration); } void injectAutoCompleteBindings() { AutoCompleteBindings().dependencies(); } }