cli/cmd/nodecmd/deploy.go

// Copyright (C) 2025, Lux Industries, Inc. All rights reserved.
// See the file LICENSE for licensing terms.
package nodecmd

import (
	"fmt"

	"github.com/luxfi/cli/v2/pkg/node"

	"github.com/luxfi/cli/v2/cmd/blockchaincmd"
	"github.com/luxfi/cli/v2/pkg/ansible"
	"github.com/luxfi/cli/v2/pkg/cobrautils"
	"github.com/luxfi/cli/v2/pkg/models"
	"github.com/luxfi/cli/v2/pkg/networkoptions"
	"github.com/luxfi/cli/v2/pkg/ux"
	"github.com/spf13/cobra"
)

var (
	subnetOnly    bool
	avoidChecks   bool
	subnetAliases []string
)

func newDeployCmd() *cobra.Command {
	cmd := &cobra.Command{
		Use:   "deploy [clusterName] [subnetName]",
		Short: "(ALPHA Warning) Deploy a subnet into a devnet cluster",
		Long: `(ALPHA Warning) This command is currently in experimental mode.

The node devnet deploy command deploys a subnet into a devnet cluster, creating subnet and blockchain txs for it.
It saves the deploy info both locally and remotely.
`,
		Args: cobrautils.ExactArgs(2),
		RunE: deploySubnet,
	}
	cmd.Flags().BoolVar(&subnetOnly, "subnet-only", false, "only create a subnet")
	cmd.Flags().BoolVar(&avoidChecks, "no-checks", false, "do not check for healthy status or rpc compatibility of nodes against subnet")
	cmd.Flags().StringSliceVar(&subnetAliases, "subnet-aliases", nil, "additional subnet aliases to be used for RPC calls in addition to subnet blockchain name")
	return cmd
}

func deploySubnet(cmd *cobra.Command, args []string) error {
	clusterName := args[0]
	subnetName := args[1]
	if err := node.CheckCluster(app, clusterName); err != nil {
		return err
	}
	if _, err := blockchaincmd.ValidateSubnetNameAndGetChains([]string{subnetName}); err != nil {
		return err
	}
	clusterConfig, err := app.GetClusterConfig(clusterName)
	if err != nil {
		return err
	}
	if clusterConfig.Local {
		return notImplementedForLocal("deploy")
	}
	if clusterConfig.Network.Kind != models.Devnet {
		return fmt.Errorf("node deploy command must be applied to devnet clusters")
	}
	hosts, err := ansible.GetInventoryFromAnsibleInventoryFile(app.GetAnsibleInventoryDirPath(clusterName))
	if err != nil {
		return err
	}
	defer node.DisconnectHosts(hosts)
	if !avoidChecks {
		if err := node.CheckHostsAreHealthy(hosts); err != nil {
			return err
		}
		if err := node.CheckHostsAreRPCCompatible(app, hosts, subnetName); err != nil {
			return err
		}
	}
	networkFlags := networkoptions.NetworkFlags{
		ClusterName: clusterName,
	}
	keyNameParam := ""
	useLedgerParam := false
	useEwoqParam := true
	sameControlKey := true

	if err := blockchaincmd.CallDeploy(
		cmd,
		subnetOnly,
		subnetName,
		networkFlags,
		keyNameParam,
		useLedgerParam,
		useEwoqParam,
		sameControlKey,
	); err != nil {
		return err
	}
	if subnetOnly {
		ux.Logger.PrintToUser("Subnet successfully created!")
	} else {
		ux.Logger.PrintToUser("Blockchain successfully created!")
	}
	return nil
}