|
1 | 1 | package utils |
2 | 2 |
|
3 | 3 | import ( |
| 4 | + "bufio" |
4 | 5 | "io" |
5 | 6 | "net/http" |
6 | 7 | "os" |
7 | 8 | "os/exec" |
8 | 9 | "path/filepath" |
| 10 | + "regexp" |
9 | 11 | "runtime" |
10 | 12 | "testing" |
11 | 13 | ) |
12 | 14 |
|
13 | | -const ( |
14 | | - // renovate: datasource=github-releases depName=ocm packageName=open-component-model/ocm |
15 | | - OCM_VERSION = "0.27.0" |
16 | | -) |
17 | | - |
18 | 15 | var ( |
19 | 16 | CacheDirRoot = filepath.Join(os.TempDir(), "openmcp-bootstrapper-test") |
| 17 | + OCMVersion = "" |
20 | 18 | ) |
21 | 19 |
|
22 | 20 | // DownloadOCMAndAddToPath downloads the OCM cli for the current platform and puts it to the PATH of the test |
23 | 21 | func DownloadOCMAndAddToPath(t *testing.T) { |
24 | 22 | t.Helper() |
25 | 23 |
|
| 24 | + ocmVersion := getOCMVersion(t) |
| 25 | + |
26 | 26 | cacheDir := filepath.Join(CacheDirRoot, "ocm-cli-cache") |
27 | 27 | if err := os.MkdirAll(cacheDir, 0o755); err != nil { |
28 | 28 | t.Fatalf("failed to create cache dir: %v", err) |
29 | 29 | } |
30 | 30 |
|
31 | | - ocmBinaryName := "ocm-" + OCM_VERSION + "-" + runtime.GOOS + "-" + runtime.GOARCH |
| 31 | + ocmBinaryName := "ocm-" + ocmVersion + "-" + runtime.GOOS + "-" + runtime.GOARCH |
32 | 32 | ocmPath := filepath.Join(cacheDir, ocmBinaryName) |
33 | 33 |
|
34 | 34 | if _, err := os.Stat(ocmPath); os.IsNotExist(err) { |
35 | 35 | t.Log("Downloading OCM as it is not present in the cache directory, starting download...") |
36 | 36 |
|
37 | 37 | downloadURL := "https://github.com/open-component-model/ocm/releases/download/v" + |
38 | | - OCM_VERSION + "/ocm-" + OCM_VERSION + "-" + runtime.GOOS + "-" + runtime.GOARCH + ".tar.gz" |
| 38 | + ocmVersion + "/ocm-" + ocmVersion + "-" + runtime.GOOS + "-" + runtime.GOARCH + ".tar.gz" |
39 | 39 |
|
40 | 40 | tempDir := t.TempDir() |
41 | 41 | archivePath := filepath.Join(tempDir, "ocm.tar.gz") |
@@ -130,3 +130,74 @@ func BuildComponent(componentConstructorLocation string, t *testing.T) string { |
130 | 130 |
|
131 | 131 | return ctfDir |
132 | 132 | } |
| 133 | + |
| 134 | +func getOCMVersion(t *testing.T) string { |
| 135 | + var err error |
| 136 | + |
| 137 | + if OCMVersion != "" { |
| 138 | + t.Logf("Using cached OCM_VERSION: %s", OCMVersion) |
| 139 | + return OCMVersion |
| 140 | + } |
| 141 | + |
| 142 | + // Find the parent directory containing the Dockerfile |
| 143 | + cwd, err := os.Getwd() |
| 144 | + if err != nil { |
| 145 | + t.Fatalf("failed to get working directory: %v", err) |
| 146 | + } |
| 147 | + |
| 148 | + var ( |
| 149 | + dockerfilePath string |
| 150 | + currentDir = cwd |
| 151 | + ) |
| 152 | + |
| 153 | + for { |
| 154 | + dockerfilePath = filepath.Join(currentDir, "Dockerfile") |
| 155 | + if _, err = os.Stat(dockerfilePath); err == nil { |
| 156 | + break |
| 157 | + } else { |
| 158 | + if !os.IsNotExist(err) { |
| 159 | + t.Fatalf("failed to check Dockerfile existence: %v", err) |
| 160 | + } |
| 161 | + } |
| 162 | + parent := filepath.Dir(currentDir) |
| 163 | + if parent == currentDir { |
| 164 | + t.Fatalf("Dockerfile not found in any parent directory of %s", cwd) |
| 165 | + } |
| 166 | + |
| 167 | + currentDir = parent |
| 168 | + } |
| 169 | + OCMVersion = parseDockerfileOCMVersion(dockerfilePath, t) |
| 170 | + |
| 171 | + t.Logf("Parsed OCM_VERSION from Dockerfile: %s", OCMVersion) |
| 172 | + return OCMVersion |
| 173 | +} |
| 174 | + |
| 175 | +// ParseDockerfileOCMVersion parses the Dockerfile to extract the OCM_VERSION argument value. |
| 176 | +func parseDockerfileOCMVersion(dockerfilePath string, t *testing.T) string { |
| 177 | + file, err := os.Open(dockerfilePath) |
| 178 | + if err != nil { |
| 179 | + t.Fatalf("failed to open Dockerfile: %v", err) |
| 180 | + } |
| 181 | + defer func(file *os.File) { |
| 182 | + err := file.Close() |
| 183 | + if err != nil { |
| 184 | + t.Fatalf("failed to close Dockerfile: %v", err) |
| 185 | + } |
| 186 | + }(file) |
| 187 | + |
| 188 | + scanner := bufio.NewScanner(file) |
| 189 | + re := regexp.MustCompile(`^ARG OCM_VERSION=([\w.-]+)`) |
| 190 | + for scanner.Scan() { |
| 191 | + line := scanner.Text() |
| 192 | + matches := re.FindStringSubmatch(line) |
| 193 | + if len(matches) == 2 { |
| 194 | + return matches[1] |
| 195 | + } |
| 196 | + } |
| 197 | + if err = scanner.Err(); err != nil { |
| 198 | + t.Fatalf("failed to read Dockerfile: %v", err) |
| 199 | + } |
| 200 | + |
| 201 | + t.Fatalf("OCM_VERSION not found in Dockerfile: %s", dockerfilePath) |
| 202 | + return "" |
| 203 | +} |
0 commit comments