update PersistenceGuardian to initialize schema provider

Author: fupelaqu

.github/workflows/release.yml

@@ -44,8 +44,8 @@ jobs:
         flags: unittests
         fail_ci_if_error: true
         verbose: true
-#    - name: Publish
-#      run: sbt publish
+    - name: Publish
+      run: sbt publish
 
   lint:
     runs-on: ubuntu-latest

build.sbt

@@ -30,7 +30,7 @@ ThisBuild / organization := "app.softnetwork"
 
 name := "generic-persistence-api"
 
-ThisBuild / version := "0.3.0.1"
+ThisBuild / version := "0.3.0.2"
 
 ThisBuild / scalaVersion := "2.12.11"
 

core/src/main/scala/app/softnetwork/persistence/launch/PersistenceGuardian.scala

@@ -23,7 +23,7 @@ import scala.language.implicitConversions
 
 /** Created by smanciot on 15/05/2020.
   */
-trait PersistenceGuardian extends ClusterDomainEventHandler { _: SchemaProvider =>
+trait PersistenceGuardian extends ClusterDomainEventHandler {
 
   def config: Config
 
@@ -50,6 +50,8 @@ trait PersistenceGuardian extends ClusterDomainEventHandler { _: SchemaProvider
 
   def startSystem: ActorSystem[_] => Unit = _ => ()
 
+  def schemaProvider: ActorSystem[_] => SchemaProvider
+
   def banner: String =
     """
       | ____         __ _              _                      _
@@ -62,11 +64,12 @@ trait PersistenceGuardian extends ClusterDomainEventHandler { _: SchemaProvider
 
   def setup(): Behavior[ClusterDomainEvent] = {
     Behaviors.setup[ClusterDomainEvent] { context =>
-      // initialize schema
-      initSchema()
 
       val system = context.system
 
+      // initialize schema
+      schemaProvider(system).initSchema()
+
       val cluster: Cluster = Cluster(system)
 
       context.log.info("Starting up cluster listener...")

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

@@ -9,7 +9,7 @@ import app.softnetwork.persistence.typed.EntityBehavior
 
 package object launch {
 
-  trait ClusterDomainEventHandler { _: SchemaProvider =>
+  trait ClusterDomainEventHandler {
     def handleEvent(event: ClusterDomainEvent)(implicit system: ActorSystem[_]): Unit = ()
   }
 

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

@@ -160,6 +160,8 @@ trait PersistenceTestKit
   implicit val patience: PatienceConfig =
     PatienceConfig(Settings.DefaultTimeout, Span(100, org.scalatest.time.Millis))
 
+  override def schemaProvider: ActorSystem[_] => SchemaProvider = _ => this
+
   override def beforeAll(): Unit = {
     initAndJoinCluster()
   }

docs/diagrams/out/Patterns.svg

@@ -14,7 +14,7 @@ package app.softnetwork {
         abstract class CommandTypeKey <C: Command> <<(T,orchid) trait >> {
             +def TypeKey(implicit c: ClassTag[C]): EntityTypeKey[C]
         }
-        note left of CommandTypeKey::TypeKey
+        note right of CommandTypeKey::TypeKey
             A key that uniquely identifies
             the type of entity in the cluster
         end note
@@ -46,5 +46,11 @@ package app.softnetwork {
             EntityPattern +-- RecipientPattern: <<implicit>>
         }
     }
+    package persistence.service {
+        abstract Service <C: Command, R: CommandResult> <<(T,orchid) trait>>{
+            +def run(entityId: String, command: C): Future[R]
+        }
+        Patterns <|.. Service: <<self>>
+    }
 }
 @enduml