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
|
// Copyright (c) 2020, Control Command Inc. All rights reserved.
// Copyright (c) 2018-2023, 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 oci
import (
"context"
"fmt"
"github.com/sylabs/singularity/v4/internal/pkg/build"
"github.com/sylabs/singularity/v4/internal/pkg/cache"
"github.com/sylabs/singularity/v4/internal/pkg/ociimage"
buildtypes "github.com/sylabs/singularity/v4/pkg/build/types"
"github.com/sylabs/singularity/v4/pkg/sylog"
)
// pullNativeSIF will build a SIF image into the cache if directTo="", or a specific file if directTo is set.
func pullNativeSIF(ctx context.Context, imgCache *cache.Handle, directTo, pullFrom string, opts PullOptions) (imagePath string, err error) {
sys, err := sysCtx(opts)
if err != nil {
return "", err
}
ref, err := ociimage.ParseImageRef(pullFrom)
if err != nil {
return "", err
}
hash, err := ociimage.ImageDigest(ctx, sys, imgCache, ref)
if err != nil {
return "", fmt.Errorf("failed to get checksum for %s: %s", pullFrom, err)
}
if directTo != "" {
sylog.Infof("Converting OCI blobs to SIF format")
if err := convertOciToSIF(ctx, imgCache, pullFrom, directTo, opts); err != nil {
return "", fmt.Errorf("while building SIF from layers: %v", err)
}
imagePath = directTo
} else {
cacheEntry, err := imgCache.GetEntry(cache.OciTempCacheType, hash.String())
if err != nil {
return "", fmt.Errorf("unable to check if %v exists in cache: %v", hash, err)
}
defer cacheEntry.CleanTmp()
if !cacheEntry.Exists {
sylog.Infof("Converting OCI blobs to SIF format")
if err := convertOciToSIF(ctx, imgCache, pullFrom, cacheEntry.TmpPath, opts); err != nil {
return "", fmt.Errorf("while building SIF from layers: %v", err)
}
err = cacheEntry.Finalize()
if err != nil {
return "", err
}
} else {
sylog.Infof("Using cached SIF image")
}
imagePath = cacheEntry.Path
}
return imagePath, nil
}
// convertOciToSIF will convert an OCI source into a SIF using the build routines
func convertOciToSIF(ctx context.Context, imgCache *cache.Handle, image, cachedImgPath string, opts PullOptions) error {
if imgCache == nil {
return fmt.Errorf("image cache is undefined")
}
b, err := build.NewBuild(
image,
build.Config{
Dest: cachedImgPath,
Format: "sif",
NoCleanUp: opts.NoCleanUp,
Opts: buildtypes.Options{
TmpDir: opts.TmpDir,
NoCache: imgCache.IsDisabled(),
NoTest: true,
NoHTTPS: opts.NoHTTPS,
DockerAuthConfig: opts.OciAuth,
DockerDaemonHost: opts.DockerHost,
ImgCache: imgCache,
Platform: opts.Platform,
},
},
)
if err != nil {
return fmt.Errorf("unable to create new build: %v", err)
}
return b.Full(ctx)
}
|
