TF-439 Add stream controller to handle get/refresh fcm token

lib/features/push_notification/presentation/config/fcm_configuration.dart

@@ -14,5 +14,6 @@ class FcmConfiguration {
     FcmReceiver.instance.onForegroundMessage();
     FcmReceiver.instance.onBackgroundMessage();
     FcmReceiver.instance.getFcmToken();
+    FcmReceiver.instance.onRefreshFcmToken();
   }
 }

lib/features/push_notification/presentation/services/fcm_receiver.dart

@@ -28,5 +28,12 @@ class FcmReceiver {
   void getFcmToken() async {
     final token = await FirebaseMessaging.instance.getToken();
     log('FcmReceiver::onFcmToken():token: $token');
+    if (token?.isNotEmpty == true) {
+      FcmService.instance.handleRefreshToken(token!);
+    }
+  }
+
+  void onRefreshFcmToken() {
+    FirebaseMessaging.instance.onTokenRefresh.listen(FcmService.instance.handleRefreshToken);
   }
 }

lib/features/push_notification/presentation/services/fcm_service.dart

@@ -16,6 +16,9 @@ class FcmService {
   final StreamController<RemoteMessage> backgroundMessageStreamController = StreamController<RemoteMessage>.broadcast();
   Stream<RemoteMessage> get backgroundMessageStream => backgroundMessageStreamController.stream;
 
+  final StreamController<String> fcmTokenStreamController = StreamController<String>.broadcast();
+  Stream<String> get fcmTokenStream => fcmTokenStreamController.stream;
+
   FirebaseToken? currentToken;
 
   FcmService._internal();
@@ -35,6 +38,10 @@ class FcmService {
     backgroundMessageStreamController.add(newRemoteMessage);
   }
 
+  void handleRefreshToken(String newToken) {
+    fcmTokenStreamController.add(newToken);
+  }
+
   void _closeStream() {
     foregroundMessageStreamController.close();
     backgroundMessageStreamController.close();