daemon

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

type AgentOp string

type AgentRequest struct {
	ID     string  `json:"id"`
	Op     AgentOp `json:"op"`
	Prompt string  `json:"prompt,omitempty"`
	// WorkDir is the caller's working directory for query/query_stream ops.
	// The daemon has no other way to know which project a one-shot query is
	// for: it's a single long-lived process that may serve callers from many
	// different directories over its lifetime. Required for those ops —
	// AgentService implementations must scope tool execution to WorkDir
	// rather than the daemon process's own (fixed, arbitrary) cwd.
	WorkDir     string         `json:"work_dir,omitempty"`
	SessionName string         `json:"session_name,omitempty"`
	SessionID   string         `json:"session_id,omitempty"`
	Tool        string         `json:"tool,omitempty"`
	ToolArgs    map[string]any `json:"tool_args,omitempty"`
}

type AgentResponse struct {
	ID       string        `json:"id"`
	Error    string        `json:"error,omitempty"`
	Sessions []SessionInfo `json:"sessions,omitempty"`
	Session  *SessionInfo  `json:"session,omitempty"`
	Result   string        `json:"result,omitempty"`
	Tool     *ToolResult   `json:"tool,omitempty"`
}

type AgentServer struct {
	// SocketPath is the Unix socket path to listen on.
	SocketPath string
	// Service backs all operations.
	Service AgentService
	// Logger receives request/error logs.
	Logger *slog.Logger
	// Activity, when non-nil, is marked Begin/End around each request so the
	// daemon idle reaper can see agent socket traffic.
	Activity *DaemonActivity
	// OnClose, when non-nil, is invoked inside Close() after the listener and
	// conns are closed, before Close returns. It blocks until the service's
	// teardown finishes — mirroring webui's waitForAgentTeardown so a daemon
	// exiting doesn't race an in-flight embedding-store flush.
	OnClose func()
	// contains filtered or unexported fields
}

type AgentService interface {
	// ListSessions returns known sessions.
	ListSessions(ctx context.Context) ([]SessionInfo, error)
	// CreateSession creates a named session.
	CreateSession(ctx context.Context, name string) (*SessionInfo, error)
	// SwitchSession activates an existing session.
	SwitchSession(ctx context.Context, sessionID string) (*SessionInfo, error)
	// Query runs a one-shot query scoped to workDir and returns the final
	// response. Implementations must not let query state (conversation
	// history, workspace root) leak between calls with different workDir —
	// each call may be for an unrelated project.
	Query(ctx context.Context, prompt, workDir string) (string, error)
	// StreamQuery is Query with streamed events instead of a single result.
	StreamQuery(ctx context.Context, prompt, workDir string, emit func(StreamEvent) error) error
	// ExecuteTool invokes a tool by name with args.
	ExecuteTool(ctx context.Context, name string, args map[string]any) (*ToolResult, error)
}

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

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

type DaemonSpec struct {
	// DaemonURL is the HTTP base URL to reach the daemon (e.g.
	// "http://127.0.0.1:56000").
	DaemonURL string

	// SocketPath is the Unix-domain socket path as an alternative to
	// TCP. If set, DetectDaemon tries this socket when DaemonURL fails.
	SocketPath string

	// PIDFilePath is the path to the PID-file lock used for cross-process
	// election. A flock on this file ensures exactly one process spawns
	// the daemon.
	PIDFilePath string

	// StartTimeout limits how long StartDaemon and EnsureDaemon wait for
	// the daemon to become healthy after spawning.
	StartTimeout time.Duration

	// ShutdownDelay is the idle timeout used by DaemonLifecycle: when
	// the last connection disconnects, the daemon is stopped after this
	// delay unless a new connection arrives.
	ShutdownDelay time.Duration

	// DaemonCommand is the command (args[0] is the binary) used to spawn
	// the daemon process. Default: [executable-path, "agent", "-d"].
	DaemonCommand []string

	// Env holds extra KEY=VALUE environment variables applied to the
	// spawned daemon process (merged over the parent's environment).
	// Used e.g. to set SPROUT_DAEMON_IDLE_TIMEOUT so auto-started
	// daemons reap themselves after an idle period.
	Env []string

	// LogPath is where the spawned daemon's stdout/stderr are redirected.
	// If empty, output goes to os.DevNull.
	LogPath string
}

type EmbeddingManagerService struct {
	// Acquire returns a manager for the workspace root, or an error when
	// the workspace is refused (e.g. the index is not enabled). A nil
	// manager with a nil error means no manager is available at all. The
	// daemon wires this to embedding.AcquireManager with the workspace's
	// config.
	Acquire func(workspaceRoot string) (*embedding.EmbeddingManager, error)
	// Release drops a reference taken by Acquire.
	Release func(m *embedding.EmbeddingManager)
	// contains filtered or unexported fields
}

type EmbeddingServer struct {
	// SocketPath is the Unix socket path to listen on.
	SocketPath string
	// Service backs all operations.
	Service EmbeddingService
	// Logger receives request/error logs.
	Logger *slog.Logger
	// Activity, when non-nil, is marked Begin/End around each request so the
	// daemon idle reaper can see embedding socket traffic.
	Activity *DaemonActivity
	// contains filtered or unexported fields
}

type EmbeddingService interface {
	// Meta returns provider identity (name, dimensions, model hash).
	Meta(ctx context.Context) (name string, dims int, modelHash string, err error)
	// Embed returns a vector for one text.
	Embed(ctx context.Context, text string) ([]float32, error)
	// EmbedBatch returns vectors for many texts (same order).
	EmbedBatch(ctx context.Context, texts []string) ([][]float32, error)
	// QuerySimilar queries the index for workspaceRoot.
	QuerySimilar(ctx context.Context, workspaceRoot, text string, topK int, threshold float32) ([]embedding.QueryResult, error)
	// BuildIndex builds the index for workspaceRoot.
	BuildIndex(ctx context.Context, workspaceRoot string) (*embedding.IndexStats, error)
	// CheckDuplicates checks content against the workspaceRoot index.
	CheckDuplicates(ctx context.Context, workspaceRoot, filePath, content string) (*embedding.CheckDuplicatesResult, error)
}

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

type HealthOption func(*HealthMonitor)

type HealthStatus struct {
	Status         string `json:"status"`
	Port           int    `json:"port"`
	Uptime         string `json:"uptime"`
	AgentAvailable bool   `json:"agent_available"`
	ActiveQueries  int    `json:"active_queries"`
}

type SessionInfo struct {
	ID        string `json:"id"`
	Name      string `json:"name"`
	CreatedAt string `json:"created_at,omitempty"`
	Active    bool   `json:"active,omitempty"`
}

type StreamEvent struct {
	Type    string `json:"type"` // "delta" | "tool" | "done" | "error"
	Content string `json:"content,omitempty"`
	Tool    string `json:"tool,omitempty"`
	Error   string `json:"error,omitempty"`
}

type ToolResult struct {
	Content string `json:"content"`
	Error   string `json:"error,omitempty"`
}