Antigravity CLI の /effort をタスク種別で振り分ける — 6週間の実測と、効かなかった領域

#!/usr/bin/env node
/**
 * effort-route.mjs
 * タスク記述から effort 段階を決めて Antigravity CLI(agy) を起動し、
 * 実行結果を JSONL に追記します。
 *
 *   node effort-route.mjs "AdMob の初期化を Application クラスへ移す"
 *   node effort-route.mjs --dry-run "ボタンの文言を修正"
 *   node effort-route.mjs --mark <id> accept
 */
import { spawn } from "node:child_process";
import { appendFile, readFile } from "node:fs/promises";
import { resolve, dirname } from "node:path";
import { fileURLToPath } from "node:url";
import { randomUUID } from "node:crypto";
 
const HERE = dirname(fileURLToPath(import.meta.url));
const POLICY_PATH = resolve(HERE, "effort-policy.json");
const LOG_PATH = resolve(HERE, "effort-runs.jsonl");
 
// 段階名は CLI のバージョンで変わるため、コードには埋め込まず policy 側に置きます。
const DEFAULT_POLICY = {
  fallback: "medium",
  rules: [
    { class: "mechanical",  level: "low",    match: "(typo|文言|リネーム|import 整理|フォーマット|整形)" },
    { class: "localized",   level: "medium", match: "(バグ|不具合|fix|テスト追加|1ファイル)" },
    { class: "structural",  level: "high",   match: "(設計|分割|移行|リファクタ|アーキ|置き換え)" },
    { class: "exploratory", level: "high",   match: "(調査|原因|なぜ|比較|検討|方針)" }
  ]
};
 
async function loadPolicy() {
  try {
    return JSON.parse(await readFile(POLICY_PATH, "utf8"));
  } catch (err) {
    if (err.code === "ENOENT") return DEFAULT_POLICY;
    // 壊れた JSON を黙って握りつぶすと全件が fallback に落ち、
    // 「なぜか全部 medium」という状態に何日も気づけません。必ず止めます。
    throw new Error(`effort-policy.json を読めませんでした: ${err.message}`);
  }
}
 
function classify(task, policy) {
  for (const rule of policy.rules) {
    if (new RegExp(rule.match, "i").test(task)) {
      return { taskClass: rule.class, level: rule.level };
    }
  }
  return { taskClass: "unclassified", level: policy.fallback };
}
 
function runAgy(task, level) {
  // 非対話起動では /effort を本文の1行目に置く形にしています。
  // 将来フラグが用意されたら、この args の組み立てだけを差し替えます。
  const prompt = `/effort ${level}\n${task}`;
  return new Promise((done) => {
    const started = Date.now();
    const child = spawn("agy", ["-p", prompt], { stdio: ["ignore", "inherit", "inherit"] });
    child.on("error", (err) =>
      done({ ok: false, code: null, ms: Date.now() - started, error: err.message })
    );
    child.on("close", (code) =>
      done({ ok: code === 0, code, ms: Date.now() - started })
    );
  });
}
 
async function main() {
  const argv = process.argv.slice(2);
 
  if (argv[0] === "--mark") {
    const [, id, verdict] = argv;
    if (!id || !["accept", "rework"].includes(verdict)) {
      console.error("usage: --mark <id> accept|rework");
      process.exit(2);
    }
    await appendFile(LOG_PATH, JSON.stringify({ type: "mark", id, verdict }) + "\n");
    return;
  }
 
  const dryRun = argv[0] === "--dry-run";
  const task = (dryRun ? argv.slice(1) : argv).join(" ").trim();
  if (!task) {
    console.error("タスク記述を渡してください");
    process.exit(2);
  }
 
  const policy = await loadPolicy();
  const { taskClass, level } = classify(task, policy);
  const id = randomUUID().slice(0, 8);
 
  console.error(`[effort-route] ${id} class=${taskClass} effort=${level}`);
  if (dryRun) return;
 
  const result = await runAgy(task, level);
  await appendFile(
    LOG_PATH,
    JSON.stringify({
      type: "run", id, taskClass, level,
      ms: result.ms, ok: result.ok, error: result.error ?? null,
      at: new Date().toISOString()
    }) + "\n"
  );
 
  console.error(`[effort-route] ${id} ${result.ok ? "ok" : "failed"} ${Math.round(result.ms / 1000)}s`);
  console.error(`[effort-route] 採用可否: node effort-route.mjs --mark ${id} accept|rework`);
  if (!result.ok) process.exit(1);
}
 
main().catch((err) => {
  console.error(`[effort-route] ${err.message}`);
  process.exit(1);
});

#!/usr/bin/env node
/** effort-report.mjs — 種別×段階ごとの一発採用率と所要時間を集計します */
import { readFile } from "node:fs/promises";
import { resolve, dirname } from "node:path";
import { fileURLToPath } from "node:url";
 
const LOG_PATH = resolve(dirname(fileURLToPath(import.meta.url)), "effort-runs.jsonl");
const lines = (await readFile(LOG_PATH, "utf8")).split("\n").filter(Boolean).map(JSON.parse);
 
const runs = new Map();
for (const e of lines) {
  if (e.type === "run") runs.set(e.id, { ...e, verdict: null });
  if (e.type === "mark" && runs.has(e.id)) runs.get(e.id).verdict = e.verdict;
}
 
const buckets = new Map();
for (const r of runs.values()) {
  if (!r.verdict) continue; // 未判定は母数から外します
  const key = `${r.taskClass}/${r.level}`;
  const b = buckets.get(key) ?? { n: 0, accepted: 0, ms: [] };
  b.n += 1;
  if (r.verdict === "accept") b.accepted += 1;
  b.ms.push(r.ms);
  buckets.set(key, b);
}
 
const p50 = (a) => [...a].sort((x, y) => x - y)[Math.floor(a.length / 2)] ?? 0;
for (const [key, b] of [...buckets].sort()) {
  const rate = ((b.accepted / b.n) * 100).toFixed(0);
  console.log(`${key.padEnd(24)} n=${String(b.n).padStart(3)}  一発採用 ${rate}%  p50 ${Math.round(p50(b.ms) / 1000)}s`);
}

---
name: mechanical-fixer
description: 正解が事前に決まっている修正だけを担当します
effort: low
---
 
## 担当する作業
- 文言・表記ゆれの修正
- リネーム、import の整理
 
## 担当しない作業
- 設計判断を伴う変更
- 依頼に書かれていない周辺の整理
 
## 完了の条件
- 依頼された箇所以外のファイルを変更していないこと
- 既存のテストが通ること