Hi! Is there anyway to get notified on onClose-events when using websockets? I recon that you get a ClosedReceiveChannelException when you try to sendto a closed channels but I would like to get triggered as soon as a client disconnects. The Frame.Closed only seems to be sent if the user actually closes, not if they crash

Hi, I have created 2 Hocon files. One for dev and one for prod. When running the application, I am currently setting the dev config file like this

io.ktor.server.netty.EngineMain.main(arrayOf("-config=dev.conf"))

. Is it possible for the appropriate file to be set automatically based on my environment? How do I detect what environment I am in to be able to set the config file?

Hi Ktor team. I am keen on using the native config interface

io.ktor.config.ApplicationConfig

across our application code to access the configuration, however still seeing it as "experimental". Are there plans for this to become "official"?

hey I get this error

Exception in thread "main" java.lang.ClassNotFoundException: Module function cannot be found for the fully qualified name 'com.minki.ktor.ApplicationKt.main'

I think I get my package right?

Any smart idea on how to intercept and modify cookies from a remote server response before passing them to the

Cookies

feature plugin? At work, we are communicating with an external service that requires cookies but that sends the

Expires

cookie in an incorrect format (i.e. localised, German weekday abbreviations that are only 2 chars long). The

ktor-client

module in our codebase subsequently throws an exception at https://github.com/ktorio/ktor/blob/68eef1948ce4c8c11dae794588f8d063afb67d0b/ktor-http/common/src/io/ktor/http/DateUtils.kt#L20 blocking further development. The communications partner is an enterprise-grade provider, so negotiating with them to just abide by the f*ing standards is not an option, I'm afraid. (Although it's sad that a company like them doesn't care for standards in the first place, but that's totally not my point here.)

Hi, I am wondering if we can use Websockets with ktor in a kotlin multiplatform project (android and iOS)?

Filed a bug report about using

ApplicationCall.receive

with Jackson, I know there's loads of issues on the repo, so would appreciate a sanity check about expected behaviour, if anyone fancies taking a look - happy to close it if it's what people are expecting 🙂 https://github.com/ktorio/ktor/issues/1146

Is the ktor client auth feature not multiplatform compatible? i thought so but getting unresolved reference and https://github.com/ktorio/ktor/tree/master/ktor-features/ktor-auth only has a jvm folder

I'm really enjoying using Ktor. We're using it for several of the services on an animal adoption project, and we'll eventually use it for all the backend services and the website itself: https://www.adoptanimals.io/ Thanks for making it 🎉

Hello, I've seen that in ktor 1.2.0 new property was added in jwt authentication provider - "authHeader", currently we are using that authHeader to pass JWT token not from header but from request cookies instead. But it token is invalid we have a need to submit 301 redirect to /login page instead of 401 auth response. Is it possible somehow to setup this behaviour in ktor? With session auth provider where is a "challenge" property for that, but not in jwt.

has been a while since i checked, but can ktor httpclient now do streaming requests ? keeping the connection open and allowing me to process the chunks (of json) coming in

How can I prevent this ktor-client exception when the response type is nullable and the body is empty?

ReceivePipelineException: Fail to run receive pipeline: NoTransformationFoundException: No transformation found: class JsHttpResponse -> class ExerciseProgressDTO

I wanted to creat an httpClient which gets png images bur when I set the content type it throws: Header Content-Type is controlled by the engine, any idea?

Hi everybody, I’d like to log all requests incomming in Ktor with header and body. Currently, I use :

install(CallLogging) {
        level = <http://Level.INFO|Level.INFO>
        filter { call -> call.request.path().startsWith("/api/v1") }
        callIdMdc()
    }

And I have some logs like :

200 OK: GET - /api/v1/health

but I’d like to have more details like the header and body because in some case I have log like

Unhandled: POST - /api/v1/catalogEdito/reunion/store

whereas this endpoint exists and returns some datas for certain type of client. So I think I need to have more details to debug and understand what is going on ! Do you know how I can do it please ?

Adding Ktor to a project seems also to include Kotlin reflect. This makes the APK size much larger and adds Metadata annotations to all the classes which are visible when decompiling the APK. Is this intended behaviour?

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

plugins {
    application
    kotlin("jvm")
}

group = "ktorserver"
version = "0.0.1"

application {
    mainClassName = "io.ktor.server.tomcat.EngineMain"
}

repositories {
    mavenLocal()
    maven { url = uri("<https://kotlin.bintray.com/ktor>") }
}

dependencies {
    compile("org.jetbrains.kotlin:kotlin-stdlib-jdk8:$kotlin_version")
    compile("io.ktor:ktor-server-tomcat:$ktor_version")
    compile("ch.qos.logback:logback-classic:$logback_version")
    compile("io.ktor:ktor-server-core:$ktor_version")
    compile("io.ktor:ktor-jackson:$ktor_version")
    testCompile("io.ktor:ktor-server-tests:$ktor_version")
}

^this my gradle.kts

what I find strange is, somehow the auth library is only in test scope...

Hello! My internet may be broken but the last link on this page seems to point to nowhere

<https://ktor.io/advanced/pipeline/route.html>

maybe it should be called to

<https://github.com/ktorio/ktor/blob/master/ktor-features/ktor-metrics/jvm/src/io/ktor/metrics/dropwizard/DropwizardMetrics.kt>

Hi, anybody knows good tutorial for auth in ktor? I found official documentation and samples too difficult to understand for a newbie like me. Where should Credentials come from? What's the need for Principal and where is it stored? I want to build a simple website with ability to register and login for user. I made a simple form and just store credentials in database and session in cookies, without any usage of Authentication plugin. I just check in needed endpoints, if there session stored, otherwise redirect to login.

📣 ktor 1.2.1 bugfix release has been published - Fixed module function lookup (regress, #1132) - Fixed SessionTransportTransformers application order (#1147) - Fixed double content length header in requests on older Androids (#1060) - Fixed receiving a byte channel crash on Android (#1140) - Fixed websocket sockets lifecyle on Jetty engine - Downgraded Gradle to reduce gradle metadata version

I've got these two routes:

/foo:{bar}/{baz}
/{bar}/{baz}

When calling

/foo:123/456

I was expecting the first route to trigger with bar=123 and baz=456. Instead, the second route triggers with bar=foo:123 and baz=456. Is this a bug or expected?

I am porting some Retrofit code to ktor. I need to add additional params (a signature calculation) to an already built URLBuilder. But I get the following:

java.lang.IllegalStateException: Cannot modify a builder when final structure has already been built

. Is there a way to do this? Any examples out there I may refer to? Thank you.

Hey this might be an odd question but is it possible to limit the amount of threads ktor will use or directly set it's thread pool?

I have two issues. 1- I'm getting too many redirects exception when using HttpsRedirect feature for server 2- I'm getting socketTimeoutException after sometime when I try to make an http call every 30 seconds. Can someone help me? I would gladly share more information if needed. Wasn't able to find anything online to help. Thank you!

How can we log a specific header from CallLogging feature ?

Hi! I trying to work with UDP sockets and have some problem. Every time I start my code, I have 50/50 chance to start normally or receive java.net.SocketException: Already bound

private suspend fun eventLoop(port: Int) {
        val server = aSocket(ActorSelectorManager(<http://Dispatchers.IO|Dispatchers.IO>))
            .udp()
            .bind(InetSocketAddress(port))       <<<<<<<<<<< Exception

I'm sure that port is free on bind moment Stacktrace

Exception in thread "main" java.net.SocketException: Already bound
	at java.base/sun.nio.ch.Net.translateToSocketException(Net.java:164)
	at java.base/sun.nio.ch.DatagramSocketAdaptor.bind(DatagramSocketAdaptor.java:105)
	at io.ktor.network.sockets.UDPSocketBuilder.bind(Builders.kt:152)
	at io.ktor.network.sockets.UDPSocketBuilder.bind$default(Builders.kt:143)
	at co.fun.multiplayer.udp.ServerListener.eventLoop(ServerListener.kt:34)
	at co.fun.multiplayer.udp.ServerListener$start$1.invokeSuspend(ServerListener.kt:26)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
	at kotlinx.coroutines.DispatchedTask.run(Dispatched.kt:238)
	at kotlinx.coroutines.EventLoopImplBase.processNextEvent(EventLoop.kt:116)
	at kotlinx.coroutines.BlockingCoroutine.joinBlocking(Builders.kt:80)
	at kotlinx.coroutines.BuildersKt__BuildersKt.runBlocking(Builders.kt:54)
	at kotlinx.coroutines.BuildersKt.runBlocking(Unknown Source)
	at kotlinx.coroutines.BuildersKt__BuildersKt.runBlocking$default(Builders.kt:36)
	at kotlinx.coroutines.BuildersKt.runBlocking$default(Unknown Source)
	at co.fun.multiplayer.udp.ServerListener.start(ServerListener.kt:25)
	at co.fun.multiplayer.udp.MainKt.main(Main.kt:14)
Caused by: java.nio.channels.AlreadyBoundException
	at java.base/sun.nio.ch.DatagramChannelImpl.bind(DatagramChannelImpl.java:784)
	at java.base/sun.nio.ch.DatagramSocketAdaptor.bind(DatagramSocketAdaptor.java:103)
	... 14 more

This workaround helping, but it is very ugly

var server: BoundDatagramSocket
        while (true) {
            try {
                server = aSocket(ActorSelectorManager(<http://Dispatchers.IO|Dispatchers.IO>))
                    .udp()
                    .bind(InetSocketAddress(port))
                break
            } catch (e: Exception) {

            }
        }

Hi! How to accept any routing path?