ehealthsolutions/element-x-android
3
0
Fork 0
mirror of https://github.com/Novaloop-AG/element-x-android.git synced 2026-11-06 16:43:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

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 7f9a30a033
commit 68708837d8
1 changed files with 12 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libraries/pushproviders/unifiedpush/src/main/kotlin/io/element/android/libraries/pushproviders/unifiedpush/VectorUnifiedPushMessagingReceiver.kt
+12 -18
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()
} }