fix(clients): create new session for every H2 requests

Author: AllanZhengYP

clients/client-kinesis/src/runtimeConfig.ts

@@ -53,7 +53,9 @@ export const getRuntimeConfig = (config: KinesisClientConfig) => {
     eventStreamSerdeProvider: config?.eventStreamSerdeProvider ?? eventStreamSerdeProvider,
     maxAttempts: config?.maxAttempts ?? loadNodeConfig(NODE_MAX_ATTEMPT_CONFIG_OPTIONS),
     region: config?.region ?? loadNodeConfig(NODE_REGION_CONFIG_OPTIONS, NODE_REGION_CONFIG_FILE_OPTIONS),
-    requestHandler: config?.requestHandler ?? new RequestHandler(defaultConfigProvider),
+    requestHandler:
+      config?.requestHandler ??
+      new RequestHandler(async () => ({ ...(await defaultConfigProvider()), disableConcurrentStreams: true })),
     retryMode:
       config?.retryMode ??
       loadNodeConfig({

clients/client-lex-runtime-v2/src/runtimeConfig.ts

@@ -55,7 +55,9 @@ export const getRuntimeConfig = (config: LexRuntimeV2ClientConfig) => {
     eventStreamSerdeProvider: config?.eventStreamSerdeProvider ?? eventStreamSerdeProvider,
     maxAttempts: config?.maxAttempts ?? loadNodeConfig(NODE_MAX_ATTEMPT_CONFIG_OPTIONS),
     region: config?.region ?? loadNodeConfig(NODE_REGION_CONFIG_OPTIONS, NODE_REGION_CONFIG_FILE_OPTIONS),
-    requestHandler: config?.requestHandler ?? new RequestHandler(defaultConfigProvider),
+    requestHandler:
+      config?.requestHandler ??
+      new RequestHandler(async () => ({ ...(await defaultConfigProvider()), disableConcurrentStreams: true })),
     retryMode:
       config?.retryMode ??
       loadNodeConfig({

clients/client-transcribe-streaming/src/runtimeConfig.ts

@@ -19,7 +19,7 @@ import {
   NODE_RETRY_MODE_CONFIG_OPTIONS,
 } from "@aws-sdk/middleware-retry";
 import { loadConfig as loadNodeConfig } from "@aws-sdk/node-config-provider";
-import { NodeHttp2Handler, streamCollector } from "@aws-sdk/node-http-handler";
+import { NodeHttp2Handler as RequestHandler, streamCollector } from "@aws-sdk/node-http-handler";
 import { fromBase64, toBase64 } from "@aws-sdk/util-base64-node";
 import { calculateBodyLength } from "@aws-sdk/util-body-length-node";
 import { defaultUserAgent } from "@aws-sdk/util-user-agent-node";
@@ -55,7 +55,9 @@ export const getRuntimeConfig = (config: TranscribeStreamingClientConfig) => {
     eventStreamSerdeProvider: config?.eventStreamSerdeProvider ?? eventStreamSerdeProvider,
     maxAttempts: config?.maxAttempts ?? loadNodeConfig(NODE_MAX_ATTEMPT_CONFIG_OPTIONS),
     region: config?.region ?? loadNodeConfig(NODE_REGION_CONFIG_OPTIONS, NODE_REGION_CONFIG_FILE_OPTIONS),
-    requestHandler: config?.requestHandler ?? new NodeHttp2Handler({ disableConcurrentStreams: true }),
+    requestHandler:
+      config?.requestHandler ??
+      new RequestHandler(async () => ({ ...(await defaultConfigProvider()), disableConcurrentStreams: true })),
     retryMode:
       config?.retryMode ??
       loadNodeConfig({

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

@@ -49,7 +49,11 @@ public Map<String, Consumer<TypeScriptWriter>> getRuntimeConfigWriters(
                     writer.addDependency(TypeScriptDependency.AWS_SDK_NODE_HTTP_HANDLER);
                     writer.addImport("NodeHttp2Handler", "RequestHandler",
                             TypeScriptDependency.AWS_SDK_NODE_HTTP_HANDLER.packageName);
-                    writer.write("new RequestHandler(defaultConfigProvider)");
+                    writer.openBlock("new RequestHandler(async () => ({", "}))", () -> {
+                        writer.write("...await defaultConfigProvider(),");
+                        // TODO: remove this when root cause of #3809 is found
+                        writer.write("disableConcurrentStreams: true");
+                    });
                 });
             default:
                 return Collections.emptyMap();

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

@@ -77,14 +77,6 @@ public Map<String, Consumer<TypeScriptWriter>> getRuntimeConfigWriters(
                 });
 
         switch (target) {
-            case NODE:
-                return MapUtils.of(
-                    "requestHandler", writer -> {
-                        writer.addDependency(TypeScriptDependency.AWS_SDK_NODE_HTTP_HANDLER);
-                        writer.addImport("NodeHttp2Handler", "NodeHttp2Handler",
-                            TypeScriptDependency.AWS_SDK_NODE_HTTP_HANDLER.packageName);
-                         writer.write("new NodeHttp2Handler({ disableConcurrentStreams: true })");
-                    });
             case REACT_NATIVE:
             case BROWSER:
                 return transcribeStreamingHandlerConfig;