The Ktor plugin for IntelliJ is marked as Obsolete, is there a current one? There is this but it looks like it is only for Ultimate edition.

Hello 👋🏽 I’ve gotta a question here which I’m not entirely sure if it relates with Coroutines or Ktor. Apologies if this is the wrong channel. Well, I’ve recently updated Kotlin  

1.4.10 -> 1.4.32

 and Ktor 

1.4.2 -> 1.5.3

 . I was definitely expecting some of Unit tests to break due to compatibility and I’ve already fixed them. However, there are still 4 of them that I’m struggling to understand what could be wrong. When one of the unit tests starts, it adds an entity to a Global Variable with type 

mutableListOf<MyModel>()

. I can confirm that the value was added successfully.  

ArrayList@XXXX

. However, when one of the routes of my Ktor server attempt to read the value from that Global Variable, it is empty and the id of the object is now 

ArrayList@YYYY

. It looks like when 

embeddedServer(…).start()

 is executed, it creates a new instance of the Global Object, hence it is empty. I’ve already tried many things, SynchronizeListOf, add the global variable into an object, but no matter what I do the reference of the GlobalObject into Ktor is always different. Would anyone be able to shed some light, please? Thanks heaps.

I've got a bit of a dumb question.. Using dagger for DI in Ktor. Where do I @Inject all my things?

Hei Ktor team! Can we please prioritize this ? https://youtrack.jetbrains.com/issue/KTOR-1973 This affects our applications often.

hi all, I've came across this issue with the server I have, and I get an exception about

ClosedWatchServiceException

, when running multiple tests all together. I'm using ktor:

1.5.2

, and having a

jetty

server. The issue is thrown when the server is restarted in following tests. here's a code snippet to exemplify the error:

class StartStopServerTest : FreeSpec({  
    "server" - {
        val server = embeddedServer(
            factory = Jetty,
            port = 8080,
            module = {}
        )

        "start" {
            server.start()
        }

        "stop" {
            server.stop(1000, 1000)
        }

        "restart" {
            server.start()  // this fails with the error as shown in the picture
        }

        "stop again" {
            server.stop(1000, 1000)
        }
    }
})

Did anybody face this as well? Appreciate any suggestions and help, thank you 🙏

Hello, I’ve a few questions regarding authentication with Google oAuth. I’m developing a Server and a webApp. For now the Server acts like a proxy between webApp and a Google API (down the road I’ll add some custom logic to justify the existence of the SS, but for now existis for the purpose of the exercise). The idea is: - webApp has a few .ftl pages and respective Routing Locations. One of this .ftl needs authentication (to fetch data from Google Api through Server) - Server communicates with Google API using the AccessToken provided by Google OAuth to the webApp This is my configuration: Application.kt

install(Sessions) {
    cookie<Session>(SESSION_COOKIE) {
        cookie.extensions["SameSite"] = "lax"
        transform(SessionTransportTransformerMessageAuthentication(hex(...)))
    }
}
install(Authentication) {
    session<Session>(SESSION_AUTH) {
        challenge { throw AuthenticationException() }
        validate { session -> if (session.accessToken.isEmpty()) null else session }
    }
    oauth(GOOGLE_OAUTH) {
        client = httpClient
        providerLookup = {
            OAuthServerSettings.OAuth2ServerSettings(
                name = "google",
                authorizeUrl = "<https://accounts.google.com/o/oauth2/auth>",
                accessTokenUrl = "<https://www.googleapis.com/oauth2/v3/token>",
                requestMethod = <http://HttpMethod.Post|HttpMethod.Post>,
                ...
            )
        }
        urlProvider = { p -> redirectUrl(Login(p.name), false) }
    }
}

webApp/Auth.kt

@KtorExperimentalLocationsAPI
@Location("/login/{provider?}")
class Login(val provider: String = "google")

@KtorExperimentalLocationsAPI
fun Route.login(client: HttpClient) {
    authenticate(GOOGLE_OAUTH) {
        location<Login> {
            param("error") { handle {...} }
            handle {
                val principal = call.authentication.principal<OAuthAccessTokenResponse>()
                if (principal != null) {
                    val oauth = call.authentication.principal<OAuthAccessTokenResponse.OAuth2>()!!
                    val response = client.get<UserInfo>("<https://www.googleapis.com/oauth2/v1/userinfo>") {
                        header(HttpHeaders.Authorization, "Bearer ${oauth.accessToken}")
                    }
                    call.sessions.set(Session(response, oauth.accessToken, oauth.refreshToken?: ""))
                    call.redirect(Home())
                } else {
                    call.respond(status = HttpStatusCode.Unauthorized, "Unauthorized, no token issued")
                }
            }
        }
    }
}

webApp/Data.kt

@KtorExperimentalLocationsAPI
@Location("/data")
class Data

@KtorExperimentalLocationsAPI
fun Route.data(client: HttpClient) {
    authenticate(SESSION_AUTH) {
        get<Data> {
        	val response = client.get<Info>("<http://localhost:8080>${application.locationToUrl(DataApi())}") {
                    header(HttpHeaders.Authorization, "Bearer ${call.getSession()?.accessToken}")
                    ...
            }
            ...
        }
        post<Data> {...}
    }
}

api/DataApi.kt

@KtorExperimentalLocationsAPI
@Location("$API_VERSION/data")
class DataApi

@KtorExperimentalLocationsAPI
fun Route.dataApi(client: HttpClient) {
//    authenticate(SESSION_AUTH) {
        get<DataApi> {
        	...
            val response = client.get<SomeApiData>("<https://www.googleapis.com/>...") {
                    parameter("key", params.apiKey)
                    header(HttpHeaders.Authorization, call.request.headers[HttpHeaders.Authorization])
            }
            ...
        }
        post<DataApi> {...}
//    }
}

Everything is working but, I have the following questions: 1 - How can I setup refreshToken logic? I’ve searched in the docs/samples but I must have missed, can you point me to it? Btw, Google sends a null refreshToken, how will I manage auth-refresh in this case? 2 - Is authentication well configured? I thought I should incapsulate both Route.data and Route.dataApi with authenticate but if I wrap Route.dataApi for some reason I’ll receive a “400. That’s an error. Your client has issued a malformed or illegal request. ” from Google 😕 (both with SESSION_AUTH or GOOGLE_OAUTH). Why? 3 - How can I redirect to the page that asked for authentication in the client webApp? For instance, if I try to go to /data it asks for authentication (Route.login) and after success it fires call.redirect(Home()), how can I redirect to the Location that asked for auth? Thanks for you time! 🙏

interface Animal

@Serializable
class Dog : Animal

@Serializable
class Cat : Animal

// subclasses are explicitly registered in serializerModule.

client.get<...>("...") {
    contentType(Json)
    body = Dog()
}

How do I get ktor to do polymorphic serialisation correctly?

body

ends up being

{}

instead of

{ "type": "Dog" }

.

Whenever I run Ktor with Exposed, only the one that comes first actually works. For example, if I put the database stuff above the install if-statement, Hikari works fine and I get a bunch of console spam of hikari logs, however ktor doesn't connect. If I put Exposed at the bottom, ktor works but exposed doesn't. routing above transaction & datasource 2021-04-28 01:42:59.490 [main] INFO Application - Responding at http://0.0.0.0:2828 2021-04-28 01:42:59.490 [main] INFO Application - Responding at https://0.0.0.0:1818 routing below database stuff: 2021-04-28 01:34:18.495 [main] INFO Application - No ktor.deployment.watch patterns specified, automatic reload is not active 2021-04-28 01:34:18.942 [main] DEBUG com.zaxxer.hikari.HikariConfig - Driver class com.mysql.cj.jdbc.Driver found in Thread context class loader sun.misc.Launcher$AppClassLoader@1b6d3586 2021-04-28 01:34:19.026 [main] DEBUG com.zaxxer.hikari.HikariConfig - HikariPool-1 - configuration: ....

@Suppress("unused") // Referenced in application.conf
@kotlin.jvm.JvmOverloads
fun Application.module(testing: Boolean = false) {
    // <https://ktor.io/servers/features/https-redirect.html#testing>
    if (!testing) {
        install(HttpsRedirect) {
            // The port to redirect to. By default 443, the default HTTPS port.
            sslPort = 1818
            // 301 Moved Permanently, or 302 Found redirect.
            permanentRedirect = true
        }
    }
    install(ContentNegotiation) {
        gson {}
    }

    routing {
        userRoutes()
        /*
        fileRoutes()
        miscRoutes()
        deliveryRoutes()
        */

        static("/") {
            files("public")
            default("public/index.html")
        }
    }

    val dataSource = HikariDataSource().apply {
        maximumPoolSize = 20
        driverClassName = "com.mysql.cj.jdbc.Driver"
        jdbcUrl = "[removed]"
        addDataSourceProperty("user", "mediauser")
        addDataSourceProperty("password", "[removed]")
        isAutoCommit = false
    }

    Database.Companion.connect(dataSource)

    transaction {
        addLogger(StdOutSqlLogger)
        SchemaUtils.create(MediaPropertiesTable, MediaContentTable, UserAPIKeysTable, UserTable)
    }

    Thread(ConsoleRunnable).run()
}

not really a problem in ktor, but the ktor source causes a lot of exceptions in idea. just git checkout main, open the project in idea, and the exception reporter starts reporting errors. Its also not possible to navigate by control clicking.

Many folks have told us that they lack guidance on real-world samples with Ktor. We’re going to work on fixing this. Do let us know (either here or replying to the tweet), what you’d like to see. https://twitter.com/JetBrainsKtor/status/1387406887315025924

Hi. Why I can’t request GET request with body?

I’m encountering the following error.

Exception in thread “main” io.ktor.application.DuplicateApplicationFeatureException: Conflicting application feature is already installed with the same key as

Call Logging

embeddedServer(
    factory = Netty,
    port = 8080,
    host = "0.0.0.0",
    watchPaths = listOf("classes"),
    module = {
        install(CallLogging)
        install(CachingHeaders)
        artworkRouting()
    }

I can’t figure out why this has suddenly started occurring.. Any ideas?

Hello, Is this the correct procedure to catch a 3rd party API error, parse it to evaluate the type of exception, and proceed with custom logic? Details in thread :thread-please: Thanks!

Is there plans to release Ktor, which will be compatible with Kotlin

1.5.0

? Ktor update required for: 1. Coroutines

1.5.0-RC

2. Serialization

1.2.0

3. Kotlin Wrappers update Bulk update required, because JS module name of serialization library was changed 😞

I figured out the cause of the

DuplicateApplicationFeatureException

, I believe it's due to a bug in Ktor (sort of tracked here: https://youtrack.jetbrains.com/issue/KTOR-2586)

I’m having trouble getting the remote jvm debugger to attach to my ktor application. The application runs in a docker container, via

installDist

as per the documentation. Running on openjdk 11 JVM args are :

applicationDefaultJvmArgs = listOf(
    "-Dio.ktor.development=true",
    "-Dagentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=*:8081"
)

I’ve exposed the port 8081.

message has been deleted

Hi fella, hope you are doing good. So, I have the following configuration in my server

routing {
  get("/") {
    // this works as expected
  }

  static("/") {
    // I have this as well
  }

  //and
  get("/config/{file}") {
    // overridden by static("/")
  }
}

Question is, how do I implement both

static("/")

overriding my

get("/config/{file}")

. With both of them existing, ,aking a get request to

/config/user1

returns not fount. I am assuming it is looking to the files served as static resources. Help?

ktor-client question --- I’m trying to make an HTTP POST request with an xml body and no magic serialization, and to set the ContentType header. I assumed I could do, e.g.

val xmlBody: String = [prepare body]

<http://client.post|client.post>([uri]) {
    contentType(ContentType.Text.Xml)
    body = xmlBody
}

However, I’m getting,

io.ktor.http.UnsafeHeaderException: Header(s) [Content-Type] are controlled by the engine and cannot be set explicitly

What’s the correct way to specify the Content-Type header, if not by explicitly calling contentType()?

Why may Ktor Authentication feature's authenticated route handlers be executed with empty principal, despite of not being optional? Code further in thread

Hey all, is there a default database connection pooler for Ktor + Exposed or do you need to use something like Hikari? Haven't been able to find a definitive answer from the docs

I see that Ktor has a generator that reads OpenAPI, is there a way to do the opposite (generate an OpenAPI file from my route declarations)?

For Ktor Server - If I wanted to log the request for any server error in ktor, what would be the best way to do that?

In Android, since ktor 1.5.3 I been having at random times a failure in client requests, if I use android engine I've got unexpected end of stream time to time, If I use CIO engine I've got IllegalStateException expected 8 bytes in the trailer actual 7. time to time too. And well the request is just the same it works ok 7 times and fails 3 +-. I thing there should to be a bug somewhere .....

Say a user tries hitting the endpoint with a 5 gb file, and I use this code:

val buffer = (part as PartData.FileItem).streamProvider().buffered()

Those 5gb will never load into memory correct? Is there a way I can get the size of the uploaded file without loading it all into memory as well?

Hello all, I’m using SLQDelight to create a DB. Everything is ok and works as expected, my question is: How can I avoid BD recreation every-time I run/kill my localhost server? 🤔 All my tables are created with

CREATE TABLE IF NOT EXISTS

so I assume the file is being deleted. How can I avoid that? Also, where’s the file located? I don’t have this problem in KMM projects (for android/ios), the BD is never deleted (only if I clean cache of course). Thanks!

i am trying to use

Curl

engine on desktop i am running into

C:\Users\nikky\.konan\dependencies\msys2-mingw-w64-x86_64-clang-llvm-lld-compiler_rt-8.0.1\bin\ld: cannot find -lcurl

i am trying to figure out where i need to install curl.. or what magic env var i have to set i am guessing i need to install

pacman -S mingw-w64-x86_64-curl

in MSYS2, but apparently it is not picked up maybe because my msys2 is not in the default location? i also installed

curl

via scoop, not sure what else i can do

Hey folks! I'm using Ktor in a Kotlin Multiplatform project, where I have a strange error. I was wondering if you could help me out on what could be the problem: So far I've been using ktor 1.4.0 with kotlinx serialization 1.0.0-RC and it was working properly (parsing json responses from our backend). I've tried to upgrade today and checked out ktor 1.5.4 with kotlinx serialization 1.2.0 and whenever my app would send a message to the server it instantly fails and returns the following message in the log: 2021-05-06 15:38:33.244 12301-12404/com.myappsid I/System.out: >> Exception: length=164; index=164