diff --git a/scripts/capture-baseline-post.ts b/scripts/capture-baseline-post.ts new file mode 100644 index 0000000..9b08818 --- /dev/null +++ b/scripts/capture-baseline-post.ts @@ -0,0 +1,110 @@ +/** + * Post-Phase-1a Baseline Capture - diff-only helper + * + * Queries the renamed tables and writes post-rename JSON fixtures. After running, + * diff these against test-fixtures/baselines/*-pre-phase1.json to verify the + * rename did not change any data. DO NOT COMMIT THIS FILE OR ITS OUTPUT. + * + * Usage: + * npx dotenv -- tsx scripts/capture-baseline-post.ts + */ + +import { drizzle } from "drizzle-orm/postgres-js"; +import postgres from "postgres"; +import { sql } from "drizzle-orm"; +import { writeFileSync, mkdirSync } from "fs"; +import { join } from "path"; +import * as schema from "../database/schema.js"; + +const OUT_DIR = join(process.cwd(), "test-fixtures", "baselines"); + +async function main() { + const dbUrl = process.env.DATABASE_URL; + if (!dbUrl) { + console.error("ERROR: DATABASE_URL is required"); + process.exit(1); + } + + console.log("Connecting to database..."); + const client = postgres(dbUrl, { max: 1 }); + const db = drizzle(client, { schema }); + + mkdirSync(OUT_DIR, { recursive: true }); + console.log(`Output directory: ${OUT_DIR}\n`); + + // ─── 1. season_participant_qualifying_totals ────────────────────────────────── + + console.log("Capturing season_participant_qualifying_totals..."); + const qpTotals = await db.execute(sql` + SELECT pqt.*, ss.id as sports_season_id, ss.name as sports_season_name, s.name as sport_name + FROM season_participant_qualifying_totals pqt + JOIN sports_seasons ss ON ss.id = pqt.sports_season_id + JOIN sports s ON s.id = ss.sport_id + WHERE ss.scoring_pattern = 'qualifying_points' + ORDER BY ss.id, pqt.participant_id + `); + + writeFileSync( + join(OUT_DIR, "qp-totals-post-phase1a.json"), + JSON.stringify(qpTotals, null, 2) + ); + console.log(` Wrote ${qpTotals.length} rows → qp-totals-post-phase1a.json`); + + // ─── 2. event_results with qualifying_points_awarded ───────────────────────── + + console.log("Capturing event_results with qualifying_points_awarded..."); + const eventResults = await db.execute(sql` + SELECT er.*, se.sports_season_id, se.name as event_name + FROM event_results er + JOIN scoring_events se ON se.id = er.scoring_event_id + JOIN sports_seasons ss ON ss.id = se.sports_season_id + WHERE ss.scoring_pattern = 'qualifying_points' + AND er.qualifying_points_awarded IS NOT NULL + ORDER BY se.sports_season_id, er.scoring_event_id, er.season_participant_id + `); + + writeFileSync( + join(OUT_DIR, "event-results-post-phase1a.json"), + JSON.stringify(eventResults, null, 2) + ); + console.log(` Wrote ${eventResults.length} rows → event-results-post-phase1a.json`); + + // ─── 3. season_participant_surface_elos ────────────────────────────────────── + + console.log("Capturing season_participant_surface_elos..."); + const surfaceElos = await db.execute(sql` + SELECT pse.*, ss.sport_id, ss.name as sports_season_name, s.name as sport_name + FROM season_participant_surface_elos pse + JOIN sports_seasons ss ON ss.id = pse.sports_season_id + JOIN sports s ON s.id = ss.sport_id + WHERE ss.scoring_pattern = 'qualifying_points' + ORDER BY ss.id, pse.participant_id + `); + + writeFileSync( + join(OUT_DIR, "surface-elos-post-phase1a.json"), + JSON.stringify(surfaceElos, null, 2) + ); + console.log(` Wrote ${surfaceElos.length} rows → surface-elos-post-phase1a.json`); + + console.log(`\n✓ Post-rename capture complete!`); + console.log(` ${qpTotals.length} QP totals`); + console.log(` ${eventResults.length} event results`); + console.log(` ${surfaceElos.length} surface elo rows`); + console.log(`\nNow diff against the pre-phase1 fixtures:`); + console.log(` diff <(jq -S . test-fixtures/baselines/qp-totals-pre-phase1.json) \\`); + console.log(` <(jq -S . test-fixtures/baselines/qp-totals-post-phase1a.json)`); + console.log(` diff <(jq -S . test-fixtures/baselines/surface-elos-pre-phase1.json) \\`); + console.log(` <(jq -S . test-fixtures/baselines/surface-elos-post-phase1a.json)`); + console.log(` diff <(jq -S 'map(del(.participant_id))' test-fixtures/baselines/event-results-pre-phase1.json) \\`); + console.log(` <(jq -S 'map(del(.season_participant_id))' test-fixtures/baselines/event-results-post-phase1a.json)`); + + await client.end(); +} + +main() + .then(() => process.exit(0)) + .catch((e) => { + console.error("FATAL:", e); + process.exit(1); + });