fixed handling cache clearing

bancorprotocol · May 31, 2024 · b9dbd6b · b9dbd6b
1 parent 3fa7e28
commit b9dbd6b
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/src/chain-cache/ChainCache.ts b/src/chain-cache/ChainCache.ts
@@ -174,7 +174,7 @@ export class ChainCache extends (EventEmitter as new () => TypedEventEmitter<Cac
     logger.debug('Cache miss for pair', token0, token1, 'resolved');
   }
 
-  public clear(): void {
+  public clear(silent: boolean = false): void {
     const pairs = Object.keys(this._strategiesByPair).map(fromPairKey);
     this._strategiesByPair = {};
     this._strategiesById = {};
@@ -183,7 +183,9 @@ export class ChainCache extends (EventEmitter as new () => TypedEventEmitter<Cac
     this._latestTradesByPair = {};
     this._latestTradesByDirectedPair = {};
     this._blocksMetadata = [];
-    this.emit('onPairDataChanged', pairs);
+    if (!silent) {
+      this.emit('onPairDataChanged', pairs);
+    }
   }
 
   //#region public getters

diff --git a/src/chain-cache/ChainSync.ts b/src/chain-cache/ChainSync.ts
@@ -51,7 +51,8 @@ export class ChainSync {
         `startDataSync - cache is too old: current block ${blockNumber}, cache block ${latestBlockInCache}`,
         arguments
       );
-      // cache starts from scratch so we want to avoid getting events from the beginning of time
+      // cache is too old so we want to clear it and avoid getting events from the beginning of time
+      this._chainCache.clear(true);
       this._chainCache.applyBatchedUpdates(blockNumber, [], [], [], [], []);
     }