feat: add timeout for emitting reorgs

src/blockchain/reorg-emitter.ts

@@ -7,7 +7,10 @@ const DEFAULT_DEBOUNCE_TIME = 5000
 const REORG_EVENT = 'reorg-event'
 
 export class ReorgEmitterService implements Partial<ServiceMethods<any>> {
-  private readonly debounceTime: number = DEFAULT_DEBOUNCE_TIME
+  private readonly debounceTime: number = DEFAULT_DEBOUNCE_TIME // ms
+  private reorgContract: string[] = []
+  private lastProcessedBlockNumber = 0
+  private timeoutStarted = false
   emit?: Function
   events: string[]
 
@@ -22,7 +25,21 @@ export class ReorgEmitterService implements Partial<ServiceMethods<any>> {
     if (!this.emit) {
       throw new Error('ReorgEmitterService invalid setup. Missing \'emit\' function')
     }
+
+    if (!this.timeoutStarted) {
+      setTimeout(() => {
+        if (this.emit) {
+          this.emit({ contracts: this.reorgContract, lastProcessedBlockNumber: this.lastProcessedBlockNumber })
+        }
+        this.reorgContract = []
+        this.lastProcessedBlockNumber = 0
+      })
+      this.timeoutStarted = true
+    }
+
+    this.reorgContract = [...this.reorgContract, contractName]
+    this.lastProcessedBlockNumber = lastProcessedBlockNumber
+
     logger.info(`Reorg happens on block number ${lastProcessedBlockNumber} for ${contractName} contract`)
-    this.emit(REORG_EVENT, { lastProcessedBlockNumber, contractName })
   }
 }