Re-enable way more tests

Author: lauzadis

runtime/crt-util/jvmAndNative/test/aws/smithy/kotlin/runtime/crt/SdkSourceBodyStreamTest.kt

@@ -22,7 +22,6 @@ class SdkSourceBodyStreamTest {
         return MutableBuffer.of(dest) to dest
     }
 
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native implementation
     @Test
     fun testReadFully() = runTest {
         val data = byteArrayOf(1, 2, 3, 4, 5)
@@ -37,7 +36,6 @@ class SdkSourceBodyStreamTest {
         }
     }
 
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native implementation
     @Test
     fun testPartialRead() = runTest {
         val source = "123456".encodeToByteArray().source()
@@ -55,7 +53,6 @@ class SdkSourceBodyStreamTest {
         assertEquals("456", sent2.decodeToString())
     }
 
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native implementation
     @Test
     fun testLargeTransfer() = runTest {
         val data = "foobar"

runtime/protocol/aws-event-stream/common/test/aws/smithy/kotlin/runtime/awsprotocol/eventstream/FrameDecoderTest.kt

@@ -15,7 +15,6 @@ import kotlin.test.assertEquals
 import kotlin.test.assertFailsWith
 
 class FrameDecoderTest {
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native implementation
     @Test
     fun testFrameStreamSingleMessage() = runTest {
         val encoded = validMessageWithAllHeaders()
@@ -29,7 +28,6 @@ class FrameDecoderTest {
         assertEquals(expected, actual.first())
     }
 
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native implementation
     @Test
     fun testFrameStreamMultipleMessagesChunked() = runTest {
         val encoded = SdkBuffer().apply {
@@ -53,7 +51,6 @@ class FrameDecoderTest {
         assertEquals(expected3, actual[2])
     }
 
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native implementation
     @Test
     fun testChannelClosed() = runTest {
         // contents don't matter

runtime/protocol/aws-json-protocols/common/test/aws/smithy/kotlin/runtime/awsprotocol/json/AwsJsonProtocolTest.kt

@@ -18,7 +18,6 @@ import kotlin.test.Test
 import kotlin.test.assertEquals
 
 class AwsJsonProtocolTest {
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native implementation
     @Test
     fun testSetJsonProtocolHeaders() = runTest {
         @Suppress("DEPRECATION")
@@ -41,7 +40,6 @@ class AwsJsonProtocolTest {
         assertEquals("FooService_blah.Bar", request.headers["X-Amz-Target"])
     }
 
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native implementation
     @Test
     fun testEmptyBody() = runTest {
         @Suppress("DEPRECATION")
@@ -61,7 +59,6 @@ class AwsJsonProtocolTest {
         assertEquals("{}", actual)
     }
 
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native implementation
     @Test
     fun testDoesNotOverride() = runTest {
         @Suppress("DEPRECATION")

runtime/protocol/http-client-engines/http-client-engine-crt/jvmAndNative/test/aws/smithy/kotlin/runtime/http/engine/crt/AsyncStressTest.kt

@@ -37,7 +37,7 @@ class AsyncStressTest : TestWithLocalServer() {
         }
     }.start()
 
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native implementation
+//    @IgnoreNative // FIXME Re-enable after Kotlin/Native implementation
     @Test
     fun testStreamNotConsumed() = runBlocking {
         // test that filling the stream window and not consuming the body stream still cleans up resources

runtime/protocol/http-client-engines/http-client-engine-crt/jvmAndNative/test/aws/smithy/kotlin/runtime/http/engine/crt/RequestConversionTest.kt

@@ -54,7 +54,6 @@ class RequestConversionTest {
         assertFalse(crtRequest.body is ReadChannelBodyStream)
     }
 
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native implementation
     @Test
     fun testSdkToCrtRequestStreamingBody() {
         val stream = byteStreamFromContents("foobar")
@@ -73,7 +72,6 @@ class RequestConversionTest {
         crtBody.cancel()
     }
 
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native implementation
     @Test
     fun testEngineAddsContentLengthHeader() {
         val stream = byteStreamFromContents("foobar")

runtime/protocol/http-client-engines/http-client-engine-crt/jvmAndNative/test/aws/smithy/kotlin/runtime/http/engine/crt/SdkStreamResponseHandlerTest.kt

@@ -125,7 +125,6 @@ class SdkStreamResponseHandlerTest {
         assertTrue(respChan.isClosedForWrite)
     }
 
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native implementation
     @Test
     fun testRespBody() = runTest {
         val handler = SdkStreamResponseHandler(mockConn, coroutineContext)
@@ -154,7 +153,6 @@ class SdkStreamResponseHandlerTest {
         assertEquals(data, respChan.readToBuffer().readUtf8())
     }
 
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native implementation
     @Test
     fun testStreamError() = runTest {
         val handler = SdkStreamResponseHandler(mockConn, coroutineContext)

runtime/protocol/http-client-engines/http-client-engine-crt/jvmAndNative/test/aws/smithy/kotlin/runtime/http/engine/crt/SendChunkedBodyTest.kt

@@ -28,7 +28,6 @@ class SendChunkedBodyTest {
         }
     }
 
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native implementation
     @Test
     fun testSourceContent() = runTest {
         val stream = MockHttpStream(200)
@@ -46,7 +45,6 @@ class SendChunkedBodyTest {
         assertEquals(1, stream.numChunksWritten)
     }
 
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native implementation
     @Test
     fun testChannelContentMultipleChunks() = runTest {
         val stream = MockHttpStream(200)
@@ -68,7 +66,6 @@ class SendChunkedBodyTest {
         assertTrue(stream.numChunksWritten > 1)
     }
 
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native implementation
     @Test
     fun testChannelContent() = runTest {
         val stream = MockHttpStream(200)
@@ -87,7 +84,6 @@ class SendChunkedBodyTest {
         assertEquals(1, stream.numChunksWritten)
     }
 
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native implementation
     @Test
     fun testSourceContentMultipleChunks() = runTest {
         val stream = MockHttpStream(200)

runtime/protocol/http-client/common/test/aws/smithy/kotlin/runtime/http/engine/HttpCallContextTest.kt

@@ -25,7 +25,6 @@ import kotlin.test.assertTrue
 import kotlin.coroutines.coroutineContext as currentCoroutineContext
 
 class HttpCallContextTest {
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native Implementation
     @OptIn(ExperimentalCoroutinesApi::class)
     @Test
     fun testStructuredConcurrency() = runTest {

runtime/protocol/http-client/common/test/aws/smithy/kotlin/runtime/http/engine/HttpClientEngineTest.kt

@@ -61,7 +61,6 @@ class HttpClientEngineTest {
     private val HttpCall.job: Job
         get() = coroutineContext.job
 
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native Implementation
     @Test
     fun testCallComplete() = runTest {
         val call = client.call(HttpRequestBuilder())
@@ -71,7 +70,6 @@ class HttpClientEngineTest {
         assertTrue(call.job.isCompleted)
     }
 
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native Implementation
     @Test
     fun testUserContextCancelsRequestJob() = runTest {
         val job = launch {
@@ -88,7 +86,6 @@ class HttpClientEngineTest {
         assertTrue(callJob.isCancelled)
     }
 
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native Implementation
     @Test
     fun testInFlightRequestJobsAreIndependent() = runTest {
         val job1 = launch {
@@ -113,7 +110,6 @@ class HttpClientEngineTest {
         job2.cancel()
     }
 
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native Implementation
     @Test
     fun testEngineJobNotCancelledByRequestJobs() = runTest {
         launch {
@@ -131,7 +127,6 @@ class HttpClientEngineTest {
         assertTrue(engine.coroutineContext.job.isActive)
     }
 
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native Implementation
     @Test
     fun testShutdownOnlyAfterInFlightDone() = runTest {
         val waiter = Channel<Unit>(1)
@@ -166,7 +161,6 @@ class HttpClientEngineTest {
         assertTrue(engine.shutdownCalled)
     }
 
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native Implementation
     @Test
     fun testRequestAfterClose() = runTest {
         engine.close()

runtime/protocol/http-client/common/test/aws/smithy/kotlin/runtime/http/interceptors/CachingChecksumInterceptorTest.kt

@@ -25,7 +25,6 @@ private val CHECKSUM_TEST_HEADER = "x-amz-kotlin-sdk-test-checksum-header"
 class CachingChecksumInterceptorTest {
     private val client = SdkHttpClient(TestEngine())
 
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native Implementation
     @Test
     fun testChecksumIsCalculatedAndApplied() = runTest {
         val req = HttpRequestBuilder().apply {
@@ -42,7 +41,6 @@ class CachingChecksumInterceptorTest {
         assertEquals(expectedChecksumValue, call.request.headers[CHECKSUM_TEST_HEADER])
     }
 
-    @IgnoreNative // FIXME Re-enable after Kotlin/Native Implementation
     @Test
     fun testCachedChecksumIsUsed() = runTest {
         val req = HttpRequestBuilder().apply {