From 3e1078efec52c8080497c99829a8ded3b905a39f Mon Sep 17 00:00:00 2001 From: Caleb Gardner Date: Thu, 8 May 2025 02:24:54 -0500 Subject: [PATCH] Cleaned-up the cleanup loop --- internal/backend/darkstorm.go | 29 +++++++++++++++++------------ 1 file changed, 17 insertions(+), 12 deletions(-) diff --git a/internal/backend/darkstorm.go b/internal/backend/darkstorm.go index a76dc18..2ac27a2 100644 --- a/internal/backend/darkstorm.go +++ b/internal/backend/darkstorm.go @@ -75,19 +75,24 @@ func NewBackend(keyTable Table[ApiKey], apps ...App) (*Backend, error) { } func (b *Backend) cleanupLoop() { + b.cleanup() for range time.Tick(24 * time.Hour) { - old := getDate(time.Now().Add(-30 * 24 * time.Hour)) - var err error - for _, a := range b.apps { - log.Printf("Removing logs for %v", a.AppID()) - tab := a.CountTable() - if tab == nil { - continue - } - err = tab.RemoveOldLogs(context.Background(), old) - if err != nil { - log.Printf("error removing old logs for %v: %v\n", a.AppID(), err) - } + b.cleanup() + } +} + +func (b *Backend) cleanup() { + old := getDate(time.Now().Add(-30 * 24 * time.Hour)) + var err error + for _, a := range b.apps { + log.Printf("Removing logs for %v", a.AppID()) + tab := a.CountTable() + if tab == nil { + continue + } + err = tab.RemoveOldLogs(context.Background(), old) + if err != nil { + log.Printf("error removing old logs for %v: %v\n", a.AppID(), err) } } }