I have a question about websockets, i have a Channel that i am calling consumeEach on in the body of the webSocket route. This channel opens some resources which i would like to close if the websocket receives a client disconnect. Anyone any suggestions on how i might go about that?

Is there anyone here who managed to get

watch

to work in Ktor? I've been trying for ages but it never works. Right now I get

Module function provided as lambda cannot be unlinked for reload

even though I copied the exact same code from the documentation site:

fun main(args: Array<String>) {
    embeddedServer(
            Netty,
            watchPaths = listOf("mydir"),
            port = PORT,
            module = Application::module
    ).start(true)
}

What am I doing wrong?

Do i read it correctly that Ktors HTTP2 support does not work without SSL/TLS? browser is not an issue for me because i am implementing a REST service (netty engine).

After update to ktor 1.4.0, the

KotlinxSerializer

is missing. Is there a way to solve this?

using

-javaagent:kotlinx-coroutines-debug-1.3.9.jar

and

DebugProbes.dumpCoroutines

the coroutines running ktor client requests are not showing up… is there some case of how coroutines are created that are missing in the agent instrumentation?

Hi! We are using

compile "io.ktor:ktor-client-apache:1.2.3"

in a full fledged ktor project we have. We've been quite happy with it but lately it seems some services detoriate over time and we start to see

IO: Connection reset by peer

. Now my first approach was to check the server that is receiving the calls we are making (if they were being ddosed by us, potential downtime etc) but it seems that the http call doesn't even leave us. Given the detoriation over time my mind goes towards stale connection or something of that sort. Has anybody else experienced this kind of issue?

Is it possible to run on ktor 1.3.x with Kotlin 1.4.x or is that mix of versions discouraged?

Hello, How can I get the http body message in my response when i get a http error ? I see the response.readText() but it doesn't seem to work...

Your current kotlinx.serialization core version is too low, while current Kotlin compiler plugin 1.4.0 requires at least 1.0-M1-SNAPSHOT. Please update your kotlinx.serialization runtime dependency.

This is what I see after upgrading to 1.4.0

Hi all I am trying to enable autoreload function and I have tried as follows:

ktor {
    deployment {
        port = 8080
        port = ${?PORT}
        watch = [ user-svc ]
    }
    application {
        modules = [ io.databaker.ApplicationKt.module ]
    }
}

And the following statement does not work

./gradlew -t installDist .

FAILURE: Build failed with an exception.

* What went wrong:
Task '.' not found in root project 'user-svc'.

* Try:
Run gradlew tasks to get a list of available tasks. Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights.

* Get more help at <https://help.gradle.org>

BUILD FAILED in 409ms

I am using https://github.com/JetBrains/Exposed

How does one do:

withTestApplication(Application::commonFeatures AND Application::someotherFeatures)

Has anyone used R8 with a ktor server app?

How do I redirect ALL non-authenticated routes to a login page? i.e. how does one get("EVERYTHING")... get(" * ") only gets ANYTHING/ but not ANYTHING/ANYTHING.

the source from https://github.com/ktorio/ktor-samples/blob/1.3.0/deployment/jetty-war/build.gradle

Hey everyone, I’m wondering, will this do what I believe it will do?

/**
 * Compose multiple pipeline [interceptors] into one. This executes [interceptors] in a new pipeline running in this
 * interceptors context on this interceptors subject
 *
 * @return A [PipelineInterceptor] that executes other [interceptors] in a pipeline within its own context on its own subject
 * @param interceptors [PipelineInterceptor]s to execute **serially**
 */
fun <TSubject : Any, TContext : Any> compose(
  vararg interceptors: PipelineInterceptor<TSubject, TContext>
): PipelineInterceptor<TSubject, TContext> = {
  val pipeline = Pipeline(PipelinePhase("Compose"), interceptors.asList())
  pipeline.execute(context, subject)
}

with usage:

route("/api") {
  get("/comics", GetAllComics)
  get("/comics/{page}", GetComicPage)
  get("/comics/latest", GetComicLatest)
  put("/users/token", compose(AuthenticateUser, SaveUserToken))
  put("/users/page", compose(AuthenticateUser, SaveUserPage))
}

I am trying to get the same behavior as nodejs’s

express

interceptors.

Hi! Has anyone done a nice implementation or library where you can add an auth mechanism to the call-stack like what was usually done with mdc/thread locals in Java? I read about the ContextElements but apparantly you have to keep track of your context every time you do a launch/async which seems a bit error prone/brittle

Hello guys! I was wondering if someone could give me a hand configuring a proxy using Ktor with CIO engine. I’ve been struggling to get it worked… I’m constantly receiving exceptions such as:

Could not find io.ktor:ktor-client-mock-native:1.4.0.

Hi, guys, I have a problem on Ktor client native. I’ve been struggling to make the code below works after migrating kotlin to 1.4.0 version while migrating, I changed coroutine version to

1.3.9-native-mt

class TestFreezingViewModel(val client: HttpClient) {

    fun call() {
         CoroutineScope(Dispatchers.Main).launch(start = CoroutineStart.LAZY) {
            try {
                client.get<String>("<https://test.com>") {}
            } catch (e: Throwable) {
                e.printStackTrace()
            }

        }.start()
    }
}

// swift side code
TestFreezingViewModel().call()

while the code running, The error(on the slack thread) occurs when Coroutine’s

invokeOnCompletion

is invoked, freeze() is called. and it tells that

HttpClient

can’t be frozen When I checked the source code HttpClient.init calls

preventFreeze()

I would like to know the intention of

preventFreeze

and what is the proper approach to use on developer’s side. Is there some advice?

one more questions😅 https://kotlinlang.slack.com/archives/C1CFAFJSK/p1597886480055300 ktor client 1.4.0 seems related to coroutines-core:1.3.9-native-mt when I use all of the below, there is error shared on the link • maven-publish • coroutine 1.3.9 • ktor-client-core 1.4.0 is there some workaround not to use native-mt? or instead, is it fine to use ktor 1.3.2 with kotlin 1.4.0?

However, how to configure it?

Hello. I am using ktor 1.4.0 and trying to use websockets. Setup contains: websocket client, websocket server, ktor 1.4.0, launching of websocket on client side working inside of flow. I faced the problem that it is blocking the thread and the whole page freezing. It would partially ok in case, if request would reach its destimation, but on server side there are no any tracing of connection receiving (I have enabled it) and there are no any action triggered inside of websocket routing.

is it known that the native mock engine is broken in 1.4?

How do I make authentication optional for a few endpoints? E.g. signin API doesn't need authentication, but the other APIs need it (I'm thinking of JWT).

Hey! Does anyone know how i can get around "Header Content-Type is controlled by the engine and cannot be set explicitly" My app can return JSON and CSV and the format is controlled by the Accept header in the request. I can set the content type explicitly to text/csv when using respondOutputStream or streamDirect but i can't use it with call.respond("my csv, as text").

Hello! From client side, how can one get the progress of a call (pending, connecting, writing and how many bytes sent vs total, waiting for response, reading and how many bytes sent vs total)? I'd like to expose such data in a flow in order to provide the best UX possible regarding the user knowing what they are waiting for and how fast it's going.