@Deactivated User do you have any ideas for an optional jwt auth? I thought I could use the

skipWhen

flag, which according to doc:

If there is no filters, authentication is required. If any filter returns true, authentication is not required.

Meaning that when it returns true, auth is optional. But it seems more like it completely skips the auth process.

Is there some kind of plugin for message queues like Kafka or RabbitMQ for Ktor? Also, is there some kind of integration w/ Prometheus monitoring?

I thought the intercept was activated only for that specific route or static route whatever if inserted inside it

Someone on Vert.x Gitter channel suggested replacing Netty's EventGroups w/ Vert.x's to implement a Vert.x bridge with Ktor, see: https://github.com/ktorio/ktor/blob/d1e3a495cfe26c32aa5af4b110f6af9ddbd329e4/ktor-server/ktor-server-netty/src/io/ktor/server/netty/NettyApplicationEngine.kt#L51 https://github.com/eclipse/vert.x/blob/master/src/main/java/io/vertx/core/http/impl/HttpServerImpl.java#L247 Then I could expose the Vert.x instance to the app somehow to use it to create Vert.x components like async dbs etc... is it possible that it's that easy, or are there possible pitfalls in this approach?

isn't there a finished release 0.9.3 yet right?

Hello 🙂 Do you have a good tutorial to use Google Oauth with the ktor feature Oauth please ?

Does anyone know of a way to get the built-in ContentNegotiaion feature to use a default output converter for requests with no

Accept

header? I'm not seeing an obvious way to configure the module to use a default, and also have not been able to figure out a way to mutate / replace the request headers before the ContentNegotiation module looks at them to fake it out.

Hi everyone, I made a nice event based wrapper for Ktor WebSockets. Because this is my first library I could really use your feedbacks to improve my coding / sharing skills, so do not hesitate to point me anything ! https://github.com/rozaxe/hypercube

I was doing some diligence over the weekend to see how ktor would hold up for some of our needs. I was checking to see how ktor handles coroutine suspend / resume because we have a need to use structured logging in our apps. We’ve traditionally handled things like requestId in spring by using MDC.putCloseable in an interceptor. I put together a simple example below with ktor. This seems to be working out of the box without me having to do anything special, but it seems like I’m just getting lucky (or maybe false positives) because it’s not what I would have expected.

fun main(args: Array<String>) {
    val server = embeddedServer(Netty, port = 9000) {
        intercept(ApplicationCallPipeline.Infrastructure){
            val requestId = UUID.randomUUID()
            MDC.putCloseable("req.Id", requestId.toString()).use {
                <http://this.context.application.log.info|this.context.application.log.info>("Interceptor")
                proceed()
            }
        }
        routing {
            get("/") {
                <http://call.application.log.info|call.application.log.info>("Inside /")
                call.respondText("Hello World!", ContentType.Text.Plain)
            }
        }
    }
    server.start(wait = true)
}

I tested using

wrk -t6 -c200 -d15s <http://localhost:9000/>

just to get a little bit of concurrency. Added context: https://github.com/Kotlin/kotlinx.coroutines/issues/119

can i have one gradle project that contains my server side code using ktor, and also the code for my web frontend, using the kotlin-frontend-plugin?

I am trying to run some tests were I don't send anything back and let the test hang inside handleWebSocketConversation

When I close a websocket, the exception is not propagated over the channel, when I call receive() on one side, and the channel was closed with close(e) on the other side, It doesn't trace the cause, receive() just throws ClosedReceiveChannelException, not the cause of it happened on the other side

This message was deleted.

Another question about session feature. ow do you do to don’t create a new session if the same user log again and again please ?

^ :thread-please:

how do I tell ktor to use secure websockets? "wss://" ?

are there any soap clients?

can I use socks5 proxy with the httpclient ?

Is it possible to get the matched route in a intercepting feature. For metrics purposes it would be good if I could get /user/{name} not user/Jozef for response time metrics?

Hello, one question about sessions feature. When you use Session Content (client-side), where the system stock the authentication please ?

^ :thread-please:

Is it possible to custom the body of an Apache client post ? I want to send a post request like in postman (form-data) where you can put a key like “photo” and a value with the file corresponding to the photo.

When using

default

to specify a default file, shouldn't it be served, when I call an otherwise unhandled endpoint?

I'd like to run

install(CORS) { anyHost() }

just when I'm running locally in developer mode -- is there a standard way to check that programatically?

can’t you just do

val result = client.get<HttpResponse> { /* your code here */ }
val data = result.content.readRemaining().readText()

Hello, Is it possible to add an expiration time (TTL) for session cookie (client side) please ?

@cy @Deactivated User Thanks for merging my JWT fixes into master. We’re about to release code that will need those fixes this week, so this is very timely. Any time you guys want to do an

0.9.3-alpha-6

, that would be great with me 🙂

I'm using

withTestApplication

to test my microservice, and wanted to send it data classes rather than JSON strings, and receive unmarshalled data classes as responses (rather than raw JSON strings from HTTP response bodies). Is it a case of just using Jackson directly, or is there any special support available in Ktor for this?

📣 ktor

0.9.3

has been released * Improved WebSocket API * Websocket header

Sec-WebSocket-Key

is now optional * Fixed client cookies rendering to avoid

x-enc

* Fixed plain text client reader (#392) * Added EC support in CIO TLS (#394: ECDHE_RSA_AES256_SHA384, ECDHE_RSA_AES128_SHA256) * Fix client certificate validation * Introduced optional authentication * Added

ApplicationCall

as receiver for auth

validate

functions * Introduced

call.respondBytes

(#395) * Improved JWT support: multiple schemes, nullable issuer * Conversion service enum type diagnostics improved (#403) * Avoided using apos entity in HTML escaping as IE doesn't support it (#400) * Converter support for java big numbers * Ability to add auth methods to existing feature on the fly * Improved auth header scheme and contents validation (#415) * Default charset for BasicAuth is now UTF-8 (#420) * Added

ByteArrayContent.contentLength

(#421) * Fixed

headersOf

case insensitive issue (#426) * Client deserialization improved by using type token * Ability to disable client default transformers * Explicit

Accept

header in client request * Turn on masking in client websockets (#423) * Fixed inverted

PartialContent.Configuration.maxRangeCount

check (#440) * Fixed uncaught

UnsupportedMediaTypeException

from

receiveOrNull()

(#442) * Fix multipart boundary header parsing * Upgraded jwks/jwt, applied RSA256 by default if unspecified (#434, #435) * Upgrade coroutine version to 0.23.3 * Upgrade Jetty version to 9.4.11.v20180605 * Add

client-mock-engine

for testing purpose * Use default available engine by deafult * Upgrade kotlin to 1.2.50 Move ktor-samples to a separate repository (#340). https://github.com/ktorio/ktor-samples See http://ktor.io/quickstart/migration/0.9.3.html for migration steps