LogDog: Add project namespace to Butler/Collector.

client/internal/logdog/butler/butler_test.go

 // Copyright 2015 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 butler
 
 import (
         "bytes"
         "errors"
         "fmt"
@@ skipping 210 matching lines @@
 }
 
 func TestConfig(t *testing.T) {
         t.Parallel()
 
         Convey(`A Config instance`, t, func() {
                 to := testOutput{
                         maxSize: 1024,
                 }
                 conf := Config{
-                        Output: &to,
-                        Prefix: "unit/test",
+                        Output:  &to,
+                        Prefix:  "unit/test",
+                        Project: "test-project",
+                        Secret:  types.PrefixSecret(bytes.Repeat([]byte{0x55}, types.PrefixSecretLength)),
                 }
 
                 Convey(`Will validate.`, func() {
                         So(conf.Validate(), ShouldBeNil)
                 })
 
                 Convey(`Will not validate with a nil Output.`, func() {
                         conf.Output = nil
                         So(conf.Validate(), ShouldErrLike, "an Output must be supplied")
                 })
 
                 Convey(`Will not validate with an invalid Prefix.`, func() {
                         conf.Prefix = "!!!!invalid!!!!"
-                        So(conf.Validate(), ShouldErrLike, "invalid Prefix")
+                        So(conf.Validate(), ShouldErrLike, "invalid prefix")
+                })
+
+                Convey(`Will not validate with an invalid Project.`, func() {
+                        conf.Project = "!!!!invalid!!!!"
+                        So(conf.Validate(), ShouldErrLike, "invalid project")
                 })
         })
 }
 
 // mkb is shorthand for "make Butler". It calls "new" and panics if there is
 // an error.
 func mkb(c context.Context, config Config) *Butler {
         b, err := New(c, config)
         if err != nil {
                 panic(err)
@@ skipping 10 matching lines @@
                 teeStderr := bytes.Buffer{}
                 to := testOutput{
                         maxSize: 1024,
                 }
 
                 conf := Config{
                         Output:        &to,
                         OutputWorkers: 1,
                         BufferLogs:    false,
                         Prefix:        "unit/test",
+                        Project:       "test-project",
+                        Secret:        types.PrefixSecret(bytes.Repeat([]byte{0x55}, types.PrefixSecretLength)),
                         TeeStdout:     &teeStdout,
                         TeeStderr:     &teeStderr,
                 }
 
                 Convey(`Will error if an invalid Config is passed.`, func() {
                         conf.Output = nil
                         So(conf.Validate(), ShouldNotBeNil)
 
                         _, err := New(c, conf)
                         So(err, ShouldNotBeNil)
@@ skipping 235 matching lines @@
                         tss.onNext = func() {
                                 panic("test panic")
                         }
 
                         b := mkb(c, conf)
                         b.AddStreamServer(tss)
                         So(b.Wait(), ShouldErrLike, "test panic")
                 })
         })
 }