/
quay.go
111 lines (88 loc) · 2.46 KB
/
quay.go
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
111
package docker_registry
import (
"context"
"errors"
"fmt"
"net/http"
"path"
"strings"
"github.com/google/go-containerregistry/pkg/name"
)
const (
QuayImplementationName = "quay"
quayRepositoryNotFoundErrPrefix = "quay repository not found: "
)
type QuayRepositoryNotFoundErr apiError
func NewQuayRepositoryNotFoundErr(err error) QuayRepositoryNotFoundErr {
return QuayRepositoryNotFoundErr{
error: errors.New(quayRepositoryNotFoundErrPrefix + err.Error()),
}
}
func IsQuayRepositoryNotFoundErr(err error) bool {
return strings.Contains(err.Error(), quayRepositoryNotFoundErrPrefix)
}
var quayPatterns = []string{"^quay\\.io", "^quay\\..*\\.com"}
type quay struct {
*defaultImplementation
quayApi
quayCredentials
}
type quayOptions struct {
defaultImplementationOptions
quayCredentials
}
type quayCredentials struct {
token string
}
func newQuay(options quayOptions) (*quay, error) {
d, err := newDefaultAPIForImplementation(QuayImplementationName, options.defaultImplementationOptions)
if err != nil {
return nil, err
}
quay := &quay{
defaultImplementation: d,
quayApi: newQuayApi(),
quayCredentials: options.quayCredentials,
}
return quay, nil
}
func (r *quay) DeleteRepo(ctx context.Context, reference string) error {
return r.deleteRepo(ctx, reference)
}
func (r *quay) deleteRepo(ctx context.Context, reference string) error {
hostname, namespace, repository, err := r.parseReference(reference)
if err != nil {
return err
}
resp, err := r.quayApi.DeleteRepository(ctx, hostname, namespace, repository, r.quayCredentials.token)
if err != nil {
if resp != nil && resp.StatusCode == http.StatusNotFound {
return NewQuayRepositoryNotFoundErr(err)
}
return err
}
defer resp.Body.Close()
return nil
}
func (r *quay) String() string {
return QuayImplementationName
}
func (r *quay) parseReference(reference string) (string, string, string, error) {
parsedReference, err := name.NewRepository(reference)
if err != nil {
return "", "", "", err
}
hostname := parsedReference.RegistryStr()
repositoryStr := parsedReference.RepositoryStr()
var namespace, repository string
switch len(strings.Split(repositoryStr, "/")) {
case 1:
namespace = repositoryStr
case 2:
repository = path.Base(repositoryStr)
namespace = path.Base(strings.TrimSuffix(repositoryStr, repository))
default:
return "", "", "", fmt.Errorf("unexpected reference %s", reference)
}
return hostname, namespace, repository, nil
}