LogDog: Implement RegisterPrefix RPC.

appengine/logdog/coordinator/coordinatorTest/logStream.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 coordinatorTest
 
 import (
         "bytes"
         "fmt"
+        "time"
 
         "github.com/golang/protobuf/proto"
         ds "github.com/luci/gae/service/datastore"
         "github.com/luci/luci-go/appengine/logdog/coordinator"
         "github.com/luci/luci-go/common/clock"
         "github.com/luci/luci-go/common/config"
         "github.com/luci/luci-go/common/logdog/types"
         "github.com/luci/luci-go/common/proto/google"
         "github.com/luci/luci-go/common/proto/logdog/logpb"
         "golang.org/x/net/context"
@@ skipping 19 matching lines @@
         // Prefix is the Coordinator LogStreamState entity.
         State *coordinator.LogStreamState
         // Prefix is the Coordinator LogStream entity.
         Stream *coordinator.LogStream
 }
 
 // MakeStream builds a new TestStream with the supplied parameters.
 func MakeStream(c context.Context, project config.ProjectName, path types.StreamPath) *TestStream {
         prefix, name := path.Split()
 
-        now := ds.RoundTime(clock.Now(c)).UTC()
+        now := clock.Now(c).UTC()
         secret := TestSecret()
 
         ts := TestStream{
                 Project: project,
+                Prefix: &coordinator.LogPrefix{
+                        ID:      "", // Filled in by Reload.
+                        Created: ds.RoundTime(now),
+                        Prefix:  "", // Filled in by Reload.
+                        Source:  []string{"test suite"},
+                        Secret:  secret,
+                },
                 Desc: &logpb.LogStreamDescriptor{
                         Prefix:      string(prefix),
                         Name:        string(name),
                         StreamType:  logpb.StreamType_TEXT,
                         ContentType: "application/text",
                         Timestamp:   google.NewTimestamp(now),
                 },
-                Prefix: &coordinator.LogPrefix{
-                        Created: ds.RoundTime(now),
-                        Secret:  secret,
-                },
                 State: &coordinator.LogStreamState{
-                        Created:       now,
+                        Parent:        nil, // Filled in by Reload.
+                        Created:       ds.RoundTime(now),
+                        Updated:       time.Time{}, // Filled in by Reload.
                         Secret:        secret,
                         TerminalIndex: -1,
                 },
                 Stream: &coordinator.LogStream{
+                        ID:           "", // Filled in by Reload.
                         ProtoVersion: logpb.Version,
-                        Created:      now,
+                        Created:      ds.RoundTime(now),
+                        // Descriptor-derived fields filled in by Reload.
                 },
         }
         ts.Reload(c)
         return &ts
 }
 
 // Reload loads derived fields from their base fields.
 func (ts *TestStream) Reload(c context.Context) {
         ts.Path = ts.Desc.Path()
 
@@ skipping 76 matching lines @@
                 }
         }
         return &le
 }
 
 // WithProjectNamespace runs f in proj's namespace, bypassing authentication
 // checks.
 func (ts *TestStream) WithProjectNamespace(c context.Context, f func(context.Context)) {
         WithProjectNamespace(c, ts.Project, f)
 }