@@ -14,6 +14,7 @@ let sdk: MockSdk;
1414let monitor : CloudWatchLogEventMonitor ;
1515let ioHost = new TestIoHost ( ) ;
1616beforeEach ( ( ) => {
17+ mockCloudWatchClient . reset ( ) ;
1718 monitor = new CloudWatchLogEventMonitor ( {
1819 ioHelper : ioHost . asHelper ( 'deploy' ) ,
1920 startTime : new Date ( T100 ) ,
@@ -29,10 +30,10 @@ afterEach(async () => {
2930
3031test ( 'process events' , async ( ) => {
3132 // GIVEN
32- const eventDate = new Date ( T0 + 102 * 1000 ) ;
33- mockCloudWatchClient . on ( FilterLogEventsCommand ) . resolves ( {
34- events : [ event ( 102 , 'message' , eventDate ) ] ,
35- } ) ;
33+ const eventDate = new Date ( T102 ) ;
34+ mockCloudWatchClient . on ( FilterLogEventsCommand )
35+ . resolvesOnce ( { events : [ event ( 102 , 'message' , eventDate ) ] } )
36+ . resolves ( { events : [ ] } ) ;
3637
3738 monitor . addLogGroups (
3839 {
@@ -46,7 +47,7 @@ test('process events', async () => {
4647 // WHEN
4748 await monitor . activate ( ) ;
4849 // need time for the log processing to occur
49- await sleep ( 1000 ) ;
50+ await sleep ( 2500 ) ;
5051
5152 // THEN
5253 const expectedLocaleTimeString = eventDate . toLocaleTimeString ( ) ;
@@ -56,16 +57,16 @@ test('process events', async () => {
5657
5758test ( 'process truncated events' , async ( ) => {
5859 // GIVEN
59- const eventDate = new Date ( T0 + 102 * 1000 ) ;
60+ const eventDate = new Date ( T102 ) ;
6061 const events : FilteredLogEvent [ ] = [ ] ;
6162 for ( let i = 0 ; i < 100 ; i ++ ) {
6263 events . push ( event ( 102 + i , 'message' + i , eventDate ) ) ;
6364 }
6465
65- mockCloudWatchClient . on ( FilterLogEventsCommand ) . resolves ( {
66- events,
67- nextToken : 'some-token' ,
68- } ) ;
66+ mockCloudWatchClient . on ( FilterLogEventsCommand )
67+ . resolvesOnce ( { events, nextToken : 'some-token' } )
68+ . resolves ( { events : [ ] } ) ;
69+
6970 monitor . addLogGroups (
7071 {
7172 name : 'name' ,
@@ -78,7 +79,7 @@ test('process truncated events', async () => {
7879 // WHEN
7980 await monitor . activate ( ) ;
8081 // need time for the log processing to occur
81- await sleep ( 1000 ) ;
82+ await sleep ( 2500 ) ;
8283
8384 // THEN
8485 const expectedLocaleTimeString = eventDate . toLocaleTimeString ( ) ;
@@ -91,6 +92,7 @@ test('process truncated events', async () => {
9192
9293const T0 = 1597837230504 ;
9394const T100 = T0 + 100 * 1000 ;
95+ const T102 = T0 + 102 * 1000 ;
9496function event ( nr : number , message : string , timestamp : Date ) : FilteredLogEvent {
9597 return {
9698 eventId : `${ nr } ` ,
0 commit comments