ipc

type AnvilPollItem struct {
	Anvil     string    `json:"anvil"`
	Timestamp time.Time `json:"timestamp"`
	OK        bool      `json:"ok"`                // true when the last poll completed without error
	Message   string    `json:"message,omitempty"` // human-readable summary, e.g. "5 ready" or the error text
}

type AppendNotesPayload struct {
	BeadID string `json:"bead_id"`
	Anvil  string `json:"anvil"`
	Notes  string `json:"notes"`
}

type ApproveAsIsPayload struct {
	BeadID string `json:"bead_id"`
	Anvil  string `json:"anvil"`
}

type AssayRerunPayload struct {
	Anvil string `json:"anvil"`
	PR    int    `json:"pr"`
}

type ClarificationPayload struct {
	BeadID string `json:"bead_id"`
	Anvil  string `json:"anvil"`  // Required: which anvil the bead belongs to
	Reason string `json:"reason"` // Why clarification is needed (used when setting)
}

type ClearBeadPayload struct {
	BeadID string `json:"bead_id"`
	Anvil  string `json:"anvil"`
}

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

type CloseBeadPayload struct {
	BeadID string `json:"bead_id"`
	Anvil  string `json:"anvil"`
}

type Command struct {
	Type    string          `json:"type"`    // "status", "kill_worker", "refresh", "queue", "run_bead", "set_clarification", "clear_clarification", "assay_rerun"
	Payload json.RawMessage `json:"payload"` // Type-specific data
	// ReadTimeout is an optional client-side timeout for reading the response.
	// Zero uses DefaultReadTimeout. Long-running commands that go through bd or
	// gh (e.g. run_bead) should set BdBackedReadTimeout. This field is not sent
	// on the wire — it only influences Client.Send's read deadline.
	ReadTimeout time.Duration `json:"-"`
}

type CommandHandler func(cmd Command) Response

type CompletionResult struct {
	Response Response
	Err      error
}

type CrucibleActionPayload struct {
	ParentID string `json:"parent_id"` // Parent bead ID of the Crucible
	Anvil    string `json:"anvil"`
	Action   string `json:"action"` // "resume" | "stop"
}

type CrucibleStatusItem struct {
	ParentID          string `json:"parent_id"`
	ParentTitle       string `json:"parent_title"`
	Anvil             string `json:"anvil"`
	Branch            string `json:"branch"`
	Phase             string `json:"phase"` // "started", "dispatching", "waiting", "final_pr", "complete", "paused"
	TotalChildren     int    `json:"total_children"`
	CompletedChildren int    `json:"completed_children"`
	CurrentChild      string `json:"current_child"`
	StartedAt         string `json:"started_at"`
}

type CruciblesResponse struct {
	Crucibles []CrucibleStatusItem `json:"crucibles"`
}

type DismissBeadPayload struct {
	BeadID string `json:"bead_id"`
	Anvil  string `json:"anvil"`
	PRID   int    `json:"pr_id,omitempty"`
}

type Event struct {
	Type      string          `json:"type"`
	Timestamp time.Time       `json:"timestamp"`
	Data      json.RawMessage `json:"data"`
}

type EventInfo struct {
	ID        int    `json:"id"`
	Timestamp string `json:"timestamp"`
	Type      string `json:"type"`
	Message   string `json:"message"`
	BeadID    string `json:"bead_id,omitempty"`
	Anvil     string `json:"anvil,omitempty"`
}

type EventsResponse struct {
	Events []EventInfo `json:"events"`
}

type ForceSmithPayload struct {
	BeadID   string `json:"bead_id"`
	Anvil    string `json:"anvil"`
	UserNote string `json:"user_note,omitempty"`
}

type GetIngotPayload struct {
	BeadID string `json:"bead_id"`
	Anvil  string `json:"anvil,omitempty"`
}

type GetIngotsPayload struct {
	Anvil  string `json:"anvil,omitempty"`
	Status string `json:"status,omitempty"`
	Limit  int    `json:"limit,omitempty"` // default 50
}

type KillWorkerPayload struct {
	WorkerID string `json:"worker_id"`
	PID      int    `json:"pid"`
}

type MergePRPayload struct {
	PRID     int    `json:"pr_id"`
	PRNumber int    `json:"pr_number"`
	Anvil    string `json:"anvil"`
}

type PRActionPayload struct {
	PRID     int    `json:"pr_id"`
	PRNumber int    `json:"pr_number"`
	Anvil    string `json:"anvil"`
	BeadID   string `json:"bead_id"`
	Branch   string `json:"branch"`
	Action   string `json:"action"` // "open_browser" | "merge" | "quench" | "burnish" | "rebase" | "close" | "approve" | "assign_bellows" | "unassign_bellows"
}

type QueueActionPayload struct {
	BeadID    string `json:"bead_id"`
	ForgeID   string `json:"forge_id,omitempty"`
	AnvilName string `json:"anvil_name,omitempty"`
	Note      string `json:"note,omitempty"`
}

type QueueItem struct {
	BeadID      string   `json:"bead_id"`
	Anvil       string   `json:"anvil"`
	Title       string   `json:"title"`
	Description string   `json:"description,omitempty"`
	Priority    int      `json:"priority"`
	Status      string   `json:"status"`
	Labels      []string `json:"labels"`
	Section     string   `json:"section"`
	Assignee    string   `json:"assignee,omitempty"`
	CreatedAt   string   `json:"created_at"`
	UpdatedAt   string   `json:"updated_at"`
	// AutoDispatchTag is the anvil's configured dispatch label (forge.yaml
	// `auto_dispatch_tag`). Surfaced on each queue row so the Hearth web UI
	// can render a one-click "apply tag" button on Unlabeled beads without
	// an extra round-trip to the anvil registry. Empty when the owning
	// anvil has no tag configured.
	AutoDispatchTag string `json:"auto_dispatch_tag,omitempty"`
}

type QueueResponse struct {
	Items []QueueItem `json:"items"`
}

type QueuedPayload struct {
	Message string `json:"message,omitempty"`
}

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

type ResolveOrphanPayload struct {
	BeadID string `json:"bead_id"`
	Anvil  string `json:"anvil"`
	Action string `json:"action"` // "recover" | "close" | "discard"
}

type Response struct {
	Type      string          `json:"type"`                 // "ok", "error", "status", "event", "queued"
	Payload   json.RawMessage `json:"payload"`              // Type-specific data
	RequestID string          `json:"request_id,omitempty"` // Set when Type is "queued"; correlates async completion
}

type RetryBeadPayload struct {
	BeadID string `json:"bead_id"`
	Anvil  string `json:"anvil"`
	PRID   int    `json:"pr_id,omitempty"`
}

type RunBeadPayload struct {
	BeadID   string `json:"bead_id"`
	Anvil    string `json:"anvil"`     // Optional: narrows search if multiple anvils have same bead ID
	ForceRun bool   `json:"force_run"` // When true, fetch via bd show (bypass bd ready), skip crucible/parent checks
}

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

type StatusPayload struct {
	Running        bool                      `json:"running"`
	PID            int                       `json:"pid"`
	Uptime         string                    `json:"uptime"`
	Workers        int                       `json:"workers"`
	QueueSize      int                       `json:"queue_size"`
	OpenPRs        int                       `json:"open_prs"`
	LastPoll       string                    `json:"last_poll"`
	Quotas         map[string]provider.Quota `json:"quotas,omitempty"`
	DailyCost      float64                   `json:"daily_cost"`
	DailyCostLimit float64                   `json:"daily_cost_limit,omitempty"`
	// CostLimitPaused reports that cost-based auto-dispatch via the Poller is
	// currently paused due to hitting the daily cost limit. Manual run_bead
	// dispatch remains allowed while this flag is true.
	CostLimitPaused bool `json:"cost_limit_paused,omitempty"`
	// CopilotPremiumRequests is the weighted count of Copilot premium requests used today.
	CopilotPremiumRequests float64 `json:"copilot_premium_requests,omitempty"`
	// CopilotRequestLimit is the configured daily limit (0 = no limit).
	CopilotRequestLimit int `json:"copilot_request_limit,omitempty"`
	// CopilotLimitReached is true when the copilot daily request limit has been reached.
	CopilotLimitReached bool `json:"copilot_limit_reached,omitempty"`
	// AnvilLastPoll carries the most recent poll outcome per anvil, populated
	// from the daemon's in-memory snapshot. Successful polls are no longer
	// persisted as events, so Hearth and `forge status` consume this field for
	// fresh per-anvil timestamps instead of querying the events table.
	AnvilLastPoll []AnvilPollItem `json:"anvil_last_poll,omitempty"`
	// MaxTotalSmiths is the configured global cap on concurrent Smith workers.
	// Hearth 2.0 uses this to size the "Idle" placeholder slots in the
	// Workers pane (max_total_smiths - active_workers).
	MaxTotalSmiths int `json:"max_total_smiths,omitempty"`
}

type StopBeadPayload struct {
	BeadID string `json:"bead_id"`
	Anvil  string `json:"anvil"`
	Reason string `json:"reason"` // Optional; defaults to "manually stopped"
}

type TagBeadPayload struct {
	BeadID string `json:"bead_id"`
	Anvil  string `json:"anvil"`
}

type UpdateLabelPayload struct {
	BeadID string `json:"bead_id"`
	Anvil  string `json:"anvil"`
	Label  string `json:"label"`
	Action string `json:"action"` // "add" | "remove"
}

type ViewLogsPayload struct {
	BeadID string `json:"bead_id"`
}

type ViewLogsResponse struct {
	LogPath   string   `json:"log_path"`
	LastLines []string `json:"last_lines"`
}

type WardenRerunPayload struct {
	BeadID string `json:"bead_id"`
	Anvil  string `json:"anvil"`
}

type WicketStatusPayload struct {
	Enabled        bool           `json:"enabled"`
	Interval       string         `json:"interval"`
	MonitoredRepos []string       `json:"monitored_repos"` // explicitly configured repos
	DerivedAnvils  int            `json:"derived_anvils"`  // anvil count deriving repo from git remote at runtime
	IssueCounts    map[string]int `json:"issue_counts"`    // state -> count
	LastScanAt     *time.Time     `json:"last_scan_at,omitempty"`
}

type WorkerInfo struct {
	ID          string `json:"id"`
	BeadID      string `json:"bead_id"`
	Anvil       string `json:"anvil"`
	Branch      string `json:"branch,omitempty"`
	Title       string `json:"title,omitempty"`
	Status      string `json:"status"`
	Phase       string `json:"phase,omitempty"`
	Kind        string `json:"kind,omitempty"`
	PID         int    `json:"pid,omitempty"`
	StartedAt   string `json:"started_at"`
	CompletedAt string `json:"completed_at,omitempty"`
	LogPath     string `json:"log_path,omitempty"`
	PRNumber    int    `json:"pr_number,omitempty"`
}

type WorkersResponse struct {
	Workers []WorkerInfo `json:"workers"`
}