list tags for OCI charts

Author: petar-cvit

cyclops-ctrl/internal/controller/templates.go

@@ -212,17 +212,23 @@ func (c *Templates) GetTemplateRevisions(ctx *gin.Context) {
 	ctx.Header("Access-Control-Allow-Origin", "*")
 
 	repo := ctx.Query("repo")
+	path := ctx.Query("path")
 
 	if repo == "" {
 		ctx.JSON(http.StatusOK, []string{})
 		return
 	}
 
-	revisions, err := c.templatesRepo.GetTemplateRevisions(repo)
+	revisions, err := c.templatesRepo.GetTemplateRevisions(repo, path)
 	if err != nil {
 		ctx.JSON(http.StatusBadRequest, dto.NewError("Error loading template", err.Error()))
 		return
 	}
 
+	if revisions == nil {
+		ctx.JSON(http.StatusOK, []string{})
+		return
+	}
+
 	ctx.JSON(http.StatusOK, revisions)
 }

cyclops-ctrl/pkg/template/oci.go

@@ -226,22 +226,31 @@ func fetchDigest(repo, chart, version, token string) (string, error) {
 }
 
 func getOCIStrictVersion(repo, chart, version string) (string, error) {
-	token, err := authorizeOCITags(repo, chart)
+	allTags, err := GetOCIChartTags(repo, chart)
 	if err != nil {
 		return "", err
 	}
 
+	return resolveSemver(version, allTags)
+}
+
+func GetOCIChartTags(repo, chart string) ([]string, error) {
+	token, err := authorizeOCITags(repo, chart)
+	if err != nil {
+		return nil, err
+	}
+
 	tURL, err := tagsURL(repo, chart)
 	if err != nil {
-		return "", err
+		return nil, err
 	}
 
 	client := &http.Client{}
 	var allTags []string
 	for {
 		req, err := http.NewRequest(http.MethodGet, tURL.String(), nil)
 		if err != nil {
-			return "", err
+			return nil, err
 		}
 
 		req.Header.Set("User-Agent", "Helm/3.13.3")
@@ -251,21 +260,21 @@ func getOCIStrictVersion(repo, chart, version string) (string, error) {
 
 		resp, err := client.Do(req)
 		if err != nil {
-			return "", err
+			return nil, err
 		}
 		defer resp.Body.Close()
 
 		responseBody, err := ioutil.ReadAll(resp.Body)
 		if err != nil {
-			return "", err
+			return nil, err
 		}
 
 		var tagsResp struct {
 			Tags []string `json:"tags"`
 		}
 
 		if err := json.Unmarshal(responseBody, &tagsResp); err != nil {
-			return "", err
+			return nil, err
 		}
 
 		allTags = append(allTags, tagsResp.Tags...)
@@ -278,7 +287,7 @@ func getOCIStrictVersion(repo, chart, version string) (string, error) {
 
 		nextURL, err := parseNextLink(linkHeader)
 		if err != nil {
-			return "", err
+			return nil, err
 		}
 
 		if nextURL == "" {
@@ -287,11 +296,11 @@ func getOCIStrictVersion(repo, chart, version string) (string, error) {
 
 		tURL, err = resolveRelativeURL(tURL, nextURL)
 		if err != nil {
-			return "", err
+			return nil, err
 		}
 	}
 
-	return resolveSemver(version, allTags)
+	return allTags, err
 }
 
 func authorizeOCI(repo, chart, version string) (string, error) {

cyclops-ctrl/pkg/template/template.go

@@ -30,7 +30,7 @@ type ITemplateRepo interface {
 		version string,
 		source cyclopsv1alpha1.TemplateSourceType,
 	) (map[string]interface{}, error)
-	GetTemplateRevisions(repo string) ([]string, error)
+	GetTemplateRevisions(repo, path string) ([]string, error)
 	ReturnCache() *ristretto.Cache
 }
 
@@ -181,7 +181,11 @@ func (r Repo) assumeTemplateSourceType(repo string) (cyclopsv1alpha1.TemplateSou
 	return cyclopsv1alpha1.TemplateSourceTypeGit, nil
 }
 
-func (r Repo) GetTemplateRevisions(repo string) ([]string, error) {
+func (r Repo) GetTemplateRevisions(repo, path string) ([]string, error) {
+	if registry.IsOCI(repo) {
+		return GetOCIChartTags(repo, path)
+	}
+
 	if !gitproviders2.IsGitHubSource(repo) {
 		return nil, nil
 	}