Move ktor test suite to jvmAndNative

Author: lauzadis

gradle/libs.versions.toml

@@ -91,6 +91,7 @@ docker-transport-zerodep = { module = "com.github.docker-java:docker-java-transp
 ktor-http-cio = { module = "io.ktor:ktor-http-cio", version.ref = "ktor-version" }
 ktor-utils = { module = "io.ktor:ktor-utils", version.ref = "ktor-version" }
 ktor-io = { module = "io.ktor:ktor-io", version.ref = "ktor-version" }
+ktor-server-core = { module = "io.ktor:ktor-server-core", version.ref = "ktor-version" }
 ktor-server-netty = { module = "io.ktor:ktor-server-netty", version.ref = "ktor-version" }
 ktor-server-jetty-jakarta = { module = "io.ktor:ktor-server-jetty-jakarta", version.ref = "ktor-version" }
 ktor-server-cio = { module = "io.ktor:ktor-server-cio", version.ref = "ktor-version" }

runtime/protocol/http-client-engines/test-suite/build.gradle.kts

@@ -38,6 +38,7 @@ kotlin {
 
         jvmAndNativeMain {
             dependencies {
+                implementation(libs.ktor.server.core)
                 implementation(libs.kotlinx.coroutines.test)
             }
         }

runtime/protocol/http-client-engines/test-suite/jvm/src/aws/smithy/kotlin/runtime/http/test/util/TestServers.kt

@@ -12,7 +12,6 @@ import aws.smithy.kotlin.runtime.http.test.suite.tlsTests
 import aws.smithy.kotlin.runtime.http.test.suite.uploadTests
 import io.ktor.server.application.*
 import io.ktor.server.engine.*
-import io.ktor.server.jetty.*
 import io.ktor.server.jetty.jakarta.Jetty
 import io.ktor.server.jetty.jakarta.JettyApplicationEngineBase
 import redirectTests

runtime/protocol/http-client-engines/test-suite/jvm/src/aws/smithy/kotlin/runtime/http/test/suite/Concurrency.kt renamed to runtime/protocol/http-client-engines/test-suite/jvmAndNative/src/aws/smithy/kotlin/runtime/http/test/suite/Concurrency.kt

@@ -1,13 +1,14 @@
 /*
- * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
- * SPDX-License-Identifier: Apache-2.0
- */
+* Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+* SPDX-License-Identifier: Apache-2.0
+*/
 
 package aws.smithy.kotlin.runtime.http.test.suite
 
 import io.ktor.server.application.*
 import io.ktor.server.response.*
 import io.ktor.server.routing.*
+import io.ktor.utils.io.writeFully
 import kotlinx.coroutines.delay
 import kotlin.time.Duration.Companion.milliseconds
 
@@ -24,10 +25,10 @@ internal fun Application.concurrentTests() {
         route("slow") {
             get {
                 val chunk = ByteArray(256) { it.toByte() }
-                call.respondOutputStream {
+                call.respondBytesWriter {
                     repeat(10) {
                         delay(200.milliseconds)
-                        write(chunk)
+                        writeFully(chunk)
                     }
                 }
             }

runtime/protocol/http-client-engines/test-suite/jvm/src/aws/smithy/kotlin/runtime/http/test/suite/Connections.kt renamed to runtime/protocol/http-client-engines/test-suite/jvmAndNative/src/aws/smithy/kotlin/runtime/http/test/suite/Connections.kt

@@ -6,15 +6,16 @@
 package aws.smithy.kotlin.runtime.http.test.suite
 
 import aws.smithy.kotlin.runtime.hashing.sha256
+import aws.smithy.kotlin.runtime.io.GzipSdkSource
+import aws.smithy.kotlin.runtime.io.readToByteArray
+import aws.smithy.kotlin.runtime.io.source
 import aws.smithy.kotlin.runtime.text.encoding.encodeToHex
 import io.ktor.http.*
 import io.ktor.server.application.*
 import io.ktor.server.response.*
 import io.ktor.server.routing.*
 import io.ktor.utils.io.*
 import kotlinx.coroutines.delay
-import java.io.ByteArrayOutputStream
-import java.util.zip.GZIPOutputStream
 import kotlin.random.Random
 
 internal const val DOWNLOAD_SIZE = 16L * 1024 * 1024 // 16MB
@@ -53,18 +54,9 @@ internal fun Application.downloadTests() {
                 call.response.header("x-bar", "bar")
             }
 
-            // FIXME This is the only thing keeping this directory in `jvm`, could be `jvmAndNative`
             get("/gzipped") {
                 val uncompressed = ByteArray(1024) { it.toByte() }
-                val compressed = ByteArrayOutputStream().use { baStream ->
-                    GZIPOutputStream(baStream).use { gzStream ->
-                        gzStream.write(uncompressed)
-                        gzStream.flush()
-                    }
-                    baStream.flush()
-                    baStream.toByteArray()
-                }
-
+                val compressed = GzipSdkSource(uncompressed.source()).readToByteArray()
                 call.response.header("Content-Encoding", "gzip")
                 call.respondBytes(compressed)
             }