fix: resolve ktor3 api breaks

KyoriPowered · Nov 3, 2024 · a0b2d0c · a0b2d0c
1 parent 55c24c9
commit a0b2d0c
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 8 deletions.
diff --git a/src/jvmMain/kotlin/net/kyori/adventure/webui/jvm/Application.kt b/src/jvmMain/kotlin/net/kyori/adventure/webui/jvm/Application.kt
@@ -15,7 +15,8 @@ import io.ktor.server.websocket.WebSockets
 import io.ktor.server.websocket.pingPeriod
 import io.ktor.server.websocket.timeout
 import io.ktor.websocket.WebSocketDeflateExtension
-import java.time.Duration
+import kotlin.time.Duration
+import kotlin.time.Duration.Companion.seconds
 
 public fun Application.main() {
     install(Compression) {
@@ -36,8 +37,8 @@ public fun Application.main() {
     }
 
     install(WebSockets) {
-        pingPeriod = Duration.ofSeconds(15)
-        timeout = Duration.ofSeconds(5)
+        pingPeriod = 15.seconds
+        timeout = 5.seconds
 
         extensions { install(WebSocketDeflateExtension) }
     }

diff --git a/src/jvmMain/kotlin/net/kyori/adventure/webui/jvm/minimessage/MiniMessage.kt b/src/jvmMain/kotlin/net/kyori/adventure/webui/jvm/minimessage/MiniMessage.kt
@@ -2,7 +2,6 @@ package net.kyori.adventure.webui.jvm.minimessage
 
 import io.ktor.http.HttpStatusCode
 import io.ktor.server.application.Application
-import io.ktor.server.application.call
 import io.ktor.server.http.content.defaultResource
 import io.ktor.server.http.content.resource
 import io.ktor.server.http.content.resources

diff --git a/...in/kotlin/net/kyori/adventure/webui/jvm/minimessage/preview/ServerStatusPreviewManager.kt b/...in/kotlin/net/kyori/adventure/webui/jvm/minimessage/preview/ServerStatusPreviewManager.kt
@@ -8,7 +8,9 @@ import io.ktor.network.sockets.openWriteChannel
 import io.ktor.server.application.Application
 import io.ktor.utils.io.ByteReadChannel
 import io.ktor.utils.io.ByteWriteChannel
-import io.ktor.utils.io.close
+import io.ktor.utils.io.readByte
+import io.ktor.utils.io.readFully
+import io.ktor.utils.io.readShort
 import io.ktor.utils.io.writeByte
 import io.ktor.utils.io.writeFully
 import kotlinx.coroutines.CoroutineScope
@@ -97,7 +99,7 @@ public class ServerStatusPreviewManager(
                             }
                         }
 
-                        sendChannel.close()
+                        sendChannel.flushAndClose()
                     } catch (e: Exception) {
                         logger.error("An unknown error occurred whilst responding to a ping from ${socket.remoteAddress}", e)
                     }
@@ -157,11 +159,11 @@ public class ServerStatusPreviewManager(
         var value = int
         while (true) {
             if ((value and 0x7F.inv()) == 0) {
-                writeByte(value)
+                writeByte(value.toByte())
                 return
             }
 
-            writeByte((value and 0x7F) or 0x80)
+            writeByte(((value and 0x7F) or 0x80).toByte())
 
             value = value ushr 7
         }