[logdog] Remove list functionality.

logdog/appengine/coordinator/endpoints/services/registerStream_test.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,
@@ skipping 10 matching lines @@
         "time"
 
         "github.com/luci/gae/filter/featureBreaker"
         ds "github.com/luci/gae/service/datastore"
         "github.com/luci/luci-go/common/proto/google"
         "github.com/luci/luci-go/logdog/api/config/svcconfig"
         "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"
         ct "github.com/luci/luci-go/logdog/appengine/coordinator/coordinatorTest"
-        "github.com/luci/luci-go/logdog/appengine/coordinator/hierarchy"
         "github.com/luci/luci-go/logdog/common/types"
         "github.com/luci/luci-go/luci_config/common/cfgtypes"
         "golang.org/x/net/context"
 
         . "github.com/luci/luci-go/common/testing/assertions"
         . "github.com/smartystreets/goconvey/convey"
 )
 
 func TestRegisterStream(t *testing.T) {
         t.Parallel()
@@ skipping 77 matching lines @@
                                         So(tls.State.Terminated(), ShouldBeFalse)
                                         So(tls.State.ArchivalState(), ShouldEqual, coordinator.NotArchived)
 
                                         // Should also register the log stream Prefix.
                                         So(tls.Prefix.Created, ShouldResemble, created)
                                         So(tls.Prefix.Secret, ShouldResemble, req.Secret)
 
                                         // No archival request yet.
                                         So(env.ArchivalPublisher.Hashes(), ShouldResemble, []string{})
 
-                                        // Should have name components.
-                                        getNameComponents := func(b string) []string {
-                                                l, err := hierarchy.Get(c, hierarchy.Request{Project: string(tls.Project), PathBase: b})
-                                                if err != nil {
-                                                        panic(err)
-                                                }
-                                                names := make([]string, len(l.Comp))
-                                                for i, e := range l.Comp {
-                                                        names[i] = e.Name
-                                                        if e.Stream {
-                                                                names[i] += "$"
-                                                        }
-                                                }
-                                                return names
-                                        }
-                                        So(getNameComponents(""), ShouldResemble, []string{"testing"})
-                                        So(getNameComponents("testing"), ShouldResemble, []string{"+"})
-                                        So(getNameComponents("testing/+"), ShouldResemble, []string{"foo"})
-                                        So(getNameComponents("testing/+/foo"), ShouldResemble, []string{"bar$"})
-
                                         Convey(`Can register the stream again (idempotent).`, func() {
                                                 env.Clock.Set(created.Add(10 * time.Minute))
 
                                                 resp, err := svr.RegisterStream(c, &req)
                                                 So(err, ShouldBeRPCOK)
                                                 So(resp, ShouldResemble, expResp)
 
                                                 tls.WithProjectNamespace(c, func(c context.Context) {
                                                         So(ds.Get(c, tls.Stream, tls.State), ShouldBeNil)
                                                 })
@@ skipping 198 matching lines @@
                         Desc:          tls.DescBytes(),
                         TerminalIndex: -1,
                 }
 
                 _, err := svr.RegisterStream(c, &req)
                 if err != nil {
                         b.Fatalf("failed to get OK response (%s)", err)
                 }
         }
 }