Method runIteration

internal/loop/loop.go:319–398

runIteration spawns the agent and processes its output.

(ctx context.Context)

// runIteration spawns the agent and processes its output.
func (l *Loop) runIteration(ctx context.Context) error {
	workDir := l.effectiveWorkDir()
	cmd := l.provider.LoopCommand(ctx, l.prompt, workDir)
	l.mu.Lock()
	l.agentCmd = cmd
	// Initialize watchdog state
	l.lastOutputTime = time.Now()
	watchdogTimeout := l.watchdogTimeout
	l.mu.Unlock()

	// Create pipes for stdout and stderr
	stdout, err := l.agentCmd.StdoutPipe()
	if err != nil {
		return fmt.Errorf("failed to create stdout pipe: %w", err)
	}

	stderr, err := l.agentCmd.StderrPipe()
	if err != nil {
		return fmt.Errorf("failed to create stderr pipe: %w", err)
	}

	// Start the command
	if err := l.agentCmd.Start(); err != nil {
		return fmt.Errorf("failed to start %s: %w", l.provider.Name(), err)
	}

	// Start watchdog goroutine to detect hung processes
	watchdogDone := make(chan struct{})
	var watchdogFired atomic.Bool
	if watchdogTimeout > 0 {
		go l.runWatchdog(watchdogTimeout, watchdogDone, &watchdogFired)
	}

	// Process stdout in a separate goroutine
	var wg sync.WaitGroup
	wg.Add(2)

	go func() {
		defer wg.Done()
		l.processOutput(stdout)
	}()

	// Log stderr to the log file
	go func() {
		defer wg.Done()
		l.logStream(stderr, "[stderr] ")
	}()

	// Wait for output processing to complete
	wg.Wait()

	// Stop watchdog
	close(watchdogDone)

	// Wait for the command to finish
	if err := l.agentCmd.Wait(); err != nil {
		// If the context was cancelled, don't treat it as an error
		if ctx.Err() != nil {