Changelog 2.2 version

2.2.4

released 28th February 2023

Client

ContentNegotiation: The "charset=UTF-8" part is added for the Content-Type header

Connect timeout is not respected when using the HttpRequestRetry plugin

OkHttp: Cancelling while writing to ByteWriteChannel when overriding WriteChannelContent causes propagation of CancellationException to a caller

https://youtrack.jetbrains.com/issue/KTOR-5518

Hello Ktor team :)

It has been pleasure to work with Ktor so far, but we stumbled on some issue that we are not sure how to solve, I will try to provide as much information as I can but if you need anything else from me please let me know so that perhaps we can figure something out together :)

We are trying to implement the feature where we want to cancel an outgoing asset upload to the server, this is basicly what we are trying to achieve :

class StreamAssetContent(
    private val fileContentStream: okio.Source
) : OutgoingContent.WriteChannelContent()  {

    override suspend fun writeTo(channel: ByteWriteChannel) {
        val contentBuffer = Buffer()
        while (fileContentStream.read(contentBuffer, BUFFER_SIZE) != -1L) {
            contentBuffer.readByteArray().let { content ->
                channel.writePacket(ByteReadPacket(content))
            }
        }
        channel.writeStringUtf8(closingArray)
        channel.flush()
        channel.close()
    }

    private companion object {
        const val BUFFER_SIZE = 1024 * 8L
    }
}

suspend fun cancelDuringUpload() {
    val httpClient = HttpClient(engine = OkHttp.create())
    
    val uploadJob = launch {
        httpClient.post(PATH_PUBLIC_ASSETS_V3) {
            contentType(ContentType.MultiPart.Mixed)
            setBody(StreamAssetContent(fileSource))
        }
    }
    
    delay(100.milliseconds)
    uploadJob.cancel()
}

according to my knowledge this should work as it cancels the coroutine it is launched in, but it crashes the app with CancellationException, we were able to solve
by isolating the throwing of the CancellationException from the insides of the Ktor

class StreamAssetContent(
    private val fileContentStream: okio.Source
) : OutgoingContent.WriteChannelContent()  {
   override suspend fun writeTo(channel: ByteWriteChannel) {
        try {
       coroutineScope {
                if (!channel.isClosedForWrite && producerJob.isActive) {
                    channel.writeStringUtf8(openingData)
                    val contentBuffer = Buffer()
                    while (fileContentStream.read(contentBuffer, BUFFER_SIZE) != -1L) {
                        contentBuffer.readByteArray().let { content ->
                            channel.writePacket(ByteReadPacket(content))
                        }
                    }
                    channel.writeStringUtf8(closingArray)
                    channel.flush()
                    channel.close()
                }
            }
        } catch (e: Exception) {
            channel.flush()
            channel.close()
            producerJob.completeExceptionally(e)
            throw IOException(e.message)
        } finally {
            producerJob.complete()
        }
    }
}

This would be a nice fix, but unfortunetly this was not enough, because when the timing is right the content of this class coming from Ktor also can throw CancellationException

internal class StreamRequestBody(
    private val contentLength: Long?,
  private val block: () -> ByteReadChannel`
) : RequestBody() {
    override fun contentType(): MediaType? = null
    override fun writeTo(sink: BufferedSink) {
        block().toInputStream().source().use {
            sink.writeAll(it)
       }
    }
    override fun contentLength(): Long = contentLength ?: -1
    override fun isOneShot(): Boolean = true
}

so we again override it and this is we come up with :

class ByteChannelRequestBody(
    private val contentLength: Long?,
    private val callContext: CoroutineContext,
    private val block: () -> ByteReadChannel
) : RequestBody(), CoroutineScope {
    private val producerJob = Job(callContext[Job])

    override val coroutineContext: CoroutineContext
        get() = callContext + producerJob + Dispatchers.IO
    override fun contentLength(): Long = contentLength ?: -1
    override fun contentType(): MediaType? = null

    override fun writeTo(sink: BufferedSink) {
        withJob(producerJob) {
            if (producerJob.isActive) {
                block().toInputStream().source().use {
                    sink.writeAll(it)
                }
            }
        }
    }

    private inline fun <T> withJob(job: CompletableJob, block: () -> T): T {
        try {
            return block()
        } catch (ex: Exception) {
           job.completeExceptionally(ex)
            // wrap all exceptions thrown from inside `okhttp3.RequestBody#writeTo(..)` as an IOException`    
            throw IOException(ex)
        } finally {
            job.complete()
        }
    }
}

the issue here is that in order to use this imlementation I had to copy-paste Ktor source code, because the place that is allowing us to use our custom Class is Ktor internal. This requires us to maintain the Ktor classes with each update, which we would ike not to do since you guys are doing it way better :P

internal fun OutgoingContent.convertToOkHttpBody(callContext: CoroutineContext): RequestBody = when (this) {
    is OutgoingContent.ByteArrayContent -> bytes().let {
        it.toRequestBody(null, 0, it.size)
    }
    is OutgoingContent.ReadChannelContent -> ByteChannelRequestBody(contentLength, callContext) { readFrom() }
    is OutgoingContent.WriteChannelContent -> {
        ByteChannelRequestBody(contentLength, callContext) {
            GlobalScope.writer(callContext) { writeTo(channel) }.channel
        }
    }
    is OutgoingContent.NoContent -> ByteArray(0).toRequestBody(null, 0, 0)
    else -> throw UnsupportedContentTypeException(this)
}

We are on :

okio = 3.2.0
ok-http = 4.9.3
ktor = 2.2.1

Here is also the stacktrace when the issues are happening:

com.wire.kalium.network.exceptions.KaliumException$GenericError
	at com.wire.kalium.network.api.v2.authenticated.AssetApiV2.uploadAsset$suspendImpl(AssetApiV2.kt:89)
	at com.wire.kalium.network.api.v2.authenticated.AssetApiV2$uploadAsset$1.invokeSuspend(Unknown Source:18)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
	at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:104)
	at kotlinx.coroutines.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:570)
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.executeTask(CoroutineScheduler.kt:750)
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.runWorker(CoroutineScheduler.kt:677)
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:664)
Caused by: java.util.concurrent.CancellationException: test
	at com.wire.kalium.network.http.request.ByteChannelRequestBody.writeTo(ByteChannelRequestBody.kt:63)
	at okhttp3.internal.http.CallServerInterceptor.intercept(CallServerInterceptor.kt:59)
	at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.kt:109)
	at okhttp3.internal.connection.ConnectInterceptor.intercept(ConnectInterceptor.kt:34)
	at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.kt:109)
	at okhttp3.internal.cache.CacheInterceptor.intercept(CacheInterceptor.kt:95)
	at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.kt:109)
	at okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.kt:83)
	at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.kt:109)
	at okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.kt:76)
	at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.kt:109)
	at okhttp3.internal.connection.RealCall.getResponseWithInterceptorChain$okhttp(RealCall.kt:201)
	at okhttp3.internal.connection.RealCall$AsyncCall.run(RealCall.kt:517)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1137)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:637)
	at java.lang.Thread.run(Thread.java:1012)

so my question to you, is there anything we are perhaps doing wrong, or is this simply not yet easily supported in Ktor ?

There is also an issue on this from AWS :
https://github.com/awslabs/aws-sdk-kotlin/issues/733

And this is the PR coming from us - Wire
https://github.com/wireapp/kalium/pull/1288

thanks for any help and let us know if you need anything else from us

Core

URLs with underscore fail to parse correctly in HTTP client request

Generator

Update the latest version of Ktor by the latest version of Ktor Gradle plugin

Create Postgres JDBC Plugin for Generator

Create Exposed Plugin for Generator

IntelliJ IDEA Plugin

OpenApi for StatusPages is cached and not updated accordingly to the code

NullPointerException in KtorRoutingVisitor.processLastArgumentsBodyIfRouteExtensionLambda

https://youtrack.jetbrains.com/issue/KTOR-5461

    at io.ktor.ide.KtorRoutingVisitor.processLastArgumentsBodyIfRouteExtensionLambda(KtorUrlResolver.kt:149)
    at io.ktor.ide.KtorRoutingVisitor.visitCallExpression(KtorUrlResolver.kt:188)
    at org.jetbrains.uast.kotlin.KotlinUFunctionCallExpression.accept(KotlinUFunctionCallExpression.kt:165)
    at org.jetbrains.uast.internal.ImplementationUtilsKt.acceptList(implementationUtils.kt:14)
    at org.jetbrains.uast.UBlockExpression.accept(UBlockExpression.kt:21)
    at org.jetbrains.uast.ULambdaExpression.accept(ULambdaExpression.kt:40)
    at org.jetbrains.uast.internal.ImplementationUtilsKt.acceptList(implementationUtils.kt:14)
    at org.jetbrains.uast.kotlin.KotlinUFunctionCallExpression.accept(KotlinUFunctionCallExpression.kt:169)
    at org.jetbrains.uast.internal.ImplementationUtilsKt.acceptList(implementationUtils.kt:14)
    at org.jetbrains.uast.UBlockExpression.accept(UBlockExpression.kt:21)
    at org.jetbrains.uast.ULambdaExpression.accept(ULambdaExpression.kt:40)
    at org.jetbrains.uast.internal.ImplementationUtilsKt.acceptList(implementationUtils.kt:14)
    at org.jetbrains.uast.kotlin.KotlinUFunctionCallExpression.accept(KotlinUFunctionCallExpression.kt:169)
    at io.ktor.ide.KtorUrlResolverKt.getAllUrlMappings$lambda$3$lambda$2(KtorUrlResolver.kt:65)
    at io.ktor.ide.KtorUtilsKt.withProgress(KtorUtils.kt:112)
    at io.ktor.ide.KtorUrlResolverKt.getAllUrlMappings$lambda$3(KtorUrlResolver.kt:64)
    at com.intellij.psi.impl.PsiCachedValueImpl.doCompute(PsiCachedValueImpl.java:39)
    at com.intellij.util.CachedValueBase.lambda$getValueWithLock$3(CachedValueBase.java:231)
    at com.intellij.util.CachedValueBase.computeData(CachedValueBase.java:41)
    at com.intellij.util.CachedValueBase.lambda$getValueWithLock$4(CachedValueBase.java:231)
    at com.intellij.openapi.util.RecursionManager$1.computePreventingRecursion(RecursionManager.java:112)
    at com.intellij.openapi.util.RecursionGuard.doPreventingRecursion(RecursionGuard.java:42)
    at com.intellij.openapi.util.RecursionManager.doPreventingRecursion(RecursionManager.java:66)
    at com.intellij.util.CachedValueBase.getValueWithLock(CachedValueBase.java:232)
    at com.intellij.psi.impl.PsiCachedValueImpl.getValue(PsiCachedValueImpl.java:28)
    at com.intellij.util.CachedValuesManagerImpl.getCachedValue(CachedValuesManagerImpl.java:72)
    at com.intellij.psi.util.CachedValuesManager.getCachedValue(CachedValuesManager.java:111)
    at io.ktor.ide.KtorUrlResolverKt.getAllUrlMappings(KtorUrlResolver.kt:61)
    at io.ktor.ide.KtorUrlResolverKt.access$getAllUrlMappings(KtorUrlResolver.kt:1)
    at io.ktor.ide.KtorUrlResolver$getVariants$2.invoke(KtorUrlResolver.kt:41)
    at io.ktor.ide.KtorUrlResolver$getVariants$2.invoke(KtorUrlResolver.kt:41)
    at kotlin.sequences.FlatteningSequence$iterator$1.ensureItemIterator(Sequences.kt:315)
    at kotlin.sequences.FlatteningSequence$iterator$1.hasNext(Sequences.kt:303)
    at kotlin.sequences.TransformingSequence$iterator$1.hasNext(Sequences.kt:214)
    at kotlin.sequences.TransformingSequence$iterator$1.hasNext(Sequences.kt:214)
    at kotlin.sequences.TransformingSequence$iterator$1.hasNext(Sequences.kt:214)
    at kotlin.sequences.FilteringSequence$iterator$1.calcNext(Sequences.kt:169)
    at kotlin.sequences.FilteringSequence$iterator$1.hasNext(Sequences.kt:194)
    at com.intellij.microservices.gotosymbol.UrlSearchEverywhereContributor$fetchWeightedElements$lambda$2$$inlined$computeInReadActionWithWriteActionPriority$1.run(UrlSearchEverywhereContributor.kt:205)
    at com.intellij.openapi.application.impl.ApplicationImpl.tryRunReadAction(ApplicationImpl.java:1086)
    at com.intellij.openapi.progress.util.ProgressIndicatorUtils.lambda$runInReadActionWithWriteActionPriority$0(ProgressIndicatorUtils.java:71)
    at com.intellij.openapi.progress.util.ProgressIndicatorUtilService.runActionAndCancelBeforeWrite(ProgressIndicatorUtilService.java:63)
    at com.intellij.openapi.progress.util.ProgressIndicatorUtils.runActionAndCancelBeforeWrite(ProgressIndicatorUtils.java:128)
    at com.intellij.openapi.progress.util.ProgressIndicatorUtils.lambda$runWithWriteActionPriority$1(ProgressIndicatorUtils.java:109)
    at com.intellij.openapi.progress.ProgressManager.lambda$runProcess$0(ProgressManager.java:68)
    at com.intellij.openapi.progress.impl.CoreProgressManager.lambda$runProcess$2(CoreProgressManager.java:188)
    at com.intellij.openapi.progress.impl.CoreProgressManager.lambda$executeProcessUnderProgress$13(CoreProgressManager.java:589)
    at com.intellij.openapi.progress.impl.CoreProgressManager.registerIndicatorAndRun(CoreProgressManager.java:664)
    at com.intellij.openapi.progress.impl.CoreProgressManager.computeUnderProgress(CoreProgressManager.java:620)
    at com.intellij.openapi.progress.impl.CoreProgressManager.executeProcessUnderProgress(CoreProgressManager.java:588)
    at com.intellij.openapi.progress.impl.ProgressManagerImpl.executeProcessUnderProgress(ProgressManagerImpl.java:60)
    at com.intellij.openapi.progress.impl.CoreProgressManager.runProcess(CoreProgressManager.java:175)
    at com.intellij.openapi.progress.ProgressManager.runProcess(ProgressManager.java:68)
    at com.intellij.openapi.progress.util.ProgressIndicatorUtils.runWithWriteActionPriority(ProgressIndicatorUtils.java:106)
    at com.intellij.openapi.progress.util.ProgressIndicatorUtils.runInReadActionWithWriteActionPriority(ProgressIndicatorUtils.java:71)
    at com.intellij.microservices.gotosymbol.UrlSearchEverywhereContributor.p(UrlSearchEverywhereContributor.kt:202)
    at com.intellij.concurrency.JobLauncherImpl.lambda$processImmediatelyIfTooFew$2(JobLauncherImpl.java:137)
    at com.intellij.openapi.progress.impl.CoreProgressManager.lambda$executeProcessUnderProgress$13(CoreProgressManager.java:589)
    at com.intellij.openapi.progress.impl.CoreProgressManager.registerIndicatorAndRun(CoreProgressManager.java:664)
    at com.intellij.openapi.progress.impl.CoreProgressManager.computeUnderProgress(CoreProgressManager.java:620)
    at com.intellij.openapi.progress.impl.CoreProgressManager.executeProcessUnderProgress(CoreProgressManager.java:588)
    at com.intellij.openapi.progress.impl.ProgressManagerImpl.executeProcessUnderProgress(ProgressManagerImpl.java:60)
    at com.intellij.concurrency.JobLauncherImpl.lambda$processImmediatelyIfTooFew$3(JobLauncherImpl.java:133)
    at com.intellij.concurrency.JobLauncherImpl.processImmediatelyIfTooFew(JobLauncherImpl.java:147)
    at com.intellij.concurrency.JobLauncherImpl.invokeConcurrentlyUnderProgress(JobLauncherImpl.java:44)

OpenAPI for StatusPages: java.lang.IllegalStateException: Calling invokeAndWait from read-action leads to possible deadlock

Ktor IDE does not generate proper OpenAPI with StatusPages and recursive calls (plus `error(...)` calls)

Samples

Integration tests for API secured with (RSA signed) JSON web tokens sample

Apply Ktor Gradle plugin to all sample projects and remove specific versions for artifacts

Server

Routing: Wrong content-type results in 405 instead of 415 status code with two routes

Compressing the response will result in unexpected ERROR log output after processing in the StatusPages

Javadoc for Resources.kt cannot be compiled

Shared

kotlinx.serialization.SerializationException is lost for the classes that have generic type parameters

2.2.3

released 1st February 2023

Client

ContentNegotiation: "Skipping because the type is ignored" log message is unclear

FileStorage throws java.io.FileNotFoundException (File name too long) when request path is long

HttpRequestRetry retries on FileNotFoundException thrown by FileStorage

Add Client Plugins Trace Logging

Docs

Remove Ktor samples that duplicate existing samples in docs

Generator

Cannot compile a project generated with the Exposed plugin

Migration breaks Gson import

IntelliJ IDEA Plugin

`parent` params from nested resources are erroneously represented in OpenAPI

Server

Multipart File doesn't upload whole file, throws "Unexpected EOF: expected 4096 more bytes" for larger files

https://youtrack.jetbrains.com/issue/KTOR-3455

Steps to reproduce:

check out the reproducer project. It contains a simple upload sample and Gradle run task that constrains memory to 128mb.
Create a large file to upload (e.g. on macOS with mkfile -n 2g upload.bin)
Navigate to http://0.0.0.0:8080/upload and upload the file

The significant part seems to be UploadRoute's stream-copying:

                it.streamProvider().use { partstream ->
                    targetFile.outputStream().use { os ->
                        partstream.copyTo(os, 8192)
                    }
                }

It results in the following:

2021-11-21 20:49:35.681 [eventLoopGroupProxy-4-1] ERROR ktor.application - Unhandled exception caught for CoroutineName(call-handler)
kotlinx.coroutines.channels.ClosedReceiveChannelException: Unexpected EOF: expected 4096 more bytes
	at io.ktor.utils.io.ByteBufferChannel.readFullySuspend(ByteBufferChannel.kt:573)
	at io.ktor.utils.io.ByteBufferChannel.readFully(ByteBufferChannel.kt:565)
	at io.ktor.utils.io.ByteBufferChannel.readPacketSuspend(ByteBufferChannel.kt:781)
	at io.ktor.utils.io.ByteBufferChannel.readPacket$suspendImpl(ByteBufferChannel.kt:767)
	at io.ktor.utils.io.ByteBufferChannel.readPacket(ByteBufferChannel.kt)
	at io.ktor.utils.io.ByteReadChannelKt.readPacket(ByteReadChannel.kt:198)
	at io.ktor.http.cio.MultipartKt$parseMultipart$1.invokeSuspend(Multipart.kt:342)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
	at kotlinx.coroutines.internal.DispatchedContinuation.resumeWith(DispatchedContinuation.kt:205)
	at io.ktor.utils.io.internal.CancellableReusableContinuation.resumeWith(CancellableReusableContinuation.kt:93)
	at io.ktor.utils.io.ByteBufferChannel.resumeWriteOp(ByteBufferChannel.kt:2138)
	at io.ktor.utils.io.ByteBufferChannel.bytesRead(ByteBufferChannel.kt:887)
	at io.ktor.utils.io.ByteBufferChannel.readAsMuchAsPossible(ByteBufferChannel.kt:483)
	at io.ktor.utils.io.ByteBufferChannel.readAvailable$suspendImpl(ByteBufferChannel.kt:678)
	at io.ktor.utils.io.ByteBufferChannel.readAvailable(ByteBufferChannel.kt)
	at io.ktor.utils.io.ByteBufferChannel.readAvailableSuspend(ByteBufferChannel.kt:722)
	at io.ktor.utils.io.ByteBufferChannel.access$readAvailableSuspend(ByteBufferChannel.kt:24)
	at io.ktor.utils.io.ByteBufferChannel$readAvailableSuspend$2.invokeSuspend(ByteBufferChannel.kt)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
	at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:106)
	at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
	at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:469)
	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986)
	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
	at io.ktor.server.netty.EventLoopGroupProxy$Companion.create$lambda-1$lambda-0(NettyApplicationEngine.kt:260)
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
	at java.base/java.lang.Thread.run(Thread.java:831)

My two-gigabyte sample files have only arrived in part to /tmp, as well.

DropwizardMetricsPlugin logs status code incorrectly when is used together with StatusPages plugin

Log HTTP request time

Netty: Unable to set the `tcpKeepAlive`

HOCON: CLI parameters don't override custom array properties since 2.1.0

Other

Support `call.receive` (request body) in OpenAPI generator

Make OAuth2 functionality multiplatform

2.2.2

released 4th January 2023

Client

iOS unit test deadlocks with DarwinClientEngine

HttpRequestRetry: Memory leak of coroutines objects when using the plugin

Gzip encoding: IllegalStateException: Expected 112, actual 113

Core

Allow specifying immutable in CacheControl

Docs

Use more clear term instead of 'authorization scope' in auth docs

Document how to generate OpenAPI specification for EngineMain servers

IntelliJ IDEA Plugin

Open API: Support request headers in OpenAPI generator

OpenAPI: support request cookies in documentation

Open API: Support a list of values as request header

Ktor templates use translated string for declaring the dependency when using the Language Pack

Server

Engine shutdown grace period and timeout are not configurable

Server cannot be started with the Swagger plugin

The swaggerUI method is too restrictive and cannot be called inside a route

Netty, HSTS: UnsupportedOperationException is thrown when the server responds before HSTS plugin

https://youtrack.jetbrains.com/issue/KTOR-5276

I installed the HSTS Plugin to my KTOR app and always, when a static file is requested, i get this Exception:

2022-12-05 15:41:40.202 [eventLoopGroupProxy-4-3] INFO  ktor.application - 200 OK: GET - /static/bootstrap/dist/css/bootstrap.min.css.map
2022-12-05 15:41:40.205 [eventLoopGroupProxy-4-3] ERROR ktor.application - 200 OK: GET - /static/bootstrap/dist/css/bootstrap.min.css.map
java.lang.UnsupportedOperationException: Headers can no longer be set because response was already completed
	at io.ktor.server.netty.http1.NettyHttp1ApplicationResponse$headers$1.engineAppendHeader(NettyHttp1ApplicationResponse.kt:42)
	at io.ktor.server.response.ResponseHeaders.append(ResponseHeaders.kt:57)
	at io.ktor.server.response.ResponseHeaders.append$default(ResponseHeaders.kt:48)
	at io.ktor.server.response.ApplicationResponsePropertiesKt.header(ApplicationResponseProperties.kt:14)
	at io.ktor.server.plugins.hsts.HSTSKt$HSTS$2$1.invokeSuspend(HSTS.kt:109)
	at io.ktor.server.plugins.hsts.HSTSKt$HSTS$2$1.invoke(HSTS.kt)
	at io.ktor.server.plugins.hsts.HSTSKt$HSTS$2$1.invoke(HSTS.kt)
	at io.ktor.server.application.PluginBuilder$onCall$2.invokeSuspend(PluginBuilder.kt:90)
	at io.ktor.server.application.PluginBuilder$onCall$2.invoke(PluginBuilder.kt)
	at io.ktor.server.application.PluginBuilder$onCall$2.invoke(PluginBuilder.kt)
	at io.ktor.server.application.PluginBuilder$onDefaultPhase$1.invokeSuspend(PluginBuilder.kt:217)
	at io.ktor.server.application.PluginBuilder$onDefaultPhase$1.invoke(PluginBuilder.kt)
	at io.ktor.server.application.PluginBuilder$onDefaultPhase$1.invoke(PluginBuilder.kt)
	at io.ktor.server.application.PluginBuilder$onDefaultPhaseWithMessage$1$1$1.invokeSuspend(PluginBuilder.kt:200)
	at io.ktor.server.application.PluginBuilder$onDefaultPhaseWithMessage$1$1$1.invoke(PluginBuilder.kt)
	at io.ktor.server.application.PluginBuilder$onDefaultPhaseWithMessage$1$1$1.invoke(PluginBuilder.kt)
	at io.ktor.util.debug.ContextUtilsKt$addToContextInDebugMode$2.invokeSuspend(ContextUtils.kt:33)
	at io.ktor.util.debug.ContextUtilsKt$addToContextInDebugMode$2.invoke(ContextUtils.kt)
	at io.ktor.util.debug.ContextUtilsKt$addToContextInDebugMode$2.invoke(ContextUtils.kt)
	at kotlinx.coroutines.intrinsics.UndispatchedKt.startUndispatchedOrReturn(Undispatched.kt:89)
	at kotlinx.coroutines.BuildersKt__Builders_commonKt.withContext(Builders.common.kt:169)
	at kotlinx.coroutines.BuildersKt.withContext(Unknown Source)
	at io.ktor.util.debug.ContextUtilsKt.addToContextInDebugMode(ContextUtils.kt:33)
	at io.ktor.server.application.PluginBuilder$onDefaultPhaseWithMessage$1$1.invokeSuspend(PluginBuilder.kt:196)
	at io.ktor.server.application.PluginBuilder$onDefaultPhaseWithMessage$1$1.invoke(PluginBuilder.kt)
	at io.ktor.server.application.PluginBuilder$onDefaultPhaseWithMessage$1$1.invoke(PluginBuilder.kt)
	at io.ktor.util.pipeline.SuspendFunctionGun.loop(SuspendFunctionGun.kt:123)
	at io.ktor.util.pipeline.SuspendFunctionGun.access$loop(SuspendFunctionGun.kt:14)
	at io.ktor.util.pipeline.SuspendFunctionGun$continuation$1.resumeWith(SuspendFunctionGun.kt:62)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:46)
	at kotlinx.coroutines.UndispatchedCoroutine.afterResume(CoroutineContext.kt:233)
	at kotlinx.coroutines.AbstractCoroutine.resumeWith(AbstractCoroutine.kt:102)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:46)
	at io.ktor.util.pipeline.SuspendFunctionGun.resumeRootWith(SuspendFunctionGun.kt:138)
	at io.ktor.util.pipeline.SuspendFunctionGun.loop(SuspendFunctionGun.kt:112)
	at io.ktor.util.pipeline.SuspendFunctionGun.access$loop(SuspendFunctionGun.kt:14)
	at io.ktor.util.pipeline.SuspendFunctionGun$continuation$1.resumeWith(SuspendFunctionGun.kt:62)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:46)
	at io.ktor.util.pipeline.SuspendFunctionGun.resumeRootWith(SuspendFunctionGun.kt:138)
	at io.ktor.util.pipeline.SuspendFunctionGun.loop(SuspendFunctionGun.kt:112)
	at io.ktor.util.pipeline.SuspendFunctionGun.access$loop(SuspendFunctionGun.kt:14)
	at io.ktor.util.pipeline.SuspendFunctionGun$continuation$1.resumeWith(SuspendFunctionGun.kt:62)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:46)
	at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:106)
	at io.netty.util.concurrent.AbstractEventExecutor.runTask$$$capture(AbstractEventExecutor.java:174)
	at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java)
	at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:167)
	at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
	at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)
	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:503)
	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
	at io.ktor.server.netty.EventLoopGroupProxy$Companion.create$lambda-1$lambda-0(NettyApplicationEngine.kt:288)
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
	at java.base/java.lang.Thread.run(Thread.java:829)

It seems that the reason for that is the usage of onCall here. I tested it with onCallRespond instead and it seemed to work without throwing those Exceptions. Hope, someone can fix this.

Shared

Resource annotation should be MetaSerializable

Other

Regression in 2.2.1: Got EOF but at least 0 bytes were expected

https://youtrack.jetbrains.com/issue/KTOR-5372

I tried to update ktor from 2.1.3 to 2.2.1 in the IJ Platform, but I get the following error:

Exception in thread "main" java.io.EOFException: Got EOF but at least 0 bytes were expected
	at io.ktor.utils.io.ByteBufferChannel.read$suspendImpl(ByteBufferChannel.kt:1658)
	at io.ktor.utils.io.ByteBufferChannel.read(ByteBufferChannel.kt)
	at io.ktor.utils.io.ByteBufferChannel.readBlockSuspend(ByteBufferChannel.kt:1713)
	at io.ktor.utils.io.ByteBufferChannel.access$readBlockSuspend(ByteBufferChannel.kt:23)
	at io.ktor.utils.io.ByteBufferChannel$readBlockSuspend$1.invokeSuspend(ByteBufferChannel.kt)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
	at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:106)
	at kotlinx.coroutines.internal.LimitedDispatcher.run(LimitedDispatcher.kt:42)
	at kotlinx.coroutines.scheduling.TaskImpl.run(Tasks.kt:95)
	at kotlinx.coroutines.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:570)
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.executeTask(CoroutineScheduler.kt:750)
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.runWorker(CoroutineScheduler.kt:677)
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:664)

I "fixed" it by catching EOFException and ignoring it, but then I get:

java.io.EOFException: Failed to parse HTTP response: unexpected EOF
  at io.ktor.client.engine.cio.UtilsKt$readResponse$2.invokeSuspend(utils.kt:132)
  at    (Coroutine boundary. ( )
  at io.ktor.client.engine.HttpClientEngine$DefaultImpls.executeWithinCallContext(HttpClientEngine.kt:100)
  at io.ktor.client.engine.HttpClientEngine$install$1.invokeSuspend(HttpClientEngine.kt:70)
  at io.ktor.client.plugins.HttpSend$DefaultSender.execute(HttpSend.kt:138)
  at io.ktor.client.plugins.HttpRequestRetry$intercept$1.invokeSuspend(HttpRequestRetry.kt:291)
  at io.ktor.client.plugins.HttpRedirect$Plugin$install$1.invokeSuspend(HttpRedirect.kt:61)
  at io.ktor.client.plugins.HttpCallValidator$Companion$install$3.invokeSuspend(HttpCallValidator.kt:147)
  at io.ktor.client.plugins.HttpSend$Plugin$install$1.invokeSuspend(HttpSend.kt:104)
  at io.ktor.client.engine.HttpClientEngine$DefaultImpls.executeWithinCallContext(HttpClientEngine.kt:100)
  at io.ktor.client.engine.HttpClientEngine$install$1.invokeSuspend(HttpClientEngine.kt:70)
  at io.ktor.client.plugins.HttpSend$DefaultSender.execute(HttpSend.kt:138)
  at io.ktor.client.plugins.HttpRequestRetry$intercept$1.invokeSuspend(HttpRequestRetry.kt:291)
  at io.ktor.client.plugins.HttpRedirect$Plugin$install$1.invokeSuspend(HttpRedirect.kt:61)
  at io.ktor.client.plugins.HttpCallValidator$Companion$install$3.invokeSuspend(HttpCallValidator.kt:147)
  at io.ktor.client.plugins.HttpSend$Plugin$install$1.invokeSuspend(HttpSend.kt:104)
  at io.ktor.client.plugins.HttpCallValidator$Companion$install$1.invokeSuspend(HttpCallValidator.kt:126)
  at io.ktor.client.plugins.HttpRequestLifecycle$Plugin$install$1.invokeSuspend(HttpRequestLifecycle.kt:35)
  at io.ktor.client.HttpClient.execute$ktor_client_core(HttpClient.kt:191)
  at io.ktor.client.statement.HttpStatement.executeUnsafe(HttpStatement.kt:108)
  at io.ktor.client.statement.HttpStatement.execute(HttpStatement.kt:47)
  at org.jetbrains.intellij.build.KtorKt$downloadFileToCacheLocation$$inlined$useWithScope2$1.invokeSuspend(ktor.kt:114)

So, I guess it is some kind of regression, since code was working previously. Probably the result of https://youtrack.jetbrains.com/issue/KTOR-5252 fix.

2.2.1

released 8th December 2022

Other

Hotfix: update atomicfu version

2.2.0

released 7th December 2022

Build System Plugin

Enable GraalVM Metadata Repository in Gradle plugin

Add BOM file to the dependencies provided by the Gradle plugin

Client

Retry and timeout client plugins don't work together

Darwin: response is never returned when usePreconfiguredSession is used

Logging: the plugin instantiates the default logger even when a custom one is provided

https://youtrack.jetbrains.com/issue/KTOR-5186

I'm getting an error while trying to set a custom Logger for Ktor:

SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/C:/Program%20Files/JetBrains/IntelliJ%20IDEA%20Community%20Edition/plugins/maven/lib/maven36-server.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/C:/Program%20Files/JetBrains/IntelliJ%20IDEA%20Community%20Edition/lib/3rd-party-rt.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.jetbrains.idea.maven.server.Maven3WrapperSl4LoggerFactory]
java.lang.LinkageError: loader constraint violation: when resolving method "org.slf4j.impl.StaticLoggerBinder.getLoggerFactory()Lorg/slf4j/ILoggerFactory;" the class loader com.intellij.ide.plugins.cl.PluginClassLoader @2fc90a94 (instance of com.intellij.ide.plugins.cl.PluginClassLoader, child of 'bootstrap') of the current class, org/slf4j/LoggerFactory, and the class loader com.intellij.ide.plugins.cl.PluginClassLoader @55b14fad (instance of com.intellij.ide.plugins.cl.PluginClassLoader, child of 'bootstrap') for the method's defining class, org/slf4j/impl/StaticLoggerBinder, have different Class objects for the type org/slf4j/ILoggerFactory used in the signature
	at org.slf4j.LoggerFactory.getILoggerFactory(LoggerFactory.java:423)
	at org.slf4j.LoggerFactory.getLogger(LoggerFactory.java:362)
	at org.slf4j.LoggerFactory.getLogger(LoggerFactory.java:388)
	at io.ktor.client.plugins.logging.LoggerJvmKt$DEFAULT$1.<init>(LoggerJvm.kt:12)
	at io.ktor.client.plugins.logging.LoggerJvmKt.getDEFAULT(LoggerJvm.kt:11)
	at io.ktor.client.plugins.logging.Logging$Config.<init>(Logging.kt:45)
	at io.ktor.client.plugins.logging.Logging$Companion.prepare(Logging.kt:216)
	at io.ktor.client.plugins.logging.Logging$Companion.prepare(Logging.kt:212)
	at io.ktor.client.HttpClientConfig$install$3.invoke(HttpClientConfig.kt:84)
	at io.ktor.client.HttpClientConfig$install$3.invoke(HttpClientConfig.kt:81)
	at io.ktor.client.HttpClientConfig.install(HttpClientConfig.kt:104)

This is the code for the client:

HttpClient(CIO) {
  install(Logging) {
    logger = object : Logger {
      override fun log(message: String) {
        println(message)
      }
    }
  }
}

You can see that a new instance of config is created in prepare():

    public companion object : HttpClientPlugin<Config, Logging> {
        override val key: AttributeKey<Logging> = AttributeKey("ClientLogging")

        override fun prepare(block: Config.() -> Unit): Logging {
            val config = Config().apply(block)
            return Logging(config.logger, config.level, config.filters)
        }

        override fun install(plugin: Logging, scope: HttpClient) {
            plugin.setupRequestLogging(scope)
            plugin.setupResponseLogging(scope)
        }
    }

Which creates a new instance of the default logger, even if I provided a custom one:

    @KtorDsl
    public class Config {
        /**
         * filters
         */
        internal var filters = mutableListOf<(HttpRequestBuilder) -> Boolean>()

        /**
         * Specifies a [Logger] instance.
         */
        public var logger: Logger = Logger.DEFAULT

        /**
         * Specifies the log the logging level.
         */
        public var level: LogLevel = LogLevel.HEADERS

        /**
         * Allows you to filter log messages for calls matching a [predicate].
         */
        public fun filter(predicate: (HttpRequestBuilder) -> Boolean) {
            filters.add(predicate)
        }
    }

Could anyone suggest a workaround, until this is fixed?

See:

https://github.com/ktorio/ktor/blob/428b2972ac92408b4937b43d62695d3c00bfd1ff/ktor-client/ktor-client-plugins/ktor-client-logging/common/src/io/ktor/client/plugins/logging/Logging.kt#L216

https://github.com/ktorio/ktor/blob/428b2972ac92408b4937b43d62695d3c00bfd1ff/ktor-client/ktor-client-plugins/ktor-client-logging/common/src/io/ktor/client/plugins/logging/Logging.kt#L45

Java client engine doesn't handle HttpTimeout.INFINITE_TIMEOUT_MS properly

New plugins API for client

Persistent Client HttpCache

Support native windows HTTP client

Websockets, Darwin: trusting a certificate via `handleChallenge` doesn't work for Websockets connections

https://youtrack.jetbrains.com/issue/KTOR-5094

We have dev environment with a self-signed certificate, we use ktor (2.1.3) for REST and web sockets,

REST endpoints work pretty well, but web sockets crash with errors:

Task <A986E3F4-E43F-4909-A663-5B1CBD50FFEF>.<1> finished with error [-1202] Error Domain=NSURLErrorDomain Code=-1202 "The certificate for this server is invalid. You might be connecting to a server that is pretending to be “walp.kube” which could put your confidential information at risk." UserInfo={NSErrorFailingURLStringKey=wss://walp.kube/ws, NSErrorFailingURLKey=wss://walp.kube/ws, NSLocalizedRecoverySuggestion=Would you like to connect to the server anyway?, _NSURLErrorRelatedURLSessionTaskErrorKey=(
    "LocalWebSocketTask <A986E3F4-E43F-4909-A663-5B1CBD50FFEF>.<1>"
), _NSURLErrorFailingURLSessionTaskErrorKey=LocalWebSocketTask <A986E3F4-E43F-4909-A663-5B1CBD50FFEF>.<1>, NSLocalizedDescription=The certificate for this server is invalid. You might be connecting to a server that is pretending to be “walp.kube” which could put your confidential information at risk.}
HttpClient: REQUEST wss://walp.kube/ws failed with exception: kotlinx.coroutines.JobCancellationException: Parent job is Cancelling; job=JobImpl{Cancelling}@2f08970
Exception doesn't match @Throws-specified class list and thus isn't propagated from Kotlin to Objective-C/Swift as NSError.
It is considered unexpected and unhandled instead. Program will be terminated.
Uncaught Kotlin exception: io.ktor.client.engine.darwin.DarwinHttpRequestException: Exception in http request: Error Domain=NSURLErrorDomain Code=-1202 "The certificate for this server is invalid. You might be connecting to a server that is pretending to be “walp.kube” which could put your confidential information at risk." UserInfo={NSErrorFailingURLStringKey=wss://walp.kube/ws, NSErrorFailingURLKey=wss://walp.kube/ws, NSLocalizedRecoverySuggestion=Would you like to connect to the server anyway?, NSLocalizedDescription=The certificate for this server is invalid. You might be connecting to a server that is pretending to be “walp.kube” which could put your confidential information at risk.}
    at 0   WalletApi                           0x116af7767        kfun:io.ktor.client.engine.darwin.DarwinHttpRequestException#<init>(platform.Foundation.NSError){} + 167 
    at 1   WalletApi                           0x116afcdaf        kfun:io.ktor.client.engine.darwin.$receiveMessage$lambda-0$FUNCTION_REFERENCE$76.$<bridge-UNNNN>invoke(-1:0;-1:1){}#internal + 223 
    at 2   WalletApi                           0x116c9fa1f        ___696f2e6b746f723a6b746f722d636c69656e742d64617277696e_knbridge45_block_invoke + 507 
    at 3   Foundation                          0x1807ec16f        __NSBLOCKOPERATION_IS_CALLING_OUT_TO_A_BLOCK__ + 15 
    at 4   Foundation                          0x1807ec04b        -[NSBlockOperation main] + 99 
    at 5   Foundation                          0x1807ef16f        __NSOPERATION_IS_INVOKING_MAIN__ + 19 
    at 6   Foundation                          0x1807eb1cf        -[NSOperation start] + 759 
    at 7   Foundation                          0x1807efb07        __NSOPERATIONQUEUE_IS_STARTING_AN_OPERATION__ + 19 
    at 8   Foundation                          0x1807ef60f        __NSOQSchedule_f + 179 
    at 9   libdispatch.dylib                   0x106310f9b        _dispatch_block_async_invoke2 + 103 
    at 10  libdispatch.dylib                   0x106301b93        _dispatch_client_callout + 15 
    at 11  libdispatch.dylib                   0x10630489b        _dispatch_continuation_pop + 555 
    at 12  libdispatch.dylib                   0x106303cff        _dispatch_async_redirect_invoke + 695 
    at 13  libdispatch.dylib                   0x106313feb        _dispatch_root_queue_drain + 439 
    at 14  libdispatch.dylib                   0x106314ab7        _dispatch_worker_thread2 + 187 
    at 15  libsystem_pthread.dylib             0x1cc0adb03        _pthread_wqthread + 223 
    at 16  libsystem_pthread.dylib             0x1cc0ac903        start_wqthread + 7 
dyld4 config: DYLD_ROOT_PATH=/Applications/Xcode.app/Contents/Developer/Platforms/iPhoneOS.platform/Library/Developer/CoreSimulator/Profiles/Runtimes/iOS.simruntime/Contents/Resources/RuntimeRoot DYLD_LIBRARY_PATH=/Users/s.iastremskyi/Library/Developer/Xcode/DerivedData/CEXWallet-frzuyzmdwpwcxcbdtqjosexjngpm/Build/Products/Debug-iphonesimulator:/Applications/Xcode.app/Contents/Developer/Platforms/iPhoneOS.platform/Library/Developer/CoreSimulator/Profiles/Runtimes/iOS.simruntime/Contents/Resources/RuntimeRoot/usr/lib/system/introspection DYLD_INSERT_LIBRARIES=/Applications/Xcode.app/Contents/Developer/Platforms/iPhoneOS.platform/Library/Developer/CoreSimulator/Profiles/Runtimes/iOS.simruntime/Contents/Resources/RuntimeRoot/usr/lib/libBacktraceRecording.dylib:/Applications/Xcode.app/Contents/Developer/Platforms/iPhoneOS.platform/Library/Developer/CoreSimulator/Profiles/Runtimes/iOS.simruntime/Contents/Resources/RuntimeRoot/usr/lib/libMainThreadChecker.dylib:/Applications/Xcode.app/Contents/Developer/Platforms/iPhoneOS.platform/Library/Developer/CoreSimulator/Profiles/Runtimes/iOS.simruntime/Contents/Resources/RuntimeRoot/Developer/Library/PrivateFrameworks/DTDDISupport.framework/libViewDebuggerSupport.dylib DYLD_FRAMEWORK_PATH=/Users/s.iastremskyi/Library/Developer/Xcode/DerivedData/CEXWallet-frzuyzmdwpwcxcbdtqjosexjngpm/Build/Products/Debug-iphonesimulator:/Users/s.iastremskyi/Library/Developer/Xcode/DerivedData/CEXWallet-frzuyzmdwpwcxcbdtqjosexjngpm/Build/Products/Debug-iphonesimulator/PackageFrameworks
CoreSimulator 857.7 - Device: iPhone 13 Pro Max (6E9732C3-9A52-46CD-BDA9-9C1F5538EA0B) - Runtime: iOS 15.5 (19F70) - DeviceType: iPhone 13 Pro Max

Client (iOS) configured for trust skip as well:

actual val clientEngine: HttpClientEngine = Darwin.create {

    handleChallenge { session, task, challenge, completionHandler ->
        challenge.protectionSpace.serverTrust?.let {
            if (challenge.protectionSpace.authenticationMethod == NSURLAuthenticationMethodServerTrust) {
                val credential = NSURLCredential.credentialForTrust(it)
                completionHandler(NSURLSessionAuthChallengeUseCredential, credential)
            }
        }
    }
}

Jackson converter: Support requests with Content-Length header

https://youtrack.jetbrains.com/issue/KTOR-4904

Hello,

With Ktor 2.0 release there was a change in default client behavior when handling JSON - changed from setting Content-Length to a Transfer-Encoding: chunked header on the request. Reverting to old behavior is not trivial - we would either need to manually compute the length of the request and explicitly set it on the headers OR write custom Jackson converter that uses TextContent instead of OutputStreamContent. It would be great if end users could select the appropriate behavior without any custom code.

---

Example code included below for reference (introspection query is just a String constant).

v1.6 code

HttpClient(engineFactory = Apache) {
    install(HttpTimeout) {
        connectTimeoutMillis = connectTimeout
        requestTimeoutMillis = readTimeout
    }
    install(feature = JsonFeature)
}.use { client ->
    runBlocking {
        val introspectionResult = try {
            client.post<Map<String, Any?>> {
                url(endpoint)
                contentType(ContentType.Application.Json)
                httpHeaders.forEach { (name, value) ->
                    header(name, value)
                }
                body = mapOf(
                    "query" to INTROSPECTION_QUERY,
                    "operationName" to "IntrospectionQuery"
                )
            }
        } catch (e: Throwable) {
            when (e) {
                is ClientRequestException, is HttpRequestTimeoutException, is UnknownHostException -> throw e
                else -> throw RuntimeException("Unable to run introspection query against the specified endpoint=$endpoint", e)
            }
        }
}

v2.0 code

HttpClient(engineFactory = Apache) {
    install(HttpTimeout) {
        connectTimeoutMillis = connectTimeout
        requestTimeoutMillis = readTimeout
    }
    install(ContentNegotiation) {
        jackson()
    }
}.use { client ->
    runBlocking {
        val introspectionResult = try {
            client.post {
                url(endpoint)
                contentType(ContentType.Application.Json)
                httpHeaders.forEach { (name, value) ->
                    header(name, value)
                }
                setBody(
                    mapOf(
                        "query" to INTROSPECTION_QUERY,
                        "operationName" to "IntrospectionQuery"
                    )
                )
                expectSuccess = true
            }.body<Map<String, Any?>>()
        } catch (e: Throwable) {
            when (e) {
                is ClientRequestException, is HttpRequestTimeoutException, is UnknownHostException -> throw e
                else -> throw RuntimeException("Unable to run introspection query against the specified endpoint=$endpoint", e)
            }
        }
}

Core

The beginning character of encodedPath field(Url class) is wrong when relative path

parseAuthorizationHeader throws ParseException on header value with multiple challenges

NativePRNGNonBlocking is not found, fallback to SHA1PRNG

Remove check for internal class in Select

Docs

Create the migration guide for updating a Ktor project from 2.0.0 to 2.2.0

Documentation doens't match the convert{} extensions in 2.1.0

Ktor install() function errors when installing Mustache integration

https://youtrack.jetbrains.com/issue/KTOR-2434

After reading the docutmentation on using Mustache with Ktor as seen here https://ktor.io/docs/mustache.html . I checked again and it appears that this extends to any time the install() function is called.

Site.kt

 package xyz.qixt
 // General deps
 import io.ktor.server.engine.*
 import io.ktor.server.netty.*
 import io.ktor.application.*
 import io.ktor.features.*
 import io.ktor.response.*
 import io.ktor.routing.*
 // Frontend imports
 import com.github.mustachejava.*
 import io.ktor.mustache.*
 
@Suppress("unused") // Referenced in application.conf
@kotlin.jvm.JvmOverloads

fun main(args: Array<String>) {
     embeddedServer(Netty, port = 8080){}.start()
}
fun Application.pages() {
   install(Mustache) {
         MustacheFactory = DefaultMustacheFactory("views/mustache")
   }
   routing {
         get ("/"){
             val CurrentUser = User("Will")
             call.respond(MustacheContent("index.hbs", mapOf("user" to CurrentUser)))
         }
     }
  }
data class User(val name: String)

build.gradle.kts

import org.jetbrains.kotlin.gradle.dsl.Coroutines
import org.jetbrains.kotlin.gradle.tasks.KotlinCompile

val logback_version: String by project
val ktor_version: String by project
val kotlin_version: String by project

plugins {
    application
    kotlin("jvm") version "1.4.30"
}

group = "xyz.qixt"
version = "0.0.1-SNAPSHOT"

application {
    //mainClassName = "io.ktor.server.netty.EngineMain"
    mainClassName = "xyz.qixt.SiteKt"
}

repositories {
    mavenLocal()
    jcenter()
    maven { url = uri("https://kotlin.bintray.com/ktor") }
    maven { url = uri("https://kotlin.bintray.com/kotlin-js-wrappers") }
}

dependencies {
    implementation("org.jetbrains.kotlin:kotlin-stdlib-jdk8:$kotlin_version")
    implementation("io.ktor:ktor-server-netty:$ktor_version")
    implementation("ch.qos.logback:logback-classic:$logback_version")
    implementation("io.ktor:ktor-server-core:$ktor_version")
    implementation("io.ktor:ktor-html-builder:$ktor_version")
    implementation("org.jetbrains:kotlin-css-jvm:1.0.0-pre.31-kotlin-1.2.41")
    implementation("io.ktor:ktor-mustache:$ktor_version")
    implementation("io.ktor:ktor-server-host-common:$ktor_version")
    testImplementation("io.ktor:ktor-server-tests:$ktor_version")
}

kotlin.sourceSets["main"].kotlin.srcDirs("src")
kotlin.sourceSets["test"].kotlin.srcDirs("test")

sourceSets["main"].resources.srcDirs("resources")
sourceSets["test"].resources.srcDirs("resources")

output/error

src/Site.kt: (28, 5): Not enough information to infer type variable B
src/Site.kt: (28, 13): Unresolved reference: Mustache
src/Site.kt: (29, 9): Variable expected

Explain the pros and cons of each engine

Generator

Wizard: Creating a project with sample code creates `Application.configureRouting` and `ApplicationTest` with unused imports

Support YAML generation in wizard and start.ktor.io

start.ktor.io produces project with compilation errors

Add OpenAPI and Swagger plugins to generator

Replace the Locations plugin with a new Resources plugin

Exclude 2.2.0 from Ktor generator because it's faulty

The Ktor plugin doesn't add any code for the Metrics plugin

Install plugin on the fly stopped working

Generate application module extension even for embeddedServer (in Generator)

Upgrade to the latest Ktor version trashes kotlinx.json import statement

IntelliJ IDEA Plugin

Support StatusPages plugin in generator

Support type highlighting of Yaml files for Ktor in IDE

Support properties completion in ktor's YAML config files in IDE

Add completion and resolve for ktor.application.modules in YAML files

Add inspections for ktor yaml config files in IDE

Support YAML in IDE/editor

"Create Test" action should not configure application in the created test if it's called not from `Application` extension

Module Plugins are not Applied when Generating Test for Endpoint

IntelliJ IDEA extracts a module to an extension function on cancelling

KDoc parameters/tags are not parsed properly in OpenAPI generator

EA: Throwable: Must be executed under progress indicator: com.intellij.openapi.progress.EmptyProgressIndicator@2ff16fee. Please see e.g. ProgressManager.runProcess()

Deduce parameter types from usage in OpenAPI in cases when they are primitive (string, number, integer, boolean)

Support headers in responses in OpenAPI generator

Support full schemas in OpenAPI generator

OpenAPI is incorrectly generated for List<T> respond types (item type is missing)

"Dialog shown not from EDT" and "Read access not allowed here" exceptions when generating tests with extraction in IJ 231

Add Macros to Create Ktor Client with Engine Dependencies

Generating OpenAPI by default and warning level of inspection is too in your face

The IDEA plugin generates code with deprecated API for StatusPages

Naked underscore as a subdomain for Website field leads to error

Wizard: Creating a project with sample code creates `Application.configureRouting` with two `routing` blocks

Feature Name from Source Code is Used for Marketplace

Exceptions at creating a ktor run configuration

https://youtrack.jetbrains.com/issue/KTOR-3399

build 213.5744.8
-go to any project (for example, created sample ktor project)
-go to run configurations
-press +
-select Ktor
Result: the Exception below and others. Also, I've tried to create any other run configuration(spring boot, just to try it, without any reasonable intensions ) and got also the same exception and many others. See log for details.

java.lang.Throwable: Slow operations are prohibited on EDT. See SlowOperations.assertSlowOperationsAreAllowed javadoc.
	at com.intellij.openapi.diagnostic.Logger.error(Logger.java:182)
	at com.intellij.util.SlowOperations.assertSlowOperationsAreAllowed(SlowOperations.java:102)
	at com.intellij.util.indexing.FileBasedIndexImpl.ensureUpToDate(FileBasedIndexImpl.java:784)
	at com.intellij.psi.stubs.StubIndexImpl.getContainingIds(StubIndexImpl.java:514)
	at com.intellij.psi.stubs.StubIndexImpl.processElements(StubIndexImpl.java:318)
	at com.intellij.psi.stubs.StubIndex.getElements(StubIndex.java:100)
	at com.intellij.psi.stubs.StubIndex.getElements(StubIndex.java:88)
	at com.intellij.psi.impl.java.stubs.index.JavaFullClassNameIndex.get(JavaFullClassNameIndex.java:30)
	at com.intellij.psi.impl.file.impl.JavaFileManagerImpl.doFindClasses(JavaFileManagerImpl.java:84)
	at com.intellij.psi.impl.file.impl.JavaFileManagerImpl.findClass(JavaFileManagerImpl.java:110)
	at com.intellij.psi.impl.PsiElementFinderImpl.findClass(PsiElementFinderImpl.java:40)
	at com.intellij.psi.impl.JavaPsiFacadeImpl.doFindClass(JavaPsiFacadeImpl.java:91)
	at com.intellij.psi.impl.JavaPsiFacadeImpl.findClass(JavaPsiFacadeImpl.java:69)
	at com.intellij.jam.JavaLibraryUtils.lambda$getLibraryClassMap$2(JavaLibraryUtils.java:56)
	at com.intellij.util.containers.ConcurrentFactoryMap$2.create(ConcurrentFactoryMap.java:174)
	at com.intellij.util.containers.ConcurrentFactoryMap.get(ConcurrentFactoryMap.java:40)
	at java.base/java.util.concurrent.ConcurrentMap.getOrDefault(ConcurrentMap.java:88)
	at com.intellij.jam.JavaLibraryUtils.hasLibraryClass(JavaLibraryUtils.java:37)
	at io.ktor.initializr.intellij.run.KtorLibraryUtilKt.hasKtorLibraryOnJVM(KtorLibraryUtil.kt:34)
	at io.ktor.initializr.intellij.run.KtorLibraryUtilKt.hasKtorLibrary(KtorLibraryUtil.kt:45)
	at io.ktor.initializr.intellij.run.KtorRunConfigurationEditor$moduleSelector$1.isModuleAccepted(KtorRunConfigurationEditor.kt:50)
	at com.intellij.execution.ui.ConfigurationModuleSelector.reset(ConfigurationModuleSelector.java:136)
	at com.intellij.execution.ui.ConfigurationModuleSelector.reset(ConfigurationModuleSelector.java:123)
	at io.ktor.initializr.intellij.run.KtorRunConfigurationEditor.resetEditorFrom(KtorRunConfigurationEditor.kt:129)
	at io.ktor.initializr.intellij.run.KtorRunConfigurationEditor.resetEditorFrom(KtorRunConfigurationEditor.kt:38)
	at com.intellij.openapi.options.SettingsEditor.lambda$resetFrom$0(SettingsEditor.java:77)
	at com.intellij.openapi.options.SettingsEditor.bulkUpdate(SettingsEditor.java:85)
	at com.intellij.openapi.options.SettingsEditor.resetFrom(SettingsEditor.java:75)
	at com.intellij.execution.impl.ConfigurationSettingsEditor$ConfigToSettingsWrapper.resetEditorFrom(ConfigurationSettingsEditor.java:307)
	at com.intellij.execution.impl.ConfigurationSettingsEditor$ConfigToSettingsWrapper.resetEditorFrom(ConfigurationSettingsEditor.java:290)
	at com.intellij.openapi.options.CompositeSettingsEditor.resetEditorFrom(CompositeSettingsEditor.java:44)
	at com.intellij.execution.impl.ConfigurationSettingsEditorWrapper.resetEditorFrom(ConfigurationSettingsEditorWrapper.java:129)
	at com.intellij.execution.impl.ConfigurationSettingsEditorWrapper.resetEditorFrom(ConfigurationSettingsEditorWrapper.java:31)
	at com.intellij.openapi.options.SettingsEditor.lambda$resetFrom$0(SettingsEditor.java:77)
	at com.intellij.openapi.options.SettingsEditor.bulkUpdate(SettingsEditor.java:85)
	at com.intellij.openapi.options.SettingsEditor.resetFrom(SettingsEditor.java:75)
	at com.intellij.openapi.options.SettingsEditorConfigurable.reset(SettingsEditorConfigurable.java:39)
	at com.intellij.execution.impl.SingleConfigurationConfigurable.reset(SingleConfigurationConfigurable.java:179)
	at com.intellij.execution.impl.SingleConfigurationConfigurable.editSettings(SingleConfigurationConfigurable.java:116)
	at com.intellij.execution.impl.RunConfigurable.createNewConfiguration(RunConfigurable.kt:861)
	at com.intellij.execution.impl.RunConfigurable.createNewConfiguration(RunConfigurable.kt:896)
	at com.intellij.execution.impl.RunConfigurable$MyToolbarAddAction$showAddPopup$popup$1.consume(RunConfigurable.kt:938)
	at com.intellij.execution.impl.RunConfigurable$MyToolbarAddAction$showAddPopup$popup$1.consume(RunConfigurable.kt:909)
	at com.intellij.execution.impl.NewRunConfigurationPopup$5.onChosen(NewRunConfigurationPopup.java:249)
	at com.intellij.ui.popup.tree.TreePopupImpl.handleSelect(TreePopupImpl.java:357)
	at com.intellij.ui.popup.tree.TreePopupImpl$MyMouseListener.mousePressed(TreePopupImpl.java:307)
	at java.desktop/java.awt.AWTEventMulticaster.mousePressed(AWTEventMulticaster.java:288)
	at java.desktop/java.awt.Component.processMouseEvent(Component.java:6651)
	at java.desktop/javax.swing.JComponent.processMouseEvent(JComponent.java:3345)
	at com.intellij.ui.treeStructure.Tree.processMouseEvent(Tree.java:394)
	at java.desktop/java.awt.Component.processEvent(Component.java:6419)
	at java.desktop/java.awt.Container.processEvent(Container.java:2263)
	at java.desktop/java.awt.Component.dispatchEventImpl(Component.java:5029)
	at java.desktop/java.awt.Container.dispatchEventImpl(Container.java:2321)
	at java.desktop/java.awt.Component.dispatchEvent(Component.java:4861)
	at java.desktop/java.awt.LightweightDispatcher.retargetMouseEvent(Container.java:4918)
	at java.desktop/java.awt.LightweightDispatcher.processMouseEvent(Container.java:4544)
	at java.desktop/java.awt.LightweightDispatcher.dispatchEvent(Container.java:4488)
	at java.desktop/java.awt.Container.dispatchEventImpl(Container.java:2307)
	at java.desktop/java.awt.Window.dispatchEventImpl(Window.java:2790)
	at java.desktop/java.awt.Component.dispatchEvent(Component.java:4861)
	at java.desktop/java.awt.EventQueue.dispatchEventImpl(EventQueue.java:778)
	at java.desktop/java.awt.EventQueue$4.run(EventQueue.java:727)
	at java.desktop/java.awt.EventQueue$4.run(EventQueue.java:721)
	at java.base/java.security.AccessController.doPrivileged(Native Method)
	at java.base/java.security.ProtectionDomain$JavaSecurityAccessImpl.doIntersectionPrivilege(ProtectionDomain.java:85)
	at java.base/java.security.ProtectionDomain$JavaSecurityAccessImpl.doIntersectionPrivilege(ProtectionDomain.java:95)
	at java.desktop/java.awt.EventQueue$5.run(EventQueue.java:751)
	at java.desktop/java.awt.EventQueue$5.run(EventQueue.java:749)
	at java.base/java.security.AccessController.doPrivileged(Native Method)
	at java.base/java.security.ProtectionDomain$JavaSecurityAccessImpl.doIntersectionPrivilege(ProtectionDomain.java:85)
	at java.desktop/java.awt.EventQueue.dispatchEvent(EventQueue.java:748)
	at com.intellij.ide.IdeEventQueue.defaultDispatchEvent(IdeEventQueue.java:891)
	at com.intellij.ide.IdeEventQueue.dispatchMouseEvent(IdeEventQueue.java:820)
	at com.intellij.ide.IdeEventQueue._dispatchEvent(IdeEventQueue.java:757)
	at com.intellij.ide.IdeEventQueue.lambda$dispatchEvent$6(IdeEventQueue.java:447)
	at com.intellij.openapi.progress.impl.CoreProgressManager.computePrioritized(CoreProgressManager.java:818)
	at com.intellij.ide.IdeEventQueue.lambda$dispatchEvent$7(IdeEventQueue.java:446)
	at com.intellij.openapi.application.impl.ApplicationImpl.runIntendedWriteActionOnCurrentThread(ApplicationImpl.java:805)
	at com.intellij.ide.IdeEventQueue.dispatchEvent(IdeEventQueue.java:498)
	at java.desktop/java.awt.EventDispatchThread.pumpOneEventForFilters(EventDispatchThread.java:203)
	at java.desktop/java.awt.EventDispatchThread.pumpEventsForFilter(EventDispatchThread.java:124)
	at java.desktop/java.awt.EventDispatchThread.pumpEventsForFilter(EventDispatchThread.java:117)
	at java.desktop/java.awt.WaitDispatchSupport$2.run(WaitDispatchSupport.java:190)
	at java.desktop/java.awt.WaitDispatchSupport$4.run(WaitDispatchSupport.java:235)
	at java.desktop/java.awt.WaitDispatchSupport$4.run(WaitDispatchSupport.java:233)
	at java.base/java.security.AccessController.doPrivileged(Native Method)
	at java.desktop/java.awt.WaitDispatchSupport.enter(WaitDispatchSupport.java:233)
	at java.desktop/java.awt.Dialog.show(Dialog.java:1070)
	at com.intellij.openapi.ui.impl.DialogWrapperPeerImpl$MyDialog.show(DialogWrapperPeerImpl.java:701)
	at com.intellij.openapi.ui.impl.DialogWrapperPeerImpl.show(DialogWrapperPeerImpl.java:437)
	at com.intellij.openapi.ui.DialogWrapper.doShow(DialogWrapper.java:1671)
	at com.intellij.openapi.ui.DialogWrapper.show(DialogWrapper.java:1629)
	at com.intellij.execution.actions.EditRunConfigurationsAction.actionPerformed(EditRunConfigurationsAction.java:30)
	at com.intellij.openapi.actionSystem.ex.ActionUtil.lambda$performActionDumbAwareWithCallbacks$4(ActionUtil.java:244)
	at com.intellij.openapi.actionSystem.ex.ActionUtil.performDumbAwareWithCallbacks(ActionUtil.java:265)
	at com.intellij.openapi.actionSystem.ex.ActionUtil.performActionDumbAwareWithCallbacks(ActionUtil.java:244)
	at com.intellij.ui.popup.ActionPopupStep.performAction(ActionPopupStep.java:253)
	at com.intellij.ui.popup.ActionPopupStep.performAction(ActionPopupStep.java:243)
	at com.intellij.ui.popup.ActionPopupStep.lambda$onChosen$2(ActionPopupStep.java:229)
	at com.intellij.openapi.application.TransactionGuardImpl.performUserActivity(TransactionGuardImpl.java:94)
	at com.intellij.ui.popup.AbstractPopup.lambda$dispose$18(AbstractPopup.java:1511)
	at com.intellij.util.ui.EdtInvocationManager.invokeLaterIfNeeded(EdtInvocationManager.java:101)
	at com.intellij.ide.IdeEventQueue.ifFocusEventsInTheQueue(IdeEventQueue.java:186)
	at com.intellij.ide.IdeEventQueue.executeWhenAllFocusEventsLeftTheQueue(IdeEventQueue.java:140)
	at com.intellij.openapi.wm.impl.FocusManagerImpl.doWhenFocusSettlesDown(FocusManagerImpl.java:175)
	at com.intellij.openapi.wm.impl.IdeFocusManagerImpl.doWhenFocusSettlesDown(IdeFocusManagerImpl.java:36)
	at com.intellij.ui.popup.AbstractPopup.dispose(AbstractPopup.java:1508)
	at com.intellij.ui.popup.WizardPopup.dispose(WizardPopup.java:164)
	at com.intellij.ui.popup.list.ListPopupImpl.dispose(ListPopupImpl.java:326)
	at com.intellij.ui.popup.PopupFactoryImpl$ActionGroupPopup.dispose(PopupFactoryImpl.java:271)
	at com.intellij.openapi.util.ObjectTree.runWithTrace(ObjectTree.java:136)
	at com.intellij.openapi.util.ObjectTree.executeAll(ObjectTree.java:166)
	at com.intellij.openapi.util.Disposer.dispose(Disposer.java:169)
	at com.intellij.openapi.util.Disposer.dispose(Disposer.java:157)
	at com.intellij.ui.popup.WizardPopup.disposeAllParents(WizardPopup.java:268)
	at com.intellij.ui.popup.list.ListPopupImpl.handleNextStep(ListPopupImpl.java:433)
	at com.intellij.ui.popup.list.ListPopupImpl._handleSelect(ListPopupImpl.java:405)
	at com.intellij.ui.popup.list.ListPopupImpl.handleSelect(ListPopupImpl.java:361)
	at com.intellij.ui.popup.PopupFactoryImpl$ActionGroupPopup.handleSelect(PopupFactoryImpl.java:288)
	at com.intellij.ui.popup.list.ListPopupImpl$MyMouseListener.mouseReleased(ListPopupImpl.java:618)
	at java.desktop/java.awt.AWTEventMulticaster.mouseReleased(AWTEventMulticaster.java:298)
	at java.desktop/java.awt.Component.processMouseEvent(Component.java:6654)
	at java.desktop/javax.swing.JComponent.processMouseEvent(JComponent.java:3345)
	at com.intellij.ui.popup.list.ListPopupImpl$MyList.processMouseEvent(ListPopupImpl.java:695)
	at java.desktop/java.awt.Component.processEvent(Component.java:6419)
	at java.desktop/java.awt.Container.processEvent(Container.java:2263)
	at java.desktop/java.awt.Component.dispatchEventImpl(Component.java:5029)
	at java.desktop/java.awt.Container.dispatchEventImpl(Container.java:2321)
	at java.desktop/java.awt.Component.dispatchEvent(Component.java:4861)
	at java.desktop/java.awt.LightweightDispatcher.retargetMouseEvent(Container.java:4918)
	at java.desktop/java.awt.LightweightDispatcher.processMouseEvent(Container.java:4547)
	at java.desktop/java.awt.LightweightDispatcher.dispatchEvent(Container.java:4488)
	at java.desktop/java.awt.Container.dispatchEventImpl(Container.java:2307)
	at java.desktop/java.awt.Window.dispatchEventImpl(Window.java:2790)
	at java.desktop/java.awt.Component.dispatchEvent(Component.java:4861)
	at java.desktop/java.awt.EventQueue.dispatchEventImpl(EventQueue.java:778)
	at java.desktop/java.awt.EventQueue$4.run(EventQueue.java:727)
	at java.desktop/java.awt.EventQueue$4.run(EventQueue.java:721)
	at java.base/java.security.AccessController.doPrivileged(Native Method)
	at java.base/java.security.ProtectionDomain$JavaSecurityAccessImpl.doIntersectionPrivilege(ProtectionDomain.java:85)
	at java.base/java.security.ProtectionDomain$JavaSecurityAccessImpl.doIntersectionPrivilege(ProtectionDomain.java:95)
	at java.desktop/java.awt.EventQueue$5.run(EventQueue.java:751)
	at java.desktop/java.awt.EventQueue$5.run(EventQueue.java:749)
	at java.base/java.security.AccessController.doPrivileged(Native Method)
	at java.base/java.security.ProtectionDomain$JavaSecurityAccessImpl.doIntersectionPrivilege(ProtectionDomain.java:85)
	at java.desktop/java.awt.EventQueue.dispatchEvent(EventQueue.java:748)
	at com.intellij.ide.IdeEventQueue.defaultDispatchEvent(IdeEventQueue.java:891)
	at com.intellij.ide.IdeEventQueue.dispatchMouseEvent(IdeEventQueue.java:820)
	at com.intellij.ide.IdeEventQueue._dispatchEvent(IdeEventQueue.java:757)
	at com.intellij.ide.IdeEventQueue.lambda$dispatchEvent$6(IdeEventQueue.java:447)
	at com.intellij.openapi.progress.impl.CoreProgressManager.computePrioritized(CoreProgressManager.java:818)
	at com.intellij.ide.IdeEventQueue.lambda$dispatchEvent$7(IdeEventQueue.java:446)
	at com.intellij.openapi.application.impl.ApplicationImpl.runIntendedWriteActionOnCurrentThread(ApplicationImpl.java:805)
	at com.intellij.ide.IdeEventQueue.dispatchEvent(IdeEventQueue.java:498)
	at java.desktop/java.awt.EventDispatchThread.pumpOneEventForFilters(EventDispatchThread.java:203)
	at java.desktop/java.awt.EventDispatchThread.pumpEventsForFilter(EventDispatchThread.java:124)
	at java.desktop/java.awt.EventDispatchThread.pumpEventsForHierarchy(EventDispatchThread.java:113)
	at java.desktop/java.awt.EventDispatchThread.pumpEvents(EventDispatchThread.java:109)
	at java.desktop/java.awt.EventDispatchThread.pumpEvents(EventDispatchThread.java:101)
	at java.desktop/java.awt.EventDispatchThread.run(EventDispatchThread.java:90)

Consider showing warning on openapi plugin in IDE if there is no openapi documentation file is not there

The generator adds the deprecated Locations plugin when installing OAuth

"Main method, not found in class" when main is a suspend function

Selecting the 'WebSocket-Server' endpoint type in the Endpoints tool window clears all websocket endpoints

"Could not convert string to current locale" error when path contains emoji

Autoimport for DefaultHeaders conflict with Netty

Run configuration for newly created projects

Support `io.ktor.server.response.ResponseHeaders` to make possible information about headers in responses in OpenAPI generator

Ktor wizard generates the yellow code

An exception is thrown in Endpoints View and OpenAPI generate action for `handle` route

Intention `Generate open API documentation for current module` duplicates in embedded server entry point

Kdocs with simple tags are invalid in OpenAPI generator.

Add Client Plugins Completion

After selecting Generate OpenAPI, IDEA incorrectly shows that documentation already exists

Support wildcard and tailcard parameters in Swagger

Inspection for the case if embeddedServer is used without Application.module function reference

Include whole (ktor module) set of configured plugins in generated Ktor routing tests

Migration to the latest version of Ktor doesn't work

Avoid using Kotlin structuralSearch submodule directly

NPE in KtorRoutingVisitor in IJ 2022.3 EAP

https://youtrack.jetbrains.com/issue/KTOR-5052

Open Endpoints tool window
Search for /api/search/plugins

java.lang.NullPointerException
	at io.ktor.ide.KtorRoutingVisitor.processLastArgumentsBodyIfRouteExtensionLambda(KtorUrlResolver.kt:150)
	at io.ktor.ide.KtorRoutingVisitor.visitCallExpression(KtorUrlResolver.kt:188)
	at org.jetbrains.uast.kotlin.KotlinUFunctionCallExpression.accept(KotlinUFunctionCallExpression.kt:176)
	at org.jetbrains.uast.UReturnExpression.accept(UReturnExpression.kt:22)
	at org.jetbrains.uast.internal.ImplementationUtilsKt.acceptList(implementationUtils.kt:14)
	at org.jetbrains.uast.UBlockExpression.accept(UBlockExpression.kt:21)
	at org.jetbrains.uast.UMethod.accept(UMethod.kt:45)
	at io.ktor.ide.KtorRoutingVisitor.visitCallExpression(KtorUrlResolver.kt:197)
	at org.jetbrains.uast.kotlin.KotlinUFunctionCallExpression.accept(KotlinUFunctionCallExpression.kt:176)
	at org.jetbrains.uast.internal.ImplementationUtilsKt.acceptList(implementationUtils.kt:14)
	at org.jetbrains.uast.UBlockExpression.accept(UBlockExpression.kt:21)
	at org.jetbrains.uast.ULambdaExpression.accept(ULambdaExpression.kt:40)
	at org.jetbrains.uast.internal.ImplementationUtilsKt.acceptList(implementationUtils.kt:14)
	at org.jetbrains.uast.kotlin.KotlinUFunctionCallExpression.accept(KotlinUFunctionCallExpression.kt:180)
	at org.jetbrains.uast.internal.ImplementationUtilsKt.acceptList(implementationUtils.kt:14)
	at org.jetbrains.uast.UBlockExpression.accept(UBlockExpression.kt:21)
	at org.jetbrains.uast.ULambdaExpression.accept(ULambdaExpression.kt:40)
	at org.jetbrains.uast.internal.ImplementationUtilsKt.acceptList(implementationUtils.kt:14)
	at org.jetbrains.uast.kotlin.KotlinUFunctionCallExpression.accept(KotlinUFunctionCallExpression.kt:180)
	at io.ktor.ide.KtorServerEndpointsProviderKt$collectUrlMappingsInside$processor$1.invoke(KtorServerEndpointsProvider.kt:95)
	at io.ktor.ide.KtorServerEndpointsProviderKt$collectUrlMappingsInside$processor$1.invoke(KtorServerEndpointsProvider.kt:94)
	at io.ktor.ide.KtorRoutingCallsProcessor.visitCallExpression(KtorServerEndpointsProvider.kt:78)
	at org.jetbrains.uast.kotlin.KotlinUFunctionCallExpression.accept(KotlinUFunctionCallExpression.kt:176)
	at org.jetbrains.uast.internal.ImplementationUtilsKt.acceptList(implementationUtils.kt:14)
	at org.jetbrains.uast.UBlockExpression.accept(UBlockExpression.kt:21)
	at org.jetbrains.uast.ULambdaExpression.accept(ULambdaExpression.kt:40)
	at org.jetbrains.uast.internal.ImplementationUtilsKt.acceptList(implementationUtils.kt:14)
	at org.jetbrains.uast.kotlin.KotlinUFunctionCallExpression.accept(KotlinUFunctionCallExpression.kt:180)
	at org.jetbrains.uast.UQualifiedReferenceExpression.accept(UQualifiedReferenceExpression.kt:33)
	at org.jetbrains.uast.UReturnExpression.accept(UReturnExpression.kt:22)
	at org.jetbrains.uast.internal.ImplementationUtilsKt.acceptList(implementationUtils.kt:14)
	at org.jetbrains.uast.UBlockExpression.accept(UBlockExpression.kt:21)
	at org.jetbrains.uast.ULambdaExpression.accept(ULambdaExpression.kt:40)
	at org.jetbrains.uast.internal.ImplementationUtilsKt.acceptList(implementationUtils.kt:14)
	at org.jetbrains.uast.kotlin.KotlinUFunctionCallExpression.accept(KotlinUFunctionCallExpression.kt:180)
	at org.jetbrains.uast.internal.ImplementationUtilsKt.acceptList(implementationUtils.kt:14)
	at org.jetbrains.uast.UBlockExpression.accept(UBlockExpression.kt:21)
	at org.jetbrains.uast.UMethod.accept(UMethod.kt:45)
	at org.jetbrains.uast.internal.ImplementationUtilsKt.acceptList(implementationUtils.kt:14)
	at org.jetbrains.uast.kotlin.AbstractKotlinUClass.accept(AbstractKotlinUClass.kt:99)
	at org.jetbrains.uast.internal.ImplementationUtilsKt.acceptList(implementationUtils.kt:14)
	at org.jetbrains.uast.UFile.accept(UFile.kt:89)
	at io.ktor.ide.KtorServerEndpointsProviderKt.collectUrlMappingsInside(KtorServerEndpointsProvider.kt:97)
	at io.ktor.ide.KtorServerEndpointsProviderKt.collectUrlMappingsInside$default(KtorServerEndpointsProvider.kt:91)
	at io.ktor.ide.KtorServerEndpointsProvider.getEndpoints(KtorServerEndpointsProvider.kt:46)
	at io.ktor.ide.KtorServerEndpointsProvider.getEndpoints(KtorServerEndpointsProvider.kt:21)
	at com.intellij.microservices.ui.flat.FlatEndpointGroup.getEndpoints(EndpointsCursor.kt:187)
	at com.intellij.microservices.ui.flat.EndpointsCursorKt.getProviderEndpoints(EndpointsCursor.kt:153)
	at com.intellij.microservices.ui.flat.EndpointsCursorKt.access$getProviderEndpoints(EndpointsCursor.kt:1)
	at com.intellij.microservices.ui.flat.EndpointsCursor$endpointsMap$1.invoke(EndpointsCursor.kt:50)
	at com.intellij.microservices.ui.flat.EndpointsCursor$endpointsMap$1.invoke(EndpointsCursor.kt:47)
	at com.intellij.microservices.ui.flat.EndpointsCursor.endpointsMap$lambda$2(EndpointsCursor.kt:47)
	at com.intellij.util.containers.ConcurrentFactoryMap$2.create(ConcurrentFactoryMap.java:174)
	at com.intellij.util.containers.ConcurrentFactoryMap.get(ConcurrentFactoryMap.java:40)
	at java.base/java.util.concurrent.ConcurrentMap.getOrDefault(ConcurrentMap.java:88)
	at com.intellij.microservices.ui.flat.EndpointsCursor$request$allSequence$3.invoke(EndpointsCursor.kt:63)
	at com.intellij.microservices.ui.flat.EndpointsCursor$request$allSequence$3.invoke(EndpointsCursor.kt:63)
	at kotlin.sequences.FlatteningSequence$iterator$1.ensureItemIterator(Sequences.kt:315)
	at kotlin.sequences.FlatteningSequence$iterator$1.hasNext(Sequences.kt:303)
	at kotlin.sequences.FilteringSequence$iterator$1.calcNext(Sequences.kt:169)
	at kotlin.sequences.FilteringSequence$iterator$1.hasNext(Sequences.kt:194)
	at kotlin.sequences.DropWhileSequence$iterator$1.hasNext(Sequences.kt:557)
	at kotlin.sequences.TransformingSequence$iterator$1.hasNext(Sequences.kt:214)
	at kotlin.sequences.SequenceBuilderIterator.hasNext(SequenceBuilder.kt:115)
	at kotlin.sequences.TakeSequence$iterator$1.hasNext(Sequences.kt:421)
	at kotlin.sequences.TransformingSequence$iterator$1.hasNext(Sequences.kt:214)
	at kotlin.sequences.SequencesKt___SequencesKt.toCollection(_Sequences.kt:787)
	at kotlin.sequences.SequencesKt___SequencesKt.toMutableList(_Sequences.kt:817)
	at kotlin.sequences.SequencesKt___SequencesKt.toList(_Sequences.kt:808)
	at com.intellij.microservices.ui.flat.EndpointsView.load$lambda$18(EndpointsView.kt:773)
	at com.intellij.openapi.application.impl.NonBlockingReadActionImpl$OTelMonitor.callWrapped(NonBlockingReadActionImpl.java:746)
	at com.intellij.openapi.application.impl.NonBlockingReadActionImpl$OTelMonitor$MonitoredComputation.call(NonBlockingReadActionImpl.java:778)
	at com.intellij.openapi.application.impl.NonBlockingReadActionImpl$Submission.insideReadAction(NonBlockingReadActionImpl.java:573)
	at com.intellij.openapi.application.impl.NonBlockingReadActionImpl$Submission.lambda$attemptComputation$3(NonBlockingReadActionImpl.java:537)
	at com.intellij.openapi.application.impl.ApplicationImpl.tryRunReadAction(ApplicationImpl.java:1086)

Fix ActionUpdateThread is missing(Inspection check)

Generate OpenAPI Documentation is reported multiple times.

Support respondFile in OpenAPI documentation

Support optional path parameters in IDE

Wizard: Do not include transitive dependency `kotlinx:kotlinx-html-jvm` in build file

Server

No way getting client's source address from IP packet

Intergate Swagger UI Hosting as Ktor Feature

https://youtrack.jetbrains.com/issue/KTOR-774

This issue was imported from GitHub issue: https://github.com/ktorio/ktor/issues/453

It would be really nice if Ktor could support hosting a Swagger UI that is generated from your routes configuration.

For example, the following could be used to generate a Swagger UI.

data class PetModel(val id: Int?, val name: String)

data class PetsModel(val pets: MutableList<PetModel>)

val data = PetsModel(mutableListOf(PetModel(1, "max"), PetModel(2, "moritz")))
fun newId() = ((data.pets.map { it.id ?: 0 }.max()) ?: 0) + 1

@Group("pet operations")
@Location("/pets/{id}")
class pet(val id: Int)

@Group("pet operations")
@Location("/pets")
class pets

@Group("debug")
@Location("/request/info")
class requestInfo

@Group("debug")
@Location("/request/withHeader")
class withHeader

class Header(val optionalHeader: String?, val mandatoryHeader: Int)

@Group("debug")
@Location("/request/withQueryParameter")
class withQueryParameter

class QueryParameter(val optionalParameter: String?, val mandatoryParameter: Int)

fun main(args: Array<String>) {
    val server = embeddedServer(Netty, getInteger("server.port", 8080)) {
        install(DefaultHeaders)
        install(Compression)
        install(CallLogging)
        install(ContentNegotiation) {
            gson {
                setPrettyPrinting()
            }
        }
        install(Locations)
        install(SwaggerSupport) {
            forwardRoot = true
            swagger.info = Information(
                version = "0.1",
                title = "sample api implemented in ktor",
                description = "This is a sample which combines [ktor](https://github.com/Kotlin/ktor) with [swaggerUi](https://swagger.io/). You find the sources on [github](https://github.com/nielsfalk/ktor-swagger)",
                contact = Contact(
                    name = "Niels Falk",
                    url = "https://nielsfalk.de"
                )
            )
        }
        routing {
            get<pets>("all".responds(ok<PetsModel>())) {
                call.respond(data)
            }
            post<pets, PetModel>("create".responds(ok<PetModel>())) { _, entity ->
                // http201 would be better but there is no way to do this see org.jetbrains.ktor.gson.GsonSupport.renderJsonContent
                call.respond(entity.copy(id = newId()).apply {
                    data.pets.add(this)
                })
            }
            get<pet>("find".responds(ok<PetModel>(), notFound())) { params ->
                data.pets.find { it.id == params.id }
                    ?.let {
                        call.respond(it)
                    }
            }
            put<pet, PetModel>("update".responds(ok<PetModel>(), notFound())) { params, entity ->
                if (data.pets.removeIf { it.id == params.id && it.id == entity.id }) {
                    data.pets.add(entity)
                    call.respond(entity)
                }
            }
            delete<pet>("delete".responds(ok<Unit>(), notFound())) { params ->
                if (data.pets.removeIf { it.id == params.id }) {
                    call.respond(Unit)
                }
            }
            get<requestInfo>(
                responds(ok<Unit>()),
                respondRequestDetails()
            )
            get<withQueryParameter>(
                responds(ok<Unit>())
                    .parameter<QueryParameter>(),
                respondRequestDetails()
            )
            get<withHeader>(
                responds(ok<Unit>())
                    .header<Header>(),
                respondRequestDetails()
            )
        }
    }
    server.start(wait = true)
}

fun respondRequestDetails(): suspend PipelineContext<Unit, ApplicationCall>.(Any) -> Unit {
    return {
        call.respond(
            mapOf(
                "parameter" to call.parameters,
                "header" to call.request.headers
            ).format()
        )
    }
}

private fun Map<String, StringValues>.format() =
    mapValues {
        it.value.toMap()
            .flatMap { (key, value) -> value.map { key to it } }
            .map { (key, value) -> "$key: $value" }
            .joinToString(separator = ",\n")
    }
        .map { (key, value) -> "$key:\n$value" }
        .joinToString(separator = "\n\n")

This is the swagger UI generated from the above.

I spent today overhauling @nielsfalk's project ktor-swagger to use the newest version of Ktor and also use Gradle to build the application PR here.

I think this project has quite a bit of potential and could satisfy a need in the community by allowing for a fast way to create documentation for API's written using Ktor.

If the Ktor team would like to adopt this project as a feature, I'm happy to try to make the port from the external project it is today into this repository.

If the interest does not exist to adopt a new feature, I totally understand. The concern that I have with publishing this myself (or with @nielsfalk assistance) is the issue of incompatible breaking changes in Ktor (as Ktor is pre-1.0).

I open the floor to the developers of this project. I'd love to see this integrated as a fully supported feature, but I understand if this is outside the scope of this project.

Support serving OpenAPI from resources

Restoring thread context elements when directly resuming to parent is broken

Inconsistency among server engines when determining port/host of an incoming request

ApplicationCall.respondRedirect should have overload for Url

Add a way to get a client's port

Rate-Limit Support on Server

Add a method that returns a list of child routes recursively

Netty: ApplicationStarted event is fired before the server starts accepting connections

https://youtrack.jetbrains.com/issue/KTOR-4259

We use ktor in our application and have written a set of integration tests that utilize the ktor client to connect to our server. These recently started failing for me on my mac and I noticed that the ApplicationStarted monitor was notified but the server is rejecting the connection. I have created a minimal example in the following repo [1]. I have found I need to increase the client delay ms field to around 5500 in order for this test to pass on my macbook. On my PC this is fine with 1ms of delay.

System: macOS 11.6.5, 2.4GHz 8-core Intel Core i9, 64 GB RAM, kotlin version 1.6.21, ktor version 2.0.1

Steps to reproduce:
1. Clone repo
2. mvn test

Expected:

Both assert pass

Actual:

The client receives an exception,

java.net.ConnectException: Connection refused
	at java.base/sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
	at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:777)
	at io.ktor.network.sockets.SocketImpl.connect$ktor_network(SocketImpl.kt:50)
	at io.ktor.network.sockets.SocketImpl$connect$1.invokeSuspend(SocketImpl.kt)
	(Coroutine boundary)
	at io.ktor.client.engine.cio.Endpoint.execute(Endpoint.kt:76)
	at io.ktor.client.engine.cio.CIOEngine.execute(CIOEngine.kt:80)
	at io.ktor.client.engine.HttpClientEngine$executeWithinCallContext$2.invokeSuspend(HttpClientEngine.kt:97)
	at io.ktor.client.engine.HttpClientEngine$DefaultImpls.executeWithinCallContext(HttpClientEngine.kt:98)
	at io.ktor.client.engine.HttpClientEngine$install$1.invokeSuspend(HttpClientEngine.kt:68)
	at io.ktor.client.plugins.HttpSend$DefaultSender.execute(HttpSend.kt:135)
	at io.ktor.client.plugins.HttpRedirect$Plugin$install$1.invokeSuspend(HttpRedirect.kt:61)
	at io.ktor.client.plugins.HttpCallValidator$Companion$install$3.invokeSuspend(HttpCallValidator.kt:149)
	at io.ktor.client.plugins.HttpSend$Plugin$install$1.invokeSuspend(HttpSend.kt:101)
	at io.ktor.client.plugins.HttpCallValidator$Companion$install$1.invokeSuspend(HttpCallValidator.kt:125)
	at io.ktor.client.plugins.HttpRequestLifecycle$Plugin$install$1.invokeSuspend(HttpRequestLifecycle.kt:35)
	at io.ktor.client.statement.HttpStatement.executeUnsafe(HttpStatement.kt:107)
	at io.ktor.client.statement.HttpStatement.execute(HttpStatement.kt:46)
	at KtorClientTest$getData$2$1.invokeSuspend(KtorTest.kt:96)
Caused by: java.net.ConnectException: Connection refused
	at java.base/sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
	at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:777)
	at io.ktor.network.sockets.SocketImpl.connect$ktor_network(SocketImpl.kt:50)
	at io.ktor.network.sockets.SocketImpl$connect$1.invokeSuspend(SocketImpl.kt)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
	at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:106)
	at kotlinx.coroutines.internal.LimitedDispatcher.run(LimitedDispatcher.kt:42)
	at kotlinx.coroutines.scheduling.TaskImpl.run(Tasks.kt:95)
	at kotlinx.coroutines.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:570)
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.executeTask(CoroutineScheduler.kt:749)
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.runWorker(CoroutineScheduler.kt:677)
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:664)

[1] https://github.com/botscholar-scott/ktor-rejected-test

Application data in OAuth State parameter

Not calling call.respond() at server results in 404 for the client

Allow nested authentications to be combined using AND

The swaggerUI plugin should be placed in the io.ktor.server.plugins.swagger package

The default path to an OpenAPI specification doesn't work for the 'openAPI' plugin

JWT: JWTPayloadHolder.getListClaim() throws NPE when specified claim is absent

SessionTransportTransformerMessageAuthentication: Comparison of digests fails when there is a space in a value

Add Server BearerAuthenticationProvider

Merged config: "Property *.size not found" error when calling `configList` method on an array property

https://youtrack.jetbrains.com/issue/KTOR-5143

Given the following HOCON config:

some {
  arr = [1, 2, 3]
}

To reproduce run the following code on a server that uses the above config:

environment.config.configList("some.arr")

As a result, an unexpected ApplicationConfigurationException is thrown:

Exception in thread "main" io.ktor.server.config.ApplicationConfigurationException: Property some.arr.size not found.
	at io.ktor.server.config.MapApplicationConfig.configList(MapApplicationConfig.kt:57)
	at io.ktor.server.config.MergedApplicationConfig.configList(MergedApplicationConfig.kt:37)
	at EngineMainKt.module(EngineMain.kt:6)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/java.lang.reflect.Method.invoke(Method.java:566)
	at kotlin.reflect.jvm.internal.calls.CallerImpl$Method.callMethod(CallerImpl.kt:97)
	at kotlin.reflect.jvm.internal.calls.CallerImpl$Method$Static.call(CallerImpl.kt:106)
	at kotlin.reflect.jvm.internal.KCallableImpl.call(KCallableImpl.kt:108)
	at kotlin.reflect.jvm.internal.KCallableImpl.callDefaultMethod$kotlin_reflection(KCallableImpl.kt:159)
	at kotlin.reflect.jvm.internal.KCallableImpl.callBy(KCallableImpl.kt:112)
	at io.ktor.server.engine.internal.CallableUtilsKt.callFunctionWithInjection(CallableUtils.kt:119)
	at io.ktor.server.engine.internal.CallableUtilsKt.executeModuleFunction(CallableUtils.kt:36)
	at io.ktor.server.engine.ApplicationEngineEnvironmentReloading$launchModuleByName$1.invoke(ApplicationEngineEnvironmentReloading.kt:335)
	at io.ktor.server.engine.ApplicationEngineEnvironmentReloading$launchModuleByName$1.invoke(ApplicationEngineEnvironmentReloading.kt:334)
	at io.ktor.server.engine.ApplicationEngineEnvironmentReloading.avoidingDoubleStartupFor(ApplicationEngineEnvironmentReloading.kt:359)
	at io.ktor.server.engine.ApplicationEngineEnvironmentReloading.launchModuleByName(ApplicationEngineEnvironmentReloading.kt:334)
	at io.ktor.server.engine.ApplicationEngineEnvironmentReloading.access$launchModuleByName(ApplicationEngineEnvironmentReloading.kt:32)
	at io.ktor.server.engine.ApplicationEngineEnvironmentReloading$instantiateAndConfigureApplication$1.invoke(ApplicationEngineEnvironmentReloading.kt:315)
	at io.ktor.server.engine.ApplicationEngineEnvironmentReloading$instantiateAndConfigureApplication$1.invoke(ApplicationEngineEnvironmentReloading.kt:313)
	at io.ktor.server.engine.ApplicationEngineEnvironmentReloading.avoidingDoubleStartup(ApplicationEngineEnvironmentReloading.kt:341)
	at io.ktor.server.engine.ApplicationEngineEnvironmentReloading.instantiateAndConfigureApplication(ApplicationEngineEnvironmentReloading.kt:313)
	at io.ktor.server.engine.ApplicationEngineEnvironmentReloading.createApplication(ApplicationEngineEnvironmentReloading.kt:150)
	at io.ktor.server.engine.ApplicationEngineEnvironmentReloading.start(ApplicationEngineEnvironmentReloading.kt:280)
	at io.ktor.server.netty.NettyApplicationEngine.start(NettyApplicationEngine.kt:211)
	at io.ktor.server.netty.EngineMain.main(EngineMain.kt:26)
	at EngineMainKt.main(EngineMain.kt:3)

Add the ability to access the route inside a route-scoped plugin

StatusPages can't handle errors in HTML template

https://youtrack.jetbrains.com/issue/KTOR-5107

Given the following code

fun main() {
    embeddedServer(Netty, port = 8080, host = "0.0.0.0", module = Application::module)
        .start(wait = true)
}

class MyTemplate : Template<HTML> {
    override fun HTML.apply() {
        head {
            title("Minimum Working Example")
        }
        body {
            throw Exception("Error")
        }
    }
}

fun Application.module() {
    install(Sessions) {
        cookie<String>("SESSION", SessionStorageMemory()) {
            cookie.extensions["SameSite"] = "lax"
        }
    }

    install(StatusPages) {
        exception<Throwable> { call, cause ->
            call.respond(HttpStatusCode.InternalServerError, cause.message.toString())
        }
    }

    routing {
        get("/") {
            call.respondHtmlTemplate(MyTemplate()) {}
        }
    }
}

There seems to be no way to check for already sent headers before trying to set cookies on the response sent which results in the error

Headers can no longer be set because response was already completed

It appears the header for status code was already sent by the point the intercept happens.

What is the correct way to do this, or alternatively is there a way to implement a check if the headers were already sent and then abort the cookie setting?

2022-11-04 14:47:43.202 [main] INFO  ktor.application - Autoreload is disabled because the development mode is off.
2022-11-04 14:47:43.609 [main] INFO  ktor.application - Application started in 0.467 seconds.
2022-11-04 14:47:43.950 [DefaultDispatcher-worker-2] INFO  ktor.application - Responding at http://127.0.0.1:8080
2022-11-04 14:47:45.297 [eventLoopGroupProxy-4-1] DEBUG ktor.application - Failed to lookup session: Session cdad17cf51193d184020bff9a4491f8f not found. The session id is wrong or outdated.
2022-11-04 14:47:45.346 [eventLoopGroupProxy-4-1] ERROR ktor.application - 500 Internal Server Error: GET - /
java.lang.UnsupportedOperationException: Headers can no longer be set because response was already completed
	at io.ktor.server.netty.http1.NettyHttp1ApplicationResponse$headers$1.engineAppendHeader(NettyHttp1ApplicationResponse.kt:42)
	at io.ktor.server.response.ResponseHeaders.append(ResponseHeaders.kt:57)
	at io.ktor.server.response.ResponseHeaders.append$default(ResponseHeaders.kt:48)
	at io.ktor.server.response.ResponseCookies.append(ResponseCookies.kt:33)
	at io.ktor.server.sessions.SessionTransportCookie.clear(SessionTransportCookie.kt:57)
	at io.ktor.server.sessions.SessionDataKt.sendSessionData(SessionData.kt:151)
	at io.ktor.server.sessions.SessionsKt$Sessions$2$2.invokeSuspend(Sessions.kt:59)
	at io.ktor.server.sessions.SessionsKt$Sessions$2$2.invoke(Sessions.kt)
	at io.ktor.server.sessions.SessionsKt$Sessions$2$2.invoke(Sessions.kt)
	at io.ktor.server.sessions.BeforeSend$install$1.invokeSuspend(Sessions.kt:14)
	at io.ktor.server.sessions.BeforeSend$install$1.invoke(Sessions.kt)
	at io.ktor.server.sessions.BeforeSend$install$1.invoke(Sessions.kt)
	at io.ktor.util.pipeline.SuspendFunctionGun.loop(SuspendFunctionGun.kt:123)
	at io.ktor.util.pipeline.SuspendFunctionGun.proceed(SuspendFunctionGun.kt:81)
	at io.ktor.util.pipeline.SuspendFunctionGun.execute$ktor_utils(SuspendFunctionGun.kt:101)
	at io.ktor.util.pipeline.Pipeline.execute(Pipeline.kt:77)
	at ApplicationKt$module$2$1.invokeSuspend(Application.kt:58)
	at ApplicationKt$module$2$1.invoke(Application.kt)
	at ApplicationKt$module$2$1.invoke(Application.kt)
	at io.ktor.server.plugins.statuspages.StatusPagesKt$StatusPages$2$2$1.invokeSuspend(StatusPages.kt:68)
	at io.ktor.server.plugins.statuspages.StatusPagesKt$StatusPages$2$2$1.invoke(StatusPages.kt)
	at io.ktor.server.plugins.statuspages.StatusPagesKt$StatusPages$2$2$1.invoke(StatusPages.kt)
	at io.ktor.server.logging.EmptyMDCProvider.withMDCBlock(Logging.kt:27)
	at io.ktor.server.plugins.statuspages.StatusPagesKt$StatusPages$2$2.invokeSuspend(StatusPages.kt:67)
	at io.ktor.server.plugins.statuspages.StatusPagesKt$StatusPages$2$2.invoke(StatusPages.kt)
	at io.ktor.server.plugins.statuspages.StatusPagesKt$StatusPages$2$2.invoke(StatusPages.kt)
	at io.ktor.server.application.hooks.CallFailed$install$1.invokeSuspend(CommonHooks.kt:46)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
	at kotlinx.coroutines.internal.ScopeCoroutine.afterResume(Scopes.kt:33)
	at kotlinx.coroutines.AbstractCoroutine.resumeWith(AbstractCoroutine.kt:102)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:46)
	at io.ktor.util.pipeline.SuspendFunctionGun.resumeRootWith(SuspendFunctionGun.kt:141)
	at io.ktor.util.pipeline.SuspendFunctionGun.access$resumeRootWith(SuspendFunctionGun.kt:14)
	at io.ktor.util.pipeline.SuspendFunctionGun$continuation$1.resumeWith(SuspendFunctionGun.kt:58)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:46)
	at io.ktor.util.pipeline.SuspendFunctionGun.resumeRootWith(SuspendFunctionGun.kt:141)
	at io.ktor.util.pipeline.SuspendFunctionGun.access$resumeRootWith(SuspendFunctionGun.kt:14)
	at io.ktor.util.pipeline.SuspendFunctionGun$continuation$1.resumeWith(SuspendFunctionGun.kt:58)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:46)
	at io.ktor.util.pipeline.SuspendFunctionGun.resumeRootWith(SuspendFunctionGun.kt:141)
	at io.ktor.util.pipeline.SuspendFunctionGun.access$resumeRootWith(SuspendFunctionGun.kt:14)
	at io.ktor.util.pipeline.SuspendFunctionGun$continuation$1.resumeWith(SuspendFunctionGun.kt:58)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:46)
	at io.ktor.util.pipeline.SuspendFunctionGun.resumeRootWith(SuspendFunctionGun.kt:141)
	at io.ktor.util.pipeline.SuspendFunctionGun.access$resumeRootWith(SuspendFunctionGun.kt:14)
	at io.ktor.util.pipeline.SuspendFunctionGun$continuation$1.resumeWith(SuspendFunctionGun.kt:58)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:46)
	at io.ktor.util.pipeline.SuspendFunctionGun.resumeRootWith(SuspendFunctionGun.kt:141)
	at io.ktor.util.pipeline.SuspendFunctionGun.access$resumeRootWith(SuspendFunctionGun.kt:14)
	at io.ktor.util.pipeline.SuspendFunctionGun$continuation$1.resumeWith(SuspendFunctionGun.kt:58)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:46)
	at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:104)
	at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)
	at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)
	at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)
	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:503)
	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
	at io.ktor.server.netty.EventLoopGroupProxy$Companion.create$lambda-1$lambda-0(NettyApplicationEngine.kt:288)
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
	at java.base/java.lang.Thread.run(Thread.java:833)

CallLogging and CallId: exceptions thrown in WriteChannelContent.writeTo are swallowed

https://youtrack.jetbrains.com/issue/KTOR-4954

Tested on Ktor 2.1.0, 2.1.1, 2.1.2.
Plugin CallId from io.ktor:ktor-server-call-id-jvm:2.1.2.

It seems, that using a project created by the IntelliJ IDEA wizard for Ktor selecting call logging and call ID plugins, the generated code looks something like (code compacted, some functions renamed etc. in this issue textfield. Hope the syntaxt is indeed valid)

fun Application.configureMonitoring() {
    install(CallLogging) {
        level = Level.INFO
        filter { call -> call.request.path().startsWith("/") }
        callIdMdc("call-id")
    }
    install(CallId) {
        header(HttpHeaders.XRequestId)
        verify { callId: String ->
            callId.isNotEmpty()
        }
    }
}

fun main(args: Array<String>): Unit =
    io.ktor.server.netty.EngineMain.main(args)

@Suppress("unused")
fun Application.module() {
    //configureHttp()
    configureMonitoring()
    //configureTemplating()
    //configureRouting()

    configurePage()
}

private fun Application.configurePage() {
    routing {
        route("/page") {
            get {
                call.respondHtml {
                    //defaultHead()
                    body {
                        pageForm()
                        //initScripts()
                    }
                }
            }
        }
    }
}

private fun BODY.pageForm() = form {
    // ...
    select {
        // omitted, not important
        name = "page-select"
    }
}

Would throw

2022-10-07 10:02:13.872 [eventLoopGroupProxy-4-1]  ERROR
                Application - 200 OK: GET - /page
java.lang.IllegalStateException: You can't change tag attribute because it was already passed to the downstream
	at kotlinx.html.consumers.DelayedConsumer.onTagAttributeChange(delayed-consumer.kt:16)
	at kotlinx.html.impl.DelegatingMap.put(delegating-map.kt:27)
	at kotlinx.html.impl.DelegatingMap.put(delegating-map.kt:5)
	at kotlinx.html.attributes.Attribute.set(attributes.kt:19)
	at kotlinx.html.SELECT.setName(gen-tags-s.kt:120)

But with the CallId plugin installed, all stack traces are consumed and only the call is logged and browser waits until timeout and then reports that the page didn't send any content

Commenting out the CallId plugin, the stack traces come back and everything works.

Temp files generated by multipart upload are not cleared in case of exception or cancellation

Digest auth: Support returning any objects which implement Principal interface

Server Session - Switch to Kotlinx serialization

Way to block use of TLS 1.0/1.1 when using Ktor/Netty

Unable to access userPrincipal of servletRequest in ktor-server-servlet

When unable to get JWKS, JWTAuth swallows the underlying exception and only logs the last message

https://youtrack.jetbrains.com/issue/KTOR-636

This issue was imported from GitHub issue: https://github.com/ktorio/ktor/issues/1053

https://github.com/ktorio/ktor/blob/2406dc5b5970205593efa51867c0e5a05f149210/ktor-features/ktor-auth-jwt/jvm/src/io/ktor/auth/jwt/JWTAuth.kt#L164

When unable to retrieve the JWKS, JWTAuth swallows the underlying exception and only logs the message.

This means we only get to see:
TRACE io.ktor.auth.jwt - Failed to get JWK: Failed to get key with kid 1

When stack trace is:

com.auth0.jwk.SigningKeyNotFoundException: Failed to get key with kid 1
Caused by: com.auth0.jwk.SigningKeyNotFoundException: Cannot obtain jwks from url https://localhost:2222/jwks
Caused by: java.net.ConnectException: Connection refused (Connection refused)

Simple example to reproduce:

val TestJWT = "eyJraWQiOiIxIiwiYWxnIjoiUlMyNTYifQ.eyJpc3MiOiJodHRwOi8vbG9jYWxob3N0OjgwNjAvaXNzby9vYXV0aDIiLCJleHAiOjE3MTE4NzQ3MDAsImp0aSI6IjZvWkZWa3lGX2RSd1dpcXNhQkJkWkEiLCJpYXQiOjE1NTQxOTQ3MDAsInN1YiI6Im15dXNlciIsImF1ZCI6Ik9JREMiLCJhY3IiOiJMZXZlbDQiLCJhenAiOiJPSURDIn0.NuWfe1BZK3i-VVC1l7EIvJydd9m3Pcr2_0AanhbS3YEXSq_NWKhqtFd4qM_KUhLURTTwhNhAb43Zr2HzxGFUhnYnU4uCi95fLcw3Cq8mTM3o4I0r-pgpPTkfiheUUtOA4d43cwWpyEaBdypwO_F-VLA4zBw1oTRE_M0_G-16Q6yezpjTVBvOI7nsEWLHUZ-i10hE3V53cx2-Qm5OUOtEFF-UqqFhgBU6VSRYS5J3puWQFGlLr5hGSAW3Nll1DkJbiNaHB4y7EPnSlCPcNdZ98PXckylsiJ6nhRJXg4mke-C2WWckJ5H4dgsjeoUmXDuLekO1IrvwT1JLGJYiPwlQJw"

fun main(args: Array<String>): Unit {
    Thread {
        io.ktor.server.netty.EngineMain.main(args)
    }.run()

    Thread {
        println("Testing in 3 secs...")
        Thread.sleep(3000);
        println("Testing...")
        GlobalScope.launch {
            val resp = HttpClient(Apache).use { client ->
                client.get<String>(URL("http://localhost:8080/")) {
                    this.header("Authorization", "Bearer " + TestJWT);
                }
            }
            println("RESP: ${resp}")
        }
    }.run()
}

@Suppress("unused") // Referenced in application.conf
@kotlin.jvm.JvmOverloads
fun Application.module(testing: Boolean = false) {
    install(Authentication) {
        jwt {
            verifier(JwkProviderBuilder(URL("https://localhost:2222/jwks")).build(), "http://localhost:8060/isso/oauth2");
            validate { credentials ->
                if (credentials.payload.subject == "myuser") {
                    JWTPrincipal(credentials.payload)
                } else {
                    log.info("${credentials.payload.subject} is not authorized to use this app, denying access")
                    null
                }
            }
        }
    }
    routing {
        authenticate {
            get("/") {
                call.respondText("HELLO WORLD!", contentType = ContentType.Text.Plain)
            }
        }
    }
}

CIO Server generates wrong URL for OAuth URL provider using Locations

Test Infrastructure

testApplication: application initialization block isn't eagerly called

https://youtrack.jetbrains.com/issue/KTOR-4819

When migrating from the old withTestApplication to the new testApplication, it broke my tests, because the blocks for configuration of routing and application are not executed, or only executed after the test implementation finished. When looking into the source code, it might have to do with the engine only being called/initialized after the test block. Please look at the tests below comapring the old and new approach:

import io.ktor.server.testing.*
import io.ktor.test.dispatcher.*
import org.junit.jupiter.api.Assertions.assertEquals
import org.junit.jupiter.api.Test

internal class CompareTestApplicationTest {

    @Test
    fun `New testApplication initialization is called (failing)`() = testSuspend {
        var externalServicesCalled = false
        var routingCalled = false
        var applicationCalled = false
        testApplication {
            externalServices {
                externalServicesCalled = true
                println("Always called, because this executes instantly")
            }
            routing {
                routingCalled = true
                println("Only called AFTER testApplication { } block finished")
            }
            application {
                applicationCalled = true
                println("Only called AFTER testApplication { } block finished")
            }
            assertEquals(true, externalServicesCalled) // success
            assertEquals(true, routingCalled) // failure
            assertEquals(true, applicationCalled) // failure
            println("testApplication { } block finished")
        }
    }

    @Test
    fun `Deprecated withTextApplication initialization is called (success)`() = testSuspend {
        var applicationCalled = false
        withTestApplication({
            applicationCalled = true
            println("Properly called before the actual tests below")
        }) {
            assertEquals(true, applicationCalled)
            println("withTestApplication { } block finished")
        }
    }
}

Using Ktor 2.1.0, Kotlin 1.7.10, junit-jupiter 5.9.0

It also seems that if I run multiple tests in parallel, the behavior differs compared to running tests individually. Is there some sort of caching/reusing going on, that might break tests? It should be possible to define different setups for the testApplication block for different tests, right?

testApplication: test server lifecycle management

https://youtrack.jetbrains.com/issue/KTOR-4773

Following the instructions in Ktor Server > Testing (step 7) my testing setup code looks like this:

    private fun inMemoryTestBroken(testBlock: suspend ApplicationTestBuilder.(HttpClient) -> Unit) {
        testApplication {
            environment {
                config = MapApplicationConfig(
                    "requests.heartbeatTtl" to "PT5S",
                    "requests.timeout" to "PT5S",
                    "requests.pollSleep" to "PT0.1S",
                )
            }

            application {
                // fields in the test class
                attributes.put(Connector, testInjector) 
                attributes.put(AppClock,  coroutineClock)
                
                // creates a service, but does not start the event dispatching thread
                // until the ApplicationStarted event has been broadcasted
                installService()   
                configureRouting()
            }

            val client = createClient {
                install(ContentNegotiation) { json() }
            }

            // the actual test is executed in this block as in the example
            testBlock(client) 
        }
    }

As the testApplication block is executed during the application builder config, the application is not ready at the time we run the testBlock. This means that some of the service resources have not been allocated and our tests are failing.

As a second attempt, I tried to use the test client directly:

    private fun inMemoryTestBroken(testBlock: suspend ApplicationTestBuilder.(HttpClient) -> Unit) {
        val testApplication = TestApplication {
            environment { // same as in the first snippet, reformatted for more compact view
                config = MapApplicationConfig("requests.heartbeatTtl" to "PT5S", "requests.timeout" to "PT5S", "requests.pollSleep" to "PT0.1S", )
            }

            application { // same as in the first snippet, reformatted for more compact view
                attributes.apply { put(Connector, testInjector); put(AppClock,  coroutineClock) }; installService() ; configureRouting()
            }
        }

        try {
            // PROBLEM: engine is internal and fails to compile
            testApplication.engine.start() 
            
            // PROBLEM: testApplication.builder is private and fails to compile
            // I also tried to create a fresh one, but it fails to link with the test application
            val builder = testApplication.builder 
            val client = builder.createClient {
                install(ContentNegotiation) { json() }
            }
    
            runBlocking {
                builder.testBlock(client)
            }
        } finally {
            testApplication.stop()
        }     
        
    }

As you can see in the comments, critical parts of the API are inaccessible.

It feels dirty to start threads during module installation time, but right now that is the only thing that works. Also, I am not convinced that starting my test from the init block does not have any other side effects.

Please let me known if there is any other way.

Other

Add Debug Logging to ContentNegotiation

Add Debug Logging to WebSockets Plugin

Add Debug Logging for Ktor Plugins and Routing

Update Versions of Dependencies

ByteChannel exception: Got EOF but at least 1 bytes were expected

https://youtrack.jetbrains.com/issue/KTOR-5252

There's a problem with jvm ByteChannel which is reproduciple with ktor 2.1.3 and 2.2.0-eap-553 and doesn't reproducible with 2.0.2-eap-393.
Code in the snippet throws Got EOF but at least 1 bytes were expected exception at a random attempt.

import io.ktor.utils.io.*
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.async
import kotlinx.coroutines.launch
import kotlinx.coroutines.runBlocking

fun main(args: Array<String>) {
    runBlocking {
        (1..20000).forEach { num ->
            val channel = ByteChannel(true)
            val writer = launch(Dispatchers.IO) {
                channel.writeFully("1\n".toByteArray())
                channel.close()
            }

            val reader = async(Dispatchers.IO) {
                val lines = mutableListOf<String>()
                while (true) {
                    val line = channel.readUTF8Line(5000) ?: break
                    lines.add(line)
                }
                lines
            }

            val readerResult = reader.await()
            writer.join()

            println("[$num] READER RESULT: $readerResult")
        }
    }
}

Full stacktrace:

Exception in thread "main" java.io.EOFException: Got EOF but at least 1 bytes were expected
        at io.ktor.utils.io.ByteBufferChannel.readBlockSuspend(ByteBufferChannel.kt:1707)
        at io.ktor.utils.io.ByteBufferChannel.read$suspendImpl(ByteBufferChannel.kt:1661)
        at io.ktor.utils.io.ByteBufferChannel.read(ByteBufferChannel.kt)
        at io.ktor.utils.io.ByteBufferChannel.readUTF8LineToUtf8Suspend(ByteBufferChannel.kt:1952)
        at io.ktor.utils.io.ByteBufferChannel.readUTF8LineToAscii(ByteBufferChannel.kt:1938)
        at io.ktor.utils.io.ByteBufferChannel.readUTF8LineTo$suspendImpl(ByteBufferChannel.kt:2006)
        at io.ktor.utils.io.ByteBufferChannel.readUTF8LineTo(ByteBufferChannel.kt)
        at io.ktor.utils.io.ByteBufferChannel.readUTF8Line$suspendImpl(ByteBufferChannel.kt:2010)
        at io.ktor.utils.io.ByteBufferChannel.readUTF8Line(ByteBufferChannel.kt)
        at MainKt$main$1$1$reader$1.invokeSuspend(Main.kt:19)
        at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
        at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:106)
        at kotlinx.coroutines.internal.LimitedDispatcher.run(LimitedDispatcher.kt:42)
        at kotlinx.coroutines.scheduling.TaskImpl.run(Tasks.kt:95)
        at kotlinx.coroutines.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:570)
        at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.executeTask(CoroutineScheduler.kt:750)
        at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.runWorker(CoroutineScheduler.kt:677)
        at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:664)

Also I've attached full gradle project, so you can just unarchive it and run code via ./graldew run in the project root.

Support Default Value for missing Env Variables in YAML

Out of the box ContentConverter for Protobuf

List<ApplicationConfig>.merge() should have reversed priority

CORS Plugin should log reason for returning 403 Forbidden errors

"POSIX error 56: Socket is already connected" error when a socket is connection-mode on Darwin targets

https://youtrack.jetbrains.com/issue/KTOR-4877

I faced with an error when i'm trying to send Datagram Packet using ktor-network library. I'm not sure if that error reproduced for all nix targets, but it falls for me on macosX64 and all iOS targets. JVM target works fine.

Here is a sample project with tests that reproduce the error https://github.com/KamiSempai/ktor_network_problem.

Test DnsReaderTest.testReadDns fall with following stack trace:

io.ktor.utils.io.errors.PosixException.PosixErrnoException: POSIX error 56: Socket is already connected (56)
	at kotlin.Throwable#<init>(/opt/buildAgent/work/67fbc2b507315583/kotlin/kotlin-native/runtime/src/main/kotlin/kotlin/Throwable.kt:24)
	at kotlin.Exception#<init>(/opt/buildAgent/work/67fbc2b507315583/kotlin/kotlin-native/runtime/src/main/kotlin/kotlin/Exceptions.kt:23)
	at io.ktor.utils.io.errors.PosixException#<init>(/opt/buildAgent/work/49d4a482a8522285/ktor-io/posix/src/io/ktor/utils/io/errors/PosixErrors.kt:33)
	at io.ktor.utils.io.errors.PosixException.PosixErrnoException#<init>(/opt/buildAgent/work/49d4a482a8522285/ktor-io/posix/src/io/ktor/utils/io/errors/PosixErrors.kt:64)
	at io.ktor.utils.io.errors.PosixException.Companion#forErrno(/opt/buildAgent/work/49d4a482a8522285/ktor-io/posix/src/io/ktor/utils/io/errors/PosixErrors.kt:111)
	at io.ktor.utils.io.errors.PosixException.Companion#forErrno$default(/opt/buildAgent/work/49d4a482a8522285/ktor-io/posix/src/io/ktor/utils/io/errors/PosixErrors.kt:75)
	at io.ktor.network.sockets.DatagramSendChannel.$sendImplCOROUTINE$7.invokeSuspend#internal(/opt/buildAgent/work/8d547b974a7be21f/ktor-network/nix/src/io/ktor/network/sockets/DatagramSendChannel.kt:126)
	at io.ktor.network.sockets.DatagramSendChannel.sendImpl#internal(/opt/buildAgent/work/8d547b974a7be21f/ktor-network/nix/src/io/ktor/network/sockets/DatagramSendChannel.kt:106)
	at io.ktor.network.sockets.DatagramSendChannel#sendImpl$default(/opt/buildAgent/work/8d547b974a7be21f/ktor-network/nix/src/io/ktor/network/sockets/DatagramSendChannel.kt:106)
	at io.ktor.network.sockets.DatagramSendChannel.$sendCOROUTINE$6#invokeSuspend(/opt/buildAgent/work/8d547b974a7be21f/ktor-network/nix/src/io/ktor/network/sockets/DatagramSendChannel.kt:101)
	at io.ktor.network.sockets.DatagramSendChannel#send(/opt/buildAgent/work/8d547b974a7be21f/ktor-network/nix/src/io/ktor/network/sockets/DatagramSendChannel.kt:99)
	at io.ktor.network.sockets.DatagramWriteChannel#send(/opt/buildAgent/work/8d547b974a7be21f/ktor-network/jvmAndNix/src/io/ktor/network/sockets/Datagram.kt:41)
	at com.mytest.DnsReaderTest.$readDnsRecordsCOROUTINE$0.invokeSuspend#internal(/Users/denis.shurygin/Documents/AndroidStudioProjects/ktor_network_problem/app/src/commonTest/kotlin/com/mytest/DnsReaderTest.kt:54)
	at com.mytest.DnsReaderTest.readDnsRecords#internal(/Users/denis.shurygin/Documents/AndroidStudioProjects/ktor_network_problem/app/src/commonTest/kotlin/com/mytest/DnsReaderTest.kt:43)
	at com.mytest.DnsReaderTest.$testReadDns$lambda-3COROUTINE$2.invokeSuspend#internal(/Users/denis.shurygin/Documents/AndroidStudioProjects/ktor_network_problem/app/src/commonTest/kotlin/com/mytest/DnsReaderTest.kt:35)
	at kotlin.coroutines.native.internal.BaseContinuationImpl#resumeWith(/opt/buildAgent/work/67fbc2b507315583/kotlin/kotlin-native/runtime/src/main/kotlin/kotlin/coroutines/ContinuationImpl.kt:30)
	at kotlinx.coroutines.DispatchedTask#run(/opt/buildAgent/work/44ec6e850d5c63f0/kotlinx-coroutines-core/common/src/internal/DispatchedTask.kt:106)
	at kotlinx.coroutines.EventLoopImplBase#processNextEvent(/opt/buildAgent/work/44ec6e850d5c63f0/kotlinx-coroutines-core/common/src/EventLoop.common.kt:284)
	at kotlinx.coroutines.BlockingCoroutine.joinBlocking#internal(/opt/buildAgent/work/44ec6e850d5c63f0/kotlinx-coroutines-core/native/src/Builders.kt:83)
	at kotlinx.coroutines#runBlocking(/opt/buildAgent/work/44ec6e850d5c63f0/kotlinx-coroutines-core/native/src/Builders.kt:56)
	at kotlinx.coroutines#runBlocking$default(/opt/buildAgent/work/44ec6e850d5c63f0/kotlinx-coroutines-core/native/src/Builders.kt:36)
	at com.mytest.DnsReaderTest#testReadDns(/Users/denis.shurygin/Documents/AndroidStudioProjects/ktor_network_problem/app/src/commonTest/kotlin/com/mytest/DnsReaderTest.kt:33)
	at com.mytest.$DnsReaderTest$test$0.$testReadDns$FUNCTION_REFERENCE$4.invoke#internal(/Users/denis.shurygin/Documents/AndroidStudioProjects/ktor_network_problem/app/src/commonTest/kotlin/com/mytest/DnsReaderTest.kt:32)
	at com.mytest.$DnsReaderTest$test$0.$testReadDns$FUNCTION_REFERENCE$4.$<bridge-UNNN>invoke(/Users/denis.shurygin/Documents/AndroidStudioProjects/ktor_network_problem/app/src/commonTest/kotlin/com/mytest/DnsReaderTest.kt:32)
	at kotlin.native.internal.test.BaseClassSuite.TestCase#run(/opt/buildAgent/work/67fbc2b507315583/kotlin/kotlin-native/runtime/src/main/kotlin/kotlin/native/internal/test/TestSuite.kt:85)
	at kotlin.native.internal.test.TestRunner.run#internal(/opt/buildAgent/work/67fbc2b507315583/kotlin/kotlin-native/runtime/src/main/kotlin/kotlin/native/internal/test/TestRunner.kt:245)
	at kotlin.native.internal.test.TestRunner.runIteration#internal(/opt/buildAgent/work/67fbc2b507315583/kotlin/kotlin-native/runtime/src/main/kotlin/kotlin/native/internal/test/TestRunner.kt:271)
	at kotlin.native.internal.test.TestRunner#run(/opt/buildAgent/work/67fbc2b507315583/kotlin/kotlin-native/runtime/src/main/kotlin/kotlin/native/internal/test/TestRunner.kt:286)
	at kotlin.native.internal.test#testLauncherEntryPoint(/opt/buildAgent/work/67fbc2b507315583/kotlin/kotlin-native/runtime/src/main/kotlin/kotlin/native/internal/test/Launcher.kt:30)
	at kotlin.native.internal.test#main(/opt/buildAgent/work/67fbc2b507315583/kotlin/kotlin-native/runtime/src/main/kotlin/kotlin/native/internal/test/Launcher.kt:34)
	at <global>.Konan_start(/opt/buildAgent/work/67fbc2b507315583/kotlin/kotlin-native/runtime/src/main/kotlin/kotlin/native/internal/test/Launcher.kt:33)
	at <global>.Init_and_run_start(Unknown Source)
	at <global>.0x0(Unknown Source)
	at <global>.0x0(Unknown Source)

Kotlin version: 1.7.10
Ktor version: 2.1.1
Coroutines version: 1.6.4
IDE: Android Studio 2021.2.1 Patch 1 and IntelliJ IDEA 2021.1.1 (Community Edition)