list command will show the version of darknode

Author: tok-kkk

VERSION

@@ -1 +1 @@
-3.0.9
+3.0.10

cmd/flag.go

@@ -40,6 +40,10 @@ var (
 		Name:  "version",
 		Usage: "Version of darknode you want to upgrade to",
 	}
+	DowngradeFlag = cli.BoolFlag{
+		Name:  "downgrade",
+		Usage: "Force downgrading to an older version without interactive prompts",
+	}
 )
 
 // AWS flags

cmd/list.go

@@ -48,7 +48,8 @@ func listAllNodes(ctx *cli.Context) error {
 			if err != nil {
 				return nil, err
 			}
-			return []string{name, id.String(), ip, provider, string(tags), ethAddr.Hex()}, nil
+			version := util.Version(name)
+			return []string{name, id.String(), ip, provider, string(tags), ethAddr.Hex(), version}, nil
 		}()
 		if err != nil {
 			color.Red("[%v] cannot get detail of the darknode, err = %v", name, err)
@@ -61,10 +62,10 @@ func listAllNodes(ctx *cli.Context) error {
 		return fmt.Errorf("cannot find any node")
 	}
 
-	fmt.Printf("%-20s | %-30s | %-15s | %-8s | %-15s | %-45s \n", "name", "id", "ip", "provider", "tags", "ethereum address")
+	fmt.Printf("%-20s | %-30s | %-15s | %-8s | %-15s | %-45s | %-15s\n", "name", "id", "ip", "provider", "tags", "ethereum address", "version")
 	for _, node := range nodes {
 		if node != nil {
-			fmt.Printf("%-20s | %-30s | %-15s | %-8s | %-15s | %-45s\n", node[0], node[1], node[2], node[3], node[4], node[5])
+			fmt.Printf("%-20s | %-30s | %-15s | %-8s | %-15s | %-45s | %-15s\n", node[0], node[1], node[2], node[3], node[4], node[5], node[6])
 		}
 	}
 	return nil

cmd/main.go

@@ -68,7 +68,7 @@ func main() {
 		{
 			Name:  "update",
 			Usage: "Update your Darknodes to the latest software and configuration",
-			Flags: []cli.Flag{TagsFlag, VersionFlag},
+			Flags: []cli.Flag{TagsFlag, VersionFlag, DowngradeFlag},
 			Action: func(c *cli.Context) error {
 				return updateNode(c)
 			},

cmd/update.go

@@ -20,6 +20,7 @@ import (
 func updateNode(ctx *cli.Context) error {
 	name := ctx.Args().First()
 	tags := ctx.String("tags")
+	force := ctx.Bool("downgrade")
 	version := strings.TrimSpace(ctx.String("version"))
 	nodes, err := util.ParseNodesFromNameAndTags(name, tags)
 	if err != nil {
@@ -43,13 +44,13 @@ func updateNode(ctx *cli.Context) error {
 	color.Green("Updating darknodes...")
 	errs := make([]error, len(nodes))
 	phi.ParForAll(nodes, func(i int) {
-		errs[i] = updateSingleNode(nodes[i], version)
+		errs[i] = updateSingleNode(nodes[i], version, force)
 	})
 	return util.HandleErrs(errs)
 }
 
-func updateSingleNode(name, ver string) error {
-	v, _ := util.Version(name)
+func updateSingleNode(name, ver string, force bool) error {
+	v := util.Version(name)
 	curVersion, err := version.NewVersion(strings.TrimSpace(v))
 	if err != nil {
 		return err
@@ -60,10 +61,28 @@ func updateSingleNode(name, ver string) error {
 	case 0:
 		color.Green("darknode [%v] is running version [%v] already.", name, ver)
 	case 1:
-		color.Red("darknode [%v] is running with version %v, you cannot downgrade to a lower version %v", name, curVersion.String(), newVersion.String())
+		if !force {
+			color.Red("darknode [%v] is running with version %v, you cannot downgrade to a lower version %v", name, curVersion.String(), newVersion.String())
+			return nil
+		}
+		if err := update(name, ver); err != nil {
+			color.Red("cannot downgrade darknode %v, error = %v", name, err)
+		} else {
+			color.Green("[%s] has been downgraded to version %v", name, ver)
+		}
 	default:
-		url := fmt.Sprintf("https://github.com/renproject/darknode-release/releases/download/%v", ver)
-		script := fmt.Sprintf(`mv ~/.darknode/bin/darknode ~/.darknode/bin/darknode-backup && 
+		if err := update(name, ver); err != nil {
+			color.Red("cannot update darknode %v, error = %v", name, err)
+		} else {
+			color.Green("[%s] has been updated to version %v", name, ver)
+		}
+	}
+	return nil
+}
+
+func update(name, ver string) error {
+	url := fmt.Sprintf("https://github.com/renproject/darknode-release/releases/download/%v", ver)
+	script := fmt.Sprintf(`mv ~/.darknode/bin/darknode ~/.darknode/bin/darknode-backup && 
 curl -sL %v/darknode > ~/.darknode/bin/darknode && 
 chmod +x ~/.darknode/bin/darknode && 
 systemctl --user stop darknode &&
@@ -72,14 +91,7 @@ rm -rf ~/.darknode/db &&
 mv ~/.darknode/db_bak ~/.darknode/db &&
 echo %v > ~/.darknode/version &&
 systemctl --user restart darknode`, url, ver)
-		err = util.RemoteRun(name, script)
-		if err != nil {
-			color.Red("cannot update darknode %v, error = %v", name, err)
-		} else {
-			color.Green("[%s] has been updated to version %v", name, ver)
-		}
-	}
-	return nil
+	return util.RemoteRun(name, script)
 }
 
 func validateVersion(version string) error {

util/node.go

@@ -85,13 +85,13 @@ func IP(name string) (string, error) {
 }
 
 // Version gets the version of the software the darknode currently is running.
-func Version(name string) (string, error) {
+func Version(name string) string {
 	script := "cat ~/.darknode/version"
 	version, err := RemoteOutput(name, script)
 	if err != nil {
-		return "0.0.0", err
+		return "unknown"
 	}
-	return string(version), nil
+	return strings.TrimSpace(string(version))
 }
 
 // Network gets the network of the darknode.