Visibility timout

.gitignore

@@ -4,3 +4,4 @@ jspm_packages
 # Serverless directories
 **/.serverless
 node_modules
+/.idea

README.md

@@ -43,6 +43,7 @@ functions:
           topicArn: !Ref Topic # Required - SNS topic to subscribe to
           batchSize: 2 # Optional - default value is 10
           maxRetryCount: 2 # Optional - default value is 5
+          rawMessageDelivery: true # Optional - default value is true
           filterPolicy: # Optional - filter messages that are handled
             pets:
               - dog

lib/serverless-sns-sqs-lambda.js

@@ -144,10 +144,11 @@ Usage
       handler: handler.handler
       events:
         - snsSqs:
-            name: Event             # required
-            topicArn: !Ref TopicArn # required
-            maxRetryCount: 2        # optional - default is 5
-            batchSize: 1            # optional - default is 10
+            name: Event               # required
+            topicArn: !Ref TopicArn   # required
+            maxRetryCount: 2          # optional - default is 5
+            batchSize: 1              # optional - default is 10
+            rawMessageDelivery: false # optional - default is true
             filterPolicy:
               pet:
                 - dog
@@ -164,7 +165,8 @@ Usage
       prefix:
         config.prefix || `${this.serviceName}-${stage}-${funcNamePascalCase}`,
       batchSize: parseIntOr(config.batchSize, 10),
-      maxRetryCount: parseIntOr(config.maxRetryCount, 5)
+      maxRetryCount: parseIntOr(config.maxRetryCount, 5),
+      rawMessageDelivery: config.rawMessageDelivery !== undefined ? config.rawMessageDelivery : true
     };
   }
 
@@ -209,10 +211,10 @@ Usage
    * from SNS as they arrive, holding them for processing.
    *
    * @param {object} template the template which gets mutated
-   * @param {{name, prefix, maxRetryCount}} config including name of the queue,
+   * @param {{name, prefix, maxRetryCount, visibilityTimeout}} config including name of the queue,
    *  the resource prefix and the max retry count for message handler failures.
    */
-  addEventQueue(template, { name, prefix, maxRetryCount }) {
+  addEventQueue(template, { name, prefix, maxRetryCount, visibilityTimeout }) {
     template.Resources[`${name}Queue`] = {
       Type: "AWS::SQS::Queue",
       Properties: {
@@ -222,7 +224,8 @@ Usage
             "Fn::GetAtt": [`${name}DeadLetterQueue`, "Arn"]
           },
           maxReceiveCount: maxRetryCount
-        }
+        },
+        VisibilityTimeout: visibilityTimeout
       }
     };
   }
@@ -264,13 +267,14 @@ Usage
    * @param {{name, topicArn, filterPolicy}} config including name of the queue,
    *  the arn of the topic and the filter policy for the subscription
    */
-  addTopicSubscription(template, { name, topicArn, filterPolicy }) {
+  addTopicSubscription(template, { name, topicArn, filterPolicy, rawMessageDelivery }) {
     template.Resources[`Subscribe${name}Topic`] = {
       Type: "AWS::SNS::Subscription",
       Properties: {
         Endpoint: { "Fn::GetAtt": [`${name}Queue`, "Arn"] },
         Protocol: "sqs",
         TopicArn: topicArn,
+        RawMessageDelivery: rawMessageDelivery,
         ...(filterPolicy ? { FilterPolicy: filterPolicy } : {})
       }
     };

package.json

@@ -1,5 +1,5 @@
 {
-  "name": "@agiledigital/serverless-sns-sqs-lambda",
+  "name": "@venncity/serverless-sns-sqs-lambda",
   "version": "0.1.8",
   "description": "serverless plugin to make serverless-sns-sqs-lambda events",
   "main": "lib/serverless-sns-sqs-lambda.js",