test(client-transcribe-streaming): re-enable e2e

Author: kuhe

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

@@ -1,47 +1,48 @@
-import { createReadStream } from "fs";
-import { join } from "path";
+import { TranscribeStreaming } from "@aws-sdk/client-transcribe-streaming";
+import { createReadStream } from "node:fs";
+import { join } from "node:path";
 import { afterAll, beforeAll, describe, expect, test as it } from "vitest";
 
-import { TranscribeStreaming } from "../src/index";
 const audio = createReadStream(join(__dirname, "numbers.wav"));
 
-describe("TranscribeStream client", () => {
-  const client = new TranscribeStreaming({
-    region: "us-west-2",
-    credentials: {
-      accessKeyId: "CLIENT_TEST",
-      secretAccessKey: "CLIENT_TEST",
-    },
-  });
-
-  beforeAll(async () => {});
-  afterAll(() => {
-    client.destroy();
-  });
+describe(
+  "TranscribeStream client",
+  () => {
+    const client = new TranscribeStreaming({
+      region: "us-west-2",
+    });
 
-  // TODO: not working in Node.js with HTTP2 handler?
-  it.skip("should stream the transcript", async () => {
-    const LanguageCode = "en-GB";
-    const MediaEncoding = "pcm";
-    const MediaSampleRateHertz = 44100;
-    const result = await client.startStreamTranscription({
-      LanguageCode,
-      MediaEncoding,
-      MediaSampleRateHertz,
-      AudioStream: (async function* () {
-        for await (const chunk of audio) {
-          yield { AudioEvent: { AudioChunk: chunk } };
-        }
-      })(),
+    beforeAll(async () => {});
+    afterAll(() => {
+      client.destroy();
     });
-    expect(result.LanguageCode).toBe(LanguageCode);
-    expect(result.MediaEncoding).toBe(MediaEncoding);
-    expect(result.MediaSampleRateHertz).toBe(MediaSampleRateHertz);
-    expect(result.TranscriptResultStream).toBeDefined();
-    const transcripts: any[] = [];
-    for await (const event of result.TranscriptResultStream!) {
-      transcripts.push(event);
-    }
-    expect(transcripts.filter((event) => event["TranscriptEvent"]).length).toBeGreaterThan(0);
-  }, 60000);
-});
+
+    it("should stream the transcript", async () => {
+      const LanguageCode = "en-GB";
+      const MediaEncoding = "pcm";
+      const MediaSampleRateHertz = 44100;
+      const result = await client.startStreamTranscription({
+        LanguageCode,
+        MediaEncoding,
+        MediaSampleRateHertz,
+        AudioStream: (async function* () {
+          for await (const chunk of audio) {
+            yield { AudioEvent: { AudioChunk: chunk } };
+          }
+        })(),
+      });
+      expect(result.LanguageCode).toBe(LanguageCode);
+      expect(result.MediaEncoding).toBe(MediaEncoding);
+      expect(result.MediaSampleRateHertz).toBe(MediaSampleRateHertz);
+      expect(result.TranscriptResultStream).toBeDefined();
+      const transcripts: any[] = [];
+      for await (const event of result.TranscriptResultStream!) {
+        transcripts.push(event);
+      }
+      expect(transcripts.filter((event) => event["TranscriptEvent"]).length).toBeGreaterThan(0);
+    }, 60000);
+  },
+  {
+    retry: 4,
+  }
+);