Sulkta-OSS/element-x-ada
3
0
Fork 0
Code Issues 1 Pull requests 10 Projects Releases Packages Wiki Activity Actions

Ensure UnifiedPush endpoint is registered.

Browse source
This commit is contained in:
Benoit Marty 2024-05-07 11:23:13 +02:00 • committed by Benoit Marty
parent e64051f7bd
commit dc572af9db
1 changed files with 12 additions and 18 deletions
Download patch file Download diff file Expand all files Collapse all files

30
libraries/pushproviders/unifiedpush/src/main/kotlin/io/element/android/libraries/pushproviders/unifiedpush/VectorUnifiedPushMessagingReceiver.kt
View file

@ -69,25 +69,19 @@ class VectorUnifiedPushMessagingReceiver : MessagingReceiver() {
* You should send the endpoint to your application server and sync for missing notifications. * You should send the endpoint to your application server and sync for missing notifications.
*/ */
override fun onNewEndpoint(context: Context, endpoint: String, instance: String) { override fun onNewEndpoint(context: Context, endpoint: String, instance: String) {
Timber.tag(loggerTag.value).i("onNewEndpoint: adding $endpoint") Timber.tag(loggerTag.value).i("onNewEndpoint: $endpoint")
// If the endpoint has changed coroutineScope.launch {
// or the gateway has changed val gateway = unifiedPushGatewayResolver.getGateway(endpoint)
if (unifiedPushStore.getEndpoint(instance) != endpoint) { unifiedPushStore.storePushGateway(gateway, instance)
coroutineScope.launch { gateway?.let { pushGateway ->
val gateway = unifiedPushGatewayResolver.getGateway(endpoint) newGatewayHandler.handle(endpoint, pushGateway, instance)
unifiedPushStore.storePushGateway(gateway, instance) .onFailure {
gateway?.let { pushGateway -> Timber.tag(loggerTag.value).e(it, "Failed to handle new gateway")
newGatewayHandler.handle(endpoint, pushGateway, instance) }
.onFailure { .onSuccess {
Timber.tag(loggerTag.value).e("Failed to handle new gateway") unifiedPushStore.storeUpEndpoint(endpoint, instance)
} }
.onSuccess {
unifiedPushStore.storeUpEndpoint(endpoint, instance)
}
}
} }
} else {
Timber.tag(loggerTag.value).i("onNewEndpoint: skipped")
} }
guardServiceStarter.stop() guardServiceStarter.stop()
} }