Hi I have a problem with ktor websockets, it closes the channel from time to time (randomly, I have no idea why). Client channel getting error 1006 (closed abnormally), how can I figure out what's going on? Is there a mechanism for auto-reconnect?

Hi, I’m implementing a service providing endpoints with and without authentication. After repeating the same procedures for some endpoints I wonder if there is a better way in KTor providing repeating context information for services, let me try to give an abstract example:

routing {
  get("/test") {
    call.respondText("test called")
  }
  authenticate("auth-jwt") {
    route("/featureA") {
      get("/") {
        val principalSubject = call.principal<JWTPrincipal>()?.subject
        featureAService.handleGet(call, principalSubject)
      }
      post("/") {
        val principalSubject = call.principal<JWTPrincipal>()?.subject
        featureAService.handlePost(call, principalSubject)
      }
      put("/") {
        val principalSubject = call.principal<JWTPrincipal>()?.subject
        featureAService.handlePut(call, principalSubject)
      }
    }
    route("/featureB") {
      get("/") {
        val principalSubject = call.principal<JWTPrincipal>()?.subject
        featureBService.handleGet(call, principalSubject)
      } 
    }
  }  
}

In this case I’d like to provide the principalSubject to each method (in reality there are a few more context parameters that are shared across those methods like parameters etc.). I don’t want to start each method with retrieving unsers and other context parameters and I also don’t want to repeat those lines in the

routing

section. Is there any way to reduce the amount of code here by having some preprocessor (could then use

context-receivers

)?

Hey will share this here also, probably fits better here! I use ktor version 2.0.3 and kotlin version 1.7.10

Hi, I've tried to debug this situation but I've been unable to:

val dnb = "<https://www.dnb.com/apps/dnb/servlets/CompanySearchServlet>"
val res = client.get(dnb) {
    url {
        parameters.append("pageNumber", "1")
        parameters.append("pageSize", "5")
        parameters.append("searchTerm", "NQB8 Limited")
        parameters.append(
            "token",
            "eyJwNCI6IklvTEh3WVN6SkZTaDJLUG0zYU41c1NacnZLUFBNUE1MTlBSTE1RIiwicDIiOjksInAzIjozOCwicDEiOjE2NjM2MzI0NjgyMzd9"
        )
    }
}
println(res)

It works on postman, but it kinda freezes on Ktor with no response.

Any suggestion of a scheduling library that works nicely with Ktor?

Hello lovely folks! I have a question with regards to

HttpClient

re-use. What is the accepted wisdom here? Create a new one as needed, or never

close()

the existing one? What do people do? Thanks!

Hello 👋 While using Ktor HttpClient Is there a way to automatically set

Content-Length

header (default in v1.6) vs

Transfer-Encoding: chunked

(default in v2.0)?

Hey 👋 Is there any reason why the constructor of the

HttpCacheEntry

is internal? This makes it impossible to extend the

HttpCacheStorage

to be able to implement a custom caching solution, in which the entries could be persisted in a database (Android/iOS)

hello, are there any examples of handling a client file upload using the JavaScript engine? Thanks

Is this an ok way to run backround tasks in ktor?

suspend fun Application.runJobs(jobService: JobService) {
    withContext(this.coroutineContext) {
        launch {
            while (true) {
                delay(1000)
                println("hello")
            }
        }
    }
}

Is it possible to use ktor as HTTP proxy (forward/outbound proxy)? I already implemented the reverse proxy part for inbound connections, but I need it also for outbound connections. The proxy just filters request depending on some headers.

I can't test post requests in a project I created using the Ktor project generator. I copy and pasted the sample from ktor docs: https://ktor.io/docs/testing.html#configure-client I can't quite figure out what the error is trying to tell me, I tried HttpClientConfig@this.install, but that didn't help.

Hello have somebody already done HATEOAS api with ktor?

Is there any way for me to debug why my endpoint only works once? The second time I'm calling it ktor just hangs. The debugger never hits the first line within the route endpoint body. Restarting the server makes it work for 1 time again.

Reminder: Folks, we’d really appreciate it if you could take 5-10 minutes to fill this survey in. It really does help us. Thanks. https://surveys.jetbrains.com/s3/ktor-annual-customer-survey-2022

This message was deleted.

I have a data class which looks like this:

/**
 * Represents a single list, which can contain categories to organize list items in it
 */
@Serializable
data class ListDto(
    @Contextual @SerialName("_id") val id: String = ObjectId().toHexString(),
    val user_id: String,
    var name: String,
    val categories: MutableList<CategoryDto>,
    // TODO: types do be defined
    var icon: String,
    var color: String
)

I want the user to create a new List from the frontend so I will need to receive the list data in my ktor put route

route("/lists") {
            get {
                // Returns all lists
            }

            put {
               // Need to receive the list data here but obviously it doesn't have an id yet
            }

The issue is that when the user wants to create a list it will not send the list id too, 'cause that will be generated on the server after receiving the list properties like name, categories, etc... Isn't there a way to reuse the ListDto data class but fill the id variable dynamically?

I am using rSocket with the ktor WebSockets support. Each time a client disconnects I get an Error log message. Any ideas on how I can handle it so it does not flood our server logs?

Caused by: kotlinx.coroutines.channels.ClosedReceiveChannelException: Channel was closed
	at kotlinx.coroutines.channels.Closed.getReceiveException(AbstractChannel.kt:1108)
	at kotlinx.coroutines.channels.AbstractChannel$ReceiveElement.resumeReceiveClosed(AbstractChannel.kt:913)
	at kotlinx.coroutines.channels.AbstractSendChannel.helpClose(AbstractChannel.kt:342)
	at kotlinx.coroutines.channels.AbstractSendChannel.close(AbstractChannel.kt:271)
	at kotlinx.coroutines.channels.SendChannel$DefaultImpls.close$default(Channel.kt:93)
	at io.ktor.websocket.DefaultWebSocketSessionImpl$runIncomingProcessor$1.invokeSuspend(DefaultWebSocketSession.kt:204)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
	at kotlinx.coroutines.DispatchedTaskKt.resume(DispatchedTask.kt:234)
	at kotlinx.coroutines.DispatchedTaskKt.resumeUnconfined(DispatchedTask.kt:190)
	at kotlinx.coroutines.DispatchedTaskKt.dispatch(DispatchedTask.kt:161)
	at kotlinx.coroutines.CancellableContinuationImpl.dispatchResume(CancellableContinuationImpl.kt:397)
	at kotlinx.coroutines.CancellableContinuationImpl.completeResume(CancellableContinuationImpl.kt:513)
	at kotlinx.coroutines.channels.AbstractChannel$ReceiveHasNext.completeResumeReceive(AbstractChannel.kt:947)
	at kotlinx.coroutines.channels.AbstractSendChannel.offerInternal(AbstractChannel.kt:56)
	at kotlinx.coroutines.channels.AbstractSendChannel.send(AbstractChannel.kt:134)
	at io.ktor.websocket.RawWebSocketJvm$1.invokeSuspend(RawWebSocketJvm.kt:68)
	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)

Hello, I have a problem with deflater, I use ktor CIO http client on server and ktor JS http client on client, I also use a websockets, how can I gzip messages?

I'm thinking there is a regression in Ktor 2.0 where using

kotlinx.html

DSL exceptions are swallowed and the result of a request is just

*0.0.0.0* didn't send any data. ERR_EMPTY_RESPONSE

I found this issue for Ktor 1.x: https://youtrack.jetbrains.com/issue/KTOR-756 with status of being fixed in 1.5.4. However, I'm now using Ktor JVM 2.1.1 and

kotlinx-html-jvm:0.8.0

, and all exceptions inside the DSL get swallowed and the log just shows

2022-09-29 20:12:45.948 [eventLoopGroupProxy-4-3]  INFO 
                Application - 200 OK: GET - /<path>

Debugging the exceptions, raised exception get to the

catch

block in

T.visitTag

in

commonMain/visit.kt

in

kotlinx-html-jvm

Hello! In Ktor udp client socket there is method 'connect' wich has a remote address as one of parameters. Also in Datagram constructor there is remote address parameter as well. Why?

Hello, Is it recommended to use openapi-generator to auto generate api models and functions for ktor in a KMM project?

How can i use a proxy that authanticates with a username and password with ktor client ?

Enginge OkHttp

because im getting "Exception in thread "main" java.io.IOException: Failed to authenticate with proxy"

Is there any known issue of missing body with

testApplication

? Or a proper way to debug the request response?

Hi all. I have a form that I receive 3 fields string int file (pdf). But I'm not sure how to do this with ktor/kotlin. My class

data class SomeClass (
name: String,
age: int,
document: ByteArray (is it correct?)
)
fun Route.test() {
 route("/test") {
   post("/doc") {
      val receive = call.receive<SomeClass>()
...

is there away to make Ktor Server accept connections via mTLS?

👋 I'm trying to make a companion client plugin to the provided Auth plugin; one that, at will of the developer, can rewrite the response of the next request to return an HTTP 401 to trigger the provided Auth plugin logic and ultimately, help test that the integration works correctly. Is there an example I can look at for rewriting the response through a plugin but still have other plugins process the result? I've tried intercepting using the

sendPipeline

after

State

as well as intercepting

HttpSend

. Both had issues that didn't meet my expectations. What I expect to happen is: 1. Developer triggers my companion plugin through a debug tool of their choice so the next API call will return an HTTP 401 2. Developer triggers another API call and within one execution context: a. My companion plugin is triggered, rewriting the response to HTTP 401 b. The provided Auth plugin is triggered, with the refresh token logic being invoked & in Bearer token providers, the

access_token

&

refresh_token

are rotated c. The provided Auth plugin retries the original API with the new

access_token

and returns the response

This message was deleted.