Merge pull request #366 from DefiLlama/axelar

Axelar

Author: vrtnd

src/adapters/axelar/index.ts

@@ -2,10 +2,8 @@ import { BridgeAdapter, PartialContractEventParams } from "../../helpers/bridgeA
 import { constructTransferParams } from "../../helpers/eventParams";
 import { getTxDataFromEVMEventLogs } from "../../helpers/processTransactions";
 import { BigNumber } from "ethers";
-import { fetchAssets, getTokenAddress } from "../squid/utils";
-import { getItsTokens } from "./utils";
-
-
+import { getTokenAddress } from "../squid/utils";
+import { getAssets, getItsTokens } from "./utils";
 
 const axelarChains = {
   arbitrum: {
@@ -241,11 +239,9 @@ const constructParams = (chain: SupportedChains) => {
   const itsAddy = axelarContractAddress.its;
 
   return async (fromBlock: number, toBlock: number) => {
-
-    const assets = await fetchAssets();
+    const assets = await getAssets();
     const itsAssets = await getItsTokens();
 
-
     //legacy
     const depositV1 = constructTransferParams(gatewayAddy, true, {
       excludeFrom: [gatewayAddy, nullAddress],
@@ -260,7 +256,6 @@ const constructParams = (chain: SupportedChains) => {
       includeFrom: [gatewayAddy],
     });
 
-
     const tokenSentEvent = {
       ...TokenSentParams,
       target: gatewayAddy,
@@ -305,15 +300,13 @@ const constructParams = (chain: SupportedChains) => {
         amount: (log: any) => BigNumber.from(log.amount),
         to: (log: any) => log.destinationAddress,
         token: (log: any) => {
-          const asset = itsAssets.find((item: any) =>
-            item.id.toLowerCase() === log.tokenId.toLowerCase()
-          );
+          const asset = itsAssets.find((item: any) => item.id.toLowerCase() === log.tokenId.toLowerCase());
           return asset && asset.chains && asset.chains[chain] && asset.chains[chain].tokenAddress
             ? asset.chains[chain].tokenAddress
-            : '';
-        }
-      }
-    }
+            : "";
+        },
+      },
+    };
 
     const interchainTransferReceivedEvent = {
       ...InterchainTransferReceivedParams,
@@ -323,13 +316,11 @@ const constructParams = (chain: SupportedChains) => {
         amount: (log: any) => BigNumber.from(log.amount),
         to: (log: any) => log.destinationAddress,
         token: (log: any) => {
-          const asset = itsAssets.find((item: any) =>
-            item.id.toLowerCase() === log.tokenId.toLowerCase()
-          );
-          return asset && asset.chains && asset.chains[chain] && asset.chains[chain].tokenAddress
+          const asset = itsAssets.find((item: any) => item.id.toLowerCase() === log.tokenId.toLowerCase());
+          asset && asset.chains && asset.chains[chain] && asset.chains[chain].tokenAddress
             ? asset.chains[chain].tokenAddress
-            : '';
-        }
+            : "";
+        },
       },
     };
 
@@ -344,7 +335,7 @@ const constructParams = (chain: SupportedChains) => {
       interchainTransferReceivedEvent
     );
     return await getTxDataFromEVMEventLogs("axelar", chain, fromBlock, toBlock, eventParams);
-  }
+  };
 };
 const adapter: BridgeAdapter = {
   arbitrum: constructParams("arbitrum"),
@@ -353,12 +344,12 @@ const adapter: BridgeAdapter = {
   blast: constructParams("blast"),
   bsc: constructParams("bsc"),
   celo: constructParams("celo"),
-  cfg: constructParams("cfg"), //centrifuge
+  cfg: constructParams("cfg"), //cfg
   ethereum: constructParams("ethereum"),
   fantom: constructParams("fantom"),
   filecoin: constructParams("filecoin"),
   fraxtal: constructParams("fraxtal"),
-  imx: constructParams("imx"), //immutable
+  imx: constructParams("imx"),
   kava: constructParams("kava"),
   linea: constructParams("linea"),
   mantle: constructParams("mantle"),

src/adapters/axelar/utils.ts

@@ -6,10 +6,18 @@ export const getItsTokens = () =>
     fetch("https://api.axelarscan.io/api/getITSAssets", {
       method: "GET",
       headers: { "Content-Type": "application/json" },
-    }).then((res) => res.json())
+    }).then((res: any) => res.json())
   );
 
 
-  //  TODO
-  // custom tokens dont seem to be getting queried for example token from this tx
-  // https://axelarscan.io/gmp/0x83d2af2f18c63349d755ce2f3fd3ff4a7990ebd0e61458200f60504e198c843d
+export const getAssets = () =>
+  retry(() =>
+    fetch("https://api.axelarscan.io/api/getAssets", {
+      method: "GET",
+      headers: { "Content-Type": "application/json" },
+    }).then((res: any) => res.json())
+  );
+
+//  TODO
+// custom tokens dont seem to be getting queried for example token from this tx
+// https://axelarscan.io/gmp/0x83d2af2f18c63349d755ce2f3fd3ff4a7990ebd0e61458200f60504e198c843d

src/adapters/squid/utils.ts

@@ -64,19 +64,18 @@ export const getTokenId = (token: string, chain: string): string => {
   return `${chain}:${token.toLowerCase()}`;
 }
 
-export const getTokenAddress = (symbol: string, chain: string, assets: any[]) =>  {
-    // Handle native token address
-    if (symbol === "0xEeeeeEeeeEeEeeEeEeEeeEEEeeeeEeeeeeeeEEeE") {
-      return symbol;
-    }
-
-    symbol = getSymbol(symbol);
-    chain = getChain(chain);
-    let tokenAddress = assets.find((asset) => asset.symbol === symbol)?.addresses?.[chain]?.address;
-
-    if (tokenAddress == undefined) tokenAddress = "0x000000000000000000000000000000000000dEaD"
+export const getTokenAddress = (symbol: string, chain: string, assets: any[]) => {
+  // Handle native token address
+  if (symbol === "0xEeeeeEeeeEeEeeEeEeEeeEEEeeeeEeeeeeeeEEeE") {
+    return symbol;
+  }
+  symbol = getSymbol(symbol);
+  chain = getChain(chain);
+  let tokenAddress = assets.find((asset) => asset.symbol === symbol
+  )?.addresses?.[chain == 'imx' ? 'immutable' : chain]?.address
+  if (tokenAddress == undefined) tokenAddress = "0x000000000000000000000000000000000000dEaD"
 
-    return tokenAddress;
+  return tokenAddress;
 }
 
 const getChain = (chain: string) => {
@@ -98,8 +97,8 @@ const getSymbol = (rawSymbol: string) => {
   let symbol: string = rawSymbol;
   if (symbol.startsWith("axl-")) symbol = symbol.slice(4);
   if (symbol.startsWith("axl")) symbol = symbol.slice(3);
-  
-  const nativeTokenMap: {[key: string]: string} = {
+
+  const nativeTokenMap: { [key: string]: string } = {
     "AVAX": "WAVAX",
     "FTM": "WFTM",
     "BNB": "WBNB",
@@ -130,7 +129,7 @@ export const fetchAssets = () => {
         body: JSON.stringify({
           method: "getAssets",
         }),
-      }).then((res) => res.json())
+      }).then((res: any) => res.json())
     );
 }
 
@@ -189,8 +188,8 @@ export const isStablecoin = (tokenAddress: string, chain: string) => {
 // Add helper function to convert chain ID to name
 export const getChainNameFromId = (chainId: string | number): string => {
   // Convert number to hex string if needed
-  const hexChainId = typeof chainId === "number" ? 
-    "0x" + chainId.toString(16) : 
+  const hexChainId = typeof chainId === "number" ?
+    "0x" + chainId.toString(16) :
     chainId.toLowerCase();
 
   return chainIdToName[hexChainId] || "unknown";
@@ -215,10 +214,10 @@ export const fetchWithRetry = async (url: string, maxRetries = 5) => {
       const response = await fetch(url);
       if (response.status === 429) {
         // Get retry-after header or use exponential backoff
-        const retryAfter = response.headers.get('retry-after') ? 
-          parseInt(response.headers.get('retry-after') || '1') : 
+        const retryAfter = response.headers.get('retry-after') ?
+          parseInt(response.headers.get('retry-after') || '1') :
           Math.pow(2, retries) * 1000;
-        
+
         console.log(`Rate limited. Retrying after ${retryAfter}ms...`);
         await new Promise(resolve => setTimeout(resolve, retryAfter));
         retries++;

src/adapters/test.ts

@@ -68,7 +68,6 @@ const testAdapter = async () => {
         const startBlock = number - parseInt(numberOfBlocks);
         console.log(`Getting event logs on chain ${contractsChain} from block ${startBlock} to ${number}.`);
         const eventLogs = await adapterChainEventsFn(startBlock, number);
-        // console.log(eventLogs)
         console.log(`Found ${eventLogs.length} event logs on chain ${contractsChain}.`);
         for (const log of eventLogs) {
           console.log(`[${contractsChain}] ${log.isDeposit ? "Deposit" : "Withdrawal"} ${log.txHash}`);

src/helpers/processTransactions.ts

@@ -288,6 +288,7 @@ export const getTxDataFromEVMEventLogs = async (
             let toFilter = await filter.custom(provider, iface, txLog.transactionHash);
             if (toFilter) dataKeysToFilter.push(i);
           }
+
           if (getTokenFromReceipt && getTokenFromReceipt.token) {
             const txReceipt = await provider.getTransactionReceipt(txLog.transactionHash);
             if (!txReceipt) {