chore: add codegen for eventstream handler

Author: AllanZhengYP

codegen/smithy-aws-typescript-codegen/src/main/java/software/amazon/smithy/aws/typescript/codegen/AddEventStreamSigningDependency.java renamed to codegen/smithy-aws-typescript-codegen/src/main/java/software/amazon/smithy/aws/typescript/codegen/AddEventStreamHandlingDependency.java

@@ -21,14 +21,18 @@
 import software.amazon.smithy.utils.ListUtils;
 import software.amazon.smithy.utils.MapUtils;
 
-public class AddEventStreamSigningDependency implements TypeScriptIntegration {
+/**
+ * Adds runtime client plugins that handle the eventstream flow in request,
+ * including eventstream payload signing.
+ */
+public class AddEventStreamHandlingDependency implements TypeScriptIntegration {
     @Override
     public List<RuntimeClientPlugin> getClientPlugins() {
         return ListUtils.of(
                 RuntimeClientPlugin.builder()
-                        .withConventions(AwsDependency.MIDDLEWARE_EVENTSTREAM_SIGNING.dependency,
+                        .withConventions(AwsDependency.MIDDLEWARE_EVENTSTREAM.dependency,
                                 "EventStream")
-                        .servicePredicate(AddEventStreamSigningDependency::hasEventStreamInput)
+                        .servicePredicate(AddEventStreamHandlingDependency::hasEventStreamInput)
                         .build()
         );
     }
@@ -41,10 +45,10 @@ public void addConfigInterfaceFields(
             TypeScriptWriter writer
     ) {
         if (hasEventStreamInput(model, settings.getService(model))) {
-            writer.addImport("EventStreamSignerProvider", "__EventStreamSignerProvider",
+            writer.addImport("EventStreamPayloadHandlerProvider", "__EventStreamPayloadHandlerProvider",
                     TypeScriptDependency.AWS_SDK_TYPES.packageName);
-            writer.writeDocs("The function that provides necessary utilities for singing event stream");
-            writer.write("eventStreamSignerProvider?: __EventStreamSignerProvider;\n");
+            writer.writeDocs("The function that provides necessary utilities for handling request event stream.");
+            writer.write("eventStreamPayloadHandlerProvider?: __EventStreamPayloadHandlerProvider;\n");
         }
     }
 
@@ -62,25 +66,24 @@ public Map<String, Consumer<TypeScriptWriter>> getRuntimeConfigWriters(
 
         switch (target) {
             case NODE:
-                return MapUtils.of("eventStreamSignerProvider", writer -> {
-                    writer.addDependency(AwsDependency.AWS_SDK_EVENTSTREAM_SIGNER_NODE);
-                    writer.addImport("eventStreamSignerProvider", "eventStreamSignerProvider",
-                            AwsDependency.AWS_SDK_EVENTSTREAM_SIGNER_NODE.packageName);
-                    writer.write("eventStreamSignerProvider,");
+                return MapUtils.of("eventStreamPayloadHandlerProvider", writer -> {
+                    writer.addDependency(AwsDependency.AWS_SDK_EVENTSTREAM_HANDLER_NODE);
+                    writer.addImport("eventStreamPayloadHandlerProvider", "eventStreamPayloadHandlerProvider",
+                            AwsDependency.AWS_SDK_EVENTSTREAM_HANDLER_NODE.packageName);
+                    writer.write("eventStreamPayloadHandlerProvider,");
                 });
             case BROWSER:
                 /**
                  * Browser doesn't support streaming requests as of March 2020.
-                 * Here we don't supply invalidFunction. Each service client needs to support eventstream request
-                 * in browsers has to implement a customization providing its own eventStreamSignerProvider
-                 * TODO: update this when WebSocket event stream support lands
+                 * Each service client needs to support eventstream request in browser individually.
+                 * Services like TranscribeStreaming support it via WebSocket.
                  */
-                return MapUtils.of("eventStreamSignerProvider", writer -> {
+                return MapUtils.of("eventStreamPayloadHandlerProvider", writer -> {
                     writer.addDependency(TypeScriptDependency.INVALID_DEPENDENCY);
                     writer.addImport("invalidFunction", "invalidFunction",
                             TypeScriptDependency.INVALID_DEPENDENCY.packageName);
-                    writer.openBlock("eventStreamSignerProvider: () => ({", "}),", () -> {
-                        writer.write("sign: invalidFunction(\"event stream request is not supported in browser.\"),");
+                    writer.openBlock("eventStreamPayloadHandlerProvider: () => ({", "}),", () -> {
+                        writer.write("handle: invalidFunction(\"event stream request is not supported in browser.\"),");
                     });
                 });
             case REACT_NATIVE:
@@ -89,12 +92,12 @@ public Map<String, Consumer<TypeScriptWriter>> getRuntimeConfigWriters(
                  * Here we don't supply invalidFunction. Each service client needs to support eventstream request
                  * in RN has to implement a customization providing its own eventStreamSignerProvider
                  */
-                return MapUtils.of("eventStreamSignerProvider", writer -> {
+                return MapUtils.of("eventStreamPayloadHandlerProvider", writer -> {
                     writer.addDependency(TypeScriptDependency.INVALID_DEPENDENCY);
                     writer.addImport("invalidFunction", "invalidFunction",
                             TypeScriptDependency.INVALID_DEPENDENCY.packageName);
-                    writer.openBlock("eventStreamSignerProvider: () => ({", "}),", () -> {
-                        writer.write("sign: invalidFunction(\"event stream request is not supported in ReactNative.\"),");
+                    writer.openBlock("eventStreamPayloadHandlerProvider: () => ({", "}),", () -> {
+                        writer.write("handle: invalidFunction(\"event stream request is not supported in ReactNative.\"),");
                     });
                 });
             default:

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

@@ -56,8 +56,9 @@ public enum AwsDependency implements SymbolDependencyContainer {
     XML_PARSER(NORMAL_DEPENDENCY, "fast-xml-parser", "^3.16.0"),
     UUID_GENERATOR(NORMAL_DEPENDENCY, "uuid", "^7.0.0"),
     UUID_GENERATOR_TYPES(DEV_DEPENDENCY, "@types/uuid", "^7.0.0"),
-    MIDDLEWARE_EVENTSTREAM_SIGNING(NORMAL_DEPENDENCY, "@aws-sdk/middleware-eventstream-signing", "^1.0.0-beta.0"),
-    AWS_SDK_EVENTSTREAM_SIGNER_NODE(NORMAL_DEPENDENCY, "@aws-sdk/eventstream-signer-node", "^1.0.0-beta.0");
+    MIDDLEWARE_EVENTSTREAM(NORMAL_DEPENDENCY, "@aws-sdk/middleware-eventstream", "^1.0.0-beta.0"),
+    AWS_SDK_EVENTSTREAM_HANDLER_NODE(NORMAL_DEPENDENCY, "@aws-sdk/eventstream-handler-node", "^1.0.0-beta.0"),
+    TRANSCRIBESTREAMING_MIDDLEWARE(NORMAL_DEPENDENCY, "@aws-sdk/eventstream-handler", "^1.0.0-beta.0");
 
     public final String packageName;
     public final String version;

codegen/smithy-aws-typescript-codegen/src/main/resources/META-INF/services/software.amazon.smithy.typescript.codegen.integration.TypeScriptIntegration

@@ -8,5 +8,5 @@ software.amazon.smithy.aws.typescript.codegen.AddMd5HashDependency
 software.amazon.smithy.aws.typescript.codegen.AddStreamHasherDependency
 software.amazon.smithy.aws.typescript.codegen.AddBodyChecksumGeneratorDependency
 software.amazon.smithy.aws.typescript.codegen.AddS3Config
-software.amazon.smithy.aws.typescript.codegen.AddEventStreamSigningDependency
+software.amazon.smithy.aws.typescript.codegen.AddEventStreamHandlingDependency
 software.amazon.smithy.aws.typescript.codegen.AddHttp2Dependency