Function performCheck

src/node/updater/index.ts:113–219

()

};

const performCheck = async (): Promise<void> => {
  if (settings.updates.tier === 'off') return;
  // Coalesce overlapping ticks. performCheck mutates shared in-memory state and writes
  // it to disk; concurrent runs would race on saveState() and could double-send emails.
  if (checkInFlight) return;
  checkInFlight = true;
  try {
    // getCurrentState() can throw on a non-ENOENT fs error from loadState();
    // it must run inside the try/finally so checkInFlight is always cleared,
    // otherwise a one-time permission error permanently disables polling.
    const state = await getCurrentState();
    const result = await checkLatestRelease({
      fetcher: realFetcher,
      prevEtag: state.lastEtag,
      repo: settings.updates.githubRepo,
    });
    const now = new Date();
    state.lastCheckAt = now.toISOString();

    if (result.kind === 'updated') {
      state.latest = result.release;
      state.lastEtag = result.etag;
    } else if (result.kind === 'skipped-prerelease') {
      // Preserve ETag so we don't re-fetch an unchanged prerelease body next tick.
      state.lastEtag = result.etag;
    } else if (result.kind === 'notmodified') {
      // 304 — no state change.
    } else if (result.kind === 'ratelimited') {
      logger.warn('GitHub rate-limited; will retry at next interval');
    } else if (result.kind === 'error') {
      logger.warn(`GitHub fetch error status=${result.status}`);
    }

    // Notifier pass: only when we have a known latest, an admin email, and the policy allows notify.
    if (state.latest && settings.adminEmail) {
      const current = getEpVersion();
      const policy = evaluatePolicy({
        installMethod: detectedMethod,
        tier: settings.updates.tier,
        current,
        latest: state.latest.version,
        maintenanceWindow: settings.updates.maintenanceWindow,
      });
      if (policy.canNotify) {
        const decision = decideEmails({
          adminEmail: settings.adminEmail,
          current,
          latest: state.latest.version,
          latestTag: state.latest.tag,
          isSevere: isMinorOrMoreBehind(current, state.latest.version),
          state: state.email,
          now,
        });
        for (const email of decision.toSend) {
          await sendEmailViaSmtp(settings.adminEmail, email.subject, email.body);
        }
        state.email = decision.newState;
      }