clean up

.github/workflows/ci.yml

@@ -33,7 +33,6 @@ jobs:
         with:
           node-version: 20
       - run: npm ci
-      - run: npm run migrate
       - run: npm test
 
   build-observer:
@@ -63,7 +62,6 @@ jobs:
         with:
           node-version: 20
       - run: npm ci
-      - run: npm run migrate
       - run: npm test
 
   lint-all:

README.md

@@ -75,12 +75,6 @@ Next, you need to create `spark_evaluate` database.
 psql postgres://localhost:5432/ -c "CREATE DATABASE spark_evaluate"
 ```
 
-Finally, run database schema migration scripts.
-
-```bash
-npm run migrate
-```
-
 ### Run the test suite
 
 ```sh

common/db.js

@@ -1,5 +1,6 @@
-import { migrateWithPgClient } from '@filecoin-station/spark-stats-db-migrations'
 import pg from 'pg'
+import { migrateWithPgClient as migrateEvaluateDB } from 'spark-evaluate/lib/migrate.js'
+import { migrateWithPgClient as migrateStatsDB } from '@filecoin-station/spark-stats-db-migrations'
 
 const {
 // DATABASE_URL points to `spark_stats` database managed by this monorepo
@@ -37,7 +38,7 @@ export const getStats = async () => {
     connectionString: DATABASE_URL
   })
   stats.on('error', onError)
-  await migrateWithPgClient(stats)
+  await migrateStatsDB(stats)
   return stats
 }
 
@@ -47,9 +48,7 @@ export const getEvaluate = async () => {
     connectionString: EVALUATE_DB_URL
   })
   evaluate.on('error', onError)
-
-  // Check that we can talk to the database
-  await evaluate.query('SELECT 1')
+  await migrateEvaluateDB(evaluate)
   return evaluate
 }
 
@@ -63,3 +62,15 @@ 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()
+}

observer/package.json

@@ -3,7 +3,6 @@
   "type": "module",
   "private": true,
   "scripts": {
-    "migrate": "node bin/migrate.js",
     "start": "node bin/spark-observer.js",
     "lint": "standard",
     "test": "mocha"

package.json

@@ -8,7 +8,6 @@
     "stats"
   ],
   "scripts": {
-    "migrate": "npm run migrate --workspaces --if-present",
     "lint": "standard",
     "test:observer": "npm t -w observer",
     "test:stats": "npm t -w stats",

stats/package.json

@@ -3,7 +3,6 @@
   "type": "module",
   "private": true,
   "scripts": {
-    "migrate": "node bin/migrate.js",
     "start": "node bin/spark-stats.js",
     "lint": "standard",
     "test": "mocha"