let WASM_CFLAGS = process.env.WASM_CFLAGS || '--sysroot=/usr/share/wasi-sysroot -target wasm32-unknown-wasi'

let WASM_LDFLAGS = process.env.WASM_LDFLAGS || ''

const WASM_LDLIBS = process.env.WASM_LDLIBS || ''

const WASM_OPT = process.env.WASM_OPT || './wasm-opt'

const EXTERNAL_PATH = process.env.EXTERNAL_PATH

try { execSync('command -v apk'); return true } catch (error) { return false }

const hasOptimizer = (function () {

try { execSync(`${WASM_OPT} --version`); return true } catch (error) { return false }

if (hasApk) {

// Gather information about the tools used for the build

${WASM_LDLIBS}`, { stdio: 'inherit' })

if (hasOptimizer) {

execSync(`${WASM_OPT} ${WASM_OPT_FLAGS} -o ${join(WASM_OUT, 'llhttp.wasm')} ${join(WASM_OUT, 'llhttp.wasm')}`, { stdio: 'inherit' })

writeWasmChunk('llhttp.wasm', 'llhttp-wasm.js')

${WASM_LDLIBS}`, { stdio: 'inherit' })

if (hasOptimizer) {

execSync(`${WASM_OPT} ${WASM_OPT_FLAGS} --enable-simd -o ${join(WASM_OUT, 'llhttp_simd.wasm')} ${join(WASM_OUT, 'llhttp_simd.wasm')}`, { stdio: 'inherit' })

writeWasmChunk('llhttp_simd.wasm', 'llhttp_simd-wasm.js')

const kMaxWeightPerServer = Symbol('kMaxWeightPerServer')

const kErrorPenalty = Symbol('kErrorPenalty')

function getGreatestCommonDivisor (a, b) {

if (a === 0) return b

while (b !== 0) {

const t = b

b = a % b

a = t

}

return a

function defaultFactory (origin, opts) {

}

_updateBalancedPoolStats () {

let result = 0

for (let i = 0; i < this[kClients].length; i++) {

result = getGreatestCommonDivisor(this[kClients][i][kWeight], result)

}

this[kGreatestCommonDivisor] = result

}

removeUpstream (upstream) {

> undici@6.19.8 prebuild:wasm

> node build/wasm.js --prebuild

> docker build --platform=linux/x86_64 -t llhttp_wasm_builder -f /home/runner/work/node/node/deps/undici/src/build/Dockerfile /home/runner/work/node/node/deps/undici/src

> undici@6.19.8 build:wasm

> node build/wasm.js --docker

> docker run --rm -t --platform=linux/x86_64 --user 1001:127 --mount type=bind,source=/home/runner/work/node/node/deps/undici/src/lib/llhttp,target=/home/node/undici/lib/llhttp llhttp_wasm_builder node build/wasm.js

const { webidl } = require('./webidl')

const { Blob } = require('node:buffer')

const assert = require('node:assert')

const { isErrored, isDisturbed } = require('node:stream')

const { isArrayBuffer } = require('node:util/types')

const { serializeAMimeType } = require('./data-url')

const { multipartFormDataParser } = require('./formdata-parser')

const textEncoder = new TextEncoder()

function noop () {}

const hasFinalizationRegistry = globalThis.FinalizationRegistry && process.version.indexOf('v18') !== 0

let streamRegistry

if (hasFinalizationRegistry) {

streamRegistry = new FinalizationRegistry((weakRef) => {

const stream = weakRef.deref()

if (stream && !stream.locked && !isDisturbed(stream) && !isErrored(stream)) {

stream.cancel('Response object has been garbage collected').catch(noop)

}

})

function extractBody (object, keepalive = false) {

return extractBody(object, keepalive)

function cloneBody (instance, body) {

// To clone a body body, run these steps:

// https://fetch.spec.whatwg.org/#concept-body-clone

// 1. Let « out1, out2 » be the result of teeing body’s stream.

const [out1, out2] = body.stream.tee()

if (hasFinalizationRegistry) {

streamRegistry.register(instance, new WeakRef(out1))

}

// 2. Set body’s stream to out1.

body.stream = out1

// 1. If object is unusable, then return a promise rejected

// with a TypeError.

if (bodyUnusable(object)) {

throw new TypeError('Body is unusable: Body has already been read')

}

function bodyUnusable (object) {

const body = object[kState].body

// An object including the Body interface mixin is

// said to be unusable if its body is non-null and

// its body’s stream is disturbed or locked.

extractBody,

safelyExtractBody,

cloneBody,

mixinBody,

streamRegistry,

hasFinalizationRegistry,

bodyUnusable

const { extractBody, mixinBody, cloneBody, bodyUnusable } = require('./body')

const { Headers, fill: fillHeaders, HeadersList, setHeadersGuard, getHeadersGuard, setHeadersList, getHeadersList } = require('./headers')

const { FinalizationRegistry } = require('./dispatcher-weakref')()

const util = require('../../core/util')

// 40. If initBody is null and inputBody is non-null, then:

if (initBody == null && inputBody != null) {

// 1. If input is unusable, then throw a TypeError.

if (bodyUnusable(input)) {

throw new TypeError(

'Cannot construct a Request with a Request object that has already been used.'

)

webidl.brandCheck(this, Request)

// 1. If this is unusable, then throw a TypeError.

if (bodyUnusable(this)) {

throw new TypeError('unusable')

}

// 2. If request’s body is non-null, set newRequest’s body to the

// result of cloning request’s body.

if (request.body != null) {

newRequest.body = cloneBody(newRequest, request.body)

}

// 3. Return newRequest.

const { Headers, HeadersList, fill, getHeadersGuard, setHeadersGuard, setHeadersList } = require('./headers')

const { extractBody, cloneBody, mixinBody, hasFinalizationRegistry, streamRegistry, bodyUnusable } = require('./body')

const util = require('../../core/util')

const nodeUtil = require('node:util')

const { kEnumerableProperty } = util

const { kConstruct } = require('../../core/symbols')

const assert = require('node:assert')

const { types } = require('node:util')

const textEncoder = new TextEncoder('utf-8')

class Response {

// Creates network error Response.

webidl.brandCheck(this, Response)

// 1. If this is unusable, then throw a TypeError.

if (bodyUnusable(this)) {

throw webidl.errors.exception({

header: 'Response.clone',

message: 'Body has already been consumed.'

// 3. If response’s body is non-null, then set newResponse’s body to the

// result of cloning response’s body.

if (response.body != null) {

newResponse.body = cloneBody(newResponse, response.body)

}

// 4. Return newResponse.

// a primitive or an object, even undefined. If the held value is an object, the registry keeps

// a strong reference to it (so it can pass it to the cleanup callback later). Reworded from

// https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/FinalizationRegistry

streamRegistry.register(response, new WeakRef(innerResponse.body.stream))

}

return response