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

test(gateway): stabilize cron temp cleanup

Browse Source
This commit is contained in:
Peter Steinberger
2026-01-18 06:01:00 +00:00
parent a3a2c641a7
commit d1c85cb32d
1 changed files with 23 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
src/gateway/server.cron.test.ts
View File

@@ -18,6 +18,23 @@ async function yieldToEventLoop() {
await fs.stat(process.cwd()).catch(() => {}); await fs.stat(process.cwd()).catch(() => {});
} }
async function rmTempDir(dir: string) {
for (let i = 0; i < 100; i += 1) {
try {
await fs.rm(dir, { recursive: true, force: true });
return;
} catch (err) {
const code = (err as { code?: unknown } | null)?.code;
if (code === "ENOTEMPTY" || code === "EBUSY" || code === "EPERM" || code === "EACCES") {
await yieldToEventLoop();
continue;
}
throw err;
}
}
await fs.rm(dir, { recursive: true, force: true });
}
describe("gateway server cron", () => { describe("gateway server cron", () => {
test("supports cron.add and cron.list", async () => { test("supports cron.add and cron.list", async () => {
const dir = await fs.mkdtemp(path.join(os.tmpdir(), "clawdbot-gw-cron-")); const dir = await fs.mkdtemp(path.join(os.tmpdir(), "clawdbot-gw-cron-"));
@@ -50,7 +67,7 @@ describe("gateway server cron", () => {
ws.close(); ws.close();
await server.close(); await server.close();
await fs.rm(dir, { recursive: true, force: true }); await rmTempDir(dir);
testState.cronStorePath = undefined; testState.cronStorePath = undefined;
}); });
@@ -86,7 +103,7 @@ describe("gateway server cron", () => {
ws.close(); ws.close();
await server.close(); await server.close();
await fs.rm(dir, { recursive: true, force: true }); await rmTempDir(dir);
testState.cronStorePath = undefined; testState.cronStorePath = undefined;
testState.sessionConfig = undefined; testState.sessionConfig = undefined;
}); });
@@ -118,7 +135,7 @@ describe("gateway server cron", () => {
ws.close(); ws.close();
await server.close(); await server.close();
await fs.rm(dir, { recursive: true, force: true }); await rmTempDir(dir);
testState.cronStorePath = undefined; testState.cronStorePath = undefined;
}); });
@@ -161,7 +178,7 @@ describe("gateway server cron", () => {
ws.close(); ws.close();
await server.close(); await server.close();
await fs.rm(dir, { recursive: true, force: true }); await rmTempDir(dir);
testState.cronStorePath = undefined; testState.cronStorePath = undefined;
}); });
@@ -199,7 +216,7 @@ describe("gateway server cron", () => {
ws.close(); ws.close();
await server.close(); await server.close();
await fs.rm(dir, { recursive: true, force: true }); await rmTempDir(dir);
testState.cronStorePath = undefined; testState.cronStorePath = undefined;
}); });
@@ -432,7 +449,7 @@ describe("gateway server cron", () => {
} finally { } finally {
testState.cronEnabled = false; testState.cronEnabled = false;
testState.cronStorePath = undefined; testState.cronStorePath = undefined;
await fs.rm(dir, { recursive: true, force: true }); await rmTempDir(dir);
} }
}, 45_000); }, 45_000);
}); });