LogDog: CLI can use stream URLs, fix auth.

logdog/client/cli/subcommandLatest.go

Index: logdog/client/cli/subcommandLatest.go
diff --git a/logdog/client/cli/subcommandLatest.go b/logdog/client/cli/subcommandLatest.go
index bafa210871ea69e3993494e4d3665dd0f55bd186..1df91984d6ac457feee97b13a2d5e157219d51fd 100644
--- a/logdog/client/cli/subcommandLatest.go
+++ b/logdog/client/cli/subcommandLatest.go
@@ -9,6 +9,7 @@ import (
 	"os"
 
 	"github.com/luci/luci-go/common/clock"
+	"github.com/luci/luci-go/common/errors"
 	log "github.com/luci/luci-go/common/logging"
 	"github.com/luci/luci-go/logdog/api/logpb"
 	"github.com/luci/luci-go/logdog/client/coordinator"
@@ -50,31 +51,42 @@ func (cmd *latestCommandRun) Run(scApp subcommands.Application, args []string, _
 		return 1
 	}
 
-	project, path, _, err := a.splitPath(args[0])
-	if err != nil {
-		log.WithError(err).Errorf(a, "Invalid path specifier.")
-		return 1
+	var addr *types.StreamAddr
+	var err error
+	if addr, err = types.ParseURL(args[0]); err != nil {
+		// Not a log stream address.
+		project, path, _, err := a.splitPath(args[0])
+		if err != nil {
+			log.WithError(err).Errorf(a, "Invalid path specifier.")
+			return 1
+		}
+
+		addr = &types.StreamAddr{Project: project, Path: types.StreamPath(path)}
+		if err := addr.Path.Validate(); err != nil {
+			log.Fields{
+				log.ErrorKey: err,
+				"project":    addr.Project,
+				"path":       addr.Path,
+			}.Errorf(a, "Invalid command-line stream path.")
+			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.")
+	coord, err := a.coordinatorClient(addr.Host)
+	if err != nil {
+		errors.Log(a, errors.Annotate(err).Reason("failed to create Coordinator client").Err())
 		return 1
 	}
 
-	stream := a.coord.Stream(sp.project, sp.path)
+	stream := coord.Stream(addr.Project, addr.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,
+			"project":    addr.Project,
+			"path":       addr.Path,
 		}.Errorf(a, "Failed to load latest record.")
 
 		if err == context.DeadlineExceeded {