Creepso/NuvioStreaming
1
0
Fork 0
mirror of https://github.com/tapframe/NuvioStreaming.git synced 2026-08-06 19:38:58 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Refactor CfSessionCache to use kotlinx.atomicfu locks for KMP compatibility

Browse source
This commit is contained in:
paregi12 2026-06-28 03:15:30 +05:30
parent a0f3550944
commit 2bd2d654c6
1 changed files with 12 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
composeApp/src/fullCommonMain/kotlin/com/nuvio/app/features/plugins/runtime/network/CloudflareKiller.kt
View file

@ -1,6 +1,7 @@
package com.nuvio.app.features.plugins.runtime.network
import kotlin.concurrent.Synchronized
import kotlinx.atomicfu.locks.SynchronizedObject
import kotlinx.atomicfu.locks.synchronized
import kotlinx.coroutines.sync.Mutex
import kotlinx.serialization.json.Json
import kotlinx.serialization.json.buildJsonObject
@ -42,39 +43,37 @@ internal fun createPlatformWebViewSolver(): WebViewSolver = platformWebViewSolve
internal object CfSessionCache {
private val sessions = mutableMapOf<String, CfSolveResult>()
private val hostLocks = mutableMapOf<String, Mutex>()
private val lock = SynchronizedObject()
@Synchronized
fun getMutex(host: String): Mutex = hostLocks.getOrPut(host) { Mutex() }
fun getMutex(host: String): Mutex = synchronized(lock) {
hostLocks.getOrPut(host) { Mutex() }
}
@Synchronized
fun get(host: String, pluginId: String): CfSolveResult? {
fun get(host: String, pluginId: String): CfSolveResult? = synchronized(lock) {
sessions[host]?.let { return it }
val persisted = runCatching {
com.nuvio.app.features.plugins.PluginStorage.loadCfSession(host)
}.getOrNull()
val parsed = persisted?.let(::jsonStringToCfSolveResult) ?: return null
sessions[host] = parsed
return parsed
parsed
}
@Synchronized
fun put(host: String, pluginId: String, result: CfSolveResult) {
fun put(host: String, pluginId: String, result: CfSolveResult) = synchronized(lock) {
sessions[host] = result
runCatching {
com.nuvio.app.features.plugins.PluginStorage.saveCfSession(host, result.toJsonString())
}
}
@Synchronized
fun evict(host: String, pluginId: String) {
fun evict(host: String, pluginId: String) = synchronized(lock) {
sessions.remove(host)
runCatching {
com.nuvio.app.features.plugins.PluginStorage.removeCfSession(host)
}
}
@Synchronized
fun evictIfSame(host: String, result: CfSolveResult) {
fun evictIfSame(host: String, result: CfSolveResult) = synchronized(lock) {
if (sessions[host] == result) {
sessions.remove(host)
runCatching {
@ -83,8 +82,7 @@ internal object CfSessionCache {
}
}
@Synchronized
fun clear() {
fun clear() = synchronized(lock) {
sessions.clear()
}
}