Function createSchedulerRunner

src/node/updater/Scheduler.ts:173–198

({
  now, setTimer, clearTimer, triggerApply,
}: SchedulerRunnerDeps)

}

export const createSchedulerRunner = ({
  now, setTimer, clearTimer, triggerApply,
}: SchedulerRunnerDeps): SchedulerRunner => {
  let timer: NodeJS.Timeout | null = null;
  let armedFor: string | null = null;

  return {
    arm: ({targetTag, scheduledFor}) => {
      if (timer) { clearTimer(timer); timer = null; }
      armedFor = targetTag;
      const delay = Math.max(0, new Date(scheduledFor).getTime() - now().getTime());
      timer = setTimer(() => {
        timer = null;
        const tag = armedFor;
        armedFor = null;
        if (!tag) return;
        // Discard promise — apply pipeline owns its own error reporting.
        void triggerApply(tag);
      }, delay);
    },
    cancel: () => {
      if (timer) { clearTimer(timer); timer = null; }
      armedFor = null;
    },
  };
};