Method runBootstrapDirect

internal/ui/plugins/ansible/plugin.go:1181–1289

(
	inventory coreansible.InventoryResult,
	limit string,
	dryRun bool,
	timeout time.Duration,
)

}

func (p *Plugin) runBootstrapDirect(
	inventory coreansible.InventoryResult,
	limit string,
	dryRun bool,
	timeout time.Duration,
) {
	bootstrap := p.ansiblePluginConfig().Bootstrap
	targets := selectDirectBootstrapTargets(inventory.Hosts, limit)
	if len(targets) == 0 {
		p.app.ShowMessageSafe("No matching bootstrap targets for the selected scope/limit.")
		return
	}

	var keyContent string
	if bootstrap.InstallAuthorizedKey {
		keyPath := strings.TrimSpace(bootstrap.SSHPublicKeyFile)
		if keyPath == "" {
			p.app.ShowMessageSafe("Bootstrap ssh_public_key_file is required when install_authorized_key is enabled.")
			return
		}
		// #nosec G304 -- path is a local, user-configured key file for bootstrap.
		data, err := os.ReadFile(keyPath)
		if err != nil {
			p.app.ShowMessageSafe(fmt.Sprintf("Failed to read SSH public key file: %v", err))
			return
		}
		keyContent = strings.TrimSpace(string(data))
		if keyContent == "" {
			p.app.ShowMessageSafe("SSH public key file is empty.")
			return
		}
	}

	appendLiveLine, closeLive := p.showLiveOutputModal("Running direct bootstrap workflow...")
	ctx, cancel := context.WithTimeout(context.Background(), timeout)
	p.setRunningCancel(cancel)

	go func() {
		defer cancel()
		defer p.clearRunningCancel()

		results := make([]directBootstrapResult, len(targets))
		parallelism := bootstrap.Parallelism
		if parallelism <= 0 {
			parallelism = 1
		}
		sem := make(chan struct{}, parallelism)
		var wg sync.WaitGroup

		nodeByName := map[string]coreansible.InventoryHost{}
		for _, host := range inventory.Hosts {
			if host.Vars["pvetui_kind"] == hostKindNode {
				nodeByName[host.Vars["pvetui_node"]] = host
			}
		}
		guestByNodeID := map[string]*api.VM{}
		for _, vm := range p.app.VMList().GetVMs() {
			if vm == nil {