Function notifyJob

src/index.js:577–581

(directory, job, reason)

async function writeState(directory, sessionID, state) {
  await withStateWriteLock(directory, sessionID, async () => {
    await ensureDir(stateDir(directory));
    const target = statePath(directory, sessionID);
    const baseline = state?.[STATE_BASELINE];
    let jobs = structuredClone(state.jobs || []);
    if (Array.isArray(baseline)) {
      const current = await readStateFile(directory, sessionID);
      jobs = mergeStateJobs(baseline, jobs, current.jobs || []);
      state.jobs = structuredClone(jobs);