Devnet wiz: one command for devnet + subnet flow

cmd/nodecmd/create.go

@@ -146,6 +146,13 @@ func createNodes(_ *cobra.Command, args []string) error {
 	if err != nil {
 		return err
 	}
+	if numNodes <= 0 {
+		var err error
+		numNodes, err = app.Prompt.CaptureInt("How many nodes do you want to set up?")
+		if err != nil {
+			return err
+		}
+	}
 	usr, err := user.Current()
 	if err != nil {
 		return err

cmd/nodecmd/create_aws.go

@@ -166,13 +166,6 @@ func createEC2Instances(rootBody *hclwrite.Body,
 	if err := terraformaws.SetCloudCredentials(rootBody, awsProfile, region); err != nil {
 		return nil, nil, "", "", err
 	}
-	if numNodes <= 0 {
-		var err error
-		numNodes, err = app.Prompt.CaptureInt("How many nodes do you want to set up on AWS?")
-		if err != nil {
-			return nil, nil, "", "", err
-		}
-	}
 	ux.Logger.PrintToUser("Creating new EC2 instance(s) on AWS...")
 	var useExistingKeyPair bool
 	keyPairExists, err := awsAPI.CheckKeyPairExists(ec2Svc, keyPairName)

cmd/nodecmd/create_gcp.go

@@ -160,12 +160,6 @@ func createGCEInstances(rootBody *hclwrite.Body,
 	if err := terraformgcp.SetCloudCredentials(rootBody, zone, credentialsPath, projectName); err != nil {
 		return nil, nil, "", "", err
 	}
-	if numNodes <= 0 {
-		numNodes, err = app.Prompt.CaptureInt("How many nodes do you want to set up on GCP?")
-		if err != nil {
-			return nil, nil, "", "", err
-		}
-	}
 	ux.Logger.PrintToUser("Creating new VM instance(s) on Google Compute Engine...")
 	certInSSHDir, err := app.CheckCertInSSHDir(fmt.Sprintf("%s-keypair.pub", cliDefaultName))
 	if err != nil {

cmd/nodecmd/devnet.go

@@ -25,5 +25,7 @@ You can check the updated status by calling avalanche node status <clusterName>`
 	}
 	// node devnet deploy
 	cmd.AddCommand(newDeployCmd())
+	// node devnet wiz
+	cmd.AddCommand(newWizCmd())
 	return cmd
 }

cmd/nodecmd/stop.go

@@ -194,3 +194,16 @@ func getClusterNodes(clusterName string) ([]string, error) {
 	}
 	return clusterNodes, nil
 }
+
+func clusterExists(clusterName string) (bool, error) {
+	clustersConfig := models.ClustersConfig{}
+	if app.ClustersConfigExists() {
+		var err error
+		clustersConfig, err = app.LoadClustersConfig()
+		if err != nil {
+			return false, err
+		}
+	}
+	_, ok := clustersConfig.Clusters[clusterName]
+	return ok, nil
+}

cmd/nodecmd/sync.go

@@ -162,35 +162,6 @@ func syncSubnet(_ *cobra.Command, args []string) error {
 		}
 		return fmt.Errorf("the Avalanche Go version of node(s) %s is incompatible with VM RPC version of %s", incompatibleNodes, subnetName)
 	}
-	hosts, err := ansible.GetInventoryFromAnsibleInventoryFile(app.GetAnsibleInventoryDirPath(clusterName))
-	if err != nil {
-		return err
-	}
-	wg := sync.WaitGroup{}
-	wgResults := models.NodeResults{}
-	for _, host := range hosts {
-		wg.Add(1)
-		go func(nodeResults *models.NodeResults, host models.Host) {
-			defer wg.Done()
-			if err := host.Connect(constants.SSHScriptTimeout); err != nil {
-				nodeResults.AddResult(host.NodeID, nil, err)
-				return
-			}
-			defer func() {
-				if err := host.Disconnect(); err != nil {
-					nodeResults.AddResult(host.NodeID, nil, err)
-				}
-			}()
-			if err := ssh.RunSSHSetupBuildEnv(host); err != nil {
-				nodeResults.AddResult(host.NodeID, nil, err)
-				return
-			}
-		}(&wgResults, host)
-	}
-	wg.Wait()
-	if wgResults.HasErrors() {
-		return fmt.Errorf("failed to get setup build env for node(s) %s", wgResults.GetErrorHostMap())
-	}
 	clustersConfig, err := app.LoadClustersConfig()
 	if err != nil {
 		return err
@@ -334,10 +305,6 @@ func trackSubnet(clusterName, subnetName string, network models.Network) ([]stri
 					nodeResults.AddResult(host.NodeID, nil, err)
 				}
 			}()
-			if err := ssh.RunSSHSetupCLIFromSource(host, constants.SetupCLIFromSourceBranch); err != nil {
-				nodeResults.AddResult(host.NodeID, nil, err)
-				return
-			}
 			subnetExportPath := filepath.Join("/tmp", filepath.Base(subnetPath))
 			if err := ssh.RunSSHExportSubnet(host, subnetPath, subnetExportPath); err != nil {
 				nodeResults.AddResult(host.NodeID, nil, err)

cmd/nodecmd/updateSubnet.go

@@ -69,36 +69,6 @@ func updateSubnet(_ *cobra.Command, args []string) error {
 		}
 		return fmt.Errorf("the Avalanche Go version of node(s) %s is incompatible with VM RPC version of %s", incompatibleNodes, subnetName)
 	}
-
-	hosts, err := ansible.GetInventoryFromAnsibleInventoryFile(app.GetAnsibleInventoryDirPath(clusterName))
-	if err != nil {
-		return err
-	}
-	wg := sync.WaitGroup{}
-	wgResults := models.NodeResults{}
-	for _, host := range hosts {
-		wg.Add(1)
-		go func(nodeResults *models.NodeResults, host models.Host) {
-			defer wg.Done()
-			if err := host.Connect(constants.SSHScriptTimeout); err != nil {
-				nodeResults.AddResult(host.NodeID, nil, err)
-				return
-			}
-			defer func() {
-				if err := host.Disconnect(); err != nil {
-					nodeResults.AddResult(host.NodeID, nil, err)
-				}
-			}()
-			if err := ssh.RunSSHSetupBuildEnv(host); err != nil {
-				nodeResults.AddResult(host.NodeID, nil, err)
-				return
-			}
-		}(&wgResults, host)
-	}
-	wg.Wait()
-	if wgResults.HasErrors() {
-		return fmt.Errorf("failed to get setup build env for node(s) %s", wgResults.GetErrorHostMap())
-	}
 	nonUpdatedNodes, err := doUpdateSubnet(clusterName, subnetName, models.FujiNetwork)
 	if err != nil {
 		return err