move from s3 to sns

index.js

@@ -4,16 +4,14 @@ let s3Api = test ? require('./test/s3ApiMock.js') : require('./s3Api.js');
 exports.handler = async (event) => {
 
     let {
-        Records: [{
-            s3: {
-                bucket: {
-                    name: bucketName
-                },
-                object: {
-                    key: key
-                }
+        MessageAttributes: {
+            bucket: {
+                Value: bucketName
+            },
+            key: {
+                Value: key
             }
-        }]
+        }
     } = event;
 
     let fbFn = {

test/snsEventData.json

@@ -0,0 +1,21 @@
+{
+   "Type": "Notification",
+   "MessageId": "38c6d7ad-31ea-5dfa-ab09-84234e60df79",
+   "TopicArn": "arn:aws:sns:eu-west-1:029902516270:s2t-base-s2tNewFile-1SSWKUD35MW0J",
+   "Message": "not_empty",
+   "Timestamp": "2018-06-03T23:44:10.678Z",
+   "SignatureVersion": "1",
+   "Signature": "dlsQQtE23X1QBzN5SqHzTiSrpGxMnNCe3Eu5fYfVS+b2Y6uLpc9E27bTKFqTBf/XuvLiKYv/gba1KF5+dZk3inxkwE82cU0kZmULVRmPgylpdcdCjVURskCYugWoI6SmRY1mN2/0hb7bdNmt4KW3hnAUWKSiqcrIQNHURn4t9WUuhCMvqarTmc9j0G5XgO4wKQCrqTYSRreHe0qHdoAoM+ab1htptqCpCUKX8cs1nfwUqf7bPttJhaxUlIIyDTDo4NbS3i+LHxO1OLbTm9BkpDJBDKXBXIPLSkLMtZhQi94b5M6XXANOFls8gCIxHZlQzdU+EsjeXdFAq2MswpCY5Q==",
+   "SigningCertURL": "https://sns.eu-west-1.amazonaws.com/SimpleNotificationService-eaea6120e66ea12e88dcd8bcbddca752.pem",
+   "UnsubscribeURL": "https://sns.eu-west-1.amazonaws.com/?Action=Unsubscribe&SubscriptionArn=arn:aws:sns:eu-west-1:029902516270:s2t-base-s2tNewFile-1SSWKUD35MW0J:fa2b8a09-b038-4c79-b49d-b0d4eb71b5d2",
+   "MessageAttributes": {
+      "bucket": {
+         "Type": "String",
+         "Value": "s2t-base-s2tbucket-19xbw73dypb0s"
+      },
+      "key": {
+         "Type": "String",
+         "Value": "gcp/not-transcoded/sugr1km8s6/f423fbfb-6381-11e8-a23f-c7cbebde15f2.ogg"
+      }
+   }
+}

test/test.js

@@ -6,7 +6,7 @@ require('dotenv').config({
 const expect = require('chai').expect;
 
 const fs = require('fs');
-const event = JSON.parse(fs.readFileSync('test/s3EventData.json', 'utf8'));
+const event = JSON.parse(fs.readFileSync('test/snsEventData.json', 'utf8'));
 
 describe('eventhandler', () => {