agent

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

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

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

type AgentMessage struct {
	ID        string         `json:"id,omitempty"`
	Role      MessageRole    `json:"role"`
	Content   []ContentBlock `json:"content"`
	Timestamp int64          `json:"timestamp,omitempty"`
	Metadata  map[string]any `json:"metadata,omitempty"`
}

type AgentState struct {
	SystemPrompt  string
	Model         string
	Provider      string
	ThinkingLevel string // off, minimal, low, medium, high, xhigh
	Tools         []Tool
	Messages      []AgentMessage
	IsStreaming   bool
	StreamMessage *AgentMessage // Current streaming message
	PendingTools  map[string]bool
	Error         error

	// Queues for message injection (inspired by pi-mono)
	SteeringQueue []AgentMessage
	SteeringMode  MessageQueueMode
	FollowUpQueue []AgentMessage
	FollowUpMode  MessageQueueMode

	// Session key
	SessionKey string

	// Skills support
	LoadedSkills []string
}

type AgentTool interface {
	// Name returns the tool name (used for tool calls)
	Name() string

	// Description returns what the tool does
	Description() string

	// Parameters returns JSON Schema for the tool's parameters
	Parameters() map[string]any

	// Label returns a human-readable label for UI display
	// Inspired by pi-mono's AgentTool.label
	Label() string

	// Execute runs the tool with streaming update support
	// toolCallId: unique identifier for this tool call
	// params: validated parameters
	// signal: cancellation signal
	// onUpdate: callback for streaming updates
	Execute(ctx context.Context, toolCallId string, params map[string]any, signal context.Context, onUpdate func(AgentToolResult)) (AgentToolResult, error)
}

type AgentToolResult struct {
	// Content blocks supporting text and images
	Content []ContentBlock `json:"content"`
	// Details to be displayed in a UI or logged
	Details map[string]any `json:"details"`
}

type AnnounceCallback func(sessionKey, message string) error

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

type BindingEntry struct {
	AgentID   string
	Channel   string
	AccountID string
	Agent     *Agent
}

type ContentBlock interface {
	ContentType() string
}

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

type DeliveryContext struct {
	Channel   string `json:"channel,omitempty"`
	AccountID string `json:"account_id,omitempty"`
	To        string `json:"to,omitempty"`
	ThreadID  string `json:"thread_id,omitempty"`
}

type Event struct {
	Type      EventType     `json:"type"`
	Message   *AgentMessage `json:"message,omitempty"`
	Timestamp int64         `json:"timestamp"`
	// Tool execution fields
	ToolID     string         `json:"tool_id,omitempty"`
	ToolName   string         `json:"tool_name,omitempty"`
	ToolArgs   map[string]any `json:"tool_args,omitempty"`
	ToolResult *ToolResult    `json:"tool_result,omitempty"`
	ToolError  bool           `json:"tool_error,omitempty"`
	// Turn end fields
	StopReason    string         `json:"stop_reason,omitempty"`
	FinalMessages []AgentMessage `json:"final_messages,omitempty"`
	// Message update event
	AssistantMessageEvent interface{} `json:"assistant_message_event,omitempty"`
	// Streaming fields
	StreamContent string `json:"stream_content,omitempty"`
}

type EventType string

type ImageContent struct {
	URL      string `json:"url,omitempty"`
	Data     string `json:"data,omitempty"` // base64
	MimeType string `json:"mimeType,omitempty"`
}

type LoopConfig struct {
	Model         string
	Provider      providers.Provider
	SessionMgr    *session.Manager
	MaxIterations int
	SessionID     string
	ToolTimeout   time.Duration // Timeout for individual tool executions (default: 3 minutes)
	Retry         *RetryConfig  // Retry configuration

	// Hooks for message transformation
	ConvertToLLM     func([]AgentMessage) ([]providers.Message, error)
	TransformContext func([]AgentMessage) ([]AgentMessage, error)

	// Queues for message injection
	GetSteeringMessages func() ([]AgentMessage, error)
	GetFollowUpMessages func() ([]AgentMessage, error)

	// Skills support
	Skills         []*Skill
	LoadedSkills   []string
	ContextBuilder *ContextBuilder

	// Error handling
	ErrorClassifier errors.ErrorClassifier
}

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

type Message struct {
	Role       string     `json:"role"`
	Content    string     `json:"content"`
	Images     []string   `json:"images,omitempty"`
	ToolCallID string     `json:"tool_call_id,omitempty"`
	ToolCalls  []ToolCall `json:"tool_calls,omitempty"`
}

type MessageQueueMode string

type MessageRole string

type MissingDeps struct {
	Bins       []string `yaml:"bins"`       // 缺失的二进制
	AnyBins    []string `yaml:"anyBins"`    // 缺失的可选二进制
	Env        []string `yaml:"env"`        // 缺失的环境变量
	PythonPkgs []string `yaml:"pythonPkgs"` // 缺失的Python包
	NodePkgs   []string `yaml:"nodePkgs"`   // 缺失的Node.js包
}

type NewAgentConfig struct {
	Bus                *bus.MessageBus
	Provider           providers.Provider
	SessionMgr         *session.Manager
	Tools              *ToolRegistry
	Context            *ContextBuilder
	Workspace          string
	MaxIteration       int
	MaxHistoryMessages int // 最大历史消息数量
	SkillsLoader       *SkillsLoader
	Retry              *RetryConfig // Retry configuration
}

type NewAgentManagerConfig struct {
	Bus            *bus.MessageBus
	Provider       providers.Provider
	SessionMgr     *session.Manager
	Tools          *ToolRegistry
	DataDir        string          // 数据目录，用于存储分身注册表
	ContextBuilder *ContextBuilder // 上下文构建器
	SkillsLoader   *SkillsLoader   // 技能加载器
	ChannelMgr     *channels.Manager
}

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

type PackageType string

type PromptMode string

type RecoveryAction string

type RetryConfig struct {
	Enabled               bool
	MaxRetries            int
	InitialDelay          time.Duration
	MaxDelay              time.Duration
	BackoffFactor         float64
	RetryableErrors       []string
	ContextOverflowAction string
}

type RetryDecision struct {
	ShouldRetry     bool
	Delay           time.Duration
	Action          RecoveryAction
	ProfileToUse    string
	CompressContext bool
	Reason          string
}

type RetryManager interface {
	ShouldRetry(err error) bool
	GetDelay() time.Duration
	RecordError(err error) RetryDecision
	RecordSuccess()
	GetState() *RetryState
	Reset()
}

type RetryState struct {
	Attempt         int
	LastError       error
	LastErrorReason errors.FailoverReason
	NextRetryAt     time.Time
	TotalDelay      time.Duration
}

type SearchResult struct {
	Skill   *Skill
	Source  string // skill的来源路径
	Score   float64
	Matches []string // 匹配的字段
}

type Skill struct {
	Name        string `yaml:"name"`
	Description string `yaml:"description"`
	Version     string `yaml:"version"`
	Author      string `yaml:"author"`
	Homepage    string `yaml:"homepage"`
	Always      bool   `yaml:"always"`
	Metadata    struct {
		OpenClaw struct {
			Emoji    string `yaml:"emoji"`
			Always   bool   `yaml:"always"`
			Requires struct {
				Bins       []string `yaml:"bins"`
				AnyBins    []string `yaml:"anyBins"`
				Env        []string `yaml:"env"`
				Config     []string `yaml:"config"`
				OS         []string `yaml:"os"`
				PythonPkgs []string `yaml:"pythonPkgs"` // Python包依赖
				NodePkgs   []string `yaml:"nodePkgs"`   // Node.js包依赖
			} `yaml:"requires"`
			Install []SkillInstall `yaml:"install"`
		} `yaml:"openclaw"`
	} `yaml:"metadata"`
	Requires SkillRequirements `yaml:"requires"` // 兼容旧格式
	Content  string            `yaml:"-"`        // 技能内容（Markdown）
	// 缺失的依赖信息
	MissingDeps *MissingDeps `yaml:"-"` // 解析时填充
}

type SkillInstall struct {
	ID      string   `yaml:"id"`      // 安装方式唯一标识
	Kind    string   `yaml:"kind"`    // 安装方式: brew, apt, npm, pip, uv, go
	Formula string   `yaml:"formula"` // 包名 (brew, apt)
	Package string   `yaml:"package"` // 包名 (npm, pip, go)
	Bins    []string `yaml:"bins"`    // 安装后提供的可执行文件
	Label   string   `yaml:"label"`   // 安装说明
	OS      []string `yaml:"os"`      // 适用的操作系统
	Command string   `yaml:"command"` // 自定义安装命令
}

type SkillRequirements struct {
	Bins []string `yaml:"bins"`
	Env  []string `yaml:"env"`
}

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

type SubagentAnnounceParams struct {
	ChildSessionKey     string
	ChildRunID          string
	RequesterSessionKey string
	RequesterOrigin     *DeliveryContext
	RequesterDisplayKey string
	Task                string
	Label               string
	StartedAt           *int64
	EndedAt             *int64
	Outcome             *SubagentRunOutcome
	Cleanup             string
	AnnounceType        SubagentAnnounceType
	TimeoutSeconds      int
}

type SubagentAnnounceType string

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

type SubagentCompletion struct {
	Status    string // ok, error, timeout
	StartedAt int64
	EndedAt   int64
	Error     string
}

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

type SubagentRunOutcome struct {
	Status string `json:"status"` // ok, error, timeout, unknown
	Error  string `json:"error,omitempty"`
}

type SubagentRunParams struct {
	RunID               string
	ChildSessionKey     string
	RequesterSessionKey string
	RequesterOrigin     *DeliveryContext
	RequesterDisplayKey string
	Task                string
	Cleanup             string
	Label               string
	ArchiveAfterMinutes int
}

type SubagentRunRecord struct {
	RunID               string              `json:"run_id"`
	ChildSessionKey     string              `json:"child_session_key"`
	RequesterSessionKey string              `json:"requester_session_key"`
	RequesterOrigin     *DeliveryContext    `json:"requester_origin,omitempty"`
	RequesterDisplayKey string              `json:"requester_display_key"`
	Task                string              `json:"task"`
	Cleanup             string              `json:"cleanup"` // delete, keep
	Label               string              `json:"label,omitempty"`
	CreatedAt           int64               `json:"created_at"`
	StartedAt           *int64              `json:"started_at,omitempty"`
	EndedAt             *int64              `json:"ended_at,omitempty"`
	Outcome             *SubagentRunOutcome `json:"outcome,omitempty"`
	ArchiveAtMs         *int64              `json:"archive_at_ms,omitempty"`
	CleanupCompletedAt  *int64              `json:"cleanup_completed_at,omitempty"`
	CleanupHandled      bool                `json:"cleanup_handled"`
}

type SubagentSystemPromptParams struct {
	RequesterSessionKey string
	RequesterOrigin     *DeliveryContext
	ChildSessionKey     string
	Label               string
	Task                string
}

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

type ThinkingContent struct {
	Thinking string `json:"thinking"`
}

type Tool interface {
	Name() string
	Description() string
	Parameters() map[string]any

	// Label returns a human-readable label for the tool (for UI display)
	// Inspired by pi-mono's AgentTool.label
	Label() string

	// Execute runs the tool with optional streaming updates
	Execute(ctx context.Context, params map[string]any, onUpdate func(ToolResult)) (ToolResult, error)
}

type ToolCall struct {
	ID     string                 `json:"id"`
	Name   string                 `json:"name"`
	Params map[string]interface{} `json:"params"`
}

type ToolCallContent struct {
	ID        string         `json:"id"`
	Name      string         `json:"name"`
	Arguments map[string]any `json:"arguments"`
}

type ToolPolicy struct {
	Deny      map[string]bool
	Allow     map[string]bool
	AllowOnly bool
}

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

type ToolResult struct {
	Content []ContentBlock `json:"content"`
	Details map[string]any `json:"details"`
	Error   error          `json:"error,omitempty"`
}

type ToolValidationError struct {
	Field   string
	Message string
}

type UpdateSessionOptions struct {
	SaveImmediately bool // Save to disk after updating
}