feat(notifications): Add SNS msg attributes for service notification filtering (#2412); r=philbooth

lib/notifier.js

@@ -28,6 +28,21 @@ if (notifierSnsTopicArn !== 'disabled') {
   sns = new AWS.SNS({endpoint: notifierSnsTopicEndpoint, region: region})
 }
 
+function formatMessageAttributes(msg) {
+  const attrs = {}
+  attrs.event_type = {
+    DataType: 'String',
+    StringValue: msg.event
+  }
+  if (msg.email) {
+    attrs.email_domain = {
+      DataType: 'String',
+      StringValue: msg.email.split('@')[1]
+    }
+  }
+  return attrs
+}
+
 module.exports = function notifierLog(log) {
   return {
     send: (event, callback) => {
@@ -36,7 +51,8 @@ module.exports = function notifierLog(log) {
 
       sns.publish({
         TopicArn: notifierSnsTopicArn,
-        Message: JSON.stringify(msg)
+        Message: JSON.stringify(msg),
+        MessageAttributes: formatMessageAttributes(msg)
       }, (err, data) => {
         if (err) {
           log.error({op: 'Notifier.publish', err: err})

test/local/notifier.js

@@ -21,8 +21,11 @@ describe('notifier', () => {
     log.trace.reset()
   })
 
-  it('works with sns configuration', () => {
-    const config = {
+  describe('with sns configuration', () => {
+    let config, notifier
+
+    beforeEach(() => {
+      config = {
         get: (key) => {
           if (key === 'snsTopicArn') {
             return 'arn:aws:sns:us-west-2:927034868275:foo'
@@ -30,17 +33,43 @@ describe('notifier', () => {
         }
       }
 
-    const notifier = proxyquire(`${ROOT_DIR}/lib/notifier`, {
+      notifier = proxyquire(`${ROOT_DIR}/lib/notifier`, {
         '../config': config
       })(log)
 
       notifier.__sns.publish = sinon.spy((event, cb) => {
         cb(null, event)
       })
+    })
 
+    it('publishes a correctly-formatted message', () => {
       notifier.send({
-      event: {
-        stuff: true
+        event: 'stuff'
+      })
+
+      assert.deepEqual(log.trace.args[0][0], {
+        op: 'Notifier.publish',
+        data: {
+          TopicArn: 'arn:aws:sns:us-west-2:927034868275:foo',
+          Message: '{\"event\":\"stuff\"}',
+          MessageAttributes: {
+            event_type: {
+              DataType: 'String',
+              StringValue: 'stuff'
+            }
+          }
+        },
+        success: true
+      })
+      assert.equal(log.error.called, false)
+    })
+
+    it('flattens additional data into the message body', () => {
+      notifier.send({
+        event: 'stuff-with-data',
+        data: {
+          cool: 'stuff',
+          more: 'stuff'
         }
       })
 
@@ -48,13 +77,49 @@ describe('notifier', () => {
         op: 'Notifier.publish',
         data: {
           TopicArn: 'arn:aws:sns:us-west-2:927034868275:foo',
-        Message: '{\"event\":{\"stuff\":true}}'
+          Message: '{\"cool\":\"stuff\",\"more\":\"stuff\",\"event\":\"stuff-with-data\"}',
+          MessageAttributes: {
+            event_type: {
+              DataType: 'String',
+              StringValue: 'stuff-with-data'
+            }
+          }
         },
         success: true
       })
       assert.equal(log.error.called, false)
     })
 
+    it('includes email domain in message attributes', () => {
+      notifier.send({
+        event: 'email-change',
+        data: {
+          email: 'testme@example.com'
+        }
+      })
+
+      assert.deepEqual(log.trace.args[0][0], {
+        op: 'Notifier.publish',
+        data: {
+          TopicArn: 'arn:aws:sns:us-west-2:927034868275:foo',
+          Message: '{\"email\":\"testme@example.com\",\"event\":\"email-change\"}',
+          MessageAttributes: {
+            email_domain: {
+              DataType: 'String',
+              StringValue: 'example.com'
+            },
+            event_type: {
+              DataType: 'String',
+              StringValue: 'email-change'
+            }
+          }
+        },
+        success: true
+      })
+      assert.equal(log.error.called, false)
+    })
+  })
+
   it('works with disabled configuration', () => {
     const config = {
       get: (key) => {
@@ -68,7 +133,7 @@ describe('notifier', () => {
     })(log)
 
     notifier.send({
-      stuff: true
+      event: 'stuff'
     }, () => {
       assert.deepEqual(log.trace.args[0][0], {
         op: 'Notifier.publish',