Add endpoints for active relayers and traded tokens

Author: cbovis

src/app/routes/v1/metrics.js

@@ -3,6 +3,8 @@ const Router = require('koa-router');
 
 const { TIME_PERIOD } = require('../../../constants');
 const checkTraderExists = require('../../../traders/check-trader-exists');
+const getActiveRelayerMetrics = require('../../../metrics/get-active-relayer-metrics');
+const getTradedTokenMetrics = require('../../../metrics/get-traded-token-metrics');
 const getActiveTraderMetrics = require('../../../metrics/get-active-trader-metrics');
 const getAssetBridgeMetrics = require('../../../metrics/get-asset-bridge-metrics');
 const getAssetBridgingMetrics = require('../../../asset-bridges/get-asset-bridging-metrics');
@@ -237,6 +239,40 @@ const createRouter = () => {
     },
   );
 
+  router.get(
+    '/active-relayer',
+    middleware.timePeriod('period', TIME_PERIOD.MONTH),
+    middleware.metricGranularity({
+      period: 'period',
+      granularity: 'granularity',
+    }),
+    async ({ params, response }, next) => {
+      const { granularity, period } = params;
+      const metrics = await getActiveRelayerMetrics(period, granularity);
+
+      response.body = metrics;
+
+      await next();
+    },
+  );
+
+  router.get(
+    '/traded-token',
+    middleware.timePeriod('period', TIME_PERIOD.MONTH),
+    middleware.metricGranularity({
+      period: 'period',
+      granularity: 'granularity',
+    }),
+    async ({ params, response }, next) => {
+      const { granularity, period } = params;
+      const metrics = await getTradedTokenMetrics(period, granularity);
+
+      response.body = metrics;
+
+      await next();
+    },
+  );
+
   return router;
 };
 

src/metrics/get-active-relayer-metrics.js

@@ -0,0 +1,54 @@
+const elasticsearch = require('../util/elasticsearch');
+const getDatesForMetrics = require('../util/get-dates-for-metrics');
+
+const getActiveRelayerMetrics = async (period, granularity) => {
+  const { dateFrom, dateTo } = getDatesForMetrics(period, granularity);
+
+  const results = await elasticsearch.getClient().search({
+    body: {
+      query: {
+        bool: {
+          filter: [
+            {
+              range: {
+                date: {
+                  gte: dateFrom,
+                  lte: dateTo,
+                },
+              },
+            },
+            { exists: { field: 'relayerId' } },
+          ],
+        },
+      },
+      aggs: {
+        metrics_by_date: {
+          date_histogram: {
+            field: 'date',
+            calendar_interval: granularity,
+            extended_bounds: {
+              min: dateFrom,
+              max: dateTo,
+            },
+          },
+          aggs: {
+            relayerCount: {
+              cardinality: {
+                field: 'relayerId',
+              },
+            },
+          },
+        },
+      },
+    },
+    index: 'fills',
+    size: 0,
+  });
+
+  return results.body.aggregations.metrics_by_date.buckets.map(x => ({
+    activeRelayers: x.relayerCount.value,
+    date: new Date(x.key_as_string),
+  }));
+};
+
+module.exports = getActiveRelayerMetrics;

src/metrics/get-traded-token-metrics.js

@@ -0,0 +1,47 @@
+const elasticsearch = require('../util/elasticsearch');
+const getDatesForMetrics = require('../util/get-dates-for-metrics');
+
+const getTradedTokenMetrics = async (period, granularity) => {
+  const { dateFrom, dateTo } = getDatesForMetrics(period, granularity);
+
+  const results = await elasticsearch.getClient().search({
+    body: {
+      query: {
+        range: {
+          date: {
+            gte: dateFrom,
+            lte: dateTo,
+          },
+        },
+      },
+      aggs: {
+        metrics_by_date: {
+          date_histogram: {
+            field: 'date',
+            calendar_interval: granularity,
+            extended_bounds: {
+              min: dateFrom,
+              max: dateTo,
+            },
+          },
+          aggs: {
+            tokenCount: {
+              cardinality: {
+                field: 'assets.tokenAddress',
+              },
+            },
+          },
+        },
+      },
+    },
+    index: 'fills',
+    size: 0,
+  });
+
+  return results.body.aggregations.metrics_by_date.buckets.map(x => ({
+    date: new Date(x.key_as_string),
+    tradedTokens: x.tokenCount.value,
+  }));
+};
+
+module.exports = getTradedTokenMetrics;