Function captureOutput

pkg/cli/checks_command_test.go:566–609

(t *testing.T, fn func() error)

}

func captureOutput(t *testing.T, fn func() error) (string, string) {
	t.Helper()
	// Do not call this helper from tests using t.Parallel; it manipulates
	// process-global stdout/stderr and must be serialized.
	captureOutputMu.Lock()
	defer captureOutputMu.Unlock()

	stdoutReader, stdoutWriter, err := os.Pipe()
	require.NoError(t, err, "should create stdout pipe")

	stderrReader, stderrWriter, err := os.Pipe()
	require.NoError(t, err, "should create stderr pipe")
	t.Cleanup(func() {
		_ = stdoutReader.Close()
		_ = stderrReader.Close()
	})

	origStdout := os.Stdout
	origStderr := os.Stderr
	var runErr error
	func() {
		os.Stdout = stdoutWriter
		os.Stderr = stderrWriter
		defer func() {
			os.Stdout = origStdout
			os.Stderr = origStderr
			_ = stdoutWriter.Close()
			_ = stderrWriter.Close()
		}()

		runErr = fn()
	}()
	require.NoError(t, runErr, "output function should not return an error")

	var stdoutBuf bytes.Buffer
	_, err = io.Copy(&stdoutBuf, stdoutReader)
	require.NoError(t, err, "should read stdout output")

	var stderrBuf bytes.Buffer
	_, err = io.Copy(&stderrBuf, stderrReader)
	require.NoError(t, err, "should read stderr output")

	return stdoutBuf.String(), stderrBuf.String()
}