@@ -82,13 +82,14 @@ describe("BulkQueue", () => {
8282 await vi . advanceTimersByTimeAsync ( 10 ) ;
8383 expect ( sendBulk ) . toHaveBeenCalledTimes ( 1 ) ;
8484 expect ( await queue . size ( ) ) . toBe ( 0 ) ;
85- expect ( logger . error ) . toHaveBeenCalledWith (
85+ expect ( logger . debug ) . toHaveBeenCalledWith (
8686 "bulk request failed; dropping batch" ,
8787 expect . objectContaining ( {
8888 error : expect . any ( Error ) ,
8989 batchSize : 1 ,
9090 } ) ,
9191 ) ;
92+ expect ( logger . error ) . not . toHaveBeenCalled ( ) ;
9293 } ) ;
9394
9495 it ( "drops 4xx responses, logs error, and does not retry" , async ( ) => {
@@ -237,9 +238,16 @@ describe("BulkQueue", () => {
237238 resolveSend = resolve ;
238239 } ) ,
239240 ) ;
241+ const logger = {
242+ debug : vi . fn ( ) ,
243+ info : vi . fn ( ) ,
244+ warn : vi . fn ( ) ,
245+ error : vi . fn ( ) ,
246+ } ;
240247 const queue = new BulkQueue ( sendBulk , {
241248 flushDelayMs : 10_000 ,
242249 maxSize : 2 ,
250+ logger,
243251 } ) ;
244252
245253 await queue . enqueue ( userEvent ) ;
@@ -249,6 +257,16 @@ describe("BulkQueue", () => {
249257 expect ( await queue . size ( ) ) . toBe ( 2 ) ;
250258 expect ( sendBulk ) . toHaveBeenCalledTimes ( 1 ) ;
251259 expect ( sendBulk ) . toHaveBeenCalledWith ( [ userEvent , companyEvent ] ) ;
260+ expect ( logger . debug ) . toHaveBeenCalledWith (
261+ "bulk queue dropped events due to max size" ,
262+ expect . objectContaining ( {
263+ droppedEvents : 1 ,
264+ totalDroppedEvents : 1 ,
265+ queueSize : 2 ,
266+ maxSize : 2 ,
267+ } ) ,
268+ ) ;
269+ expect ( logger . error ) . not . toHaveBeenCalled ( ) ;
252270
253271 resolveSend ?.( new Response ( "" , { status : 200 } ) ) ;
254272 } ) ;
0 commit comments