projectworkflowchain

type AutomationAPI interface {
	CreateAutomation(context.Context, projectautomation.CreateAutomationInput) (projectautomation.Automation, error)
	ListAutomations(context.Context, projectautomation.AutomationFilter) ([]projectautomation.Automation, error)
	ReconcileReadyAutomationsForPlan(context.Context, string, string) error
	// CancelAutomationsForPlan disables all enabled automations for a plan.
	// Used by CancelChain (GAP-12) so cancelled chains don't leave stale
	// automations that pollute the reconciler's scan.
	CancelAutomationsForPlan(context.Context, string, string) error
	// DeleteAutomationsForPlanCascade permanently removes every automation for
	// a plan together with each automation's runs. Used by the governed
	// chain-run delete cascade.
	DeleteAutomationsForPlanCascade(context.Context, string, string) (projectautomation.AutomationDeleteCounts, error)
}

type AutomationRunAPI interface {
	ListRuns(context.Context, projectautomation.RunFilter) ([]projectautomation.AutomationRun, error)
}

type ChainFilter struct {
	ProjectID string
	ChainRef  string
	Status    string
}

type ChainRun struct {
	ID                        string     `json:"chain_run_id"`
	ProjectID                 string     `json:"project_id"`
	ChainRef                  string     `json:"chain_ref"`
	InputRef                  string     `json:"input_ref"`
	Status                    string     `json:"status"`
	ContextRefs               []string   `json:"context_refs,omitempty"`
	StageRuns                 []StageRun `json:"stage_runs,omitempty"`
	WorkPlanIDs               []string   `json:"work_plan_ids,omitempty"`
	AutomationIDs             []string   `json:"automation_ids,omitempty"`
	CreatedByRunID            string     `json:"created_by_run_id,omitempty"`
	TraceID                   string     `json:"trace_id,omitempty"`
	GitOpsReady               bool       `json:"gitops_ready,omitempty"`
	GitOpsAttemptCount        int        `json:"gitops_attempt_count,omitempty"`
	GitOpsFailureCategory     string     `json:"gitops_failure_category,omitempty"`
	GitOpsFailureEvidenceRefs []string   `json:"gitops_failure_evidence_refs,omitempty"`
	GitOpsRecoveryStatus      string     `json:"gitops_recovery_status,omitempty"`
	GitOpsResetCount          int        `json:"gitops_reset_count,omitempty"`
	// GitOpsAdvisoryProceed is set true when a verifier failure has persisted
	// through the full reconciler reset budget (sustained stagnation), indicating
	// the verifier is beyond the repair agent's ability to fix. When true, the
	// finalization verifier gate treats a failed verifier ref as an advisory
	// warning (via the existing failedVerifierRefHasFinalReadinessDisposition
	// escape hatch) and the draft PR proceeds. Per policy, workflow gates are
	// advisory by default; the downstream GitHub CI / human review is the real
	// gate. This field is NOT cleared by the reconciler auto-reset — it is a
	// durable decision once the stagnation threshold is reached.
	GitOpsAdvisoryProceed bool      `json:"gitops_advisory_proceed,omitempty"`
	PullRequestRef        string    `json:"pull_request_ref,omitempty"`
	NextAction            string    `json:"next_action,omitempty"`
	CreatedAt             time.Time `json:"created_at"`
	UpdatedAt             time.Time `json:"updated_at"`
}

type Config struct {
	ProjectID            string        `json:"project_id"`
	ChainRef             string        `json:"chain_ref"`
	Enabled              bool          `json:"enabled"`
	InputKind            string        `json:"input_kind,omitempty"`
	InputPattern         string        `json:"input_pattern,omitempty"`
	ContextProvider      string        `json:"context_provider,omitempty"`
	ContextMode          string        `json:"context_mode,omitempty"`
	DefaultTitleTemplate string        `json:"default_title_template,omitempty"`
	GitOpsMode           string        `json:"gitops_mode,omitempty"`
	GitOpsEnabled        bool          `json:"gitops_enabled,omitempty"`
	Stages               []StageConfig `json:"stages,omitempty"`
}

type DeleteChainRunCounts struct {
	Plans       int `json:"plans"`
	Tasks       int `json:"tasks"`
	Attachments int `json:"attachments"`
	Automations int `json:"automations"`
	Runs        int `json:"runs"`
}

type DeleteChainRunResult struct {
	ChainRunID string               `json:"chain_run_id"`
	ProjectID  string               `json:"project_id"`
	Deleted    DeleteChainRunCounts `json:"deleted"`
}

type GitOpsFinalizeInput struct {
	ProjectID        string
	ChainRunID       string
	ChainRef         string
	InputRef         string
	WorkPlan         projectworkplan.WorkPlan
	StageRuns        []StageRun
	AutomationIDs    []string
	AllowedPathspecs []string
	ReviewRefs       []string
	VerifierRefs     []string
	TestResults      []string
	CreatedByRunID   string
	TraceID          string
	// AdvisoryProceed indicates the chain has exhausted its repair budget and
	// the PR should be created with a verifier warning instead of failing on
	// verifier errors. When true, the finalizer MUST skip server-side verifier
	// re-runs (the verifier ladder already failed and the repair agent cannot
	// fix it — the PR is created as a draft with a warning).
	AdvisoryProceed bool
}

type GitOpsFinalizeResult struct {
	CommitRef      string
	PushRef        string
	PullRequestRef string
	EvidenceRefs   []string
	NoChanges      bool
	Skipped        bool
}

type GitOpsFinalizer interface {
	FinalizeWorkflowChain(context.Context, GitOpsFinalizeInput) (GitOpsFinalizeResult, error)
}

type ListResult struct {
	Chains []Config   `json:"chains,omitempty"`
	Runs   []ChainRun `json:"runs,omitempty"`
}

type LocalContextReader interface {
	ReadLocalContent(context.Context, projectintegrations.LocalReadInput) (projectintegrations.RichContentReadResult, error)
}

type Options struct {
	GitOpsRecoveryMaxAttempts int
	ReconcilerInterval        time.Duration
	// ReconcilerGitOpsResets bounds the number of auto-reset cycles the
	// reconciler performs before a terminal GitOps failure escalates to
	// advisory-proceed or permanent terminal. Defaults to
	// defaultReconcilerGitOpsResets (5). Previously hardcoded; now configurable.
	ReconcilerGitOpsResets int
	// AdvisoryProceedEnabled controls whether a verifier failure that has
	// persisted through the full reconciler reset budget (sustained stagnation)
	// converts to advisory proceed (draft PR with a verifier warning) instead of
	// permanently terminal-blocking. Defaults to true via NewWithOptions.
	AdvisoryProceedEnabled bool
}

type ProjectRunSummary struct {
	ProjectID           string         `json:"project_id"`
	TotalChains         int            `json:"total_chains"`
	ActiveChains        int            `json:"active_chains"`
	BlockedChains       int            `json:"blocked_chains"`
	TotalPlans          int            `json:"total_plans"`
	ActivePlans         int            `json:"active_plans"`
	BlockedPlans        int            `json:"blocked_plans"`
	TaskCounts          TaskCounts     `json:"task_counts"`
	AutomationRunCounts map[string]int `json:"automation_run_counts,omitempty"`
	ActiveRuns          []RunSummary   `json:"active_runs,omitempty"`
}

type RunSummary struct {
	ChainRunID           string    `json:"chain_run_id"`
	TraceID              string    `json:"trace_id,omitempty"`
	InputRef             string    `json:"input_ref,omitempty"`
	Status               string    `json:"status"`
	CurrentStage         string    `json:"current_stage,omitempty"`
	StagesCompleted      int       `json:"stages_completed"`
	StagesTotal          int       `json:"stages_total"`
	TaskDone             int       `json:"task_done"`
	TaskTotal            int       `json:"task_total"`
	ActiveAutomationRuns int       `json:"active_automation_runs,omitempty"`
	PullRequestRef       string    `json:"pull_request_ref,omitempty"`
	UpdatedAt            time.Time `json:"updated_at"`
}

type RunTree struct {
	ChainRun ChainRun    `json:"chain_run"`
	Stages   []StageTree `json:"stages,omitempty"`
	// Recovery is the chain-wide rollup of task-level gitops recovery activity
	// (summed across stages). It is computed read-side in GetRunTree from the
	// automation-runs fetch each stage already performs — no extra I/O, no new
	// persistence. Nil when there is no recovery activity (omitempty hides it).
	Recovery *StageRecoverySummary `json:"recovery,omitempty"`
}

type Service struct {
	// contains filtered or unexported fields
}

type StageConfig struct {
	StageRef                 string   `json:"stage_ref"`
	WorkflowRef              string   `json:"workflow_ref"`
	Trigger                  string   `json:"trigger,omitempty"`
	DependsOn                []string `json:"depends_on,omitempty"`
	AutomationRefTemplate    string   `json:"automation_ref_template,omitempty"`
	RequiredStatusBeforeNext string   `json:"required_status_before_next,omitempty"`
}

type StageRecoverySummary struct {
	// RecoveringRuns counts runs whose SafeSummary is the active recovery
	// marker (RunSafeSummaryGitOpsPostTaskRecovery) — i.e. the recovery loop
	// has re-armed them and they are in flight again.
	RecoveringRuns int `json:"recovering_runs,omitempty"`
	// FailedRuns counts runs in RunStatusFailed — candidates the recovery
	// loop is evaluating. Distinct from RecoveringRuns (which are already
	// re-claimed).
	FailedRuns int `json:"failed_runs,omitempty"`
	// TotalAttempts sums AttemptCount across recovering + failed runs, so an
	// operator sees the cumulative retry pressure (a run on attempt 7 is a
	// different signal than 7 runs on attempt 1).
	TotalAttempts int `json:"total_attempts,omitempty"`
	// FailureCategories lists the distinct failure_category values across
	// recovering + failed runs, deduped and capped. These are already-validated
	// safe refs (they pass the safe-ref boundary at write time).
	FailureCategories []string `json:"failure_categories,omitempty"`
}

type StageRun struct {
	StageRef      string    `json:"stage_ref"`
	WorkflowRef   string    `json:"workflow_ref"`
	WorkflowID    string    `json:"workflow_id,omitempty"`
	Status        string    `json:"status"`
	WorkPlanID    string    `json:"work_plan_id,omitempty"`
	WorkTaskIDs   []string  `json:"work_task_ids,omitempty"`
	AutomationIDs []string  `json:"automation_ids,omitempty"`
	StartedAt     time.Time `json:"started_at,omitempty"`
	CompletedAt   time.Time `json:"completed_at,omitempty"`
	BlockedCode   string    `json:"blocked_code,omitempty"`
	BlockedReason string    `json:"blocked_reason,omitempty"`
}

type StageTree struct {
	StageRef             string                         `json:"stage_ref"`
	Status               string                         `json:"status"`
	Plan                 *projectworkplan.WorkPlan      `json:"plan,omitempty"`
	Tasks                []projectworkplan.WorkTask     `json:"tasks,omitempty"`
	Automations          []projectautomation.Automation `json:"automations,omitempty"`
	ActiveAutomationRuns int                            `json:"active_automation_runs,omitempty"`
	// Recovery tallies this stage's task-level gitops recovery activity. Nil
	// when the stage has no recovering or failed runs (omitempty hides it).
	Recovery *StageRecoverySummary `json:"recovery,omitempty"`
}

type StartInput struct {
	ProjectID      string
	ChainRef       string
	InputText      string
	CreatedByRunID string
	TraceID        string
	DryRun         bool
}

type StartResult struct {
	ProjectID      string     `json:"project_id"`
	ChainRef       string     `json:"chain_ref"`
	InputRef       string     `json:"input_ref"`
	Status         string     `json:"status"`
	ContextRefs    []string   `json:"context_refs,omitempty"`
	ChainRunID     string     `json:"chain_run_id,omitempty"`
	StageRuns      []StageRun `json:"stage_runs,omitempty"`
	WorkPlanIDs    []string   `json:"work_plan_ids,omitempty"`
	AutomationIDs  []string   `json:"automation_ids,omitempty"`
	DryRun         bool       `json:"dry_run,omitempty"`
	NextAction     string     `json:"next_action"`
	PullRequestRef string     `json:"pull_request_ref,omitempty"`
}

type Store interface {
	CreateChainRun(context.Context, ChainRun) (ChainRun, error)
	GetChainRun(context.Context, string, string) (ChainRun, error)
	ListChainRuns(context.Context, ChainFilter) ([]ChainRun, error)
	UpdateChainRun(context.Context, ChainRun) (ChainRun, error)
	FindChainRunByWorkPlan(context.Context, string, string) (ChainRun, error)
	// DeleteChainRun permanently removes a chain run. Scoped by project;
	// idempotent. Used by the governed chain-run delete cascade.
	DeleteChainRun(context.Context, string, string) error
}

type TaskCounts struct {
	Total       int `json:"total"`
	Done        int `json:"done"`
	Active      int `json:"active"`
	Blocked     int `json:"blocked"`
	Failed      int `json:"failed"`
	NeedsReview int `json:"needs_review,omitempty"`
}

type WorkPlanAPI interface {
	GetWorkPlan(context.Context, string, string) (projectworkplan.WorkPlan, error)
	GetWorkPlansByIDs(context.Context, string, []string) ([]projectworkplan.WorkPlan, error)
	ListWorkPlans(context.Context, projectworkplan.WorkPlanFilter) ([]projectworkplan.WorkPlan, error)
	GetWorkTask(context.Context, string, string) (projectworkplan.WorkTask, error)
	ListWorkTasksByPlanIDs(context.Context, string, []string) ([]projectworkplan.WorkTask, error)
	ListWorkTasks(context.Context, projectworkplan.WorkTaskFilter) ([]projectworkplan.WorkTask, error)
	ListOpenWorkTasks(context.Context, projectworkplan.WorkTaskFilter) ([]projectworkplan.WorkTask, error)
	CreateWorkTask(context.Context, projectworkplan.CreateWorkTaskInput) (projectworkplan.WorkTask, error)
	AttachReviewResult(context.Context, projectworkplan.AttachInput) (projectworkplan.Attachment, error)
	UpdateWorkPlanStatus(context.Context, projectworkplan.UpdateWorkPlanStatusInput) (projectworkplan.WorkPlan, error)
	UpdateWorkTaskStatus(context.Context, projectworkplan.UpdateWorkTaskStatusInput) (projectworkplan.WorkTask, error)
	// ResetWorkTaskRecovery stamps the operator recovery marker on a blocked/
	// failed task, clears the poison TraceID and stale ClaimedByRunID, and
	// transitions the task to ready. This is the full recovery path that
	// resets the replacement-retry counter so the automation orchestrator can
	// queue a fresh run. Used by the chain reconciler's soft-verifier recovery
	// to avoid the zombie loop where a reopened task gets immediately re-blocked
	// by accumulated terminal failures (MASS-3847).
	ResetWorkTaskRecovery(context.Context, projectworkplan.WorkTaskActionInput) (projectworkplan.WorkTask, error)
	// DeleteWorkPlanCascade permanently removes a plan, its tasks, and task
	// attachments. Used by the governed chain-run delete cascade.
	DeleteWorkPlanCascade(context.Context, string, string) (projectworkplan.WorkPlanDeleteCounts, error)
}

type WorkflowAPI interface {
	ListWorkflows(context.Context, projectworkflow.WorkflowFilter) ([]projectworkflow.WorkflowDefinition, error)
	CompileWorkflow(context.Context, projectworkflow.WorkflowCompileInput) (projectworkflow.WorkflowCompileResult, error)
}