protocol

type AgentDoneMsg struct{}

type Attachment struct {
	Type      string `json:"type"`
	MediaType string `json:"media_type"`
	Data      string `json:"data"`
	Path      string `json:"path,omitempty"`
}

type ClearMsg struct{}

type ConfirmRequestMsg struct {
	ToolName string
	Params   map[string]any
}

type DaemonDisconnectedMsg struct{}

type DaemonEventMsg struct {
	Event ThreadEvent
}

type DaemonStatusMsg struct {
	Connected bool
}

type DirUsage struct {
	// Path is the working directory (thread CWD).
	Path string `json:"path"`
	// Count is the number of open user threads rooted at Path.
	Count int `json:"count"`
	// LastRequestAt is the most recent activity across those threads,
	// RFC3339; used to order by recency and to pick the "latest used" dir.
	LastRequestAt string `json:"last_request_at,omitempty"`
}

type ErrorMsg struct{ Err error }

type EventCompacted struct {
	FromTokens      int64 `json:"from_tokens"`
	ToTokens        int64 `json:"to_tokens"`
	SummarizedTurns int   `json:"summarized_turns"`
	Auto            bool  `json:"auto"` // true = auto-trigger, false = /compact
}

type EventConfirmRequest struct {
	ToolName      string         `json:"tool_name"`
	Params        map[string]any `json:"params"`
	RequestedDirs []string       `json:"requested_dirs,omitempty"` // directories outside cwd that require approval
	Detail        string         `json:"detail,omitempty"`         // same format as EventToolResult.Detail — fenced code block or structured diff
}

type EventError struct {
	Message string `json:"message"`
	// Code is an optional machine-readable discriminator. Used by the attach
	// flow: "thread_not_found" tells the client a resume target no longer
	// exists on disk so it can orphan the thread (offer /copy) instead of
	// retrying the reconnect forever; "thread_busy" tells the client the
	// thread is already open in another connection (exclusive single-writer
	// ownership) so it should retry later or attach a different thread.
	Code string `json:"code,omitempty"`
}

type EventInitState struct {
	State int    `json:"state"`
	Model string `json:"model,omitempty"` // resolved model spec, set on InitDone
}

type EventJobDone struct {
	JobID    string `json:"job_id"`
	Name     string `json:"name,omitempty"`
	Status   string `json:"status"`
	Error    string `json:"error,omitempty"`
	ThreadID string `json:"thread_id,omitempty"`
}

type EventJobRun struct {
	JobID  string `json:"job_id"`
	Name   string `json:"name,omitempty"`
	Status string `json:"status"`
	Error  string `json:"error,omitempty"`
}

type EventJobsChanged struct{}

type EventMCPChanged struct{}

type EventPlanComplete struct {
	Plan *Plan `json:"plan"`
}

type EventPlanProposed struct {
	Plan *Plan `json:"plan"`
}

type EventPlanTaskDone struct {
	TaskIdx int    `json:"task_idx"`
	Title   string `json:"title"`
	Success bool   `json:"success"`
	Summary string `json:"summary"`
}

type EventPlanTaskStart struct {
	TaskIdx int    `json:"task_idx"`
	Title   string `json:"title"`
	Total   int    `json:"total"`
}

type EventQuestionOption struct {
	Title        string `json:"title"`
	Description  string `json:"description"`
	HasUserInput bool   `json:"has_user_input,omitempty"`
}

type EventReplay struct {
	Messages       []ReplayMessage `json:"messages"`
	Todos          []TodoItem      `json:"todos,omitempty"`
	ActivePlan     *Plan           `json:"active_plan,omitempty"`
	Model          string          `json:"model,omitempty"`
	Title          string          `json:"title,omitempty"`
	ThreadMode     string          `json:"thread_mode,omitempty"`
	ActiveWorkflow string          `json:"active_workflow,omitempty"`
	// Warnings are human-readable restore notices rendered into the viewport
	// (e.g. "Saved with model X; switched to your current default Y.").
	Warnings []string `json:"warnings,omitempty"`
}

type EventRetry struct {
	Attempt    int    `json:"attempt"`
	MaxRetries int    `json:"max_retries"`
	WaitSecs   int    `json:"wait_secs"`
	Reason     string `json:"reason"`
}

type EventSkillsAvailable struct {
	Skills []SkillInfo `json:"skills"`
}

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

type EventStreamDone struct {
	InputTokens         int64 `json:"input_tokens"`
	OutputTokens        int64 `json:"output_tokens"`
	CacheCreationTokens int64 `json:"cache_creation_tokens"`
	CacheReadTokens     int64 `json:"cache_read_tokens"`
	ElapsedMs           int64 `json:"elapsed_ms"`
}

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

type EventThinkingStall struct {
	ElapsedMs    int64 `json:"elapsed_ms"`
	SummaryChars int   `json:"summary_chars"`
}

type EventThreadStarted struct {
	ThreadID    string `json:"thread_id"`
	StartedAt   string `json:"started_at"` // RFC3339
	ParentID    string `json:"parent_id,omitempty"`
	ForkTurnIdx int    `json:"fork_turn_idx,omitempty"`
	// WhiteboardBase is the local web UI origin (e.g. "http://localhost:1337")
	// used by the client to build whiteboard links for mermaid diagrams. Empty
	// when the web UI is disabled, in which case the client shows no link.
	WhiteboardBase string `json:"whiteboard_base,omitempty"`
}

type EventThreadsChanged struct{}

type EventTitleUpdated struct {
	Title string `json:"title"`
}

type EventTodoListUpdated struct {
	Todos []TodoItem `json:"todos"`
}

type EventToolBackends struct {
	GrepEffective  string `json:"grep_effective"`
	GrepConfigured string `json:"grep_configured"`
	GlobEffective  string `json:"glob_effective"`
	GlobConfigured string `json:"glob_configured"`
}

type EventToolCall struct {
	ToolID string `json:"tool_id"`
	Name   string `json:"name"`
	// Arguments is the raw tool input as issued by the model (structured
	// key/value payload). Included so trajectory consumers (ATIF exporters,
	// SFT/RL pipelines) can round-trip the exact call without re-deriving
	// it from Summary. Summary stays the human-readable one-liner.
	Arguments map[string]any `json:"arguments,omitempty"`
	Summary   string         `json:"summary"`
	Reason    string         `json:"reason,omitempty"`
	// TimeoutSec is the effective tool-call timeout in seconds, after daemon
	// clamping. See daemon.resolveToolTimeout: floor and cap come from the
	// `tool_timeouts` block in settings.json (defaulting to 120s / 600s when
	// absent or invalid), and only bash/glob_files honor the model's
	// `timeout` override.
	TimeoutSec int `json:"timeout_sec,omitempty"`
	// Bash-specific alternative-tool justifications (omitted when empty or "N/A").
	ReasonNotReadFile  string `json:"reason_not_read_file,omitempty"`
	ReasonNotEditFile  string `json:"reason_not_edit_file,omitempty"`
	ReasonNotGlobFiles string `json:"reason_not_glob_files,omitempty"`
	// ReasonToIncreaseTimeout is the model's justification for raising the
	// bash/glob_files timeout above the 120s default. Populated from the
	// `reason_to_increase_timeout` field of the tool input.
	ReasonToIncreaseTimeout string `json:"reason_to_increase_timeout,omitempty"`
}

type EventToolResult struct {
	ToolID  string `json:"tool_id"`
	Name    string `json:"name"`
	Output  string `json:"output"`
	IsError bool   `json:"is_error"`
	Detail  string `json:"detail,omitempty"` // optional rich detail (e.g. edit diff)
}

type EventUpdateAvailable struct {
	Current string `json:"current"`
	Latest  string `json:"latest,omitempty"`
	URL     string `json:"url,omitempty"`
	Method  string `json:"method,omitempty"`
}

type EventUserQuestion struct {
	// Single-question fields (backward compatible)
	Question    string                `json:"question"`
	Options     []string              `json:"options"`
	RichOptions []EventQuestionOption `json:"rich_options,omitempty"` // structured options (workflow tool steps)
	Placeholder string                `json:"placeholder,omitempty"`
	Category    string                `json:"category,omitempty"`

	// Multi-question batch (if set, overrides single fields)
	Questions []QuestionDef `json:"questions,omitempty"`
}

type EventWorkflowComplete struct {
	WorkflowName string     `json:"workflow_name"`
	Success      bool       `json:"success"`
	Summary      string     `json:"summary,omitempty"`
	StepCosts    []StepCost `json:"step_costs,omitempty"`
	DurationMs   int64      `json:"duration_ms,omitempty"`
}

type EventWorkflowStart struct {
	WorkflowName string             `json:"workflow_name"`
	TotalSteps   int                `json:"total_steps"`
	Steps        []WorkflowStepInfo `json:"steps,omitempty"`
}

type EventWorkflowStatus struct {
	WorkflowName   string `json:"workflow_name"`
	Status         string `json:"status"`
	StepID         string `json:"step_id,omitempty"`
	Iteration      int    `json:"iteration,omitempty"`
	TokensUsed     int64  `json:"tokens_used,omitempty"`
	TokenBudget    int64  `json:"token_budget,omitempty"`
	ElapsedSeconds int64  `json:"elapsed_seconds,omitempty"`
	Note           string `json:"note,omitempty"`
}

type EventWorkflowStepDone struct {
	StepID              string     `json:"step_id"`
	StepIdx             int        `json:"step_idx"`
	Total               int        `json:"total"`
	Success             bool       `json:"success"`
	TimedOut            bool       `json:"timed_out,omitempty"` // bash step killed by per-step timeout; workflow continues
	Display             string     `json:"display,omitempty"`
	Command             string     `json:"command,omitempty"`     // bash step: resolved command that was run
	BashOutput          string     `json:"bash_output,omitempty"` // bash step: first 5 lines of output
	Model               string     `json:"model,omitempty"`
	InputTokens         int64      `json:"input_tokens,omitempty"`
	OutputTokens        int64      `json:"output_tokens,omitempty"`
	CacheCreationTokens int64      `json:"cache_creation_tokens,omitempty"`
	CacheReadTokens     int64      `json:"cache_read_tokens,omitempty"`
	ToolStats           []ToolStat `json:"tool_stats,omitempty"`
	DurationMs          int64      `json:"duration_ms,omitempty"`
}

type EventWorkflowStepStart struct {
	StepID      string `json:"step_id"`
	StepIdx     int    `json:"step_idx"`
	Total       int    `json:"total"`
	Agent       string `json:"agent"`
	Explanation string `json:"explanation,omitempty"`
}

type EventWorkflowsAvailable struct {
	Workflows []WorkflowInfo `json:"workflows"`
}

type HookSummary struct {
	ID          string `json:"id"`
	Name        string `json:"name,omitempty"`
	Enabled     bool   `json:"enabled"`
	Event       string `json:"event,omitempty"` // the lifecycle event it subscribes to
	Matcher     string `json:"matcher,omitempty"`
	Mode        string `json:"mode,omitempty"`          // sync | async
	LastFiredAt string `json:"last_fired_at,omitempty"` // RFC3339, empty when never fired
	LastStatus  string `json:"last_status,omitempty"`
	CreatedBy   string `json:"created_by,omitempty"`
}

type InitState int

type InitStateMsg struct{ State int }

type InstanceRegisterData struct {
	InstanceID string `json:"instance_id,omitempty"`
	Mode       string `json:"mode,omitempty"` // "tui" | "headless"
}

type JobSummary struct {
	ID      string `json:"id"`
	Name    string `json:"name,omitempty"`
	Enabled bool   `json:"enabled"`
	// TriggerType is "cron" or "at". Schedule is a human-readable rendering of
	// the trigger (the cron expression, or "at <time>" for one-shots).
	TriggerType string `json:"trigger_type,omitempty"`
	Schedule    string `json:"schedule,omitempty"`
	NextRunAt   string `json:"next_run_at,omitempty"` // RFC3339, empty when not scheduled
	LastRunAt   string `json:"last_run_at,omitempty"` // RFC3339, empty when never run
	LastStatus  string `json:"last_status,omitempty"` // ok | error | skipped | timeout
	Running     bool   `json:"running,omitempty"`     // a run is currently in flight
	CreatedBy   string `json:"created_by,omitempty"`
}

type MCPServerSummary struct {
	Name    string `json:"name"`
	Type    string `json:"type"` // "stdio" or "url"
	Enabled bool   `json:"enabled"`
	// Status is "connected", "error", or "disabled". ToolCount and Error are
	// meaningful only for enabled servers that were probed.
	Status    string `json:"status"`
	ToolCount int    `json:"tool_count"`
	Error     string `json:"error,omitempty"`
	// Auth describes OAuth state for servers configured with `oauth`:
	// "authenticated", "needs_auth", or "" (not an OAuth server).
	Auth string `json:"auth,omitempty"`
}

type Plan struct {
	Name         string      `json:"name"`
	Context      string      `json:"context"`
	Architecture string      `json:"architecture,omitempty"`
	Files        []string    `json:"files,omitempty"`
	Risks        string      `json:"risks,omitempty"`
	Tasks        []*PlanTask `json:"tasks"`
	CurrentIdx   int         `json:"current_idx"`
}

type PlanAction struct {
	Type PlanActionType
	Text string // only used for PlanModify
}

type PlanActionType int

type PlanCompleteMsg struct{ Plan *Plan }

type PlanProposedMsg struct{ Plan *Plan }

type PlanTask struct {
	ID          int        `json:"id"`
	Title       string     `json:"title"`
	Description string     `json:"description"`
	Substeps    []string   `json:"substeps,omitempty"`
	Status      TaskStatus `json:"status"`
	Result      string     `json:"result,omitempty"`
}

type PlanTaskDoneMsg struct {
	TaskIdx int
	Title   string
	Success bool
	Summary string
}

type PlanTaskStartMsg struct {
	TaskIdx int
	Title   string
	Total   int
}

type QuestionDef struct {
	ID       string   `json:"id"`
	Category string   `json:"category"`
	Question string   `json:"question"`
	Options  []string `json:"options,omitempty"`
}

type QuitMsg struct{}

type ReplayBlock struct {
	Kind     string         `json:"kind"` // "text" | "thinking" | "tool_use" | "tool_result" | "retry" | "error"
	Text     string         `json:"text,omitempty"`
	ToolID   string         `json:"tool_id,omitempty"`
	ToolName string         `json:"tool_name,omitempty"`
	Input    map[string]any `json:"input,omitempty"`
	Output   string         `json:"output,omitempty"`
	IsError  bool           `json:"is_error,omitempty"`
	// Retry-notice fields (Kind == "retry"): a transient API error that was
	// retried during a workflow run, persisted so a reopened thread replays
	// the same notice an interactive run shows live. Text carries the reason.
	Attempt    int `json:"attempt,omitempty"`
	MaxRetries int `json:"max_retries,omitempty"`
	WaitSecs   int `json:"wait_secs,omitempty"`
	// Failure-notice field (Kind == "error"): the workflow step that aborted the
	// run, when known. Text carries the failure reason (including captured step
	// output). Persisted so a reopened run shows why it failed.
	StepID string `json:"step_id,omitempty"`
}

type ReplayMessage struct {
	Role   string        `json:"role"` // "user" | "assistant"
	Blocks []ReplayBlock `json:"blocks"`
	// Timestamp is when the turn was originally sent (RFC3339), so the
	// replayed viewport shows original send times instead of the relaunch
	// time. Empty for legacy threads persisted before timestamps existed;
	// the TUI omits the "Sent at" line in that case.
	Timestamp string `json:"timestamp,omitempty"`
}

type SkillInfo struct {
	Name        string `json:"name"`
	Description string `json:"description"`
}

type StepCost struct {
	StepID              string  `json:"step_id"`
	Explanation         string  `json:"explanation,omitempty"`
	Model               string  `json:"model"`
	InputTokens         int64   `json:"input_tokens"`
	OutputTokens        int64   `json:"output_tokens"`
	CacheCreationTokens int64   `json:"cache_creation_tokens"`
	CacheReadTokens     int64   `json:"cache_read_tokens"`
	Cost                float64 `json:"cost"`
	DurationMs          int64   `json:"duration_ms,omitempty"`
}

type StreamChunkMsg struct{ Text string }

type StreamDoneMsg struct {
	InputTokens         int64
	OutputTokens        int64
	CacheCreationTokens int64
	CacheReadTokens     int64
	Elapsed             time.Duration
}

type SubagentDoneMsg struct {
	Name   string
	TaskID string
}

type SubagentStartMsg struct {
	Name       string
	Background bool
	TaskID     string
}

type TaskStatus int

type ThreadCommand struct {
	Type      string          `json:"type"`
	AuthToken string          `json:"auth_token,omitempty"`
	Data      json.RawMessage `json:"data"`
}

type ThreadConfirmData struct {
	Approved    bool `json:"approved"`
	PersistDirs bool `json:"persist_dirs,omitempty"` // save approved directories to settings.json
}

type ThreadEvent struct {
	Type string `json:"type"`
	Data any    `json:"data"`
}

type ThreadInputData struct {
	Text        string       `json:"text"`
	Attachments []Attachment `json:"attachments,omitempty"`
}

type ThreadPlanActionData struct {
	Action string `json:"action"` // "approve", "reject", "modify"
	Text   string `json:"text,omitempty"`
}

type ThreadSetModelData struct {
	Model string `json:"model"`
}

type ThreadStartData struct {
	CWD                            string `json:"cwd"`
	ConfigDir                      string `json:"config_dir,omitempty"`
	Model                          string `json:"model"`
	ForceInit                      bool   `json:"force_init"`
	EnableAutomaticWritePermission bool   `json:"enable_automatic_write_permission"`
	EnableAutomaticDirectoryAccess bool   `json:"enable_automatic_directory_access"`
	Headless                       bool   `json:"headless"`
	// ClientVersion is the vix binary version opening this thread. The daemon
	// refuses the thread (event.error, code "version_mismatch") when it does
	// not exactly match the daemon's own version — a long-lived daemon must
	// never serve a client from a different build.
	ClientVersion string `json:"client_version,omitempty"`
	// Fork fields: when ForkThreadID is non-empty the new thread is seeded
	// with the conversation history of the named thread up to and including
	// the turn at ForkTurnIdx (0-based).
	ForkThreadID string `json:"fork_thread_id,omitempty"`
	ForkTurnIdx  int    `json:"fork_turn_idx,omitempty"`
	// AttachThreadID, when non-empty, asks the daemon to resume a persisted
	// thread by ID instead of creating a fresh one: it loads the on-disk
	// record from open/, reuses that ID, and replays the conversation to the
	// client via event.replay. Records in closed/ are not attachable — an
	// explicitly closed thread stays closed. If no open record exists the
	// daemon answers with event.error carrying Code "thread_not_found".
	AttachThreadID string `json:"attach_thread_id,omitempty"`
}

type ThreadSummary struct {
	ID    string `json:"id"`
	CWD   string `json:"cwd"`
	Model string `json:"model"`
	// Title is the thread's display title: set by an LLM summarization pass
	// after a few turns (user threads) or at creation time (job runs). When
	// empty, clients fall back to FirstMessage.
	Title         string `json:"title,omitempty"`
	FirstMessage  string `json:"first_message,omitempty"`
	StartedAt     string `json:"started_at,omitempty"`      // RFC3339
	LastRequestAt string `json:"last_request_at,omitempty"` // RFC3339
	// Attached is true when this thread is currently live in the daemon (open
	// in some connection). The launching client uses it to avoid attaching a
	// thread another instance already owns (exclusive single-writer ownership).
	Attached bool `json:"attached,omitempty"`
	// Origin distinguishes user-started threads ("", the default) from
	// vix-initiated ones ("vix" — scheduled job runs, synthetic alerts). The
	// TUI groups the threads list by it and never auto-claims vix-initiated
	// threads on launch.
	Origin  string       `json:"origin,omitempty"`
	Trigger *TriggerInfo `json:"trigger,omitempty"`
	// JobStatus carries the finished run's status (ok | error | timeout) for
	// vix-initiated threads, powering the badge in the threads list.
	JobStatus string `json:"job_status,omitempty"`
	// Unread reports whether the thread holds content the user hasn't seen
	// (thread-global, persisted — survives restarts). Cleared via the
	// thread.mark_read command when the user views the thread.
	Unread bool `json:"unread,omitempty"`
}

type ThreadTrimData struct {
	TurnIdx int `json:"turn_idx"` // keep history up to and including this turn (0-based)
}

type ThreadUserAnswerData struct {
	Answer  string            `json:"answer"`
	Text    string            `json:"text,omitempty"`    // user input when has_user_input
	Answers map[string]string `json:"answers,omitempty"` // question ID → answer (batch mode)
}

type ThreadWorkflowData struct {
	Name     string          `json:"name"`
	Text     string          `json:"text"`
	Workflow json.RawMessage `json:"workflow,omitempty"`
}

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

type TodoItem struct {
	ID        string     `json:"id"`
	Content   string     `json:"content"`
	Status    TodoStatus `json:"status"`
	DependsOn []string   `json:"depends_on,omitempty"`
}

type TodoStatus string

type ToolCallMsg struct {
	Name    string
	Summary string
}

type ToolResultMsg struct {
	Name    string
	Output  string
	IsError bool
}

type ToolStat struct {
	Name    string `json:"name"`
	Calls   int    `json:"calls"`
	Summary string `json:"summary"`
}

type TriggerInfo struct {
	Type string `json:"type"`
	Ref  string `json:"ref,omitempty"`
}

type WorkflowInfo struct {
	Name string `json:"name"`
}

type WorkflowStepInfo struct {
	ID          string `json:"id"`
	Explanation string `json:"explanation,omitempty"`
}