serve

type AskData struct {
	ID        string            `json:"id"`
	Questions []bus.AskQuestion `json:"questions"`
}

type Attachment struct {
	Name string `json:"name"`
	Mime string `json:"mime"`
	Data string `json:"data"` // base64 standard encoding
}

type AttachmentDTO struct {
	ID     string `json:"id"`
	Name   string `json:"name"`
	Mime   string `json:"mime"`
	Size   int64  `json:"size"`
	Kind   string `json:"kind"`
	Width  int    `json:"width"`
	Height int    `json:"height"`
	URL    string `json:"url"`
}

type AutomationCallback struct {
	SessionID string `json:"session_id"`
	Status    string `json:"status"` // done | failed | needs_input
	Title     string `json:"title"`
	Summary   string `json:"summary"`
	URL       string `json:"url"`
	Error     string `json:"error,omitempty"`
	// Pending describes what the run is blocked on. Only set for needs_input,
	// so a machine caller can answer it through the scoped interaction
	// endpoints instead of only learning that a human is needed.
	Pending   *CallbackPending `json:"pending,omitempty"`
	Timestamp string           `json:"timestamp"` // RFC3339
}

type AutomationMCPServer struct {
	Name    string            `json:"name"`
	URL     string            `json:"url"`
	Headers map[string]string `json:"headers,omitempty"`
	// Command/Args/Env exist only so a caller that sends one gets a 400 instead
	// of a silently url-only server. They never start anything.
	Command json.RawMessage `json:"command,omitempty"`
	Args    json.RawMessage `json:"args,omitempty"`
	Env     json.RawMessage `json:"env,omitempty"`
}

type AutomationRunRequest struct {
	Prompt string `json:"prompt"`
	Model  string `json:"model"`
	CWD    string `json:"cwd"`
	Title  string `json:"title"`
	Origin string `json:"origin"`
	// IdempotencyKey deduplicates retries: webhooks redeliver, and a redelivery
	// must not spawn a second session.
	IdempotencyKey string `json:"idempotency_key"`
	// CallbackURL/CallbackSecret configure the outbound completion callback:
	// where to POST when the run settles, and the optional HMAC secret the
	// receiver verifies it with (see callback.go).
	CallbackURL    string `json:"callback_url"`
	CallbackSecret string `json:"callback_secret"`
	// MCPServers attaches session-scoped MCP servers to the run, so the agent
	// can call the caller's own tools. URL-based only — see AutomationMCPServer.
	MCPServers []AutomationMCPServer `json:"mcp_servers"`
}

type AutomationRunResponse struct {
	SessionID string `json:"session_id"`
	URL       string `json:"url"`
	// Created is false when an idempotency key matched an existing session.
	Created bool `json:"created"`
}

type BashCompleteData struct {
	JobID        string `json:"job_id"`
	OwnerAgentID string `json:"owner_agent_id,omitempty"`
	Command      string `json:"command"`
	Status       string `json:"status"`
	Text         string `json:"text"`
}

type BashJobEndData struct {
	JobID        string `json:"job_id"`
	OwnerAgentID string `json:"owner_agent_id,omitempty"`
	Status       string `json:"status"`
	Output       string `json:"output"`
}

type BashJobInitData struct {
	JobID        string `json:"job_id"`
	OwnerAgentID string `json:"owner_agent_id,omitempty"`
	Command      string `json:"command"`
	CWD          string `json:"cwd"`
	Status       string `json:"status"`
	Output       string `json:"output"`
}

type BashJobOutputData struct {
	JobID        string `json:"job_id"`
	OwnerAgentID string `json:"owner_agent_id,omitempty"`
	Delta        string `json:"delta"`
}

type BashJobStartData struct {
	JobID        string `json:"job_id"`
	OwnerAgentID string `json:"owner_agent_id,omitempty"`
	Command      string `json:"command"`
	CWD          string `json:"cwd"`
}

type CallbackPending struct {
	Kind      string            `json:"kind"` // question | permission
	ID        string            `json:"id"`
	Questions []bus.AskQuestion `json:"questions,omitempty"`
	Tool      string            `json:"tool,omitempty"`
	Summary   string            `json:"summary,omitempty"`
}

type CommandData struct {
	Command          string              `json:"command"`
	Messages         []core.AgentMessage `json:"messages,omitempty"` // compact sends updated messages
	HistoryTruncated bool                `json:"history_truncated,omitempty"`
}

type CommandDequeuedData struct {
	ID       string `json:"id"`
	Raw      string `json:"raw"`
	Executed bool   `json:"executed"`
	Err      string `json:"err,omitempty"`
}

type CommandQueuedData struct {
	ID  string `json:"id"`
	Raw string `json:"raw"`
}

type CommandResult struct {
	OK           bool   `json:"ok"`
	Message      string `json:"message"`
	NewSessionID string `json:"newSessionId,omitempty"`
	// Queued is true when the command was not executed now but enqueued as a
	// barrier in the unified queue rail (issued while the session was busy). ID
	// is then the queued chip's authoritative ID, so the client reconciles its
	// optimistic command chip by ID.
	Queued bool   `json:"queued,omitempty"`
	ID     string `json:"id,omitempty"`
}

type ConfigChangeData struct {
	Model          string `json:"model,omitempty"`
	Provider       string `json:"provider,omitempty"`
	Thinking       string `json:"thinking,omitempty"`
	PermissionMode string `json:"permission_mode,omitempty"`
	PathScope      string `json:"path_scope,omitempty"`
	// CompactAt carries a compaction-threshold change only. Pointer because 0
	// ("compact at the model window") is a real setting, not "unchanged".
	CompactAt *int `json:"compact_at,omitempty"`
	// ContextWindow carries a model switch's new input window, the denominator
	// for every context percentage the client shows.
	ContextWindow int `json:"context_window,omitempty"`
}

type ContextUpdateData struct {
	ContextPercent int `json:"context_percent"`
}

type ConversationMessage struct {
	ID            string          `json:"id"`
	Role          string          `json:"role"`
	Timestamp     time.Time       `json:"timestamp,omitempty"`
	Text          string          `json:"text,omitempty"`
	Truncated     bool            `json:"truncated,omitempty"`
	Omitted       bool            `json:"omitted,omitempty"`
	OmittedBlocks int             `json:"omitted_blocks,omitempty"`
	Tool          string          `json:"tool,omitempty"`
	Action        string          `json:"action,omitempty"`
	Target        string          `json:"target,omitempty"`
	Status        string          `json:"status,omitempty"`
	Attachments   []AttachmentDTO `json:"attachments,omitempty"`
}

type CreateOpts struct {
	Model string `json:"model"`
	Title string `json:"title"`
	CWD   string `json:"cwd"`
	// Origin records who created the session ("user" when empty). Free-form so
	// automation callers can label their integration, e.g. "linear-webhook".
	Origin string `json:"origin"`
	// contains filtered or unexported fields
}

type DeltaData struct {
	Delta string `json:"delta"`
}

type Event struct {
	Type string `json:"type"`
	Data any    `json:"data,omitempty"`
	Seq  uint64 `json:"seq,omitempty"`
}

type GoalChangeData struct {
	Active    bool   `json:"active"`
	Objective string `json:"objective,omitempty"`
	WorkDir   string `json:"work_dir,omitempty"`
	Iteration int    `json:"iteration"`
	Stalled   int    `json:"stalled"`
}

type GoalEndData struct {
	Reason string `json:"reason"`
}

type GoalIterationData struct {
	Iteration int    `json:"iteration"`
	Satisfied bool   `json:"satisfied"`
	Feedback  string `json:"feedback,omitempty"`
}

type InitData struct {
	Messages          []core.AgentMessage `json:"messages"`
	State             string              `json:"state"`
	ContextPercent    int                 `json:"context_percent"`
	ContextWindow     int                 `json:"context_window,omitempty"`
	CompactAt         int                 `json:"compact_at,omitempty"`
	CompactAtMin      int                 `json:"compact_at_min,omitempty"`
	PermissionMode    string              `json:"permission_mode"`
	PathScope         string              `json:"path_scope,omitempty"`
	PendingPermission *PermissionData     `json:"pending_permission,omitempty"`
	PendingAsk        *AskData            `json:"pending_ask,omitempty"`
	Tasks             any                 `json:"tasks,omitempty"`
	PlanMode          string              `json:"plan_mode,omitempty"`
	PlanFile          string              `json:"plan_file,omitempty"`
	GoalActive        bool                `json:"goal_active,omitempty"`
	GoalObjective     string              `json:"goal_objective,omitempty"`
	GoalWorkDir       string              `json:"goal_work_dir,omitempty"`
	GoalIteration     int                 `json:"goal_iteration,omitempty"`
	GoalStalled       int                 `json:"goal_stalled,omitempty"`
	GoalVerifying     bool                `json:"goal_verifying,omitempty"`
	Compacting        bool                `json:"compacting,omitempty"`
	StreamingText     string              `json:"streaming_text,omitempty"`
	StreamingThinking string              `json:"streaming_thinking,omitempty"`
	RunTokensUp       int                 `json:"run_tokens_up"`
	RunTokensDown     int                 `json:"run_tokens_down"`
	RunStartedAtMs    int64               `json:"run_started_at_ms,omitempty"`
	PendingSteers     []PendingSteerData  `json:"pending_steers,omitempty"`
	CostUSD           float64             `json:"cost_usd,omitempty"`
	Subagents         []SubagentInitData  `json:"subagents,omitempty"`
	BashJobs          []BashJobInitData   `json:"bash_jobs,omitempty"`
	LastSeq           uint64              `json:"last_seq,omitempty"`
	HistoryTruncated  bool                `json:"history_truncated,omitempty"`
}

type MCPChangeData struct {
	Total     int `json:"total"`
	Ready     int `json:"ready"`
	Disabled  int `json:"disabled"`
	Unhealthy int `json:"unhealthy"`
	Pending   int `json:"pending"`
}

type MCPSummary struct {
	Total     int `json:"total"`
	Ready     int `json:"ready"`
	Disabled  int `json:"disabled"`
	Unhealthy int `json:"unhealthy"`
	Pending   int `json:"pending"`
}

type ManagedSession struct {
	// Immutable after construction.
	ID      string    `json:"id"`
	CWD     string    `json:"cwd"`
	Created time.Time `json:"created"`
	// Origin is who created the session ("user" for a human, or a caller-chosen
	// label for automation). Mirrors session.Session metadata.
	Origin string `json:"origin"`

	Title       string
	TitleSource string // "manual" | "auto" | "" (legacy=auto); see session.TitleSource
	Archived    bool   // closed-but-kept (presentation-only); see session.Session.Archived
	Updated     time.Time
	// contains filtered or unexported fields
}

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

type ManagerConfig struct {
	ProviderFactory func(model core.Model) (core.Provider, error)
	Transcriber     core.Transcriber // optional; enables POST /api/transcribe
	UsagePoller     *usage.Poller    // optional; enables GET /api/usage
	PushStore       *push.Store      // optional; enables Web Push
	PushDispatcher  *push.Dispatcher // optional; enables Web Push
	DefaultModel    core.Model
	WorkspaceRoot   string
	MoaCfg          core.MoaConfig
	// ConfigLoader loads configuration for an individual session CWD. When
	// nil, core.LoadMoaConfig preserves the normal global/project lookup.
	ConfigLoader   func(cwd string) core.MoaConfig
	SessionBaseDir string // root for session stores; empty = default
	// SchedulePath overrides the durable schedules file. Empty stores it beside
	// the session base directory.
	SchedulePath       string
	ReleaseInfo        release.Info
	UpdateChecker      *release.Checker
	UpdateCheckEnabled bool
}

type MessageEndData struct {
	Text         string `json:"text"`
	MsgID        string `json:"msg_id,omitempty"`
	InputTokens  int    `json:"input_tokens,omitempty"`
	OutputTokens int    `json:"output_tokens,omitempty"`
}

type PendingSteerData struct {
	ID      string `json:"id"`
	Text    string `json:"text"`
	Command bool   `json:"command,omitempty"`
	Images  int    `json:"images,omitempty"`
}

type PermissionData struct {
	ID           string         `json:"id"`
	ToolName     string         `json:"tool_name"`
	Args         map[string]any `json:"args"`
	AllowPattern string         `json:"allow_pattern,omitempty"`
}

type PlanModeData struct {
	Mode     string `json:"mode"`
	PlanFile string `json:"plan_file,omitempty"`
}

type RateLimitData struct {
	Status              string `json:"status,omitempty"`
	RepresentativeClaim string `json:"representative_claim,omitempty"`
	OnOverage           bool   `json:"on_overage"`
	FiveHourPct         int    `json:"five_hour_pct"`
	SevenDayPct         int    `json:"seven_day_pct"`
	OveragePct          int    `json:"overage_pct"`
}

type RealtimeAPIKeyFunc func() (key string, ok bool)

type RunEndData struct {
	Text string `json:"text"`
}

type RunTokensData struct {
	Up   int `json:"up"`
	Down int `json:"down"`
}

type ServerOption func(*serverOptions)

type SessionCostData struct {
	CostUSD float64 `json:"cost_usd"`
}

type SessionInfo struct {
	ID           string       `json:"id"`
	Title        string       `json:"title"`
	Archived     bool         `json:"archived,omitempty"`
	State        SessionState `json:"state"`
	Model        string       `json:"model"`
	Provider     string       `json:"provider"`
	Thinking     string       `json:"thinking"`
	CWD          string       `json:"cwd"`
	Created      time.Time    `json:"created"`
	Updated      time.Time    `json:"updated"`
	Origin       string       `json:"origin,omitempty"` // who created it; omitted for ordinary user sessions
	Error        string       `json:"error,omitempty"`
	UntrustedMCP bool         `json:"untrusted_mcp,omitempty"`
	// MCP summarizes this session's MCP servers for the status line: a count and
	// whether any is unhealthy, so the indicator can appear only when servers
	// exist and turn red when one has failed or exited. The full per-server
	// detail is fetched on demand from GET /api/sessions/{id}/mcp. Omitted when
	// the session has no MCP servers.
	MCP            *MCPSummary `json:"mcp,omitempty"`
	PlanMode       string      `json:"plan_mode,omitempty"`
	PlanFile       string      `json:"plan_file,omitempty"`
	ContextPercent int         `json:"context_percent"` // 0-100, -1 if unknown
	// ContextWindow is the model's usable input window in tokens — the
	// denominator ContextPercent is measured against, and the scale CompactAt
	// is expressed on, so a UI can show the limit as a percentage of the ring.
	ContextWindow int `json:"context_window,omitempty"`
	// CompactAt is the soft compaction threshold in tokens; 0 means the session
	// compacts only when it approaches ContextWindow.
	CompactAt int `json:"compact_at,omitempty"`
	// CompactAtMin is the lowest threshold the engine honors, in tokens. A UI
	// picking a threshold must not offer below it — the engine would raise the
	// value and compact somewhere other than where the control says.
	CompactAtMin   int                        `json:"compact_at_min,omitempty"`
	PermissionMode string                     `json:"permission_mode"` // "yolo", "ask", "auto"
	CostUSD        float64                    `json:"cost_usd"`        // accumulated session spend (main run + subagents)
	Activity       *attention.SessionActivity `json:"activity,omitempty"`
	// CacheExpiresAt is when the Anthropic prompt cache for this session goes
	// cold (last run + cache TTL). Zero/omitted when not applicable (no run yet,
	// or a non-Anthropic model that doesn't use TTL-based prompt caching). The
	// UI warns once this time has passed that a new message pays a cache write.
	CacheExpiresAt time.Time `json:"cache_expires_at,omitzero"`
	// RunStartedAt is when the in-progress run began; zero/omitted when idle.
	// The UI anchors the activity-indicator elapsed counter to it so the counter
	// stays correct across reconnects. Only meaningful while State is running or
	// permission.
	RunStartedAt time.Time `json:"run_started_at,omitzero"`
	// BriefAttempting/BriefProgress are the cheap LLM-generated status prose:
	// what the session is attempting and how it's going. Prose that can age;
	// the actionable state is State/PermissionMode above (derived live), never
	// baked into this prose. BriefUpdated is the freshness stamp. Empty until
	// the first brief is generated. See brief.go.
	BriefAttempting string    `json:"brief_attempting,omitempty"`
	BriefProgress   string    `json:"brief_progress,omitempty"`
	BriefUpdated    time.Time `json:"brief_updated,omitzero"`
}

type SessionState string

type StateChangeData struct {
	State string `json:"state"`
	Error string `json:"error,omitempty"`
}

type SteerData struct {
	ID    string `json:"id,omitempty"`
	MsgID string `json:"msg_id,omitempty"`
	Text  string `json:"text"`
}

type SubagentCompleteData struct {
	JobID  string `json:"job_id"`
	Task   string `json:"task"`
	Status string `json:"status"`
	Text   string `json:"text"`
}

type SubagentCountData struct {
	Count int `json:"count"`
}

type SubagentEndData struct {
	JobID        string  `json:"job_id"`
	Status       string  `json:"status"`
	InputTokens  int     `json:"input_tokens"`
	OutputTokens int     `json:"output_tokens"`
	CostUSD      float64 `json:"cost_usd"`
}

type SubagentEventData struct {
	JobID string `json:"job_id"`
	Event *Event `json:"event"`
}

type SubagentInitData struct {
	JobID            string              `json:"job_id"`
	OriginToolCallID string              `json:"origin_tool_call_id,omitempty"`
	Task             string              `json:"task"`
	Model            string              `json:"model"`
	Thinking         string              `json:"thinking"`
	Status           string              `json:"status"`
	Async            bool                `json:"async"`
	Messages         []core.AgentMessage `json:"messages"`
	// StartedAtMs is the child's start time as epoch milliseconds (same
	// encoding as InitData.RunStartedAtMs), so a reconnecting client resumes
	// its live elapsed timer instead of restarting it. Omitted when unknown.
	StartedAtMs int64 `json:"started_at_ms,omitempty"`
	// InputTokens/OutputTokens/CostUSD are the child's accumulated usage/cost
	// so far, so live cost doesn't reset to zero after a reconnect. Omitted
	// (zero) until the child has closed at least one message.
	InputTokens  int     `json:"input_tokens,omitempty"`
	OutputTokens int     `json:"output_tokens,omitempty"`
	CostUSD      float64 `json:"cost_usd,omitempty"`
	// ContextPercent restores the child's own context reading after a
	// reconnect (0-100, -1 unknown) — see SubagentUsageData.ContextPercent.
	ContextPercent int `json:"context_percent"`
	// AccentIndex is the subagent's stable per-session creation ordinal, used
	// by the client to derive a deterministic accent color that survives
	// reconnects (instead of one derived from array/map position).
	AccentIndex int `json:"accent_index"`
}

type SubagentStartData struct {
	JobID            string `json:"job_id"`
	OriginToolCallID string `json:"origin_tool_call_id,omitempty"`
	Task             string `json:"task"`
	Model            string `json:"model"`
	Thinking         string `json:"thinking"`
	Async            bool   `json:"async"`
	// StartedAtMs is the child's start time as epoch milliseconds (same
	// encoding as InitData.RunStartedAtMs), so the client can compute live
	// elapsed time (now - StartedAtMs). Omitted when unknown.
	StartedAtMs int64 `json:"started_at_ms,omitempty"`
	// AccentIndex is the subagent's stable per-session creation ordinal (see
	// SubagentInitData.AccentIndex). Never omitted: 0 is a valid ordinal
	// (the session's first subagent).
	AccentIndex int `json:"accent_index"`
}

type SubagentSummary struct {
	JobID      string    `json:"job_id"`
	Task       string    `json:"task"`
	Model      string    `json:"model,omitempty"`
	Thinking   string    `json:"thinking,omitempty"`
	Status     string    `json:"status"`
	Async      bool      `json:"async"`
	StartedAt  time.Time `json:"started_at,omitempty"`
	FinishedAt time.Time `json:"finished_at,omitempty"`
	Source     string    `json:"source"`
	// Usage/cost/context of the CHILD, so a client reopening a finished
	// subagent shows the same figures its live view showed. ContextPercent is
	// -1 when unknown; the tokens and cost are omitted when zero.
	InputTokens    int     `json:"input_tokens,omitempty"`
	OutputTokens   int     `json:"output_tokens,omitempty"`
	CostUSD        float64 `json:"cost_usd,omitempty"`
	ContextPercent int     `json:"context_percent"`
}

type SubagentUsageData struct {
	JobID        string  `json:"job_id"`
	InputTokens  int     `json:"input_tokens"`
	OutputTokens int     `json:"output_tokens"`
	CostUSD      float64 `json:"cost_usd"`
	// ContextPercent is how full the CHILD's own window is (0-100), or -1 when
	// its model has no known window. Sent unconditionally (no omitempty): 0 is
	// a real reading, and a client that fell back to the parent's percentage
	// would be showing a number about a different agent.
	ContextPercent int `json:"context_percent"`
}

type TasksUpdateData struct {
	Tasks any `json:"tasks"`
}

type ToolCallDeltaData struct {
	ToolCallID string         `json:"tool_call_id"`
	Args       map[string]any `json:"args"`
}

type ToolCallStreamingData struct {
	ToolCallID string `json:"tool_call_id"`
	ToolName   string `json:"tool_name"`
}

type ToolEndData struct {
	ToolCallID string `json:"tool_call_id"`
	ToolName   string `json:"tool_name"`
	IsError    bool   `json:"is_error"`
	Rejected   bool   `json:"rejected"`
	Result     string `json:"result"`
}

type ToolStartData struct {
	ToolCallID string         `json:"tool_call_id"`
	ToolName   string         `json:"tool_name"`
	Args       map[string]any `json:"args"`
	// StartLine is the real 1-based file line where an edit's oldText starts,
	// so the frontend diff preview shows real line numbers before the tool
	// result arrives. 0 when unknown (frontend numbers from 1). Edit tool only.
	StartLine int `json:"start_line,omitempty"`
}

type ToolUpdateData struct {
	ToolCallID string `json:"tool_call_id"`
	Delta      string `json:"delta"`
}

type UserMessageData struct {
	MsgID   string         `json:"msg_id,omitempty"`
	Text    string         `json:"text,omitempty"`
	Content []core.Content `json:"content,omitempty"`
}