authenticate("auth-session") {}

Foo

Authentication

val Foo = createApplicationPlugin("Foo") {
    after(Authentication) {

    }
}

after

Type mismatch.
Required: io.ktor.server.application.Plugin<*, *, PluginInstance>
Found: io.ktor.server.auth.Authentication.Plugin

io.ktor.server.auth.Authentication.Plugin

ApplicationPlugin<Application, Configuration, Authentication>

io.ktor.server.application.Plugin<*, *, PluginInstance>

defaultRequest

HttpClient {
            // ... 
            defaultRequest {
                url {
                    protocol = URLProtocol.HTTPS
                    host = "<http://api.themoviedb.org|api.themoviedb.org>"
                    encodedPath = "/3$encodedPath" // prepend API version to path
                    parametersOf("api_key", "my_api_key_value")
                }
            }
         }

    suspend fun getConfiguration(): ApiConfig = client.get("configuration").body()

io.ktor.client.plugins.ClientRequestException: Client request(GET <https://api.themoviedb.org/3/configuration>) invalid: 401 Unauthorized. Text: "{"status_code":7,"status_message":"Invalid API key: You must be granted a valid key.","success":false}

2.0.0-beta-1

io.ktor:server-cors

window.fetch

Ktor now supports a way to construct a JSON body using the

kotlinx.serialization

DSL:

<http://client.post|client.post>("<http://localhost:9090>") {
contentType(ContentType.Application.Json)
body = json {
"key1" to 123
"map" to json {
"key2" to "abc"
}
}
}

To use it on a client, install JsonFeature and add the ktor-client-serialization dependency.

json

1.6.10

logger

Fail to create response observer in different native thread.

logger

X-GitHub-Event

X-Github-Event

java.nio.channels.UnresolvedAddressException

[ModelValidationHandler, AuthErrorHandler]

Logging

HttpClientFeature<*, *>

content

ByteReadChannel

HttpResponse

String

val observer: ResponseHandler = { response ->
                try {
                    val message = response.content
                            .readRemaining()
                            .readText(charset = response.charset()?: Charsets.UTF_8)
                } catch (_: Throwable) {
                } 
            }

            ResponseObserver.install(ResponseObserver(observer), scope)

Logging

Coroutines must be initialized from the main thread: call 'initMainThread' from the main thread first

2.0.0-beta-1

install(StatusPages) {

exception<Throwable> { cause ->

call.respond(HttpStatusCode.InternalServerError)

}

}

.close

.awaitClose()

.dispose()

fun main() {
    embeddedServer(Netty, port = 8080, host = "localhost") {
        configureRouting()
        configureSerialization()
    }.start(wait = true)
}

fun Application.configureSerialization() {
    install(ContentNegotiation) {
        json(Json {
            prettyPrint = true
            isLenient = true
        })
    }
}
fun Application.configureRouting() {
    routing {
        get("/") {
            call.respondText("Wolt Opening Times Formatter")
        }
        post("/") {
            val data = call.receive<String>()
            call.respondText(data.toString())
        }
    }
}

post("/") {
            val data = call.receive<TestData>()
            call.respondText(data.toString())
        }
    }
}
@kotlinx.serialization.Serializable
data class TestData(
    val monday: Int,
)

{
  "monday": 12
}

Cannot transform this request's content to simonvoid.gmx.de.time_formatter.plugins.TestData
io.ktor.features.CannotTransformContentToTypeException: Cannot transform this request's content to simonvoid.gmx.de.time_formatter.plugins.TestData`
...
Caused by: io.ktor.features.CannotTransformContentToTypeException: Cannot transform this request's content to simonvoid.gmx.de.time_formatter.plugins.TestData

val data = call.receive<Map<String,Int>>()

Caused by: io.ktor.features.CannotTransformContentToTypeException: Cannot transform this request's content to kotlin.collections.Map<kotlin.String, kotlin.Int>

@SpringBootApplication
class TodoConsumerApplication {
    @Bean
    fun httpClient() = HttpClient {
        install(JsonFeature)
    }
}

fun main(args: Array<String>) {
    runApplication<TodoConsumerApplication>(*args)
}

@Service
class TodoConsumerService(
    private val httpClient: HttpClient
) {
    suspend fun getItemsTwoTimes() {
        val result1 = httpClient.get<String>("<http://localhost:8080/items>")
        val result2 = httpClient.get<String>("<http://localhost:8080/items>")

        println("Result 1 = $result1 and Result 2 = $result2")
    }
}

@ExtendWith(SpringExtension::class)
@SpringBootTest
internal class TodoConsumerServiceTest {
    @MockkBean
    private lateinit var httpClient: HttpClient

    @Autowired
    private lateinit var todoConsumerService: TodoConsumerService

    @Test
    fun getItemsTwoTimes() = runBlocking {

    }
}