processor

type Dirs struct {
	Queue, Completed, Log string
}

type DirtyFileChecker interface {
	CountDirtyFiles(ctx context.Context) (int, error)
}

type GitLockChecker interface {
	Exists() bool
}

type NothingToDoCallback func(ctx context.Context, cancel context.CancelFunc)

type Processor interface {
	Process(ctx context.Context) error
	// ResumeExecuting resumes any prompts still in "executing" state on startup.
	// Called once by the runner before the normal event loop begins.
	// For each executing prompt, it reattaches to the running container and drives
	// the prompt to completion through the normal post-execution flow.
	ResumeExecuting(ctx context.Context) error
	// ResumeCommitting retries git commits for any prompts in "committing" state on startup.
	// Called once by the runner before the normal event loop begins.
	// Unlike ResumeExecuting, failures are non-fatal: the prompt stays committing and is
	// retried on the next daemon cycle.
	ResumeCommitting(ctx context.Context) error
}

type PromptManager interface {
	ListQueued(ctx context.Context) ([]prompt.Prompt, error)
	Load(ctx context.Context, path string) (*prompt.PromptFile, error)
	AllPreviousCompleted(ctx context.Context, n int) bool
	FindMissingCompleted(ctx context.Context, n int) []int
	FindPromptStatusInProgress(ctx context.Context, number int) string
	SetStatus(ctx context.Context, path string, status string) error
	MoveToCompleted(ctx context.Context, path string) error
	HasQueuedPromptsOnBranch(ctx context.Context, branch string, excludePath string) (bool, error)
	SetPRURL(ctx context.Context, path string, url string) error
	FindCommitting(ctx context.Context) ([]string, error)
}

type WorkflowDeps struct {
	ProjectName   project.Name
	PromptManager PromptManager
	AutoCompleter spec.AutoCompleter
	Releaser      git.Releaser
	VersionGetter version.Getter
	Brancher      git.Brancher
	PRCreator     git.PRCreator
	Cloner        git.Cloner
	Worktreer     git.Worktreer
	PRMerger      git.PRMerger
	PR            bool
	AutoMerge     bool
	AutoReview    bool
	AutoRelease   bool
}

type WorkflowExecutor interface {
	// Setup prepares the execution environment before the YOLO container runs.
	// For clone/worktree: creates the isolated directory and chdirs into it.
	// For branch: creates or switches to the feature branch in-place.
	// For direct: no-op.
	// Returns a wrapped error on failure; partial setup is cleaned up before returning.
	Setup(ctx context.Context, baseName prompt.BaseName, pf *prompt.PromptFile) error

	// CleanupOnError undoes any environment setup performed by Setup when
	// execution or post-execution fails. Idempotent — safe to call if Setup was
	// not called or has already been cleaned up. No-op for direct and branch
	// executors where no isolated directory exists.
	CleanupOnError(ctx context.Context)

	// Complete performs all post-execution git operations after the YOLO container
	// exits successfully: commit, chdir back, cleanup isolation, push, optional PR
	// creation/merge, and moving the prompt file to completedPath.
	//
	// gitCtx is a non-cancellable context (context.WithoutCancel) for git ops.
	// ctx is the normal request context (used for prompt-manager calls and error wrapping).
	// completedPath is the destination path — the prompt has NOT been moved yet when
	// Complete is called; each implementation calls moveToCompleted internally.
	Complete(
		gitCtx context.Context,
		ctx context.Context,
		pf *prompt.PromptFile,
		title, promptPath, completedPath string,
	) error

	// ReconstructState restores internal state for a prompt being resumed after a
	// daemon restart. Returns canResume=false if the isolated directory no longer
	// exists (caller resets the prompt to approved). Returns an error only for
	// unexpected filesystem failures.
	ReconstructState(
		ctx context.Context,
		baseName prompt.BaseName,
		pf *prompt.PromptFile,
	) (canResume bool, err error)
}