|
1 | 1 | package helm |
2 | 2 |
|
3 | 3 | import ( |
| 4 | + "encoding/json" |
4 | 5 | "os/exec" |
5 | 6 |
|
6 | 7 | "github.com/pkg/errors" |
@@ -104,3 +105,66 @@ func AddHelmRepo(name, url string) error { |
104 | 105 |
|
105 | 106 | return nil |
106 | 107 | } |
| 108 | + |
| 109 | +// UpdateHelmRepo updates the specified helm repository using the helm repo update command. |
| 110 | +func UpdateHelmRepo(name string) error { |
| 111 | + msg, err := exec.Command(helmCmd, "repo", "update", name).CombinedOutput() |
| 112 | + if err != nil { |
| 113 | + return errors.Wrap(err, "UpdateHelmRepo: "+string(msg)) |
| 114 | + } |
| 115 | + |
| 116 | + return nil |
| 117 | +} |
| 118 | + |
| 119 | +// IsReleaseExists checks if a Helm release with the given releaseName exists in the specified namespace. |
| 120 | +func IsReleaseExists(releaseName, namespace string) (bool, string, error) { |
| 121 | + |
| 122 | + commandArgs := []string{ |
| 123 | + "list", |
| 124 | + "--namespace", |
| 125 | + namespace, |
| 126 | + "--filter", |
| 127 | + releaseName, |
| 128 | + "--output", |
| 129 | + "json", |
| 130 | + } |
| 131 | + |
| 132 | + msg, err := exec.Command(helmCmd, commandArgs...).CombinedOutput() |
| 133 | + if err != nil { |
| 134 | + return false, "", errors.Wrap(err, "IsReleaseExists: "+string(msg)) |
| 135 | + } |
| 136 | + |
| 137 | + if string(msg) == "[]" || len(msg) == 0 { |
| 138 | + return false, "", nil |
| 139 | + } |
| 140 | + |
| 141 | + return true, string(msg), nil |
| 142 | +} |
| 143 | + |
| 144 | +// GetAppVersion gets the app version of a given releaseName in the specified namespace |
| 145 | +func GetAppVersion(releaseName, namespace string) (string, error) { |
| 146 | + exists, msg, err := IsReleaseExists(releaseName, namespace) |
| 147 | + if err != nil { |
| 148 | + return "", err |
| 149 | + } |
| 150 | + if !exists { |
| 151 | + return "", errors.New("release does not exist") |
| 152 | + } |
| 153 | + |
| 154 | + var releases []struct { |
| 155 | + Name string `json:"name"` |
| 156 | + AppVersion string `json:"app_version"` |
| 157 | + } |
| 158 | + |
| 159 | + if err := json.Unmarshal([]byte(msg), &releases); err != nil { |
| 160 | + return "", errors.Wrap(err, "GetAppVersion: failed to unmarshal json") |
| 161 | + } |
| 162 | + |
| 163 | + for _, r := range releases { |
| 164 | + if r.Name == releaseName { |
| 165 | + return r.AppVersion, nil |
| 166 | + } |
| 167 | + } |
| 168 | + |
| 169 | + return "", errors.New("release not found in list output") |
| 170 | +} |
0 commit comments