Automatically register push notifications via a Session parameter

Author: Franco Bugnano

examples/push_notifications/lib/main.dart

@@ -25,8 +25,8 @@ class MyApp extends StatelessWidget {
   // This widget is the root of your application.
   @override
   Widget build(BuildContext context) {
-    //final session = Session(appId: 'Hku1c4Pt');
-    final session = Session(appId: 'tuM9UrY8'); // For local testing
+    final session = Session(appId: 'Hku1c4Pt', enablePushNotifications: true);
+    //final session = Session(appId: 'tuM9UrY8', enablePushNotifications: true); // For local testing
 
     final me = session.getUser(
       id: '123456',

lib/src/chatbox.dart

@@ -14,6 +14,7 @@ import './chatoptions.dart';
 import './user.dart';
 import './message.dart';
 import './predicate.dart';
+import './notification.dart';
 
 typedef SendMessageHandler = void Function(SendMessageEvent event);
 typedef TranslationToggledHandler = void Function(TranslationToggledEvent event);
@@ -217,6 +218,17 @@ class ChatBoxState extends State<ChatBox> {
     execute('options["me"] = $variableName;');
 
     execute('const session = new Talk.Session(options);');
+
+    // TODO: This part has to be moved in the Session once we have the data layer SDK ready
+    if (widget.session.enablePushNotifications) {
+      if (fcmToken != null) {
+        execute('session.setPushRegistration({provider: "fcm", pushRegistrationId: "$fcmToken"});');
+      }
+    } else {
+      if (fcmToken != null) {
+        execute('session.unsetPushRegistration({provider: "fcm", pushRegistrationId: "$fcmToken"});');
+      }
+    }
   }
 
   void _createChatBox() {

lib/src/conversationlist.dart

@@ -13,6 +13,7 @@ import './conversation.dart';
 import './user.dart';
 import './predicate.dart';
 import './chatbox.dart';
+import './notification.dart';
 
 typedef SelectConversationHandler = void Function(SelectConversationEvent event);
 
@@ -176,6 +177,17 @@ class ConversationListState extends State<ConversationList> {
     execute('options["me"] = $variableName;');
 
     execute('const session = new Talk.Session(options);');
+
+    // TODO: This part has to be moved in the Session once we have the data layer SDK ready
+    if (widget.session.enablePushNotifications) {
+      if (fcmToken != null) {
+        execute('session.setPushRegistration({provider: "fcm", pushRegistrationId: "$fcmToken"});');
+      }
+    } else {
+      if (fcmToken != null) {
+        execute('session.unsetPushRegistration({provider: "fcm", pushRegistrationId: "$fcmToken"});');
+      }
+    }
   }
 
   void _createConversationList() {

lib/src/notification.dart

@@ -287,6 +287,8 @@ void _onFCMTokenRefresh(String token) {
   print('📘 Firebase onTokenRefresh: $token');
 
   fcmToken = token;
+
+  // TODO: Update the token on the Talkjs server once we have the data layer SDK ready
 }
 
 Future<void> registerAndroidPushNotificationHandlers(AndroidChannel androidChannel) async {

lib/src/session.dart

@@ -35,7 +35,9 @@ class Session with ChangeNotifier {
   /// code.
   final String? signature;
 
-  Session({required this.appId, this.signature});
+  final bool enablePushNotifications;
+
+  Session({required this.appId, this.signature, this.enablePushNotifications = false});
 
   User getUser({
     required String id,