Function insertRow

apps/sim/lib/table/rows/service.ts:99–186

(
  data: InsertRowData,
  table: TableDefinition,
  requestId: string
)

 * @throws Error if validation fails or capacity exceeded
 */
export async function insertRow(
  data: InsertRowData,
  table: TableDefinition,
  requestId: string
): Promise<TableRow> {
  // Validate row size
  const sizeValidation = validateRowSize(data.data)
  if (!sizeValidation.valid) {
    throw new Error(sizeValidation.errors.join(', '))
  }

  // Validate against schema
  const schemaValidation = coerceRowToSchema(data.data, table.schema)
  if (!schemaValidation.valid) {
    throw new Error(`Schema validation failed: ${schemaValidation.errors.join(', ')}`)
  }

  // Check unique constraints using optimized database query
  const uniqueColumns = getUniqueColumns(table.schema)
  if (uniqueColumns.length > 0) {
    const uniqueValidation = await checkUniqueConstraintsDb(data.tableId, data.data, table.schema)
    if (!uniqueValidation.valid) {
      throw new Error(uniqueValidation.errors.join(', '))
    }
  }

  // Best-effort capacity check against the workspace's current plan limit.
  const rowLimit = await assertRowCapacity({
    workspaceId: table.workspaceId,
    currentRowCount: table.rowCount,
    addedRows: 1,
  })

  const rowId = `row_${generateId().replace(/-/g, '')}`
  const now = new Date()

  const row = await insertOrderedRow({
    tableId: data.tableId,
    workspaceId: data.workspaceId,
    data: data.data,
    rowId,
    position: data.position,
    afterRowId: data.afterRowId,
    beforeRowId: data.beforeRowId,
    createdBy: data.userId,
    now,
  })

  notifyTableRowUsage({
    workspaceId: table.workspaceId,
    currentRowCount: table.rowCount,
    addedRows: 1,
    limit: rowLimit,
  })

  logger.info(`[${requestId}] Inserted row ${rowId} into table ${data.tableId}`)

  const insertedRow: TableRow = {