モデルは残るのにパラメータだけ期限切れになる — Claude API リクエストの廃止を日付で先回りする設計

interface OutgoingRequest {
  model: string;
  params?: Record<string, string | number | boolean>;
  betaHeaders?: string[];
}
 
function decompose(req: OutgoingRequest): RequestPart[] {
  const parts: RequestPart[] = [{ kind: "model", value: req.model }];
 
  for (const [k, v] of Object.entries(req.params ?? {})) {
    parts.push({ kind: "param", value: `${k}=${v}` });
  }
  for (const b of req.betaHeaders ?? []) {
    parts.push({ kind: "beta", value: b });
  }
  return parts;
}

const partKey = (p: RequestPart) => `${p.kind}:${p.value}`;
 
// req が entry.when をすべて含んでいるか
function matches(reqParts: RequestPart[], entry: DeprecationEntry): boolean {
  const have = new Set(reqParts.map(partKey));
  return entry.when.every((w) => have.has(partKey(w)));
}

type Verdict =
  | { level: "ok" }
  | { level: "warn"; daysLeft: number; entry: DeprecationEntry }
  | { level: "expired"; entry: DeprecationEntry };
 
const DAY = 24 * 60 * 60 * 1000;
 
function evaluate(
  req: OutgoingRequest,
  now: Date,
  warnWindowDays: number,
): Verdict[] {
  const parts = decompose(req);
  const verdicts: Verdict[] = [];
 
  for (const entry of DEPRECATION_CALENDAR) {
    if (!matches(parts, entry)) continue;
 
    // タイムゾーン付き文字列を Date にすれば、比較は UTC 上で正しく行われる
    const effective = new Date(entry.effectiveAt).getTime();
    const diff = effective - now.getTime();
 
    if (diff <= 0) {
      verdicts.push({ level: "expired", entry });
    } else if (diff <= warnWindowDays * DAY) {
      verdicts.push({ level: "warn", daysLeft: Math.ceil(diff / DAY), entry });
    }
  }
 
  if (verdicts.length === 0) verdicts.push({ level: "ok" });
  return verdicts;
}

function preflight(req: OutgoingRequest, warnWindowDays = 14): void {
  const verdicts = evaluate(req, new Date(), warnWindowDays);
 
  for (const v of verdicts) {
    if (v.level === "warn") {
      console.warn(
        `[deprecation] あと${v.daysLeft}日で失効: ${JSON.stringify(v.entry.when)} → ${v.entry.migrateTo}（出典: ${v.entry.source}）`,
      );
    } else if (v.level === "expired") {
      // 呼ぶ前に、はっきり止める
      throw new Error(
        `[deprecation] 失効済みのリクエスト部品: ${JSON.stringify(v.entry.when)}。移行先: ${v.entry.migrateTo}（出典: ${v.entry.source}）`,
      );
    }
  }
}

function runScheduledBatch(req: OutgoingRequest) {
  preflight(req);          // 期限切れならここで throw し、API を叩かない
  // …実際の Messages API 呼び出し…
}

import { test, expect } from "vitest";
 
// 実際にスケジュールタスクが投げる設定を集めた配列（実運用の真実を反映させる）
import { LIVE_REQUESTS } from "./live-requests";
 
test("失効済みの部品を含む稼働中リクエストが存在しない", () => {
  const now = new Date();
  for (const req of LIVE_REQUESTS) {
    const verdicts = evaluate(req, now, 0);
    const expired = verdicts.filter((v) => v.level === "expired");
    expect(
      expired,
      `失効済み設定が残っています: ${JSON.stringify(req)}`,
    ).toHaveLength(0);
  }
});
 
test("カレンダーの各行は出典と移行先を持つ", () => {
  for (const entry of DEPRECATION_CALENDAR) {
    expect(entry.source.length).toBeGreaterThan(0);
    expect(entry.migrateTo.length).toBeGreaterThan(0);
  }
});