mirror of https://github.com/docker/cli.git
update image pull tests
Signed-off-by: Riyaz Faizullabhoy <riyaz.faizullabhoy@docker.com>
This commit is contained in:
parent
ade675d36c
commit
46f3d8bb7f
|
@ -1,51 +0,0 @@
|
||||||
package container
|
|
||||||
|
|
||||||
import (
|
|
||||||
"fmt"
|
|
||||||
"os"
|
|
||||||
"strings"
|
|
||||||
"testing"
|
|
||||||
|
|
||||||
"github.com/gotestyourself/gotestyourself/icmd"
|
|
||||||
)
|
|
||||||
|
|
||||||
const notaryURL = "https://notary-server:4443"
|
|
||||||
const registryPrefix = "registry:5000"
|
|
||||||
|
|
||||||
func TestPullWithContentTrust(t *testing.T) {
|
|
||||||
image := createTrustedRemoteImage(t, "trust", "latest")
|
|
||||||
icmd.RunCmd(trustedCmdNoPassphrases(icmd.Command("docker", "pull", image))).Assert(t, icmd.Success)
|
|
||||||
|
|
||||||
// test that pulling without the tag defaults to latest
|
|
||||||
imageWithoutTag := strings.TrimSuffix(image, ":latest")
|
|
||||||
icmd.RunCmd(trustedCmdNoPassphrases(icmd.Command("docker", "pull", imageWithoutTag))).Assert(t, icmd.Success)
|
|
||||||
}
|
|
||||||
|
|
||||||
func createTrustedRemoteImage(t *testing.T, repo, tag string) string {
|
|
||||||
image := fmt.Sprintf("%s/%s:%s", registryPrefix, repo, tag)
|
|
||||||
icmd.RunCommand("docker", "pull", alpineImage).Assert(t, icmd.Success)
|
|
||||||
icmd.RunCommand("docker", "tag", alpineImage, image).Assert(t, icmd.Success)
|
|
||||||
icmd.RunCmd(trustedCmdWithPassphrases(icmd.Command("docker", "push", image), "root_password", "repo_password")).Assert(t, icmd.Success)
|
|
||||||
icmd.RunCommand("docker", "rmi", image).Assert(t, icmd.Success)
|
|
||||||
return image
|
|
||||||
}
|
|
||||||
|
|
||||||
func trustedCmdWithPassphrases(cmd icmd.Cmd, rootPwd, repositoryPwd string) icmd.Cmd {
|
|
||||||
env := append(os.Environ(), []string{
|
|
||||||
"DOCKER_CONTENT_TRUST=1",
|
|
||||||
fmt.Sprintf("DOCKER_CONTENT_TRUST_SERVER=%s", notaryURL),
|
|
||||||
fmt.Sprintf("DOCKER_CONTENT_TRUST_ROOT_PASSPHRASE=%s", rootPwd),
|
|
||||||
fmt.Sprintf("DOCKER_CONTENT_TRUST_REPOSITORY_PASSPHRASE=%s", repositoryPwd),
|
|
||||||
}...)
|
|
||||||
cmd.Env = append(cmd.Env, env...)
|
|
||||||
return cmd
|
|
||||||
}
|
|
||||||
|
|
||||||
func trustedCmdNoPassphrases(cmd icmd.Cmd) icmd.Cmd {
|
|
||||||
env := append(os.Environ(), []string{
|
|
||||||
"DOCKER_CONTENT_TRUST=1",
|
|
||||||
fmt.Sprintf("DOCKER_CONTENT_TRUST_SERVER=%s", notaryURL),
|
|
||||||
}...)
|
|
||||||
cmd.Env = append(cmd.Env, env...)
|
|
||||||
return cmd
|
|
||||||
}
|
|
|
@ -0,0 +1,17 @@
|
||||||
|
package image
|
||||||
|
|
||||||
|
import (
|
||||||
|
"fmt"
|
||||||
|
"os"
|
||||||
|
"testing"
|
||||||
|
|
||||||
|
"github.com/docker/cli/internal/test/environment"
|
||||||
|
)
|
||||||
|
|
||||||
|
func TestMain(m *testing.M) {
|
||||||
|
if err := environment.Setup(); err != nil {
|
||||||
|
fmt.Println(err.Error())
|
||||||
|
os.Exit(3)
|
||||||
|
}
|
||||||
|
os.Exit(m.Run())
|
||||||
|
}
|
|
@ -0,0 +1,75 @@
|
||||||
|
package image
|
||||||
|
|
||||||
|
import (
|
||||||
|
"fmt"
|
||||||
|
"os"
|
||||||
|
"strings"
|
||||||
|
"testing"
|
||||||
|
|
||||||
|
"github.com/gotestyourself/gotestyourself/icmd"
|
||||||
|
"github.com/stretchr/testify/require"
|
||||||
|
)
|
||||||
|
|
||||||
|
const notaryURL = "https://notary-server:4443"
|
||||||
|
const registryPrefix = "registry:5000"
|
||||||
|
|
||||||
|
const alpineImage = "registry:5000/alpine:3.6"
|
||||||
|
const busyboxImage = "registry:5000/busybox:1.27.2"
|
||||||
|
|
||||||
|
func TestPullWithContentTrust(t *testing.T) {
|
||||||
|
image := createTrustedRemoteImage(t, "trust", "latest")
|
||||||
|
|
||||||
|
// test that pulling without the tag defaults to latest
|
||||||
|
imageWithoutTag := strings.TrimSuffix(image, ":latest")
|
||||||
|
icmd.RunCmd(trustedCmdNoPassphrases(icmd.Command("docker", "pull", imageWithoutTag))).Assert(t, icmd.Success)
|
||||||
|
icmd.RunCommand("docker", "rmi", image).Assert(t, icmd.Success)
|
||||||
|
|
||||||
|
// try pulling with the tag, record output for comparison later
|
||||||
|
result := icmd.RunCmd(trustedCmdNoPassphrases(icmd.Command("docker", "pull", image)))
|
||||||
|
result.Assert(t, icmd.Success)
|
||||||
|
firstPullOutput := result.String()
|
||||||
|
icmd.RunCommand("docker", "rmi", image).Assert(t, icmd.Success)
|
||||||
|
|
||||||
|
// push an unsigned image on the same reference name, but with different content (busybox)
|
||||||
|
icmd.RunCommand("docker", "pull", busyboxImage).Assert(t, icmd.Success)
|
||||||
|
icmd.RunCommand("docker", "tag", busyboxImage, image).Assert(t, icmd.Success)
|
||||||
|
icmd.RunCommand("docker", "push", image).Assert(t, icmd.Success)
|
||||||
|
icmd.RunCommand("docker", "rmi", image).Assert(t, icmd.Success)
|
||||||
|
|
||||||
|
// now pull with content trust
|
||||||
|
result = icmd.RunCmd(trustedCmdNoPassphrases(icmd.Command("docker", "pull", image)))
|
||||||
|
result.Assert(t, icmd.Success)
|
||||||
|
secondPullOutput := result.String()
|
||||||
|
|
||||||
|
// assert that the digest and other output is the same since we ignore the unsigned image
|
||||||
|
require.Equal(t, firstPullOutput, secondPullOutput)
|
||||||
|
}
|
||||||
|
|
||||||
|
func createTrustedRemoteImage(t *testing.T, repo, tag string) string {
|
||||||
|
image := fmt.Sprintf("%s/%s:%s", registryPrefix, repo, tag)
|
||||||
|
icmd.RunCommand("docker", "pull", alpineImage).Assert(t, icmd.Success)
|
||||||
|
icmd.RunCommand("docker", "tag", alpineImage, image).Assert(t, icmd.Success)
|
||||||
|
icmd.RunCmd(trustedCmdWithPassphrases(icmd.Command("docker", "push", image), "root_password", "repo_password")).Assert(t, icmd.Success)
|
||||||
|
icmd.RunCommand("docker", "rmi", image).Assert(t, icmd.Success)
|
||||||
|
return image
|
||||||
|
}
|
||||||
|
|
||||||
|
func trustedCmdWithPassphrases(cmd icmd.Cmd, rootPwd, repositoryPwd string) icmd.Cmd {
|
||||||
|
env := append(os.Environ(), []string{
|
||||||
|
"DOCKER_CONTENT_TRUST=1",
|
||||||
|
"DOCKER_CONTENT_TRUST_SERVER=" + notaryURL,
|
||||||
|
"DOCKER_CONTENT_TRUST_ROOT_PASSPHRASE=" + rootPwd,
|
||||||
|
"DOCKER_CONTENT_TRUST_REPOSITORY_PASSPHRASE=" + repositoryPwd,
|
||||||
|
}...)
|
||||||
|
cmd.Env = append(cmd.Env, env...)
|
||||||
|
return cmd
|
||||||
|
}
|
||||||
|
|
||||||
|
func trustedCmdNoPassphrases(cmd icmd.Cmd) icmd.Cmd {
|
||||||
|
env := append(os.Environ(), []string{
|
||||||
|
"DOCKER_CONTENT_TRUST=1",
|
||||||
|
"DOCKER_CONTENT_TRUST_SERVER=" + notaryURL,
|
||||||
|
}...)
|
||||||
|
cmd.Env = append(cmd.Env, env...)
|
||||||
|
return cmd
|
||||||
|
}
|
|
@ -0,0 +1,8 @@
|
||||||
|
#!/usr/bin/env bash
|
||||||
|
set -eu -o pipefail
|
||||||
|
|
||||||
|
src=busybox@sha256:3e8fa85ddfef1af9ca85a5cfb714148956984e02f00bec3f7f49d3925a91e0e7
|
||||||
|
dest=registry:5000/busybox:1.27.2
|
||||||
|
docker pull $src
|
||||||
|
docker tag $src $dest
|
||||||
|
docker push $dest
|
|
@ -23,6 +23,7 @@ function setup {
|
||||||
export DOCKER_HOST="$engine_host"
|
export DOCKER_HOST="$engine_host"
|
||||||
timeout -t 200 ./scripts/test/e2e/wait-on-daemon
|
timeout -t 200 ./scripts/test/e2e/wait-on-daemon
|
||||||
./scripts/test/e2e/load-alpine
|
./scripts/test/e2e/load-alpine
|
||||||
|
./scripts/test/e2e/load-busybox
|
||||||
is_swarm_enabled || docker swarm init
|
is_swarm_enabled || docker swarm init
|
||||||
) >&2
|
) >&2
|
||||||
echo "$engine_host"
|
echo "$engine_host"
|
||||||
|
|
|
@ -23,7 +23,7 @@ docker build \
|
||||||
-f dockerfiles/Dockerfile.dev .
|
-f dockerfiles/Dockerfile.dev .
|
||||||
|
|
||||||
notary_volume="${unique_id}_notary-fixtures"
|
notary_volume="${unique_id}_notary-fixtures"
|
||||||
docker volume create "$notary_volume"
|
docker volume create --name "$notary_volume"
|
||||||
docker run --rm \
|
docker run --rm \
|
||||||
-v "$PWD:/go/src/github.com/docker/cli" \
|
-v "$PWD:/go/src/github.com/docker/cli" \
|
||||||
-v "$notary_volume:/data" \
|
-v "$notary_volume:/data" \
|
||||||
|
|
Loading…
Reference in New Issue