Function insertOrderedRow

apps/sim/lib/table/rows/ordering.ts:339–416

(params: {
  tableId: string
  workspaceId: string
  data: RowData
  rowId: string
  position?: number
  afterRowId?: string
  beforeRowId?: string
  createdBy?: string
  now: Date
})

 * `increment_user_table_row_count` trigger.
 */
export async function insertOrderedRow(params: {
  tableId: string
  workspaceId: string
  data: RowData
  rowId: string
  position?: number
  afterRowId?: string
  beforeRowId?: string
  createdBy?: string
  now: Date
}): Promise<{
  id: string
  data: RowData
  position: number
  orderKey: string | null
  createdAt: Date
  updatedAt: Date
}> {
  const { tableId, workspaceId, data, rowId, position, afterRowId, beforeRowId, createdBy, now } =
    params
  const [row] = await db.transaction(async (trx) => {
    await setTableTxTimeouts(trx)
    await acquireRowOrderLock(trx, tableId)

    const fractionalOrdering = await isFeatureEnabled('tables-fractional-ordering')

    // Resolve the order key (and a legacy slot position for the flag-off shift
    // path) from neighbor ids when given, else from the requested position.
    let orderKey: string
    let slotPosition = position
    if (afterRowId || beforeRowId) {
      const resolved = await resolveInsertByNeighbor(trx, tableId, afterRowId, beforeRowId)
      orderKey = resolved.orderKey
      slotPosition = resolved.position
    } else {
      orderKey = await resolveInsertOrderKey(trx, tableId, position)
    }

    let targetPosition: number
    if (fractionalOrdering) {
      // order_key is authoritative — keep a best-effort, no-shift position.
      targetPosition = await nextRowPosition(trx, tableId)
    } else if (slotPosition !== undefined) {
      const [existing] = await trx
        .select({ id: userTableRows.id })
        .from(userTableRows)
        .where(and(eq(userTableRows.tableId, tableId), eq(userTableRows.position, slotPosition)))
        .limit(1)
      if (existing) await shiftRowsUpFrom(trx, tableId, slotPosition)
      targetPosition = slotPosition
    } else {
      targetPosition = await nextRowPosition(trx, tableId)
    }

    return trx
      .insert(userTableRows)
      .values({
        id: rowId,