cron

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

type Config struct {
	Timezone string
	Store    JobStore
	OnFire   func(job *Job) error
	// OnRunLog is called after each job execution to persist the run record.
	// Receives job, output text (may be empty), error, and success flag.
	// Best-effort — errors from this callback are logged but not surfaced.
	OnRunLog func(job *Job, output, errMsg string, success bool)
}

type CronExpr struct {
	Minute  field
	Hour    field
	Day     field
	Month   field
	Weekday field
}

type ExecutionStyle string

type Job struct {
	ID             string         `json:"id"`
	Name           string         `json:"name"`
	Schedule       string         `json:"schedule"`
	Timezone       string         `json:"timezone"`
	ExecutionStyle ExecutionStyle `json:"execution_style"`
	SessionID      string         `json:"session_id,omitempty"`
	Command        string         `json:"command"`
	Status         JobStatus      `json:"status"`
	LastRun        time.Time      `json:"last_run"`
	NextRun        time.Time      `json:"next_run"`
	RunCount       int            `json:"run_count"`
	FailureCount   int            `json:"failure_count"`
	MaxRetries     int            `json:"max_retries"`
	// BackoffBaseSec is the initial retry delay in seconds (default 60).
	// Doubles on each subsequent failure up to BackoffMaxSec.
	BackoffBaseSec int `json:"backoff_base_sec"`
	// BackoffMaxSec caps the retry delay (default 300).
	BackoffMaxSec int               `json:"backoff_max_sec"`
	CreatedAt     time.Time         `json:"created_at"`
	Metadata      map[string]string `json:"metadata"`
	// DeliveryTarget restricts delivery of cron output to a specific
	// gateway channel. Valid values: "telegram", "slack", "discord",
	// "" (default — dispatch to the cron channel only).
	DeliveryTarget string `json:"delivery_target"`
	// NotifyGateway, when true, dispatches cron output through the
	// gateway dispatcher so the agent processes it as an inbound
	// message. When false, output goes to shell only (legacy).
	NotifyGateway bool `json:"notify_gateway"`
}

type JobStatus string

type JobStore interface {
	SaveJob(ctx context.Context, job *Job) error
	LoadJobs(ctx context.Context) ([]Job, error)
	DeleteJob(ctx context.Context, id string) error
}

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

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

type RunLog struct {
	ID      int64     `json:"id"`
	JobID   string    `json:"job_id"`
	Output  string    `json:"output"`
	Error   string    `json:"error"`
	Success bool      `json:"success"`
	RunAt   time.Time `json:"run_at"`
}

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