fix: bug in deleting the pool from local state

paraswap · Oct 9, 2023 · 15b7a88 · 15b7a88
1 parent 360a035
commit 15b7a88
Show file tree

Hide file tree

Showing 6 changed files with 9 additions and 9 deletions.
diff --git a/src/dex/algebra/algebra-factory.ts b/src/dex/algebra/algebra-factory.ts
@@ -62,8 +62,8 @@ export class AlgebraFactory extends StatefulEventSubscriber<FactoryState> {
   }
 
   async handleNewPool(event: LogDescription) {
-    const token0 = event.args.token0;
-    const token1 = event.args.token1;
+    const token0 = event.args.token0.toLowerCase();
+    const token1 = event.args.token1.toLowerCase();
 
     await this.onPoolCreated({ token0, token1 });
   }

diff --git a/src/dex/algebra/algebra.ts b/src/dex/algebra/algebra.ts
@@ -167,7 +167,7 @@ export class Algebra extends SimpleExchange implements IDex<AlgebraData> {
   }) => {
     const logPrefix = '[Algebra.onPoolCreatedDeleteFromNonExistingSet]';
     const [_token0, _token1] = this._sortTokens(token0, token1);
-    const poolKey = `${_token0}_${_token1}`.toLowerCase();
+    const poolKey = `${_token0}_${_token1}`;
 
     // consider doing it only from master pool for less calls to distant cache
 

diff --git a/src/dex/pancakeswap-v3/pancakeswap-v3-factory.ts b/src/dex/pancakeswap-v3/pancakeswap-v3-factory.ts
@@ -64,8 +64,8 @@ export class PancakeswapV3Factory extends StatefulEventSubscriber<FactoryState>
   }
 
   async handleNewPool(event: LogDescription) {
-    const token0 = event.args.token0;
-    const token1 = event.args.token1;
+    const token0 = event.args.token0.toLowerCase();
+    const token1 = event.args.token1.toLowerCase();
     const fee = event.args.fee;
 
     await this.onPoolCreated({ token0, token1, fee });

diff --git a/src/dex/pancakeswap-v3/pancakeswap-v3.ts b/src/dex/pancakeswap-v3/pancakeswap-v3.ts
@@ -178,7 +178,7 @@ export class PancakeswapV3
   }) => {
     const logPrefix = '[PancakeV3.onPoolCreatedDeleteFromNonExistingSet]';
     const [_token0, _token1] = this._sortTokens(token0, token1);
-    const poolKey = `${_token0}_${_token1}_${fee}`.toLowerCase();
+    const poolKey = `${_token0}_${_token1}_${fee}`;
 
     // consider doing it only from master pool for less calls to distant cache
 

diff --git a/src/dex/uniswap-v3/uniswap-v3-factory.ts b/src/dex/uniswap-v3/uniswap-v3-factory.ts
@@ -64,8 +64,8 @@ export class UniswapV3Factory extends StatefulEventSubscriber<FactoryState> {
   }
 
   async handleNewPool(event: LogDescription) {
-    const token0 = event.args.token0;
-    const token1 = event.args.token1;
+    const token0 = event.args.token0.toLowerCase();
+    const token1 = event.args.token1.toLowerCase();
     const fee = event.args.fee;
 
     await this.onPoolCreated({ token0, token1, fee });

diff --git a/src/dex/uniswap-v3/uniswap-v3.ts b/src/dex/uniswap-v3/uniswap-v3.ts
@@ -209,7 +209,7 @@ export class UniswapV3
   }) => {
     const logPrefix = '[UniswapV3.onPoolCreatedDeleteFromNonExistingSet]';
     const [_token0, _token1] = this._sortTokens(token0, token1);
-    const poolKey = `${_token0}_${_token1}_${fee}`.toLowerCase();
+    const poolKey = `${_token0}_${_token1}_${fee}`;
 
     // consider doing it only from master pool for less calls to distant cache