Added Talk.initPushNotificationHandlers and Talk.handleFCMBackgroundMessage

Author: Franco Bugnano

lib/src/notification.dart

@@ -202,112 +202,114 @@ Future<ByteArrayAndroidIcon?> _androidIconFromUrl(String? url) async {
 
 @pragma("vm:entry-point")
 Future<void> _onFCMBackgroundMessage(RemoteMessage firebaseMessage) async {
+  await handleTalkJSFCMBackgroundMessage(firebaseMessage);
+}
+
+Future<bool> handleTalkJSFCMBackgroundMessage(
+    RemoteMessage firebaseMessage) async {
   print("📘 Handling a background message: ${firebaseMessage.messageId}");
 
   print('📘 Message data: ${firebaseMessage.data}');
 
   if (firebaseMessage.notification != null) {
     print(
-        '📘 Message also contained a notification: ${firebaseMessage.notification}');
+      '📘 Message also contained a notification: ${firebaseMessage.notification}',
+    );
   }
 
   final data = firebaseMessage.data;
   StyleInformation styleInformation;
   styleInformation = MessagingStyleInformation(Person(name: 'me'));
   int showId;
-  if (data['talkjs'] is String) {
-    print("📘 _onFCMBackgroundMessage: data['talkjs'] is String");
-    final Map<String, dynamic> talkjsData = json.decode(data['talkjs']);
-    final String notificationId = talkjsData['conversation']['id'];
 
-    if (!_showIdFromNotificationId.containsKey(notificationId)) {
-      _showIdFromNotificationId[notificationId] = _nextId;
-      _nextId += 1;
-    }
+  if (!(data['talkjs'] is String)) {
+    print("📘 _onFCMBackgroundMessage: data['talkjs'] is NOT String");
+    return false;
+  }
 
-    showId = _showIdFromNotificationId[notificationId]!;
+  print("📘 _onFCMBackgroundMessage: data['talkjs'] is String");
+  final Map<String, dynamic> talkjsData = json.decode(data['talkjs']);
+  final String notificationId = talkjsData['conversation']['id'];
 
-    final timestamp =
-        DateTime.fromMillisecondsSinceEpoch(talkjsData['timestamp']);
+  if (!_showIdFromNotificationId.containsKey(notificationId)) {
+    _showIdFromNotificationId[notificationId] = _nextId;
+    _nextId += 1;
+  }
 
-    final activeNotifications = _activeNotifications[notificationId];
+  showId = _showIdFromNotificationId[notificationId]!;
 
-    if (activeNotifications == null) {
-      print("📘 _onFCMBackgroundMessage: activeNotifications == null");
-      _activeNotifications[notificationId] = [data['talkjs']];
+  final timestamp =
+      DateTime.fromMillisecondsSinceEpoch(talkjsData['timestamp']);
 
-      final attachment = talkjsData['message']['attachment'];
+  final activeNotifications = _activeNotifications[notificationId];
 
-      if (attachment != null) {
-        print("📘 _onFCMBackgroundMessage: attachment != null");
-        final picture = await _androidBitmapFromUrl(attachment['url']);
-        if (picture != null) {
-          print("📘 _onFCMBackgroundMessage: picture != null");
-          styleInformation = BigPictureStyleInformation(picture);
-        } else {
-          print("📘 _onFCMBackgroundMessage: picture == null");
-        }
+  if (activeNotifications == null) {
+    print("📘 _onFCMBackgroundMessage: activeNotifications == null");
+    _activeNotifications[notificationId] = [data['talkjs']];
+
+    final attachment = talkjsData['message']['attachment'];
+
+    if (attachment != null) {
+      print("📘 _onFCMBackgroundMessage: attachment != null");
+      final picture = await _androidBitmapFromUrl(attachment['url']);
+      if (picture != null) {
+        print("📘 _onFCMBackgroundMessage: picture != null");
+        styleInformation = BigPictureStyleInformation(picture);
       } else {
-        print("📘 _onFCMBackgroundMessage: attachment == null");
-        final sender = talkjsData['sender'];
-        styleInformation = MessagingStyleInformation(
-          Person(
-            name: 'me',
-          ),
-          groupConversation:
-              talkjsData['conversation']['participants'].length > 2,
-          messages: [
-            Message(
-              talkjsData['message']['text'],
-              timestamp,
-              Person(
-                icon: await _androidIconFromUrl(sender['photoUrl']),
-                key: sender['id'],
-                name: sender['name'],
-              ),
-            ),
-          ],
-        );
+        print("📘 _onFCMBackgroundMessage: picture == null");
       }
     } else {
-      print("📘 _onFCMBackgroundMessage: activeNotifications != null");
-      activeNotifications.add(data['talkjs']);
-      final messages = <Message>[];
-      for (final talkjsString in activeNotifications) {
-        final Map<String, dynamic> messageTalkjsData =
-            json.decode(talkjsString);
-        final messageTimestamp =
-            DateTime.fromMillisecondsSinceEpoch(messageTalkjsData['timestamp']);
-        final messageSender = talkjsData['sender'];
-
-        messages.add(
-          Message(
-            messageTalkjsData['message']['text'],
-            messageTimestamp,
-            Person(
-              icon: await _androidIconFromUrl(messageSender['photoUrl']),
-              key: messageSender['id'],
-              name: messageSender['name'],
-            ),
-          ),
-        );
-      }
-
+      print("📘 _onFCMBackgroundMessage: attachment == null");
+      final sender = talkjsData['sender'];
       styleInformation = MessagingStyleInformation(
         Person(
           name: 'me',
         ),
         groupConversation:
             talkjsData['conversation']['participants'].length > 2,
-        messages: messages,
+        messages: [
+          Message(
+            talkjsData['message']['text'],
+            timestamp,
+            Person(
+              icon: await _androidIconFromUrl(sender['photoUrl']),
+              key: sender['id'],
+              name: sender['name'],
+            ),
+          ),
+        ],
       );
     }
   } else {
-    print("📘 _onFCMBackgroundMessage: data['talkjs'] is NOT String");
-    showId = _nextId;
-    _nextId += 1;
+    print("📘 _onFCMBackgroundMessage: activeNotifications != null");
+    activeNotifications.add(data['talkjs']);
+    final messages = <Message>[];
+    for (final talkjsString in activeNotifications) {
+      final Map<String, dynamic> messageTalkjsData = json.decode(talkjsString);
+      final messageTimestamp =
+          DateTime.fromMillisecondsSinceEpoch(messageTalkjsData['timestamp']);
+      final messageSender = talkjsData['sender'];
+
+      messages.add(
+        Message(
+          messageTalkjsData['message']['text'],
+          messageTimestamp,
+          Person(
+            icon: await _androidIconFromUrl(messageSender['photoUrl']),
+            key: messageSender['id'],
+            name: messageSender['name'],
+          ),
+        ),
+      );
+    }
 
-    styleInformation = DefaultStyleInformation(false, false);
+    styleInformation = MessagingStyleInformation(
+      Person(
+        name: 'me',
+      ),
+      groupConversation: talkjsData['conversation']['participants'].length > 2,
+      messages: messages,
+    );
   }
 
   // Fetch the push notification settings from shared preferences.
@@ -350,6 +352,8 @@ Future<void> _onFCMBackgroundMessage(RemoteMessage firebaseMessage) async {
     platformChannelSpecifics, // notificationDetails
     payload: data['talkjs'],
   );
+
+  return true;
 }
 
 // The commented code is for when we will upgrade to flutter_local_notifications version 10
@@ -373,8 +377,9 @@ void _onFCMTokenRefresh(String token) {
   // TODO: Update the token on the Talkjs server once we have the data layer SDK ready
 }
 
-Future<void> registerAndroidPushNotificationHandlers(
-    AndroidSettings androidSettings) async {
+Future<void> initAndroidPushNotificationHandlers(
+  AndroidSettings androidSettings,
+) async {
   // Get the token each time the application loads
   fcmToken = await FirebaseMessaging.instance.getToken();
   print('📘 Firebase token: $fcmToken');
@@ -433,6 +438,12 @@ Future<void> registerAndroidPushNotificationHandlers(
     // PlatformException is raised on Android < 6.0
     // Simply ignoring this part
   }
+}
+
+Future<void> registerAndroidPushNotificationHandlers(
+  AndroidSettings androidSettings,
+) async {
+  await initAndroidPushNotificationHandlers(androidSettings);
 
   FirebaseMessaging.onBackgroundMessage(_onFCMBackgroundMessage);
 }
@@ -448,8 +459,9 @@ Future<void> _onPush(String name, ApnsRemoteMessage message) async {
   }
 }
 
-Future<void> registerIOSPushNotificationHandlers(
-    IOSSettings iosSettings) async {
+Future<void> initIOSPushNotificationHandlers(
+  IOSSettings iosSettings,
+) async {
   final connector = ApnsPushConnectorOnly();
 
   connector.configureApns(
@@ -471,3 +483,9 @@ Future<void> registerIOSPushNotificationHandlers(
     });
   }
 }
+
+Future<void> registerIOSPushNotificationHandlers(
+  IOSSettings iosSettings,
+) async {
+  await initIOSPushNotificationHandlers(iosSettings);
+}

lib/talkjs_flutter.dart

@@ -34,14 +34,27 @@ class Talk {
     return hash.substring(0, 20);
   }
 
-  static Future<void> registerPushNotificationHandlers(
-      {AndroidSettings? androidSettings, IOSSettings? iosSettings}) async {
+  static Future<void> registerPushNotificationHandlers({
+    AndroidSettings? androidSettings,
+    IOSSettings? iosSettings,
+  }) async {
     if ((Platform.isAndroid) && (androidSettings != null)) {
       await registerAndroidPushNotificationHandlers(androidSettings);
+    } else if ((Platform.isIOS) && (iosSettings != null)) {
+      await registerIOSPushNotificationHandlers(iosSettings);
     }
+  }
 
-    if ((Platform.isIOS) && (iosSettings != null)) {
-      await registerIOSPushNotificationHandlers(iosSettings);
+  static Future<void> initPushNotificationHandlers({
+    AndroidSettings? androidSettings,
+    IOSSettings? iosSettings,
+  }) async {
+    if ((Platform.isAndroid) && (androidSettings != null)) {
+      await initAndroidPushNotificationHandlers(androidSettings);
+    } else if ((Platform.isIOS) && (iosSettings != null)) {
+      await initIOSPushNotificationHandlers(iosSettings);
     }
   }
+
+  static const handleFCMBackgroundMessage = handleTalkJSFCMBackgroundMessage;
 }