Feature/format codepipeline notifications

Makefile

@@ -15,10 +15,21 @@ deps:
 .PHONY: test
 test:
 	@test -s $(CONFIG_FILE) || { echo "No lambda config file. Update deploy.env.example and copy it to deploy.env"; exit 1; }
-	AWS_REGION=$(AWS_REGION) $(LAMBDA_TEST) --configFile=$(CONFIG_FILE) run -x test/context.json -j test/sns-cloudwatch-event.json
+	AWS_REGION=$(AWS_REGION) $(LAMBDA_TEST) --configFile=$(CONFIG_FILE) run -x test/context.json -j test/sns-codedeploy-event.json
+
+.PHONY: test-codepipeline
+test-codepipeline:
+	@test -s $(CONFIG_FILE) || { echo "No lambda config file. Update deploy.env.example and copy it to deploy.env"; exit 1; }
+	AWS_REGION=$(AWS_REGION) $(LAMBDA_TEST) --configFile=$(CONFIG_FILE) run -x test/context.json -j test/sns-codepipeline-event-pipeline-started.json
+	AWS_REGION=$(AWS_REGION) $(LAMBDA_TEST) --configFile=$(CONFIG_FILE) run -x test/context.json -j test/sns-codepipeline-event-stage-started.json
+	AWS_REGION=$(AWS_REGION) $(LAMBDA_TEST) --configFile=$(CONFIG_FILE) run -x test/context.json -j test/sns-codepipeline-event-stage-succeeded.json
+	AWS_REGION=$(AWS_REGION) $(LAMBDA_TEST) --configFile=$(CONFIG_FILE) run -x test/context.json -j test/sns-codepipeline-event-stage-failed.json
+
 
 .PHONY: test-all
-test-all: test
+test-all: test test-codepipeline
+	AWS_REGION=$(AWS_REGION) $(LAMBDA_TEST) --configFile=$(CONFIG_FILE) run -x test/context.json -j test/sns-cloudwatch-event.json
+	AWS_REGION=$(AWS_REGION) $(LAMBDA_TEST) --configFile=$(CONFIG_FILE) run -x test/context.json -j test/sns-codepipeline-event.json
 	AWS_REGION=$(AWS_REGION) $(LAMBDA_TEST) --configFile=$(CONFIG_FILE) run -x test/context.json -j test/sns-event.json
 	AWS_REGION=$(AWS_REGION) $(LAMBDA_TEST) --configFile=$(CONFIG_FILE) run -x test/context.json -j test/sns-elastic-beanstalk-event.json
 	AWS_REGION=$(AWS_REGION) $(LAMBDA_TEST) --configFile=$(CONFIG_FILE) run -x test/context.json -j test/sns-codedeploy-event.json
@@ -39,4 +50,4 @@ deploy:
 				--secretKey $(AWS_ACCESS_KEY_SECRET) \
 				--region $(AWS_REGION) \
 				--configFile $(CONFIG_FILE) \
-				--profile $(AWS_PROFILE)
+				--profile $(AWS_PROFILE)

config.js

@@ -17,6 +17,10 @@ module.exports = {
       // text in the sns message or topicname to match on to process this service type
       match_text: "CloudWatchNotifications"
     },
+    codepipeline: {
+      // text in the sns message or topicname to match on to process this service type
+      match_text: "CodePipelineNotifications"
+    },
     codedeploy: {
       // text in the sns message or topicname to match on to process this service type
       match_text: "CodeDeploy"
@@ -31,4 +35,4 @@ module.exports = {
     }
   }
 
-}
+}

index.js

@@ -144,6 +144,65 @@ var handleCodeDeploy = function(event, context) {
   return _.merge(slackMessage, baseSlackMessage);
 };
 
+var handleCodePipeline = function(event, context) {
+  var subject = "AWS CodePipeline Notification";
+  var timestamp = (new Date(event.Records[0].Sns.Timestamp)).getTime()/1000;
+  var snsSubject = event.Records[0].Sns.Subject;
+  var message;
+  var fields = [];
+  var color = "warning";
+  var changeType = "";
+
+  try {
+    message = JSON.parse(event.Records[0].Sns.Message);
+    detailType = message['detail-type'];
+
+    if(detailType === "CodePipeline Pipeline Execution State Change"){
+      changeType = "";
+    } else if(detailType === "CodePipeline Stage Execution State Change"){
+      changeType = "STAGE " + message.detail.stage;
+    } else if(detailType === "CodePipeline Action Execution State Change"){
+      changeType = "ACTION";
+    }
+
+    if(message.detail.state === "SUCCEEDED"){
+      color = "good";
+    } else if(message.detail.state === "FAILED"){
+      color = "danger";
+    }
+    header = message.detail.state + ": CodePipeline " + changeType;
+    fields.push({ "title": "Message", "value": header, "short": false });
+    fields.push({ "title": "Pipeline", "value": message.detail.pipeline, "short": true });
+    fields.push({ "title": "Region", "value": message.region, "short": true });
+    fields.push({
+      "title": "Status Link",
+      "value": "https://console.aws.amazon.com/codepipeline/home?region=" + message.region + "#/view/" + message.detail.pipeline,
+      "short": false
+    });
+  }
+  catch(e) {
+    color = "good";
+    message = event.Records[0].Sns.Message;
+    header = message.detail.state + ": CodePipeline " + message.detail.pipeline;
+    fields.push({ "title": "Message", "value": header, "short": false });
+    fields.push({ "title": "Detail", "value": message, "short": false });
+  }
+
+
+  var slackMessage = {
+    text: "*" + subject + "*",
+    attachments: [
+      {
+        "color": color,
+        "fields": fields,
+        "ts": timestamp
+      }
+    ]
+  };
+
+  return _.merge(slackMessage, baseSlackMessage);
+};
+
 var handleElasticache = function(event, context) {
   var subject = "AWS ElastiCache Notification"
   var message = JSON.parse(event.Records[0].Sns.Message);
@@ -311,7 +370,11 @@ var processEvent = function(event, context) {
   var eventSnsSubject = event.Records[0].Sns.Subject || 'no subject';
   var eventSnsMessage = event.Records[0].Sns.Message;
 
-  if(eventSubscriptionArn.indexOf(config.services.elasticbeanstalk.match_text) > -1 || eventSnsSubject.indexOf(config.services.elasticbeanstalk.match_text) > -1 || eventSnsMessage.indexOf(config.services.elasticbeanstalk.match_text) > -1){
+  if(eventSubscriptionArn.indexOf(config.services.codepipeline.match_text) > -1 || eventSnsSubject.indexOf(config.services.codepipeline.match_text) > -1 || eventSnsMessage.indexOf(config.services.codepipeline.match_text) > -1){
+    console.log("processing codepipeline notification");
+    slackMessage = handleCodePipeline(event,context)
+  }
+  else if(eventSubscriptionArn.indexOf(config.services.elasticbeanstalk.match_text) > -1 || eventSnsSubject.indexOf(config.services.elasticbeanstalk.match_text) > -1 || eventSnsMessage.indexOf(config.services.elasticbeanstalk.match_text) > -1){
     console.log("processing elasticbeanstalk notification");
     slackMessage = handleElasticBeanstalk(event,context)
   }
@@ -373,4 +436,4 @@ exports.handler = function(event, context) {
   } else {
     context.fail('hook url has not been set.');
   }
-};
+};

test/sns-codepipeline-event-pipeline-started.json

@@ -0,0 +1,18 @@
+{
+  "Records": [
+    {
+      "EventSource": "aws:sns",
+      "EventVersion": "1.0",
+      "EventSubscriptionArn": "arn:aws:sns:us-east-1:123456789123:CodePipelineNotifications:00000000-0000-0000-0000-000000000000",
+      "Sns": {
+        "Type": "Notification",
+        "MessageId": "00000000-0000-0000-0000-000000000000",
+        "TopicArn": "arn:aws:sns:us-east-1:123456789:codepipeline-alerts",
+        "Subject": null,
+        "Message": "{\"version\":\"0\",\"id\":\"00000000-0000-0000-0000-000000000000\",\"detail-type\":\"CodePipeline Pipeline Execution State Change\",\"source\":\"aws.codepipeline\",\"account\":\"123456789123\",\"time\":\"2018-02-14T07:14:14Z\",\"region\":\"us-east-1\",\"resources\":[\"arn:aws:codepipeline:us-east-1:123456789123:a-pipeline-project\"],\"detail\":{\"pipeline\":\"a-pipeline-project\",\"execution-id\":\"00000000-0000-0000-0000-000000000000\",\"state\":\"STARTED\",\"version\":1.0}}",
+        "Timestamp": "2018-02-14T07:14:27.208Z",
+        "MessageAttributes": {}
+      }
+    }
+  ]
+}

test/sns-codepipeline-event-stage-failed.json

@@ -0,0 +1,18 @@
+{
+  "Records": [
+    {
+      "EventSource": "aws:sns",
+      "EventVersion": "1.0",
+      "EventSubscriptionArn": "arn:aws:sns:us-east-1:123456789123:CodePipelineNotifications:00000000-0000-0000-0000-000000000000",
+      "Sns": {
+        "Type": "Notification",
+        "MessageId": "00000000-0000-0000-0000-000000000000",
+        "TopicArn": "arn:aws:sns:us-east-1:123456789:codepipeline-alerts",
+        "Subject": null,
+        "Message": "{\"version\":\"0\",\"id\":\"00000000-0000-0000-0000-000000000000\",\"detail-type\":\"CodePipeline Stage Execution State Change\",\"source\":\"aws.codepipeline\",\"account\":\"123456789123\",\"time\":\"2018-02-14T07:14:14Z\",\"region\":\"us-east-1\",\"resources\":[\"arn:aws:codepipeline:us-east-1:123456789123:a-pipeline-project\"],\"detail\":{\"pipeline\":\"a-pipeline-project\",\"execution-id\":\"00000000-0000-0000-0000-000000000000\",\"stage\":\"Build\",\"state\":\"FAILED\",\"version\":1.0}}",
+        "Timestamp": "2018-02-14T07:14:27.208Z",
+        "MessageAttributes": {}
+      }
+    }
+  ]
+}

test/sns-codepipeline-event-stage-started.json

@@ -0,0 +1,18 @@
+{
+  "Records": [
+    {
+      "EventSource": "aws:sns",
+      "EventVersion": "1.0",
+      "EventSubscriptionArn": "arn:aws:sns:us-east-1:123456789123:CodePipelineNotifications:00000000-0000-0000-0000-000000000000",
+      "Sns": {
+        "Type": "Notification",
+        "MessageId": "00000000-0000-0000-0000-000000000000",
+        "TopicArn": "arn:aws:sns:us-east-1:123456789:codepipeline-alerts",
+        "Subject": null,
+        "Message": "{\"version\":\"0\",\"id\":\"00000000-0000-0000-0000-000000000000\",\"detail-type\":\"CodePipeline Stage Execution State Change\",\"source\":\"aws.codepipeline\",\"account\":\"123456789123\",\"time\":\"2018-02-14T07:14:14Z\",\"region\":\"us-east-1\",\"resources\":[\"arn:aws:codepipeline:us-east-1:123456789123:a-pipeline-project\"],\"detail\":{\"pipeline\":\"a-pipeline-project\",\"execution-id\":\"00000000-0000-0000-0000-000000000000\",\"stage\":\"Build\",\"state\":\"STARTED\",\"version\":1.0}}",
+        "Timestamp": "2018-02-14T07:14:27.208Z",
+        "MessageAttributes": {}
+      }
+    }
+  ]
+}

test/sns-codepipeline-event-stage-succeeded.json

@@ -0,0 +1,18 @@
+{
+  "Records": [
+    {
+      "EventSource": "aws:sns",
+      "EventVersion": "1.0",
+      "EventSubscriptionArn": "arn:aws:sns:us-east-1:123456789123:CodePipelineNotifications:00000000-0000-0000-0000-000000000000",
+      "Sns": {
+        "Type": "Notification",
+        "MessageId": "00000000-0000-0000-0000-000000000000",
+        "TopicArn": "arn:aws:sns:us-east-1:123456789:codepipeline-alerts",
+        "Subject": null,
+        "Message": "{\"version\":\"0\",\"id\":\"00000000-0000-0000-0000-000000000000\",\"detail-type\":\"CodePipeline Stage Execution State Change\",\"source\":\"aws.codepipeline\",\"account\":\"123456789123\",\"time\":\"2018-02-14T07:14:14Z\",\"region\":\"us-east-1\",\"resources\":[\"arn:aws:codepipeline:us-east-1:123456789123:a-pipeline-project\"],\"detail\":{\"pipeline\":\"a-pipeline-project\",\"execution-id\":\"00000000-0000-0000-0000-000000000000\",\"stage\":\"Build\",\"state\":\"SUCCEEDED\",\"version\":1.0}}",
+        "Timestamp": "2018-02-14T07:14:27.208Z",
+        "MessageAttributes": {}
+      }
+    }
+  ]
+}