test: add single-integration for dynamodb

Author: horike37

__tests__/integration/dynamodb/single-integration/service/serverless.yml

@@ -0,0 +1,38 @@
+service: dynamodb-proxy
+
+provider:
+  name: aws
+  runtime: nodejs10.x
+
+plugins:
+  localPath: './../../../../../../'
+  modules:
+    - serverless-apigateway-service-proxy
+
+custom:
+  apiGatewayServiceProxies:
+    - dynamodb:
+        path: /dynamodb
+        method: post
+        tableName:
+          Ref: MyTestTable
+        hashKey: 'id'
+        cors: true
+
+resources:
+  Resources:
+    MyTestTable:
+      Type: AWS::DynamoDB::Table
+      Properties:
+        TableName: MyTestTable
+        AttributeDefinitions:
+          -
+            AttributeName: id
+            AttributeType: S
+        KeySchema:
+          -
+            AttributeName: id
+            KeyType: HASH
+        ProvisionedThroughput:
+          ReadCapacityUnits: 1
+          WriteCapacityUnits: 1

__tests__/integration/dynamodb/single-integration/tests.js

@@ -0,0 +1,45 @@
+'use strict'
+
+const expect = require('chai').expect
+const fetch = require('node-fetch')
+const { deployWithRandomStage, removeService, getDynamodbItem } = require('../../../utils')
+
+describe('Single dynamodb Proxy Integration Test', () => {
+  let endpoint
+  let stage
+  const tableName = 'MyTestTable'
+  const config = '__tests__/integration/dynamodb/single-integration/service/serverless.yml'
+
+  beforeAll(async () => {
+    const result = await deployWithRandomStage(config)
+
+    stage = result.stage
+    endpoint = result.endpoint
+  })
+
+  afterAll(async () => {
+    removeService(stage, config)
+  })
+
+  it('should get correct response from dynamodb proxy endpoint', async () => {
+    const testEndpoint = `${endpoint}/dynamodb`
+
+    const response = await fetch(testEndpoint, {
+      method: 'POST',
+      headers: { 'Content-Type': 'application/json' },
+      body: JSON.stringify({ item1: { S: 'item1' }, item2: { S: 'item2' } })
+    })
+    expect(response.headers.get('access-control-allow-origin')).to.deep.equal('*')
+    expect(response.status).to.be.equal(200)
+    const body = await response.json()
+
+    const item = await getDynamodbItem(tableName, body.id)
+    expect(item).to.be.deep.equal({
+      Item: {
+        id: { S: body.id },
+        item1: { S: 'item1' },
+        item2: { S: 'item2' }
+      }
+    })
+  })
+})

__tests__/utils.js

@@ -9,6 +9,7 @@ const aws = require('aws-sdk')
 const s3 = new aws.S3()
 
 const region = 'us-east-1'
+const dynamodb = new aws.DynamoDB({ region })
 const cloudformation = new aws.CloudFormation({ region })
 
 function getApiGatewayEndpoint(outputs) {
@@ -25,6 +26,19 @@ async function getStackOutputs(stackName) {
   return _.zipObject(keys, values)
 }
 
+async function getDynamodbItem(tableName, hashKey) {
+  return await dynamodb
+    .getItem({
+      Key: {
+        id: {
+          S: hashKey
+        }
+      },
+      TableName: tableName
+    })
+    .promise()
+}
+
 async function getS3Object(bucket, key) {
   const resp = await s3
     .getObject({
@@ -77,5 +91,6 @@ module.exports = {
   removeService,
   deployWithRandomStage,
   getS3Object,
-  deleteS3Object
+  deleteS3Object,
+  getDynamodbItem
 }