Track Ipor PlasmaVault fees

fees/ipor-protocol/index.ts

@@ -0,0 +1,89 @@
+import { FetchOptions, SimpleAdapter } from "../../adapters/types";
+import { getConfig } from "../../helpers/cache";
+import { CHAIN } from "../../helpers/chains";
+
+const IPOR_GITHUB_ADDRESSES_URL = "https://raw.githubusercontent.com/IPOR-Labs/ipor-abi/refs/heads/main/mainnet/addresses.json";
+
+const eventAbis = {
+    managementFee: "event ManagementFeeRealized(uint256 unrealizedFeeInUnderlying, uint256 unrealizedFeeInShares)",
+}
+
+const methodology = {
+    Fees: 'Management fees collected by the protocol are included in event logs emitted by each vault contract.',
+    Revenue: 'Total fees collected by the protocol.',
+}
+
+const fetch = () => {
+    return async (options: FetchOptions) => {
+        const dailyFees = options.createBalances()
+        const dailyRevenue = options.createBalances()
+
+        const config = await getConfig('ipor/assets', IPOR_GITHUB_ADDRESSES_URL);
+        const chainConfig = config[options.chain];
+        if (!chainConfig || !chainConfig.vaults) {
+            return { dailyFees, dailyRevenue };
+        }
+
+        const vaults = chainConfig.vaults.map((vault: any) => vault.PlasmaVault);
+
+        const logs = await options.api.getLogs({
+            targets: vaults,
+            eventAbi: eventAbis.managementFee,
+            fromBlock: await options.getFromBlock(),
+            toBlock: await options.getToBlock(),
+        })
+
+        // Call asset() for each vault to get underlying tokens
+        const assetCalls = await options.api.multiCall({
+            abi: 'function asset() view returns (address)',
+            calls: vaults.map((v: string) => ({ target: v })),
+            permitFailure: true,
+        })
+
+        const vaultToToken: Record<string, string> = {}
+        vaults.forEach((v: string, i: number) => {
+            if (assetCalls[i]) {
+                vaultToToken[v.toLowerCase()] = assetCalls[i]
+            }
+        })
+
+        logs.forEach((log: any) => {
+            const token = vaultToToken[log.address.toLowerCase()]
+            if (token) {
+                dailyFees.add(token, log.args[0])
+                dailyRevenue.add(token, log.args[0])
+            }
+        })
+
+        return { dailyFees, dailyRevenue }
+    }
+}
+
+const adapter: SimpleAdapter = {
+    version: 2,
+    adapter: {
+        [CHAIN.ETHEREUM]: {
+            fetch: fetch(),
+            start: "9-29-2024",
+        },
+        [CHAIN.ARBITRUM]: {
+            fetch: fetch(),
+            start: "9-3-2024",
+        },
+        [CHAIN.BASE]: {
+            fetch: fetch(),
+            start: "11-8-2024",
+        },
+        [CHAIN.UNICHAIN]: {
+            fetch: fetch(),
+            start: "6-18-2025",
+        },
+        [CHAIN.TAC]: {
+            fetch: fetch(),
+            start: "7-11-2025",
+        },
+    },
+    methodology
+}
+
+export default adapter;