Milo: Buildbucket PubSub ingestion outline

milo/common/config.go

 // 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 common
 
 import (
         "fmt"
         "time"
 
@@ skipping 146 matching lines @@
                 logging.Infof(c, "revisions differ (old %s, new %s), updating",
                         oldConfig.Revision, newConfig.Revision)
                 return datastore.Put(c, &newConfig)
         }, nil)
 
         if err != nil {
                 return fmt.Errorf("failed to update config entry in transaction", err)
         }
         logging.Infof(c, "successfully updated to new config")
 
+        if err := ensurePubSubSubscribed(c, settings); err != nil {
+                return fmt.Errorf("count not ensure pubsub subscriptions: %s", err)
+        }
+
         return nil
 }
 
 // UpdateProjectConfigs internal project configuration based off luci-config.
 // update updates Milo's configuration based off luci config.  This includes
 // scanning through all project and extract all console configs.
 func UpdateProjectConfigs(c context.Context) error {
         cfgName := info.AppID(c) + ".cfg"
 
         var (
@@ skipping 94 matching lines @@
         if err != nil {
                 return nil, err
         }
         for _, cs := range p.Consoles {
                 if cs.Name == consoleName {
                         return cs, nil
                 }
         }
         return nil, fmt.Errorf("Console %s not found in project %s", consoleName, projName)
 }