[logdog] Remove list functionality.

logdog/appengine/coordinator/endpoints/services/registerStream.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 services
 
 import (
         "crypto/subtle"
 
         "github.com/golang/protobuf/proto"
         ds "github.com/luci/gae/service/datastore"
         "github.com/luci/luci-go/common/clock"
         log "github.com/luci/luci-go/common/logging"
         "github.com/luci/luci-go/grpc/grpcutil"
         "github.com/luci/luci-go/logdog/api/endpoints/coordinator/services/v1"
         "github.com/luci/luci-go/logdog/api/logpb"
         "github.com/luci/luci-go/logdog/appengine/coordinator"
         "github.com/luci/luci-go/logdog/appengine/coordinator/endpoints"
-        "github.com/luci/luci-go/logdog/appengine/coordinator/hierarchy"
         "github.com/luci/luci-go/logdog/appengine/coordinator/mutations"
         "github.com/luci/luci-go/logdog/common/types"
         "github.com/luci/luci-go/tumble"
         "golang.org/x/net/context"
         "google.golang.org/grpc/codes"
 )
 
 func buildLogStreamState(ls *coordinator.LogStream, lst *coordinator.LogStreamState) *logdog.LogStreamState {
         st := logdog.LogStreamState{
                 ProtoVersion:  ls.ProtoVersion,
@@ skipping 106 matching lines @@
         // (non-transactional).
         ls := &coordinator.LogStream{ID: logStreamID}
         lst := ls.State(c)
 
         if err := ds.Get(c, ls, lst); err != nil {
                 if !anyNoSuchEntity(err) {
                         log.WithError(err).Errorf(c, "Failed to check for log stream.")
                         return nil, err
                 }
 
-                // The stream is not registered. Perform a transactional registration via
-                // mutation.
-                //
-                // Determine which hierarchy components we need to add.
-                comps := hierarchy.Components(path, true)
-                if comps, err = hierarchy.Missing(c, comps); err != nil {
-                        log.WithError(err).Warningf(c, "Failed to probe for missing hierarchy components.")
-                }
-
-                // Before we go into transaction, try and put these entries. This should not
-                // be contested, since components don't share an entity root.
-                if err := hierarchy.PutMulti(c, comps); err != nil {
-                        log.WithError(err).Errorf(c, "Failed to add missing hierarchy components.")
-                        return nil, grpcutil.Internal
-                }
-
                 // The stream does not exist. Proceed with transactional registration.
                 lstKey := ds.KeyForObj(c, lst)
                 err = tumble.RunUnbuffered(c, lstKey, func(c context.Context) ([]tumble.Mutation, error) {
                         // Load our state and stream (transactional).
                         switch err := ds.Get(c, ls, lst); {
                         case err == nil:
                                 // The stream is already registered.
                                 return nil, nil
 
                         case !anyNoSuchEntity(err):
@@ skipping 92 matching lines @@
                         }.Errorf(c, "Failed to register LogStream.")
                         return nil, err
                 }
         }
 
         return &logdog.RegisterStreamResponse{
                 Id:    string(ls.ID),
                 State: buildLogStreamState(ls, lst),
         }, nil
 }