Update sushiswap dex subgraph endpoints

Author: 0xtawa

dexVolumes/helper/chains.ts

@@ -13,6 +13,7 @@ const POLYGON = "polygon";
 const RONIN = "ronin";
 const XDAI = "xdai";
 const AURORA = "aurora";
+const MOONRIVER = "moonriver"
 
 export {
   ARBITRUM,
@@ -30,4 +31,5 @@ export {
   RONIN,
   XDAI,
   AURORA,
+  MOONRIVER
 };

dexVolumes/helper/getUniSubgraphVolume.ts

@@ -62,34 +62,34 @@ function getChainVolume({
   const totalVolumeQuery = gql`
   ${totalVolume.factory}(
     block: { number: $block }
-  ) {
-    ${totalVolume.field}
-  }
-  `;
-
-  const dailyVolumeQuery =
+    ) {
+      ${totalVolume.field}
+    }
+    `;
+    
+    const dailyVolumeQuery =
     customDailyVolume ||
     gql`
-  ${dailyVolume.factory} (
-    id: $id
-  ) {
-    ${dailyVolume.field}
-  }
-  `;
-  const graphQueryTotalVolume = gql`
+    ${dailyVolume.factory} (
+      id: $id
+      ) {
+        ${dailyVolume.field}
+      }
+      `;
+      const graphQueryTotalVolume = gql`
   ${hasTotalVolume ? `query get_total_volume($block: Int) { ${totalVolumeQuery} }` : ""}`
   const graphQueryDailyVolume = gql`
   ${hasDailyVolume ? `query get_daily_volume($id: Int) { ${dailyVolumeQuery} }` : ""}`;
-
+  
   return (chain: Chain) => {
     return async (timestamp: number, chainBlocks: ChainBlocks) => {
       const block =
         getCustomBlock ?
           await getCustomBlock(timestamp) :
           await getBlock(timestamp, chain, chainBlocks);
       const id = getUniswapDateId(new Date(timestamp * 1000));
-      const graphResTotal = await request(graphUrls[chain], graphQueryTotalVolume, { block }).catch(e => console.log(e));
-      const graphResDaily = await request(graphUrls[chain], graphQueryDailyVolume, { id }).catch(e => console.log(e));
+      const graphResTotal = await request(graphUrls[chain], graphQueryTotalVolume, { block }).catch(e => console.error(`Failed to get total volume${e.message}`));
+      const graphResDaily = await request(graphUrls[chain], graphQueryDailyVolume, { id }).catch(e => console.error(`Failed to get daily volume${e.message}`));
       return {
         timestamp,
         block,

dexVolumes/sushiswap/index.ts

@@ -11,43 +11,31 @@ import {
   HECO,
   POLYGON,
   XDAI,
+  MOONRIVER
 } from "../helper/chains";
 import { DexVolumeAdapter } from "../dexVolume.type";
 import { Chain } from "@defillama/sdk/build/general";
 
 const endpoints = {
-  [ARBITRUM]:
-    "https://api.thegraph.com/subgraphs/name/sushiswap/arbitrum-exchange",
-  [AVAX]:
-    "https://api.thegraph.com/subgraphs/name/sushiswap/avalanche-exchange",
-  [BSC]: "https://api.thegraph.com/subgraphs/name/sushiswap/bsc-exchange",
-  // [CELO]: "https://api.thegraph.com/subgraphs/name/sushiswap/celo-exchange",
   [ETHEREUM]: "https://api.thegraph.com/subgraphs/name/sushiswap/exchange",
+  [BSC]: "https://api.thegraph.com/subgraphs/name/sushiswap/bsc-exchange",
+  [POLYGON]: "https://api.thegraph.com/subgraphs/name/sushiswap/matic-exchange",
   [FANTOM]: "https://api.thegraph.com/subgraphs/name/sushiswap/fantom-exchange",
-  [HARMONY]:
-    "https://sushi.graph.t.hmny.io/subgraphs/name/sushiswap/harmony-exchange",
+  [ARBITRUM]: "https://api.thegraph.com/subgraphs/name/sushiswap/arbitrum-exchange",
+  [CELO]: "https://api.thegraph.com/subgraphs/name/sushiswap/celo-exchange",
+  [AVAX]: "https://api.thegraph.com/subgraphs/name/sushiswap/avalanche-exchange",
+  [HARMONY]: "https://sushi.graph.t.hmny.io/subgraphs/name/sushiswap/harmony-exchange",
+  [MOONRIVER]: "https://api.thegraph.com/subgraphs/name/sushiswap/moonriver-exchange",
+  [XDAI]: "https://api.thegraph.com/subgraphs/name/sushiswap/xdai-exchange",
   // [HECO]: "https://q.hg.network/subgraphs/name/heco-exchange/heco",
   //'okexchain': 'https://q.hg.network/subgraphs/name/okex-exchange/oec',
   //'okexchain': 'https://q.hg.network/subgraphs/name/sushiswap/okex-exchange',
-  [POLYGON]: "https://api.thegraph.com/subgraphs/name/sushiswap/matic-exchange",
-  [XDAI]: "https://api.thegraph.com/subgraphs/name/sushiswap/xdai-exchange",
 };
 
 const VOLUME_FIELD = "volumeUSD";
 
 const graphs = getChainVolume({
-  graphUrls: {
-    [ARBITRUM]: endpoints[ARBITRUM],
-    [AVAX]: endpoints[AVAX],
-    [BSC]: endpoints[BSC],
-    // [CELO]: endpoints[CELO],
-    [ETHEREUM]: endpoints[ETHEREUM],
-    [FANTOM]: endpoints[FANTOM],
-    [HARMONY]: endpoints[HARMONY],
-    // [HECO]: endpoints[HECO],
-    [POLYGON]: endpoints[POLYGON],
-    [XDAI]: endpoints[XDAI],
-  },
+  graphUrls: endpoints,
   totalVolume: {
     factory: "factories",
     field: VOLUME_FIELD,