velora holder revenue and prefetch to optimize api call (DefiLlama#3427)

Author: treeoflife2

aggregators/paraswap/paraswapApi.ts

@@ -3,13 +3,16 @@ import { CHAIN } from "../../helpers/chains";
 import { getTimestampAtStartOfDayUTC } from "../../utils/date";
 import { Chain } from "../../adapters/types";
 import { httpGet } from "../../utils/fetchURL";
+import { FetchOptions } from "../../adapters/types";
 
+interface IResponse {
+  daily: any[];
+  allTime: any;
+}
 
 const feesMMURL = "https://api.paraswap.io/stk/volume-stats/breakdown-by-chain";
-type TChainId = {
-  [l: string | Chain]: string;
-}
-const mapChainId: TChainId = {
+
+const mapChainId: Record<string, string> = {
   [CHAIN.ETHEREUM]: '1',
   [CHAIN.OPTIMISM]: '10',
   [CHAIN.BSC]: '56',
@@ -21,88 +24,81 @@ const mapChainId: TChainId = {
   [CHAIN.AVAX]: '43114',
 } 
 
-type IRequest = {
-  [key: string]: Promise<any>;
+const prefetch = async (_: any) => {
+  const headers: any = {
+    "accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.7",
+    "accept-language": "en-US,en;q=0.9",
+    "cache-control": "max-age=0",
+    "priority": "u=0, i",
+    "upgrade-insecure-requests": "1",
+    "referrerPolicy": "strict-origin-when-cross-origin",
+  };
+  return await httpGet(feesMMURL, {headers});
 }
-const requests: IRequest = {}
 
-const fetchCacheURL = (url: string) => {
-  const key = url;
-  if (!requests[key]) {
-      const headers: any = {
-        "accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.7",
-        "accept-language": "en-US,en;q=0.9",
-        "cache-control": "max-age=0",
-        "priority": "u=0, i",
-        "upgrade-insecure-requests": "1",
-        "referrerPolicy": "strict-origin-when-cross-origin",
-      };
-      requests[key] = httpGet(url, {headers});
-  }
-  return requests[key];
-}
+const fetchFees = (chain: Chain) => {
+  return async (timestamp: number, _: any, options: FetchOptions): Promise<FetchResultFees> => {
+    if (chain == CHAIN.FANTOM && timestamp > 1744416000) return {} as FetchResultFees; // fantom delisted at 2025-04-12
+    const timestampToday = getTimestampAtStartOfDayUTC(timestamp)
+    const response: IResponse = options.preFetchedResults || [];
+    const dailyResultFees: any[] = response.daily;
 
-interface IResponse {
-  daily: any[];
-  allTime: any;
+    const [dailyVolume, partnerRev, protocolRev]: number[] = dailyResultFees.filter(([time]: any) => time === timestampToday)
+      .map(([_, data]: any) => data[mapChainId[chain]]).flat()
+
+    const dailyFees = partnerRev || 0 + protocolRev || 0;
+    const dailyRevenue = (protocolRev || 0);
+    const holdersRevenue = dailyRevenue * 0.8; // 80% staking rewards
+    const protocolRevenue = dailyRevenue * 0.2; // 20% protocol revenue
+
+    return {
+        dailyFees : dailyFees || 0,
+        dailyUserFees: dailyFees || 0,
+        dailyRevenue : dailyRevenue || 0,
+        dailyProtocolRevenue : protocolRevenue || 0,
+        dailyHoldersRevenue: holdersRevenue || 0,
+    }
+  }
 }
 
-export function getParaswapAdapter(type:"fees"|"volume"){
-const fetch = (chain: Chain) => {
-  return async (timestamp: number): Promise<FetchResultFees|FetchResultVolume> => {
-    if (chain == CHAIN.FANTOM && timestamp > 1744416000) return {} as FetchResultFees; // fantom delisted at 2025-04-12
+const fetchVolume = (chain: Chain) => {
+  return async (timestamp: number, _: any, options: FetchOptions): Promise<FetchResultVolume> => {
+    if (chain == CHAIN.FANTOM && timestamp > 1744416000) return {} as FetchResultVolume; // fantom delisted at 2025-04-12
     const timestampToday = getTimestampAtStartOfDayUTC(timestamp)
-    const response: IResponse = (await fetchCacheURL(feesMMURL));
+    const response: IResponse = options.preFetchedResults || [];
     const dailyResultFees: any[] = response.daily;
-    const [totalVolume,totalPartnerRevenue, totalProtocolRevenue]: number[] = response.allTime[mapChainId[chain]];
-    const [dailyVolume, partnerRevenue, protocolRevenue]: number[] = dailyResultFees.filter(([time]: any) => time === timestampToday)
+
+    const [dailyVolume, partnerRev, protocolRev]: number[] = dailyResultFees.filter(([time]: any) => time === timestampToday)
       .map(([_, data]: any) => data[mapChainId[chain]]).flat()
-    const otherFees = partnerRevenue || 0 + protocolRevenue || 0;
-    const otherProtocolReveune = protocolRevenue || 0;
 
-    const dailyFees = otherFees;
-    if (dailyFees > 1_000_000) {
-      return {} as FetchResultFees;
-    }
-    const dailyRevenue = otherProtocolReveune;
-    const totalFees = totalPartnerRevenue + totalProtocolRevenue;
-    const totalRevenue = totalProtocolRevenue;
-    if(type === "fees"){
-        return {
-            dailyFees : dailyFees || 0,
-            dailyRevenue : dailyRevenue || 0,
-            dailyProtocolRevenue : dailyRevenue || 0,
-            totalRevenue: totalRevenue,
-            totalFees: totalFees,
-            timestamp
-        }
-    } else {
-        return {
-            dailyVolume: dailyVolume || 0,
-            totalVolume: totalVolume,
-            timestamp
-        }
+    return {
+        dailyVolume: dailyVolume || 0
     }
   }
 }
 
-const adapter: Adapter = {
-  version : 1,
-  adapter: Object.keys(mapChainId).reduce((all, chain)=>({
-    ...all,
-    [chain]:{
-        fetch: fetch(chain),
+const createAdapter = (fetchFunction: (chain: Chain) => any): Adapter => ({
+  version: 1,
+  adapter: Object.fromEntries(
+    Object.keys(mapChainId).map(chain => [
+      chain,
+      {
+        fetch: fetchFunction(chain),
         start: '2022-03-22',
         meta: {
           methodology: {
-            Fees: "All trading fees paid by users.",
-            Revenue: "Trading fees are collected by Velora protocol.",
-            ProtocolRevenue: "Trading fees are collected by Velora protocol.",
+            Fees: "All trading fees paid by users",
+            Revenue: "Trading fees collected by Velora protocol", 
+            ProtocolRevenue: "20% of revenue to Velora protocol",
+            HoldersRevenue: "80% of revenue to stakers as part of PSP 2.0 staking rewards",
           }
         }
-    }
-  }), {} as any)
-}
+      }
+    ])
+  ),
+  prefetch,
+})
 
-return adapter
+export function getParaswapAdapter(type: "fees" | "volume"): Adapter {
+  return createAdapter(type === "fees" ? fetchFees : fetchVolume);
 }