Merge pull request #2386 from ydever02/rooster

Add Rooster Fee/Volume

Author: dtmkeng

dexs/maverick-v2/maverick-v2.ts

@@ -39,53 +39,68 @@ const mavV2PoolCreated = `event PoolCreated(address poolAddress,uint8 protocolFe
 const mavV2SwapEvent =
   "event PoolSwap(address sender,address recipient,(uint256 amount,bool tokenAIn,bool exactOutput,int32 tickLimit) params,uint256 amountIn,uint256 amountOut)";
 
-export const getData = async (options: FetchOptions) => {
-  const factory = maverickV2Factories[options.chain].factory;
-  const factoryFromBlock = maverickV2Factories[options.chain].startBlock;
-  const dailyFees = options.createBalances();
-  const dailyVolume = options.createBalances();
-  try {
-    const logs = await options.getLogs({
-      target: factory,
-      fromBlock: factoryFromBlock,
-      eventAbi: mavV2PoolCreated,
-    });
-    const pools = [...new Set(logs.map((log: any) => log.poolAddress))];
-    const tokenAs = await options.api.multiCall({ abi: "address:tokenA", calls: pools! });
-    const tokenBs = await options.api.multiCall({ abi: "address:tokenB", calls: pools! });
-    const swapLogs = await options.getLogs({
-      targets: pools,
-      eventAbi: mavV2SwapEvent,
-      topic: "0x103ed084e94a44c8f5f6ba8e3011507c41063177e29949083c439777d8d63f60",
-      flatten: false,
-    });
+export const createGetData = (factories: { [chain: string]: { factory: string; startBlock: number } }) => {
+  return async (options: FetchOptions) => {
+    const factory = factories[options.chain].factory;
+    const factoryFromBlock = factories[options.chain].startBlock;
+    const dailyFees = options.createBalances();
+    const dailyVolume = options.createBalances();
 
-    const feesA = logs.map((log: any) => Number(log.feeAIn));
-    const feesB = logs.map((log: any) => Number(log.feeBIn));
+    try {
+      const logs = await options.getLogs({
+        target: factory,
+        fromBlock: factoryFromBlock,
+        eventAbi: mavV2PoolCreated,
+      });
+
+      const pools = [...new Set(logs.map((log: any) => log.poolAddress))];
+      const tokenAs = await options.api.multiCall({
+        abi: "address:tokenA",
+        calls: pools!,
+      });
+      const tokenBs = await options.api.multiCall({
+        abi: "address:tokenB",
+        calls: pools!,
+      });
 
-    swapLogs.forEach((log: any[], index: number) => {
-      const tokenA = tokenAs[index];
-      const tokenB = tokenBs[index];
-      if (!log.length) return;
-      log.forEach((i: any) => {
-        // element 3 is amount in
-        const amount = Number(i[3]);
-        // element 2,1 is tokenAIn
-        const tokenAIn = Boolean(i[2][1]);
-        const fee = tokenAIn ? feesA[index] : feesB[index];
-        dailyFees.add(tokenAIn ? tokenA : tokenB, (amount) * (fee / 1e18));
-        dailyVolume.add(tokenAIn ? tokenA : tokenB, amount);
+      const swapLogs = await options.getLogs({
+        targets: pools,
+        eventAbi: mavV2SwapEvent,
+        topic:
+        "0x103ed084e94a44c8f5f6ba8e3011507c41063177e29949083c439777d8d63f60",
+        flatten: false,
       });
-    });
-    return {
-      dailyVolume: dailyVolume,
-      dailyFees: dailyFees,
-    };
-  } catch (e) {
-    console.error(e);
-    return {
-      dailyVolume: dailyVolume,
-      dailyFees: dailyFees,
-    };
-  }
+
+      const feesA = logs.map((log: any) => Number(log.feeAIn));
+      const feesB = logs.map((log: any) => Number(log.feeBIn));
+
+      swapLogs.forEach((log: any[], index: number) => {
+        const tokenA = tokenAs[index];
+        const tokenB = tokenBs[index];
+        if (!log.length) return;
+        log.forEach((i: any) => {
+          // element 3 is amount in
+          const amount = Number(i[3]);
+          // element 2,1 is tokenAIn
+          const tokenAIn = Boolean(i[2][1]);
+          const fee = tokenAIn ? feesA[index] : feesB[index];
+          dailyFees.add(tokenAIn ? tokenA : tokenB, amount * (fee / 1e18));
+          dailyVolume.add(tokenAIn ? tokenA : tokenB, amount);
+        });
+      });
+      return {
+        dailyVolume: dailyVolume,
+        dailyFees: dailyFees,
+      };
+    } catch (e) {
+      console.error(e);
+      return {
+        dailyVolume: dailyVolume,
+        dailyFees: dailyFees,
+      };
+    }
+  };
 };
+
+// Export a function that calls createGetData with the maverickV2Factories
+export const getData = createGetData(maverickV2Factories);

dexs/rooster/index.ts

@@ -0,0 +1,26 @@
+//  Maverick v2 volume
+import { SimpleAdapter } from "../../adapters/types";
+import { CHAIN } from "../../helpers/chains";
+import { createGetData } from "../maverick-v2/maverick-v2";
+
+export const factories: { [key: string]: any } = {
+  [CHAIN.PLUME]: {
+    factory: "0x056A588AfdC0cdaa4Cab50d8a4D2940C5D04172E",
+    startBlock: 91952,
+    startTimestamp: 1734665440,
+  },
+};
+
+const getData = createGetData(factories);
+
+const adapter: SimpleAdapter = {
+  version: 2,
+  adapter: {
+    [CHAIN.PLUME]: {
+      fetch: getData,
+      start: factories[CHAIN.PLUME].startTimestamp,
+    },
+  },
+};
+
+export default adapter;