expect(result).toEqual({ recovered: 1, failed: 0, skipped: 0 });

expect(callGateway).toHaveBeenCalledOnce();

expect(vi.mocked(callGateway).mock.calls[0]?.[0].params).toMatchObject({

sessionKey: "agent:main:main",

deliver: false,

lane: "main",

});

const resumeParams = vi.mocked(callGateway).mock.calls[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 store = loadSessionStore(path.join(sessionsDir, "sessions.json"));

expect(store["agent:main:main"]?.abortedLastRun).toBe(false);

});

const beforeStoreRead = Date.now();

const store = loadSessionStore(path.join(sessionsDir, "sessions.json"));

const entry = store["agent:main:main"];

expect(entry).toMatchObject({

abortedLastRun: false,

pendingFinalDelivery: true,

pendingFinalDeliveryText: pendingPayload,

pendingFinalDeliveryAttemptCount: 1,

pendingFinalDeliveryLastError: null,

});

expect(entry?.abortedLastRun).toBe(false);

expect(entry?.pendingFinalDelivery).toBe(true);

expect(entry?.pendingFinalDeliveryText).toBe(pendingPayload);

expect(entry?.pendingFinalDeliveryAttemptCount).toBe(1);

expect(entry?.pendingFinalDeliveryLastError).toBeNull();

expect(entry?.pendingFinalDeliveryCreatedAt).toBeLessThanOrEqual(beforeStoreRead);

expect(entry?.pendingFinalDeliveryLastAttemptAt).toBeLessThanOrEqual(beforeStoreRead);

expect(entry?.pendingFinalDeliveryLastAttemptAt ?? 0).toBeGreaterThanOrEqual(