format codepipeline notifications for slack

Author: ts33

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.');
   }
-};
+};