test(qqbot): keep stt temp helper on sdk surface

vincentkoc · vincentkoc · commit 37962aac954d · 2026-06-19T17:03:16.000+02:00
diff --git a/extensions/qqbot/src/engine/utils/stt.test.ts b/extensions/qqbot/src/engine/utils/stt.test.ts
@@ -2,7 +2,7 @@
 import * as fs from "node:fs";
 import * as path from "node:path";
 import { afterAll, afterEach, beforeEach, describe, expect, it, vi } from "vitest";
-import { createTempDirTracker } from "../../../../../test/helpers/temp-dir.js";
+import { withTempDir } from "openclaw/plugin-sdk/test-env";
 
 const ssrfRuntimeMocks = vi.hoisted(() => ({
   fetchWithSsrFGuard: vi.fn(),
@@ -19,8 +19,6 @@ afterAll(() => {
 
 import { resolveSTTConfig, transcribeAudio } from "./stt.js";
 
-const tempDirs = createTempDirTracker();
-
 function cancelTrackedResponse(
   text: string,
   init: ResponseInit,
@@ -71,7 +69,6 @@ describe("engine/utils/stt", () => {
   });
 
   afterEach(() => {
-    tempDirs.cleanup();
     ssrfRuntimeMocks.fetchWithSsrFGuard.mockReset();
     vi.unstubAllGlobals();
   });
@@ -135,70 +132,19 @@ describe("engine/utils/stt", () => {
   });
 
   it("posts audio to OpenAI-compatible transcription endpoint", async () => {
-    const tmpDir = tempDirs.make("openclaw-qqbot-stt-");
-    const audioPath = path.join(tmpDir, "voice.wav");
-    fs.writeFileSync(audioPath, Buffer.from([1, 2, 3, 4]));
-
-    const release = vi.fn(async () => {});
-    ssrfRuntimeMocks.fetchWithSsrFGuard.mockResolvedValueOnce({
-      response: Response.json({
-        text: "hello from audio",
-      }),
-      release,
-    });
-
-    const transcript = await transcribeAudio(audioPath, {
-      channels: {
-        qqbot: {
-          stt: {
-            baseUrl: "https://api.example.test/v1/",
-            apiKey: "secret",
-            model: "whisper-1",
-          },
-        },
-      },
-    });
-
-    expect(transcript).toBe("hello from audio");
-    expect(ssrfRuntimeMocks.fetchWithSsrFGuard).toHaveBeenCalledTimes(1);
-    const request = requireFirstSsrfRequest();
-    expect(request.url).toBe("https://api.example.test/v1/audio/transcriptions");
-    expect(request.auditContext).toBe("qqbot-stt");
-    expect(request.init?.method).toBe("POST");
-    expect(request.init?.headers).toEqual({ Authorization: "Bearer secret" });
-    expect(request.init?.body).toBeInstanceOf(FormData);
-    const body = request.init?.body as FormData;
-    expect(body.get("model")).toBe("whisper-1");
-    const file = body.get("file");
-    expect(file).toBeInstanceOf(File);
-    expect((file as File).name).toBe("voice.wav");
-    expect((file as File).type).toBe("audio/wav");
-    expect(new Uint8Array(await (file as File).arrayBuffer())).toEqual(
-      new Uint8Array([1, 2, 3, 4]),
-    );
-    expect(release).toHaveBeenCalledTimes(1);
-  });
-
-  it("bounds STT error bodies without using response.text()", async () => {
-    const tmpDir = tempDirs.make("openclaw-qqbot-stt-error-");
-    const audioPath = path.join(tmpDir, "voice.wav");
-    fs.writeFileSync(audioPath, Buffer.from([1, 2, 3, 4]));
-
-    const release = vi.fn(async () => {});
-    const tracked = cancelTrackedResponse(`${"stt provider unavailable ".repeat(1024)}tail`, {
-      status: 503,
-      statusText: "Service Unavailable",
-      headers: { "content-type": "text/plain" },
-    });
-    const textSpy = vi.spyOn(tracked.response, "text").mockRejectedValue(new Error("unbounded"));
-    ssrfRuntimeMocks.fetchWithSsrFGuard.mockResolvedValueOnce({
-      response: tracked.response,
-      release,
-    });
+    await withTempDir("openclaw-qqbot-stt-", async (tmpDir) => {
+      const audioPath = path.join(tmpDir, "voice.wav");
+      fs.writeFileSync(audioPath, Buffer.from([1, 2, 3, 4]));
+
+      const release = vi.fn(async () => {});
+      ssrfRuntimeMocks.fetchWithSsrFGuard.mockResolvedValueOnce({
+        response: Response.json({
+          text: "hello from audio",
+        }),
+        release,
+      });
 
-    let error: unknown;
-    try {
-      await transcribeAudio(audioPath, {
+      const transcript = await transcribeAudio(audioPath, {
         channels: {
           qqbot: {
             stt: {
@@ -209,14 +155,67 @@ describe("engine/utils/stt", () => {
           },
         },
       });
-    } catch (caught) {
-      error = caught;
-    }
-
-    expect(String(error)).toContain("STT failed (HTTP 503): stt provider unavailable");
-    expect(String(error)).not.toContain("tail");
-    expect(tracked.wasCanceled()).toBe(true);
-    expect(textSpy).not.toHaveBeenCalled();
-    expect(release).toHaveBeenCalledTimes(1);
+
+      expect(transcript).toBe("hello from audio");
+      expect(ssrfRuntimeMocks.fetchWithSsrFGuard).toHaveBeenCalledTimes(1);
+      const request = requireFirstSsrfRequest();
+      expect(request.url).toBe("https://api.example.test/v1/audio/transcriptions");
+      expect(request.auditContext).toBe("qqbot-stt");
+      expect(request.init?.method).toBe("POST");
+      expect(request.init?.headers).toEqual({ Authorization: "Bearer secret" });
+      expect(request.init?.body).toBeInstanceOf(FormData);
+      const body = request.init?.body as FormData;
+      expect(body.get("model")).toBe("whisper-1");
+      const file = body.get("file");
+      expect(file).toBeInstanceOf(File);
+      expect((file as File).name).toBe("voice.wav");
+      expect((file as File).type).toBe("audio/wav");
+      expect(new Uint8Array(await (file as File).arrayBuffer())).toEqual(
+        new Uint8Array([1, 2, 3, 4]),
+      );
+      expect(release).toHaveBeenCalledTimes(1);
+    });
+  });
+
+  it("bounds STT error bodies without using response.text()", async () => {
+    await withTempDir("openclaw-qqbot-stt-error-", async (tmpDir) => {
+      const audioPath = path.join(tmpDir, "voice.wav");
+      fs.writeFileSync(audioPath, Buffer.from([1, 2, 3, 4]));
+
+      const release = vi.fn(async () => {});
+      const tracked = cancelTrackedResponse(`${"stt provider unavailable ".repeat(1024)}tail`, {
+        status: 503,
+        statusText: "Service Unavailable",
+        headers: { "content-type": "text/plain" },
+      });
+      const textSpy = vi.spyOn(tracked.response, "text").mockRejectedValue(new Error("unbounded"));
+      ssrfRuntimeMocks.fetchWithSsrFGuard.mockResolvedValueOnce({
+        response: tracked.response,
+        release,
+      });
+
+      let error: unknown;
+      try {
+        await transcribeAudio(audioPath, {
+          channels: {
+            qqbot: {
+              stt: {
+                baseUrl: "https://api.example.test/v1/",
+                apiKey: "secret",
+                model: "whisper-1",
+              },
+            },
+          },
+        });
+      } catch (caught) {
+        error = caught;
+      }
+
+      expect(String(error)).toContain("STT failed (HTTP 503): stt provider unavailable");
+      expect(String(error)).not.toContain("tail");
+      expect(tracked.wasCanceled()).toBe(true);
+      expect(textSpy).not.toHaveBeenCalled();
+      expect(release).toHaveBeenCalledTimes(1);
+    });
   });
 });
