dynamically add and remove new stacks

Author: clangenb

swarmcd/init.go

@@ -111,6 +111,8 @@ func initStacks() error {
 	var newStackStatus = map[string]*StackStatus{}
 
 	for stack, stackConfig := range config.StackConfigs {
+		logger.Info(fmt.Sprintf("Initializing Stack %v", stack))
+
 		stackRepo, ok := repos[stackConfig.Repo]
 		if !ok {
 			return fmt.Errorf("error initializing %s stack, no such repo: %s", stack, stackConfig.Repo)

swarmcd/swarmcd.go

@@ -16,8 +16,7 @@ func Run() {
 		var waitGroup sync.WaitGroup
 		logger.Info("updating stacks...")
 		for _, swarmStack := range stacks {
-			logger.Info("Starting go routine for %v", swarmStack.name)
-
+			logger.Debug(fmt.Sprintf("Starting go routine for %v", swarmStack.name))
 			waitGroup.Add(1)
 			go updateStackThread(swarmStack, &waitGroup)
 		}
@@ -34,6 +33,7 @@ func updateStackConfigs() {
 	err := util.LoadConfigs()
 	if err != nil {
 		logger.Info("Error calling loadConfig again: %v", err)
+		return
 	}
 
 	err = initRepos()

util/config.go

@@ -77,6 +77,10 @@ func readRepoConfigs() (err error) {
 	if err != nil {
 		return
 	}
+
+	// **Reset maps before unmarshaling to remove old keys**
+	Configs.RepoConfigs = make(map[string]*RepoConfig)
+
 	return reposViper.Unmarshal(&Configs.RepoConfigs)
 }
 
@@ -88,5 +92,9 @@ func readStackConfigs() (err error) {
 	if err != nil {
 		return
 	}
+
+	// **Reset maps before unmarshaling to remove old keys**
+	Configs.StackConfigs = make(map[string]*StackConfig)
+
 	return stacksViper.Unmarshal(&Configs.StackConfigs)
 }