Adds an api/schedule/status route

Author: joe-at-startupmedia

Makefile

@@ -41,4 +41,4 @@ tools:
 	fi
 build:
 	$(GO) mod tidy
-	$(GO) build
+	$(GO) build -buildvcs=false

pkg/http.go

@@ -50,6 +50,7 @@ func setupRouter(s *Schedule) *httprouter.Router {
 	router.GET("/api/jobs/:jobId/runs/:jobRunId", getJobRun(s))
 	router.POST("/api/jobs/:jobId/trigger", postTrigger(s))
 	router.GET("/api/core/logs", getCoreLogs(s))
+	router.GET("/api/schedule/status", getScheduleStatus(s))
 
 	fileServer := http.FileServer(http.FS(fsys()))
 	router.GET("/static/*filepath", func(w http.ResponseWriter, r *http.Request, _ httprouter.Params) {
@@ -140,6 +141,36 @@ func getJobs(s *Schedule) httprouter.Handle {
 	}
 }
 
+type ScheduleStatusResponse struct {
+	Status         map[string]int `json:"status,omitempty"`
+	FailedRunCount int            `json:"failed_run_count,omitempty"`
+	HasFailedRuns  bool           `json:"has_failed_runs,omitempty"`
+}
+
+func getScheduleStatus(s *Schedule) httprouter.Handle {
+	return func(w http.ResponseWriter, r *http.Request, _ httprouter.Params) {
+		w.Header().Set("Content-Type", "application/json")
+
+		ssr := ScheduleStatusResponse{
+			Status: make(map[string]int, len(s.Jobs)),
+		}
+		for _, j := range s.Jobs {
+			j.loadRunsFromDb(1, false)
+			lastRunStatus := j.Runs[0].Status
+			ssr.Status[j.Name] = lastRunStatus
+			if lastRunStatus == 1 {
+				ssr.FailedRunCount++
+			}
+		}
+
+		ssr.HasFailedRuns = ssr.FailedRunCount > 0
+
+		if err := json.NewEncoder(w).Encode(ssr); err != nil {
+			http.Error(w, err.Error(), http.StatusInternalServerError)
+		}
+	}
+}
+
 func getCoreLogs(s *Schedule) httprouter.Handle {
 	return func(w http.ResponseWriter, r *http.Request, _ httprouter.Params) {
 		w.Header().Set("Content-Type", "application/json")

pkg/schedule.go

@@ -208,20 +208,20 @@ func (n *notify) EventLeader(f bool) {
 func elector(s *Schedule) *election.Election {
 
 	conf := api.DefaultConfig()
-  if len(s.ConsulAclToken) > 0 {
-    conf.Token = s.ConsulAclToken
-  }
+	if len(s.ConsulAclToken) > 0 {
+		conf.Token = s.ConsulAclToken
+	}
 
-  consul, _ := api.NewClient(conf)
+	consul, _ := api.NewClient(conf)
 	n := &notify{
 		T: "cheek-turner",
 	}
 
-  sessionKey := "service/cheek-turner-election"
+	sessionKey := "service/cheek-turner-election"
 
-  if len(s.ConsulSessionKey) > 0 {
-    sessionKey = s.ConsulSessionKey
-  }
+	if len(s.ConsulSessionKey) > 0 {
+		sessionKey = s.ConsulSessionKey
+	}
 
 	elconf := &election.ElectionConfig{
 		CheckTimeout: 5 * time.Second,