Merge branch 'feature/agent-orchestration-system'

Author: ScientiaCapital

docs/plans/2025-11-17-agent-orchestration-mvp.md

@@ -18,7 +18,7 @@ module.exports = {
   coverageReporters: ['text', 'lcov', 'html'],
   setupFilesAfterEnv: ['<rootDir>/tests/setup.ts'],
   testTimeout: 10000,
-  moduleNameMapping: {
+  moduleNameMapper: {
     '^@/(.*)$': '<rootDir>/src/$1'
   }
 };

jest.config.js

@@ -19,7 +19,8 @@
     "test:e2e:debug": "playwright test --debug",
     "test:e2e:report": "playwright show-report",
     "test:e2e:comprehensive": "tsx scripts/run-comprehensive-e2e.ts",
-    "test:e2e:validate": "playwright test tests/e2e/validation/comprehensive-validation.spec.ts"
+    "test:e2e:validate": "playwright test tests/e2e/validation/comprehensive-validation.spec.ts",
+    "orchestrator:use": "tsx scripts/set-orchestrator.ts"
   },
   "dependencies": {
     "@anthropic-ai/sdk": "^0.68.0",

package-lock.json

@@ -0,0 +1,54 @@
+#!/usr/bin/env node
+import fs from 'fs'
+import path from 'path'
+
+const validModels = [
+  'claude-sonnet-4.5',
+  'claude-opus-4',
+  'deepseek-r1',
+  'kimi-k1.5',
+  'llama-3.3-70b',
+  'qwen-2.5-coder-32b'
+]
+
+const model = process.argv[2]
+
+if (!model) {
+  console.error('Usage: npm run orchestrator:use <model>')
+  console.log('Available models:')
+  validModels.forEach(m => console.log(`  - ${m}`))
+  process.exit(1)
+}
+
+if (!validModels.includes(model)) {
+  console.error(`Invalid model: ${model}`)
+  console.log('Available models:')
+  validModels.forEach(m => console.log(`  - ${m}`))
+  process.exit(1)
+}
+
+// Update .env file
+const envPath = path.join(process.cwd(), '.env')
+const envExamplePath = path.join(process.cwd(), '.env.example')
+
+let envContent = ''
+
+if (fs.existsSync(envPath)) {
+  envContent = fs.readFileSync(envPath, 'utf-8')
+} else if (fs.existsSync(envExamplePath)) {
+  envContent = fs.readFileSync(envExamplePath, 'utf-8')
+}
+
+// Update or add ORCHESTRATOR_MODEL
+const modelRegex = /^ORCHESTRATOR_MODEL=.*/m
+if (modelRegex.test(envContent)) {
+  envContent = envContent.replace(modelRegex, `ORCHESTRATOR_MODEL=${model}`)
+} else {
+  envContent += `\nORCHESTRATOR_MODEL=${model}\n`
+}
+
+fs.writeFileSync(envPath, envContent)
+
+console.log(`✅ Orchestrator model set to: ${model}`)
+console.log(`📝 Updated .env file`)
+console.log(`🔄 Restart your dev server to apply changes`)

package.json

@@ -0,0 +1,131 @@
+import { BaseAgent } from './BaseAgent'
+import { ProjectWorkspace } from '@/services/workspace/ProjectWorkspace'
+import { AgentOutput, ProjectContext } from '@/types/orchestrator'
+
+export interface BackendDeveloperContext {
+  projectId: string
+  userRequest: string
+  workspace: ProjectWorkspace
+  architecture?: any
+}
+
+export interface BackendDeveloperOutput {
+  filesCreated: string[]
+  filesModified: string[]
+  cost: number
+  duration: number
+}
+
+export class BackendDeveloper extends BaseAgent {
+  agentType = 'BackendDeveloper' as const
+
+  private workspace: ProjectWorkspace
+  private userRequest: string
+  private architecture?: any
+
+  constructor(context: BackendDeveloperContext) {
+    // Create a minimal ProjectContext for BaseAgent
+    const projectContext: ProjectContext = {
+      state: {
+        userRequest: context.userRequest,
+        userId: 'test-user',
+        organizationId: 'test-org',
+        projectId: context.projectId,
+        projectName: context.projectId,
+        createdAt: new Date().toISOString(),
+        agentsSpawned: [],
+        agentOutputs: {},
+        errors: [],
+        retryCount: 0,
+      },
+      organizationId: 'test-org',
+      userId: 'test-user',
+      costOptimizerUrl: process.env.COST_OPTIMIZER_URL || 'http://localhost:3001',
+      costOptimizerApiKey: process.env.COST_OPTIMIZER_API_KEY || 'test-key',
+    }
+
+    super('BackendDeveloper', projectContext)
+    this.workspace = context.workspace
+    this.userRequest = context.userRequest
+    this.architecture = context.architecture
+  }
+
+  async execute(): Promise<AgentOutput> {
+    const startTime = Date.now()
+
+    try {
+      // TODO: Load skills (test-driven-development, api-design-patterns, security-best-practices)
+      // TODO: Use MCP tools (context7, sequential-thinking, supabase)
+
+      // For MVP: Generate simple API file structure
+      const prompt = this.buildPrompt()
+      const response = await this.think({ prompt, complexity: 'simple' })
+
+      // Parse response and generate files
+      const files = await this.generateFiles(response)
+
+      this.output.duration = Date.now() - startTime
+
+      return this.getOutput()
+    } catch (error) {
+      console.error('[BackendDeveloper] Error:', error)
+      this.addError(`BackendDeveloper execution failed: ${error}`)
+      this.output.duration = Date.now() - startTime
+      return this.getOutput()
+    }
+  }
+
+  private buildPrompt(): string {
+    return `You are a backend developer agent. Generate TypeScript files for the following request:
+
+User Request: ${this.userRequest}
+
+${this.architecture ? `Architecture Context:\n${JSON.stringify(this.architecture, null, 2)}\n` : ''}
+
+Generate a simple API structure with:
+1. API route file (app/api/[resource]/route.ts)
+2. Service layer file (src/services/[resource]Service.ts)
+3. Type definitions (src/types/[resource].ts)
+
+Return a JSON array of files:
+[
+  {
+    "path": "app/api/todos/route.ts",
+    "content": "import { NextRequest, NextResponse } from 'next/server'..."
+  },
+  {
+    "path": "src/services/todoService.ts",
+    "content": "export class TodoService { ... }"
+  }
+]
+
+Keep it simple and focused. Use Next.js 15 patterns.`
+  }
+
+  private async generateFiles(response: string): Promise<string[]> {
+    try {
+      // Try to parse JSON response
+      const files = JSON.parse(response)
+      const createdFiles: string[] = []
+
+      for (const file of files) {
+        await this.workspace.writeFile(file.path, file.content)
+        createdFiles.push(file.path)
+
+        // Track file creation using BaseAgent method
+        this.addFileCreated(file.path)
+      }
+
+      return createdFiles
+    } catch (error) {
+      // If JSON parsing fails, create a single example file
+      console.warn('[BackendDeveloper] Failed to parse response, creating example file')
+
+      const exampleFile = 'src/example-generated.ts'
+      await this.workspace.writeFile(exampleFile, `// Generated by BackendDeveloper\n// Request: ${this.userRequest}\n\nexport const placeholder = true;`)
+
+      this.addFileCreated(exampleFile)
+      return [exampleFile]
+    }
+  }
+}

scripts/set-orchestrator.ts

@@ -0,0 +1,3 @@
+export { BaseAgent } from './BaseAgent'
+export { CodeArchitect } from './CodeArchitect'
+export { BackendDeveloper } from './BackendDeveloper'

src/agents/BackendDeveloper.ts

@@ -0,0 +1,54 @@
+import { NextRequest, NextResponse } from 'next/server'
+import { AgentOrchestrator } from '@/orchestrator/AgentOrchestrator'
+import { CodebaseReview } from '@/types/events'
+
+export async function POST(request: NextRequest) {
+  try {
+    // Parse request body
+    const body = await request.json()
+    const { projectPath } = body
+
+    // Validation
+    if (!projectPath || typeof projectPath !== 'string') {
+      return NextResponse.json(
+        { error: 'projectPath is required and must be a string' },
+        { status: 400 }
+      )
+    }
+
+    // Get orchestrator instance
+    const orchestrator = AgentOrchestrator.getInstance()
+
+    // Trigger review
+    const review: CodebaseReview = await orchestrator.reviewCodebase(projectPath)
+
+    // Return result
+    return NextResponse.json(
+      {
+        success: true,
+        data: review
+      },
+      { status: 200 }
+    )
+  } catch (error) {
+    console.error('❌ Review API error:', error)
+
+    return NextResponse.json(
+      {
+        success: false,
+        error: error instanceof Error ? error.message : 'Unknown error occurred'
+      },
+      { status: 500 }
+    )
+  }
+}
+
+// Optional: GET endpoint to check API health
+export async function GET(request: NextRequest) {
+  return NextResponse.json({
+    status: 'ok',
+    endpoint: '/api/orchestrator/review',
+    methods: ['POST'],
+    description: 'Trigger codebase review and analysis'
+  })
+}