fix(client-transcribe-streaming): add plugin only for operations with streaming trait

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

@@ -12,7 +12,6 @@ import {
 } from "@aws-sdk/middleware-host-header";
 import { getLoggerPlugin } from "@aws-sdk/middleware-logger";
 import { getRecursionDetectionPlugin } from "@aws-sdk/middleware-recursion-detection";
-import { getTranscribeStreamingPlugin } from "@aws-sdk/middleware-sdk-transcribe-streaming";
 import {
  getUserAgentPlugin,
  resolveUserAgentConfig,
@@ -361,7 +360,6 @@ export class TranscribeStreamingClient extends __Client<
  }),
  })
  );
- this.middlewareStack.use(getTranscribeStreamingPlugin(this.config));
  this.middlewareStack.use(getHttpSigningPlugin(this.config));
  }
 

clients/client-transcribe-streaming/src/commands/StartCallAnalyticsStreamTranscriptionCommand.ts

@@ -1,5 +1,6 @@
 // smithy-typescript generated code
 import { getEventStreamPlugin } from "@aws-sdk/middleware-eventstream";
+import { getTranscribeStreamingPlugin } from "@aws-sdk/middleware-sdk-transcribe-streaming";
 import { getWebSocketPlugin } from "@aws-sdk/middleware-websocket";
 import { getEndpointPlugin } from "@smithy/middleware-endpoint";
 import { getSerdePlugin } from "@smithy/middleware-serde";
@@ -248,6 +249,7 @@ export class StartCallAnalyticsStreamTranscriptionCommand extends $Command
  getWebSocketPlugin(config, {
  headerPrefix: "x-amzn-transcribe-",
  }),
+ getTranscribeStreamingPlugin(config),
  ];
  })
  .s("Transcribe", "StartCallAnalyticsStreamTranscription", {

clients/client-transcribe-streaming/src/commands/StartMedicalStreamTranscriptionCommand.ts

@@ -1,5 +1,6 @@
 // smithy-typescript generated code
 import { getEventStreamPlugin } from "@aws-sdk/middleware-eventstream";
+import { getTranscribeStreamingPlugin } from "@aws-sdk/middleware-sdk-transcribe-streaming";
 import { getWebSocketPlugin } from "@aws-sdk/middleware-websocket";
 import { getEndpointPlugin } from "@smithy/middleware-endpoint";
 import { getSerdePlugin } from "@smithy/middleware-serde";
@@ -229,6 +230,7 @@ export class StartMedicalStreamTranscriptionCommand extends $Command
  getWebSocketPlugin(config, {
  headerPrefix: "x-amzn-transcribe-",
  }),
+ getTranscribeStreamingPlugin(config),
  ];
  })
  .s("Transcribe", "StartMedicalStreamTranscription", {

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

@@ -1,5 +1,6 @@
 // smithy-typescript generated code
 import { getEventStreamPlugin } from "@aws-sdk/middleware-eventstream";
+import { getTranscribeStreamingPlugin } from "@aws-sdk/middleware-sdk-transcribe-streaming";
 import { getWebSocketPlugin } from "@aws-sdk/middleware-websocket";
 import { getEndpointPlugin } from "@smithy/middleware-endpoint";
 import { getSerdePlugin } from "@smithy/middleware-serde";
@@ -253,6 +254,7 @@ export class StartStreamTranscriptionCommand extends $Command
  getWebSocketPlugin(config, {
  headerPrefix: "x-amzn-transcribe-",
  }),
+ getTranscribeStreamingPlugin(config),
  ];
  })
  .s("Transcribe", "StartStreamTranscription", {

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

@@ -22,6 +22,8 @@
 import software.amazon.smithy.aws.traits.ServiceTrait;
 import software.amazon.smithy.codegen.core.SymbolProvider;
 import software.amazon.smithy.model.Model;
+import software.amazon.smithy.model.knowledge.EventStreamIndex;
+import software.amazon.smithy.model.shapes.OperationShape;
 import software.amazon.smithy.model.shapes.ServiceShape;
 import software.amazon.smithy.typescript.codegen.LanguageTarget;
 import software.amazon.smithy.typescript.codegen.TypeScriptSettings;
@@ -54,7 +56,7 @@ public List<RuntimeClientPlugin> getClientPlugins() {
  RuntimeClientPlugin.builder()
  .withConventions(AwsDependency.TRANSCRIBE_STREAMING_MIDDLEWARE.dependency,
  "TranscribeStreaming", RuntimeClientPlugin.Convention.HAS_MIDDLEWARE)
- .servicePredicate((m, s) -> isTranscribeStreaming(s))
+ .operationPredicate((m, s, o) -> isTranscribeStreaming(s) && hasEventStreamInput(m, s, o))
  .build()
  );
  }
@@ -92,6 +94,11 @@ private static boolean isTranscribeStreaming(ServiceShape service) {
  String serviceId = service.getTrait(ServiceTrait.class).map(ServiceTrait::getSdkId).orElse("");
  return serviceId.equals("Transcribe Streaming");
  }
+
+ private static boolean hasEventStreamInput(Model model, ServiceShape service, OperationShape operation) {
+ EventStreamIndex eventStreamIndex = EventStreamIndex.of(model);
+ return eventStreamIndex.getInputInfo(operation).isPresent();
+ }
 }