YuzuZensai/Minikura
1
0
Fork 0
mirror of https://github.com/YuzuZensai/Minikura.git synced 2026-09-14 03:09:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: websocket auto detect server info change

Browse Source
This commit is contained in:
Nakiri
2025-06-01 16:27:34 +07:00
parent e843480f17
commit 367be7dc11
13 changed files with 248 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/MinikuraVelocity/src/main/kotlin/cafe/kirameki/minikuraVelocity/MinikuraWebSocketClient.kt
+87 -4
View File
@@ -6,22 +6,105 @@ import org.java_websocket.handshake.ServerHandshake
import org.slf4j.Logger
import java.net.URI
import java.time.Duration
import com.google.gson.JsonParser
class MinikuraWebSocketClient(private val plugin: Main, private val logger: Logger, private val server: ProxyServer, serverUri: URI?) : WebSocketClient(serverUri) {
override fun onOpen(handshakedata: ServerHandshake) {
logger.info("Connected to websocket")
logger.info("Connected to WebSocket server at: ${uri}")
}
override fun onMessage(message: String) {
logger.debug("Received: $message")
try {
val jsonElement = JsonParser.parseString(message)
if (jsonElement.isJsonObject) {
val jsonObject = jsonElement.asJsonObject
val type = jsonObject.get("type")?.asString
val endpoint = jsonObject.get("endpoint")?.asString
val timestamp = jsonObject.get("timestamp")?.asString
when (type) {
"test" -> {
logger.info("API Call detected: endpoint=$endpoint, timestamp=$timestamp")
when (endpoint) {
"/servers" -> {
logger.info("dawdawdawdawd")
}
else -> {
logger.info("API endpoint $endpoint was accessed")
}
}
}
"SERVER_CHANGE" -> {
val action = jsonObject.get("action")?.asString
val serverType = jsonObject.get("serverType")?.asString
val serverId = jsonObject.get("serverId")?.asString
logger.info("Server change detected: action=$action, serverType=$serverType, serverId=$serverId")
when (action) {
"CREATE" -> {
logger.info("Server '$serverId' was created")
executeRefreshCommand()
}
"UPDATE" -> {
logger.info("Server '$serverId' was updated")
executeRefreshCommand()
}
"DELETE" -> {
logger.info("Server '$serverId' was deleted")
executeRefreshCommand()
}
else -> {
logger.info("$action")
}
}
}
else -> {
logger.info("Received WebSocket message of type: $type")
}
}
} else {
logger.info("Received non-JSON WebSocket message: $message")
}
} catch (e: Exception) {
logger.warn("Failed to parse WebSocket message: $message", e)
}
}
override fun onError(ex: Exception) {
ex.printStackTrace()
when (ex) {
is java.net.ConnectException -> {
logger.warn("Failed to connect to WebSocket server at: ${uri}")
}
else -> {
logger.error("WebSocket error occurred", ex)
}
}
}
override fun onClose(code: Int, reason: String, remote: Boolean) {
logger.info("Connection closed, attempting to reconnect...")
server.scheduler.buildTask(plugin, Runnable { reconnect() }).delay(Duration.ofMillis(5000)).schedule()
logger.info("WebSocket connection closed (code: $code, reason: $reason)")
}
private fun executeRefreshCommand() {
try {
server.scheduler.buildTask(plugin, Runnable {
try {
logger.info("Executing automatic server refresh...")
plugin.refreshServers()
plugin.getallServer()
logger.info("Server refresh completed successfully")
} catch (e: Exception) {
logger.error("Failed to refresh servers", e)
}
}).schedule()
} catch (e: Exception) {
logger.error("Failed to schedule refresh command", e)
}
}
}