From 4e5b2d9dfd9413ce084e64e048a57ad6e23356d3 Mon Sep 17 00:00:00 2001 From: "Gabriel A. Giovanini" Date: Mon, 20 Jun 2022 18:35:50 +0200 Subject: ref: Remove model dependency fom worker It was a bit weird to have that dependency in first place. --- controller/controller.go | 17 ++++++++++++++++- 1 file changed, 16 insertions(+), 1 deletion(-) (limited to 'controller/controller.go') diff --git a/controller/controller.go b/controller/controller.go index 7fc8748..e381bf8 100644 --- a/controller/controller.go +++ b/controller/controller.go @@ -2,6 +2,7 @@ package controller import ( "net/http" + "time" "git.sr.ht/~gabrielgio/midr/db" "git.sr.ht/~gabrielgio/midr/worker" @@ -13,7 +14,7 @@ type Env struct { Worker worker.Worker } -func (e Env) GetEntries(c *gin.Context) { +func (e *Env) GetEntries(c *gin.Context) { entries := e.Entries.All() c.HTML(http.StatusOK, "index", entries) } @@ -54,3 +55,17 @@ func (e *Env) GetJobs(c *gin.Context) { jobs := e.Worker.GetJobs() c.JSON(http.StatusOK, jobs) } + +func (e *Env) StartScheduler() { + e.Worker.StartReader() + go func() { + for true { + entries := e.Entries.All() + + for _, entry := range entries { + e.Worker.SpawnWorker(entry.ID, entry.Link, entry.OutputFolder) + } + time.Sleep(30 * time.Minute) + } + }() +} -- cgit v1.2.3