BACK-1274: Cache invalidation on pool creation (bug with local state)

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@paraswap/dex-lib",
-  "version": "2.37.3",
+  "version": "2.37.4-cache-invalidation-fix.2",
   "main": "build/index.js",
   "types": "build/index.d.ts",
   "repository": "https://github.com/paraswap/paraswap-dex-lib",

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 });
   }

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
 

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 });

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
 

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 });

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