Function deleteOrderedRowsByIds

apps/sim/lib/table/rows/ordering.ts:456–490

(params: {
  tableId: string
  workspaceId: string
  rowIds: string[]
})

 * and delete-by-filter).
 */
export async function deleteOrderedRowsByIds(params: {
  tableId: string
  workspaceId: string
  rowIds: string[]
}): Promise<{ id: string; position: number }[]> {
  const { tableId, workspaceId, rowIds } = params
  if (rowIds.length === 0) return []
  return db.transaction(async (trx) => {
    await setTableTxTimeouts(trx, { statementMs: 60_000 })
    const deleted: { id: string; position: number }[] = []
    for (let i = 0; i < rowIds.length; i += TABLE_LIMITS.DELETE_BATCH_SIZE) {
      const batch = rowIds.slice(i, i + TABLE_LIMITS.DELETE_BATCH_SIZE)
      const rows = await trx
        .delete(userTableRows)
        .where(
          and(
            eq(userTableRows.tableId, tableId),
            eq(userTableRows.workspaceId, workspaceId),
            inArray(userTableRows.id, batch)
          )
        )
        .returning({ id: userTableRows.id, position: userTableRows.position })
      deleted.push(...rows)
    }
    // Fractional ordering: deletes leave order_key untouched, so no recompaction.
    if (!(await isFeatureEnabled('tables-fractional-ordering')) && deleted.length > 0) {
      const minDeletedPos = deleted.reduce(
        (min, r) => (r.position < min ? r.position : min),
        deleted[0].position
      )
      await compactPositions(trx, tableId, minDeletedPos)
    }
    return deleted
  })
}

/**
 * Selects one page of row ids to delete for the async delete-job worker: base scope plus a