to: "123",

});

expect(() => applyJobPatch(job, switchToMainPatch())).not.toThrow();

applyJobPatch(job, switchToMainPatch());

expect(job.sessionTarget).toBe("main");

expect(job.payload.kind).toBe("systemEvent");

expect(job.delivery).toBeUndefined();

to: "https://example.invalid/cron",

});

expect(() => applyJobPatch(job, switchToMainPatch())).not.toThrow();

applyJobPatch(job, switchToMainPatch());

expect(job.sessionTarget).toBe("main");

expect(job.delivery).toEqual({ mode: "webhook", to: "https://example.invalid/cron" });

});

},

};

expect(() => applyJobPatch(job, patch)).not.toThrow();

applyJobPatch(job, patch);

expect(job.payload.kind).toBe("agentTurn");

if (job.payload.kind === "agentTurn") {

expect(job.payload.message).toBe("do it");

to: " https://example.invalid/failure ",

},

};

expect(() => applyJobPatch(job, { enabled: true })).not.toThrow();

applyJobPatch(job, { enabled: true });

expect(job.delivery?.failureDestination?.to).toBe("https://example.invalid/failure");

});

to: "-10012345/6789",

});

expect(() => applyJobPatch(job, { enabled: true })).not.toThrow();

applyJobPatch(job, { enabled: true });

expect(job.delivery?.to).toBe("-10012345/6789");

});

...(to ? { to } : {}),

});

expect(() => applyJobPatch(job, { enabled: true })).not.toThrow();

applyJobPatch(job, { enabled: true });

expect(job.enabled).toBe(true);

});

});

{ name: "case-insensitive defaultAgentId match", defaultAgentId: "Main", agentId: "MAIN" },

] as const)("allows creating a main-session job for $name", ({ defaultAgentId, agentId }) => {

const state = createMockState(now, { defaultAgentId });

expect(() => createJob(state, mainJobInput(agentId))).not.toThrow();

const job = createJob(state, mainJobInput(agentId));

expect(job.sessionTarget).toBe("main");

});

it.each([

);

return;

}

expect(() => applyJobPatch(job, patch, { defaultAgentId: "main" })).not.toThrow();

applyJobPatch(job, patch, { defaultAgentId: "main" });

expect(job.agentId).toBe("main");

});

it("rejects patching to a custom session target with path separators", () => {

store: { version: 1 as const, jobs: [job] },

} as CronServiceState;

expect(() => recomputeNextRunsForMaintenance(state)).not.toThrow();

recomputeNextRunsForMaintenance(state);

expect(job.state.nextRunAtMs).toBe(future);

expect(job.state.scheduleErrorCount).toBeUndefined();

});