From d62e3ba8fa65ab5731060250974d9e216b448103 Mon Sep 17 00:00:00 2001
From: David Schlachter <t480-debian-git@schlachter.ca>
Date: Mon, 10 Nov 2025 00:24:57 -0500
Subject: Add jobs to scheduler

---
 main.go | 20 ++++++++++----------
 1 file changed, 10 insertions(+), 10 deletions(-)

(limited to 'main.go')

diff --git a/main.go b/main.go
index 515407f..a2109e0 100644
--- a/main.go
+++ b/main.go
@@ -33,19 +33,13 @@ func main() {
 		if err != nil {
 			log.Printf("reading input: %s", err)
 		}
-		changed := inputChanged(lastSeenInput, input)
-		if changed {
-			fmt.Println("changed!")
+
+		if inputChanged(lastSeenInput, input) {
 			lastSeenInput = input
 			c.Stop()
 			c := cron.New()
-			err := addJobs(c)
-			if err != nil {
-				log.Printf("adding jobs: %s", err)
-			}
+			addJobs(c, input)
 			c.Start()
-		} else {
-			fmt.Println("not changed!")
 		}
 
 		time.Sleep(time.Minute) // re-read the input file every minute
@@ -114,4 +108,10 @@ func inputChanged(old, new map[inputLine]struct{}) bool {
 	return false
 }
 
-func addJobs(c *cron.Cron) error { return nil }
+func createTask(task string) {}
+
+func addJobs(c *cron.Cron, tasks map[inputLine]struct{}) {
+	for task := range tasks {
+		c.AddFunc(task.Schedule, func() { createTask(task.Task) })
+	}
+}
-- 
cgit v1.2.3