hearth

type ActionMenuChoice int

type AnvilHealth struct {
	Anvil     string
	OK        bool   // true = last poll succeeded
	Message   string // e.g. "5 ready" or error text
	Timestamp string // "15:04:05" format
	Age       string // e.g. "2m", "1h"
}

type AttentionReason int

type CrucibleActionMenuChoice int

type CrucibleActionResultMsg struct {
	ParentID string
	Action   string // "resume" or "stop"
	Err      error
}

type CrucibleItem struct {
	ParentID          string
	ParentTitle       string
	Anvil             string
	Branch            string
	Phase             string // "started", "dispatching", "waiting", "final_pr", "complete", "paused"
	TotalChildren     int
	CompletedChildren int
	CurrentChild      string
	StartedAt         string
}

type DataSource struct {
	DB *state.DB
	// Exhaustion thresholds from config. Zero values fall back to state package defaults.
	MaxCIFixAttempts     int
	MaxReviewFixAttempts int
	MaxRebaseAttempts    int
	// AnvilNames lists all registered anvil names (sorted) so the Queue panel
	// can show empty anvils with a (0) count.
	AnvilNames []string
	// Cost limits from config for the Usage panel display.
	DailyCostLimit           float64
	CopilotDailyRequestLimit int
	// AutoMergeAnvils returns the set of anvil names that have auto_merge
	// enabled. The map is built once at Hearth startup from the loaded config;
	// reflecting config changes requires restarting Hearth.
	// When nil, no PRs are tagged [auto].
	AutoMergeAnvils func() map[string]bool
}

type EventItem struct {
	Timestamp string
	Type      string
	Message   string
	BeadID    string
}

type KillWorkerMsg struct {
	WorkerID string
	PID      int
}

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

type MergeMenuChoice int

type MergeResultMsg struct {
	PRNumber int
	Err      error
}

type Model struct {

	// Callback for killing a worker (set by the caller)
	OnKill func(workerID string, pid int)

	// Callback for stopping a bead entirely: kills worker, sets clarification,
	// releases to open (set by the caller).
	OnStopBead func(beadID, anvil string) error

	// Callbacks for Needs Attention actions (set by the caller)
	OnRetryBead   func(beadID, anvil string, prID int) error
	OnDismissBead func(beadID, anvil string, prID int) error
	OnViewLogs    func(beadID string) (logPath string, lines []string)
	OnWardenRerun func(beadID, anvil string) error
	OnApproveAsIs func(beadID, anvil string) error
	OnForceSmith  func(beadID, anvil, userNote string) error

	// Callback for tagging a bead (set by the caller).
	// Called with (beadID, anvil) when user presses 'l' on an unlabeled bead.
	OnTagBead func(beadID, anvil string) error

	// Callback for closing a bead (set by the caller).
	OnCloseBead func(beadID, anvil string) error

	// Callback for force-running a bead independently (set by the caller).
	// Dispatches via bd show, bypassing bd ready and crucible/parent checks.
	OnForceRunBead func(beadID, anvil string) error

	// Callback for merging a PR (set by the caller).
	OnMergePR func(prID, prNumber int, anvil string) error

	// Callback for PR panel actions (set by the caller).
	// Called with (prID, prNumber, anvil, beadID, branch, action).
	OnPRAction func(prID, prNumber int, anvil, beadID, branch, action string) error

	// Callback for triggering PR reconciliation with GitHub (set by the caller).
	OnReconcilePRs func() error

	// Callback for resolving an orphaned bead (set by the caller).
	// Called with (beadID, anvil, action) where action is "recover", "close", or "discard".
	OnResolveOrphan func(beadID, anvil, action string) error

	// Callback for crucible actions (resume/stop) on a paused crucible (set by caller).
	// Called with (parentID, anvil, action) where action is "resume" or "stop".
	OnCrucibleAction func(parentID, anvil, action string) error

	// Callback for appending notes to a bead via bd update --append-notes (set by caller).
	// Called with (beadID, anvil, notes).
	OnAppendNotes func(beadID, anvil, notes string) error
	// contains filtered or unexported fields
}

type NeedsAttentionErrorMsg struct{ Err error }

type NeedsAttentionItem struct {
	BeadID           string
	Title            string
	Description      string
	Anvil            string
	Reason           string
	ReasonCategory   AttentionReason
	PRID             int // Non-zero when item originates from an exhausted PR
	PRNumber         int
	LastWardenReject string // Most recent warden_reject message, if any
}

type NotesResultMsg struct {
	BeadID string
	Anvil  string
	Err    error
}

type OpenPRsErrorMsg struct{ Err error }

type OrphanDialogChoice int

type OrphanResolveResultMsg struct {
	BeadID string
	Action string
	Err    error
}

type PRActionMenuChoice int

type PRActionResultMsg struct {
	PRNumber int
	Action   string
	Err      error
}

type PRItem struct {
	PRID                 int
	PRNumber             int
	Anvil                string
	BeadID               string
	Branch               string
	Status               string // "open", "approved", "needs_fix"
	Title                string
	CIPassing            bool
	IsConflicting        bool
	HasUnresolvedThreads bool
	HasPendingReviews    bool
	HasApproval          bool
	CIFixCount           int
	ReviewFixCount       int
	RebaseCount          int
	IsExternal           bool // true for PRs discovered via GitHub reconciliation
	BellowsManaged       bool // true when bellows runs lifecycle workers for this PR
}

type Panel int

type PendingOrphanItem struct {
	BeadID string
	Anvil  string
	Title  string
	Branch string
}

type ProviderUsage struct {
	Provider     string
	Cost         float64
	InputTokens  int
	OutputTokens int
}

type QueueActionMenuChoice int

type QueueActionResultMsg struct {
	BeadID string
	Action string // "tag", "force_run", "close", or "stop"
	Err    error
}

type QueueErrorMsg struct{ Err error }

type QueueItem struct {
	BeadID      string
	Title       string
	Description string
	Anvil       string
	Priority    int
	Status      string
	Section     string // "ready", "unlabeled", "in_progress"
	Assignee    string
}

type ReadyToMergeErrorMsg struct{ Err error }

type ReadyToMergeItem struct {
	PRID      int
	PRNumber  int
	BeadID    string
	Anvil     string
	Branch    string
	Title     string
	AutoMerge bool // true when the anvil has auto_merge enabled
}

type SpinnerTickMsg time.Time

type TickMsg time.Time

type UpdateAnvilHealthMsg struct{ Items []AnvilHealth }

type UpdateCruciblesMsg struct{ Items []CrucibleItem }

type UpdateDaemonHealthMsg struct {
	Connected bool
	Workers   int
	QueueSize int
	LastPoll  string
	Uptime    string
}

type UpdateEventsMsg struct{ Items []EventItem }

type UpdateIngotCountsMsg struct {
	Counts map[ingot.Status]int
	Total  int
}

type UpdateNeedsAttentionMsg struct{ Items []NeedsAttentionItem }

type UpdateOpenPRsMsg struct {
	Items []PRItem
}

type UpdatePendingOrphansMsg struct {
	Items []PendingOrphanItem
}

type UpdateQueueMsg struct{ Items []QueueItem }

type UpdateReadyToMergeMsg struct{ Items []ReadyToMergeItem }

type UpdateUsageMsg struct {
	Data UsageData
}

type UpdateWorkersMsg struct{ Items []WorkerItem }

type UsageData struct {
	Providers    []ProviderUsage
	TotalCost    float64
	CostLimit    float64 // 0 = no limit
	CopilotUsed  float64
	CopilotLimit int // 0 = no limit
}

type WorkerItem struct {
	ID            string
	BeadID        string
	Title         string // Bead title for display
	Anvil         string
	Status        string
	Duration      string
	CostUSD       float64
	Type          string   // "smith", "warden", "temper", "quench", "burnish", "rebase"
	PRNumber      int      // PR number for bellows-triggered workers
	LastLog       string   // Last line from the worker log
	PID           int      // Process ID for kill
	LogPath       string   // Path to the worker's log file
	ActivityLines []string // Recent parsed activity from the log (tool calls, thinking, text)
}