Method runBootstrapAccess

internal/ui/plugins/ansible/plugin.go:1097–1167

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

}

func (p *Plugin) runBootstrapAccess(
	inventory coreansible.InventoryResult,
	limit string,
	dryRun bool,
	extraArgs []string,
	timeout time.Duration,
) {
	if err := p.runner.CheckAvailability(); err != nil {
		p.app.ShowMessageSafe(fmt.Sprintf("Ansible is not available: %v", err))
		return
	}

	bootstrap := p.ansiblePluginConfig().Bootstrap
	playbookContent, err := p.buildBootstrapPlaybook(bootstrap)
	if err != nil {
		p.app.ShowMessageSafe(fmt.Sprintf("Bootstrap setup error: %v", err))
		return
	}

	playbookPath, cleanup, err := writeTempPlaybook(playbookContent)
	if err != nil {
		p.app.ShowMessageSafe(fmt.Sprintf("Failed to create bootstrap playbook: %v", err))
		return
	}

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

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

		opts := coreansible.PlaybookOptions{
			PlaybookPath: playbookPath,
			Limit:        strings.TrimSpace(limit),
			CheckMode:    dryRun,
			ExtraArgs:    append([]string{}, extraArgs...),
		}

		if bootstrap.Parallelism > 0 {
			opts.ExtraArgs = append(opts.ExtraArgs, "--forks", strconv.Itoa(bootstrap.Parallelism))
		}

		opts.ExtraArgs = p.mergeConfiguredAnsibleArgs(opts.ExtraArgs)
		p.runner.SetEnv(p.ansiblePluginConfig().Env)
		result := p.runner.RunPlaybookStream(
			ctx,
			inventory.Text,
			inventory.Format,
			opts,
			func(line string) {
				appendLiveLine(line)
				ansibleLogger().Debug("ansible bootstrap stream: %s", line)
			},
		)