[milo] {buildbucket,buildbot,swarming,logdog} -> backends/*.

milo/appengine/buildbucket/common.go

Index: milo/appengine/buildbucket/common.go
diff --git a/milo/appengine/buildbucket/common.go b/milo/appengine/buildbucket/common.go
deleted file mode 100644
index bdd7fabf97f8c0cb0117b877c4e22bd1b5454057..0000000000000000000000000000000000000000
--- a/milo/appengine/buildbucket/common.go
+++ /dev/null
@@ -1,151 +0,0 @@
-// Copyright 2016 The LUCI Authors. All rights reserved.
-// Use of this source code is governed under the Apache License, Version 2.0
-// that can be found in the LICENSE file.
-
-package buildbucket
-
-import (
-	"fmt"
-	"net/http"
-	"strings"
-	"time"
-
-	"golang.org/x/net/context"
-
-	"github.com/luci/luci-go/common/api/buildbucket/buildbucket/v1"
-	"github.com/luci/luci-go/common/api/buildbucket/swarmbucket/v1"
-	"github.com/luci/luci-go/milo/api/resp"
-	"github.com/luci/luci-go/milo/appengine/common/model"
-	"github.com/luci/luci-go/server/auth"
-)
-
-const (
-	// StatusScheduled means a build is pending.
-	StatusScheduled = "SCHEDULED"
-	// StatusStarted means a build is executing.
-	StatusStarted = "STARTED"
-	// StatusCompleted means a build is completed (successfully or not).
-	StatusCompleted = "COMPLETED"
-)
-
-// ParseTags parses buildbucket build tags to a map.
-// Ignores tags that doesn't have colon (we don't have them in practice because
-// buildbucket validates tags).
-func ParseTags(tags []string) map[string]string {
-	result := make(map[string]string, len(tags))
-	for _, t := range tags {
-		parts := strings.SplitN(t, ":", 2)
-		if len(parts) == 2 {
-			result[parts[0]] = parts[1]
-		}
-	}
-	return result
-}
-
-func newSwarmbucketClient(c context.Context, server string) (*swarmbucket.Service, error) {
-	c, _ = context.WithTimeout(c, time.Minute)
-	t, err := auth.GetRPCTransport(c, auth.AsUser)
-	if err != nil {
-		return nil, err
-	}
-	client, err := swarmbucket.New(&http.Client{Transport: t})
-	if err != nil {
-		return nil, err
-	}
-	client.BasePath = fmt.Sprintf("https://%s/api/swarmbucket/v1/", server)
-	return client, nil
-}
-
-func newBuildbucketClient(c context.Context, server string) (*buildbucket.Service, error) {
-	c, _ = context.WithTimeout(c, time.Minute)
-	t, err := auth.GetRPCTransport(c, auth.AsUser)
-	if err != nil {
-		return nil, err
-	}
-	client, err := buildbucket.New(&http.Client{Transport: t})
-	if err != nil {
-		return nil, err
-	}
-	client.BasePath = fmt.Sprintf("https://%s/api/buildbucket/v1/", server)
-	return client, nil
-}
-
-// parseStatus converts a buildbucket build status to resp.Status.
-func parseStatus(build *buildbucket.ApiCommonBuildMessage) (model.Status, error) {
-	switch build.Status {
-	case StatusScheduled:
-		return model.NotRun, nil
-
-	case StatusStarted:
-		return model.Running, nil
-
-	case StatusCompleted:
-		switch build.Result {
-		case "SUCCESS":
-			return model.Success, nil
-
-		case "FAILURE":
-			switch build.FailureReason {
-			case "BUILD_FAILURE":
-				return model.Failure, nil
-			default:
-				return model.InfraFailure, nil
-			}
-
-		case "CANCELED":
-			return model.InfraFailure, nil
-
-		default:
-			return 0, fmt.Errorf("unexpected buildbucket build result %q", build.Result)
-		}
-
-	default:
-		return 0, fmt.Errorf("unexpected buildbucket build status %q", build.Status)
-	}
-}
-
-// getChangeList tries to extract CL information from a buildbucket build.
-func getChangeList(
-	build *buildbucket.ApiCommonBuildMessage, params *buildParameters,
-	resultDetails *resultDetails) (result *resp.Commit) {
-
-	prop := &params.Properties
-	switch prop.PatchStorage {
-	case "rietveld":
-		if prop.RietveldURL != "" && prop.Issue != 0 {
-			result = &resp.Commit{
-				RequestRevision: resp.NewLink(prop.Revision, ""),
-				Changelist: resp.NewLink(
-					fmt.Sprintf("Rietveld CL %d", prop.Issue),
-					fmt.Sprintf("%s/%d/#ps%d", prop.RietveldURL, prop.Issue, prop.PatchSet),
-				),
-			}
-			if resultDetails.Properties.GotRevision != "" {
-				// TODO(hinoka): Figure out the full URL for these revisions, add it
-				// to the URL field.
-				result.Revision = resp.NewLink(resultDetails.Properties.GotRevision, "")
-			}
-		}
-
-	case "gerrit":
-		if prop.GerritPatchURL != "" && prop.GerritPatchIssue != 0 {
-			path := fmt.Sprintf("%d", prop.GerritPatchIssue)
-			if prop.GerritPatchSet != 0 {
-				path = fmt.Sprintf("%d/%d", prop.GerritPatchIssue, prop.GerritPatchSet)
-			}
-			result = &resp.Commit{
-				Changelist: resp.NewLink(
-					fmt.Sprintf("Gerrit CL %d", prop.GerritPatchIssue),
-					fmt.Sprintf("%s/c/%s", prop.GerritPatchURL, path),
-				),
-			}
-		}
-	}
-
-	if result != nil && len(params.Changes) != 0 {
-		// tryjobs have one change and it is the CL author
-		result.AuthorEmail = params.Changes[0].Author.Email
-	}
-
-	return
-}