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

go/rietveld/rietveld.go

 package rietveld
 
 import (
         "encoding/json"
         "fmt"
         "net/http"
         "net/url"
         "regexp"
         "sort"
         "strings"
         "time"
 )
 
 import (
         "github.com/skia-dev/glog"
         "go.skia.org/infra/go/util"
 )
 
 var (
         committedIssueRegexp []string = []string{
                 "Committed patchset #[0-9]+ \\((id:)?[0-9]+\\) as [0-9a-f]{2,40}",
+                "Committed patchset #[0-9]+",
                 "Change committed as [0-9]+",
         }
 )
 
 // Issue contains information about a Rietveld issue.
 type Issue struct {
         CC             []string
         Closed         bool
         Committed      bool
         Created        time.Time
@@ skipping 75 matching lines @@
         value := "2"
         if open {
                 value = "3"
         }
         return &SearchTerm{
                 Key:   "closed",
                 Value: value,
         }
 }
 
-func SearchLimit(limit int) *SearchTerm {
-        return &SearchTerm{
-                Key:   "limit",
-                Value: fmt.Sprintf("%d", limit),
-        }
-}
-
 // Search returns a slice of Issues which fit the given criteria.
-func (r Rietveld) Search(terms ...*SearchTerm) ([]*Issue, error) {
-        searchUrl := "/search?format=json"
+func (r Rietveld) Search(limit int, terms ...*SearchTerm) ([]*Issue, error) {
+        searchUrl := fmt.Sprintf("/search?format=json&limit=%d", limit)
         for _, term := range terms {
                 searchUrl += fmt.Sprintf("&%s=%s", term.Key, term.Value)
         }
 
         var issues issueListSortable
         cursor := ""
         for {
                 var data rietveldResults
                 err := r.get(searchUrl+cursor, &data)
                 if err != nil {
@@ skipping 22 matching lines @@
                                                 glog.Error(err)
                                                 continue
                                         }
                                         if committed {
                                                 fullIssue.Committed = true
                                         }
                                 }
                                 issues = append(issues, &fullIssue)
                         }
                 }
+                if len(issues) >= limit {
+                        break
+                }
                 cursor = "&cursor=" + data.Cursor
         }
         sort.Sort(issues)
         return issues, nil
 }
 
 // getIssueProperties returns a fully filled-in Issue object, as opposed to
 // the partial data returned by Rietveld's search endpoint.
 func (r Rietveld) getIssueProperties(issue int, messages bool) (Issue, error) {
         url := fmt.Sprintf("/api/%v", issue)
         if messages {
                 url += "?messages=true"
         }
         var res Issue
         err := r.get(url, &res)
         if err != nil {
                 return Issue{}, fmt.Errorf("Failed to load details for issue %d: %v", issue, err)
         }
         return res, nil
 }
 
 // New returns a new Rietveld instance.
 func New(url string) Rietveld {
         url = strings.TrimRight(url, "/")
         return Rietveld{url}
 }