Function handleBatchInsert

apps/sim/app/api/table/[tableId]/rows/route.ts:39–106

(
  requestId: string,
  tableId: string,
  validated: BatchInsertTableRowsBodyInput,
  userId: string,
  authType: AuthTypeValue | undefined
)

}

async function handleBatchInsert(
  requestId: string,
  tableId: string,
  validated: BatchInsertTableRowsBodyInput,
  userId: string,
  authType: AuthTypeValue | undefined
): Promise<NextResponse> {
  const accessResult = await checkAccess(tableId, userId, 'write')
  if (!accessResult.ok) return accessError(accessResult, requestId, tableId)

  const { table } = accessResult

  if (validated.workspaceId !== table.workspaceId) {
    logger.warn(
      `[${requestId}] Workspace ID mismatch for table ${tableId}. Provided: ${validated.workspaceId}, Actual: ${table.workspaceId}`
    )
    return NextResponse.json({ error: 'Invalid workspace ID' }, { status: 400 })
  }

  const wire = rowWireTranslators(authType, table.schema as TableSchema)
  const rows = (validated.rows as RowData[]).map((row) => wire.dataIn(row))

  // Validate rows before calling service (service also validates, but route-level
  // validation returns structured HTTP responses)
  const validation = await validateBatchRows({
    rows,
    schema: table.schema as TableSchema,
    tableId,
  })
  if (!validation.valid) return validation.response

  try {
    const insertedRows = await batchInsertRows(
      {
        tableId,
        rows,
        workspaceId: validated.workspaceId,
        userId,
        positions: validated.positions,
        orderKeys: validated.orderKeys,
      },
      table,
      requestId
    )

    return NextResponse.json({
      success: true,
      data: {
        rows: insertedRows.map((r) => ({
          id: r.id,
          data: wire.dataOut(r.data),
          position: r.position,
          orderKey: r.orderKey ?? undefined,
          createdAt: r.createdAt instanceof Date ? r.createdAt.toISOString() : r.createdAt,
          updatedAt: r.updatedAt instanceof Date ? r.updatedAt.toISOString() : r.updatedAt,
        })),
        insertedCount: insertedRows.length,
        message: `Successfully inserted ${insertedRows.length} rows`,