Add build scheduler DB interface, dumb in-memory impl, cache

go/buildbucket/buildbucket.go

 // Package buildbucket provides tools for interacting with the buildbucket API.
 package buildbucket
 
 import (
         "bytes"
         "encoding/json"
         "fmt"
         "io/ioutil"
         "net/http"
+        "strconv"
+        "time"
 
         "go.skia.org/infra/go/util"
 )
 
 const (
         apiUrl = "https://cr-buildbucket.appspot.com/_ah/api/buildbucket/v1"
 )
 
 var (
         DEFAULT_SCOPES = []string{
@@ skipping 40 matching lines @@
         Url                    string `json:"url"`
         ParametersJson         string `json:"parameters_json"`
         Result                 string `json:"result"`
         ResultDetailsJson      string `json:"result_details_json"`
         Status                 string `json:"status"`
         StatusChangedTimestamp string `json:"status_changed_ts"`
         UpdatedTimestamp       string `json:"updated_ts"`
         UtcNowTimestamp        string `json:"utcnow_ts"`
 }
 
+func (b *Build) Copy() *Build {
+        return &Build{
+                Bucket:                 b.Bucket,
+                CompletedTimestamp:     b.CompletedTimestamp,
+                CreatedBy:              b.CreatedBy,
+                CreatedTimestamp:       b.CreatedTimestamp,
+                FailureReason:          b.FailureReason,
+                Id:                     b.Id,
+                Url:                    b.Url,
+                ParametersJson:         b.ParametersJson,
+                Result:                 b.Result,
+                ResultDetailsJson:      b.ResultDetailsJson,
+                Status:                 b.Status,
+                StatusChangedTimestamp: b.StatusChangedTimestamp,
+                UpdatedTimestamp:       b.UpdatedTimestamp,
+                UtcNowTimestamp:        b.UtcNowTimestamp,
+        }
+}
+
+func parseTime(t string) (time.Time, error) {
+        i, err := strconv.ParseInt(t, 10, 64)
+        if err != nil {
+                return time.Time{}, err
+        }
+        return time.Unix(0, i), nil
+}
+
+func (b *Build) Created() (time.Time, error) {
+        return parseTime(b.CreatedTimestamp)
+}
+
+func (b *Build) Completed() (time.Time, error) {
+        return parseTime(b.CompletedTimestamp)
+}
+
+func (b *Build) StatusChanged() (time.Time, error) {
+        return parseTime(b.StatusChangedTimestamp)
+}
+
+func (b *Build) Updated() (time.Time, error) {
+        return parseTime(b.UpdatedTimestamp)
+}
+
 // Client is used for interacting with the BuildBucket API.
 type Client struct {
         *http.Client
 }
 
 // NewClient returns an authenticated Client instance.
 func NewClient(c *http.Client) *Client {
         return &Client{c}
 }
 
@@ skipping 117 matching lines @@
                 }
         }
         return rv, nil
 }
 
 // GetTrybotsForCL retrieves trybot results for the given CL.
 func (c *Client) GetTrybotsForCL(issueID int64, patchsetID int64) ([]*Build, error) {
         url := fmt.Sprintf("%s/search?tag=buildset%%3Apatch%%2Frietveld%%2Fcodereview.chromium.org%%2F%d%%2F%d", apiUrl, issueID, patchsetID)
         return c.Search(url)
 }