How can I import features.* ? and hopefully that will fix ContentNegotiation

If I have a

ktor-client

feature that has a

sendPipeline

and a

receivePipeline

intercept. How can I pass values from the sendPipeline intercept to the receivePipeline intercept (e.g. a class instance and/or some value)?

Does the normal version of Ktor support the new Kotlin Native Memory Management Model from 1.6.3+? I don’t see anything in the changelog

Nvm got it, u use the execute method

Anyone has a working config of ktor 2 client with json plugin and using new kotlin native memory model? For me it crashes with

InvalidMutabilityException: mutation attempt of frozen kotlin.Array@249bab0

 in 

kfun:io.ktor.client.plugins.json.serializer.SerializerInitializer.<init>#internal

Another quick

ktor-client

question. Is the

scope.receivePipeline.intercept(HttpReceivePipeline.State) {

always getting executed even if the API call failed (e.g. Invalid Host or Timeout)? If yes what value would

context.response.status.value

contain? And if not what pipeline do I need to adjust to to catch that?

Question about ktor-client. How to know there is response boby or not, before calling

HttpResponse.body()

?

Hi there, I'm here to step up my kotlin specialization! I have a lot of questions to post! but for now, I'm looking for a good example of to how use properly ktor client response validation... can someone post me something? Thanks!

I wanna make a value that only makes a network request when its read from. Using lazy delegate seemed like the solution but then I cant do that because the get method on the HTTP client is a suspending method. How would I be able to do this?

I found a small glitch on https://ktor.io/create/ - in Manual Configuration, choosing "Gradle Kotlin" displays Groovy, and vice versa. I wanted to contribute and fix it myself, but cannot find the source code.

the code example for streaming responses seems to be outdated, it does not compile: https://ktor.io/docs/response.html#streaming

Yay 🤞

I was under the impression that a

WebSocketSession

would be canceled (the coroutine that is) when both the incoming and outgoing channels are closed but this doesn’t seem to be the case. Can someone confirm that this is the intended behavior?

Hello, whats the difference between Ktor-client features vs plugin? Will plugins replace features?

Hi, as part of a plugin that i am writing i need to change the http response body for not found error code. I understand that i should override ApplicationCallPipeline.Fallback phase, but don't sure how to change the response body. Any help?

Hello, I tried to move to ktor version 2.0.0-beta-1 and now I have some problems. First question: Is there any documentation available? I couldn't find any.

Still have some error I get after migrating to version 2.0.0-beta-1 that I do not understand (Ktor-Client). If I try to execute the following code:

override suspend fun authenticateUser(userNameHash: String, passwordHash: String): UserAuthData? {
        return try {
            <http://client.post|client.post>(HttpRoutes.AUTHENTICATE_USER_FQDN) {
                contentType(ContentType.Application.Json)
                setBody {
                    UserRegistrationData(
                        userNameHash = userNameHash,
                        passwordHash = passwordHash
                    )
                }
            }.body<UserAuthData>()
        } catch (e: Exception) {
 ...
           }
    }

Data Class looks like this:

@kotlinx.serialization.Serializable
data class UserRegistrationData(
    val userNameHash: String,
    val passwordHash: String
)

HttpClient

HttpClient(Android) {
....
        install(ContentNegotiation) {
                json(Json {
                    ignoreUnknownKeys = true
                    isLenient = true
                }
                )
            }
....
}

Dependencies (for serialization)

implementation("io.ktor:ktor-client-content-negotiation:$ktor_version")
implementation("io.ktor:ktor-serialization-kotlinx-json:$ktor_version")

Error Message: Line: 58, Method: authenticateUser: Serializer for class 'null' is not found. Mark the class as @Serializable or provide the serializer explicitly.

I have another issue (hopefully last one). I load a list of quotes from an api. Everything worked fine before migration.

override suspend fun getInspiringQuotes(): Resource<List<InspiringQuoteRemote>> {
        return try {
            val quotes = client.get {
                url(WordpressRoutes.InspiringQuotes)
            }.body<List<InspiringQuoteRemote>>()
            Resource.Success(quotes)
        } catch (e: Exception) {
            Timber.e(e)
            Resource.Error(e.localizedMessage)
        }
    }

This is the json-response I receive. I validated the response with an online tool that said it's a VALID (RFC 8259)

[
   {
      "quote_author":"Oskar Wilde",
      "quote":"Unzufriedenheit ist der erste Schritt zum Erfolg."
   },
   {
      "quote_author":"Winston Churchill",
      "quote":"Erfolg haben heißt, einmal mehr aufstehen, als man hingefallen ist."
   },
   {
      "quote_author":"Henry Ford",
      "quote":"Erfolg besteht darin, dass man genau die Fähigkeiten hat, die im Moment gefragt sind."
   },

   {
      "quote_author":"Albert Einstein",
      "quote":"Der sicherste Ort für ein Schiff ist der Hafen. Doch dafür sind Schiffe nicht gemacht."
   }
]

Still I get the following error. kotlinx.serialization.json.internal.JsonDecodingException: Expected start of the array '[', but had 'EOF' instead Any idea?

hi all, i am having issue closing a client . i keep receiving messages event though i called

client.close()

client.wss() {
    incoming.consumeAsFlow().onCompletion{
          // never stops receiving even after closing connection with `client.close()`
    }
}

https://ktor.io/create/ The "Manual Configuration" part placed the groovy config under the gradle tab, and gradle config under the groovy tab

How would I configure my app using ktor client running Kotlin Native to only connect to a server using TLS 1.3?

I’m learning Ktor and Kotlin. I’m trying to create a validation function for my Ktor 2 server app. I came up with :

fun validate(title: String): Json {
        val errors: Json
        val titleArray: Array<String?>
        if(title.length < 20) {
            titleArray.add("The title must contain at least 20 characters")
        }
        if(title.length > 100) {
            titleArray.add("The title must contain no more than 100 characters")
        }
        if(titleArray.length > 0) {
            errors.title = titleArray
        }
        return Json {
            "errors": errors
        }
    }

as it is, I get this error :

Variable 'titleArray' must be initialized

actual class Test actual constructor() {
    actual val httpClientEngine: HttpClientEngineFactory<HttpClientEngineConfig>
        get() = OkHttp
}

I’m integrating the certificate pinning to the ktor kmm Does ktor use

network_security_config

file in android ?

Greetings, I'm trying to serve static files (from resources folder), it works properly according to the (guide)[https://ktor.io/docs/serving-static-content.html#defining-a-default-resource]. However, the filename is changed to

download

and I would like to keep the original one.

routing {
        static("/download") {
            defaultResource("distributive/loottherun-desktop-0.10.29.zip")
        }
    }

So when I go to

localhost:8080/download

I see that browser "downloads"

download

file. It is the same as my zip, but naming is wrong. How I can keep the right naming? Tried to play around arguments in defaultResource method, but didn't work.

Hello everyone, is it possible to use ktor client for gRPC/protobuf and KMM (iOS/Android)? If someone could point me to a sample project/guide/docs that'd be great!

Hei @Aleksei Tirman [JB] Is there a plan for this to be fixed in 2.0.0 https://youtrack.jetbrains.com/issue/KTOR-2435 ? Or atleast provide

DoubleReceive

feature for httpClients ?

How does it work for the application.conf locally vs in production. Do you create a application.conf.example, commit it on the repo but then add the application.conf in the .gitignore ? because the values in the fil will be different in production

ktor {
    development = true
    deployment {
        port = 8080
        port = ${?PORT}
    }...

I'm not sure how it works, but when I use jib to build the container, it pushes the docker container to gcloud container registry where I run it. I don't have an application.conf at all it just somehow works.