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

test: dedupe restart recovery mock reads

Browse Source
This commit is contained in:
Peter Steinberger
2026-05-13 04:36:36 +01:00
parent c31874fe87
commit 3cfbc9e234
1 changed files with 17 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
src/agents/main-session-restart-recovery.test.ts
View File

@@ -61,6 +61,18 @@ function cleanedLock(sessionsDir: string, sessionId: string): SessionLockInspect
return cleanedLockForPath(path.join(sessionsDir, `${sessionId}.jsonl.lock`));
}
function firstGatewayParams(): Record<string, unknown> {
const call = vi.mocked(callGateway).mock.calls[0];
if (!call) {
throw new Error("expected gateway call");
}
const params = call[0].params;
if (!params || typeof params !== "object" || Array.isArray(params)) {
throw new Error("expected gateway params");
}
return params as Record<string, unknown>;
}
describe("main-session-restart-recovery", () => {
it("marks only main running sessions whose transcript lock was cleaned", async () => {
const sessionsDir = await makeSessionsDir();
@@ -235,12 +247,10 @@ describe("main-session-restart-recovery", () => {
expect(result).toEqual({ recovered: 1, failed: 0, skipped: 0 });
expect(callGateway).toHaveBeenCalledOnce();
const resumeParams = vi.mocked(callGateway).mock.calls.at(0)?.[0].params as
| { sessionKey?: string; deliver?: boolean; lane?: string }
| undefined;
expect(resumeParams?.sessionKey).toBe("agent:main:main");
expect(resumeParams?.deliver).toBe(false);
expect(resumeParams?.lane).toBe("main");
const resumeParams = firstGatewayParams();
expect(resumeParams.sessionKey).toBe("agent:main:main");
expect(resumeParams.deliver).toBe(false);
expect(resumeParams.lane).toBe("main");
const store = loadSessionStore(path.join(sessionsDir, "sessions.json"));
expect(store["agent:main:main"]?.abortedLastRun).toBe(false);
});
@@ -303,10 +313,7 @@ describe("main-session-restart-recovery", () => {
expect(result).toEqual({ recovered: 1, failed: 0, skipped: 0 });
expect(callGateway).toHaveBeenCalledOnce();
const callParams = vi.mocked(callGateway).mock.calls.at(0)?.[0].params as {
message?: string;
};
expect(callParams.message).toContain(pendingPayload);
expect(firstGatewayParams().message).toContain(pendingPayload);
const beforeStoreRead = Date.now();
const store = loadSessionStore(path.join(sessionsDir, "sessions.json"));