Add logging to client command.

internal/cmd/client/pubsub.go

@@ -3,7 +3,6 @@ package client
 import (
 	"fmt"
 	"io"
-	"time"
 
 	"github.com/urfave/cli/v2"
 	"github.com/wetware/ww/pkg/client"
@@ -53,11 +52,6 @@ func publish() cli.ActionFunc {
 			return err
 		}
 
-		// FIXME:  if we remove this, commands with sochastically hang.
-		//         Best guess is that this happens when they are pipelined
-		//         against a pending FutureTopic.
-		time.Sleep(time.Millisecond * 5)
-
 		return t.Publish(c.Context, b)
 	}
 }
@@ -69,6 +63,8 @@ func subscribe() cli.ActionFunc {
 			msg []byte
 		)
 
+		logger.Debug("connected to cluster")
+
 		t := node.Join(c.Context, c.String("topic"))
 		defer t.Release()
 
@@ -87,10 +83,6 @@ func subscribe() cli.ActionFunc {
 			fmt.Fprintln(c.App.Writer, string(msg))
 		}
 
-		if err == client.ErrDisconnected {
-			err = nil
-		}
-
 		return err
 	}
 }

internal/cmd/client/runtime.go

@@ -20,17 +20,19 @@ import (
 )
 
 var (
-	app  *fx.App
-	node *client.Node
+	app    *fx.App
+	node   *client.Node
+	logger log.Logger
 )
 
 func setup() cli.BeforeFunc {
 	return func(c *cli.Context) error {
 		app = fx.New(fx.NopLogger,
 			fx.Supply(c),
+			fx.Populate(&logger),
 			fx.Provide(
 				localhost,
-				logger,
+				logging,
 				dialer),
 			fx.Invoke(dial))
 
@@ -50,7 +52,7 @@ func teardown() cli.AfterFunc {
 	}
 }
 
-func logger(c *cli.Context) log.Logger {
+func logging(c *cli.Context) log.Logger {
 	return logutil.New(c).With(discoveryFields(c))
 }