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
|
package marketplace
import (
"fmt"
"strings"
"github.com/scaleway/scaleway-sdk-go/internal/errors"
"github.com/scaleway/scaleway-sdk-go/scw"
)
// getLocalImage returns the correct local version of an image matching
// the current zone and the compatible commercial type
func (version *Version) getLocalImage(zone scw.Zone, commercialType string) (*LocalImage, error) {
for _, localImage := range version.LocalImages {
// Check if in correct zone
if localImage.Zone != zone {
continue
}
// Check if compatible with wanted commercial type
for _, compatibleCommercialType := range localImage.CompatibleCommercialTypes {
if compatibleCommercialType == commercialType {
return localImage, nil
}
}
}
return nil, fmt.Errorf("couldn't find compatible local image for this image version (%s)", version.ID)
}
// getLatestVersion returns the current/latest version on an image,
// or an error in case the image doesn't have a public version.
func (image *Image) getLatestVersion() (*Version, error) {
for _, version := range image.Versions {
if version.ID == image.CurrentPublicVersion {
return version, nil
}
}
return nil, errors.New("latest version could not be found for image %s", image.Label)
}
// GetLocalImageIDByLabelRequest is used by GetLocalImageIDByLabel
type GetLocalImageIDByLabelRequest struct {
ImageLabel string
Zone scw.Zone
CommercialType string
}
// GetLocalImageIDByLabel search for an image with the given label (exact match) in the given region
// it returns the latest version of this specific image.
func (s *API) GetLocalImageIDByLabel(req *GetLocalImageIDByLabelRequest, opts ...scw.RequestOption) (string, error) {
if req.Zone == "" {
defaultZone, _ := s.client.GetDefaultZone()
req.Zone = defaultZone
}
listImageRequest := &ListImagesRequest{}
opts = append(opts, scw.WithAllPages())
listImageResponse, err := s.ListImages(listImageRequest, opts...)
if err != nil {
return "", err
}
images := listImageResponse.Images
label := strings.Replace(req.ImageLabel, "-", "_", -1)
commercialType := strings.ToUpper(req.CommercialType)
for _, image := range images {
// Match label of the image
if label == image.Label {
latestVersion, err := image.getLatestVersion()
if err != nil {
return "", errors.Wrap(err, "couldn't find a matching image for the given label (%s), zone (%s) and commercial type (%s)", req.ImageLabel, req.Zone, req.CommercialType)
}
localImage, err := latestVersion.getLocalImage(req.Zone, commercialType)
if err != nil {
return "", errors.Wrap(err, "couldn't find a matching image for the given label (%s), zone (%s) and commercial type (%s)", req.ImageLabel, req.Zone, req.CommercialType)
}
return localImage.ID, nil
}
}
return "", errors.New("couldn't find a matching image for the given label (%s), zone (%s) and commercial type (%s)", req.ImageLabel, req.Zone, req.CommercialType)
}
// UnsafeSetTotalCount should not be used
// Internal usage only
func (r *ListImagesResponse) UnsafeSetTotalCount(totalCount int) {
r.TotalCount = uint32(totalCount)
}
// UnsafeSetTotalCount should not be used
// Internal usage only
func (r *ListVersionsResponse) UnsafeSetTotalCount(totalCount int) {
r.TotalCount = uint32(totalCount)
}
|
