hi all. For those using kotlinx-serialization with ktor, how did you manage to use @Serializer custom serializers with content-negotiation plugin ? i have some classes that are auto generated (so I cannot annotate them with @Serializable), but I cannot find a way for ktor to use the custom serializer

Hello, I would to make a jar with shadowJar of Ktor + Vue.js. But Vue.js is not working with the jar. Any idea ?

I'm building a Telegram Bot API library in Ktor and I realized there's something I don't understand about Ktor client. I'm using

kotlinx.serialization

for serializing objects and here's my issue: The Telegram API supports a lot of methods. Here's an example of one such method: The

getFile

method. It has one parameter:

file_id

which is of type

String

. These methods can receive their parameters through JSON objects. So, if I want to send a request to this method, I first create a

class

called

GetFileJSONRequest

with

@SerialName()

annotations (because in Kotlin, the parameter is called

fileId

and in JSON it has to be

file_id

). And then, I send the request like this:

val response: HttpResponse = <http://client.post|client.post>("<https://api.telegram.org/bot123456:ABC-DEF1234ghIkl-zyx57W2v1u123ew11/getFile|https://api.telegram.org/bot123456:ABC-DEF1234ghIkl-zyx57W2v1u123ew11/getFile>") {
    contentType(ContentType.Application.Json)
    setBody(GetFileJSONRequest(fileId = fileId))
}

This whole process with creating classes seems very tedious and I wonder if there's a much better solution to my problem.

Hi all, good day. I would like to ask if someone know if its possible to run a ktor service with two different ports (and set of routes) so, for example, I can have the metrics scrapper running on a separate port) . I tried looking at the docs but could not figure out a way of doing that.

Could someone please help me with the

kotlinx.serialization

one? I saw on Stack Overflow that it's an unsolved mystery, but I feel like it is super important to know a good fix because it might be a deal breaker for some people.

Hi, Does anyone have a clue if it's possible to retrieve client principal when using the StatusPage plugin? The AuthContext does not seem to exist in call.attributes

📣 Ktor 2.0.3 has been released 📣 https://twitter.com/JetBrainsKtor/status/1543854529720061955

here's a random and spontaneous THANK YOU for creating ktor 🙂 I know ktor a bit, and now learning about Spring Boot. I really like how ktor tackles routing and e.g. security - it's so clear to see which endpoints are secured with each mechanism, contrary to how it's done in Spring. No magic annotations! 🙂 Thanks and please keep up the great work!

Should https://kotlinlang.org/docs/releases.html#release-details still reference ktor 2.0.0-beta1 as the recommend version?

Just hit my head on something that was totally my fault, but maybe could be improved on. I couldn't tell why I was getting 404s on my routes for some, but not all. I was using type-safe routing.

import <http://io.ktor.server.resources.post|io.ktor.server.resources.post> // GOOD
import <http://io.ktor.server.routing.post|io.ktor.server.routing.post> // BAD

I'm facing a weird error after migrating to ktor 2, about coroutine dispatcher limited parallelism. This is something they changed and added as support but seems weird that I need to set some configuration about it. Has someone experienced this issue? Using Ktor 2.0.3, Kotlin 1.7.0 and kotlinx-coroutines 1.6.0 (tried with 1.6.2 too)

In the ktor client docs https://ktor.io/docs/response.html#streaming. It shows usecase of a function called

prepareGet

but doesn't seem like this function exists

After switching to Kotlin 1.7.0, my JS application with the Ktor client 2.0.2/2.0.3 throws an exception. Has anyone else observed this?

Is it possible to download a file from the local file system using ktor?

We've started seeing an intermittent StacklessClosedChannelException since updating to ktor 2 (Netty). Is there anything we could try to squash them? Attaching stacktrace 🧵

Hi everyone! Trying to understand how to pass command-line options for array parameters (e. g.

ktor.application.modules = []

), but it fails with error like this:

Exception in thread "main" com.typesafe.config.ConfigException$WrongType: Command-line options: tasks has type STRING rather than LIST

I'm using a long polling method of retrieving data from the Telegram API and basically, the problem is that it takes sometimes too much time for the client to respond to a response. Basically, I send a request to the server, the server keeps the connection open until some new update arises, and when it does, the server (API) responds to my request, delivering new useful information. Now... It takes sometimes a second (which I consider too much time) from me sending a message until the client registers it. Here's the client code:

private val client = HttpClient(CIO) {
    install(DefaultRequest)
    install(ContentNegotiation) {
        json(Config.json)
    }
    install(HttpTimeout) {
        connectTimeoutMillis = 30_000
        requestTimeoutMillis = 30_000
    }
    install(Logging) {
        level = LogLevel.ALL
    }
    defaultRequest {
        url("<https://api.telegram.org/bot${bot.token}/>")
    }
}

And this is how I handle the updates:

internal val updateFlow: Flow<Update> = flow {
    while (true) {
        try {
            val updates = getUpdates(
                offset = currentOffset,
                timeout = KramBot.LONG_POLLING_TIMEOUT_SECONDS
            )
            // Telegram servers return an empty JSON array after the timeout if there are no updates
            if (updates.isEmpty()) continue
            updates.forEach { emit(it) }
            currentOffset = updates.last().updateId + 1
        } catch (e: HttpRequestTimeoutException) {
            println("Timed out.")
        }
    }
}

private suspend fun getUpdates(
    offset: Int? = null,
    limit: Int? = null,
    timeout: Int? = null,
    allowedUpdates: List<String>? = null
): List<Update> {
    val response = <http://client.post|client.post>("getUpdates") {
        with(url.parameters) {
            offset?.let { append("offset", it.toString()) }
            limit?.let { append("limit", it.toString()) }
            timeout?.let { append("timeout", it.toString()) }
            allowedUpdates?.let { append("allowed_updates", it.toString()) }
        }
    }
    when (val apiResponse = response.body<ApiResponse<List<UpdateDto>>>()) {
        is ApiResponse.Ok -> return apiResponse.result.map { it.toEntity() }
        is ApiResponse.Error -> error(
            """
                Got an error response from the getUpdates method which should be impossible.
                Error code: ${apiResponse.errorCode}
                Description: ${apiResponse.description}
            """.trimIndent()
        )
    }
}

Hey everyone, I’m struggling with SSL and the ktor client. For some reason when i try to do a GET request with an HttpClient(CIO) i receive a

Failed to parse HTTP response: unexpected EOF

. After searching for a while I stumbled upon a java example where they were using this command:

System.setProperty("jdk.tls.maxHandshakeMessageSize", "65536")

. It did not change a thing when using HttpClient(CIO) but with HttpClient(Apache) the call is going through just fine now. Is there some other way to change the message size for CIO or should i just stick with the Apache engine?

hi, everyone I'm using Ktor client 2.0.x with Bearer Auth. I have many requests don't need authorization. what is the way to tell Ktor don't add authorization header

is there any way to catch connection errors in Ktor client? Am using OkHttp engine

Hello Team! Whats the best way to get metrics from

ktor-client

? It looks like the

ktor-server

has some metrics integrations - but I couldn’t quite get the details for the client.

Is there a way to limit the file upload size using multipart with

ktor-server

? I'm using

1.6.8

.

Hello. I’m an Android developer who use Ktor in private and pro apps I’m learning the server side with Ktor and I’d like to expose a video file thought API (like real time streaming content). I know nothing about this kind of thing and I don’t even know where to begin with. Is Partial Content is the way ? Oh and is there any third party library that can help me to do so (+ can handle slow connection and stuff like this) ?

📣 New Deployment Plugin 📣 We’ve just released a new plugin for Gradle that aims at simplifying deployment. It’s still in EAP, but we’d love to get some feedback. You can find instructions on how to use it on GitHub. https://github.com/ktorio/ktor-build-plugins

Is it possible to replace a mock response in an already created

HttpClient

without having to create other

HttpClient

?

I think I’ve discovered a bug with gzip client handling (and likely all compression plugins). If I issue a

get

for compressed data at a URL, and then call

response.body<ByteArray>()

the response bytes are truncated to the content length of the response, but that value is the compressed size. So it’s taking the uncompressed bytes, and truncated them to the size of the compressed data. Is there another way to get at the uncompressed data without doing the gzip stuff myself?

I need set NSURLSessionConfiguration into IosClientEngineConfig, how to do it ?

Hei Hei. I am wondering if Ktor team has concluded something regarding open api doc generation/ swagger support so far ? Would be super interesting to hear if you have thought about how this will be supported in the framework or the project attached in the swagger youtrack ticket will be adopted as is ? It was mentioned in the roadmap https://blog.jetbrains.com/ktor/2022/02/11/ktor-roadmap-what-s-next/

Is there a way to have a route with optional authentication? I have a specific route that both users and anonymous clients can access.

What would be the equivalent of this curl statement in ktor?

curl -X POST \
    $url \
    -H "Accept: application/json" \
    -H "Content-Type: application/octet-stream" \
    --data-binary "@$FILE"

i tried sending the file as body but I quickly ran out of memory with

setBody(file.readBytes()

. Is there a streaming implementation without using MultiPartForm?