定期ジョブの取りこぼしに二週間気づけなかったのは、成功ログだけを見ていたからです

// ジョブの先頭で1行追記する（成功・失敗に関係なく必ず書く）
import { appendFileSync } from "node:fs";
 
function stamp(processed = 0, status = "started") {
  const now = new Date();
  const jst = new Date(now.getTime() + 9 * 60 * 60 * 1000);
  const row = {
    date: jst.toISOString().slice(0, 10),
    at: jst.toISOString().slice(11, 16), // "04:31"
    processed,
    status,
  };
  appendFileSync("ledger.jsonl", JSON.stringify(row) + "\n");
}

// ledger.mjs — 期待発火スロットと実行記録を突き合わせる
// 使い方: node ledger.mjs ledger.jsonl 2026-08-10 2026-08-23
import { readFileSync } from "node:fs";
 
const SLOTS = ["04:30", "16:30"]; // 1日に発火すべき時刻（JST）
const TOLERANCE_MIN = 20;         // 遅延の許容幅
 
const toMin = (hhmm) => {
  const [h, m] = hhmm.split(":").map(Number);
  return h * 60 + m;
};
 
function loadLedger(path) {
  const rows = [];
  for (const line of readFileSync(path, "utf8").split("\n")) {
    const s = line.trim();
    if (!s) continue;
    try {
      const r = JSON.parse(s);
      if (r.date && r.at) rows.push(r);
    } catch {
      // 壊れた行があっても集計を止めない（欠落検出のほうが優先）
    }
  }
  return rows;
}
 
function eachDate(from, to) {
  const out = [];
  for (
    let d = new Date(`${from}T00:00:00Z`);
    d <= new Date(`${to}T00:00:00Z`);
    d.setUTCDate(d.getUTCDate() + 1)
  ) {
    out.push(d.toISOString().slice(0, 10));
  }
  return out;
}
 
export function audit(path, from, to) {
  const rows = loadLedger(path);
  const byDate = new Map();
  for (const r of rows) {
    if (!byDate.has(r.date)) byDate.set(r.date, []);
    byDate.get(r.date).push(r);
  }
 
  const missing = [];
  let expected = 0;
  let matched = 0;
 
  for (const date of eachDate(from, to)) {
    const runs = byDate.get(date) ?? [];
    for (const slot of SLOTS) {
      expected += 1;
      const hit = runs.find(
        (r) => Math.abs(toMin(r.at) - toMin(slot)) <= TOLERANCE_MIN
      );
      if (hit) matched += 1;
      else missing.push({ date, slot });
    }
  }
  return { expected, matched, missing, coverage: matched / expected };
}
 
const [, , path, from, to] = process.argv;
const r = audit(path, from, to);
console.log(
  `期待 ${r.expected} 回 / 実行 ${r.matched} 回 / 充足率 ${(r.coverage * 100).toFixed(1)}%`
);
console.log(
  `欠落 ${r.missing.length} 回:`,
  r.missing.slice(0, 5).map((m) => `${m.date} ${m.slot}`).join(", "),
  r.missing.length > 5 ? "…" : ""
);
process.exitCode = r.missing.length === 0 ? 0 : 1;

// backlog.mjs — 未処理キューが減っているかを見る
// 成功ログが並んでいても、供給に処理が追いついていなければ滞留は増え続ける
import { readFileSync } from "node:fs";
 
const WINDOW = 7;      // 直近7点で傾きを見る
const SLOPE_LIMIT = 0; // 1日あたりの増加がこれを超えたら異常
 
function slope(ys) {
  const n = ys.length;
  const xs = ys.map((_, i) => i);
  const mx = xs.reduce((a, b) => a + b, 0) / n;
  const my = ys.reduce((a, b) => a + b, 0) / n;
  let num = 0;
  let den = 0;
  for (let i = 0; i < n; i++) {
    num += (xs[i] - mx) * (ys[i] - my);
    den += (xs[i] - mx) ** 2;
  }
  return den === 0 ? 0 : num / den;
}
 
export function checkBacklog(points) {
  const recent = points.slice(-WINDOW);
  const s = slope(recent.map((p) => p.pending));
  return {
    from: recent[0],
    to: recent.at(-1),
    slopePerDay: Number(s.toFixed(2)),
    healthy: s <= SLOPE_LIMIT,
    daysToDouble: s > 0 ? Math.ceil(recent.at(-1).pending / s) : null,
  };
}
 
const points = JSON.parse(readFileSync(process.argv[2], "utf8"));
const r = checkBacklog(points);
console.log(`${r.from.date} pending=${r.from.pending} → ${r.to.date} pending=${r.to.pending}`);
console.log(
  `傾き ${r.slopePerDay} 件/日 / 判定 ${r.healthy ? "OK" : "滞留増加"}` +
    (r.daysToDouble ? ` / このペースで倍増まで ${r.daysToDouble} 日` : "")
);
process.exitCode = r.healthy ? 0 : 1;