Merge pull request #1174 from mars-protocol/fallback-pyth-api

src/api/prices/getPythPrices.ts

@@ -8,11 +8,28 @@ import { BN } from 'utils/helpers'
 
 export default async function fetchPythPrices(priceFeedIds: string[], assets: Asset[]) {
   const pricesUrl = new URL(`${pythEndpoints.api}/latest_price_feeds`)
+  const fallbackUrl = new URL(`${pythEndpoints.fallbackApi}/latest_price_feeds`)
+
   try {
-    priceFeedIds.forEach((id) => pricesUrl.searchParams.append('ids[]', id))
+    priceFeedIds.forEach((id) => {
+      pricesUrl.searchParams.append('ids[]', id)
+      fallbackUrl.searchParams.append('ids[]', id)
+    })
 
     const pythResponse: PythPriceData[] = await cacheFn(
-      () => fetchWithTimeout(pricesUrl.toString(), FETCH_TIMEOUT).then((res) => res.json()),
+      async () => {
+        try {
+          return await fetchWithTimeout(pricesUrl.toString(), FETCH_TIMEOUT).then((res) =>
+            res.json(),
+          )
+        } catch (error) {
+          console.warn('Primary Pyth API failed, falling back to fallback API', error)
+
+          return await fetchWithTimeout(fallbackUrl.toString(), FETCH_TIMEOUT).then((res) =>
+            res.json(),
+          )
+        }
+      },
       pythPriceCache,
       `pythPrices/${priceFeedIds.flat().join('-')}`,
       30,

src/constants/pyth.ts

@@ -1,4 +1,5 @@
 export const pythEndpoints = {
   api: process.env.NEXT_PUBLIC_PYTH_API ?? 'https://hermes.pyth.network/api',
+  fallbackApi: 'https://hermes.pyth.network/api',
   candles: 'https://benchmarks.pyth.network/v1/shims/tradingview',
 }