[annotee] add SOURCE_MANIFEST annotation.

logdog/client/annotee/annotation/annotation.go

 // Copyright 2015 The LUCI Authors.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
 // You may obtain a copy of the License at
 //
 //      http://www.apache.org/licenses/LICENSE-2.0
 //
 // Unless required by applicable law or agreed to in writing, software
 // distributed under the License is distributed on an "AS IS" BASIS,
 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
 package annotation
 
 import (
+        "encoding/hex"
         "fmt"
         "strconv"
         "strings"
         "time"
 
         "github.com/golang/protobuf/ptypes/timestamp"
 
         "github.com/luci/luci-go/common/clock"
         "github.com/luci/luci-go/common/proto/google"
         "github.com/luci/luci-go/common/proto/milo"
@@ skipping 337 matching lines @@
 
         // @@@SET_BUILD_PROPERTY@<name>@<json>@@@
         case "SET_BUILD_PROPERTY":
                 step := s.CurrentStep()
                 parts := strings.SplitN(params, "@", 2)
                 if len(parts) == 1 {
                         parts = append(parts, "")
                 }
                 updatedIf(step, UpdateIterative, step.SetProperty(parts[0], parts[1]))
 
-                // @@@STEP_TRIGGER@<spec>@@@
+        // @@@STEP_TRIGGER@<spec>@@@
         case "STEP_TRIGGER":
                 // Annotee will stop short of sending an actual request to BuildBucket.
                 break
+
+        // This is ONLY supported by annotee, not by buildbot.
+        // @@@DEPLOYMENT_MANIFEST@<name>@<sha256>@<url>@@@
+        case "DEPLOYMENT_MANIFEST":
+                parts := strings.SplitN(params, "@", 3)
+                if len(parts) != 3 {
+                        return fmt.Errorf("DEPLOYMENT_MANIFEST expected 3 params, got %q", params)
+                }
+
+                step := s.RootStep()
+                if step.DeploymentManifests == nil {
+                        step.DeploymentManifests = map[string]*milo.Step_ManifestLink{}
+                }
+
+                name, hashHex, url := parts[0], parts[1], parts[2]
+                hash, err := hex.DecodeString(hashHex)
+                if err != nil {
+                        return fmt.Errorf("DEPLOYMENT_MANIFEST has bad hash: %s", err)
+                }
+                if _, ok := step.DeploymentManifests[name]; ok {
+                        return fmt.Errorf("repeated DEPLOYMENT_MANIFEST name %q", name)
+                }
+
+                step.DeploymentManifests[name] = &milo.Step_ManifestLink{
+                        Sha256: hash,
+                        Url:    url,
+                }
+                updated = step
         }
 
         if updated != nil {
                 s.Callbacks.Updated(updated, updateType)
         }
         return nil
 }
 
 // Finish closes the top-level annotation state and any outstanding steps.
 func (s *State) Finish() {
@@ skipping 562 matching lines @@
         as.StderrStream, updated = as.maybeSetLogDogStream(as.StderrStream, st)
         return
 }
 
 func (as *Step) maybeSetLogDogStream(target *milo.LogdogStream, st *milo.LogdogStream) (*milo.LogdogStream, bool) {
         if (target == nil && st == nil) || (target != nil && st != nil && *target == *st) {
                 return target, false
         }
         return st, true
 }