add request template

Author: horike37

lib/deploy/events/apiGateway/methods.js

@@ -0,0 +1,108 @@
+'use strict';
+
+const BbPromise = require('bluebird');
+const _ = require('lodash');
+
+module.exports = {
+
+  compileMethods() {
+    this.apiGatewayMethodLogicalIds = [];
+
+    this.pluginhttpValidated.events.forEach((event) => {
+      const resourceId = this.getResourceId(event.http.path);
+      const resourceName = this.getResourceName(event.http.path);
+      const requestParameters = (event.http.request && event.http.request.parameters) || {};
+
+      const template = {
+        Type: 'AWS::ApiGateway::Method',
+        Properties: {
+          HttpMethod: event.http.method.toUpperCase(),
+          RequestParameters: requestParameters,
+          ResourceId: resourceId,
+          RestApiId: { Ref: this.apiGatewayRestApiLogicalId },
+        },
+      };
+
+      if (event.http.private) {
+        template.Properties.ApiKeyRequired = true;
+      }
+
+      _.merge(template,
+        this.getMethodIntegration(event.http, event.stateMachineName)
+//        this.getMethodResponses(event.http)
+      );
+
+      const methodLogicalId = this.provider.naming
+        .getMethodLogicalId(resourceName, event.http.method);
+
+      this.apiGatewayMethodLogicalIds.push(methodLogicalId);
+
+      _.merge(this.serverless.service.provider.compiledCloudFormationTemplate.Resources, {
+        [methodLogicalId]: template,
+      });
+    });
+
+    return BbPromise.resolve();
+  },
+
+  getMethodIntegration(http, stateMachineName) {
+    const stateMachineLogicalId = this.getStateMachineLogicalId(stateMachineName);
+    const integration = {
+      IntegrationHttpMethod: 'POST',
+      Type: 'AWS',
+      Credentials: {
+        'Fn::GetAtt': [
+          'APIAssumeRolePolicyDocument',
+          'Arn',
+        ],
+      },
+      Uri: {
+        'Fn::Join': [
+          '',
+          [
+            'arn:aws:apigateway:',
+            {
+              Ref: 'AWS::Region',
+            },
+            ':states:action/StartExecution',
+          ],
+        ],
+      },
+      PassthroughBehavior: 'NEVER',
+      RequestTemplates: {
+        'application/json': {
+          'Fn::Join': [
+            '', [
+              "#set( $body = $util.escapeJavaScript($input.json('$')) ) \n\n",
+              '{"input": "$body","name": "$context.requestId","stateMachineArn":"',
+              {
+                Ref: `${stateMachineLogicalId}`,
+              },
+              '"}',
+            ],
+          ],
+        },
+      },
+      IntegrationResponses: [
+        {
+          StatusCode: 200,
+          SelectionPattern: '',
+          ResponseParameters: {},
+          ResponseTemplates: {},
+        },
+        {
+          StatusCode: 400,
+          SelectionPattern: '[\\s\\S]*\\[400\\][\\s\\S]*',
+          ResponseParameters: {},
+          ResponseTemplates: {},
+        },
+      ],
+    };
+
+    return {
+      Properties: {
+        Integration: integration,
+      },
+    };
+  },
+};

lib/index.js

@@ -6,6 +6,7 @@ const compileActivities = require('./deploy/stepFunctions/compileActivities');
 const compileIamRole = require('./deploy/stepFunctions/compileIamRole');
 const httpValidate = require('./deploy/events/apiGateway/validate');
 const httpResources = require('./deploy/events/apiGateway/resources');
+const httpMethods = require('./deploy/events/apiGateway/methods');
 const coreCompileRestApi =
   require('serverless/lib/plugins/aws/deploy/compile/events/apiGateway/lib/restApi');
 const yamlParser = require('./yamlParser');
@@ -39,6 +40,7 @@ class ServerlessStepFunctions {
       coreCompileRestApi,
       httpValidate,
       httpResources,
+      httpMethods,
       yamlParser,
       naming
     );
@@ -90,15 +92,15 @@ class ServerlessStepFunctions {
         .then(this.compileStateMachines)
         .then(this.compileActivities),
       'deploy:compileEvents': () => {
-    //    this.coreValidated = this.awsCompileApigEvents.validate();
         this.pluginhttpValidated = this.httpValidate();
 
         if (this.pluginhttpValidated.events.length === 0) {
           return BbPromise.resolve();
         } else if (!this.isCoreHttpevents()) {
           return BbPromise.bind(this)
             .then(this.compileRestApi)
-            .then(this.compileResources);
+            .then(this.compileResources)
+            .then(this.compileMethods);
         }
         return BbPromise.bind(this)
           .then(this.compileResources);