feat(workflow): add agent engine tracking and update functionality

- Introduce new agent:engine event type and emitter method
- Extend UI state and actions to handle engine updates
- Update workflow execution to track and display resolved engines

Author: moazbuilds

src/cli/tui/routes/workflow/adapters/opentui.ts

@@ -30,6 +30,7 @@ export interface UIActions {
     totalSteps?: number
   }): void
   updateAgentStatus(agentId: string, status: AgentStatus): void
+  updateAgentEngine(agentId: string, engine: string): void
   updateAgentModel(agentId: string, model: string): void
   updateAgentTelemetry(
     agentId: string,
@@ -124,6 +125,10 @@ export class OpenTUIAdapter extends BaseUIAdapter {
         this.actions.updateAgentStatus(event.agentId, event.status)
         break
 
+      case "agent:engine":
+        this.actions.updateAgentEngine(event.agentId, event.engine)
+        break
+
       case "agent:model":
         this.actions.updateAgentModel(event.agentId, event.model)
         break

src/cli/tui/routes/workflow/context/ui-state/actions/agent-actions.ts

@@ -45,6 +45,17 @@ export function createAgentActions(ctx: AgentActionsContext) {
     ctx.notifyImmediate()
   }
 
+  function updateAgentEngine(agentId: string, engine: string): void {
+    const state = ctx.getState()
+    ctx.setState({
+      ...state,
+      agents: state.agents.map((agent) =>
+        agent.id === agentId ? { ...agent, engine } : agent,
+      ),
+    })
+    ctx.notify()
+  }
+
   function updateAgentModel(agentId: string, model: string): void {
     const state = ctx.getState()
     ctx.setState({
@@ -80,6 +91,7 @@ export function createAgentActions(ctx: AgentActionsContext) {
   return {
     addAgent,
     updateAgentStatus,
+    updateAgentEngine,
     updateAgentModel,
     updateAgentTelemetry,
     registerMonitoringId,

src/cli/tui/routes/workflow/context/ui-state/types.ts

@@ -20,6 +20,7 @@ export type UIActions = {
   subscribe(fn: Listener): () => void
   addAgent(agent: WorkflowState["agents"][number]): void
   updateAgentStatus(agentId: string, status: AgentStatus): void
+  updateAgentEngine(agentId: string, engine: string): void
   updateAgentModel(agentId: string, model: string): void
   updateAgentTelemetry(agentId: string, telemetry: Partial<WorkflowState["agents"][number]["telemetry"]>): void
   setLoopState(loopState: LoopState | null): void

src/workflows/events/emitter.ts

@@ -139,6 +139,17 @@ export class WorkflowEventEmitter {
     });
   }
 
+  /**
+   * Emit agent engine update (called when engine is resolved at execution time)
+   */
+  updateAgentEngine(agentId: string, engine: string): void {
+    this.bus.emit({
+      type: 'agent:engine',
+      agentId,
+      engine,
+    });
+  }
+
   /**
    * Emit agent model update (called when model is resolved at execution time)
    */

src/workflows/events/types.ts

@@ -46,6 +46,7 @@ export type WorkflowEvent =
   // Agent lifecycle events
   | { type: 'agent:added'; agent: AgentInfo }
   | { type: 'agent:status'; agentId: string; status: AgentStatus }
+  | { type: 'agent:engine'; agentId: string; engine: string }
   | { type: 'agent:model'; agentId: string; model: string }
   | { type: 'agent:telemetry'; agentId: string; telemetry: Partial<AgentTelemetry> }
   | { type: 'agent:reset'; agentId: string; cycleNumber?: number }

src/workflows/execution/run.ts

@@ -15,6 +15,8 @@ import {
   getSelectedTrack,
   getSelectedConditions,
   getStepData,
+  loadControllerConfig,
+  setAutonomousMode,
 } from '../../shared/workflows/index.js';
 import { registry } from '../../infra/engines/index.js';
 import { shouldSkipStep, logSkipDebug, type ActiveLoop } from '../behaviors/skip.js';
@@ -89,6 +91,11 @@ export async function runWorkflow(options: RunWorkflowOptions = {}): Promise<voi
   // Load selected conditions for condition-based filtering
   const selectedConditions = await getSelectedConditions(cmRoot);
 
+  // Load controller configuration (autonomous mode)
+  const controllerState = await loadControllerConfig(cmRoot);
+  const controllerConfig = controllerState.controllerConfig ?? null;
+  let controllerEnabled = template.controller === true && controllerState.autonomousMode === true && !!controllerConfig;
+
   // Load chain resume info (for resuming mid-chain)
   const chainResumeInfo = await getChainResumeInfo(cmRoot);
 
@@ -236,6 +243,13 @@ export async function runWorkflow(options: RunWorkflowOptions = {}): Promise<voi
 
   process.on('workflow:pause', pauseListener);
   process.on('workflow:input', inputListener);
+  const autonomyListener = () => {
+    controllerEnabled = false;
+    setAutonomousMode(cmRoot, false).catch(() => {
+      // best-effort persistence; keep running even if it fails
+    });
+  };
+  process.on('workflow:autonomy:disable', autonomyListener);
 
   try {
     debug(`[DEBUG workflow] Entering step loop. startIndex=${startIndex}, totalSteps=${template.steps.length}, workflowShouldStop=${workflowShouldStop}`);
@@ -336,6 +350,9 @@ export async function runWorkflow(options: RunWorkflowOptions = {}): Promise<voi
     // Mutate current step to carry the chosen engine forward
     step.engine = engineType;
 
+    // Update TUI with resolved engine (may differ from workflow file due to fallback)
+    emitter.updateAgentEngine(uniqueAgentId, engineType);
+
     debug(`[DEBUG workflow] Resolving model...`);
     // Resolve model: step override > engine default, and update UI
     const engineModule = registry.get(engineType);
@@ -406,6 +423,11 @@ export async function runWorkflow(options: RunWorkflowOptions = {}): Promise<voi
         isResumingFromSavedSessionWithChains,
         stepResumePrompt,
         stepResumeMonitoringId,
+        controller: controllerEnabled && controllerConfig ? {
+          isEnabled: () => controllerEnabled,
+          agentId: controllerConfig.agentId,
+          sessionId: controllerConfig.sessionId,
+        } : undefined,
       });
 
       // Handle post-execution behaviors
@@ -541,5 +563,6 @@ export async function runWorkflow(options: RunWorkflowOptions = {}): Promise<voi
     process.removeListener('workflow:stop', stopListener);
     process.removeListener('workflow:pause', pauseListener);
     process.removeListener('workflow:input', inputListener);
+    process.removeListener('workflow:autonomy:disable', autonomyListener);
   }
 }