schedule

type CreateScheduleRequest struct {
	Name          string        `json:"name"`
	ScheduledAt   *time.Time    `json:"scheduled_at,omitempty"`
	CronExpr      string        `json:"cron_expr,omitempty"`
	Timezone      string        `json:"timezone,omitempty"`
	SessionConfig SessionConfig `json:"session_config"`
}

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

type ErrInvalidSchedule struct {
	Field   string
	Message string
}

type ErrScheduleNotFound struct {
	ID string
}

type ExecutionRecord struct {
	// ExecutedAt is when the execution was attempted
	ExecutedAt time.Time `json:"executed_at"`
	// SessionID is the ID of the created session (if successful)
	SessionID string `json:"session_id,omitempty"`
	// Status is the result of the execution: "success", "failed", or "skipped"
	Status string `json:"status"`
	// Error contains the error message if execution failed
	Error string `json:"error,omitempty"`
}

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

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

type LeaderElectionConfig struct {
	// LeaseDuration is the duration that non-leader candidates will wait to force acquire leadership
	LeaseDuration time.Duration
	// RenewDeadline is the duration that the acting master will retry refreshing leadership before giving up
	RenewDeadline time.Duration
	// RetryPeriod is the duration the LeaderElector clients should wait between tries of actions
	RetryPeriod time.Duration
	// LeaseName is the name of the lease resource
	LeaseName string
	// Namespace is the namespace for the lease resource
	Namespace string
}

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

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

type Manager interface {
	// Create creates a new schedule
	Create(ctx context.Context, schedule *Schedule) error

	// Get retrieves a schedule by ID
	Get(ctx context.Context, id string) (*Schedule, error)

	// List retrieves schedules matching the filter
	List(ctx context.Context, filter ScheduleFilter) ([]*Schedule, error)

	// Update updates an existing schedule
	Update(ctx context.Context, schedule *Schedule) error

	// Delete removes a schedule by ID
	Delete(ctx context.Context, id string) error

	// GetDueSchedules returns schedules that are due for execution
	GetDueSchedules(ctx context.Context, now time.Time) ([]*Schedule, error)

	// RecordExecution records an execution attempt
	RecordExecution(ctx context.Context, id string, record ExecutionRecord) error

	// UpdateNextExecution updates the next execution time for a schedule
	UpdateNextExecution(ctx context.Context, id string, nextAt time.Time) error
}

type Schedule struct {
	// ID is the unique identifier for the schedule
	ID string `json:"id"`
	// Name is a human-readable name for the schedule
	Name string `json:"name"`
	// UserID is the ID of the user who created the schedule
	UserID string `json:"user_id"`
	// Status is the current status of the schedule
	Status ScheduleStatus `json:"status"`

	// ScheduledAt is the time when the schedule should first execute (optional)
	// If set without CronExpr, this is a one-time schedule
	// If set with CronExpr, execution starts from this time
	ScheduledAt *time.Time `json:"scheduled_at,omitempty"`

	// CronExpr is the cron expression for recurring execution (optional)
	// Standard cron format: minute hour day-of-month month day-of-week
	// Example: "0 9 * * 1-5" (weekdays at 9:00 AM)
	CronExpr string `json:"cron_expr,omitempty"`

	// Timezone is the IANA timezone for schedule evaluation (default: UTC)
	Timezone string `json:"timezone,omitempty"`

	// SessionConfig contains the configuration for creating sessions
	SessionConfig SessionConfig `json:"session_config"`

	// LastExecution contains the most recent execution record
	LastExecution *ExecutionRecord `json:"last_execution,omitempty"`

	// NextExecutionAt is the calculated next execution time
	NextExecutionAt *time.Time `json:"next_execution_at,omitempty"`

	// ExecutionCount is the total number of executions
	ExecutionCount int `json:"execution_count"`

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

	// UpdatedAt is when the schedule was last updated
	UpdatedAt time.Time `json:"updated_at"`
}

type ScheduleFilter struct {
	// UserID filters by user ID
	UserID string
	// Status filters by schedule status
	Status ScheduleStatus
}

type ScheduleResponse struct {
	ID              string           `json:"id"`
	Name            string           `json:"name"`
	UserID          string           `json:"user_id"`
	Status          ScheduleStatus   `json:"status"`
	ScheduledAt     *time.Time       `json:"scheduled_at,omitempty"`
	CronExpr        string           `json:"cron_expr,omitempty"`
	Timezone        string           `json:"timezone,omitempty"`
	SessionConfig   SessionConfig    `json:"session_config"`
	NextExecutionAt *time.Time       `json:"next_execution_at,omitempty"`
	ExecutionCount  int              `json:"execution_count"`
	LastExecution   *ExecutionRecord `json:"last_execution,omitempty"`
	CreatedAt       time.Time        `json:"created_at"`
	UpdatedAt       time.Time        `json:"updated_at"`
}

type ScheduleStatus string

type SessionConfig struct {
	// Environment variables to set for the session
	Environment map[string]string `json:"environment,omitempty"`
	// Tags for the session (including repository info)
	Tags map[string]string `json:"tags,omitempty"`
	// Params contains session parameters like initial message
	Params *proxy.SessionParams `json:"params,omitempty"`
}

type UpdateScheduleRequest struct {
	Name          *string         `json:"name,omitempty"`
	Status        *ScheduleStatus `json:"status,omitempty"`
	ScheduledAt   *time.Time      `json:"scheduled_at,omitempty"`
	CronExpr      *string         `json:"cron_expr,omitempty"`
	Timezone      *string         `json:"timezone,omitempty"`
	SessionConfig *SessionConfig  `json:"session_config,omitempty"`
}

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

type WorkerConfig struct {
	// CheckInterval is how often to check for due schedules
	CheckInterval time.Duration
	// Enabled indicates whether the worker should run
	Enabled bool
}