negodiy/openclaw
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

test(cli): dedupe temp dirs in camera tests and cover non-ok url responses

Browse Source
This commit is contained in:
Peter Steinberger
2026-02-21 19:12:09 +00:00
parent 0ecb07e6d1
commit b889a5d516
1 changed files with 29 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

45
src/cli/nodes-camera.test.ts
View File

@@ -12,6 +12,15 @@ import {
} from "./nodes-camera.js";
import { parseScreenRecordPayload, screenRecordTempPath } from "./nodes-screen.js";
async function withTempDir<T>(prefix: string, run: (dir: string) => Promise<T>): Promise<T> {
const dir = await fs.mkdtemp(path.join(os.tmpdir(), prefix));
try {
return await run(dir);
} finally {
await fs.rm(dir, { recursive: true, force: true });
}
}
describe("nodes camera helpers", () => {
it("parses camera.snap payload", () => {
expect(
@@ -58,8 +67,7 @@ describe("nodes camera helpers", () => {
});
it("writes camera clip payload to temp path", async () => {
const dir = await fs.mkdtemp(path.join(os.tmpdir(), "openclaw-test-"));
try {
await withTempDir("openclaw-test-", async (dir) => {
const out = await writeCameraClipPayloadToFile({
payload: {
format: "mp4",
@@ -73,17 +81,15 @@ describe("nodes camera helpers", () => {
});
expect(out).toBe(path.join(dir, "openclaw-camera-clip-front-clip1.mp4"));
await expect(fs.readFile(out, "utf8")).resolves.toBe("hi");
} finally {
await fs.rm(dir, { recursive: true, force: true });
}
});
});
it("writes base64 to file", async () => {
const dir = await fs.mkdtemp(path.join(os.tmpdir(), "openclaw-test-"));
const out = path.join(dir, "x.bin");
await writeBase64ToFile(out, "aGk=");
await expect(fs.readFile(out, "utf8")).resolves.toBe("hi");
await fs.rm(dir, { recursive: true, force: true });
await withTempDir("openclaw-test-", async (dir) => {
const out = path.join(dir, "x.bin");
await writeBase64ToFile(out, "aGk=");
await expect(fs.readFile(out, "utf8")).resolves.toBe("hi");
});
});
afterEach(() => {
@@ -95,14 +101,11 @@ describe("nodes camera helpers", () => {
"fetch",
vi.fn(async () => new Response("url-content", { status: 200 })),
);
const dir = await fs.mkdtemp(path.join(os.tmpdir(), "openclaw-test-"));
const out = path.join(dir, "x.bin");
try {
await withTempDir("openclaw-test-", async (dir) => {
const out = path.join(dir, "x.bin");
await writeUrlToFile(out, "https://example.com/clip.mp4");
await expect(fs.readFile(out, "utf8")).resolves.toBe("url-content");
} finally {
await fs.rm(dir, { recursive: true, force: true });
}
});
});
it("rejects non-https url payload", async () => {
@@ -126,6 +129,16 @@ describe("nodes camera helpers", () => {
/exceeds max/i,
);
});
it("rejects non-ok https url payload responses", async () => {
vi.stubGlobal(
"fetch",
vi.fn(async () => new Response("down", { status: 503, statusText: "Service Unavailable" })),
);
await expect(writeUrlToFile("/tmp/ignored", "https://example.com/down.bin")).rejects.toThrow(
/503/i,
);
});
});
describe("nodes screen helpers", () => {