fix: event stream serialization (#1674)

Author: kuhe

smithy-typescript-codegen/src/main/java/software/amazon/smithy/typescript/codegen/integration/EventStreamGenerator.java

@@ -387,7 +387,7 @@ private void writeEventBody(
                     writer.write("body = input.$L;", payloadMemberName);
                 } else if (payloadShape instanceof StringShape) {
                     writer.write("body = context.utf8Decoder(input.$L);", payloadMemberName);
-                } else if (payloadShape instanceof BlobShape || payloadShape instanceof StringShape) {
+                } else if (payloadShape instanceof StructureShape || payloadShape instanceof UnionShape) {
                     Symbol symbol = getSymbol(context, payloadShape);
                     String serFunctionName = ProtocolGenerator.getSerFunctionShortName(symbol);
                     boolean mayElide = serdeElisionIndex.mayElide(payloadShape);

smithy-typescript-codegen/src/main/java/software/amazon/smithy/typescript/codegen/integration/HttpRpcProtocolGenerator.java

@@ -34,6 +34,7 @@
 import software.amazon.smithy.typescript.codegen.TypeScriptWriter;
 import software.amazon.smithy.typescript.codegen.knowledge.SerdeElisionIndex;
 import software.amazon.smithy.utils.OptionalUtils;
+import software.amazon.smithy.utils.SmithyInternalApi;
 import software.amazon.smithy.utils.SmithyUnstableApi;
 
 /**
@@ -107,7 +108,7 @@ public void generateSharedComponents(GenerationContext context) {
             getDocumentContentType(),
             () -> {
                 TypeScriptWriter writer = context.getWriter();
-                writer.write("body = context.utf8Decoder(body);");
+                serializeEventStreamBodyToBytes(writer);
             },
             serializingDocumentShapes
         );
@@ -606,6 +607,17 @@ protected String getErrorBodyLocation(GenerationContext context, String outputLo
         return outputLocation;
     }
 
+    /**
+     * Allows RPC protocols to designate how to convert the body into bytes.
+     *
+     * @deprecated superseded by schema-serde.
+     */
+    @Deprecated
+    @SmithyInternalApi
+    protected void serializeEventStreamBodyToBytes(TypeScriptWriter writer) {
+        writer.write("body = context.utf8Decoder(JSON.stringify(body));");
+    }
+
     /**
      * Writes the code needed to deserialize the output document of a response.
      *

smithy-typescript-codegen/src/main/java/software/amazon/smithy/typescript/codegen/protocols/cbor/SmithyRpcV2Cbor.java

@@ -67,7 +67,11 @@ public void generateSharedComponents(GenerationContext context) {
             service,
             getDocumentContentType(),
             () -> {
-                writer.write("body = context.utf8Decoder(body);");
+                writer.addImportSubmodule(
+                    "cbor", null,
+                    TypeScriptDependency.SMITHY_CORE, SmithyCoreSubmodules.CBOR
+                );
+                writer.write("body = cbor.encode(body);");
             },
             serializingDocumentShapes
         );