LogDog: Update to archival V2.

appengine/logdog/coordinator/endpoints/services/registerStream.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 (
         "crypto/subtle"
         "errors"
 
@@ skipping 44 matching lines @@
                 Archived:      ls.Archived(),
                 Purged:        ls.Purged,
         }
         if !ls.Terminated() {
                 st.TerminalIndex = -1
         }
         return &st
 }
 
 // RegisterStream is an idempotent stream state register operation.
-func (b *Server) RegisterStream(c context.Context, req *logdog.RegisterStreamRequest) (
-        *logdog.RegisterStreamResponse, error) {
-        if err := Auth(c); err != nil {
+func (s *Server) RegisterStream(c context.Context, req *logdog.RegisterStreamRequest) (*logdog.RegisterStreamResponse, error) {
+        svc := s.GetServices()
+        if err := Auth(c, svc); err != nil {
                 return nil, err
         }
 
         log.Fields{
                 "path": req.Path,
         }.Infof(c, "Registration request for log stream.")
 
         path := types.StreamPath(req.Path)
         if err := path.Validate(); err != nil {
                 return nil, grpcutil.Errf(codes.InvalidArgument, "Invalid path (%s): %s", path, err)
@@ skipping 96 matching lines @@
         log.Infof(c, "Registering new log stream'")
 
         // The stream is not yet registered.
         if err := m.LoadDescriptor(m.req.Desc); err != nil {
                 log.Fields{
                         log.ErrorKey: err,
                 }.Errorf(c, "Failed to load descriptor into LogStream.")
                 return nil, grpcutil.Errf(codes.InvalidArgument, "Failed to load descriptor.")
         }
 
-        now := ds.RoundTime(clock.Now(c).UTC())
         m.Secret = m.req.Secret
         m.ProtoVersion = m.req.ProtoVersion
-        m.State = coordinator.LSPending
-        m.Created = now
-        m.Updated = now
+        m.State = coordinator.LSStreaming
+        m.Created = ds.RoundTime(clock.Now(c).UTC())
         m.TerminalIndex = -1
 
-        if err := m.Put(di); err != nil {
+        if err := di.Put(m.LogStream); err != nil {
                 log.Fields{
                         log.ErrorKey: err,
                 }.Errorf(c, "Failed to Put() LogStream.")
                 return nil, grpcutil.Internal
         }
 
         return []tumble.Mutation{
                 &mutations.PutHierarchyMutation{
                         Path: m.Path(),
                 },
         }, nil
 }
 
 func (m registerStreamMutation) Root(c context.Context) *ds.Key {
         return ds.Get(c).KeyForObj(m.LogStream)
 }