WIP

Author: jakubjanecek

build.sbt

@@ -21,6 +21,8 @@ lazy val root = project
     bundleMonixHttp4sBlaze,
     bundleZioHttp4sBlaze,
     example,
+    flyway,
+    flywayPureConfig,
     http4sClientBlaze,
     http4sClientBlazePureConfig,
     http4sServer,
@@ -77,6 +79,23 @@ lazy val example = project
     libraryDependencies += Dependencies.logbackClassic
   )
 
+lazy val flyway = project
+  .in(file("flyway"))
+  .settings(commonSettings)
+  .settings(
+    name := "sst-flyway",
+    libraryDependencies += Dependencies.flywayCore
+  )
+
+lazy val flywayPureConfig = project
+  .in(file("flyway-pureconfig"))
+  .dependsOn(flyway)
+  .settings(commonSettings)
+  .settings(
+    name := "sst-flyway-pureconfig",
+    libraryDependencies += Dependencies.pureConfig
+  )
+
 lazy val http4sClientBlaze = project
   .in(file("http4s-client-blaze"))
   .settings(commonSettings)

flyway-pureconfig/src/main/scala/com/avast/sst/flyway/pureconfig/ConfigReaders.scala

@@ -0,0 +1,11 @@
+package com.avast.sst.flyway.pureconfig
+
+import com.avast.sst.flyway.FlywayConfig
+import pureconfig.ConfigReader
+import pureconfig.generic.semiauto.deriveReader
+
+trait ConfigReaders {
+
+  implicit val configReader: ConfigReader[FlywayConfig] = deriveReader
+
+}

flyway-pureconfig/src/main/scala/com/avast/sst/flyway/pureconfig/implicits.scala

@@ -0,0 +1,3 @@
+package com.avast.sst.flyway.pureconfig
+
+object implicits extends ConfigReaders

flyway/src/main/scala/com/avast/sst/flyway/FlywayConfig.scala

@@ -0,0 +1,3 @@
+package com.avast.sst.flyway
+
+final case class FlywayConfig(url: String, username: String, password: String, baselineOnMigrate: Boolean = false)

flyway/src/main/scala/com/avast/sst/flyway/FlywayModule.scala

@@ -0,0 +1,17 @@
+package com.avast.sst.flyway
+
+import cats.effect.Sync
+import org.flywaydb.core.Flyway
+
+object FlywayModule {
+
+  def make[F[_]: Sync](config: FlywayConfig): F[Flyway] = {
+    Flyway
+      .configure
+      .dataSource(config.url, config.username, config.password)
+      .baselineOnMigrate(config.baselineOnMigrate)
+      .load()
+    ???
+  }
+
+}

project/Dependencies.scala

@@ -3,6 +3,7 @@ import sbt._
 object Dependencies {
 
   val catsEffect = "org.typelevel" %% "cats-effect" % "2.0.0"
+  val flywayCore = "org.flywaydb" % "flyway-core" % "6.0.7"
   val http4sBlazeClient = "org.http4s" %% "http4s-blaze-client" % Versions.http4s
   val http4sBlazeServer = "org.http4s" %% "http4s-blaze-server" % Versions.http4s
   val http4sDsl = "org.http4s" %% "http4s-dsl" % Versions.http4s