Add daily scheduled rewards

README.md

@@ -24,7 +24,7 @@ Base URL: http://stats.filspark.com/
 
 - `GET /participants/scheduled-rewards/?address=<address>&from=<day>&to=<day>`
 
-  http://stats.filspark.com/participants/scheduled-rewards/
+  http://stats.filspark.com/participants/scheduled-rewards
 
 - `GET /miners/retrieval-success-rate/summary?from=<day>&to=<day>`
 

db/index.js

@@ -5,6 +5,8 @@ import { dirname, join } from 'node:path'
 import { fileURLToPath } from 'node:url'
 import Postgrator from 'postgrator'
 
+export { migrateEvaluateDB, migrateStatsDB }
+
 const {
   // DATABASE_URL points to `spark_stats` database managed by this monorepo
   DATABASE_URL = 'postgres://localhost:5432/spark_stats',
@@ -71,17 +73,6 @@ export const getPgPools = async () => {
   return { stats, evaluate, end }
 }
 
-export const migrate = async () => {
-  const pgPools = await getPgPools()
-
-  console.log('Migrating spark_evaluate database')
-  await migrateEvaluateDB(pgPools.evaluate)
-  console.log('Migrating spark_stats database')
-  await migrateStatsDB(pgPools.stats)
-
-  await pgPools.end()
-}
-
 /**
  * @param {pg.Client} client
  */

observer/bin/dry-run.js

@@ -3,7 +3,7 @@ import { ethers } from 'ethers'
 
 import { RPC_URL, rpcHeaders } from '../lib/config.js'
 import { observeTransferEvents, observeScheduledRewards } from '../lib/observer.js'
-import { getPgPools } from '../../db-clients/index.js'
+import { getPgPools } from '@filecoin-station/spark-stats-db'
 
 const pgPools = await getPgPools()
 

observer/bin/migrate.js

@@ -1,3 +1,5 @@
-import { migrate } from '@filecoin-station/spark-stats-db'
+import { migrateStatsDB, migrateEvaluateDB, getPgPools } from '@filecoin-station/spark-stats-db'
 
-await migrate()
+const pgPools = await getPgPools()
+await migrateStatsDB(pgPools.stats)
+await migrateEvaluateDB(pgPools.evaluate)

stats/bin/migrate.js

@@ -1,3 +1,5 @@
-import { migrate } from '@filecoin-station/spark-stats-db'
+import { migrateStatsDB, migrateEvaluateDB, getPgPools } from '@filecoin-station/spark-stats-db'
 
-await migrate()
+const pgPools = await getPgPools()
+await migrateStatsDB(pgPools.stats)
+await migrateEvaluateDB(pgPools.evaluate)