Merge pull request #2401 from moby-dev02/moby-bera

feat: add moby berachain integration

Author: dtmkeng

options/moby/index.ts

@@ -10,25 +10,30 @@ interface IMobyVolumeResponse {
 }
 
 // endTime is in ms
-export const mobyVolumeEndpoint = (endTime: number) => {
+export const arb_mobyVolumeEndpoint = (endTime: number) => {
   return `https://lambda-api.moby.trade/getVolumeData?end_time=${endTime}`;
 }
 
+export const bera_mobyVolumeEndpoint = (endTime: number) => {
+  return `https://lambda-bera-api.moby.trade/getVolumeData?end_time=${endTime}`;
+}
+
 export const moby_adapter: SimpleAdapter = {
   adapter: {
     [CHAIN.ARBITRUM]: {
-      fetch: fetchMobyVolumeData,
+      fetch: arb_fetchMobyVolumeData,
       start: '2024-04-03'
     },
+    [CHAIN.BERACHAIN]: {
+      fetch: bera_fetchMobyVolumeData,
+      start: '2025-02-08'
+    }
   },
 };
 
-export async function fetchMobyVolumeData(
-  /** Timestamp representing the end of the 24 hour period */
-  timestamp: number
-) {
+const _fetchMobyVolumeData = async (timestamp, endPoint) => {
   let timestamp_in_ms = timestamp * 1000
-  const mobyVolumeData = await getMobyVolumeData(mobyVolumeEndpoint(timestamp_in_ms));
+  const mobyVolumeData = await getMobyVolumeData(endPoint(timestamp_in_ms));
 
   const dailyNotionalVolume = Number(mobyVolumeData.daily_notional_volume).toFixed(2);
   const dailyPremiumVolume =  Number(mobyVolumeData.daily_premium_volume).toFixed(2);
@@ -44,6 +49,20 @@ export async function fetchMobyVolumeData(
   };
 }
 
+export async function arb_fetchMobyVolumeData(
+  /** Timestamp representing the end of the 24 hour period */
+  timestamp: number
+) {
+  return await _fetchMobyVolumeData(timestamp, arb_mobyVolumeEndpoint);
+}
+
+export async function bera_fetchMobyVolumeData(
+  /** Timestamp representing the end of the 24 hour period */
+  timestamp: number
+) {
+  return await _fetchMobyVolumeData(timestamp, bera_mobyVolumeEndpoint);
+}
+
 async function getMobyVolumeData(endpoint: string): Promise<IMobyVolumeResponse> {
   const results = await fetchURL(endpoint)