scheduler

type Anticipation struct {
	ID              string            `json:"id"`
	Description     string            `json:"description"`                // Human-readable: "Dan's flight arriving"
	Context         string            `json:"context"`                    // Injected on match: instructions/reasoning
	ContextEntities []string          `json:"context_entities,omitempty"` // Entity IDs to snapshot on wake
	Recurring       bool              `json:"recurring,omitempty"`        // true = keep firing; false = auto-resolve after wake
	CooldownSeconds int               `json:"cooldown_seconds,omitempty"` // 0 = use global default
	Model           string            `json:"model,omitempty"`            // Soft model preference for wake execution
	LocalOnly       *bool             `json:"local_only,omitempty"`       // nil = use default (true); explicit false allows cloud
	QualityFloor    int               `json:"quality_floor,omitempty"`    // 0 = use wake default (6)
	Trigger         Trigger           `json:"trigger"`                    // When this anticipation activates
	CreatedAt       time.Time         `json:"created_at"`
	ExpiresAt       *time.Time        `json:"expires_at,omitempty"` // nil = no expiration
	ResolvedAt      *time.Time        `json:"resolved_at,omitempty"`
	LastFiredAt     *time.Time        `json:"last_fired_at,omitempty"`
	Metadata        map[string]string `json:"metadata,omitempty"` // Arbitrary k/v for matching
}

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

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

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

type Duration struct {
	time.Duration
}

type ExecuteFunc func(ctx context.Context, task *Task, execution *Execution) error

type Execution struct {
	ID          string          `json:"id"`           // UUIDv7
	TaskID      string          `json:"task_id"`      // FK to Task
	ScheduledAt time.Time       `json:"scheduled_at"` // When it was supposed to run
	StartedAt   *time.Time      `json:"started_at,omitempty"`
	CompletedAt *time.Time      `json:"completed_at,omitempty"`
	Status      ExecutionStatus `json:"status"`
	Result      string          `json:"result,omitempty"` // Output or error
}

type ExecutionStatus string

type Payload struct {
	Kind   PayloadKind    `json:"kind"`
	Target string         `json:"target,omitempty"` // Session ID, entity ID, etc.
	Data   map[string]any `json:"data,omitempty"`   // Kind-specific data
}

type PayloadKind string

type Schedule struct {
	Kind     ScheduleKind `json:"kind"`
	At       *time.Time   `json:"at,omitempty"`       // For "at" kind
	Every    *Duration    `json:"every,omitempty"`    // For "every" kind
	Cron     string       `json:"cron,omitempty"`     // For "cron" kind
	Timezone string       `json:"timezone,omitempty"` // IANA timezone
}

type ScheduleKind string

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

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

type Task struct {
	ID        string    `json:"id"`       // UUIDv7
	Name      string    `json:"name"`     // Human-readable label
	Schedule  Schedule  `json:"schedule"` // When to run
	Payload   Payload   `json:"payload"`  // What to do
	Enabled   bool      `json:"enabled"`
	CreatedAt time.Time `json:"created_at"`
	CreatedBy string    `json:"created_by"` // Session or user ID
	UpdatedAt time.Time `json:"updated_at"`
}

type Trigger struct {
	// Time-based: activates after this time
	AfterTime *time.Time `json:"after_time,omitempty"`

	// State-based: activates when entity matches state
	EntityID    string `json:"entity_id,omitempty"`    // e.g., "person.dan"
	EntityState string `json:"entity_state,omitempty"` // e.g., "home" or state to match

	// Zone-based: activates on zone transition
	Zone       string `json:"zone,omitempty"`        // e.g., "airport"
	ZoneAction string `json:"zone_action,omitempty"` // "enter" or "leave"

	// Event-based: activates on specific event type
	EventType string `json:"event_type,omitempty"` // e.g., "presence_change"

	// Custom expression (future: CEL or simple DSL)
	Expression string `json:"expression,omitempty"`
}

type WakeContext struct {
	Time        time.Time
	EventType   string            // What triggered the wake: "cron", "presence", "state_change", etc.
	EntityID    string            // Relevant entity if any
	EntityState string            // Current state of that entity
	Zone        string            // Zone involved if presence event
	ZoneAction  string            // "enter" or "leave"
	Metadata    map[string]string // Additional context
}