add sns emoji react

emojiReact.js

@@ -0,0 +1,18 @@
+exports.emojiReact = async function(event, context) {
+  try {
+    console.log(event);
+    console.log(JSON.stringify(event));
+    console.log(event.Records[0].Sns.Message);
+    console.log(JSON.parse(event.Records[0].Sns.Message));
+    return {
+      statusCode: 200,
+      body: "success"
+    };
+  } catch (err) {
+    console.log(err);
+    return {
+      statusCode: 401,
+      body: "fail"
+    };
+  }
+};

post.js

@@ -178,6 +178,7 @@ const times = x => f => {
 
 exports.post = async function(event, context) {
   try {
+    console.log("message", event.Records[0].Sns.Message);
     await getMembers({
       channel: event.Records[0].Sns.Message
     });
@@ -186,6 +187,7 @@ exports.post = async function(event, context) {
       body: "success"
     };
   } catch (err) {
+    console.log("error");
     console.log(err);
     return {
       statusCode: 401,

serverless.yml

@@ -5,6 +5,7 @@ custom:
     port: 4002 # a free port for the sns server to run on
     debug: false
   mySnsTopic: "${self:service}-${self:provider.stage}-sns-consume"
+  emojiReactionSns: "${self:service}-${self:provider.stage}-emoji-reaction-consume"
   mySnsTopicArn:
     local: "arn:aws:sns:us-east-1:123456789012:${self:custom.mySnsTopic}"
     dev:
@@ -31,6 +32,32 @@ custom:
             ],
           ],
       }
+  emojiReactionSnsArn:
+    local: "arn:aws:sns:us-east-1:123456789012:${self:custom.emojiReactionSns}"
+    dev:
+      {
+        "Fn::Join":
+          [
+            "",
+            [
+              "arn:aws:sns:${self:provider.region}:",
+              { "Ref": "AWS::AccountId" },
+              ":${self:custom.emojiReactionSns}",
+            ],
+          ],
+      }
+    prod:
+      {
+        "Fn::Join":
+          [
+            "",
+            [
+              "arn:aws:sns:${self:provider.region}:",
+              { "Ref": "AWS::AccountId" },
+              ":${self:custom.emojiReactionSns}",
+            ],
+          ],
+      }
 
 provider:
   name: aws
@@ -48,6 +75,7 @@ provider:
   environment:
     NODE_ENV: "${file(./serverless.env.yml):NODE_ENV}"
     SLACK_TOKEN: "${file(./serverless.env.yml):SLACK_TOKEN}"
+    APP_ID: "${file(./serverless.env.yml):APP_ID}"
 
 plugins:
   - serverless-offline
@@ -64,6 +92,10 @@ functions:
     handler: post.post
     events:
       - sns: ${self:custom.mySnsTopic}
+  emojiReact:
+    handler: emojiReact.emojiReact
+    events:
+      - sns: ${self:custom.emojiReactionSns}
 
   trigger:
     handler: trigger.trigger
@@ -73,3 +105,4 @@ functions:
           method: any
     environment:
       mySnsTopicArn: ${self:custom.mySnsTopicArn.${self:provider.stage}}
+      emojiReactionSnsArn: ${self:custom.emojiReactionSnsArn.${self:provider.stage}}

trigger.js

@@ -2,6 +2,14 @@ const AWS = require("aws-sdk");
 
 exports.trigger = async function(event, context) {
   try {
+    const eventBody = JSON.parse(event.body).event;
+    if (isReactionToOtherPost(eventBody)) {
+      return {
+        statusCode: 200,
+        body: "ok"
+      };
+    }
+
     let snsOpts = {
       region: "eu-west-1"
     };
@@ -11,10 +19,27 @@ exports.trigger = async function(event, context) {
     }
 
     let sns = new AWS.SNS(snsOpts);
-    let messageData = {
-      Message: JSON.parse(event.body).event.channel,
-      TopicArn: process.env.mySnsTopicArn
-    };
+
+    let messageData;
+    switch (eventBody.type) {
+      case "app_mention":
+        messageData = {
+          Message: eventBody.channel,
+          TopicArn: process.env.mySnsTopicArn
+        };
+        break;
+      case "reaction_added":
+        console.log("getting into reaction");
+        console.log();
+        messageData = {
+          Message: JSON.stringify({
+            item: eventBody.item,
+            reaction: eventBody.reaction
+          }),
+          TopicArn: process.env.emojiReactionSnsArn
+        };
+        break;
+    }
 
     console.log("PUBLISHING MESSAGE TO SNS:", messageData);
     await sns.publish(messageData).promise();
@@ -25,11 +50,14 @@ exports.trigger = async function(event, context) {
       body: "ok"
     };
   } catch (err) {
-    console.log("error", err);
     console.error(err);
     return {
       statusCode: 200,
       body: "ok"
     };
   }
 };
+
+function isReactionToOtherPost({ type, item_user }) {
+  return type === "reaction_added" && item_user !== process.env.APP_ID;
+}