coordinator

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

type AgentConfig struct {
	ID                  string   `yaml:"id" json:"id"`
	Label               string   `yaml:"label" json:"label"`
	Inbox               string   `yaml:"inbox" json:"inbox"`                                 // Message inbox to watch
	Workspace           string   `yaml:"workspace" json:"workspace"`                         // Base directory for worktrees
	Capabilities        []string `yaml:"capabilities" json:"capabilities"`                   // e.g., ["code", "research", "docs"]
	TriggerOnComplete   []string `yaml:"trigger_on_complete" json:"trigger_on_complete"`     // Agent IDs to trigger when this agent completes
	AutoApproveHandoffs bool     `yaml:"auto_approve_handoffs" json:"auto_approve_handoffs"` // Skip approval for agent-to-agent handoffs
	AutoMerge           bool     `yaml:"auto_merge" json:"auto_merge"`                       // Automatically merge approved work
	SkipApproval        bool     `yaml:"skip_approval" json:"skip_approval"`                 // Skip approval workflow entirely (for script agents)
	Provider            string   `yaml:"provider" json:"provider"`                           // "claude" or "gemini"
	MergeBranch         string   `yaml:"merge_branch" json:"merge_branch"`                   // Target branch for merges (e.g., "dev", "main")
	MaxConcurrentTasks  int      `yaml:"max_concurrent_tasks" json:"max_concurrent_tasks"`   // 0 = unlimited
	SessionContinuity   bool     `yaml:"session_continuity" json:"session_continuity"`       // Use --resume for Claude Code / --conversation-id for Gemini

	// Generic workflow configuration (v0.6.3+)
	Invoke           *InvokeConfig   `yaml:"invoke" json:"invoke,omitempty"`                       // How to invoke this agent
	OutputMarkers    []string        `yaml:"output_markers" json:"output_markers,omitempty"`       // Markers to extract from output (e.g., "DESIGN_DOC_PATH:")
	ArtifactPatterns []string        `yaml:"artifact_patterns" json:"artifact_patterns,omitempty"` // File patterns for artifacts (e.g., "*.md", "design_docs/**")
	Approval         *ApprovalConfig `yaml:"approval" json:"approval,omitempty"`                   // Approval workflow configuration

	// Per-agent system prompt (v0.8.0+)
	// Appended to the global meta-prompt for agent-specific instructions.
	SystemPrompt string `yaml:"system_prompt" json:"system_prompt,omitempty"`

	// Per-agent model override (v0.8.0+)
	// Controls which Claude model is used for this agent's tasks.
	// Examples: "opus", "sonnet", "haiku", "claude-opus-4-5-20251101"
	// If empty, falls back to the executor's default (currently "haiku").
	Model string `yaml:"model" json:"model,omitempty"`

	// Per-agent execution timeout (v0.8.1+)
	// Go duration string (e.g., "15m", "30m", "1h"). Default: 60m (hard ceiling).
	Timeout string `yaml:"timeout" json:"timeout,omitempty"`

	// Per-agent idle timeout (v0.8.1+)
	// Kill if no streaming events for this long. Default: 3m.
	// Distinguishes "agent is stuck" from "agent is working but slow".
	IdleTimeout string `yaml:"idle_timeout" json:"idle_timeout,omitempty"`

	// Per-agent effort level (Claude Code 2.1.47+: "low", "medium", "high")
	// Controls how much effort Claude puts into the task. Default: unset (Claude's default).
	Effort string `yaml:"effort" json:"effort,omitempty"`

	// Per-agent plugin directories (M-CLOUD-PLUGIN-SKILLS, v0.9.1).
	// Local paths to Claude Code plugin directories containing .claude-plugin/plugin.json.
	// Passed as --plugin-dir flags. Complementary to coordinator-level PluginRepo (for cloud).
	PluginDirs []string `yaml:"plugin_dirs" json:"plugin_dirs,omitempty"`

	// Per-agent third-party plugin configuration (M-CLOUD-PLUGIN-SKILLS, v0.9.1).
	// Installs marketplace and custom plugins before task execution.
	Plugins *PluginsConfig `yaml:"plugins" json:"plugins,omitempty"`

	// Per-agent auth mode override (M-CLOUD-DUAL-AUTH, v0.9.2).
	// "oauth" (default) or "apikey" — selects Cloud Run Job template.
	// User-provided API keys from messages override this setting.
	AuthMode string `yaml:"auth_mode" json:"auth_mode,omitempty"`

	// Per-agent git mode (M-GIT-GUARDRAILS, v0.9.2).
	// Controls how the PreToolUse git_guard.sh hook restricts git operations:
	// "guardrails" (default) — reads + commits allowed, push only to expected branch
	// "strict" — all git write operations blocked (read-only)
	// "permissive" — all allowed except force-push and reset --hard
	GitMode string `yaml:"git_mode" json:"git_mode,omitempty"`

	// Subdirectory within the workspace for monorepo support (M-PKG-AUTONOMOUS-UPDATES, v0.10.0).
	// When set, the agent's working directory is scoped to this path within the worktree.
	// Used for package agents that operate on a specific package within a monorepo.
	// Example: "packages/auth" for a package agent in the ailang-packages monorepo.
	Subdirectory string `yaml:"subdirectory" json:"subdirectory,omitempty"`
}

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

type AgentResult struct {
	// Artifact paths (set whichever is relevant)
	ArtifactPath    string   // Primary artifact (design doc, sprint plan, etc.)
	ArtifactContent string   // Optional: content for GitHub comment display
	AllArtifacts    []string // All discovered artifacts from git diff

	// Execution metrics
	Duration     time.Duration
	Cost         float64
	TokensUsed   int
	InputTokens  int
	OutputTokens int

	// Implementation-specific (for sprint-executor type agents)
	BranchName    string
	WorktreePath  string
	FilesCreated  []string
	FilesModified []string
}

type AnalyzedTask struct {
	Task        *Task
	Type        TaskType
	Keywords    []string
	Fingerprint uint64
	DuplicateOf string // ID of duplicate task, if any

	// Capability detection (migrated from internal/agent)
	Capabilities  []Capability `json:"capabilities,omitempty"`   // Detected capability requirements
	ImpactLevel   string       `json:"impact_level,omitempty"`   // "low", "medium", or "high"
	EstimatedCost float64      `json:"estimated_cost,omitempty"` // Pre-execution cost estimate in USD
}

type ApprovalCallback func(request *ApprovalRequest)

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

type ApprovalConfig struct {
	NeedsLabel            string `yaml:"needs_label" json:"needs_label"`                         // Label to add when awaiting approval (e.g., "needs-design-approval")
	ApprovedLabel         string `yaml:"approved_label" json:"approved_label"`                   // Label that triggers next stage (e.g., "design-approved")
	GithubCommentTemplate string `yaml:"github_comment_template" json:"github_comment_template"` // Template for GitHub comment on completion
}

type ApprovalEvent struct {
	TaskID      string
	IssueNumber int
	Label       string
	EventType   ApprovalEventType
	// Feedback contains human comments harvested from GitHub (may be empty)
	Feedback string
	// FeedbackAuthor is the author of the most recent human comment
	FeedbackAuthor string
	// Channel indicates where the approval came from (github, dashboard, cli)
	Channel string
}

type ApprovalEventType string

type ApprovalHandler func(ctx context.Context, event *ApprovalEvent) error

type ApprovalParams struct {
	TaskID      string // Required: task ID or approval ID (apr-xxx converted to task-xxx)
	Action      string // Required: "approve" or "reject"
	ApprovedBy  string // Required: who is approving/rejecting (e.g., "cli-user", "dashboard-user")
	Channel     string // Required: source channel ("cli", "dashboard", "daemon")
	Feedback    string // Optional: feedback text for rejections
	MergeBranch string // Optional: target branch for merge (defaults from config, then channel)

	// Behavior options
	SkipMerge         bool // If true, don't merge worktree on approval
	KeepWorktree      bool // If true, don't clean up worktree after merge
	RetriggerOnReject bool // If true, send feedback to agent for re-attempt (feedback loop)

	// Dependencies (injected by caller)
	Store         Store                  // Required: coordinator store for task/approval operations
	MsgStore      messaging.MessageStore // Optional: messaging store for sending feedback to agents
	GitHubPoster  *GitHubPoster          // Optional: for posting feedback to GitHub issues
	AgentRegistry *AgentRegistry         // Optional: for looking up per-agent merge branch
	ObsBackend    observatory.Backend    // Optional: for updating chain/stage status (M-CHAINS-SIMPLIFY)
}

type ApprovalRequest struct {
	ID           string         `json:"id"`
	TaskID       string         `json:"task_id"`
	ThreadID     string         `json:"thread_id,omitempty"`
	Type         ApprovalType   `json:"type"`
	Status       ApprovalStatus `json:"status"`
	Title        string         `json:"title"`
	Description  string         `json:"description"`
	DiffSummary  string         `json:"diff_summary,omitempty"`
	FilesChanged []string       `json:"files_changed,omitempty"`
	CreatedAt    time.Time      `json:"created_at"`
	ResolvedAt   *time.Time     `json:"resolved_at,omitempty"`
	ResolvedBy   string         `json:"resolved_by,omitempty"`
	Timeout      time.Duration  `json:"timeout"`
	AutoReject   bool           `json:"auto_reject"` // Reject on timeout instead of approve

	// Handoff-specific fields (used when Type == ApprovalTypeHandoff)
	SourceAgentID string `json:"source_agent_id,omitempty"` // Agent that completed the task
	TargetAgentID string `json:"target_agent_id,omitempty"` // Agent to hand off to
	SessionID     string `json:"session_id,omitempty"`      // Claude Code/Gemini CLI session for continuity
	HandoffData   string `json:"handoff_data,omitempty"`    // Additional context for handoff
}

type ApprovalRequestRecord struct {
	ID          string     `json:"id"`
	TaskID      string     `json:"task_id"`
	Type        string     `json:"type"`
	Description string     `json:"description"`
	ContextJSON string     `json:"context_json,omitempty"`
	Status      string     `json:"status"`
	ResolvedBy  string     `json:"resolved_by,omitempty"`
	CreatedAt   time.Time  `json:"created_at"`
	ResolvedAt  *time.Time `json:"resolved_at,omitempty"`
	TimeoutAt   *time.Time `json:"timeout_at,omitempty"`
	AutoReject  bool       `json:"auto_reject"`
}

type ApprovalResult struct {
	Success       bool
	Message       string   // Human-readable result message
	MergeCommit   string   // Commit hash if merged
	MergedFiles   []string // Files that were merged
	ConflictFiles []string // Files with conflicts (if merge failed)
	NewTaskID     string   // ID of new task if re-triggered
	Error         string   // Error message if failed
}

type ApprovalStatus string

type ApprovalStore interface {
	CreateApprovalRequest(ctx context.Context, req *ApprovalRequestRecord) error
	GetApprovalRequest(ctx context.Context, id string) (*ApprovalRequestRecord, error)
	GetApprovalRequestByTask(ctx context.Context, taskID string) (*ApprovalRequestRecord, error)
	ListPendingApprovals(ctx context.Context) ([]*ApprovalRequestRecord, error)
	ResolveApprovalRequest(ctx context.Context, id string, status string, resolvedBy string) error
}

type ApprovalType string

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

type ArtifactDiscovery struct {
	WorktreePath string   // Path to git worktree
	Patterns     []string // Glob patterns to filter files (e.g., "*.md", "design_docs/**")
	BaseBranch   string   // Base branch to compare against (default: auto-detect)
	BaseCommit   string   // Base commit hash (stable - branch may have moved since worktree creation)
}

type BudgetsConfig struct {
	Global    *GlobalBudget             `yaml:"global"`
	Providers map[string]*ProviderLimit `yaml:"providers"`
}

type Capability struct {
	Type        CapabilityType `json:"type"`
	Paths       []string       `json:"paths,omitempty"`        // Affected paths or URLs
	BudgetDelta float64        `json:"budget_delta,omitempty"` // Estimated cost if Budget type
}

type CapabilityDetector struct{}

type CapabilityType string

type CascadeCircuitBreaker struct {
	MaxFailures   int
	CorrelationID string
	// contains filtered or unexported fields
}

type ChangeClass int

type CloudDispatcher interface {
	// Dispatch triggers execution of a task on the remote backend.
	// The task is already persisted in the task store — the dispatcher
	// only needs to trigger execution with the given parameters.
	Dispatch(ctx context.Context, params DispatchParams) error
}

type CommentData struct {
	// Task information
	TaskID    string
	Title     string
	Type      string
	Priority  int
	Stage     string
	Status    string
	Agent     string
	Workspace string

	// GitHub context
	IssueNumber int
	Repository  string

	// Timing
	StartedAt   *time.Time
	CompletedAt *time.Time
	Duration    time.Duration

	// Results
	Success      bool
	Output       string
	Error        string
	Cost         float64
	TokensUsed   int
	InputTokens  int
	OutputTokens int

	// Evaluation results (sprint-evaluator)
	EvaluationScore      int
	EvaluationResult     string // "pass" or "fail"
	EvaluationRound      int
	EvaluationReportPath string
	FeedbackSummary      string

	// Artifacts
	DesignDocPath     string
	DesignDocContent  string // Actual markdown content of the design doc
	SprintPlanPath    string
	SprintPlanContent string // Actual markdown content of the sprint plan
	WorktreePath      string
	BranchName        string
	FilesCreated      []string
	FilesModified     []string

	// Custom data
	Extra map[string]interface{}
}

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

type Config struct {
	PollInterval         time.Duration // How often to check for new messages
	MaxWorktrees         int           // Maximum concurrent worktrees
	LogFile              string        // Path to log file
	PIDFile              string        // Path to PID file
	StateDir             string        // Directory for state files
	ApprovalPollInterval time.Duration // How often to poll GitHub for approval labels (M-COORD-GITHUB-AUTO-ROUTING)
	DevMode              bool          // Skip stale detector + approval watcher, increase poll interval
}

type ConfigFile struct {
	Coordinator *CoordinatorConfig `yaml:"coordinator"`
	Budgets     *BudgetsConfig     `yaml:"budgets"`
	Firebase    *FirebaseConfig    `yaml:"firebase"`
	Workspaces  *WorkspacesConfig  `yaml:"workspaces"`
}

type CoordinatorConfig struct {
	Agents          []*AgentConfig    `yaml:"agents" json:"agents"`
	DefaultProvider string            `yaml:"default_provider" json:"default_provider"`
	ClaudePath      string            `yaml:"claude_path" json:"claude_path,omitempty"` // Explicit path to Claude CLI binary (empty = auto-detect: native > PATH > NVM)
	MergeBranch     string            `yaml:"merge_branch" json:"merge_branch"`         // Target branch for approvals (default: "dev")
	GitHubSync      *GitHubSyncConfig `yaml:"github_sync" json:"github_sync"`

	// PluginRepo is a git URL for a shared skills plugin (M-CLOUD-PLUGIN-SKILLS, v0.9.1).
	// In cloud mode, this repo is cloned and passed as --plugin-dir to Claude CLI.
	// Example: "https://github.com/sunholo-data/ailang_bootstrap.git"
	PluginRepo string `yaml:"plugin_repo" json:"plugin_repo,omitempty"`

	// DevMode disables stale task detector and approval watcher to reduce
	// Firestore reads during local development. (M-COST1)
	DevMode bool `yaml:"dev_mode" json:"dev_mode,omitempty"`
}

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

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

type DesignDocResult struct {
	Path         string   // Path to .md file (may be empty if no .md found)
	AllArtifacts []string // All discovered artifacts (any file type)
	Duration     time.Duration
	Cost         float64
	TokensUsed   int
	InputTokens  int
	OutputTokens int
}

type DetailedStats struct {
	Count        int     `json:"count"`
	CostUSD      float64 `json:"cost_usd"`
	InputTokens  int     `json:"input_tokens"`
	OutputTokens int     `json:"output_tokens"`
}

type DispatchParams struct {
	TaskID       string  // Coordinator task ID (e.g., "task-29404032")
	AgentID      string  // Target agent (e.g., "sprint-executor")
	Workspace    string  // Workspace path
	Provider     string  // AI provider ("claude" or "gemini")
	Directive    string  // Task prompt (optional — job can fetch from Firestore)
	RepoURL      string  // Git repo URL
	Branch       string  // Base branch (default: "dev")
	PushBranch   string  // If set, push directly to this branch (skip coordinator/ branch creation)
	PluginRepo   string  // Git URL for shared skills plugin (M-CLOUD-PLUGIN-SKILLS, v0.9.1)
	Model        string  // AI model override (e.g., "sonnet", "opus") — from agent config
	Timeout      string  // Executor timeout (e.g., "15m", "60m") — from agent config (M-CLOUD-OAUTH)
	AuthMode     string  // "oauth" (default) or "apikey" — selects Cloud Run Job template (M-CLOUD-DUAL-AUTH)
	APIKey       string  // User-provided Anthropic API key, only when AuthMode == "apikey"
	MaxCostUSD   float64 // Per-task cost budget (0 = unlimited) — M-CLOUD-PROGRESS-TRACKING
	GitMode      string  // "guardrails", "strict", "permissive" — M-GIT-GUARDRAILS
	SiteSlug     string  // Website site slug for commit message — M-HARNESS-COMMIT-CONTRACT
	BriefID      string  // Brief ID for commit message — M-HARNESS-COMMIT-CONTRACT
	Subdirectory string  // Monorepo subdirectory for package agents — M-PKG-AUTONOMOUS-UPDATES
}

type EventBroadcaster func(*websocket.TaskStreamEvent)

type EventStorer func(*TaskEventRecord) error

type EventsResponse struct {
	TaskID      string             `json:"task_id"`
	TotalEvents int                `json:"total_events"`
	TotalTurns  int                `json:"total_turns"`
	Iteration   int                `json:"iteration,omitempty"`
	Events      []*TaskEventRecord `json:"events"`
}

type ExecuteOptions struct {
	Timeout      time.Duration // Hard ceiling (max wall-clock time)
	IdleTimeout  time.Duration // Kill if no events for this long (v0.8.1+)
	DryRun       bool
	Workspace    string                // Working directory for the task
	Model        string                // Model to use (provider-specific)
	EventHandler executor.EventHandler // Optional handler for streaming events

	// Observatory context for trace linking (M-TASK-HIERARCHY)
	ObservatoryContext *ObservatoryContext

	// InvokeConfig for script execution (v0.6.4+)
	// Set when the agent has invoke.type: "script"
	InvokeConfig *InvokeConfig

	// AgentConfig for system prompt construction (v0.8.0+)
	// Used by providers to build the meta-prompt with agent-specific instructions.
	AgentConfig *AgentConfig

	// Effort level for Claude Code (low/medium/high). Empty = Claude's default.
	Effort string

	// PluginDirs for Claude Code (M-CLOUD-PLUGIN-SKILLS, v0.9.1).
	// Paths to plugin directories passed as --plugin-dir flags.
	PluginDirs []string

	// Plugins for per-agent third-party plugin installation (M-CLOUD-PLUGIN-SKILLS, v0.9.1).
	Plugins *PluginsConfig
}

type ExecuteResult struct {
	Success    bool
	Output     string
	Error      string
	Provider   string
	Duration   time.Duration
	Cost       float64
	TokensUsed int // Total tokens (InputTokens + OutputTokens)
	// Detailed token breakdown
	InputTokens  int
	OutputTokens int
	// Execution detail
	NumTurns      int
	ToolCallCount int
	// Files affected
	FilesCreated  []string
	FilesModified []string
	// Session continuity (for agent-to-agent handoffs)
	SessionID string // Claude Code --resume ID or Gemini CLI --conversation-id
}

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

type FirebaseConfig struct {
	ProjectID string `yaml:"project_id"` // GCP/Firebase project ID (e.g., "ailang-dev")
}

type FormatOptions struct {
	// ShowTimestamps includes timestamps in text output
	ShowTimestamps bool
	// ShowToolInputs includes full tool input in text output
	ShowToolInputs bool
	// MaxTextLength truncates long text blocks (0 = no limit)
	MaxTextLength int
	// TurnFilter only shows specific turn (0 = all turns)
	TurnFilter int
	// TypeFilter only shows specific event types (empty = all types)
	TypeFilter []string
}

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

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

type GitHubSyncConfig struct {
	// Legacy single-repo fields (for backwards compatibility)
	Enabled           bool     `yaml:"enabled" json:"enabled"`
	IntervalSecs      int      `yaml:"interval_secs" json:"interval_secs"`               // Default: 300 (5 min)
	WatchLabels       []string `yaml:"watch_labels" json:"watch_labels"`                 // Filter by labels
	TargetInbox       string   `yaml:"target_inbox" json:"target_inbox"`                 // Where to send imported issues
	ResyncLabels      bool     `yaml:"resync_labels" json:"resync_labels"`               // Re-check labels on imported messages
	ResyncIntervalSec int      `yaml:"resync_interval_secs" json:"resync_interval_secs"` // Default: 3600 (1 hour)

	// Multi-repo configuration (v0.6.6+)
	// If Repos is non-empty, uses multi-repo mode (ignores legacy fields above except ResyncLabels)
	Repos []RepoSyncConfig `yaml:"repos" json:"repos"`
}

type GlobalBudget struct {
	WorkspaceBudget  float64 `yaml:"workspace_budget"`
	DailyBudget      float64 `yaml:"daily_budget"`
	TaskMaxCost      float64 `yaml:"task_max_cost"`
	WarningThreshold float64 `yaml:"warning_threshold"`
}

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

type HumanFeedback struct {
	TaskID    string    // Task being reviewed
	Iteration int       // Current iteration of the task
	Feedback  string    // Human's feedback text
	Action    string    // "reject" or "approve"
	Timestamp time.Time // When feedback was provided
	UserID    string    // Who provided feedback (optional)
}

type ImplementResult struct {
	BranchName    string
	WorktreePath  string
	Duration      time.Duration
	Cost          float64
	TokensUsed    int
	InputTokens   int
	OutputTokens  int
	FilesCreated  []string
	FilesModified []string
}

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

type InvokeConfig struct {
	Type         string `yaml:"type" json:"type"`                   // "skill", "agent", "prompt", or "script"
	Name         string `yaml:"name" json:"name"`                   // Skill/agent name (for skill/agent types)
	Template     string `yaml:"template" json:"template"`           // Custom template (for prompt type) - inline
	TemplateFile string `yaml:"template_file" json:"template_file"` // Path to template file (for prompt type) - v0.6.7+

	// Script-specific fields (v0.6.4+)
	// Used when Type == "script" for deterministic workflow execution
	Command        string `yaml:"command" json:"command,omitempty"`                   // Script path or inline command
	Shell          string `yaml:"shell" json:"shell,omitempty"`                       // Shell to use (default: /bin/sh)
	EnvFromPayload bool   `yaml:"env_from_payload" json:"env_from_payload,omitempty"` // Parse JSON payload as env vars
	Timeout        string `yaml:"timeout" json:"timeout,omitempty"`                   // Execution timeout (e.g., "30m", "2h")
	WorkingDir     string `yaml:"working_dir" json:"working_dir,omitempty"`           // Working directory (supports {{.Workspace}})
}

type IssueComment struct {
	ID        int64
	Body      string
	Author    string
	CreatedAt time.Time
	IsBot     bool
}

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

type LabelRouteConfig struct {
	LabelPrefix string `yaml:"label_prefix" json:"label_prefix"` // Match labels starting with this
	Target      string `yaml:"target" json:"target"`             // Route to this inbox
}

type MergeResult struct {
	Success       bool     `json:"success"`
	MergedFiles   []string `json:"merged_files,omitempty"`
	ConflictFiles []string `json:"conflict_files,omitempty"`
	Error         string   `json:"error,omitempty"`
	CommitHash    string   `json:"commit_hash,omitempty"`
}

type Message struct {
	ID           string
	From         string
	Title        string
	Content      string
	Inbox        string // Target inbox (set by PubSubInboxAdapter from message attributes, M-CLOUD-E2E)
	Type         string // bug, feature, task, etc. (category)
	Kind         string // directive, question (message type)
	Priority     string // high, medium, low
	GithubIssue  int    // Linked GitHub issue number (M-COORD-GITHUB-AUTO-ROUTING)
	GithubRepo   string // GitHub repo (owner/repo) for issue operations (M-COORD-GITHUB-CLOSE-ON-MERGE)
	ParentTaskID string // Parent task ID for hierarchy tracking (M-TASK-HIERARCHY)
	Iteration    int    // Iteration number for feedback loops (M-TASK-HIERARCHY)
	ChainID      string // ExecutionChain ID for unified hierarchy (M-CHAINS-SIMPLIFY)
	CreatedAt    time.Time
}

type MessageStore interface {
	ListUnread() ([]*Message, error)
	MarkAsRead(id string) error
}

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

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

type ObservatoryContext struct {
	TaskID       string // Coordinator task ID
	AgentID      string // Agent handling the task (e.g., "design-doc-creator")
	AssignmentID string // Observatory agent_assignment ID (aa_xxx)
	WorkspaceID  string // Observatory workspace ID (ws_xxx)

	// Chain context for unified hierarchy tracking (M-CHAINS-SIMPLIFY)
	ChainID   string // Execution chain ID (UUID)
	StageID   string // Chain stage ID (UUID)
	MessageID string // Source message ID that triggered this chain
}

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

type PluginsConfig struct {
	// Marketplaces to register (e.g., "anthropics/claude-code", "anthropics/skills")
	Marketplaces []string `yaml:"marketplaces" json:"marketplaces,omitempty"`
	// Plugins to install from registered marketplaces (e.g., "frontend-design@anthropics-claude-code")
	Install []string `yaml:"install" json:"install,omitempty"`
}

type Provider interface {
	// Name returns the provider identifier (e.g., "claude", "gemini", "gemini-api")
	Name() string

	// CanHandle returns true if this provider can handle the given task type
	CanHandle(task *AnalyzedTask) bool

	// Execute runs a task and returns the result
	Execute(ctx context.Context, task *AnalyzedTask, opts *ExecuteOptions) (*ExecuteResult, error)
}

type ProviderLimit struct {
	DailyBudget      float64 `yaml:"daily_budget"`
	TaskMaxCost      float64 `yaml:"task_max_cost"`
	HardLimit        bool    `yaml:"hard_limit"`
	WarningThreshold float64 `yaml:"warning_threshold"`
}

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

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

type RepoSyncConfig struct {
	Repo         string             `yaml:"repo" json:"repo"`                   // GitHub repo (owner/repo)
	Enabled      bool               `yaml:"enabled" json:"enabled"`             // Enable sync for this repo
	IntervalSecs int                `yaml:"interval_secs" json:"interval_secs"` // Override default interval
	WatchLabels  []string           `yaml:"watch_labels" json:"watch_labels"`   // Filter by labels
	TargetInbox  string             `yaml:"target_inbox" json:"target_inbox"`   // Default inbox for this repo
	LabelRouting []LabelRouteConfig `yaml:"label_routing" json:"label_routing"` // Route by label prefix
}

type ResourceMetrics struct {
	TaskID    string    `json:"task_id"`
	ThreadID  string    `json:"thread_id,omitempty"`
	Timestamp time.Time `json:"timestamp"`

	// Process metrics
	CPUPercent float64 `json:"cpu_percent"`
	MemoryMB   float64 `json:"memory_mb"`
	PID        int     `json:"pid,omitempty"`

	// Token metrics (accumulated)
	TokensIn  int `json:"tokens_in"`
	TokensOut int `json:"tokens_out"`

	// Cost metrics
	Cost float64 `json:"cost"`

	// Duration
	DurationSec int `json:"duration_sec"`

	// Peak values
	PeakCPU    float64 `json:"peak_cpu"`
	PeakMemory float64 `json:"peak_memory_mb"`
}

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

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

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

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

type SprintPlanResult struct {
	Path         string   // Path to .md file (may be empty if no .md found)
	AllArtifacts []string // All discovered artifacts (any file type)
	Duration     time.Duration
	Cost         float64
	TokensUsed   int
	InputTokens  int
	OutputTokens int
}

type StageExecutionResult struct {
	// Design doc stage
	DesignDocPath string

	// Sprint plan stage
	SprintPlanPath string

	// Implementation stage
	BranchName    string
	FilesCreated  []string
	FilesModified []string

	// Common fields
	Duration     time.Duration
	Cost         float64
	TokensUsed   int
	InputTokens  int
	OutputTokens int
}

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

type Status struct {
	Running   bool      `json:"running"`
	PID       int       `json:"pid,omitempty"`
	StartedAt time.Time `json:"started_at,omitempty"`
	Uptime    string    `json:"uptime,omitempty"`
	TasksRun  int       `json:"tasks_run"`
	// Extended stats from database
	PendingTasks     int     `json:"pending_tasks,omitempty"`
	RunningTasks     int     `json:"running_tasks,omitempty"`
	PendingApprovals int     `json:"pending_approvals,omitempty"` // Tasks awaiting human approval
	FailedTasks      int     `json:"failed_tasks,omitempty"`
	TotalCost        float64 `json:"total_cost,omitempty"`
	TotalTokens      int     `json:"total_tokens,omitempty"`
}

type Store interface {
	// Task CRUD operations
	CreateTask(ctx context.Context, task *TaskRecord) error
	GetTask(ctx context.Context, id string) (*TaskRecord, error)
	UpdateTask(ctx context.Context, task *TaskRecord) error
	DeleteTask(ctx context.Context, id string) error

	// Task queries
	ListTasks(ctx context.Context, filter *TaskFilter) ([]*TaskRecord, error)
	GetTaskStats(ctx context.Context) (*TaskStats, error)

	// Task state transitions
	MarkTaskQueued(ctx context.Context, id string) error
	MarkTaskRunning(ctx context.Context, id, provider, worktreeID string) error
	MarkTaskPendingApproval(ctx context.Context, id, worktreePath, worktreeBranch, baseBranch, baseCommit string, result *ExecuteResult) error // Work done, awaiting human review
	MarkTaskCompleted(ctx context.Context, id string, result *ExecuteResult) error
	MarkTaskFailed(ctx context.Context, id string, err error) error
	MarkTaskRejected(ctx context.Context, id string) error // Human rejected the work
	MarkTaskCancelled(ctx context.Context, id string) error
	RequeueTask(ctx context.Context, id string) error        // Reset status to pending for next stage execution
	ResetTaskToPending(ctx context.Context, id string) error // Reset running task back to pending (worktree limit recovery)

	// Duplicate detection
	FindDuplicateTask(ctx context.Context, fingerprint uint64, threshold float64) (*TaskRecord, error)
	SetTaskFingerprint(ctx context.Context, id string, fingerprint uint64) error

	// Thread linking (for dashboard visibility)
	SetTaskThreadID(ctx context.Context, id string, threadID string) error

	// Execution chain tracking (M-CHAINS-SIMPLIFY)
	UpdateTaskChainInfo(ctx context.Context, id, chainID, stageID string) error

	// Cross-database correlation (for Control Plane event classification)
	// Returns agent info for a task: agentID (FromAgent), inbox (ToInbox), title
	// Note: By convention, agent id == inbox in agent config
	GetTaskAgentInfo(ctx context.Context, taskID string) (agentID, inbox, title string, err error)

	// GitHub integration (M-COORD-GITHUB-AUTO-ROUTING)
	SetTaskGithubIssue(ctx context.Context, id string, issueNum int) error
	SetTaskStage(ctx context.Context, id string, stage TaskStage) error
	SetTaskDesignDocPath(ctx context.Context, id string, path string) error
	SetTaskSprintPlanPath(ctx context.Context, id string, path string) error
	GetTasksByGithubIssue(ctx context.Context, issueNum int) ([]*TaskRecord, error)
	GetTasksByStage(ctx context.Context, stage TaskStage) ([]*TaskRecord, error)

	// Resource metrics
	UpdateTaskMetrics(ctx context.Context, id string, peakCPU, peakMemory float64) error

	// Budget tracking (per-provider)
	GetCostByProvider() (map[string]float64, error)

	// Approval requests
	CreateApprovalRequest(ctx context.Context, req *ApprovalRequestRecord) error
	GetApprovalRequest(ctx context.Context, id string) (*ApprovalRequestRecord, error)                    // Get by approval ID
	GetApprovalRequestByTask(ctx context.Context, taskID string) (*ApprovalRequestRecord, error)          // Get pending by task ID
	GetApprovalRequestByTaskAnyStatus(ctx context.Context, taskID string) (*ApprovalRequestRecord, error) // Get approval regardless of status (for handoff triggering)
	ListPendingApprovals(ctx context.Context) ([]*ApprovalRequestRecord, error)
	ListResolvedApprovals(ctx context.Context, limit int) ([]*ApprovalRequestRecord, error) // List resolved (approved/rejected) approvals
	ResolveApprovalRequest(ctx context.Context, id, status, resolvedBy string) error
	ResolveApprovalRequestByTask(ctx context.Context, taskID, status, resolvedBy string) error
	MarkApprovalHandoffsTriggered(ctx context.Context, taskID string) error                        // Mark that handoffs were sent
	ListApprovedMergeHandoffsWithoutTrigger(ctx context.Context) ([]*ApprovalRequestRecord, error) // Find missed handoffs

	// Cleanup
	DeleteOldTasks(ctx context.Context, olderThan time.Duration) (int, error)
	RecoverStaleTasks(ctx context.Context, staleThreshold time.Duration) (int, error) // Cancel stale running/queued tasks on startup
	RetryAllFailedTasks(ctx context.Context) (int, error)                             // Reset all failed tasks to pending

	// Event storage (for task logs)
	StoreTaskEvent(ctx context.Context, event *TaskEventRecord) error
	GetTaskEvents(ctx context.Context, taskID string, limit int) ([]*TaskEventRecord, error)

	// Lifecycle
	Close() error
}

type StoreBackedApprovalCheckpoint struct {
	*ApprovalCheckpoint
	// contains filtered or unexported fields
}

type StoreConfig struct {
	DBPath string
}

type Task struct {
	ID           string
	Title        string
	Content      string
	Kind         string // "directive" or "question" - affects execution mode
	Priority     int
	MessageID    string
	ParentTaskID string // Parent task ID for hierarchy tracking (M-TASK-HIERARCHY)
	CreatedAt    time.Time
	// M-TRANSCRIPT: Feedback loop support
	Iteration int    // Current iteration (1 = first run, 2+ = re-run with feedback)
	SessionID string // Session ID for resume capability
}

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

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

type TaskEventContext struct {
	Workspace  string // Working directory path
	Directive  string // Full initial directive/prompt
	AgentID    string // Agent identifier (e.g., "design-doc-creator")
	SourceType string // Event source: coordinator, eval, github, direct
}

type TaskEventRecord struct {
	ID          int64     `json:"id"`
	TaskID      string    `json:"task_id"`
	ThreadID    string    `json:"thread_id,omitempty"`
	StreamType  string    `json:"stream_type"` // "text", "tool_use", "tool_result", "error", "status", "turn_start", "turn_end"
	TurnNum     int       `json:"turn_num,omitempty"`
	Text        string    `json:"text,omitempty"`
	ToolName    string    `json:"tool_name,omitempty"`
	ToolInput   string    `json:"tool_input,omitempty"`
	ToolOutput  string    `json:"tool_output,omitempty"`
	ErrorMsg    string    `json:"error_msg,omitempty"`
	Status      string    `json:"status,omitempty"`
	TokensIn    int       `json:"tokens_in,omitempty"`
	TokensOut   int       `json:"tokens_out,omitempty"`
	Cost        float64   `json:"cost,omitempty"`
	DurationSec int       `json:"duration_sec,omitempty"`
	CreatedAt   time.Time `json:"created_at"`
}

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

type TaskFilter struct {
	Status    []TaskStatus
	Type      []TaskType
	Provider  string
	Workspace string // Filter by source workspace
	Since     *time.Time
	Until     *time.Time
	Limit     int
	Offset    int
	OrderBy   string // "created_at", "priority", "started_at"
	OrderDesc bool
}

type TaskRecord struct {
	ID           string     `json:"id"`
	MessageID    string     `json:"message_id,omitempty"`
	ThreadID     string     `json:"thread_id,omitempty"`      // Thread in collaboration.db for dashboard visibility
	ParentTaskID string     `json:"parent_task_id,omitempty"` // Parent task for hierarchy tracking (handoffs)
	Title        string     `json:"title"`
	Content      string     `json:"content"`
	Type         TaskType   `json:"type"`
	Kind         string     `json:"kind,omitempty"` // "directive" or "question" - affects execution mode
	Priority     int        `json:"priority"`
	Status       TaskStatus `json:"status"`
	Provider     string     `json:"provider,omitempty"`
	AgentID      string     `json:"agent_id,omitempty"` // ID of agent that processed this task
	WorktreeID   string     `json:"worktree_id,omitempty"`
	WorktreePath string     `json:"worktree_path,omitempty"` // Path to git worktree (preserved until approval)
	BaseBranch   string     `json:"base_branch,omitempty"`   // Base branch worktree was created from (for diff comparison)
	BaseCommit   string     `json:"base_commit,omitempty"`   // Base commit hash at worktree creation (stable reference for diff)
	SessionID    string     `json:"session_id,omitempty"`    // Claude Code/Gemini CLI session for resumption
	Iteration    int        `json:"iteration,omitempty"`     // Iteration number (1 = first, 2+ = re-run with feedback)
	Workspace    string     `json:"workspace,omitempty"`     // Source workspace from thread (not worktree)
	// Execution chain tracking (M-CHAINS-SIMPLIFY)
	ChainID string `json:"chain_id,omitempty"` // ExecutionChain ID for unified hierarchy
	StageID string `json:"stage_id,omitempty"` // ChainStage ID for this agent's execution
	// GitHub integration (M-COORD-GITHUB-AUTO-ROUTING)
	GithubIssue    int       `json:"github_issue,omitempty"`     // Linked GitHub issue number
	GithubRepo     string    `json:"github_repo,omitempty"`      // GitHub repo (owner/repo) for issue operations
	Stage          TaskStage `json:"stage,omitempty"`            // Pipeline stage (design, sprint, implementation, merge)
	DesignDocPath  string    `json:"design_doc_path,omitempty"`  // Path to design doc (for merge comment)
	SprintPlanPath string    `json:"sprint_plan_path,omitempty"` // Path to sprint plan (for merge comment)
	// Timestamps
	CreatedAt   time.Time     `json:"created_at"`
	StartedAt   *time.Time    `json:"started_at,omitempty"`
	CompletedAt *time.Time    `json:"completed_at,omitempty"`
	Duration    time.Duration `json:"duration,omitempty"`
	Error       string        `json:"error,omitempty"`
	Output      string        `json:"output,omitempty"`
	Cost        float64       `json:"cost,omitempty"`
	TokensUsed  int           `json:"tokens_used,omitempty"`
	// Detailed token breakdown
	InputTokens  int `json:"input_tokens,omitempty"`
	OutputTokens int `json:"output_tokens,omitempty"`
	// Resource metrics
	PeakCPU    float64 `json:"peak_cpu,omitempty"`
	PeakMemory float64 `json:"peak_memory_mb,omitempty"`
	// Capability detection (M-DEPRECATE-AILANG-AGENT)
	Capabilities  []Capability `json:"capabilities,omitempty"`   // Detected capability requirements
	ImpactLevel   string       `json:"impact_level,omitempty"`   // "low", "medium", or "high"
	EstimatedCost float64      `json:"estimated_cost,omitempty"` // Pre-execution cost estimate in USD
	// M-HARNESS-COMMIT-CONTRACT: Website builder metadata from message payload
	SiteSlug string `json:"site_slug,omitempty"` // Site identifier for commit messages
	BriefID  string `json:"brief_id,omitempty"`  // Brief identifier for commit messages
}

type TaskStats struct {
	TotalTasks       int                       `json:"total_tasks"`
	PendingTasks     int                       `json:"pending_tasks"`
	RunningTasks     int                       `json:"running_tasks"`
	PendingApprovals int                       `json:"pending_approvals"` // Tasks awaiting human approval
	CompletedTasks   int                       `json:"completed_tasks"`
	FailedTasks      int                       `json:"failed_tasks"`
	ByType           map[string]int            `json:"by_type"`
	ByProvider       map[string]*DetailedStats `json:"by_provider"`
	ByWorkspace      map[string]*DetailedStats `json:"by_workspace"` // Per-workspace breakdown
	TotalCost        float64                   `json:"total_cost"`
	TotalTokens      int                       `json:"total_tokens"`
	AvgDuration      time.Duration             `json:"avg_duration"`
}

type TaskStatus string