Function runCommandWithStreaming

internal/ui/plugins/ansible/plugin.go:2898–2947

(cmd *exec.Cmd, stream func(string))

}

func runCommandWithStreaming(cmd *exec.Cmd, stream func(string)) (string, error) {
	stdoutPipe, err := cmd.StdoutPipe()
	if err != nil {
		return "", fmt.Errorf("stdout pipe: %w", err)
	}
	stderrPipe, err := cmd.StderrPipe()
	if err != nil {
		return "", fmt.Errorf("stderr pipe: %w", err)
	}

	if err := cmd.Start(); err != nil {
		return "", err
	}

	var (
		wg sync.WaitGroup
		mu sync.Mutex
		b  bytes.Buffer
	)
	appendLine := func(line string) {
		mu.Lock()
		defer mu.Unlock()
		if b.Len() > 0 {
			b.WriteString("\n")
		}
		b.WriteString(line)
		if stream != nil {
			stream(line)
		}
	}
	readPipe := func(r io.Reader) {
		defer wg.Done()
		scanner := bufio.NewScanner(r)
		const maxScanToken = 1024 * 1024
		buf := make([]byte, 0, 64*1024)
		scanner.Buffer(buf, maxScanToken)
		for scanner.Scan() {
			appendLine(scanner.Text())
		}
	}

	wg.Add(2)
	go readPipe(stdoutPipe)
	go readPipe(stderrPipe)

	waitErr := cmd.Wait()
	wg.Wait()

	return b.String(), waitErr
}

func ansibleLogger() interface {
	Debug(format string, args ...interface{})