LogDog: Add project namespace to service endpoint.

server/internal/logdog/collector/collector_test.go

 // Copyright 2016 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 package collector
 
 import (
         "bytes"
         "fmt"
         "sync/atomic"
@@ skipping 140 matching lines @@
                                         So(errors.IsTransient(err), ShouldBeFalse)
                                         So(tcc, shouldNotHaveRegisteredStream, "foo/+/bar")
                                 })
 
                                 Convey(`Will drop messages with mismatching secrets.`, func() {
                                         bb.addStreamEntries("foo/+/bar", -1, 0, 1, 2)
                                         So(coll.Process(c, bb.bundle()), ShouldBeNil)
 
                                         // Push another bundle with a different secret.
                                         be := bb.genBundleEntry("foo/+/bar", 4, 3, 4)
-                                        be.Secret = bytes.Repeat([]byte{0xAA}, types.StreamSecretLength)
+                                        be.Secret = bytes.Repeat([]byte{0xAA}, types.PrefixSecretLength)
                                         be.TerminalIndex = 1337
                                         bb.addBundleEntry(be)
                                         bb.addFullStream("foo/+/baz", 3)
                                         So(coll.Process(c, bb.bundle()), ShouldBeNil)
 
                                         So(tcc, shouldHaveRegisteredStream, "foo/+/bar", -1)
                                         So(st, shouldHaveStoredStream, "foo/+/bar", indexRange{0, 2})
 
                                         So(tcc, shouldHaveRegisteredStream, "foo/+/baz", 2)
                                         So(st, shouldHaveStoredStream, "foo/+/baz", indexRange{0, 2})
@@ skipping 63 matching lines @@
                                         })
                                         bb.addBundleEntry(be)
                                         So(coll.Process(c, bb.bundle()), ShouldErrLike, "invalid log entry")
 
                                         So(tcc, shouldNotHaveRegisteredStream, "foo/+/bar")
                                 })
                         })
                 }
         })
 }