refactor

Author: juliangruber

stats/lib/platform-routes.js

@@ -6,9 +6,8 @@ import {
   fetchTopEarningParticipants,
   fetchParticipantsWithTopMeasurements,
   fetchDailyStationMeasurementCounts,
-  fetchParticipantsSummary
+  respondWithParticipantsSummary
 } from './platform-stats-fetchers.js'
-import { json } from 'http-responders'
 
 const createRespondWithFetchFn = (pathname, searchParams, res) => (pgPool, fetchFn) => {
   return getStatsWithFilterAndCaching(
@@ -39,9 +38,7 @@ export const handlePlatformRoutes = async (req, res, pgPools) => {
   } else if (req.method === 'GET' && url === '/participants/top-earning') {
     await respond(pgPools.stats, fetchTopEarningParticipants)
   } else if (req.method === 'GET' && url === '/participants/summary') {
-    const summary = await fetchParticipantsSummary(pgPools.evaluate)
-    res.setHeader('cache-control', `public, max-age=${24 * 3600 /* one day */}`)
-    json(res, summary)
+    await respondWithParticipantsSummary(res, pgPools.evaluate)
   } else if (req.method === 'GET' && url === '/transfers/daily') {
     await respond(pgPools.stats, fetchDailyRewardTransfers)
   } else {

stats/lib/platform-stats-fetchers.js

@@ -1,5 +1,6 @@
 import assert from 'http-assert'
 import { today, yesterday } from './request-helpers.js'
+import { json } from 'http-responders'
 
 /** @typedef {import('@filecoin-station/spark-stats-db').Queryable} Queryable */
 
@@ -116,3 +117,13 @@ export const fetchParticipantsSummary = async (pgPool) => {
     participant_count: Number(rows[0].count)
   }
 }
+
+/**
+ * @param {import('http').ServerResponse} res
+ * @param {Queryable} pgPool
+ */
+export const respondWithParticipantsSummary = async (res, pgPool) => {
+  const summary = await fetchParticipantsSummary(pgPool)
+  res.setHeader('cache-control', `public, max-age=${24 * 3600 /* one day */}`)
+  json(res, summary)
+}