Hi there. What is the preferred way of mocking ApplicationCall? I don’t want to create whole

testApplication { … }

, but I have a method that is simply

suspend fun readPartsContents(call: ApplicationCall): List<UploadedContent> = call
    .receiveMultipart()
    .readAllParts()
    .flatMap(::processPart)

and I’d like to mock that

call

in my unit test. But I can’t since

.receiveMultipart()

is unmockable extension function…

📣 Ktor 2.1.1 released! https://ktor.io/changelog/2.1/ 📣

Hi, what plugin should I use to have code completion for my

application.conf

file ? I have the

ktor

plugin but it shows very little syntax highlighting and no real code completion ? (just the words I already used in the file)

In Ktor client How does the

DefaultRequest

plugin work with

WebSockets

.

Hi, Why isn't there a nullable variant of

@JvmName("postTyped")
public inline fun <reified R : Any> <http://Route.post|Route.post>(
    crossinline body: suspend PipelineContext<Unit, ApplicationCall>.(R) -> Unit
): Route = post {
    body(call.receive())
}

? I realize there's

receiveNullable

but there's no way to do it via route declaration, only in the body of the route itself 😕 EDIT: Nvm I realize I'm just stupid, I could just make properties inside the route model nullable instead to achieve the same effect :D

hi everyone

I am looking for a function that manages programmatically the parameters in a GET, to create DB queries dynamically. At the moment, i have the following:

route("/sCap"){
    val dao: DAOFacade = DAOFacadeImpl()
    get{      
        val codiceParam = call.request.queryParameters["codice"]
        val listSCap = dao.allSCapFiltered(codiceParam)
        if(listSCap.isEmpty())
            call.respondText("Nessun elemento trovato", status = HttpStatusCode.NotFound)
        else
            call.respond(listSCap)
    }
...
}

and in the DAO:

override suspend fun allSCapFiltered(codice: String?): List<SCap> {
    return if(codice.isNullOrEmpty()){
        DatabaseFactory.dbQuery {
            S_Cap.selectAll().map(::resultRowToSCap)
        }
    } else {
        DatabaseFactory.dbQuery {
            S_Cap
                .select { S_Cap.codice like "%$codice%" }
                .map(::resultRowToSCap)
        }
    }
}

is there a way to manage all the parameters expected dynamically, based on properties of data class?

data class SCap(val idcap: Int?,
                    val regione: String?,
                    val prov: String?,
                    val comune: String?,
                    val cap: Int?,
                    val codice: String?
                    )

Thanks everyone for suggestions!

I would appreciate some help with this issue I posted on Youtrack https://youtrack.jetbrains.com/issue/KTOR-4865/Receiving-null-body-after-HttpResponseValidator-is-executed

Ktor support STOMP??

Hey, I want to create a client library for opensearch that takes advantage of kotlin features to provide a better DSL than a pure java library. For it, I am considering using ktor as the http client library. Is there any guidance on the best practices / do's & don'ts of writing such client libraries? Or perhaps another client library which "does it well"? Some things like using different dispatchers or not, ways of allowing user to configure the internals, other things I need to consider etc.

How can I write a unsigned 16 bit int to the send channel in a unix socket connection? There's

writeShort

but that's for signed int

Hello, how can I know in local if I’m in debug mode or not ?

Hey guys, I'm currently trying to write a TCP proxy with KTor, however I'm having some trouble reading from one

ByteReadChannel

and copying those bytes over and Writing to another

ByteWriteChannel

The proxy should tunnel connections from client A to server B via proxy server C like so:

A <---> C <---> B

currently, I have something like the following:

//some boilerplate to open correct channels and establish socket connections
val clientReadChannel = clientSocket.openReadChannel()
val clientWriteChannel = clientSocket.openWriteChannel(true)

val serverReadChannel = serverSocket.openReadChannel()
val serverWriteChannel = serverSocket.openWriteChannel(true)

launch(<http://Dispatchers.IO|Dispatchers.IO>) {
    clientReadChannel.copyTo(serverWriteChannel)
}

launch(<http://Dispatchers.IO|Dispatchers.IO>) {
    serverReadChannel.copyTo(clientWriteChannel)
}

I'm having some trouble figuring out what I'm doing wrong in my code using sockets to communicate with the X window system protocol

val selectorManager = SelectorManager(Dispatchers.Main)
val socketPath = "/tmp/.X11-unix/X2"
val tcp = aSocket(selectorManager).tcp()
val clientConnection = try {
    tcp.connect(UnixSocketAddress(socketPath))
} catch (e: Exception) {
    selectorManager.close()
    println(e.message)
    exitProcess(1)
}

val readChannel = clientConnection.openReadChannel()
val sendChannel = clientConnection.openWriteChannel()

val authName = ""
val authData = ""

fun BytePacketBuilder.writePadding(bytes: Int) {
    repeat((4 - bytes % 4) % 4) { writeByte(0) }
}

sendChannel.writePacket {
    writeUByte(102u)
    writeByte(0)
    writeUShort(11u)
    writeUShort(0u)
    writeUShort(authName.length.toUShort())
    writeUShort(authData.length.toUShort())
    writeByte(0)
    writeText(authName)
    writePadding(authName.length)
    writeText(authData)
    writePadding(authData.length)
}

sendChannel.flush()

println(readChannel.readByte())

It just suspends at the readByte call

How do I setup static routing with the Native version of Ktor Server? I tried doing the following to setup static routing:

// ...
    static("/") {
        staticRootFolder = File("files")
        file("index.html")
        default("index.html")
        static("assets") {
            files("css")
            files("js")
        }
    }

For some reason all the missing imports cannot be completed. The main exception to this is

File

.

Is there a simpler way to do this

val vendor = buildString {
    repeat(lengthOfVendor) {
        append(readChannel.readByte().toInt().toChar())
    }
}

Hei ! I see Ktor is very relaxed on using GlobalScope in the framework. However, GlobalScope is marked as delicate api, and I have been bitten by it by abusing it unintentionally. Biggest disadvantage of using GlobalScope is, that it is not bound to any scope, thus it cannot be cancelled, in regards to structured concurrency (correct me if I am wrong). This can easily lead to memory leaks and unclosed operations. Have the team thought about moving away from GlobalScope ?

Hi guys, i have question regarding a HttpClient query which is returning a TooLongLineException. Is there any way to fix this issue in ktor? It seems there is a but raised for it https://youtrack.jetbrains.com/issue/KTOR-2588/ByteReadChannel-is-unable-to-read-files-with-long-lines

"i.k.u.i.c.TooLongLineException: Line is longer than limit\n\tat i.k.u.i.ByteBufferChannel$readUTF8LineToUtf8Suspend$2.invokeSuspend(ByteBufferChannel.kt:2094)\n\tat i.k.u.i.ByteBufferChannel$readUTF8LineToUtf8Suspend$2.invoke(ByteBufferChannel.kt)\n\tat i.k.u.i.ByteBufferChannel$readUTF8LineToUtf8Suspend$2.invoke(ByteBufferChannel.kt)\n\tat i.k.u.i.ByteBufferChannel.lookAheadSuspend$suspendImpl(ByteBufferChannel.kt:1826)\n\tat i.k.u.i.ByteBufferChannel.lookAheadSuspend(ByteBufferChannel.kt)\n\tat i.k.u.i.ByteBufferChannel.readUTF8LineToUtf8Suspend(ByteBufferChannel.kt:2076)\n\tat i.k.u.i.ByteBufferChannel.readUTF8LineToAscii(ByteBufferChannel.kt:2011)\n\tat i.k.u.i.ByteBufferChannel.readUTF8LineTo$suspendImpl(ByteBufferChannel.kt:2113)\n\tat i.k.u.i.ByteBufferChannel.readUTF8LineTo(ByteBufferChannel.kt)\n\tat i.k.u.i.ByteBufferChannel.readUTF8Line$suspendImpl(ByteBufferChannel.kt:2117)\n\tat i.k.u.i.ByteBufferChannel.readUTF8Line(ByteBufferChannel.kt)\n\t

Using ktor-network, how can I accept incoming connections while still respecting cancellation? acceptSuspend does a

while (true)

loop until a connection appears.

Hello! How can i make HttpClient's coroutine scope not cancelling on call fails?

I've been trying to use ktor's auto-reload with embeddedServer, and it seems like everything should be working.

INFO  ktor.application - Application auto-reloaded in 0.008 seconds.

the above prints and everything in the console, but the actually responses aren't changing. I'm using coretto 17

In "Sign and encrypt session data" (https://ktor.io/docs/sessions.html#sign_encrypt_session) the example code uses hex strings, can these be of any random hex sequence (assuming they're the same every time), or is there some importance to their values?

Hey! Regarding client

ContentNegotiation

plugin: I need access to the serialised body (as

TextContent

) in order to calculate a header value: The api I’m using expects a signature header which needs the body content for calculating the signature value 🙃. Snipped of what I’m trying to do in

HttpRequestPipeline.Send

phase:

private val HttpRequestBuilder.bodyAsText get() = (body as? TextContent)?.text

(Prior to send the body is not available as text) Problem: I cannot set headers anymore after the body had been serialised, is that correct? Do you know a workaround?

Hi, we are using ktor-client-apache to fetch some json:

client.request(url) {
    HttpMethod.Get
    accept(ContentType.Application.Json)
    contentType(ContentType.Application.Json)
    timeout { requestTimeoutMillis = 60 * 1000
              connectTimeoutMillis = 5 * 1000
              socketTimeoutMillis = 60 * 1000 }
}

Using ktor 2.0.3 we never had any problems, with version 2.1.0 and 2.1.1 sometimes the call fails with:

org.apache.http.ConnectionClosedException: Premature end of Content-Length delimited message body (expected: 41,606; received: 26,090)

Same code with the old ktor version started to work again correctly. Anyone having the same problem? Any hint on how to fix it? Thanks!

Hi, is there a lib for authentication/authorization with baked in storage for session in DB or I should implement it by my self using sessions plug ? Something like https://github.com/heartcombo/devise

Hi, while trying to deserialize an array of data, I got an error when trying to deserialize an empty JSON array that was sent with

prettyPrint

, so

[

]

I get an error

io.ktor.serialization.JsonConvertException: Illegal input

, which doesn't occur when using only

kotlinx.serialization

What value should I pass to `BearerTokens`' constructor as the (non-nullable)

refreshToken

property if there is no refresh token (in case of _client_credentials_ flow)? Thanks.

I'm trying to make a multiplatform library that wraps some API functions with ktor and I've run into the issue of how to design the libraries client constructor. Should the user just be able to call it with no args and have the library create the HttpClient, or some other design? This is the first time I've tried making a library so im a little unfamiliar right now

📣 Please take a few minutes to fill out our survey. It helps us tremendously. Thank you https://surveys.jetbrains.com/s3/ktor-annual-customer-survey-2022 📣