マルチエージェントパターン

graph TD
    subgraph "並列パターン"
        P1["メイン"] --> PA["エージェントA"]
        P1 --> PB["エージェントB"]
        PA --> PR["結果統合"]
        PB --> PR
    end

graph LR
    subgraph "直列パターン"
        S1["エージェントA"] --> S2["エージェントB"] --> S3["エージェントC"]
    end

graph TD
    subgraph "階層パターン"
        H1["統括エージェント"]
        H1 --> H2["中間エージェント1"]
        H1 --> H3["中間エージェント2"]
        H2 --> H4["末端エージェントA"]
        H2 --> H5["末端エージェントB"]
    end

graph LR
    A["調査サブエージェント"] -->|"調査結果（生データ）"| M["メインエージェント"]
    M -->|"要点を整形した指示"| B["実装サブエージェント"]
    B -->|"diff"| M
    M -->|"diff + レビュー観点"| C["レビューサブエージェント"]
 
    style M fill:#fff3e0,stroke:#e65100

graph LR
    A["query() #1<br/>調査"] -->|"result文字列"| Code["呼び出し側のコード"]
    Code -->|"プロンプトに埋め込み"| B["query() #2<br/>実装"]
    B -->|"result文字列"| Code2["呼び出し側のコード"]
    Code2 -->|"プロンプトに埋め込み"| C["query() #3<br/>レビュー"]
 
    style Code fill:#e8f4fd,stroke:#1a73e8
    style Code2 fill:#e8f4fd,stroke:#1a73e8

---
name: bug-investigator
description: バグの原因を調査する。再現条件・関連コード・根本原因を特定する。バグ報告を受けたときに使用する。
tools: Read, Grep, Glob, Bash
---
 
報告されたバグについて、関連するコードを調査し、以下を報告してください。
 
1. 再現条件（どんな入力・操作で発生するか）
2. 根本原因と考えられる箇所（ファイルパス・行番号付き）
3. 修正方針の提案（複数ある場合は選択肢として）
 
実装はしないでください。調査と原因特定に専念してください。

---
name: bug-fixer
description: 調査済みのバグを修正実装する。bug-investigatorの調査結果を受け取って実装する。
tools: Read, Edit, Write, Bash
---
 
渡された調査結果（根本原因・修正方針）に基づいて、修正を実装してください。
実装後、関連するテストを実行して結果を報告してください。
テストが存在しない場合は、再発防止のためのテストも追加してください。

---
name: fix-reviewer
description: バグ修正の実装をレビューする。実装の妥当性とエッジケースの考慮漏れを確認する。
tools: Read, Bash
---
 
実装されたバグ修正の diff をレビューしてください。
 
- 報告されたバグが実際に解消されているか
- 修正によって新たな問題が生まれていないか（副作用・エッジケース）
- テストが修正内容を適切にカバーしているか
 
指摘は「ブロッカー」「推奨」「問題なし」の3区分で報告してください。

次の手順でログイン画面のバグを修正して。
 
1. bug-investigatorサブエージェントで「ログイン後にリダイレクトが2回発生する」
   バグの原因を調査する
2. 調査結果をもとに、bug-fixerサブエージェントで修正を実装する
3. 実装結果をfix-reviewerサブエージェントでレビューする
4. レビューでブロッカーがあれば、bug-fixerに差し戻して再修正する

import { query } from "@anthropic-ai/claude-agent-sdk";
 
async function runResultText(prompt: string, allowedTools: string[]): Promise<string> {
  let result = "";
  for await (const message of query({ prompt, options: { allowedTools } })) {
    if (message.type === "result" && message.subtype === "success") {
      result = message.result;
    }
  }
  return result;
}
 
async function fixBugPipeline(bugReport: string) {
  // ステージ1: 調査（読み取り専用ツールのみ許可）
  const investigation = await runResultText(
    `次のバグについて、原因調査だけを行い、実装はしないでください。\n\nバグ報告: ${bugReport}`,
    ["Read", "Grep", "Glob", "Bash"]
  );
  console.log("=== 調査結果 ===\n", investigation);
 
  // ステージ2: 実装(調査結果を明示的にプロンプトへ埋め込む)
  const implementation = await runResultText(
    `以下の調査結果に基づいて修正を実装し、テストを実行してください。\n\n調査結果:\n${investigation}`,
    ["Read", "Edit", "Write", "Bash"]
  );
  console.log("=== 実装結果 ===\n", implementation);
 
  // ステージ3: レビュー(実装結果を渡す。読み取り専用)
  const review = await runResultText(
    `次の実装内容をレビューし、「ブロッカー」「推奨」「問題なし」の3区分で報告してください。\n\n実装結果:\n${implementation}`,
    ["Read", "Bash"]
  );
  console.log("=== レビュー結果 ===\n", review);
 
  return { investigation, implementation, review };
}
 
fixBugPipeline("ログイン後にリダイレクトが2回発生する");

async function fixBugPipelineWithRetry(bugReport: string, maxRetries = 2) {
  const investigation = await runResultText(
    `次のバグについて原因調査だけを行ってください。\n\nバグ報告: ${bugReport}`,
    ["Read", "Grep", "Glob", "Bash"]
  );
 
  let implementation = await runResultText(
    `以下の調査結果に基づいて修正を実装してください。\n\n調査結果:\n${investigation}`,
    ["Read", "Edit", "Write", "Bash"]
  );
 
  for (let attempt = 0; attempt < maxRetries; attempt++) {
    const review = await runResultText(
      `次の実装をレビューし、ブロッカーがあれば具体的に指摘してください。先頭に「ブロッカーあり」か「問題なし」と明記すること。\n\n実装結果:\n${implementation}`,
      ["Read", "Bash"]
    );
 
    if (review.startsWith("問題なし")) {
      console.log("レビュー完了:", review);
      return { investigation, implementation, review };
    }
 
    // ブロッカーが残っている場合は、レビュー指摘を踏まえて再実装する
    console.log(`再修正が必要 (試行 ${attempt + 1}/${maxRetries}):`, review);
    implementation = await runResultText(
      `以下のレビュー指摘を踏まえて修正してください。\n\nレビュー指摘:\n${review}\n\n元の実装:\n${implementation}`,
      ["Read", "Edit", "Write", "Bash"]
    );
  }
 
  throw new Error("最大リトライ回数に達しましたが、レビューを通過できませんでした");
}