1 files changed, 72 insertions, 0 deletions
diff --git a/internal/blogtrigger/blogtrigger.go b/internal/blogtrigger/blogtrigger.go
new file mode 100644
index 0000000..81efafe
--- /dev/null
+++ b/internal/blogtrigger/blogtrigger.go
@@ -0,0 +1,72 @@
+package blogtrigger
+
+import (
+	"fmt"
+	"log/slog"
+
+	"github.com/SayaAndy/saya-today-web/config"
+	"github.com/SayaAndy/saya-today-web/internal/blog"
+	"github.com/go-co-op/gocron/v2"
+)
+
+type BlogTriggerScheduler struct {
+	s              gocron.Scheduler
+	knownBlogPages map[string]map[string]*blog.Page
+	blogClient     blog.Client
+	onTrigger      func([]*blog.Page) error
+}
+
+func NewBlogTriggerScheduler(blogClient blog.Client, availableLanguages []config.AvailableLanguageConfig, cron string, onTrigger func([]*blog.Page) error) (*BlogTriggerScheduler, error) {
+	s, err := gocron.NewScheduler()
+	if err != nil {
+		return nil, fmt.Errorf("failed to create new scheduler: %w", err)
+	}
+
+	knownBlogPages := make(map[string]map[string]*blog.Page, len(availableLanguages))
+	for _, lang := range availableLanguages {
+		knownBlogPages[lang.Name] = make(map[string]*blog.Page)
+	}
+
+	bts := &BlogTriggerScheduler{s, knownBlogPages, blogClient, onTrigger}
+	defer bts.s.Start()
+
+	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()))
+			return
+		}
+		if err = onTrigger(posts); err != nil {
+			slog.Error("error happened on callback function after scanning new blog pages", slog.String("error", err.Error()))
+			return
+		}
+	}, bts))
+
+	if _, err = bts.scan(); err != nil {
+		return nil, fmt.Errorf("failed to scan existing blog pages in b2: %w", err)
+	}
+
+	return bts, nil
+}
+
+func (bts *BlogTriggerScheduler) Close() error {
+	return bts.s.Shutdown()
+}
+
+func (bts *BlogTriggerScheduler) scan() (newPages []*blog.Page, err error) {
+	newPages = make([]*blog.Page, 0)
+	for lang := range bts.knownBlogPages {
+		posts, err := bts.blogClient.Scan(lang + "/")
+		if err != nil {
+			return nil, fmt.Errorf("failed to scan blog pages in b2 on '%s': %w", lang, err)
+		}
+		for _, post := range posts {
+			if _, ok := bts.knownBlogPages[lang][post.FileName]; !ok {
+				post.Lang = lang
+				newPages = append(newPages, post)
+				bts.knownBlogPages[lang][post.FileName] = post
+			}
+		}
+	}
+	return newPages, nil
+}