added scheduler code

backend/internal/app/data.go

@@ -5,6 +5,7 @@ import "threadule/backend/internal/data/models"
 type Data interface {
 	UpdateTweet(tweet *models.Tweet) error
 
+	GetScheduledThreads() ([]models.Thread, error)
 	GetTweetsForThread(thread *models.Thread) ([]models.Tweet, error)
 	UpdateThread(thread *models.Thread) error
 }

backend/internal/data/thread.go

@@ -1,6 +1,9 @@
 package data
 
-import "threadule/backend/internal/data/models"
+import (
+	"threadule/backend/internal/data/models"
+	"time"
+)
 
 func (d *Data) UpdateThread(thread *models.Thread) error {
 	return d.db.Save(thread).Error
@@ -14,3 +17,14 @@ func (d *Data) GetTweetsForThread(thread *models.Thread) ([]models.Tweet, error)
 		Find(&tweets).Error
 	return tweets, err
 }
+
+func (d *Data) GetScheduledThreads() ([]models.Thread, error) {
+	var threads []models.Thread
+
+	err := d.db.
+		Where("scheduled_for <= ?", time.Now()).
+		Where("status = ?", models.ThreadScheduled).
+		Find(&threads).
+		Error
+	return threads, err
+}

backend/internal/logic/logic.go

@@ -9,7 +9,11 @@ type Logic struct {
 var _ app.Logic = &Logic{}
 
 func Setup(ctx *app.Context) (app.Logic, error) {
-	return &Logic{
+	logic := &Logic{
 		ctx: ctx,
-	}, nil
+	}
+
+	logic.startScheduler()
+
+	return logic, nil
 }

backend/internal/logic/scheduler.go

@@ -0,0 +1,14 @@
+package logic
+
+import "time"
+
+func (l *Logic) startScheduler() {
+	ticker := time.NewTicker(time.Minute)
+
+	go func() {
+		for {
+			_ = <-ticker.C
+			l.scheduleTrigger()
+		}
+	}()
+}

backend/internal/logic/twitter.go

@@ -1,6 +1,8 @@
 package logic
 
-import "threadule/backend/internal/data/models"
+import (
+	"threadule/backend/internal/data/models"
+)
 import "github.com/dghubble/oauth1"
 import "github.com/dghubble/go-twitter/twitter"
 
@@ -100,3 +102,15 @@ func (l *Logic) sendThread(thread *models.Thread) {
 	_ = l.ctx.Data.UpdateThread(thread)
 	// TODO log data error
 }
+
+func (l *Logic) scheduleTrigger() {
+	threads, err := l.ctx.Data.GetScheduledThreads()
+	if err != nil {
+		// TODO log error
+		return
+	}
+
+	for _, thread := range threads {
+		l.sendThread(&thread)
+	}
+}