Merge pull request #310 from evanlinjin/feature/tp-status-cli-#302

Added 'is_up' to transport status CLI.

cmd/skywire-cli/commands/visor/transports.go

@@ -144,15 +144,15 @@ var rmTpCmd = &cobra.Command{
 func printTransports(tps ...*visor.TransportSummary) {
 	sortTransports(tps...)
 	w := tabwriter.NewWriter(os.Stdout, 0, 0, 5, ' ', tabwriter.TabIndent)
-	_, err := fmt.Fprintln(w, "type\tid\tremote\tmode")
+	_, err := fmt.Fprintln(w, "type\tid\tremote\tmode\tis_up")
 	internal.Catch(err)
 	for _, tp := range tps {
 		tpMode := "regular"
 		if tp.IsSetup {
 			tpMode = "setup"
 		}
 
-		_, err = fmt.Fprintf(w, "%s\t%s\t%s\t%s\n", tp.Type, tp.ID, tp.Remote, tpMode)
+		_, err = fmt.Fprintf(w, "%s\t%s\t%s\t%s\t%v\n", tp.Type, tp.ID, tp.Remote, tpMode, tp.IsUp)
 		internal.Catch(err)
 	}
 	internal.Catch(w.Flush())

pkg/transport/managed_transport.go

@@ -94,6 +94,14 @@ func NewManagedTransport(n *snet.Network, dc DiscoveryClient, ls LogStore, rPK c
 	return mt
 }
 
+// IsUp returns true if transport status is up.
+func (mt *ManagedTransport) IsUp() bool {
+	mt.isUpMux.Lock()
+	isUp := mt.isUp && mt.isUpErr == nil
+	mt.isUpMux.Unlock()
+	return isUp
+}
+
 // Serve serves and manages the transport.
 func (mt *ManagedTransport) Serve(readCh chan<- routing.Packet) {
 	defer mt.wg.Done()

pkg/visor/rpc.go

@@ -146,16 +146,17 @@ type TransportSummary struct {
 	Type    string              `json:"type"`
 	Log     *transport.LogEntry `json:"log,omitempty"`
 	IsSetup bool                `json:"is_setup"`
+	IsUp    bool                `json:"is_up"`
 }
 
 func newTransportSummary(tm *transport.Manager, tp *transport.ManagedTransport, includeLogs, isSetup bool) *TransportSummary {
-
 	summary := &TransportSummary{
 		ID:      tp.Entry.ID,
 		Local:   tm.Local(),
 		Remote:  tp.Remote(),
 		Type:    tp.Type(),
 		IsSetup: isSetup,
+		IsUp:    tp.IsUp(),
 	}
 	if includeLogs {
 		summary.Log = tp.LogEntry