upgrade persistence dependencies

Author: fupelaqu

api/src/main/scala/app/softnetwork/notification/api/AllNotificationsApi.scala

@@ -13,10 +13,11 @@ import app.softnetwork.notification.persistence.typed.{
   NotificationBehavior
 }
 import app.softnetwork.persistence.jdbc.query.{JdbcJournalProvider, JdbcOffsetProvider}
+import app.softnetwork.persistence.jdbc.schema.JdbcSchemaProvider
 import app.softnetwork.scheduler.config.SchedulerSettings
 import com.typesafe.config.Config
 
-trait AllNotificationsApi extends NotificationApplication[Notification] {
+trait AllNotificationsApi extends NotificationApplication[Notification] with JdbcSchemaProvider {
 
   override def notificationBehaviors: ActorSystem[_] => Seq[NotificationBehavior[Notification]] =
     _ => Seq(AllNotificationsBehavior)

api/src/main/scala/app/softnetwork/notification/api/AllNotificationsPostgresLauncher.scala

@@ -1,19 +1,12 @@
 package app.softnetwork.notification.api
 
-import akka.actor.{typed, ActorSystem}
-import app.softnetwork.persistence.jdbc.schema.PostgresSchemaProvider
-import app.softnetwork.persistence.schema.SchemaProvider
-import app.softnetwork.persistence.typed._
-import com.typesafe.config.Config
+import app.softnetwork.persistence.jdbc.schema.JdbcSchemaTypes
+import app.softnetwork.persistence.schema.SchemaType
 import org.slf4j.{Logger, LoggerFactory}
 
 object AllNotificationsPostgresLauncher extends AllNotificationsApi {
 
   lazy val log: Logger = LoggerFactory getLogger getClass.getName
 
-  override def schemaProvider: typed.ActorSystem[_] => SchemaProvider = sys =>
-    new PostgresSchemaProvider {
-      override implicit def classicSystem: ActorSystem = sys
-      override def config: Config = AllNotificationsPostgresLauncher.this.config
-    }
+  override val schemaType: SchemaType = JdbcSchemaTypes.Postgres
 }

api/src/main/scala/app/softnetwork/notification/api/AllNotificationsWithSchedulerPostgresLauncher.scala

@@ -1,19 +1,12 @@
 package app.softnetwork.notification.api
 
-import akka.actor.{typed, ActorSystem}
-import app.softnetwork.persistence.jdbc.schema.PostgresSchemaProvider
-import app.softnetwork.persistence.schema.SchemaProvider
-import app.softnetwork.persistence.typed._
-import com.typesafe.config.Config
+import app.softnetwork.persistence.jdbc.schema.JdbcSchemaTypes
+import app.softnetwork.persistence.schema.SchemaType
 import org.slf4j.{Logger, LoggerFactory}
 
 object AllNotificationsWithSchedulerPostgresLauncher extends AllNotificationsWithSchedulerApi {
 
   lazy val log: Logger = LoggerFactory getLogger getClass.getName
 
-  override def schemaProvider: typed.ActorSystem[_] => SchemaProvider = sys =>
-    new PostgresSchemaProvider {
-      override implicit def classicSystem: ActorSystem = sys
-      override def config: Config = AllNotificationsWithSchedulerPostgresLauncher.this.config
-    }
+  override val schemaType: SchemaType = JdbcSchemaTypes.Postgres
 }

build.sbt

@@ -31,7 +31,7 @@ ThisBuild / organization := "app.softnetwork"
 
 name := "notification"
 
-ThisBuild / version := "0.3.0"
+ThisBuild / version := "0.3.0.1"
 
 ThisBuild / scalaVersion := "2.12.15"
 

core/src/main/scala/app/softnetwork/notification/launch/NotificationApplication.scala

@@ -5,12 +5,13 @@ import akka.http.scaladsl.model.{HttpRequest, HttpResponse}
 import app.softnetwork.api.server.launch.HealthCheckApplication
 import app.softnetwork.notification.api.NotificationServiceApiHandler
 import app.softnetwork.notification.model.Notification
+import app.softnetwork.persistence.schema.SchemaProvider
 
 import scala.concurrent.Future
 
 trait NotificationApplication[T <: Notification]
     extends HealthCheckApplication
-    with NotificationGuardian[T] {
+    with NotificationGuardian[T] { _: SchemaProvider =>
   override def grpcServices
     : ActorSystem[_] => Seq[PartialFunction[HttpRequest, Future[HttpResponse]]] = system =>
     notificationServers(system).map(

core/src/main/scala/app/softnetwork/notification/launch/NotificationGuardian.scala

@@ -10,11 +10,13 @@ import app.softnetwork.notification.persistence.query.{
 import app.softnetwork.notification.persistence.typed.NotificationBehavior
 import app.softnetwork.persistence.launch.{PersistenceGuardian, PersistentEntity}
 import app.softnetwork.persistence.query.EventProcessorStream
+import app.softnetwork.persistence.schema.SchemaProvider
 import com.typesafe.scalalogging.StrictLogging
 
 import scala.language.implicitConversions
 
 trait NotificationGuardian[T <: Notification] extends PersistenceGuardian with StrictLogging {
+  _: SchemaProvider =>
 
   import app.softnetwork.persistence.launch.PersistenceGuardian._
 

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

@@ -2,11 +2,11 @@ package app.softnetwork.sbt.build
 
 object Versions {
 
-  val genericPersistence = "0.3.0.2"
+  val genericPersistence = "0.3.0.3"
 
-  val scheduler = "0.3.0"
+  val scheduler = "0.3.0.1"
 
-  val server = "0.3.0.2"
+  val server = "0.3.0.3"
 
   val scalatest = "3.1.1"
 }