fix: await init

paraswap · Sep 30, 2023 · de231db · de231db
1 parent ac7792c
commit de231db
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/src/dex/algebra/algebra.ts b/src/dex/algebra/algebra.ts
@@ -137,7 +137,7 @@ export class Algebra extends SimpleExchange implements IDex<AlgebraData> {
 
   async initializePricing(blockNumber: number) {
     // Init listening to new pools creation
-    this.factory.initialize(blockNumber);
+    await this.factory.initialize(blockNumber);
 
     if (!this.dexHelper.config.isSlave) {
       const cleanExpiredNotExistingPoolsKeys = async () => {

diff --git a/src/dex/pancakeswap-v3/pancakeswap-v3.ts b/src/dex/pancakeswap-v3/pancakeswap-v3.ts
@@ -147,7 +147,7 @@ export class PancakeswapV3
 
   async initializePricing(blockNumber: number) {
     // Init listening to new pools creation
-    this.factory.initialize(blockNumber);
+    await this.factory.initialize(blockNumber);
 
     if (!this.dexHelper.config.isSlave) {
       const cleanExpiredNotExistingPoolsKeys = async () => {

diff --git a/src/dex/uniswap-v3/uniswap-v3.ts b/src/dex/uniswap-v3/uniswap-v3.ts
@@ -165,7 +165,7 @@ export class UniswapV3
 
   async initializePricing(blockNumber: number) {
     // Init listening to new pools creation
-    this.factory.initialize(blockNumber);
+    await this.factory.initialize(blockNumber);
 
     // This is only for testing, because cold pool fetching is goes out of
     // FETCH_POOL_INDENTIFIER_TIMEOUT range