Claude Codeのソースコード漏洩から生まれた軽量マルチエージェントOSS「open-multi-agent」

import { OpenMultiAgent } from '@jackchen_me/open-multi-agent';

const orchestrator = new OpenMultiAgent();

// チームメンバーを定義
const team = orchestrator.createTeam([
  {
    name: 'architect',
    model: 'claude-sonnet-4-6',
    systemPrompt: 'You design clean API contracts and system architecture.',
    tools: ['file_write'],
  },
  {
    name: 'developer',
    model: 'claude-sonnet-4-6',
    systemPrompt: 'You implement designs with clean, testable code.',
    tools: ['bash', 'file_read', 'file_write', 'file_edit'],
  },
  {
    name: 'reviewer',
    model: 'gpt-4o',  // モデルを混在させることも可能
    systemPrompt: 'You review code for quality and security.',
    tools: ['file_read', 'grep'],
  },
]);

// ゴールを指定して実行（タスク分解は自動）
const result = await orchestrator.runTeam(
  team,
  'Create a REST API for a todo list with CRUD operations, tests, and OpenAPI docs'
);

console.log(result.output);
console.log(`Completed in ${result.duration}ms`);

import { OpenMultiAgent, Task } from '@jackchen_me/open-multi-agent';

const orchestrator = new OpenMultiAgent();
const team = orchestrator.createTeam([/* エージェント定義 */]);

// タスクをDAGとして明示的に定義
const tasks: Task[] = [
  {
    id: 'fetch_requirements',
    agent: 'architect',
    prompt: 'Analyze the requirements from requirements.md',
    // 依存なし → 最初に実行
  },
  {
    id: 'design_api',
    agent: 'architect',
    prompt: 'Design the API contract based on requirements',
    dependsOn: ['fetch_requirements'],  // fetch_requirementsの後に実行
  },
  {
    id: 'implement_endpoints',
    agent: 'developer',
    prompt: 'Implement the API endpoints from the design',
    dependsOn: ['design_api'],
  },
  {
    id: 'write_tests',
    agent: 'developer',
    prompt: 'Write integration tests for the endpoints',
    dependsOn: ['implement_endpoints'],
  },
  {
    id: 'security_review',
    agent: 'reviewer',
    prompt: 'Review the implementation for security vulnerabilities',
    dependsOn: ['implement_endpoints'],  // implement_endpointsの後、testsと並列実行
  },
  {
    id: 'final_review',
    agent: 'reviewer',
    prompt: 'Final code review incorporating all feedback',
    dependsOn: ['write_tests', 'security_review'],  // 両方完了後に実行
  },
];

const result = await orchestrator.runTasks(team, tasks);

import { z } from 'zod';
import { OpenMultiAgent } from '@jackchen_me/open-multi-agent';

const AnalysisSchema = z.object({
  summary: z.string(),
  issues: z.array(z.object({
    severity: z.enum(['critical', 'high', 'medium', 'low']),
    description: z.string(),
    file: z.string().optional(),
  })),
  recommendations: z.array(z.string()),
  score: z.number().min(0).max(100),
});

const orchestrator = new OpenMultiAgent();

const result = await orchestrator.runAgent({
  name: 'security_analyzer',
  model: 'claude-sonnet-4-6',
  systemPrompt: 'You are a security expert analyzing codebases.',
  tools: ['file_read', 'grep'],
  outputSchema: AnalysisSchema,  // Zodスキーマを指定
}, 'Analyze the security of the current codebase');

// result.outputはAnalysisSchema型として型安全に使える
console.log(`Security score: ${result.output.score}/100`);
result.output.issues
  .filter(i => i.severity === 'critical')
  .forEach(i => console.error(`CRITICAL: ${i.description}`));

const orchestrator = new OpenMultiAgent({
  onTrace: (event) => {
    // LLMコール、ツール実行、エラーをリアルタイム追跡
    if (event.type === 'llm_call') {
      console.log(`[${event.agent}] ${event.model} - ${event.tokens} tokens`);
    } else if (event.type === 'tool_use') {
      console.log(`[${event.agent}] Using tool: ${event.tool}`);
    } else if (event.type === 'task_complete') {
      console.log(`Task "${event.taskId}" completed in ${event.duration}ms`);
    }
  },
});

// 費用のかかるタスクはクラウドAPIに、センシティブな処理はローカルに
const team = orchestrator.createTeam([
  {
    name: 'planner',
    model: 'claude-sonnet-4-6',  // 高精度な計画立案
    systemPrompt: 'You decompose complex goals into sub-tasks.',
    tools: [],
  },
  {
    name: 'local_processor',
    model: 'ollama/llama3.2',    // ローカルモデルで機密データ処理
    systemPrompt: 'You process sensitive internal data.',
    tools: ['file_read', 'file_write'],
    baseURL: 'http://localhost:11434/v1',  // Ollama endpoint
  },
]);