共通エージェント定義をセッション単位で差し替える運用設計

import Anthropic from "@anthropic-ai/sdk";
 
const client = new Anthropic();
 
// 土台エージェントで「許可してよい」上限。オーバーライドがこれを超えたら止める。
const TOOL_ALLOWLIST = new Set([
  "web_search",
  "bash",
  "text_editor",
]);
const MCP_ALLOWLIST = new Set([
  "mcp-claudelab",
  "mcp-gemilab",
  "mcp-antigravitylab",
  "mcp-rorklab",
]);
 
type SiteOverride = {
  site: string;
  systemPrompt: string;
  tools: string[];      // そのセッションでの最終形
  mcpServers: string[]; // そのセッションでの最終形
  skills: string[];
  model?: string;
};
 
function assertSubset(name: string, given: string[], allow: Set<string>) {
  const stray = given.filter((v) => !allow.has(v));
  if (stray.length > 0) {
    // 想定外の権限拡大を、実行前に必ず落とす
    throw new Error(
      `[override guard] ${name} に未許可の項目: ${stray.join(", ")}`
    );
  }
}
 
export function buildSessionAgent(base: string, o: SiteOverride) {
  // オーバーライドは「上書き」なので、渡す前にこちら側で境界を検証する
  assertSubset("tools", o.tools, TOOL_ALLOWLIST);
  assertSubset("mcpServers", o.mcpServers, MCP_ALLOWLIST);
 
  if (o.tools.length === 0) {
    // 空配列は「ツール無し」を意味する。事故を疑いたいので明示ログ。
    console.warn(`[override] ${o.site}: tools が空。意図的か確認すること`);
  }
 
  const overridden = {
    type: "agent_with_overrides" as const,
    agent_id: base,
    overrides: {
      model: o.model,                 // 省略時は土台のモデルを継承
      system: o.systemPrompt,
      tools: o.tools.map((name) => ({ name })),
      mcp_servers: o.mcpServers,
      skills: o.skills,
    },
  };
 
  // 何をどう差し替えたかを一行で残す。あとで挙動を追える。
  console.info(
    `[session] site=${o.site} model=${o.model ?? "(inherit)"} ` +
      `tools=${o.tools.length} mcp=${o.mcpServers.join("+")}`
  );
 
  return overridden;
}

const SITE_OVERRIDES: Record<string, SiteOverride> = {
  claudelab: {
    site: "claudelab",
    systemPrompt: "あなたは Claude 技術ブログの編集者です。敬体で書きます。",
    tools: ["web_search", "text_editor"],
    mcpServers: ["mcp-claudelab"],
    skills: ["article-gate", "templating-gate"],
  },
  rorklab: {
    site: "rorklab",
    systemPrompt: "あなたは Rork アプリ開発ブログの編集者です。敬体で書きます。",
    tools: ["web_search", "text_editor", "bash"], // Rork はビルド確認で bash を使う
    mcpServers: ["mcp-rorklab"],
    skills: ["article-gate"],
    model: "claude-opus-4-8",
  },
};
 
async function runFor(site: string) {
  const override = SITE_OVERRIDES[site];
  if (!override) throw new Error(`未定義のサイト: ${site}`);
 
  const session = await client.beta.messages.sessions.create({
    agent: buildSessionAgent("agent_blog_base", override),
  });
  return session;
}

type Delta = { add?: string[]; remove?: string[] };
 
// 土台の現在値に足し引きを適用し、「そのフィールドの最終形」と差分を返す
function applyDelta(current: string[], delta: Delta, label = "field") {
  const remove = new Set(delta.remove ?? []);
 
  // 土台側で名前が変わったのに remove 指定が古いまま、という状態を拾う
  const ghosts = [...remove].filter((n) => !current.includes(n));
  if (ghosts.length > 0) {
    console.warn(
      `[delta] ${label}: 土台に無い項目の remove 指定: ${ghosts.join(", ")}`
    );
  }
 
  const kept = current.filter((n) => !remove.has(n));
  const appended = (delta.add ?? []).filter((n) => !kept.includes(n));
  const next = [...kept, ...appended];
 
  return { next, diff: diffOf(current, next) };
}
 
function diffOf(before: string[], after: string[]): string[] {
  const b = new Set(before);
  const a = new Set(after);
  return [
    ...before.filter((n) => !a.has(n)).map((n) => `-${n}`),
    ...after.filter((n) => !b.has(n)).map((n) => `+${n}`),
  ];
}

// 土台の現在値は起動時に一度だけ取得する（メソッド名は SDK の版で変わり得ます）
const base = await client.beta.agents.retrieve("agent_blog_base");
const baseTools = (base.tools ?? []).map((t) => t.name);
 
const { next, diff } = applyDelta(baseTools, { add: ["bash"] }, "tools");
console.info(`[delta] tools ${diff.join(" ") || "(変更なし)"} -> ${next.join(", ")}`);
 
// この next を SiteOverride.tools に入れてから buildSessionAgent へ渡す

検証用に bash を足す -> [web_search, text_editor, bash] diff=[+bash]
検索を外す           -> [text_editor] diff=[-web_search]
入れ替える           -> [text_editor, bash] diff=[-web_search +bash]
既にある物を足す     -> [web_search, text_editor] diff=[]
土台に無い物を外す   -> [web_search, text_editor] diff=[]
[delta] tools: 土台に無い項目の remove 指定: computer

import { readFileSync } from "node:fs";
 
// [session] 行だけを拾う。先頭の日付は runner が付けても、行内に含めてもよい。
const LINE =
  /^(?<ts>\d{4}-\d{2}-\d{2})\S*\s+\[session\]\s+site=(?<site>\S+)\s+model=(?<model>\S+)\s+tools=(?<tools>\d+)\s+mcp=(?<mcp>\S+)/;
 
const rows = readFileSync(process.argv[2], "utf8")
  .split("\n")
  .map((l) => l.match(LINE)?.groups)
  .filter(Boolean);
 
const agg = new Map();
for (const r of rows) {
  const key = `${r.ts}\t${r.site}\t${r.model}`;
  const cur = agg.get(key) ?? { runs: 0, tools: new Set(), mcp: new Set() };
  cur.runs++;
  cur.tools.add(Number(r.tools));            // 同じ日に数が揺れたら列に残る
  r.mcp.split("+").forEach((m) => cur.mcp.add(m));
  agg.set(key, cur);
}
 
console.log(["date", "site", "model", "runs", "tools", "mcp"].join("\t"));
for (const [key, v] of [...agg].sort()) {
  const tools = [...v.tools].sort((a, b) => a - b).join("/");
  console.log([key, v.runs, tools, [...v.mcp].join(",")].join("\t"));
}
 
// 継承のまま走った回数は、土台のモデルを上げたときに波及する範囲そのもの
const inherited = rows.filter((r) => r.model === "(inherit)").length;
console.log(`\n継承(inherit)で走った回数: ${inherited} / ${rows.length}`);

date        site        model             runs  tools  mcp
2026-07-28  claudelab   (inherit)         2     1/2    mcp-claudelab
2026-07-28  gemilab     (inherit)         1     2      mcp-gemilab
2026-07-28  rorklab     claude-opus-4-8   1     3      mcp-rorklab
2026-07-29  claudelab   (inherit)         1     2      mcp-claudelab
2026-07-29  gemilab     (inherit)         1     2      mcp-gemilab,mcp-shared
2026-07-29  rorklab     claude-opus-4-8   1     3      mcp-rorklab
 
継承(inherit)で走った回数: 5 / 7

// フェーズごとの「ツールの最終形」。会話中に入れ替える想定のものを後ろへ寄せる。
const PHASE_TOOLS: Record<"research" | "edit" | "verify", string[]> = {
  research: ["text_editor", "web_search"],
  edit: ["text_editor"],
  verify: ["text_editor", "bash"],
};
 
// 次のターンに渡すツール定義を組み立てる。境界の判断はセッション生成時と共有する。
function toolsForPhase(sessionId: string, phase: keyof typeof PHASE_TOOLS) {
  const tools = PHASE_TOOLS[phase];
  assertSubset("tools", tools, TOOL_ALLOWLIST);
 
  // どのターンで権限が変わったかを、あとから追えるようにしておく
  console.info(`[phase] ${sessionId} -> ${phase} tools=${tools.join(",")}`);
 
  return tools.map((name) => ({ name }));
}