fun main() {
    embeddedServer(
        Netty, watchPaths = listOf("jvmMain"), port = 8080,
        module = Application::myModule
    ).start(wait = true)
}

fun Application.myModule() {
    routing {
        get("/") {
            call.respondHtml(HttpStatusCode.OK, HTML::index)
        }
        static("/static") {
            resources()
        }
    }
}

stack_trace	   	java.io.IOException: Connection reset by peer
	at (Coroutine boundary.()
	at io.ktor.client.engine.apache.ApacheEngine.execute(ApacheEngine.kt:23)
	at io.ktor.client.engine.HttpClientEngine$install$1.invokeSuspend(HttpClientEngine.kt:49)
	at io.ktor.client.features.HttpSend$DefaultSender.execute(HttpSend.kt:90)
	at io.ktor.client.features.HttpSend$Feature$install$1.invokeSuspend(HttpSend.kt:62)
	at io.ktor.client.HttpClient.execute(HttpClient.kt:141)
	at io.ktor.client.call.HttpClientCallKt.call(HttpClientCall.kt:140)
	at mycompany.clients.SearchClient.getSearch(SearchClient.kt:76)
	at mycompany.services.SearchService$getPrerequisits$2.invokeSuspend(SearchService.kt:28)
	at mycompany.endpoints.SearchEndpoints$createRoutes$1$1$2.invokeSuspend(ExportEndpoints.kt:61)
	at mycompany.core.ktor.Router_extensionsKt$postAndReportMetrics$2.invokeSuspend(router_extensions.kt:57)
	at io.ktor.routing.Routing.executeResult(Routing.kt:147)
	at io.ktor.routing.Routing$Feature$install$1.invokeSuspend(Routing.kt:99)
	at io.ktor.server.engine.DefaultEnginePipelineKt$defaultEnginePipeline$2.invokeSuspend(DefaultEnginePipeline.kt:118)
	at io.ktor.server.netty.NettyApplicationCallHandler$handleRequest$1.invokeSuspend(NettyApplicationCallHandler.kt:36)
Caused by: java.io.IOException: Connection reset by peer
	at sun.nio.ch.FileDispatcherImpl.read0(Native Method)
	at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39)
	at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223)
	at sun.nio.ch.IOUtil.read(IOUtil.java:197)
	at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:377)
	at org.apache.http.nio.reactor.ssl.SSLIOSession.receiveEncryptedData(SSLIOSession.java:444)
	at org.apache.http.nio.reactor.ssl.SSLIOSession.isAppInputReady(SSLIOSession.java:499)
	at org.apache.http.impl.nio.reactor.AbstractIODispatch.inputReady(AbstractIODispatch.java:120)
	at org.apache.http.impl.nio.reactor.BaseIOReactor.readable(BaseIOReactor.java:162)
	at org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvent(AbstractIOReactor.java:337)
	at org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvents(AbstractIOReactor.java:315)
	at org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:276)
	at org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104)
	at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:588)
	at java.lang.Thread.run(Thread.java:748)
t tags	   	logstash
t thread_name	   	DefaultDispatcher-worker-7 @call-handler#3553

MockEngine

install(...)

1.4.0

1.3.2-1.4.0-rc

Thread 1: signal SIGABRT

Uncaught Kotlin exception: kotlin.native.concurrent.InvalidMutabilityException: mutation attempt of frozen kotlinx.coroutines.ChildHandleNode@31dca08

CallLogging

DoubleReceive

install(DoubleReceive)

install(CallLogging) {
    level = <http://Level.INFO|Level.INFO>
    format { callFormatterAsCurlCommand(it) }
}

fun callFormatterAsCurlCommand(call: ApplicationCall): String {
    val payload = runBlocking { call.receiveText() }
    return payload
}

Request body has been already consumed

DoubleReceive.kt

All the receive methods consume the whole payload sent by the client so an attempt to receive a request body twice will lead to 

RequestAlreadyConsumedException

 error unless you have DoubleReceive feature installed.

https://ktor.io/servers/calls/requests.html#receiving-several-times

io.ktor.request.RequestAlreadyConsumedException: Request body has been already consumed (received).
	at io.ktor.features.DoubleReceive$Feature$install$1.invokeSuspend(DoubleReceive.kt:93) ~[ktor-server-core-jvm-1.4.0.jar:1.4.0]
	at io.ktor.features.DoubleReceive$Feature$install$1.invoke(DoubleReceive.kt) ~[ktor-server-core-jvm-1.4.0.jar:1.4.0]
	at io.ktor.util.pipeline.SuspendFunctionGun.loop(PipelineContext.kt:323) ~[ktor-utils-jvm-1.4.0.jar:1.4.0]

.close()

.dipose()

kotlinx.serialization.json.internal.JsonDecodingException: Unexpected JSON token at offset 15: Expected '[, kind: SEALED'
JSON input: {
    "place":{
        "type":"point",
        "lon":22.0,
        "lat":56.7
    }
}

post("/") {
  val body = call.receive<AddVisitDataDto>()
  call.respond(body.toString())
}

@kotlinx.serialization.Serializable
data class AddVisitDataDto(
    val place: PlaceDto
)

@kotlinx.serialization.Serializable
sealed class PlaceDto {
    @kotlinx.serialization.Serializable
    @SerialName("external")
    data class External(val externalId: String) : PlaceDto()
    @kotlinx.serialization.Serializable
    @SerialName("point")
    data class Point(val lon: Double, val lat: Double) : PlaceDto()
}

val text = call.receiveText()
val body = Json.decodeFromString<AddVisitDataDto>(text)

@Polymorphic

place

kotlinx.serialization.json.internal.JsonDecodingException: Unexpected JSON token at offset 15: Expected '[, kind: OPEN'

open class SimpleJWT(val secret: String) {
    private val algorithm = Algorithm.HMAC256(secret)
    val verifier = JWT.require(algorithm).build()
    fun sign(name: String): String = JWT.create().withClaim("name", name).sign(algorithm)
}
fun Application.module() {
    val simpleJwt = SimpleJWT("my-super-secret-for-jwt")
    install(Authentication) {
        jwt {
            verifier(simpleJwt.verifier)
            validate {
                UserIdPrincipal(it.payload.getClaim("name").asString())
            }
        }
    }
    // ...
}

digest

basic

sendWithoutRequest = true

digest

1.4

<http://httpClient.post|httpClient.post><SpecificType>()