第9章 — Workflow: オーケストラの指揮者

// 60ファイルを並列にリファクタリング
const results = await pipeline(
  files,
  // ステージ1: 各ファイルを分析
  (file) => agent(`Analyze ${file} for auth patterns`, {
    label: `analyze:${file}`,
    phase: 'Analyze'
  }),
  // ステージ2: 変換
  (analysis, file) => agent(`Refactor ${file}: ${analysis}`, {
    label: `refactor:${file}`,
    phase: 'Refactor',
    isolation: 'worktree'
  })
)

// 全レビューを集めてから重複排除
const allFindings = await parallel(
  dimensions.map(d => () =>
    agent(d.prompt, { schema: FINDINGS_SCHEMA })
  )
)
const deduped = dedup(allFindings.flat())

export const meta = {
  name: 'auth-migration',
  description: 'JWT 認証を OAuth に移行する',
  phases: [
    { title: 'Discover', detail: '影響ファイルを特定' },
    { title: 'Migrate', detail: '各ファイルを変換' },
    { title: 'Verify', detail: 'テストと監査' },
  ],
}
 
// Phase 1: 影響範囲の特定
phase('Discover')
const discovery = await agent(
  'grep で JWT 関連のパターンを検索し、影響ファイルの一覧を返せ',
  { schema: { type: 'object', properties: {
    files: { type: 'array', items: { type: 'string' } }
  }}}
)
 
log(`${discovery.files.length} ファイルを発見`)
 
// Phase 2: 各ファイルを並列に変換
phase('Migrate')
const results = await pipeline(
  discovery.files,
  // 分析
  (file) => agent(
    `${file} の JWT 認証パターンを分析し、OAuth への変換計画を立てよ`,
    { label: `plan:${file}`, phase: 'Migrate', effort: 'low' }
  ),
  // 変換（worktree で隔離）
  (plan, file) => agent(
    `${file} を以下の計画に従って変換せよ: ${plan}`,
    { label: `migrate:${file}`, phase: 'Migrate', isolation: 'worktree' }
  )
)
 
// Phase 3: 検証
phase('Verify')
const testResult = await agent('pnpm test を実行し、結果を報告せよ')
const auditResult = await agent(
  '変更されたファイルのセキュリティ監査を実施せよ',
  { agentType: 'security-auditor' }
)
 
return { migrated: results.filter(Boolean).length, testResult, auditResult }

// 3人の独立した検証者で多数決
const votes = await parallel(
  Array.from({ length: 3 }, () => () =>
    agent(
      `この発見を反駁せよ: ${finding.description}。
       不確かなら refuted=true とせよ`,
      { schema: VERDICT_SCHEMA }
    )
  )
)
const confirmed = votes.filter(Boolean)
  .filter(v => !v.refuted).length >= 2

const seen = new Set()
let dryRounds = 0
 
while (dryRounds < 2) {
  const found = await agent(
    'まだ見つかっていないバグを探せ',
    { schema: BUGS_SCHEMA }
  )
  const fresh = found.bugs.filter(b => !seen.has(b.id))
 
  if (fresh.length === 0) {
    dryRounds++
    continue
  }
 
  dryRounds = 0
  fresh.forEach(b => seen.add(b.id))
  log(`${seen.size} 件のバグを発見`)
}

const critic = await agent(
  `以下の分析結果を見て、欠けている観点を指摘せよ:
   ${JSON.stringify(allResults)}
   - 調査されていないファイル種別はないか
   - 検証されていない主張はないか
   - 見落とされているエッジケースはないか`,
  { label: 'completeness-critic' }
)

// 探索は安く
agent('ファイルを探せ', { effort: 'low' })
 
// 分析は中程度
agent('コードを分析せよ', { effort: 'medium' })
 
// 実装は深く
agent('リファクタリングせよ', { effort: 'high' })
 
// 検証は最も深く
agent('セキュリティ監査せよ', { effort: 'xhigh' })