nomisRev

package org.jetbrains.demo

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.*

fun main() {
    embeddedServer(Netty, configure = {

nomisRev

package com.example

import com.auth0.jwk.JwkProviderBuilder
import io.ktor.client.HttpClient
import io.ktor.client.call.body
import io.ktor.client.request.get
import io.ktor.http.HttpMethod
import io.ktor.server.auth.AuthenticationConfig
import io.ktor.server.auth.OAuthServerSettings
import io.ktor.server.auth.authentication

nomisRev

suspend fun refreshToken(): String? = withContext(Dispatchers.IO) {
        val callback = CompletableDeferred<OAuth2>()
        val server = embeddedServer(CIO, port = 0) {
            val port = async { engine.resolvedConnectors().first().port }
            authentication {
                oauth("oauth") {
                    @OptIn(ExperimentalCoroutinesApi::class)
                    urlProvider = { "http://localhost:${port.getCompleted()}/callback" }
                    providerLookup = {
                        OAuthServerSettings.OAuth2ServerSettings(

nomisRev

package io.ktor.route.simple

import io.ktor.server.plugins.BadRequestException
import kotlin.reflect.KProperty1

class ValidationBuilder<T> {

    private val validators = mutableListOf<Pair<KProperty1<T, *>, (value: Any?) -> String?>>()

    fun validate(instance: T): List<String> =

nomisRev

Ktor 3.2.0 Config EAP

Ktor 3.2.0 will add support for automatically deserializing configuration files into data classes. Let's define a simple application.yaml that defines some database configuration.

database:
    driverClassName: "$DB_DRIVER_CLASS_NAME:org.postgresql.Driver"
    host: "$DB_HOST:localhost"
    port: "$DATABASE_PORT:5432"

nomisRev

package org.jetbrains.ktor.sample

import kotlin.properties.ReadOnlyProperty
import kotlin.reflect.KProperty
import org.jetbrains.exposed.sql.Database
import org.jetbrains.exposed.sql.transactions.TransactionManager
import org.jetbrains.ktor.sample.config.dataSource
import org.jetbrains.ktor.sample.config.flyway
import org.junit.ClassRule
import org.junit.rules.ExternalResource

nomisRev

nomisRev

import com.apurebase.kgraphql.GraphQL
import com.apurebase.kgraphql.schema.Publisher
import com.apurebase.kgraphql.schema.dsl.SchemaBuilder
import io.ktor.server.application.*
import org.koin.dsl.module
import org.koin.ktor.ext.inject
import org.koin.ktor.plugin.Koin
import org.koin.logger.slf4jLogger
import kotlin.getValue

nomisRev

package io.github.nomisrev

import app.cash.sqldelight.driver.jdbc.asJdbcDriver
import arrow.continuations.SuspendApp
import arrow.continuations.ktor.server
import arrow.fx.coroutines.autoCloseable
import arrow.fx.coroutines.closeable
import arrow.fx.coroutines.resourceScope
import com.zaxxer.hikari.HikariConfig
import com.zaxxer.hikari.HikariDataSource

nomisRev

import arrow.atomic.Atomic
import arrow.atomic.update

/**
  * AutoClose offers DSL style API for creating parent-child relationships of AutoCloseable dependencies
  */
interface AutoClose : AutoCloseable {
  fun <A : AutoCloseable> autoClose(autoCloseable: A): A
}