From 51b5332d21e24eb5664ac2364205fcd0e75750ab Mon Sep 17 00:00:00 2001 From: Frederico Santos Date: Thu, 17 Oct 2024 00:46:27 +0100 Subject: [PATCH] feat: Update S3 migration schedule to hourly and limit old account retrieval to 3000 records --- api/daily/common.go | 3 +-- db/savedata.go | 2 +- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/api/daily/common.go b/api/daily/common.go index f38eb05..df048e2 100644 --- a/api/daily/common.go +++ b/api/daily/common.go @@ -96,8 +96,7 @@ func Init() error { return nil } - S3SaveMigration() - _, err = s3scheduler.AddFunc("@weekly", func() { + _, err = s3scheduler.AddFunc("@hourly", func() { time.Sleep(time.Second) S3SaveMigration() }) diff --git a/db/savedata.go b/db/savedata.go index 5b9e9e1..77dc3f6 100644 --- a/db/savedata.go +++ b/db/savedata.go @@ -270,7 +270,7 @@ func RetrieveSystemSaveFromS3(uuid []byte) error { func RetrieveOldAccounts() [][]byte { var users [][]byte - rows, err := handle.Query("SELECT uuid FROM accounts WHERE isInLocalDb = 1 && lastActivity < DATE_SUB(NOW(), INTERVAL 3 MONTH)") + rows, err := handle.Query("SELECT uuid FROM accounts WHERE isInLocalDb = 1 && lastActivity < DATE_SUB(NOW(), INTERVAL 3 MONTH) LIMIT 3000") if err != nil { return nil }