refactor: replace boolean property with AtomicBoolean for thread-safe AFK status management

Author: twisti-dev

surf-cloud-bukkit/src/main/kotlin/dev/slne/surf/cloud/bukkit/util/ObservableFieldByEvent.kt

@@ -1,6 +1,5 @@
 package dev.slne.surf.cloud.bukkit.util
 
-import dev.slne.surf.cloud.api.common.util.mutableObjectSetOf
 import dev.slne.surf.cloud.api.common.util.observer.ObservableField.ObservableCoroutineScope
 import dev.slne.surf.surfapi.bukkit.api.event.listen
 import kotlinx.coroutines.CoroutineDispatcher
@@ -11,6 +10,7 @@ import kotlinx.coroutines.launch
 import org.bukkit.event.Event
 import org.bukkit.plugin.Plugin
 import org.bukkit.plugin.java.JavaPlugin
+import java.util.concurrent.CopyOnWriteArrayList
 import kotlin.reflect.KClass
 
 class ObservableFieldByEvent<E : Event, T>(
@@ -23,7 +23,7 @@ class ObservableFieldByEvent<E : Event, T>(
     customDispatcher: CoroutineDispatcher? = null
 ) {
     private val channel = Channel<T>(Channel.CONFLATED)
-    private val listener = mutableObjectSetOf<(T) -> Unit>()
+    private val listener = CopyOnWriteArrayList<(T) -> Unit>()
 
     init {
         val dispatcher = customDispatcher?.let { CoroutineScope(it + SupervisorJob()) }

surf-cloud-core/surf-cloud-core-client/src/main/kotlin/dev/slne/surf/cloud/core/client/netty/ConnectionVerifier.kt

@@ -19,7 +19,6 @@ class ConnectionVerifier : CloudLifecycleAware {
         CloudConnectionVerificationScope.launch {
             while (isActive) {
                 delay(5.minutes)
-
             }
         }
     }

surf-cloud-core/surf-cloud-core-client/src/main/kotlin/dev/slne/surf/cloud/core/client/player/ClientCloudPlayerImpl.kt

@@ -14,6 +14,8 @@ import dev.slne.surf.cloud.api.common.player.teleport.TeleportCause
 import dev.slne.surf.cloud.api.common.player.teleport.TeleportFlag
 import dev.slne.surf.cloud.api.common.player.teleport.TeleportLocation
 import dev.slne.surf.cloud.api.common.server.CloudServer
+import dev.slne.surf.cloud.api.common.util.getValue
+import dev.slne.surf.cloud.api.common.util.setValue
 import dev.slne.surf.cloud.core.client.server.serverManagerImpl
 import dev.slne.surf.cloud.core.client.util.luckperms
 import dev.slne.surf.cloud.core.common.netty.network.protocol.running.*
@@ -42,6 +44,7 @@ import net.luckperms.api.platform.PlayerAdapter
 import java.net.Inet4Address
 import java.time.ZonedDateTime
 import java.util.*
+import java.util.concurrent.atomic.AtomicBoolean
 import kotlin.time.Duration
 import kotlin.time.Duration.Companion.days
 import dev.slne.surf.cloud.core.common.netty.network.protocol.running.ServerboundRequestPlayerDataResponse.NameHistory as NameHistoryResponse
@@ -54,8 +57,7 @@ abstract class ClientCloudPlayerImpl<PlatformPlayer : Audience>(uuid: UUID, name
     @Volatile
     var serverUid: Long? = null
 
-    @Volatile
-    var afk: Boolean = false
+    var afk: Boolean by AtomicBoolean()
 
     override val connectedToProxy get() = proxyServerUid != null
 

surf-cloud-core/surf-cloud-core-client/src/main/kotlin/dev/slne/surf/cloud/core/client/player/CommonClientCloudPlayerManagerImpl.kt

@@ -1,13 +1,12 @@
 package dev.slne.surf.cloud.core.client.player
 
-import dev.slne.surf.cloud.api.common.player.OfflineCloudPlayer
 import dev.slne.surf.cloud.core.common.player.CloudPlayerManagerImpl
 import dev.slne.surf.cloud.core.common.player.CommonOfflineCloudPlayerImpl
 import dev.slne.surf.cloud.core.common.player.playerManagerImpl
 import net.kyori.adventure.audience.Audience
 import java.util.*
 
-abstract class CommonClientCloudPlayerManagerImpl<Platform: Audience, P : ClientCloudPlayerImpl<Platform>> :
+abstract class CommonClientCloudPlayerManagerImpl<Platform : Audience, P : ClientCloudPlayerImpl<Platform>> :
     CloudPlayerManagerImpl<P>() {
     override suspend fun updateProxyServer(
         player: P,