From e0945d4e326dfbafd9ab18fb19bed28fc785aed4 Mon Sep 17 00:00:00 2001
From: shutsuwei <shu.tsu.wei88@gmail.com>
Date: Wed, 12 Jul 2023 16:01:18 +0700
Subject: [PATCH 1/2] feat: add HMX trading vol

---
 dexs/hmx/index.ts | 98 +++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 98 insertions(+)
 create mode 100644 dexs/hmx/index.ts

diff --git a/dexs/hmx/index.ts b/dexs/hmx/index.ts
new file mode 100644
index 0000000000..c2fe5bce88
--- /dev/null
+++ b/dexs/hmx/index.ts
@@ -0,0 +1,98 @@
+import { Adapter } from "../../adapters/types";
+import { CHAIN } from "../../helpers/chains";
+import { request, gql } from "graphql-request";
+import type { ChainEndpoints } from "../../adapters/types";
+import { Chain } from "@defillama/sdk/build/general";
+import { HOUR, getTimestampAtStartOfHour } from "../../utils/date";
+
+const endpoints = {
+  [CHAIN.ARBITRUM]:
+    "https://subgraph.satsuma-prod.com/6350b8b3ceb3/92d146b1e22261b5990c85a8b277ed8804ce4906c5e095f5311b4e4ce8ce4bf8/arbitrum-one-stats/version/v.0.0.4/api",
+};
+
+type MarketStat = {
+  id: string;
+  totalTradingVolume: string;
+};
+
+const graphs = (graphUrls: ChainEndpoints) => {
+  return (chain: Chain) => {
+    return async (timestamp: number) => {
+      if (chain === CHAIN.ARBITRUM) {
+        // Get total trading volume
+        const totalTradingVolumeQuery = gql`
+          {
+            marketStats {
+              id
+              totalTradingVolume
+            }
+          }
+        `;
+        const totalMarketStats = (
+          await request(graphUrls[chain], totalTradingVolumeQuery)
+        ).marketStats as Array<MarketStat>;
+        const totalVolume =
+          totalMarketStats.reduce(
+            (accum: number, t: MarketStat) =>
+              accum + parseInt(t.totalTradingVolume),
+            0 as number
+          ) / 1e30;
+
+        // Get daily trading volume
+        const hourIndexes: Array<number> = [];
+        let latestHourIndex = Math.floor(
+          getTimestampAtStartOfHour(timestamp) / HOUR
+        );
+        for (let i = 0; i < 24; i++) {
+          hourIndexes.push(latestHourIndex - i);
+        }
+        let last24hrVolume: number = 0;
+        for (const marketStat of totalMarketStats) {
+          const filter = hourIndexes
+            .map((h) => `"${h}_${marketStat.id}"`)
+            .join(",");
+          const last24hrVolumeQuery = gql`
+            {
+              marketHourlyStats(where: {
+                id_in: [${filter}]
+              }) {
+                tradingVolume
+              }
+            }
+          `;
+          const last24hrMarketStats = (
+            await request(graphUrls[chain], last24hrVolumeQuery)
+          ).marketHourlyStats as Array<{ tradingVolume: string }>;
+          last24hrVolume +=
+            last24hrMarketStats.reduce(
+              (accum, t) => accum + parseInt(t.tradingVolume),
+              0 as number
+            ) / 1e30;
+        }
+
+        return {
+          timestamp,
+          totalVolume: totalVolume.toString(),
+          dailyVolume: last24hrVolume.toString(),
+        };
+      }
+
+      return {
+        timestamp,
+        totalVolume: "0",
+        dailyVolume: "0",
+      };
+    };
+  };
+};
+
+const adapter: Adapter = {
+  adapter: {
+    [CHAIN.ARBITRUM]: {
+      fetch: graphs(endpoints)(CHAIN.ARBITRUM),
+      start: async () => 1687806000,
+    },
+  },
+};
+
+export default adapter;

From e7b867ac3f86efcc35992c7e3e22503d979d0f35 Mon Sep 17 00:00:00 2001
From: shutsuwei <shu.tsu.wei88@gmail.com>
Date: Wed, 12 Jul 2023 16:52:37 +0700
Subject: [PATCH 2/2] chore: optimized for faster speed

---
 dexs/hmx/index.ts | 42 ++++++++++++++++++++++--------------------
 1 file changed, 22 insertions(+), 20 deletions(-)

diff --git a/dexs/hmx/index.ts b/dexs/hmx/index.ts
index c2fe5bce88..b99de5e49e 100644
--- a/dexs/hmx/index.ts
+++ b/dexs/hmx/index.ts
@@ -39,36 +39,38 @@ const graphs = (graphUrls: ChainEndpoints) => {
           ) / 1e30;
 
         // Get daily trading volume
-        const hourIndexes: Array<number> = [];
+        const ids: Array<string> = [];
         let latestHourIndex = Math.floor(
           getTimestampAtStartOfHour(timestamp) / HOUR
         );
         for (let i = 0; i < 24; i++) {
-          hourIndexes.push(latestHourIndex - i);
+          for (const marketStat of totalMarketStats) {
+            ids.push(`"${latestHourIndex - i}_${marketStat.id}"`);
+          }
         }
-        let last24hrVolume: number = 0;
-        for (const marketStat of totalMarketStats) {
-          const filter = hourIndexes
-            .map((h) => `"${h}_${marketStat.id}"`)
-            .join(",");
-          const last24hrVolumeQuery = gql`
+        const filter = ids.join(",");
+        // first 2400 should covers 100 markets last 24 hours
+        // which virtually covers all markets
+        const last24hrVolumeQuery = gql`
             {
-              marketHourlyStats(where: {
-                id_in: [${filter}]
-              }) {
+              marketHourlyStats(
+                first: 2400
+                where: {
+                  id_in: [${filter}]
+                }
+              ) {
                 tradingVolume
               }
             }
           `;
-          const last24hrMarketStats = (
-            await request(graphUrls[chain], last24hrVolumeQuery)
-          ).marketHourlyStats as Array<{ tradingVolume: string }>;
-          last24hrVolume +=
-            last24hrMarketStats.reduce(
-              (accum, t) => accum + parseInt(t.tradingVolume),
-              0 as number
-            ) / 1e30;
-        }
+        const last24hrMarketStats = (
+          await request(graphUrls[chain], last24hrVolumeQuery)
+        ).marketHourlyStats as Array<{ tradingVolume: string }>;
+        const last24hrVolume =
+          last24hrMarketStats.reduce(
+            (accum, t) => accum + parseInt(t.tradingVolume),
+            0 as number
+          ) / 1e30;
 
         return {
           timestamp,