LogDog: Implement prefix expiration.

appengine/logdog/coordinator/endpoints/services/registerStream_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"
         "time"
@@ skipping 202 matching lines @@
 
                                 Convey(`Returns internal server error if the Prefix Put() fails.`, func() {
                                         c, fb := featureBreaker.FilterRDS(c, nil)
                                         fb.BreakFeatures(errors.New("test error"), "PutMulti")
 
                                         _, err := svr.RegisterStream(c, &req)
                                         So(err, ShouldBeRPCInternal)
                                 })
 
                                 Convey(`Registration failure cases`, func() {
+                                        Convey(`Will not register a stream if its prefix has expired.`, func() {
+                                                env.Clock.Set(tls.Prefix.Expiration)
+
+                                                _, err := svr.RegisterStream(c, &req)
+                                                So(err, ShouldBeRPCFailedPrecondition, "prefix has expired")
+                                        })
+
                                         Convey(`Will not register a stream without a protobuf version.`, func() {
                                                 req.ProtoVersion = ""
                                                 _, err := svr.RegisterStream(c, &req)
                                                 So(err, ShouldBeRPCInvalidArgument, "Unrecognized protobuf version")
                                         })
 
                                         Convey(`Will not register a stream with an unknown protobuf version.`, func() {
                                                 req.ProtoVersion = "unknown"
                                                 _, err := svr.RegisterStream(c, &req)
                                                 So(err, ShouldBeRPCInvalidArgument, "Unrecognized protobuf version")
@@ skipping 35 matching lines @@
                                                 fb.BreakFeatures(errors.New("test error"), "PutMulti")
 
                                                 _, err := rsm.RollForward(c)
                                                 So(err, ShouldBeRPCInternal)
                                         })
                                 })
                         })
                 })
         })
 }