session

type Budget interface {
	CanExecute(sessionID string) bool
}

type Config struct {
	InputBufferSize    int
	OutputBufferSize   int
	EnableQueue        bool
	QueueSize          int
	MaxPending         int
	PlannerEnabled     bool
	PlannerPrompt      string
	PlannerAutoApprove bool
	// UserID 显式归属的 user；空 = 未显式指定（回退配置 DefaultUserID，再回退 "default"）。
	// P3.2 user 全局合并：归属在 session 创建时固化（INSERT OR IGNORE），不动态变更。
	UserID string
}

type Event struct {
	Type       EventType      `json:"type"`
	SessionID  string         `json:"session_id"`
	Content    string         `json:"content,omitempty"`
	Thinking   string         `json:"thinking,omitempty"`
	ToolCallID string         `json:"tool_call_id,omitempty"`
	ToolName   string         `json:"tool_name,omitempty"`
	ToolInput  map[string]any `json:"tool_input,omitempty"`
	ToolOutput any            `json:"tool_output,omitempty"`
	Error      string         `json:"error,omitempty"`
	Approved   bool           `json:"approved,omitempty"`
	Usage      *Usage         `json:"usage,omitempty"`
	Plan       *Plan          `json:"plan,omitempty"`
	StopCause  string         `json:"stop_cause,omitempty"`
	// Question question 工具向用户提问的内容（P2.1）。配套 QuestionID 供回答注入。
	QuestionID string `json:"question_id,omitempty"`
	Question   string `json:"question,omitempty"`
	// Source 事件来源（S4/B2，subagent-s3s4 §7.7）。默认 "user"（向后兼容，
	// 缺失字段 = user）。唤醒注入 turn = "subagent"，供消费方（client.go /
	// turn_observe.go）识别并折叠，避免"幽灵用户消息"喷到 UI 与 assistant-text。
	Source    EventSource `json:"source,omitempty"`
	Timestamp time.Time   `json:"timestamp"`
}

type EventSource string

type EventType string

type ExecuteResponse struct {
	SessionID string
	Content   string
	ToolCalls []ToolCallInfo
	Usage     Usage
	Error     error
}

type FileSnapshot struct {
	Version              int             `json:"version"`
	SessionID            string          `json:"session_id"`
	Messages             []types.Message `json:"messages"`
	Usage                types.Usage     `json:"usage"`
	MemoryCompletedTurns uint32          `json:"memory_completed_turns"`
}

type Info struct {
	ID        string    `json:"id"`
	Title     string    `json:"title"`
	Summary   *Summary  `json:"summary,omitempty"`
	Time      Time      `json:"time"`
	CreatedAt time.Time `json:"created_at"`
	UpdatedAt time.Time `json:"updated_at"`
}

type Observer interface {
	OnEvent(event *Event)
}

type ObserverFunc func(event *Event)

type Option func(*Config)

type OutputObserver = Observer

type Plan struct {
	Goal      string     `json:"goal,omitempty"`
	Steps     []PlanStep `json:"steps"`
	Reasoning string     `json:"reasoning,omitempty"`
	Approved  bool       `json:"approved"`
}

type PlanApproval struct {
	Approved bool
	Plan     *Plan
}

type PlanMode string

type PlanStep struct {
	Index     int                    `json:"index"`
	Tool      string                 `json:"tool"`
	Input     map[string]interface{} `json:"input"`
	Reasoning string                 `json:"reasoning"`
}

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

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

type SessionFactory interface {
	RecordLoop(sessionID string, action agentutils.LoopDetectAction)
	RecordTokens(ctx context.Context, sessionID string, tokens int)
	Detect(ctx context.Context, sessionID string, action agentutils.LoopDetectAction) *agentutils.LoopDetectResult
}

type Summary struct {
	Additions int    `json:"additions"`
	Deletions int    `json:"deletions"`
	Files     int    `json:"files"`
	Diffs     string `json:"diffs,omitempty"`
}

type Time struct {
	Created    int64 `json:"created"`
	Updated    int64 `json:"updated"`
	Compacting int64 `json:"compacting,omitempty"`
	Archived   int64 `json:"archived,omitempty"`
}

type ToolCallInfo struct {
	ID    string
	Name  string
	Input map[string]interface{}
}

type TurnCanceledError struct {
	Err error
}

type TurnObservation struct {
	AssistantText   string
	Usage           *Usage
	HadError        bool
	ErrorMessage    string
	EngineStopCause string
}

type TurnSessionClosedError struct {
	Err error
}

type Usage = agenttypes.Usage

type WakePayload struct {
	// TaskID DelegateResult.TaskID（spawn_agent 返回的 task_id）。
	TaskID string
	// Text DelegateResult.Truncated() 结果，直接注入下一 turn。
	Text string
}

type WakeSource interface {
	// Wake 有新完成通知时产出信号（不携带 payload；payload 经 Collect 获取）。
	Wake() <-chan struct{}
	// Collect 取走全部未读完成（DrainAll + Truncated）。仅 session idle 时调用
	// （onSubagentCompletion），与 wait_agent（turn 内阻塞）互斥。
	Collect() []WakePayload
}