chore(codegen): temp generate clients/client-transcribe-streaming

aws · Nov 22, 2023 · 3632d25 · 3632d25
1 parent d248841
commit 3632d25
Show file tree

Hide file tree

Showing 8 changed files with 55 additions and 14 deletions.
diff --git a/clients/client-transcribe-streaming/package.json b/clients/client-transcribe-streaming/package.json
@@ -25,6 +25,8 @@
     "@aws-sdk/client-sts": "*",
     "@aws-sdk/core": "*",
     "@aws-sdk/credential-provider-node": "*",
+    "@aws-sdk/eventstream-handler-node": "*",
+    "@aws-sdk/middleware-eventstream": "*",
     "@aws-sdk/middleware-host-header": "*",
     "@aws-sdk/middleware-logger": "*",
     "@aws-sdk/middleware-recursion-detection": "*",

diff --git a/clients/client-transcribe-streaming/src/TranscribeStreamingClient.ts b/clients/client-transcribe-streaming/src/TranscribeStreamingClient.ts
@@ -1,4 +1,9 @@
 // smithy-typescript generated code
+import {
+  EventStreamInputConfig,
+  EventStreamResolvedConfig,
+  resolveEventStreamConfig,
+} from "@aws-sdk/middleware-eventstream";
 import {
   getHostHeaderPlugin,
   HostHeaderInputConfig,
@@ -15,6 +20,7 @@ import {
   UserAgentResolvedConfig,
 } from "@aws-sdk/middleware-user-agent";
 import { resolveWebSocketConfig, WebSocketInputConfig, WebSocketResolvedConfig } from "@aws-sdk/middleware-websocket";
+import { EventStreamPayloadHandlerProvider as __EventStreamPayloadHandlerProvider } from "@aws-sdk/types";
 import { RegionInputConfig, RegionResolvedConfig, resolveRegionConfig } from "@smithy/config-resolver";
 import {
   DefaultIdentityProviderConfig,
@@ -235,6 +241,12 @@ export interface ClientDefaults extends Partial<__SmithyResolvedConfiguration<__
    * The {@link @smithy/smithy-client#DefaultsMode} that will be used to determine how certain default configuration options are resolved in the SDK.
    */
   defaultsMode?: __DefaultsMode | __Provider<__DefaultsMode>;
+
+  /**
+   * The function that provides necessary utilities for handling request event stream.
+   * @internal
+   */
+  eventStreamPayloadHandlerProvider?: __EventStreamPayloadHandlerProvider;
 }
 
 /**
@@ -246,10 +258,11 @@ export type TranscribeStreamingClientConfigType = Partial<__SmithyConfiguration<
   EndpointInputConfig<EndpointParameters> &
   RetryInputConfig &
   HostHeaderInputConfig &
-  WebSocketInputConfig &
   UserAgentInputConfig &
   EventStreamSerdeInputConfig &
   HttpAuthSchemeInputConfig &
+  EventStreamInputConfig &
+  WebSocketInputConfig &
   ClientInputEndpointParameters;
 /**
  * @public
@@ -268,10 +281,11 @@ export type TranscribeStreamingClientResolvedConfigType = __SmithyResolvedConfig
   EndpointResolvedConfig<EndpointParameters> &
   RetryResolvedConfig &
   HostHeaderResolvedConfig &
-  WebSocketResolvedConfig &
   UserAgentResolvedConfig &
   EventStreamSerdeResolvedConfig &
   HttpAuthSchemeResolvedConfig &
+  EventStreamResolvedConfig &
+  WebSocketResolvedConfig &
   ClientResolvedEndpointParameters;
 /**
  * @public
@@ -335,13 +349,14 @@ export class TranscribeStreamingClient extends __Client<
     const _config_3 = resolveEndpointConfig(_config_2);
     const _config_4 = resolveRetryConfig(_config_3);
     const _config_5 = resolveHostHeaderConfig(_config_4);
-    const _config_6 = resolveWebSocketConfig(_config_5);
-    const _config_7 = resolveUserAgentConfig(_config_6);
-    const _config_8 = resolveEventStreamSerdeConfig(_config_7);
-    const _config_9 = resolveHttpAuthSchemeConfig(_config_8);
-    const _config_10 = resolveRuntimeExtensions(_config_9, configuration?.extensions || []);
-    super(_config_10);
-    this.config = _config_10;
+    const _config_6 = resolveUserAgentConfig(_config_5);
+    const _config_7 = resolveEventStreamSerdeConfig(_config_6);
+    const _config_8 = resolveHttpAuthSchemeConfig(_config_7);
+    const _config_9 = resolveEventStreamConfig(_config_8);
+    const _config_10 = resolveWebSocketConfig(_config_9);
+    const _config_11 = resolveRuntimeExtensions(_config_10, configuration?.extensions || []);
+    super(_config_11);
+    this.config = _config_11;
     this.middlewareStack.use(getRetryPlugin(this.config));
     this.middlewareStack.use(getContentLengthPlugin(this.config));
     this.middlewareStack.use(getHostHeaderPlugin(this.config));

diff --git a/.../client-transcribe-streaming/src/commands/StartCallAnalyticsStreamTranscriptionCommand.ts b/.../client-transcribe-streaming/src/commands/StartCallAnalyticsStreamTranscriptionCommand.ts
@@ -1,4 +1,5 @@
 // smithy-typescript generated code
+import { getEventStreamPlugin } from "@aws-sdk/middleware-eventstream";
 import { getWebSocketPlugin } from "@aws-sdk/middleware-websocket";
 import { EndpointParameterInstructions, getEndpointPlugin } from "@smithy/middleware-endpoint";
 import { getSerdePlugin } from "@smithy/middleware-serde";
@@ -270,6 +271,7 @@ export class StartCallAnalyticsStreamTranscriptionCommand extends $Command<
     this.middlewareStack.use(
       getEndpointPlugin(configuration, StartCallAnalyticsStreamTranscriptionCommand.getEndpointParameterInstructions())
     );
+    this.middlewareStack.use(getEventStreamPlugin(configuration));
     this.middlewareStack.use(getWebSocketPlugin(configuration, { headerPrefix: "x-amzn-transcribe-" }));
 
     const stack = clientStack.concat(this.middlewareStack);
@@ -286,6 +288,10 @@ export class StartCallAnalyticsStreamTranscriptionCommand extends $Command<
       [SMITHY_CONTEXT_KEY]: {
         service: "Transcribe",
         operation: "StartCallAnalyticsStreamTranscription",
+        /**
+         * @internal
+         */
+        isEventStreaming: true,
       },
     };
     const { requestHandler } = configuration;

diff --git a/clients/client-transcribe-streaming/src/commands/StartMedicalStreamTranscriptionCommand.ts b/clients/client-transcribe-streaming/src/commands/StartMedicalStreamTranscriptionCommand.ts
@@ -1,4 +1,5 @@
 // smithy-typescript generated code
+import { getEventStreamPlugin } from "@aws-sdk/middleware-eventstream";
 import { getWebSocketPlugin } from "@aws-sdk/middleware-websocket";
 import { EndpointParameterInstructions, getEndpointPlugin } from "@smithy/middleware-endpoint";
 import { getSerdePlugin } from "@smithy/middleware-serde";
@@ -251,6 +252,7 @@ export class StartMedicalStreamTranscriptionCommand extends $Command<
     this.middlewareStack.use(
       getEndpointPlugin(configuration, StartMedicalStreamTranscriptionCommand.getEndpointParameterInstructions())
     );
+    this.middlewareStack.use(getEventStreamPlugin(configuration));
     this.middlewareStack.use(getWebSocketPlugin(configuration, { headerPrefix: "x-amzn-transcribe-" }));
 
     const stack = clientStack.concat(this.middlewareStack);
@@ -267,6 +269,10 @@ export class StartMedicalStreamTranscriptionCommand extends $Command<
       [SMITHY_CONTEXT_KEY]: {
         service: "Transcribe",
         operation: "StartMedicalStreamTranscription",
+        /**
+         * @internal
+         */
+        isEventStreaming: true,
       },
     };
     const { requestHandler } = configuration;

diff --git a/clients/client-transcribe-streaming/src/commands/StartStreamTranscriptionCommand.ts b/clients/client-transcribe-streaming/src/commands/StartStreamTranscriptionCommand.ts
@@ -1,4 +1,5 @@
 // smithy-typescript generated code
+import { getEventStreamPlugin } from "@aws-sdk/middleware-eventstream";
 import { getWebSocketPlugin } from "@aws-sdk/middleware-websocket";
 import { EndpointParameterInstructions, getEndpointPlugin } from "@smithy/middleware-endpoint";
 import { getSerdePlugin } from "@smithy/middleware-serde";
@@ -275,6 +276,7 @@ export class StartStreamTranscriptionCommand extends $Command<
     this.middlewareStack.use(
       getEndpointPlugin(configuration, StartStreamTranscriptionCommand.getEndpointParameterInstructions())
     );
+    this.middlewareStack.use(getEventStreamPlugin(configuration));
     this.middlewareStack.use(getWebSocketPlugin(configuration, { headerPrefix: "x-amzn-transcribe-" }));
 
     const stack = clientStack.concat(this.middlewareStack);
@@ -291,6 +293,10 @@ export class StartStreamTranscriptionCommand extends $Command<
       [SMITHY_CONTEXT_KEY]: {
         service: "Transcribe",
         operation: "StartStreamTranscription",
+        /**
+         * @internal
+         */
+        isEventStreaming: true,
       },
     };
     const { requestHandler } = configuration;

diff --git a/clients/client-transcribe-streaming/src/runtimeConfig.browser.ts b/clients/client-transcribe-streaming/src/runtimeConfig.browser.ts
@@ -3,8 +3,10 @@
 import packageInfo from "../package.json"; // eslint-disable-line
 
 import { Sha256 } from "@aws-crypto/sha256-browser";
-import { eventStreamPayloadHandler } from "@aws-sdk/middleware-sdk-transcribe-streaming";
-import { WebSocketFetchHandler as WebSocketRequestHandler } from "@aws-sdk/middleware-websocket";
+import {
+  WebSocketFetchHandler as WebSocketRequestHandler,
+  eventStreamPayloadHandlerProvider,
+} from "@aws-sdk/middleware-websocket";
 import { defaultUserAgent } from "@aws-sdk/util-user-agent-browser";
 import { DEFAULT_USE_DUALSTACK_ENDPOINT, DEFAULT_USE_FIPS_ENDPOINT } from "@smithy/config-resolver";
 import { eventStreamSerdeProvider } from "@smithy/eventstream-serde-browser";
@@ -35,7 +37,7 @@ export const getRuntimeConfig = (config: TranscribeStreamingClientConfig) => {
     defaultUserAgentProvider:
       config?.defaultUserAgentProvider ??
       defaultUserAgent({ serviceId: clientSharedValues.serviceId, clientVersion: packageInfo.version }),
-    eventStreamPayloadHandlerProvider: config?.eventStreamPayloadHandlerProvider ?? (() => eventStreamPayloadHandler),
+    eventStreamPayloadHandlerProvider: config?.eventStreamPayloadHandlerProvider ?? eventStreamPayloadHandlerProvider,
     eventStreamSerdeProvider: config?.eventStreamSerdeProvider ?? eventStreamSerdeProvider,
     maxAttempts: config?.maxAttempts ?? DEFAULT_MAX_ATTEMPTS,
     region: config?.region ?? invalidProvider("Region is missing"),

diff --git a/clients/client-transcribe-streaming/src/runtimeConfig.native.ts b/clients/client-transcribe-streaming/src/runtimeConfig.native.ts
@@ -1,6 +1,6 @@
 // smithy-typescript generated code
 import { Sha256 } from "@aws-crypto/sha256-js";
-import { eventStreamPayloadHandler } from "@aws-sdk/middleware-sdk-transcribe-streaming";
+import { invalidFunction } from "@smithy/invalid-dependency";
 
 import { getRuntimeConfig as getBrowserRuntimeConfig } from "./runtimeConfig.browser";
 import { TranscribeStreamingClientConfig } from "./TranscribeStreamingClient";
@@ -14,7 +14,9 @@ export const getRuntimeConfig = (config: TranscribeStreamingClientConfig) => {
     ...browserDefaults,
     ...config,
     runtime: "react-native",
-    eventStreamPayloadHandlerProvider: config?.eventStreamPayloadHandlerProvider ?? (() => eventStreamPayloadHandler),
+    eventStreamPayloadHandlerProvider:
+      config?.eventStreamPayloadHandlerProvider ??
+      (() => ({ handle: invalidFunction("event stream request is not supported in ReactNative.") })),
     sha256: config?.sha256 ?? Sha256,
   };
 };
diff --git a/clients/client-transcribe-streaming/src/runtimeConfig.ts b/clients/client-transcribe-streaming/src/runtimeConfig.ts
@@ -5,6 +5,7 @@ import packageInfo from "../package.json"; // eslint-disable-line
 import { decorateDefaultCredentialProvider } from "@aws-sdk/client-sts";
 import { emitWarningIfUnsupportedVersion as awsCheckVersion } from "@aws-sdk/core";
 import { defaultProvider as credentialDefaultProvider } from "@aws-sdk/credential-provider-node";
+import { eventStreamPayloadHandlerProvider } from "@aws-sdk/eventstream-handler-node";
 import { defaultUserAgent } from "@aws-sdk/util-user-agent-node";
 import {
   NODE_REGION_CONFIG_FILE_OPTIONS,
@@ -45,6 +46,7 @@ export const getRuntimeConfig = (config: TranscribeStreamingClientConfig) => {
     defaultUserAgentProvider:
       config?.defaultUserAgentProvider ??
       defaultUserAgent({ serviceId: clientSharedValues.serviceId, clientVersion: packageInfo.version }),
+    eventStreamPayloadHandlerProvider: config?.eventStreamPayloadHandlerProvider ?? eventStreamPayloadHandlerProvider,
     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),