Function testDialStdio

tests/dialstdio.go:27–121

(t *testing.T, sb integration.Sandbox)

}

func testDialStdio(t *testing.T, sb integration.Sandbox) {
	do := func(t *testing.T, pipe func(t *testing.T, cmd *exec.Cmd) net.Conn) {
		errBuf := bytes.NewBuffer(nil)
		defer func() {
			if t.Failed() {
				t.Log(errBuf.String())
			}
		}()
		var cmd *exec.Cmd
		c, err := client.New(sb.Context(), "", client.WithContextDialer(func(ctx context.Context, _ string) (net.Conn, error) {
			cmd = buildxCmd(sb, withArgs("dial-stdio", "--progress", "auto"))
			conn := pipe(t, cmd)
			cmd.Stderr = errBuf
			if err := cmd.Start(); err != nil {
				return nil, errors.Wrap(err, errBuf.String())
			}

			return conn, nil
		}))
		require.NoError(t, err)

		defer func() {
			c.Close()
			// Since the client is closed (and as such the connection shutdown), the buildx command should exit cleanly.
			chErr := make(chan error, 1)
			go func() {
				chErr <- cmd.Wait()
			}()
			select {
			case <-time.After(10 * time.Second):
				t.Error("timeout waiting for buildx command to exit")
			case <-chErr:
				require.NoError(t, err)
			}
		}()

		skipNoCompatBuildKit(t, sb, ">= 0.11.0-0", "unknown method Info for service moby.buildkit.v1.Control")
		_, err = c.Info(sb.Context())
		require.NoError(t, err)

		require.Contains(t, errBuf.String(), "builder: "+sb.Address())

		dir := t.TempDir()

		f, err := os.CreateTemp(dir, "log")
		require.NoError(t, err)
		defer f.Close()

		defer func() {
			if t.Failed() {
				dt, _ := os.ReadFile(f.Name())
				t.Log(string(dt))
			}
		}()

		p, err := progress.NewPrinter(sb.Context(), f, progressui.AutoMode)
		require.NoError(t, err)