Support for custom Decimal type in the common target

2 files changed, 100 insertions, 18 deletions

diff --git a/kvision-modules/kvision-server-jooby/src/main/kotlin/pl/treksoft/kvision/remote/KVServiceManager.kt b/kvision-modules/kvision-server-jooby/src/main/kotlin/pl/treksoft/kvision/remote/KVServiceManager.kt
index ac799769..6cc2b73d 100644
--- a/kvision-modules/kvision-server-jooby/src/main/kotlin/pl/treksoft/kvision/remote/KVServiceManager.kt
+++ b/kvision-modules/kvision-server-jooby/src/main/kotlin/pl/treksoft/kvision/remote/KVServiceManager.kt
@@ -40,12 +40,13 @@ import org.jooby.Response
 import org.slf4j.Logger
 import org.slf4j.LoggerFactory
 import pl.treksoft.kvision.types.*
-import kotlin.reflect.KClass
-import java.time.LocalDateTime
+import java.math.BigDecimal
 import java.time.LocalDate
+import java.time.LocalDateTime
 import java.time.LocalTime
 import java.time.OffsetDateTime
 import java.time.OffsetTime
+import kotlin.reflect.KClass
 
 
 /**
@@ -67,11 +68,13 @@ actual open class KVServiceManager<T : Any> actual constructor(val serviceClass:
         module.addSerializer(LocalTime::class.java, LocalTimeSerializer())
         module.addSerializer(OffsetDateTime::class.java, OffsetDateTimeSerializer())
         module.addSerializer(OffsetTime::class.java, OffsetTimeSerializer())
+        module.addSerializer(BigDecimal::class.java, BigDecimalSerializer())
         module.addDeserializer(LocalDateTime::class.java, LocalDateTimeDeserializer())
         module.addDeserializer(LocalDate::class.java, LocalDateDeserializer())
         module.addDeserializer(LocalTime::class.java, LocalTimeDeserializer())
         module.addDeserializer(OffsetDateTime::class.java, OffsetDateTimeDeserializer())
         module.addDeserializer(OffsetTime::class.java, OffsetTimeDeserializer())
+        module.addDeserializer(BigDecimal::class.java, BigDecimalDeserializer())
         this.registerModule(module)
     }
     var counter: Int = 0
@@ -108,8 +111,12 @@ actual open class KVServiceManager<T : Any> actual constructor(val serviceClass:
                         )
                     } catch (e: Exception) {
                         if (!(e is ServiceException)) LOG.error(e.message, e)
-                        res.send(JsonRpcResponse(id = jsonRpcRequest.id, error = e.message ?: "Error",
-                                exceptionType = e.javaClass.canonicalName))
+                        res.send(
+                            JsonRpcResponse(
+                                id = jsonRpcRequest.id, error = e.message ?: "Error",
+                                exceptionType = e.javaClass.canonicalName
+                            )
+                        )
                     }
                 }
             }.invoke(this)
@@ -148,8 +155,12 @@ actual open class KVServiceManager<T : Any> actual constructor(val serviceClass:
                             )
                         } catch (e: Exception) {
                             if (!(e is ServiceException)) LOG.error(e.message, e)
-                            res.send(JsonRpcResponse(id = jsonRpcRequest.id, error = e.message ?: "Error",
-                                exceptionType = e.javaClass.canonicalName))
+                            res.send(
+                                JsonRpcResponse(
+                                    id = jsonRpcRequest.id, error = e.message ?: "Error",
+                                    exceptionType = e.javaClass.canonicalName
+                                )
+                            )
                         }
                     }
                 } else {
@@ -192,8 +203,12 @@ actual open class KVServiceManager<T : Any> actual constructor(val serviceClass:
                             )
                         } catch (e: Exception) {
                             if (!(e is ServiceException)) LOG.error(e.message, e)
-                            res.send(JsonRpcResponse(id = jsonRpcRequest.id, error = e.message ?: "Error",
-                                exceptionType = e.javaClass.canonicalName))
+                            res.send(
+                                JsonRpcResponse(
+                                    id = jsonRpcRequest.id, error = e.message ?: "Error",
+                                    exceptionType = e.javaClass.canonicalName
+                                )
+                            )
                         }
                     }
                 } else {
@@ -238,8 +253,12 @@ actual open class KVServiceManager<T : Any> actual constructor(val serviceClass:
                             )
                         } catch (e: Exception) {
                             if (!(e is ServiceException)) LOG.error(e.message, e)
-                            res.send(JsonRpcResponse(id = jsonRpcRequest.id, error = e.message ?: "Error",
-                                exceptionType = e.javaClass.canonicalName))
+                            res.send(
+                                JsonRpcResponse(
+                                    id = jsonRpcRequest.id, error = e.message ?: "Error",
+                                    exceptionType = e.javaClass.canonicalName
+                                )
+                            )
                         }
                     }
                 } else {
@@ -285,8 +304,12 @@ actual open class KVServiceManager<T : Any> actual constructor(val serviceClass:
                             )
                         } catch (e: Exception) {
                             if (!(e is ServiceException)) LOG.error(e.message, e)
-                            res.send(JsonRpcResponse(id = jsonRpcRequest.id, error = e.message ?: "Error",
-                                exceptionType = e.javaClass.canonicalName))
+                            res.send(
+                                JsonRpcResponse(
+                                    id = jsonRpcRequest.id, error = e.message ?: "Error",
+                                    exceptionType = e.javaClass.canonicalName
+                                )
+                            )
                         }
                     }
                 } else {
@@ -334,8 +357,12 @@ actual open class KVServiceManager<T : Any> actual constructor(val serviceClass:
                             )
                         } catch (e: Exception) {
                             if (!(e is ServiceException)) LOG.error(e.message, e)
-                            res.send(JsonRpcResponse(id = jsonRpcRequest.id, error = e.message ?: "Error",
-                                exceptionType = e.javaClass.canonicalName))
+                            res.send(
+                                JsonRpcResponse(
+                                    id = jsonRpcRequest.id, error = e.message ?: "Error",
+                                    exceptionType = e.javaClass.canonicalName
+                                )
+                            )
                         }
                     }
                 } else {
@@ -448,8 +475,12 @@ actual open class KVServiceManager<T : Any> actual constructor(val serviceClass:
                             )
                         } catch (e: Exception) {
                             if (!(e is ServiceException)) LOG.error(e.message, e)
-                            res.send(JsonRpcResponse(id = jsonRpcRequest.id, error = e.message ?: "Error",
-                                exceptionType = e.javaClass.canonicalName))
+                            res.send(
+                                JsonRpcResponse(
+                                    id = jsonRpcRequest.id, error = e.message ?: "Error",
+                                    exceptionType = e.javaClass.canonicalName
+                                )
+                            )
                         }
                     }
                 } else {
@@ -493,8 +524,12 @@ actual open class KVServiceManager<T : Any> actual constructor(val serviceClass:
                             )
                         } catch (e: Exception) {
                             if (!(e is ServiceException)) LOG.error(e.message, e)
-                            res.send(JsonRpcResponse(id = jsonRpcRequest.id, error = e.message ?: "Error",
-                                exceptionType = e.javaClass.canonicalName))
+                            res.send(
+                                JsonRpcResponse(
+                                    id = jsonRpcRequest.id, error = e.message ?: "Error",
+                                    exceptionType = e.javaClass.canonicalName
+                                )
+                            )
                         }
                     }
                 } else {
diff --git a/kvision-modules/kvision-server-jooby/src/main/kotlin/pl/treksoft/kvision/types/Decimal.kt b/kvision-modules/kvision-server-jooby/src/main/kotlin/pl/treksoft/kvision/types/Decimal.kt
new file mode 100644
index 00000000..1d37ae51
--- /dev/null
+++ b/kvision-modules/kvision-server-jooby/src/main/kotlin/pl/treksoft/kvision/types/Decimal.kt
@@ -0,0 +1,47 @@
+/*
+ * Copyright (c) 2017-present Robert Jaros
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy
+ * of this software and associated documentation files (the "Software"), to deal
+ * in the Software without restriction, including without limitation the rights
+ * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+ * copies of the Software, and to permit persons to whom the Software is
+ * furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+ * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+ * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+ * SOFTWARE.
+ */
+package pl.treksoft.kvision.types
+
+import com.fasterxml.jackson.core.JsonGenerator
+import com.fasterxml.jackson.core.JsonParser
+import com.fasterxml.jackson.databind.DeserializationContext
+import com.fasterxml.jackson.databind.JsonDeserializer
+import com.fasterxml.jackson.databind.JsonSerializer
+import com.fasterxml.jackson.databind.SerializerProvider
+import java.io.IOException
+import java.math.BigDecimal
+
+actual typealias Decimal = BigDecimal
+
+class BigDecimalSerializer : JsonSerializer<BigDecimal>() {
+    @Throws(IOException::class)
+    override fun serialize(value: BigDecimal, gen: JsonGenerator, provider: SerializerProvider) {
+        gen.writeNumber(value.toDouble())
+    }
+}
+
+class BigDecimalDeserializer : JsonDeserializer<BigDecimal>() {
+    @Throws(IOException::class)
+    override fun deserialize(p: JsonParser, ctx: DeserializationContext): BigDecimal? {
+        return p.doubleValue.toBigDecimal()
+    }
+}