refactor: track upstream HTTP serde changes (#1263)

Author: aajtodd

codegen/aws-sdk-codegen/src/main/kotlin/aws/sdk/kotlin/codegen/customization/s3/S3OperationErrorHandler.kt

@@ -63,8 +63,7 @@ class S3OperationErrorHandler : KotlinIntegration {
             namespace = "${ctx.settings.pkg.name}.internal"
         }
 
-        writer.write("val payload = call.response.body.#T()", RuntimeTypes.Http.readAll)
-            .write("val wrappedResponse = call.response.#T(payload)", RuntimeTypes.AwsProtocolCore.withPayload)
+        writer.write("val wrappedResponse = call.response.#T(payload)", RuntimeTypes.AwsProtocolCore.withPayload)
             .write("val wrappedCall = call.copy(response = wrappedResponse)")
             .write("")
             .write("val errorDetails = try {")
@@ -97,7 +96,7 @@ class S3OperationErrorHandler : KotlinIntegration {
                     name = "${errSymbol.name}Deserializer"
                     namespace = ctx.settings.pkg.serde
                 }
-                writer.write("#S -> #T().deserialize(context, wrappedCall)", err.name, errDeserializerSymbol)
+                writer.write("#S -> #T().deserialize(context, wrappedCall, payload)", err.name, errDeserializerSymbol)
             }
             write("else -> #T(errorDetails.message)", exceptionBaseSymbol)
         }

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.1.1"
-smithy-kotlin-codegen-version = "0.31.1"
+smithy-kotlin-runtime-version = "1.1.3"
+smithy-kotlin-codegen-version = "0.31.3"
 
 # codegen
 smithy-version = "1.45.0"

services/route53/common/test/aws/sdk/kotlin/services/route53/internal/ChangeResourceRecordSetsUnmarshallingTest.kt

@@ -41,7 +41,7 @@ class ChangeResourceRecordSetsUnmarshallingTest {
 
         val exception = assertFailsWith<InvalidChangeBatch> {
             runBlocking {
-                ChangeResourceRecordSetsOperationDeserializer().deserialize(ExecutionContext(), call)
+                ChangeResourceRecordSetsOperationDeserializer().deserialize(ExecutionContext(), call, bodyText.encodeToByteArray())
             }
         }
         assertEquals(listOf<String>("InvalidChangeBatch message"), exception.messages)
@@ -70,7 +70,7 @@ class ChangeResourceRecordSetsUnmarshallingTest {
 
         val exception = assertFailsWith<InvalidChangeBatch> {
             runBlocking {
-                ChangeResourceRecordSetsOperationDeserializer().deserialize(ExecutionContext(), call)
+                ChangeResourceRecordSetsOperationDeserializer().deserialize(ExecutionContext(), call, bodyText.encodeToByteArray())
             }
         }
         assertEquals(listOf<String>("InvalidChangeBatch message 1", "InvalidChangeBatch message 2"), exception.messages)
@@ -100,7 +100,7 @@ class ChangeResourceRecordSetsUnmarshallingTest {
 
         val exception = assertFailsWith<InvalidChangeBatch> {
             runBlocking {
-                ChangeResourceRecordSetsOperationDeserializer().deserialize(ExecutionContext(), call)
+                ChangeResourceRecordSetsOperationDeserializer().deserialize(ExecutionContext(), call, bodyText.encodeToByteArray())
             }
         }
         assertEquals(listOf<String>("InvalidChangeBatch message 1", "InvalidChangeBatch message 2"), exception.messages)

services/s3/common/test/aws/sdk/kotlin/services/s3/internal/GetBucketLocationOperationDeserializerTest.kt

@@ -38,7 +38,7 @@ class GetBucketLocationOperationDeserializerTest {
         val call = HttpCall(HttpRequestBuilder().build(), response, Instant.now(), Instant.now())
 
         val actual = runBlocking {
-            GetBucketLocationOperationDeserializer().deserialize(ExecutionContext(), call)
+            GetBucketLocationOperationDeserializer().deserialize(ExecutionContext(), call, responseXML.encodeToByteArray())
         }
 
         assertEquals(BucketLocationConstraint.UsWest2, actual.locationConstraint)
@@ -63,7 +63,7 @@ class GetBucketLocationOperationDeserializerTest {
         val call = HttpCall(HttpRequestBuilder().build(), response, Instant.now(), Instant.now())
         val exception = assertFailsWith<S3Exception> {
             runBlocking {
-                GetBucketLocationOperationDeserializer().deserialize(ExecutionContext(), call)
+                GetBucketLocationOperationDeserializer().deserialize(ExecutionContext(), call, responseXML.encodeToByteArray())
             }
         }