feat: manually update transcribe client

Author: AllanZhengYP

clients/client-transcribe-streaming/TranscribeStreamingClient.ts

@@ -20,14 +20,9 @@ import { getContentLengthPlugin } from "@aws-sdk/middleware-content-length";
 import {
   EventStreamInputConfig,
   EventStreamResolvedConfig,
+  getEventStreamPlugin,
   resolveEventStreamConfig
 } from "@aws-sdk/middleware-eventstream";
-import {
-  WebSocketInputConfig,
-  WebSocketResolvedConfig,
-  resolveWebSocketConfig,
-  getWebSocketPlugin
-} from "@aws-sdk/middleware-sdk-transcribe-streaming";
 import {
   HostHeaderInputConfig,
   HostHeaderResolvedConfig,
@@ -63,8 +58,8 @@ import {
   Credentials as __Credentials,
   Decoder as __Decoder,
   Encoder as __Encoder,
+  EventStreamPayloadHandlerProvider as __EventStreamPayloadHandlerProvider,
   EventStreamSerdeProvider as __EventStreamSerdeProvider,
-  EventStreamPayloadHandlerProvider as __EventStreamPayloadhandlerProvider,
   HashConstructor as __HashConstructor,
   HttpHandlerOptions as __HttpHandlerOptions,
   Provider as __Provider,
@@ -161,12 +156,12 @@ export interface ClientDefaults
   regionInfoProvider?: RegionInfoProvider;
 
   /**
-   * The function that provides necessary utilities for singing event stream
+   * The function that provides necessary utilities for handling request event stream.
    */
-  eventStreamPayloadHandlerProvider?: __EventStreamPayloadhandlerProvider;
+  eventStreamPayloadHandlerProvider?: __EventStreamPayloadHandlerProvider;
 
   /**
-   * The function that provides necessary utilities for generating and signing event stream
+   * The function that provides necessary utilities for generating and parsing event stream
    */
   eventStreamSerdeProvider?: __EventStreamSerdeProvider;
 }
@@ -178,7 +173,6 @@ export type TranscribeStreamingClientConfig = Partial<
   RegionInputConfig &
   EndpointsInputConfig &
   AwsAuthInputConfig &
-  WebSocketInputConfig &
   RetryInputConfig &
   UserAgentInputConfig &
   HostHeaderInputConfig &
@@ -192,7 +186,6 @@ export type TranscribeStreamingClientResolvedConfig = __SmithyResolvedConfigurat
   RegionResolvedConfig &
   EndpointsResolvedConfig &
   AwsAuthResolvedConfig &
-  WebSocketResolvedConfig &
   RetryResolvedConfig &
   UserAgentResolvedConfig &
   HostHeaderResolvedConfig &
@@ -218,8 +211,7 @@ export class TranscribeStreamingClient extends __Client<
     let _config_1 = resolveRegionConfig(_config_0);
     let _config_2 = resolveEndpointsConfig(_config_1);
     let _config_3 = resolveAwsAuthConfig(_config_2);
-    let _config_31 = resolveWebSocketConfig(_config_3);
-    let _config_4 = resolveRetryConfig(_config_31);
+    let _config_4 = resolveRetryConfig(_config_3);
     let _config_5 = resolveUserAgentConfig(_config_4);
     let _config_6 = resolveHostHeaderConfig(_config_5);
     let _config_7 = resolveEventStreamConfig(_config_6);
@@ -231,7 +223,7 @@ export class TranscribeStreamingClient extends __Client<
     this.middlewareStack.use(getUserAgentPlugin(this.config));
     this.middlewareStack.use(getContentLengthPlugin(this.config));
     this.middlewareStack.use(getHostHeaderPlugin(this.config));
-    this.middlewareStack.use(getWebSocketPlugin(this.config));
+    this.middlewareStack.use(getEventStreamPlugin(this.config));
   }
 
   destroy(): void {

clients/client-transcribe-streaming/commands/StartStreamTranscriptionCommand.ts

@@ -12,7 +12,6 @@ import {
   serializeAws_restJson1_1StartStreamTranscriptionCommand
 } from "../protocols/Aws_restJson1_1";
 import { getSerdePlugin } from "@aws-sdk/middleware-serde";
-import { getEventStreamPlugin } from "@aws-sdk/middleware-eventstream";
 import {
   HttpRequest as __HttpRequest,
   HttpResponse as __HttpResponse
@@ -58,7 +57,6 @@ export class StartStreamTranscriptionCommand extends $Command<
     this.middlewareStack.use(
       getSerdePlugin(configuration, this.serialize, this.deserialize)
     );
-    this.middlewareStack.use(getEventStreamPlugin(configuration));
 
     const stack = clientStack.concat(this.middlewareStack);
 

clients/client-transcribe-streaming/package.json

@@ -32,13 +32,15 @@
     "@aws-crypto/sha256-js": "^1.0.0-alpha.0",
     "@aws-sdk/config-resolver": "1.0.0-beta.4",
     "@aws-sdk/credential-provider-node": "1.0.0-beta.4",
+    "@aws-sdk/eventstream-handler-node": "1.0.0-beta.0",
     "@aws-sdk/eventstream-serde-browser": "1.0.0-beta.4",
     "@aws-sdk/eventstream-serde-config-resolver": "1.0.0-beta.4",
     "@aws-sdk/eventstream-serde-node": "1.0.0-beta.4",
     "@aws-sdk/fetch-http-handler": "1.0.0-beta.4",
     "@aws-sdk/hash-node": "1.0.0-beta.4",
     "@aws-sdk/invalid-dependency": "1.0.0-beta.2",
     "@aws-sdk/middleware-content-length": "1.0.0-beta.4",
+    "@aws-sdk/middleware-eventstream": "1.0.0-beta.0",
     "@aws-sdk/middleware-host-header": "1.0.0-beta.4",
     "@aws-sdk/middleware-retry": "1.0.0-beta.4",
     "@aws-sdk/middleware-serde": "1.0.0-beta.4",

clients/client-transcribe-streaming/protocols/Aws_restJson1_1.ts

@@ -60,10 +60,6 @@ export const serializeAws_restJson1_1StartStreamTranscriptionCommand = async (
       serializeAws_restJson1_1AudioStream_event(event, context)
     );
   }
-  if (body === undefined) {
-    body = {};
-  }
-  body = JSON.stringify(body);
   const { hostname, protocol = "https", port } = await context.endpoint();
   return new __HttpRequest({
     protocol,

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

@@ -20,6 +20,9 @@ export const ClientDefaultValues: Required<ClientDefaults> = {
   bodyLengthChecker: calculateBodyLength,
   credentialDefaultProvider: invalidFunction("Credential is missing") as any,
   defaultUserAgent: defaultUserAgent(name, version),
+  eventStreamPayloadHandlerProvider: () => ({
+    handle: invalidFunction("event stream request is not supported in browser.")
+  }),
   eventStreamSerdeProvider,
   regionDefaultProvider: invalidFunction("Region is missing") as any,
   requestHandler: new FetchHttpHandler(),

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

@@ -11,6 +11,11 @@ export const ClientDefaultValues: Required<ClientDefaults> = {
   ...BrowserDefaults,
   runtime: "react-native",
   defaultUserAgent: `aws-sdk-js-v3-react-native-${name}/${version}`,
+  eventStreamPayloadHandlerProvider: () => ({
+    handle: invalidFunction(
+      "event stream request is not supported in ReactNative."
+    )
+  }),
   eventStreamSerdeProvider: () => ({
     serialize: invalidFunction("event stream is not supported in ReactNative."),
     deserialize: invalidFunction(

clients/client-transcribe-streaming/runtimeConfig.ts

@@ -1,7 +1,7 @@
 import { name, version } from "./package.json";
 import { defaultProvider as credentialDefaultProvider } from "@aws-sdk/credential-provider-node";
-import { eventStreamSerdeProvider } from "@aws-sdk/eventstream-serde-node";
 import { eventStreamPayloadHandlerProvider } from "@aws-sdk/eventstream-handler-node";
+import { eventStreamSerdeProvider } from "@aws-sdk/eventstream-serde-node";
 import { Hash } from "@aws-sdk/hash-node";
 import { NodeHttp2Handler } from "@aws-sdk/node-http-handler";
 import { defaultProvider as regionDefaultProvider } from "@aws-sdk/region-provider";
@@ -22,8 +22,8 @@ export const ClientDefaultValues: Required<ClientDefaults> = {
   bodyLengthChecker: calculateBodyLength,
   credentialDefaultProvider,
   defaultUserAgent: defaultUserAgent(name, version),
-  eventStreamSerdeProvider,
   eventStreamPayloadHandlerProvider,
+  eventStreamSerdeProvider,
   regionDefaultProvider,
   requestHandler: new NodeHttp2Handler(),
   sha256: Hash.bind(null, "sha256"),