agent

type ActivityTracker interface {
	LastActivity() time.Time
}

type Aliver interface {
	Alive() bool
}

type BeforeRunBuilder func(ctx context.Context, build pkgplugins.BeforeRunContext) (pkgplugins.BeforeRunResult, error)

type BuiltinToolsFactory func(snap *config.Snapshot) []tools.Tool

type ChatOption func(*chatOptions)

type CompactionConfig struct {
	// MaxTokens triggers compaction when the estimated token count exceeds this.
	// 0 (or omitted) uses the default of 80000. Negative values disable
	// automatic compaction. Manual /compact still works.
	MaxTokens int `yaml:"max_tokens"`
	// KeepTail is the number of recent message entries to preserve verbatim
	// after compaction. Default: 20.
	KeepTail int `yaml:"keep_tail"`
}

type DBPromptParams struct {
	SystemPrompt      string                    // agent's base system prompt from DB
	AgentSoul         string                    // agent's default soul from DB (fallback for all users)
	Memory            memory.Provider           // active provider for profile loading (may be nil)
	KnowledgeStore    pkgplugins.KnowledgeStore // optional; injects ## Knowledge section when set
	UserID            int64                     // auth user ID for profile lookup
	AgentID           string                    // agent ID for profile lookup
	AnnaHome          string
	AgentRoot         string
	ProjectRoot       string // optional project root for local/project-attached runs
	UserRoot          string // per-user writable root
	PromptTools       []pkgplugins.PromptToolInfo
	PluginPrompts     []pkgplugins.SystemPromptSection
	PromptSections    []pkgplugins.SystemPromptSection
	Host              sandbox.Host
	SnapshotVersion   int64     // frozen memory version for this session; 0 means current
	SnapshotUpdatedAt time.Time // wall-clock time of the last snapshot advance; used to filter knowledge
}

type Envelope struct {
	Type string          `json:"type"`
	Data json.RawMessage `json:"data"`
}

type Event struct {
	Text    string
	Image   *ImageEvent
	File    *FileEvent
	ToolUse *ToolUseEvent
	Store   ai.Message // if non-nil, Pool appends to session history
	Err     error
}

type FileEvent struct {
	Path string // absolute path on disk
	Name string // display filename (with extension)
}

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

type GoRunnerConfig struct {
	API              string // provider key: "anthropic", "openai"
	Model            string // e.g. "claude-sonnet-4-20250514"
	APIKey           string
	BaseURL          string // optional provider base URL override
	AgentRoot        string // agent root directory
	AnnaHome         string // anna home directory (e.g. ~/.anna)
	ProjectRoot      string // optional project root for project-aware tools and prompt/context loading
	System           string // optional system prompt override (bypasses default prompt building)
	PluginPrompts    []pkgplugins.SystemPromptSection
	PromptSections   []pkgplugins.SystemPromptSection
	ExtraTools       []tools.Tool // additional tools to register
	PluginTools      func(context.Context, plugintools.BuildContext) []tools.Tool
	SessionEnvSpecs  []pkgplugins.SessionEnvSpec
	UserRoot         string             // required per-user root used by prompts, skills, and sandbox execution
	HookPlugins      []hooks.HookPlugin // hook plugins for the engine loop
	ToolLifecycle    *coreagent.ToolLifecycle
	Providers        ProviderRegistryBuilder
	Sandbox          config.SandboxConfig
	SandboxBackendFn func(ctx context.Context) string // resolves active backend at session time; overrides Sandbox.Backend
	UserID           int64                            // auth user ID; used for vault secret injection
	VaultEnvLoader   VaultEnvLoader                   // optional; if set, vault secrets are injected into sandbox env
	TokenManager     *oauth.TokenManager              // optional; if set, runtime OAuth tokens are injected into sandbox env
}

type HandlerFunc func(ctx context.Context, history []ai.Message, message MessageContent) <-chan Event

type ImageEvent struct {
	Data     string // base64 encoded
	MimeType string // e.g. "image/jpeg"
}

type MessageContent = any

type NewRunnerFunc func(ctx context.Context, params RunnerParams) (Runner, error)

type PluginHooksBuilder func(ctx context.Context) []hooks.HookPlugin

type PluginPromptsBuilder func() []pkgplugins.SystemPromptSection

type PluginToolsBuilder func(ctx context.Context, build plugintools.BuildContext) []tools.Tool

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

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

type PoolManagerOption func(*PoolManager)

type PoolOption func(*Pool)

type PromptSectionsBuilder func(ctx context.Context, build pkgplugins.SystemPromptContext) ([]pkgplugins.SystemPromptSection, error)

type PromptToolsBuilder func(ctx context.Context) ([]pkgplugins.PromptToolInfo, error)

type ProviderRegistryBuilder func(api, apiKey, baseURL string) (*providers.Registry, error)

type Runner interface {
	Chat(ctx context.Context, history []ai.Message, message MessageContent) <-chan Event
}

type RunnerParams struct {
	Model   string                    // model ID (empty = use default)
	Memory  any                       // memory.Provider — typed as any to avoid circular imports
	UserID  int64                     // auth user ID for user-scoped runner creation
	AgentID string                    // agent ID for profile loading
	HooksFn func() []hooks.HookPlugin // resolved at runner-creation time; nil = no hooks
}

type Session struct {
	Info   SessionInfo
	Runner Runner
	Model  string // model ID the current runner was created with
}

type SessionInfo = memory.SessionInfo

type SessionPluginViewBuilder func(ctx context.Context) (pkgplugins.SessionPluginView, error)

type Stateful interface {
	Stateful() bool
}

type SystemPrompter interface {
	SystemPrompt() string
}

type ToolUseEvent struct {
	Tool   string // tool name, e.g. "bash", "read"
	Status string // "running", "done", "error"
	Input  string // short summary of the tool input
	Detail string // error detail or result summary (for "error" status)
}

type VaultEnvLoader interface {
	LoadEnv(ctx context.Context, userID int64) (map[string]string, error)
}