@@ -119,6 +119,10 @@ async function writeMainSessionTranscript(sessionDir: string, lines: string[]) {
119119await fs.writeFile(path.join(sessionDir, "sess-main.jsonl"), `${lines.join("\n")}\n`, "utf-8");
120120}
121121122+async function removeTempDir(dir: string): Promise<void> {
123+await fs.rm(dir, { recursive: true, force: true, maxRetries: 5, retryDelay: 50 });
124+}
125+122126async function readTimelineEvents(filePath: string): Promise<Array<Record<string, unknown>>> {
123127const raw = await fs.readFile(filePath, "utf-8");
124128return raw
@@ -296,7 +300,7 @@ describe("gateway server chat", () => {
296300clearConfigCache();
297301testState.agentConfig = undefined;
298302testState.sessionStorePath = undefined;
299-await fs.rm(sessionDir, { recursive: true, force: true });
303+await removeTempDir(sessionDir);
300304}
301305});
302306@@ -527,7 +531,7 @@ describe("gateway server chat", () => {
527531expect(payload?.metadata).toBeUndefined();
528532} finally {
529533testState.sessionStorePath = undefined;
530-await fs.rm(sessionDir, { recursive: true, force: true, maxRetries: 5, retryDelay: 50 });
534+await removeTempDir(sessionDir);
531535}
532536});
533537@@ -687,7 +691,7 @@ describe("gateway server chat", () => {
687691);
688692} finally {
689693testState.sessionStorePath = undefined;
690-await fs.rm(sessionDir, { recursive: true, force: true, maxRetries: 5, retryDelay: 50 });
694+await removeTempDir(sessionDir);
691695}
692696});
693697@@ -892,7 +896,7 @@ describe("gateway server chat", () => {
892896dispatchInboundMessageMock.mockReset();
893897testState.sessionStorePath = undefined;
894898clearConfigCache();
895-await fs.rm(sessionDir, { recursive: true, force: true });
899+await removeTempDir(sessionDir);
896900}
897901});
898902@@ -1082,7 +1086,7 @@ describe("gateway server chat", () => {
10821086dispatchInboundMessageMock.mockReset();
10831087testState.sessionStorePath = undefined;
10841088clearConfigCache();
1085-await fs.rm(sessionDir, { recursive: true, force: true });
1089+await removeTempDir(sessionDir);
10861090}
10871091});
10881092@@ -1234,7 +1238,7 @@ describe("gateway server chat", () => {
12341238testState.agentConfig = undefined;
12351239testState.sessionStorePath = undefined;
12361240clearConfigCache();
1237-await fs.rm(sessionDir, { recursive: true, force: true });
1241+await removeTempDir(sessionDir);
12381242}
12391243},
12401244);
@@ -1421,7 +1425,7 @@ describe("gateway server chat", () => {
14211425dispatchInboundMessageMock.mockReset();
14221426testState.sessionStorePath = undefined;
14231427clearConfigCache();
1424-await fs.rm(sessionDir, { recursive: true, force: true });
1428+await removeTempDir(sessionDir);
14251429}
14261430});
14271431@@ -1536,7 +1540,7 @@ describe("gateway server chat", () => {
15361540dispatchInboundMessageMock.mockReset();
15371541testState.sessionStorePath = undefined;
15381542clearConfigCache();
1539-await fs.rm(sessionDir, { recursive: true, force: true });
1543+await removeTempDir(sessionDir);
15401544}
15411545});
15421546@@ -1670,7 +1674,7 @@ describe("gateway server chat", () => {
16701674dispatchInboundMessageMock.mockReset();
16711675testState.sessionStorePath = undefined;
16721676clearConfigCache();
1673-await fs.rm(sessionDir, { recursive: true, force: true });
1677+await removeTempDir(sessionDir);
16741678}
16751679});
16761680@@ -1821,7 +1825,7 @@ describe("gateway server chat", () => {
18211825dispatchInboundMessageMock.mockReset();
18221826testState.sessionStorePath = undefined;
18231827clearConfigCache();
1824-await fs.rm(sessionDir, { recursive: true, force: true });
1828+await removeTempDir(sessionDir);
18251829}
18261830});
18271831@@ -1973,7 +1977,7 @@ describe("gateway server chat", () => {
19731977dispatchInboundMessageMock.mockReset();
19741978testState.sessionStorePath = undefined;
19751979clearConfigCache();
1976-await fs.rm(sessionDir, { recursive: true, force: true });
1980+await removeTempDir(sessionDir);
19771981}
19781982});
19791983@@ -2354,7 +2358,7 @@ describe("gateway server chat", () => {
23542358} else {
23552359process.env.OPENCLAW_DIAGNOSTICS_TIMELINE_PATH = previousTimelinePath;
23562360}
2357-await fs.rm(timelineDir, { recursive: true, force: true, maxRetries: 5, retryDelay: 50 });
2361+await removeTempDir(timelineDir);
23582362}
23592363});
23602364此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。