Wire project infrastructure

server/src/main/kotlin/dev/ulfrx/recipe/Application.kt

@@ -1,20 +1,38 @@
 package dev.ulfrx.recipe
 
-import io.ktor.server.application.*
-import io.ktor.server.engine.*
-import io.ktor.server.netty.*
-import io.ktor.server.response.*
-import io.ktor.server.routing.*
+import io.ktor.serialization.kotlinx.json.json
+import io.ktor.server.application.Application
+import io.ktor.server.application.install
+import io.ktor.server.engine.embeddedServer
+import io.ktor.server.netty.Netty
+import io.ktor.server.plugins.contentnegotiation.ContentNegotiation
+import io.ktor.server.response.respond
+import io.ktor.server.routing.get
+import io.ktor.server.routing.routing
+import kotlinx.serialization.Serializable
 
 fun main() {
     embeddedServer(Netty, port = SERVER_PORT, host = "0.0.0.0", module = Application::module)
         .start(wait = true)
 }
 
+@Serializable
+private data class Health(
+    val status: String,
+)
+
 fun Application.module() {
+    install(ContentNegotiation) {
+        json()
+    }
+    Database.migrate(this)
+    configureRouting()
+}
+
+fun Application.configureRouting() {
     routing {
-        get("/") {
-            call.respondText("Ktor: ${Greeting().greet()}")
+        get("/health") {
+            call.respond(Health(status = "ok"))
         }
     }
-}
+}

server/src/main/kotlin/dev/ulfrx/recipe/Database.kt

@@ -0,0 +1,41 @@
+package dev.ulfrx.recipe
+
+import io.ktor.server.application.Application
+import org.flywaydb.core.Flyway
+import org.slf4j.LoggerFactory
+
+object Database {
+    private val log = LoggerFactory.getLogger(Database::class.java)
+
+    fun migrate(app: Application) {
+        val url =
+            app.environment.config
+                .property("database.url")
+                .getString()
+        val user =
+            app.environment.config
+                .property("database.user")
+                .getString()
+        val password =
+            app.environment.config
+                .property("database.password")
+                .getString()
+
+        log.info("Connecting to {} as {} and running Flyway migrations", url, user)
+
+        runCatching {
+            Flyway
+                .configure()
+                .dataSource(url, user, password)
+                .locations("classpath:db/migration")
+                .baselineOnMigrate(true)
+                .validateOnMigrate(true)
+                .cleanDisabled(true)
+                .load()
+                .migrate()
+        }.onFailure { ex ->
+            log.error("Flyway migration failed — cannot start server", ex)
+            throw IllegalStateException("Database unreachable or migration failed", ex)
+        }
+    }
+}