With Ktor, do we have an easy way as with Spring to decorate methods to automatically generate OpenAPI definitions or some plugin in IntelliJ to generate it based on the available routes etc? Would be very handy. If there isn't any out there that is convenient, I'm thinking of creating one. But would be awesome if someone already built it!

Hi everyone, Why does this test pass even if it throws

AssertionFailedError

?

@Test
    fun test() = testApplication {
        install(io.ktor.server.websocket.WebSockets) {
            contentConverter = KotlinxWebsocketSerializationConverter(
                Json {
                    ignoreUnknownKeys = true
                }
            )
        }
        routing {
            webSocket("/") {
                sendSerialized(Incoming.Ping("123"))
                val outgoing = receiveDeserialized<Outgoing.Pong>()

                val a = "3"
                assertEquals("2", a) //this throws AssertionFailedError but test passes
            }
        }
        val client = createClient {
            install(WebSockets) {
                contentConverter = KotlinxWebsocketSerializationConverter(
                    Json {
                        ignoreUnknownKeys = true
                    }
                )
            }
        }

        client
            .wss("/") {
                val received = receiveDeserialized<Incoming.Ping>()
                assertIs<Incoming.Ping>(received)
                sendSerialized(Outgoing.Pong(received.id))
                val a = "3"
                assertEquals("3", a) //if this fails, test doesn't pass as expected.
            }
    }

Hi I am new to ktor , moving from reactive WebClient and having a stupid issue with non compiling code in ktor, does someone have a good example in GitHub for a post Kotlin/JVM + Spring boot 3, e.g.

val response = <http://httpClient.post|httpClient.post><MyClass1> {
    url("$myUrl")
    contentType(ContentType.Application.Json)
    body = MyClass2(MyClass3(param1, param2))
}

How would I use receivedDeserialized in a flow-style, as receiving one single frame is not really useful? I currently have this code, however this doesn't receive a single value, if I turn it into a simple for loop and receive raw frames, all frames come in fine

@OptIn(ExperimentalCoroutinesApi::class)
    private fun asFlow(session: DefaultClientWebSocketSession) = flow<Event> {
        try {
            session.incoming.consume {
                while (!isClosedForReceive) {
                    val value = session.receiveDeserialized<Event>()
                    println("Emitting event: $value")
                    emit(value)
                }
            }
        } catch (ignore: CancellationException) {
            //reading was stopped from somewhere else, ignore
        }
    }

Hi, maybe a stupid question, but I want to serve compose-web from ktor, but I’m unsure how to reference the js+html files in ktor. I have multi project setup in gradle

Is thr any way to get json data from mysql like for varchar we do it like this

val meterId = varchar("meter_id")

Good team, 1) Anybody here a microservices developer with kotlin and ktor who can share with me the repository? 2) What book or course can you recommend to learn ktor? Greetings,

Is there some set up required to make the ContentNegotiation plugin (Ktor Server) work correctly? I installed it without configuration and am using call.respond(file.readBytes()) to send the response, from a file. Content-Type header is not being set, it's the expected behavior. What am I doing wrong?

Hi! What could this error mean? I have the connectors set up and everything... (this is in unit tests using testApplication and the environment block to set the connectors...)

Can not resolve request to <http://localhost:8080>. Main app runs at 0.0.0.0:8080, 127.0.0.1:8090 and external services are 
io.ktor.server.testing.client.InvalidTestRequestException: Can not resolve request to <http://localhost:8080>. Main app runs at 0.0.0.0:8080, 127.0.0.1:8090 and external services are 
	at app//io.ktor.server.testing.client.DelegatingTestClientEngine.execute(DelegatingTestClientEngine.kt:59)
	at app//io.ktor.client.engine.HttpClientEngine$executeWithinCallContext$2.invokeSuspend(HttpClientEngine.kt:99)

Do not abandon me, thank you https://kotlinlang.slack.com/archives/C0A974TJ9/p1680122337173049

I'm reading up on how Bearer auth works with Ktor client. Am I correct that, notwithstanding a

sendWithoutRequest

block, it looks for a 401 response with a

WWW-Authenticate

header with a matching

realm

and then sends that token? Is there any way to short-circuit or restrict that?

Is there anyway to restrict Ktor Server http and/or websocket to TLS only? I know I can catch cases in the block and shut things down that way, but is there any way to configure the server to actually refuse to connect to insecure attempts?

did someone meet the issue with length of params? I made an object but the keys were param string length is shorter than 4 chars are ignored

Does the resources plugin also allow defining the data objects returned in a way that would be shareable between the client and the server (to fully specify the API in a central file)?

Hi everyone! I just discovered this wonderful community and now I have a question I hope someone can help me with. I am currently developing a Ktor application serving some endpoints to interact with a database. The endpoints defined in the routing block all exist in an authenticated block, so all requests have to include a JWT using the Bearer authentication scheme. Authentication is configured to accept JWTs signed with the RSA algorithm, very similar to the instructions in the Ktor documentation https://ktor.io/docs/jwt.html . The application works as expected, but I have a problem when creating integration tests for this application, as I then have to generate my own JWT for these tests and then somehow host a .well-known/jwks.json file for the JwkProvider to read the signing key from. From the ktor server testing documentation, I thought it would be possible to add a route in a

testApplication

hosting a jwks.json file with something like this:

@Test
fun `test that cases are correctly added to database`() = testApplication {
	routing {
		static(".well-known") {
			staticRootFolder = File("certs")
			file("jwks.json")
		}
	}
	
	<...>
}

However, that does not seem to work, and my theory is that the application sets up the routing defined here after the authentication is installed and configured(?). So my question is, does someone know a way of setting up this route before the authentication in the application is configured? Or alternatively, if someone has experience in writing integration tests for apis that are secured with (RSA signed) JSON web tokens, perhaps you can point me to a better solution for solving this. Hopefully that made sense to someone :-)

Hi. I tried ktor with xml support, but unfortunatelly i can not get it up. here is my sample i tried:

@Serializable
@SerialName("modules")
data class Modules(
    val resId: String?,
    val contentUrl: String?,
)

val httpClient = HttpClient(Android) {
    install(ContentNegotiation) {
        xml()
    }
}

lifecycleScope.launch {
    val modules = httpClient.get("...").body<Modules>()
    Log.d("MODULES", modules.toString())
}

But when i do the

httpClient.get(url).body<Modules>()

i get the following error. can you please tell me what i am doing wrong.

io.ktor.client.call.NoTransformationFoundException: No transformation found: class io.ktor.utils.io.ByteBufferChannel -> class com.example.ktor.Modules

I'm using Ktor Server with WebSocket. When I close a connection using the

close(CloseReason)

method, the connection is closed fine, but I never receive the text of the CloseReason in any browser. How can I make this work?

Hi, I was directed to this channel. Is there a good way to stream a ByteReadChannel as a ktor server response?

Is it possible to get an instance of

Json

through an instance of

HttpClient

if I can guarantee that there is a

ContentNegotiation

plugin installed with

json

configuration?

Hi there, Why Ktor can not read response twice? Anyone find a workaround for this issue by any chance? It's getting super frustrating to handle this logic in an interceptor for a kmm project. https://youtrack.jetbrains.com/issue/KTOR-5223/Ktor-Cannot-read-response-multiple-times

Howdy! Is there a way to avoid or remove automatically added Accept header

application/json

?

install(ContentNegotiation) {
    json()
}

The API I'm working with wants to deal with

application/vnd.api+json

only, and however I try to manipulate the headers, my requests are always sent with both (

Accept: application/vnd.api+json; application/json

) Thanks!

https://ktor.io/docs/type-safe-request.html Can I use Type safe requests together with

HttpClient.prepareGet()

?

Hello, guys. I’ve reported question on github https://github.com/ktorio/ktor/issues/3473 Could you please look at it?

My team is running some servers, and our app is moving into some new countries. Those countries (i.e. UK) have customer data laws, where customer data isn't allowed to leave the country, and must be stored in the country. We have the option of 1. Deploying all of our App servers into each of these regions, or 2. Deploying databases into these regions where the data is stored. My teams server experience is fairly limited, and I wondered if anyone from the community had any thoughts and could weigh in?

Can I create a plugin that adds context to the coroutine started by ktor (server) to handle a request?

Hi. I am working on a Ktor project and I need to execute a code block for every request made to the server. I am passing the Firebase authToken from client as header and need to verify if for all the requests. One approach is to create a lamba and call it for every request manually. Any good alternative for this?

I am trying to use Websockets on K/N but I receive this error "Uncaught Kotlin exception: io.ktor.client.network.sockets.ConnectTimeoutException: Failed to receive response: Das Zeitlimit für den Vorgang wurde erreicht. Error 12002 (0x80072ee2)" Code

public fun main(): Unit = runBlocking {
    val client = HttpClient(WinHttp) {
        install(WebSockets)
    }

    println("Connecting now")
    val session = client.webSocketSession("<wss://ws.postman-echo.com/raw>")
    println("sending")
    session.outgoing.send(Frame.Text("test"))
    println("Receiving")
    println(session.incoming.receive().data.decodeToString())
}

Hi. I followed this tutorial Build a full-stack web app with Kotlin Multiplatform, but instead of MongoDB, I used h2database with Exposed. Now I want to deploy this project on Azure. I found this tutorial Deploy Your Ktor Project Anywhere! (the idea is to create a jar and then deploy it with Docker). But when I try to run the jar created by shadowJar, I see just a white screen. I mean backend works, but the frontend doesn't. I would be really grateful for any help.

In case anyone is interested, I documented my integration of Ktor (server-side) with Sentry performance monitoring here: https://youtrack.jetbrains.com/issue/KTOR-5323/How-to-enable-sentry-api-call-transaction-reports#focus=Comments-27-7091879.0-0.

I see that

AuthenticationContext.principal

is now deprecated. What if I don't know the provider of my principals and I just want to get a list of them? That doesn't seem possible anymore?