Merge pull request #151 from dappradar/Clipper-fix

Update index.ts
dappradar · Jun 29, 2023 · 887ae12 · 887ae12
2 parents bd80a3b + 4ce8c63
commit 887ae12
Showing 1 changed file with 31 additions and 12 deletions.
diff --git a/src/factory/providers/moonbeam/clipper/index.ts b/src/factory/providers/moonbeam/clipper/index.ts
@@ -1,19 +1,38 @@
 import util from '../../../../util/blockchainUtil';
 import formatter from '../../../../util/formatter';
+import basicUtil from '../../../../util/basicUtil';
+import { log } from '../../../../util/logger/logger';
 import { ITvlParams, ITvlReturn } from '../../../../interfaces/ITvl';
 import axios from 'axios';
 
-async function getChainData() {
-  const {
-    data: {
-      pool: { address: poolAddress },
-      assets,
-    },
-  } = await axios.get(`https://api.clipper.exchange/rfq/pool?chain_id=1284`);
-  return {
-    poolAddress,
-    tokens: assets.map(({ address }) => address),
-  };
+async function getChainData(chain, provider) {
+  let poolInfo: { poolAddress: string; tokens: string[] };
+
+  try {
+    const {
+      data: {
+        pool: { address: poolAddress },
+        assets,
+      },
+    } = await axios.get(`https://api.clipper.exchange/rfq/pool?chain_id=1284`);
+
+    poolInfo = {
+      poolAddress,
+      tokens: assets.map(({ address }) => address),
+    };
+
+    await basicUtil.saveIntoCache(poolInfo, 'poolInfo.json', chain, provider);
+  } catch (e) {
+    log.error({
+      message: `Issue with Clipper API`,
+      stack: e.stack,
+      detail: `Error: getChainData of moonbeam/clipper`,
+      endpoint: 'getChainData',
+    });
+    poolInfo = await basicUtil.readFromCache('poolInfo.json', chain, provider);
+  }
+
+  return poolInfo;
 }
 
 async function tvl(params: ITvlParams): Promise<Partial<ITvlReturn>> {
@@ -23,7 +42,7 @@ async function tvl(params: ITvlParams): Promise<Partial<ITvlReturn>> {
   }
 
   const balances = {};
-  const { poolAddress, tokens } = await getChainData();
+  const { poolAddress, tokens } = await getChainData(chain, provider);
   const tokenBalances = await util.getTokenBalances(
     poolAddress,
     tokens,