Add GET /participants/summary

README.md

@@ -52,6 +52,10 @@ Base URL: http://stats.filspark.com/
 
   http://stats.filspark.com/participants/top-measurements?from=yesterday&to=yesterday
 
+- `GET /participants/summary`
+
+  http://stats.filspark.com/participants/summary
+
 - `GET /participant/:address/scheduled-rewards?address=<address>&from=<day>&to=<day>`
 
   http://stats.filspark.com/participant/0x000000000000000000000000000000000000dEaD/scheduled-rewards

stats/lib/platform-routes.js

@@ -5,7 +5,8 @@ import {
   fetchDailyRewardTransfers,
   fetchTopEarningParticipants,
   fetchParticipantsWithTopMeasurements,
-  fetchDailyStationMeasurementCounts
+  fetchDailyStationMeasurementCounts,
+  respondWithParticipantsSummary
 } from './platform-stats-fetchers.js'
 
 const createRespondWithFetchFn = (pathname, searchParams, res) => (pgPool, fetchFn) => {
@@ -36,6 +37,8 @@ export const handlePlatformRoutes = async (req, res, pgPools) => {
     await respond(pgPools.evaluate, fetchParticipantsWithTopMeasurements)
   } else if (req.method === 'GET' && url === '/participants/top-earning') {
     await respond(pgPools.stats, fetchTopEarningParticipants)
+  } else if (req.method === 'GET' && url === '/participants/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 */
 
@@ -104,3 +105,25 @@ export const fetchTopEarningParticipants = async (pgPool, filter) => {
   `, [filter.from, filter.to])
   return rows
 }
+
+/**
+ * @param {Queryable} pgPool
+ */
+export const fetchParticipantsSummary = async (pgPool) => {
+  const { rows } = await pgPool.query(`
+    SELECT COUNT(DISTINCT participant_id) FROM daily_participants
+  `)
+  return {
+    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)
+}

stats/test/platform-routes.test.js

@@ -7,6 +7,7 @@ import { getPgPools } from '@filecoin-station/spark-stats-db'
 import { assertResponseStatus, getPort } from './test-helpers.js'
 import { createHandler } from '../lib/handler.js'
 import { getLocalDayAsISOString, today, yesterday } from '../lib/request-helpers.js'
+import { givenDailyParticipants } from '@filecoin-station/spark-stats-db/test-helpers.js'
 
 const debug = createDebug('test')
 
@@ -338,6 +339,29 @@ describe('Platform Routes HTTP request handler', () => {
       await assertResponseStatus(res, 400)
     })
   })
+
+  describe('GET /participants/summary', () => {
+    it('counts participants', async () => {
+      await givenDailyParticipants(
+        pgPools.evaluate,
+        '2000-01-01',
+        ['0x1', '0x2', '0x3']
+      )
+
+      const res = await fetch(
+        new URL('/participants/summary', baseUrl), {
+          redirect: 'manual'
+        }
+      )
+      await assertResponseStatus(res, 200)
+      const summary = await res.json()
+      assert.deepStrictEqual(summary, { participant_count: 3 })
+      assert.strictEqual(
+        res.headers.get('cache-control'),
+        'public, max-age=86400'
+      )
+    })
+  })
 })
 
 const givenDailyMeasurementsSummary = async (pgPoolEvaluate, summaryData) => {