runner

type ActivityTracker interface {
	LastActivity() time.Time
}

type Aliver interface {
	Alive() bool
}

type CoreToolsBuilder func(plugintools.BuildContext) []tools.Tool

type DBPromptParams struct {
	SystemPrompt   string          // agent's full system prompt from DB (the base layer)
	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
	Workspace      string
	Cwd            string // optional working directory
	UserDataDir    string // optional per-user data directory
	PromptTools    []pkgplugins.PromptToolInfo
	PromptSections []pkgplugins.SystemPromptSection
}

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
	WorkDir        string // working directory for tool execution
	Workspace      string // workspace dir for skills/memory (e.g. ~/.anna/workspace)
	AnnaHome       string // anna home directory (e.g. ~/.anna)
	System         string // optional system prompt override (bypasses default prompt building)
	PromptSections []pkgplugins.SystemPromptSection
	ExtraTools     []tools.Tool       // additional tools to register
	UserDataDir    string             // per-user data directory for sandbox enforcement (empty = no sandbox)
	HookPlugins    []hooks.HookPlugin // hook plugins for the engine loop
	ToolLifecycle  *coreagent.ToolLifecycle
	CoreTools      CoreToolsBuilder
	Providers      ProviderRegistryBuilder
}

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 (0 = no user isolation)
	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)
}