fix: sync issues and don't use main thread for DB access

Yash-Garg · Sep 8, 2023 · 4a82eee · 4a82eee
1 parent 43533d2
commit 4a82eee
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 8 deletions.
diff --git a/app/src/main/kotlin/dev/yashgarg/qbit/data/manager/ClientManagerImpl.kt b/app/src/main/kotlin/dev/yashgarg/qbit/data/manager/ClientManagerImpl.kt
@@ -31,12 +31,14 @@ constructor(
     }
 
     private suspend fun checkIfConfigsExist() {
-        configDao.getConfigs().collect { configs ->
-            if (configs.isNotEmpty()) {
-                _configStatus.emit(ConfigStatus.EXISTS)
-                checkAndGetClient()
-            } else {
-                _configStatus.emit(ConfigStatus.DOES_NOT_EXIST)
+        withContext(Dispatchers.IO) {
+            configDao.getConfigs().collect { configs ->
+                if (configs.isNotEmpty()) {
+                    _configStatus.emit(ConfigStatus.EXISTS)
+                    checkAndGetClient()
+                } else {
+                    _configStatus.emit(ConfigStatus.DOES_NOT_EXIST)
+                }
             }
         }
     }

diff --git a/app/src/main/kotlin/dev/yashgarg/qbit/ui/config/ConfigViewModel.kt b/app/src/main/kotlin/dev/yashgarg/qbit/ui/config/ConfigViewModel.kt
@@ -20,6 +20,7 @@ import kotlinx.coroutines.flow.asStateFlow
 import kotlinx.coroutines.flow.receiveAsFlow
 import kotlinx.coroutines.flow.update
 import kotlinx.coroutines.launch
+import kotlinx.coroutines.withContext
 import qbittorrent.QBittorrentClient
 
 @HiltViewModel
@@ -187,7 +188,7 @@ class ConfigViewModel @Inject constructor(private val configDao: ConfigDao) : Vi
                 trustSelfSigned = trustSelfSigned
             )
 
-        viewModelScope.launch { configDao.addConfig(config) }
+        viewModelScope.launch { withContext(Dispatchers.IO) { configDao.addConfig(config) } }
     }
 
     suspend fun testConfig(

diff --git a/app/src/main/kotlin/dev/yashgarg/qbit/ui/server/ServerViewModel.kt b/app/src/main/kotlin/dev/yashgarg/qbit/ui/server/ServerViewModel.kt
@@ -27,7 +27,7 @@ class ServerViewModel @Inject constructor(private val repository: QbitRepository
     private var syncJob: Job? = null
 
     init {
-        refresh()
+        syncJob = viewModelScope.launch { syncData() }
     }
 
     fun refresh() {