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

Author: trivikr

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();
+    }
 }