chore: Updated codegen (#1415)

awslabs · Mar 18, 2024 · af98402 · af98402
1 parent 02cc6cb
commit af98402
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 10 deletions.
diff --git a/Sources/Services/AWSLexRuntimeV2/LexRuntimeV2Client.swift b/Sources/Services/AWSLexRuntimeV2/LexRuntimeV2Client.swift
@@ -505,7 +505,7 @@ extension LexRuntimeV2Client {
         operation.buildStep.intercept(position: .before, middleware: ClientRuntime.AuthSchemeMiddleware<StartConversationOutput>())
         operation.serializeStep.intercept(position: .after, middleware: ClientRuntime.HeaderMiddleware<StartConversationInput, StartConversationOutput>(StartConversationInput.headerProvider(_:)))
         operation.serializeStep.intercept(position: .after, middleware: ContentTypeMiddleware<StartConversationInput, StartConversationOutput>(contentType: "application/json"))
-        operation.serializeStep.intercept(position: .after, middleware: ClientRuntime.EventStreamBodyMiddleware<StartConversationInput, StartConversationOutput, LexRuntimeV2ClientTypes.StartConversationRequestEventStream>(keyPath: \.requestEventStream, defaultBody: "{}"))
+        operation.serializeStep.intercept(position: .after, middleware: ClientRuntime.EventStreamBodyMiddleware<StartConversationInput, StartConversationOutput, LexRuntimeV2ClientTypes.StartConversationRequestEventStream>(keyPath: \.requestEventStream, defaultBody: "{}", marshalClosure: jsonMarshalClosure(requestEncoder: encoder)))
         operation.finalizeStep.intercept(position: .before, middleware: ClientRuntime.ContentLengthMiddleware())
         operation.finalizeStep.intercept(position: .after, middleware: ClientRuntime.RetryMiddleware<ClientRuntime.DefaultRetryStrategy, AWSClientRuntime.AWSRetryErrorInfoProvider, StartConversationOutput>(options: config.retryStrategyOptions))
         operation.finalizeStep.intercept(position: .before, middleware: ClientRuntime.SignerMiddleware<StartConversationOutput>())

diff --git a/Sources/Services/AWSS3/models/Models.swift b/Sources/Services/AWSS3/models/Models.swift
@@ -1832,7 +1832,7 @@ extension S3ClientTypes.ContinuationEvent {
 
     static var readingClosure: SmithyReadWrite.ReadingClosure<S3ClientTypes.ContinuationEvent, SmithyXML.Reader> {
         return { reader in
-            guard reader.content != nil else { return nil }
+            guard reader.content != nil || Mirror(reflecting: self).children.isEmpty else { return nil }
             return S3ClientTypes.ContinuationEvent()
         }
     }
@@ -5162,7 +5162,7 @@ extension S3ClientTypes.EndEvent {
 
     static var readingClosure: SmithyReadWrite.ReadingClosure<S3ClientTypes.EndEvent, SmithyXML.Reader> {
         return { reader in
-            guard reader.content != nil else { return nil }
+            guard reader.content != nil || Mirror(reflecting: self).children.isEmpty else { return nil }
             return S3ClientTypes.EndEvent()
         }
     }
@@ -6431,7 +6431,7 @@ extension S3ClientTypes.EventBridgeConfiguration {
 
     static var readingClosure: SmithyReadWrite.ReadingClosure<S3ClientTypes.EventBridgeConfiguration, SmithyXML.Reader> {
         return { reader in
-            guard reader.content != nil else { return nil }
+            guard reader.content != nil || Mirror(reflecting: self).children.isEmpty else { return nil }
             return S3ClientTypes.EventBridgeConfiguration()
         }
     }
@@ -15529,7 +15529,7 @@ extension S3ClientTypes.ParquetInput {
 
     static var readingClosure: SmithyReadWrite.ReadingClosure<S3ClientTypes.ParquetInput, SmithyXML.Reader> {
         return { reader in
-            guard reader.content != nil else { return nil }
+            guard reader.content != nil || Mirror(reflecting: self).children.isEmpty else { return nil }
             return S3ClientTypes.ParquetInput()
         }
     }
@@ -20381,7 +20381,7 @@ extension S3ClientTypes.SSES3 {
 
     static var readingClosure: SmithyReadWrite.ReadingClosure<S3ClientTypes.SSES3, SmithyXML.Reader> {
         return { reader in
-            guard reader.content != nil else { return nil }
+            guard reader.content != nil || Mirror(reflecting: self).children.isEmpty else { return nil }
             return S3ClientTypes.SSES3()
         }
     }
@@ -20982,7 +20982,7 @@ extension S3ClientTypes.SimplePrefix {
 
     static var readingClosure: SmithyReadWrite.ReadingClosure<S3ClientTypes.SimplePrefix, SmithyXML.Reader> {
         return { reader in
-            guard reader.content != nil else { return nil }
+            guard reader.content != nil || Mirror(reflecting: self).children.isEmpty else { return nil }
             return S3ClientTypes.SimplePrefix()
         }
     }

diff --git a/Sources/Services/AWSTranscribeStreaming/TranscribeStreamingClient.swift b/Sources/Services/AWSTranscribeStreaming/TranscribeStreamingClient.swift
@@ -191,7 +191,7 @@ extension TranscribeStreamingClient {
         operation.buildStep.intercept(position: .before, middleware: ClientRuntime.AuthSchemeMiddleware<StartCallAnalyticsStreamTranscriptionOutput>())
         operation.serializeStep.intercept(position: .after, middleware: ClientRuntime.HeaderMiddleware<StartCallAnalyticsStreamTranscriptionInput, StartCallAnalyticsStreamTranscriptionOutput>(StartCallAnalyticsStreamTranscriptionInput.headerProvider(_:)))
         operation.serializeStep.intercept(position: .after, middleware: ContentTypeMiddleware<StartCallAnalyticsStreamTranscriptionInput, StartCallAnalyticsStreamTranscriptionOutput>(contentType: "application/json"))
-        operation.serializeStep.intercept(position: .after, middleware: ClientRuntime.EventStreamBodyMiddleware<StartCallAnalyticsStreamTranscriptionInput, StartCallAnalyticsStreamTranscriptionOutput, TranscribeStreamingClientTypes.AudioStream>(keyPath: \.audioStream, defaultBody: "{}"))
+        operation.serializeStep.intercept(position: .after, middleware: ClientRuntime.EventStreamBodyMiddleware<StartCallAnalyticsStreamTranscriptionInput, StartCallAnalyticsStreamTranscriptionOutput, TranscribeStreamingClientTypes.AudioStream>(keyPath: \.audioStream, defaultBody: "{}", marshalClosure: jsonMarshalClosure(requestEncoder: encoder)))
         operation.finalizeStep.intercept(position: .before, middleware: ClientRuntime.ContentLengthMiddleware())
         operation.finalizeStep.intercept(position: .after, middleware: ClientRuntime.RetryMiddleware<ClientRuntime.DefaultRetryStrategy, AWSClientRuntime.AWSRetryErrorInfoProvider, StartCallAnalyticsStreamTranscriptionOutput>(options: config.retryStrategyOptions))
         operation.finalizeStep.intercept(position: .before, middleware: ClientRuntime.SignerMiddleware<StartCallAnalyticsStreamTranscriptionOutput>())
@@ -255,7 +255,7 @@ extension TranscribeStreamingClient {
         operation.buildStep.intercept(position: .before, middleware: ClientRuntime.AuthSchemeMiddleware<StartMedicalStreamTranscriptionOutput>())
         operation.serializeStep.intercept(position: .after, middleware: ClientRuntime.HeaderMiddleware<StartMedicalStreamTranscriptionInput, StartMedicalStreamTranscriptionOutput>(StartMedicalStreamTranscriptionInput.headerProvider(_:)))
         operation.serializeStep.intercept(position: .after, middleware: ContentTypeMiddleware<StartMedicalStreamTranscriptionInput, StartMedicalStreamTranscriptionOutput>(contentType: "application/json"))
-        operation.serializeStep.intercept(position: .after, middleware: ClientRuntime.EventStreamBodyMiddleware<StartMedicalStreamTranscriptionInput, StartMedicalStreamTranscriptionOutput, TranscribeStreamingClientTypes.AudioStream>(keyPath: \.audioStream, defaultBody: "{}"))
+        operation.serializeStep.intercept(position: .after, middleware: ClientRuntime.EventStreamBodyMiddleware<StartMedicalStreamTranscriptionInput, StartMedicalStreamTranscriptionOutput, TranscribeStreamingClientTypes.AudioStream>(keyPath: \.audioStream, defaultBody: "{}", marshalClosure: jsonMarshalClosure(requestEncoder: encoder)))
         operation.finalizeStep.intercept(position: .before, middleware: ClientRuntime.ContentLengthMiddleware())
         operation.finalizeStep.intercept(position: .after, middleware: ClientRuntime.RetryMiddleware<ClientRuntime.DefaultRetryStrategy, AWSClientRuntime.AWSRetryErrorInfoProvider, StartMedicalStreamTranscriptionOutput>(options: config.retryStrategyOptions))
         operation.finalizeStep.intercept(position: .before, middleware: ClientRuntime.SignerMiddleware<StartMedicalStreamTranscriptionOutput>())
@@ -319,7 +319,7 @@ extension TranscribeStreamingClient {
         operation.buildStep.intercept(position: .before, middleware: ClientRuntime.AuthSchemeMiddleware<StartStreamTranscriptionOutput>())
         operation.serializeStep.intercept(position: .after, middleware: ClientRuntime.HeaderMiddleware<StartStreamTranscriptionInput, StartStreamTranscriptionOutput>(StartStreamTranscriptionInput.headerProvider(_:)))
         operation.serializeStep.intercept(position: .after, middleware: ContentTypeMiddleware<StartStreamTranscriptionInput, StartStreamTranscriptionOutput>(contentType: "application/json"))
-        operation.serializeStep.intercept(position: .after, middleware: ClientRuntime.EventStreamBodyMiddleware<StartStreamTranscriptionInput, StartStreamTranscriptionOutput, TranscribeStreamingClientTypes.AudioStream>(keyPath: \.audioStream, defaultBody: "{}"))
+        operation.serializeStep.intercept(position: .after, middleware: ClientRuntime.EventStreamBodyMiddleware<StartStreamTranscriptionInput, StartStreamTranscriptionOutput, TranscribeStreamingClientTypes.AudioStream>(keyPath: \.audioStream, defaultBody: "{}", marshalClosure: jsonMarshalClosure(requestEncoder: encoder)))
         operation.finalizeStep.intercept(position: .before, middleware: ClientRuntime.ContentLengthMiddleware())
         operation.finalizeStep.intercept(position: .after, middleware: ClientRuntime.RetryMiddleware<ClientRuntime.DefaultRetryStrategy, AWSClientRuntime.AWSRetryErrorInfoProvider, StartStreamTranscriptionOutput>(options: config.retryStrategyOptions))
         operation.finalizeStep.intercept(position: .before, middleware: ClientRuntime.SignerMiddleware<StartStreamTranscriptionOutput>())