dev_agent
ecf7c6be89
CI / ci (push) Successful in 8m28s
Co-authored-by: dev_agent <dev_agent@cubecraftlabs.com>
47 lines
1.6 KiB
Go
47 lines
1.6 KiB
Go
package harness
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"log/slog"
|
|
"time"
|
|
|
|
"code.cubecraftlabs.com/Maniacs_Mansion/Meal-Quest/internal/household"
|
|
"code.cubecraftlabs.com/Maniacs_Mansion/Meal-Quest/internal/scheduler"
|
|
"code.cubecraftlabs.com/Maniacs_Mansion/Meal-Quest/internal/store"
|
|
)
|
|
|
|
// PurgeTime is when, every day in the household zone, ai_runs_purge runs.
|
|
// It is fixed, not a setting.
|
|
const PurgeTime = "03:00"
|
|
|
|
// PurgeSchedule is the ai_runs_purge schedule over st: every day at
|
|
// PurgeTime it deletes the ai_runs rows created more than RunRetention
|
|
// before the fire time with Purge, its period scheduler.Daily keyed
|
|
// ai_runs_purge:YYYY-MM-DD. A purge caught up late deletes no row younger
|
|
// than RunRetention; one that fails is the period's error and is not
|
|
// retried, and the next day's purge deletes what it left.
|
|
func PurgeSchedule(st *store.Store, logger *slog.Logger) (scheduler.Schedule, error) {
|
|
if st == nil {
|
|
return scheduler.Schedule{}, errors.New("harness: purge schedule: nil store")
|
|
}
|
|
if logger == nil {
|
|
return scheduler.Schedule{}, errors.New("harness: purge schedule: nil logger")
|
|
}
|
|
return scheduler.Schedule{
|
|
Name: scheduler.AIRunsPurge,
|
|
Rule: func(household.Settings) scheduler.Rule {
|
|
return scheduler.Daily(PurgeTime)
|
|
},
|
|
Run: func(ctx context.Context, p scheduler.Period) error {
|
|
cutoff := p.FireAt.Add(-RunRetention)
|
|
n, err := Purge(ctx, st, cutoff)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
logger.InfoContext(ctx, "ai_runs purged", "period", p.Key, "deleted", n, "created_before", cutoff.UTC().Format(time.RFC3339))
|
|
return nil
|
|
},
|
|
}, nil
|
|
}
|