Adding slack integration for posting to channel on applies. Fixes #179

server/events/apply_executor.go

@@ -11,11 +11,13 @@ import (
 	"github.com/hootsuite/atlantis/server/events/github"
 	"github.com/hootsuite/atlantis/server/events/models"
 	"github.com/hootsuite/atlantis/server/events/run"
+	"github.com/hootsuite/atlantis/server/events/slack"
 	"github.com/hootsuite/atlantis/server/events/terraform"
 )
 
 type ApplyExecutor struct {
 	Github            github.Client
+	Slack             slack.Client
 	Terraform         *terraform.Client
 	RequireApproval   bool
 	Run               *run.Run
@@ -93,8 +95,14 @@ func (a *ApplyExecutor) apply(ctx *CommandContext, repoDir string, plan models.P
 	tfApplyCmd := append(append(append([]string{"apply", "-no-color"}, applyExtraArgs...), ctx.Command.Flags...), plan.LocalPath)
 	output, err := a.Terraform.RunCommandWithVersion(ctx.Log, absolutePath, tfApplyCmd, terraformVersion, env)
 	if err != nil {
+		if a.Slack != nil {
+			a.Slack.PostMessage(createSlackMessage(ctx, false))
+		}
 		return ProjectResult{Error: fmt.Errorf("%s\n%s", err.Error(), output)}
 	}
+	if a.Slack != nil {
+		a.Slack.PostMessage(createSlackMessage(ctx, true))
+	}
 	ctx.Log.Info("apply succeeded")
 
 	if len(config.PostApply) > 0 {
@@ -106,3 +114,19 @@ func (a *ApplyExecutor) apply(ctx *CommandContext, repoDir string, plan models.P
 
 	return ProjectResult{ApplySuccess: output}
 }
+
+func createSlackMessage(ctx *CommandContext, success bool) string {
+	var status string
+	if success {
+		status = ":white_check_mark:"
+	} else {
+		status = ":x:"
+	}
+
+	return fmt.Sprintf("%s *%s* %s in <%s|%s>.",
+		status,
+		ctx.User.Username,
+		ctx.Command.Name.String()+" "+ctx.Command.Environment,
+		ctx.Pull.URL,
+		ctx.BaseRepo.Name)
+}

server/events/slack/slack_client.go

@@ -0,0 +1,52 @@
+package slack
+
+import (
+	"errors"
+
+	"github.com/nlopes/slack"
+)
+
+type Client interface {
+	PostMessage(text string) (string, error)
+}
+
+type ConcreteClient struct {
+	client  *slack.Client
+	channel string
+}
+
+func NewClient(slackToken string, channelName string) (*ConcreteClient, error) {
+	slackClient := slack.New(slackToken)
+
+	if _, err := slackClient.AuthTest(); err != nil {
+		return nil, err
+	}
+
+	// https://api.slack.com/faq
+	// 'How do I find a channel's ID if I only have its #name?'
+	// says need to look through all channels and match the name
+	channels, err := slackClient.GetChannels(true)
+	if err != nil {
+		return nil, err
+	}
+	for _, c := range channels {
+		if c.Name == channelName {
+			// channel exists, no errors
+			return &ConcreteClient{
+				client:  slackClient,
+				channel: channelName,
+			}, nil
+		}
+	}
+
+	return nil, errors.New("channel_not_found")
+}
+
+func (s *ConcreteClient) PostMessage(text string) (string, error) {
+	params := slack.NewPostMessageParameters()
+	params.AsUser = true
+	params.EscapeText = false
+
+	_, timestamp, err := s.client.PostMessage(s.channel, text, params)
+	return timestamp, err
+}

server/server.go

@@ -18,6 +18,7 @@ import (
 	"github.com/hootsuite/atlantis/server/events/locking"
 	"github.com/hootsuite/atlantis/server/events/locking/boltdb"
 	"github.com/hootsuite/atlantis/server/events/run"
+	"github.com/hootsuite/atlantis/server/events/slack"
 	"github.com/hootsuite/atlantis/server/events/terraform"
 	"github.com/hootsuite/atlantis/server/logging"
 	"github.com/hootsuite/atlantis/server/static"
@@ -53,6 +54,8 @@ type Config struct {
 	LogLevel            string `mapstructure:"log-level"`
 	Port                int    `mapstructure:"port"`
 	RequireApproval     bool   `mapstructure:"require-approval"`
+	SlackToken          string `mapstructure:"slack-token"`
+	SlackChannel        string `mapstructure:"slack-channel"`
 }
 
 func NewServer(config Config) (*Server, error) {
@@ -61,6 +64,14 @@ func NewServer(config Config) (*Server, error) {
 		return nil, err
 	}
 	githubStatus := &events.GithubStatus{Client: githubClient}
+	// nil slackClient unless token and channel was specified
+	var slackClient slack.Client
+	if config.SlackToken != "" && config.SlackChannel != "" {
+		slackClient, err = slack.NewClient(config.SlackToken, config.SlackChannel)
+		if err != nil {
+			return nil, errors.Wrap(err, "initializing slack client")
+		}
+	}
 	terraformClient, err := terraform.NewClient()
 	if err != nil {
 		return nil, errors.Wrap(err, "initializing terraform")
@@ -86,6 +97,7 @@ func NewServer(config Config) (*Server, error) {
 	}
 	applyExecutor := &events.ApplyExecutor{
 		Github:            githubClient,
+		Slack:             slackClient,
 		Terraform:         terraformClient,
 		RequireApproval:   config.RequireApproval,
 		Run:               run,