let5see/clawdbot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

style: biome format gateway server tests

Browse Source
This commit is contained in:
Peter Steinberger
2025-12-30 05:34:53 +01:00
parent fb8f72d5a9
commit dcee8beb99
1 changed files with 45 additions and 41 deletions
Download Patch File Download Diff File Expand all files Collapse all files

86
src/gateway/server.test.ts
View File

@@ -439,56 +439,60 @@ describe("gateway server", () => {
"voicewake.get returns defaults and voicewake.set broadcasts", "voicewake.get returns defaults and voicewake.set broadcasts",
{ timeout: 15_000 }, { timeout: 15_000 },
async () => { async () => {
const homeDir = await fs.mkdtemp(path.join(os.tmpdir(), "clawdis-home-")); const homeDir = await fs.mkdtemp(path.join(os.tmpdir(), "clawdis-home-"));
const prevHome = process.env.HOME; const prevHome = process.env.HOME;
process.env.HOME = homeDir; process.env.HOME = homeDir;
const { server, ws } = await startServerWithClient(); const { server, ws } = await startServerWithClient();
await connectOk(ws); await connectOk(ws);
const initial = await rpcReq<{ triggers: string[] }>(ws, "voicewake.get"); const initial = await rpcReq<{ triggers: string[] }>(ws, "voicewake.get");
expect(initial.ok).toBe(true); expect(initial.ok).toBe(true);
expect(initial.payload?.triggers).toEqual(["clawd", "claude", "computer"]); expect(initial.payload?.triggers).toEqual([
"clawd",
"claude",
"computer",
]);
const changedP = onceMessage<{ const changedP = onceMessage<{
type: "event"; type: "event";
event: string; event: string;
payload?: unknown; payload?: unknown;
}>(ws, (o) => o.type === "event" && o.event === "voicewake.changed"); }>(ws, (o) => o.type === "event" && o.event === "voicewake.changed");
const setRes = await rpcReq<{ triggers: string[] }>(ws, "voicewake.set", { const setRes = await rpcReq<{ triggers: string[] }>(ws, "voicewake.set", {
triggers: [" hi ", "", "there"], triggers: [" hi ", "", "there"],
}); });
expect(setRes.ok).toBe(true); expect(setRes.ok).toBe(true);
expect(setRes.payload?.triggers).toEqual(["hi", "there"]); expect(setRes.payload?.triggers).toEqual(["hi", "there"]);
const changed = await changedP; const changed = await changedP;
expect(changed.event).toBe("voicewake.changed"); expect(changed.event).toBe("voicewake.changed");
expect( expect(
(changed.payload as { triggers?: unknown } | undefined)?.triggers, (changed.payload as { triggers?: unknown } | undefined)?.triggers,
).toEqual(["hi", "there"]); ).toEqual(["hi", "there"]);
const after = await rpcReq<{ triggers: string[] }>(ws, "voicewake.get"); const after = await rpcReq<{ triggers: string[] }>(ws, "voicewake.get");
expect(after.ok).toBe(true); expect(after.ok).toBe(true);
expect(after.payload?.triggers).toEqual(["hi", "there"]); expect(after.payload?.triggers).toEqual(["hi", "there"]);
const onDisk = JSON.parse( const onDisk = JSON.parse(
await fs.readFile( await fs.readFile(
path.join(homeDir, ".clawdis", "settings", "voicewake.json"), path.join(homeDir, ".clawdis", "settings", "voicewake.json"),
"utf8", "utf8",
), ),
) as { triggers?: unknown; updatedAtMs?: unknown }; ) as { triggers?: unknown; updatedAtMs?: unknown };
expect(onDisk.triggers).toEqual(["hi", "there"]); expect(onDisk.triggers).toEqual(["hi", "there"]);
expect(typeof onDisk.updatedAtMs).toBe("number"); expect(typeof onDisk.updatedAtMs).toBe("number");
ws.close(); ws.close();
await server.close(); await server.close();
if (prevHome === undefined) { if (prevHome === undefined) {
delete process.env.HOME; delete process.env.HOME;
} else { } else {
process.env.HOME = prevHome; process.env.HOME = prevHome;
} }
}, },
); );