github/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-08 10:41:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor(test): share corrupt session fixture

Browse Source
This commit is contained in:
Peter Steinberger
2026-02-15 15:42:23 +00:00
parent 2b143de554
commit e683353cab
1 changed files with 33 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

52
src/auto-reply/reply/agent-runner.heartbeat-typing.runreplyagent-typing-heartbeat.test.ts
View File

@@ -51,6 +51,27 @@ async function withTempStateDir<T>(fn: (stateDir: string) => Promise<T>): Promis
} }
} }
async function writeCorruptGeminiSessionFixture(params: {
stateDir: string;
sessionId: string;
persistStore: boolean;
}) {
const storePath = path.join(params.stateDir, "sessions", "sessions.json");
const sessionEntry = { sessionId: params.sessionId, updatedAt: Date.now() };
const sessionStore = { main: sessionEntry };
await fs.mkdir(path.dirname(storePath), { recursive: true });
if (params.persistStore) {
await fs.writeFile(storePath, JSON.stringify(sessionStore), "utf-8");
}
const transcriptPath = sessions.resolveSessionTranscriptPath(params.sessionId);
await fs.mkdir(path.dirname(transcriptPath), { recursive: true });
await fs.writeFile(transcriptPath, "bad", "utf-8");
return { storePath, sessionEntry, sessionStore, transcriptPath };
}
describe("runReplyAgent typing (heartbeat)", () => { describe("runReplyAgent typing (heartbeat)", () => {
installRunReplyAgentTypingHeartbeatTestHooks(); installRunReplyAgentTypingHeartbeatTestHooks();
@@ -404,17 +425,12 @@ describe("runReplyAgent typing (heartbeat)", () => {
it("resets corrupted Gemini sessions and deletes transcripts", async () => { it("resets corrupted Gemini sessions and deletes transcripts", async () => {
await withTempStateDir(async (stateDir) => { await withTempStateDir(async (stateDir) => {
const sessionId = "session-corrupt"; const { storePath, sessionEntry, sessionStore, transcriptPath } =
const storePath = path.join(stateDir, "sessions", "sessions.json"); await writeCorruptGeminiSessionFixture({
const sessionEntry = { sessionId, updatedAt: Date.now() }; stateDir,
const sessionStore = { main: sessionEntry }; sessionId: "session-corrupt",
persistStore: true,
await fs.mkdir(path.dirname(storePath), { recursive: true }); });
await fs.writeFile(storePath, JSON.stringify(sessionStore), "utf-8");
const transcriptPath = sessions.resolveSessionTranscriptPath(sessionId);
await fs.mkdir(path.dirname(transcriptPath), { recursive: true });
await fs.writeFile(transcriptPath, "bad", "utf-8");
runEmbeddedPiAgentMock.mockImplementationOnce(async () => { runEmbeddedPiAgentMock.mockImplementationOnce(async () => {
throw new Error( throw new Error(
@@ -484,14 +500,12 @@ describe("runReplyAgent typing (heartbeat)", () => {
.spyOn(sessions, "saveSessionStore") .spyOn(sessions, "saveSessionStore")
.mockRejectedValueOnce(new Error("boom")); .mockRejectedValueOnce(new Error("boom"));
try { try {
const sessionId = "session-corrupt"; const { storePath, sessionEntry, sessionStore, transcriptPath } =
const storePath = path.join(stateDir, "sessions", "sessions.json"); await writeCorruptGeminiSessionFixture({
const sessionEntry = { sessionId, updatedAt: Date.now() }; stateDir,
const sessionStore = { main: sessionEntry }; sessionId: "session-corrupt",
persistStore: false,
const transcriptPath = sessions.resolveSessionTranscriptPath(sessionId); });
await fs.mkdir(path.dirname(transcriptPath), { recursive: true });
await fs.writeFile(transcriptPath, "bad", "utf-8");
runEmbeddedPiAgentMock.mockImplementationOnce(async () => { runEmbeddedPiAgentMock.mockImplementationOnce(async () => {
throw new Error( throw new Error(