feat: merkle fallback

Author: essserrr

src/core/merkle/merklAPI.ts

@@ -1,4 +1,5 @@
 import type { Address } from "viem";
+import { cachedAxios } from "../axios";
 
 interface MerkleXYZChain {
   id: number;
@@ -128,10 +129,28 @@ export interface MerklXYZV4RewardCampaign {
 export type MerkleXYZV4RewardCampaignResponse = Array<MerklXYZV4RewardCampaign>;
 
 export class MerkleXYZApi {
-  static getOpportunitiesByAddressUrl = (a: Address) =>
-    `https://api.merkl.xyz/v4/opportunities?search=${a}`;
-  static getGearboxCampaignsUrl = () =>
-    "https://api.merkl.xyz/v4/opportunities?name=gearbox";
-  static getGearboxRewardCampaignUrl = (campaignId: Address) =>
-    `https://api.merkl.xyz/v4/campaigns?campaignId=${campaignId}`;
+  private constructor() {}
+
+  static defaultDomain = "https://api.merkl.xyz";
+  static angleDomain = "https://api-merkl.angle.money";
+
+  static getOpportunitiesByAddressUrl = (a: Address) => (domain: string) =>
+    `${domain}/v4/opportunities?search=${a}`;
+
+  static getGearboxCampaignsUrl =
+    () =>
+    (domain = MerkleXYZApi.defaultDomain) =>
+      `${domain}/v4/opportunities?name=gearbox`;
+
+  static getGearboxRewardCampaignUrl =
+    (campaignId: Address) => (domain: string) =>
+      `${domain}/v4/campaigns?campaignId=${campaignId}`;
+
+  static fetchWithFallback = async <T>(getUrl: (domain: string) => string) => {
+    try {
+      return await cachedAxios.get<T>(getUrl(MerkleXYZApi.defaultDomain));
+    } catch {
+      return await cachedAxios.get<T>(getUrl(MerkleXYZApi.angleDomain));
+    }
+  };
 }

src/pools/extraAPY/apy.ts

@@ -2,7 +2,6 @@ import type { AxiosResponse } from "axios";
 import moment from "moment";
 import type { Address } from "viem";
 
-import { cachedAxios } from "../../core/axios";
 import type {
   MerkleXYZV4CampaignsResponse,
   MerkleXYZV4RewardCampaignResponse,
@@ -23,9 +22,10 @@ const IDS_TO_OMIT = {
 
 export const getPoolExtraAPY: PoolExtraAPYHandler = async () => {
   // get all campaigns
-  const res = await cachedAxios.get<MerkleXYZV4CampaignsResponse>(
-    MerkleXYZApi.getGearboxCampaignsUrl(),
-  );
+  const res =
+    await MerkleXYZApi.fetchWithFallback<MerkleXYZV4CampaignsResponse>(
+      MerkleXYZApi.getGearboxCampaignsUrl(),
+    );
   // filter out not active
   const currentActiveCampaigns = res.data.filter(
     c => c.status === "LIVE" && !BROKEN_CAMPAIGNS[c.id],
@@ -43,11 +43,13 @@ export const getPoolExtraAPY: PoolExtraAPYHandler = async () => {
   );
 
   const aprIdsResponse: Array<
-    PromiseSettledResult<AxiosResponse<MerkleXYZV4RewardCampaignResponse, any>>
+    PromiseSettledResult<
+      AxiosResponse<MerkleXYZV4RewardCampaignResponse, unknown>
+    >
   > = [];
   for (const id of aprIdsList) {
     const resp = await Promise.allSettled([
-      cachedAxios.get<MerkleXYZV4RewardCampaignResponse>(
+      MerkleXYZApi.fetchWithFallback<MerkleXYZV4RewardCampaignResponse>(
         MerkleXYZApi.getGearboxRewardCampaignUrl(id.aprId),
       ),
     ]);

src/tokens/apy/merkle/apy.ts

@@ -2,7 +2,6 @@ import type { NetworkType } from "@gearbox-protocol/sdk";
 import { getChain } from "@gearbox-protocol/sdk";
 import type { CacheAxiosResponse } from "axios-cache-interceptor";
 import type { Address } from "viem";
-import { cachedAxios } from "../../../core/axios";
 import type { MerkleXYZV4CampaignsResponse } from "../../../core/merkle/merklAPI";
 import { MerkleXYZApi } from "../../../core/merkle/merklAPI";
 import type { PartialRecord } from "../../../core/utils";
@@ -33,7 +32,7 @@ const getAPYMerkle_withFilter = async (
   const [additionalAPYs, ...res] = await Promise.allSettled([
     getAdditionalAPYs(network, tokenEntries),
     ...tokenEntries.map(([, c]) =>
-      cachedAxios.get<MerkleXYZV4CampaignsResponse>(
+      MerkleXYZApi.fetchWithFallback<MerkleXYZV4CampaignsResponse>(
         MerkleXYZApi.getOpportunitiesByAddressUrl(c.id),
       ),
     ),