vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-06 05:30:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: retry gateway chat temp cleanup

Browse Source
This commit is contained in:
Peter Steinberger
2026-05-06 00:47:43 +01:00
parent df4db5a721
commit c7b69a319b
1 changed files with 13 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
src/gateway/server.chat.gateway-server-chat.test.ts
View File

@@ -38,6 +38,10 @@ describe("gateway server chat", () => {
dispatchInboundMessageMock.mockReset();
});
const removeTempDir = async (dir: string): Promise<void> => {
await fs.rm(dir, { recursive: true, force: true, maxRetries: 5, retryDelay: 50 });
};
const buildNoReplyHistoryFixture = (includeMixedAssistant = false) => [
{
role: "user",
@@ -109,7 +113,7 @@ describe("gateway server chat", () => {
return await run(dir);
} finally {
testState.sessionStorePath = undefined;
await fs.rm(dir, { recursive: true, force: true, maxRetries: 5, retryDelay: 50 });
await removeTempDir(dir);
}
};
@@ -223,7 +227,7 @@ describe("gateway server chat", () => {
expect(res.payload?.messageSeq).toBe(1);
} finally {
testState.sessionStorePath = undefined;
await fs.rm(dir, { recursive: true, force: true, maxRetries: 5, retryDelay: 50 });
await removeTempDir(dir);
}
});
@@ -250,7 +254,7 @@ describe("gateway server chat", () => {
expect(res.payload?.messageSeq).toBe(1);
} finally {
testState.sessionStorePath = undefined;
await fs.rm(dir, { recursive: true, force: true });
await removeTempDir(dir);
}
});
@@ -325,7 +329,7 @@ describe("gateway server chat", () => {
}
} finally {
testState.sessionStorePath = undefined;
await fs.rm(dir, { recursive: true, force: true });
await removeTempDir(dir);
}
});
@@ -360,7 +364,7 @@ describe("gateway server chat", () => {
}
} finally {
testState.sessionStorePath = undefined;
await fs.rm(dir, { recursive: true, force: true });
await removeTempDir(dir);
}
});
@@ -606,7 +610,7 @@ describe("gateway server chat", () => {
if (webchatWs) {
webchatWs.close();
}
await Promise.all(tempDirs.map((dir) => fs.rm(dir, { recursive: true, force: true })));
await Promise.all(tempDirs.map((dir) => removeTempDir(dir)));
}
});
@@ -1049,7 +1053,7 @@ describe("gateway server chat", () => {
testState.agentConfig = undefined;
testState.agentsConfig = undefined;
testState.sessionStorePath = undefined;
await fs.rm(dir, { recursive: true, force: true });
await removeTempDir(dir);
}
});
@@ -1189,7 +1193,7 @@ describe("gateway server chat", () => {
} finally {
resolveAgentRun?.();
testState.sessionStorePath = undefined;
await fs.rm(dir, { recursive: true, force: true });
await removeTempDir(dir);
}
});
@@ -1403,7 +1407,7 @@ describe("gateway server chat", () => {
}
} finally {
webchatWs.close();
await fs.rm(dir, { recursive: true, force: true });
await removeTempDir(dir);
testState.sessionStorePath = undefined;
}
});