1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
|
//go:build !remote
package libimage
import (
"context"
"os"
"strings"
"testing"
"github.com/containers/common/pkg/config"
"github.com/stretchr/testify/require"
)
func TestSave(t *testing.T) {
runtime := testNewRuntime(t)
ctx := context.Background()
// Prefetch alpine, busybox.
pullOptions := &PullOptions{}
pullOptions.Writer = os.Stdout
_, err := runtime.Pull(ctx, "quay.io/libpod/alpine:latest", config.PullPolicyAlways, pullOptions)
require.NoError(t, err)
_, err = runtime.Pull(ctx, "quay.io/libpod/busybox:latest", config.PullPolicyAlways, pullOptions)
require.NoError(t, err)
// Save the two images into a multi-image archive. This way, we can
// reload the images for each test.
saveOptions := &SaveOptions{}
saveOptions.Writer = os.Stdout
imageCache, err := os.CreateTemp(t.TempDir(), "saveimagecache")
require.NoError(t, err)
imageCache.Close()
err = runtime.Save(ctx, []string{"alpine", "busybox"}, "docker-archive", imageCache.Name(), saveOptions)
require.NoError(t, err)
loadOptions := &LoadOptions{}
loadOptions.Writer = os.Stdout
// The table tests are smoke tests to exercise the different code
// paths. More detailed tests follow below.
for _, test := range []struct {
names []string
tags []string
format string
isDir bool
expectError bool
}{
// No `names`
{nil, nil, "", false, true},
{[]string{}, nil, "", false, true},
// Invalid/unsupported format
{[]string{"something"}, nil, "", false, true},
{[]string{"something"}, nil, "else", false, true},
// oci
{[]string{"busybox"}, nil, "oci-dir", true, false},
{[]string{"busybox"}, nil, "oci-archive", false, false},
// oci-archive doesn't support multi-image archives
{[]string{"busybox", "alpine"}, nil, "oci-archive", false, true},
// docker
{[]string{"busybox"}, nil, "docker-archive", false, false},
{[]string{"busybox"}, []string{"localhost/tag:1", "quay.io/repo/image:tag"}, "docker-archive", false, false},
{[]string{"busybox"}, nil, "docker-dir", true, false},
{[]string{"busybox", "alpine"}, nil, "docker-archive", false, false},
// additional tags and multi-images conflict
{[]string{"busybox", "alpine"}, []string{"tag"}, "docker-archive", false, true},
} {
// First clean up all images and load the cache.
_, rmErrors := runtime.RemoveImages(ctx, nil, nil)
require.Nil(t, rmErrors)
_, err = runtime.Load(ctx, imageCache.Name(), loadOptions)
require.NoError(t, err)
tmp := t.TempDir()
if !test.isDir {
tmp += "/archive.tar"
}
saveOptions.AdditionalTags = test.tags
err = runtime.Save(ctx, test.names, test.format, tmp, saveOptions)
if test.expectError {
require.Error(t, err, "%v", test)
continue
}
require.NoError(t, err, "%v", test)
// Now remove all images again and attempt to load the
// previously saved ones.
_, rmErrors = runtime.RemoveImages(ctx, nil, nil)
require.Nil(t, rmErrors)
namesAndTags := append(test.names, test.tags...) //nolint:gocritic // ignore "appendAssign: append result not assigned to the same slice"
loadedImages, err := runtime.Load(ctx, tmp, loadOptions)
require.NoError(t, err)
require.Len(t, loadedImages, len(namesAndTags))
// Now make sure that all specified names (and tags) resolve to
// an image the local containers storage. Note that names are
// only preserved in archives.
if strings.HasSuffix(test.format, "-dir") {
continue
}
_, err = runtime.ListImagesByNames(namesAndTags)
require.NoError(t, err, "%v", test)
}
}
|
