misc: add an E2E test setting Content-Length header on an aws-chunked request (#1257)

Author: lauzadis

gradle/libs.versions.toml

@@ -9,8 +9,8 @@ coroutines-version = "1.7.3"
 atomicfu-version = "0.23.1"
 
 # smithy-kotlin codegen and runtime are versioned separately
-smithy-kotlin-runtime-version = "1.0.19"
-smithy-kotlin-codegen-version = "0.30.20"
+smithy-kotlin-runtime-version = "1.0.20"
+smithy-kotlin-codegen-version = "0.30.21"
 
 # codegen
 smithy-version = "1.45.0"

services/s3/e2eTest/src/S3IntegrationTest.kt

@@ -14,13 +14,15 @@ import aws.smithy.kotlin.runtime.content.asByteStream
 import aws.smithy.kotlin.runtime.content.decodeToString
 import aws.smithy.kotlin.runtime.content.fromFile
 import aws.smithy.kotlin.runtime.content.toByteArray
+import aws.smithy.kotlin.runtime.content.toByteStream
 import aws.smithy.kotlin.runtime.hashing.sha256
 import aws.smithy.kotlin.runtime.http.HttpException
 import aws.smithy.kotlin.runtime.http.interceptors.HttpInterceptor
 import aws.smithy.kotlin.runtime.http.request.HttpRequest
 import aws.smithy.kotlin.runtime.testing.RandomTempFile
 import aws.smithy.kotlin.runtime.text.encoding.encodeToHex
 import kotlinx.coroutines.*
+import kotlinx.coroutines.flow.flow
 import kotlinx.coroutines.flow.toList
 import org.junit.jupiter.api.AfterAll
 import org.junit.jupiter.api.BeforeAll
@@ -108,6 +110,20 @@ class S3BucketOpsIntegrationTest {
         assertEquals(contents, roundTrippedContents)
     }
 
+    @Test
+    fun testPutObjectWithToByteStreamAndContentLength(): Unit = runBlocking {
+        // See https://github.com/awslabs/aws-sdk-kotlin/issues/1249
+        val keyName = "toByteStream-contentLength.txt"
+        val arr = "Hello!".encodeToByteArray()
+
+        client.putObject {
+            bucket = testBucket
+            key = keyName
+            body = flow { emit(arr) }.toByteStream(this@runBlocking, arr.size.toLong())
+            contentLength = arr.size.toLong()
+        }
+    }
+
     @Test
     fun testGetEmptyObject(): Unit = runBlocking {
         // See https://github.com/awslabs/aws-sdk-kotlin/issues/1014