Allow for posting to multiple slack channels

ankh/main.go

@@ -299,7 +299,7 @@ func reconcileMissingConfigs(ctx *ankh.ExecutionContext, ankhFile *ankh.AnkhFile
 		}
 
 		// we should finally have a tag value
-		if ctx.SlackChannel != "" {
+		if len(ctx.SlackChannels) > 0 {
 			ctx.SlackDeploymentVersion = *chart.Tag
 		}
 	}
@@ -414,7 +414,7 @@ func execute(ctx *ankh.ExecutionContext) {
 		executeContext(ctx, &rootAnkhFile)
 	}
 
-	if ctx.SlackChannel != "" {
+	if len(ctx.SlackChannels) > 0 {
 		if ctx.Mode == ankh.Rollback {
 			ctx.SlackDeploymentVersion = "rollback"
 		}
@@ -889,7 +889,7 @@ func main() {
 				ctx.LocalChart = true
 			}
 			ctx.Mode = ankh.Apply
-			ctx.SlackChannel = *slackChannel
+			ctx.SlackChannels = append(ctx.SlackChannels, *slackChannel)
 			ctx.SlackMessageOverride = *slackMessageOverride
 			filters := []string{}
 			for _, filter := range *filter {
@@ -921,7 +921,7 @@ func main() {
 				ctx.LocalChart = true
 			}
 			ctx.Mode = ankh.Rollback
-			ctx.SlackChannel = *slackChannel
+			ctx.SlackChannels = append(ctx.SlackChannels, *slackChannel)
 			ctx.SlackMessageOverride = *slackMessageOverride
 			ctx.Filters = []string{"deployment", "statfulset"}
 

context/context.go

@@ -53,7 +53,7 @@ type ExecutionContext struct {
 	DataDir        string
 	HelmSetValues  map[string]string
 
-	SlackChannel           string
+	SlackChannels          []string
 	SlackMessageOverride   string
 	SlackDeploymentVersion string
 
@@ -78,7 +78,7 @@ type Context struct {
 	Release            string                 `yaml:"release,omitempty"`
 	HelmRegistryURL    string                 `yaml:"helm-registry-url,omitempty"` // deprecated in favor of top-level config `helm.registry`
 	ClusterAdminUnused bool                   `yaml:"cluster-admin,omitempty"`     // deprecated
-	Global             map[string]interface{} `yaml:"global",omitempty"`
+	Global             map[string]interface{} `yaml:"global,omitempty"`
 }
 
 // An Environment is a collection of contexts over which operations should be applied

slack/slack.go

@@ -52,16 +52,22 @@ func PingSlackChannel(ctx *ankh.ExecutionContext) error {
 		Username: username,
 	}
 
-	channelId, err := getSlackChannelIDByName(api, ctx.SlackChannel)
-	if err != nil {
-		return err
-	}
-
-	if !ctx.DryRun {
-		_, _, err = api.PostMessage(channelId, slack.MsgOptionAttachments(attachment), slack.MsgOptionPostMessageParameters(messageParams))
-	} else {
-		ctx.Logger.Infof("--dry-run set so not sending message '%v' to slack channel %v", messageText, ctx.SlackChannel)
-	}
+        channels := make(map[string]string, len(ctx.SlackChannels))
+	for _, ch := range ctx.SlackChannels {
+		channelId, err := getSlackChannelIDByName(api, ch)
+	        if err != nil {
+		        return err
+	        }
+                channels[ch] = channelId
+        }
+
+	for name, id := range channels {
+	        if !ctx.DryRun {
+		        _, _, err = api.PostMessage(id, slack.MsgOptionAttachments(attachment), slack.MsgOptionPostMessageParameters(messageParams))
+	        } else {
+		        ctx.Logger.Infof("--dry-run set so not sending message '%v' to slack channel %v", messageText, name)
+	        }
+        }
 
 	return err
 }