@@ -38,6 +38,10 @@ describe("gateway server chat", () => {
3838dispatchInboundMessageMock.mockReset();
3939});
404041+const removeTempDir = async (dir: string): Promise<void> => {
42+await fs.rm(dir, { recursive: true, force: true, maxRetries: 5, retryDelay: 50 });
43+};
44+4145const buildNoReplyHistoryFixture = (includeMixedAssistant = false) => [
4246{
4347role: "user",
@@ -109,7 +113,7 @@ describe("gateway server chat", () => {
109113return await run(dir);
110114} finally {
111115testState.sessionStorePath = undefined;
112-await fs.rm(dir, { recursive: true, force: true, maxRetries: 5, retryDelay: 50 });
116+await removeTempDir(dir);
113117}
114118};
115119@@ -223,7 +227,7 @@ describe("gateway server chat", () => {
223227expect(res.payload?.messageSeq).toBe(1);
224228} finally {
225229testState.sessionStorePath = undefined;
226-await fs.rm(dir, { recursive: true, force: true, maxRetries: 5, retryDelay: 50 });
230+await removeTempDir(dir);
227231}
228232});
229233@@ -250,7 +254,7 @@ describe("gateway server chat", () => {
250254expect(res.payload?.messageSeq).toBe(1);
251255} finally {
252256testState.sessionStorePath = undefined;
253-await fs.rm(dir, { recursive: true, force: true });
257+await removeTempDir(dir);
254258}
255259});
256260@@ -325,7 +329,7 @@ describe("gateway server chat", () => {
325329}
326330} finally {
327331testState.sessionStorePath = undefined;
328-await fs.rm(dir, { recursive: true, force: true });
332+await removeTempDir(dir);
329333}
330334});
331335@@ -360,7 +364,7 @@ describe("gateway server chat", () => {
360364}
361365} finally {
362366testState.sessionStorePath = undefined;
363-await fs.rm(dir, { recursive: true, force: true });
367+await removeTempDir(dir);
364368}
365369});
366370@@ -606,7 +610,7 @@ describe("gateway server chat", () => {
606610if (webchatWs) {
607611webchatWs.close();
608612}
609-await Promise.all(tempDirs.map((dir) => fs.rm(dir, { recursive: true, force: true })));
613+await Promise.all(tempDirs.map((dir) => removeTempDir(dir)));
610614}
611615});
612616@@ -1049,7 +1053,7 @@ describe("gateway server chat", () => {
10491053testState.agentConfig = undefined;
10501054testState.agentsConfig = undefined;
10511055testState.sessionStorePath = undefined;
1052-await fs.rm(dir, { recursive: true, force: true });
1056+await removeTempDir(dir);
10531057}
10541058});
10551059@@ -1189,7 +1193,7 @@ describe("gateway server chat", () => {
11891193} finally {
11901194resolveAgentRun?.();
11911195testState.sessionStorePath = undefined;
1192-await fs.rm(dir, { recursive: true, force: true });
1196+await removeTempDir(dir);
11931197}
11941198});
11951199@@ -1403,7 +1407,7 @@ describe("gateway server chat", () => {
14031407}
14041408} finally {
14051409webchatWs.close();
1406-await fs.rm(dir, { recursive: true, force: true });
1410+await removeTempDir(dir);
14071411testState.sessionStorePath = undefined;
14081412}
14091413});
此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。