fluffychat/lib/utils/background_push.dart

723 lines
23 KiB
Dart
Raw Normal View History

2021-02-07 17:18:38 +01:00
/*
* Famedly
* Copyright (C) 2020, 2021 Famedly GmbH
* Copyright (C) 2021 Fluffychat
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as
* published by the Free Software Foundation, either version 3 of the
* License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
import 'dart:async';
import 'dart:convert';
import 'dart:io';
2022-04-05 07:49:28 +02:00
import 'dart:typed_data';
2021-02-07 17:18:38 +01:00
import 'dart:ui';
import 'package:flutter/material.dart';
2021-10-26 18:50:34 +02:00
import 'package:flutter_cache_manager/flutter_cache_manager.dart';
2021-02-07 17:18:38 +01:00
import 'package:flutter_gen/gen_l10n/l10n.dart';
import 'package:flutter_local_notifications/flutter_local_notifications.dart';
2021-10-26 18:50:34 +02:00
import 'package:http/http.dart' as http;
import 'package:matrix/matrix.dart';
2022-04-05 07:49:28 +02:00
import 'package:unifiedpush/unifiedpush.dart';
2021-05-23 13:11:55 +02:00
import 'package:vrouter/vrouter.dart';
2021-10-26 18:50:34 +02:00
2021-12-25 14:42:48 +01:00
import 'package:fluffychat/utils/matrix_sdk_extensions.dart/client_stories_extension.dart';
2021-04-09 16:29:48 +02:00
import '../config/app_config.dart';
2021-02-07 17:18:38 +01:00
import '../config/setting_keys.dart';
import 'famedlysdk_store.dart';
import 'matrix_sdk_extensions.dart/matrix_locals.dart';
2021-10-26 18:50:34 +02:00
import 'platform_infos.dart';
//import 'package:fcm_shared_isolate/fcm_shared_isolate.dart';
2021-02-07 17:18:38 +01:00
class NoTokenException implements Exception {
String get cause => 'Cannot get firebase token';
}
class BackgroundPush {
2022-01-29 12:35:03 +01:00
static BackgroundPush? _instance;
2021-02-07 17:18:38 +01:00
final FlutterLocalNotificationsPlugin _flutterLocalNotificationsPlugin =
FlutterLocalNotificationsPlugin();
Client client;
2022-01-29 12:35:03 +01:00
BuildContext? context;
GlobalKey<VRouterState>? router;
String? _fcmToken;
void Function(String errorMsg, {Uri? link})? onFcmError;
L10n? l10n;
Store? _store;
2021-02-07 17:18:38 +01:00
Store get store => _store ??= Store();
Future<void> loadLocale() async {
// inspired by _lookupL10n in .dart_tool/flutter_gen/gen_l10n/l10n.dart
2022-01-29 12:35:03 +01:00
l10n ??= (context != null ? L10n.of(context!) : null) ??
(await L10n.delegate.load(window.locale));
2021-02-07 17:18:38 +01:00
}
final pendingTests = <String, Completer<void>>{};
2022-01-29 12:35:03 +01:00
DateTime? lastReceivedPush;
2021-02-07 17:18:38 +01:00
bool upAction = false;
2021-05-28 20:32:52 +02:00
BackgroundPush._(this.client, {this.onFcmError}) {
2021-02-07 17:18:38 +01:00
onLogin ??=
client.onLoginStateChanged.stream.listen(handleLoginStateChanged);
onRoomSync ??= client.onSync.stream
.where((s) => s.hasRoomUpdate)
.listen((s) => _onClearingPush(getFromServer: false));
_fcmSharedIsolate?.setListeners(
2021-03-28 09:20:34 +02:00
onMessage: _onFcmMessage,
onNewToken: _newFcmToken,
);
2021-03-27 20:05:51 +01:00
if (Platform.isAndroid) {
2022-04-05 07:49:28 +02:00
UnifiedPush.initialize(
2021-03-27 20:05:51 +01:00
onNewEndpoint: _newUpEndpoint,
onRegistrationFailed: _upUnregistered,
onUnregistered: _upUnregistered,
onMessage: _onUpMessage,
);
}
2021-02-07 17:18:38 +01:00
}
factory BackgroundPush.clientOnly(Client client) {
2021-02-07 17:18:38 +01:00
_instance ??= BackgroundPush._(client);
2022-01-29 12:35:03 +01:00
return _instance!;
2021-02-07 17:18:38 +01:00
}
factory BackgroundPush(
2022-01-29 12:35:03 +01:00
Client _client, BuildContext _context, GlobalKey<VRouterState>? router,
{final void Function(String errorMsg, {Uri? link})? onFcmError}) {
2021-02-07 17:18:38 +01:00
final instance = BackgroundPush.clientOnly(_client);
instance.context = _context;
2021-10-14 18:09:30 +02:00
// ignore: prefer_initializing_formals
2021-05-23 13:11:55 +02:00
instance.router = router;
2021-10-14 18:09:30 +02:00
// ignore: prefer_initializing_formals
2021-05-28 20:32:52 +02:00
instance.onFcmError = onFcmError;
2021-02-07 17:18:38 +01:00
instance.fullInit();
return instance;
}
2021-10-16 09:59:38 +02:00
Future<void> fullInit() => setupPush();
2021-02-07 17:18:38 +01:00
2021-10-16 09:59:38 +02:00
void handleLoginStateChanged(_) => setupPush();
2021-02-07 17:18:38 +01:00
void _newFcmToken(String token) {
_fcmToken = token;
setupPush();
}
2022-01-29 12:35:03 +01:00
final dynamic _fcmSharedIsolate = null; //FcmSharedIsolate();
2021-02-07 17:18:38 +01:00
2022-01-29 12:35:03 +01:00
StreamSubscription<LoginState>? onLogin;
StreamSubscription<SyncUpdate>? onRoomSync;
2021-02-07 17:18:38 +01:00
Future<void> setupPusher({
2022-01-29 12:35:03 +01:00
String? gatewayUrl,
String? token,
Set<String?>? oldTokens,
2021-02-07 17:18:38 +01:00
bool useDeviceSpecificAppId = false,
}) async {
2021-03-28 09:20:34 +02:00
if (PlatformInfos.isIOS) {
await _fcmSharedIsolate?.requestPermission();
2021-03-28 09:20:34 +02:00
}
2021-02-07 17:18:38 +01:00
final clientName = PlatformInfos.clientName;
oldTokens ??= <String>{};
2022-01-29 12:35:03 +01:00
final pushers = await (client.getPushers().catchError((e) {
Logs().w('[Push] Unable to request pushers', e);
return <Pusher>[];
})) ??
[];
2021-02-07 17:18:38 +01:00
var setNewPusher = false;
// Just the plain app id, we add the .data_message suffix later
var appId = AppConfig.pushNotificationsAppId;
// we need the deviceAppId to remove potential legacy UP pusher
var deviceAppId = '$appId.${client.deviceID}';
// appId may only be up to 64 chars as per spec
if (deviceAppId.length > 64) {
deviceAppId = deviceAppId.substring(0, 64);
}
if (!useDeviceSpecificAppId && PlatformInfos.isAndroid) {
appId += '.data_message';
}
final thisAppId = useDeviceSpecificAppId ? deviceAppId : appId;
2022-01-29 12:35:03 +01:00
if (gatewayUrl != null && token != null) {
2021-02-07 17:18:38 +01:00
final currentPushers = pushers.where((pusher) => pusher.pushkey == token);
if (currentPushers.length == 1 &&
currentPushers.first.kind == 'http' &&
currentPushers.first.appId == thisAppId &&
currentPushers.first.appDisplayName == clientName &&
currentPushers.first.deviceDisplayName == client.deviceName &&
currentPushers.first.lang == 'en' &&
currentPushers.first.data.url.toString() == gatewayUrl &&
currentPushers.first.data.format ==
AppConfig.pushNotificationsPusherFormat) {
Logs().i('[Push] Pusher already set');
} else {
2021-03-27 20:05:51 +01:00
Logs().i('Need to set new pusher');
2021-02-07 17:18:38 +01:00
oldTokens.add(token);
if (client.isLogged()) {
setNewPusher = true;
}
}
2021-03-27 20:05:51 +01:00
} else {
Logs().w('[Push] Missing required push credentials');
2021-02-07 17:18:38 +01:00
}
for (final pusher in pushers) {
if ((token != null &&
pusher.pushkey != token &&
deviceAppId == pusher.appId) ||
oldTokens.contains(pusher.pushkey)) {
try {
2022-01-29 12:35:03 +01:00
await client.deletePusher(pusher);
2021-02-07 17:18:38 +01:00
Logs().i('[Push] Removed legacy pusher for this device');
} catch (err) {
Logs().w('[Push] Failed to remove old pusher', err);
}
}
}
if (setNewPusher) {
try {
2021-05-20 13:59:55 +02:00
await client.postPusher(
2021-02-07 17:18:38 +01:00
Pusher(
2022-01-29 12:35:03 +01:00
pushkey: token!,
appId: thisAppId,
appDisplayName: clientName,
2022-01-29 12:35:03 +01:00
deviceDisplayName: client.deviceName!,
lang: 'en',
data: PusherData(
2022-01-29 12:35:03 +01:00
url: Uri.parse(gatewayUrl!),
2021-02-07 17:18:38 +01:00
format: AppConfig.pushNotificationsPusherFormat,
),
kind: 'http',
),
append: false,
);
} catch (e, s) {
Logs().e('[Push] Unable to set pushers', e, s);
}
}
}
bool _wentToRoomOnStartup = false;
2021-02-07 17:18:38 +01:00
Future<void> setupPush() async {
Logs().d("SetupPush");
await setupLocalNotificationsPlugin();
2021-09-24 11:42:56 +02:00
if (client.loginState != LoginState.loggedIn ||
2021-02-07 17:18:38 +01:00
!PlatformInfos.isMobile ||
context == null) {
return;
}
// Do not setup unifiedpush if this has been initialized by
// an unifiedpush action
if (upAction) {
return;
}
2021-02-07 17:18:38 +01:00
if (!PlatformInfos.isIOS &&
(await UnifiedPush.getDistributors()).isNotEmpty) {
await setupUp();
} else {
await setupFirebase();
}
// ignore: unawaited_futures
_flutterLocalNotificationsPlugin
.getNotificationAppLaunchDetails()
.then((details) {
if (details == null ||
!details.didNotificationLaunchApp ||
_wentToRoomOnStartup ||
2021-05-23 13:11:55 +02:00
router == null) {
return;
}
_wentToRoomOnStartup = true;
goToRoom(details.payload);
});
2021-02-07 17:18:38 +01:00
}
Future<void> _noFcmWarning() async {
if (context == null) {
return;
}
if (await store.getItemBool(SettingKeys.showNoGoogle, true)) {
await loadLocale();
2021-09-24 11:42:56 +02:00
if (PlatformInfos.isAndroid) {
onFcmError?.call(
2022-01-29 12:35:03 +01:00
l10n!.noGoogleServicesWarning,
2021-09-24 11:42:56 +02:00
link: Uri.parse(
AppConfig.enablePushTutorial,
),
);
}
2022-01-29 12:35:03 +01:00
onFcmError?.call(l10n!.oopsPushError);
2021-05-28 20:32:52 +02:00
2021-02-07 17:18:38 +01:00
if (null == await store.getItem(SettingKeys.showNoGoogle)) {
await store.setItemBool(SettingKeys.showNoGoogle, false);
}
}
}
Future<void> setupFirebase() async {
2021-05-28 20:32:52 +02:00
Logs().v('Setup firebase');
2021-02-07 17:18:38 +01:00
if (_fcmToken?.isEmpty ?? true) {
try {
_fcmToken = await _fcmSharedIsolate?.getToken();
2021-11-21 09:07:33 +01:00
if (_fcmToken == null) throw ('PushToken is null');
2021-02-07 17:18:38 +01:00
} catch (e, s) {
2021-11-21 09:07:33 +01:00
Logs().w('[Push] cannot get token', e, e is String ? null : s);
2021-02-07 17:18:38 +01:00
await _noFcmWarning();
return;
}
}
await setupPusher(
gatewayUrl: AppConfig.pushNotificationsGatewayUrl,
token: _fcmToken,
);
}
2022-01-29 12:35:03 +01:00
Future<void> goToRoom(String? roomId) async {
2021-02-07 17:18:38 +01:00
try {
Logs().v('[Push] Attempting to go to room $roomId...');
if (router == null || roomId == null) {
2021-02-07 17:18:38 +01:00
return;
}
2022-01-29 12:35:03 +01:00
await client.roomsLoading;
await client.accountDataLoading;
2021-12-25 14:42:48 +01:00
final isStory = client
.getRoomById(roomId)
2021-12-25 14:42:48 +01:00
?.getState(EventTypes.RoomCreate)
?.content
2022-01-29 12:35:03 +01:00
.tryGet<String>('type') ==
2021-12-25 14:42:48 +01:00
ClientStoriesExtension.storiesRoomType;
2022-01-29 12:35:03 +01:00
router!.currentState!.toSegments([isStory ? 'stories' : 'rooms', roomId]);
2021-02-07 17:18:38 +01:00
} catch (e, s) {
Logs().e('[Push] Failed to open room', e, s);
}
}
bool _notificationsPluginSetUp = false;
Future<void> setupLocalNotificationsPlugin() async {
if (_notificationsPluginSetUp) {
return;
}
// initialise the plugin. app_icon needs to be a added as a drawable resource to the Android head project
2021-10-14 18:09:30 +02:00
const initializationSettingsAndroid =
2021-02-07 17:18:38 +01:00
AndroidInitializationSettings('notifications_icon');
2022-01-29 12:35:03 +01:00
final initializationSettingsIOS = IOSInitializationSettings(
onDidReceiveLocalNotification: (i, a, b, c) async => null,
);
2021-04-14 10:37:15 +02:00
final initializationSettings = InitializationSettings(
2021-02-07 17:18:38 +01:00
android: initializationSettingsAndroid,
iOS: initializationSettingsIOS,
);
await _flutterLocalNotificationsPlugin.initialize(initializationSettings,
onSelectNotification: goToRoom);
_notificationsPluginSetUp = true;
}
Future<void> setupUp() async {
2022-04-05 07:49:28 +02:00
await UnifiedPush.registerAppWithDialog(context!);
2021-02-07 17:18:38 +01:00
}
Future<void> _onFcmMessage(Map<dynamic, dynamic> message) async {
2021-03-27 20:05:51 +01:00
Logs().v('[Push] Foreground message received');
2022-01-29 12:35:03 +01:00
final data = Map<String, dynamic>.from(message['data'] ?? message);
2021-02-07 17:18:38 +01:00
try {
await _onMessage(data);
} catch (e, s) {
Logs().e('[Push] Error while processing notification', e, s);
await _showDefaultNotification(data);
}
}
2022-04-05 07:49:28 +02:00
Future<void> _newUpEndpoint(String newEndpoint, String i) async {
upAction = true;
2022-01-29 12:35:03 +01:00
if (newEndpoint.isEmpty) {
2022-04-05 07:49:28 +02:00
await _upUnregistered(i);
2021-02-07 17:18:38 +01:00
return;
}
var endpoint =
'https://matrix.gateway.unifiedpush.org/_matrix/push/v1/notify';
try {
final url = Uri.parse(newEndpoint)
.replace(
path: '/_matrix/push/v1/notify',
query: '',
)
.toString()
.split('?')
.first;
2021-04-21 14:19:54 +02:00
final res =
json.decode(utf8.decode((await http.get(Uri.parse(url))).bodyBytes));
if (res['gateway'] == 'matrix' ||
(res['unifiedpush'] is Map &&
res['unifiedpush']['gateway'] == 'matrix')) {
2021-02-07 17:18:38 +01:00
endpoint = url;
}
} catch (e) {
Logs().i(
'[Push] No self-hosted unified push gateway present: ' + newEndpoint);
}
Logs().i('[Push] UnifiedPush using endpoint ' + endpoint);
2022-01-29 12:35:03 +01:00
final oldTokens = <String?>{};
2021-02-07 17:18:38 +01:00
try {
final fcmToken = await _fcmSharedIsolate?.getToken();
2021-02-07 17:18:38 +01:00
oldTokens.add(fcmToken);
} catch (_) {}
await setupPusher(
gatewayUrl: endpoint,
token: newEndpoint,
oldTokens: oldTokens,
useDeviceSpecificAppId: true,
);
await store.setItem(SettingKeys.unifiedPushEndpoint, newEndpoint);
await store.setItemBool(SettingKeys.unifiedPushRegistered, true);
}
2022-04-05 07:49:28 +02:00
Future<void> _upUnregistered(String i) async {
upAction = true;
2021-02-07 17:18:38 +01:00
Logs().i('[Push] Removing UnifiedPush endpoint...');
final oldEndpoint = await store.getItem(SettingKeys.unifiedPushEndpoint);
await store.setItemBool(SettingKeys.unifiedPushRegistered, false);
await store.deleteItem(SettingKeys.unifiedPushEndpoint);
if (oldEndpoint?.isNotEmpty ?? false) {
// remove the old pusher
await setupPusher(
oldTokens: {oldEndpoint},
);
}
}
2022-04-05 07:49:28 +02:00
Future<void> _onUpMessage(Uint8List message, String i) async {
upAction = true;
2022-04-05 07:49:28 +02:00
final data = Map<String, dynamic>.from(
json.decode(utf8.decode(message))['notification']);
2021-02-07 17:18:38 +01:00
try {
await _onMessage(data);
} catch (e, s) {
Logs().e('[Push] Error while processing notification', e, s);
await _showDefaultNotification(data);
}
}
Future<void> _onMessage(Map<String, dynamic> data) async {
Logs().v('[Push] _onMessage');
lastReceivedPush = DateTime.now();
final roomId = data['room_id'];
final eventId = data['event_id'];
if (roomId == 'test') {
Logs().v('[Push] Test $eventId was successful!');
pendingTests.remove(eventId)?.complete();
return;
}
2022-01-29 12:35:03 +01:00
// For legacy reasons the counts map could be a String encoded JSON:
final countsMap =
data.tryGetMap<String, dynamic>('counts', TryGet.silent) ??
(jsonDecode(data.tryGet<String>('counts') ?? '{}')
as Map<String, dynamic>);
final unread = countsMap.tryGet<int>('unread');
2021-02-07 17:18:38 +01:00
if ((roomId?.isEmpty ?? true) ||
(eventId?.isEmpty ?? true) ||
unread == 0) {
await _onClearingPush();
return;
}
var giveUp = false;
var loaded = false;
final stopwatch = Stopwatch();
stopwatch.start();
final syncSubscription = client.onSync.stream.listen((r) {
if (stopwatch.elapsed.inSeconds >= 30) {
giveUp = true;
}
});
final eventSubscription = client.onEvent.stream.listen((e) {
if (e.content['event_id'] == eventId) {
loaded = true;
}
});
try {
if (!(await eventExists(roomId, eventId)) && !loaded) {
do {
Logs().v('[Push] getting ' + roomId + ', event ' + eventId);
await client
.oneShotSync()
.catchError((e) => Logs().v('[Push] Error one-shot syncing', e));
if (stopwatch.elapsed.inSeconds >= 60) {
giveUp = true;
}
} while (!loaded && !giveUp);
}
Logs().v('[Push] ' +
(giveUp ? 'gave up on ' : 'got ') +
roomId +
', event ' +
eventId);
} finally {
await syncSubscription.cancel();
await eventSubscription.cancel();
}
await _showNotification(roomId, eventId);
}
2022-01-29 12:35:03 +01:00
Future<bool> eventExists(String roomId, String? eventId) async {
2021-02-07 17:18:38 +01:00
final room = client.getRoomById(roomId);
if (room == null) return false;
2022-01-29 12:35:03 +01:00
return (await client.database!.getEventById(eventId!, room)) != null;
2021-02-07 17:18:38 +01:00
}
/// Workaround for the problem that local notification IDs must be int but we
/// sort by [roomId] which is a String. To make sure that we don't have duplicated
/// IDs we map the [roomId] to a number and store this number.
2022-01-29 12:35:03 +01:00
late Map<String, int> idMap;
2021-02-07 17:18:38 +01:00
Future<void> _loadIdMap() async {
2022-01-29 12:35:03 +01:00
idMap = Map<String, int>.from(json.decode(
2021-02-07 17:18:38 +01:00
(await store.getItem(SettingKeys.notificationCurrentIds)) ?? '{}'));
}
Future<int> mapRoomIdToInt(String roomId) async {
await _loadIdMap();
2022-01-29 12:35:03 +01:00
int? currentInt;
2021-02-07 17:18:38 +01:00
try {
currentInt = idMap[roomId];
} catch (_) {
currentInt = null;
}
if (currentInt != null) {
return currentInt;
}
2022-01-29 12:35:03 +01:00
var nCurrentInt = 0;
2021-02-07 17:18:38 +01:00
while (idMap.values.contains(currentInt)) {
2022-01-29 12:35:03 +01:00
nCurrentInt++;
2021-02-07 17:18:38 +01:00
}
2022-01-29 12:35:03 +01:00
idMap[roomId] = nCurrentInt;
2021-02-07 17:18:38 +01:00
await store.setItem(SettingKeys.notificationCurrentIds, json.encode(idMap));
2022-01-29 12:35:03 +01:00
return nCurrentInt;
2021-02-07 17:18:38 +01:00
}
bool _clearingPushLock = false;
Future<void> _onClearingPush({bool getFromServer = true}) async {
if (_clearingPushLock) {
return;
}
try {
_clearingPushLock = true;
2022-01-29 12:35:03 +01:00
late Iterable<String> emptyRooms;
2021-02-07 17:18:38 +01:00
if (getFromServer) {
Logs().v('[Push] Got new clearing push');
var syncErrored = false;
if (client.syncPending) {
Logs().v('[Push] waiting for existing sync');
// we need to catchError here as the Future might be in a different execution zone
await client.oneShotSync().catchError((e) {
syncErrored = true;
Logs().v('[Push] Error one-shot syncing', e);
});
}
if (!syncErrored) {
Logs().v('[Push] single oneShotSync');
// we need to catchError here as the Future might be in a different execution zone
await client.oneShotSync().catchError((e) {
syncErrored = true;
Logs().v('[Push] Error one-shot syncing', e);
});
if (!syncErrored) {
emptyRooms = client.rooms
2022-01-29 12:35:03 +01:00
.where((r) => r.notificationCount == 0)
2021-02-07 17:18:38 +01:00
.map((r) => r.id);
}
}
if (syncErrored) {
try {
Logs().v(
'[Push] failed to sync for fallback push, fetching notifications endpoint...');
2021-05-20 13:59:55 +02:00
final notifications = await client.getNotifications(limit: 20);
2021-02-07 17:18:38 +01:00
final notificationRooms =
notifications.notifications.map((n) => n.roomId).toSet();
emptyRooms = client.rooms
.where((r) => !notificationRooms.contains(r.id))
.map((r) => r.id);
} catch (e) {
Logs().v(
'[Push] failed to fetch pending notifications for clearing push, falling back...',
e);
emptyRooms = client.rooms
2022-01-29 12:35:03 +01:00
.where((r) => r.notificationCount == 0)
2021-02-07 17:18:38 +01:00
.map((r) => r.id);
}
}
} else {
emptyRooms = client.rooms
2022-01-29 12:35:03 +01:00
.where((r) => r.notificationCount == 0)
2021-02-07 17:18:38 +01:00
.map((r) => r.id);
}
await _loadIdMap();
var changed = false;
for (final roomId in emptyRooms) {
2022-01-29 12:35:03 +01:00
final id = idMap[roomId];
if (id != null) {
2021-02-07 17:18:38 +01:00
idMap.remove(roomId);
changed = true;
2022-01-29 12:35:03 +01:00
await _flutterLocalNotificationsPlugin.cancel(id);
2021-02-07 17:18:38 +01:00
}
}
if (changed) {
await store.setItem(
SettingKeys.notificationCurrentIds, json.encode(idMap));
}
} finally {
_clearingPushLock = false;
}
}
Future<void> _showNotification(String roomId, String eventId) async {
await setupLocalNotificationsPlugin();
final room = client.getRoomById(roomId);
if (room == null) {
throw 'Room not found';
}
2021-04-08 07:38:14 +02:00
await room.postLoad();
2022-01-29 12:35:03 +01:00
final event = await client.database!.getEventById(eventId, room);
2021-02-07 17:18:38 +01:00
2022-01-29 12:35:03 +01:00
final activeRoomId = router!.currentState!.pathParameters['roomid'];
if (((activeRoomId?.isNotEmpty ?? false) &&
activeRoomId == room.id &&
2021-02-07 17:18:38 +01:00
client.syncPresence == null) ||
2022-01-29 12:35:03 +01:00
(event != null && (room.notificationCount == 0))) {
2021-02-07 17:18:38 +01:00
return;
}
// load the locale
await loadLocale();
// Calculate title
2022-01-29 12:35:03 +01:00
final title = l10n!.unreadMessages(room.notificationCount);
2021-02-07 17:18:38 +01:00
// Calculate the body
2022-01-29 12:35:03 +01:00
final body = event!.getLocalizedBody(
MatrixLocals(L10n.of(context!)!),
2021-08-28 18:05:41 +02:00
withSenderNamePrefix: !room.isDirectChat,
plaintextBody: true,
hideReply: true,
hideEdit: true,
);
2021-02-07 17:18:38 +01:00
// The person object for the android message style notification
final avatar = room.avatar == null
? null
: await DefaultCacheManager().getSingleFile(
2022-01-29 12:35:03 +01:00
event.room.avatar!
.getThumbnail(
client,
width: 126,
height: 126,
)
.toString(),
2021-02-07 17:18:38 +01:00
);
final person = Person(
2022-01-29 12:35:03 +01:00
name: room.getLocalizedDisplayname(MatrixLocals(l10n!)),
icon: avatar == null ? null : BitmapFilePathAndroidIcon(avatar.path),
2021-02-07 17:18:38 +01:00
);
// Show notification
2021-04-14 10:37:15 +02:00
final androidPlatformChannelSpecifics = _getAndroidNotificationDetails(
2021-02-07 17:18:38 +01:00
styleInformation: MessagingStyleInformation(
person,
conversationTitle: title,
messages: [
Message(
body,
2022-01-29 12:35:03 +01:00
event.originServerTs,
2021-02-07 17:18:38 +01:00
person,
)
],
),
2022-01-29 12:35:03 +01:00
ticker: l10n!.newMessageInFluffyChat,
2021-02-07 17:18:38 +01:00
);
2021-10-14 18:09:30 +02:00
const iOSPlatformChannelSpecifics = IOSNotificationDetails();
2021-04-14 10:37:15 +02:00
final platformChannelSpecifics = NotificationDetails(
2021-02-07 17:18:38 +01:00
android: androidPlatformChannelSpecifics,
iOS: iOSPlatformChannelSpecifics,
);
await _flutterLocalNotificationsPlugin.show(
await mapRoomIdToInt(room.id),
2022-01-29 12:35:03 +01:00
room.getLocalizedDisplayname(MatrixLocals(l10n!)),
2021-02-07 17:18:38 +01:00
body,
platformChannelSpecifics,
payload: roomId,
);
}
Future<dynamic> _showDefaultNotification(Map<String, dynamic> data) async {
try {
await setupLocalNotificationsPlugin();
await loadLocale();
2022-01-29 12:35:03 +01:00
final String? eventId = data['event_id'];
final String? roomId = data['room_id'];
// For legacy reasons the counts map could be a String encoded JSON:
final countsMap = data.tryGetMap<String, dynamic>('counts') ??
(jsonDecode(data.tryGet<String>('counts') ?? '{}')
as Map<String, dynamic>);
final unread = countsMap.tryGet<int>('unread') ?? 1;
2021-02-07 17:18:38 +01:00
if (unread == 0 || roomId == null || eventId == null) {
await _onClearingPush();
return;
}
// Display notification
2021-04-14 10:37:15 +02:00
final androidPlatformChannelSpecifics = _getAndroidNotificationDetails();
2021-10-14 18:09:30 +02:00
const iOSPlatformChannelSpecifics = IOSNotificationDetails();
2021-04-14 10:37:15 +02:00
final platformChannelSpecifics = NotificationDetails(
2021-02-07 17:18:38 +01:00
android: androidPlatformChannelSpecifics,
iOS: iOSPlatformChannelSpecifics,
);
2022-01-29 12:35:03 +01:00
final title = l10n!.unreadChats(unread);
2021-02-07 17:18:38 +01:00
await _flutterLocalNotificationsPlugin.show(
await mapRoomIdToInt(roomId),
title,
2022-01-29 12:35:03 +01:00
l10n!.openAppToReadMessages,
2021-02-07 17:18:38 +01:00
platformChannelSpecifics,
payload: roomId,
);
} catch (e, s) {
Logs().e('[Push] Error while processing background notification', e, s);
}
}
AndroidNotificationDetails _getAndroidNotificationDetails(
2022-01-29 12:35:03 +01:00
{MessagingStyleInformation? styleInformation, String? ticker}) {
final color = (context != null ? Theme.of(context!).primaryColor : null) ??
2021-10-14 18:09:30 +02:00
const Color(0xFF5625BA);
2021-02-07 17:18:38 +01:00
return AndroidNotificationDetails(
AppConfig.pushNotificationsChannelId,
AppConfig.pushNotificationsChannelName,
AppConfig.pushNotificationsChannelDescription,
styleInformation: styleInformation,
importance: Importance.max,
priority: Priority.high,
ticker: ticker,
color: color,
);
}
}