add startTime filter to filterLogEvents

Author: erezrokah

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();