update jdbc schema provider to handle event processor offsets so as to use its own pool of database connections

Author: fupelaqu

build.sbt

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

jdbc/build.sbt

@@ -1,4 +1,5 @@
 import app.softnetwork.sbt.build.Versions
+app.softnetwork.sbt.build.Publication.settings
 
 Test / parallelExecution := false
 

jdbc/src/main/resources/softnetwork-jdbc-persistence.conf

@@ -53,6 +53,16 @@ jdbc-durable-state-store {
 }
 
 jdbc-event-processor-offsets {
+  db {
+    url = "jdbc:postgresql://"${db.ip}":"${db.port}"/"${db.name}"?reWriteBatchedInserts=true"
+    user = ${credentials.db.username}
+    password = ${credentials.db.password}
+    driver = "org.postgresql.Driver"
+    numThreads = ${db.max-connections}
+    minConnections = 10
+    maxConnections = 50
+    idleTimeout = 10000 //10 seconds
+  }
   schema = ${credentials.db.username}
   table = "event_processor_offsets"
 }
@@ -65,8 +75,8 @@ slick {
     password = ${credentials.db.password}
     driver = "org.postgresql.Driver"
     numThreads = ${db.max-connections}
-    maxConnections = ${db.max-connections}
     minConnections = ${db.min-connections}
+    maxConnections = ${db.max-connections}
     idleTimeout = 10000 //10 seconds
   }
 }
@@ -78,10 +88,10 @@ db {
   port = ${?DB_PORT}
   name = "softnetwork"
   name = ${?DB_NAME}
-  max-connections = 100
-  max-connections = ${?DB_MAX_CONNECTIONS}
   min-connections = 10
   min-connections = ${?DB_MIN_CONNECTIONS}
+  max-connections = 100
+  max-connections = ${?DB_MAX_CONNECTIONS}
 }
 
 credentials{

jdbc/src/main/scala/app/softnetwork/persistence/jdbc/config/Settings.scala renamed to jdbc/src/main/scala/app/softnetwork/persistence/jdbc/config/JdbcSettings.scala

@@ -6,7 +6,7 @@ import configs.Configs
 
 /** Created by smanciot on 15/09/2020.
   */
-object Settings extends StrictLogging {
+object JdbcSettings extends StrictLogging {
 
   case class JdbcEventProcessorOffsets(schema: String, table: String)
 

jdbc/src/main/scala/app/softnetwork/persistence/jdbc/query/JdbcJournalProvider.scala

@@ -6,12 +6,12 @@ import akka.persistence.jdbc.query.scaladsl.JdbcReadJournal
 import akka.persistence.query.{EventEnvelope, Offset, PersistenceQuery, Sequence}
 
 import akka.stream.scaladsl.Source
-import app.softnetwork.persistence.jdbc.config.Settings
 
 import slick.jdbc.JdbcBackend.Session
 
 import scala.concurrent.Future
 
+import app.softnetwork.persistence.jdbc.config.JdbcSettings._
 import app.softnetwork.persistence.query.JournalProvider
 
 import scala.util.{Failure, Success, Try}
@@ -20,8 +20,6 @@ import scala.util.{Failure, Success, Try}
   */
 trait JdbcJournalProvider extends JournalProvider { _: JdbcSchemaProvider =>
 
-  import Settings._
-
   lazy val offsetSchema: String = jdbcEventProcessorOffsets.schema
 
   lazy val offsetTable: String = jdbcEventProcessorOffsets.table

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

@@ -32,7 +32,7 @@ trait JdbcSchemaProvider extends SchemaProvider with ClasspathResources with Str
 
   def cfg: Config = ConfigFactory.load()
 
-  def db: Database = JdbcBackend.createDatabase(cfg, "slick.db")
+  lazy val db: Database = JdbcBackend.createDatabase(cfg, "jdbc-event-processor-offsets.db")
 
   def initSchema(): Unit = {
     create(schemaType.schema)