test: added single-integration s3 test

Author: theburningmonk

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

@@ -0,0 +1,32 @@
+service: s3-proxy
+
+provider:
+  name: aws
+  runtime: nodejs10.x
+
+plugins:
+  localPath: './../../../../../../'
+  modules:
+    - serverless-apigateway-service-proxy
+
+custom:
+  apiGatewayServiceProxies:
+    - s3:
+        path: /s3/{key}
+        method: post
+        action: PutObject
+        bucket:
+          Ref: S3Bucket
+        key:
+          pathParam: key
+        cors: true
+
+resources:
+  Resources:
+    S3Bucket:
+      Type: 'AWS::S3::Bucket'
+
+  Outputs:
+    S3BucketName:
+      Value:
+        Ref: S3Bucket

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

@@ -0,0 +1,46 @@
+'use strict'
+
+const expect = require('chai').expect
+const fetch = require('node-fetch')
+const {
+  deployWithRandomStage,
+  removeService,
+  getS3Object,
+  deleteS3Object
+} = require('../../../utils')
+
+describe('Single S3 Proxy Integration Test', () => {
+  let endpoint
+  let stage
+  let bucket
+  const config = '__tests__/integration/s3/single-integration/service/serverless.yml'
+  const key = 'my-test-object.json'
+
+  beforeAll(async () => {
+    const result = await deployWithRandomStage(config)
+
+    stage = result.stage
+    endpoint = result.endpoint
+    bucket = result.outputs.S3BucketName
+  })
+
+  afterAll(async () => {
+    await deleteS3Object(bucket, key)
+    removeService(stage, config)
+  })
+
+  it('should get correct response from s3 proxy endpoint', async () => {
+    const testEndpoint = `${endpoint}/s3/${key}`
+
+    const response = await fetch(testEndpoint, {
+      method: 'POST',
+      headers: { 'Content-Type': 'application/json' },
+      body: JSON.stringify({ message: 'test' })
+    })
+    expect(response.headers.get('access-control-allow-origin')).to.deep.equal('*')
+    expect(response.status).to.be.equal(200)
+
+    const uploadedObject = await getS3Object(bucket, key)
+    expect(uploadedObject.toString()).to.equal(JSON.stringify({ message: 'test' }))
+  })
+})

__tests__/utils.js

@@ -6,14 +6,41 @@ const fs = require('fs')
 const path = require('path')
 const execSync = require('child_process').execSync
 const aws = require('aws-sdk')
+const s3 = new aws.S3()
 const cloudformation = new aws.CloudFormation({ region: 'us-east-1' })
 
-async function getApiGatewayEndpoint(stackName) {
+function getApiGatewayEndpoint(outputs) {
+  return outputs.ServiceEndpoint.match(/https:\/\/.+\.execute-api\..+\.amazonaws\.com.+/)[0]
+}
+
+async function getStackOutputs(stackName) {
   const result = await cloudformation.describeStacks({ StackName: stackName }).promise()
+  const stack = result.Stacks[0]
+
+  const keys = stack.Outputs.map((x) => x.OutputKey)
+  const values = stack.Outputs.map((x) => x.OutputValue)
+
+  return _.zipObject(keys, values)
+}
+
+async function getS3Object(bucket, key) {
+  const resp = await s3
+    .getObject({
+      Bucket: bucket,
+      Key: key
+    })
+    .promise()
+
+  return resp.Body
+}
 
-  const endpointOutput = _.find(result.Stacks[0].Outputs, { OutputKey: 'ServiceEndpoint' })
-    .OutputValue
-  return endpointOutput.match(/https:\/\/.+\.execute-api\..+\.amazonaws\.com.+/)[0]
+async function deleteS3Object(bucket, key) {
+  await s3
+    .deleteObject({
+      Bucket: bucket,
+      Key: key
+    })
+    .promise()
 }
 
 function deployService(stage, config) {
@@ -37,14 +64,16 @@ async function deployWithRandomStage(config) {
     .substring(2)
   const stackName = `${serviceName}-${stage}`
   deployService(stage, config)
-  const endpoint = await getApiGatewayEndpoint(stackName)
+  const outputs = await getStackOutputs(stackName)
+  const endpoint = getApiGatewayEndpoint(outputs)
 
-  return { stage, endpoint }
+  return { stackName, stage, outputs, endpoint }
 }
 
 module.exports = {
-  getApiGatewayEndpoint,
   deployService,
   removeService,
-  deployWithRandomStage
+  deployWithRandomStage,
+  getS3Object,
+  deleteS3Object
 }