LogDog: Add log rendering view.

appengine/logdog/coordinator/endpoints/logs/get_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 logs
 
 import (
         "bytes"
         "errors"
         "fmt"
@@ skipping 12 matching lines @@
         "github.com/luci/luci-go/common/clock/testclock"
         "github.com/luci/luci-go/common/gcloud/gs"
         "github.com/luci/luci-go/common/iotools"
         "github.com/luci/luci-go/common/logdog/types"
         "github.com/luci/luci-go/common/proto/logdog/logpb"
         "github.com/luci/luci-go/common/proto/logdog/svcconfig"
         "github.com/luci/luci-go/common/recordio"
         "github.com/luci/luci-go/server/auth"
         "github.com/luci/luci-go/server/auth/authtest"
         "github.com/luci/luci-go/server/logdog/storage"
+        ast "github.com/luci/luci-go/server/logdog/storage/archive"
         memoryStorage "github.com/luci/luci-go/server/logdog/storage/memory"
         "golang.org/x/net/context"
 
         . "github.com/luci/luci-go/common/testing/assertions"
         . "github.com/smartystreets/goconvey/convey"
 )
 
 type staticArchiveSource []*logpb.LogEntry
 
 func (s *staticArchiveSource) NextLogEntry() (le *logpb.LogEntry, err error) {
@@ skipping 162 matching lines @@
                                 panic(err)
                         }
                         protobufs[uint64(v)] = d
                 }
 
                 // Define and populate our Storage.
                 s := Server{}
 
                 ms := memoryStorage.Storage{}
                 gsc := testGSClient{}
-                s.StorageFunc = func(context.Context) (storage.Storage, error) {
+                s.IntermediateStorageFunc = func(c context.Context) (storage.Storage, error) {
                         return &ms, nil
                 }
-                s.GSClientFunc = func(context.Context) (gs.Client, error) {
-                        return gsc, nil
+                s.ArchiveStorageFunc = func(c context.Context, ls *coordinator.LogStream) (storage.Storage, error) {
+                        return ast.New(c, ast.Options{
+                                IndexURL:  ls.ArchiveIndexURL,
+                                StreamURL: ls.ArchiveStreamURL,
+                                Client:    &gsc,
+                        })
                 }
 
                 Convey(`Testing Get requests (no logs)`, func() {
                         req := logs.GetRequest{
                                 Path: string(ls.Path()),
                         }
 
                         Convey(`Will fail if the Path is not a stream path or a hash.`, func() {
                                 req.Path = "not/a/full/stream/path"
                                 _, err := s.Get(c, &req)
@@ skipping 342 matching lines @@
                                                 resp, err := s.Tail(c, &req)
                                                 So(err, ShouldBeRPCOK)
                                                 So(resp, shouldHaveLogs, 7)
                                                 So(resp.State, ShouldResemble, loadLogStreamState(ls))
                                         })
                                 })
                         })
                 }
         })
 }