diff --git a/lib/features/base/base_controller.dart b/lib/features/base/base_controller.dart index 1c975df29..92dc926a5 100644 --- a/lib/features/base/base_controller.dart +++ b/lib/features/base/base_controller.dart @@ -228,11 +228,11 @@ abstract class BaseController extends GetxController final mapEnvData = Map.from(dotenv.env); await AppUtils.loadFcmConfigFileToEnv(currentMapEnvData: mapEnvData); FcmConfiguration.initialize(); - if (!BuildUtils.isWeb) { - await LocalNotificationManager.instance.setUp(); - } FcmInteractorBindings().dependencies(); - FcmMessageController.instance.initialize(session: session, accountId: accountId); + FcmMessageController.instance.initializeFromAccountId(accountId); + if (!BuildUtils.isWeb) { + LocalNotificationManager.instance.setUp(); + } } else { throw NotSupportFCMException(); } diff --git a/lib/features/push_notification/presentation/action/fcm_action.dart b/lib/features/push_notification/presentation/action/fcm_action.dart index 847d377de..34e757730 100644 --- a/lib/features/push_notification/presentation/action/fcm_action.dart +++ b/lib/features/push_notification/presentation/action/fcm_action.dart @@ -21,7 +21,7 @@ class SynchronizeEmailOnForegroundAction extends FcmStateChangeAction { class PushNotificationAction extends FcmStateChangeAction { - final Session session; + final Session? session; final AccountId accountId; PushNotificationAction( diff --git a/lib/features/push_notification/presentation/controller/fcm_message_controller.dart b/lib/features/push_notification/presentation/controller/fcm_message_controller.dart index 6c6a78462..203960679 100644 --- a/lib/features/push_notification/presentation/controller/fcm_message_controller.dart +++ b/lib/features/push_notification/presentation/controller/fcm_message_controller.dart @@ -3,6 +3,7 @@ import 'dart:async'; import 'package:collection/collection.dart'; import 'package:core/data/network/config/dynamic_url_interceptors.dart'; +import 'package:core/presentation/extensions/uri_extension.dart'; import 'package:core/presentation/state/failure.dart'; import 'package:core/presentation/state/success.dart'; import 'package:core/utils/app_logger.dart'; @@ -32,6 +33,8 @@ import 'package:tmail_ui_user/features/push_notification/presentation/listener/e import 'package:tmail_ui_user/features/push_notification/presentation/listener/mailbox_change_listener.dart'; import 'package:tmail_ui_user/features/push_notification/presentation/services/fcm_service.dart'; import 'package:tmail_ui_user/features/push_notification/presentation/utils/fcm_utils.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/routes/route_navigation.dart'; @@ -44,6 +47,7 @@ class FcmMessageController extends FcmBaseController { GetAuthenticatedAccountInteractor? _getAuthenticatedAccountInteractor; DynamicUrlInterceptors? _dynamicUrlInterceptors; AuthorizationInterceptors? _authorizationInterceptors; + GetSessionInteractor? _getSessionInteractor; FcmMessageController._internal() { _listenFcmStream(); @@ -53,12 +57,13 @@ class FcmMessageController extends FcmBaseController { static FcmMessageController get instance => _instance; - void initialize({Session? session, AccountId? accountId}) { - _currentSession = session; + void initializeFromAccountId(AccountId accountId) { _currentAccountId = accountId; FcmTokenController.instance.initialize(); } + void initialize() {} + void _listenFcmStream() async { await Future.wait([ listenForegroundMessageStream(), @@ -89,11 +94,11 @@ class FcmMessageController extends FcmBaseController { } void _handleForegroundMessageAction(RemoteMessage newRemoteMessage) { - log('FcmMessageController::_handleForegroundMessageAction():remoteMessage: ${newRemoteMessage.data}'); - if (_currentAccountId != null && _currentSession != null) { + log('FcmMessageController::_handleForegroundMessageAction():remoteMessage: ${newRemoteMessage.data} | _currentAccountId: $_currentAccountId'); + if (_currentAccountId != null) { final stateChange = _convertRemoteMessageToStateChange(newRemoteMessage); final mapTypeState = stateChange.getMapTypeState(_currentAccountId!); - _mappingTypeStateToAction(_currentSession!, mapTypeState, _currentAccountId!); + _mappingTypeStateToAction(mapTypeState, _currentAccountId!); } } @@ -109,10 +114,10 @@ class FcmMessageController extends FcmBaseController { } void _mappingTypeStateToAction( - Session session, Map mapTypeState, AccountId accountId, { bool isForeground = true, + Session? session }) { log('FcmMessageController::_mappingTypeStateToAction():mapTypeState: $mapTypeState'); final listTypeName = mapTypeState.keys @@ -121,7 +126,7 @@ class FcmMessageController extends FcmBaseController { final listEmailActions = listTypeName .where((typeName) => typeName == TypeName.emailType || typeName == TypeName.emailDelivery) - .map((typeName) => toFcmAction(session, typeName, accountId, mapTypeState, isForeground)) + .map((typeName) => toFcmAction(typeName, accountId, mapTypeState, isForeground, session: session)) .whereNotNull() .toList(); @@ -133,7 +138,7 @@ class FcmMessageController extends FcmBaseController { final listMailboxActions = listTypeName .where((typeName) => typeName == TypeName.mailboxType) - .map((typeName) => toFcmAction(session, typeName, accountId, mapTypeState, isForeground)) + .map((typeName) => toFcmAction(typeName, accountId, mapTypeState, isForeground)) .whereNotNull() .toList(); @@ -145,11 +150,13 @@ class FcmMessageController extends FcmBaseController { } FcmAction? toFcmAction( - Session session, TypeName typeName, AccountId accountId, Map mapTypeState, - isForeground + isForeground, + { + Session? session + } ) { final newState = jmap.State(mapTypeState[typeName.value]); if (typeName == TypeName.emailType) { @@ -192,6 +199,7 @@ class FcmMessageController extends FcmBaseController { _getAuthenticatedAccountInteractor = getBinding(); _dynamicUrlInterceptors = getBinding(); _authorizationInterceptors = getBinding(); + _getSessionInteractor = getBinding(); FcmTokenController.instance.initialize(); } catch (e) { logError('FcmMessageController::_getBindings(): ${e.toString()}'); @@ -210,34 +218,74 @@ class FcmMessageController extends FcmBaseController { void _handleGetAuthenticatedAccountSuccess(GetAuthenticatedAccountSuccess success) { _currentAccountId = success.account.accountId; - _dynamicUrlInterceptors?.changeBaseUrl(success.account.apiUrl); + if (!FcmUtils.instance.isMobileAndroid) { + _dynamicUrlInterceptors?.changeBaseUrl(success.account.apiUrl); + } log('FcmMessageController::_handleGetAuthenticatedAccountSuccess():_currentAccountId: $_currentAccountId'); } void _handleGetAccountByOidcSuccess(GetStoredTokenOidcSuccess storedTokenOidcSuccess) { log('FcmMessageController::_handleGetAccountByOidcSuccess():'); + _dynamicUrlInterceptors?.setJmapUrl(storedTokenOidcSuccess.baseUrl.toString()); _authorizationInterceptors?.setTokenAndAuthorityOidc( newToken: storedTokenOidcSuccess.tokenOidc.toToken(), newConfig: storedTokenOidcSuccess.oidcConfiguration ); - _pushActionFromRemoteMessageBackground(); + + if (FcmUtils.instance.isMobileAndroid) { + _dynamicUrlInterceptors?.changeBaseUrl(storedTokenOidcSuccess.baseUrl.toString()); + _getSessionAction(); + } else { + _pushActionFromRemoteMessageBackground(); + } } void _handleGetAccountByBasicAuthSuccess(GetCredentialViewState credentialViewState) { log('FcmMessageController::_handleGetAccountByBasicAuthSuccess():'); + _dynamicUrlInterceptors?.setJmapUrl(credentialViewState.baseUrl.toString()); _authorizationInterceptors?.setBasicAuthorization( credentialViewState.userName.userName, credentialViewState.password.value, ); - _pushActionFromRemoteMessageBackground(); + if (FcmUtils.instance.isMobileAndroid) { + _dynamicUrlInterceptors?.changeBaseUrl(credentialViewState.baseUrl.toString()); + _getSessionAction(); + } else { + _pushActionFromRemoteMessageBackground(); + } + } + + void _getSessionAction() { + if (_getSessionInteractor != null) { + consumeState(_getSessionInteractor!.execute().asStream()); + } else { + _clearRemoteMessageBackground(); + logError('FcmMessageController::_getSessionAction():_getSessionInteractor is null'); + } + } + + void _handleGetSessionSuccess(GetSessionSuccess success) { + _currentSession = success.session; + final jmapUrl = _dynamicUrlInterceptors?.jmapUrl; + final apiUrl = jmapUrl != null + ? success.session.apiUrl.toQualifiedUrl(baseUrl: Uri.parse(jmapUrl)).toString() + : success.session.apiUrl.toString(); + log('FcmMessageController::_pushActionFromRemoteMessageBackground():jmapUrl: $jmapUrl | apiUrl: $apiUrl'); + if (apiUrl.isNotEmpty) { + _dynamicUrlInterceptors?.changeBaseUrl(apiUrl); + _pushActionFromRemoteMessageBackground(); + } else { + _clearRemoteMessageBackground(); + logError('FcmMessageController::_handleGetSessionSuccess():apiUrl is null'); + } } void _pushActionFromRemoteMessageBackground() { - log('FcmMessageController::_pushActionFromRemoteMessageBackground():'); - if (_remoteMessageBackground != null && _currentAccountId != null && _currentSession != null) { + log('FcmMessageController::_pushActionFromRemoteMessageBackground():_remoteMessageBackground: $_remoteMessageBackground | _currentAccountId: $_currentAccountId | _currentSession: $_currentSession'); + if (_remoteMessageBackground != null && _currentAccountId != null) { final stateChange = _convertRemoteMessageToStateChange(_remoteMessageBackground!); final mapTypeState = stateChange.getMapTypeState(_currentAccountId!); - _mappingTypeStateToAction(_currentSession!, mapTypeState, _currentAccountId!, isForeground: false); + _mappingTypeStateToAction(mapTypeState, _currentAccountId!, isForeground: false, session: _currentSession); } _clearRemoteMessageBackground(); } @@ -257,6 +305,8 @@ class FcmMessageController extends FcmBaseController { log('FcmMessageController::_handleSuccessViewState(): $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) { diff --git a/lib/features/push_notification/presentation/listener/email_change_listener.dart b/lib/features/push_notification/presentation/listener/email_change_listener.dart index e5bb69f00..9e4a7517a 100644 --- a/lib/features/push_notification/presentation/listener/email_change_listener.dart +++ b/lib/features/push_notification/presentation/listener/email_change_listener.dart @@ -82,9 +82,10 @@ class EmailChangeListener extends ChangeListener { } } - void _pushNotificationAction(jmap.State newState, AccountId accountId, Session session) { + void _pushNotificationAction(jmap.State newState, AccountId accountId, Session? session) { _newState = newState; _accountId = accountId; + _session = session; log('EmailChangeListener::_pushNotificationAction():newState: $newState'); if (BuildUtils.isWeb) { @@ -184,7 +185,7 @@ class EmailChangeListener extends ChangeListener { if (_newState != null) { _storeEmailDeliveryStateAction(_newState!); - if (!BuildUtils.isWeb && Platform.isAndroid) { + if (FcmUtils.instance.isMobileAndroid) { _handleLocalPushNotification(success.emailList); } } diff --git a/lib/features/push_notification/presentation/notification/local_notification_manager.dart b/lib/features/push_notification/presentation/notification/local_notification_manager.dart index 3f187d066..f236e1de7 100644 --- a/lib/features/push_notification/presentation/notification/local_notification_manager.dart +++ b/lib/features/push_notification/presentation/notification/local_notification_manager.dart @@ -131,6 +131,9 @@ class LocalNotificationManager { EmailAddress? emailAddress, String? payload }) async { + if (!_notificationsEnabled) { + return; + } final inboxStyleInformation = InboxStyleInformation( [message?.addBlockTag('p', attribute: 'style="color:#6D7885;"') ?? ''], htmlFormatLines: true, diff --git a/lib/features/push_notification/presentation/services/fcm_receiver.dart b/lib/features/push_notification/presentation/services/fcm_receiver.dart index 5103cdfec..e3daf22ad 100644 --- a/lib/features/push_notification/presentation/services/fcm_receiver.dart +++ b/lib/features/push_notification/presentation/services/fcm_receiver.dart @@ -1,8 +1,8 @@ import 'package:core/utils/app_logger.dart'; -import 'package:core/utils/build_utils.dart'; import 'package:firebase_messaging/firebase_messaging.dart'; import 'package:tmail_ui_user/features/push_notification/presentation/services/fcm_service.dart'; +import 'package:tmail_ui_user/features/push_notification/presentation/utils/fcm_utils.dart'; import 'package:tmail_ui_user/main/utils/app_utils.dart'; @pragma('vm:entry-point') @@ -30,7 +30,7 @@ class FcmReceiver { try { final currentToken = await FirebaseMessaging.instance.getToken(vapidKey: AppUtils.fcmVapidPublicKey); log('FcmReceiver::onFcmToken():currentToken: $currentToken'); - if (BuildUtils.isWeb) { + if (!FcmUtils.instance.isMobileAndroid) { FcmService.instance.handleGetToken(currentToken); } } catch(e) { diff --git a/lib/features/push_notification/presentation/utils/fcm_utils.dart b/lib/features/push_notification/presentation/utils/fcm_utils.dart index c63ec4096..36e4f8551 100644 --- a/lib/features/push_notification/presentation/utils/fcm_utils.dart +++ b/lib/features/push_notification/presentation/utils/fcm_utils.dart @@ -108,4 +108,6 @@ class FcmUtils { log('FcmUtils::hashCodeTokenToDeviceId():deviceId: $deviceId'); return deviceId; } + + bool get isMobileAndroid => !BuildUtils.isWeb && Platform.isAndroid; } \ No newline at end of file diff --git a/lib/main/bindings/session/session_bindings.dart b/lib/main/bindings/session/session_bindings.dart index 801f1f44e..bd66a86cb 100644 --- a/lib/main/bindings/session/session_bindings.dart +++ b/lib/main/bindings/session/session_bindings.dart @@ -1,5 +1,5 @@ import 'package:get/get.dart'; -import 'package:tmail_ui_user/features/base/base_bindings.dart'; +import 'package:tmail_ui_user/features/base/interactors_bindings.dart'; import 'package:tmail_ui_user/features/session/data/datasource/session_datasource.dart'; import 'package:tmail_ui_user/features/session/data/datasource_impl/session_datasource_impl.dart'; import 'package:tmail_ui_user/features/session/data/network/session_api.dart'; @@ -8,11 +8,7 @@ import 'package:tmail_ui_user/features/session/domain/repository/session_reposit import 'package:tmail_ui_user/features/session/domain/usecases/get_session_interactor.dart'; import 'package:tmail_ui_user/main/exceptions/remote_exception_thrower.dart'; -class SessionBindings extends BaseBindings { - - @override - void bindingsController() { - } +class SessionBindings extends InteractorsBindings { @override void bindingsDataSource() {