feat: add support for InterChat player presence

Author: acrylic-style

server/build.gradle.kts

@@ -37,7 +37,7 @@ dependencies {
     implementation("io.ktor:ktor-client-cio-jvm:2.3.5")
     implementation("ch.qos.logback:logback-classic:$logbackVersion")
     implementation("redis.clients:jedis:4.2.3")
-    implementation("net.azisaba.interchat:api:2.10.0")
+    implementation("net.azisaba.interchat:api:2.12.0")
     implementation("net.kyori:adventure-api:$adventureVersion")
     implementation("net.kyori:adventure-text-serializer-legacy:$adventureVersion")
     implementation("net.kyori:adventure-text-serializer-gson:$adventureVersion")

server/src/main/kotlin/net/azisaba/api/server/TaskScheduler.kt

@@ -6,9 +6,13 @@ import kotlinx.coroutines.runBlocking
 import kotlinx.serialization.encodeToString
 import kotlinx.serialization.json.Json
 import net.azisaba.api.Logger
+import net.azisaba.api.server.interchat.InterChatPacketListener
+import net.azisaba.api.server.interchat.JedisBoxProvider
 import net.azisaba.api.server.resources.punishments.RouteSearch
 import net.azisaba.api.server.schemas.SpicyAzisaBan
 import net.azisaba.api.server.vector.RawTextVector
+import net.azisaba.interchat.api.data.PlayerPresenceData
+import net.azisaba.interchat.api.network.RedisKeys
 import org.jetbrains.exposed.sql.transactions.transaction
 import java.io.File
 import java.util.*
@@ -26,6 +30,23 @@ object TaskScheduler : Timer("Async Task Scheduler", true) {
             }
         }
 
+        schedule(1000 * 30) {
+            try {
+                InterChatPacketListener.sockets.forEach { socket ->
+                    if (socket.uuid == null) return@forEach
+                    val existingData = JedisBoxProvider.get().getOptional(RedisKeys.playerPresence(socket.uuid!!.toString()), PlayerPresenceData.CODEC, 1000, true)
+                    if (existingData.isPresent && existingData.get().cause() == PlayerPresenceData.Cause.INTERCHAT && System.currentTimeMillis() - existingData.get().lastSeen() < 1000 * 60) {
+                        // skip if the player is connected to azisaba
+                        return@forEach
+                    }
+                    val presenceData = PlayerPresenceData(socket.uuid!!, socket.server, System.currentTimeMillis(), PlayerPresenceData.Cause.OTHER)
+                    JedisBoxProvider.get().set(RedisKeys.playerPresence(socket.uuid!!.toString()), PlayerPresenceData.CODEC, presenceData)
+                }
+            } catch (e: Exception) {
+                Logger.currentLogger.error("Error updating InterChat player presence", e)
+            }
+        }
+
         schedule(1000 * 3, 1000 * 60 * 10) {
             try {
                 runBlocking {

server/src/main/kotlin/net/azisaba/api/server/resources/interchat/RouteIdentifiedGuilds.kt

@@ -6,11 +6,17 @@ import io.ktor.server.application.*
 import io.ktor.server.auth.*
 import io.ktor.util.pipeline.*
 import kotlinx.serialization.Serializable
+import kotlinx.serialization.json.JsonElement
+import kotlinx.serialization.json.JsonObject
+import kotlinx.serialization.json.JsonPrimitive
 import net.azisaba.api.server.auth.APIKeyPrincipal
 import net.azisaba.api.server.interchat.InterChatApi
+import net.azisaba.api.server.interchat.JedisBoxProvider
 import net.azisaba.api.server.resources.RequestHandler
 import net.azisaba.api.server.resources.respondJson
 import net.azisaba.api.server.schemas.SpicyAzisaBan
+import net.azisaba.interchat.api.data.PlayerPresenceData
+import net.azisaba.interchat.api.network.RedisKeys
 
 @Serializable
 @Resource("/interchat/guilds/{id}")
@@ -28,15 +34,25 @@ data class RouteIdentifiedGuilds(val id: Long) {
                     return call.respondJson(mapOf("error" to "not found"), status = HttpStatusCode.NotFound)
                 }
                 call.respondJson(members.map {
-                    mapOf(
-                        "guild_id" to it.guildId(),
-                        "uuid" to it.uuid().toString(),
-                        "name" to SpicyAzisaBan.Players.getUsernameById(it.uuid()),
-                        "role" to it.role().name,
-                        "nickname" to it.nickname(),
-                    )
+                    val presenceData = JedisBoxProvider.get().getOptional(RedisKeys.playerPresence(it.uuid().toString()), PlayerPresenceData.CODEC, 100, true)
+                    val extraData = mutableMapOf<String, JsonElement>()
+                    if (presenceData.isPresent) {
+                        extraData["presence"] = JsonObject(mapOf(
+                            "server" to JsonPrimitive(presenceData.get().server()),
+                            "last_seen" to JsonPrimitive(presenceData.get().lastSeen()),
+                            "cause" to JsonPrimitive(presenceData.get().cause().name),
+                        ))
+                    }
+                    JsonObject(mapOf(
+                        "guild_id" to JsonPrimitive(it.guildId()),
+                        "uuid" to JsonPrimitive(it.uuid().toString()),
+                        "name" to JsonPrimitive(SpicyAzisaBan.Players.getUsernameById(it.uuid())),
+                        "role" to JsonPrimitive(it.role().name),
+                        "nickname" to JsonPrimitive(it.nickname()),
+                    )) + JsonObject(extraData)
                 })
             } catch (e: Exception) {
+                e.printStackTrace()
                 return call.respondJson(mapOf("error" to "not found"), status = HttpStatusCode.NotFound)
             }
         }