Merge pull request #2210 from NablaFinance/update-nablaFinance-hyperEvmAndMonad

Add yield support for Nabla Finance deployments on HyperEVM and Monad

Author: slasher125

src/adaptors/nabla-finance/index.js

@@ -9,6 +9,13 @@ const graphUrls = {
   base: 'https://subgraph.satsuma-prod.com/9b84d9926bf3/nabla-finance--3958960/nabla-mainnetAlpha-base/api',
   berachain:
     'https://subgraph.satsuma-prod.com/9b84d9926bf3/nabla-finance--3958960/nabla-mainnetAlpha-berachain-public/api',
+  hyperliquid:
+    'https://api.goldsky.com/api/public/project_cm7aautkjfpbg01v47kya5470/subgraphs/nabla-mainnetAlpha-hyperliquid/v0.0.3/gn',
+};
+
+const nablaIndexerUrls = {
+  monad:
+    'https://indexer.nabla.fi/bsps/0x11B06EF8Adc5ea73841023CB39Be614f471213cc',
 };
 
 const query = gql`
@@ -32,7 +39,96 @@ const apr7dToApy = (apr) => {
   return (1 + aprDay) ** 365 - 1;
 };
 
-const poolsFunction = async (chain) => {
+// Process Nabla indexer response
+const getNablaIndexerPoolsMetrics = async (chain) => {
+  try {
+    const response = await superagent.get(nablaIndexerUrls[chain]);
+    const data = response.body;
+
+    if (!data.bsps || data.bsps.length === 0) {
+      console.log(`No BSPs found for chain: ${chain}`);
+      return [];
+    }
+
+    const allPools = [];
+
+    for (const bsp of data.bsps) {
+      const coveredPools = bsp.coveredSwapPools || [];
+
+      if (coveredPools.length === 0) continue;
+
+      // Collect all unique token addresses
+      const tokens = [...new Set(coveredPools.map((pool) => pool.asset))];
+
+      const priceKeys = tokens.map((address) => getPriceKey(address, chain));
+
+      let usdPrices = {};
+      try {
+        const priceResponse = await superagent.get(
+          `https://coins.llama.fi/prices/current/${priceKeys
+            .join(',')
+            .toLowerCase()}`
+        );
+        usdPrices = priceResponse.body.coins || {};
+      } catch (err) {
+        console.error(`Failed fetching prices for chain ${chain}:`, err);
+        continue;
+      }
+
+      for (const pool of coveredPools) {
+        const {
+          address: poolAddress,
+          asset: tokenAddress,
+          asset_symbol,
+          asset_decimals,
+          total_liabilities,
+          weekly_apr,
+        } = pool;
+
+        const key = getPriceKey(tokenAddress, chain).toLowerCase();
+        const priceData = usdPrices[key];
+
+        if (!priceData) {
+          console.log(`No price data found for token: ${key}`);
+          continue;
+        }
+
+        const { price } = priceData;
+        const decimals = asset_decimals || 18;
+
+        // Calculate TVL from total_liabilities
+        const tvlNormalized = BigNumber(total_liabilities || 0).div(
+          10 ** decimals
+        );
+        const tvlUsd = tvlNormalized.times(price).toNumber();
+
+        // Convert weekly APR to APY (weekly_apr is already in %)
+        const aprDecimal = Number(weekly_apr || 0) / 100;
+        const apyBase = apr7dToApy(aprDecimal) * 100;
+
+        allPools.push({
+          pool: `${poolAddress}-${chain}`,
+          chain: utils.formatChain(chain),
+          project: 'nabla-finance',
+          symbol: utils.formatSymbol(asset_symbol),
+          underlyingTokens: [tokenAddress],
+          tvlUsd: tvlUsd,
+          apyBase: apyBase,
+        });
+      }
+    }
+
+    return allPools;
+  } catch (error) {
+    console.error(
+      `Error fetching pools from Monad indexer for chain ${chain}:`,
+      error
+    );
+    return [];
+  }
+};
+
+const getGraphPoolsMetrics = async (chain) => {
   try {
     const swapPools = (await request(graphUrls[chain], query)).swapPools;
 
@@ -97,15 +193,32 @@ const poolsFunction = async (chain) => {
 };
 
 const poolsOnAllChains = async () => {
-  const chains = Object.keys(graphUrls);
+  const graphChains = Object.keys(graphUrls);
+  const nablaIndexerChains = Object.keys(nablaIndexerUrls);
 
-  const allPoolsPromises = chains.map((chain) =>
-    poolsFunction(chain).catch((error) => {
+  // Fetch from GraphQL subgraphs
+  const graphPoolsPromises = graphChains.map((chain) =>
+    getGraphPoolsMetrics(chain).catch((error) => {
       console.error(`Failed to fetch pools for chain ${chain}:`, error);
       return [];
     })
   );
 
+  // Fetch from Nabla indexer
+  const nablaIndexerPoolsPromises = nablaIndexerChains.map((chain) =>
+    getNablaIndexerPoolsMetrics(chain).catch((error) => {
+      console.error(
+        `Failed to fetch pools from indexer for chain ${chain}:`,
+        error
+      );
+      return [];
+    })
+  );
+
+  const allPoolsPromises = [
+    ...graphPoolsPromises,
+    ...nablaIndexerPoolsPromises,
+  ];
   const allPools = await Promise.all(allPoolsPromises);
   return allPools.flat();
 };