From 865f5c2054f63f4659642b12711c2d142f4559f6 Mon Sep 17 00:00:00 2001 From: Eric Bower Date: Wed, 13 Jul 2022 23:05:05 -0400 Subject: [PATCH] chore(cron): add some logging --- internal/api.go | 2 +- internal/cron.go | 8 +++++--- 2 files changed, 6 insertions(+), 4 deletions(-) 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) } }