diff options
| -rw-r--r-- | main.go | 20 |
1 files changed, 10 insertions, 10 deletions
@@ -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) }) + } +} |