Function monitorActivity

apps/web/src/scripts/monitor-pg-activity.ts:33–70

()

let iter = 0;

async function monitorActivity(): Promise<void> {
  try {
    iter++;
    const result = await pool.query('SELECT * FROM pg_stat_activity');
    const rows = result.rows;
    const rowCount = rows.length;
    if (rowCount < ALERT_THRESHOLD && iter % 12 !== 0) {
      return;
    }
    // Create filename with ISO timestamp (path-safe) and row count
    const isoTimestamp = new Date().toISOString().replace(/:/g, '-');
    const filename = `log_${isoTimestamp}__${rowCount}.json`;
    const filepath = path.join(LOG_DIR, filename);

    // Write to file (with BigInt serialization support)
    await writeFile(
      filepath,
      JSON.stringify(
        rows,
        (_, value: unknown) => (typeof value === 'bigint' ? value.toString() : value),
        2
      )
    );

    const now = new Date().toISOString();
    console.log(`[${now}] 📊 Logged ${rowCount} active connections to ${filename}`);

    // Play alert if threshold exceeded
    if (rowCount >= ALERT_THRESHOLD) {
      console.log(
        `⚠️  WARNING: Connection count (${rowCount}) reached threshold (${ALERT_THRESHOLD})`
      );
      await playAlertSound();
    }
  } catch (error) {
    console.error('❌ Error monitoring pg_stat_activity:', error);
  }
}

async function run(): Promise<void> {
  console.log('🚀 Starting PostgreSQL activity monitor');