While trying to upload files and the file is a little big (>700KB) from kotlin-react with ktor-client I still hit a buffer limit:

"IllegalArgumentException: should should be greater than write space + end gap (size = 9, writeRemaining = 0, endGap = 8, rem+gap = 8
    at IllegalArgumentException_init_0 (<http://localhost:9000/bundle.js:162304:32>)
    at require$ObjectLiteral_1.doFail (<http://localhost:9000/bundle.js:34344:9>)
    at IoBuffer.writeBufferAppend_ehtrw3$ (<http://localhost:9000/bundle.js:35661:7>)
    at ByteReadPacket_0.ByteReadPacketBase.prepareRead_87ik6q$ (<http://localhost:9000/bundle.js:31628:10>)
    at ByteReadPacket_0.ByteReadPacketBase.readAsMuchAsPossible_v6e8td$_0 (<http://localhost:9000/bundle.js:31444:15>)
    at ByteReadPacket_0.ByteReadPacketBase.readAsMuchAsPossible_v6e8td$_0 (<http://localhost:9000/bundle.js:31455:19>)
    at ByteReadPacket_0.ByteReadPacketBase.readAsMuchAsPossible_v6e8td$_0 (<http://localhost:9000/bundle.js:31455:19>)
    at ByteReadPacket_0.ByteReadPacketBase.readAsMuchAsPossible_v6e8td$_0 (<http://localhost:9000/bundle.js:31455:19>)
    at ByteReadPacket_0.ByteReadPacketBase.readAsMuchAsPossible_v6e8td$_0 (<http://localhost:9000/bundle.js:31455:19>)
    at ByteReadPacket_0.ByteReadPacketBase.readAsMuchAsPossible_v6e8td$_0 (<http://localhost:9000/bundle.js:31455:19>)"

I post via

client.submitForm {}

and I’ve tried

submitFormWithBinaryData {}

as well, no differences 😞

seems to be happening because of

val client = HttpClient() {
    install(BasicAuth) {
      username = "test"
      password = "pass"
    }
    install(JsonFeature) {
      serializer = GsonSerializer()
    }
  }

Hi, all. I got some trouble with ktor. I made java lib(jar) which include following code. And I call the function in SpringBoot project. Compilation is ok but when it is called, I got “java.lang.ClassNotFoundException: io.ktor.client.HttpClientJvmKt” error. What’s should I do?

Hi, we are working on an offline-first app that may be run on shared computers and are trying to put together a sensible session management process. We'd initially used the out-of-the-box cookie-based sessions setup and an HttpOnly cookie to mitigate the risk of session hijacking via XSS. However this poses a problem because when the user's session expires while they are offline, it makes it impossible to clear down that cookie programatically. To solve this, we'd like to set up sessions based on one HttpOnly cookie and one that is accessible to JavaScript as a kind of composite key, and we're trying to gauge how much of the ktor sessions code we will be able to reuse and how much we would need to implement. That will enable us to clear one of the cookies to kill the session even while the user is offline, but we still get the benefits of the HttpOnly cookie while they are online. Our understanding is that the existing cookie() feature expects to deal with only a single cookie. Also Sessions.Configuration is not an open class so we cannot create our own implementation there, which means we probably can't use the existing feature at all, and would need to reimplement most of the cookie session handling code. Is that correct? Perhaps you have a better approach for how to handle an offline logout - we'd certainly be interested!

Is there a good example of unit testing MPP Ktor client using serialization with

MockEngine

?

Hi guys! I'm trying to create a Feature that will wrap the end result of the various parsing engines (JsonFeature etc...) to a custom Response class. What's the best way of doing it? e.g. I want to be able to do

httpClient.get<Result<MyApiResponseType>>(...)

and getting a result object that will contain its success/fail state, the exception etc.

Hi everyone, has anyone had success using Ktor as a real-time backend for a game? Does that sound like a reasonable undertaking or would things like scaling be too cumbersome to deal with?

I’m trying to use JWT authentication for a REST API. I have the verifier running but I can’t get at the things I’d like to in the token, for example the scopes. If I look in the debugger I can see that the Payload is actually an Auth0 PayloadImpl. The Impl has a ‘tree’ property that has the data I need but this isn’t a public class so I can’t cast to it. Am I missing something, is there a way to get at the scopes for example?

What is the best way to read the full response body of a Ktor

HttpResponse

as a String? We are finding crashes when we do things like

response.content.readUTF8Line()

Hello, just curious Why ktor http client cannot set header

Content-type

?

Hello, I can set socketTimeout at different block, is there any differences between the block between

engine block

and

customizeClient block

?

val clientCall = HttpClient(Apache){
          engine {
            socketTimeout = config?.timeoutMsec ?: 10_000
            connectTimeout = config?.connectTimeout ?: 10_000
            connectionRequestTimeout = 20_000

            customizeClient {
              setProxy(requestProxyHost)

              socketTimeout = config?.timeoutMsec ?: 10_000
              connectTimeout = config?.connectTimeout ?: 10_000
              connectionRequestTimeout = 20_000
            }
          }
        }

My scenario is for my signature validation on my auth provider I need the "raw" string. And in my actual code I need it parsed as form parameters (using receiveParameters)

Hello I got this error, when do http call using ktor http client

Request cannot be executed; I/O reactor status: STOPPED

What does it mean ?

Hello everyone, I would like to implement a system in order to get push notifications for devices. What approach would you consider? I was thinking about authenticated websockets, but I'm not sure this would be the best approach. Have you guys any idea how I could implement such a feature with Ktor?

I have a weird problem with HttpClient Logging feature, if I use body logging with call pipeline receive<InputStream> and then streaming the response into Jackson object mapper, the logger freezes at BODY START indefinitely. Is it a bug?

Hello, with this code, why it hang up ? As you can see at console.log, it stop at the total cpu core

suspend fun main () = coroutineScope {
    var counter = 1
    launch {
        while (true) {
            HttpClient(Apache) {
                engine {

                }
            }.use {
                val clientResponse = it.call {
                    method = <http://HttpMethod.Post|HttpMethod.Post>
                    url(URL("<https://httpbin.org/post>"))
                    body = TextContent(bodyVal, contentType = ContentType("application", "json"))
                }.response

                val jsonResponseString = String(clientResponse.readBytes())

                println(counter.toString())
                counter += 1
            }
        }
    }

    println("abc")
}

Hi guys, I have some code that relies on MDC to log some context data (SessionID for example). I use Ktor Http Client to call some REST services, with OkHttp. I understand that the OkHttp calls are made using coroutines and I don't have access to MDC data that is based on

ThreadLocal

. I saw that

kotlinx.coroutines.slf4j

introduces

MDCContext()

and that, this way, you can launch some coroutines passing them MDC data. But is there a way I can use it to propagate my MDC data to the underlying OkHttp calls ?

I have a service that do http call to other service. Is it okay to not close() the ktor http client ?

Hello, why this code block doesn't work ya ?

fun exec () {
    GlobalScope.launch {
        var counter = 1
        val httpClient = HttpClient(Apache)
        while (true) {
            val clientResponse = httpClient.use {
                it.call {
                    method = <http://HttpMethod.Post|HttpMethod.Post>
                    url(URL("<https://httpbin.org/post>"))
                    body = TextContent(bodyVal, contentType = ContentType("application", "json"))
                }.response
            }

            val jsonResponseString = String(clientResponse.readBytes())
            println(counter.toString())
            counter += 1
        }
    }
}

suspend fun main () = coroutineScope {
    exec()

    Thread.sleep(1000000)
}

Is it because I use

.use{

?

with ktor I can do

server.start(wait = false)

however the server never stops.

server.stop(1, 1, TimeUnit.SECONDS)
server.application.dispose()

result in the process staying alive, even though the netty worker pool is freed. Is there a way to fully stop the server and let the process naturally exit?

What’s the

ktor-auth

idiomatic way to return a

403 Forbidden

for a found principal? I am able to authenticate the user with their credentials, but I committed to the clients that I would return a forbidden respond when the user is not authorized with a certain permission.

sorry noob question, I'm curious about how ktor implement http client call, is it will utilize coroutines for each http call instead of threads ?

would anyone have any guidance if i wanted to send a param like

?myParam=text,2.0

?

Hi guys, can anyone help me figure out how to call two

suspend

functions in parallel inside a route? This compiles but crashes at runtime with `io.ktor.util.pipeline.SuspendFunctionGun cannot be cast to kotlinx.coroutines.CoroutineScope`:

fun Routing.test() {
    get("/") {
        val firstResultDeferred = async { firstCall() }
        val secondResultDeferred = async { secondCall() }
        
        val firstResult = firstResultDeferred.await()
        val secondResult = secondResultDeferred.await()

        call.respond(listOf(firstResult, secondResult))
    }
}

Hi guys, when using ktor's GMTDate, I'm getting this bug:

// 10:18:47 4.FEB.2019
// dateRaw: GMTDate = GMTDate(seconds=47, minutes=18, hours=10, dayOfWeek=MONDAY, dayOfMonth=4, dayOfYear=35, month=FEBRUARY, year=2019, timestamp=1549275527000)

val date = dateRaw.toJvmDate()
// date: Date (JVM/Android) — Mon Feb 25 13:07:27 GMT+03:00 2019 (CURRENT DATE)

to do otherwise you must add an annotation that tells Gson the expected JSON key for a field that does no match it.

Hi, I have a question on how and why to use dispatchers. I have a ktor project in which I fetch a number of results from the database, then I need to split these results and send them to a separate service, waiting for the response. I've implemented this using Deferreds, and using awaitall() on them. My current implementation creates a

CoroutineScope(<http://Dispatchers.IO|Dispatchers.IO>)

and then uses

async

on it to create the Deferreds. My question is whether this is the correct way to do this, or if I should use the

coroutineScope

function to create the scope and call

async

from within. Unsure if this is a #ktor or #coroutines question, seems more like the former.

Anyone worked with deserializing a map? Guessing a custom serializer is needed.

I’m using Ktor for get a simple file. This unit test runs successfully 10/10

fun `playlist realTest`() {
        val source = ParsersImpl()

        runBlocking {
            source.readFrom(
                    Playlist("<https://sourcetv.info/dl/01/it29.m3u>", SourceFile.Type.REMOTE ),
                    onChannel = { println( it ) },
                    onGroup = { println( it ) },
                    onError = { println( "${it.reason.name} - ${it.rawChannel}" ) }
            )
        }
    }

The http call resides here:

override suspend fun readBytes( path: String ) = client.get<ByteArray>( path )

The problem is that when I run my Android app, 9/10 gives me the following exception