Function runCommunityScriptsInstall

internal/cli/community_scripts.go:232–346

(cmd *cobra.Command, args []string)

}

func runCommunityScriptsInstall(cmd *cobra.Command, args []string) error {
	session, err := initCLISession(cmd)
	if err != nil {
		return printError(err)
	}
	if session == nil {
		return nil
	}
	if err := ensureCommunityScriptsEnabled(session); err != nil {
		return printError(err)
	}

	nodeName, _ := cmd.Flags().GetString("node")
	skipURLCheck, _ := cmd.Flags().GetBool("skip-url-check")
	env, err := parseCommunityScriptEnvFlags(cmd)
	if err != nil {
		return printError(err)
	}
	nonInteractive := communityScriptNonInteractive(cmd)

	ctx := context.Background()
	node, err := session.findNodeByName(ctx, nodeName)
	if err != nil {
		return printError(err)
	}
	if !node.Online {
		return printError(fmt.Errorf("node %q is offline", nodeName))
	}

	script, err := findCommunityScript(args[0])
	if err != nil {
		return printError(err)
	}
	if err := validateCommunityScriptInstall(script); err != nil {
		return printError(err)
	}
	if !skipURLCheck {
		ok, err := core.ScriptURLExists(script)
		if err != nil {
			return printError(fmt.Errorf("failed to verify script URL: %w", err))
		}
		if !ok {
			return printError(fmt.Errorf("script URL not found: %s", core.RawScriptURL(script)))
		}
	}

	sshUser, jumpHost := session.resolveNodeSSHCreds(node)
	if sshUser == "" {
		return printError(fmt.Errorf("SSH user not configured; set ssh_user in config or use --ssh-user"))
	}

	host := node.IP
	if host == "" {
		host = node.Name
	}

	var warnings []string
	beforeVMs, beforeErr := session.getVMs(ctx)