projectautomation

type Automation struct {
	ID                    string    `json:"id"`
	ProjectID             string    `json:"project_id"`
	AutomationRef         string    `json:"automation_ref"`
	Title                 string    `json:"title"`
	Purpose               string    `json:"purpose"`
	Status                string    `json:"status"`
	AgentID               string    `json:"agent_id"`
	PlanID                string    `json:"plan_id,omitempty"`
	AllowedTaskRefs       []string  `json:"allowed_task_refs,omitempty"`
	RequiredReviewTaskIDs []string  `json:"required_review_task_ids,omitempty"`
	TriggerKind           string    `json:"trigger_kind"`
	SourceKind            string    `json:"source_kind,omitempty"`
	SchedulePolicy        string    `json:"schedule_policy,omitempty"`
	PermissionRef         string    `json:"permission_ref"`
	CreatedByRunID        string    `json:"created_by_run_id,omitempty"`
	TraceID               string    `json:"trace_id,omitempty"`
	CreatedAt             time.Time `json:"created_at"`
	UpdatedAt             time.Time `json:"updated_at"`
}

type AutomationAgent struct {
	ID              string        `json:"id"`
	DisplayName     string        `json:"display_name"`
	Purpose         string        `json:"purpose"`
	Enabled         bool          `json:"enabled"`
	AllowedSkills   []string      `json:"allowed_skills,omitempty"`
	AllowedTools    []string      `json:"allowed_tools,omitempty"`
	AllowedCommands []CommandSpec `json:"allowed_commands,omitempty"`
	DeniedCommands  []string      `json:"denied_commands,omitempty"`
	WorkspaceMode   string        `json:"workspace_mode"`
	NetworkPolicy   string        `json:"network_policy"`
	SecretPolicy    string        `json:"secret_policy"`
	LogPolicy       string        `json:"log_policy"`
	MaxRuntime      time.Duration `json:"max_runtime"`
	MaxRetries      int           `json:"max_retries"`
}

type AutomationAttempt struct {
	ID                 string    `json:"id"`
	ProjectID          string    `json:"project_id"`
	AutomationRunID    string    `json:"automation_run_id"`
	AttemptNumber      int       `json:"attempt_number"`
	RunnerKind         string    `json:"runner_kind"`
	CommandRef         string    `json:"command_ref,omitempty"`
	InputSummaryHash   string    `json:"input_summary_hash,omitempty"`
	OutputSummaryHash  string    `json:"output_summary_hash,omitempty"`
	Status             string    `json:"status"`
	FailureCategory    string    `json:"failure_category,omitempty"`
	DurationMS         int64     `json:"duration_ms"`
	VerifierResultRefs []string  `json:"verifier_result_refs,omitempty"`
	EvidenceRefs       []string  `json:"evidence_refs,omitempty"`
	ClaimRefs          []string  `json:"claim_refs,omitempty"`
	KnowledgeRefs      []string  `json:"knowledge_candidate_refs,omitempty"`
	CreatedAt          time.Time `json:"created_at"`
	FinishedAt         time.Time `json:"finished_at,omitempty"`
}

type AutomationFilter struct {
	ProjectID string `json:"project_id,omitempty"`
	Status    string `json:"status,omitempty"`
	AgentID   string `json:"agent_id,omitempty"`
}

type AutomationParallelBatch struct {
	ID                string    `json:"id"`
	ProjectID         string    `json:"project_id"`
	AutomationRunID   string    `json:"automation_run_id"`
	OrchestratorRunID string    `json:"orchestrator_run_id"`
	PlanID            string    `json:"plan_id"`
	TaskIDs           []string  `json:"task_ids"`
	Status            string    `json:"status"`
	SafetyReason      string    `json:"safety_reason"`
	ConflictSummary   string    `json:"conflict_summary,omitempty"`
	CreatedAt         time.Time `json:"created_at"`
	UpdatedAt         time.Time `json:"updated_at"`
}

type AutomationRun struct {
	ID                string    `json:"id"`
	ProjectID         string    `json:"project_id"`
	AutomationID      string    `json:"automation_id"`
	AgentID           string    `json:"agent_id"`
	PlanID            string    `json:"plan_id"`
	TaskID            string    `json:"task_id"`
	WorkTaskStatus    string    `json:"work_task_status"`
	Status            string    `json:"status"`
	RunnerKind        string    `json:"runner_kind"`
	AgentRunID        string    `json:"agent_run_id,omitempty"`
	TraceID           string    `json:"trace_id,omitempty"`
	AttemptCount      int       `json:"attempt_count"`
	OrchestratorRunID string    `json:"orchestrator_run_id,omitempty"`
	ParentRunID       string    `json:"parent_run_id,omitempty"`
	WorkerRunIDs      []string  `json:"worker_run_ids,omitempty"`
	ParallelGroupID   string    `json:"parallel_group_id,omitempty"`
	FailureCategory   string    `json:"failure_category,omitempty"`
	SafeSummary       string    `json:"safe_summary,omitempty"`
	StartedAt         time.Time `json:"started_at,omitempty"`
	FinishedAt        time.Time `json:"finished_at,omitempty"`
	CreatedAt         time.Time `json:"created_at"`
	UpdatedAt         time.Time `json:"updated_at"`
}

type ClaimNextRunInput struct {
	ProjectID  string `json:"project_id,omitempty"`
	AgentID    string `json:"agent_id,omitempty"`
	RunnerKind string `json:"runner_kind,omitempty"`
}

type ClaimedRun struct {
	Run        AutomationRun  `json:"run"`
	CodexInput CodexTaskInput `json:"codex_input"`
	TimeoutMS  int64          `json:"timeout_ms"`
}

type CodexCommand struct {
	Path      string
	Args      []string
	Env       []string
	StdinFile string
	Timeout   time.Duration
}

type CodexCommandInput struct {
	BinaryPath string
	InputPath  string
	Timeout    time.Duration
	EnvAllow   map[string]string
}

type CodexRunResult struct {
	ExitCode        int
	Duration        time.Duration
	TimedOut        bool
	OutputTruncated bool
}

type CodexTaskInput struct {
	SchemaVersion           int      `json:"schema_version"`
	ProjectID               string   `json:"project_id"`
	AutomationRunID         string   `json:"automation_run_id"`
	TraceID                 string   `json:"trace_id,omitempty"`
	PlanID                  string   `json:"plan_id"`
	TaskID                  string   `json:"task_id"`
	TaskRef                 string   `json:"task_ref"`
	Title                   string   `json:"title"`
	Description             string   `json:"description,omitempty"`
	EvidenceNeeded          []string `json:"evidence_needed,omitempty"`
	ContextPackRefs         []string `json:"context_pack_refs,omitempty"`
	LikelyFilesAffected     []string `json:"likely_files_affected,omitempty"`
	VerificationRequirement string   `json:"verification_requirement"`
	ExpectedOutput          string   `json:"expected_output,omitempty"`
	FailureCriteria         string   `json:"failure_criteria,omitempty"`
	ResumeInstructions      string   `json:"resume_instructions,omitempty"`
	RunnerInstructions      []string `json:"runner_instructions"`
}

type CommandSpec struct {
	Command string   `json:"command"`
	Args    []string `json:"args,omitempty"`
}

type CompleteAttemptInput struct {
	ProjectID          string   `json:"project_id,omitempty"`
	RunID              string   `json:"run_id"`
	Status             string   `json:"status"`
	FailureCategory    string   `json:"failure_category,omitempty"`
	DurationMS         int64    `json:"duration_ms,omitempty"`
	VerifierResultRefs []string `json:"verifier_result_refs,omitempty"`
	EvidenceRefs       []string `json:"evidence_refs,omitempty"`
	ClaimRefs          []string `json:"claim_refs,omitempty"`
	ReviewRefs         []string `json:"review_result_refs,omitempty"`
	KnowledgeRefs      []string `json:"knowledge_candidate_refs,omitempty"`
}

type ComputeParallelBatchInput struct {
	ProjectID         string   `json:"project_id,omitempty"`
	AutomationRunID   string   `json:"automation_run_id,omitempty"`
	OrchestratorRunID string   `json:"orchestrator_run_id,omitempty"`
	PlanID            string   `json:"plan_id,omitempty"`
	TaskIDs           []string `json:"task_ids,omitempty"`
	MaxTasks          int      `json:"max_tasks,omitempty"`
}

type ConfidenceGovernance interface {
	RecordConfidenceRef(context.Context, GovernanceConfidenceInput) (string, error)
}

type CreateAutomationInput struct {
	ProjectID             string   `json:"project_id,omitempty"`
	AutomationRef         string   `json:"automation_ref"`
	Title                 string   `json:"title"`
	Purpose               string   `json:"purpose"`
	Status                string   `json:"status,omitempty"`
	AgentID               string   `json:"agent_id"`
	PlanID                string   `json:"plan_id,omitempty"`
	AllowedTaskRefs       []string `json:"allowed_task_refs,omitempty"`
	RequiredReviewTaskIDs []string `json:"required_review_task_ids,omitempty"`
	TriggerKind           string   `json:"trigger_kind,omitempty"`
	SchedulePolicy        string   `json:"schedule_policy,omitempty"`
	PermissionRef         string   `json:"permission_ref"`
	SourceKind            string   `json:"source_kind,omitempty"`
	CreatedByRunID        string   `json:"created_by_run_id,omitempty"`
	TraceID               string   `json:"trace_id,omitempty"`
}

type EvidenceGovernance interface {
	CreateActionRef(context.Context, GovernanceActionInput) (string, error)
	CreateOutcomeRef(context.Context, GovernanceOutcomeInput) (string, error)
}

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

type ExecutorOptions struct {
	Enabled               bool
	RunnerEnabled         bool
	RunnerExecution       string
	PollInterval          time.Duration
	GlobalWorkerCount     int
	PerProjectWorkerLimit int
	PerAgentWorkerLimit   int
	ProjectIDs            []string
}

type GovernanceActionInput struct {
	ProjectID    string
	AutomationID string
	RunID        string
	TaskID       string
	ActionKind   string
}

type GovernanceConfidenceInput struct {
	ProjectID    string
	RunID        string
	TaskID       string
	ClaimRefs    []string
	EvidenceRefs []string
	VerifierRefs []string
	ReviewRefs   []string
	OutcomeRef   string
}

type GovernanceKnowledgeCandidateInput struct {
	ProjectID     string
	RunID         string
	TaskID        string
	ClaimRefs     []string
	EvidenceRefs  []string
	VerifierRefs  []string
	ReviewRefs    []string
	OutcomeRef    string
	ConfidenceRef string
}

type GovernanceOptions struct {
	Evidence   EvidenceGovernance
	Confidence ConfidenceGovernance
	Knowledge  KnowledgeGovernance
}

type GovernanceOutcomeInput struct {
	ProjectID     string
	AutomationID  string
	RunID         string
	TaskID        string
	AttemptID     string
	Status        string
	DurationMS    int64
	VerifierRefs  []string
	EvidenceRefs  []string
	ClaimRefs     []string
	ReviewRefs    []string
	KnowledgeRefs []string
}

type KnowledgeGovernance interface {
	CreateCandidateRef(context.Context, GovernanceKnowledgeCandidateInput) (string, error)
}

type Options struct {
	Enabled                   bool
	RunnerEnabled             bool
	RequireCodexWhenAvailable bool
	AllowManualRunner         bool
	RunnerExecution           string
	MaxParallelTasks          int
	DefaultMaxRuntime         time.Duration
	CodexBinaryPath           string
	Agents                    []AutomationAgent
	PermissionResolver        PermissionResolver
	Governance                GovernanceOptions
	WorkPlanStatusTrigger     WorkPlanStatusTriggerOptions
}

type PermissionCheckInput struct {
	ProjectID       string
	AutomationID    string
	AutomationRef   string
	AgentID         string
	PermissionRef   string
	RunnerKind      string
	RunnerExecution string
}

type PermissionResolver interface {
	CheckAutomationPermission(context.Context, PermissionCheckInput) (PermissionSnapshotMetadata, error)
}

type PermissionSnapshotMetadata struct {
	PermissionRef      string
	AgentID            string
	AllowedRunnerKinds []string
	DeniedCommands     []string
}

type RunFilter struct {
	ProjectID         string `json:"project_id,omitempty"`
	AutomationID      string `json:"automation_id,omitempty"`
	PlanID            string `json:"plan_id,omitempty"`
	Status            string `json:"status,omitempty"`
	OrchestratorRunID string `json:"orchestrator_run_id,omitempty"`
}

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

type Store interface {
	CreateAutomation(context.Context, Automation) (Automation, error)
	GetAutomation(context.Context, string, string) (Automation, error)
	ListAutomations(context.Context, AutomationFilter) ([]Automation, error)
	UpdateAutomation(context.Context, Automation) (Automation, error)
	CreateRun(context.Context, AutomationRun) (AutomationRun, error)
	GetRun(context.Context, string, string) (AutomationRun, error)
	ListRuns(context.Context, RunFilter) ([]AutomationRun, error)
	UpdateRun(context.Context, AutomationRun) (AutomationRun, error)
	CreateAttempt(context.Context, AutomationAttempt) (AutomationAttempt, error)
	CreateParallelBatch(context.Context, AutomationParallelBatch) (AutomationParallelBatch, error)
	GetParallelBatch(context.Context, string, string) (AutomationParallelBatch, error)
}

type SubmitRunInput struct {
	ProjectID         string   `json:"project_id,omitempty"`
	AutomationID      string   `json:"automation_id"`
	PlanID            string   `json:"plan_id,omitempty"`
	TaskID            string   `json:"task_id,omitempty"`
	OwnerAgent        string   `json:"owner_agent,omitempty"`
	RunnerKind        string   `json:"runner_kind,omitempty"`
	OrchestratorRunID string   `json:"orchestrator_run_id,omitempty"`
	ParentRunID       string   `json:"parent_run_id,omitempty"`
	EvidenceRefs      []string `json:"evidence_refs,omitempty"`
	VerifierRefs      []string `json:"verifier_result_refs,omitempty"`
	SafeNextAction    string   `json:"safe_next_action,omitempty"`
}

type UpdateAutomationStatusInput struct {
	ProjectID    string `json:"project_id,omitempty"`
	AutomationID string `json:"automation_id"`
	Status       string `json:"status"`
	RunID        string `json:"run_id,omitempty"`
	TraceID      string `json:"trace_id,omitempty"`
}

type WorkPlanStatusTriggerOptions struct {
	Enabled  bool
	Statuses []string
}

type WorkTaskAPI interface {
	GetWorkTask(context.Context, string, string) (projectworkplan.WorkTask, error)
	ListOpenWorkTasks(context.Context, projectworkplan.WorkTaskFilter) ([]projectworkplan.WorkTask, error)
	ClaimWorkTask(context.Context, projectworkplan.WorkTaskActionInput) (projectworkplan.WorkTask, error)
	StartWorkTask(context.Context, projectworkplan.WorkTaskActionInput) (projectworkplan.WorkTask, error)
	AttachEvidence(context.Context, projectworkplan.AttachInput) (projectworkplan.Attachment, error)
	AttachVerifierResult(context.Context, projectworkplan.AttachInput) (projectworkplan.Attachment, error)
	CompleteWorkTask(context.Context, projectworkplan.WorkTaskActionInput) (projectworkplan.WorkTask, error)
	FailWorkTask(context.Context, projectworkplan.WorkTaskActionInput) (projectworkplan.WorkTask, error)
	BlockWorkTask(context.Context, projectworkplan.WorkTaskActionInput) (projectworkplan.WorkTask, error)
}