X-Git-Url: https://git.giacomolli.uk/onechat/blobdiff_plain/add3cf6416e33c24331fd1e90e99284f44d2aae2..f5c601f1801aaa276f8c335fcb51c373edc0b50c:/schedule.go diff --git a/schedule.go b/schedule.go index 28a5a76..5fa35da 100644 --- a/schedule.go +++ b/schedule.go @@ -48,6 +48,40 @@ const ( scheduleLateLine = "This run is late: the daemon was stopped at that time." ) +// Schedules holds the schedules of the agent: tasks that start a turn at one +// time or at the times of a cron expression. Each change writes the file whole +// before it returns, so a schedule survives a restart. The mutex protects the +// schedules, because the tools change them from a turn while Run reads them. +// changed tells Run that a set or a remove changed the times. +type Schedules struct { + path string + owner string + clock func() time.Time + logger *slog.Logger + changed chan struct{} + + mutex sync.Mutex + file ScheduleFile +} + +// ScheduleFile is the content of the file of the schedules: the ID of the last +// schedule, so that an ID is never used again, and the schedules. +type ScheduleFile struct { + Next int `json:"next"` + Schedules []Schedule `json:"schedules"` +} + +// Schedule is one schedule: its owner, its ID, the task for the agent, the cron +// expression of a repeating schedule, empty for a one-time schedule, and its +// next time. +type Schedule struct { + Owner string `json:"owner"` + ID int `json:"id"` + Text string `json:"text"` + Cron string `json:"cron"` + Due time.Time `json:"due"` +} + // openSchedules reads the schedules of the file at path. A missing file holds // none. The owner names its agent. Schedules without an owner take this name. A // different stored owner is an error. The clock gives the time and the time @@ -107,22 +141,6 @@ func openSchedules(path, owner string, clock func() time.Time, logger *slog.Logg return s, nil } -// Schedules holds the schedules of the agent: tasks that start a turn at one -// time or at the times of a cron expression. Each change writes the file whole -// before it returns, so a schedule survives a restart. The mutex protects the -// schedules, because the tools change them from a turn while Run reads them. -// changed tells Run that a set or a remove changed the times. -type Schedules struct { - path string - owner string - clock func() time.Time - logger *slog.Logger - changed chan struct{} - - mutex sync.Mutex - file ScheduleFile -} - // Run starts the runs of the due schedules in l until ctx ends. It waits until // the first due time, at most scheduleClockWaitTimeout at a time, and also // wakes at a set or a remove. So a schedule that came due while the daemon was @@ -420,24 +438,6 @@ func (s *Schedules) save() error { return nil } -// ScheduleFile is the content of the file of the schedules: the ID of the last -// schedule, so that an ID is never used again, and the schedules. -type ScheduleFile struct { - Next int `json:"next"` - Schedules []Schedule `json:"schedules"` -} - -// Schedule is one schedule: its owner, its ID, the task for the agent, the cron -// expression of a repeating schedule, empty for a one-time schedule, and its -// next time. -type Schedule struct { - Owner string `json:"owner"` - ID int `json:"id"` - Text string `json:"text"` - Cron string `json:"cron"` - Due time.Time `json:"due"` -} - // Message returns the text of a run at now for the log, with the times in the // location of now. The first line starts with [Schedule ID] and gives the due // time and once or the cron expression. Then come the text, the line about a