extract common classes

Author: BFergerson

src/jvmMain/kotlin/spp/protocol/util/KSerializers.kt

@@ -0,0 +1,23 @@
+package spp.protocol.util
+
+import com.fasterxml.jackson.core.JsonGenerator
+import com.fasterxml.jackson.core.JsonParser
+import com.fasterxml.jackson.databind.*
+import kotlinx.datetime.Instant
+
+/**
+ * Used to serialize/deserialize Kotlin classes.
+ *
+ * @since 0.1.0
+ */
+object KSerializers {
+    class KotlinInstantSerializer : JsonSerializer<Instant>() {
+        override fun serialize(value: Instant, jgen: JsonGenerator, provider: SerializerProvider) =
+            jgen.writeNumber(value.toEpochMilliseconds())
+    }
+
+    class KotlinInstantDeserializer : JsonDeserializer<Instant>() {
+        override fun deserialize(p: JsonParser, p1: DeserializationContext): Instant =
+            Instant.fromEpochMilliseconds((p.codec.readTree(p) as JsonNode).longValue())
+    }
+}

src/jvmMain/kotlin/spp/protocol/util/LocalMessageCodec.kt

@@ -0,0 +1,22 @@
+package spp.protocol.util
+
+import io.vertx.core.buffer.Buffer
+import io.vertx.core.eventbus.MessageCodec
+import java.util.*
+
+/**
+ * Used to transmit protocol messages.
+ *
+ * @since 0.1.0
+ */
+class LocalMessageCodec<T> : MessageCodec<T, T> {
+    override fun encodeToWire(buffer: Buffer, o: T): Unit =
+        throw UnsupportedOperationException("Not supported yet.")
+
+    override fun decodeFromWire(pos: Int, buffer: Buffer): T =
+        throw UnsupportedOperationException("Not supported yet.")
+
+    override fun transform(o: T): T = o
+    override fun name(): String = UUID.randomUUID().toString()
+    override fun systemCodecID(): Byte = -1
+}