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
107
108
109
110
|
// Copyright (c) 2020, Sylabs Inc. All rights reserved.
// This software is licensed under a 3-clause BSD license. Please consult the
// LICENSE.md file distributed with the sources of this project regarding your
// rights to use or distribute this software.
package cache
import (
"net/http"
"net/http/httptest"
"os"
"path"
"path/filepath"
"testing"
"github.com/sylabs/singularity/v4/e2e/internal/e2e"
"github.com/sylabs/singularity/v4/internal/pkg/util/fs"
)
// issue5097 - need to handle an existing directory entry present in the cache
// from older singularity versions.
func (c cacheTests) issue5097(t *testing.T) {
imgCacheDir, cleanCache := e2e.MakeCacheDir(t, c.env.TestDir)
defer cleanCache(t)
c.env.UnprivCacheDir = imgCacheDir
tempDir, imgStoreCleanup := e2e.MakeTempDir(t, "", "", "image store")
defer imgStoreCleanup(t)
imagePath := filepath.Join(tempDir, imgName)
srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
http.ServeFile(w, r, c.env.ImagePath)
}))
defer srv.Close()
// Pull through the cache - will give us a new style file in the cache
c.env.RunSingularity(
t,
e2e.WithProfile(e2e.UserProfile),
e2e.WithCommand("pull"),
e2e.WithArgs([]string{"--force", imagePath, srv.URL}...),
e2e.ExpectExit(0),
)
// Replace the cache entry with a directory, containing the image,
// like in older versions of singularity
hash, err := netHash(srv.URL)
if err != nil {
t.Fatalf("Could not calculate hash of test image: %v", err)
}
cachePath := path.Join(imgCacheDir, "cache", "net", hash)
err = os.Remove(cachePath)
if err != nil {
t.Fatalf("Could not remove cached image '%s': %v", cachePath, err)
}
err = os.Mkdir(cachePath, 0o700)
if err != nil {
t.Fatalf("Could not create directory '%s': %v", cachePath, err)
}
err = fs.CopyFile(imagePath, path.Join(cachePath, hash), 0o700)
if err != nil {
t.Fatalf("Could not copy file to directory '%s': %v", cachePath, err)
}
// Pull through the cache - it should work as we now remove the directory and
// re-pull a file into the cache
c.env.RunSingularity(
t,
e2e.WithProfile(e2e.UserProfile),
e2e.WithCommand("pull"),
e2e.WithArgs([]string{"--force", imagePath, srv.URL}...),
e2e.ExpectExit(0),
)
if !fs.IsFile(cachePath) {
t.Fatalf("Cache entry '%s' is not a file", cachePath)
}
}
// issue5350 - need to handle the cache being inside a non-accessible directory
// e.g. home directory without perms to access
func (c cacheTests) issue5350(t *testing.T) {
e2e.EnsureORASImage(t, c.env)
outerDir, cleanupOuter := e2e.MakeTempDir(t, c.env.TestDir, "issue5350-cache-", "")
defer e2e.Privileged(cleanupOuter)(t)
sandboxDir, cleanupSandbox := e2e.MakeTempDir(t, c.env.TestDir, "issue5350-sandbox-", "")
defer e2e.Privileged(cleanupSandbox)(t)
imgCacheDir, cleanCache := e2e.MakeCacheDir(t, outerDir)
defer cleanCache(t)
c.env.UnprivCacheDir = imgCacheDir
if err := os.Chmod(outerDir, 0o000); err != nil {
t.Fatalf("Could not chmod 000 cache outer dir: %v", err)
}
c.env.RunSingularity(
t,
e2e.WithProfile(e2e.UserProfile),
e2e.WithCommand("build"),
e2e.WithArgs([]string{"--force", "-s", sandboxDir, c.env.OrasTestImage}...),
e2e.ExpectExit(0),
)
// Open up permissions or our cleanup will fail
if err := os.Chmod(outerDir, 0o755); err != nil {
t.Fatalf("Could not chmod 755 cache outer dir: %v", err)
}
}
|
