ignore old events in ContractEventsEmitter

powerpool-finance · Feb 20, 2024 · dfd3fe0 · dfd3fe0
1 parent 8859e31
commit dfd3fe0
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/app/services/ContractEventsEmitter.ts b/app/services/ContractEventsEmitter.ts
@@ -12,6 +12,8 @@ export default class ContractEventsEmitter {
   contractEmitterCount = {};
   emitByBlockCount = {};
 
+  lastBlockNumber = null;
+
   constructor(_blockLogsMode) {
     this.setBlockLogsMode(_blockLogsMode);
   }
@@ -22,7 +24,10 @@ export default class ContractEventsEmitter {
   }
 
   emitByContractAddress(address, eventName, value) {
-    this.contractEmitterByAddress[address].emit(eventName, value);
+    if (!this.lastBlockNumber || value.blockNumber >= this.lastBlockNumber) {
+      this.contractEmitterByAddress[address].emit(eventName, value);
+      this.lastBlockNumber = value.blockNumber;
+    }
   }
 
   emitByBlockLogs(logs, forceEmit = false) {