cron

type AgentRunner interface {
	Run(ctx context.Context, sessionKey string, prompt string) (string, error)
}

type ChannelSender interface {
	SendMessage(ctx context.Context, channel string, message string) error
}

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

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

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

type HistoryEntry struct {
	ID           string
	JobID        string
	JobName      string
	Status       string // "running" | "completed" | "failed"
	Prompt       string
	Result       string
	ErrorMessage string
	TokensUsed   int
	StartedAt    time.Time
	CompletedAt  *time.Time
}

type Job struct {
	ID           string
	Name         string
	ScheduleType string // "at" | "every" | "cron"
	Schedule     string
	Prompt       string
	SessionMode  string // "isolated" | "main"
	DeliverTo    []string
	Timezone     string
	Enabled      bool
	Timeout      time.Duration // per-job timeout (0 = use default)
	LastRunAt    *time.Time
	NextRunAt    *time.Time
	CreatedAt    time.Time
}

type JobResult struct {
	JobID     string
	JobName   string
	Response  string
	Error     error
	StartedAt time.Time
	Duration  time.Duration
}

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

type SchedulerConfig struct {
	Timezone       string
	MaxJobs        int
	DefaultTimeout time.Duration
	Logger         *zap.SugaredLogger
}

type Store interface {
	Create(ctx context.Context, job Job) error
	Get(ctx context.Context, id string) (*Job, error)
	GetByName(ctx context.Context, name string) (*Job, error)
	List(ctx context.Context) ([]Job, error)
	ListEnabled(ctx context.Context) ([]Job, error)
	Update(ctx context.Context, job Job) error
	Upsert(ctx context.Context, job Job) (stored *Job, updated bool, err error)
	Delete(ctx context.Context, id string) error
	SaveHistory(ctx context.Context, entry HistoryEntry) error
	ListHistory(ctx context.Context, jobID string, limit int) ([]HistoryEntry, error)
	ListAllHistory(ctx context.Context, limit int) ([]HistoryEntry, error)
}

type TypingIndicator interface {
	StartTyping(ctx context.Context, channel string) (stop func(), err error)
}