Add support for unknown relayers (#327)

* Return unknown relayer from relayers endpoint

* Allow fetching of unknown relayer

* Allow fetching of fills for unknown relayers

* Allow fetching of unknown relayer metrics

Author: cbovis

src/fills/search-fills.js

@@ -46,6 +46,14 @@ const buildQuery = ({
     filters.push({ term: { relayerId } });
   }
 
+  if (_.isNull(relayerId)) {
+    exclusions.push({
+      exists: {
+        field: 'relayerId',
+      },
+    });
+  }
+
   if (_.isFinite(protocolVersion)) {
     filters.push({ term: { protocolVersion } });
   }

src/metrics/get-network-metrics.js

@@ -37,7 +37,8 @@ const getNetworkMetrics = async (
       $match: _.merge(
         { date: { $gte: dayFrom, $lte: dayTo } },
         ..._.compact([
-          _.isNumber(filter.relayerId) && { relayerId: filter.relayerId },
+          _.isNumber(filter.relayerId) ||
+            (_.isNull(filter.relayerId) && { relayerId: filter.relayerId }),
         ]),
       ),
     },

src/relayers/get-relayer-by-slug.js

@@ -1,6 +1,14 @@
 const Relayer = require('../model/relayer');
 
 const getRelayerBySlug = async slug => {
+  if (slug === 'unknown') {
+    return {
+      id: 'unknown',
+      name: 'Unknown',
+      slug: 'unknown',
+    };
+  }
+
   const relayer = await Relayer.findOne({ slug }).lean();
 
   return relayer;

src/relayers/get-relayer-lookup-id.js

@@ -7,6 +7,10 @@ const getRelayerLookupId = async relayerId => {
     return undefined;
   }
 
+  if (relayerId === 'unknown') {
+    return null;
+  }
+
   const relayers = await getRelayers();
   const relayer = relayers[relayerId];
 

src/relayers/get-relayers-with-24-hour-stats.js

@@ -25,7 +25,6 @@ const getRelayersWith24HourStats = async options => {
             .toDate(),
           $lte: dateTo,
         },
-        relayerId: { $ne: null },
       },
     },
     {
@@ -108,7 +107,11 @@ const getRelayersWith24HourStats = async options => {
   ]);
 
   return {
-    relayers: _.get(result, '[0].relayers', []),
+    relayers: _.get(result, '[0].relayers', []).map(relayer =>
+      relayer.id === undefined
+        ? { ...relayer, id: 'unknown', name: 'Unknown', slug: 'unknown' }
+        : relayer,
+    ),
     resultCount: _.get(result, '[0].totals[0].relayerCount', 0),
   };
 };

src/relayers/get-relayers-with-stats-for-dates.js

@@ -15,7 +15,6 @@ const getRelayersWithStatsForDates = async (dateFrom, dateTo, options) => {
           $gte: dateFrom,
           $lte: dateTo,
         },
-        relayerId: { $ne: null },
       },
     },
     {
@@ -79,7 +78,11 @@ const getRelayersWithStatsForDates = async (dateFrom, dateTo, options) => {
   ]);
 
   return {
-    relayers: _.get(result, '[0].relayers', []),
+    relayers: _.get(result, '[0].relayers', []).map(relayer =>
+      relayer.id === undefined
+        ? { ...relayer, id: 'unknown', name: 'Unknown', slug: 'unknown' }
+        : relayer,
+    ),
     resultCount: _.get(result, '[0].totals[0].relayerCount', 0),
   };
 };