event

type AgentMessageItem struct {
	Text      string `json:"text,omitempty"`
	Reasoning string `json:"reasoning,omitempty"`
}

type Approval struct {
	ID      string
	Tool    string
	Subject string
	// Decisions (spec 5-7) are the selectable options; nil = default 3.
	Decisions []Decision
	// Args is the raw JSON arguments of the call being approved, so a card can
	// show specifics itself (the bash command, target paths). Empty for
	// synthetic approvals (plan/replan) that have no tool args.
	Args string
	// Changes carries the previewed per-file changes for writer tools (via the
	// tool's Previewer, computed at request time — before the permission
	// decision). Nil for tools that can't describe their change.
	Changes []FileChange
}

type ApprovalItem struct {
	Tool    string       `json:"tool"`
	Subject string       `json:"subject"`
	Changes []FileChange `json:"changes,omitempty"`
}

type Ask struct {
	ID        string
	Questions []AskQuestion
}

type AskAnswer struct {
	QuestionID string
	Selected   []string
}

type AskOption struct {
	Label       string
	Description string // optional one-line explanation shown under the label
}

type AskQuestion struct {
	ID      string // stable per-question id, so answers correlate back
	Header  string // short label (the tab title)
	Prompt  string // the question text
	Options []AskOption
	Multi   bool // allow selecting more than one option
}

type Attachment struct {
	Path string `json:"path"` // repo-relative, under .fairpeer/attachments/
	Kind string `json:"kind"` // "image"
}

type CacheDiagnostics struct {
	PrefixHash          string
	PrefixChanged       bool
	PrefixChangeReasons []string // "system", "tools", "log_rewrite"
	SystemHash          string
	ToolsHash           string
	LogRewriteVersion   int
	ToolSchemaTokens    int
	CacheMissTokens     int
	CacheHitTokens      int
}

type Collab struct {
	RunID     string
	TeamID    string
	TeamName  string
	Task      string
	Mode      string
	Rounds    [][]CollabAnswer
	Synthesis string
	CreatedAt int64 // unix ms
}

type CollabAnswer struct {
	ExpertName string
	Text       string
}

type Compaction struct {
	Trigger  string // "auto" | "manual"
	Messages int    // Done: how many messages were folded into the summary
	Summary  string // Done: the briefing the agent keeps relying on
	Archive  string // Done: path the dropped originals were archived to ("" if none)
}

type CompactionItem struct {
	Trigger  string `json:"trigger"`
	Messages int    `json:"messages,omitempty"`
	Summary  string `json:"summary,omitempty"`
}

type Decision struct {
	Label        string        `json:"label"`
	Scope        string        `json:"scope"` // once | session | always | path | host
	Restrictions *Restrictions `json:"restrictions,omitempty"`
}

type Event struct {
	Kind             Kind
	Text             string            // Reasoning / Text / Message / Notice / Phase
	Reasoning        string            // Message: the full reasoning chain
	Tool             Tool              // ToolDispatch / ToolResult
	Usage            *provider.Usage   // Usage
	Pricing          *provider.Pricing // Usage: for cost display (nil = omit cost)
	CacheDiagnostics *CacheDiagnostics // Usage: cache-churn attribution (nil = N/A)
	// SessionHit/SessionMiss carry cumulative cache tokens across the whole
	// session (Usage events only), so a frontend can show the aggregate hit-rate
	// — which doesn't crater on a short turn or after compaction — alongside
	// Usage's single-turn numbers.
	SessionHit   int        // Usage: cumulative cache-hit prompt tokens this session
	SessionMiss  int        // Usage: cumulative cache-miss prompt tokens this session
	Level        Level      // Notice
	Approval     Approval   // ApprovalRequest
	Ask          Ask        // AskRequest
	Err          error      // TurnDone: non-nil on failure
	Compaction   Compaction // Compaction
	RetryAttempt int        // Retrying: 1-based attempt about to be made
	RetryMax     int        // Retrying: total attempts before giving up
	RetryAfterMs int64      // Retrying: backoff delay before the attempt (0 = immediate)
	Collab       Collab     // ExpertCollab
	// Item carries the item-model payload (4-1 dual-track). Non-nil only on
	// the synthetic "Item" Kind; old sinks skip it naturally.
	Item *ItemEvent
}

type FileChange struct {
	Path    string
	Kind    string
	Added   int
	Removed int
	Diff    string
}

type FileDiff struct {
	Diff    string
	Added   int
	Removed int
}

type FuncSink func(Event)

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

type ItemEvent struct {
	Phase    ItemPhaseTransition `json:"phase"`
	ItemID   string              `json:"item_id"`
	ItemKind ItemKind            `json:"item_kind"`
	// Delta carries the incremental text for ItemDelta (streaming).
	Delta string `json:"delta,omitempty"`
	// Item carries the full item payload on ItemStarted/ItemCompleted.
	// Structure depends on ItemKind; consumers switch on ItemKind.
	Item json.RawMessage `json:"item,omitempty"`
}

type ItemKind string

type ItemPhaseTransition string

type Kind int

type Level int

type NoticeItem struct {
	Level string `json:"level"` // info | warn
	Text  string `json:"text"`
}

type Profile struct {
	Model  string
	Effort string
}

type ReadinessAuditSink interface {
	RecordReadinessAudit(evidence.ReadinessAudit)
}

type Restrictions struct {
	AllowedPaths []string `json:"allowed_paths,omitempty"` // glob patterns
	AllowedHosts []string `json:"allowed_hosts,omitempty"` // host[:port]
}

type SessionSnapshot struct {
	SessionID string      `json:"session_id"`
	Revision  int         `json:"revision"`
	Items     []ItemEvent `json:"items"`
	CreatedAt time.Time   `json:"created_at"`
}

type Sink interface {
	Emit(Event)
}

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

type Tool struct {
	ID         string
	Name       string
	Args       string
	Output     string // ToolResult: the result text fed to the model
	Err        string // ToolResult: non-empty when the call failed or was blocked
	ReadOnly   bool
	Truncated  bool  // ToolResult: Output was head+tailed before display/model
	DurationMs int64 // ToolResult: wall-clock execution time in milliseconds
	// Partial marks an early ToolDispatch emitted when a call begins (ID/Name set,
	// Args still streaming) so a frontend can show the card immediately; a second,
	// full ToolDispatch (Partial false, Args set) follows when the call completes.
	Partial bool
	// ParentID, when set, is the ID of the tool call that spawned this one — a
	// sub-agent's calls carry the parent `task` call's ID so a frontend can nest
	// them under it. Empty for top-level calls.
	ParentID string
	// Attachments carries files the tool generated (e.g. image_generate pictures
	// saved under .fairpeer/attachments/), parsed from the result text so the
	// frontend can display them regardless of what the model writes back.
	Attachments []Attachment
	FileDiff
	Profile *Profile // ToolDispatch: subagent model/effort (set for task/skill calls)
}

type ToolCallItem struct {
	Name       string    `json:"name"`
	Args       string    `json:"args,omitempty"`
	Output     string    `json:"output,omitempty"`
	Err        string    `json:"err,omitempty"`
	FileDiff   *FileDiff `json:"file_diff,omitempty"`
	ReadOnly   bool      `json:"read_only"`
	DurationMs int64     `json:"duration_ms,omitempty"`
	Status     string    `json:"status"` // running | done | error | stopped
}