Function deleteRowsById

apps/sim/lib/cleanup/batch-delete.ts:230–264

(
  tableDef: PgTable,
  idCol: PgColumn,
  ids: string[],
  tableName: string,
  chunkSize: number = DEFAULT_DELETE_CHUNK_SIZE
)

 * Partial progress survives chunk-level failures.
 */
export async function deleteRowsById(
  tableDef: PgTable,
  idCol: PgColumn,
  ids: string[],
  tableName: string,
  chunkSize: number = DEFAULT_DELETE_CHUNK_SIZE
): Promise<TableCleanupResult> {
  const result: TableCleanupResult = { table: tableName, deleted: 0, failed: 0 }
  if (ids.length === 0) return result

  const chunks = chunkArray(ids, chunkSize)
  for (const [chunkIdx, chunkIds] of chunks.entries()) {
    try {
      const deleted = await db
        .delete(tableDef)
        .where(inArray(idCol, chunkIds))
        .returning({ id: idCol })
      result.deleted += deleted.length
    } catch (error) {
      // Upper bound: Postgres rolls back the chunk on error, so actual deletes = 0,
      // but we can't tell which IDs in the chunk would have matched. The next cron
      // run picks up whatever's still expired, so this only inflates the metric.
      result.failed += chunkIds.length
      logger.error(
        `[${tableName}] Delete chunk ${chunkIdx + 1}/${chunks.length} failed (up to ${chunkIds.length} rows):`,
        { error }
      )
    }
  }

  logger.info(
    `[${tableName}] Deleted ${result.deleted} rows across ${chunks.length} chunk(s)${result.failed > 0 ? `, ${result.failed} failed` : ''}`
  )
  return result
}