Initial commit

blokk-server/src/main/kotlin/space/blokk/net/FramingCodec.kt

@@ -0,0 +1,31 @@
+package space.blokk.net
+
+import io.netty.buffer.ByteBuf
+import io.netty.channel.ChannelHandlerContext
+import io.netty.handler.codec.ByteToMessageCodec
+
+class FramingCodec: ByteToMessageCodec<ByteBuf>() {
+    private var currentLength: Int? = null
+
+    override fun encode(ctx: ChannelHandlerContext, msg: ByteBuf, out: ByteBuf) {
+        out.writeVarInt(msg.readableBytes())
+        msg.readerIndex(0)
+        out.writeBytes(msg)
+    }
+
+    override fun decode(ctx: ChannelHandlerContext, msg: ByteBuf, out: MutableList<Any>) {
+        var length = currentLength
+        if (length == null) {
+            if (msg.varIntReadable()) {
+                length = msg.readVarInt()
+                currentLength = length
+            }
+            else return
+        }
+
+        if (msg.readableBytes() >= length) {
+            out.add(msg.readBytes(length))
+            currentLength = null
+        }
+    }
+}