working example based on avro-kotlin-serialization snapshot

lib/fixtures/pom.xml

@@ -18,8 +18,8 @@
 
   <dependencies>
     <dependency>
-      <groupId>io.toolisticon.lib</groupId>
-      <artifactId>avro-kotlin</artifactId>
+      <groupId>io.toolisticon.kotlin.avro</groupId>
+      <artifactId>avro-kotlin-serialization</artifactId>
       <scope>provided</scope>
     </dependency>
     <dependency>
@@ -66,10 +66,6 @@
       <artifactId>jackson-avro-module</artifactId>
       <version>${jackson-avro-module.version}</version>
     </dependency>
-    <dependency>
-      <groupId>com.github.avro-kotlin.avro4k</groupId>
-      <artifactId>avro4k-core</artifactId>
-    </dependency>
 
     <dependency>
       <groupId>${project.groupId}</groupId>

lib/fixtures/src/main/kotlin/bankaccount/command/CreateBankAccount.kt

@@ -1,13 +1,13 @@
 package bankaccount.command
 
-import bankaccount.conversions.MoneySerializer
+import bankaccount.conversions.MoneyLogicalType
 import kotlinx.serialization.Serializable
 import org.javamoney.moneta.Money
 
 @Serializable
 data class CreateBankAccount(
   val accountId: String,
-  @Serializable(with = MoneySerializer::class)
+  @Serializable(with = MoneyLogicalType.MoneySerializer::class)
   val initialBalance: Money
 ) {
 }

lib/fixtures/src/main/kotlin/bankaccount/command/DepositMoney.kt

@@ -1,6 +1,6 @@
 package bankaccount.command
 
-import bankaccount.conversions.MoneySerializer
+import bankaccount.conversions.MoneyLogicalType
 import kotlinx.serialization.Serializable
 import org.axonframework.modelling.command.TargetAggregateIdentifier
 import org.javamoney.moneta.Money
@@ -9,6 +9,6 @@ import org.javamoney.moneta.Money
 data class DepositMoney(
   @TargetAggregateIdentifier
   val accountId: String,
-  @Serializable(with = MoneySerializer::class)
+  @Serializable(with = MoneyLogicalType.MoneySerializer::class)
   val amount: Money
 )

lib/fixtures/src/main/kotlin/bankaccount/command/WithdrawMoney.kt

@@ -1,6 +1,6 @@
 package bankaccount.command
 
-import bankaccount.conversions.MoneySerializer
+import bankaccount.conversions.MoneyLogicalType
 import kotlinx.serialization.Serializable
 import org.axonframework.modelling.command.TargetAggregateIdentifier
 import org.javamoney.moneta.Money
@@ -9,6 +9,6 @@ import org.javamoney.moneta.Money
 data class WithdrawMoney(
   @TargetAggregateIdentifier
   val accountId: String,
-  @Serializable(with = MoneySerializer::class)
+  @Serializable(with = MoneyLogicalType.MoneySerializer::class)
   val amount: Money
 )

lib/fixtures/src/main/kotlin/bankaccount/event/BankAccountAuditEvent.kt

@@ -1,6 +1,6 @@
 package bankaccount.event
 
-import bankaccount.conversions.MoneySerializer
+import bankaccount.conversions.MoneyLogicalType
 import com.github.avrokotlin.avro4k.serializer.InstantSerializer
 import kotlinx.serialization.Serializable
 import org.javamoney.moneta.Money
@@ -12,7 +12,7 @@ data class BankAccountAuditEvent(
   @Serializable(with = InstantSerializer::class)
   val timestamp: Instant,
   val accountId: String,
-  @Serializable(with = MoneySerializer::class)
+  @Serializable(with = MoneyLogicalType.MoneySerializer::class)
   val amount: Money,
   val traceId: String,
   val correlationId: String

lib/fixtures/src/main/kotlin/bankaccount/query/CurrentBalance.kt

@@ -1,6 +1,6 @@
 package bankaccount.query
 
-import bankaccount.conversions.MoneySerializer
+import bankaccount.conversions.MoneyLogicalType.MoneySerializer
 import kotlinx.serialization.Serializable
 import org.javamoney.moneta.Money
 

lib/logical-types/pom.xml

@@ -15,14 +15,10 @@
 
   <dependencies>
     <dependency>
-      <groupId>io.toolisticon.lib</groupId>
-      <artifactId>avro-kotlin</artifactId>
+      <groupId>io.toolisticon.kotlin.avro</groupId>
+      <artifactId>avro-kotlin-serialization</artifactId>
     </dependency>
 
-    <dependency>
-      <groupId>com.github.avro-kotlin.avro4k</groupId>
-      <artifactId>avro4k-core</artifactId>
-    </dependency>
 
     <dependency>
       <groupId>org.javamoney.moneta</groupId>

lib/logical-types/src/main/kotlin/bankaccount/conversions/MoneyLogicalType.kt

@@ -0,0 +1,51 @@
+package bankaccount.conversions
+
+import io.toolisticon.avro.kotlin.logical.StringLogicalType
+import io.toolisticon.avro.kotlin.logical.StringLogicalTypeFactory
+import io.toolisticon.avro.kotlin.logical.conversion.StringLogicalTypeConversion
+import io.toolisticon.avro.kotlin.logical.conversion.TypeConverter
+import io.toolisticon.avro.kotlin.value.LogicalTypeName.Companion.toLogicalTypeName
+import io.toolisticon.kotlin.avro.serialization.serializer.StringLogicalTypeSerializer
+import io.toolisticon.kotlin.avro.serialization.spi.AvroSerializerModuleFactory
+import kotlinx.serialization.modules.SerializersModule
+import org.javamoney.moneta.Money
+import java.util.*
+import javax.money.format.AmountFormatQuery
+import javax.money.format.MonetaryFormats
+
+
+object MoneyLogicalType : StringLogicalType("money".toLogicalTypeName()) {
+
+  val convertedType = Money::class
+  val conversion = MoneyConversion()
+
+  val converter = object : TypeConverter<String, Money> {
+    private val format = MonetaryFormats.getAmountFormat(AmountFormatQuery.of(Locale.GERMAN))
+
+    override fun fromAvro(value: String): Money {
+      return Money.from(format.parse(value))
+    }
+
+    override fun toAvro(value: Money): String {
+      return format.format(value)
+    }
+  }
+
+  class MoneyLogicalTypeFactory : StringLogicalTypeFactory<MoneyLogicalType>(logicalType = MoneyLogicalType)
+
+  class MoneyConversion : StringLogicalTypeConversion<MoneyLogicalType, Money>(
+    logicalType = MoneyLogicalType,
+    convertedType = convertedType
+  ) {
+    override fun fromAvro(value: String): Money = converter.fromAvro(value)
+    override fun toAvro(value: Money): String = converter.toAvro(value)
+  }
+
+  class MoneySerializer : StringLogicalTypeSerializer<MoneyLogicalType, Money>(conversion)
+
+  class MoneySerializerModuleFactory : AvroSerializerModuleFactory {
+    override fun invoke(): SerializersModule = SerializersModule {
+      contextual(convertedType, MoneySerializer())
+    }
+  }
+}