prepare release v0.7.0

Author: fupelaqu

build.sbt

@@ -2,7 +2,7 @@ ThisBuild / organization := "app.softnetwork"
 
 name := "resource"
 
-ThisBuild / version := "0.6.0"
+ThisBuild / version := "0.7.0"
 
 ThisBuild / scalaVersion := "2.12.18"
 

common/src/main/protobuf/message/resource.proto

@@ -13,6 +13,7 @@ option (scalapb.options) = {
     import: "app.softnetwork.serialization._"
     import: "app.softnetwork.resource.model._"
     preamble: "trait ResourceEvent extends CrudEvent"
+    preamble: "trait SessionResourceEvent extends ResourceEvent{ def uuid: String; def sessionId: String }"
     preserve_unknown_fields: false
 };
 
@@ -23,18 +24,39 @@ message ResourceCreatedEvent {
     required app.softnetwork.resource.model.Resource document = 1;
 }
 
+message SessionResourceCreatedEvent {
+    option (scalapb.message).extends = "ProtobufEvent";
+    option (scalapb.message).extends = "SessionResourceEvent";
+    required string uuid = 1;
+    required string sessionId = 2;
+    optional string uri = 3;
+}
+
 message ResourceUpdatedEvent {
     option (scalapb.message).extends = "ProtobufEvent";
     option (scalapb.message).extends = "Updated[Resource]";
     option (scalapb.message).extends = "ResourceEvent";
     required app.softnetwork.resource.model.Resource document = 1;
 }
 
+message SessionResourceUpdatedEvent {
+    option (scalapb.message).extends = "ProtobufEvent";
+    option (scalapb.message).extends = "SessionResourceEvent";
+    required string uuid = 1;
+    required string sessionId = 2;
+    optional string uri = 3;
+}
+
 message ResourceDeletedEvent {
     option (scalapb.message).extends = "ProtobufEvent";
     option (scalapb.message).extends = "Deleted";
     option (scalapb.message).extends = "ResourceEvent";
     required string uuid = 1;
 }
 
-
+message SessionResourceDeletedEvent {
+    option (scalapb.message).extends = "ProtobufEvent";
+    option (scalapb.message).extends = "SessionResourceEvent";
+    required string uuid = 1;
+    required string sessionId = 2;
+}

core/src/main/scala/app/softnetwork/resource/persistence/typed/ResourceBehavior.scala

@@ -42,12 +42,20 @@ sealed trait ResourceBehavior
     */
   override protected def tagEvent(entityId: String, event: ResourceEvent): Set[String] = {
     event match {
+      case _: SessionResourceEvent =>
+        Set(
+          s"${persistenceId.toLowerCase}-to-session"
+        )
       case _ =>
         Set(
           persistenceId,
           s"${persistenceId.toLowerCase}-to-localfilesystem",
           s"${persistenceId.toLowerCase}-to-s3",
-          s"${persistenceId.toLowerCase}-to-gcs"
+          s"${persistenceId.toLowerCase}-to-gcs",
+          s"${persistenceId.toLowerCase}-to-azure",
+          s"${persistenceId.toLowerCase}-to-minio",
+          s"${persistenceId.toLowerCase}-to-db", // database storage (Cassandra, Postgres, MySQL...)
+          s"${persistenceId.toLowerCase}-to-redis" // redis storage
         )
     }
   }
@@ -77,13 +85,20 @@ sealed trait ResourceBehavior
       case cmd: CreateResource =>
         import cmd._
         val createdDate = Instant.now()
+        val sessionId = if (uuid.contains('#')) uuid.split('#').headOption else None
+        val sessionEvent = sessionId.map(sid =>
+          SessionResourceCreatedEvent.defaultInstance
+            .withUuid(uuid)
+            .withSessionId(sid)
+            .copy(uri = uri)
+        )
         Effect
           .persist(
             ResourceCreatedEvent(
               asResource(uuid, bytes, uri)
                 .withCreatedDate(createdDate)
                 .withLastUpdated(createdDate)
-            )
+            ) +: sessionEvent.toList
           )
           .thenRun(_ => { ResourceCreated ~> replyTo })
 
@@ -96,13 +111,20 @@ sealed trait ResourceBehavior
             case None           => Instant.now()
           }
         }
+        val sessionId = if (uuid.contains('#')) uuid.split('#').headOption else None
+        val sessionEvent = sessionId.map(sid =>
+          SessionResourceUpdatedEvent.defaultInstance
+            .withUuid(uuid)
+            .withSessionId(sid)
+            .copy(uri = uri)
+        )
         Effect
           .persist(
             ResourceUpdatedEvent(
               asResource(uuid, bytes, uri)
                 .withCreatedDate(createdDate)
                 .withLastUpdated(lastUpdated)
-            )
+            ) +: sessionEvent.toList
           )
           .thenRun(_ => { ResourceUpdated ~> replyTo })
 
@@ -120,11 +142,15 @@ sealed trait ResourceBehavior
                 case Some(uri) => s"$uri/$entityId"
                 case _         => entityId
               }
+            val sessionId = if (uuid.contains('#')) uuid.split('#').headOption else None
+            val sessionEvent = sessionId.map(sid =>
+              SessionResourceDeletedEvent.defaultInstance.withUuid(uuid).withSessionId(sid)
+            )
             Effect
               .persist[ResourceEvent, Option[Resource]](
                 ResourceDeletedEvent(
                   uuid
-                )
+                ) +: sessionEvent.toList
               )
               .thenRun(_ => {
                 ResourceDeleted ~> replyTo

project/Versions.scala

@@ -1,6 +1,6 @@
 object Versions {
 
-  val genericPersistence = "0.7.1"
+  val genericPersistence = "0.7.3"
 
   val scalatest = "3.2.16"
 }