projectworkplan

type AttachInput struct {
	ProjectID       string `json:"project_id,omitempty"`
	TaskID          string `json:"task_id"`
	Ref             string `json:"ref"`
	AttachedByRunID string `json:"attached_by_run_id,omitempty"`
	TraceID         string `json:"trace_id,omitempty"`
	Note            string `json:"note,omitempty"`
}

type Attachment struct {
	ID              string    `json:"id"`
	ProjectID       string    `json:"project_id"`
	PlanID          string    `json:"plan_id"`
	TaskID          string    `json:"task_id"`
	Kind            string    `json:"kind"`
	Ref             string    `json:"ref"`
	AttachedByRunID string    `json:"attached_by_run_id,omitempty"`
	TraceID         string    `json:"trace_id,omitempty"`
	Note            string    `json:"note,omitempty"`
	CreatedAt       time.Time `json:"created_at"`
}

type CreateWorkPlanInput struct {
	ProjectID        string `json:"project_id,omitempty"`
	PlanRef          string `json:"plan_ref"`
	UserRequestRef   string `json:"user_request_ref,omitempty"`
	Title            string `json:"title"`
	GoalSummary      string `json:"goal_summary"`
	OwnerAgent       string `json:"owner_agent,omitempty"`
	CreatedByRunID   string `json:"created_by_run_id,omitempty"`
	ChainRunID       string `json:"chain_run_id,omitempty"`
	TraceID          string `json:"trace_id,omitempty"`
	ResumeSummary    string `json:"resume_summary,omitempty"`
	IsolationMode    string `json:"isolation_mode,omitempty"`
	ParallelGroupRef string `json:"parallel_group_ref,omitempty"`
	WorkspaceRef     string `json:"workspace_ref,omitempty"`
	GitBaseRef       string `json:"git_base_ref,omitempty"`
	GitBranchRef     string `json:"git_branch_ref,omitempty"`
	GitWorktreeRef   string `json:"git_worktree_ref,omitempty"`
}

type CreateWorkTaskInput struct {
	ProjectID               string   `json:"project_id,omitempty"`
	PlanID                  string   `json:"plan_id"`
	TaskRef                 string   `json:"task_ref"`
	Title                   string   `json:"title"`
	Description             string   `json:"description,omitempty"`
	Status                  string   `json:"status,omitempty"`
	OwnerAgent              string   `json:"owner_agent,omitempty"`
	RunID                   string   `json:"run_id,omitempty"`
	TraceID                 string   `json:"trace_id,omitempty"`
	EvidenceNeeded          []string `json:"evidence_needed,omitempty"`
	ContextPackRefs         []string `json:"context_pack_refs,omitempty"`
	FilesToRead             []string `json:"files_to_read,omitempty"`
	FilesToEdit             []string `json:"files_to_edit,omitempty"`
	LikelyFilesAffected     []string `json:"likely_files_affected,omitempty"`
	DependencyTaskIDs       []string `json:"dependency_task_ids,omitempty"`
	VerificationRequirement string   `json:"verification_requirement"`
	GitOpsVerificationMode  string   `json:"gitops_verification_mode,omitempty"`
	ExpectedOutput          string   `json:"expected_output,omitempty"`
	FailureCriteria         string   `json:"failure_criteria,omitempty"`
	ReviewGate              string   `json:"review_gate,omitempty"`
	ResumeInstructions      string   `json:"resume_instructions,omitempty"`
	KnowledgeCandidateRefs  []string `json:"knowledge_candidate_refs,omitempty"`
	EvidenceRefs            []string `json:"evidence_refs,omitempty"`
	ClaimRefs               []string `json:"claim_refs,omitempty"`
	VerifierResultRefs      []string `json:"verifier_result_refs,omitempty"`
	ReviewResultRefs        []string `json:"review_result_refs,omitempty"`
	ReviewExemptReason      string   `json:"review_exempt_reason,omitempty"`
	ArtifactRefs            []string `json:"artifact_refs,omitempty"`
	AgentRunIDs             []string `json:"agent_run_ids,omitempty"`
	DecompositionQuality    string   `json:"decomposition_quality,omitempty"`
	AcceptanceCriteria      []string `json:"acceptance_criteria,omitempty"`
	StopConditions          []string `json:"stop_conditions,omitempty"`
	VerifierLadder          []string `json:"verifier_ladder,omitempty"`
	RegressionApplicability string   `json:"regression_test_applicability,omitempty"`
	DownstreamImpactRefs    []string `json:"downstream_impact_refs,omitempty"`
	OutputContract          string   `json:"output_contract,omitempty"`
}

type DependencySummary struct {
	TaskID string `json:"task_id"`
	Status string `json:"status"`
	Ready  bool   `json:"ready"`
}

type DirtyScopeRetryIncrementInput struct {
	ProjectID string
	TaskID    string
}

type ExpandWorkTaskScopeInput struct {
	ProjectID          string   `json:"project_id,omitempty"`
	TaskID             string   `json:"task_id"`
	FilesToEdit        []string `json:"files_to_edit,omitempty"`
	ResumeInstructions string   `json:"resume_instructions,omitempty"`
	RunID              string   `json:"run_id,omitempty"`
	TraceID            string   `json:"trace_id,omitempty"`
}

type GetNextWorkTaskInput struct {
	ProjectID          string `json:"project_id,omitempty"`
	PlanID             string `json:"plan_id,omitempty"`
	OwnerAgent         string `json:"owner_agent,omitempty"`
	RunID              string `json:"run_id,omitempty"`
	TraceID            string `json:"trace_id,omitempty"`
	IncludeClaimedByMe bool   `json:"include_claimed_by_me,omitempty"`
}

type GetNextWorkTaskResult struct {
	Found                bool                `json:"found"`
	Task                 WorkTask            `json:"task,omitempty"`
	Plan                 WorkPlan            `json:"plan,omitempty"`
	DependencySummary    []DependencySummary `json:"dependency_summary,omitempty"`
	EvidenceRefs         []string            `json:"evidence_refs,omitempty"`
	ContextPackRefs      []string            `json:"context_pack_refs,omitempty"`
	ResumeInstructions   string              `json:"resume_instructions,omitempty"`
	RequiredVerification string              `json:"required_verification,omitempty"`
	SafeReason           string              `json:"safe_reason,omitempty"`
	OpenCount            int                 `json:"open_count"`
	BlockedCount         int                 `json:"blocked_count"`
	ClaimedCount         int                 `json:"claimed_count"`
	Reason               string              `json:"reason,omitempty"`
}

type RequestReworkInput struct {
	ProjectID        string `json:"project_id"`
	TaskID           string `json:"task_id"`
	RequestedByRunID string `json:"requested_by_run_id"`
	Reason           string `json:"reason,omitempty"`
	TraceID          string `json:"trace_id,omitempty"`
	Budget           int    `json:"budget,omitempty"`
}

type ResumeWorkPlanInput struct {
	ProjectID string `json:"project_id,omitempty"`
	PlanID    string `json:"plan_id"`
}

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

type Store interface {
	CreateWorkPlan(context.Context, WorkPlan) (WorkPlan, error)
	GetWorkPlan(context.Context, string, string) (WorkPlan, error)
	GetWorkPlansByIDs(context.Context, string, []string) ([]WorkPlan, error)
	ListWorkPlans(context.Context, WorkPlanFilter) ([]WorkPlan, error)
	UpdateWorkPlan(context.Context, WorkPlan) (WorkPlan, error)
	CreateWorkTask(context.Context, WorkTask) (WorkTask, error)
	GetWorkTask(context.Context, string, string) (WorkTask, error)
	ListWorkTasksByPlanIDs(context.Context, string, []string) ([]WorkTask, error)
	ListWorkTasks(context.Context, WorkTaskFilter) ([]WorkTask, error)
	UpdateWorkTask(context.Context, WorkTask) (WorkTask, error)
	CreateAttachment(context.Context, Attachment) (Attachment, error)
	ListAttachments(context.Context, string, string) ([]Attachment, error)
	// DeleteWorkPlan permanently removes a work plan node. Scoped by project.
	// Idempotent: deleting an absent plan is a no-op.
	DeleteWorkPlan(context.Context, string, string) error
	// DeleteWorkTask permanently removes a work task node (not its plan).
	// Scoped by project. Idempotent.
	DeleteWorkTask(context.Context, string, string) error
	// DeleteAttachmentsForTask permanently removes every attachment node owned
	// by the given task, across all attachment kinds. Returns the count removed.
	// Scoped by project. Idempotent (0, nil) when none exist.
	DeleteAttachmentsForTask(context.Context, string, string) (int, error)
}

type UpdateWorkPlanStatusInput struct {
	ProjectID      string `json:"project_id,omitempty"`
	PlanID         string `json:"plan_id"`
	Status         string `json:"status"`
	SafeNextAction string `json:"safe_next_action,omitempty"`
	ResumeSummary  string `json:"resume_summary,omitempty"`
	Outcome        string `json:"outcome,omitempty"`
	CurrentTaskID  string `json:"current_task_id,omitempty"`
	RunID          string `json:"run_id,omitempty"`
	TraceID        string `json:"trace_id,omitempty"`
}

type UpdateWorkTaskStatusInput struct {
	WorkTaskActionInput
	Status string `json:"status"`
}

type WorkPlan struct {
	ID             string `json:"id"`
	ProjectID      string `json:"project_id"`
	PlanRef        string `json:"plan_ref"`
	UserRequestRef string `json:"user_request_ref,omitempty"`
	Title          string `json:"title"`
	GoalSummary    string `json:"goal_summary"`
	Status         string `json:"status"`
	OwnerAgent     string `json:"owner_agent,omitempty"`
	CreatedByRunID string `json:"created_by_run_id,omitempty"`
	// ChainRunID is the raw workflow chain run id that owns this plan, when the
	// plan was created by a chain compile. Unlike CreatedByRunID (which is a
	// synthetic workflow-safe token like "workflow-chain-run-<safeToken>"),
	// ChainRunID is the exact id returned by workflow_chains.list, so an
	// operator can match a plan to its chain run directly. Populated alongside
	// CreatedByRunID at compile time (T3.3). May be empty for plans created
	// outside a chain (manual plans, durable workflows). See
	// .ai/tasks/RUN_OBSERVABILITY_GAP.md §4 T3.3.
	ChainRunID       string    `json:"chain_run_id,omitempty"`
	TraceID          string    `json:"trace_id,omitempty"`
	CurrentTaskID    string    `json:"current_task_id,omitempty"`
	ResumeSummary    string    `json:"resume_summary,omitempty"`
	Outcome          string    `json:"outcome,omitempty"`
	IsolationMode    string    `json:"isolation_mode,omitempty"`
	ParallelGroupRef string    `json:"parallel_group_ref,omitempty"`
	WorkspaceRef     string    `json:"workspace_ref,omitempty"`
	GitBaseRef       string    `json:"git_base_ref,omitempty"`
	GitBranchRef     string    `json:"git_branch_ref,omitempty"`
	GitWorktreeRef   string    `json:"git_worktree_ref,omitempty"`
	CreatedAt        time.Time `json:"created_at"`
	UpdatedAt        time.Time `json:"updated_at"`
}

type WorkPlanDeleteCounts struct {
	Tasks       int `json:"tasks"`
	Attachments int `json:"attachments"`
}

type WorkPlanFilter struct {
	ProjectID  string   `json:"project_id,omitempty"`
	PlanIDs    []string `json:"plan_ids,omitempty"`
	Status     string   `json:"status,omitempty"`
	OwnerAgent string   `json:"owner_agent,omitempty"`
	PageSize   int      `json:"page_size,omitempty"`
	PageToken  string   `json:"page_token,omitempty"`
}

type WorkPlanStatusChange struct {
	ProjectID  string
	PlanID     string
	PlanRef    string
	OldStatus  string
	NewStatus  string
	OwnerAgent string
	ChangedAt  time.Time
}

type WorkPlanStatusChangeHandler interface {
	HandleWorkPlanStatusChanged(context.Context, WorkPlanStatusChange) error
}

type WorkTask struct {
	ID                      string   `json:"id"`
	ProjectID               string   `json:"project_id"`
	PlanID                  string   `json:"plan_id"`
	TaskRef                 string   `json:"task_ref"`
	Title                   string   `json:"title"`
	Description             string   `json:"description,omitempty"`
	Status                  string   `json:"status"`
	OwnerAgent              string   `json:"owner_agent,omitempty"`
	ClaimedByRunID          string   `json:"claimed_by_run_id,omitempty"`
	TraceID                 string   `json:"trace_id,omitempty"`
	EvidenceNeeded          []string `json:"evidence_needed,omitempty"`
	ContextPackRefs         []string `json:"context_pack_refs,omitempty"`
	FilesToRead             []string `json:"files_to_read,omitempty"`
	FilesToEdit             []string `json:"files_to_edit,omitempty"`
	LikelyFilesAffected     []string `json:"likely_files_affected,omitempty"`
	DependencyTaskIDs       []string `json:"dependency_task_ids,omitempty"`
	VerificationRequirement string   `json:"verification_requirement"`
	GitOpsVerificationMode  string   `json:"gitops_verification_mode,omitempty"`
	ExpectedOutput          string   `json:"expected_output,omitempty"`
	FailureCriteria         string   `json:"failure_criteria,omitempty"`
	ReviewGate              string   `json:"review_gate,omitempty"`
	Outcome                 string   `json:"outcome,omitempty"`
	ResumeInstructions      string   `json:"resume_instructions,omitempty"`
	BlockedReason           string   `json:"blocked_reason,omitempty"`
	// SafeNextAction is a persisted, queryable next-action hint for the task. It is
	// set by the automation service when a task is blocked (e.g. replacement-retry
	// limit reached) and by operator recovery (reset_recovery). Operators and the
	// orchestrator read it to decide what to do next without re-deriving it.
	SafeNextAction          string   `json:"safe_next_action,omitempty"`
	BlockedByTaskIDs        []string `json:"blocked_by_task_ids,omitempty"`
	KnowledgeCandidateRefs  []string `json:"knowledge_candidate_refs,omitempty"`
	EvidenceRefs            []string `json:"evidence_refs,omitempty"`
	ClaimRefs               []string `json:"claim_refs,omitempty"`
	VerifierResultRefs      []string `json:"verifier_result_refs,omitempty"`
	ReviewResultRefs        []string `json:"review_result_refs,omitempty"`
	ReviewExemptReason      string   `json:"review_exempt_reason,omitempty"`
	ArtifactRefs            []string `json:"artifact_refs,omitempty"`
	AgentRunIDs             []string `json:"agent_run_ids,omitempty"`
	DecompositionQuality    string   `json:"decomposition_quality"`
	AcceptanceCriteria      []string `json:"acceptance_criteria,omitempty"`
	StopConditions          []string `json:"stop_conditions,omitempty"`
	VerifierLadder          []string `json:"verifier_ladder,omitempty"`
	RegressionApplicability string   `json:"regression_test_applicability,omitempty"`
	DownstreamImpactRefs    []string `json:"downstream_impact_refs,omitempty"`
	OutputContract          string   `json:"output_contract,omitempty"`
	// Rework lifecycle (Phase 1 of the review-rework-loop fix). These fields
	// model reviewer-requested rework as a first-class signal, distinct from
	// approval refs (see .ai/tasks/review-rework-loop-audit-and-fix-plan.md R8:
	// a marker on ReviewResultRefs would be misread as a passing approval by
	// reviewResultRefIsPassing).
	//
	// ReworkRequestedRef holds the most recent rework marker ref
	// (rework_request_<taskID>_<nonce>). When non-empty, the guarded
	// rework transitions (verifying→in_progress, needs_review→in_progress)
	// become legal via validateReworkTransition. It is cleared once the
	// rework is consumed (the task is reclaimed for re-implementation).
	// ReworkCount is the lifetime number of rework requests accepted on this
	// task; it is the input to the rework-budget check (Phase 3).
	// ReworkBudgetRemaining is the remaining rework budget for this task
	// (seeded by the automation layer; 0 means unset/exhausted).
	// ReworkRequestedBy records the reviewer run that requested rework, for
	// auditability and the independence gate.
	// ReworkReason is the reviewer-supplied reason, surfaced to the
	// implementer on the next attempt.
	ReworkRequestedRef    string `json:"rework_requested_ref,omitempty"`
	ReworkCount           int    `json:"rework_count,omitempty"`
	ReworkBudgetRemaining int    `json:"rework_budget_remaining,omitempty"`
	ReworkRequestedBy     string `json:"rework_requested_by,omitempty"`
	ReworkReason          string `json:"rework_reason,omitempty"`
	// DirtyScopeRetryCount is the F4 dirty-scope loop guard counter: the number
	// of times this task has been requeued after a gitops_dirty_worktree_scope
	// failure. Unlike the run's AttemptCount (which blockTaskAfterOutOfScope-
	// DirtyPaths resets to 0 on every requeue, defeating canRetryRun), this
	// counter is task-level and monotonic across run resets, so it is the only
	// reliable signal for detecting the dirty-scope re-claim loop (the live
	// MASS-1929 25-claim incident). The automation layer increments it at the
	// dirty-scope requeue chokepoint and hard-blocks the task once it exceeds
	// Options.RecoveryMaxReplacementRunsPerTask. ResetWorkTaskRecovery clears it
	// so an operator reset gives the task a fresh budget.
	DirtyScopeRetryCount int       `json:"dirty_scope_retry_count,omitempty"`
	CreatedAt            time.Time `json:"created_at"`
	UpdatedAt            time.Time `json:"updated_at"`
	ClaimedAt            time.Time `json:"claimed_at,omitempty"`
	StartedAt            time.Time `json:"started_at,omitempty"`
	CompletedAt          time.Time `json:"completed_at,omitempty"`
}

type WorkTaskActionInput struct {
	ProjectID          string   `json:"project_id,omitempty"`
	TaskID             string   `json:"task_id"`
	OwnerAgent         string   `json:"owner_agent,omitempty"`
	RunID              string   `json:"run_id,omitempty"`
	TraceID            string   `json:"trace_id,omitempty"`
	Outcome            string   `json:"outcome,omitempty"`
	SafeNextAction     string   `json:"safe_next_action,omitempty"`
	BlockedReason      string   `json:"blocked_reason,omitempty"`
	BlockedByTaskIDs   []string `json:"blocked_by_task_ids,omitempty"`
	ContextPackRefs    []string `json:"context_pack_refs,omitempty"`
	EvidenceRefs       []string `json:"evidence_refs,omitempty"`
	ClaimRefs          []string `json:"claim_refs,omitempty"`
	KnowledgeRefs      []string `json:"knowledge_candidate_refs,omitempty"`
	ResumeInstructions string   `json:"resume_instructions,omitempty"`
	VerifierResultRefs []string `json:"verifier_result_refs,omitempty"`
	ReviewResultRefs   []string `json:"review_result_refs,omitempty"`
	ReviewExemptReason string   `json:"review_exempt_reason,omitempty"`
}

type WorkTaskFilter struct {
	ProjectID      string   `json:"project_id,omitempty"`
	PlanID         string   `json:"plan_id,omitempty"`
	PlanIDs        []string `json:"plan_ids,omitempty"`
	Status         string   `json:"status,omitempty"`
	OwnerAgent     string   `json:"owner_agent,omitempty"`
	ClaimedByRunID string   `json:"claimed_by_run_id,omitempty"`
	PageSize       int      `json:"page_size,omitempty"`
	PageToken      string   `json:"page_token,omitempty"`
}