LogDog: Update to archival V2.

common/logdog/coordinator/stream_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 coordinator
 
 import (
         "errors"
         "testing"
 
@@ skipping 147 matching lines @@
                                         var ls LogStream
                                         p = p.State(&ls)
 
                                         svc.GH = func(*logdog.GetRequest) (*logdog.GetResponse, error) {
                                                 return &logdog.GetResponse{
                                                         Logs: []*logpb.LogEntry{
                                                                 genLog(1337, "kthxbye"),
                                                         },
                                                         State: &logdog.LogStreamState{
                                                                 Created: google.NewTimestamp(now),
-                                                                Updated: google.NewTimestamp(now),
                                                                 Archive: &logdog.LogStreamState_ArchiveInfo{
                                                                         IndexUrl:  "index",
                                                                         StreamUrl: "stream",
                                                                         DataUrl:   "data",
                                                                 },
                                                         },
                                                         Desc: &logpb.LogStreamDescriptor{
                                                                 Prefix:     "test",
                                                                 Name:       "a",
                                                                 StreamType: logpb.StreamType_TEXT,
                                                         },
                                                 }, nil
                                         }
 
                                         l, err := s.Get(c, p)
                                         So(err, ShouldBeNil)
                                         So(l, ShouldResemble, []*logpb.LogEntry{genLog(1337, "kthxbye")})
                                         So(ls, ShouldResemble, LogStream{
                                                 Path: "test/+/a",
                                                 Desc: &logpb.LogStreamDescriptor{
                                                         Prefix:     "test",
                                                         Name:       "a",
                                                         StreamType: logpb.StreamType_TEXT,
                                                 },
                                                 State: &StreamState{
                                                         Created:          now,
-                                                        Updated:          now,
                                                         Archived:         true,
                                                         ArchiveIndexURL:  "index",
                                                         ArchiveStreamURL: "stream",
                                                         ArchiveDataURL:   "data",
                                                 },
                                         })
                                 })
 
                                 Convey(`Will return ErrNoSuchStream if the stream is not found.`, func() {
                                         svc.GH = func(*logdog.GetRequest) (*logdog.GetResponse, error) {
@@ skipping 22 matching lines @@
                                         So(err, ShouldEqual, ErrNoAccess)
                                 })
                         })
 
                         Convey(`Test State`, func() {
                                 Convey(`Will request just the state if asked.`, func() {
                                         svc.GH = func(*logdog.GetRequest) (*logdog.GetResponse, error) {
                                                 return &logdog.GetResponse{
                                                         State: &logdog.LogStreamState{
                                                                 Created: google.NewTimestamp(now),
-                                                                Updated: google.NewTimestamp(now),
                                                         },
                                                 }, nil
                                         }
 
                                         l, err := s.State(c)
                                         So(err, ShouldBeNil)
                                         So(l, ShouldResemble, &LogStream{
                                                 Path: "test/+/a",
                                                 State: &StreamState{
                                                         Created: now.UTC(),
-                                                        Updated: now.UTC(),
                                                 },
                                         })
 
                                         // Validate the HTTP request that we made.
                                         So(svc.GR, ShouldResemble, logdog.GetRequest{
                                                 Path:     "test/+/a",
                                                 LogCount: -1,
                                                 State:    true,
                                         })
                                 })
@@ skipping 25 matching lines @@
                                         So(err, ShouldEqual, ErrNoAccess)
                                 })
                         })
 
                         Convey(`Test Tail`, func() {
                                 Convey(`Will form a proper Tail query.`, func() {
                                         svc.TH = func(*logdog.TailRequest) (*logdog.GetResponse, error) {
                                                 return &logdog.GetResponse{
                                                         State: &logdog.LogStreamState{
                                                                 Created: google.NewTimestamp(now),
-                                                                Updated: google.NewTimestamp(now),
                                                         },
                                                         Desc: &logpb.LogStreamDescriptor{
                                                                 Prefix:     "test",
                                                                 Name:       "a",
                                                                 StreamType: logpb.StreamType_TEXT,
                                                         },
                                                         Logs: []*logpb.LogEntry{
                                                                 genLog(1337, "kthxbye"),
                                                         },
                                                 }, nil
@@ skipping 13 matching lines @@
                                         So(l, ShouldResemble, genLog(1337, "kthxbye"))
                                         So(ls, ShouldResemble, LogStream{
                                                 Path: "test/+/a",
                                                 Desc: &logpb.LogStreamDescriptor{
                                                         Prefix:     "test",
                                                         Name:       "a",
                                                         StreamType: logpb.StreamType_TEXT,
                                                 },
                                                 State: &StreamState{
                                                         Created: now,
-                                                        Updated: now,
                                                 },
                                         })
                                 })
 
                                 Convey(`Will return nil with state if no logs are returned from the endpoint.`, func() {
                                         svc.TH = func(*logdog.TailRequest) (*logdog.GetResponse, error) {
                                                 return &logdog.GetResponse{
                                                         State: &logdog.LogStreamState{
                                                                 Created: google.NewTimestamp(now),
-                                                                Updated: google.NewTimestamp(now),
                                                         },
                                                         Desc: &logpb.LogStreamDescriptor{
                                                                 Prefix:     "test",
                                                                 Name:       "a",
                                                                 StreamType: logpb.StreamType_TEXT,
                                                         },
                                                 }, nil
                                         }
 
                                         var ls LogStream
                                         l, err := s.Tail(c, &ls)
                                         So(err, ShouldBeNil)
                                         So(l, ShouldBeNil)
                                         So(ls, ShouldResemble, LogStream{
                                                 Path: "test/+/a",
                                                 Desc: &logpb.LogStreamDescriptor{
                                                         Prefix:     "test",
                                                         Name:       "a",
                                                         StreamType: logpb.StreamType_TEXT,
                                                 },
                                                 State: &StreamState{
                                                         Created: now,
-                                                        Updated: now,
                                                 },
                                         })
                                 })
 
                                 Convey(`Will error if multiple logs are returned from the endpoint.`, func() {
                                         svc.TH = func(*logdog.TailRequest) (*logdog.GetResponse, error) {
                                                 return &logdog.GetResponse{
                                                         State: &logdog.LogStreamState{
                                                                 Created: google.NewTimestamp(now),
-                                                                Updated: google.NewTimestamp(now),
                                                         },
                                                         Logs: []*logpb.LogEntry{
                                                                 genLog(1337, "ohai"),
                                                                 genLog(1338, "kthxbye"),
                                                         },
                                                 }, nil
                                         }
 
                                         _, err := s.Tail(c, nil)
                                         So(err, ShouldErrLike, "tail call returned 2 logs")
@@ skipping 22 matching lines @@
                                                 return nil, grpcutil.PermissionDenied
                                         }
 
                                         _, err := s.Tail(c, nil)
                                         So(err, ShouldEqual, ErrNoAccess)
                                 })
                         })
                 })
         })
 }