runner

type ActivityTracker interface {
	LastActivity() time.Time
}

type Aliver interface {
	Alive() bool
}

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)
	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
	PromptSections []pkgplugins.SystemPromptSection
	Host           sandbox.Host
}

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

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

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)
	PromptSections   []pkgplugins.SystemPromptSection
	ExtraTools       []tools.Tool // additional tools to register
	PluginTools      func(context.Context, plugintools.BuildContext) []tools.Tool
	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
	LarkAppID        string                           // optional Lark app_id from plugin config
	LarkBrand        string                           // optional Lark brand: "lark" or "feishu"
}

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 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 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)
}