Poc

.gitignore

@@ -1,2 +1,15 @@
 *.class
 *.log
+
+.bsp/
+.idea/
+
+dist/*
+target/
+lib_managed/
+src_managed/
+project/boot/
+project/plugins/project/
+.history
+.cache
+.lib/

build.sbt

@@ -0,0 +1,14 @@
+import Dependencies._
+
+ThisBuild / scalaVersion     := "2.12.13"
+ThisBuild / version          := "0.1.0-SNAPSHOT"
+ThisBuild / organization     := "com.example"
+ThisBuild / organizationName := "example"
+
+lazy val root = (project in file("."))
+  .settings(
+    name := "akka-safer-serializer",
+    libraryDependencies ++= deps
+  )
+
+// See https://www.scala-sbt.org/1.x/docs/Using-Sonatype.html for instructions on how to publish to Sonatype.

project/Dependencies.scala

@@ -0,0 +1,21 @@
+import sbt._
+
+object Dependencies {
+  val borerVersion = "1.6.3"
+  val akkaVersion = "2.6.10"
+
+  val scalaTest = "org.scalatest" %% "scalatest" % "3.2.2"
+  val akkaTyped = "com.typesafe.akka" %% "akka-actor-typed" % akkaVersion
+  val akkaTestKit = "com.typesafe.akka" %% "akka-actor-testkit-typed" % akkaVersion
+  val enumeratum = "com.beachape" %% "enumeratum" % "1.6.1"
+  val borerCore = "io.bullet" %% "borer-core" % borerVersion
+  val borerDerivation = "io.bullet" %% "borer-derivation" % borerVersion
+
+  val deps = Seq(
+    scalaTest % Test,
+    akkaTestKit % Test,
+    akkaTyped,
+    enumeratum,
+    borerCore,
+    borerDerivation)
+}

project/build.properties

@@ -0,0 +1 @@
+sbt.version=1.4.9

src/main/scala/example/CborAkkaSerializer.scala

@@ -0,0 +1,40 @@
+package example
+
+import akka.serialization.Serializer
+import io.bullet.borer.{Cbor, Codec, Decoder, Encoder}
+
+import scala.reflect.ClassTag
+
+
+trait CborAkkaSerializer[Ser] extends Serializer {
+
+  private var registrations: List[(Class[_], Codec[_])] = Nil
+
+  protected def register[T <: Ser: Encoder: Decoder: ClassTag]: Unit = {
+    registrations ::= scala.reflect.classTag[T].runtimeClass -> Codec.of[T]
+  }
+
+  override def includeManifest: Boolean = true
+
+  override def toBinary(o: AnyRef): Array[Byte] = {
+    val codec   = getCodec(o.getClass, "encoding")
+    val encoder = codec.encoder.asInstanceOf[Encoder[AnyRef]]
+    Cbor.encode(o)(encoder).toByteArray
+  }
+
+  override def fromBinary(bytes: Array[Byte], manifest: Option[Class[_]]): AnyRef = {
+    val codec   = getCodec(manifest.get, "decoding")
+    val decoder = codec.decoder.asInstanceOf[Decoder[AnyRef]]
+    Cbor.decode(bytes).to[AnyRef](decoder).value
+  }
+
+  private def getCodec(classValue: Class[_], action: String): Codec[_] = {
+    registrations
+      .collectFirst {
+        case (clazz, codec) if clazz.isAssignableFrom(classValue) => codec
+      }
+      .getOrElse {
+        throw new RuntimeException(s"$action of $classValue is not configured")
+      }
+  }
+}

src/test/resources/application.conf

@@ -0,0 +1,10 @@
+akka.actor {
+  serializers {
+    borer-cbor = "example.BorerAkkaSerializer"
+  }
+  serialization-bindings {
+    "example.BorerSerializable" = borer-cbor
+  }
+  enable-additional-serialization-bindings = on
+  allow-java-serialization = off
+}

src/test/scala/example/Codecs.scala

@@ -0,0 +1,10 @@
+package example
+
+import io.bullet.borer.Codec
+import io.bullet.borer.derivation.MapBasedCodecs.deriveAllCodecs
+
+trait Codecs {
+  implicit lazy val animalCodec: Codec[Animal] = deriveAllCodecs
+  implicit lazy val greetingCodec: Codec[Greeting] = deriveAllCodecs
+  implicit lazy val zooCodec: Codec[Zoo] = deriveAllCodecs
+}

src/test/scala/example/Data.scala

@@ -0,0 +1,54 @@
+package example
+
+trait BorerSerializable
+
+sealed abstract class Animal extends BorerSerializable
+
+sealed trait Zoo extends BorerSerializable {
+  def primaryAttraction: Animal
+}
+
+
+object Zoo {
+
+  final case class NorthZoo(primaryAttraction: Animal) extends Zoo
+
+  final case class SouthZoo(primaryAttraction: Animal) extends Zoo
+
+  final case class GreetingZoo(primaryAttraction: Animal, greeting: Greeting) extends Zoo
+
+}
+
+object Animal {
+
+  final case class Lion(name: String) extends Animal
+
+  final case class Elephant(name: String, age: Int) extends Animal
+
+  final case object Tiger extends Animal
+
+  trait NoCompile
+
+//  Uncommenting this results in failure in compilation
+//  final case class InvalidAnimal(noCompile: NoCompile) extends Animal
+
+}
+
+import enumeratum._
+
+import scala.collection.immutable.IndexedSeq
+
+sealed trait Greeting extends EnumEntry
+
+object Greeting extends Enum[Greeting] {
+  val values: IndexedSeq[Greeting] = findValues
+
+  case object Hello extends Greeting
+
+  case object GoodBye extends Greeting
+
+  case object Hi extends Greeting
+
+  case object Bye extends Greeting
+
+}

src/test/scala/example/TestBorerAkkaSerializer.scala

@@ -0,0 +1,9 @@
+package example
+
+class TestBorerAkkaSerializer extends CborAkkaSerializer[BorerSerializable] with Codecs {
+
+  override def identifier: Int = 19923
+
+  register[Zoo]
+  register[Animal]
+}

src/test/scala/example/TestBorerAkkaSerializerSpec.scala

@@ -0,0 +1,37 @@
+package example
+
+import akka.actor.testkit.typed.scaladsl.{ActorTestKit, SerializationTestKit}
+import akka.actor.typed.ActorSystem
+import com.typesafe.config.ConfigFactory
+import example.Animal.{Lion, Tiger}
+import example.Zoo.{GreetingZoo, NorthZoo}
+import org.scalatest.matchers.should.Matchers
+import org.scalatest.wordspec.AnyWordSpecLike
+
+class TestBorerAkkaSerializerSpec extends AnyWordSpecLike with Matchers {
+
+  "BorerAkkaSerializer" should {
+
+    val config = ConfigFactory.load("application.conf").withFallback(ConfigFactory.load())
+    val testKit: ActorTestKit = ActorTestKit(config)
+    val system: ActorSystem[Nothing] = testKit.system
+    val serializationTestKit = new SerializationTestKit(system)
+
+    "serialize singleton" in {
+      serializationTestKit.verifySerialization(Tiger)
+    }
+
+    "serialize final case class" in {
+      serializationTestKit.verifySerialization(Lion("lion"))
+    }
+
+    "serialize nested case class" in {
+      serializationTestKit.verifySerialization(NorthZoo(Lion("lion")))
+    }
+
+    "serialize case class with enumeration" in {
+      serializationTestKit.verifySerialization(GreetingZoo(Lion("lion"), Greeting.Hello))
+    }
+  }
+
+}