feat(auggie): add session resuming support and improve pause/skip handling

implement session resuming capability in Auggie engine by adding resumeSessionId and resumePrompt options
enhance step runner to properly distinguish between pause and skip abort scenarios
add session ID tracking and callback in Auggie execution

Author: moazbuilds

config/main.agents.js

@@ -78,7 +78,7 @@ module.exports = [
     description: 'BMAD product owner controller for autonomous mode',
     role: 'controller',
     promptPath: path.join(promptsDir, 'bmad', 'controller', 'PO.md'),
-    engine: 'codex'
+    engine: 'opencode'
   },
 
   // BMAD agents

src/infra/engines/providers/auggie/execution/commands.ts

@@ -3,6 +3,10 @@ export interface AuggieCommandOptions {
    * Model identifier (if supported by Auggie)
    */
   model?: string;
+  /**
+   * Session ID to resume
+   */
+  resumeSessionId?: string;
 }
 
 export interface AuggieCommand {
@@ -13,6 +17,11 @@ export interface AuggieCommand {
 export function buildAuggieRunCommand(options: AuggieCommandOptions = {}): AuggieCommand {
   const args: string[] = ['--print', '--quiet', '--output-format', 'json'];
 
+  // Add resume flag if resuming a session
+  if (options.resumeSessionId?.trim()) {
+    args.push('--resume', options.resumeSessionId.trim());
+  }
+
   // Add model if specified (check Auggie docs for exact flag)
   if (options.model?.trim()) {
     args.push('--model', options.model.trim());

src/infra/engines/providers/auggie/execution/runner.ts

@@ -10,11 +10,14 @@ import type { ParsedTelemetry } from '../../../core/types.js';
 export interface RunAuggieOptions {
   prompt: string;
   workingDir: string;
+  resumeSessionId?: string;
+  resumePrompt?: string;
   model?: string;
   env?: NodeJS.ProcessEnv;
   onData?: (chunk: string) => void;
   onErrorData?: (chunk: string) => void;
   onTelemetry?: (telemetry: ParsedTelemetry) => void;
+  onSessionId?: (sessionId: string) => void;
   abortSignal?: AbortSignal;
   timeout?: number; // Timeout in milliseconds (default: 1800000ms = 30 minutes)
 }
@@ -48,6 +51,20 @@ function cleanAnsi(text: string, plainLogs: boolean): string {
   return text.replace(ANSI_ESCAPE_SEQUENCE, '');
 }
 
+/**
+ * Build the final resume prompt combining steering instruction with user message
+ */
+function buildResumePrompt(userPrompt?: string): string {
+  const defaultPrompt = 'Continue from where you left off.';
+
+  if (!userPrompt) {
+    return defaultPrompt;
+  }
+
+  // Combine steering instruction with user's message
+  return `[USER STEERING] The user paused this session to give you new direction. Continue from where you left off, but prioritize the user's request: "${userPrompt}"`;
+}
+
 // Note: Auggie returns a single result object, not streaming events like OpenCode
 // Therefore, we don't need complex formatting helpers like formatToolUse or formatStepEvent
 
@@ -71,11 +88,14 @@ export async function runAuggie(options: RunAuggieOptions): Promise<RunAuggieRes
   const {
     prompt,
     workingDir,
+    resumeSessionId,
+    resumePrompt,
     model,
     env,
     onData,
     onErrorData,
     onTelemetry,
+    onSessionId,
     abortSignal,
     timeout = 1800000,
   } = options;
@@ -91,13 +111,16 @@ export async function runAuggie(options: RunAuggieOptions): Promise<RunAuggieRes
   const runnerEnv = resolveRunnerEnv(env);
   const plainLogs =
     (env?.CODEMACHINE_PLAIN_LOGS ?? process.env.CODEMACHINE_PLAIN_LOGS ?? '').toString() === '1';
-  const { command, args } = buildAuggieRunCommand({ model });
+  const { command, args } = buildAuggieRunCommand({ model, resumeSessionId });
 
   // Add working directory to args (Auggie uses --workspace-root, not --cwd)
   args.push('--workspace-root', workingDir);
 
+  // When resuming, use the resume prompt instead of the original prompt
+  const effectivePrompt = resumeSessionId ? buildResumePrompt(resumePrompt) : prompt;
+
   // Add prompt as positional argument (Auggie accepts it as the last argument)
-  args.push(prompt);
+  args.push(effectivePrompt);
 
   logger.debug(
     `Auggie runner - prompt length: ${prompt.length}, lines: ${prompt.split('\n').length}, model: ${
@@ -108,6 +131,7 @@ export async function runAuggie(options: RunAuggieOptions): Promise<RunAuggieRes
   const telemetryCapture = createTelemetryCapture('auggie', model, prompt, workingDir);
   let jsonBuffer = '';
   let isFirstStep = true;
+  let sessionIdCaptured = false;
 
   const processLine = (line: string): void => {
     if (!line.trim()) {
@@ -131,6 +155,12 @@ export async function runAuggie(options: RunAuggieOptions): Promise<RunAuggieRes
     // Auggie returns a single JSON object with type "result"
     // Format: {"type":"result","result":"...","is_error":false,"subtype":"success","session_id":"...","num_turns":0}
     if (parsedObj.type === 'result') {
+      // Capture session ID from result event
+      if (!sessionIdCaptured && parsedObj.session_id && onSessionId) {
+        sessionIdCaptured = true;
+        onSessionId(parsedObj.session_id);
+      }
+
       const resultText = typeof parsedObj.result === 'string' ? parsedObj.result : '';
       const isError = parsedObj.is_error === true;
 

src/workflows/step/run.ts

@@ -202,9 +202,18 @@ export async function runStepFresh(ctx: RunnerContext): Promise<RunStepResult |
     return { output: stepOutput };
   } catch (error) {
     if (error instanceof Error && error.name === 'AbortError') {
-      debug('[step/run] Step aborted, skipping to next');
-      ctx.emitter.updateAgentStatus(uniqueAgentId, 'skipped');
-      ctx.machine.send({ type: 'SKIP' });
+      // PAUSE sends PAUSE event (transitions running→awaiting) BEFORE calling abort()
+      // SKIP only calls abort() without sending any event first
+      // So if machine is still 'running', this was a skip - send SKIP to advance
+      // If machine is 'awaiting', this was a pause - preserve that state
+      if (ctx.machine.state === 'running') {
+        debug('[step/run] Step aborted via skip, advancing to next step');
+        ctx.emitter.updateAgentStatus(uniqueAgentId, 'skipped');
+        ctx.machine.send({ type: 'SKIP' });
+      } else {
+        debug('[step/run] Step aborted via pause, entering awaiting state');
+        ctx.emitter.updateAgentStatus(uniqueAgentId, 'awaiting');
+      }
       return null;
     }