@@ -26,7 +26,8 @@ import { advanceTimersByTime } from '../../tests/testUtils';
26
26
import { getMockLogger } from '../tests/mock/mock_logger' ;
27
27
import { getMockRepeater } from '../tests/mock/mock_repeater' ;
28
28
import * as retry from '../utils/executor/backoff_retry_runner' ;
29
- import { ServiceState } from '../service' ;
29
+ import { ServiceState , StartupLog } from '../service' ;
30
+ import { LogLevel } from '../modules/logging' ;
30
31
31
32
const getMockDispatcher = ( ) => {
32
33
return {
@@ -50,6 +51,38 @@ describe('QueueingEventProcessor', async () => {
50
51
} ) ;
51
52
52
53
describe ( 'start' , ( ) => {
54
+ it . only ( 'should log startupLogs on start' , ( ) => {
55
+ const startupLogs : StartupLog [ ] = [
56
+ {
57
+ level : LogLevel . WARNING ,
58
+ message : 'warn message' ,
59
+ params : [ 1 , 2 ]
60
+ } ,
61
+ {
62
+ level : LogLevel . ERROR ,
63
+ message : 'error message' ,
64
+ params : [ 3 , 4 ]
65
+ } ,
66
+ ] ;
67
+
68
+ const logger = getMockLogger ( ) ;
69
+
70
+ const processor = new BatchEventProcessor ( {
71
+ eventDispatcher : getMockDispatcher ( ) ,
72
+ dispatchRepeater : getMockRepeater ( ) ,
73
+ batchSize : 1000 ,
74
+ startupLogs,
75
+ } ) ;
76
+
77
+ processor . setLogger ( logger ) ;
78
+ processor . start ( ) ;
79
+
80
+
81
+ expect ( logger . log ) . toHaveBeenCalledTimes ( 2 ) ;
82
+ expect ( logger . log ) . toHaveBeenNthCalledWith ( 1 , LogLevel . WARNING , 'warn message' , 1 , 2 ) ;
83
+ expect ( logger . log ) . toHaveBeenNthCalledWith ( 2 , LogLevel . ERROR , 'error message' , 3 , 4 ) ;
84
+ } ) ;
85
+
53
86
it ( 'should resolve onRunning() when start() is called' , async ( ) => {
54
87
const eventDispatcher = getMockDispatcher ( ) ;
55
88
const processor = new BatchEventProcessor ( {
0 commit comments