cron

type ContextJobHandler func(ctx context.Context, job *CronJob) (string, error)

type CronAgentOption func(*cronConfig)

type CronAgentResult struct {
	Agent   adk.TypedAgent[*schema.AgenticMessage]
	Service *CronService
}

type CronJob struct {
	ID             string       `json:"id" gorm:"column:id;primaryKey;type:varchar(32)"`
	UserID         string       `json:"userId,omitempty" gorm:"column:user_id;type:varchar(64);index"`
	Name           string       `json:"name" gorm:"column:name;type:varchar(100)"`
	Enabled        bool         `json:"enabled" gorm:"column:enabled"`
	Schedule       CronSchedule `json:"schedule" gorm:"embedded"`
	Payload        CronPayload  `json:"payload" gorm:"embedded"`
	State          CronJobState `json:"state" gorm:"embedded"`
	CreatedAtMS    int64        `json:"createdAtMs" gorm:"column:created_at_ms"`
	UpdatedAtMS    int64        `json:"updatedAtMs" gorm:"column:updated_at_ms"`
	DeleteAfterRun bool         `json:"deleteAfterRun" gorm:"column:delete_after_run"`
}

type CronJobState struct {
	NextRunAtMS *int64 `json:"nextRunAtMs,omitempty" gorm:"column:next_run_at_ms"`
	LastRunAtMS *int64 `json:"lastRunAtMs,omitempty" gorm:"column:last_run_at_ms"`
	LastStatus  string `json:"lastStatus,omitempty" gorm:"column:last_status;type:varchar(20)"`
	LastError   string `json:"lastError,omitempty" gorm:"column:last_error;type:text"`
}

type CronPayload struct {
	Message string `json:"message" gorm:"column:message;type:text"`
}

type CronSchedule struct {
	Kind    string `json:"kind" gorm:"column:kind;type:varchar(10);not null"`   // "at" | "every" | "cron"
	AtMS    *int64 `json:"atMs,omitempty" gorm:"column:at_ms"`                  // Kind=at 时的触发时间戳（毫秒）
	EveryMS *int64 `json:"everyMs,omitempty" gorm:"column:every_ms"`            // Kind=every 时的间隔（毫秒）
	Expr    string `json:"expr,omitempty" gorm:"column:expr;type:varchar(100)"` // Kind=cron 时的 cron 表达式
}

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

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

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

type JobContextBuilder func(ctx context.Context, job *CronJob) context.Context

type JobHandler func(job *CronJob) (string, error)

type JobLifecycle struct {
	// OnTriggered 在任务触发后、模型处理前调用。
	OnTriggered func(ctx context.Context, job *CronJob)
	// OnProcessed 在模型处理结束后调用（无论成功或失败）。
	OnProcessed func(ctx context.Context, job *CronJob, response string, err error)
}

type Locker interface {
	Lock(ctx context.Context, key string) error
	Unlock(ctx context.Context, key string) error
}

type Store interface {
	// List 列出所有任务
	List() ([]CronJob, error)

	// Get 根据 ID 获取任务
	Get(id string) (*CronJob, error)

	// Save 保存任务（新增或更新）
	Save(job *CronJob) error

	// Delete 根据 ID 删除任务
	Delete(id string) error
}