add validation feature of sqs

Author: horike37

lib/index.js

@@ -19,7 +19,7 @@ const compileKinesisServiceProxy = require('./package/kinesis/compileKinesisServ
 // SQS
 const compileMethodsToSqs = require('./package/sqs/compileMethodsToSqs')
 const compileIamRoleToSqs = require('./package/sqs/compileIamRoleToSqs')
-//const validateKinesisServiceProxy = require('./package/sqs/validateKinesisServiceProxy')
+const validateSqsServiceProxy = require('./package/sqs/validateSqsServiceProxy')
 const compileSqsServiceProxy = require('./package/sqs/compileSqsServiceProxy')
 
 class ServerlessApigatewayServiceProxy {
@@ -44,6 +44,7 @@ class ServerlessApigatewayServiceProxy {
       compileMethodsToSqs,
       compileIamRoleToSqs,
       compileSqsServiceProxy,
+      validateSqsServiceProxy,
       getStackInfo,
       validate,
       methods,

lib/package/sqs/compileSqsServiceProxy.js

@@ -1,7 +1,7 @@
 'use strict'
 module.exports = {
   async compileSqsServiceProxy() {
-    //await this.validateKinesisServiceProxy()
+    await this.validateSqsServiceProxy()
     await this.compileIamRoleToSqs()
     await this.compileMethodsToSqs()
   }

lib/package/sqs/validateSqsServiceProxy.js

@@ -0,0 +1,44 @@
+'use strict'
+
+const BbPromise = require('bluebird')
+const _ = require('lodash')
+
+module.exports = {
+  async validateSqsServiceProxy() {
+    await BbPromise.all(
+      this.validated.events.map(async (serviceProxy) => {
+        if (serviceProxy.functionName == 'sqs') {
+          if (!_.has(serviceProxy.http, 'queueName')) {
+            return BbPromise.reject(
+              new this.serverless.classes.Error('Missing "queueName" property in SQS Service Proxy')
+            )
+          }
+
+          if (
+            typeof serviceProxy.http.queueName != 'object' &&
+            typeof serviceProxy.http.queueName != 'string'
+          ) {
+            const errorMessage = [
+              'You can only set "string" or the AWS "Fn::GetAtt" intrinsic function',
+              ' like { Fn::GetAtt: [ "SQSQueueResourceId", "QueueName" ] }}',
+              ' as a queueName property'
+            ].join('')
+            return BbPromise.reject(new this.serverless.classes.Error(errorMessage))
+          }
+
+          if (
+            typeof serviceProxy.http.queueName == 'object' &&
+            !_.has(serviceProxy.http.queueName, 'Fn::GetAtt')
+          ) {
+            const errorMessage = [
+              'You can only set "string" or the AWS "Fn::GetAtt" intrinsic function',
+              ' like { Fn::GetAtt: [ "SQSQueueResourceId", "QueueName" ] }}',
+              ' as a queueName property'
+            ].join('')
+            return BbPromise.reject(new this.serverless.classes.Error(errorMessage))
+          }
+        }
+      })
+    )
+  }
+}