79201820a9
Four separate postgres() clients were open simultaneously (app, timer, snapshots, socket), each defaulting to 10 connections, exhausting the database's max_connections limit. Replaced with a single shared lazy- initialized client in server/db.ts using a Proxy to defer the DATABASE_URL check until first use (preserving test compatibility). Also bumps the CS2 Champions Stage stochastic test from 200 → 1000 iterations to eliminate flakiness. https://claude.ai/code/session_019w21Nkf5TvTZHH6oVHaQXR
108 lines
3.2 KiB
TypeScript
108 lines
3.2 KiB
TypeScript
import * as schema from "~/database/schema";
|
|
import { eq, or } from "drizzle-orm";
|
|
import { createDailySnapshot } from "~/models/standings";
|
|
import { logger } from "./logger";
|
|
import { db } from "./db";
|
|
|
|
let snapshotInterval: NodeJS.Timeout | null = null;
|
|
const CHECK_INTERVAL = 24 * 60 * 60 * 1000; // Check once per day (in milliseconds)
|
|
|
|
/**
|
|
* Start the daily snapshot system
|
|
* Runs once per day to create snapshots for all active seasons
|
|
*/
|
|
export function startSnapshotSystem(): void {
|
|
if (snapshotInterval) {
|
|
logger.log("[Snapshots] Snapshot system already running");
|
|
return;
|
|
}
|
|
|
|
// Run immediately on startup
|
|
void createDailySnapshots();
|
|
|
|
// Then run once per day
|
|
snapshotInterval = setInterval(async () => {
|
|
try {
|
|
await createDailySnapshots();
|
|
} catch (error) {
|
|
logger.error("[Snapshots] Error creating daily snapshots:", error);
|
|
}
|
|
}, CHECK_INTERVAL);
|
|
|
|
logger.log("[Snapshots] Daily snapshot system started (runs once per day)");
|
|
}
|
|
|
|
/**
|
|
* Stop the snapshot system
|
|
*/
|
|
export function stopSnapshotSystem(): void {
|
|
if (snapshotInterval) {
|
|
clearInterval(snapshotInterval);
|
|
snapshotInterval = null;
|
|
logger.log("[Snapshots] Snapshot system stopped");
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Create daily snapshots for all active seasons
|
|
* Only creates snapshots if they don't already exist for today
|
|
*/
|
|
async function createDailySnapshots(): Promise<void> {
|
|
const now = new Date();
|
|
const today = `${now.getFullYear()}-${String(now.getMonth() + 1).padStart(2, "0")}-${String(now.getDate()).padStart(2, "0")}`;
|
|
|
|
logger.log(`[Snapshots] Checking for snapshots to create (${today})`);
|
|
|
|
// Get all seasons that are active or in draft (we want to track standings for these)
|
|
const activeSeasons = await db.query.seasons.findMany({
|
|
where: or(
|
|
eq(schema.seasons.status, "active"),
|
|
eq(schema.seasons.status, "draft")
|
|
),
|
|
});
|
|
|
|
if (activeSeasons.length === 0) {
|
|
logger.log("[Snapshots] No active seasons found");
|
|
return;
|
|
}
|
|
|
|
logger.log(`[Snapshots] Found ${activeSeasons.length} active season(s)`);
|
|
|
|
for (const season of activeSeasons) {
|
|
try {
|
|
await createDailySnapshot(season.id, db);
|
|
logger.log(`[Snapshots] ✅ Upserted snapshot for season ${season.id}`);
|
|
} catch (error) {
|
|
logger.error(`[Snapshots] Error creating snapshot for season ${season.id}:`, error);
|
|
}
|
|
}
|
|
|
|
logger.log("[Snapshots] Daily snapshot check complete");
|
|
}
|
|
|
|
/**
|
|
* Manually trigger snapshot creation for specific seasons
|
|
* Useful for admin tools or manual triggers
|
|
*/
|
|
export async function createSnapshotsForSeasons(seasonIds: string[]): Promise<void> {
|
|
logger.log(`[Snapshots] Manual trigger for ${seasonIds.length} season(s)`);
|
|
|
|
for (const seasonId of seasonIds) {
|
|
try {
|
|
await createDailySnapshot(seasonId, db);
|
|
logger.log(`[Snapshots] ✅ Created snapshot for season ${seasonId}`);
|
|
} catch (error) {
|
|
logger.error(`[Snapshots] Error creating snapshot for season ${seasonId}:`, error);
|
|
throw error;
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Manually trigger snapshot creation for all active seasons
|
|
* Useful for testing or manual refreshes
|
|
*/
|
|
export async function createSnapshotsForAllSeasons(): Promise<void> {
|
|
logger.log("[Snapshots] Manual trigger for all active seasons");
|
|
await createDailySnapshots();
|
|
}
|