track kura fees & volume

Author: g1nt0ki

dexs/kura-v2.ts

@@ -0,0 +1,27 @@
+/* import { uniV2Exports } from "../helpers/uniswap";
+
+export default uniV2Exports({ 
+  sei: {
+    factory: '0xAEbdA18889D6412E237e465cA25F5F346672A2eC',
+  }
+}) */
+
+import { univ2Adapter2 } from "../helpers/getUniSubgraphVolume";
+import { CHAIN } from "../helpers/chains";
+import { SimpleAdapter } from "../adapters/types";
+
+const fetch = univ2Adapter2({
+  endpoints: {
+    [CHAIN.SEI]: "https://api.goldsky.com/api/public/project_cm9ghm7cnxuaa01x5g6pfchp7/subgraphs/sei/2/gn"
+  },
+  factoriesName: 'legacyFactories',
+  totalFeesField: 'totalFeeUSD'
+})
+
+const adapter: SimpleAdapter = {
+  version: 2,
+  fetch,
+  chains: [CHAIN.SEI],
+}
+
+export default adapter

dexs/kura-v3.ts

@@ -0,0 +1,28 @@
+// import { uniV3Exports } from "../helpers/uniswap";
+
+// export default uniV3Exports({ 
+//   sei: {
+//     factory: '0xd0c54c480fD00DDa4DF1BbE041A6881f2F09111e',
+//   }
+// })
+
+
+import { univ2Adapter2 } from "../helpers/getUniSubgraphVolume";
+import { CHAIN } from "../helpers/chains";
+import { SimpleAdapter } from "../adapters/types";
+
+const fetch = univ2Adapter2({
+  endpoints: {
+    [CHAIN.SEI]: "https://api.goldsky.com/api/public/project_cm9ghm7cnxuaa01x5g6pfchp7/subgraphs/sei/2/gn"
+  },
+  factoriesName: 'clFactories',
+  totalFeesField: 'totalFeesUSD'
+})
+
+const adapter: SimpleAdapter = {
+  version: 2,
+  fetch,
+  chains: [CHAIN.SEI],
+}
+
+export default adapter

helpers/getUniSubgraphVolume.ts

@@ -41,13 +41,14 @@ interface IGetChainVolumeParams {
   totalVolume: {
     factory: string,
     field: string,
-    filterParams?: IGetChainVolumeFilterParams[], 
+    filterParams?: IGetChainVolumeFilterParams[],
   },
   dailyVolume?: {
     factory: string,
     field: string,
     dateField?: string,
   },
+  totalFeesField?: string,
   customDailyVolume?: string,
   hasDailyVolume?: boolean
   hasTotalVolume?: boolean
@@ -117,7 +118,7 @@ function getChainVolume({
           switch (item.name) {
             case "id":
               graphQueryTodayTotalVolumeVariables["id"] = id;
-              graphQueryYesterdayTotalVolumeVariables["id"] = id-1
+              graphQueryYesterdayTotalVolumeVariables["id"] = id - 1
             default:
           }
         });
@@ -131,7 +132,7 @@ function getChainVolume({
       if (hasDailyVolume && !dailyVolumeValue) {
         graphResDaily = await request(graphUrls[chain], alternativeDaily(getUniqStartOfTodayTimestamp(new Date(endTimestamp * 1000))));
         const factory = dailyVolume.factory.toLowerCase().charAt(dailyVolume.factory.length - 1) === 's' ? dailyVolume.factory : `${dailyVolume.factory}s`
-        dailyVolumeValue = graphResDaily ? graphResDaily[`${factory }`].reduce((p: any, c: any) => p + Number(c[`${dailyVolume.field}`]), 0) : undefined;
+        dailyVolumeValue = graphResDaily ? graphResDaily[`${factory}`].reduce((p: any, c: any) => p + Number(c[`${dailyVolume.field}`]), 0) : undefined;
       }
       if (!hasDailyVolume) {
         const fromBlock = await getFromBlock()
@@ -160,6 +161,7 @@ function getChainVolume2({
     factory: DEFAULT_TOTAL_VOLUME_FACTORY,
     field: DEFAULT_TOTAL_VOLUME_FIELD,
   },
+  totalFeesField,
   hasTotalVolume = true,
   getCustomBlock = undefined,
 }: IGetChainVolumeParams) {
@@ -168,6 +170,7 @@ function getChainVolume2({
     block: { number: $block }
     ) {
       ${totalVolume.field}
+      ${totalFeesField ? totalFeesField : ''}
     }
     `;
 
@@ -178,19 +181,24 @@ function getChainVolume2({
       const { endTimestamp, startTimestamp, getEndBlock, getStartBlock } = options;
 
       const endBlock = (await (getCustomBlock ? getCustomBlock(endTimestamp) : getEndBlock())) ?? undefined;
-      const startBlock = (await (getCustomBlock ? getCustomBlock(startTimestamp) :getStartBlock())) ?? undefined;
+      const startBlock = (await (getCustomBlock ? getCustomBlock(startTimestamp) : getStartBlock())) ?? undefined;
 
-      const graphResTotal = hasTotalVolume ? await request(graphUrls[chain], graphQueryTotalVolume, { block: endBlock }): undefined;
+      const graphResTotal = hasTotalVolume ? await request(graphUrls[chain], graphQueryTotalVolume, { block: endBlock }) : undefined;
       const total = graphResTotal ? graphResTotal[totalVolume.factory]?.reduce((total: number, factory: any) => total + Number(factory[totalVolume.field]), 0) : undefined;
+      const totalFees = totalFeesField && graphResTotal ? graphResTotal[totalVolume.factory]?.reduce((total: number, factory: any) => total + Number(factory[totalFeesField]), 0) : undefined;
 
       const graphResPrevTotal = hasTotalVolume ? await request(graphUrls[chain], graphQueryTotalVolume, { block: startBlock }) : undefined;
       const prevTotal = graphResPrevTotal ? graphResPrevTotal[totalVolume.factory]?.reduce((total: number, factory: any) => total + Number(factory[totalVolume.field]), 0) : undefined;
+      const prevTotalFees = totalFeesField && graphResPrevTotal ? graphResPrevTotal[totalVolume.factory]?.reduce((total: number, factory: any) => total + Number(factory[totalFeesField]), 0) : undefined;
 
       let dailyVolumeValue = total - prevTotal
 
-      return {
+      const response: any = {
         dailyVolume: dailyVolumeValue,
-      };
+      }
+      if (totalFeesField)
+        response.dailyFees = totalFees - prevTotalFees
+      return response
     };
   };
 }
@@ -211,8 +219,8 @@ function getChainVolumeWithGasToken({
   hasTotalVolume = true,
   getCustomBlock = undefined,
   priceToken,
-}: IGetChainVolumeParams & {priceToken:string}) {
-  const basic = getChainVolume({graphUrls, totalVolume, dailyVolume, customDailyVolume, hasDailyVolume, hasTotalVolume, getCustomBlock})
+}: IGetChainVolumeParams & { priceToken: string }) {
+  const basic = getChainVolume({ graphUrls, totalVolume, dailyVolume, customDailyVolume, hasDailyVolume, hasTotalVolume, getCustomBlock })
   return (chain: Chain) => {
     return async (_a: any, _b: any, options: FetchOptions) => {
       const {
@@ -236,39 +244,46 @@ function getChainVolumeWithGasToken2({
     factory: DEFAULT_TOTAL_VOLUME_FACTORY,
     field: 'totalVolumeETH',
   },
+  totalFeesField,
   getCustomBlock = undefined,
   priceToken,
-}: IGetChainVolumeParams & {priceToken:string}) {
-  const basic = getChainVolume2({graphUrls, totalVolume, getCustomBlock})
+}: IGetChainVolumeParams & { priceToken: string }) {
+  const basic = getChainVolume2({ graphUrls, totalVolume, totalFeesField, getCustomBlock })
   return (chain: Chain) => {
     return async (options: FetchOptions): Promise<FetchResultV2> => {
       const {
         dailyVolume,
+        dailyFees,
       } = await basic(chain)(options);
 
-      const timestamp = options.endTimestamp
-      const balances = new Balances({ chain, timestamp })
+      const balances = options.createBalances()
       balances.add(priceToken, Number(dailyVolume).toFixed(0), { skipChain: true })
+      let dailyFeesObj = options.createBalances()
+      if (totalFeesField)
+        dailyFeesObj.add(priceToken, Number(dailyFees).toFixed(0), { skipChain: true })
 
-      return {
-        dailyVolume: await balances.getUSDString(),
+      const response: any = {
+        dailyVolume: balances,
       }
+      if (totalFeesField)
+        response.dailyFees = dailyFeesObj
+      return response
     };
   };
 }
 
 function univ2Adapter({
-  endpoints = {} as {[chain: string]: string},
+  endpoints = {} as { [chain: string]: string },
   factoriesName = DEFAULT_TOTAL_VOLUME_FACTORY,
   dayData = DEFAULT_DAILY_VOLUME_FACTORY,
   totalVolume = DEFAULT_TOTAL_VOLUME_FIELD,
   totalVolumeFilterParams = undefined as IGetChainVolumeFilterParams[] | undefined,
   dailyVolume = DEFAULT_DAILY_VOLUME_FIELD,
   dailyVolumeTimestampField = DEFAULT_DATE_FIELD,
   hasTotalVolume = true,
-  hasDailyVolume = undefined as boolean|undefined,
-  gasToken = null as string|null
-}){
+  hasDailyVolume = undefined as boolean | undefined,
+  gasToken = null as string | null
+}) {
   const graphs = (gasToken === null ? getChainVolume : getChainVolumeWithGasToken as typeof getChainVolume)({
     graphUrls: endpoints,
     hasTotalVolume,
@@ -285,23 +300,25 @@ function univ2Adapter({
     hasDailyVolume,
     priceToken: gasToken
   } as any);
-  return async (_a:any, _b:any, options: FetchOptions) => {
+  return async (_a: any, _b: any, options: FetchOptions) => {
     return graphs(options.chain)(_a, _b, options)
   }
 }
 
 function univ2Adapter2({
-  endpoints = {} as {[chain: string]: string},
+  endpoints = {} as { [chain: string]: string },
   factoriesName = DEFAULT_TOTAL_VOLUME_FACTORY,
   totalVolume = DEFAULT_TOTAL_VOLUME_FIELD,
-  gasToken = null as string|null,
-}){
+  totalFeesField = null as string | null,
+  gasToken = null as string | null,
+}) {
   const graphs = (gasToken === null ? getChainVolume2 : getChainVolumeWithGasToken2 as typeof getChainVolume2)({
     graphUrls: endpoints,
     totalVolume: {
       factory: factoriesName,
       field: totalVolume
     },
+    totalFeesField,
     priceToken: gasToken
   } as any);
   return async (options: FetchOptions) => {