Skip to content

Commit 2e9b30b

Browse files
committed
Move NerdctlArchiveCache function to cacheutil
Signed-off-by: Anders F Björklund <[email protected]>
1 parent 726f61d commit 2e9b30b

File tree

2 files changed

+49
-38
lines changed

2 files changed

+49
-38
lines changed

Diff for: pkg/cacheutil/cacheutil.go

+47
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,47 @@
1+
package cacheutil
2+
3+
import (
4+
"context"
5+
"fmt"
6+
7+
"github.com/lima-vm/lima/pkg/downloader"
8+
"github.com/lima-vm/lima/pkg/fileutils"
9+
"github.com/lima-vm/lima/pkg/limayaml"
10+
)
11+
12+
// EnsureNerdctlArchiveCache prefetches the archive into the cache.
13+
//
14+
// EnsureNerdctlArchiveCache prefetches the nerdctl-full-VERSION-GOOS-GOARCH.tar.gz archive
15+
// into the cache before launching the hostagent process, so that we can show the progress in tty.
16+
// https://github.com/lima-vm/lima/issues/326
17+
func EnsureNerdctlArchiveCache(ctx context.Context, y *limayaml.LimaYAML, created bool) (string, error) {
18+
if !*y.Containerd.System && !*y.Containerd.User {
19+
// nerdctl archive is not needed
20+
return "", nil
21+
}
22+
23+
errs := make([]error, len(y.Containerd.Archives))
24+
for i, f := range y.Containerd.Archives {
25+
// Skip downloading again if the file is already in the cache
26+
if created && f.Arch == *y.Arch && !downloader.IsLocal(f.Location) {
27+
path, err := fileutils.CachedFile(f)
28+
if err == nil {
29+
return path, nil
30+
}
31+
}
32+
path, err := fileutils.DownloadFile(ctx, "", f, false, "the nerdctl archive", *y.Arch)
33+
if err != nil {
34+
errs[i] = err
35+
continue
36+
}
37+
if path == "" {
38+
if downloader.IsLocal(f.Location) {
39+
return f.Location, nil
40+
}
41+
return "", fmt.Errorf("cache did not contain %q", f.Location)
42+
}
43+
return path, nil
44+
}
45+
46+
return "", fileutils.Errors(errs)
47+
}

Diff for: pkg/instance/start.go

+2-38
Original file line numberDiff line numberDiff line change
@@ -15,15 +15,14 @@ import (
1515
"time"
1616

1717
"github.com/coreos/go-semver/semver"
18+
"github.com/lima-vm/lima/pkg/cacheutil"
1819
"github.com/lima-vm/lima/pkg/driver"
1920
"github.com/lima-vm/lima/pkg/driverutil"
2021
"github.com/lima-vm/lima/pkg/osutil"
2122
"github.com/lima-vm/lima/pkg/qemu"
2223
"github.com/lima-vm/lima/pkg/qemu/entitlementutil"
2324
"github.com/mattn/go-isatty"
2425

25-
"github.com/lima-vm/lima/pkg/downloader"
26-
"github.com/lima-vm/lima/pkg/fileutils"
2726
hostagentevents "github.com/lima-vm/lima/pkg/hostagent/events"
2827
"github.com/lima-vm/lima/pkg/limayaml"
2928
"github.com/lima-vm/lima/pkg/store"
@@ -35,41 +34,6 @@ import (
3534
// to be running before timing out.
3635
const DefaultWatchHostAgentEventsTimeout = 10 * time.Minute
3736

38-
// ensureNerdctlArchiveCache prefetches the nerdctl-full-VERSION-GOOS-GOARCH.tar.gz archive
39-
// into the cache before launching the hostagent process, so that we can show the progress in tty.
40-
// https://github.com/lima-vm/lima/issues/326
41-
func ensureNerdctlArchiveCache(ctx context.Context, y *limayaml.LimaYAML, created bool) (string, error) {
42-
if !*y.Containerd.System && !*y.Containerd.User {
43-
// nerdctl archive is not needed
44-
return "", nil
45-
}
46-
47-
errs := make([]error, len(y.Containerd.Archives))
48-
for i, f := range y.Containerd.Archives {
49-
// Skip downloading again if the file is already in the cache
50-
if created && f.Arch == *y.Arch && !downloader.IsLocal(f.Location) {
51-
path, err := fileutils.CachedFile(f)
52-
if err == nil {
53-
return path, nil
54-
}
55-
}
56-
path, err := fileutils.DownloadFile(ctx, "", f, false, "the nerdctl archive", *y.Arch)
57-
if err != nil {
58-
errs[i] = err
59-
continue
60-
}
61-
if path == "" {
62-
if downloader.IsLocal(f.Location) {
63-
return f.Location, nil
64-
}
65-
return "", fmt.Errorf("cache did not contain %q", f.Location)
66-
}
67-
return path, nil
68-
}
69-
70-
return "", fileutils.Errors(errs)
71-
}
72-
7337
type Prepared struct {
7438
Driver driver.Driver
7539
NerdctlArchiveCache string
@@ -104,7 +68,7 @@ func Prepare(ctx context.Context, inst *store.Instance) (*Prepared, error) {
10468
if err := limaDriver.CreateDisk(ctx); err != nil {
10569
return nil, err
10670
}
107-
nerdctlArchiveCache, err := ensureNerdctlArchiveCache(ctx, y, created)
71+
nerdctlArchiveCache, err := cacheutil.EnsureNerdctlArchiveCache(ctx, y, created)
10872
if err != nil {
10973
return nil, err
11074
}

0 commit comments

Comments
 (0)