自律エージェントの破壊的操作に事前条件・事後条件の契約ゲートを付ける

// contract-gate.ts
export type GuardResult = { ok: true } | { ok: false; reason: string };
 
export interface Contract<Ctx> {
  name: string;
  // 適用前に検査する不変条件。複数返してよい。
  pre: (ctx: Ctx) => Promise<GuardResult[]> | GuardResult[];
  // 巻き戻しに必要な状態を捕捉する。
  snapshot: (ctx: Ctx) => Promise<unknown> | unknown;
  // 実際の破壊的操作。
  apply: (ctx: Ctx) => Promise<void> | void;
  // 適用後に検査する不変条件。
  post: (ctx: Ctx) => Promise<GuardResult[]> | GuardResult[];
  // 事後条件が破れたときに snapshot まで戻す。冪等であること。
  rollback: (ctx: Ctx, snapshot: unknown) => Promise<void> | void;
}
 
export class ContractViolation extends Error {
  constructor(
    public phase: "pre" | "post",
    public contract: string,
    public reasons: string[],
  ) {
    super(`[${contract}] ${phase} 条件違反: ${reasons.join("; ")}`);
    this.name = "ContractViolation";
  }
}
 
export async function runWithContract<Ctx>(
  contract: Contract<Ctx>,
  ctx: Ctx,
): Promise<void> {
  // 1. 事前条件
  const preResults = await contract.pre(ctx);
  const preFailed = preResults.filter((r) => !r.ok) as { reason: string }[];
  if (preFailed.length > 0) {
    throw new ContractViolation("pre", contract.name, preFailed.map((r) => r.reason));
  }
 
  // 2. 巻き戻し点
  const snap = await contract.snapshot(ctx);
 
  // 3. 適用
  await contract.apply(ctx);
 
  // 4. 事後条件 → 破れていたら巻き戻す
  const postResults = await contract.post(ctx);
  const postFailed = postResults.filter((r) => !r.ok) as { reason: string }[];
  if (postFailed.length > 0) {
    await contract.rollback(ctx, snap);
    throw new ContractViolation("post", contract.name, postFailed.map((r) => r.reason));
  }
}

// 記事を公開するツールに契約ゲートを被せる例
import { runWithContract, type Contract } from "./contract-gate";
import { execSync } from "node:child_process";
import { readdirSync } from "node:fs";
 
interface PublishCtx {
  repoPath: string;
  jaFile: string;
  enFile: string;
}
 
const publishContract: Contract<PublishCtx> = {
  name: "publish-article",
  pre: (ctx) => {
    const results = [];
    // 事前条件1: 日英ファイルが両方そろっている
    results.push(
      ctx.jaFile && ctx.enFile
        ? { ok: true as const }
        : { ok: false as const, reason: "日本語版または英語版が欠落しています" },
    );
    // 事前条件2: 作業ツリーがクリーンで、想定外の変更がない
    const dirty = execSync(`git -C ${ctx.repoPath} status --porcelain`).toString().trim();
    const unexpected = dirty.split("\n").filter((l) => l && !l.includes("content/articles/"));
    results.push(
      unexpected.length === 0
        ? { ok: true as const }
        : { ok: false as const, reason: `想定外の変更: ${unexpected.join(", ")}` },
    );
    return results;
  },
  snapshot: (ctx) =>
    execSync(`git -C ${ctx.repoPath} rev-parse HEAD`).toString().trim(),
  apply: (ctx) => {
    execSync(`git -C ${ctx.repoPath} add content/`);
    execSync(`git -C ${ctx.repoPath} commit -m "Add: article (JA+EN)"`);
  },
  post: (ctx) => {
    const ja = readdirSync(`${ctx.repoPath}/content/articles/ja`, { recursive: true })
      .filter((f) => String(f).endsWith(".mdx")).length;
    const en = readdirSync(`${ctx.repoPath}/content/articles/en`, { recursive: true })
      .filter((f) => String(f).endsWith(".mdx")).length;
    // 事後条件: コミット後、日英の本数が一致している
    return [
      ja === en
        ? { ok: true as const }
        : { ok: false as const, reason: `日英本数不一致 ja=${ja} en=${en}` },
    ];
  },
  rollback: (ctx, snap) => {
    // コミットを取り消して元の HEAD に戻す（冪等）
    execSync(`git -C ${ctx.repoPath} reset --hard ${snap}`);
  },
};
 
// ツール実行時に呼ぶ
await runWithContract(publishContract, { repoPath, jaFile, enFile });