test: account for native cursor projection metadata

This commit is contained in:
Dotta committed 2026-11-03 14:04:49 -06:00
1 parent 68b2424a99
commit e993c9b2fd
5 files changed
+12 -6

No files matched your search

@@ -61,7 +61,7 @@ if (!support.supported) console.warn(`Skipping idle sleep diagnostics Postgres t
expect(blockers(report)).toEqual([]);
expect(report.diagnostics?.checks.filter(check => !check.reason.includes(".") ||
["agents.execution_or_timer", "agents.lifecycle", "agents.company_hold", "heartbeat_runs.budget_cancellation"].includes(check.reason)))
.toHaveLength(72);
.toHaveLength(73);
expect(await db.select().from(heartbeatRuns).where(eq(heartbeatRuns.id, f.runId))).toHaveLength(1);
});
@@ -40,7 +40,7 @@ describe("owned idle sleep diagnostics", () => {
expect(result.diagnostics?.complete).toBe(true);
expect(result.diagnostics?.checks.filter(check => check.state === "present").map(check => check.reason))
.toEqual(["agent_api_keys", "chat_deliveries", "heartbeat_runs", "muse_mailbox_items"]);
expect(f.keys()).toHaveLength(72);
expect(f.keys()).toHaveLength(73);
expect(new Set(f.keys()).size).toBe(f.keys().length);
const inventory = readFileSync(new URL("../../../doc/plans/2026-11-02-sleep-blocker-inventory.md", import.meta.url), "utf8");
const documented = [...inventory.matchAll(/^\| `([a-z0-9_.]+)` \|/gm)].map(match => match[1]);
@@ -230,7 +230,8 @@ suite("settled native run process identity", () => {
expect(summary.responseValueBytes).toBeLessThan(8192);
const after = await readRun(runId);
expect(after).toEqual({ ...saved, processPid: null, processGroupId: null, processStartedAt: null,
nextEventSeq: saved.nextEventSeq + 1, updatedAt: after.updatedAt });
nextEventSeq: saved.nextEventSeq + 1, eventCursorProjectionSeq: saved.eventCursorProjectionSeq + 1,
updatedAt: after.updatedAt });
expect(await hasNativeLocalProcessStop(db, companyId, runId)).toBe(true);
expect(JSON.stringify(events)).not.toContain(bulk.slice(0, 64));
});