| Index: appengine/logdog/coordinator/endpoints/services/registerStream_test.go
|
| diff --git a/appengine/logdog/coordinator/endpoints/services/registerStream_test.go b/appengine/logdog/coordinator/endpoints/services/registerStream_test.go
|
| index eed181769ff5b041e2c45965f01ce1959979aba2..36bdc235efc6ba1a5248c671cddd2fa8be4c8eab 100644
|
| --- a/appengine/logdog/coordinator/endpoints/services/registerStream_test.go
|
| +++ b/appengine/logdog/coordinator/endpoints/services/registerStream_test.go
|
| @@ -33,6 +33,9 @@ func TestRegisterStream(t *testing.T) {
|
| c := tt.Context()
|
| ds.Get(c).Testable().Consistent(true)
|
|
|
| + fs := authtest.FakeState{}
|
| + c = auth.WithState(c, &fs)
|
| +
|
| svcStub := ct.Services{}
|
| svcStub.InitConfig()
|
| svcStub.ServiceConfig.Coordinator.ServiceAuthGroup = "test-services"
|
| @@ -40,9 +43,6 @@ func TestRegisterStream(t *testing.T) {
|
|
|
| svr := New()
|
|
|
| - fs := authtest.FakeState{}
|
| - c = auth.WithState(c, &fs)
|
| -
|
| Convey(`Returns Forbidden error if not a service.`, func() {
|
| _, err := svr.RegisterStream(c, &logdog.RegisterStreamRequest{})
|
| So(err, ShouldBeRPCPermissionDenied)
|
| @@ -52,7 +52,7 @@ func TestRegisterStream(t *testing.T) {
|
| fs.IdentityGroups = []string{"test-services"}
|
|
|
| desc := ct.TestLogStreamDescriptor(c, "foo/bar")
|
| - secret := bytes.Repeat([]byte{0xAA}, types.StreamSecretLength)
|
| + secret := bytes.Repeat([]byte{0xAA}, types.PrefixSecretLength)
|
|
|
| Convey(`A stream registration request for "testing/+/foo/bar"`, func() {
|
| req := logdog.RegisterStreamRequest{
|
| @@ -157,7 +157,7 @@ func TestRegisterStream(t *testing.T) {
|
| Convey(`Will not register a wrong-sized secret.`, func() {
|
| req.Secret = nil
|
| _, err := svr.RegisterStream(c, &req)
|
| - So(err, ShouldBeRPCInvalidArgument, "Invalid secret length")
|
| + So(err, ShouldBeRPCInvalidArgument, "Invalid prefix secret")
|
| })
|
|
|
| Convey(`Will not register with an empty descriptor.`, func() {
|
|
|