refactor(agent): improve notification handling and prompt processing

- Replace ctx.notify() with ctx.notifyImmediate() for immediate UI updates
- Enhance NEXT action to use queued prompts when available
- Prefer formatted stdout over raw JSON in agent execution
- Add debug logging for chained prompts loading

Author: moazbuilds

src/agents/runner/runner.ts

@@ -407,7 +407,8 @@ export async function executeAgent(
     });
 
     // Store output in memory
-    const stdout = result.stdout || totalStdout;
+    // Prefer totalStdout (formatted text from onData) over result.stdout (raw JSON)
+    const stdout = totalStdout || result.stdout;
     const slice = stdout.slice(-2000);
     await store.append({
       agentId,
@@ -426,15 +427,16 @@ export async function executeAgent(
     // Always load on fresh execution; on resume, workflow.ts decides whether to use them
     // based on chain resume state (chainResumeInfo)
     let chainedPrompts: ChainedPrompt[] | undefined;
+    debug(`[ChainedPrompts] agentConfig.chainedPromptsPath: ${agentConfig.chainedPromptsPath}`);
     if (agentConfig.chainedPromptsPath) {
       chainedPrompts = await loadChainedPrompts(
         agentConfig.chainedPromptsPath,
         projectRoot ?? workingDir,
         selectedConditions ?? []
       );
-      if (chainedPrompts.length > 0) {
-        debug(`Loaded ${chainedPrompts.length} chained prompts for agent '${agentId}'`);
-      }
+      debug(`[ChainedPrompts] Loaded ${chainedPrompts.length} chained prompts for agent '${agentId}'`);
+    } else {
+      debug(`[ChainedPrompts] No chainedPromptsPath for agent '${agentId}'`);
     }
 
     return {

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

@@ -53,7 +53,7 @@ export function createAgentActions(ctx: AgentActionsContext) {
         agent.id === agentId ? { ...agent, engine } : agent,
       ),
     })
-    ctx.notify()
+    ctx.notifyImmediate()
   }
 
   function updateAgentModel(agentId: string, model: string): void {
@@ -64,7 +64,7 @@ export function createAgentActions(ctx: AgentActionsContext) {
         agent.id === agentId ? { ...agent, model } : agent,
       ),
     })
-    ctx.notify()
+    ctx.notifyImmediate()
   }
 
   function updateAgentTelemetry(

src/workflows/input/controller.ts

@@ -143,9 +143,22 @@ export class ControllerInputProvider implements InputProvider {
         debug('[Controller] Action detected: %s', action);
 
         switch (action) {
-          case 'NEXT':
-            this.emitter.emitReceived({ input: '', source: 'controller' });
-            return { type: 'input', value: '' };
+          case 'NEXT': {
+            // Use next queued prompt content to advance
+            const hasQueuedPrompt = context.promptQueue.length > 0 &&
+              context.promptQueueIndex < context.promptQueue.length;
+            const nextPrompt = hasQueuedPrompt
+              ? context.promptQueue[context.promptQueueIndex].content
+              : '';
+            debug('[Controller] ACTION: NEXT with prompt: %s', nextPrompt ? nextPrompt.slice(0, 50) + '...' : '(empty)');
+            this.emitter.emitReceived({ input: nextPrompt, source: 'controller' });
+            return {
+              type: 'input',
+              value: nextPrompt,
+              resumeMonitoringId: context.stepOutput.monitoringId,
+              source: 'controller',
+            };
+          }
           case 'SKIP':
             this.emitter.emitReceived({ input: '', source: 'controller' });
             return { type: 'skip' };