From 768eadd561404f1740ab26ca913647f953a5d976 Mon Sep 17 00:00:00 2001 From: dalbodeule <11470513+dalbodeule@users.noreply.github.com> Date: Mon, 25 Nov 2024 19:56:22 +0900 Subject: [PATCH] debugs... --- .../chzzk_bot/webserver/routes/WSSongListRoutes.kt | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/webserver/src/main/kotlin/space/mori/chzzk_bot/webserver/routes/WSSongListRoutes.kt b/webserver/src/main/kotlin/space/mori/chzzk_bot/webserver/routes/WSSongListRoutes.kt index 837d86d..955767d 100644 --- a/webserver/src/main/kotlin/space/mori/chzzk_bot/webserver/routes/WSSongListRoutes.kt +++ b/webserver/src/main/kotlin/space/mori/chzzk_bot/webserver/routes/WSSongListRoutes.kt @@ -65,7 +65,7 @@ fun Routing.wsSongListRoutes() { } delay(100) // Check every 100 ms } - return false // Timeoutㅌ + return false // Timeout } suspend fun sendWithRetry(uid: String, res: SongResponse, maxRetries: Int = 5, delayMillis: Long = 3000L) { @@ -75,11 +75,15 @@ fun Routing.wsSongListRoutes() { while (attempt < maxRetries && !sentSuccessfully) { val ws = sessions[uid] try { + if(ws == null) { + delay(delayMillis) + continue + } // Attempt to send the message - ws?.sendSerialized(res) + ws.sendSerialized(res) logger.debug("Message sent successfully to $uid on attempt $attempt") // Wait for ACK - val ackReceived = ws?.let { waitForAck(it, res.type) } + val ackReceived = waitForAck(ws, res.type) if (ackReceived == true) { sentSuccessfully = true } else { @@ -129,7 +133,7 @@ fun Routing.wsSongListRoutes() { for (frame in incoming) { when (frame) { is Text -> { - if (frame.readText() == "ping") { + if (frame.readText().trim() == "ping") { send("pong") } else { val data = frame.readText().let { Json.decodeFromString(it) }