Merge pull request #32 from erezrokah/limit_toHaveLog_results_by_startTime

add startTime filter to filterLogEvents

Author: erezrokah

package.json

@@ -1,6 +1,6 @@
 {
   "name": "aws-testing-library",
-  "version": "1.0.1",
+  "version": "1.0.2",
   "description": "Chai and Jest matchers for aws services",
   "scripts": {
     "lint": "tslint 'src/**/*.ts'",

src/utils/cloudwatch.test.ts

@@ -15,6 +15,8 @@ jest.mock('aws-sdk', () => {
   return { CloudWatchLogs };
 });
 
+jest.spyOn(Date, 'now').mockImplementation(() => 12 * 60 * 60 * 1000);
+
 describe('cloudwatch utils', () => {
   const AWS = require('aws-sdk');
   const cloudWatchLogs = AWS.CloudWatchLogs;
@@ -91,6 +93,7 @@ describe('cloudwatch utils', () => {
         interleaved: true,
         limit: 1,
         logGroupName,
+        startTime: 11 * 60 * 60 * 1000,
       });
       expect(actual).toEqual({ events });
     });

src/utils/cloudwatch.ts

@@ -2,6 +2,8 @@ import AWS = require('aws-sdk');
 
 const getLogGroupName = (functionName: string) => `/aws/lambda/${functionName}`;
 
+const hoursToMilliseconds = (hours: number) => hours * 60 * 60 * 1000;
+
 export const filterLogEvents = async (
   region: string,
   functionName: string,
@@ -10,13 +12,15 @@ export const filterLogEvents = async (
   const cloudWatchLogs = new AWS.CloudWatchLogs({ region });
   const logGroupName = getLogGroupName(functionName);
   const filterPattern = `"${pattern}"`; // enclose with "" to support special characters
+  const startTime = Date.now() - hoursToMilliseconds(1);
 
   const { events = [] } = await cloudWatchLogs
     .filterLogEvents({
       filterPattern,
       interleaved: true,
       limit: 1,
       logGroupName,
+      startTime,
     })
     .promise();