change async way

Author: horike37

lib/package/kinesis/compileMethodsToKinesis.js

@@ -6,7 +6,7 @@ const _ = require('lodash')
 module.exports = {
   async compileMethodsToKinesis() {
     this.apiGatewayMethodLogicalIds = []
-    this.validated.events.forEach((event) => {
+    this.validated.events.forEach(async (event) => {
       const resourceId = this.getResourceId(event.http.path)
       const resourceName = this.getResourceName(event.http.path)
 
@@ -24,8 +24,8 @@ module.exports = {
 
       _.merge(
         template,
-        this.getKinesisMethodIntegration(event.http),
-        this.getMethodResponses(event.http)
+        await this.getKinesisMethodIntegration(event.http),
+        await this.getMethodResponses(event.http)
       )
 
       const methodLogicalId = this.provider.naming.getMethodLogicalId(
@@ -43,7 +43,7 @@ module.exports = {
     return BbPromise.resolve()
   },
 
-  getKinesisMethodIntegration(http) {
+  async getKinesisMethodIntegration(http) {
     const integration = {
       IntegrationHttpMethod: 'POST',
       Type: 'AWS',
@@ -63,7 +63,7 @@ module.exports = {
         ]
       },
       PassthroughBehavior: 'NEVER',
-      RequestTemplates: this.getKinesisIntegrationRequestTemplates(http)
+      RequestTemplates: await this.getKinesisIntegrationRequestTemplates(http)
     }
 
     const integrationResponse = {
@@ -89,7 +89,7 @@ module.exports = {
         origin = http.cors.origins.join(',')
       }
 
-      integrationResponse.IntegrationResponses.forEach((val, i) => {
+      integrationResponse.IntegrationResponses.forEach(async (val, i) => {
         integrationResponse.IntegrationResponses[i].ResponseParameters = {
           'method.response.header.Access-Control-Allow-Origin': `'${origin}'`
         }
@@ -105,19 +105,19 @@ module.exports = {
     }
   },
 
-  getKinesisIntegrationRequestTemplates(http) {
-    const defaultRequestTemplates = this.getDefaultKinesisRequestTemplates(http)
+  async getKinesisIntegrationRequestTemplates(http) {
+    const defaultRequestTemplates = await this.getDefaultKinesisRequestTemplates(http)
     return Object.assign(defaultRequestTemplates, _.get(http, ['request', 'template']))
   },
 
-  getDefaultKinesisRequestTemplates(http) {
+  async getDefaultKinesisRequestTemplates(http) {
     return {
-      'application/json': this.buildDefaultKinesisRequestTemplate(http),
-      'application/x-www-form-urlencoded': this.buildDefaultKinesisRequestTemplate(http)
+      'application/json': await this.buildDefaultKinesisRequestTemplate(http),
+      'application/x-www-form-urlencoded': await this.buildDefaultKinesisRequestTemplate(http)
     }
   },
 
-  buildDefaultKinesisRequestTemplate(http) {
+  async buildDefaultKinesisRequestTemplate(http) {
     let streamName
     if (typeof http.streamName == 'object') {
       streamName = http.streamName