Alias for event source mapping (davidgf#9)

* Support stream events

* Add end-to-end tests

.gitignore

@@ -1 +1,5 @@
 node_modules
+.serverless
+.serverless_plugins
+mappings.json
+serverless-plugin-canary-deployments*.tgz

.npmignore

@@ -0,0 +1 @@
+example/

example/handler.js

@@ -1,11 +1,10 @@
-'use strict';
-
 module.exports.hello = (event, context, callback) => {
  if ((event.queryStringParameters || {}).error) callback(new Error('Oh no!'));
+ console.log('The first version');
  const response = {
  statusCode: 200,
  body: JSON.stringify({
- message: 'First version',
+ message: 'The first version'
  })
  };
  return callback(null, response);

example/package.json

@@ -4,15 +4,19 @@
  "description": "",
  "main": "handler.js",
  "dependencies": {
- "aws-sdk": "^2.203.0"
+ "aws-sdk": "^2.203.0",
+ "uuid": "^3.2.1"
  },
  "devDependencies": {
  "serverless": "^1.26.1",
  "serverless-plugin-aws-alerts": "^1.2.4",
  "serverless-plugin-canary-deployments": "^0.1.0"
  },
  "scripts": {
- "test": "echo \"Error: no test specified\" && exit 1"
+ "test": "echo \"Error: no test specified\" && exit 1",
+ "package": "npm un --no-save serverless-plugin-canary-deployments && npm pack ../ && npm i --no-save serverless-plugin-canary-deployments-0.1.0.tgz && sls package -s dev",
+ "deploy": "npm un --no-save serverless-plugin-canary-deployments && npm pack ../ && npm i --no-save serverless-plugin-canary-deployments-0.1.0.tgz && sls deploy -s dev",
+ "populate-table": "node ./scripts/populate-test-table"
  },
  "author": "",
  "license": "ISC"

example/scripts/populate-test-table.js

@@ -0,0 +1,13 @@
+const AWS = require('aws-sdk');
+const uuid = require('uuid');
+
+const generatePutRequest = () => ({ PutRequest: { Item: { id: uuid() } } });
+const putRequests = new Array(25).fill().map(() => generatePutRequest());
+const params = { RequestItems: { StreamsTestTable: putRequests } };
+
+const documentClient = new AWS.DynamoDB.DocumentClient({ region: 'us-east-1' });
+
+documentClient.batchWrite(params, (err, data) => {
+ if (err) console.log(err);
+ else console.log(data);
+});

example/serverless.yml

@@ -22,6 +22,12 @@ functions:
  handler: handler.hello
  events:
  - http: GET hello
+ - stream:
+ type: dynamodb
+ arn:
+ Fn::GetAtt:
+ - StreamsTestTable
+ - StreamArn
  alarms:
  - name: foo
  namespace: 'AWS/Lambda'
@@ -42,3 +48,21 @@ functions:
  handler: hooks.pre
  postHook:
  handler: hooks.post
+
+resources:
+ Resources:
+ StreamsTestTable:
+ Type: AWS::DynamoDB::Table
+ Properties:
+ TableName: StreamsTestTable
+ AttributeDefinitions:
+ - AttributeName: id
+ AttributeType: S
+ KeySchema:
+ - AttributeName: id
+ KeyType: HASH
+ ProvisionedThroughput:
+ ReadCapacityUnits: 1
+ WriteCapacityUnits: 1
+ StreamSpecification:
+ StreamViewType: NEW_AND_OLD_IMAGES