feat(qcsd): wire MCP task_orchestrate to auto-execute workflows

Issue #206: Fix gap where ideation-assessment tasks submitted via
task_orchestrate would only spawn agents but not execute the
qcsd-ideation-swarm workflow.

Changes:
- Add WorkflowOrchestrator to MCP FleetState
- Initialize and register domain workflow actions during fleet_init
- Add TASK_WORKFLOW_MAP mapping TaskType to workflow IDs
- Modify handleTaskOrchestrate to execute workflows for mapped types
- Return status 'workflow-started' with execution ID for workflow tasks

Now calling task_orchestrate with QCSD keywords automatically executes
the qcsd-ideation-swarm workflow with proper input mapping.

Co-Authored-By: Claude Opus 4.5 <[email protected]>

Author: Lalit

v3/src/mcp/handlers/core-handlers.ts

@@ -8,6 +8,7 @@ import { QEKernel } from '../../kernel/interfaces';
 import { QEKernelImpl } from '../../kernel/kernel';
 import { ALL_DOMAINS, DomainName } from '../../shared/types';
 import { QueenCoordinator, createQueenCoordinator } from '../../coordination/queen-coordinator';
+import { WorkflowOrchestrator } from '../../coordination/workflow-orchestrator';
 
 /**
  * User-facing QE domains (excludes internal 'coordination' domain)
@@ -32,6 +33,10 @@ import {
   DomainStatusResult,
 } from '../types';
 
+// Import domain plugins that register workflow actions
+import type { RequirementsValidationExtendedAPI } from '../../domains/requirements-validation/index.js';
+import type { VisualAccessibilityAPI } from '../../domains/visual-accessibility/index.js';
+
 // ============================================================================
 // Fleet State
 // ============================================================================
@@ -41,6 +46,7 @@ interface FleetState {
   kernel: QEKernel | null;
   queen: QueenCoordinator | null;
   router: CrossDomainEventRouter | null;
+  workflowOrchestrator: WorkflowOrchestrator | null;
   initialized: boolean;
   initTime: Date | null;
 }
@@ -50,6 +56,7 @@ const state: FleetState = {
   kernel: null,
   queen: null,
   router: null,
+  workflowOrchestrator: null,
   initialized: false,
   initTime: null,
 };
@@ -134,6 +141,18 @@ export async function handleFleetInit(
     );
     await state.queen.initialize();
 
+    // Create Workflow Orchestrator for workflow execution
+    state.workflowOrchestrator = new WorkflowOrchestrator(
+      state.kernel.eventBus,
+      state.kernel.memory,
+      state.kernel.coordinator
+    );
+    await state.workflowOrchestrator.initialize();
+
+    // Register domain workflow actions (Issue #206)
+    // This enables workflows like qcsd-ideation-swarm to execute their actions
+    registerDomainWorkflowActions(state.kernel, state.workflowOrchestrator);
+
     state.initialized = true;
     state.initTime = new Date();
 
@@ -321,6 +340,10 @@ export async function disposeFleet(): Promise<void> {
   resetTaskExecutor();
   resetAllToolCaches();
 
+  if (state.workflowOrchestrator) {
+    await state.workflowOrchestrator.dispose();
+    state.workflowOrchestrator = null;
+  }
   if (state.queen) {
     await state.queen.dispose();
     state.queen = null;
@@ -337,3 +360,30 @@ export async function disposeFleet(): Promise<void> {
   state.fleetId = null;
   state.initTime = null;
 }
+
+// ============================================================================
+// Domain Workflow Action Registration (Issue #206)
+// ============================================================================
+
+/**
+ * Register domain-specific workflow actions with the WorkflowOrchestrator.
+ * This enables workflows like qcsd-ideation-swarm to execute their actions.
+ */
+function registerDomainWorkflowActions(
+  kernel: QEKernel,
+  orchestrator: WorkflowOrchestrator
+): void {
+  // Register requirements-validation domain actions (including QCSD Ideation)
+  const reqValAPI = kernel.getDomainAPI<RequirementsValidationExtendedAPI>('requirements-validation');
+  if (reqValAPI?.registerWorkflowActions) {
+    reqValAPI.registerWorkflowActions(orchestrator);
+    console.log('[Fleet] Registered requirements-validation workflow actions (includes QCSD Ideation)');
+  }
+
+  // Register visual-accessibility domain actions
+  const visA11yAPI = kernel.getDomainAPI<VisualAccessibilityAPI>('visual-accessibility');
+  if (visA11yAPI?.registerWorkflowActions) {
+    visA11yAPI.registerWorkflowActions(orchestrator);
+    console.log('[Fleet] Registered visual-accessibility workflow actions');
+  }
+}

v3/src/mcp/handlers/task-handlers.ts

@@ -3,6 +3,7 @@
  * Task submission, status, and management handlers
  *
  * ADR-051: Integrated with Model Router for intelligent tier selection
+ * Issue #206: Workflow auto-execution for task types with associated workflows
  */
 
 import { getFleetState, isFleetInitialized } from './core-handlers';
@@ -28,6 +29,18 @@ import {
 } from '../services/reasoning-bank-service';
 import type { ModelTier } from '../../integrations/agentic-flow';
 
+// ============================================================================
+// Task Type to Workflow Mapping (Issue #206)
+// Maps TaskTypes to their associated workflow IDs for auto-execution
+// ============================================================================
+
+const TASK_WORKFLOW_MAP: Partial<Record<TaskType, string>> = {
+  'ideation-assessment': 'qcsd-ideation-swarm',
+  // Add more mappings as workflows are created:
+  // 'generate-tests': 'comprehensive-testing',
+  // 'test-accessibility': 'visual-accessibility-workflow',
+};
+
 // ============================================================================
 // Task Submit Handler
 // ============================================================================
@@ -287,7 +300,7 @@ export async function handleTaskOrchestrate(
     };
   }
 
-  const { queen } = getFleetState();
+  const { queen, workflowOrchestrator } = getFleetState();
 
   try {
     // ADR-051: Route task to optimal model tier BEFORE execution
@@ -305,7 +318,63 @@ export async function handleTaskOrchestrate(
     const taskType = inferTaskType(params.task);
     const priority = mapPriority(params.priority || 'medium');
 
-    // Submit the task with routing decision included in payload
+    // Issue #206: Check if this task type has an associated workflow
+    const workflowId = TASK_WORKFLOW_MAP[taskType];
+
+    if (workflowId && workflowOrchestrator) {
+      // Execute the associated workflow directly
+      console.log(`[TaskOrchestrate] Task type '${taskType}' has workflow '${workflowId}' - executing workflow`);
+
+      // Build workflow input from task params and context
+      const workflowInput: Record<string, unknown> = {
+        // Pass through context fields as workflow input
+        targetId: params.context?.project || `task-${Date.now()}`,
+        targetType: 'epic', // Default for QCSD ideation
+        description: params.task,
+        acceptanceCriteria: params.context?.requirements || [],
+        // Include routing info for downstream processing
+        routing: {
+          tier: routingResult.decision.tier,
+          modelId: routingResult.modelId,
+          executionStrategy: routingResult.executionStrategy,
+          complexity: routingResult.decision.complexityAnalysis.overall,
+        },
+      };
+
+      const workflowResult = await workflowOrchestrator.executeWorkflow(workflowId, workflowInput);
+
+      if (!workflowResult.success) {
+        return {
+          success: false,
+          error: `Workflow execution failed: ${workflowResult.error.message}`,
+        };
+      }
+
+      return {
+        success: true,
+        data: {
+          taskId: workflowResult.value, // This is the workflow execution ID
+          type: taskType,
+          priority,
+          strategy: params.strategy || 'adaptive',
+          status: 'workflow-started',
+          message: `Workflow '${workflowId}' started for task: ${params.task}`,
+          routing: {
+            tier: routingResult.decision.tier,
+            tierName: routingResult.tierInfo.name,
+            modelId: routingResult.modelId,
+            executionStrategy: routingResult.executionStrategy,
+            complexity: routingResult.decision.complexityAnalysis.overall,
+            confidence: routingResult.decision.confidence,
+            useAgentBooster: routingResult.useAgentBooster,
+            rationale: routingResult.decision.rationale,
+            decisionTimeMs: routingResult.decision.metadata.decisionTimeMs,
+          },
+        },
+      };
+    }
+
+    // No workflow - submit as a regular task
     const result = await queen!.submitTask({
       type: taskType,
       priority,