yuzu/Minikura
1
0
Fork 0
mirror of https://github.com/YuzuZensai/Minikura.git synced 2026-01-06 04:32:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

✨ feat: use plugin logger for websocket

Browse Source
This commit is contained in:
Yuzu
2025-01-02 22:14:51 +07:00
parent edcb36e279
commit 4a92cf9703
2 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
plugins/MinikuraVelocity/src/main/kotlin/cafe/kirameki/minikuraVelocity/MinikuraWebSocketClient.kt
View File

@@ -3,16 +3,17 @@ package cafe.kirameki.minikuraVelocity
import com.velocitypowered.api.proxy.ProxyServer import com.velocitypowered.api.proxy.ProxyServer
import org.java_websocket.client.WebSocketClient import org.java_websocket.client.WebSocketClient
import org.java_websocket.handshake.ServerHandshake import org.java_websocket.handshake.ServerHandshake
import org.slf4j.Logger
import java.net.URI import java.net.URI
import java.time.Duration import java.time.Duration
class MinikuraWebSocketClient(private val plugin: Main, private val server: ProxyServer, serverUri: URI?) : WebSocketClient(serverUri) { class MinikuraWebSocketClient(private val plugin: Main, private val logger: Logger, private val server: ProxyServer, serverUri: URI?) : WebSocketClient(serverUri) {
override fun onOpen(handshakedata: ServerHandshake) { override fun onOpen(handshakedata: ServerHandshake) {
println("Connected to server") logger.info("Connected to websocket")
} }
override fun onMessage(message: String) { override fun onMessage(message: String) {
println("Received: $message") logger.debug("Received: $message")
} }
override fun onError(ex: Exception) { override fun onError(ex: Exception) {
@@ -20,7 +21,7 @@ class MinikuraWebSocketClient(private val plugin: Main, private val server: Prox
} }
override fun onClose(code: Int, reason: String, remote: Boolean) { override fun onClose(code: Int, reason: String, remote: Boolean) {
println("Disconnected from websocket, reconnecting...") logger.info("Connection closed, attempting to reconnect...")
server.scheduler.buildTask(plugin, Runnable { reconnect() }).delay(Duration.ofMillis(5000)).schedule() server.scheduler.buildTask(plugin, Runnable { reconnect() }).delay(Duration.ofMillis(5000)).schedule()
} }
} }

5
plugins/MinikuraVelocity/src/main/kotlin/cafe/kirameki/minikuraVelocity/utils/WebSocketUtils.kt
View File

@@ -3,10 +3,11 @@ package cafe.kirameki.minikuraVelocity.utils
import cafe.kirameki.minikuraVelocity.Main import cafe.kirameki.minikuraVelocity.Main
import cafe.kirameki.minikuraVelocity.MinikuraWebSocketClient import cafe.kirameki.minikuraVelocity.MinikuraWebSocketClient
import com.velocitypowered.api.proxy.ProxyServer import com.velocitypowered.api.proxy.ProxyServer
import org.slf4j.Logger
import java.net.URI import java.net.URI
fun createWebSocketClient(plugin: Main, server: ProxyServer, websocketUrl: String): MinikuraWebSocketClient { fun createWebSocketClient(plugin: Main, logger: Logger, server: ProxyServer, websocketUrl: String): MinikuraWebSocketClient {
val uri = URI(websocketUrl) val uri = URI(websocketUrl)
val client = MinikuraWebSocketClient(plugin, server, uri) val client = MinikuraWebSocketClient(plugin, logger, server, uri)
return client return client
} }