Fix Mayan volume issues (#417)

* 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

* added missing filters  to process batch

* fixed double counting txs, removed pricing from mayan's API and added correct chain assignments

Author: kinsyudev

src/adapters/mayan/index.ts

@@ -13,34 +13,18 @@ type WormholeBridgeEvent = {
 };
 
 const chains = [
+  "solana",
   "ethereum",
-  "avalanche",
-  "avax",
-  "bsc",
-  "polygon",
+  "base",
   "arbitrum",
   "optimism",
-  "base",
-  "zksync",
-  "scroll",
-  "aptos",
+  "polygon",
+  "avalanche",
+  "bsc",
   "sui",
-  "solana",
-  "sei",
-  "mantle",
-  "fantom",
-  "injective",
-  "moonbeam",
-  "oasis",
-  "celo",
-  "kaia",
-  "near",
-  "algorand",
-  "terra",
-  "terra classic",
-  "karura",
-  "acala",
-  "wormchain",
+  "unichain",
+  "aptos",
+  "linea",
 ];
 
 export const chainNameMapping: { [key: string]: string } = {
@@ -145,9 +129,6 @@ export const fetchMayanEvents = async (fromTimestamp: number, toTimestamp: numbe
         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;
 
@@ -159,8 +140,8 @@ export const fetchMayanEvents = async (fromTimestamp: number, toTimestamp: numbe
           token_address: row.token || "",
           token_usd_amount: String(usdAmount),
           token_amount: row.amount || "0",
-          source_chain: source,
-          destination_chain: dest,
+          source_chain: sourceChain,
+          destination_chain: destChain,
           is_deposit: row.isDeposit, // Include deposit flag for filtering in handler
         };
       });

src/data/bridgeNetworkData.ts

@@ -2492,7 +2492,7 @@ export default [
       "Plume",
       "ZKsync Era",
       "Metis",
-      "Sei" 
+      "Sei",
     ],
     chainMapping: {
       "World Chain": "wc",
@@ -2546,27 +2546,27 @@ export default [
       "hyperliquid": "hyperliquid", // Identity mapping
     },
   },
-  // {
-  //   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",
-  //   ],
-  // },
+  {
+    id: 99,
+    displayName: "Mayan",
+    bridgeDbName: "mayan",
+    slug: "mayan",
+    iconLink: "icons:mayan",
+    largeTxThreshold: 10000,
+    url: "https://swap.mayan.finance/",
+    chains: [
+      "Solana",
+      "Ethereum",
+      "Base",
+      "Arbitrum",
+      "Optimism",
+      "Polygon",
+      "Avalanche",
+      "BSC",
+      "Sui",
+      "Unichain",
+      "Aptos",
+      "Linea",
+    ],
+  },
 ] as BridgeNetwork[];

src/handlers/runMayan.ts

@@ -34,8 +34,7 @@ export const handler = async () => {
 
     const processBatch = async (sql: any, batch: any[]) => {
       const start = dayjs().unix();
-      const sourceTransactions = [];
-      const destinationTransactions = [];
+      const transactions = [];
 
       for (const event of batch) {
         const {
@@ -44,60 +43,45 @@ export const handler = async () => {
           token_transfer_from_address,
           token_transfer_to_address,
           token_address,
-          token_usd_amount,
+          token_amount,
           source_chain,
           destination_chain,
+          is_deposit,
         } = event;
 
         const sourceChain = normalizeChainName(source_chain);
         const destinationChain = normalizeChainName(destination_chain);
 
-        if (bridgeIds[sourceChain]) {
-          sourceTransactions.push({
-            bridge_id: bridgeIds[sourceChain],
-            chain: sourceChain,
+        // Determine the correct chain to use for the bridge_id based on deposit status
+        const transactionChain = is_deposit ? destinationChain : sourceChain;
+        const originChain = is_deposit ? sourceChain : null;
+
+        // Only create one transaction per event, using the appropriate chain's bridge_id
+        if (bridgeIds[transactionChain]) {
+          transactions.push({
+            bridge_id: bridgeIds[transactionChain],
+            chain: transactionChain,
             tx_hash: transaction_hash,
             ts: parseInt(block_timestamp) * 1000,
             tx_block: null,
             tx_from: token_transfer_from_address ?? "0x",
             tx_to: token_transfer_to_address ?? "0x",
             token: token_address ?? "0x0000000000000000000000000000000000000000",
-            amount: token_usd_amount || "0",
-            is_deposit: true,
-            is_usd_volume: true,
-            txs_counted_as: 1,
-            origin_chain: null,
-          });
-        }
-
-        if (bridgeIds[destinationChain]) {
-          destinationTransactions.push({
-            bridge_id: bridgeIds[destinationChain],
-            chain: destinationChain,
-            tx_hash: `${transaction_hash}_destination`,
-            ts: parseInt(block_timestamp) * 1000,
-            tx_block: null,
-            tx_from: token_transfer_to_address ?? "0x",
-            tx_to: token_transfer_from_address ?? "0x",
-            token: token_address ?? "0x0000000000000000000000000000000000000000",
-            amount: token_usd_amount || "0",
-            is_deposit: false,
-            is_usd_volume: true,
+            amount: token_amount ?? "0",
+            is_deposit: is_deposit,
+            is_usd_volume: false,
             txs_counted_as: 1,
-            origin_chain: null,
+            origin_chain: originChain,
           });
         }
       }
 
       try {
-        if (sourceTransactions.length > 0) {
-          await insertTransactionRows(sql, true, sourceTransactions, "upsert");
-        }
-        if (destinationTransactions.length > 0) {
-          await insertTransactionRows(sql, true, destinationTransactions, "upsert");
+        if (transactions.length > 0) {
+          await insertTransactionRows(sql, true, transactions, "upsert");
         }
       } catch (error) {
-        console.error(`Error inserting Wormhole batch:`, error);
+        console.error(`Error inserting Mayan batch:`, error);
         throw error;
       }
 
@@ -124,7 +108,7 @@ export const handler = async () => {
       const amount = parseFloat(curr.token_usd_amount || "0");
 
       // Skip transactions over $1M (outliers from API issues. Mayan's API pricing isn't perfectly reliable, a majority of the outliers are caught with this)
-      if (amount > 1000000) {
+      if (amount > 1_000_000) {
         return acc;
       }
 
@@ -143,4 +127,6 @@ export const handler = async () => {
   }
 };
 
-export default wrapScheduledLambda(handler);
+// export default wrapScheduledLambda(handler);
+
+handler().then(() => process.exit(0));