feat(dynamodb): add request parameters to db requests

Author: Jeremiah Langner

lib/apiGateway/schema.js

@@ -300,6 +300,7 @@ const proxiesSchemas = {
       condition: Joi.string(),
       hashKey: dynamodbDefaultKeyScheme.required(),
       rangeKey: dynamodbDefaultKeyScheme,
+      requestParameters,
       request,
       response: extendedResponse
     })

lib/package/dynamodb/compileMethodsToDynamodb.js

@@ -14,7 +14,7 @@ module.exports = {
           Type: 'AWS::ApiGateway::Method',
           Properties: {
             HttpMethod: event.http.method.toUpperCase(),
-            RequestParameters: {},
+            RequestParameters: event.http.acceptParameters || {},
             AuthorizationType: event.http.auth.authorizationType,
             AuthorizationScopes: event.http.auth.authorizationScopes,
             AuthorizerId: event.http.auth.authorizerId,
@@ -58,6 +58,7 @@ module.exports = {
         ]
       },
       PassthroughBehavior: 'NEVER',
+      RequestParameters: this.getDynamodbIntegrationRequestParameters(http),
       RequestTemplates: this.getDynamodbIntegrationRequestTemplates(http)
     }
 
@@ -144,6 +145,15 @@ module.exports = {
     }
   },
 
+  getDynamodbIntegrationRequestParameters(http) {
+    const defaultRequestParameters = this.buildDefaultDynamodbRequestParameters(http)
+    return Object.assign(defaultRequestParameters, _.get(http, ['request', 'requestParameters']))
+  },
+
+  buildDefaultDynamodbRequestParameters(http) {
+    return _.merge({}, http.requestParameters)
+  },
+
   getDynamodbObjectHashkeyParameter(http) {
     if (http.hashKey.pathParam) {
       return {

lib/package/dynamodb/compileMethodsToDynamodb.test.js

@@ -84,7 +84,15 @@ describe('#compileMethodsToDynamodb()', () => {
   })
 
   const testSingleProxy = (opts) => {
-    const { http, logicalId, method, intRequestTemplates, uri, intResponseTemplates } = opts
+    const {
+      http,
+      logicalId,
+      method,
+      requestParams,
+      intRequestTemplates,
+      uri,
+      intResponseTemplates
+    } = opts
 
     serverlessApigatewayServiceProxy.validated = {
       events: [
@@ -112,6 +120,7 @@ describe('#compileMethodsToDynamodb()', () => {
         AuthorizerId: http.auth.authorizerId,
         Integration: {
           Uri: uri,
+          RequestParameters: requestParams,
           RequestTemplates: intRequestTemplates,
           IntegrationResponses: [
             {
@@ -158,7 +167,7 @@ describe('#compileMethodsToDynamodb()', () => {
       logicalId: `ApiGatewayMethoddynamodb${http.method.substring(0, 1).toUpperCase() +
         http.method.substring(1)}`,
       method: http.method.toUpperCase(),
-      requestParams,
+      requestParams: params.RequestParameters || requestParams,
       intRequestTemplates,
       uri,
       intResponseTemplates
@@ -786,6 +795,7 @@ describe('#compileMethodsToDynamodb()', () => {
                 ]
               },
               PassthroughBehavior: 'NEVER',
+              RequestParameters: {},
               RequestTemplates: {
                 'application/json': {
                   'Fn::Sub': [
@@ -902,6 +912,7 @@ describe('#compileMethodsToDynamodb()', () => {
                 ]
               },
               PassthroughBehavior: 'NEVER',
+              RequestParameters: {},
               RequestTemplates: {
                 'application/json': {
                   'Fn::Sub': [