Update ktor, use std allocator as the fastest one (#4)

Author: trueangle

gradle.properties

@@ -7,3 +7,4 @@ org.gradle.jvmargs=-Xmx2048M -Dfile.encoding=UTF-8 -Dkotlin.daemon.jvm.options\=
 io.ktor.development=true
 
 #kotlin.native.cacheKind.linuxX64=none
+kotlin.native.ignoreDisabledTargets=true

gradle/libs.versions.toml

@@ -1,8 +1,8 @@
 [versions]
 junit = "4.13.2"
-kotlin = "2.0.10"
+kotlin = "2.0.20"
 coroutinest-test = "1.9.0-RC"
-ktor = "3.0.0-beta-2"
+ktor = "3.0.0-rc-1"
 serialization = "1.6.3"
 logback = "1.5.6"
 io = "0.5.1"

lambda-runtime/build.gradle.kts

@@ -1,4 +1,7 @@
 import dev.mokkery.MockMode
+import org.jetbrains.kotlin.gradle.ExperimentalKotlinGradlePluginApi
+import org.jetbrains.kotlin.gradle.tasks.KotlinCompilationTask
+import org.jetbrains.kotlin.gradle.tasks.KotlinCompileCommon
 
 plugins {
     alias(libs.plugins.kotlin.multiplatform)
@@ -14,6 +17,11 @@ kotlin {
     //linuxArm64() // https://youtrack.jetbrains.com/issue/KT-36871/Support-Aarch64-Linux-as-a-host-for-the-Kotlin-Native
     linuxX64()
 
+    @OptIn(ExperimentalKotlinGradlePluginApi::class)
+    compilerOptions {
+        freeCompilerArgs.addAll(listOf("-Xallocator=std"))
+    }
+
     sourceSets {
         commonMain.dependencies {
             implementation(projects.lambdaEvents)
@@ -38,4 +46,4 @@ kotlin {
 
 mokkery {
     defaultMockMode.set(MockMode.autoUnit)
-}
+}

lambda-runtime/src/commonMain/kotlin/io/github/trueangle/knative/lambda/runtime/api/LambdaRuntimeClient.kt

@@ -21,6 +21,7 @@ import io.ktor.client.statement.HttpResponse
 import io.ktor.http.HttpStatusCode
 import io.ktor.http.content.OutgoingContent
 import io.ktor.http.contentType
+import io.ktor.http.isSuccess
 import io.ktor.util.reflect.TypeInfo
 import kotlinx.serialization.json.Json
 import kotlin.time.Duration.Companion.minutes
@@ -53,6 +54,11 @@ internal class LambdaClientImpl(private val httpClient: HttpClient): LambdaClien
                 exponentialDelay()
             }
         }
+
+        if(!response.status.isSuccess()) {
+            throw NonRecoverableStateException(message = "Lambda environment is unavailable. Can't retrieve an event. Terminating")
+        }
+
         val context = contextFromResponseHeaders(response)
         val body = try {
             response.body(bodyType) as T

lambda-runtime/src/nativeTest/kotlin/io/github/trueangle/knative/lambda/runtime/LambdaRuntimeTest.kt

@@ -11,7 +11,8 @@ import dev.mokkery.verify.VerifyMode.Companion.exactly
 import dev.mokkery.verify.VerifyMode.Companion.not
 import dev.mokkery.verify.VerifyMode.Companion.order
 import dev.mokkery.verifySuspend
-import io.github.trueangle.knative.lambda.runtime.LambdaEnvironmentException.*
+import io.github.trueangle.knative.lambda.runtime.LambdaEnvironmentException.BadRequestException
+import io.github.trueangle.knative.lambda.runtime.LambdaEnvironmentException.NonRecoverableStateException
 import io.github.trueangle.knative.lambda.runtime.LambdaRuntimeException.Invocation.EventBodyParseException
 import io.github.trueangle.knative.lambda.runtime.LambdaRuntimeException.Invocation.HandlerException
 import io.github.trueangle.knative.lambda.runtime.ReservedRuntimeEnvironmentVariables.AWS_LAMBDA_FUNCTION_NAME
@@ -33,12 +34,8 @@ import io.ktor.client.engine.mock.MockRequestHandleScope
 import io.ktor.client.engine.mock.respond
 import io.ktor.client.engine.mock.respondBadRequest
 import io.ktor.client.engine.mock.respondError
-import io.ktor.client.engine.mock.respondOk
-import io.ktor.client.request.HttpRequestData
 import io.ktor.http.HttpHeaders
 import io.ktor.http.HttpStatusCode
-import io.ktor.http.content.ChannelWriterContent
-import io.ktor.http.content.OutgoingContent
 import io.ktor.http.headers
 import io.ktor.http.headersOf
 import io.ktor.util.reflect.typeInfo
@@ -48,16 +45,12 @@ import io.ktor.utils.io.copyTo
 import kotlinx.cinterop.ExperimentalForeignApi
 import kotlinx.cinterop.toKString
 import kotlinx.coroutines.test.runTest
-import kotlinx.io.Buffer
-import kotlinx.io.RawSource
-import kotlinx.io.Source
 import kotlinx.serialization.json.Json
 import platform.posix.getenv
 import platform.posix.setenv
 import kotlin.test.BeforeTest
 import kotlin.test.Test
 import kotlin.test.assertFailsWith
-import kotlin.test.assertTrue
 
 internal const val RESOURCES_PATH = "src/nativeTest/resources"
 
@@ -197,10 +190,7 @@ class LambdaRuntimeTest {
         val lambdaRunner = createRunner(MockEngine { request ->
             val path = request.url.encodedPath
             when {
-                path.contains("/invocation/next") -> {
-                    respondError(HttpStatusCode.InternalServerError)
-                }
-
+                path.contains("/invocation/next") -> respondError(HttpStatusCode.InternalServerError)
                 else -> respondError(HttpStatusCode.Forbidden)
             }
         })

sample/build.gradle.kts

@@ -14,6 +14,7 @@ kotlin {
         it.binaries {
             executable {
                 entryPoint = "com.github.trueangle.knative.lambda.runtime.sample.main"
+                freeCompilerArgs += listOf("-Xallocator=std")
             }
         }
     }