eduvia/workavia-mail-front
11
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

TF-2298 Always get token when open app

Browse Source 
Signed-off-by: dab246 <tdvu@linagora.com>
(cherry picked from commit fae6398d87fdbe2c49fa2dd69b8b20ef11171775)
This commit is contained in:
dab246
2023-12-20 20:20:35 +07:00
committed by Dat H. Pham
parent d152056473
commit bfcdda6b67
10 changed files with 106 additions and 149 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/features/push_notification/presentation/config/fcm_configuration.dart
-13
View File
@@ -1,22 +1,9 @@
import 'package:firebase_core/firebase_core.dart';
import 'package:tmail_ui_user/features/push_notification/presentation/config/firebase_options.dart';
import 'package:tmail_ui_user/features/push_notification/presentation/services/fcm_receiver.dart';
import 'package:tmail_ui_user/features/push_notification/presentation/services/fcm_service.dart';
class FcmConfiguration {
static Future<void> initialize() async {
await Firebase.initializeApp(options: DefaultFirebaseOptions.currentPlatform);
await FcmService.instance.recreateStreamController();
_initMessageListener();
}
static void _initMessageListener() {
FcmReceiver.instance.onForegroundMessage();
FcmReceiver.instance.onBackgroundMessage();
FcmReceiver.instance.onMessageOpenedApp();
FcmReceiver.instance.getFcmToken();
FcmReceiver.instance.onRefreshFcmToken();
}
}
lib/features/push_notification/presentation/controller/fcm_message_controller.dart
+28 -28
View File
@@ -28,6 +28,7 @@ import 'package:tmail_ui_user/features/login/domain/state/get_stored_token_oidc_
import 'package:tmail_ui_user/features/login/domain/usecases/get_authenticated_account_interactor.dart';
import 'package:tmail_ui_user/features/mailbox_dashboard/presentation/bindings/mailbox_dashboard_bindings.dart';
import 'package:tmail_ui_user/features/offline_mode/manager/new_email_cache_manager.dart';
import 'package:tmail_ui_user/features/push_notification/data/local/fcm_cache_manager.dart';
import 'package:tmail_ui_user/features/push_notification/presentation/action/fcm_action.dart';
import 'package:tmail_ui_user/features/push_notification/presentation/bindings/fcm_interactor_bindings.dart';
import 'package:tmail_ui_user/features/push_notification/presentation/controller/fcm_base_controller.dart';
@@ -52,51 +53,43 @@ class FcmMessageController extends FcmBaseController {
AuthorizationInterceptors? _authorizationInterceptors;
GetSessionInteractor? _getSessionInteractor;
NewEmailCacheManager? _newEmailCacheManager;
FCMCacheManager? _fcmCacheManager;
FcmMessageController._internal() {
_listenFcmStream();
}
FcmMessageController._internal();
static final FcmMessageController _instance = FcmMessageController._internal();
static FcmMessageController get instance => _instance;
void initializeFromAccountId(AccountId accountId, Session session) {
void initialize({AccountId? accountId, Session? session}) {
_currentAccountId = accountId;
_currentSession = session;
_userName = session.username;
FcmTokenController.instance.initialize();
_userName = session?.username;
_listenTokenStream();
_listenForegroundMessageStream();
_listenBackgroundMessageStream();
}
void initialize() {}
void _listenFcmStream() async {
await Future.wait([
listenForegroundMessageStream(),
listenBackgroundMessageStream(),
listenTokenStream()
]);
}
Future<void> listenForegroundMessageStream() {
FcmService.instance.foregroundMessageStream
void _listenForegroundMessageStream() {
FcmService.instance.foregroundMessageStreamController
?.stream
.throttleTime(const Duration(milliseconds: FcmService.durationMessageComing))
.listen(_handleForegroundMessageAction);
return Future.value();
}
Future<void> listenBackgroundMessageStream() {
FcmService.instance.backgroundMessageStream
void _listenBackgroundMessageStream() {
FcmService.instance.backgroundMessageStreamController
?.stream
.throttleTime(const Duration(milliseconds: FcmService.durationMessageComing))
.listen(_handleBackgroundMessageAction);
return Future.value();
}
Future<void> listenTokenStream() {
FcmService.instance.fcmTokenStream
.debounceTime(const Duration(milliseconds: FcmService.durationRefreshToken))
void _listenTokenStream() {
FcmService.instance.fcmTokenStreamController
?.stream
.throttleTime(const Duration(milliseconds: FcmService.durationRefreshToken))
.listen(FcmTokenController.instance.onFcmTokenChanged);
return Future.value();
}
void _handleForegroundMessageAction(RemoteMessage newRemoteMessage) {
@@ -201,7 +194,12 @@ class FcmMessageController extends FcmBaseController {
_getInteractorBindings();
await _newEmailCacheManager?.closeNewEmailHiveCacheBox();
await Future.wait([
if (_newEmailCacheManager != null)
_newEmailCacheManager!.closeNewEmailHiveCacheBox(),
if (_fcmCacheManager != null)
_fcmCacheManager!.closeCacheBox(),
]);
}
void _getInteractorBindings() {
@@ -210,7 +208,9 @@ class FcmMessageController extends FcmBaseController {
_authorizationInterceptors = getBinding<AuthorizationInterceptors>();
_getSessionInteractor = getBinding<GetSessionInteractor>();
_newEmailCacheManager = getBinding<NewEmailCacheManager>();
FcmTokenController.instance.initialize();
_fcmCacheManager = getBinding<FCMCacheManager>();
FcmTokenController.instance.initialBindingInteractor();
}
void _getAuthenticatedAccount() {
lib/features/push_notification/presentation/controller/fcm_token_controller.dart
+1 -1
View File
@@ -43,7 +43,7 @@ class FcmTokenController extends FcmBaseController {
UpdateFirebaseRegistrationTokenInteractor? _updateFirebaseRegistrationTokenInteractor;
DeleteFirebaseRegistrationCacheInteractor? _deleteFirebaseRegistrationCacheInteractor;
void initialize() {
void initialBindingInteractor() {
_storeFirebaseRegistrationInteractor = getBinding<StoreFirebaseRegistrationInteractor>();
_getFirebaseRegistrationByDeviceIdInteractor = getBinding<GetFirebaseRegistrationByDeviceIdInteractor>();
_registerNewFirebaseRegistrationTokenInteractor = getBinding<RegisterNewFirebaseRegistrationTokenInteractor>();
lib/features/push_notification/presentation/services/fcm_receiver.dart
+36 -21
View File
@@ -1,13 +1,15 @@
import 'package:core/utils/app_logger.dart';
import 'package:core/utils/platform_info.dart';
import 'package:firebase_messaging/firebase_messaging.dart';
import 'package:tmail_ui_user/features/push_notification/presentation/controller/fcm_message_controller.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';
import 'package:tmail_ui_user/main/utils/app_config.dart';
@pragma('vm:entry-point')
Future<void> handleFirebaseBackgroundMessage(RemoteMessage message) async {
log('FcmReceiver::handleFirebaseBackgroundMessage(): ${message.data}');
FcmService.instance.initialStreamController();
FcmMessageController.instance.initialize();
FcmService.instance.handleFirebaseBackgroundMessage(message);
}
@@ -18,35 +20,48 @@ class FcmReceiver {
static FcmReceiver get instance => _instance;
void onForegroundMessage() {
Future onInitialFcmListener() async {
log('FcmReceiver::onInitialFcmListener:');
await _onHandleFcmToken();
_onForegroundMessage();
_onBackgroundMessage();
_onMessageOpenedApp();
}
void _onForegroundMessage() {
FirebaseMessaging.onMessage.listen(FcmService.instance.handleFirebaseForegroundMessage);
}
void onBackgroundMessage() {
void _onBackgroundMessage() {
FirebaseMessaging.onBackgroundMessage(handleFirebaseBackgroundMessage);
}
void onMessageOpenedApp() {
void _onMessageOpenedApp() {
FirebaseMessaging.onMessageOpenedApp.listen(FcmService.instance.handleFirebaseMessageOpenedApp);
}
void getFcmToken() async {
try {
final currentToken = await FirebaseMessaging.instance.getToken(vapidKey: AppUtils.fcmVapidPublicKey);
log('FcmReceiver::onFcmToken():currentToken: $currentToken');
if (!FcmUtils.instance.isMobileAndroid) {
FcmService.instance.handleGetToken(currentToken);
}
} catch(e) {
log('FcmReceiver::onFcmToken():exception: $e');
}
Future<String?> _getInitialToken() async {
final token = await FirebaseMessaging.instance.getToken(
vapidKey: PlatformInfo.isWeb ? AppConfig.fcmVapidPublicKeyWeb : null
);
log('FcmReceiver::_getInitialToken:token: $token');
return token;
}
void onRefreshFcmToken() {
FirebaseMessaging.instance.onTokenRefresh.listen(FcmService.instance.handleRefreshToken);
Future _onHandleFcmToken() async {
final token = await _getInitialToken();
FcmService.instance.handleToken(token);
FirebaseMessaging.instance.onTokenRefresh.listen((newToken) {
log('FcmReceiver::_onHandleFcmToken:onTokenRefresh: $newToken');
if (newToken != token) {
FcmService.instance.handleToken(newToken);
}
});
}
void deleteFcmToken(){
FirebaseMessaging.instance.deleteToken();
Future deleteFcmToken() async {
await FirebaseMessaging.instance.deleteToken();
}
}
lib/features/push_notification/presentation/services/fcm_service.dart
+23 -61
View File
@@ -3,7 +3,6 @@ import 'dart:async';
import 'package:core/utils/app_logger.dart';
import 'package:firebase_messaging/firebase_messaging.dart';
import 'package:tmail_ui_user/features/push_notification/presentation/controller/fcm_message_controller.dart';
import 'package:tmail_ui_user/features/push_notification/presentation/notification/local_notification_manager.dart';
class FcmService {
@@ -11,37 +10,24 @@ class FcmService {
static const int durationMessageComing = 2000;
static const int durationRefreshToken = 2000;
late StreamController<RemoteMessage> foregroundMessageStreamController;
Stream<RemoteMessage> get foregroundMessageStream => foregroundMessageStreamController.stream;
StreamController<RemoteMessage>? foregroundMessageStreamController;
StreamController<RemoteMessage>? backgroundMessageStreamController;
StreamController<String?>? fcmTokenStreamController;
late StreamController<RemoteMessage> backgroundMessageStreamController;
Stream<RemoteMessage> get backgroundMessageStream => backgroundMessageStreamController.stream;
late StreamController<String?> fcmTokenStreamController;
Stream<String?> get fcmTokenStream => fcmTokenStreamController.stream;
FcmService._internal() {
foregroundMessageStreamController = StreamController<RemoteMessage>.broadcast();
backgroundMessageStreamController = StreamController<RemoteMessage>.broadcast();
fcmTokenStreamController = StreamController<String?>.broadcast();
}
FcmService._internal();
static final FcmService _instance = FcmService._internal();
static FcmService get instance => _instance;
void handleFirebaseForegroundMessage(RemoteMessage newRemoteMessage) {
log('FcmService::handleFirebaseForegroundMessage():message: ${newRemoteMessage.data}');
if (!foregroundMessageStreamController.isClosed) {
foregroundMessageStreamController.add(newRemoteMessage);
}
log('FcmService::handleFirebaseForegroundMessage():data: ${newRemoteMessage.data}');
foregroundMessageStreamController?.add(newRemoteMessage);
}
void handleFirebaseBackgroundMessage(RemoteMessage newRemoteMessage) {
FcmMessageController.instance.initialize();
if (!backgroundMessageStreamController.isClosed) {
backgroundMessageStreamController.add(newRemoteMessage);
}
log('FcmService::handleFirebaseBackgroundMessage():data: ${newRemoteMessage.data}');
backgroundMessageStreamController?.add(newRemoteMessage);
}
void handleFirebaseMessageOpenedApp(RemoteMessage newRemoteMessage) async {
@@ -49,49 +35,25 @@ class FcmService {
await LocalNotificationManager.instance.removeNotificationBadgeForIOS();
}
void handleGetToken(String? currentToken) async {
log('FcmService::handleGetToken():currentToken: $currentToken');
if (fcmTokenStreamController.isClosed) {
log('FcmService::handleGetToken():fcmTokenStreamController: isClosed');
fcmTokenStreamController = StreamController<String?>.broadcast();
await FcmMessageController.instance.listenTokenStream();
}
if (!fcmTokenStreamController.isClosed) {
fcmTokenStreamController.add(currentToken);
}
void handleToken(String? token) {
log('FcmService::handleToken():token: $token');
fcmTokenStreamController?.add(token);
}
void handleRefreshToken(String? newToken) async {
log('FcmService::handleRefreshToken():newToken: $newToken');
if (fcmTokenStreamController.isClosed) {
log('FcmService::handleRefreshToken():fcmTokenStreamController: isClosed');
fcmTokenStreamController = StreamController<String?>.broadcast();
await FcmMessageController.instance.listenTokenStream();
}
if (!fcmTokenStreamController.isClosed) {
fcmTokenStreamController.add(newToken);
}
}
Future<void> recreateStreamController() async {
if (foregroundMessageStreamController.isClosed) {
foregroundMessageStreamController = StreamController<RemoteMessage>.broadcast();
await FcmMessageController.instance.listenForegroundMessageStream();
}
if (backgroundMessageStreamController.isClosed) {
backgroundMessageStreamController = StreamController<RemoteMessage>.broadcast();
await FcmMessageController.instance.listenBackgroundMessageStream();
}
if (fcmTokenStreamController.isClosed) {
fcmTokenStreamController = StreamController<String?>.broadcast();
await FcmMessageController.instance.listenTokenStream();
}
return Future.value();
void initialStreamController() {
log('FcmService::initialStreamController:');
foregroundMessageStreamController = StreamController<RemoteMessage>.broadcast();
backgroundMessageStreamController = StreamController<RemoteMessage>.broadcast();
fcmTokenStreamController = StreamController<String?>.broadcast();
}
void closeStream() {
foregroundMessageStreamController.close();
backgroundMessageStreamController.close();
fcmTokenStreamController.close();
foregroundMessageStreamController?.close();
backgroundMessageStreamController?.close();
fcmTokenStreamController?.close();
foregroundMessageStreamController = null;
backgroundMessageStreamController = null;
fcmTokenStreamController = null;
}
}