Function pushLocalImage

integration/integrationtest/docker.go:529–589

(t *testing.T, pool *dockertest.Pool, opts pushOptions)

}

func pushLocalImage(t *testing.T, pool *dockertest.Pool, opts pushOptions) RegistryImage {
	t.Helper()

	const registryHost = "127.0.0.1"
	name := filepath.Base(opts.RemoteImage)
	repoTag := strings.Split(name, ":")
	tag := "latest"
	if len(repoTag) == 2 {
		tag = repoTag[1]
	}

	tw := &testWriter{
		t: t,
	}
	err := pool.Client.PullImage(docker.PullImageOptions{
		Repository:   strings.Split(opts.RemoteImage, ":")[0],
		Tag:          tag,
		OutputStream: tw,
	}, docker.AuthConfiguration{})
	require.NoError(t, err)

	_, port, err := net.SplitHostPort(opts.Host)
	require.NoError(t, err)

	err = pool.Client.TagImage(opts.RemoteImage, docker.TagImageOptions{
		Repo: fmt.Sprintf("%s:%s/%s", registryHost, port, name),
		Tag:  tag,
	})
	require.NoError(t, err)

	type config struct {
		Auths map[string]dockerutil.AuthConfig `json:"auths"`
	}

	auth := base64.StdEncoding.EncodeToString([]byte(fmt.Sprintf("%s:%s", opts.Username, opts.Password)))

	cfg := config{
		Auths: map[string]dockerutil.AuthConfig{
			net.JoinHostPort(registryHost, port): {
				Username: opts.Username,
				Password: opts.Password,
				Auth:     auth,
			},
		},
	}
	b, err := json.Marshal(cfg)
	require.NoError(t, err)
	configPath := filepath.Join(opts.ConfigDir, "config.json")
	WriteFile(t, configPath, string(b))

	// Idk what to tell you but the pool.Client.PushImage
	// function is bugged or I'm just dumb...
	image := fmt.Sprintf("%s:%s/%s:%s", registryHost, port, name, tag)
	//nolint:gosec
	cmd := exec.Command("docker", "--config", opts.ConfigDir, "push", image)
	cmd.Stderr = tw
	cmd.Stdout = tw
	err = cmd.Run()