Add autoroll package, alerts for failed rolls, recent rolls on Status

status/go/status/main.go

 /*
         Provides roll-up statuses for Skia build/test/perf.
 */
 
 package main
 
 import (
         "encoding/json"
         "flag"
         "fmt"
         "net/http"
         "path"
         "path/filepath"
         "runtime"
         "strconv"
         "strings"
         "text/template"
         "time"
         "unicode"
 )
 
 import (
         "github.com/gorilla/mux"
         "github.com/skia-dev/glog"
 )
 
 import (
+        "go.skia.org/infra/go/autoroll"
         "go.skia.org/infra/go/buildbot"
         "go.skia.org/infra/go/common"
         "go.skia.org/infra/go/gitinfo"
         "go.skia.org/infra/go/influxdb"
         "go.skia.org/infra/go/login"
         "go.skia.org/infra/go/metadata"
         "go.skia.org/infra/go/skiaversion"
         "go.skia.org/infra/go/timer"
         "go.skia.org/infra/go/util"
         "go.skia.org/infra/status/go/commit_cache"
@@ skipping 11 matching lines @@
         commitCaches         map[string]*commit_cache.CommitCache = nil
         buildbotDashTemplate *template.Template                   = nil
         commitsTemplate      *template.Template                   = nil
         hostsTemplate        *template.Template                   = nil
         infraTemplate        *template.Template                   = nil
         dbClient             *influxdb.Client                     = nil
         goldGMStatus         *util.IntPollingStatus               = nil
         goldSKPStatus        *util.IntPollingStatus               = nil
         goldImageStatus      *util.IntPollingStatus               = nil
         perfStatus           *util.PollingStatus                  = nil
+        rollStatus           *util.PollingStatus                  = nil
         slaveHosts           *util.PollingStatus                  = nil
         androidDevices       *util.PollingStatus                  = nil
         sshDevices           *util.PollingStatus                  = nil
 )
 
 // flags
 var (
         graphiteServer = flag.String("graphite_server", "localhost:2003", "Where is Graphite metrics ingestion server running.")
         host           = flag.String("host", "localhost", "HTTP service host")
         port           = flag.String("port", ":8002", "HTTP service port (e.g., ':8002')")
@@ skipping 341 matching lines @@
         if err := json.NewEncoder(w).Encode(map[string]interface{}{
                 "gm":    goldGMStatus,
                 "skp":   goldSKPStatus,
                 "image": goldImageStatus,
         }); err != nil {
                 glog.Errorf("Failed to write or encode output: %s", err)
                 return
         }
 }
 
+func autoRollJsonHandler(w http.ResponseWriter, r *http.Request) {
+        w.Header().Set("Content-Type", "application/json")
+        if err := json.NewEncoder(w).Encode(rollStatus); err != nil {
+                util.ReportError(w, r, err, fmt.Sprintf("Failed to report AutoRoll status: %v", err))
+                return
+        }
+}
+
 func slaveHostsJsonHandler(w http.ResponseWriter, r *http.Request) {
         w.Header().Set("Content-Type", "application/json")
         if err := json.NewEncoder(w).Encode(map[string]interface{}{
                 "hosts":          slaveHosts,
                 "androidDevices": androidDevices,
                 "sshDevices":     sshDevices,
         }); err != nil {
                 glog.Errorf("Failed to write or encode output: %s", err)
                 return
         }
@@ skipping 23 matching lines @@
         r.HandleFunc("/buildbots", buildbotDashHandler)
         r.HandleFunc("/hosts", hostsHandler)
         r.HandleFunc("/infra", infraHandler)
         builders := r.PathPrefix("/json/{repo}/builders/{builder}").Subrouter()
         builders.HandleFunc("/status", addBuilderStatusHandler).Methods("POST")
         commits := r.PathPrefix("/json/{repo}/commits").Subrouter()
         commits.HandleFunc("/", commitsJsonHandler)
         commits.HandleFunc("/{commit:[a-f0-9]+}/comments", addCommitCommentHandler).Methods("POST")
         r.HandleFunc("/json/perfAlerts", perfJsonHandler)
         r.HandleFunc("/json/goldStatus", goldJsonHandler)
+        r.HandleFunc("/json/autoRoll", autoRollJsonHandler)

[rmistry, 2015/06/10 20:20:54]

sort the HandleFuncs ?

[borenet, 2015/06/11 11:40:10]

Done.

         r.HandleFunc("/json/slaveHosts", slaveHostsJsonHandler)
         r.HandleFunc("/json/version", skiaversion.JsonHandler)
         r.HandleFunc("/oauth2callback/", login.OAuth2CallbackHandler)
         r.HandleFunc("/logout/", login.LogoutHandler)
         r.HandleFunc("/loginstatus/", login.StatusHandler)
         http.Handle("/", util.LoggingGzipRequestResponse(r))
         glog.Infof("Ready to serve on %s", serverURL)
         glog.Fatal(http.ListenAndServe(*port, nil))
 }
 
@@ skipping 103 matching lines @@
         }
         androidDevices, err = device_cfg.AndroidDeviceCfgPoller(*workdir)
         if err != nil {
                 glog.Fatal(err)
         }
         sshDevices, err = device_cfg.SSHDeviceCfgPoller(*workdir)
         if err != nil {
                 glog.Fatal(err)
         }
 
+        // Load AutoRoll data in a loop.
+        rollStatus, err = autoroll.AutoRollStatusPoller()
+        if err != nil {
+                glog.Fatal(err)
+        }
+
         runServer(serverURL)
 }