This message was deleted.

Hey there! My name is Gunnar, I work for a small analytics company located in Austria and we're using Ktor as backend technology for serving our dashboard applications.

I have a rather specific question. Would it be possible from a technical perspective to "mount" a Ktor application at a specific path, e.g. "/dashboard1", inside a host application? I know I can achieve something similar by just writing an application module, but I'd prefer complete isolation of application features. If this is possible, could anyone outline the necessary steps, e.g. custom ApplicationEnvironment, etc. to achieve this? Many thanks in advance!

When I send a POST request with String typed body,

<http://client.post|client.post><String>("/path", "hello")

I get double-quoted data on both sides.

println(call.receiveText())
// Result: "hello"

What is the proper way to handle this?

I have a question regarding request queueing in

io.ktor.server.netty.NettyApplicationEngine

. It seems like the inner Configuration's

requestQueueLimit

and

runningLimit

parameters are not actually used (as far as I can tell by looking in the master branch the idea seems to be that these are propagated to

io.ktor.server.netty.cio.NettyRequestQueue

, but don't seem to be used). Are there any plans to actually support these in the future or will they be dropped? If they are planned for support, can I help speed things up (by contributing an implementation for example)? @cy

Is there SQL database that supports nonblocking access? It is kinda moot to use nonblocking ktor server only to end up blocking on JDBC queries.

Hello, I think I've found a bug and opened an issue for it: https://github.com/ktorio/ktor/issues/1216 It seems like when a timeout occurs during the deserialization phase of a request (hard to reproduce), we get a

Operation is a already in progress

exception. Any advice on what I could do to avoid this in the meantime ?

As I've understood it

location

(in terms of routing) is being deprecated? All oauth examples I can find utilizes that quite heavily and I'm a bit new to Ktor to know my way around things. Anyone can point me to an example of OAuth implementation that doesn't depend on

location

and such?

Hello everyone, Im getting No such element exception - List is empty when changing the configuration of HttpClient in iOS. client = HttpClient().config { expectSuccess = false install(JsonFeature) { serializer = defaultSerializer() } }

Hi! I’ve been fiddling around with Ktor and K/N on MacOS. I got other suspending functions which do work in the same app(called the same way as the following function), but this suspended function just hangs forever:

suspend fun getContent(): String {
    val client = HttpClient()
    return client.get<String>("<http://www.google.com>")
}

Any ideas on what might cause it? I came across with the following similar issues, but I was not able to fix the issue of mine based on how the these issues had been solved: - https://stackoverflow.com/q/56347516/1538877 - https://github.com/ktorio/ktor/issues/678 All the help is appreciated, thanks in advance!

hello i'm starting up with ktor , and want to implement my own oauth2 provider can i do it with ktor ?

Hi everyone! I've have just a (maybe noob) question. I'm implementing Oauth2 by using this guide -> https://ktor.io/quickstart/guides/oauth.html and looks like everything is working fine, I can see the token but... the question is, how can I indicate that requests need the auth? Right now my config is something like this:

routing {
        authenticate(OauthConfig.NAME) {
            route("/test") {
                get { call.respond("Sample from auth part...") }
            }
        }
    }

When I call this WS, I set the access token into the auth header (Bearer) with postman but I get 401, if I do the request from browser, I always get a redirection to the login and it generates new token 😞

is there a shortcut to

exception.response.content.readUTF8Line()

? For debugging I feel like this overly complicated and confusing

Hi everyone! I've following question: There is a cookie definition from Ktor:

data class Cookie(
    val name: String,
    val value: String,
    val encoding: CookieEncoding = CookieEncoding.URI_ENCODING,
    val maxAge: Int = 0,

How it's possible to set cookie without 'maxage' - per standard, it means the lifetime of cookie is restricted by lifetime of client ?

Hi all! I'm new to Ktor and I'd need some help on how to generate a .war file from my Ktor webapp? Though I created a .war using Gretty plugin but the artifact has strange folder structure. I copied the .war on a Tomcat but can't see anything in the browser.

I'm currently playing around with ktor client. It looks like the auth feature has some problems since version 1.2.0 . This import doesn't work with all versions above 1.1.5: io.ktor.client.features.auth.Auth. Is someone else having the same issue?

Is Ktor for JVM also designed with Java 9+ modules compatibility in mind (i.e. containing Java module define and avoiding split packages)?

Is there a way to automatically retry a request given a specific response (for example, HTTP 421) with HttpClient ?

@tseisel don’t know about any such built in behavior but when we’ve come across such use cases in my team we have used kotlins repeat and in some cases just written extensions

Hi all, I'm trying to use ktor 1.2.2 with Curl engine to call REST API on Windows, but it always returns the following excpetion. Could you kindly give some comments? Thanks. Console log: HttpClient: REQUEST: https://postman-echo.com/get?foo1=bar1&foo2=bar2 HttpClient: METHOD: HttpMethod(value=GET) HttpClient: COMMON HEADERS HttpClient: -> Accept-Charset: UTF-8 HttpClient: -> Accept: / HttpClient: CONTENT HEADERS HttpClient: REQUEST https://postman-echo.com/get?foo1=bar1&foo2=bar2 failed with exception: io.ktor.client.engine.curl.CurlIllegalStateException: Connection failed for request: io.ktor.client.engine.curl.internal.CurlRequestData@48bd218

Hey all. Maybe you guys can help us out. We are using the ktor apache http client and we get random "Connection reset by peer" exceptions . We only observed this for a particular service that runs behind a load balancer. So the assumption is that if the client gets balanced to another node, it won't have a valid connection anymore. To start with, I don't understand how http clients are meant to be used in ktor. Our ktor backend acts as a gateway between a frontend and multiple backend services. So the question is: should we recreate a http client instance for every request and then immediately close the client, as it is shown in the ktor examples? https://ktor.io/clients/http-client.html Or should we initialize the client once, say as part of the initialization of an object, and then reuse it for all requests? What happens when a http client is instantiated? I once forgot to close a client and it seemed on every instance creation it spawned 10 new threads, which indicates to me that it is meant for reuse?

Hey guys, I have a question. Is there a way in Ktor to limit identical GET requests to the same endpoint from the client's side? Eg. if my client app makes a single GET request to the

xyz

endpoint and then at almost the same time makes another two to the same endpoint with the same method/payload, I would like to let only the first one to actually reach the server and deliver response to all 3 client requests. Is there any way to achieve this with ktor?

Hi! I apologize if this has been asked before, but is there a good canonical way in ktor to map query params from a GET request to a model class in kotlin? Here’s an example:

application.routing {
    get("myroute") {
        val queryParams = call.parameters // the query params from the call
        val paramsMap: Map<String, String> = queryParams.toMap().mapValues { it.value.first() } // I can put them in a map of string fairly easily
        val instanceOfMyClass: MyClass = MyClass(paramsMap["val1"], paramsMap["val2"], etc...) // I have to map them to my class manually each time :(
        // do stuff with the query params
        call.respondJson("your response here.")
    }
}

To be clear, the equivalent of what I’m looking for in spring would look like:

import javax.validation.Valid;

@RequestMapping(value = "/getItem", method = RequestMethod.GET)
public ServiceRequest<List<SomeModel>> getClaimStatuses(@Valid RequestParamsModel model) {
    // ...
}

and in JAX-RS it’d use

@BeanParam

https://dennis-xlc.gitbooks.io/restful-java-with-jax-rs-2-0-2rd-edition/en/part1/chapter5/bean_param.html

And 2. Is it possible to gzip compress requests ? (Looks like response decompression is supported but not request compression)

Hello there, I'm trying to create a custom feature for Ktor Server that validates request signature and needs to fully read request content. I'm wondering what's the right pipeline and phase to intercept here. Currently intercepting

ApplicationReceivePipeline.Before

– this kinda works, but in case of invalid signature after I send 401 back and call

finish()

I still get

CannotTransformContentToTypeException

in the related target route. I understand that it's what triggers receive pipeline, so this setup is obviously wrong. Seeking for the right solution, appreciate any help.

Hi there 🙂 I'm currently writing a custom feature for ktor, that wraps exceptions in a RFC7807 style problem+json object (https://github.com/tyntec/ktor-problem). Even if it is in early stage, I wanted to ask if someone would be interested in doing a review / give hints what can be improved. Many thanks in advance

Hello, I'm using ktor 1.2.2 and using ktor web socket client in Android, all seems ok, but if user enters airplane mode or disables internet it gets app crash with exception:

java.io.IOException: Software caused connection abort
        at sun.nio.ch.FileDispatcherImpl.read0(Native Method)
        at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:43)
        at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223)
        at sun.nio.ch.IOUtil.read(IOUtil.java:192)
        at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:382)
        at kotlinx.io.nio.ChannelsKt.read(Channels.kt:117)
        at io.ktor.network.sockets.CIOReaderKt$attachForReadingDirectImpl$1$1.invokeSuspend(CIOReader.kt:75)
        at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
        at kotlinx.coroutines.ResumeModeKt.resumeMode(ResumeMode.kt:67)
        at kotlinx.coroutines.DispatchedKt.resume(Dispatched.kt:309)
        at kotlinx.coroutines.DispatchedKt.resumeUnconfined(Dispatched.kt:49)
        at kotlinx.coroutines.DispatchedKt.dispatch(Dispatched.kt:295)
        at kotlinx.coroutines.CancellableContinuationImpl.dispatchResume(CancellableContinuationImpl.kt:250)
        at kotlinx.coroutines.CancellableContinuationImpl.resumeImpl(CancellableContinuationImpl.kt:260)
        at kotlinx.coroutines.CancellableContinuationImpl.resumeWith(CancellableContinuationImpl.kt:189)
        at io.ktor.network.selector.SelectorManagerSupport.handleSelectedKey(SelectorManagerSupport.kt:83)
        at io.ktor.network.selector.SelectorManagerSupport.handleSelectedKeys(SelectorManagerSupport.kt:63)
        at io.ktor.network.selector.ActorSelectorManager.process(ActorSelectorManager.kt:74)
        at io.ktor.network.selector.ActorSelectorManager$process$1.invokeSuspend(ActorSelectorManager.kt)
        at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)

I've added everythere try catch blocks but still this exception was not caught anywhere. Maybe anyone can help me how to overcome this?

Is it possible to mix

websocket

routes and

http

routes? I get a

500

hitting an

http

route when a websocket route is open. I thought it would suspend.

Hello, I have tried to use ktor auth, but faced problem with launching simple example. How can it be solved? If it is important: I am using OpenJDK 12 and in other project there is not problems with

ktor client

and

ktor cio