turret-io · December 22, 2016 16:16 · Jun 5, 2015 · Jun 5, 2015 · Jun 4, 2015
diff --git a/slackNotify.js b/slackNotify.js
@@ -1,6 +1,7 @@
 var http = require('https');
 
 // Create Slack channel -> Slack URL mapping
+// This incoming webhook URL is provided when adding a Slack integration
 var config = {
     '#mychannel': 'https://hooks.slack.com/services/YOUR/SLACK/HOOK_HERE',
 };

diff --git a/slackNotify.js b/slackNotify.js
@@ -3,33 +3,33 @@ var http = require('https');
 // Create Slack channel -> Slack URL mapping
 var config = {
     '#mychannel': 'https://hooks.slack.com/services/YOUR/SLACK/HOOK_HERE',
-}
+};
 
 /*
   Convenience method to fetch the channel's URL
 */
 get_channel_endpoint = function(chan) {
     return config[chan];
-}
+};
 
 /*
   Parse the SNS payload. This function assumes only one message
   notification is sent as part of the payload. The payload is
   broken up into key:value pairs and returned as an object.
 */
 parse = function(payload) {
-    parts = payload['Records'][0]['Sns']['Message'].split('\n');
+    parts = payload.Records[0].Sns.Message.split('\n');
     data = {};
     parts.forEach(function(part) {
         if(part.length < 1) {
             return;
         }
         key = part.split(':', 1)[0];
-        value = part.split(key+': ').reverse()[0]
+        value = part.split(key+': ').reverse()[0];
         data[key] = value;
     });
     return data;
-}
+};
 
 /*
   Convenience method for creating the payload to send to Slack
@@ -39,7 +39,7 @@ buildSlackPayload = function(postData, endPoint) {
         'postData': JSON.stringify(postData), 
         'options': endPoint
     };
-}
+};
 
 /*
   Adds extra "attachment" data to display a customized message in Slack
@@ -53,10 +53,10 @@ makeSlackAttachmentFields = function(d) {
        if(excludeKeys.indexOf(k) != -1) {
            return;
        }
-       arr.push({"title": k, "value": d[k], "short":false}) 
+       arr.push({"title": k, "value": d[k], "short":false});
     });
     return arr;
-}
+};
 
 /*
   Main Lambda handler
@@ -80,16 +80,16 @@ exports.handler = function(event, context) {
         "username": "builder",
         "attachments": [
             {
-                "fallback": data['Message'],
-                "text": data['Message'],
+                "fallback": data.Message,
+                "text": data.Message,
                 "fields": dataFields
             }    
         ]
-    }
+    };
     dOpt = buildSlackPayload(postData, get_channel_endpoint(channel));
 
     // Create HTTP request
-    var req = http.request(dOpt['options'], function(res){
+    var req = http.request(dOpt.options, function(res){
         res.setEncoding("utf8");
         res.on('data', function(d) {
             console.log(d);
@@ -107,10 +107,10 @@ exports.handler = function(event, context) {
 
     // Set request headers
     req.setHeader('Content-Type', 'application/x-www-form-urlencoded');
-    req.setHeader('Content-Length', dOpt['postData'].length);
+    req.setHeader('Content-Length', dOpt.postData.length);
 
     // Write the actual POST data
-    req.write(dOpt['postData']);
+    req.write(dOpt.postData);
 
     // Indicate no additional data will be written
     req.end();

diff --git a/slackNotify.js b/slackNotify.js
@@ -0,0 +1,117 @@
+var http = require('https');
+
+// Create Slack channel -> Slack URL mapping
+var config = {
+    '#mychannel': 'https://hooks.slack.com/services/YOUR/SLACK/HOOK_HERE',
+}
+
+/*
+  Convenience method to fetch the channel's URL
+*/
+get_channel_endpoint = function(chan) {
+    return config[chan];
+}
+
+/*
+  Parse the SNS payload. This function assumes only one message
+  notification is sent as part of the payload. The payload is
+  broken up into key:value pairs and returned as an object.
+*/
+parse = function(payload) {
+    parts = payload['Records'][0]['Sns']['Message'].split('\n');
+    data = {};
+    parts.forEach(function(part) {
+        if(part.length < 1) {
+            return;
+        }
+        key = part.split(':', 1)[0];
+        value = part.split(key+': ').reverse()[0]
+        data[key] = value;
+    });
+    return data;
+}
+
+/*
+  Convenience method for creating the payload to send to Slack
+*/
+buildSlackPayload = function(postData, endPoint) {
+    return {
+        'postData': JSON.stringify(postData), 
+        'options': endPoint
+    };
+}
+
+/*
+  Adds extra "attachment" data to display a customized message in Slack
+  instead of a simple message. We're excluding 'Message' here beacuse
+  we're using message as the main content of the Slack notification.
+*/
+makeSlackAttachmentFields = function(d) {
+    var excludeKeys = ['RequestId', 'NotificationProcessId', 'Message'];
+    var arr = [];
+    Object.keys(d).forEach(function(k){
+       if(excludeKeys.indexOf(k) != -1) {
+           return;
+       }
+       arr.push({"title": k, "value": d[k], "short":false}) 
+    });
+    return arr;
+}
+
+/*
+  Main Lambda handler
+*/
+exports.handler = function(event, context) {
+    // Slack channel to notify
+    var channel = "#mychannel";
+
+    // Parse event data from SNS
+    data = parse(event);
+
+    // Create Slack attachment data
+    dataFields = makeSlackAttachmentFields(data);
+
+    postData = {
+        // Set the Slack channel within the payload
+        "channel": channel,
+
+        // Name of the Slack "bot" (this can be anything, doesn't
+        // have to be an existing user)
+        "username": "builder",
+        "attachments": [
+            {
+                "fallback": data['Message'],
+                "text": data['Message'],
+                "fields": dataFields
+            }    
+        ]
+    }
+    dOpt = buildSlackPayload(postData, get_channel_endpoint(channel));
+
+    // Create HTTP request
+    var req = http.request(dOpt['options'], function(res){
+        res.setEncoding("utf8");
+        res.on('data', function(d) {
+            console.log(d);
+            // Wait for a response before calling succeed, otherwise
+            // our Lambda function will exit too early
+            context.succeed();
+        });
+    });
+    req.on('error', function(err){
+        console.log(err.message);
+        // If we get an error, stop execution.
+        context.fail(err.message);
+
+    });
+
+    // Set request headers
+    req.setHeader('Content-Type', 'application/x-www-form-urlencoded');
+    req.setHeader('Content-Length', dOpt['postData'].length);
+
+    // Write the actual POST data
+    req.write(dOpt['postData']);
+
+    // Indicate no additional data will be written
+    req.end();
+};
No results found