Add Mayan Finance volume to bridges (#415)

* set up mayan adapter

* Add Mayan adapter and integrate event fetching and volume calculation

* Refactor Mayan event fetching to use API key and improve error handling; streamline volume calculation logic

* deleted pnpm lock yaml

* removed old comment

* Refactor Mayan event fetching to use secure API endpoint and improve error handling; update handler export for scheduled execution

Author: kinsyudev

src/adapters/index.ts

@@ -76,6 +76,7 @@ import retrobridge from "./retrobridge";
 import layerswap from "./layerswap";
 import hyperlane from "./hyperlane";
 import wormhole from "./wormhole";
+import mayan from "./mayan";
 import thresholdnetwork from "./threshold-network";
 import zircuit from "./zircuit";
 import hyperliquid from "./hyperliquid";
@@ -172,6 +173,7 @@ export default {
   layerswap,
   hyperlane,
   wormhole,
+  mayan,
   thresholdnetwork,
   zircuit,
   hyperliquid,

src/adapters/mayan/index.ts

@@ -0,0 +1,188 @@
+import dayjs from "dayjs";
+type WormholeBridgeEvent = {
+  block_timestamp: string;
+  transaction_hash: string;
+  token_transfer_from_address: string;
+  token_transfer_to_address: string;
+  token_address: string;
+  token_usd_amount: string;
+  token_amount: string;
+  source_chain: string;
+  destination_chain: string;
+  is_deposit?: boolean;
+};
+
+const chains = [
+  "ethereum",
+  "avalanche",
+  "avax",
+  "bsc",
+  "polygon",
+  "arbitrum",
+  "optimism",
+  "base",
+  "zksync",
+  "scroll",
+  "aptos",
+  "sui",
+  "solana",
+  "sei",
+  "mantle",
+  "fantom",
+  "injective",
+  "moonbeam",
+  "oasis",
+  "celo",
+  "kaia",
+  "near",
+  "algorand",
+  "terra",
+  "terra classic",
+  "karura",
+  "acala",
+  "wormchain",
+];
+
+export const chainNameMapping: { [key: string]: string } = {
+  ethereum: "Ethereum",
+  avalanche: "Avalanche",
+  avax: "Avalanche",
+  polygon: "Polygon",
+  arbitrum: "Arbitrum",
+  optimism: "Optimism",
+  fantom: "Fantom",
+  base: "Base",
+  solana: "Solana",
+  sui: "Sui",
+  aptos: "Aptos",
+  celo: "Celo",
+  mantle: "Mantle",
+  scroll: "Scroll",
+  algorand: "Algorand",
+  sei: "Sei",
+  moonbeam: "Moonbeam",
+  injective: "Injective",
+  kaia: "Kaia",
+  oasis: "Oasis",
+  BNB_Smart_Chain: "BSC",
+  bnb_smart_chain: "BSC",
+  terra: "Terra Classic",
+  terra2: "Terra",
+  "terra classic": "Terra Classic",
+  near: "Near",
+  karura: "Karura",
+  acala: "Acala",
+  wormchain: "Wormchain",
+  xlayer: "xLayer",
+  blast: "Blast",
+  xpla: "XPLA",
+};
+
+export function normalizeChainName(chainName: string): string {
+  const lowercaseChain = chainName.toLowerCase();
+
+  const mapping = chainNameMapping[lowercaseChain] || chainNameMapping[chainName];
+
+  if (mapping) {
+    return mapping?.toLowerCase();
+  }
+
+  return chainName?.toLowerCase();
+}
+
+// Map wormhole chain IDs to chain names
+const wormholeChainMap: { [key: string]: string } = {
+  "1": "solana",
+  "2": "ethereum",
+  "30": "base",
+  "23": "arbitrum",
+  "24": "optimism",
+  "5": "polygon",
+  "6": "avalanche",
+  "4": "bsc",
+  "21": "sui",
+  "44": "unichain",
+  "22": "aptos",
+  "38": "linea",
+};
+
+export const fetchMayanEvents = async (fromTimestamp: number, toTimestamp: number): Promise<WormholeBridgeEvent[]> => {
+  let allResults: WormholeBridgeEvent[] = [];
+  let offset = 0;
+  const BATCH_SIZE = 10000;
+  const API_KEY = process.env.MAYAN_API_KEY || "";
+
+  // Convert timestamps to milliseconds for API
+  const startMs = fromTimestamp * 1000;
+  const endMs = toTimestamp * 1000;
+
+  while (true) {
+    try {
+      const url = `https://dlapi.wormhole.com/swaps?startTs=${startMs}&endTs=${endMs}&offset=${offset}&limit=${BATCH_SIZE}`;
+
+      const response = await fetch(url, {
+        headers: {
+          "API-KEY": API_KEY,
+          "Content-Type": "application/json",
+        },
+      });
+
+      if (!response.ok) {
+        throw new Error(`API request failed with status: ${response.status}`);
+      }
+
+      const result = await response.json();
+
+      if (result.length === 0) {
+        break;
+      }
+
+      const normalizedBatch = result.map((row: any) => {
+        // Parse timestamp - handle both ISO string and unix formats
+        const timestamp = row.ts ? dayjs(row.ts).unix() : dayjs().unix();
+
+        // Map chain IDs to chain names
+        const sourceChain = wormholeChainMap[row.originChain] || row.originChain || "unknown";
+        const destChain = wormholeChainMap[row.chain] || row.chain || "unknown";
+
+        // For deposits, swap source/dest (deposit means going FROM origin TO current chain)
+        const [source, dest] = row.isDeposit ? [sourceChain, destChain] : [destChain, sourceChain];
+
+        // Parse USD amount
+        const usdAmount = parseFloat(row.amountUsd || "0") || 0;
+
+        return {
+          block_timestamp: timestamp,
+          transaction_hash: row.txHash || row.orderId || "",
+          token_transfer_from_address: row.txFrom || "",
+          token_transfer_to_address: row.txTo || "",
+          token_address: row.token || "",
+          token_usd_amount: String(usdAmount),
+          token_amount: row.amount || "0",
+          source_chain: source,
+          destination_chain: dest,
+          is_deposit: row.isDeposit, // Include deposit flag for filtering in handler
+        };
+      });
+
+      allResults = [...allResults, ...normalizedBatch];
+
+      offset += BATCH_SIZE;
+
+      if (result.length < BATCH_SIZE) {
+        break;
+      }
+    } catch (error) {
+      throw error;
+    }
+  }
+
+  return allResults;
+};
+
+const adapter = chains.reduce((acc: any, chain: string) => {
+  acc[chain] = true;
+  return acc;
+}, {});
+
+export default adapter;

src/data/bridgeNetworkData.ts

@@ -1235,14 +1235,27 @@ export default [
     iconLink: "icons:butter-network",
     largeTxThreshold: 10000,
     url: "",
-    chains: ["Ethereum", "Polygon", "BSC", "Arbitrum", "Base", "Optimism", "Tron",
-      "X Layer", "MAP Relay Chain", "Kaia", "Linea",
-      "Scroll", "Mantle", "Merlin", "Blast"],
+    chains: [
+      "Ethereum",
+      "Polygon",
+      "BSC",
+      "Arbitrum",
+      "Base",
+      "Optimism",
+      "Tron",
+      "X Layer",
+      "MAP Relay Chain",
+      "Kaia",
+      "Linea",
+      "Scroll",
+      "Mantle",
+      "Merlin",
+      "Blast",
+    ],
     chainMapping: {
       "map relay chain": "map",
       "x layer": "xlayer",
       kaia: "klaytn",
-
     },
     destinationChain: "MAP Relay Chain",
   },
@@ -2455,13 +2468,7 @@ export default [
     iconLink: "icons:agglayer",
     largeTxThreshold: 10000,
     url: "https://agglayer.dev/",
-    chains: [
-      "Ethereum",
-      "Katana",
-      "Polygon Zkevm",
-      "Ternoa",
-      "X Layer"
-    ],
+    chains: ["Ethereum", "Katana", "Polygon Zkevm", "Ternoa", "X Layer"],
     chainMapping: {
       "polygon zkevm": "polygon_zkevm",
       "x layer": "xlayer",
@@ -2493,9 +2500,32 @@ export default [
       "solana",
     ],
     chainMapping: {
-      "avalanche": "avax",
+      avalanche: "avax",
       "world chain": "wc",
-      "hyperliquid": "hyperliquid",
+      hyperliquid: "hyperliquid",
     },
   },
+  {
+    id: 99,
+    displayName: "Mayan",
+    bridgeDbName: "mayan",
+    slug: "mayan",
+    iconLink: "icons:mayana",
+    largeTxThreshold: 10000,
+    url: "https://swap.mayan.finance/",
+    chains: [
+      "Solana",
+      "Ethereum",
+      "Base",
+      "Arbitrum",
+      "Optimism",
+      "Polygon",
+      "Avalanche",
+      "BSC",
+      "Sui",
+      "Unichain",
+      "Aptos",
+      "Linea",
+    ],
+  },
 ] as BridgeNetwork[];