temple/Suwayomi-Server
1
0
Fork 0
mirror of https://github.com/Suwayomi/Suwayomi-Server.git synced 2026-07-04 11:24:35 -05:00
Code Issues Packages Projects Releases Wiki Activity

Make startSync non-suspend

Browse Source
This commit is contained in:
Bartu Özen
2025-12-18 20:23:02 +03:00
parent 3364d53c46
commit 5c0f714a3d
2 changed files with 6 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
server/src/main/kotlin/suwayomi/tachidesk/global/impl/sync/SyncManager.kt
View File

@@ -65,9 +65,7 @@ object SyncManager {
HAScheduler.schedule( HAScheduler.schedule(
{ {
GlobalScope.launch {
startSync() startSync()
}
}, },
interval = intervalMs, interval = intervalMs,
delay = intervalMs, delay = intervalMs,
@@ -81,7 +79,8 @@ object SyncManager {
) )
} }
suspend fun startSync() { @OptIn(DelicateCoroutinesApi::class)
fun startSync() {
if (!serverConfig.syncYomiEnabled.value) { if (!serverConfig.syncYomiEnabled.value) {
return return
} }
@@ -90,9 +89,9 @@ object SyncManager {
return return
} }
try { GlobalScope.launch {
syncData() syncData()
} finally { }.invokeOnCompletion {
syncMutex.unlock() syncMutex.unlock()
} }
} }

7
server/src/main/kotlin/suwayomi/tachidesk/graphql/mutations/SyncMutation.kt
View File

@@ -1,11 +1,7 @@
package suwayomi.tachidesk.graphql.mutations package suwayomi.tachidesk.graphql.mutations
import kotlinx.coroutines.DelicateCoroutinesApi
import kotlinx.coroutines.GlobalScope
import kotlinx.coroutines.launch
import suwayomi.tachidesk.global.impl.sync.SyncManager import suwayomi.tachidesk.global.impl.sync.SyncManager
import suwayomi.tachidesk.graphql.directives.RequireAuth import suwayomi.tachidesk.graphql.directives.RequireAuth
import suwayomi.tachidesk.server.serverConfig
class SyncMutation { class SyncMutation {
data class StartSyncInput( data class StartSyncInput(
@@ -16,14 +12,11 @@ class SyncMutation {
val clientMutationId: String? = null, val clientMutationId: String? = null,
) )
@OptIn(DelicateCoroutinesApi::class)
@RequireAuth @RequireAuth
fun startSync(input: StartSyncInput): StartSyncPayload { fun startSync(input: StartSyncInput): StartSyncPayload {
val (clientMutationId) = input val (clientMutationId) = input
GlobalScope.launch {
SyncManager.startSync() SyncManager.startSync()
}
return StartSyncPayload( return StartSyncPayload(
clientMutationId = clientMutationId, clientMutationId = clientMutationId,