-
Notifications
You must be signed in to change notification settings - Fork 31
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #145 from nicholasSUSE/create-release-cmd
Create release command
- Loading branch information
Showing
8 changed files
with
510 additions
and
49 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,171 @@ | ||
| package auto | ||
|
|
||
| import ( | ||
| "errors" | ||
| "fmt" | ||
| "io" | ||
| "os" | ||
|
|
||
| "github.com/rancher/charts-build-scripts/pkg/filesystem" | ||
| "github.com/rancher/charts-build-scripts/pkg/git" | ||
| "github.com/rancher/charts-build-scripts/pkg/lifecycle" | ||
| "github.com/rancher/charts-build-scripts/pkg/path" | ||
| "gopkg.in/yaml.v3" | ||
| ) | ||
|
|
||
| // Release holds necessary metadata to release a chart version | ||
| type Release struct { | ||
| git *git.Git | ||
| VR *lifecycle.VersionRules | ||
| AssetTgz string | ||
| AssetPath string | ||
| ChartVersion string | ||
| Chart string | ||
| ReleaseYamlPath string | ||
| ForkRemoteURL string | ||
| } | ||
|
|
||
| // InitRelease will create the Release struct with access to the necessary dependencies. | ||
| func InitRelease(d *lifecycle.Dependencies, s *lifecycle.Status, v, c, f string) (*Release, error) { | ||
| r := &Release{ | ||
| git: d.Git, | ||
| VR: d.VR, | ||
| ChartVersion: v, | ||
| Chart: c, | ||
| ForkRemoteURL: f, | ||
| } | ||
|
|
||
| var ok bool | ||
| var assetVersions []lifecycle.Asset | ||
|
|
||
| assetVersions, ok = s.AssetsToBeReleased[r.Chart] | ||
| if !ok { | ||
| assetVersions, ok = s.AssetsToBeForwardPorted[r.Chart] | ||
| if !ok { | ||
| return nil, errors.New("no asset version to release for chart:" + r.Chart) | ||
| } | ||
| } | ||
|
|
||
| var assetVersion string | ||
| for _, version := range assetVersions { | ||
| if version.Version == r.ChartVersion { | ||
| assetVersion = version.Version | ||
| break | ||
| } | ||
| } | ||
| if assetVersion == "" { | ||
| return nil, errors.New("no asset version to release for chart:" + r.Chart + " version:" + r.ChartVersion) | ||
| } | ||
|
|
||
| r.AssetPath, r.AssetTgz = mountAssetVersionPath(r.Chart, assetVersion) | ||
|
|
||
| // Check again if the asset was already released in the local repository | ||
| if err := checkAssetReleased(r.AssetPath); err != nil { | ||
| return nil, fmt.Errorf("failed to check for chart:%s ; err: %w", r.Chart, err) | ||
| } | ||
|
|
||
| // Check if we have a release.yaml file in the expected path | ||
| if exist, err := filesystem.PathExists(d.RootFs, path.RepositoryReleaseYaml); err != nil || !exist { | ||
| return nil, errors.New("release.yaml not found") | ||
| } | ||
|
|
||
| r.ReleaseYamlPath = filesystem.GetAbsPath(d.RootFs, path.RepositoryReleaseYaml) | ||
|
|
||
| return r, nil | ||
| } | ||
|
|
||
| // PullAsset will execute the release porting for a chart in the repository | ||
| func (r *Release) PullAsset() error { | ||
| if err := r.git.FetchBranch(r.VR.DevBranch); err != nil { | ||
| return err | ||
| } | ||
|
|
||
| if err := r.git.CheckFileExists(r.AssetPath, r.VR.DevBranch); err != nil { | ||
| return fmt.Errorf("asset version not found in dev branch: %w", err) | ||
| } | ||
|
|
||
| if err := r.git.CheckoutFile(r.VR.DevBranch, r.AssetPath); err != nil { | ||
| return err | ||
| } | ||
|
|
||
| return r.git.ResetHEAD() | ||
| } | ||
|
|
||
| func checkAssetReleased(chartVersion string) error { | ||
| if _, err := os.Stat(chartVersion); err != nil { | ||
| return err | ||
| } | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| // mountAssetVersionPath returns the asset path and asset tgz name for a given chart and version. | ||
| // example: assets/longhorn/longhorn-100.0.0+up0.0.0.tgz | ||
| func mountAssetVersionPath(chart, version string) (string, string) { | ||
| assetTgz := chart + "-" + version + ".tgz" | ||
| assetPath := "assets/" + chart + "/" + assetTgz | ||
| return assetPath, assetTgz | ||
| } | ||
|
|
||
| func (r *Release) readReleaseYaml() (map[string][]string, error) { | ||
| var releaseVersions = make(map[string][]string, 0) | ||
|
|
||
| file, err := os.Open(r.ReleaseYamlPath) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| defer file.Close() | ||
|
|
||
| decoder := yaml.NewDecoder(file) | ||
| if err := decoder.Decode(&releaseVersions); err != nil { | ||
| if err == io.EOF { | ||
| // Handle EOF error gracefully | ||
| return releaseVersions, nil | ||
| } | ||
| return nil, err | ||
| } | ||
|
|
||
| return releaseVersions, nil | ||
| } | ||
|
|
||
| // UpdateReleaseYaml reads and parse the release.yaml file to a struct, appends the new version and writes it back to the file. | ||
| func (r *Release) UpdateReleaseYaml() error { | ||
| releaseVersions, err := r.readReleaseYaml() | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| // Append new version and remove duplicates if any | ||
| releaseVersions[r.Chart] = append(releaseVersions[r.Chart], r.ChartVersion) | ||
| releaseVersions[r.Chart] = removeDuplicates(releaseVersions[r.Chart]) | ||
|
|
||
| // Since we opened and read the file before we can truncate it. | ||
| outputFile, err := os.Create(r.ReleaseYamlPath) | ||
| if err != nil { | ||
| return err | ||
| } | ||
| defer outputFile.Close() | ||
|
|
||
| encoder := yaml.NewEncoder(outputFile) | ||
| encoder.SetIndent(2) | ||
| if err := encoder.Encode(releaseVersions); err != nil { | ||
| return err | ||
| } | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| // removeDuplicates takes a slice of strings and returns a new slice with duplicates removed. | ||
| func removeDuplicates(slice []string) []string { | ||
| seen := make(map[string]struct{}) // map to keep track of seen strings | ||
| var result []string // slice to hold the results | ||
|
|
||
| for _, val := range slice { | ||
| if _, ok := seen[val]; !ok { | ||
| seen[val] = struct{}{} // mark string as seen | ||
| result = append(result, val) // append to result if not seen before | ||
| } | ||
| } | ||
|
|
||
| return result | ||
| } |
Oops, something went wrong.