Hey ! What order plugins get called if there are multiple plugins performing operations on one phase ? For example on call setup phase (

on(CallSetup)

) I have three different plugins registered. What is the execution strategy ?

Anyone deploying Ktor service using Railway?

I wonder, is there any tool which takes an OpenAPI yml file, and generates a ktor client with all the existing endpoints?

very basic… but why this test code is not compiling on the

install

statement?

@Test
    fun testOptimizeRouter() = testApplication {
        val client = createClient {
            install(ContentNegotiation) {
                json()
            }
        }
        // omitted
     }

Ktor 2.1.3 Kotlin 1.7.21 IDEA CE 2022.3 Beta (EAP)

Hi, I wrote a HttpClient plugin to change the auth header for some requests; so far so good. I do not want the user to get the session cookie, so I want to strip the "set-cookie" header from the response. The headers in the response object are read-only. Is there a location (intercept) somewhere where I could change the response headers?

scope.requestPipeline.intercept(HttpRequestPipeline.State) {
   // inject auth header here - works fine
   val clientCall = proceedWith(subject)
   // Remove session cookie here - don't know how to do this
}

does someone have a working example of hosting a JS frontend from within ktor server? I’m aware of singlePageApplication routing and I achieved something like this like a year or two with a bunch of custom logic, but now I want to use the idiomatic way I’m stuck in a place where I have two projects: the one in Kotlin/JS (React) that produces a working bundle in

build/distributions

, and another module with a working ktor server. What’s the idiomatic way to declare a dependency on the web UI project form the ktor project, copy over the bundle to the ktor module and serve it from ktor? My ultimate goal is being able to create a Docker image with the server hosting the web UI, so I presume the bundle should land somewhere in JVM

resources

Is there a way to schedule a task in ktor? I want to sechedule a task for 20 minutes if they are over, that task should be marked expired. Am having idea of using delay but not sure if its tye best approach so far.Any one please?

hey guys, does anyone know any alternate way of registering everything in the application receiver object, this seems to grow a lot when you add stuff and can become quite messy

Is it possible to send a chunked response with ktor-server? Here is what it looks like in vertx:

val response = request.response()
val channel = response.toSendChannel(vertx)

response.headers().set("Transfer-Encoding", "chunked")

for (i in 1..10) {
  delay(200)
  channel.send(Buffer.buffer("""{"id": $i}"""))
  channel.send(Buffer.buffer("\n"))
}

response.end().await()

Hello, we have a sequence of tests like:

should("respond OK") {
    testApplication {
        application {
            mockService("11111111111")
            configureServing()
            configureRouting()
        }
        client.get("/v1/foo/XXX00000000123").apply {
            assertEquals(HttpStatusCode.OK, status)
        }
    }
}
should("respond to Unauthorized") {
    testApplication {
        application {
            mockService("12345678")
            configureServing()
            configureRouting()
        }
        client.get("/v1/foo/XXX00000000123").apply {
            assertEquals(HttpStatusCode.Unauthorized, status)
        }
    }
}

and the mockService mock a static builder using mockk

private fun mockService(id: String?) {
    mockkObject(ReferenceClientBuilder)
    val fakeService = mockk<ReferenceClient>()
    coEvery { fakeService.customerId(any()) } returns id
    ...
    coEvery { ReferenceClientBuilder.getClient(any()) } returns fakeService
}

Up to ktor 2.1.2 everything was ok, but now with 2.1.3 the second test fails cause the static mockk is just set on the first test and not updated on following ones. Any hints? Thanks!

Hi, I'm trying to use https://ktor.io/docs/response-validation.html#2xx and in there to use request attributes so, something like:

httpClient.get("/whatever") {
   attributes.put("operation", "whatever")
}

and then in my validator:

val client = HttpClient(CIO) {
    install(ContentNegotiation) { json() }
    HttpResponseValidator {
        validateResponse { response ->
          if response.request.attributes["operation"] == "whatever"
          //whatever
        }
    }
}

is this possible at all

Do I have to do something different in KTor 2.x to receive nested JSon classes? I haven't been able to find anything obvious in the KTor serialisation docs. I have a receivable class that arrives perfectly well in one call as an array of this class, but when (in another call) it's a property of a larger class no data (for it) is de-serialised. Although I'm certain the data is sent from the server, it doesn't show up in the log of the received data, which also seems strange. I know this sounds like a foolish question but it used to work, although I'm not sure if this failure is due to the KTor 2.x update or something else.

📣 Announcement: Marketplace Feedback We are starting work on the marketplace, which will allow Ktor users to discover and use 3rd party Ktor plugins. Whether you're a consumer of these plugins or publish Ktor plugins, we would really love to have a chat with you and make sure that the challenges you are facing would be accounted for. Please ping me or reply in this message if you'd like to discuss and work a bit closer on this matter with us.

Hi Team! I'm still new to ktor/kotlin, and have been playing around with the framework for websocket development. My current project is a websocket proxy (we accept a ws connection, and create a connection to another backend ws server, and route messages between them). The code works fine, but I'm having issues with setting up tests for this, specifically with trying to mock out the backend ws server with

externalServices

. This is the mock I have right now in my `testApplication`:

externalServices {
    hosts("<ws://test.com>") {
        install(io.ktor.server.websocket.WebSockets) {}
        routing {
            webSocket("/") {
                this.send("hello")
            }
        }
    }
}

My test will hang when it tries to connect to

<ws://test.com>

and eventually return a

io.ktor.client.network.sockets.ConnectTimeoutException: Connect timeout has expired [url=<ws://test.com>, connect_timeout=unknown ms]

error. Can

externalServices

mock out ws servers? If not, are there any suggestions on how to mock a ws server for testing? Thank you!

Hello Team, How do we suppose to parse this json using ktor client?

{
  "base": "xyz",
  "rates": {
    "AED": 3.67295,
    "AFN": 87.499995
  }
}

@Serializable
class Obj(val base: String, val rates : Map<String?,Double>?)

I use kotlin serialization but observed following error

io.ktor.client.call.NoTransformationFoundException: No transformation found: class io.ktor.utils.io.ByteBufferChannel (Kotlin reflection is not available) -> class dev.packge (Kotlin reflection is not available)

I'm seeing odd behavior If i create an

HttpClient

from an

ApplicationTestBuilder()

in a test, or create an

HttpClient

mockk, and inject that into my code path that uses a normal

HttpClient

(e.g.

HttpClient(CIO)

) during a

testApplication

run. Odd side effects include authentication principals becoming null, and testcontainers not being recognized. For context I'm trying to do this to mock out some behaviors for testing. Does anyone know why this is?

I'm trying to implement a Moshi ContentConverter, but when I run the tests in

JsonContentNegotiationTest

for it, it fails testBadlyFormattedJson, that it expects a BAD REQUEST... what am I doing wrong? (code in the thread)

When defining a route that runs into an exception ktor will return an internal server error (500) by default.

fun Application.configureRouting() {
    routing {
        get("/") {
            error("Something went wrong")
        }
    }
}

But when using this in a test, the test application will not return a 500 but throw the exception instead

class ApplicationTest {
    @Test
    fun testRoot() = testApplication {
        application {
            configureRouting()
        }
        
        val response = client.get("/") // java.lang.IllegalStateException: Something went wrong
        assertEquals(HttpStatusCode.InternalServerError, response.status)
    }
}

How do I test this behavior when I rely on the default implementation of ktor?

Hey everyone, is there any more up to date redis sample other than https://github.com/ktorio/ktor-clients/tree/main/ktor-client-redis/src/io/ktor/experimental/client/redis

What is this:

'fun <P : Pipeline<*, ApplicationCall>, B : Any, F : Any> install(plugin: Plugin<Application, AuthenticationConfig, Authentication>, configure: AuthenticationConfig.() -> Unit = ...): Unit' can't be called in this context by implicit receiver. Use the explicit one if necessary

?

I had to do

this@testApplication.install(...)

🙈...

Now I'm getting

The test application has already been built. Make sure you configure the application before accessing the client for the first time.

🤕... I wish Ktor would just let me create my own

testApplication

without trying to magically find an existing one...

I see several tickets that were closed earlier for setting a base url / path. How would we properly set a base url and path for requests in ktor?

Is there a way to configure the HttpBuilder so that it won't encode the path? Android doesn't encode, but iOS does. "/v3/subscribers%3Bview=subuser_overview" vs"/v3/subscribers;view=subuser_overview" The difference causes my app to get a 404 vs the proper response.

Hi, can anyone point me to an example of a Ktor app authenticating with Azure AD?

👋Hi, I'm evaluating Ktor and was wondering what benchmarking tools folks use. I've used hey for Golang and Scala applications, and I'm seeing mixed behaviour when I run Ktor with both Netty and CIO natively on an M1 mac, as well as within Docker of the same architecture (ARM). I seem to max out at 125 connections with Netty both on the host and within a container. For CIO, I max out at 500 connections on the host, but 125 in a container. Wondering what I might need to configure/tune.

I’m receiving this when trying to run my application

Correct the classpath of your application so that it contains compatible versions of the classes io.ktor.client.utils.CoroutineDispatcherUtilsKt and kotlinx.coroutines.CoroutineDispatcher

which versions would be compatible in this case?

Is there a way to listen to the progress of a file being uploaded to a ktor server from the server side? I have a ktor server running in an Android app and I would like to display a progress bar while the ktor server is receiving the file. my code looks like this:

// 1
call.receiveMultipart().forEachPart { part ->
    // 2
    when (part) {
        is PartData.FileItem -> {
            val input = part.provider()
            // Read from input by chunks
        }
        else -> {}
    }
}

I would like to listen to the progress between (1) and (2). Right now (1) is called, then the file is fully uploaded to the server, and then (2) is called.

While testing redirects on Ktor client, i got

SendCountException

. Code in 🧵

How do I read a text/event-stream content type? In my API its being used as a sort of progress indicator. So each newline contains some data. I need to get the last line in the stream