test(client-transcribe-streaming): add smoke test

Author: AllanZhengYP

clients/client-transcribe-streaming/.npmignore

@@ -1,4 +1,5 @@
 /coverage/
 /docs/
+/test/
 tsconfig.test.json
 *.tsbuildinfo

clients/client-transcribe-streaming/package.json

@@ -12,8 +12,7 @@
     "remove-documentation": "rimraf ./docs",
     "remove-js": "rimraf *.js && rimraf ./commands/*.js && rimraf ./models/*.js && rimraf ./protocols/*.js",
     "remove-maps": "rimraf *.js.map && rimraf ./commands/*.js.map && rimraf ./models/*.js.map && rimraf ./protocols/*.js.map",
-    "test": "exit 0",
-    "smoke-test": "npm run pretest && node ./test/smoke/index.spec.js",
+    "test:integ": "npm run pretest && jest ./test/integ/index.nodejs.spec.js",
     "build:es": "tsc -p tsconfig.es.json",
     "build": "yarn pretest && yarn build:es"
   },

clients/client-transcribe-streaming/test/integ/index.nodejs.spec.ts

@@ -0,0 +1,36 @@
+import { TranscribeStreaming, TranscriptResultStream } from "../../index";
+import { createReadStream } from "fs";
+import { join } from "path";
+const moduleRoot = join(__dirname, "..", "..", "..", "..");
+const audio = createReadStream(join(moduleRoot, "test", "integ", "speech.wav"));
+
+describe("TranscribeStream client", () => {
+  const client = new TranscribeStreaming({});
+  afterAll(() => {
+    client.destroy();
+  });
+
+  it("should stream the transcript", async () => {
+    const result = await client.startStreamTranscription({
+      LanguageCode: "en-US",
+      MediaEncoding: "pcm",
+      MediaSampleRateHertz: 44100,
+      AudioStream: (async function* () {
+        for await (const chunk of audio) {
+          yield { AudioEvent: { AudioChunk: chunk } };
+        }
+      })()
+    });
+    expect(result.LanguageCode).toBe("en-US");
+    expect(result.MediaEncoding).toBe("pcm");
+    expect(result.MediaSampleRateHertz).toBe(44100);
+    expect(result.TranscriptResultStream).toBeDefined();
+    const transcripts = [];
+    for await (const event of result.TranscriptResultStream!) {
+      transcripts.push(event);
+    }
+    expect(
+      transcripts.filter(event => event["TranscriptEvent"]).length
+    ).toBeGreaterThan(0);
+  }, 60000);
+});