Function runGuestsExec

internal/cli/guests.go:502–593

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

}

func runGuestsExec(cmd *cobra.Command, args []string) error {
	vmid, err := parseVMID(args[0])
	if err != nil {
		return printError(err)
	}

	command := args[1]
	timeout, _ := cmd.Flags().GetDuration("timeout")

	session, initErr := initCLISession(cmd)
	if initErr != nil {
		return printError(initErr)
	}

	if session == nil {
		return nil
	}

	ctx := context.Background()

	vm, err := session.findVM(ctx, vmid)
	if err != nil {
		return printError(err)
	}

	if vm.Type != api.VMTypeQemu && vm.Type != api.VMTypeLXC {
		return printError(fmt.Errorf("guest %d is type %q; exec is only supported for QEMU VMs and LXC containers", vmid, vm.Type))
	}

	if vm.Status != api.VMStatusRunning {
		return printError(fmt.Errorf("guest %d is not running (status: %s)", vmid, vm.Status))
	}

	execCtx, cancel := context.WithTimeout(ctx, timeout)
	defer cancel()

	start := time.Now()

	var stdout, stderr string
	var exitCode int

	if vm.Type == api.VMTypeLXC {
		stdout, stderr, exitCode, err = session.execLXC(execCtx, vm, []string{"/bin/sh", "-c", command}, timeout)
		if err != nil {
			return printError(fmt.Errorf("exec failed on LXC %d: %w", vmid, err))
		}
	} else {
		if !vm.AgentEnabled || !vm.AgentRunning {
			return printError(fmt.Errorf("guest agent is not available on VM %d (enabled: %v, running: %v)", vmid, vm.AgentEnabled, vm.AgentRunning))
		}

		client, clientErr := session.clientForVM(vm)
		if clientErr != nil {
			return printError(clientErr)
		}

		cmdParts := buildExecCommand(vm.OSType, command)
		stdout, stderr, exitCode, err = client.ExecuteGuestAgentCommand(execCtx, vm, cmdParts, timeout)