Dynamo/Cass command line configuration [IA-247]

common-types/src/main/scala/com/improving/app/common/config/AppConfig.scala

@@ -0,0 +1,15 @@
+package com.improving.app.common.config
+
+import com.typesafe.config.{Config, ConfigFactory}
+
+class AppConfig(useDyanmo: Boolean = false) {
+  val configFile: String = if (useDyanmo) {
+    "application-dynamo-journal.conf"
+  } else {
+    "application-cass-journal.conf"
+  }
+
+  def loadConfig: Config = ConfigFactory
+    .load(configFile)
+    .withFallback(ConfigFactory.defaultApplication())
+}

common-types/src/main/scala/com/improving/app/common/service/ServiceMain.scala

@@ -4,18 +4,19 @@ import akka.actor.typed.ActorSystem
 import akka.actor.typed.scaladsl.Behaviors
 import akka.http.scaladsl.Http
 import akka.http.scaladsl.model.{HttpRequest, HttpResponse}
-import com.typesafe.config.ConfigFactory
+import com.improving.app.common.config.AppConfig
+import com.typesafe.config.{Config, ConfigFactory}
 import com.typesafe.scalalogging.StrictLogging
 import org.scalatest.time.SpanSugar.convertIntToGrainOfTime
 
 import scala.concurrent.{ExecutionContext, Future}
 import scala.util.{Failure, Success}
 
 /**
- * This trait is extended by the gRPC services. This file represents the typical pattern for a gRPC server
- * and the parts that only vary across projects is the projectName, port, and ServiceHandler/ServiceImpl to use.
+ * This trait is extended by the gRPC services. This file represents the typical pattern for a gRPC server and the parts
+ * that only vary across projects is the projectName, port, and ServiceHandler/ServiceImpl to use.
  */
-trait ServiceMain extends App with StrictLogging{
+trait ServiceMain extends App with StrictLogging {
   // projectName is the name of the service, usually in the format of 'improving-app-SOME-SERVICE'
   protected val projectName: String
 
@@ -30,10 +31,9 @@ trait ServiceMain extends App with StrictLogging{
    */
   protected def run(): Unit = {
 
-    val conf = ConfigFactory
-      .load("application.conf")
-      .withFallback(ConfigFactory.defaultApplication())
-    implicit val system = ActorSystem[Nothing](Behaviors.empty, projectName, conf)
+    val appConfig: AppConfig = new AppConfig(args(0).equals("dynamo"))
+    val conf: Config = appConfig.loadConfig
+    implicit val system: ActorSystem[Nothing] = ActorSystem[Nothing](Behaviors.empty, projectName, conf)
 
     // ActorSystem threads will keep the app alive until `system.terminate()` is called
 
@@ -55,4 +55,4 @@ trait ServiceMain extends App with StrictLogging{
         system.terminate()
     }
   }
-}
+}

event/src/main/resources/application-dynamo-journal.conf

@@ -0,0 +1,27 @@
+// Important: enable HTTP/2 in ActorSystem's config
+akka.http.server.preview.enable-http2 = on
+
+akka.actor.provider = cluster
+
+//FIXME - autocreate only for dev
+akka.actor.serialization-bindings{
+  "com.improving.app.common.serialize.PBMsgSerializable" = proto
+}
+akka.remote.artery.canonical.port = 0
+
+akka.actor.allow-java-serialization = off
+akka.persistence {
+  snapshot-store.plugin = "my-dynamodb-snapshot-store"
+}
+datastax-java-driver.advanced.reconnect-on-init = true
+datastax-java-driver {
+  basic.contact-points = ["10.152.183.5:9042"]
+  basic.load-balancing-policy.local-datacenter = "datacenter1"
+}
+
+my-dynamodb-journal = ${dynamodb-journal}
+my-dynamodb-journal {
+    journal-table =  "event_service"
+    journal-name =  "event_service"
+    endpoint =  "https://dynamodb.us-east-1.amazonaws.com"
+}

member/src/main/resources/application-dynamo-journal.conf

@@ -0,0 +1,27 @@
+// Important: enable HTTP/2 in ActorSystem's config
+akka.http.server.preview.enable-http2 = on
+
+akka.actor.provider = cluster
+
+//FIXME - autocreate only for dev
+akka.actor.serialization-bindings{
+  "com.improving.app.common.serialize.PBMsgSerializable" = proto
+}
+akka.remote.artery.canonical.port = 0
+
+akka.actor.allow-java-serialization = off
+akka.persistence {
+  snapshot-store.plugin = "my-dynamodb-snapshot-store"
+}
+datastax-java-driver.advanced.reconnect-on-init = true
+datastax-java-driver {
+  basic.contact-points = ["10.152.183.5:9042"]
+  basic.load-balancing-policy.local-datacenter = "datacenter1"
+}
+
+my-dynamodb-journal = ${dynamodb-journal}
+my-dynamodb-journal {
+    journal-table =  "member_service"
+    journal-name =  "member_service"
+    endpoint =  "https://dynamodb.us-east-1.amazonaws.com"
+}

organization/src/main/resources/application-dynamo-journal.conf

@@ -0,0 +1,27 @@
+// Important: enable HTTP/2 in ActorSystem's config
+akka.http.server.preview.enable-http2 = on
+
+akka.actor.provider = cluster
+
+//FIXME - autocreate only for dev
+akka.actor.serialization-bindings{
+  "com.improving.app.common.serialize.PBMsgSerializable" = proto
+}
+akka.remote.artery.canonical.port = 0
+
+akka.actor.allow-java-serialization = off
+akka.persistence {
+  snapshot-store.plugin = "my-dynamodb-snapshot-store"
+}
+datastax-java-driver.advanced.reconnect-on-init = true
+datastax-java-driver {
+  basic.contact-points = ["10.152.183.5:9042"]
+  basic.load-balancing-policy.local-datacenter = "datacenter1"
+}
+
+my-dynamodb-journal = ${dynamodb-journal}
+my-dynamodb-journal {
+    journal-table =  "organization_service"
+    journal-name =  "organization_service"
+    endpoint =  "https://dynamodb.us-east-1.amazonaws.com"
+}

product/src/main/resources/application-dynamo-journal.conf

@@ -0,0 +1,27 @@
+// Important: enable HTTP/2 in ActorSystem's config
+akka.http.server.preview.enable-http2 = on
+
+akka.actor.provider = cluster
+
+//FIXME - autocreate only for dev
+akka.actor.serialization-bindings{
+  "com.improving.app.common.serialize.PBMsgSerializable" = proto
+}
+akka.remote.artery.canonical.port = 0
+
+akka.actor.allow-java-serialization = off
+akka.persistence {
+  snapshot-store.plugin = "my-dynamodb-snapshot-store"
+}
+datastax-java-driver.advanced.reconnect-on-init = true
+datastax-java-driver {
+  basic.contact-points = ["10.152.183.5:9042"]
+  basic.load-balancing-policy.local-datacenter = "datacenter1"
+}
+
+my-dynamodb-journal = ${dynamodb-journal}
+my-dynamodb-journal {
+    journal-table =  "product_service"
+    journal-name =  "product_service"
+    endpoint =  "https://dynamodb.us-east-1.amazonaws.com"
+}

project/Dependencies.scala

@@ -25,6 +25,7 @@ object Dependencies {
     val cats = "2.9.0"
     val circe = "0.14.5"
     val gatling = "3.9.5"
+    val dynamoDB = "1.3.0"
   }
 
   import Versions._
@@ -124,4 +125,8 @@ object Dependencies {
     "io.gatling" % "gatling-test-framework" % Versions.gatling % "test",
     "com.github.phisgr" % "gatling-grpc" % "0.16.0" % "test"
   )
+
+  val dynamoDBDependencies: Seq[ModuleID] = Seq(
+    "com.typesafe.akka" %% "akka-persistence-dynamodb" % Versions.dynamoDB
+  )
 }

project/Helpers.scala

@@ -164,7 +164,7 @@ object C {
           "org.wvlet.airframe" %% "airframe-ulid" % V.airframeUlidVersion,
         ) ++ akkaHttpTestingDependencies ++ scalaPbDependencies ++ scalaPbValidationDependencies ++ Seq(
           scalaPbCompilerPlugin
-        ),
+        ) ++ dynamoDBDependencies,
         dockerSettings(port, artifactName),
       )
   }

store/src/main/resources/application-dynamo-journal.conf

@@ -0,0 +1,27 @@
+// Important: enable HTTP/2 in ActorSystem's config
+akka.http.server.preview.enable-http2 = on
+
+akka.actor.provider = cluster
+
+//FIXME - autocreate only for dev
+akka.actor.serialization-bindings{
+  "com.improving.app.common.serialize.PBMsgSerializable" = proto
+}
+akka.remote.artery.canonical.port = 0
+
+akka.actor.allow-java-serialization = off
+akka.persistence {
+  snapshot-store.plugin = "my-dynamodb-snapshot-store"
+}
+datastax-java-driver.advanced.reconnect-on-init = true
+datastax-java-driver {
+  basic.contact-points = ["10.152.183.5:9042"]
+  basic.load-balancing-policy.local-datacenter = "datacenter1"
+}
+
+my-dynamodb-journal = ${dynamodb-journal}
+my-dynamodb-journal {
+    journal-table =  "store_service"
+    journal-name =  "store_service"
+    endpoint =  "https://dynamodb.us-east-1.amazonaws.com"
+}

tenant/src/main/resources/application.conf → tenant/src/main/resources/application-cass-journal.conf

@@ -34,4 +34,11 @@ datastax-java-driver.advanced.reconnect-on-init = true
 datastax-java-driver {
   basic.contact-points = ["10.152.183.5:9042"]
   basic.load-balancing-policy.local-datacenter = "datacenter1"
+}
+
+my-dynamodb-journal = ${dynamodb-journal}
+my-dynamodb-journal {                     # and add some overrides
+    journal-table =  "tenant_service"
+    journal-name =  "tenant_service"
+    endpoint =  "https://dynamodb.us-east-1.amazonaws.com" # or where your deployment is
 }

tenant/src/main/resources/application-dynamo-journal.conf

@@ -0,0 +1,27 @@
+// Important: enable HTTP/2 in ActorSystem's config
+akka.http.server.preview.enable-http2 = on
+
+akka.actor.provider = cluster
+
+//FIXME - autocreate only for dev
+akka.actor.serialization-bindings{
+  "com.improving.app.common.serialize.PBMsgSerializable" = proto
+}
+akka.remote.artery.canonical.port = 0
+
+akka.actor.allow-java-serialization = off
+akka.persistence {
+  snapshot-store.plugin = "my-dynamodb-snapshot-store"
+}
+datastax-java-driver.advanced.reconnect-on-init = true
+datastax-java-driver {
+  basic.contact-points = ["10.152.183.5:9042"]
+  basic.load-balancing-policy.local-datacenter = "datacenter1"
+}
+
+my-dynamodb-journal = ${dynamodb-journal}
+my-dynamodb-journal {
+    journal-table =  "tenant_service"
+    journal-name =  "tenant_service"
+    endpoint =  "https://dynamodb.us-east-1.amazonaws.com"
+}