@@ -91,7 +91,7 @@ export const searchAfterAndBulkCreate = async ({
9191 } ;
9292
9393 let sortId ; // tells us where to start our next search_after query
94- let searchResultSize = 0 ;
94+ let signalsCreatedCount = 0 ;
9595
9696 /*
9797 The purpose of `maxResults` is to ensure we do not perform
@@ -127,8 +127,8 @@ export const searchAfterAndBulkCreate = async ({
127127 toReturn . success = false ;
128128 return toReturn ;
129129 }
130- searchResultSize = 0 ;
131- while ( searchResultSize < tuple . maxSignals ) {
130+ signalsCreatedCount = 0 ;
131+ while ( signalsCreatedCount < tuple . maxSignals ) {
132132 try {
133133 logger . debug ( buildRuleMessage ( `sortIds: ${ sortId } ` ) ) ;
134134 const {
@@ -187,12 +187,12 @@ export const searchAfterAndBulkCreate = async ({
187187
188188 // make sure we are not going to create more signals than maxSignals allows
189189 if (
190- searchResultSize != null &&
191- searchResultSize + filteredEvents . hits . hits . length > tuple . maxSignals
190+ signalsCreatedCount != null &&
191+ signalsCreatedCount + filteredEvents . hits . hits . length > tuple . maxSignals
192192 ) {
193193 filteredEvents . hits . hits = filteredEvents . hits . hits . slice (
194194 0 ,
195- tuple . maxSignals - searchResultSize
195+ tuple . maxSignals - signalsCreatedCount
196196 ) ;
197197 }
198198
@@ -220,7 +220,7 @@ export const searchAfterAndBulkCreate = async ({
220220 } ) ;
221221 logger . debug ( buildRuleMessage ( `created ${ createdCount } signals` ) ) ;
222222 toReturn . createdSignalsCount += createdCount ;
223- searchResultSize += createdCount ;
223+ signalsCreatedCount += createdCount ;
224224 if ( bulkDuration ) {
225225 toReturn . bulkCreateTimes . push ( bulkDuration ) ;
226226 }
0 commit comments