upgrade dependencies to akka http json4s, akka http session, jackson, json4s - add dependencies to tapir - implement akka http session with tapir endpoints

Author: fupelaqu

build.sbt

@@ -30,11 +30,11 @@ ThisBuild / organization := "app.softnetwork"
 
 name := "generic-persistence-api"
 
-ThisBuild / version := "0.3.0.3"
+ThisBuild / version := "0.3.1"
 
 ThisBuild / scalaVersion := "2.12.11"
 
-ThisBuild / scalacOptions ++= Seq("-deprecation", "-feature", "-target:jvm-1.8")
+ThisBuild / scalacOptions ++= Seq("-deprecation", "-feature", "-target:jvm-1.8", "-Ypartial-unification")
 
 ThisBuild / javacOptions ++= Seq("-source", "1.8", "-target", "1.8")
 

core/src/main/scala/app/softnetwork/persistence/package.scala

@@ -43,4 +43,5 @@ package object persistence {
 
   val version: String = sys.env.getOrElse("VERSION", BuildInfo.version)
 
+  val appName: String = sys.env.getOrElse("APP", BuildInfo.name)
 }

core/testkit/src/main/scala/app/softnetwork/persistence/person/PersonTestKit.scala

@@ -52,7 +52,7 @@ trait PersonTestKit extends PersonHandler with AnyWordSpecLike with PersistenceT
       val probe: TestProbe[PersonEvent] = createTestProbe[PersonEvent]()
       subscribeProbe(probe)
       ?(uuid, AddPerson("name", birthday)) await {
-        case PersonAdded =>
+        case _: PersonAdded =>
           assert(loadPerson(uuid).map(_.name).getOrElse("") == "name")
           probe.receiveMessage() match {
             case _: PersonCreatedEvent =>

core/testkit/src/main/scala/app/softnetwork/persistence/person/message/package.scala

@@ -24,7 +24,7 @@ package object message {
   case object DeletePerson extends PersonCommand
 
   sealed trait PersonCommandResult extends CommandResult
-  case object PersonAdded extends PersonCommandResult
+  case class PersonAdded(uuid: String) extends PersonCommandResult
   case object PersonUpdated extends PersonCommandResult
   case object NameUpdated extends PersonCommandResult
   case object PersonDeleted extends PersonCommandResult

core/testkit/src/main/scala/app/softnetwork/persistence/person/typed/PersonBehavior.scala

@@ -74,7 +74,7 @@ trait PersonBehavior
         import cmd._
         Effect
           .persist(PersonCreatedEvent(Person(entityId, name, birthDate)))
-          .thenRun(_ => PersonAdded ~> replyTo)
+          .thenRun(_ => PersonAdded(entityId) ~> replyTo)
       case LoadPerson =>
         state match {
           case Some(person) => Effect.none.thenRun(_ => PersonLoaded(person) ~> replyTo)

core/testkit/src/main/scala/app/softnetwork/persistence/scalatest/PersistenceTestKit.scala

@@ -18,7 +18,7 @@ import org.scalatest.time.Span
 import org.scalatest.{BeforeAndAfterAll, Suite}
 import org.slf4j.Logger
 
-import java.net.{InetAddress, ServerSocket}
+import java.net.ServerSocket
 import scala.language.implicitConversions
 import scala.reflect.ClassTag
 
@@ -39,7 +39,7 @@ trait PersistenceTestKit
 
   lazy val systemName: String = generateUUID()
 
-  def hostname: String = InetAddress.getLocalHost.getHostAddress
+  def hostname: String = "127.0.0.1"
 
   def dynamicPort: Int = {
     val socket = new ServerSocket(0)
@@ -95,7 +95,8 @@ trait PersistenceTestKit
                 |
                 |akka.management {
                 |  http {
-                |    port = $managementPort
+                |    hostname = $hostname
+                |    port     = $managementPort
                 |  }
                 |  cluster.bootstrap {
                 |    contact-point-discovery {
@@ -104,6 +105,7 @@ trait PersistenceTestKit
                 |  }
                 |}
                 |
+                |akka.remote.artery.canonical.hostname = $hostname
                 |akka.remote.artery.canonical.port = 0
                 |
                 |akka.coordinated-shutdown.exit-jvm = off

jdbc/build.sbt

@@ -8,7 +8,7 @@ organization := "app.softnetwork.persistence"
 name := "persistence-jdbc"
 
 val akkaPersistenceJdbc = Seq(
-  "com.lightbend.akka" %% "akka-persistence-jdbc" % Versions.lightbendAkkaPersistenceJdbc,
+  "com.lightbend.akka" %% "akka-persistence-jdbc" % Versions.akkaPersistenceJdbc,
   "com.typesafe.akka" %% "akka-persistence-query" % Versions.akka,
   "com.typesafe.slick" %% "slick" % Versions.slick,
   "com.typesafe.slick" %% "slick-hikaricp" % Versions.slick,

jdbc/src/main/scala/app/softnetwork/persistence/jdbc/schema/JdbcSchemaProvider.scala

@@ -2,16 +2,15 @@ package app.softnetwork.persistence.jdbc.schema
 
 import akka.actor
 import akka.actor.typed.ActorSystem
+import app.softnetwork.persistence.launch.PersistenceGuardian
 import app.softnetwork.persistence.schema.{Schema, SchemaProvider, SchemaType}
 import app.softnetwork.persistence.typed._
 import com.typesafe.config.Config
 
-trait JdbcSchemaProvider extends SchemaProvider {
+trait JdbcSchemaProvider extends SchemaProvider { _: PersistenceGuardian =>
 
   def schemaType: SchemaType
 
-  def config: Config
-
   override def schema: ActorSystem[_] => Schema = sys =>
     new JdbcSchema {
       override def schemaType: SchemaType = JdbcSchemaProvider.this.schemaType

project/plugins.sbt

@@ -8,7 +8,7 @@ addSbtPlugin("com.tapad" % "sbt-docker-compose" % "1.0.34")
 
 addSbtPlugin("com.eed3si9n" % "sbt-buildinfo" % "0.7.0")
 
-addSbtPlugin("net.virtual-void" % "sbt-dependency-graph" % "0.10.0-RC1")
+addDependencyTreePlugin
 
 //addSbtPlugin("com.typesafe.sbt" % "sbt-multi-jvm" % "0.4.0")
 

project/src/main/scala/app/softnetwork/sbt/build/Versions.scala

@@ -6,11 +6,13 @@ object Versions {
 
   val akkaHttp = "10.2.10"
 
-  val akkaHttpJson4s = "1.37.0" //1.37.0 -> 1.39.2
+  val akkaHttpJson4s = "1.39.2" //1.37.0 -> 1.39.2
 
-  val akkaHttpSession = "0.5.11" // 0.5.11 -> 0.7.0
+  val akkaHttpSession = "0.7.0" // 0.5.11 -> 0.7.0
 
-  val akkaPersistenceJdbc = "3.5.2"
+  val tapir = "1.3.0"
+
+  val akkaPersistenceJdbc = "5.0.4"
 
   val akkaManagement = "1.1.4" // 1.1.4 -> 1.2
 
@@ -22,9 +24,9 @@ object Versions {
 
   val kxbmap = "0.4.4"
 
-  val jackson = "2.11.4"
+  val jackson = "2.12.7" // 2.11.4 -> 2.12.7
 
-  val json4s = "3.6.12"
+  val json4s = "4.0.6" // 3.6.12 -> 4.0.6
 
   val scalaLogging = "3.9.2"
 
@@ -46,8 +48,6 @@ object Versions {
 
   val slick = "3.3.3"
 
-  val lightbendAkkaPersistenceJdbc = "5.0.4"
-
   val akkaPersistenceCassandra = "1.0.6"
 
   val testContainers = "1.18.0"