fix zrx

dexs/0x/index.ts

@@ -1,5 +1,6 @@
 import { BreakdownAdapter, FetchV2, } from "../../adapters/types";
 import { CHAIN } from "../../helpers/chains";
+import { adapter_aggs } from './zrx/index'
 
 // https://0x.org/docs/introduction/0x-cheat-sheet
 const config = {
@@ -91,6 +92,7 @@ const adapter: BreakdownAdapter = {
     // "0x ERC1155": adaptersERC1155,
     // "0x ERC721": adaptersERC721,
     "0x Limit": adaptersERCLimit,
+    "zrx": adapter_aggs["adapter"]
   },
   version: 2
 }

aggregators/zrx/index.ts → dexs/0x/zrx/index.ts

@@ -1,6 +1,7 @@
 import { GraphQLClient, gql } from "graphql-request";
-import { getUniqStartOfTodayTimestamp } from "../../helpers/getUniSubgraphVolume";
-import { getEnv } from "../../helpers/env";
+import { getUniqStartOfTodayTimestamp } from "../../../helpers/getUniSubgraphVolume";
+import { getEnv } from "../../../helpers/env";
+import { FetchOptions } from "../../../adapters/types";
 
 const CHAINS = [
   "Arbitrum",
@@ -41,35 +42,43 @@ const getVolumeByChain = async (chain: string) => {
   return data;
 };
 
-const fetch = (chain: string) => async (timestamp: number) => {
+const fetch = async (options: FetchOptions) => {
   const unixTimestamp = getUniqStartOfTodayTimestamp(
-    new Date(timestamp * 1000)
+    new Date(options.endTimestamp * 1000)
   );
-
-  const data = await getVolumeByChain(chain);
-  const dayData = data.find(
-    ({ timestamp }: { timestamp: number }) =>
-      getUniqStartOfTodayTimestamp(new Date(timestamp)) === unixTimestamp
-  );
-
-  return {
-    dailyVolume: dayData.volumeUSD,
-    timestamp: unixTimestamp,
-  };
+  try {
+    const data = await getVolumeByChain(options.chain);
+    const dayData = data.find(
+      ({ timestamp }: { timestamp: number }) =>
+        getUniqStartOfTodayTimestamp(new Date(timestamp)) === unixTimestamp
+    );
+    return {
+      dailyVolume: dayData.volumeUSD,
+      timestamp: unixTimestamp,
+    };
+  } catch (e) {
+    console.error(e);
+    return {
+      dailyVolume: "0",
+      timestamp: unixTimestamp,
+    };
+  }
 };
 
-const adapter: any = {
+const adapter_aggs: any = {
+  version: 2,
   adapter: {
     ...Object.values(CHAINS).reduce((acc, chain) => {
       return {
         ...acc,
         [chain]: {
-          fetch: fetch(chain),
-          start: 1671062400,
+          fetch: fetch,
+          start: 0,
         },
       };
     }, {}),
   },
 };
-
-export default adapter;
+export {
+  adapter_aggs
+}