Method Run

internal/loop/loop.go:138–240

Run executes the agent loop until completion or max iterations.

(ctx context.Context)

// Run executes the agent loop until completion or max iterations.
func (l *Loop) Run(ctx context.Context) error {
	if l.provider == nil {
		return fmt.Errorf("loop provider is not configured")
	}

	// Open log file in PRD directory
	prdDir := filepath.Dir(l.prdPath)
	logPath := filepath.Join(prdDir, l.provider.LogFileName())
	var err error
	l.logFile, err = os.OpenFile(logPath, os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0644)
	if err != nil {
		return fmt.Errorf("failed to open log file: %w", err)
	}
	defer l.logFile.Close()
	defer close(l.events)

	for {
		l.mu.Lock()
		if l.stopped {
			l.mu.Unlock()
			return nil
		}
		if l.paused {
			l.mu.Unlock()
			return nil
		}
		l.iteration++
		currentIter := l.iteration
		l.mu.Unlock()

		// Check if max iterations reached
		if currentIter > l.maxIter {
			l.events <- Event{
				Type:      EventMaxIterationsReached,
				Iteration: currentIter - 1,
			}
			return nil
		}

		// Rebuild prompt if builder is set (inlines the current story each iteration)
		if l.buildPrompt != nil {
			prompt, storyID, err := l.buildPrompt()
			if err != nil {
				l.events <- Event{
					Type:      EventComplete,
					Iteration: currentIter,
				}
				return nil
			}
			l.mu.Lock()
			l.prompt = prompt
			l.currentStoryID = storyID
			l.sawStoryDone = false
			l.mu.Unlock()
		}

		// Send iteration start event with current story ID
		l.mu.Lock()