Refactoring FirebaseController

lib/components/matrix.dart

@@ -1,25 +1,17 @@
 import 'dart:async';
-import 'dart:convert';
 import 'dart:io';
 
 import 'package:famedlysdk/famedlysdk.dart';
-import 'package:firebase_messaging/firebase_messaging.dart';
 import 'package:fluffychat/components/dialogs/simple_dialogs.dart';
+import 'package:fluffychat/utils/firebase_controller.dart';
 import 'package:flutter/foundation.dart';
 import 'package:flutter/material.dart';
-import 'package:flutter_local_notifications/flutter_local_notifications.dart';
-import 'package:flutter_styled_toast/flutter_styled_toast.dart';
 import 'package:localstorage/localstorage.dart';
-import 'package:path_provider/path_provider.dart';
 import 'package:url_launcher/url_launcher.dart';
 
 import '../i18n/i18n.dart';
-import '../utils/app_route.dart';
 import '../utils/beautify_string_extension.dart';
-import '../utils/event_extension.dart';
 import '../utils/famedlysdk_store.dart';
-import '../utils/room_extension.dart';
-import '../views/chat.dart';
 import 'avatar.dart';
 
 class Matrix extends StatefulWidget {
@@ -41,7 +33,7 @@ class Matrix extends StatefulWidget {
   static MatrixState of(BuildContext context) {
     MatrixState newState =
         (context.dependOnInheritedWidgetOfExactType<_InheritedMatrix>()).data;
-    newState.context = context;
+    newState.context = FirebaseController.context = context;
     return newState;
   }
 }
@@ -50,9 +42,6 @@ class MatrixState extends State<Matrix> {
   Client client;
   BuildContext context;
 
-  FirebaseMessaging _firebaseMessaging = FirebaseMessaging();
-  FlutterLocalNotificationsPlugin _flutterLocalNotificationsPlugin =
-      FlutterLocalNotificationsPlugin();
   Map<String, dynamic> get shareContent => _shareContent;
   set shareContent(Map<String, dynamic> content) {
     _shareContent = content;
@@ -77,213 +66,16 @@ class MatrixState extends State<Matrix> {
     await storage.deleteItem(widget.clientName);
   }
 
-  Future<String> downloadAndSaveContent(Uri content,
-      {int width, int height, ThumbnailMethod method}) async {
-    final bool thumbnail = width == null && height == null ? false : true;
-    final String tempDirectory = (await getTemporaryDirectory()).path;
-    final String prefix = thumbnail ? "thumbnail" : "";
-    File file =
-        File('$tempDirectory/${prefix}_${content.toString().split("/").last}');
-
-    if (!file.existsSync()) {
-      final url = thumbnail
-          ? content.getThumbnail(client,
-              width: width, height: height, method: method)
-          : content.getDownloadLink(client);
-      var request = await HttpClient().getUrl(Uri.parse(url));
-      var response = await request.close();
-      var bytes = await consolidateHttpClientResponseBytes(response);
-      await file.writeAsBytes(bytes);
-    }
-
-    return file.path;
-  }
-
-  Future<void> setupFirebase() async {
-    if (Platform.isIOS) iOS_Permission();
-
-    String token;
-    try {
-      token = await _firebaseMessaging.getToken();
-    } catch (_) {
-      token = null;
-    }
-    if (token?.isEmpty ?? true) {
-      showToast(
-        I18n.of(context).noGoogleServicesWarning,
-        duration: Duration(seconds: 15),
-      );
-      return;
-    }
-    await client.setPushers(
-      token,
-      "http",
-      "chat.fluffy.fluffychat",
-      widget.clientName,
-      client.deviceName,
-      "en",
-      "https://janian.de:7023/",
-      append: false,
-      format: "event_id_only",
-    );
-
-    Function goToRoom = (dynamic message) async {
-      try {
-        String roomId;
-        if (message is String) {
-          roomId = message;
-        } else if (message is Map) {
-          roomId = (message["data"] ?? message)["room_id"];
-        }
-        if (roomId?.isEmpty ?? true) throw ("Bad roomId");
-        await Navigator.of(context).pushAndRemoveUntil(
-            AppRoute.defaultRoute(
-              context,
-              ChatView(roomId),
-            ),
-            (r) => r.isFirst);
-      } catch (_) {
-        showToast("Failed to open chat...");
-        debugPrint(_);
-      }
-    };
-
-    // initialise the plugin. app_icon needs to be a added as a drawable resource to the Android head project
-    var initializationSettingsAndroid =
-        AndroidInitializationSettings('notifications_icon');
-    var initializationSettingsIOS =
-        IOSInitializationSettings(onDidReceiveLocalNotification: (i, a, b, c) {
-      return null;
-    });
-    var initializationSettings = InitializationSettings(
-        initializationSettingsAndroid, initializationSettingsIOS);
-    await _flutterLocalNotificationsPlugin.initialize(initializationSettings,
-        onSelectNotification: goToRoom);
-
-    _firebaseMessaging.configure(
-      onMessage: (Map<String, dynamic> message) async {
-        try {
-          final data = message['data'] ?? message;
-          final String roomId = data["room_id"];
-          final String eventId = data["event_id"];
-          final int unread = json.decode(data["counts"])["unread"];
-          if ((roomId?.isEmpty ?? true) ||
-              (eventId?.isEmpty ?? true) ||
-              unread == 0) {
-            await _flutterLocalNotificationsPlugin.cancelAll();
-            return null;
-          }
-          if (activeRoomId == roomId) return null;
-
-          // Get the room
-          Room room = client.getRoomById(roomId);
-          if (room == null) {
-            await client.onRoomUpdate.stream
-                .where((u) => u.id == roomId)
-                .first
-                .timeout(Duration(seconds: 10));
-            room = client.getRoomById(roomId);
-            if (room == null) return null;
-          }
-
-          // Get the event
-          Event event = await client.store.getEventById(eventId, room);
-          if (event == null) {
-            final EventUpdate eventUpdate = await client.onEvent.stream
-                .where((u) => u.content["event_id"] == eventId)
-                .first
-                .timeout(Duration(seconds: 10));
-            event = Event.fromJson(eventUpdate.content, room);
-            if (room == null) return null;
-          }
-
-          // Count all unread events
-          int unreadEvents = 0;
-          client.rooms
-              .forEach((Room room) => unreadEvents += room.notificationCount);
-
-          // Calculate title
-          final String title = unread > 1
-              ? I18n.of(context).unreadMessagesInChats(
-                  unreadEvents.toString(), unread.toString())
-              : I18n.of(context).unreadMessages(unreadEvents.toString());
-
-          // Calculate the body
-          final String body = event.getLocalizedBody(context,
-              withSenderNamePrefix: true, hideReply: true);
-
-          // The person object for the android message style notification
-          final person = Person(
-            name: room.getLocalizedDisplayname(context),
-            icon: room.avatar == null
-                ? null
-                : await downloadAndSaveContent(
-                    room.avatar,
-                    width: 126,
-                    height: 126,
-                  ),
-            iconSource: IconSource.FilePath,
-          );
-
-          // Show notification
-          var androidPlatformChannelSpecifics = AndroidNotificationDetails(
-              'fluffychat_push',
-              'FluffyChat push channel',
-              'Push notifications for FluffyChat',
-              style: AndroidNotificationStyle.Messaging,
-              styleInformation: MessagingStyleInformation(
-                person,
-                conversationTitle: title,
-                messages: [
-                  Message(
-                    body,
-                    event.time,
-                    person,
-                  )
-                ],
-              ),
-              importance: Importance.Max,
-              priority: Priority.High,
-              ticker: I18n.of(context).newMessageInFluffyChat);
-          var iOSPlatformChannelSpecifics = IOSNotificationDetails();
-          var platformChannelSpecifics = NotificationDetails(
-              androidPlatformChannelSpecifics, iOSPlatformChannelSpecifics);
-          await _flutterLocalNotificationsPlugin.show(
-              0,
-              room.getLocalizedDisplayname(context),
-              body,
-              platformChannelSpecifics,
-              payload: roomId);
-        } catch (exception) {
-          debugPrint("[Push] Error while processing notification: " +
-              exception.toString());
-        }
-        return null;
-      },
-      onResume: goToRoom,
-      // Currently fires unexpectetly... https://github.com/FirebaseExtended/flutterfire/issues/1060
-      //onLaunch: goToRoom,
-    );
-    debugPrint("[Push] Firebase initialized");
-    return;
-  }
-
-  void iOS_Permission() {
-    _firebaseMessaging.requestNotificationPermissions(
-        IosNotificationSettings(sound: true, badge: true, alert: true));
-    _firebaseMessaging.onIosSettingsRegistered
-        .listen((IosNotificationSettings settings) {
-      debugPrint("Settings registered: $settings");
-    });
-  }
-
   void _initWithStore() async {
     Future<LoginState> initLoginState = client.onLoginStateChanged.stream.first;
     client.storeAPI = kIsWeb ? Store(client) : ExtendedStore(client);
     debugPrint(
         "[Store] Store is extended: ${client.storeAPI.extended.toString()}");
     if (await initLoginState == LoginState.logged && !kIsWeb) {
-      await setupFirebase();
+      await FirebaseController.setupFirebase(
+        client,
+        widget.clientName,
+      );
     }
   }
 

lib/utils/firebase_controller.dart

@@ -0,0 +1,224 @@
+import 'dart:convert';
+import 'dart:io';
+
+import 'package:firebase_messaging/firebase_messaging.dart';
+import 'package:fluffychat/components/matrix.dart';
+import 'package:fluffychat/i18n/i18n.dart';
+import 'package:fluffychat/utils/app_route.dart';
+import 'package:fluffychat/views/chat.dart';
+import 'package:flutter/foundation.dart';
+import 'package:flutter/material.dart';
+import 'package:flutter_local_notifications/flutter_local_notifications.dart';
+import 'package:flutter_styled_toast/flutter_styled_toast.dart';
+import 'package:path_provider/path_provider.dart';
+import 'package:famedlysdk/famedlysdk.dart';
+import '../utils/event_extension.dart';
+import '../utils/room_extension.dart';
+
+abstract class FirebaseController {
+  static FirebaseMessaging _firebaseMessaging = FirebaseMessaging();
+  static FlutterLocalNotificationsPlugin _flutterLocalNotificationsPlugin =
+      FlutterLocalNotificationsPlugin();
+  static BuildContext context;
+
+  static Future<void> setupFirebase(Client client, String clientName) async {
+    if (Platform.isIOS) iOS_Permission();
+
+    String token;
+    try {
+      token = await _firebaseMessaging.getToken();
+    } catch (_) {
+      token = null;
+    }
+    if (token?.isEmpty ?? true) {
+      showToast(
+        I18n.of(context).noGoogleServicesWarning,
+        duration: Duration(seconds: 15),
+      );
+      return;
+    }
+    await client.setPushers(
+      token,
+      "http",
+      "chat.fluffy.fluffychat",
+      clientName,
+      client.deviceName,
+      "en",
+      "https://janian.de:7023/",
+      append: false,
+      format: "event_id_only",
+    );
+
+    Function goToRoom = (dynamic message) async {
+      try {
+        String roomId;
+        if (message is String) {
+          roomId = message;
+        } else if (message is Map) {
+          roomId = (message["data"] ?? message)["room_id"];
+        }
+        if (roomId?.isEmpty ?? true) throw ("Bad roomId");
+        await Navigator.of(context).pushAndRemoveUntil(
+            AppRoute.defaultRoute(
+              context,
+              ChatView(roomId),
+            ),
+            (r) => r.isFirst);
+      } catch (_) {
+        showToast("Failed to open chat...");
+        debugPrint(_);
+      }
+    };
+
+    // initialise the plugin. app_icon needs to be a added as a drawable resource to the Android head project
+    var initializationSettingsAndroid =
+        AndroidInitializationSettings('notifications_icon');
+    var initializationSettingsIOS =
+        IOSInitializationSettings(onDidReceiveLocalNotification: (i, a, b, c) {
+      return null;
+    });
+    var initializationSettings = InitializationSettings(
+        initializationSettingsAndroid, initializationSettingsIOS);
+    await _flutterLocalNotificationsPlugin.initialize(initializationSettings,
+        onSelectNotification: goToRoom);
+
+    _firebaseMessaging.configure(
+      onMessage: (Map<String, dynamic> message) async {
+        try {
+          print(message);
+          final data = message['data'] ?? message;
+          final String roomId = data["room_id"];
+          final String eventId = data["event_id"];
+          final int unread = json.decode(data["counts"])["unread"];
+          if ((roomId?.isEmpty ?? true) ||
+              (eventId?.isEmpty ?? true) ||
+              unread == 0) {
+            await _flutterLocalNotificationsPlugin.cancelAll();
+            return null;
+          }
+          if (Matrix.of(context).activeRoomId == roomId) return null;
+
+          // Get the room
+          Room room = client.getRoomById(roomId);
+          if (room == null) {
+            await client.onRoomUpdate.stream
+                .where((u) => u.id == roomId)
+                .first
+                .timeout(Duration(seconds: 10));
+            room = client.getRoomById(roomId);
+            if (room == null) return null;
+          }
+
+          // Get the event
+          Event event = await client.store.getEventById(eventId, room);
+          if (event == null) {
+            final EventUpdate eventUpdate = await client.onEvent.stream
+                .where((u) => u.content["event_id"] == eventId)
+                .first
+                .timeout(Duration(seconds: 10));
+            event = Event.fromJson(eventUpdate.content, room);
+            if (room == null) return null;
+          }
+
+          // Count all unread events
+          int unreadEvents = 0;
+          client.rooms
+              .forEach((Room room) => unreadEvents += room.notificationCount);
+
+          // Calculate title
+          final String title = unread > 1
+              ? I18n.of(context).unreadMessagesInChats(
+                  unreadEvents.toString(), unread.toString())
+              : I18n.of(context).unreadMessages(unreadEvents.toString());
+
+          // Calculate the body
+          final String body = event.getLocalizedBody(context,
+              withSenderNamePrefix: true, hideReply: true);
+
+          // The person object for the android message style notification
+          final person = Person(
+            name: room.getLocalizedDisplayname(context),
+            icon: room.avatar == null
+                ? null
+                : await downloadAndSaveAvatar(
+                    room.avatar,
+                    client,
+                    width: 126,
+                    height: 126,
+                  ),
+            iconSource: IconSource.FilePath,
+          );
+
+          // Show notification
+          var androidPlatformChannelSpecifics = AndroidNotificationDetails(
+              'fluffychat_push',
+              'FluffyChat push channel',
+              'Push notifications for FluffyChat',
+              style: AndroidNotificationStyle.Messaging,
+              styleInformation: MessagingStyleInformation(
+                person,
+                conversationTitle: title,
+                messages: [
+                  Message(
+                    body,
+                    event.time,
+                    person,
+                  )
+                ],
+              ),
+              importance: Importance.Max,
+              priority: Priority.High,
+              ticker: I18n.of(context).newMessageInFluffyChat);
+          var iOSPlatformChannelSpecifics = IOSNotificationDetails();
+          var platformChannelSpecifics = NotificationDetails(
+              androidPlatformChannelSpecifics, iOSPlatformChannelSpecifics);
+          await _flutterLocalNotificationsPlugin.show(
+              0,
+              room.getLocalizedDisplayname(context),
+              body,
+              platformChannelSpecifics,
+              payload: roomId);
+        } catch (exception) {
+          debugPrint("[Push] Error while processing notification: " +
+              exception.toString());
+        }
+        return null;
+      },
+      onResume: goToRoom,
+      // Currently fires unexpectetly... https://github.com/FirebaseExtended/flutterfire/issues/1060
+      //onLaunch: goToRoom,
+    );
+    debugPrint("[Push] Firebase initialized");
+    return;
+  }
+
+  static Future<String> downloadAndSaveAvatar(Uri content, Client client,
+      {int width, int height}) async {
+    final bool thumbnail = width == null && height == null ? false : true;
+    final String tempDirectory = (await getTemporaryDirectory()).path;
+    final String prefix = thumbnail ? "thumbnail" : "";
+    File file =
+        File('$tempDirectory/${prefix}_${content.toString().split("/").last}');
+
+    if (!file.existsSync()) {
+      final url = thumbnail
+          ? content.getThumbnail(client, width: width, height: height)
+          : content.getDownloadLink(client);
+      var request = await HttpClient().getUrl(Uri.parse(url));
+      var response = await request.close();
+      var bytes = await consolidateHttpClientResponseBytes(response);
+      await file.writeAsBytes(bytes);
+    }
+
+    return file.path;
+  }
+
+  static void iOS_Permission() {
+    _firebaseMessaging.requestNotificationPermissions(
+        IosNotificationSettings(sound: true, badge: true, alert: true));
+    _firebaseMessaging.onIosSettingsRegistered
+        .listen((IosNotificationSettings settings) {
+      debugPrint("Settings registered: $settings");
+    });
+  }
+}

lib/views/login.dart

@@ -4,6 +4,7 @@ import 'package:famedlysdk/famedlysdk.dart';
 import 'package:fluffychat/components/matrix.dart';
 import 'package:fluffychat/i18n/i18n.dart';
 import 'package:fluffychat/utils/app_route.dart';
+import 'package:fluffychat/utils/firebase_controller.dart';
 import 'package:flutter/foundation.dart';
 import 'package:flutter/material.dart';
 
@@ -53,7 +54,10 @@ class _LoginState extends State<Login> {
     }
     if (!kIsWeb) {
       try {
-        await matrix.setupFirebase();
+        await FirebaseController.setupFirebase(
+          matrix.client,
+          matrix.widget.clientName,
+        );
       } catch (exception) {
         await matrix.client.logout();
         matrix.clean();