99 "net/http"
1010 "os"
1111 "regexp"
12- "time"
1312
1413 "golang.org/x/exp/maps"
1514 "oras.land/oras-go/pkg/registry/remote"
@@ -21,24 +20,19 @@ const (
2120)
2221
2322var (
24- repo * string
25- baseURL * string
26- dryRun * bool
2723 accessToken = os .Getenv ("ACCESS_TOKEN" )
2824 preserveSubstrings = []string {
2925 "latest" ,
30- // Preserve release branch images
31- "release-v*" ,
32- // Semver regex - vX.Y.Z(-rc1)
33- "^v(?P<major>0|[1-9]\\ d*)\\ .(?P<minor>0|[1-9]\\ d*)\\ .(?P<patch>0|[1-9]\\ d*)(?:-(?P<prerelease>(?:0|[1-9]\\ d*|\\ d*[a-zA-Z-][0-9a-zA-Z-]*)(?:\\ .(?:0|[1-9]\\ d*|\\ d*[a-zA-Z-][0-9a-zA-Z-]*))*))?(?:\\ +(?P<buildmetadata>[0-9a-zA-Z-]+(?:\\ .[0-9a-zA-Z-]+)*))?$" ,
26+ // Preserve semver release branch or semver tag regex - release-vX.Y.Z(-rc1) or vX.Y.Z(-rc1)
27+ // Based on https://semver.org/#is-there-a-suggested-regular-expression-regex-to-check-a-semver-string
28+ "^(v|release-v)(?P<major>0|[1-9]\\ d*)\\ .(?P<minor>0|[1-9]\\ d*)\\ .(?P<patch>0|[1-9]\\ d*)(?:-(?P<prerelease>(?:0|[1-9]\\ d*|\\ d*[a-zA-Z-][0-9a-zA-Z-]*)(?:\\ .(?:0|[1-9]\\ d*|\\ d*[a-zA-Z-][0-9a-zA-Z-]*))*))?(?:\\ +(?P<buildmetadata>[0-9a-zA-Z-]+(?:\\ .[0-9a-zA-Z-]+)*))?$" ,
3429 }
3530)
3631
3732// Tag represents a tag in the repository.
3833type Tag struct {
39- Name string `json:"name"`
40- LastModified string `json:"last_modified"`
41- Expiration string `json:"expiration"`
34+ Name string `json:"name"`
35+ Expiration string `json:"expiration"`
4236}
4337
4438// TagsResponse represents the structure of the API response that contains tags.
@@ -49,9 +43,9 @@ type TagsResponse struct {
4943}
5044
5145func main () {
52- repo = flag .String ("repo" , "kuadrant/kuadrant-operator" , "Repository name" )
53- baseURL = flag .String ("base-url" , "https://quay.io/api/v1/repository/" , "Base API URL" )
54- dryRun = flag .Bool ("dry-run" , true , "Dry run" )
46+ repo : =flag .String ("repo" , "kuadrant/kuadrant-operator" , "Repository name" )
47+ baseURL : =flag .String ("base-url" , "https://quay.io/api/v1/repository/" , "Base API URL" )
48+ dryRun : =flag .Bool ("dry-run" , true , "Dry run" )
5549 flag .Parse ()
5650
5751 client := & http.Client {}
@@ -63,7 +57,7 @@ func main() {
6357 }
6458
6559 // Fetch tags from the API
66- tags , err := fetchTags (client )
60+ tags , err := fetchTags (client , baseURL , repo )
6761 if err != nil {
6862 logger .Fatalln ("Error fetching tags:" , err )
6963 }
@@ -81,7 +75,7 @@ func main() {
8175 if dryRun != nil && * dryRun {
8276 logger .Printf ("DRY RUN - Successfully deleted tag: %s\n " , tagName )
8377 } else {
84- if err := deleteTag (client , accessToken , tagName ); err != nil {
78+ if err := deleteTag (client , baseURL , repo , accessToken , tagName ); err != nil {
8579 logger .Println (err )
8680 continue
8781 }
@@ -99,13 +93,13 @@ func main() {
9993
10094// fetchTags retrieves the tags from the repository using the Quay.io API.
10195// https://docs.quay.io/api/swagger/#!/tag/listRepoTags
102- func fetchTags (client remote.Client ) ([]Tag , error ) {
96+ func fetchTags (client remote.Client , baseURL , repo * string ) ([]Tag , error ) {
10397 allTags := make ([]Tag , 0 )
10498
10599 i := 1
106100
107101 for {
108- req , err := http .NewRequest ("GET" , fmt .Sprintf ("%s%s /tag/?page=%d&limit=%d" , * baseURL , * repo , i , pageLimit ), nil )
102+ req , err := http .NewRequest ("GET" , fmt .Sprintf ("%v%v /tag/?page=%d&limit=%d" , baseURL , repo , i , pageLimit ), nil )
109103 if err != nil {
110104 return nil , fmt .Errorf ("error creating request: %w" , err )
111105 }
@@ -155,8 +149,8 @@ func fetchTags(client remote.Client) ([]Tag, error) {
155149// deleteTag sends a DELETE request to remove the specified tag from the repository
156150// Returns nil if successful, error otherwise
157151// https://docs.quay.io/api/swagger/#!/tag/deleteFullTag
158- func deleteTag (client remote.Client , accessToken , tagName string ) error {
159- req , err := http .NewRequest ("DELETE" , fmt .Sprintf ("%s%s /tag/%s" , * baseURL , * repo , tagName ), nil )
152+ func deleteTag (client remote.Client , baseURL , repo * string , accessToken , tagName string ) error {
153+ req , err := http .NewRequest ("DELETE" , fmt .Sprintf ("%v%v /tag/%s" , baseURL , repo , tagName ), nil )
160154 if err != nil {
161155 return fmt .Errorf ("error creating DELETE request: %s" , err )
162156 }
@@ -178,11 +172,8 @@ func deleteTag(client remote.Client, accessToken, tagName string) error {
178172
179173// filterTags takes a slice of tags and preserves string regex and returns two maps: one for tags to delete and one for remaining tags.
180174func filterTags (tags []Tag , preserveSubstrings []string ) (map [string ]struct {}, map [string ]struct {}, error ) {
181- // Calculate the cutoff time
182- cutOffTime := time .Now ().AddDate (0 , 0 , 0 ).Add (0 * time .Hour ).Add (- 1 * time .Minute )
183-
184175 tagsToDelete := make (map [string ]struct {})
185- perservedTags := make (map [string ]struct {})
176+ preservedTags := make (map [string ]struct {})
186177
187178 // Compile the regexes for each preserve substring
188179 var preserveRegexes []* regexp.Regexp
@@ -211,17 +202,12 @@ func filterTags(tags []Tag, preserveSubstrings []string) (map[string]struct{}, m
211202 }
212203 }
213204
214- lastModified , err := time .Parse (time .RFC1123 , tag .LastModified )
215- if err != nil {
216- return nil , nil , err
217- }
218-
219- if lastModified .Before (cutOffTime ) && ! preserve {
205+ if ! preserve {
220206 tagsToDelete [tag .Name ] = struct {}{}
221207 } else {
222- perservedTags [tag .Name ] = struct {}{}
208+ preservedTags [tag .Name ] = struct {}{}
223209 }
224210 }
225211
226- return tagsToDelete , perservedTags , nil
212+ return tagsToDelete , preservedTags , nil
227213}
0 commit comments