feat: add sync time out

Author: jvsena42

app/src/main/java/to/bitkit/repositories/LightningRepo.kt

@@ -17,6 +17,7 @@ import kotlinx.coroutines.flow.first
 import kotlinx.coroutines.flow.update
 import kotlinx.coroutines.tasks.await
 import kotlinx.coroutines.withContext
+import kotlinx.coroutines.withTimeout
 import kotlinx.coroutines.withTimeoutOrNull
 import org.lightningdevkit.ldknode.Address
 import org.lightningdevkit.ldknode.BalanceDetails
@@ -57,6 +58,8 @@ import kotlin.time.Duration
 import kotlin.time.Duration.Companion.minutes
 import kotlin.time.Duration.Companion.seconds
 
+private const val SYNC_TIMEOUT_MS = 10_000L
+
 @Singleton
 class LightningRepo @Inject constructor(
     @BgDispatcher private val bgDispatcher: CoroutineDispatcher,
@@ -260,7 +263,10 @@ class LightningRepo @Inject constructor(
         if (_lightningState.value.isSyncingWallet) {
             Logger.warn("Sync already in progress, waiting for existing sync.", context = TAG)
         }
-        _lightningState.first { !it.isSyncingWallet }
+
+        withTimeout(SYNC_TIMEOUT_MS) {
+            _lightningState.first { !it.isSyncingWallet }
+        }
 
         _lightningState.update { it.copy(isSyncingWallet = true) }
         lightningService.sync()

app/src/main/java/to/bitkit/repositories/WalletRepo.kt

@@ -6,6 +6,7 @@ import com.synonym.bitkitcore.decode
 import kotlinx.coroutines.CoroutineDispatcher
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.SupervisorJob
+import kotlinx.coroutines.TimeoutCancellationException
 import kotlinx.coroutines.flow.MutableStateFlow
 import kotlinx.coroutines.flow.asStateFlow
 import kotlinx.coroutines.flow.filter
@@ -152,6 +153,9 @@ class WalletRepo @Inject constructor(
             syncBalances()
             return@withContext Result.success(Unit)
         }.onFailure { e ->
+            if (e is TimeoutCancellationException) {
+                syncBalances()
+            }
             return@withContext Result.failure(e)
         }
     }