fix: workaround Packet was larger than I expected error

OKTW-Network · Jul 15, 2024 · 05f145a · 05f145a
1 parent 4a9dd75
commit 05f145a
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 2 deletions.
diff --git a/src/main/kotlin/one/oktw/galaxy/network/ProxyAPIPayload.kt b/src/main/kotlin/one/oktw/galaxy/network/ProxyAPIPayload.kt
@@ -34,7 +34,12 @@ data class ProxyAPIPayload(val packet: Packet) : CustomPayload {
         val ID = CustomPayload.Id<ProxyAPIPayload>(PROXY_IDENTIFIER)
         val CODEC: PacketCodec<PacketByteBuf, ProxyAPIPayload> = PacketCodec.of(
             { value, buf -> buf.writeBytes(wrappedBuffer(encode(value.packet))) },
-            { buf -> ProxyAPIPayload(ProxyAPI.decode(buf.nioBuffer())) })
+            { buf ->
+                val packet = ProxyAPIPayload(ProxyAPI.decode(buf.nioBuffer()))
+                // FIXME: Workaround force clear buffer to suppress "Packet was larger than I expected" error
+                buf.clear()
+                return@of packet
+            })
     }
 
     override fun getId(): CustomPayload.Id<out CustomPayload> {

diff --git a/src/main/kotlin/one/oktw/galaxy/network/ProxyChatPayload.kt b/src/main/kotlin/one/oktw/galaxy/network/ProxyChatPayload.kt
@@ -34,7 +34,12 @@ data class ProxyChatPayload(val packet: Packet) : CustomPayload {
         val ID = CustomPayload.Id<ProxyChatPayload>(PROXY_CHAT_IDENTIFIER)
         val CODEC: PacketCodec<PacketByteBuf, ProxyChatPayload> = PacketCodec.of(
             { value, buf -> buf.writeBytes(wrappedBuffer(encode(value.packet))) },
-            { buf -> ProxyChatPayload(ProxyAPI.decode(buf.nioBuffer())) })
+            { buf ->
+                val packet = ProxyChatPayload(ProxyAPI.decode(buf.nioBuffer()))
+                // FIXME: Workaround force clear buffer to suppress "Packet was larger than I expected" error
+                buf.clear()
+                return@of packet
+            })
     }
 
     override fun getId(): CustomPayload.Id<out CustomPayload> {