it prints out

2018-12-02 16:14:17.012 [nettyWorkerPool-3-1] INFO  Application - Changes in application detected.

but then it never gives any content on any port again

Hey Everyone, I'm reposting this to the proper channel. Expected I'm attempting to have my Ktor app's main method run automatically once deployed to AppEngine, similar to how a Jars main method runs when uploaded to AppEngine. Actual Currently the Ktor application's main method is only called when the app's hosted route is called: https://[yourProjectName].appspot.com. In the applications's main method is logic to retrieve content from an API request based on a Timer and save that information to a Firestore database which a client consumes. The goal is to have this task running continuously. Thanks for the help! 🙂

How would I got about splitting up my endpoints into separate files? Ideally I want to have this syntax

routing {
route("/route", endpoints())
}

or any other way to move all of the posts, deletes etc. out of this file and into something else.

anyone here that has a lot of experience with netty? We migrated a vertx+coroutine (kotlin 1.2.61-app) to ktor 1.0 and we are seeing some memory leakage. This is the visualvm images which I can’t really tell a lot from but the reason why I am asking about netty is the call-thread

is there anyhow I could log the execution time of requests with ktor? Is that when the MDC should be used in the callLogging? https://ktor.io/servers/features/call-logging.html

I get these errors when I am running my test (but running the app in a container works perfectly fine)

Caused by: java.lang.ClassNotFoundException: org.eclipse.jetty.server.handler.ContextHandler$NoContext

Has anyone experience the same thing with ktor+JettyEngine?

or better question, how would I download a large file with the ktor http client?

So I have a POST route that takes a request body and then makes its own post call to a third party server. if that request is successful, i want to respond to the original request with a 200 OK status. I can't quite figure out how to do that. I can make the post to the third party and its successful because i see the data being received in the third party just fine but i can't figure out how to get the status back in my code for the call to the third party so i can report it in my response to the original request

Any suggestions related to Data Class Validator library? Using arrow validated type is okay, but it is not "dsl friendly enough" 😁 I want to run validation for request inside ktor handler

I would like to rig my dev environment to do auto reload, but i must be missing something. In my resources/application.conf file I added content:

ktor {
    deployment {
        environment = development
        port = 8080
        autoreload = true
        watch = [ org/grcole/bfw ]
    }

    application {
        modules = [ org.grcole.bfw.BFWApplicationKt.main ]
    }
}

but when I run it, it tells me there are no watched locations:

[grcole@C02WP0CRHTDG bfw (master)]$ ./gradlew :run

> Task :run
2018-12-05 19:04:49.865 [main] INFO  Application - No ktor.deployment.watch patterns match classpath entries, automatic reload is not active
2018-12-05 19:04:50.295 [main] INFO  Application - Responding at <http://0.0.0.0:8080>

Is there a 'best practice link' for env setup for a noob?

Is there a way to stream content from the http client?

Hi @Deactivated User, I found it quite hard to understand how to use the OAuth feature and its magic. I finally did my own implementation that made me understand all interactions. I think that, in the oauth guide, having a sequence diagram that shows the different requests between the browser, ktor and the oauth provider would help.

Hi guys, I am using Ktor Http client to call REST APIs and I use JsonFeature to deserialize the responses. In case of a response with a status ≠200 OK, my json body cannot be mapped to the same object as when the response is OK. How would you do serializing in this case ? I would have liked something like

client.get<Either<ResponseObject, ErrorObject>>() {}

when working with ktor, is there any documentation about the coroutineScope that is given you when you expose an endpoint? Are there any best practices when it comes to calling businessServices from the “controller/endpoints”-layer? E.g. what happens if you from an endpoint call a blocking service?

I want to have a docker container that contains my service, for now I'm just making a fatjar (which I have to learn how to make smaller)

but it seems like only the first auth method given in

authenticate("auth1", "auth2")

is used. So if I change to

authenticate("auth2", "auth1")

then basic auth works but not the other way around.

Using the ktor client, how do I save an xml file from a http call as a

File

so I can process it with a DOM parser? I guess I readBytes and then do something but I don’t really know, surely download an xml file must be something quite standard.

Trying to get kotlinx.serialization working on jvm with ktor client (cio) but I keep getting a very unhelpful error

When im receiving Frame.Text I get

Exception in thread "DefaultDispatcher-worker-3" kotlinx.io.charsets.MalformedInputException: Input length = 1

can anyone recommend an analytics solution for my

ktor

backend? E.g. which endpoints get called the most, from which countries, which browsers etc?

connecting to databases, using oauth, and maybe some social network login samples?

is there a way to do SSR with Ktor?

Is there any plans for a discourse for Ktor? A great project like this deserves something more than just a single slack channel.

Any progress on the ktor wss issue from earlier

anybody have a way to work around the above ^. I'm a bit confused about the error

ktor Content-Type need to be passed in OutgoingContent.contentType

. Anybody have links to OutgoingContent documentation and how I can configure it at instantiation?

What's the best way to provide features which may perform a lot of work (i.e. spend a lot of time suspended). Do I need to offload that to another dispatcher or can I just run it in the pipeline's own scope?

pipeline.sendPipeline.intercept(ApplicationSendPipeline.Render) { subject ->
	if (subject is OutgoingContent) return@intercept

	launch(context = <http://Dispatchers.IO|Dispatchers.IO>) {
		proceedWith(feature.process(subject))
	}
}

Could you help me testing the WebSocket endpoint below, please? It's supposed to keep receiving data without interruption, persist that data and send it to a Kotlin Coroutines channel to be processed. Simplified main code:

fun Application.module(database: Database, channel: Channel<String>) {
    routing {
        webSocket("/") {
            while (true) {
                val payload = incoming.receive() as Frame.Text
                val event = payload.readText()

                database.save(event)
                channel.send(event)
            }
        }
    }
}

For some reason the test below does not finish and produces a INFO log entry:

val database = mockk<Database>()
val channel = Channel<String>()
val event = "John's birthday"

withTestApplication({ module(database, channel) }) {
    runBlocking {
        launch {
            handleWebSocket("/") {
                setBody(event)
            }
        }


        delay(300)

        expectThat(channel.count()).isEqualTo(1)
        coVerify(exactly = 1) { database.save(event) }
    }
}

2018-12-14 02:13:46.002 [DefaultDispatcher-worker-1 @coroutine#3] INFO  ktor.test - 101 Switching Protocols: GET - /

When running in production the code works as expected, so I may be missing something in the test case. The Kotlin version is 1.3.10 and Ktor version is 1.0.0.

Hi guys. I was trying to parse a request from a post method using ContentNegotiation feature with GSON and it’s not working… Ktor produces

UnsupportedMediaTypeException

when try to parse the body. Do you know what i’m doing wrong? I just followed the documentation:

<https://ktor.io/servers/calls/requests.html#typed-objects>

fun main() {
    embeddedServer(Netty, port = 8080, watchPaths = listOf(""), module = Application::module).start()
}

fun Application.module() {
    install(StatusPages) {
        exception<Throwable> {
            call.respondText(it.localizedMessage, ContentType.Text.Plain, HttpStatusCode.InternalServerError)
        }
    }
    install(ContentNegotiation) {
        gson()
    }
    routing {
        get("/") {
            call.respondText("Hello World", ContentType.Text.Html)
        }
        post("/verify") {
            val request = call.receive<Request>()
            call.respond(request)
        }
    }
}

data class Request(val userId: String, val productId: String)

data class Response(val status: String)

Hi. Is there a way to do soap client in Ktor ? Or ktor is for rest only ?