LogDog: Split CLI tool into package and main.

logdog/client/cmd/logdog/subcommandLatest.go

Index: logdog/client/cmd/logdog/subcommandLatest.go
diff --git a/logdog/client/cmd/logdog/subcommandLatest.go b/logdog/client/cmd/logdog/subcommandLatest.go
deleted file mode 100644
index 59cdd9fcad8b6de1b98f1277383b816a0ff9a182..0000000000000000000000000000000000000000
--- a/logdog/client/cmd/logdog/subcommandLatest.go
+++ /dev/null
@@ -1,123 +0,0 @@
-// Copyright 2016 The LUCI Authors. All rights reserved.
-// Use of this source code is governed under the Apache License, Version 2.0
-// that can be found in the LICENSE file.
-
-package main
-
-import (
-	"io"
-	"os"
-
-	"github.com/luci/luci-go/common/clock"
-	log "github.com/luci/luci-go/common/logging"
-	"github.com/luci/luci-go/logdog/api/logpb"
-	"github.com/luci/luci-go/logdog/client/coordinator"
-	"github.com/luci/luci-go/logdog/common/renderer"
-	"github.com/luci/luci-go/logdog/common/types"
-
-	"github.com/maruel/subcommands"
-	"golang.org/x/net/context"
-)
-
-type latestCommandRun struct {
-	subcommands.CommandRunBase
-
-	raw bool
-}
-
-func newLatestCommand() *subcommands.Command {
-	return &subcommands.Command{
-		UsageLine: "latest [options] stream",
-		ShortDesc: "Write the latest full log record in a stream to STDOUT.",
-		LongDesc: "Write the latest full log record in a stream to STDOUT. If the stream " +
-			"doesn't have any log entries, will block until a log entry is available.",
-		CommandRun: func() subcommands.CommandRun {
-			cmd := &latestCommandRun{}
-
-			cmd.Flags.BoolVar(&cmd.raw, "raw", false,
-				"Reproduce original log stream, instead of attempting to render for humans.")
-			return cmd
-		},
-	}
-}
-
-func (cmd *latestCommandRun) Run(scApp subcommands.Application, args []string) int {
-	a := scApp.(*application)
-
-	// User-friendly: trim any leading or trailing slashes from the path.
-	if len(args) != 1 {
-		log.Errorf(a, "Exactly one argument, the stream path, must be supplied.")
-		return 1
-	}
-
-	project, path, _, err := a.splitPath(args[0])
-	if err != nil {
-		log.WithError(err).Errorf(a, "Invalid path specifier.")
-		return 1
-	}
-
-	sp := streamPath{project, types.StreamPath(path)}
-	if err := sp.path.Validate(); err != nil {
-		log.Fields{
-			log.ErrorKey: err,
-			"project":    sp.project,
-			"path":       sp.path,
-		}.Errorf(a, "Invalid command-line stream path.")
-		return 1
-	}
-
-	stream := a.coord.Stream(sp.project, sp.path)
-
-	tctx, _ := a.timeoutCtx(a)
-	le, st, err := cmd.getTailEntry(tctx, stream)
-	if err != nil {
-		log.Fields{
-			log.ErrorKey: err,
-			"project":    sp.project,
-			"path":       sp.path,
-		}.Errorf(a, "Failed to load latest record.")
-
-		if err == context.DeadlineExceeded {
-			return 2
-		}
-		return 1
-	}
-
-	// Render the entry.
-	r := renderer.Renderer{
-		Source:         &renderer.StaticSource{le},
-		Raw:            cmd.raw,
-		DatagramWriter: getDatagramWriter(a, &st.Desc),
-	}
-	if _, err := io.Copy(os.Stdout, &r); err != nil {
-		log.WithError(err).Errorf(a, "failed to write to output")
-		return 1
-	}
-
-	return 0
-}
-
-func (cmd *latestCommandRun) getTailEntry(c context.Context, s *coordinator.Stream) (
-	*logpb.LogEntry, *coordinator.LogStream, error) {
-
-	// Loop until we either hard fail or succeed.
-	var st coordinator.LogStream
-	for {
-		ls, err := s.Tail(c, coordinator.Complete(), coordinator.WithState(&st))
-		switch {
-		case err == nil:
-			return ls, &st, nil
-
-		case err == coordinator.ErrNoSuchStream, ls == nil:
-			log.WithError(err).Warningf(c, "No log entries, sleeping and retry.")
-
-			if ar := <-clock.After(c, noStreamDelay); ar.Incomplete() {
-				// Timer stopped prematurely.
-				return nil, nil, ar.Err
-			}
-
-		default:
-			return nil, nil, err
-		}
-	}
-}