diff --git a/internal/api.go b/internal/api.go index 5f1827b..8ae58ff 100644 --- a/internal/api.go +++ b/internal/api.go @@ -482,7 +482,7 @@ func StartApiServer() { defer db.Close() logger := cfg.Logger - go CronDeleteExpiredPosts(db) + go CronDeleteExpiredPosts(cfg, db) staticRoutes := createStaticRoutes() mainRoutes := createMainRoutes(staticRoutes) diff --git a/internal/cron.go b/internal/cron.go index 83433a6..1f0a442 100644 --- a/internal/cron.go +++ b/internal/cron.go @@ -6,7 +6,8 @@ import ( "git.sr.ht/~erock/wish/cms/db" ) -func deleteExpiredPosts(dbpool db.DB) error { +func deleteExpiredPosts(cfg *ConfigSite, dbpool db.DB) error { + cfg.Logger.Infof("checking for expired posts") now := time.Now() // delete posts that are older than three days expired := now.AddDate(0, 0, -3) @@ -20,6 +21,7 @@ func deleteExpiredPosts(dbpool db.DB) error { postIds = append(postIds, post.ID) } + cfg.Logger.Infof("deleteing (%d) expired posts", len(postIds)) err = dbpool.RemovePosts(postIds) if err != nil { return err @@ -28,9 +30,9 @@ func deleteExpiredPosts(dbpool db.DB) error { return nil } -func CronDeleteExpiredPosts(dbpool db.DB) { +func CronDeleteExpiredPosts(cfg *ConfigSite, dbpool db.DB) { for { - deleteExpiredPosts(dbpool) + deleteExpiredPosts(cfg, dbpool) time.Sleep(1 * time.Hour) } }