archive-gh-me/serverless
1
0
Fork 0
mirror of https://github.com/serverless/serverless.git synced 2026-01-25 15:07:39 +00:00
Code Issues Projects Releases Wiki Activity

test(AWS Stream): Improve reliabiity of tests

Browse Source 
To avoid race condition as observed here: https://github.com/serverless/serverless/runs/858566550
This commit is contained in:
Mariusz Nowak 2020-07-13 11:56:16 +02:00
parent 3ffa549183
commit 4aa24088f8
No known key found for this signature in database
GPG Key ID: A292FE0143B1828B
1 changed files with 18 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
tests/integration-all/stream/tests.js
View File

@ -10,13 +10,8 @@ const {
putKinesisRecord,
} = require('../../utils/kinesis');
const { putDynamoDbItem } = require('../../utils/dynamodb');
const {
createTestService,
deployService,
removeService,
waitForFunctionLogs,
} = require('../../utils/integration');
const { getMarkers } = require('../shared/utils');
const { confirmCloudWatchLogs } = require('../../utils/misc');
const { createTestService, deployService, removeService } = require('../../utils/integration');
describe('AWS - Stream Integration Test', function() {
this.timeout(1000 * 60 * 100); // Involves time-taking deploys
@ -70,32 +65,32 @@ describe('AWS - Stream Integration Test', function() {
describe('Kinesis Streams', () => {
it('should invoke on kinesis messages from the trim horizon', () => {
const functionName = 'streamKinesis';
const markers = getMarkers(functionName);
const message = 'Hello from Kinesis!';
return putKinesisRecord(streamName, message)
.then(() => waitForFunctionLogs(tmpDirPath, functionName, markers.start, markers.end))
.then(logs => {
expect(logs).to.include(functionName);
expect(logs).to.include(message);
expect(logs).to.include(historicStreamMessage);
});
return confirmCloudWatchLogs(`/aws/lambda/${stackName}-${functionName}`, () =>
putKinesisRecord(streamName, message)
).then(events => {
const logs = events.reduce((data, event) => data + event.message, '');
expect(logs).to.include(functionName);
expect(logs).to.include(message);
expect(logs).to.include(historicStreamMessage);
});
});
});
describe('DynamoDB Streams', () => {
it('should invoke on dynamodb messages from the latest position', () => {
const functionName = 'streamDynamoDb';
const markers = getMarkers(functionName);
const item = { id: 'message', hello: 'from dynamo!' };
return confirmCloudWatchLogs(`/aws/lambda/${stackName}-${functionName}`, () =>
putDynamoDbItem(tableName, item)
).then(events => {
const logs = events.reduce((data, event) => data + event.message, '');
return putDynamoDbItem(tableName, item)
.then(() => waitForFunctionLogs(tmpDirPath, functionName, markers.start, markers.end))
.then(logs => {
expect(logs).to.include(functionName);
expect(logs).to.include('INSERT');
expect(logs).to.include(item.id);
});
expect(logs).to.include(functionName);
expect(logs).to.include('INSERT');
expect(logs).to.include(item.id);
});
});
});
});