-
Notifications
You must be signed in to change notification settings - Fork 31
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
fix(neon_framework): Migrate to notifications_push_repository
Signed-off-by: provokateurin <[email protected]>
- Loading branch information
1 parent
8b905a0
commit ffb6bbf
Showing
26 changed files
with
149 additions
and
538 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
126 changes: 19 additions & 107 deletions
126
packages/neon_framework/lib/src/blocs/push_notifications.dart
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,143 +1,55 @@ | ||
| import 'dart:async'; | ||
| import 'dart:convert'; | ||
|
|
||
| import 'package:account_repository/account_repository.dart'; | ||
| import 'package:built_collection/built_collection.dart'; | ||
| import 'package:logging/logging.dart'; | ||
| import 'package:meta/meta.dart'; | ||
| import 'package:neon_framework/src/bloc/bloc.dart'; | ||
| import 'package:neon_framework/src/platform/platform.dart'; | ||
| import 'package:neon_framework/src/storage/keys.dart'; | ||
| import 'package:neon_framework/src/utils/global_options.dart'; | ||
| import 'package:neon_framework/src/utils/push_utils.dart'; | ||
| import 'package:neon_framework/storage.dart'; | ||
| import 'package:nextcloud/notifications.dart' as notifications; | ||
| import 'package:unifiedpush/unifiedpush.dart'; | ||
| import 'package:notifications_push_repository/notifications_push_repository.dart'; | ||
| import 'package:permission_handler/permission_handler.dart'; | ||
|
|
||
| /// Bloc for managing push notifications and registration. | ||
| /// Bloc for managing push subscriptions. | ||
| sealed class PushNotificationsBloc { | ||
| @internal | ||
| factory PushNotificationsBloc({ | ||
| required GlobalOptions globalOptions, | ||
| required AccountRepository accountRepository, | ||
| required NotificationsPushRepository notificationsPushRepository, | ||
| }) = _PushNotificationsBloc; | ||
| } | ||
|
|
||
| class _PushNotificationsBloc extends Bloc implements PushNotificationsBloc { | ||
| _PushNotificationsBloc({ | ||
| required this.globalOptions, | ||
| required this.accountRepository, | ||
| required this.notificationsPushRepository, | ||
| }) { | ||
| if (NeonPlatform.instance.canUsePushNotifications) { | ||
| unawaited(UnifiedPush.getDistributors().then(globalOptions.updateDistributors)); | ||
|
|
||
| globalOptions.pushNotificationsEnabled.addListener(pushNotificationsEnabledListener); | ||
| // Call the listener to update everything | ||
| unawaited(pushNotificationsEnabledListener()); | ||
| } | ||
| unawaited(changeDistributor()); | ||
| globalOptions.pushNotificationsDistributor.addListener(changeDistributor); | ||
| } | ||
|
|
||
| @override | ||
| final log = Logger('PushNotificationsBloc'); | ||
|
|
||
| late final storage = NeonStorage().settingsStore(StorageKeys.lastEndpoint); | ||
| final GlobalOptions globalOptions; | ||
| final AccountRepository accountRepository; | ||
|
|
||
| StreamSubscription<({Account? active, BuiltList<Account> accounts})>? accountsListener; | ||
| final NotificationsPushRepository notificationsPushRepository; | ||
| String? oldDistributor; | ||
|
|
||
| @override | ||
| void dispose() { | ||
| unawaited(accountsListener?.cancel()); | ||
| globalOptions.pushNotificationsEnabled.removeListener(pushNotificationsEnabledListener); | ||
| } | ||
|
|
||
| Future<void> pushNotificationsEnabledListener() async { | ||
| if (globalOptions.pushNotificationsEnabled.value) { | ||
| await setupUnifiedPush(); | ||
|
|
||
| globalOptions.pushNotificationsDistributor.addListener(distributorListener); | ||
| accountsListener = accountRepository.accounts.listen(registerUnifiedPushInstances); | ||
| } else { | ||
| globalOptions.pushNotificationsDistributor.removeListener(distributorListener); | ||
| unawaited(accountsListener?.cancel()); | ||
| } | ||
| } | ||
|
|
||
| Future<void> setupUnifiedPush() async { | ||
| // We just use a single RSA keypair for all accounts | ||
| final keypair = PushUtils.loadRSAKeypair(); | ||
|
|
||
| await UnifiedPush.initialize( | ||
| onNewEndpoint: (endpoint, instance) async { | ||
| final account = accountRepository.accountByID(instance); | ||
| if (account == null) { | ||
| log.fine('Account for $instance not found, can not process endpoint'); | ||
| return; | ||
| } | ||
|
|
||
| if (storage.getString(account.id) == endpoint) { | ||
| log.fine('Endpoint not changed'); | ||
| return; | ||
| } | ||
|
|
||
| log.fine('Registering account $instance for push notifications on $endpoint'); | ||
|
|
||
| final subscription = await account.client.notifications.push.registerDevice( | ||
| $body: notifications.PushRegisterDeviceRequestApplicationJson( | ||
| (b) => b | ||
| ..pushTokenHash = notifications.generatePushTokenHash(endpoint) | ||
| ..devicePublicKey = keypair.publicKey.toFormattedPEM() | ||
| ..proxyServer = '$endpoint#', // This is a hack to make the Nextcloud server directly push to the endpoint | ||
| ), | ||
| ); | ||
|
|
||
| await storage.setString(account.id, endpoint); | ||
|
|
||
| log.fine( | ||
| 'Account $instance registered for push notifications ${json.encode(subscription.body.ocs.data.toJson())}', | ||
| ); | ||
| }, | ||
| onMessage: PushUtils.onMessage, | ||
| ); | ||
| globalOptions.pushNotificationsDistributor.removeListener(changeDistributor); | ||
| } | ||
|
|
||
| Future<void> distributorListener() async { | ||
| Future<void> changeDistributor() async { | ||
| final distributor = globalOptions.pushNotificationsDistributor.value; | ||
| final disabled = distributor == null; | ||
| final sameDistributor = distributor == await UnifiedPush.getDistributor(); | ||
| final accounts = await accountRepository.accounts.first; | ||
| if (disabled || !sameDistributor) { | ||
| await unregisterUnifiedPushInstances(accounts.accounts); | ||
| } | ||
| if (!disabled && !sameDistributor) { | ||
| log.fine('UnifiedPush distributor changed to $distributor'); | ||
| await UnifiedPush.saveDistributor(distributor); | ||
| } | ||
| if (!disabled) { | ||
| await registerUnifiedPushInstances(accounts); | ||
| } | ||
| } | ||
|
|
||
| Future<void> unregisterUnifiedPushInstances(BuiltList<Account> accounts) async { | ||
| for (final account in accounts) { | ||
| try { | ||
| await account.client.notifications.push.removeDevice(); | ||
| await UnifiedPush.unregister(account.id); | ||
| await storage.remove(account.id); | ||
| } on Exception catch (error) { | ||
| log.warning( | ||
| 'Failed to unregister device.', | ||
| error, | ||
| ); | ||
| if (distributor != null) { | ||
| final response = await Permission.notification.request(); | ||
| if (!response.isGranted) { | ||
| log.fine('Notifications permission denied, disabling push notifications'); | ||
|
|
||
| globalOptions.pushNotificationsDistributor.reset(); | ||
| return; | ||
| } | ||
| } | ||
| } | ||
|
|
||
| Future<void> registerUnifiedPushInstances(({Account? active, BuiltList<Account> accounts}) event) async { | ||
| // Notifications will only work on accounts with app password | ||
| for (final account in event.accounts.where((a) => a.credentials.appPassword != null)) { | ||
| await UnifiedPush.registerApp(account.id); | ||
| } | ||
| await notificationsPushRepository.changeDistributor(distributor); | ||
| } | ||
| } |
Oops, something went wrong.