mirror of
https://github.com/moby/moby.git
synced 2022-11-09 12:21:53 -05:00
429 lines
14 KiB
Go
429 lines
14 KiB
Go
package main
|
|
|
|
import (
|
|
"fmt"
|
|
"io/ioutil"
|
|
"os"
|
|
"os/exec"
|
|
"path/filepath"
|
|
"reflect"
|
|
"sort"
|
|
"strings"
|
|
"testing"
|
|
)
|
|
|
|
// save a repo using gz compression and try to load it using stdout
|
|
func TestSaveXzAndLoadRepoStdout(t *testing.T) {
|
|
tempDir, err := ioutil.TempDir("", "test-save-xz-gz-load-repo-stdout")
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
defer os.RemoveAll(tempDir)
|
|
|
|
tarballPath := filepath.Join(tempDir, "foobar-save-load-test.tar.xz.gz")
|
|
|
|
runCmd := exec.Command(dockerBinary, "run", "-d", "busybox", "true")
|
|
out, _, err := runCommandWithOutput(runCmd)
|
|
if err != nil {
|
|
t.Fatalf("failed to create a container: %v %v", out, err)
|
|
}
|
|
|
|
cleanedContainerID := stripTrailingCharacters(out)
|
|
|
|
repoName := "foobar-save-load-test-xz-gz"
|
|
|
|
inspectCmd := exec.Command(dockerBinary, "inspect", cleanedContainerID)
|
|
out, _, err = runCommandWithOutput(inspectCmd)
|
|
if err != nil {
|
|
t.Fatalf("output should've been a container id: %v %v", cleanedContainerID, err)
|
|
}
|
|
|
|
commitCmd := exec.Command(dockerBinary, "commit", cleanedContainerID, repoName)
|
|
out, _, err = runCommandWithOutput(commitCmd)
|
|
if err != nil {
|
|
t.Fatalf("failed to commit container: %v %v", out, err)
|
|
}
|
|
|
|
inspectCmd = exec.Command(dockerBinary, "inspect", repoName)
|
|
before, _, err := runCommandWithOutput(inspectCmd)
|
|
if err != nil {
|
|
t.Fatalf("the repo should exist before saving it: %v %v", before, err)
|
|
}
|
|
|
|
saveCmdTemplate := `%v save %v | xz -c | gzip -c > %s`
|
|
saveCmdFinal := fmt.Sprintf(saveCmdTemplate, dockerBinary, repoName, tarballPath)
|
|
saveCmd := exec.Command("bash", "-c", saveCmdFinal)
|
|
out, _, err = runCommandWithOutput(saveCmd)
|
|
if err != nil {
|
|
t.Fatalf("failed to save repo: %v %v", out, err)
|
|
}
|
|
|
|
deleteImages(repoName)
|
|
|
|
loadCmdFinal := fmt.Sprintf(`cat %s | docker load`, tarballPath)
|
|
loadCmd := exec.Command("bash", "-c", loadCmdFinal)
|
|
out, _, err = runCommandWithOutput(loadCmd)
|
|
if err == nil {
|
|
t.Fatalf("expected error, but succeeded with no error and output: %v", out)
|
|
}
|
|
|
|
inspectCmd = exec.Command(dockerBinary, "inspect", repoName)
|
|
after, _, err := runCommandWithOutput(inspectCmd)
|
|
if err == nil {
|
|
t.Fatalf("the repo should not exist: %v", after)
|
|
}
|
|
|
|
deleteContainer(cleanedContainerID)
|
|
deleteImages(repoName)
|
|
|
|
logDone("load - save a repo with xz compression & load it using stdout")
|
|
}
|
|
|
|
// save a repo using xz+gz compression and try to load it using stdout
|
|
func TestSaveXzGzAndLoadRepoStdout(t *testing.T) {
|
|
tempDir, err := ioutil.TempDir("", "test-save-xz-gz-load-repo-stdout")
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
defer os.RemoveAll(tempDir)
|
|
|
|
tarballPath := filepath.Join(tempDir, "foobar-save-load-test.tar.xz.gz")
|
|
|
|
runCmd := exec.Command(dockerBinary, "run", "-d", "busybox", "true")
|
|
out, _, err := runCommandWithOutput(runCmd)
|
|
if err != nil {
|
|
t.Fatalf("failed to create a container: %v %v", out, err)
|
|
}
|
|
|
|
cleanedContainerID := stripTrailingCharacters(out)
|
|
|
|
repoName := "foobar-save-load-test-xz-gz"
|
|
|
|
inspectCmd := exec.Command(dockerBinary, "inspect", cleanedContainerID)
|
|
out, _, err = runCommandWithOutput(inspectCmd)
|
|
if err != nil {
|
|
t.Fatalf("output should've been a container id: %v %v", cleanedContainerID, err)
|
|
}
|
|
|
|
commitCmd := exec.Command(dockerBinary, "commit", cleanedContainerID, repoName)
|
|
out, _, err = runCommandWithOutput(commitCmd)
|
|
if err != nil {
|
|
t.Fatalf("failed to commit container: %v %v", out, err)
|
|
}
|
|
|
|
inspectCmd = exec.Command(dockerBinary, "inspect", repoName)
|
|
before, _, err := runCommandWithOutput(inspectCmd)
|
|
if err != nil {
|
|
t.Fatalf("the repo should exist before saving it: %v %v", before, err)
|
|
}
|
|
|
|
saveCmdTemplate := `%v save %v | xz -c | gzip -c > %s`
|
|
saveCmdFinal := fmt.Sprintf(saveCmdTemplate, dockerBinary, repoName, tarballPath)
|
|
saveCmd := exec.Command("bash", "-c", saveCmdFinal)
|
|
out, _, err = runCommandWithOutput(saveCmd)
|
|
if err != nil {
|
|
t.Fatalf("failed to save repo: %v %v", out, err)
|
|
}
|
|
|
|
deleteImages(repoName)
|
|
|
|
loadCmdFinal := fmt.Sprintf(`cat %s | docker load`, tarballPath)
|
|
loadCmd := exec.Command("bash", "-c", loadCmdFinal)
|
|
out, _, err = runCommandWithOutput(loadCmd)
|
|
if err == nil {
|
|
t.Fatalf("expected error, but succeeded with no error and output: %v", out)
|
|
}
|
|
|
|
inspectCmd = exec.Command(dockerBinary, "inspect", repoName)
|
|
after, _, err := runCommandWithOutput(inspectCmd)
|
|
if err == nil {
|
|
t.Fatalf("the repo should not exist: %v", after)
|
|
}
|
|
|
|
deleteContainer(cleanedContainerID)
|
|
deleteImages(repoName)
|
|
|
|
logDone("load - save a repo with xz+gz compression & load it using stdout")
|
|
}
|
|
|
|
func TestSaveSingleTag(t *testing.T) {
|
|
repoName := "foobar-save-single-tag-test"
|
|
|
|
tagCmdFinal := fmt.Sprintf("%v tag busybox:latest %v:latest", dockerBinary, repoName)
|
|
tagCmd := exec.Command("bash", "-c", tagCmdFinal)
|
|
if out, _, err := runCommandWithOutput(tagCmd); err != nil {
|
|
t.Fatalf("failed to tag repo: %s, %v", out, err)
|
|
}
|
|
|
|
idCmdFinal := fmt.Sprintf("%v images -q --no-trunc %v", dockerBinary, repoName)
|
|
idCmd := exec.Command("bash", "-c", idCmdFinal)
|
|
out, _, err := runCommandWithOutput(idCmd)
|
|
if err != nil {
|
|
t.Fatalf("failed to get repo ID: %s, %v", out, err)
|
|
}
|
|
|
|
cleanedImageID := stripTrailingCharacters(out)
|
|
|
|
saveCmdFinal := fmt.Sprintf("%v save %v:latest | tar t | grep -E '(^repositories$|%v)'", dockerBinary, repoName, cleanedImageID)
|
|
saveCmd := exec.Command("bash", "-c", saveCmdFinal)
|
|
if out, _, err = runCommandWithOutput(saveCmd); err != nil {
|
|
t.Fatalf("failed to save repo with image ID and 'repositories' file: %s, %v", out, err)
|
|
}
|
|
|
|
deleteImages(repoName)
|
|
|
|
logDone("save - save a specific image:tag")
|
|
}
|
|
|
|
func TestSaveImageId(t *testing.T) {
|
|
repoName := "foobar-save-image-id-test"
|
|
|
|
tagCmdFinal := fmt.Sprintf("%v tag emptyfs:latest %v:latest", dockerBinary, repoName)
|
|
tagCmd := exec.Command("bash", "-c", tagCmdFinal)
|
|
if out, _, err := runCommandWithOutput(tagCmd); err != nil {
|
|
t.Fatalf("failed to tag repo: %s, %v", out, err)
|
|
}
|
|
|
|
idLongCmdFinal := fmt.Sprintf("%v images -q --no-trunc %v", dockerBinary, repoName)
|
|
idLongCmd := exec.Command("bash", "-c", idLongCmdFinal)
|
|
out, _, err := runCommandWithOutput(idLongCmd)
|
|
if err != nil {
|
|
t.Fatalf("failed to get repo ID: %s, %v", out, err)
|
|
}
|
|
|
|
cleanedLongImageID := stripTrailingCharacters(out)
|
|
|
|
idShortCmdFinal := fmt.Sprintf("%v images -q %v", dockerBinary, repoName)
|
|
idShortCmd := exec.Command("bash", "-c", idShortCmdFinal)
|
|
out, _, err = runCommandWithOutput(idShortCmd)
|
|
if err != nil {
|
|
t.Fatalf("failed to get repo short ID: %s, %v", out, err)
|
|
}
|
|
|
|
cleanedShortImageID := stripTrailingCharacters(out)
|
|
|
|
saveCmdFinal := fmt.Sprintf("%v save %v | tar t | grep %v", dockerBinary, cleanedShortImageID, cleanedLongImageID)
|
|
saveCmd := exec.Command("bash", "-c", saveCmdFinal)
|
|
if out, _, err = runCommandWithOutput(saveCmd); err != nil {
|
|
t.Fatalf("failed to save repo with image ID: %s, %v", out, err)
|
|
}
|
|
|
|
deleteImages(repoName)
|
|
|
|
logDone("save - save a image by ID")
|
|
}
|
|
|
|
// save a repo and try to load it using flags
|
|
func TestSaveAndLoadRepoFlags(t *testing.T) {
|
|
runCmd := exec.Command(dockerBinary, "run", "-d", "busybox", "true")
|
|
out, _, err := runCommandWithOutput(runCmd)
|
|
if err != nil {
|
|
t.Fatalf("failed to create a container: %s, %v", out, err)
|
|
}
|
|
|
|
cleanedContainerID := stripTrailingCharacters(out)
|
|
|
|
repoName := "foobar-save-load-test"
|
|
|
|
inspectCmd := exec.Command(dockerBinary, "inspect", cleanedContainerID)
|
|
if out, _, err = runCommandWithOutput(inspectCmd); err != nil {
|
|
t.Fatalf("output should've been a container id: %s, %v", out, err)
|
|
}
|
|
|
|
commitCmd := exec.Command(dockerBinary, "commit", cleanedContainerID, repoName)
|
|
if out, _, err = runCommandWithOutput(commitCmd); err != nil {
|
|
t.Fatalf("failed to commit container: %s, %v", out, err)
|
|
}
|
|
|
|
inspectCmd = exec.Command(dockerBinary, "inspect", repoName)
|
|
before, _, err := runCommandWithOutput(inspectCmd)
|
|
if err != nil {
|
|
t.Fatalf("the repo should exist before saving it: %s, %v", before, err)
|
|
}
|
|
|
|
saveCmdTemplate := `%v save -o /tmp/foobar-save-load-test.tar %v`
|
|
saveCmdFinal := fmt.Sprintf(saveCmdTemplate, dockerBinary, repoName)
|
|
saveCmd := exec.Command("bash", "-c", saveCmdFinal)
|
|
if out, _, err = runCommandWithOutput(saveCmd); err != nil {
|
|
t.Fatalf("failed to save repo: %s, %v", out, err)
|
|
}
|
|
|
|
deleteImages(repoName)
|
|
|
|
loadCmdFinal := `docker load -i /tmp/foobar-save-load-test.tar`
|
|
loadCmd := exec.Command("bash", "-c", loadCmdFinal)
|
|
if out, _, err = runCommandWithOutput(loadCmd); err != nil {
|
|
t.Fatalf("failed to load repo: %s, %v", out, err)
|
|
}
|
|
|
|
inspectCmd = exec.Command(dockerBinary, "inspect", repoName)
|
|
after, _, err := runCommandWithOutput(inspectCmd)
|
|
if err != nil {
|
|
t.Fatalf("the repo should exist after loading it: %s, %v", after, err)
|
|
}
|
|
|
|
if before != after {
|
|
t.Fatalf("inspect is not the same after a save / load")
|
|
}
|
|
|
|
deleteContainer(cleanedContainerID)
|
|
deleteImages(repoName)
|
|
|
|
os.Remove("/tmp/foobar-save-load-test.tar")
|
|
|
|
logDone("save - save a repo using -o && load a repo using -i")
|
|
}
|
|
|
|
func TestSaveMultipleNames(t *testing.T) {
|
|
repoName := "foobar-save-multi-name-test"
|
|
|
|
// Make one image
|
|
tagCmdFinal := fmt.Sprintf("%v tag emptyfs:latest %v-one:latest", dockerBinary, repoName)
|
|
tagCmd := exec.Command("bash", "-c", tagCmdFinal)
|
|
if out, _, err := runCommandWithOutput(tagCmd); err != nil {
|
|
t.Fatalf("failed to tag repo: %s, %v", out, err)
|
|
}
|
|
defer deleteImages(repoName + "-one")
|
|
|
|
// Make two images
|
|
tagCmdFinal = fmt.Sprintf("%v tag emptyfs:latest %v-two:latest", dockerBinary, repoName)
|
|
tagCmd = exec.Command("bash", "-c", tagCmdFinal)
|
|
if out, _, err := runCommandWithOutput(tagCmd); err != nil {
|
|
t.Fatalf("failed to tag repo: %s, %v", out, err)
|
|
}
|
|
defer deleteImages(repoName + "-two")
|
|
|
|
saveCmdFinal := fmt.Sprintf("%v save %v-one %v-two:latest | tar xO repositories | grep -q -E '(-one|-two)'", dockerBinary, repoName, repoName)
|
|
saveCmd := exec.Command("bash", "-c", saveCmdFinal)
|
|
if out, _, err := runCommandWithOutput(saveCmd); err != nil {
|
|
t.Fatalf("failed to save multiple repos: %s, %v", out, err)
|
|
}
|
|
|
|
deleteImages(repoName)
|
|
|
|
logDone("save - save by multiple names")
|
|
}
|
|
|
|
func TestSaveRepoWithMultipleImages(t *testing.T) {
|
|
|
|
makeImage := func(from string, tag string) string {
|
|
runCmd := exec.Command(dockerBinary, "run", "-d", from, "true")
|
|
var (
|
|
out string
|
|
err error
|
|
)
|
|
if out, _, err = runCommandWithOutput(runCmd); err != nil {
|
|
t.Fatalf("failed to create a container: %v %v", out, err)
|
|
}
|
|
cleanedContainerID := stripTrailingCharacters(out)
|
|
|
|
commitCmd := exec.Command(dockerBinary, "commit", cleanedContainerID, tag)
|
|
if out, _, err = runCommandWithOutput(commitCmd); err != nil {
|
|
t.Fatalf("failed to commit container: %v %v", out, err)
|
|
}
|
|
imageID := stripTrailingCharacters(out)
|
|
|
|
deleteContainer(cleanedContainerID)
|
|
return imageID
|
|
}
|
|
|
|
repoName := "foobar-save-multi-images-test"
|
|
tagFoo := repoName + ":foo"
|
|
tagBar := repoName + ":bar"
|
|
|
|
idFoo := makeImage("busybox:latest", tagFoo)
|
|
idBar := makeImage("busybox:latest", tagBar)
|
|
|
|
deleteImages(repoName)
|
|
|
|
// create the archive
|
|
saveCmdFinal := fmt.Sprintf("%v save %v | tar t | grep 'VERSION' |cut -d / -f1", dockerBinary, repoName)
|
|
saveCmd := exec.Command("bash", "-c", saveCmdFinal)
|
|
out, _, err := runCommandWithOutput(saveCmd)
|
|
if err != nil {
|
|
t.Fatalf("failed to save multiple images: %s, %v", out, err)
|
|
}
|
|
actual := strings.Split(stripTrailingCharacters(out), "\n")
|
|
|
|
// make the list of expected layers
|
|
historyCmdFinal := fmt.Sprintf("%v history -q --no-trunc %v", dockerBinary, "busybox:latest")
|
|
historyCmd := exec.Command("bash", "-c", historyCmdFinal)
|
|
out, _, err = runCommandWithOutput(historyCmd)
|
|
if err != nil {
|
|
t.Fatalf("failed to get history: %s, %v", out, err)
|
|
}
|
|
|
|
expected := append(strings.Split(stripTrailingCharacters(out), "\n"), idFoo, idBar)
|
|
|
|
sort.Strings(actual)
|
|
sort.Strings(expected)
|
|
if !reflect.DeepEqual(expected, actual) {
|
|
t.Fatalf("achive does not contains the right layers: got %v, expected %v", actual, expected)
|
|
}
|
|
|
|
logDone("save - save repository with multiple images")
|
|
}
|
|
|
|
// Issue #6722 #5892 ensure directories are included in changes
|
|
func TestSaveDirectoryPermissions(t *testing.T) {
|
|
layerEntries := []string{"opt/", "opt/a/", "opt/a/b/", "opt/a/b/c"}
|
|
layerEntriesAUFS := []string{"./", ".wh..wh.aufs", ".wh..wh.orph/", ".wh..wh.plnk/", "opt/", "opt/a/", "opt/a/b/", "opt/a/b/c"}
|
|
|
|
name := "save-directory-permissions"
|
|
tmpDir, err := ioutil.TempDir("", "save-layers-with-directories")
|
|
if err != nil {
|
|
t.Errorf("failed to create temporary directory: %s", err)
|
|
}
|
|
extractionDirectory := filepath.Join(tmpDir, "image-extraction-dir")
|
|
os.Mkdir(extractionDirectory, 0777)
|
|
|
|
defer os.RemoveAll(tmpDir)
|
|
defer deleteImages(name)
|
|
_, err = buildImage(name,
|
|
`FROM busybox
|
|
RUN adduser -D user && mkdir -p /opt/a/b && chown -R user:user /opt/a
|
|
RUN touch /opt/a/b/c && chown user:user /opt/a/b/c`,
|
|
true)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
|
|
saveCmdFinal := fmt.Sprintf("%s save %s | tar -xf - -C %s", dockerBinary, name, extractionDirectory)
|
|
saveCmd := exec.Command("bash", "-c", saveCmdFinal)
|
|
if out, _, err := runCommandWithOutput(saveCmd); err != nil {
|
|
t.Errorf("failed to save and extract image: %s", out)
|
|
}
|
|
|
|
dirs, err := ioutil.ReadDir(extractionDirectory)
|
|
if err != nil {
|
|
t.Errorf("failed to get a listing of the layer directories: %s", err)
|
|
}
|
|
|
|
found := false
|
|
for _, entry := range dirs {
|
|
if entry.IsDir() {
|
|
layerPath := filepath.Join(extractionDirectory, entry.Name(), "layer.tar")
|
|
|
|
f, err := os.Open(layerPath)
|
|
if err != nil {
|
|
t.Fatalf("failed to open %s: %s", layerPath, err)
|
|
}
|
|
|
|
entries, err := ListTar(f)
|
|
if err != nil {
|
|
t.Fatalf("encountered error while listing tar entries: %s", err)
|
|
}
|
|
|
|
if reflect.DeepEqual(entries, layerEntries) || reflect.DeepEqual(entries, layerEntriesAUFS) {
|
|
found = true
|
|
break
|
|
}
|
|
}
|
|
}
|
|
|
|
if !found {
|
|
t.Fatalf("failed to find the layer with the right content listing")
|
|
}
|
|
|
|
logDone("save - ensure directories exist in exported layers")
|
|
}
|