Method cleanup

server/src/db/catalog-events-db.ts:163–188

* Delete events older than the retention window.

(retentionDays: number = RETENTION_DAYS_DEFAULT)

   * Delete events older than the retention window.
   */
  async cleanup(retentionDays: number = RETENTION_DAYS_DEFAULT): Promise<number> {
    const BATCH_SIZE = 5000;
    let totalDeleted = 0;
    let batchDeleted: number;

    // Delete in batches to avoid long-running transactions and dead-tuple bloat
    do {
      const result = await query(
        `DELETE FROM catalog_events
         WHERE event_id IN (
           SELECT event_id FROM catalog_events
           WHERE created_at < NOW() - INTERVAL '1 day' * $1
           ORDER BY event_id
           LIMIT $2
         )`,
        [retentionDays, BATCH_SIZE]
      );
      batchDeleted = result.rowCount ?? 0;
      totalDeleted += batchDeleted;
    } while (batchDeleted === BATCH_SIZE);

    if (totalDeleted > 0) {
      logger.info(`Cleaned up ${totalDeleted} catalog events older than ${retentionDays} days`);
    }
    return totalDeleted;
  }
}