feat: add response classes for BigDecimal and BigInteger types

Author: twisti-dev

surf-cloud-api/surf-cloud-api-common/src/main/kotlin/dev/slne/surf/cloud/api/common/netty/network/protocol/double/BigDecimalResponse.kt

@@ -0,0 +1,32 @@
+package dev.slne.surf.cloud.api.common.netty.network.protocol.double
+
+import dev.slne.surf.cloud.api.common.meta.SurfNettyPacket
+import dev.slne.surf.cloud.api.common.netty.network.protocol.CommonResponseType
+import dev.slne.surf.cloud.api.common.netty.network.protocol.CommonResponseTypeFactory
+import dev.slne.surf.cloud.api.common.netty.network.protocol.PacketFlow
+import dev.slne.surf.cloud.api.common.netty.packet.RespondingNettyPacket
+import dev.slne.surf.cloud.api.common.netty.packet.ResponseNettyPacket
+import dev.slne.surf.cloud.api.common.netty.packet.packetCodec
+import dev.slne.surf.cloud.api.common.netty.protocol.buffer.SurfByteBuf
+import java.math.BigDecimal
+
+typealias BigDecimalResponsePacket = RespondingNettyPacket<BigDecimalResponse>
+
+@SurfNettyPacket("big_decimal_response", PacketFlow.BIDIRECTIONAL)
+class BigDecimalResponse(override val value: BigDecimal) : ResponseNettyPacket(), CommonResponseType<BigDecimal> {
+    companion object: CommonResponseTypeFactory<BigDecimalResponse, BigDecimal> {
+        val STREAM_CODEC = packetCodec(BigDecimalResponse::write, ::BigDecimalResponse)
+
+        override fun create(value: BigDecimal): BigDecimalResponse {
+            return BigDecimalResponse(value)
+        }
+    }
+
+    private constructor(buf: SurfByteBuf) : this(BigDecimal(buf.readUtf()))
+
+    private fun write(buf: SurfByteBuf) {
+        buf.writeUtf(value.toString())
+    }
+
+    operator fun component1() = value
+}

surf-cloud-api/surf-cloud-api-common/src/main/kotlin/dev/slne/surf/cloud/api/common/netty/network/protocol/double/OptionalBigDecimalResponse.kt

@@ -0,0 +1,34 @@
+package dev.slne.surf.cloud.api.common.netty.network.protocol.double
+
+import dev.slne.surf.cloud.api.common.meta.SurfNettyPacket
+import dev.slne.surf.cloud.api.common.netty.network.protocol.CommonResponseType
+import dev.slne.surf.cloud.api.common.netty.network.protocol.CommonResponseTypeFactory
+import dev.slne.surf.cloud.api.common.netty.network.protocol.PacketFlow
+import dev.slne.surf.cloud.api.common.netty.packet.RespondingNettyPacket
+import dev.slne.surf.cloud.api.common.netty.packet.ResponseNettyPacket
+import dev.slne.surf.cloud.api.common.netty.packet.packetCodec
+import dev.slne.surf.cloud.api.common.netty.protocol.buffer.SurfByteBuf
+import java.math.BigDecimal
+
+typealias OptionalBigDecimalResponsePacket = RespondingNettyPacket<OptionalBigDecimalResponse>
+
+@SurfNettyPacket("optional_big_decimal_response", PacketFlow.BIDIRECTIONAL)
+class OptionalBigDecimalResponse(override val value: BigDecimal?) : ResponseNettyPacket(),
+    CommonResponseType<BigDecimal?> {
+    companion object : CommonResponseTypeFactory<OptionalBigDecimalResponse, BigDecimal?> {
+        val STREAM_CODEC =
+            packetCodec(OptionalBigDecimalResponse::write, ::OptionalBigDecimalResponse)
+
+        override fun create(value: BigDecimal?): OptionalBigDecimalResponse {
+            return OptionalBigDecimalResponse(value)
+        }
+    }
+
+    private constructor(buf: SurfByteBuf) : this(buf.readNullableString()?.let { BigDecimal(it) })
+
+    private fun write(buf: SurfByteBuf) {
+        buf.writeNullable(value?.toString())
+    }
+
+    operator fun component1() = value
+}

surf-cloud-api/surf-cloud-api-common/src/main/kotlin/dev/slne/surf/cloud/api/common/netty/network/protocol/int/BigIntegerResponse.kt

@@ -0,0 +1,33 @@
+package dev.slne.surf.cloud.api.common.netty.network.protocol.int
+
+import dev.slne.surf.cloud.api.common.meta.SurfNettyPacket
+import dev.slne.surf.cloud.api.common.netty.network.protocol.CommonResponseType
+import dev.slne.surf.cloud.api.common.netty.network.protocol.CommonResponseTypeFactory
+import dev.slne.surf.cloud.api.common.netty.network.protocol.PacketFlow
+import dev.slne.surf.cloud.api.common.netty.packet.RespondingNettyPacket
+import dev.slne.surf.cloud.api.common.netty.packet.ResponseNettyPacket
+import dev.slne.surf.cloud.api.common.netty.packet.packetCodec
+import dev.slne.surf.cloud.api.common.netty.protocol.buffer.SurfByteBuf
+import java.math.BigInteger
+
+typealias BigIntegerResponsePacket = RespondingNettyPacket<BigIntegerResponse>
+
+@SurfNettyPacket("big_integer_response", PacketFlow.BIDIRECTIONAL)
+class BigIntegerResponse(override val value: BigInteger) : ResponseNettyPacket(),
+    CommonResponseType<BigInteger> {
+    companion object : CommonResponseTypeFactory<BigIntegerResponse, BigInteger> {
+        val STREAM_CODEC = packetCodec(BigIntegerResponse::write, ::BigIntegerResponse)
+
+        override fun create(value: BigInteger): BigIntegerResponse {
+            return BigIntegerResponse(value)
+        }
+    }
+
+    private constructor(buf: SurfByteBuf) : this(BigInteger(buf.readUtf()))
+
+    private fun write(buf: SurfByteBuf) {
+        buf.writeUtf(value.toString())
+    }
+
+    operator fun component1() = value
+}

surf-cloud-api/surf-cloud-api-common/src/main/kotlin/dev/slne/surf/cloud/api/common/netty/network/protocol/int/OptionalBigIntegerResponse.kt

@@ -0,0 +1,34 @@
+package dev.slne.surf.cloud.api.common.netty.network.protocol.int
+
+import dev.slne.surf.cloud.api.common.meta.SurfNettyPacket
+import dev.slne.surf.cloud.api.common.netty.network.protocol.CommonResponseType
+import dev.slne.surf.cloud.api.common.netty.network.protocol.CommonResponseTypeFactory
+import dev.slne.surf.cloud.api.common.netty.network.protocol.PacketFlow
+import dev.slne.surf.cloud.api.common.netty.packet.RespondingNettyPacket
+import dev.slne.surf.cloud.api.common.netty.packet.ResponseNettyPacket
+import dev.slne.surf.cloud.api.common.netty.packet.packetCodec
+import dev.slne.surf.cloud.api.common.netty.protocol.buffer.SurfByteBuf
+import java.math.BigInteger
+
+typealias OptionalBigIntegerResponsePacket = RespondingNettyPacket<OptionalBigIntegerResponse>
+
+@SurfNettyPacket("optional_big_integer_response", PacketFlow.BIDIRECTIONAL)
+class OptionalBigIntegerResponse(override val value: BigInteger?) : ResponseNettyPacket(),
+    CommonResponseType<BigInteger?> {
+    companion object : CommonResponseTypeFactory<OptionalBigIntegerResponse, BigInteger?> {
+        val STREAM_CODEC =
+            packetCodec(OptionalBigIntegerResponse::write, ::OptionalBigIntegerResponse)
+
+        override fun create(value: BigInteger?): OptionalBigIntegerResponse {
+            return OptionalBigIntegerResponse(value)
+        }
+    }
+
+    private constructor(buf: SurfByteBuf) : this(buf.readNullableString()?.let { BigInteger(it) })
+
+    private fun write(buf: SurfByteBuf) {
+        buf.writeNullable(value?.toString())
+    }
+
+    operator fun component1() = value
+}