Function runNightly

telemetry-worker/src/rollup.ts:260–304

(env: Env, atMs: number)

 * quietly skipping a day; every write here is idempotent, so a retry is safe.
 */
export async function runNightly(env: Env, atMs: number): Promise<void> {
  const started = Date.now();
  const keepDays = retentionDays(env);
  const cutoff = retentionCutoff(atMs, keepDays);

  const rolled: string[] = [];
  const failed: string[] = [];
  let rows = 0;
  for (let back = 1; back <= ROLLUP_LOOKBACK_DAYS; back++) {
    const day = utcDay(atMs - back * DAY_MS);
    try {
      rows += (await rollupDay(env, day, { cutoff })).rows;
      rolled.push(day);
    } catch (err) {
      failed.push(day);
      console.error(JSON.stringify({ msg: 'rollup day failed', day, err: String(err) }));
    }
  }

  let purge: PurgeResult | null = null;
  try {
    purge = await purgeOldEvents(env, cutoff);
  } catch (err) {
    console.error(JSON.stringify({ msg: 'purge failed', cutoff, err: String(err) }));
  }

  console.log(
    JSON.stringify({
      msg: 'nightly rollup',
      days: rolled,
      rows,
      failed: failed.length,
      retention_days: keepDays,
      purged_before: cutoff,
      purged: purge?.deleted ?? null,
      purge_batches: purge?.batches ?? null,
      purge_capped: purge?.capped ?? null,
      ms: Date.now() - started,
    }),
  );

  if (failed.length > 0 || purge === null) {
    throw new Error(`nightly rollup incomplete: ${failed.length} day(s) failed, purge ${purge ? 'ok' : 'failed'}`);
  }
}

// ---------------------------------------------------------------------------
// POST /admin/rollup — manual backfill / repair