Handle all external APIs failure gracefully

package.json

@@ -90,5 +90,6 @@
   },
   "engines": {
     "node": "20.x"
-  }
+  },
+  "packageManager": "[email protected]+sha512.a6b2f7906b721bba3d67d4aff083df04dad64c399707841b7acf00f6b133b7ac24255f2652fa22ae3534329dc6180534e98d17432037ff6fd140556e2bb3137e"
 }

src/app/community/page.tsx

@@ -35,6 +35,7 @@
   Text,
   useDisclosure,
 } from '@chakra-ui/react';
+import fetchWithRetry from '@/utils/fetchWithRetry';
 
 interface OGNFTUserData {
   address: string;
@@ -50,8 +51,13 @@
     queryFn: async ({ _queryKey }: any): Promise<OGNFTUserData | null> => {
       const address = get(addressAtom) || '0x0';
       if (!address) return null;
-      const data = await fetch(`/api/users/ognft/${address}`);
-      return data.json();
+      const data = await fetchWithRetry(
+        `/api/users/ognft/${address}`,
+        {},
+        'Error fetching OG NFT eligibility',
+      );
+      if (!data) return null;
+      return await data.json();
     },
     refetchInterval: 5000,
   };
@@ -367,7 +373,7 @@
                 ) : !address ? (
                   'Connect wallet to check eligibility'
                 ) : isOGNFTEligible.isLoading ||
                   balanceQueryStatus == 'pending' ? (
                   <Spinner size="sm" />
                 ) : hasNFT ? (
                   'Claimed'

src/components/TxButton.tsx

@@ -21,6 +21,7 @@
 import mixpanel from 'mixpanel-browser';
 import { useEffect, useMemo } from 'react';
 import { isMobile } from 'react-device-detect';
+import toast from 'react-hot-toast';
 import { TwitterShareButton } from 'react-share';
 import { Call } from 'starknet';
 

src/store/carmine.store.ts

@@ -5,6 +5,20 @@ import { PoolInfo, ProtocolAtoms } from './pools';
 import { Jediswap } from './jedi.store';
 import { atomWithQuery } from 'jotai-tanstack-query';
 import { StrategyLiveStatus } from '@/strategies/IStrategy';
+import fetchWithRetry from '@/utils/fetchWithRetry';
+
+type CarminePoolData = {
+  week: number;
+  week_annualized: number;
+  launch: number;
+  launch_annualized: number;
+};
+
+type CarmineAPRData = {
+  tvl: number;
+  allocation: number;
+  apy: number;
+};
 
 const poolConfigs = [
   { name: 'STRK/USDC Call Pool (STRK)', tokenA: 'STRK', tokenB: 'USDC' },
@@ -122,15 +136,40 @@ const poolEndpoints = [
 export const CarmineAtom = atomWithQuery((get) => ({
   queryKey: ['isCarmine'],
   queryFn: async ({ queryKey }) => {
-    const fetchPool = async (endpoint: any) => {
-      const res = await fetch(`${CONSTANTS.CARMINE_URL}/${endpoint}/apy`);
+    const fetchPool = async (
+      endpoint: string,
+    ): Promise<{ data: CarminePoolData }> => {
+      const res = await fetchWithRetry(
+        `${CONSTANTS.CARMINE_URL}/${endpoint}/apy`,
+        {},
+        'Failed to fetch Carmine data',
+      );
+
+      if (!res) {
+        return {
+          data: {
+            week_annualized: 0,
+            week: 0,
+            launch_annualized: 0,
+            launch: 0,
+          },
+        };
+      }
       let data = await res.text();
       data = data.replaceAll('NaN', '0');
       return JSON.parse(data);
     };
 
-    const fetchRewardApr = async () => {
-      const res = await fetch(CONSTANTS.CARMINE_INCENTIVES_URL);
+    const fetchRewardApr = async (): Promise<{ data: CarmineAPRData }> => {
+      const res = await fetchWithRetry(
+        CONSTANTS.CARMINE_INCENTIVES_URL,
+        {},
+        'Failed to fetch Carmine incentives data',
+      );
+
+      if (!res) {
+        return { data: { apy: 0, tvl: 0, allocation: 0 } };
+      }
       let data = await res.text();
       data = data.replaceAll('NaN', '0');
       return JSON.parse(data);

src/store/ekobu.store.ts

@@ -12,12 +12,9 @@
   StrkDexIncentivesAtom,
 } from './pools';
 import { StrategyLiveStatus } from '@/strategies/IStrategy';
+import fetchWithRetry from '@/utils/fetchWithRetry';
 import { getPrice } from '@/utils';
 
-const _fetcher = async (...args: any[]) => {
-  return fetch(args[0], args[1]).then((res) => res.json());
-};
-
 interface EkuboBaseAprDoc {
   tokens: Token[];
   defiSpringData: DefiSpringData;
@@ -309,7 +306,6 @@
     });
 
     const [ethPrice, strkPrice, usdcPrice] = await Promise.all(pricePromises);
-
     return {
       tokens,
       defiSpringData,

src/store/haiko.store.ts

@@ -12,6 +12,7 @@ import { atom } from 'jotai';
 import { AtomWithQueryResult, atomWithQuery } from 'jotai-tanstack-query';
 import { IDapp } from './IDapp.store';
 import { StrategyLiveStatus } from '@/strategies/IStrategy';
+import fetchWithRetry from '@/utils/fetchWithRetry';
 
 type Token = {
   address: string;
@@ -187,13 +188,19 @@ export const haiko = new Haiko();
 const HaikoAtoms: ProtocolAtoms = {
   baseAPRs: atomWithQuery((get) => ({
     queryKey: ['haiko_base_aprs'],
-    queryFn: async ({ queryKey }) => {
-      const response = await fetch(`${CONSTANTS.HAIKO.BASE_APR_API}`);
-      const data = await response.json();
-
-      return data;
+    queryFn: async ({ queryKey }): Promise<Pool[]> => {
+        const response = await fetchWithRetry(`${CONSTANTS.HAIKO.BASE_APR_API}`, {
+          headers: {
+            'Content-Type': 'application/json',
+          },
+        }, 'Error fetching haiko base APRs');
+        if (!response) return [];
+        const data = await response.json();
+
+        return data;
     },
   })),
+
   pools: atom((get) => {
     const poolsInfo = get(StrkDexIncentivesAtom);
     const empty: PoolInfo[] = [];

src/store/jedi.store.ts

@@ -13,6 +13,7 @@ import { IDapp } from './IDapp.store';
 import { AtomWithQueryResult, atomWithQuery } from 'jotai-tanstack-query';
 import { BlockInfo, getBlock } from './utils.atoms';
 import { StrategyLiveStatus } from '@/strategies/IStrategy';
+import fetchWithRetry from '@/utils/fetchWithRetry';
 
 interface MyBaseAprDoc {
   id: string;
@@ -147,15 +148,17 @@ async function getVolumes(block: number) {
     variables: {},
   });
 
-  const res = await fetch(CONSTANTS.JEDI.BASE_API, {
+  const res = await fetchWithRetry(CONSTANTS.JEDI.BASE_API, {
     method: 'POST',
     headers: {
       Accept: 'application/json',
       'Content-Type': 'application/json',
     },
     body: data,
-  });
-  return res.json();
+  }, 'Error fetching jedi volumes');
+
+  if (!res) return { data: { pairs: [] } };
+  return await res.json();
 }
 
 export const jedi = new Jediswap();

src/store/myswap.store.ts

@@ -12,6 +12,7 @@ import { IDapp } from './IDapp.store';
 import CONSTANTS, { TokenName } from '@/constants';
 import { AtomWithQueryResult, atomWithQuery } from 'jotai-tanstack-query';
 import { StrategyLiveStatus } from '@/strategies/IStrategy';
+import fetchWithRetry from '@/utils/fetchWithRetry';
 
 interface Token {
   symbol: string;
@@ -181,8 +182,13 @@ export class MySwap extends IDapp<IndexedPoolData> {
   }
 }
 
-const fetch_pools = async () => {
-  const response = await fetch(`${CONSTANTS.MY_SWAP.POOLS_API}`);
+const fetch_pools = async (): Promise<Pools> => {
+  const response = await fetchWithRetry(
+    `${CONSTANTS.MY_SWAP.POOLS_API}`,
+    {},
+    'Error fetching myswap pools',
+  );
+  if (!response) return { pools: [] };
   const data = await response.json();
   return data;
 };
@@ -213,14 +219,16 @@ const fetchAprData = async (
       if (pool_keys.length) {
         const pools = await Promise.all(
           pool_keys.map(async (pool_key) => {
-            const response = await fetch(
+            const response = await fetchWithRetry(
               `${CONSTANTS.MY_SWAP.BASE_APR_API}/${pool_key}/overview.json`,
+              {},
+              'Error fetching myswap apr data',
             );
-
+            if (!response) return null;
             const data = await response.json();
             return data;
           }),
-        );
+        ).then((results) => results.filter((result) => result !== null));
 
         return [pool_name, pools];
       }

src/store/pools.ts

@@ -4,6 +4,7 @@ import { AtomWithQueryResult, atomWithQuery } from 'jotai-tanstack-query';
 import { CustomAtomWithQueryResult } from '@/utils/customAtomWithQuery';
 import { customAtomWithFetch } from '@/utils/customAtomWithFetch';
 import { StrategyLiveStatus } from '@/strategies/IStrategy';
+import fetchWithRetry from '@/utils/fetchWithRetry';
 
 export enum Category {
   Stable = 'Stable Pools',
@@ -59,6 +60,25 @@ export interface PoolInfo extends PoolMetadata {
   };
 }
 
+type NostraPoolData = {
+  id?: string;
+  address?: string;
+  isDegen?: boolean;
+  tokenA?: string;
+  tokenAAddress?: string;
+  tokenB?: string;
+  tokenBAddress?: string;
+  volume?: string;
+  fee?: string;
+  swap?: number;
+  tvl?: string;
+  baseApr?: string;
+  rewardApr?: string;
+  rewardAllocation?: string;
+};
+
+type NostraPools = Record<string, NostraPoolData>;
+
 export interface ProtocolAtoms {
   pools: Atom<PoolInfo[]>;
   baseAPRs?: Atom<AtomWithQueryResult<any, Error>>;
@@ -86,20 +106,30 @@ export const StrkDexIncentivesAtom = atom((get) => {
 
 export const StrkIncentivesAtom = atomWithQuery((get) => ({
   queryKey: get(StrkIncentivesQueryKeyAtom),
-  queryFn: async ({ queryKey }) => {
-    const res = await fetch(CONSTANTS.NOSTRA_DEGEN_INCENTIVE_URL);
-    let data = await res.text();
-    data = data.replaceAll('NaN', '0');
-    const parsedData = JSON.parse(data);
-
-    if (queryKey[1] === 'isNostraDex') {
-      // Filter the data to include only the specific nostra dex pools we are tracking
-      return Object.values(parsedData).filter((item: any) => {
-        const id = item.id;
-        return id === 'ETH-USDC' || id === 'STRK-ETH' || id === 'STRK-USDC';
-      });
+  queryFn: async ({ queryKey }): Promise<NostraPools | NostraPoolData[]> => {
+    try {
+      const res = await fetchWithRetry(
+        CONSTANTS.NOSTRA_DEGEN_INCENTIVE_URL,
+        {},
+        'Error fetching nostra incentives',
+      );  
+      if (!res) return [];
+      let data = await res.text();
+      data = data.replaceAll('NaN', '0');
+      const parsedData: NostraPools = JSON.parse(data);
+
+      if (queryKey[1] === 'isNostraDex') {
+        // Filter the data to include only the specific nostra dex pools we are tracking
+        return Object.values(parsedData).filter((item: any) => {
+          const id = item.id;
+          return id === 'ETH-USDC' || id === 'STRK-ETH' || id === 'STRK-USDC';
+        });
+      }
+      return parsedData;
+    } catch (error) {
+      console.error('Error fetching nostra incentives: ', error);
+      return [];
     }
-    return parsedData;
   },
 }));
 

src/store/utils.atoms.ts

@@ -1,8 +1,8 @@
 import CONSTANTS from '@/constants';
-import axios from 'axios';
 import { atomWithQuery } from 'jotai-tanstack-query';
 import { atomWithStorage, createJSONStorage } from 'jotai/utils';
 import { addressAtom } from './claims.atoms';
+import fetchWithRetry from '@/utils/fetchWithRetry';
 
 export interface BlockInfo {
   data: {
@@ -71,8 +71,9 @@ interface DAppStats {
 export const dAppStatsAtom = atomWithQuery((get) => ({
   queryKey: ['stats'],
   queryFn: async (): Promise<DAppStats> => {
-    const res = await axios.get('/api/stats');
-    return res.data;
+    const res = await fetchWithRetry('/api/stats', {}, 'Error fetching dApp stats');
+    if (!res) return { tvl: 0 };
+    return await res.json();
   },
 }));
 
@@ -102,8 +103,9 @@ export const userStatsAtom = atomWithQuery((get) => ({
     if (!addr) {
       return null;
     }
-    const res = await axios.get(`/api/stats/${addr}`);
-    return res.data;
+    const res = await fetchWithRetry(`/api/stats/${addr}`, {}, 'Error fetching user stats');
+    if (!res) return null;
+    return await res.json();
   },
 }));
 
@@ -171,16 +173,18 @@ export const blockInfoMinus1DAtom = atomWithQuery((get) => ({
       variables: {},
     });
     console.log('jedi base', 'data', data);
-    const res = await fetch(CONSTANTS.JEDI.BASE_API, {
+
+    const res = await fetchWithRetry(CONSTANTS.JEDI.BASE_API, {
       method: 'POST',
       headers: {
         Accept: 'application/json',
         'Content-Type': 'application/json',
       },
       body: data,
-    });
+    }, 'Error fetching block minus 1d');
+    if (!res) return { data: { blocks: [] } };
     console.log('jedi base', 'data2', res.json());
-    return res.json();
+    return await res.json();
   },
 }));
 

src/strategies/delta_neutral_mm.ts

@@ -329,9 +329,13 @@ export class DeltaNeutralMM extends IStrategy {
         usdValue: Number(amount.toEtherStr()) * price,
         tokenInfo: this.token,
       };
-    } catch (e) {
-      console.log('getTVL err', e);
-      throw e;
+    } catch (error) {
+      console.error('Error fetching TVL:', error);
+      return {
+        amount: MyNumber.fromEther('0', this.token.decimals),
+        usdValue: 0,
+        tokenInfo: this.token,
+      };
     }
   };