automation

type AgentConfig struct {
	// Slug references a named agent definition in seshat-ai (e.g. "accounting-agent").
	// When set, the daemon fetches the agent's model, tools, system_prompt, and
	// max_turns from seshat-ai and merges them with any inline overrides below.
	Slug string
	// BaseType is the built-in agent type to use as a starting point.
	// Empty defaults to "general-purpose".
	BaseType string
	// Tools is the list of tool name patterns the agent is allowed to use
	// (e.g. "read", "web_search", "bash"). Empty = all tools (or inherits from agent).
	Tools []string
	// Skills is the list of skill names to load for this agent.
	Skills []string
	// Model overrides the agent/server default (format "provider:model").
	Model string
	// MaxTurns caps autonomous execution. 0 = inherit from agent or single turn.
	MaxTurns int
	// SystemPrompt overrides the default system prompt when non-empty.
	SystemPrompt string
}

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

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

type DiscardSink struct{}

type ExecuteConfig struct {
	// StreamFn receives each text delta in real time. May be nil.
	StreamFn func(string)
	// ModelOverride specifies a different model for this execution only.
	// Format: "provider:model". Empty means use RunnerConfig.Model.
	ModelOverride string
	// SystemPrompt replaces the entire Seshat default system prompt.
	// Empty means use the default.
	SystemPrompt string
}

type ExecuteFunc func(ctx context.Context, w Workflow, opts Options) (Result, error)

type ExecutionState struct {
	WorkflowName string    `json:"workflow_name"`
	LastRunAt    time.Time `json:"last_run_at"`
	NextRunAt    time.Time `json:"next_run_at,omitempty"`
	LastStatus   string    `json:"last_status"` // "success" | "error" | "running"
	LastError    string    `json:"last_error,omitempty"`
	RunCount     int64     `json:"run_count"`
	SuccessCount int64     `json:"success_count"`
	FailureCount int64     `json:"failure_count"`
	ConsecErrors int       `json:"consec_errors"`
}

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

type ExecutorConfig struct {
	RunnerConfig RunnerConfig
	// Middleware is applied in order (first = outermost wrapper).
	Middleware []Middleware
	// Sinks receive the completed Result after each execution.
	Sinks []Sink
	// State persists execution history. May be nil (no persistence).
	State StateStore
}

type FileSink struct {
	// Dir is the directory where output files are written. Created if absent.
	Dir string
	// Format is "text" (default) or "json".
	Format string
}

type FileStateStore struct {
	Dir string
	// contains filtered or unexported fields
}

type IntervalSchedule struct {
	Interval time.Duration
}

type Job struct {
	ID            string
	OwnerID       string // user ID from the calling app — empty means unowned (system job)
	Name          string
	Description   string
	Trigger       Trigger
	Agent         AgentConfig
	Task          string
	Status        JobStatus
	LastRunAt     *time.Time
	NextRunAt     *time.Time
	LastRunStatus string // "success" | "error" | ""
	CreatedAt     time.Time
	UpdatedAt     time.Time
}

type JobRun struct {
	ID        string
	JobID     string
	StartedAt time.Time
	EndedAt   *time.Time
	Status    RunStatus
	Output    string
	Error     string
}

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

type JobStatus string

type JobStore interface {
	CreateJob(ctx context.Context, job *Job) error
	// GetJob returns a job by ID regardless of owner (for internal scheduler use).
	GetJob(ctx context.Context, id string) (*Job, error)
	// ListJobs returns all jobs for ownerID; pass "" to list all (scheduler/admin).
	ListJobs(ctx context.Context, ownerID string) ([]*Job, error)
	UpdateJob(ctx context.Context, job *Job) error
	// DeleteJob deletes a job by ID; ownerID="" bypasses ownership check (admin).
	DeleteJob(ctx context.Context, id, ownerID string) error

	CreateRun(ctx context.Context, run *JobRun) error
	UpdateRun(ctx context.Context, run *JobRun) error
	ListRuns(ctx context.Context, jobID string, limit int) ([]*JobRun, error)
	GetRun(ctx context.Context, id string) (*JobRun, error)
}

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

type Middleware func(next ExecuteFunc) ExecuteFunc

type MultiSink struct {
	Sinks []Sink
}

type OnceSchedule struct {
	At time.Time
}

type Options struct {
	// Model overrides the Runner's default model for this execution only.
	// Format: "provider:model" (e.g. "anthropic:claude-sonnet-4-6").
	Model string

	// DryRun skips actual LLM execution and returns an empty Result.
	// Useful for validating scheduler configuration without incurring cost.
	DryRun bool

	// Timeout caps the total wall-clock time for the workflow.
	// Zero means no per-execution timeout (context deadline still applies).
	Timeout time.Duration

	// MaxRetries is the number of additional attempts after a failure.
	// Zero means no retry. Used by WithRetry middleware.
	MaxRetries int

	// RetryBackoff is the initial wait between retries (doubles each attempt).
	// Defaults to 5s when zero and MaxRetries > 0.
	RetryBackoff time.Duration

	// Extra holds workflow-specific key-value options that are not part of
	// the standard contract. Workflows may inspect this map for opt-in features.
	Extra map[string]any
}

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

type Result struct {
	WorkflowName string
	StartedAt    time.Time
	FinishedAt   time.Time
	Duration     time.Duration
	Output       string // accumulated text streamed by the agent
	Error        error
	Metadata     map[string]any // arbitrary key-value pairs set by middleware or workflow
}

type RunStatus string

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

type RunnerConfig struct {
	Model          sdk.ModelIdentifier
	ProviderConfig *providers.Config
	MaxTokens      int
	// WebSearchKeys provides per-owner web search provider keys.
	// When set, the web_search tool uses these keys instead of reading from the
	// process environment — required for safe multi-tenant execution.
	WebSearchKeys map[string]string
	// RAGService enables the rag_search/rag_ingest tools for this
	// execution when set. Callers embedding automation in a multi-tenant
	// host (e.g. seshat-ai/seshat-server) are expected to build one scoped
	// to the right organization/corpus namespace per execution, the same
	// way WebSearchKeys is resolved per owner rather than read from a
	// single process-wide config.
	RAGService *rag.Service
	// DoclingURL enables the read_document_url tool when set — fetches
	// and converts a remote document (PDF, webpage, ...) to markdown via a
	// running docling-serve instance. Unlike WebSearchKeys/RAGService this
	// isn't a secret or per-tenant value, so it's fine to read straight
	// from RunnerConfig rather than resolved per execution.
	DoclingURL string
}

type RunnerResolver func(ctx context.Context, ownerID string, agentSlug string, modelOverride string) (*Runner, AgentConfig, error)

type Schedule interface {
	// Next returns the next time the schedule fires after from.
	// Returns the zero Time if the schedule never fires again.
	Next(from time.Time) time.Time
	// String returns a human-readable description of the schedule.
	String() string
}

type ScheduledRun struct {
	WorkflowName string
	Schedule     string
	NextRun      time.Time
}

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

type Sink interface {
	Write(ctx context.Context, r Result) error
}

type StateStore interface {
	Load(ctx context.Context, workflowName string) (*ExecutionState, error)
	Save(ctx context.Context, state ExecutionState) error
	List(ctx context.Context) ([]ExecutionState, error)
	Delete(ctx context.Context, workflowName string) error
}

type StdoutSink struct {
	// Quiet suppresses the footer when true.
	Quiet bool
}

type SystemPrompter interface {
	SystemPrompt() string
}

type Trigger struct {
	Type     TriggerType
	Cron     string        // valid when Type == TriggerTypeCron
	Interval time.Duration // valid when Type == TriggerTypeInterval
	RunAt    *time.Time    // valid when Type == TriggerTypeOnce
}

type TriggerType string

type WebhookSink struct {
	URL     string
	Headers map[string]string
	// Timeout for the HTTP request. Defaults to 15s.
	Timeout time.Duration
	// contains filtered or unexported fields
}

type Workflow interface {
	Name() string
	Description() string
	Run(ctx context.Context, session *sdk.Session) error
}