Merge pull request #265 from DefiLlama/fix_comet

Fix comet

src/adapters/cometbridge/index.ts

@@ -0,0 +1,108 @@
+import { BridgeAdapter, PartialContractEventParams } from "../../helpers/bridgeAdapter.type";
+import { getTxDataFromEVMEventLogs } from "../../helpers/processTransactions";
+import { constructTransferParams } from "../../helpers/eventParams";
+import { Chain } from "@defillama/sdk/build/general";
+import { EventData } from "../../utils/types";
+import { getTxsBlockRangeEtherscan, wait } from "../../helpers/etherscan";
+
+export const bridgesAddress = {
+    ethereum: ["0xB50Ac92D6d8748AC42721c25A3e2C84637385A6b"],
+    arbitrum: ["0xB50Ac92D6d8748AC42721c25A3e2C84637385A6b"],
+    optimism: ["0xB50Ac92D6d8748AC42721c25A3e2C84637385A6b"],
+    era: ["0xB50Ac92D6d8748AC42721c25A3e2C84637385A6b"],
+    base: ["0xB50Ac92D6d8748AC42721c25A3e2C84637385A6b"],
+    linea: ["0xB50Ac92D6d8748AC42721c25A3e2C84637385A6b"],
+    scroll: ["0xB50Ac92D6d8748AC42721c25A3e2C84637385A6b"],
+    blast: ["0xB50Ac92D6d8748AC42721c25A3e2C84637385A6b"],
+    xlayer: ["0xB50Ac92D6d8748AC42721c25A3e2C84637385A6b"],
+    taiko: ["0xB50Ac92D6d8748AC42721c25A3e2C84637385A6b"],
+    zklink: ["0xB50Ac92D6d8748AC42721c25A3e2C84637385A6b"],
+    bsc: ["0xB50Ac92D6d8748AC42721c25A3e2C84637385A6b"],
+    mode: ["0xB50Ac92D6d8748AC42721c25A3e2C84637385A6b"],
+    merlin: ["0xB50Ac92D6d8748AC42721c25A3e2C84637385A6b"],
+    "b2-mainnet": ["0xB50Ac92D6d8748AC42721c25A3e2C84637385A6b"],
+} as const;
+
+const nativeTokens: Record<string, string> = {
+    ethereum: "0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2",
+    arbitrum: "0x82af49447d8a07e3bd95bd0d56f35241523fbab1",
+    optimism: "0x4200000000000000000000000000000000000006",
+    base: "0x4200000000000000000000000000000000000006",
+    linea: "0xe5D7C2a44FfDDf6b295A15c148167daaAf5Cf34f",
+    blast: "0x4300000000000000000000000000000000000004",
+    scroll: "0x5300000000000000000000000000000000000004",
+    polygon: "0x0d500B1d8E8eF31E21C99d1Db9A6444d3ADf1270",
+    bsc: "0xbb4CdB9CBd36B01bD1cBaEBF2De08d9173bc095c",
+    era: "0x5AEa5775959fBC2557Cc8789bC1bf90A239D9a91",
+    merlin: "0xF6D226f9Dc15d9bB51182815b320D3fBE324e1bA",
+};
+const nativeTokenTransferSignature = ["0x535741", "0x"];
+
+type SupportedChains = keyof typeof bridgesAddress;
+
+const constructParams = (chain: SupportedChains) => {
+    const bridgeAddress = bridgesAddress[chain];
+
+    let eventParams = [] as any;
+    bridgeAddress.map((address: string) => {
+        const transferWithdrawalParams: PartialContractEventParams = constructTransferParams(address, false);
+        const transferDepositParams: PartialContractEventParams = constructTransferParams(address, true);
+        eventParams.push(transferWithdrawalParams, transferDepositParams);
+    });
+
+    if (nativeTokens.hasOwnProperty(chain)) {
+        return async (fromBlock: number, toBlock: number) => {
+            const eventLogData = await getTxDataFromEVMEventLogs("comet", chain as Chain, fromBlock, toBlock, eventParams);
+
+            const nativeEvents = await Promise.all([
+                ...bridgeAddress.map(async (address: string, i: number) => {
+                    await wait(300 * i); // for etherscan
+                    let txs: any[] = [];
+                        txs = await getTxsBlockRangeEtherscan(chain, address, fromBlock, toBlock, {
+                            includeSignatures: nativeTokenTransferSignature,
+                        });
+
+                    const eventsRes: EventData[] = txs.map((tx: any) => {
+                        const event: EventData = {
+                            txHash: tx.hash,
+                            blockNumber: +tx.blockNumber,
+                            from: tx.from,
+                            to: tx.to,
+                            token: nativeTokens[chain],
+                            amount: tx.value,
+                            isDeposit: address === tx.to,
+                        };
+                        return event;
+                    });
+
+                    return eventsRes;
+                }),
+            ]
+            );
+            const allEvents = [...eventLogData, ...nativeEvents.flat()];
+            return allEvents;
+        };
+    } else {
+        return async (fromBlock: number, toBlock: number) =>
+            getTxDataFromEVMEventLogs("comet", chain as Chain, fromBlock, toBlock, eventParams);
+    }
+}
+
+
+const adapter: BridgeAdapter = {
+    ethereum: constructParams("ethereum"),
+    arbitrum: constructParams("arbitrum"),
+    optimism: constructParams("optimism"),
+    base: constructParams("base"),
+    linea: constructParams("linea"),
+    blast: constructParams("blast"),
+    scroll: constructParams("scroll"),
+    bsc: constructParams("bsc"),
+    taiko: constructParams("taiko"),
+    zklink: constructParams("zklink"),
+
+    'x layer': constructParams("xlayer"),
+    "zksync era": constructParams("era"),
+};
+
+export default adapter;

src/adapters/index.ts

@@ -64,6 +64,7 @@ import oooo from "./oooo";
 import memebridge from "./memebridge";
 import bunnyfi from "./bunnyfi";
 import minibridge from "./minibridge";
+import cometbridge from "./cometbridge";
 
 export default {
   polygon,
@@ -131,6 +132,7 @@ export default {
   memebridge,
   bunnyfi,
   minibridge,
+  cometbridge,
 } as {
   [bridge: string]: BridgeAdapter;
 };

src/data/bridgeNetworkData.ts

@@ -1412,4 +1412,34 @@ export default [
       bitlayer: "btr",
     },
   },
+  {
+    id: 69,
+    displayName: "CometBridge",
+    bridgeDbName: "cometbridge",
+    iconLink: "icons:comet",
+    largeTxThreshold: 10000,
+    url: "https://cometbridge.app",
+    chains: [
+      "Ethereum",
+      "Arbitrum",
+      "Optimism",
+      "Base",
+      "Linea",
+      "Blast",
+      "Scroll",
+      "BSC",
+      "X Layer",
+      "Taiko",
+      "ZkLink",
+      "zkSync Era",
+      "Merlin",
+      "BSquared",
+      "Bitlayer",
+      "Mode",
+    ],
+    chainMapping: {
+      "zksync era": "era",
+      "x layer": "xlayer",
+    },
+  },
 ] as BridgeNetwork[];