Hi folks. Let’s say I have a string representing a path “/some/path”. I’d like to know if a route has been defined for that path. Is there a way to search and see if a route matching that path has already been defined?

Hey guys! What's up? Does anyone here have an example of using Ktor with Apache Kafka?

What’s your strategy to return meaningful error to the user from a Ktor Server when using Kotlinx Serialization to parse the body of a request, and the body isn’t valid?

suspend fun GETRequest(
    baseUrl:String,
    path: String,
    headers: List<Headers>? = null,
    model: , MODEL_CLASS_NAME
    json: Json = Json {
        ignoreUnknownKeys = true
    }
) : MODEL_CLASS {
    val builder = HttpRequestBuilder()
    builder.method = HttpMethod.Get
    builder.url {
        takeFrom(baseUrl)
        encodedPath = encodedPath.let { startingPath ->
            path(path)
            return@let startingPath + encodedPath.substring(1)
        }
    }

    with(builder.headers) {
        if (!headers.isNullOrEmpty()) {
            headers.forEach {
                append(it.key, it.value)
            }
        }
    }

    try {
        val serializer = model.serializer()

        //not primitive type
        val result: String = httpApiClient.request(builder)
        return json.decodeFromString(serializer, result)
    } catch (pipeline: ReceivePipelineException) {
        throw pipeline.cause
    }
}

I am trying to make a generic GETrequest function which can be used from Android and iOS in Ktor native with KMM, I am not sure how can we pass the

MODEL_CLASS_NAME

, any idea ?

When using the Locations plugin, is there a way to specify the body variables instead of just the query parameters? For example I want to have something like this

@Location("/login")
data class PostLogin(val username: String, val password: String)

But I want the

username

and the

password

to be part of the body of the post request instead of the Params. Is that something that is possible, or must I do

call.receive

like I would when I wasn’t using the Locations plugin?

Hello everybody, I would want to know if someone knows what happens with the resources that a client it’s using in a http call if the coroutine is cancelled by any of the previous coroutines . I saw there’s a method in the response class:

public fun CoroutineScope.cancel(message: String, cause: Throwable? = null): Unit = cancel(CancellationException(message, cause))

But it just cancel de coroutine and i don’t know what happens with the connection, buffers, etc. Thanks!

Hello all, I noticed that after upgrading to Ktor 1.6.1 I had to replace

embeddedServer(Netty, 8080, module = Application::module).start()

with

developmentMode = false

to be able to run my application locally. Is that expected? I couldn’t find any information in the change logs.

val builder = ApplicationEngineEnvironmentBuilder()
    builder.module(Application::module)
    embeddedServer(Netty, builder.build {
        developmentMode = false
        connector {
            port = 8080
        }
    }).start()

The reason I had to do it, was to avoid the a similar error reported here. https://youtrack.jetbrains.com/issue/KTOR-2306

Hi All, I am working on a generic ktor client abstraction on my iOS and Android app where I want any client to call our networking library and make request and can send the Model they expect and Error Model they expect from the API.

APIClient.GETRequest<UserData, Error>("/kmm-test", { success -> 
    Log.i(TAG, "Success: ${it.toString()}")
}, { error -> 
    Log.e(TAG, "Error: ${it.cause}")
}, { genericError ->
    Log.e(TAG, "Throwable: ${it.message}")
})

it looks something like this. I am handeling the generic error with ktor client engine. but the error from API is still a mystery to me, can someone guide me to a good direction ?

hey, we're upgrading from ktor 1.4 to ktor 1.6 and are encountering an

IllegalStateException

when trying to use our ktor client to call a ktor server for our integration tests, anyone able to take a look? This is the error message when

customPost()

is called:

Failed to parse request body: request body length should be specified, chunked transfer encoding should be used or keep-alive should be disabled (connection: close)

setup:

val httpClient = HttpClient(CIO) {
    expectSuccess = false
  }

suspend inline fun <reified TRequestData> customPost(
    url: String,
    requestCacheKey: String,
    requestContent: TRequestData,
    headers: Map<String, String>? = null,
    contentType: ContentType = ContentType.Application.Json
  ) {
        <http://httpClient.post|httpClient.post><HttpResponse>(url) {
            var contentAstString = requestCacheManager.getOrCreateRawString(requestCacheKey) { requestContent } // returns a string
            headers?.forEach { headerKey, value ->
                header(headerKey, value)
            }
            body = TextContent(contentAstString, contentType)
        }
  }

Hello, I am writing a Plugin in Ktor, the idea of this Plugin is to first check if Internet is available, if not cancel request and throw error, and when we receive response we check if the status is

401

in that case retry the call after making a new token.

scope.requestPipeline.intercept(HttpRequestPipeline.State) {
    println("MyNewPlugin : works the scope ${context.method}")
    context.header(HttpHeaders.UserAgent, feature.agent)
}
scope.responsePipeline.intercept(HttpRequestPipeline.State) {
    println("MyNewPlugin : works the scope ${context.response.status}")
}

I wrote this in the

install

function to test the Plugin for request and response pipeline but it crashes with this error

Caused by: io.ktor.util.pipeline.InvalidPhaseException: Phase Phase('State') was not registered for this pipeline

Is there anyone successfully using ktor on ios via kotlin multiplatform? I gave up trying 6-12 months ago in favor of my own home-grown (but hacky) solution, but curious if the kinks ever got worked out.

I’m trying to use new Bearer based authorisation https://ktor.io/docs/auth.html#bearer. Wondering why we need to have

refreshToken

in

BearerTokens

. I don’t found an usage inside library. In my case I’m storing and refreshing tokens on application side.

java.lang.Exception: 
Exception -> java.lang.IllegalStateException Expected 8 bytes in the trailer. Actual: 7 $
   at io.ktor.util.EncodersJvmKt$inflate$1.invokeSuspend(EncodersJvm.kt:128)
   at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
   at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:106)
   at kotlinx.coroutines.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:571)
   at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.executeTask(CoroutineScheduler.kt:750)
   at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.runWorker(CoroutineScheduler.kt:678)
   at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:665)

I'm finding this error at random times, it happens when building up the body parameters in a POST with json. Unfortunately it only happens time to time but of course is annoying , the request is cancelled before being send to the server. (Since version 1.5.4) .

After reading the documentation on Ktor Modules, I'm unclear on what advantage there is (if any) to separating a Ktor Server into different 'modules' vs just breaking down a single module into sub-functions for organisation. In particular; it's not stated whether installing a Plugin is scoped to the current module or global to the Application.

Hello. In a ClientRequestException, how to access to the text only ? For example, in

Client request(<http://localhost:2077/login>) invalid: 400 Bad Request. Text: "Wrong password"

printed by

exception.message

, is there a way to print only "Wrong password" ?

Hi. I run a Ktor server on Android 5+, and I'm trying to upgrade Ktor from 1.4 to 1.6. Unfortunately, some of the changes in ktor uses

java.nio.file.FileSystems

, which breaks on Android 5-8 but works in newer versions. This line in `ApplicationEngineEnvironmentReloading` is the culprit, but I don't think that class should be used in production, right? So how can I disable that behaviour, so that that class won't be loaded? I'm not running the server in development mode, so it shouldn't be trying to reload the server.

Hello guys! Is it possible for modules to communicate with one another?

I'd like to create a cookie when the client makes a specific request. If I understand correctly, that means I need to add a

Set-Cookie

header in the response. However,

call.respond

doesn't take a lambda to configure the request, unlike its client-side equivalent. I found

call.respondText

, which has an override with a lambda with an

OutgoingContent

receiver, which has a

headers

attribute, however it seems to be immutable. How can I add a specific header for a specific request? I don't want that header to be present in other requests.

I have a working KMM module using Ktor client on iOS and Android. Trying to add macOS support. I use the following pattern:

GlobalScope.launch {
    launch(ApplicationDispatcher) {
       client.get {
       }
    }
}

but when testing with a macOS SwiftUI app, I get the following:

Error: There is no event loop. Use runBlocking { ... } to start one.

but runBlocking cannot be used in the common code. Any solutions to this? Is the above ‘canonical’ way to make Ktor client calls in common code?

Is there any downside to letting exceptions bubble up to the top of the route in ktor server?

i'm use ktor version 1.6.1 on KMM, for first time call API to Backend its ok, but for the second time is fail and error.

failed with exception: kotlinx.coroutines.JobCancellationException: Parent job is Completed; job=JobImpl{Completed}

Good afternoon... I've been trying to figure this out with no luck: Is there any way to make EngineMain use another file instead of application.conf? I'm trying to create a monolith here with several Ktor servers and a application-server-#.conf for each server.

Hi All 😒imple_smile: 👋 , I’ve been trying to deploy my ktor server to GCP Cloud Run for the last few days but I keep getting this error when the server is being started up.

Error: Could not find or load main class io.ktor.server.netty.EngineMain

Does anyone know how to fix it?

So, based on a deep analysis and help from @napperley I have discovered that the

ktor-client-curl

library on a linuxX64 target fails to located libcurl,

cannot find -lcurl

I can add a def file but that would fail in my CI encironment. I am confident that I have installed libcurl while I installed curl but I am open to know if that's not the case So, how does one go about having a configuration that can run locally and on CI?

Hello. Does ktor-server-kotlinMultiplatform support iOS? I guess only ktor-client supports it

What is the reasoning behind this? I was just trying out 2.0.0-eap, and now I have to add

.body()

after every request. This doesn’t look like an improvement at all.

which method of working with failed states in routes more idiomatic? 1.Similar to call.respondRedirect()

val id = query["id"] ?: return@post call.respondBadRequest()

2. Using exceptions and StatusPage

val id = query["id"]  ?: throw BadRequestException()

I’m trying to create an adapter between Okio and Ktor. Could someone be able to check if this piece of code for reading from a

ByteReadChannel

looks correct?

private fun ByteReadChannel.source(): okio.Source {
  val channel = this
  return object : okio.Source {
    override fun read(sink: okio.Buffer, byteCount: Long): Long {
      if (byteCount == 0L) return 0L

      return runBlocking {
        if (!channel.isClosedForRead) {
          val bytes = channel.toByteArray(byteCount.toInt())
          sink.write(bytes)
          bytes.size.toLong()
        } else {
          -1. // Source is exhausted.
        }
      }
    }

    override fun close() = Unit // Couldn't find any way to close ByteReadChannel.
    override fun timeout() = Timeout.NONE
  }
}

I have a fleet of IoT devices and want some GUI to control them. GUI per device. There is nothing in the wild to meet my requirements. But panels themselves are elementary: show some data, let press some buttons to execute something in a shell. Setup Ktor with a few endpoints + WebSocket is easy. But GUI is another story. MPP + kotlin/js + GUI itself requires tons of time. What lib/frameworks/tools are devs using nowadays? My requirements are pretty low, just get shit done and be very fast. It could look ugly as hell. Love to hear some advice.