diff options
| author |  SayaAndy <saya.andy@posteo.com>
| 2025-10-25 18:57:48 +0700 |
|---|---|---|
| committer | SayaAndy <saya.andy@posteo.com>
| 2025-10-25 18:57:48 +0700 |
| commit | 249f73a7eff43994ed91fb1e1bef8edf5ac6c86a (patch) | |
| tree | 9c646c0e0ba8b9a1486cfb7732c5db42fbe690a3 /internal/blogtrigger | |
| parent | 427ab1a9a4d6094d9f3a84e62f09cc396b49a09b (diff) | |
| download | web-249f73a7eff43994ed91fb1e1bef8edf5ac6c86a.tar.gz web-249f73a7eff43994ed91fb1e1bef8edf5ac6c86a.zip | |
feat: configurable cron for mail trigger
Diffstat (limited to 'internal/blogtrigger')
| -rw-r--r-- | internal/blogtrigger/blogtrigger.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/internal/blogtrigger/blogtrigger.go b/internal/blogtrigger/blogtrigger.go index ab66981..9b016e8 100644 --- a/internal/blogtrigger/blogtrigger.go +++ b/internal/blogtrigger/blogtrigger.go @@ -16,7 +16,7 @@ type BlogTriggerScheduler struct { onTrigger func([]*b2.BlogPage) error } -func NewBlogTriggerScheduler(b2Client *b2.B2Client, availableLanguages []config.AvailableLanguageConfig, onTrigger func([]*b2.BlogPage) error) (*BlogTriggerScheduler, error) { +func NewBlogTriggerScheduler(b2Client *b2.B2Client, availableLanguages []config.AvailableLanguageConfig, cron string, onTrigger func([]*b2.BlogPage) error) (*BlogTriggerScheduler, error) { s, err := gocron.NewScheduler() if err != nil { return nil, fmt.Errorf("failed to create new scheduler: %w", err) @@ -30,7 +30,7 @@ func NewBlogTriggerScheduler(b2Client *b2.B2Client, availableLanguages []config. bts := &BlogTriggerScheduler{s, knownBlogPages, b2Client, onTrigger} defer bts.s.Start() - bts.s.NewJob(gocron.CronJob("0/5 * * * *", false), gocron.NewTask(func(bts *BlogTriggerScheduler) { + bts.s.NewJob(gocron.CronJob(cron, false), gocron.NewTask(func(bts *BlogTriggerScheduler) { posts, err := bts.scan() if err != nil { slog.Error("failed to execute scanning new blog pages cron job", slog.String("error", err.Error())) |