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

Author: AllanZhengYP

clients/client-transcribe-streaming/.gitignore

@@ -11,4 +11,5 @@ package-lock.json
 
 *.d.ts
 *.js
+!jest*.config.js
 *.js.map

clients/client-transcribe-streaming/.npmignore

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

clients/client-transcribe-streaming/jest.config.js

@@ -0,0 +1,13 @@
+const base = require("../../jest.config.base.js");
+
+module.exports = {
+  ...base,
+  // Only test cjs dist, avoid testing the package twice
+  testPathIgnorePatterns: ["/node_modules/", "/es/", ".*.integ.spec.js"],
+  coveragePathIgnorePatterns: [
+    "/node_modules/",
+    "/commands/",
+    "/protocols/", // protocols tested in protocol protocol_tests folder
+    "endpoints" // endpoint tested in tests/functional/endpoints
+  ]
+};

clients/client-transcribe-streaming/jest.integ.config.js

@@ -0,0 +1,6 @@
+const base = require("../../jest.config.base.js");
+
+module.exports = {
+  ...base,
+  testMatch: ["**/*.integ.spec.js"]
+};

clients/client-transcribe-streaming/package.json

@@ -12,7 +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",
+    "test": "yarn build && jest --coverage --passWithNoTests",
     "build:es": "tsc -p tsconfig.es.json",
     "build": "yarn pretest && yarn build:es"
   },

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

@@ -0,0 +1,36 @@
+import { TranscribeStreaming } from "../index";
+import { createReadStream } from "fs";
+import { join } from "path";
+const moduleRoot = join(__dirname, "..", "..", "..");
+const audio = createReadStream(join(moduleRoot, "test", "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);
+});

clients/client-transcribe-streaming/test/speech.wav

@@ -15,5 +15,6 @@
       "es2015.symbol.wellknown"
     ],
     "outDir": "dist/es"
-  }
+  },
+  "exclude": ["test"]
 }