fix: debounce

Author: jvsena42

app/src/main/java/to/bitkit/ui/settings/advanced/RgsServerViewModel.kt

@@ -5,6 +5,8 @@ import androidx.lifecycle.ViewModel
 import androidx.lifecycle.viewModelScope
 import dagger.hilt.android.lifecycle.HiltViewModel
 import kotlinx.coroutines.CoroutineDispatcher
+import kotlinx.coroutines.Job
+import kotlinx.coroutines.delay
 import kotlinx.coroutines.flow.MutableStateFlow
 import kotlinx.coroutines.flow.StateFlow
 import kotlinx.coroutines.flow.asStateFlow
@@ -18,6 +20,7 @@ import to.bitkit.env.Env
 import to.bitkit.repositories.LightningRepo
 import java.net.URI
 import javax.inject.Inject
+import kotlin.time.Duration.Companion.seconds
 
 @HiltViewModel
 class RgsServerViewModel @Inject constructor(
@@ -32,11 +35,14 @@ class RgsServerViewModel @Inject constructor(
             RegexOption.IGNORE_CASE,
         )
         private val PATH_PATTERN = Regex("^(/[a-zA-Z\\d_.~%+-]*)*$")
+        private val VALIDATION_DEBOUNCE = 1.seconds
     }
 
     private val _uiState = MutableStateFlow(RgsServerUiState())
     val uiState: StateFlow<RgsServerUiState> = _uiState.asStateFlow()
 
+    private var validationJob: Job? = null
+
     init {
         observeState()
     }
@@ -57,17 +63,20 @@ class RgsServerViewModel @Inject constructor(
     }
 
     fun setRgsUrl(url: String) {
-        _uiState.update {
-            val newState = it.copy(rgsUrl = url.trim())
-            computeState(newState)
-        }
+        _uiState.update { it.copy(rgsUrl = url.trim()) }
+        debounceValidation()
     }
 
     fun resetToDefault() {
-        val defaultUrl = Env.ldkRgsServerUrl ?: ""
-        _uiState.update {
-            val newState = it.copy(rgsUrl = defaultUrl)
-            computeState(newState)
+        _uiState.update { it.copy(rgsUrl = Env.ldkRgsServerUrl ?: "") }
+        debounceValidation()
+    }
+
+    private fun debounceValidation() {
+        validationJob?.cancel()
+        validationJob = viewModelScope.launch(bgDispatcher) {
+            delay(VALIDATION_DEBOUNCE)
+            _uiState.update { computeState(it) }
         }
     }
 

app/src/test/java/to/bitkit/ui/settings/advanced/RgsServerViewModelTest.kt

@@ -4,6 +4,7 @@ import app.cash.turbine.test
 import kotlinx.coroutines.ExperimentalCoroutinesApi
 import kotlinx.coroutines.flow.flowOf
 import kotlinx.coroutines.test.advanceUntilIdle
+import kotlinx.coroutines.withTimeout
 import org.junit.Before
 import org.junit.Test
 import org.mockito.kotlin.mock
@@ -14,7 +15,6 @@ import to.bitkit.data.SettingsData
 import to.bitkit.data.SettingsStore
 import to.bitkit.repositories.LightningRepo
 import to.bitkit.test.BaseUnitTest
-import kotlinx.coroutines.withTimeout
 import kotlin.test.assertEquals
 import kotlin.test.assertFalse
 import kotlin.test.assertNotNull
@@ -64,6 +64,7 @@ class RgsServerViewModelTest : BaseUnitTest() {
         advanceUntilIdle()
 
         sut.setRgsUrl("https://other.server.com/snapshot")
+        advanceUntilIdle()
 
         val state = sut.uiState.value
         assertEquals("https://other.server.com/snapshot", state.rgsUrl)
@@ -226,6 +227,7 @@ class RgsServerViewModelTest : BaseUnitTest() {
         sut.setRgsUrl("https://custom.server.com/snapshot")
 
         sut.resetToDefault()
+        advanceUntilIdle()
 
         val state = sut.uiState.value
         assertFalse(state.canReset)
@@ -239,6 +241,7 @@ class RgsServerViewModelTest : BaseUnitTest() {
         sut = createSut()
         advanceUntilIdle()
         sut.setRgsUrl(newUrl)
+        advanceUntilIdle()
 
         sut.uiState.test {
             skipItems(1)
@@ -256,6 +259,7 @@ class RgsServerViewModelTest : BaseUnitTest() {
 
         withTimeout(2.seconds) {
             sut.setRgsUrl("https://rapidsync.lightningdevkit/snapshot/" + "a".repeat(100) + "!")
+            advanceUntilIdle()
         }
 
         assertFalse(sut.uiState.value.canConnect)
@@ -268,6 +272,7 @@ class RgsServerViewModelTest : BaseUnitTest() {
 
         withTimeout(2.seconds) {
             sut.setRgsUrl("https://rapidsync.lightningdevkit/snapshot")
+            advanceUntilIdle()
         }
 
         assertTrue(sut.uiState.value.canConnect)
@@ -289,6 +294,7 @@ class RgsServerViewModelTest : BaseUnitTest() {
         advanceUntilIdle()
 
         sut.setRgsUrl("https://192.168.1.1:8080/snapshot")
+        advanceUntilIdle()
 
         assertTrue(sut.uiState.value.canConnect)
     }