Buildbucket: Save buildbucket build info and summary on pubsub push

milo/buildsource/swarming/buildinfo.go

 // Copyright 2017 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 swarming
 
 import (
         "strconv"
         "strings"
         "unicode/utf8"
 
         swarming "github.com/luci/luci-go/common/api/swarming/swarming/v1"
         "github.com/luci/luci-go/common/errors"
         "github.com/luci/luci-go/common/logging"
         miloProto "github.com/luci/luci-go/common/proto/milo"
         "github.com/luci/luci-go/grpc/grpcutil"
         "github.com/luci/luci-go/logdog/common/types"
         "github.com/luci/luci-go/luci_config/common/cfgtypes"
         milo "github.com/luci/luci-go/milo/api/proto"
         "github.com/luci/luci-go/swarming/tasktemplate"
 
         "golang.org/x/net/context"
 )
 
 // BuildInfoProvider provides build information.
 //
 // In a production system, this will be completely defaults. For testing, the
 // various services and data sources may be substituted for testing stubs.
 type BuildInfoProvider struct {
-        bl buildLoader
+        bl BuildLoader
 
         // swarmingServiceFunc returns a swarmingService instance for the supplied
         // parameters.
         //
         // If nil, a production fetcher will be generated.
         swarmingServiceFunc func(c context.Context, host string) (swarmingService, error)
 }
 
 func (p *BuildInfoProvider) newSwarmingService(c context.Context, host string) (swarmingService, error) {
         if p.swarmingServiceFunc == nil {
-                return newProdService(c, host)
+                return NewProdService(c, host)
         }
         return p.swarmingServiceFunc(c, host)
 }
 
 // GetBuildInfo resolves a Milo protobuf Step for a given Swarming task.
 func (p *BuildInfoProvider) GetBuildInfo(c context.Context, req *milo.BuildInfoRequest_Swarming,
         projectHint cfgtypes.ProjectName) (*milo.BuildInfoResponse, error) {
 
         // Load the Swarming task (no log content).
         sf, err := p.newSwarmingService(c, req.Host)
@@ skipping 208 matching lines @@
         }
 
         lastChar, lastCharSize := utf8.DecodeLastRuneInString(taskID)
         v, err := strconv.ParseUint(string(lastChar), 16, 8)
         if err != nil {
                 return "", errors.Annotate(err, "failed to parse hex from rune: %r", lastChar).Err()
         }
 
         return taskID[:len(taskID)-lastCharSize] + strconv.FormatUint((v|uint64(tryNumber)), 16), nil
 }