ContentNegotiation

dependencies

implementation("io.ktor:ktor-server-content-negotiation:$ktor_version")
implementation("io.ktor:ktor-serialization-kotlinx-json:$ktor_version")

ktor_version=2.0.0-beta-1

WWW-Authenticate

refreshToken

install(Logging)
    install("Fix Unauthorized headers") {
        receivePipeline.intercept(HttpReceivePipeline.Before) { response ->
            println("----------- INTERCEPTING!") // this is printed
            proceedWith(UnauthorizedResponseWrapper(response))
        }
    }
    install(Auth) {
        bearer {
            loadTokens {
                println("---------- LOADING TOKENS!") // this is printed
                ...
            }
            refreshTokens {
                println("---------- REFRESHING TOKENS!") // this is NOT printed
                ...
            }
        }
    }

UnauthorizedResponseWrapper

private class UnauthorizedResponseWrapper(response: HttpResponse): HttpResponse() {
    override val call: HttpClientCall = response.call
    override val content: ByteReadChannel = response.content
    override val coroutineContext: CoroutineContext = response.coroutineContext
    override val headers: Headers = buildHeaders {
        appendAll(response.headers)
        if (response.status == HttpStatusCode.Unauthorized && !response.headers.contains(HttpHeaders.WWWAuthenticate)) {
            println("--------- APPENDING WWWAuth header!") // this is printed!
            append(HttpHeaders.WWWAuthenticate, AuthScheme.Bearer)
        }
    }
    override val requestTime: GMTDate = response.requestTime
    override val responseTime: GMTDate = response.responseTime
    override val status: HttpStatusCode = response.status
    override val version: HttpProtocolVersion = response.version
}

CoroutineScope

SupervisorJob

async

await

CoroutineScope

SupervisorJob

await

notFine

execute

implementation("ch.qos.logback:logback-classic:$logback_version")

GraalVM native-image

<domain-config>

ktor-client-core

ktor-client-cio

OKHTTP

authenticator

alamofire

interceptors

GraalVM 22.0.0.2 Java 11 CE

implementation(files(./dependency))

testApplication {
            client.config {
                install(HttpCookies)
                install(ContentNegotiation) {
                    json()
                }
            }
            routing {
                get("/login-test") {
                    call.sessions.set(UserSession(id = 4))
                }
            }
            client.get("/login-test")
            val response = client.get("v1/words")
            response.status shouldBe HttpStatusCode.OK
        }

testApplication

private suspend fun ApplicationTestBuilder.ensureStarted() = client.get("/") { expectSuccess = false }

class MyTest : FunSpec({
    test("plugin works correctly") {
        testApplication {
            install(MyCustomPlugin) { ... }

            ensureStarted()

            // test the plugin
        }
    }
})

routing {
        authenticate("auth-jwt") {
            route("*") {
               call.response.cookies.append(...)
            }
        }
       
        addRoutes()
    }

HttpResponseValidator

handleResponseException

contentType(ContentType.Image.JPEG)
setBody(byteArray)

val response: HttpResponse = <http://client.post|client.post>(
    "<https://example.com/login>"
) {
    contentType(ContentType.Application.Json)
    LoginModel(username, password).also { body = it }
}

fun createHttpClient() = HttpClient {
    install(ContentNegotiation) {
        json(Json { isLenient = true; ignoreUnknownKeys = true; useAlternativeNames = false; prettyPrint = true }
        )
    }
    install(Logging) {
        logger = Logger.DEFAULT
        level = <http://LogLevel.INFO|LogLevel.INFO>
    }
}