moritz
/
abra
forked from coop-cloud/abra
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

evaluate if autoupdates are enabled

This commit is contained in:
Moritz 2023-01-31 14:08:33 +01:00
parent 988c673ebe
commit c7e2dac94c
1 changed files with 26 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
cli/updater/updater.go
View File

@ -77,10 +77,11 @@ var UpgradeAll = cli.Command{
stackName := stackInfo.Name
recipeName := getRecipe(cl, stackName)
chaos := getChaos(cl, stackName)
if recipeName != "" && (!chaos || internal.Force) {
updatesEnabled := getUpdateActivation(cl, stackName)
if recipeName != "" && updatesEnabled && (!chaos || internal.Force) {
upgrade(cl, stackName, recipeName)
} else {
logrus.Infof("Don't update %s due to missing recipe name or chaos deployment", stackName)
logrus.Infof("Don't update %s due to missing recipe name, disabled updates or chaos deployment", stackName)
}
}
return nil
@ -129,6 +130,29 @@ func getChaos(cl *dockerclient.Client, stackName string) bool {
return false
}
// Read chaos deployment from docker label
func getUpdateActivation(cl *dockerclient.Client, stackName string) bool {
filter := filters.NewArgs()
filter.Add("label", fmt.Sprintf("%s=%s", convert.LabelNamespace, stackName))
services, err := cl.ServiceList(context.Background(), types.ServiceListOptions{Filters: filter})
if err != nil {
logrus.Fatal(err)
}
for _, service := range services {
labelKey := fmt.Sprintf("coop-cloud.%s.autoupdate", stackName)
if chaosLabel, ok := service.Spec.Labels[labelKey]; ok {
chaos, err := strconv.ParseBool(chaosLabel)
if err != nil {
logrus.Fatal(err)
}
return chaos
}
}
logrus.Debugf("no autoupdate label found for %s", stackName)
return false
}
// Read Env variables from docker services
func getEnv(cl *dockerclient.Client, stackName string) config.AppEnv {
envMap := make(map[string]string)
@ -279,7 +303,6 @@ func upgrade(cl *dockerclient.Client, stackName string, recipeName string) {
Server: "localhost",
Env: getEnv(cl, stackName),
}
// TODO: evaluate ENABLE_AUTO_UPDATE env var
availableUpgrades := getAvailableUpgrades(cl, stackName, recipeName)
if len(availableUpgrades) == 0 {