add LONG_ARRAY and WrappedStreamCodec

Author: LukynkaCZE

gradle.properties

@@ -1,2 +1,2 @@
 kotlin.code.style=official
-tide.version=3.7
+tide.version=3.8

src/main/kotlin/io/github/dockyardmc/tide/stream/StreamCodec.kt

@@ -32,6 +32,9 @@ interface StreamCodec<T> {
         return UnionStreamCodec(this, keyFunc, serializers)
     }
 
+    fun wrapped(): WrappedStreamCodec<T> {
+        return WrappedStreamCodec<T>(this)
+    }
 
     companion object {
         val UNIT = object : StreamCodec<Unit> {
@@ -180,6 +183,23 @@ interface StreamCodec<T> {
             }
         }
 
+        val LONG_ARRAY = object : StreamCodec<LongArray> {
+
+            override fun write(buffer: ByteBuf, value: LongArray) {
+                VAR_INT.write(buffer, value.size)
+                value.forEach { long -> buffer.writeLong(long) }
+            }
+
+            override fun read(buffer: ByteBuf): LongArray {
+                val size = VAR_INT.read(buffer)
+                val longs = mutableListOf<Long>()
+                for (i in 0 until size) {
+                    longs.add(buffer.readLong())
+                }
+                return longs.toLongArray()
+            }
+        }
+
         fun <T> recursive(self: (StreamCodec<T>) -> StreamCodec<T>): RecursiveStreamCodec<T> {
             return RecursiveStreamCodec<T>(self)
         }

src/main/kotlin/io/github/dockyardmc/tide/stream/WrappedStreamCodec.kt

@@ -0,0 +1,19 @@
+package io.github.dockyardmc.tide.stream
+
+import io.netty.buffer.ByteBuf
+import io.netty.buffer.Unpooled
+
+class WrappedStreamCodec<T>(val inner: StreamCodec<T>) : StreamCodec<T> {
+
+    override fun write(buffer: ByteBuf, value: T) {
+        val innerBuffer = Unpooled.buffer()
+        inner.write(innerBuffer, value)
+        StreamCodec.BYTE_ARRAY.write(buffer, innerBuffer)
+    }
+
+    override fun read(buffer: ByteBuf): T {
+        val innerBuffer = StreamCodec.BYTE_ARRAY.read(buffer)
+        return inner.read(innerBuffer)
+    }
+
+}