[SOLVED] Hello, I'm getting a 404 error when using

@Location

on Ktor 1.6.0, anybody had similar issue?

dependencies { 
    implementation("io.ktor:ktor-locations:$ktorVersion")
}

tasks.withType<KotlinCompile> {
    kotlinOptions.freeCompilerArgs += listOf("-Xuse-experimental=io.ktor.locations.KtorExperimentalLocationsAPI")
}

import io.ktor.locations.Location

@Location("/mylocation")
class MyLocation

fun Application.someFun() {
    routing {
        route("/my-root") {
            post<MyLocation> {

Hey! I have yet some other questions about

ktor-network

: • Why is

TcpSocketBuilder.connect(...)

suspending while

TcpSocketBuilder.bind(...)

is not ? • Would it be in the project scope to accept a contribution for a

UnixDomainSocketBuilder

?

[SOLVED] Hello, I am getting some errors when running a Ktor server that uses the Location feature, the ktor app was compiled into a GraalVM native image and upon running it I get the following :

Exception in thread "DefaultDispatcher-worker-2" kotlin.reflect.jvm.internal.KotlinReflectionInternalError: Unresolved class: class applications.web.routes.roadclassification.MyLocation

import <http://io.ktor.locations.post|io.ktor.locations.post>

...
fun Routing.myFun() {
	route("/my-route") {
		post<MyLocation> {
			call.respondText { "hello" }
		}
	}
}

import io.ktor.locations.Location

@Location("/mylocation")
class MyLocation

The app works when not running the native image (regular jar) or when running the native image without using the Location feature. Thanks

Hello. I'm trying to deserialize into a LocalDate object from a JSON ISO string (e.g. "2021-10-01"). I'm using

kotlinx.serializable

On the way out (i.e. serializing) it works fine with this

@Serializable
data class Task(
    var id: Int? = null, val title: String, val detail: String? = null,
    @Contextual
    val dueDate: LocalDate? = null
)

But when I try to

val task = call.receive<Task>()

in route, then I get an

Serializer for class 'LocalDate' is not found.

I've been through the kotlinx.serialization docs, but I can't see find anything to help.

is it only me? 😅 just noticed over 100 run configurations for Ktor

Hey, why is

streamProvider

only available for

PartData.FileItem

and not for all

PartData

subclasses? It is only a shortcut for

provider().asStream()

https://github.com/ktorio/ktor/blob/1bd92eaa4974dc0b09757c635895ce0e38474a95/ktor-http/jvm/src/io/ktor/http/content/MultipartJvm.kt

hello guys, is there any documentation or example (or even a lib/framework) how to share ktor routes between server and client? i am building a multiplatform application with ktor jvm server, android app and a shared module. but jvm only example would already help a lot.

Hello everyone, does any of you use the space platform for code hosting & automation? I was wondering if there is a channel here but couldn't find one. Maybe one of guys could point me somewhere? Thanks!

After migrating to Ktor 1.6.2, it appears that

StringValuesBuilder.append

has been marked as internal. However, it is necessary to create multipart requests:

builder.append(FormPart(name, data, Headers.build {
	append(HttpHeaders.ContentType, mime) // this is now marked as internal
}))

I didn't see anything explaining how we should migrate our code.

No Kotlin 1.5.30 update in Ktor 1.6.3? Do we have to wait til next month?

I just found this line in the Ktor EAP announcement blog post: “Important – EAP artifacts will not be kept indefinitely. We’ll be cleaning them up on a frequent basis.” Could we get this information added to https://ktor.io/eap/ please? Really frustrating that it’s not more aggresively warned about.

Is there an

ktor-auth

dependency setup document for mulitplatform android/ios/web? I am running into this error:

No matching variant of io.ktor:ktor-auth:1.6.3 was found. The consumer was configured to find a usage of 'kotlin-runtime' of a component, as well as attribute 'org.jetbrains.kotlin.platform.type' with value 'js', attribute 'org.jetbrains.kotlin.js.compiler' with value 'ir' but:
          - Variant 'jvmApiElements-published' capability io.ktor:ktor-auth:1.6.3:
              - Incompatible because this component declares an API of a component, as well as attribute 'org.jetbrains.kotlin.platform.type' with value 'jvm' and the consumer needed a usage of 'kotlin-runtime' of a component, as well as attribute 'org.jetbrains.kotlin.platform.type' with value 'js'
              - Other compatible attribute:
                  - Doesn't say anything about org.jetbrains.kotlin.js.compiler (required 'ir')

Using Kotlin 1.5.30, Ktor 1.6.3, applying the

ktor-auth

in common and mixing in

ktor-client-auth-js

in common and/or jsMain and continue to get this error building/running web This worked with previous versions but having issues getting it to work now on web/js, anyone seen this?

Hello. I wanted to respond with file, but by default, downloaded file is named by route. How can it be changed? Example:

get("someRoute"){
    call.respondFile(someFile)
}

Downloaded file will be named "someRoute". Can I change it?

KTOR-2977 (make the client available in

refreshTokens

) does not seem to have actually made it into the release, see my comment on the issue for details

is it possible to build a typesafe kotlin web api that works on client using kotlinjs & server with jvm? something kinda like servant in haskell where you only have to write one api for the client & server

Hello everyone, I’ve been looking for a bit and couldn’t find anything regarding the support of arm64 for macos. Does anyone know anything about it?

Hello everyone. I have recently tried to install WebSocket feature on my Ktor Server (Ktor version 1.6.2) and implement simple chat example from ktor docs (Btw when following tutorial from chat example from docs i got 'Web socket feature is not installed Error' because in tutorial it recommends to open routing function before closing the Websocket feature install bracket, which is incorrect according to the answer i found in google - 'you should close install bracket before start writing routing for webScoket'. Anyway, when got rid of the previous error, when deploying on Heroku platform and trying to open my cloud server i got it crashed with the next Error: Exception in thread "main" java.lang.LinkageError: loader constraint violation: when resolving method "io.ktor.application.ApplicationEvents.subscribe(Lio/ktor/application/EventDefinition;Lkotlin/jvm/functions/Function1;) Lkotlinx/coroutines/DisposableHandle;" the class loader (instance of io/ktor/server/engine/OverridingClassLoader$ChildURLClassLoader) of the current class, io/ktor/websocket/WebSockets$Feature, and the class loader (instance of sun/misc/Launcher$AppClassLoader) for the method's defining class, io/ktor/application/ApplicationEvents, have different Class objects for the type kotlinx/coroutines/DisposableHandle used in the signature I guess it is kinda bug or problem with installing WebSocket feature on Server which is further deployed on Heroku platform. Is there any altrenative how can i implement WebSocket feature on my Server which is gonna be deployed on a Cloud based platform? P.S: When deleting code connected with installing and configuration of WebScoket feature, server runs well without crash when deployed on Heroku. My Application class code looks like:

fun main(args: Array<String>): Unit = io.ktor.server.netty.EngineMain.main(args)

fun Application.module(testing: Boolean = false) {

    //initialization of the Database
    DataBaseFactory.init()
    val userDb = UserDataBaseDao() //Users Database
    val loveCardDb = LoveCardsDataBaseDao()
    val hashFunction = { s: String -> hash(s) }
    val jwtService = JwtService()

    //installing content receive/respond functionality
    install(ContentNegotiation) {
        json() //converter for serialization of kotlin classes
    }
    //installing authentication
    install(Authentication){
        jwt("jwt") {
            verifier(jwtService.varifier)
            realm = "Lovecard server"
            validate {
                val payload = it.payload
                val email = payload.getClaim("email").asString()
                val user = userDb.findUserByEmail(email)
                user
            }
        }
    }

    //installing WebSocket
    install(WebSockets) {
        pingPeriod = Duration.ofSeconds(15)
        timeout = Duration.ofSeconds(15)
        maxFrameSize = Long.MAX_VALUE
        masking = false
    }
    routing {
        //basic route on connection to server
        get("/") {
            call.respondText("Hello world!", contentType = ContentType.Text.Plain)
        }
        //echo unit of websocket
        webSocket("/echo") {
            send("Please enter your name")
            for (frame in incoming) {
                when (frame) {
                    is Frame.Text -> {
                        val receivedText = frame.readText()
                        if (receivedText.equals("bye", ignoreCase = true)) {
                            close(CloseReason(CloseReason.Codes.NORMAL, "Client said BYE"))
                        } else {
                            send(Frame.Text("Hi, $receivedText!"))
                        }
                    }
                }
            }
        }
        //Websocket for data exchange
        val connections = Collections.synchronizedSet<Connection?>(LinkedHashSet())
        webSocket("/connection") {
            val thisConnection = Connection(this)
            connections += thisConnection
            send("You've logged in as [${thisConnection.name}]")

            for (frame in incoming) {
                when (frame) {
                    is Frame.Text -> {
                        val receivedText = frame.readText()
                        val textWithUsername = "[${thisConnection.name}]: $receivedText"
                        connections.forEach {
                            it.session.send(textWithUsername)
                        }
                    }
                }
            }
        }

        //register Authentication routes
        authRouting(hashFunction, jwtService)
        //register User routes
        userRouting(userDb, jwtService, hashFunction)
        //register LoveCards routes
        loveCardsRouting(loveCardDb)
    }
    
    class Connection(val session: DefaultWebSocketSession) {

      companion object{
          var lastId = AtomicInteger(0)
      }
    val name = "User ${lastId.getAndIncrement()}"
    }
}

I want to upload image to the amazon S3 server

<http://httpClient.post|httpClient.post><Unit> {
                val bucket = it.fields.bucket
                url {
                    encodedPath = bucket
                }
                body = MultiPartFormDataContent(
                    formData {
                        append("bucket", bucket)
                        append("Policy", it.fields.policy)
                        append("X-Amz-Date", it.fields.date)
                        append("X-Amz-Algorithm", it.fields.algorithm)
                        append("X-Amz-Signature", it.fields.signature)
                        append("X-Amz-Security-Token", it.fields.securityToken)
                        append("X-Amz-Credential", it.fields.credential)
                        append("acl", it.fields.acl)
                        append("key", it.fields.key)
                        appendInput(
                            key = "file",
                            headers = Headers.build {
                                append(HttpHeaders.ContentDisposition, "filename=uuid.jpg")
                                append(HttpHeaders.ContentType, "image/jpeg")
                            }) {
                                buildPacket { writeFully(input.imageByteArray) }
                            }
                    }
                )
            }

but I meet the below error

javax.net.ssl.SSLException: Write error: ssl=0xcbc0b608: I/O error during system call, Broken pipe

😞 If I upload the image to another server (not S3 anymore), the upload is successfully anyone help me 😞 ?

hello, help me please. Why is it 400? Works fine using browser or retrofit2 REQUEST: https://restaurant-api.wolt.fi/v3/venues?lat=60.170187&lon=24.930599 METHOD: HttpMethod(value=GET)  COMMON HEADERS  Accept: application/json Accept-Charset: UTF-8 CONTENT HEADERS Content-Length: 0 BODY Content-Type: null BODY START BODY END RESPONSE: 400 BAD_REQUEST

suspend fun getAllVenues(lat: Double, lon: Double): VenueResponse {
    return client.get(BuildConfig.API_URL + "venues") {
        parameter("lat", lat)
        parameter("lon", lon)
    }
}

single {
        HttpClient(Android) {
            install(JsonFeature) {
                serializer = GsonSerializer {
                    setPrettyPrinting()
                    disableHtmlEscaping()
                }
            }
            expectSuccess = false
            install(Logging) {
                logger = Logger.DEFAULT
                level = LogLevel.ALL
            }
        }
    }

OAuth2: Why does OAuth2.kt not use the return value from the NonceManager verify method? : https://github.com/ktorio/ktor/blob/main/ktor-features/ktor-auth/jvm/src/io/ktor/auth/OAuth2.kt#L170

why is the api to add headers marked as internal?

<http://ktor.post|ktor.post>(url) {
    body = ...
    headers {
        append("Content-Type", "application/json")
        append("Authorization", "Bearer $bearer")
    }

“This API is internal in ktor and should not be used. It could be removed or changed without notice.”

Its already Impressive how many native targets ktor-client already supports. With 1.5.30 and an initial support for Apple Silicon we have some more (like iosSimulatorArm64). Are there particular plans to add them? I didn’t find anything specific in roadmap or on github. Reason behind -> it will make possible to develop also with simulators in Apple M1 computers.

Has anyone ever seen something like this when building release variant of the Android app that uses KTOR client through multiplatform module?

Execution failed for task ':app-android:mobile:minifyReleaseWithR8'.
> Could not resolve all files for configuration ':app-android:mobile:releaseRuntimeClasspath'.
   > Failed to transform ktor-client-core-jvm-1.6.2.jar (io.ktor:ktor-client-core-jvm:1.6.2) to match attributes {artifactType=android-asm-instrumented-jars, asm-transformed-variant=release, org.gradle.libraryelements=jar, org.gradle.status=release, org.gradle.usage=java-runtime, org.jetbrains.kotlin.platform.type=jvm}.
      > Execution failed for AsmClassesTransform: /Users/sowodzin/.gradle/caches/transforms-3/f7fb63019a1553b70833efe63d6a881f/transformed/jetified-ktor-client-core-jvm-1.6.2.jar.
         > Index -1 out of bounds for length 0

Koltin version: 1.5.21 Android Gradle Plugin 7.0.1 (everything is fine when I switch back to 4.1.3)

okay.. I am looking at documentation my http client to make a call server that is using OAuth and responding with bearer token. I am looking at https://github.com/ktorio/ktor-documentation/blob/main/codeSnippets/snippets/client-auth-oauth-google/src/main/kotlin/com/example/Application.kt and for inspiration. But it seems that I am having some syntax errors it seems that the bearer { loadTokens { blocks are not resolvable.. I am using ktor versions "1.5.3" .. does anyone have any experience in getting this to work in 1.5.3?

I want to separate e2e test and unit test. How does everyone set up ??

question about testing in ktor-client: So, runBlockingTest {} (from kotlin-test) creates a TestDispatcher and runs its block on said dispatcher, and then fails if any work is left running at the end of the test (say, on another dispatcher). I’d assume that the ktor MockEngine is meant to be used in tests as well (where best practice seems to be to use runBlockingTest {} instead of runBlocking {}). But MockEngine creates its own dispatcher (by calling Dispatchers.clientDispatcher()), and calls to client.request() end up scheduling work on that dispatcher, which seems to cause tests that rely on a TestCoroutineDispatcher to fail. Am I understanding this correctly, or am I missing something obvious?

Does anyone use classes in ktor client like

<http://io.ktor.utils.io|io.ktor.utils.io>.core.Input

or

<http://io.ktor.utils.io|io.ktor.utils.io>.core.Output

? I can't find a description for them and i am affraid it is internal classes which will be deleted. My problem is that ByteReadChannel is malformed on receive but

io.ktor.utils.i.core.Input

works fine. Can i use

Input

class without fear?

val channel: Input = httpResponse.receive() //works fine
val channel: ByteReadChannel = httpResponse.receive() // throw exception MalformedInputException: Input length = 1

Hi there, how can I pass a cookie at Ktor client headers? I am trying the below code

header("Cookie", cookie)

but Ktor seems to ignore it.

Hello there, is there any way to get all route path on service startup ? I found someone talked about this, however I’m not sure it’s the best practice to do it https://github.com/ktorio/ktor/issues/1252#issuecomment-551304202

fun Application.ktorMain() {
    // set up omitted
    val root = feature(Routing)
    val allRoutes = allRoutes(root)
    val allRoutesWithMethod = allRoutes.filter { it.selector is HttpMethodRouteSelector }
    allRoutesWithMethod.forEach {
        <http://logger.info|logger.info>("route: $it")
    }
}

fun allRoutes(root: Route): List<Route> {
    return listOf(root) + root.children.flatMap { allRoutes(it) }
}

is there another approach to do it ?