Function decideSchedule

src/node/updater/Scheduler.ts:58–108

(input: DecideScheduleInput)

 *    email when `adminEmail` is set and `email.graceStartTag !== latest.tag`.
 */
export const decideSchedule = (input: DecideScheduleInput): SchedulerDecision => {
  const {
    state, now, policy, latest, current, preApplyGraceMinutes, adminEmail,
    maintenanceWindow,
  } = input;
  const status = state.execution.status;

  if (!latest) return {action: 'nothing'};

  if (!policy.canAuto) {
    if (status === 'scheduled') return {action: 'cancel-schedule', reason: 'policy-denied'};
    return {action: 'nothing'};
  }

  if (IN_FLIGHT.has(status) || TERMINAL.has(status)) return {action: 'nothing'};

  if (status === 'scheduled'
      && (state.execution as {targetTag: string}).targetTag === latest.tag) {
    return {action: 'nothing'};
  }

  const graceMs = clampGrace(preApplyGraceMinutes) * 60 * 1000;
  let scheduledForDate = new Date(now.getTime() + graceMs);
  // Tier 4: snap forward to the next opening if grace lands outside the window.
  if (policy.canAutonomous && maintenanceWindow) {
    if (!inWindow(scheduledForDate, maintenanceWindow)) {
      scheduledForDate = nextWindowStart(scheduledForDate, maintenanceWindow);
    }
  }
  const scheduledFor = scheduledForDate.toISOString();
  const newExecution = {
    status: 'scheduled' as const,
    targetTag: latest.tag,
    scheduledFor,
    startedAt: now.toISOString(),
  };

  const emails: PlannedEmail[] = [];
  const newEmailState: EmailSendLog = {...state.email};
  if (adminEmail && state.email.graceStartTag !== latest.tag) {
    emails.push({
      kind: 'grace-start',
      subject: `[Etherpad] Auto-update scheduled for ${latest.version}`,
      body: `Etherpad will auto-update to ${latest.tag} at ${scheduledFor}. ` +
            `Your version is ${current}. To cancel, visit /admin/update.`,
    });
    newEmailState.graceStartTag = latest.tag;
  }

  return {action: 'schedule', newExecution, emails, newEmailState};
};

export type TriggerApplyDecision =
  | {action: 'fire'}