|
|
|
@ -20794,6 +20794,9 @@ class Range {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
parseRange (range) {
|
|
|
|
parseRange (range) {
|
|
|
|
|
|
|
|
// strip build metadata so it can't bleed into the version
|
|
|
|
|
|
|
|
range = range.replace(BUILDSTRIPRE, '')
|
|
|
|
|
|
|
|
|
|
|
|
// memoize range parsing for performance.
|
|
|
|
// memoize range parsing for performance.
|
|
|
|
// this is a very hot path, and fully deterministic.
|
|
|
|
// this is a very hot path, and fully deterministic.
|
|
|
|
const memoOpts =
|
|
|
|
const memoOpts =
|
|
|
|
@ -20919,6 +20922,7 @@ const debug = __nccwpck_require__(1159)
|
|
|
|
const SemVer = __nccwpck_require__(7163)
|
|
|
|
const SemVer = __nccwpck_require__(7163)
|
|
|
|
const {
|
|
|
|
const {
|
|
|
|
safeRe: re,
|
|
|
|
safeRe: re,
|
|
|
|
|
|
|
|
src,
|
|
|
|
t,
|
|
|
|
t,
|
|
|
|
comparatorTrimReplace,
|
|
|
|
comparatorTrimReplace,
|
|
|
|
tildeTrimReplace,
|
|
|
|
tildeTrimReplace,
|
|
|
|
@ -20926,6 +20930,9 @@ const {
|
|
|
|
} = __nccwpck_require__(95471)
|
|
|
|
} = __nccwpck_require__(95471)
|
|
|
|
const { FLAG_INCLUDE_PRERELEASE, FLAG_LOOSE } = __nccwpck_require__(45101)
|
|
|
|
const { FLAG_INCLUDE_PRERELEASE, FLAG_LOOSE } = __nccwpck_require__(45101)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// unbounded global build-metadata stripper used by parseRange
|
|
|
|
|
|
|
|
const BUILDSTRIPRE = new RegExp(src[t.BUILD], 'g')
|
|
|
|
|
|
|
|
|
|
|
|
const isNullSet = c => c.value === '<0.0.0-0'
|
|
|
|
const isNullSet = c => c.value === '<0.0.0-0'
|
|
|
|
const isAny = c => c.value === ''
|
|
|
|
const isAny = c => c.value === ''
|
|
|
|
|
|
|
|
|
|
|
|
@ -20966,6 +20973,11 @@ const parseComparator = (comp, options) => {
|
|
|
|
|
|
|
|
|
|
|
|
const isX = id => !id || id.toLowerCase() === 'x' || id === '*'
|
|
|
|
const isX = id => !id || id.toLowerCase() === 'x' || id === '*'
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const invalidXRangeOrder = (M, m, p) => (
|
|
|
|
|
|
|
|
(isX(M) && !isX(m)) ||
|
|
|
|
|
|
|
|
(isX(m) && p && !isX(p))
|
|
|
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
|
|
// ~, ~> --> * (any, kinda silly)
|
|
|
|
// ~, ~> --> * (any, kinda silly)
|
|
|
|
// ~2, ~2.x, ~2.x.x, ~>2, ~>2.x ~>2.x.x --> >=2.0.0 <3.0.0-0
|
|
|
|
// ~2, ~2.x, ~2.x.x, ~>2, ~>2.x ~>2.x.x --> >=2.0.0 <3.0.0-0
|
|
|
|
// ~2.0, ~2.0.x, ~>2.0, ~>2.0.x --> >=2.0.0 <2.1.0-0
|
|
|
|
// ~2.0, ~2.0.x, ~>2.0, ~>2.0.x --> >=2.0.0 <2.1.0-0
|
|
|
|
@ -20983,6 +20995,10 @@ const replaceTildes = (comp, options) => {
|
|
|
|
|
|
|
|
|
|
|
|
const replaceTilde = (comp, options) => {
|
|
|
|
const replaceTilde = (comp, options) => {
|
|
|
|
const r = options.loose ? re[t.TILDELOOSE] : re[t.TILDE]
|
|
|
|
const r = options.loose ? re[t.TILDELOOSE] : re[t.TILDE]
|
|
|
|
|
|
|
|
// if we're including prereleases in the match, then the lower bound is
|
|
|
|
|
|
|
|
// -0, the lowest possible prerelease value, just like x-ranges and carets.
|
|
|
|
|
|
|
|
// this keeps `~1.2` equivalent to the `1.2.x` x-range it's documented as.
|
|
|
|
|
|
|
|
const z = options.includePrerelease ? '-0' : ''
|
|
|
|
return comp.replace(r, (_, M, m, p, pr) => {
|
|
|
|
return comp.replace(r, (_, M, m, p, pr) => {
|
|
|
|
debug('tilde', comp, _, M, m, p, pr)
|
|
|
|
debug('tilde', comp, _, M, m, p, pr)
|
|
|
|
let ret
|
|
|
|
let ret
|
|
|
|
@ -20990,10 +21006,10 @@ const replaceTilde = (comp, options) => {
|
|
|
|
if (isX(M)) {
|
|
|
|
if (isX(M)) {
|
|
|
|
ret = ''
|
|
|
|
ret = ''
|
|
|
|
} else if (isX(m)) {
|
|
|
|
} else if (isX(m)) {
|
|
|
|
ret = `>=${M}.0.0 <${+M + 1}.0.0-0`
|
|
|
|
ret = `>=${M}.0.0${z} <${+M + 1}.0.0-0`
|
|
|
|
} else if (isX(p)) {
|
|
|
|
} else if (isX(p)) {
|
|
|
|
// ~1.2 == >=1.2.0 <1.3.0-0
|
|
|
|
// ~1.2 == >=1.2.0 <1.3.0-0
|
|
|
|
ret = `>=${M}.${m}.0 <${M}.${+m + 1}.0-0`
|
|
|
|
ret = `>=${M}.${m}.0${z} <${M}.${+m + 1}.0-0`
|
|
|
|
} else if (pr) {
|
|
|
|
} else if (pr) {
|
|
|
|
debug('replaceTilde pr', pr)
|
|
|
|
debug('replaceTilde pr', pr)
|
|
|
|
ret = `>=${M}.${m}.${p}-${pr
|
|
|
|
ret = `>=${M}.${m}.${p}-${pr
|
|
|
|
@ -21062,10 +21078,10 @@ const replaceCaret = (comp, options) => {
|
|
|
|
if (M === '0') {
|
|
|
|
if (M === '0') {
|
|
|
|
if (m === '0') {
|
|
|
|
if (m === '0') {
|
|
|
|
ret = `>=${M}.${m}.${p
|
|
|
|
ret = `>=${M}.${m}.${p
|
|
|
|
}${z} <${M}.${m}.${+p + 1}-0`
|
|
|
|
} <${M}.${m}.${+p + 1}-0`
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
ret = `>=${M}.${m}.${p
|
|
|
|
ret = `>=${M}.${m}.${p
|
|
|
|
}${z} <${M}.${+m + 1}.0-0`
|
|
|
|
} <${M}.${+m + 1}.0-0`
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
ret = `>=${M}.${m}.${p
|
|
|
|
ret = `>=${M}.${m}.${p
|
|
|
|
@ -21091,6 +21107,10 @@ const replaceXRange = (comp, options) => {
|
|
|
|
const r = options.loose ? re[t.XRANGELOOSE] : re[t.XRANGE]
|
|
|
|
const r = options.loose ? re[t.XRANGELOOSE] : re[t.XRANGE]
|
|
|
|
return comp.replace(r, (ret, gtlt, M, m, p, pr) => {
|
|
|
|
return comp.replace(r, (ret, gtlt, M, m, p, pr) => {
|
|
|
|
debug('xRange', comp, ret, gtlt, M, m, p, pr)
|
|
|
|
debug('xRange', comp, ret, gtlt, M, m, p, pr)
|
|
|
|
|
|
|
|
if (invalidXRangeOrder(M, m, p)) {
|
|
|
|
|
|
|
|
return comp
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
const xM = isX(M)
|
|
|
|
const xM = isX(M)
|
|
|
|
const xm = xM || isX(m)
|
|
|
|
const xm = xM || isX(m)
|
|
|
|
const xp = xm || isX(p)
|
|
|
|
const xp = xm || isX(p)
|
|
|
|
@ -21267,6 +21287,22 @@ const { safeRe: re, t } = __nccwpck_require__(95471)
|
|
|
|
|
|
|
|
|
|
|
|
const parseOptions = __nccwpck_require__(70356)
|
|
|
|
const parseOptions = __nccwpck_require__(70356)
|
|
|
|
const { compareIdentifiers } = __nccwpck_require__(73348)
|
|
|
|
const { compareIdentifiers } = __nccwpck_require__(73348)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const isPrereleaseIdentifier = (prerelease, identifier) => {
|
|
|
|
|
|
|
|
const identifiers = identifier.split('.')
|
|
|
|
|
|
|
|
if (identifiers.length > prerelease.length) {
|
|
|
|
|
|
|
|
return false
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
for (let i = 0; i < identifiers.length; i++) {
|
|
|
|
|
|
|
|
if (compareIdentifiers(prerelease[i], identifiers[i]) !== 0) {
|
|
|
|
|
|
|
|
return false
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return true
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
class SemVer {
|
|
|
|
class SemVer {
|
|
|
|
constructor (version, options) {
|
|
|
|
constructor (version, options) {
|
|
|
|
options = parseOptions(options)
|
|
|
|
options = parseOptions(options)
|
|
|
|
@ -21570,8 +21606,9 @@ class SemVer {
|
|
|
|
if (identifierBase === false) {
|
|
|
|
if (identifierBase === false) {
|
|
|
|
prerelease = [identifier]
|
|
|
|
prerelease = [identifier]
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (compareIdentifiers(this.prerelease[0], identifier) === 0) {
|
|
|
|
if (isPrereleaseIdentifier(this.prerelease, identifier)) {
|
|
|
|
if (isNaN(this.prerelease[1])) {
|
|
|
|
const prereleaseBase = this.prerelease[identifier.split('.').length]
|
|
|
|
|
|
|
|
if (isNaN(prereleaseBase)) {
|
|
|
|
this.prerelease = prerelease
|
|
|
|
this.prerelease = prerelease
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
@ -21848,7 +21885,7 @@ const diff = (version1, version2) => {
|
|
|
|
return prefix + 'patch'
|
|
|
|
return prefix + 'patch'
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// high and low are preleases
|
|
|
|
// high and low are prereleases
|
|
|
|
return 'prerelease'
|
|
|
|
return 'prerelease'
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@ -22102,6 +22139,62 @@ const sort = (list, loose) => list.sort((a, b) => compareBuild(a, b, loose))
|
|
|
|
module.exports = sort
|
|
|
|
module.exports = sort
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/***/ }),
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/***/ 16114:
|
|
|
|
|
|
|
|
/***/ ((module, __unused_webpack_exports, __nccwpck_require__) => {
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
"use strict";
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const parse = __nccwpck_require__(16353)
|
|
|
|
|
|
|
|
const constants = __nccwpck_require__(45101)
|
|
|
|
|
|
|
|
const SemVer = __nccwpck_require__(7163)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const truncate = (version, truncation, options) => {
|
|
|
|
|
|
|
|
if (!constants.RELEASE_TYPES.includes(truncation)) {
|
|
|
|
|
|
|
|
return null
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const clonedVersion = cloneInputVersion(version, options)
|
|
|
|
|
|
|
|
return clonedVersion && doTruncation(clonedVersion, truncation)
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const cloneInputVersion = (version, options) => {
|
|
|
|
|
|
|
|
const versionStringToParse = (
|
|
|
|
|
|
|
|
version instanceof SemVer ? version.version : version
|
|
|
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return parse(versionStringToParse, options)
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const doTruncation = (version, truncation) => {
|
|
|
|
|
|
|
|
if (isPrerelease(truncation)) {
|
|
|
|
|
|
|
|
return version.version
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
version.prerelease = []
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
switch (truncation) {
|
|
|
|
|
|
|
|
case 'major':
|
|
|
|
|
|
|
|
version.minor = 0
|
|
|
|
|
|
|
|
version.patch = 0
|
|
|
|
|
|
|
|
break
|
|
|
|
|
|
|
|
case 'minor':
|
|
|
|
|
|
|
|
version.patch = 0
|
|
|
|
|
|
|
|
break
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return version.format()
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const isPrerelease = (type) => {
|
|
|
|
|
|
|
|
return type.startsWith('pre')
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
module.exports = truncate
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/***/ }),
|
|
|
|
/***/ }),
|
|
|
|
|
|
|
|
|
|
|
|
/***/ 58780:
|
|
|
|
/***/ 58780:
|
|
|
|
@ -22154,6 +22247,7 @@ const gte = __nccwpck_require__(41236)
|
|
|
|
const lte = __nccwpck_require__(56717)
|
|
|
|
const lte = __nccwpck_require__(56717)
|
|
|
|
const cmp = __nccwpck_require__(28646)
|
|
|
|
const cmp = __nccwpck_require__(28646)
|
|
|
|
const coerce = __nccwpck_require__(35385)
|
|
|
|
const coerce = __nccwpck_require__(35385)
|
|
|
|
|
|
|
|
const truncate = __nccwpck_require__(16114)
|
|
|
|
const Comparator = __nccwpck_require__(89379)
|
|
|
|
const Comparator = __nccwpck_require__(89379)
|
|
|
|
const Range = __nccwpck_require__(96782)
|
|
|
|
const Range = __nccwpck_require__(96782)
|
|
|
|
const satisfies = __nccwpck_require__(68011)
|
|
|
|
const satisfies = __nccwpck_require__(68011)
|
|
|
|
@ -22192,6 +22286,7 @@ module.exports = {
|
|
|
|
lte,
|
|
|
|
lte,
|
|
|
|
cmp,
|
|
|
|
cmp,
|
|
|
|
coerce,
|
|
|
|
coerce,
|
|
|
|
|
|
|
|
truncate,
|
|
|
|
Comparator,
|
|
|
|
Comparator,
|
|
|
|
Range,
|
|
|
|
Range,
|
|
|
|
satisfies,
|
|
|
|
satisfies,
|
|
|
|
@ -22479,8 +22574,8 @@ createToken('MAINVERSIONLOOSE', `(${src[t.NUMERICIDENTIFIERLOOSE]})\\.` +
|
|
|
|
|
|
|
|
|
|
|
|
// ## Pre-release Version Identifier
|
|
|
|
// ## Pre-release Version Identifier
|
|
|
|
// A numeric identifier, or a non-numeric identifier.
|
|
|
|
// A numeric identifier, or a non-numeric identifier.
|
|
|
|
// Non-numberic identifiers include numberic identifiers but can be longer.
|
|
|
|
// Non-numeric identifiers include numeric identifiers but can be longer.
|
|
|
|
// Therefore non-numberic identifiers must go first.
|
|
|
|
// Therefore non-numeric identifiers must go first.
|
|
|
|
|
|
|
|
|
|
|
|
createToken('PRERELEASEIDENTIFIER', `(?:${src[t.NONNUMERICIDENTIFIER]
|
|
|
|
createToken('PRERELEASEIDENTIFIER', `(?:${src[t.NONNUMERICIDENTIFIER]
|
|
|
|
}|${src[t.NUMERICIDENTIFIER]})`)
|
|
|
|
}|${src[t.NUMERICIDENTIFIER]})`)
|
|
|
|
@ -22537,7 +22632,7 @@ createToken('LOOSE', `^${src[t.LOOSEPLAIN]}$`)
|
|
|
|
createToken('GTLT', '((?:<|>)?=?)')
|
|
|
|
createToken('GTLT', '((?:<|>)?=?)')
|
|
|
|
|
|
|
|
|
|
|
|
// Something like "2.*" or "1.2.x".
|
|
|
|
// Something like "2.*" or "1.2.x".
|
|
|
|
// Note that "x.x" is a valid xRange identifer, meaning "any version"
|
|
|
|
// Note that "x.x" is a valid xRange identifier, meaning "any version"
|
|
|
|
// Only the first item is strictly required.
|
|
|
|
// Only the first item is strictly required.
|
|
|
|
createToken('XRANGEIDENTIFIERLOOSE', `${src[t.NUMERICIDENTIFIERLOOSE]}|x|X|\\*`)
|
|
|
|
createToken('XRANGEIDENTIFIERLOOSE', `${src[t.NUMERICIDENTIFIERLOOSE]}|x|X|\\*`)
|
|
|
|
createToken('XRANGEIDENTIFIER', `${src[t.NUMERICIDENTIFIER]}|x|X|\\*`)
|
|
|
|
createToken('XRANGEIDENTIFIER', `${src[t.NUMERICIDENTIFIER]}|x|X|\\*`)
|
|
|
|
@ -23002,7 +23097,7 @@ const compare = __nccwpck_require__(78469)
|
|
|
|
// - If LT
|
|
|
|
// - If LT
|
|
|
|
// - If LT.semver is greater than any < or <= comp in C, return false
|
|
|
|
// - If LT.semver is greater than any < or <= comp in C, return false
|
|
|
|
// - If LT is <=, and LT.semver does not satisfy every C, return false
|
|
|
|
// - If LT is <=, and LT.semver does not satisfy every C, return false
|
|
|
|
// - If GT.semver has a prerelease, and not in prerelease mode
|
|
|
|
// - If LT.semver has a prerelease, and not in prerelease mode
|
|
|
|
// - If no C has a prerelease and the LT.semver tuple, return false
|
|
|
|
// - If no C has a prerelease and the LT.semver tuple, return false
|
|
|
|
// - Else return true
|
|
|
|
// - Else return true
|
|
|
|
|
|
|
|
|
|
|
|
@ -23138,7 +23233,7 @@ const simpleSubset = (sub, dom, options) => {
|
|
|
|
if (higher === c && higher !== gt) {
|
|
|
|
if (higher === c && higher !== gt) {
|
|
|
|
return false
|
|
|
|
return false
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} else if (gt.operator === '>=' && !satisfies(gt.semver, String(c), options)) {
|
|
|
|
} else if (gt.operator === '>=' && !c.test(gt.semver)) {
|
|
|
|
return false
|
|
|
|
return false
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
@ -23156,7 +23251,7 @@ const simpleSubset = (sub, dom, options) => {
|
|
|
|
if (lower === c && lower !== lt) {
|
|
|
|
if (lower === c && lower !== lt) {
|
|
|
|
return false
|
|
|
|
return false
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} else if (lt.operator === '<=' && !satisfies(lt.semver, String(c), options)) {
|
|
|
|
} else if (lt.operator === '<=' && !c.test(lt.semver)) {
|
|
|
|
return false
|
|
|
|
return false
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
@ -28246,8 +28341,6 @@ function defaultFactory (origin, opts) {
|
|
|
|
|
|
|
|
|
|
|
|
class Agent extends DispatcherBase {
|
|
|
|
class Agent extends DispatcherBase {
|
|
|
|
constructor ({ factory = defaultFactory, maxRedirections = 0, connect, ...options } = {}) {
|
|
|
|
constructor ({ factory = defaultFactory, maxRedirections = 0, connect, ...options } = {}) {
|
|
|
|
super()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (typeof factory !== 'function') {
|
|
|
|
if (typeof factory !== 'function') {
|
|
|
|
throw new InvalidArgumentError('factory must be a function.')
|
|
|
|
throw new InvalidArgumentError('factory must be a function.')
|
|
|
|
}
|
|
|
|
}
|
|
|
|
@ -28260,6 +28353,8 @@ class Agent extends DispatcherBase {
|
|
|
|
throw new InvalidArgumentError('maxRedirections must be a positive number')
|
|
|
|
throw new InvalidArgumentError('maxRedirections must be a positive number')
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
super(options)
|
|
|
|
|
|
|
|
|
|
|
|
if (connect && typeof connect !== 'function') {
|
|
|
|
if (connect && typeof connect !== 'function') {
|
|
|
|
connect = { ...connect }
|
|
|
|
connect = { ...connect }
|
|
|
|
}
|
|
|
|
}
|
|
|
|
@ -28633,6 +28728,9 @@ const EMPTY_BUF = Buffer.alloc(0)
|
|
|
|
const FastBuffer = Buffer[Symbol.species]
|
|
|
|
const FastBuffer = Buffer[Symbol.species]
|
|
|
|
const addListener = util.addListener
|
|
|
|
const addListener = util.addListener
|
|
|
|
const removeAllListeners = util.removeAllListeners
|
|
|
|
const removeAllListeners = util.removeAllListeners
|
|
|
|
|
|
|
|
const kIdleSocketValidation = Symbol('kIdleSocketValidation')
|
|
|
|
|
|
|
|
const kIdleSocketValidationTimeout = Symbol('kIdleSocketValidationTimeout')
|
|
|
|
|
|
|
|
const kSocketUsed = Symbol('kSocketUsed')
|
|
|
|
|
|
|
|
|
|
|
|
let extractBody
|
|
|
|
let extractBody
|
|
|
|
|
|
|
|
|
|
|
|
@ -28855,29 +28953,71 @@ class Parser {
|
|
|
|
|
|
|
|
|
|
|
|
const offset = llhttp.llhttp_get_error_pos(this.ptr) - currentBufferPtr
|
|
|
|
const offset = llhttp.llhttp_get_error_pos(this.ptr) - currentBufferPtr
|
|
|
|
|
|
|
|
|
|
|
|
if (ret === constants.ERROR.PAUSED_UPGRADE) {
|
|
|
|
if (ret !== constants.ERROR.OK) {
|
|
|
|
this.onUpgrade(data.slice(offset))
|
|
|
|
const body = data.subarray(offset)
|
|
|
|
} else if (ret === constants.ERROR.PAUSED) {
|
|
|
|
|
|
|
|
this.paused = true
|
|
|
|
if (ret === constants.ERROR.PAUSED_UPGRADE) {
|
|
|
|
socket.unshift(data.slice(offset))
|
|
|
|
this.onUpgrade(body)
|
|
|
|
} else if (ret !== constants.ERROR.OK) {
|
|
|
|
} else if (ret === constants.ERROR.PAUSED) {
|
|
|
|
const ptr = llhttp.llhttp_get_error_reason(this.ptr)
|
|
|
|
this.paused = true
|
|
|
|
let message = ''
|
|
|
|
socket.unshift(body)
|
|
|
|
/* istanbul ignore else: difficult to make a test case for */
|
|
|
|
} else {
|
|
|
|
if (ptr) {
|
|
|
|
throw this.createError(ret, body)
|
|
|
|
const len = new Uint8Array(llhttp.memory.buffer, ptr).indexOf(0)
|
|
|
|
}
|
|
|
|
message =
|
|
|
|
|
|
|
|
'Response does not match the HTTP/1.1 protocol (' +
|
|
|
|
|
|
|
|
Buffer.from(llhttp.memory.buffer, ptr, len).toString() +
|
|
|
|
|
|
|
|
')'
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
throw new HTTPParserError(message, constants.ERROR[ret], data.slice(offset))
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} catch (err) {
|
|
|
|
} catch (err) {
|
|
|
|
util.destroy(socket, err)
|
|
|
|
util.destroy(socket, err)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
finish () {
|
|
|
|
|
|
|
|
assert(currentParser === null)
|
|
|
|
|
|
|
|
assert(this.ptr != null)
|
|
|
|
|
|
|
|
assert(!this.paused)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const { llhttp } = this
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
let ret
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
try {
|
|
|
|
|
|
|
|
currentParser = this
|
|
|
|
|
|
|
|
ret = llhttp.llhttp_finish(this.ptr)
|
|
|
|
|
|
|
|
} finally {
|
|
|
|
|
|
|
|
currentParser = null
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (ret === constants.ERROR.OK) {
|
|
|
|
|
|
|
|
return null
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (ret === constants.ERROR.PAUSED || ret === constants.ERROR.PAUSED_UPGRADE) {
|
|
|
|
|
|
|
|
this.paused = true
|
|
|
|
|
|
|
|
return null
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return this.createError(ret, EMPTY_BUF)
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
createError (ret, data) {
|
|
|
|
|
|
|
|
const { llhttp, contentLength, bytesRead } = this
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (contentLength && bytesRead !== parseInt(contentLength, 10)) {
|
|
|
|
|
|
|
|
return new ResponseContentLengthMismatchError()
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const ptr = llhttp.llhttp_get_error_reason(this.ptr)
|
|
|
|
|
|
|
|
let message = ''
|
|
|
|
|
|
|
|
if (ptr) {
|
|
|
|
|
|
|
|
const len = new Uint8Array(llhttp.memory.buffer, ptr).indexOf(0)
|
|
|
|
|
|
|
|
message =
|
|
|
|
|
|
|
|
'Response does not match the HTTP/1.1 protocol (' +
|
|
|
|
|
|
|
|
Buffer.from(llhttp.memory.buffer, ptr, len).toString() +
|
|
|
|
|
|
|
|
')'
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return new HTTPParserError(message, constants.ERROR[ret], data)
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
destroy () {
|
|
|
|
destroy () {
|
|
|
|
assert(this.ptr != null)
|
|
|
|
assert(this.ptr != null)
|
|
|
|
assert(currentParser == null)
|
|
|
|
assert(currentParser == null)
|
|
|
|
@ -28905,6 +29045,11 @@ class Parser {
|
|
|
|
return -1
|
|
|
|
return -1
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (client[kRunning] === 0) {
|
|
|
|
|
|
|
|
util.destroy(socket, new SocketError('bad response', util.getSocketInfo(socket)))
|
|
|
|
|
|
|
|
return -1
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
const request = client[kQueue][client[kRunningIdx]]
|
|
|
|
const request = client[kQueue][client[kRunningIdx]]
|
|
|
|
if (!request) {
|
|
|
|
if (!request) {
|
|
|
|
return -1
|
|
|
|
return -1
|
|
|
|
@ -29008,6 +29153,11 @@ class Parser {
|
|
|
|
return -1
|
|
|
|
return -1
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (client[kRunning] === 0) {
|
|
|
|
|
|
|
|
util.destroy(socket, new SocketError('bad response', util.getSocketInfo(socket)))
|
|
|
|
|
|
|
|
return -1
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
const request = client[kQueue][client[kRunningIdx]]
|
|
|
|
const request = client[kQueue][client[kRunningIdx]]
|
|
|
|
|
|
|
|
|
|
|
|
/* istanbul ignore next: difficult to make a test case for */
|
|
|
|
/* istanbul ignore next: difficult to make a test case for */
|
|
|
|
@ -29181,6 +29331,7 @@ class Parser {
|
|
|
|
request.onComplete(headers)
|
|
|
|
request.onComplete(headers)
|
|
|
|
|
|
|
|
|
|
|
|
client[kQueue][client[kRunningIdx]++] = null
|
|
|
|
client[kQueue][client[kRunningIdx]++] = null
|
|
|
|
|
|
|
|
socket[kSocketUsed] = true
|
|
|
|
|
|
|
|
|
|
|
|
if (socket[kWriting]) {
|
|
|
|
if (socket[kWriting]) {
|
|
|
|
assert(client[kRunning] === 0)
|
|
|
|
assert(client[kRunning] === 0)
|
|
|
|
@ -29239,6 +29390,9 @@ async function connectH1 (client, socket) {
|
|
|
|
socket[kWriting] = false
|
|
|
|
socket[kWriting] = false
|
|
|
|
socket[kReset] = false
|
|
|
|
socket[kReset] = false
|
|
|
|
socket[kBlocking] = false
|
|
|
|
socket[kBlocking] = false
|
|
|
|
|
|
|
|
socket[kIdleSocketValidation] = 0
|
|
|
|
|
|
|
|
socket[kIdleSocketValidationTimeout] = null
|
|
|
|
|
|
|
|
socket[kSocketUsed] = false
|
|
|
|
socket[kParser] = new Parser(client, socket, llhttpInstance)
|
|
|
|
socket[kParser] = new Parser(client, socket, llhttpInstance)
|
|
|
|
|
|
|
|
|
|
|
|
addListener(socket, 'error', function (err) {
|
|
|
|
addListener(socket, 'error', function (err) {
|
|
|
|
@ -29249,8 +29403,11 @@ async function connectH1 (client, socket) {
|
|
|
|
// On Mac OS, we get an ECONNRESET even if there is a full body to be forwarded
|
|
|
|
// On Mac OS, we get an ECONNRESET even if there is a full body to be forwarded
|
|
|
|
// to the user.
|
|
|
|
// to the user.
|
|
|
|
if (err.code === 'ECONNRESET' && parser.statusCode && !parser.shouldKeepAlive) {
|
|
|
|
if (err.code === 'ECONNRESET' && parser.statusCode && !parser.shouldKeepAlive) {
|
|
|
|
// We treat all incoming data so for as a valid response.
|
|
|
|
const parserErr = parser.finish()
|
|
|
|
parser.onMessageComplete()
|
|
|
|
if (parserErr) {
|
|
|
|
|
|
|
|
this[kError] = parserErr
|
|
|
|
|
|
|
|
this[kClient][kOnError](parserErr)
|
|
|
|
|
|
|
|
}
|
|
|
|
return
|
|
|
|
return
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@ -29269,8 +29426,10 @@ async function connectH1 (client, socket) {
|
|
|
|
const parser = this[kParser]
|
|
|
|
const parser = this[kParser]
|
|
|
|
|
|
|
|
|
|
|
|
if (parser.statusCode && !parser.shouldKeepAlive) {
|
|
|
|
if (parser.statusCode && !parser.shouldKeepAlive) {
|
|
|
|
// We treat all incoming data so far as a valid response.
|
|
|
|
const parserErr = parser.finish()
|
|
|
|
parser.onMessageComplete()
|
|
|
|
if (parserErr) {
|
|
|
|
|
|
|
|
util.destroy(this, parserErr)
|
|
|
|
|
|
|
|
}
|
|
|
|
return
|
|
|
|
return
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@ -29280,10 +29439,11 @@ async function connectH1 (client, socket) {
|
|
|
|
const client = this[kClient]
|
|
|
|
const client = this[kClient]
|
|
|
|
const parser = this[kParser]
|
|
|
|
const parser = this[kParser]
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
clearIdleSocketValidation(this)
|
|
|
|
|
|
|
|
|
|
|
|
if (parser) {
|
|
|
|
if (parser) {
|
|
|
|
if (!this[kError] && parser.statusCode && !parser.shouldKeepAlive) {
|
|
|
|
if (!this[kError] && parser.statusCode && !parser.shouldKeepAlive) {
|
|
|
|
// We treat all incoming data so far as a valid response.
|
|
|
|
this[kError] = parser.finish() || this[kError]
|
|
|
|
parser.onMessageComplete()
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
this[kParser].destroy()
|
|
|
|
this[kParser].destroy()
|
|
|
|
@ -29346,7 +29506,7 @@ async function connectH1 (client, socket) {
|
|
|
|
return socket.destroyed
|
|
|
|
return socket.destroyed
|
|
|
|
},
|
|
|
|
},
|
|
|
|
busy (request) {
|
|
|
|
busy (request) {
|
|
|
|
if (socket[kWriting] || socket[kReset] || socket[kBlocking]) {
|
|
|
|
if (socket[kWriting] || socket[kReset] || socket[kBlocking] || socket[kIdleSocketValidation] === 1) {
|
|
|
|
return true
|
|
|
|
return true
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@ -29384,6 +29544,31 @@ async function connectH1 (client, socket) {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
function clearIdleSocketValidation (socket) {
|
|
|
|
|
|
|
|
if (socket[kIdleSocketValidationTimeout]) {
|
|
|
|
|
|
|
|
clearTimeout(socket[kIdleSocketValidationTimeout])
|
|
|
|
|
|
|
|
socket[kIdleSocketValidationTimeout] = null
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
socket[kIdleSocketValidation] = 0
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
function scheduleIdleSocketValidation (client, socket) {
|
|
|
|
|
|
|
|
socket[kIdleSocketValidation] = 1
|
|
|
|
|
|
|
|
socket[kIdleSocketValidationTimeout] = setTimeout(() => {
|
|
|
|
|
|
|
|
socket[kIdleSocketValidationTimeout] = null
|
|
|
|
|
|
|
|
socket[kIdleSocketValidation] = 2
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (client[kSocket] === socket && !socket.destroyed) {
|
|
|
|
|
|
|
|
client[kResume]()
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
}, 0)
|
|
|
|
|
|
|
|
socket[kIdleSocketValidationTimeout].unref?.()
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
|
|
|
* @param {import('./client.js')} client
|
|
|
|
|
|
|
|
*/
|
|
|
|
function resumeH1 (client) {
|
|
|
|
function resumeH1 (client) {
|
|
|
|
const socket = client[kSocket]
|
|
|
|
const socket = client[kSocket]
|
|
|
|
|
|
|
|
|
|
|
|
@ -29398,6 +29583,32 @@ function resumeH1 (client) {
|
|
|
|
socket[kNoRef] = false
|
|
|
|
socket[kNoRef] = false
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (client[kRunning] === 0 && client[kPending] > 0 && socket[kSocketUsed]) {
|
|
|
|
|
|
|
|
if (socket[kIdleSocketValidation] === 0) {
|
|
|
|
|
|
|
|
scheduleIdleSocketValidation(client, socket)
|
|
|
|
|
|
|
|
socket[kParser].readMore()
|
|
|
|
|
|
|
|
if (socket.destroyed) {
|
|
|
|
|
|
|
|
return
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
return
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (socket[kIdleSocketValidation] === 1) {
|
|
|
|
|
|
|
|
socket[kParser].readMore()
|
|
|
|
|
|
|
|
if (socket.destroyed) {
|
|
|
|
|
|
|
|
return
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
return
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (client[kRunning] === 0) {
|
|
|
|
|
|
|
|
socket[kParser].readMore()
|
|
|
|
|
|
|
|
if (socket.destroyed) {
|
|
|
|
|
|
|
|
return
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
if (client[kSize] === 0) {
|
|
|
|
if (client[kSize] === 0) {
|
|
|
|
if (socket[kParser].timeoutType !== TIMEOUT_KEEP_ALIVE) {
|
|
|
|
if (socket[kParser].timeoutType !== TIMEOUT_KEEP_ALIVE) {
|
|
|
|
socket[kParser].setTimeout(client[kKeepAliveTimeoutValue], TIMEOUT_KEEP_ALIVE)
|
|
|
|
socket[kParser].setTimeout(client[kKeepAliveTimeoutValue], TIMEOUT_KEEP_ALIVE)
|
|
|
|
@ -29491,6 +29702,7 @@ function writeH1 (client, request) {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
const socket = client[kSocket]
|
|
|
|
const socket = client[kSocket]
|
|
|
|
|
|
|
|
clearIdleSocketValidation(socket)
|
|
|
|
|
|
|
|
|
|
|
|
const abort = (err) => {
|
|
|
|
const abort = (err) => {
|
|
|
|
if (request.aborted || request.completed) {
|
|
|
|
if (request.aborted || request.completed) {
|
|
|
|
@ -30812,9 +31024,10 @@ class Client extends DispatcherBase {
|
|
|
|
autoSelectFamilyAttemptTimeout,
|
|
|
|
autoSelectFamilyAttemptTimeout,
|
|
|
|
// h2
|
|
|
|
// h2
|
|
|
|
maxConcurrentStreams,
|
|
|
|
maxConcurrentStreams,
|
|
|
|
allowH2
|
|
|
|
allowH2,
|
|
|
|
|
|
|
|
webSocket
|
|
|
|
} = {}) {
|
|
|
|
} = {}) {
|
|
|
|
super()
|
|
|
|
super({ webSocket })
|
|
|
|
|
|
|
|
|
|
|
|
if (keepAlive !== undefined) {
|
|
|
|
if (keepAlive !== undefined) {
|
|
|
|
throw new InvalidArgumentError('unsupported keepAlive, use pipelining=0 instead')
|
|
|
|
throw new InvalidArgumentError('unsupported keepAlive, use pipelining=0 instead')
|
|
|
|
@ -31347,15 +31560,24 @@ const { kDestroy, kClose, kClosed, kDestroyed, kDispatch, kInterceptors } = __nc
|
|
|
|
const kOnDestroyed = Symbol('onDestroyed')
|
|
|
|
const kOnDestroyed = Symbol('onDestroyed')
|
|
|
|
const kOnClosed = Symbol('onClosed')
|
|
|
|
const kOnClosed = Symbol('onClosed')
|
|
|
|
const kInterceptedDispatch = Symbol('Intercepted Dispatch')
|
|
|
|
const kInterceptedDispatch = Symbol('Intercepted Dispatch')
|
|
|
|
|
|
|
|
const kWebSocketOptions = Symbol('webSocketOptions')
|
|
|
|
|
|
|
|
|
|
|
|
class DispatcherBase extends Dispatcher {
|
|
|
|
class DispatcherBase extends Dispatcher {
|
|
|
|
constructor () {
|
|
|
|
constructor (opts) {
|
|
|
|
super()
|
|
|
|
super()
|
|
|
|
|
|
|
|
|
|
|
|
this[kDestroyed] = false
|
|
|
|
this[kDestroyed] = false
|
|
|
|
this[kOnDestroyed] = null
|
|
|
|
this[kOnDestroyed] = null
|
|
|
|
this[kClosed] = false
|
|
|
|
this[kClosed] = false
|
|
|
|
this[kOnClosed] = []
|
|
|
|
this[kOnClosed] = []
|
|
|
|
|
|
|
|
this[kWebSocketOptions] = opts?.webSocket ?? {}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
get webSocketOptions () {
|
|
|
|
|
|
|
|
return {
|
|
|
|
|
|
|
|
maxFragments: this[kWebSocketOptions].maxFragments ?? 131072,
|
|
|
|
|
|
|
|
maxPayloadSize: this[kWebSocketOptions].maxPayloadSize ?? 128 * 1024 * 1024
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
get destroyed () {
|
|
|
|
get destroyed () {
|
|
|
|
@ -31919,8 +32141,8 @@ const kRemoveClient = Symbol('remove client')
|
|
|
|
const kStats = Symbol('stats')
|
|
|
|
const kStats = Symbol('stats')
|
|
|
|
|
|
|
|
|
|
|
|
class PoolBase extends DispatcherBase {
|
|
|
|
class PoolBase extends DispatcherBase {
|
|
|
|
constructor () {
|
|
|
|
constructor (opts) {
|
|
|
|
super()
|
|
|
|
super(opts)
|
|
|
|
|
|
|
|
|
|
|
|
this[kQueue] = new FixedQueue()
|
|
|
|
this[kQueue] = new FixedQueue()
|
|
|
|
this[kClients] = []
|
|
|
|
this[kClients] = []
|
|
|
|
@ -32180,8 +32402,6 @@ class Pool extends PoolBase {
|
|
|
|
allowH2,
|
|
|
|
allowH2,
|
|
|
|
...options
|
|
|
|
...options
|
|
|
|
} = {}) {
|
|
|
|
} = {}) {
|
|
|
|
super()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (connections != null && (!Number.isFinite(connections) || connections < 0)) {
|
|
|
|
if (connections != null && (!Number.isFinite(connections) || connections < 0)) {
|
|
|
|
throw new InvalidArgumentError('invalid connections')
|
|
|
|
throw new InvalidArgumentError('invalid connections')
|
|
|
|
}
|
|
|
|
}
|
|
|
|
@ -32206,6 +32426,8 @@ class Pool extends PoolBase {
|
|
|
|
})
|
|
|
|
})
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
super(options)
|
|
|
|
|
|
|
|
|
|
|
|
this[kInterceptors] = options.interceptors?.Pool && Array.isArray(options.interceptors.Pool)
|
|
|
|
this[kInterceptors] = options.interceptors?.Pool && Array.isArray(options.interceptors.Pool)
|
|
|
|
? options.interceptors.Pool
|
|
|
|
? options.interceptors.Pool
|
|
|
|
: []
|
|
|
|
: []
|
|
|
|
@ -37290,32 +37512,25 @@ function parseUnparsedAttributes (unparsedAttributes, cookieAttributeList = {})
|
|
|
|
// If the attribute-name case-insensitively matches the string
|
|
|
|
// If the attribute-name case-insensitively matches the string
|
|
|
|
// "SameSite", the user agent MUST process the cookie-av as follows:
|
|
|
|
// "SameSite", the user agent MUST process the cookie-av as follows:
|
|
|
|
|
|
|
|
|
|
|
|
// 1. Let enforcement be "Default".
|
|
|
|
|
|
|
|
let enforcement = 'Default'
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const attributeValueLowercase = attributeValue.toLowerCase()
|
|
|
|
const attributeValueLowercase = attributeValue.toLowerCase()
|
|
|
|
// 2. If cookie-av's attribute-value is a case-insensitive match for
|
|
|
|
|
|
|
|
// "None", set enforcement to "None".
|
|
|
|
|
|
|
|
if (attributeValueLowercase.includes('none')) {
|
|
|
|
|
|
|
|
enforcement = 'None'
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 3. If cookie-av's attribute-value is a case-insensitive match for
|
|
|
|
|
|
|
|
// "Strict", set enforcement to "Strict".
|
|
|
|
|
|
|
|
if (attributeValueLowercase.includes('strict')) {
|
|
|
|
|
|
|
|
enforcement = 'Strict'
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 4. If cookie-av's attribute-value is a case-insensitive match for
|
|
|
|
// 1. If cookie-av's attribute-value is a case-insensitive match for
|
|
|
|
// "Lax", set enforcement to "Lax".
|
|
|
|
// "None", append an attribute to the cookie-attribute-list with an
|
|
|
|
if (attributeValueLowercase.includes('lax')) {
|
|
|
|
// attribute-name of "SameSite" and an attribute-value of "None".
|
|
|
|
enforcement = 'Lax'
|
|
|
|
if (attributeValueLowercase === 'none') {
|
|
|
|
|
|
|
|
cookieAttributeList.sameSite = 'None'
|
|
|
|
|
|
|
|
} else if (attributeValueLowercase === 'strict') {
|
|
|
|
|
|
|
|
// 2. If cookie-av's attribute-value is a case-insensitive match for
|
|
|
|
|
|
|
|
// "Strict", append an attribute to the cookie-attribute-list with
|
|
|
|
|
|
|
|
// an attribute-name of "SameSite" and an attribute-value of
|
|
|
|
|
|
|
|
// "Strict".
|
|
|
|
|
|
|
|
cookieAttributeList.sameSite = 'Strict'
|
|
|
|
|
|
|
|
} else if (attributeValueLowercase === 'lax') {
|
|
|
|
|
|
|
|
// 3. If cookie-av's attribute-value is a case-insensitive match for
|
|
|
|
|
|
|
|
// "Lax", append an attribute to the cookie-attribute-list with an
|
|
|
|
|
|
|
|
// attribute-name of "SameSite" and an attribute-value of "Lax".
|
|
|
|
|
|
|
|
cookieAttributeList.sameSite = 'Lax'
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// 5. Append an attribute to the cookie-attribute-list with an
|
|
|
|
|
|
|
|
// attribute-name of "SameSite" and an attribute-value of
|
|
|
|
|
|
|
|
// enforcement.
|
|
|
|
|
|
|
|
cookieAttributeList.sameSite = enforcement
|
|
|
|
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
cookieAttributeList.unparsed ??= []
|
|
|
|
cookieAttributeList.unparsed ??= []
|
|
|
|
|
|
|
|
|
|
|
|
@ -50021,40 +50236,35 @@ const tail = Buffer.from([0x00, 0x00, 0xff, 0xff])
|
|
|
|
const kBuffer = Symbol('kBuffer')
|
|
|
|
const kBuffer = Symbol('kBuffer')
|
|
|
|
const kLength = Symbol('kLength')
|
|
|
|
const kLength = Symbol('kLength')
|
|
|
|
|
|
|
|
|
|
|
|
// Default maximum decompressed message size: 4 MB
|
|
|
|
|
|
|
|
const kDefaultMaxDecompressedSize = 4 * 1024 * 1024
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
class PerMessageDeflate {
|
|
|
|
class PerMessageDeflate {
|
|
|
|
/** @type {import('node:zlib').InflateRaw} */
|
|
|
|
/** @type {import('node:zlib').InflateRaw} */
|
|
|
|
#inflate
|
|
|
|
#inflate
|
|
|
|
|
|
|
|
|
|
|
|
#options = {}
|
|
|
|
#options = {}
|
|
|
|
|
|
|
|
|
|
|
|
/** @type {boolean} */
|
|
|
|
#maxPayloadSize = 0
|
|
|
|
#aborted = false
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/** @type {Function|null} */
|
|
|
|
|
|
|
|
#currentCallback = null
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* @param {Map<string, string>} extensions
|
|
|
|
* @param {Map<string, string>} extensions
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
constructor (extensions) {
|
|
|
|
constructor (extensions, options) {
|
|
|
|
this.#options.serverNoContextTakeover = extensions.has('server_no_context_takeover')
|
|
|
|
this.#options.serverNoContextTakeover = extensions.has('server_no_context_takeover')
|
|
|
|
this.#options.serverMaxWindowBits = extensions.get('server_max_window_bits')
|
|
|
|
this.#options.serverMaxWindowBits = extensions.get('server_max_window_bits')
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
this.#maxPayloadSize = options.maxPayloadSize
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
|
|
|
* Decompress a compressed payload.
|
|
|
|
|
|
|
|
* @param {Buffer} chunk Compressed data
|
|
|
|
|
|
|
|
* @param {boolean} fin Final fragment flag
|
|
|
|
|
|
|
|
* @param {Function} callback Callback function
|
|
|
|
|
|
|
|
*/
|
|
|
|
decompress (chunk, fin, callback) {
|
|
|
|
decompress (chunk, fin, callback) {
|
|
|
|
// An endpoint uses the following algorithm to decompress a message.
|
|
|
|
// An endpoint uses the following algorithm to decompress a message.
|
|
|
|
// 1. Append 4 octets of 0x00 0x00 0xff 0xff to the tail end of the
|
|
|
|
// 1. Append 4 octets of 0x00 0x00 0xff 0xff to the tail end of the
|
|
|
|
// payload of the message.
|
|
|
|
// payload of the message.
|
|
|
|
// 2. Decompress the resulting data using DEFLATE.
|
|
|
|
// 2. Decompress the resulting data using DEFLATE.
|
|
|
|
|
|
|
|
|
|
|
|
if (this.#aborted) {
|
|
|
|
|
|
|
|
callback(new MessageSizeExceededError())
|
|
|
|
|
|
|
|
return
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (!this.#inflate) {
|
|
|
|
if (!this.#inflate) {
|
|
|
|
let windowBits = Z_DEFAULT_WINDOWBITS
|
|
|
|
let windowBits = Z_DEFAULT_WINDOWBITS
|
|
|
|
|
|
|
|
|
|
|
|
@ -50077,23 +50287,12 @@ class PerMessageDeflate {
|
|
|
|
this.#inflate[kLength] = 0
|
|
|
|
this.#inflate[kLength] = 0
|
|
|
|
|
|
|
|
|
|
|
|
this.#inflate.on('data', (data) => {
|
|
|
|
this.#inflate.on('data', (data) => {
|
|
|
|
if (this.#aborted) {
|
|
|
|
|
|
|
|
return
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
this.#inflate[kLength] += data.length
|
|
|
|
this.#inflate[kLength] += data.length
|
|
|
|
|
|
|
|
|
|
|
|
if (this.#inflate[kLength] > kDefaultMaxDecompressedSize) {
|
|
|
|
if (this.#maxPayloadSize > 0 && this.#inflate[kLength] > this.#maxPayloadSize) {
|
|
|
|
this.#aborted = true
|
|
|
|
callback(new MessageSizeExceededError())
|
|
|
|
this.#inflate.removeAllListeners()
|
|
|
|
this.#inflate.removeAllListeners()
|
|
|
|
this.#inflate.destroy()
|
|
|
|
|
|
|
|
this.#inflate = null
|
|
|
|
this.#inflate = null
|
|
|
|
|
|
|
|
|
|
|
|
if (this.#currentCallback) {
|
|
|
|
|
|
|
|
const cb = this.#currentCallback
|
|
|
|
|
|
|
|
this.#currentCallback = null
|
|
|
|
|
|
|
|
cb(new MessageSizeExceededError())
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
return
|
|
|
|
return
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@ -50106,14 +50305,13 @@ class PerMessageDeflate {
|
|
|
|
})
|
|
|
|
})
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
this.#currentCallback = callback
|
|
|
|
|
|
|
|
this.#inflate.write(chunk)
|
|
|
|
this.#inflate.write(chunk)
|
|
|
|
if (fin) {
|
|
|
|
if (fin) {
|
|
|
|
this.#inflate.write(tail)
|
|
|
|
this.#inflate.write(tail)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
this.#inflate.flush(() => {
|
|
|
|
this.#inflate.flush(() => {
|
|
|
|
if (this.#aborted || !this.#inflate) {
|
|
|
|
if (!this.#inflate) {
|
|
|
|
return
|
|
|
|
return
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@ -50121,7 +50319,6 @@ class PerMessageDeflate {
|
|
|
|
|
|
|
|
|
|
|
|
this.#inflate[kBuffer].length = 0
|
|
|
|
this.#inflate[kBuffer].length = 0
|
|
|
|
this.#inflate[kLength] = 0
|
|
|
|
this.#inflate[kLength] = 0
|
|
|
|
this.#currentCallback = null
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
callback(null, full)
|
|
|
|
callback(null, full)
|
|
|
|
})
|
|
|
|
})
|
|
|
|
@ -50157,6 +50354,12 @@ const {
|
|
|
|
const { WebsocketFrameSend } = __nccwpck_require__(3264)
|
|
|
|
const { WebsocketFrameSend } = __nccwpck_require__(3264)
|
|
|
|
const { closeWebSocketConnection } = __nccwpck_require__(86897)
|
|
|
|
const { closeWebSocketConnection } = __nccwpck_require__(86897)
|
|
|
|
const { PerMessageDeflate } = __nccwpck_require__(19469)
|
|
|
|
const { PerMessageDeflate } = __nccwpck_require__(19469)
|
|
|
|
|
|
|
|
const { MessageSizeExceededError } = __nccwpck_require__(68707)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
function failWebsocketConnectionWithCode (ws, code, reason) {
|
|
|
|
|
|
|
|
closeWebSocketConnection(ws, code, reason, Buffer.byteLength(reason))
|
|
|
|
|
|
|
|
failWebsocketConnection(ws, reason)
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// This code was influenced by ws released under the MIT license.
|
|
|
|
// This code was influenced by ws released under the MIT license.
|
|
|
|
// Copyright (c) 2011 Einar Otto Stangvik <einaros@gmail.com>
|
|
|
|
// Copyright (c) 2011 Einar Otto Stangvik <einaros@gmail.com>
|
|
|
|
@ -50165,6 +50368,7 @@ const { PerMessageDeflate } = __nccwpck_require__(19469)
|
|
|
|
|
|
|
|
|
|
|
|
class ByteParser extends Writable {
|
|
|
|
class ByteParser extends Writable {
|
|
|
|
#buffers = []
|
|
|
|
#buffers = []
|
|
|
|
|
|
|
|
#fragmentsBytes = 0
|
|
|
|
#byteOffset = 0
|
|
|
|
#byteOffset = 0
|
|
|
|
#loop = false
|
|
|
|
#loop = false
|
|
|
|
|
|
|
|
|
|
|
|
@ -50176,18 +50380,27 @@ class ByteParser extends Writable {
|
|
|
|
/** @type {Map<string, PerMessageDeflate>} */
|
|
|
|
/** @type {Map<string, PerMessageDeflate>} */
|
|
|
|
#extensions
|
|
|
|
#extensions
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/** @type {number} */
|
|
|
|
|
|
|
|
#maxFragments
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/** @type {number} */
|
|
|
|
|
|
|
|
#maxPayloadSize
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* @param {import('./websocket').WebSocket} ws
|
|
|
|
* @param {import('./websocket').WebSocket} ws
|
|
|
|
* @param {Map<string, string>|null} extensions
|
|
|
|
* @param {Map<string, string>|null} extensions
|
|
|
|
|
|
|
|
* @param {{ maxFragments?: number, maxPayloadSize?: number }} [options]
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
constructor (ws, extensions) {
|
|
|
|
constructor (ws, extensions, options = {}) {
|
|
|
|
super()
|
|
|
|
super()
|
|
|
|
|
|
|
|
|
|
|
|
this.ws = ws
|
|
|
|
this.ws = ws
|
|
|
|
this.#extensions = extensions == null ? new Map() : extensions
|
|
|
|
this.#extensions = extensions == null ? new Map() : extensions
|
|
|
|
|
|
|
|
this.#maxFragments = options.maxFragments ?? 0
|
|
|
|
|
|
|
|
this.#maxPayloadSize = options.maxPayloadSize ?? 0
|
|
|
|
|
|
|
|
|
|
|
|
if (this.#extensions.has('permessage-deflate')) {
|
|
|
|
if (this.#extensions.has('permessage-deflate')) {
|
|
|
|
this.#extensions.set('permessage-deflate', new PerMessageDeflate(extensions))
|
|
|
|
this.#extensions.set('permessage-deflate', new PerMessageDeflate(extensions, options))
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@ -50203,6 +50416,19 @@ class ByteParser extends Writable {
|
|
|
|
this.run(callback)
|
|
|
|
this.run(callback)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
#validatePayloadLength () {
|
|
|
|
|
|
|
|
if (
|
|
|
|
|
|
|
|
this.#maxPayloadSize > 0 &&
|
|
|
|
|
|
|
|
!isControlFrame(this.#info.opcode) &&
|
|
|
|
|
|
|
|
this.#info.payloadLength + this.#fragmentsBytes > this.#maxPayloadSize
|
|
|
|
|
|
|
|
) {
|
|
|
|
|
|
|
|
failWebsocketConnectionWithCode(this.ws, 1009, 'Payload size exceeds maximum allowed size')
|
|
|
|
|
|
|
|
return false
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return true
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* Runs whenever a new chunk is received.
|
|
|
|
* Runs whenever a new chunk is received.
|
|
|
|
* Callback is called whenever there are no more chunks buffering,
|
|
|
|
* Callback is called whenever there are no more chunks buffering,
|
|
|
|
@ -50291,6 +50517,10 @@ class ByteParser extends Writable {
|
|
|
|
if (payloadLength <= 125) {
|
|
|
|
if (payloadLength <= 125) {
|
|
|
|
this.#info.payloadLength = payloadLength
|
|
|
|
this.#info.payloadLength = payloadLength
|
|
|
|
this.#state = parserStates.READ_DATA
|
|
|
|
this.#state = parserStates.READ_DATA
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (!this.#validatePayloadLength()) {
|
|
|
|
|
|
|
|
return
|
|
|
|
|
|
|
|
}
|
|
|
|
} else if (payloadLength === 126) {
|
|
|
|
} else if (payloadLength === 126) {
|
|
|
|
this.#state = parserStates.PAYLOADLENGTH_16
|
|
|
|
this.#state = parserStates.PAYLOADLENGTH_16
|
|
|
|
} else if (payloadLength === 127) {
|
|
|
|
} else if (payloadLength === 127) {
|
|
|
|
@ -50315,6 +50545,10 @@ class ByteParser extends Writable {
|
|
|
|
|
|
|
|
|
|
|
|
this.#info.payloadLength = buffer.readUInt16BE(0)
|
|
|
|
this.#info.payloadLength = buffer.readUInt16BE(0)
|
|
|
|
this.#state = parserStates.READ_DATA
|
|
|
|
this.#state = parserStates.READ_DATA
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (!this.#validatePayloadLength()) {
|
|
|
|
|
|
|
|
return
|
|
|
|
|
|
|
|
}
|
|
|
|
} else if (this.#state === parserStates.PAYLOADLENGTH_64) {
|
|
|
|
} else if (this.#state === parserStates.PAYLOADLENGTH_64) {
|
|
|
|
if (this.#byteOffset < 8) {
|
|
|
|
if (this.#byteOffset < 8) {
|
|
|
|
return callback()
|
|
|
|
return callback()
|
|
|
|
@ -50337,6 +50571,10 @@ class ByteParser extends Writable {
|
|
|
|
|
|
|
|
|
|
|
|
this.#info.payloadLength = lower
|
|
|
|
this.#info.payloadLength = lower
|
|
|
|
this.#state = parserStates.READ_DATA
|
|
|
|
this.#state = parserStates.READ_DATA
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (!this.#validatePayloadLength()) {
|
|
|
|
|
|
|
|
return
|
|
|
|
|
|
|
|
}
|
|
|
|
} else if (this.#state === parserStates.READ_DATA) {
|
|
|
|
} else if (this.#state === parserStates.READ_DATA) {
|
|
|
|
if (this.#byteOffset < this.#info.payloadLength) {
|
|
|
|
if (this.#byteOffset < this.#info.payloadLength) {
|
|
|
|
return callback()
|
|
|
|
return callback()
|
|
|
|
@ -50349,42 +50587,58 @@ class ByteParser extends Writable {
|
|
|
|
this.#state = parserStates.INFO
|
|
|
|
this.#state = parserStates.INFO
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
if (!this.#info.compressed) {
|
|
|
|
if (!this.#info.compressed) {
|
|
|
|
this.#fragments.push(body)
|
|
|
|
if (!this.writeFragments(body)) {
|
|
|
|
|
|
|
|
return
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (this.#maxPayloadSize > 0 && this.#fragmentsBytes > this.#maxPayloadSize) {
|
|
|
|
|
|
|
|
failWebsocketConnectionWithCode(this.ws, 1009, new MessageSizeExceededError().message)
|
|
|
|
|
|
|
|
return
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// If the frame is not fragmented, a message has been received.
|
|
|
|
// If the frame is not fragmented, a message has been received.
|
|
|
|
// If the frame is fragmented, it will terminate with a fin bit set
|
|
|
|
// If the frame is fragmented, it will terminate with a fin bit set
|
|
|
|
// and an opcode of 0 (continuation), therefore we handle that when
|
|
|
|
// and an opcode of 0 (continuation), therefore we handle that when
|
|
|
|
// parsing continuation frames, not here.
|
|
|
|
// parsing continuation frames, not here.
|
|
|
|
if (!this.#info.fragmented && this.#info.fin) {
|
|
|
|
if (!this.#info.fragmented && this.#info.fin) {
|
|
|
|
const fullMessage = Buffer.concat(this.#fragments)
|
|
|
|
websocketMessageReceived(this.ws, this.#info.binaryType, this.consumeFragments())
|
|
|
|
websocketMessageReceived(this.ws, this.#info.binaryType, fullMessage)
|
|
|
|
|
|
|
|
this.#fragments.length = 0
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
this.#state = parserStates.INFO
|
|
|
|
this.#state = parserStates.INFO
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
this.#extensions.get('permessage-deflate').decompress(body, this.#info.fin, (error, data) => {
|
|
|
|
this.#extensions.get('permessage-deflate').decompress(
|
|
|
|
if (error) {
|
|
|
|
body,
|
|
|
|
failWebsocketConnection(this.ws, error.message)
|
|
|
|
this.#info.fin,
|
|
|
|
return
|
|
|
|
(error, data) => {
|
|
|
|
}
|
|
|
|
if (error) {
|
|
|
|
|
|
|
|
const code = error instanceof MessageSizeExceededError ? 1009 : 1007
|
|
|
|
|
|
|
|
failWebsocketConnectionWithCode(this.ws, code, error.message)
|
|
|
|
|
|
|
|
return
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
this.#fragments.push(data)
|
|
|
|
if (!this.writeFragments(data)) {
|
|
|
|
|
|
|
|
return
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (this.#maxPayloadSize > 0 && this.#fragmentsBytes > this.#maxPayloadSize) {
|
|
|
|
|
|
|
|
failWebsocketConnectionWithCode(this.ws, 1009, new MessageSizeExceededError().message)
|
|
|
|
|
|
|
|
return
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (!this.#info.fin) {
|
|
|
|
|
|
|
|
this.#state = parserStates.INFO
|
|
|
|
|
|
|
|
this.#loop = true
|
|
|
|
|
|
|
|
this.run(callback)
|
|
|
|
|
|
|
|
return
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
websocketMessageReceived(this.ws, this.#info.binaryType, this.consumeFragments())
|
|
|
|
|
|
|
|
|
|
|
|
if (!this.#info.fin) {
|
|
|
|
|
|
|
|
this.#state = parserStates.INFO
|
|
|
|
|
|
|
|
this.#loop = true
|
|
|
|
this.#loop = true
|
|
|
|
|
|
|
|
this.#state = parserStates.INFO
|
|
|
|
this.run(callback)
|
|
|
|
this.run(callback)
|
|
|
|
return
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
)
|
|
|
|
websocketMessageReceived(this.ws, this.#info.binaryType, Buffer.concat(this.#fragments))
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
this.#loop = true
|
|
|
|
|
|
|
|
this.#state = parserStates.INFO
|
|
|
|
|
|
|
|
this.#fragments.length = 0
|
|
|
|
|
|
|
|
this.run(callback)
|
|
|
|
|
|
|
|
})
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
this.#loop = false
|
|
|
|
this.#loop = false
|
|
|
|
break
|
|
|
|
break
|
|
|
|
@ -50436,6 +50690,35 @@ class ByteParser extends Writable {
|
|
|
|
return buffer
|
|
|
|
return buffer
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
writeFragments (fragment) {
|
|
|
|
|
|
|
|
if (
|
|
|
|
|
|
|
|
this.#maxFragments > 0 &&
|
|
|
|
|
|
|
|
this.#fragments.length === this.#maxFragments
|
|
|
|
|
|
|
|
) {
|
|
|
|
|
|
|
|
failWebsocketConnectionWithCode(this.ws, 1008, 'Too many message fragments')
|
|
|
|
|
|
|
|
return false
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
this.#fragmentsBytes += fragment.length
|
|
|
|
|
|
|
|
this.#fragments.push(fragment)
|
|
|
|
|
|
|
|
return true
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
consumeFragments () {
|
|
|
|
|
|
|
|
const fragments = this.#fragments
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (fragments.length === 1) {
|
|
|
|
|
|
|
|
this.#fragmentsBytes = 0
|
|
|
|
|
|
|
|
return fragments.shift()
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const output = Buffer.concat(fragments, this.#fragmentsBytes)
|
|
|
|
|
|
|
|
this.#fragments = []
|
|
|
|
|
|
|
|
this.#fragmentsBytes = 0
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return output
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
parseCloseBody (data) {
|
|
|
|
parseCloseBody (data) {
|
|
|
|
assert(data.length !== 1)
|
|
|
|
assert(data.length !== 1)
|
|
|
|
|
|
|
|
|
|
|
|
@ -51471,7 +51754,14 @@ class WebSocket extends EventTarget {
|
|
|
|
// once this happens, the connection is open
|
|
|
|
// once this happens, the connection is open
|
|
|
|
this[kResponse] = response
|
|
|
|
this[kResponse] = response
|
|
|
|
|
|
|
|
|
|
|
|
const parser = new ByteParser(this, parsedExtensions)
|
|
|
|
const webSocketOptions = this[kController]?.dispatcher?.webSocketOptions
|
|
|
|
|
|
|
|
const maxFragments = webSocketOptions?.maxFragments
|
|
|
|
|
|
|
|
const maxPayloadSize = webSocketOptions?.maxPayloadSize
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const parser = new ByteParser(this, parsedExtensions, {
|
|
|
|
|
|
|
|
maxFragments,
|
|
|
|
|
|
|
|
maxPayloadSize
|
|
|
|
|
|
|
|
})
|
|
|
|
parser.on('drain', onParserDrain)
|
|
|
|
parser.on('drain', onParserDrain)
|
|
|
|
parser.on('error', onParserError.bind(this))
|
|
|
|
parser.on('error', onParserError.bind(this))
|
|
|
|
|
|
|
|
|
|
|
|
|