Merge pull request #7725 from vector-im/feature/bma/filterCrash

Do not propagate failure if saving the filter server side fails
This commit is contained in:
Benoit Marty 2022-12-07 13:54:57 +01:00 committed by GitHub
commit 4a5f4849e5
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 13 additions and 8 deletions

1
changelog.d/7725.bugfix Normal file
View File

@ -0,0 +1 @@
Fix crash when the network is not available.

View File

@ -42,7 +42,7 @@ internal class DefaultGetCurrentFilterTask @Inject constructor(
return when (storedFilterBody) { return when (storedFilterBody) {
currentFilterBody -> storedFilterId ?: storedFilterBody currentFilterBody -> storedFilterId ?: storedFilterBody
else -> saveFilter(currentFilter) else -> saveFilter(currentFilter) ?: currentFilterBody
} }
} }

View File

@ -16,6 +16,7 @@
package org.matrix.android.sdk.internal.session.filter package org.matrix.android.sdk.internal.session.filter
import org.matrix.android.sdk.api.extensions.tryOrNull
import org.matrix.android.sdk.internal.di.UserId import org.matrix.android.sdk.internal.di.UserId
import org.matrix.android.sdk.internal.network.GlobalErrorReceiver import org.matrix.android.sdk.internal.network.GlobalErrorReceiver
import org.matrix.android.sdk.internal.network.executeRequest import org.matrix.android.sdk.internal.network.executeRequest
@ -24,8 +25,9 @@ import javax.inject.Inject
/** /**
* Save a filter, in db and if any changes, upload to the server. * Save a filter, in db and if any changes, upload to the server.
* Return the filterId if uploading to the server is successful, else return null.
*/ */
internal interface SaveFilterTask : Task<SaveFilterTask.Params, String> { internal interface SaveFilterTask : Task<SaveFilterTask.Params, String?> {
data class Params( data class Params(
val filter: Filter val filter: Filter
@ -39,18 +41,20 @@ internal class DefaultSaveFilterTask @Inject constructor(
private val globalErrorReceiver: GlobalErrorReceiver, private val globalErrorReceiver: GlobalErrorReceiver,
) : SaveFilterTask { ) : SaveFilterTask {
override suspend fun execute(params: SaveFilterTask.Params): String { override suspend fun execute(params: SaveFilterTask.Params): String? {
val filter = params.filter val filter = params.filter
val filterResponse = executeRequest(globalErrorReceiver) { val filterResponse = tryOrNull {
// TODO auto retry executeRequest(globalErrorReceiver) {
filterAPI.uploadFilter(userId, filter) filterAPI.uploadFilter(userId, filter)
}
} }
val filterId = filterResponse?.filterId
filterRepository.storeSyncFilter( filterRepository.storeSyncFilter(
filter = filter, filter = filter,
filterId = filterResponse.filterId, filterId = filterId.orEmpty(),
roomEventFilter = FilterFactory.createDefaultRoomFilter() roomEventFilter = FilterFactory.createDefaultRoomFilter()
) )
return filterResponse.filterId return filterId
} }
} }