Signal/Android
1
0
Fork 0
mirror of https://github.com/signalapp/Signal-Android.git synced 2025-12-23 04:28:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix FTS rebuild retry.

Browse Source
This commit is contained in:
Greyson Parrelli
2023-04-25 14:43:57 -04:00
parent eedf7d4280
commit eb9915d445
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
app/src/main/java/org/thoughtcrime/securesms/jobs/RebuildMessageSearchIndexJob.kt
View File

@@ -4,6 +4,7 @@ import org.signal.core.util.logging.Log
import org.thoughtcrime.securesms.database.SignalDatabase import org.thoughtcrime.securesms.database.SignalDatabase
import org.thoughtcrime.securesms.dependencies.ApplicationDependencies import org.thoughtcrime.securesms.dependencies.ApplicationDependencies
import org.thoughtcrime.securesms.jobmanager.Job import org.thoughtcrime.securesms.jobmanager.Job
import org.thoughtcrime.securesms.transport.RetryLaterException
import java.lang.Exception import java.lang.Exception
import java.lang.IllegalStateException import java.lang.IllegalStateException
import kotlin.time.Duration.Companion.seconds import kotlin.time.Duration.Companion.seconds
@@ -34,14 +35,18 @@ class RebuildMessageSearchIndexJob private constructor(params: Parameters) : Bas
override fun onFailure() = Unit override fun onFailure() = Unit
override fun onRun() { override fun onRun() {
SignalDatabase.messageSearch.rebuildIndex() try {
SignalDatabase.messageSearch.rebuildIndex()
} catch (e: IllegalStateException) {
throw RetryLaterException(e)
}
} }
override fun getNextRunAttemptBackoff(pastAttemptCount: Int, exception: Exception): Long { override fun getNextRunAttemptBackoff(pastAttemptCount: Int, exception: Exception): Long {
return 10.seconds.inWholeMilliseconds return 10.seconds.inWholeMilliseconds
} }
override fun onShouldRetry(e: Exception): Boolean = e is IllegalStateException override fun onShouldRetry(e: Exception): Boolean = e is RetryLaterException
class Factory : Job.Factory<RebuildMessageSearchIndexJob> { class Factory : Job.Factory<RebuildMessageSearchIndexJob> {
override fun create(parameters: Parameters, serializedData: ByteArray?): RebuildMessageSearchIndexJob { override fun create(parameters: Parameters, serializedData: ByteArray?): RebuildMessageSearchIndexJob {