LogDog: Add project namespace to service endpoint.

appengine/logdog/coordinator/endpoints/services/archiveStream_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 services
 
 import (
         "errors"
         "testing"
 
@@ skipping 12 matching lines @@
         . "github.com/smartystreets/goconvey/convey"
 )
 
 func TestArchiveStream(t *testing.T) {
         t.Parallel()
 
         Convey(`With a testing configuration`, t, func() {
                 c, tc := testclock.UseTime(context.Background(), testclock.TestTimeUTC)
                 c = memory.Use(c)
 
+                fs := authtest.FakeState{}
+                c = auth.WithState(c, &fs)
+
                 svcStub := ct.Services{}
                 svcStub.InitConfig()
                 svcStub.ServiceConfig.Coordinator.ServiceAuthGroup = "test-services"
                 c = coordinator.WithServices(c, &svcStub)
 
                 svr := New()
 
                 now := ds.RoundTime(tc.Now().UTC())
 
-                fs := authtest.FakeState{}
-                c = auth.WithState(c, &fs)
-
                 // Register a testing log stream with an archive tasked.
                 ls := ct.TestLogStream(c, ct.TestLogStreamDescriptor(c, "foo"))
                 ls.State = coordinator.LSArchiveTasked
                 ls.ArchivalKey = []byte("archival key")
                 if err := ds.Get(c).Put(ls); err != nil {
                         panic(err)
                 }
 
                 req := &logdog.ArchiveStreamRequest{
                         Path:          string(ls.Path()),
@@ skipping 131 matching lines @@
                         Convey(`When datastore Put fails, returns internal error.`, func() {
                                 c, fb := featureBreaker.FilterRDS(c, nil)
                                 fb.BreakFeatures(errors.New("test error"), "PutMulti")
 
                                 _, err := svr.ArchiveStream(c, req)
                                 So(err, ShouldBeRPCInternal)
                         })
                 })
         })
 }