Function run

apps/web/src/scripts/monitor-pg-activity.ts:72–104

()

}

async function run(): Promise<void> {
  console.log('🚀 Starting PostgreSQL activity monitor');
  console.log(`📍 Log directory: ${LOG_DIR}`);
  console.log(`⏱️  Interval: ${INTERVAL_MS / 1000} seconds`);
  console.log(`🔔 Alert threshold: ${ALERT_THRESHOLD} connections`);
  console.log(`🎵 Alert sound: ${SOUND_FILE}`);
  console.log('Press Ctrl+C to stop\n');

  await ensureLogDirectory();

  // Run immediately
  await monitorActivity();

  // Then run every 30 seconds
  const intervalId = setInterval(monitorActivity, INTERVAL_MS);

  // Handle graceful shutdown
  process.on('SIGINT', async () => {
    console.log('\n\n🛑 Received SIGINT, shutting down...');
    clearInterval(intervalId);
    await pool.end();
    console.log('✅ Connection pool closed');
    process.exit(0);
  });

  process.on('SIGTERM', async () => {
    console.log('\n\n🛑 Received SIGTERM, shutting down...');
    clearInterval(intervalId);
    await pool.end();
    console.log('✅ Connection pool closed');
    process.exit(0);
  });
}

run().catch(error => {
  console.error('❌ Fatal error:', error);