fix(client-lex-runtime-v2): serialize eventstream payload properly

Author: AllanZhengYP

clients/client-lex-runtime-v2/src/protocols/Aws_restJson1.ts

@@ -1040,7 +1040,8 @@ const serializeAws_restJson1AudioInputEvent_event = (input: AudioInputEvent, con
     },
     body: new Uint8Array(),
   };
-  message.body = serializeAws_restJson1AudioInputEvent(input, context);
+  const body = serializeAws_restJson1AudioInputEvent(input, context);
+  message.body = context.utf8Decoder(JSON.stringify(body));
   return message;
 };
 const serializeAws_restJson1ConfigurationEvent_event = (
@@ -1054,7 +1055,8 @@ const serializeAws_restJson1ConfigurationEvent_event = (
     },
     body: new Uint8Array(),
   };
-  message.body = serializeAws_restJson1ConfigurationEvent(input, context);
+  const body = serializeAws_restJson1ConfigurationEvent(input, context);
+  message.body = context.utf8Decoder(JSON.stringify(body));
   return message;
 };
 const serializeAws_restJson1DisconnectionEvent_event = (
@@ -1068,7 +1070,8 @@ const serializeAws_restJson1DisconnectionEvent_event = (
     },
     body: new Uint8Array(),
   };
-  message.body = serializeAws_restJson1DisconnectionEvent(input, context);
+  const body = serializeAws_restJson1DisconnectionEvent(input, context);
+  message.body = context.utf8Decoder(JSON.stringify(body));
   return message;
 };
 const serializeAws_restJson1DTMFInputEvent_event = (input: DTMFInputEvent, context: __SerdeContext): __Message => {
@@ -1079,7 +1082,8 @@ const serializeAws_restJson1DTMFInputEvent_event = (input: DTMFInputEvent, conte
     },
     body: new Uint8Array(),
   };
-  message.body = serializeAws_restJson1DTMFInputEvent(input, context);
+  const body = serializeAws_restJson1DTMFInputEvent(input, context);
+  message.body = context.utf8Decoder(JSON.stringify(body));
   return message;
 };
 const serializeAws_restJson1PlaybackCompletionEvent_event = (
@@ -1093,7 +1097,8 @@ const serializeAws_restJson1PlaybackCompletionEvent_event = (
     },
     body: new Uint8Array(),
   };
-  message.body = serializeAws_restJson1PlaybackCompletionEvent(input, context);
+  const body = serializeAws_restJson1PlaybackCompletionEvent(input, context);
+  message.body = context.utf8Decoder(JSON.stringify(body));
   return message;
 };
 const serializeAws_restJson1TextInputEvent_event = (input: TextInputEvent, context: __SerdeContext): __Message => {
@@ -1104,7 +1109,8 @@ const serializeAws_restJson1TextInputEvent_event = (input: TextInputEvent, conte
     },
     body: new Uint8Array(),
   };
-  message.body = serializeAws_restJson1TextInputEvent(input, context);
+  const body = serializeAws_restJson1TextInputEvent(input, context);
+  message.body = context.utf8Decoder(JSON.stringify(body));
   return message;
 };
 const deserializeAws_restJson1AccessDeniedException_event = async (

codegen/smithy-aws-typescript-codegen/src/main/java/software/amazon/smithy/aws/typescript/codegen/AwsRestXml.java

@@ -20,8 +20,11 @@
 import java.util.List;
 import java.util.Set;
 import software.amazon.smithy.aws.traits.protocols.RestXmlTrait;
+import software.amazon.smithy.codegen.core.CodegenException;
+import software.amazon.smithy.codegen.core.Symbol;
 import software.amazon.smithy.codegen.core.SymbolProvider;
 import software.amazon.smithy.codegen.core.SymbolReference;
+import software.amazon.smithy.model.Model;
 import software.amazon.smithy.model.knowledge.HttpBinding;
 import software.amazon.smithy.model.knowledge.HttpBinding.Location;
 import software.amazon.smithy.model.shapes.MemberShape;
@@ -36,6 +39,7 @@
 import software.amazon.smithy.model.traits.XmlNameTrait;
 import software.amazon.smithy.typescript.codegen.TypeScriptWriter;
 import software.amazon.smithy.typescript.codegen.integration.HttpBindingProtocolGenerator;
+import software.amazon.smithy.typescript.codegen.integration.ProtocolGenerator;
 import software.amazon.smithy.utils.SmithyInternalApi;
 
 
@@ -155,6 +159,26 @@ protected void serializeInputDocumentBody(
         serializeDocumentBody(context, documentBindings);
     }
 
+    @Override
+    protected void serializeInputEventDocumentPayload(
+            GenerationContext context,
+            Shape payloadShape
+    ) {
+        TypeScriptWriter writer = context.getWriter();
+        Model model = context.getModel();
+
+        if (payloadShape instanceof StructureShape || payloadShape instanceof UnionShape) {
+            SymbolProvider symbolProvider = context.getSymbolProvider();
+            Symbol symbol = symbolProvider.toSymbol(payloadShape);
+            String serFunctionName = ProtocolGenerator.getSerFunctionName(symbol, context.getProtocolName());
+            writer.write("const bodyNode = $L(input, context);", serFunctionName);
+            writer.write("message.body = context.utf8Decoder(bodyNode.toString());");
+        } else {
+            throw new CodegenException(String.format("Unexpected shape type bound to document event payload: `%s`",
+                    payloadShape.getType()));
+        }
+    }
+
     @Override
     protected void serializeOutputDocumentBody(
             GenerationContext context,

codegen/smithy-aws-typescript-codegen/src/main/java/software/amazon/smithy/aws/typescript/codegen/RestJsonProtocolGenerator.java

@@ -17,7 +17,10 @@
 
 import java.util.List;
 import java.util.Set;
+import software.amazon.smithy.codegen.core.CodegenException;
 import software.amazon.smithy.codegen.core.SymbolProvider;
+import software.amazon.smithy.codegen.core.Symbol;
+import software.amazon.smithy.model.Model;
 import software.amazon.smithy.model.knowledge.HttpBinding;
 import software.amazon.smithy.model.shapes.DocumentShape;
 import software.amazon.smithy.model.shapes.MemberShape;
@@ -33,6 +36,7 @@
 import software.amazon.smithy.typescript.codegen.integration.DocumentMemberDeserVisitor;
 import software.amazon.smithy.typescript.codegen.integration.DocumentMemberSerVisitor;
 import software.amazon.smithy.typescript.codegen.integration.HttpBindingProtocolGenerator;
+import software.amazon.smithy.typescript.codegen.integration.ProtocolGenerator;
 import software.amazon.smithy.utils.IoUtils;
 import software.amazon.smithy.utils.SmithyInternalApi;
 
@@ -183,6 +187,26 @@ protected void serializeInputPayload(
         serializePayload(context, payloadBinding);
     }
 
+    @Override
+    protected void serializeInputEventDocumentPayload(
+            GenerationContext context,
+            Shape payloadShape
+    ) {
+        TypeScriptWriter writer = context.getWriter();
+        Model model = context.getModel();
+
+        if (payloadShape instanceof StructureShape || payloadShape instanceof UnionShape) {
+            SymbolProvider symbolProvider = context.getSymbolProvider();
+            Symbol symbol = symbolProvider.toSymbol(payloadShape);
+            String serFunctionName = ProtocolGenerator.getSerFunctionName(symbol, context.getProtocolName());
+            writer.write("const body = $L(input, context);", serFunctionName);
+            writer.write("message.body = context.utf8Decoder(JSON.stringify(body));");
+        } else {
+            throw new CodegenException(String.format("Unexpected shape type bound to document event payload: `%s`",
+                    payloadShape.getType()));
+        }
+    }
+
     @Override
     protected void serializeOutputPayload(
             GenerationContext context,