agent

type AgentMessage struct {
	Role    string `json:"role"`
	Content string `json:"content"`
}

type AgentRequest struct {
	SessionID    string         `json:"session_id"`
	ForkSession  bool           `json:"fork_session,omitempty"`
	Messages     []AgentMessage `json:"messages"`
	SystemPrompt string         `json:"system_prompt"`
	ChannelID    string         `json:"channel_id"`
	AuthorID     string         `json:"author_id,omitempty"`
	DirPath      string         `json:"dir_path,omitempty"`
	PlanMode     bool           `json:"plan_mode,omitempty"`
	Prompt       string         `json:"prompt,omitempty"`
	// OnTurn is called for each assistant turn's text content during streaming.
	// When set, the runner follows container logs in real-time instead of waiting
	// for the container to exit. When nil, the runner uses the existing
	// wait-then-read behavior.
	OnTurn func(text string) `json:"-"`
	// OnToolUse is called for each tool invocation in an assistant turn.
	OnToolUse func(name, input string) `json:"-"`
	// OnActivity is called for model detection and system events (subagent progress).
	OnActivity func(activity, detail string) `json:"-"`
}

type AgentResponse struct {
	Response   string `json:"response"`
	SessionID  string `json:"session_id"`
	Error      string `json:"error,omitempty"`
	DurationMs int    `json:"duration_ms,omitempty"`
	NumTurns   int    `json:"num_turns,omitempty"`
	StopReason string `json:"stop_reason,omitempty"`
	Model      string `json:"model,omitempty"`
}