Function startCleanup

server/src/middleware/pg-rate-limit-store.ts:17–29

()

// Periodic cleanup of expired rows (runs once, shared across all stores)
let cleanupStarted = false;
function startCleanup(): void {
  if (cleanupStarted) return;
  cleanupStarted = true;
  const timer = setInterval(async () => {
    if (!isDatabaseInitialized()) return;
    try {
      await query(`DELETE FROM rate_limit_hits WHERE reset_at <= NOW()`);
    } catch (err) {
      logger.warn({ err }, 'Failed to clean up expired rate limit hits');
    }
  }, 5 * 60 * 1000); // every 5 minutes
  timer.unref();
}

export class PostgresStore implements Store {
  private windowMs = 60_000;