cron

type Action struct {
	// Type is the action type.
	Type ActionType `json:"type"`

	// SessionID is the target session for send_message actions.
	SessionID string `json:"session_id,omitempty"`

	// Message is the content to send for send_message actions.
	Message string `json:"message,omitempty"`

	// WebhookURL is the target URL for call_webhook actions.
	WebhookURL string `json:"webhook_url,omitempty"`

	// WebhookMethod is the HTTP method (default: POST).
	WebhookMethod string `json:"webhook_method,omitempty"`

	// WebhookHeaders are additional headers for webhook requests.
	WebhookHeaders map[string]string `json:"webhook_headers,omitempty"`

	// WebhookBody is the request body for webhook requests.
	WebhookBody string `json:"webhook_body,omitempty"`

	// ToolName is the tool to invoke for call_tool actions.
	ToolName string `json:"tool_name,omitempty"`

	// ToolParams are the parameters to pass to the tool.
	ToolParams map[string]any `json:"tool_params,omitempty"`
}

type ActionType string

type Duration time.Duration

type ExecutionHandler func(ctx context.Context, job *Job) ExecutionResult

type ExecutionResult struct {
	// Success indicates if the execution completed successfully.
	Success bool `json:"success"`

	// Output is the result from the action.
	Output any `json:"output,omitempty"`

	// Error is the error message if execution failed.
	Error string `json:"error,omitempty"`

	// Duration is how long the execution took.
	Duration time.Duration `json:"duration"`

	// StartedAt is when the execution started.
	StartedAt time.Time `json:"started_at"`

	// FinishedAt is when the execution finished.
	FinishedAt time.Time `json:"finished_at"`
}

type Job struct {
	// ID is the unique identifier for the job.
	ID string `json:"id"`

	// Name is a human-readable name for the job.
	Name string `json:"name"`

	// Description provides additional context about the job.
	Description string `json:"description,omitempty"`

	// Schedule defines when the job runs.
	Schedule Schedule `json:"schedule"`

	// Action defines what the job does when it runs.
	Action Action `json:"action"`

	// Status is the current state of the job.
	Status JobStatus `json:"status"`

	// CreatedAt is when the job was created.
	CreatedAt time.Time `json:"created_at"`

	// UpdatedAt is when the job was last modified.
	UpdatedAt time.Time `json:"updated_at"`

	// LastRunAt is when the job last ran (nil if never run).
	LastRunAt *time.Time `json:"last_run_at,omitempty"`

	// NextRunAt is when the job is scheduled to run next (nil if not scheduled).
	NextRunAt *time.Time `json:"next_run_at,omitempty"`

	// RunCount is the total number of times the job has run.
	RunCount int64 `json:"run_count"`

	// LastError is the error from the last run (empty if successful).
	LastError string `json:"last_error,omitempty"`

	// Metadata contains arbitrary key-value pairs for extensibility.
	Metadata map[string]any `json:"metadata,omitempty"`
}

type JobStatus string

type Schedule struct {
	// Cron is a cron expression (e.g., "0 9 * * *" for 9am daily).
	Cron string `json:"cron,omitempty"`

	// Once is a specific time for one-time execution.
	Once *time.Time `json:"once,omitempty"`

	// Interval is the duration between runs (e.g., 1h for hourly).
	Interval Duration `json:"interval,omitempty"`
}

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

type SchedulerConfig struct {
	// Store is the job storage backend.
	Store *Store

	// Handler is called when a job executes.
	// If nil, jobs will be logged but not executed.
	Handler ExecutionHandler

	// Location is the timezone for cron expressions.
	// If nil, uses time.Local.
	Location *time.Location
}

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

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

type StoreConfig struct {
	// Backend is the KVS storage backend.
	Backend kvs.Store
}