cron

type Job struct {
	ID             string   `json:"id"`
	Name           string   `json:"name"`
	Enabled        bool     `json:"enabled"`
	Schedule       Schedule `json:"schedule"`
	Payload        Payload  `json:"payload"`
	State          JobState `json:"state"`
	CreatedAtMS    int64    `json:"created_at_ms"`
	UpdatedAtMS    int64    `json:"updated_at_ms"`
	DeleteAfterRun bool     `json:"delete_after_run,omitempty"`
}

type JobHandler func(*Job) error

type JobState struct {
	NextRunAtMS *int64 `json:"next_run_at_ms,omitempty"`
	LastRunAtMS *int64 `json:"last_run_at_ms,omitempty"`
	LastStatus  string `json:"last_status,omitempty"`
	LastError   string `json:"last_error,omitempty"`
}

type Payload struct {
	Kind    string `json:"kind"`    // "agent_turn"
	Message string `json:"message"` // message sent to agent
	Channel string `json:"channel"` // target channel name
	ChatID  string `json:"chat_id"` // target chat ID
	Deliver bool   `json:"deliver"` // true=deliver directly, false=agent processes
}

type Schedule struct {
	Kind    string `json:"kind"`               // "at" | "every" | "cron"
	AtMS    *int64 `json:"at_ms,omitempty"`    // one-shot timestamp (milliseconds)
	EveryMS *int64 `json:"every_ms,omitempty"` // interval (milliseconds)
	Expr    string `json:"expr,omitempty"`     // cron expression (5-field)
}

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

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