diff --git a/deps/undici/src/README.md b/deps/undici/src/README.md index 5acff95e270088..b7a5ef1acd45a8 100644 --- a/deps/undici/src/README.md +++ b/deps/undici/src/README.md @@ -198,7 +198,7 @@ You can pass an optional dispatcher to `fetch` as: ```js import { fetch, Agent } from 'undici' - + const res = await fetch('https://example.com', { // Mocks are also supported dispatcher: new Agent({ @@ -375,6 +375,7 @@ Refs: https://fetch.spec.whatwg.org/#atomic-http-redirect-handling * [__Daniele Belardi__](https://github.com/dnlup), * [__Ethan Arrowood__](https://github.com/ethan-arrowood), * [__Matteo Collina__](https://github.com/mcollina), +* [__Matthew Aitken__](https://github.com/KhafraDev), * [__Robert Nagy__](https://github.com/ronag), * [__Szymon Marczak__](https://github.com/szmarczak), * [__Tomas Della Vedova__](https://github.com/delvedor), diff --git a/deps/undici/src/docs/api/Dispatcher.md b/deps/undici/src/docs/api/Dispatcher.md index 56b34275209150..ffe72cceb1b7b1 100644 --- a/deps/undici/src/docs/api/Dispatcher.md +++ b/deps/undici/src/docs/api/Dispatcher.md @@ -194,18 +194,20 @@ Returns: `Boolean` - `false` if dispatcher is busy and further dispatch calls wo * **method** `string` * **body** `string | Buffer | Uint8Array | stream.Readable | Iterable | AsyncIterable | null` (optional) - Default: `null` * **headers** `UndiciHeaders | string[]` (optional) - Default: `null`. +* **query** `Record | null` (optional) - Default: `null` - Query string params to be embedded in the request URL. Note that both keys and values of query are encoded using `encodeURIComponent`. If for some reason you need to send them unencoded, embed query params into path directly instead. * **idempotent** `boolean` (optional) - Default: `true` if `method` is `'HEAD'` or `'GET'` - Whether the requests can be safely retried or not. If `false` the request won't be sent until all preceding requests in the pipeline has completed. * **blocking** `boolean` (optional) - Default: `false` - Whether the response is expected to take a long time and would end up blocking the pipeline. When this is set to `true` further pipelining will be avoided on the same connection until headers have been received. * **upgrade** `string | null` (optional) - Default: `null` - Upgrade the request. Should be used to specify the kind of upgrade i.e. `'Websocket'`. * **bodyTimeout** `number | null` (optional) - The timeout after which a request will time out, in milliseconds. Monitors time between receiving body data. Use `0` to disable it entirely. Defaults to 30 seconds. * **headersTimeout** `number | null` (optional) - The amount of time the parser will wait to receive the complete HTTP headers. Defaults to 30 seconds. +* **throwOnError** `boolean` (optional) - Default: `false` - Whether Undici should throw an error upon receiving a 4xx or 5xx response from the server. #### Parameter: `DispatchHandler` * **onConnect** `(abort: () => void, context: object) => void` - Invoked before request is dispatched on socket. May be invoked multiple times when a request is retried when the request at the head of the pipeline fails. * **onError** `(error: Error) => void` - Invoked when an error has occurred. May not throw. * **onUpgrade** `(statusCode: number, headers: Buffer[], socket: Duplex) => void` (optional) - Invoked when request is upgraded. Required if `DispatchOptions.upgrade` is defined or `DispatchOptions.method === 'CONNECT'`. -* **onHeaders** `(statusCode: number, headers: Buffer[], resume: () => void) => boolean` - Invoked when statusCode and headers have been received. May be invoked multiple times due to 1xx informational headers. Not required for `upgrade` requests. +* **onHeaders** `(statusCode: number, headers: Buffer[], resume: () => void, statusText: string) => boolean` - Invoked when statusCode and headers have been received. May be invoked multiple times due to 1xx informational headers. Not required for `upgrade` requests. * **onData** `(chunk: Buffer) => boolean` - Invoked when response payload data is received. Not required for `upgrade` requests. * **onComplete** `(trailers: Buffer[]) => void` - Invoked when response payload and trailers have been received and the request has completed. Not required for `upgrade` requests. * **onBodySent** `(chunk: string | Buffer | Uint8Array) => void` - Invoked when a body chunk is sent to the server. Not required. For a stream or iterable body this will be invoked for every chunk. For other body types, it will be invoked once after the body is sent. diff --git a/deps/undici/src/docs/best-practices/mocking-request.md b/deps/undici/src/docs/best-practices/mocking-request.md index ebcc90d24b765f..b98a450a32e29b 100644 --- a/deps/undici/src/docs/best-practices/mocking-request.md +++ b/deps/undici/src/docs/best-practices/mocking-request.md @@ -101,4 +101,36 @@ const badRequest = await bankTransfer('1234567890', '100') // subsequent request to origin http://localhost:3000 was not allowed (net.connect disabled) ``` +## Reply with data based on request +If the mocked response needs to be dynamically derived from the request parameters, you can provide a function instead of an object to `reply` + +```js +mockPool.intercept({ + path: '/bank-transfer', + method: 'POST', + headers: { + 'X-TOKEN-SECRET': 'SuperSecretToken', + }, + body: JSON.stringify({ + recepient: '1234567890', + amount: '100' + }) +}).reply(200, (opts) => { + // do something with opts + + return { message: 'transaction processed' } +}) +``` + +in this case opts will be + +``` +{ + method: 'POST', + headers: { 'X-TOKEN-SECRET': 'SuperSecretToken' }, + body: '{"recepient":"1234567890","amount":"100"}', + origin: 'http://localhost:3000', + path: '/bank-transfer' +} +``` diff --git a/deps/undici/src/index.d.ts b/deps/undici/src/index.d.ts index 44ab285041f3d9..e4aa8f62cdbc42 100644 --- a/deps/undici/src/index.d.ts +++ b/deps/undici/src/index.d.ts @@ -16,6 +16,7 @@ import { request, pipeline, stream, connect, upgrade } from './types/api' export * from './types/fetch' export * from './types/file' export * from './types/formdata' +export * from './types/diagnostics-channel' export { Interceptable } from './types/mock-interceptor' export { Dispatcher, BalancedPool, Pool, Client, buildConnector, errors, Agent, request, stream, pipeline, connect, upgrade, setGlobalDispatcher, getGlobalDispatcher, MockClient, MockPool, MockAgent, mockErrors, ProxyAgent } diff --git a/deps/undici/src/lib/api/api-request.js b/deps/undici/src/lib/api/api-request.js index bcfe483ebef7ac..2fc5afa991ca48 100644 --- a/deps/undici/src/lib/api/api-request.js +++ b/deps/undici/src/lib/api/api-request.js @@ -3,7 +3,8 @@ const Readable = require('./readable') const { InvalidArgumentError, - RequestAbortedError + RequestAbortedError, + ResponseStatusCodeError } = require('../core/errors') const util = require('../core/util') const { AsyncResource } = require('async_hooks') @@ -15,7 +16,7 @@ class RequestHandler extends AsyncResource { throw new InvalidArgumentError('invalid opts') } - const { signal, method, opaque, body, onInfo, responseHeaders } = opts + const { signal, method, opaque, body, onInfo, responseHeaders, throwOnError } = opts try { if (typeof callback !== 'function') { @@ -51,6 +52,7 @@ class RequestHandler extends AsyncResource { this.trailers = {} this.context = null this.onInfo = onInfo || null + this.throwOnError = throwOnError if (util.isStream(body)) { body.on('error', (err) => { @@ -70,7 +72,7 @@ class RequestHandler extends AsyncResource { this.context = context } - onHeaders (statusCode, rawHeaders, resume) { + onHeaders (statusCode, rawHeaders, resume, statusMessage) { const { callback, opaque, abort, context } = this if (statusCode < 200) { @@ -89,6 +91,13 @@ class RequestHandler extends AsyncResource { const headers = this.responseHeaders === 'raw' ? util.parseRawHeaders(rawHeaders) : util.parseHeaders(rawHeaders) if (callback !== null) { + if (this.throwOnError && statusCode >= 400) { + this.runInAsyncScope(callback, null, + new ResponseStatusCodeError(`Response status code ${statusCode}${statusMessage ? `: ${statusMessage}` : ''}`, statusCode, headers) + ) + return + } + this.runInAsyncScope(callback, null, null, { statusCode, headers, diff --git a/deps/undici/src/lib/core/errors.js b/deps/undici/src/lib/core/errors.js index f480f31a176acf..a36fd067c9f884 100644 --- a/deps/undici/src/lib/core/errors.js +++ b/deps/undici/src/lib/core/errors.js @@ -56,6 +56,19 @@ class BodyTimeoutError extends UndiciError { } } +class ResponseStatusCodeError extends UndiciError { + constructor (message, statusCode, headers) { + super(message) + Error.captureStackTrace(this, ResponseStatusCodeError) + this.name = 'ResponseStatusCodeError' + this.message = message || 'Response Status Code Error' + this.code = 'UND_ERR_RESPONSE_STATUS_CODE' + this.status = statusCode + this.statusCode = statusCode + this.headers = headers + } +} + class InvalidArgumentError extends UndiciError { constructor (message) { super(message) @@ -186,6 +199,7 @@ module.exports = { BodyTimeoutError, RequestContentLengthMismatchError, ConnectTimeoutError, + ResponseStatusCodeError, InvalidArgumentError, InvalidReturnValueError, RequestAbortedError, diff --git a/deps/undici/src/lib/core/request.js b/deps/undici/src/lib/core/request.js index f04fe4fab21d4a..2a13b0549a80ff 100644 --- a/deps/undici/src/lib/core/request.js +++ b/deps/undici/src/lib/core/request.js @@ -4,8 +4,8 @@ const { InvalidArgumentError, NotSupportedError } = require('./errors') -const util = require('./util') const assert = require('assert') +const util = require('./util') const kHandler = Symbol('handler') @@ -38,11 +38,13 @@ class Request { method, body, headers, + query, idempotent, blocking, upgrade, headersTimeout, - bodyTimeout + bodyTimeout, + throwOnError }, handler) { if (typeof path !== 'string') { throw new InvalidArgumentError('path must be a string') @@ -70,6 +72,8 @@ class Request { this.bodyTimeout = bodyTimeout + this.throwOnError = throwOnError === true + this.method = method if (body == null) { @@ -97,7 +101,7 @@ class Request { this.upgrade = upgrade || null - this.path = path + this.path = query ? util.buildURL(path, query) : path this.origin = origin diff --git a/deps/undici/src/lib/core/util.js b/deps/undici/src/lib/core/util.js index 0cb60b0d2a4618..635ef2e15f2a8d 100644 --- a/deps/undici/src/lib/core/util.js +++ b/deps/undici/src/lib/core/util.js @@ -26,6 +26,51 @@ function isBlobLike (object) { ) } +function isObject (val) { + return val !== null && typeof val === 'object' +} + +// this escapes all non-uri friendly characters +function encode (val) { + return encodeURIComponent(val) +} + +// based on https://github.com/axios/axios/blob/63e559fa609c40a0a460ae5d5a18c3470ffc6c9e/lib/helpers/buildURL.js (MIT license) +function buildURL (url, queryParams) { + if (url.includes('?') || url.includes('#')) { + throw new Error('Query params cannot be passed when url already contains "?" or "#".') + } + if (!isObject(queryParams)) { + throw new Error('Query params must be an object') + } + + const parts = [] + for (let [key, val] of Object.entries(queryParams)) { + if (val === null || typeof val === 'undefined') { + continue + } + + if (!Array.isArray(val)) { + val = [val] + } + + for (const v of val) { + if (isObject(v)) { + throw new Error('Passing object as a query param is not supported, please serialize to string up-front') + } + parts.push(encode(key) + '=' + encode(v)) + } + } + + const serializedParams = parts.join('&') + + if (serializedParams) { + url += '?' + serializedParams + } + + return url +} + function parseURL (url) { if (typeof url === 'string') { url = new URL(url) @@ -357,5 +402,6 @@ module.exports = { isBuffer, validateHandler, getSocketInfo, - isFormDataLike + isFormDataLike, + buildURL } diff --git a/deps/undici/src/lib/fetch/file.js b/deps/undici/src/lib/fetch/file.js index 2b98739d2bbff4..a9c2355fc89a3b 100644 --- a/deps/undici/src/lib/fetch/file.js +++ b/deps/undici/src/lib/fetch/file.js @@ -69,10 +69,6 @@ class File extends Blob { } get [Symbol.toStringTag] () { - if (!(this instanceof File)) { - throw new TypeError('Illegal invocation') - } - return this.constructor.name } } @@ -190,10 +186,6 @@ class FileLike { } get [Symbol.toStringTag] () { - if (!(this instanceof FileLike)) { - throw new TypeError('Illegal invocation') - } - return 'File' } } diff --git a/deps/undici/src/lib/fetch/formdata.js b/deps/undici/src/lib/fetch/formdata.js index 550e1e469479fe..e12d2b42bd2fbd 100644 --- a/deps/undici/src/lib/fetch/formdata.js +++ b/deps/undici/src/lib/fetch/formdata.js @@ -6,6 +6,8 @@ const { File, FileLike } = require('./file') const { Blob } = require('buffer') class FormData { + static name = 'FormData' + constructor (...args) { if (args.length > 0 && !(args[0]?.constructor?.name === 'HTMLFormElement')) { throw new TypeError( @@ -182,10 +184,6 @@ class FormData { } get [Symbol.toStringTag] () { - if (!(this instanceof FormData)) { - throw new TypeError('Illegal invocation') - } - return this.constructor.name } @@ -269,4 +267,4 @@ function makeEntry (name, value, filename) { return entry } -module.exports = { FormData: globalThis.FormData ?? FormData } +module.exports = { FormData } diff --git a/deps/undici/src/lib/fetch/index.js b/deps/undici/src/lib/fetch/index.js index 5dab8a0532fcf5..c1f3391995e357 100644 --- a/deps/undici/src/lib/fetch/index.js +++ b/deps/undici/src/lib/fetch/index.js @@ -31,7 +31,6 @@ const { coarsenedSharedCurrentTime, createDeferredPromise, isBlobLike, - CORBCheck, sameOrigin, isCancelled, isAborted @@ -52,7 +51,6 @@ const EE = require('events') const { Readable, pipeline } = require('stream') const { isErrored, isReadable } = require('../core/util') const { dataURLProcessor } = require('./dataURL') -const { kIsMockActive } = require('../mock/mock-symbols') const { TransformStream } = require('stream/web') /** @type {import('buffer').resolveObjectURL} */ @@ -588,18 +586,8 @@ async function mainFetch (fetchParams, recursive = false) { // 2. Set request’s response tainting to "opaque". request.responseTainting = 'opaque' - // 3. Let noCorsResponse be the result of running scheme fetch given - // fetchParams. - const noCorsResponse = await schemeFetch(fetchParams) - - // 4. If noCorsResponse is a filtered response or the CORB check with - // request and noCorsResponse returns allowed, then return noCorsResponse. - if (noCorsResponse.status === 0 || CORBCheck(request, noCorsResponse) === 'allowed') { - return noCorsResponse - } - - // 5. Return a new response whose status is noCorsResponse’s status. - return makeResponse({ status: noCorsResponse.status }) + // 3. Return the result of running scheme fetch given fetchParams. + return await schemeFetch(fetchParams) } // request’s current URL’s scheme is not an HTTP(S) scheme @@ -1923,7 +1911,7 @@ async function httpNetworkFetch ( path: url.pathname + url.search, origin: url.origin, method: request.method, - body: fetchParams.controller.dispatcher[kIsMockActive] ? request.body && request.body.source : body, + body: fetchParams.controller.dispatcher.isMockActive ? request.body && request.body.source : body, headers: [...request.headersList].flat(), maxRedirections: 0, bodyTimeout: 300_000, diff --git a/deps/undici/src/lib/fetch/request.js b/deps/undici/src/lib/fetch/request.js index c17927ee768a39..661f5814ba27f6 100644 --- a/deps/undici/src/lib/fetch/request.js +++ b/deps/undici/src/lib/fetch/request.js @@ -516,10 +516,6 @@ class Request { } get [Symbol.toStringTag] () { - if (!(this instanceof Request)) { - throw new TypeError('Illegal invocation') - } - return this.constructor.name } diff --git a/deps/undici/src/lib/fetch/response.js b/deps/undici/src/lib/fetch/response.js index b8aa4897c1bf3c..03db7eb488ed4d 100644 --- a/deps/undici/src/lib/fetch/response.js +++ b/deps/undici/src/lib/fetch/response.js @@ -5,7 +5,7 @@ const { AbortError } = require('../core/errors') const { extractBody, cloneBody, mixinBody } = require('./body') const util = require('../core/util') const { kEnumerableProperty } = util -const { responseURL, isValidReasonPhrase, toUSVString, isCancelled, isAborted } = require('./util') +const { responseURL, isValidReasonPhrase, toUSVString, isCancelled, isAborted, serializeJavascriptValueToJSONString } = require('./util') const { redirectStatus, nullBodyStatus, @@ -35,6 +35,50 @@ class Response { return responseObject } + // https://fetch.spec.whatwg.org/#dom-response-json + static json (data, init = {}) { + if (arguments.length === 0) { + throw new TypeError( + 'Failed to execute \'json\' on \'Response\': 1 argument required, but 0 present.' + ) + } + + if (init === null || typeof init !== 'object') { + throw new TypeError( + `Failed to execute 'json' on 'Response': init must be a RequestInit, found ${typeof init}.` + ) + } + + init = { + status: 200, + statusText: '', + headers: new HeadersList(), + ...init + } + + // 1. Let bytes the result of running serialize a JavaScript value to JSON bytes on data. + const bytes = new TextEncoder('utf-8').encode( + serializeJavascriptValueToJSONString(data) + ) + + // 2. Let body be the result of extracting bytes. + const body = extractBody(bytes) + + // 3. Let responseObject be the result of creating a Response object, given a new response, + // "response", and this’s relevant Realm. + const relevantRealm = { settingsObject: {} } + const responseObject = new Response() + responseObject[kRealm] = relevantRealm + responseObject[kHeaders][kGuard] = 'response' + responseObject[kHeaders][kRealm] = relevantRealm + + // 4. Perform initialize a response given responseObject, init, and (body, "application/json"). + initializeResponse(responseObject, init, { body: body[0], type: 'application/json' }) + + // 5. Return responseObject. + return responseObject + } + // Creates a redirect Response that redirects to url with status status. static redirect (...args) { const relevantRealm = { settingsObject: {} } @@ -105,34 +149,10 @@ class Response { // TODO this[kRealm] = { settingsObject: {} } - // 1. If init["status"] is not in the range 200 to 599, inclusive, then - // throw a RangeError. - if ('status' in init && init.status !== undefined) { - if (!Number.isFinite(init.status)) { - throw new TypeError() - } - - if (init.status < 200 || init.status > 599) { - throw new RangeError( - `Failed to construct 'Response': The status provided (${init.status}) is outside the range [200, 599].` - ) - } - } - - if ('statusText' in init && init.statusText !== undefined) { - // 2. If init["statusText"] does not match the reason-phrase token - // production, then throw a TypeError. - // See, https://datatracker.ietf.org/doc/html/rfc7230#section-3.1.2: - // reason-phrase = *( HTAB / SP / VCHAR / obs-text ) - if (!isValidReasonPhrase(String(init.statusText))) { - throw new TypeError('Invalid statusText') - } - } - - // 3. Set this’s response to a new response. + // 1. Set this’s response to a new response. this[kState] = makeResponse({}) - // 4. Set this’s headers to a new Headers object with this’s relevant + // 2. Set this’s headers to a new Headers object with this’s relevant // Realm, whose header list is this’s response’s header list and guard // is "response". this[kHeaders] = new Headers() @@ -140,48 +160,20 @@ class Response { this[kHeaders][kHeadersList] = this[kState].headersList this[kHeaders][kRealm] = this[kRealm] - // 5. Set this’s response’s status to init["status"]. - if ('status' in init && init.status !== undefined) { - this[kState].status = init.status - } + // 3. Let bodyWithType be null. + let bodyWithType = null - // 6. Set this’s response’s status message to init["statusText"]. - if ('statusText' in init && init.statusText !== undefined) { - this[kState].statusText = String(init.statusText) - } - - // 7. If init["headers"] exists, then fill this’s headers with init["headers"]. - if ('headers' in init) { - fill(this[kState].headersList, init.headers) - } - - // 8. If body is non-null, then: + // 4. If body is non-null, then set bodyWithType to the result of extracting body. if (body != null) { - // 1. If init["status"] is a null body status, then throw a TypeError. - if (nullBodyStatus.includes(init.status)) { - throw new TypeError('Response with null body status cannot have body') - } - - // 2. Let Content-Type be null. - // 3. Set this’s response’s body and Content-Type to the result of - // extracting body. - const [extractedBody, contentType] = extractBody(body) - this[kState].body = extractedBody - - // 4. If Content-Type is non-null and this’s response’s header list does - // not contain `Content-Type`, then append `Content-Type`/Content-Type - // to this’s response’s header list. - if (contentType && !this.headers.has('content-type')) { - this.headers.append('content-type', contentType) - } + const [extractedBody, type] = extractBody(body) + bodyWithType = { body: extractedBody, type } } + + // 5. Perform initialize a response given this, init, and bodyWithType. + initializeResponse(this, init, bodyWithType) } get [Symbol.toStringTag] () { - if (!(this instanceof Response)) { - throw new TypeError('Illegal invocation') - } - return this.constructor.name } @@ -477,6 +469,57 @@ function makeAppropriateNetworkError (fetchParams) { : makeNetworkError(fetchParams.controller.terminated.reason) } +// https://whatpr.org/fetch/1392.html#initialize-a-response +function initializeResponse (response, init, body) { + // 1. If init["status"] is not in the range 200 to 599, inclusive, then + // throw a RangeError. + if (init.status != null && (init.status < 200 || init.status > 599)) { + throw new RangeError('init["status"] must be in the range of 200 to 599, inclusive.') + } + + // 2. If init["statusText"] does not match the reason-phrase token production, + // then throw a TypeError. + if ('statusText' in init && init.statusText != null) { + // See, https://datatracker.ietf.org/doc/html/rfc7230#section-3.1.2: + // reason-phrase = *( HTAB / SP / VCHAR / obs-text ) + if (!isValidReasonPhrase(String(init.statusText))) { + throw new TypeError('Invalid statusText') + } + } + + // 3. Set response’s response’s status to init["status"]. + if ('status' in init && init.status != null) { + response[kState].status = init.status + } + + // 4. Set response’s response’s status message to init["statusText"]. + if ('statusText' in init && init.statusText != null) { + response[kState].statusText = init.statusText + } + + // 5. If init["headers"] exists, then fill response’s headers with init["headers"]. + if ('headers' in init && init.headers != null) { + fill(response[kState].headersList, init.headers) + } + + // 6. If body was given, then: + if (body) { + // 1. If response's status is a null body status, then throw a TypeError. + if (nullBodyStatus.includes(response.status)) { + throw new TypeError() + } + + // 2. Set response's body to body's body. + response[kState].body = body.body + + // 3. If body's type is non-null and response's header list does not contain + // `Content-Type`, then append (`Content-Type`, body's type) to response's header list. + if (body.type != null && !response[kState].headersList.has('Content-Type')) { + response[kState].headersList.append('content-type', body.type) + } + } +} + module.exports = { makeNetworkError, makeResponse, diff --git a/deps/undici/src/lib/fetch/util.js b/deps/undici/src/lib/fetch/util.js index 0116f67a8b67b2..1c67f9c7c841fa 100644 --- a/deps/undici/src/lib/fetch/util.js +++ b/deps/undici/src/lib/fetch/util.js @@ -3,6 +3,7 @@ const { redirectStatus } = require('./constants') const { performance } = require('perf_hooks') const { isBlobLike, toUSVString, ReadableStreamFrom } = require('../core/util') +const assert = require('assert') let File @@ -316,47 +317,6 @@ function sameOrigin (A, B) { return false } -// https://fetch.spec.whatwg.org/#corb-check -function CORBCheck (request, response) { - // 1. If request’s initiator is "download", then return allowed. - if (request.initiator === 'download') { - return 'allowed' - } - - // 2. If request’s current URL’s scheme is not an HTTP(S) scheme, then return allowed. - if (!/^https?$/.test(request.currentURL.scheme)) { - return 'allowed' - } - - // 3. Let mimeType be the result of extracting a MIME type from response’s header list. - const mimeType = response.headersList.get('content-type') - - // 4. If mimeType is failure, then return allowed. - if (mimeType === '') { - return 'allowed' - } - - // 5. If response’s status is 206 and mimeType is a CORB-protected MIME type, then return blocked. - - const isCORBProtectedMIME = - (/^text\/html\b/.test(mimeType) || - /^application\/javascript\b/.test(mimeType) || - /^application\/xml\b/.test(mimeType)) && !/^application\/xml\+svg\b/.test(mimeType) - - if (response.status === 206 && isCORBProtectedMIME) { - return 'blocked' - } - - // 6. If determine nosniff with response’s header list is true and mimeType is a CORB-protected MIME type or its essence is "text/plain", then return blocked. - // https://fetch.spec.whatwg.org/#determinenosniff - if (response.headersList.get('x-content-type-options') && isCORBProtectedMIME) { - return 'blocked' - } - - // 7. Return allowed. - return 'allowed' -} - function createDeferredPromise () { let res let rej @@ -384,6 +344,23 @@ function normalizeMethod (method) { : method } +// https://infra.spec.whatwg.org/#serialize-a-javascript-value-to-a-json-string +function serializeJavascriptValueToJSONString (value) { + // 1. Let result be ? Call(%JSON.stringify%, undefined, « value »). + const result = JSON.stringify(value) + + // 2. If result is undefined, then throw a TypeError. + if (result === undefined) { + throw new TypeError('Value is not JSON serializable') + } + + // 3. Assert: result is a string. + assert(typeof result === 'string') + + // 4. Return result. + return result +} + module.exports = { isAborted, isCancelled, @@ -412,6 +389,6 @@ module.exports = { isFileLike, isValidReasonPhrase, sameOrigin, - CORBCheck, - normalizeMethod + normalizeMethod, + serializeJavascriptValueToJSONString } diff --git a/deps/undici/src/lib/mock/mock-agent.js b/deps/undici/src/lib/mock/mock-agent.js index 093da5e50a9ab7..828e8af174d5f2 100644 --- a/deps/undici/src/lib/mock/mock-agent.js +++ b/deps/undici/src/lib/mock/mock-agent.js @@ -96,6 +96,12 @@ class MockAgent extends Dispatcher { this[kNetConnect] = false } + // This is required to bypass issues caused by using global symbols - see: + // https://github.com/nodejs/undici/issues/1447 + get isMockActive () { + return this[kIsMockActive] + } + [kMockAgentSet] (origin, dispatcher) { this[kClients].set(origin, new FakeWeakRef(dispatcher)) } diff --git a/deps/undici/src/lib/mock/mock-utils.js b/deps/undici/src/lib/mock/mock-utils.js index a81f05af045de7..a9ab94f36ae03a 100644 --- a/deps/undici/src/lib/mock/mock-utils.js +++ b/deps/undici/src/lib/mock/mock-utils.js @@ -6,7 +6,6 @@ const { kMockAgent, kOriginalDispatch, kOrigin, - kIsMockActive, kGetNetConnect } = require('./mock-symbols') @@ -302,7 +301,7 @@ function buildMockDispatch () { const originalDispatch = this[kOriginalDispatch] return function dispatch (opts, handler) { - if (agent[kIsMockActive]) { + if (agent.isMockActive) { try { mockDispatch.call(this, opts, handler) } catch (error) { diff --git a/deps/undici/src/lib/proxy-agent.js b/deps/undici/src/lib/proxy-agent.js index 2da6c7a5036e41..37a416806178c1 100644 --- a/deps/undici/src/lib/proxy-agent.js +++ b/deps/undici/src/lib/proxy-agent.js @@ -1,7 +1,6 @@ 'use strict' const { kProxy, kClose, kDestroy } = require('./core/symbols') -const { URL } = require('url') const Agent = require('./agent') const DispatcherBase = require('./dispatcher-base') const { InvalidArgumentError } = require('./core/errors') diff --git a/deps/undici/src/package.json b/deps/undici/src/package.json index 763eed020780a2..b30753c16d9001 100644 --- a/deps/undici/src/package.json +++ b/deps/undici/src/package.json @@ -1,6 +1,6 @@ { "name": "undici", - "version": "5.2.0", + "version": "5.3.0", "description": "An HTTP/1.1 client, written from scratch for Node.js", "homepage": "https://undici.nodejs.org", "bugs": { @@ -48,7 +48,7 @@ "lint:fix": "standard --fix | snazzy", "test": "npm run test:tap && npm run test:node-fetch && npm run test:fetch && npm run test:jest && tsd", "test:node-fetch": "node scripts/verifyVersion.js 16 || mocha test/node-fetch", - "test:fetch": "node scripts/verifyVersion.js 16 || tap test/fetch/*.js", + "test:fetch": "node scripts/verifyVersion.js 16 || (npm run build:node && tap test/fetch/*.js)", "test:jest": "jest", "test:tap": "tap test/*.js test/diagnostics-channel/*.js", "test:tdd": "tap test/*.js test/diagnostics-channel/*.js -w", @@ -91,6 +91,7 @@ "sinon": "^14.0.0", "snazzy": "^9.0.0", "standard": "^17.0.0", + "table": "^6.8.0", "tap": "^16.1.0", "tsd": "^0.20.0", "wait-on": "^6.0.0" diff --git a/deps/undici/src/types/diagnostics-channel.d.ts b/deps/undici/src/types/diagnostics-channel.d.ts new file mode 100644 index 00000000000000..8bb1926506e303 --- /dev/null +++ b/deps/undici/src/types/diagnostics-channel.d.ts @@ -0,0 +1,66 @@ +import { Socket } from "net"; +import { connector } from "./connector"; +import { HttpMethod } from "./dispatcher"; + +declare namespace DiagnosticsChannel { + interface Request { + origin?: string | URL; + completed: boolean; + method?: HttpMethod; + path: string; + headers: string; + addHeader(key: string, value: string): Request; + } + interface Response { + statusCode: number; + statusText: string; + headers: Array; + } + type Error = unknown; + interface ConnectParams { + host: URL["host"]; + hostname: URL["hostname"]; + protocol: URL["protocol"]; + port: URL["port"]; + servername: string | null; + } + type Connector = typeof connector; + export interface RequestCreateMessage { + request: Request; + } + export interface RequestBodySentMessage { + request: Request; + } + export interface RequestHeadersMessage { + request: Request; + response: Response; + } + export interface RequestTrailersMessage { + request: Request; + trailers: Array; + } + export interface RequestErrorMessage { + request: Request; + error: Error; + } + export interface ClientSendHeadersMessage { + request: Request; + headers: string; + socket: Socket; + } + export interface ClientBeforeConnectMessage { + connectParams: ConnectParams; + connector: Connector; + } + export interface ClientConnectedMessage { + socket: Socket; + connectParams: ConnectParams; + connector: Connector; + } + export interface ClientConnectErrorMessage { + error: Error; + socket: Socket; + connectParams: ConnectParams; + connector: Connector; + } +} diff --git a/deps/undici/src/types/dispatcher.d.ts b/deps/undici/src/types/dispatcher.d.ts index 9b2af26e6d23e7..4bc3241ac3da6e 100644 --- a/deps/undici/src/types/dispatcher.d.ts +++ b/deps/undici/src/types/dispatcher.d.ts @@ -47,6 +47,8 @@ declare namespace Dispatcher { body?: string | Buffer | Uint8Array | Readable | null | FormData; /** Default: `null` */ headers?: IncomingHttpHeaders | string[] | null; + /** Query string params to be embedded in the request URL. Default: `null` */ + query?: Record; /** Whether the requests can be safely retried or not. If `false` the request won't be sent until all preceding requests in the pipeline have completed. Default: `true` if `method` is `HEAD` or `GET`. */ idempotent?: boolean; /** Upgrade the request. Should be used to specify the kind of upgrade i.e. `'Websocket'`. Default: `method === 'CONNECT' || null`. */ @@ -55,6 +57,8 @@ declare namespace Dispatcher { headersTimeout?: number | null; /** The timeout after which a request will time out, in milliseconds. Monitors time between receiving body data. Use 0 to disable it entirely. Defaults to 30 seconds. */ bodyTimeout?: number | null; + /** Whether Undici should throw an error upon receiving a 4xx or 5xx response from the server. Defaults to false */ + throwOnError?: boolean; } export interface ConnectOptions { path: string; diff --git a/deps/undici/src/types/fetch.d.ts b/deps/undici/src/types/fetch.d.ts index 1b8692b251cf11..47a08dd0510f05 100644 --- a/deps/undici/src/types/fetch.d.ts +++ b/deps/undici/src/types/fetch.d.ts @@ -101,19 +101,19 @@ type RequestDestination = | 'xslt' export interface RequestInit { - readonly method?: string - readonly keepalive?: boolean - readonly headers?: HeadersInit - readonly body?: BodyInit - readonly redirect?: RequestRedirect - readonly integrity?: string - readonly signal?: AbortSignal - readonly credentials?: RequestCredentials - readonly mode?: RequestMode - readonly referrer?: string - readonly referrerPolicy?: ReferrerPolicy - readonly window?: null - readonly dispatcher?: Dispatcher + method?: string + keepalive?: boolean + headers?: HeadersInit + body?: BodyInit + redirect?: RequestRedirect + integrity?: string + signal?: AbortSignal + credentials?: RequestCredentials + mode?: RequestMode + referrer?: string + referrerPolicy?: ReferrerPolicy + window?: null + dispatcher?: Dispatcher } export type ReferrerPolicy = @@ -199,5 +199,6 @@ export declare class Response implements BodyMixin { readonly clone: () => Response static error (): Response + static json(data: any, init?: ResponseInit): Response static redirect (url: string | URL, status: ResponseRedirectStatus): Response } diff --git a/deps/undici/undici.js b/deps/undici/undici.js index 867492229205f4..16c98d7469ed1c 100644 --- a/deps/undici/undici.js +++ b/deps/undici/undici.js @@ -1,8 +1,14 @@ "use strict"; +var __defProp = Object.defineProperty; var __getOwnPropNames = Object.getOwnPropertyNames; +var __defNormalProp = (obj, key, value) => key in obj ? __defProp(obj, key, { enumerable: true, configurable: true, writable: true, value }) : obj[key] = value; var __commonJS = (cb, mod) => function __require() { return mod || (0, cb[__getOwnPropNames(cb)[0]])((mod = { exports: {} }).exports, mod), mod.exports; }; +var __publicField = (obj, key, value) => { + __defNormalProp(obj, typeof key !== "symbol" ? key + "" : key, value); + return value; +}; // lib/core/errors.js var require_errors = __commonJS({ @@ -58,6 +64,18 @@ var require_errors = __commonJS({ this.code = "UND_ERR_BODY_TIMEOUT"; } }; + var ResponseStatusCodeError = class extends UndiciError { + constructor(message, statusCode, headers) { + super(message); + Error.captureStackTrace(this, ResponseStatusCodeError); + this.name = "ResponseStatusCodeError"; + this.message = message || "Response Status Code Error"; + this.code = "UND_ERR_RESPONSE_STATUS_CODE"; + this.status = statusCode; + this.statusCode = statusCode; + this.headers = headers; + } + }; var InvalidArgumentError = class extends UndiciError { constructor(message) { super(message); @@ -176,6 +194,7 @@ var require_errors = __commonJS({ BodyTimeoutError, RequestContentLengthMismatchError, ConnectTimeoutError, + ResponseStatusCodeError, InvalidArgumentError, InvalidReturnValueError, RequestAbortedError, @@ -664,6 +683,40 @@ var require_util = __commonJS({ function isBlobLike(object) { return Blob && object instanceof Blob || object && typeof object === "object" && (typeof object.stream === "function" || typeof object.arrayBuffer === "function") && /^(Blob|File)$/.test(object[Symbol.toStringTag]); } + function isObject(val) { + return val !== null && typeof val === "object"; + } + function encode(val) { + return encodeURIComponent(val); + } + function buildURL(url, queryParams) { + if (url.includes("?") || url.includes("#")) { + throw new Error('Query params cannot be passed when url already contains "?" or "#".'); + } + if (!isObject(queryParams)) { + throw new Error("Query params must be an object"); + } + const parts = []; + for (let [key, val] of Object.entries(queryParams)) { + if (val === null || typeof val === "undefined") { + continue; + } + if (!Array.isArray(val)) { + val = [val]; + } + for (const v of val) { + if (isObject(v)) { + throw new Error("Passing object as a query param is not supported, please serialize to string up-front"); + } + parts.push(encode(key) + "=" + encode(v)); + } + } + const serializedParams = parts.join("&"); + if (serializedParams) { + url += "?" + serializedParams; + } + return url; + } function parseURL(url) { if (typeof url === "string") { url = new URL(url); @@ -911,7 +964,8 @@ var require_util = __commonJS({ isBuffer, validateHandler, getSocketInfo, - isFormDataLike + isFormDataLike, + buildURL }; } }); @@ -1056,9 +1110,6 @@ var require_file = __commonJS({ return this[kState].lastModified; } get [Symbol.toStringTag]() { - if (!(this instanceof File)) { - throw new TypeError("Illegal invocation"); - } return this.constructor.name; } }; @@ -1123,9 +1174,6 @@ var require_file = __commonJS({ return this[kState].lastModified; } get [Symbol.toStringTag]() { - if (!(this instanceof FileLike)) { - throw new TypeError("Illegal invocation"); - } return "File"; } }; @@ -1140,6 +1188,7 @@ var require_util2 = __commonJS({ var { redirectStatus } = require_constants(); var { performance } = require("perf_hooks"); var { isBlobLike, toUSVString, ReadableStreamFrom } = require_util(); + var assert = require("assert"); var File; var badPorts = [ "1", @@ -1367,26 +1416,6 @@ var require_util2 = __commonJS({ } return false; } - function CORBCheck(request, response) { - if (request.initiator === "download") { - return "allowed"; - } - if (!/^https?$/.test(request.currentURL.scheme)) { - return "allowed"; - } - const mimeType = response.headersList.get("content-type"); - if (mimeType === "") { - return "allowed"; - } - const isCORBProtectedMIME = (/^text\/html\b/.test(mimeType) || /^application\/javascript\b/.test(mimeType) || /^application\/xml\b/.test(mimeType)) && !/^application\/xml\+svg\b/.test(mimeType); - if (response.status === 206 && isCORBProtectedMIME) { - return "blocked"; - } - if (response.headersList.get("x-content-type-options") && isCORBProtectedMIME) { - return "blocked"; - } - return "allowed"; - } function createDeferredPromise() { let res; let rej; @@ -1405,6 +1434,14 @@ var require_util2 = __commonJS({ function normalizeMethod(method) { return /^(DELETE|GET|HEAD|OPTIONS|POST|PUT)$/i.test(method) ? method.toUpperCase() : method; } + function serializeJavascriptValueToJSONString(value) { + const result = JSON.stringify(value); + if (result === void 0) { + throw new TypeError("Value is not JSON serializable"); + } + assert(typeof result === "string"); + return result; + } module2.exports = { isAborted, isCancelled, @@ -1433,8 +1470,8 @@ var require_util2 = __commonJS({ isFileLike, isValidReasonPhrase, sameOrigin, - CORBCheck, - normalizeMethod + normalizeMethod, + serializeJavascriptValueToJSONString }; } }); @@ -1447,7 +1484,7 @@ var require_formdata = __commonJS({ var { kState } = require_symbols2(); var { File, FileLike } = require_file(); var { Blob } = require("buffer"); - var FormData = class { + var _FormData = class { constructor(...args) { if (args.length > 0 && !(args[0]?.constructor?.name === "HTMLFormElement")) { throw new TypeError("Failed to construct 'FormData': parameter 1 is not of type 'HTMLFormElement'"); @@ -1455,7 +1492,7 @@ var require_formdata = __commonJS({ this[kState] = []; } append(...args) { - if (!(this instanceof FormData)) { + if (!(this instanceof _FormData)) { throw new TypeError("Illegal invocation"); } if (args.length < 2) { @@ -1471,7 +1508,7 @@ var require_formdata = __commonJS({ this[kState].push(entry); } delete(...args) { - if (!(this instanceof FormData)) { + if (!(this instanceof _FormData)) { throw new TypeError("Illegal invocation"); } if (args.length < 1) { @@ -1487,7 +1524,7 @@ var require_formdata = __commonJS({ this[kState] = next; } get(...args) { - if (!(this instanceof FormData)) { + if (!(this instanceof _FormData)) { throw new TypeError("Illegal invocation"); } if (args.length < 1) { @@ -1501,7 +1538,7 @@ var require_formdata = __commonJS({ return this[kState][idx].value; } getAll(...args) { - if (!(this instanceof FormData)) { + if (!(this instanceof _FormData)) { throw new TypeError("Illegal invocation"); } if (args.length < 1) { @@ -1511,7 +1548,7 @@ var require_formdata = __commonJS({ return this[kState].filter((entry) => entry.name === name).map((entry) => entry.value); } has(...args) { - if (!(this instanceof FormData)) { + if (!(this instanceof _FormData)) { throw new TypeError("Illegal invocation"); } if (args.length < 1) { @@ -1521,7 +1558,7 @@ var require_formdata = __commonJS({ return this[kState].findIndex((entry) => entry.name === name) !== -1; } set(...args) { - if (!(this instanceof FormData)) { + if (!(this instanceof _FormData)) { throw new TypeError("Illegal invocation"); } if (args.length < 2) { @@ -1546,13 +1583,10 @@ var require_formdata = __commonJS({ } } get [Symbol.toStringTag]() { - if (!(this instanceof FormData)) { - throw new TypeError("Illegal invocation"); - } return this.constructor.name; } *entries() { - if (!(this instanceof FormData)) { + if (!(this instanceof _FormData)) { throw new TypeError("Illegal invocation"); } for (const pair of this) { @@ -1560,7 +1594,7 @@ var require_formdata = __commonJS({ } } *keys() { - if (!(this instanceof FormData)) { + if (!(this instanceof _FormData)) { throw new TypeError("Illegal invocation"); } for (const [key] of this) { @@ -1568,7 +1602,7 @@ var require_formdata = __commonJS({ } } *values() { - if (!(this instanceof FormData)) { + if (!(this instanceof _FormData)) { throw new TypeError("Illegal invocation"); } for (const [, value] of this) { @@ -1581,6 +1615,8 @@ var require_formdata = __commonJS({ } } }; + var FormData = _FormData; + __publicField(FormData, "name", "FormData"); function makeEntry(name, value, filename) { const entry = { name: null, @@ -1596,7 +1632,7 @@ var require_formdata = __commonJS({ entry.value = value; return entry; } - module2.exports = { FormData: globalThis.FormData ?? FormData }; + module2.exports = { FormData }; } }); @@ -1833,8 +1869,8 @@ var require_request = __commonJS({ InvalidArgumentError, NotSupportedError } = require_errors(); - var util = require_util(); var assert = require("assert"); + var util = require_util(); var kHandler = Symbol("handler"); var channels = {}; var extractBody; @@ -1861,11 +1897,13 @@ var require_request = __commonJS({ method, body, headers, + query, idempotent, blocking, upgrade, headersTimeout, - bodyTimeout + bodyTimeout, + throwOnError }, handler) { if (typeof path !== "string") { throw new InvalidArgumentError("path must be a string"); @@ -1886,6 +1924,7 @@ var require_request = __commonJS({ } this.headersTimeout = headersTimeout; this.bodyTimeout = bodyTimeout; + this.throwOnError = throwOnError === true; this.method = method; if (body == null) { this.body = null; @@ -1907,7 +1946,7 @@ var require_request = __commonJS({ this.completed = false; this.aborted = false; this.upgrade = upgrade || null; - this.path = path; + this.path = query ? util.buildURL(path, query) : path; this.origin = origin; this.idempotent = idempotent == null ? method === "HEAD" || method === "GET" : idempotent; this.blocking = blocking == null ? false : blocking; @@ -4462,7 +4501,7 @@ var require_response = __commonJS({ var { extractBody, cloneBody, mixinBody } = require_body(); var util = require_util(); var { kEnumerableProperty } = util; - var { responseURL, isValidReasonPhrase, toUSVString, isCancelled, isAborted } = require_util2(); + var { responseURL, isValidReasonPhrase, toUSVString, isCancelled, isAborted, serializeJavascriptValueToJSONString } = require_util2(); var { redirectStatus, nullBodyStatus, @@ -4483,6 +4522,29 @@ var require_response = __commonJS({ responseObject[kHeaders][kRealm] = relevantRealm; return responseObject; } + static json(data, init = {}) { + if (arguments.length === 0) { + throw new TypeError("Failed to execute 'json' on 'Response': 1 argument required, but 0 present."); + } + if (init === null || typeof init !== "object") { + throw new TypeError(`Failed to execute 'json' on 'Response': init must be a RequestInit, found ${typeof init}.`); + } + init = { + status: 200, + statusText: "", + headers: new HeadersList(), + ...init + }; + const bytes = new TextEncoder("utf-8").encode(serializeJavascriptValueToJSONString(data)); + const body = extractBody(bytes); + const relevantRealm = { settingsObject: {} }; + const responseObject = new Response(); + responseObject[kRealm] = relevantRealm; + responseObject[kHeaders][kGuard] = "response"; + responseObject[kHeaders][kRealm] = relevantRealm; + initializeResponse(responseObject, init, { body: body[0], type: "application/json" }); + return responseObject; + } static redirect(...args) { const relevantRealm = { settingsObject: {} }; if (args.length < 1) { @@ -4517,48 +4579,19 @@ var require_response = __commonJS({ const body = args.length >= 1 ? args[0] : null; const init = args.length >= 2 ? args[1] ?? {} : {}; this[kRealm] = { settingsObject: {} }; - if ("status" in init && init.status !== void 0) { - if (!Number.isFinite(init.status)) { - throw new TypeError(); - } - if (init.status < 200 || init.status > 599) { - throw new RangeError(`Failed to construct 'Response': The status provided (${init.status}) is outside the range [200, 599].`); - } - } - if ("statusText" in init && init.statusText !== void 0) { - if (!isValidReasonPhrase(String(init.statusText))) { - throw new TypeError("Invalid statusText"); - } - } this[kState] = makeResponse({}); this[kHeaders] = new Headers(); this[kHeaders][kGuard] = "response"; this[kHeaders][kHeadersList] = this[kState].headersList; this[kHeaders][kRealm] = this[kRealm]; - if ("status" in init && init.status !== void 0) { - this[kState].status = init.status; - } - if ("statusText" in init && init.statusText !== void 0) { - this[kState].statusText = String(init.statusText); - } - if ("headers" in init) { - fill(this[kState].headersList, init.headers); - } + let bodyWithType = null; if (body != null) { - if (nullBodyStatus.includes(init.status)) { - throw new TypeError("Response with null body status cannot have body"); - } - const [extractedBody, contentType] = extractBody(body); - this[kState].body = extractedBody; - if (contentType && !this.headers.has("content-type")) { - this.headers.append("content-type", contentType); - } + const [extractedBody, type] = extractBody(body); + bodyWithType = { body: extractedBody, type }; } + initializeResponse(this, init, bodyWithType); } get [Symbol.toStringTag]() { - if (!(this instanceof Response)) { - throw new TypeError("Illegal invocation"); - } return this.constructor.name; } get type() { @@ -4746,6 +4779,34 @@ var require_response = __commonJS({ assert(isCancelled(fetchParams)); return isAborted(fetchParams) ? makeNetworkError(new AbortError()) : makeNetworkError(fetchParams.controller.terminated.reason); } + function initializeResponse(response, init, body) { + if (init.status != null && (init.status < 200 || init.status > 599)) { + throw new RangeError('init["status"] must be in the range of 200 to 599, inclusive.'); + } + if ("statusText" in init && init.statusText != null) { + if (!isValidReasonPhrase(String(init.statusText))) { + throw new TypeError("Invalid statusText"); + } + } + if ("status" in init && init.status != null) { + response[kState].status = init.status; + } + if ("statusText" in init && init.statusText != null) { + response[kState].statusText = init.statusText; + } + if ("headers" in init && init.headers != null) { + fill(response[kState].headersList, init.headers); + } + if (body) { + if (nullBodyStatus.includes(response.status)) { + throw new TypeError(); + } + response[kState].body = body.body; + if (body.type != null && !response[kState].headersList.has("Content-Type")) { + response[kState].headersList.append("content-type", body.type); + } + } + } module2.exports = { makeNetworkError, makeResponse, @@ -5020,9 +5081,6 @@ var require_request2 = __commonJS({ this[kState].body = finalBody; } get [Symbol.toStringTag]() { - if (!(this instanceof Request)) { - throw new TypeError("Illegal invocation"); - } return this.constructor.name; } get method() { @@ -5414,34 +5472,6 @@ var require_dataURL = __commonJS({ } }); -// lib/mock/mock-symbols.js -var require_mock_symbols = __commonJS({ - "lib/mock/mock-symbols.js"(exports2, module2) { - "use strict"; - module2.exports = { - kAgent: Symbol("agent"), - kOptions: Symbol("options"), - kFactory: Symbol("factory"), - kDispatches: Symbol("dispatches"), - kDispatchKey: Symbol("dispatch key"), - kDefaultHeaders: Symbol("default headers"), - kDefaultTrailers: Symbol("default trailers"), - kContentLength: Symbol("content length"), - kMockAgent: Symbol("mock agent"), - kMockAgentSet: Symbol("mock agent set"), - kMockAgentGet: Symbol("mock agent get"), - kMockDispatch: Symbol("mock dispatch"), - kClose: Symbol("close"), - kOriginalClose: Symbol("original agent close"), - kOrigin: Symbol("origin"), - kIsMockActive: Symbol("is mock active"), - kNetConnect: Symbol("net connect"), - kGetNetConnect: Symbol("get net connect"), - kConnected: Symbol("connected") - }; - } -}); - // lib/fetch/index.js var require_fetch = __commonJS({ "lib/fetch/index.js"(exports2, module2) { @@ -5475,7 +5505,6 @@ var require_fetch = __commonJS({ coarsenedSharedCurrentTime, createDeferredPromise, isBlobLike, - CORBCheck, sameOrigin, isCancelled, isAborted @@ -5496,7 +5525,6 @@ var require_fetch = __commonJS({ var { Readable, pipeline } = require("stream"); var { isErrored, isReadable } = require_util(); var { dataURLProcessor } = require_dataURL(); - var { kIsMockActive } = require_mock_symbols(); var { TransformStream } = require("stream/web"); var resolveObjectURL; var ReadableStream; @@ -5731,11 +5759,7 @@ var require_fetch = __commonJS({ return makeNetworkError('redirect mode cannot be "follow" for "no-cors" request'); } request.responseTainting = "opaque"; - const noCorsResponse = await schemeFetch(fetchParams); - if (noCorsResponse.status === 0 || CORBCheck(request, noCorsResponse) === "allowed") { - return noCorsResponse; - } - return makeResponse({ status: noCorsResponse.status }); + return await schemeFetch(fetchParams); } if (!/^https?:/.test(requestCurrentURL(request).protocol)) { return makeNetworkError("URL scheme must be a HTTP(S) scheme"); @@ -6275,7 +6299,7 @@ var require_fetch = __commonJS({ path: url.pathname + url.search, origin: url.origin, method: request.method, - body: fetchParams.controller.dispatcher[kIsMockActive] ? request.body && request.body.source : body, + body: fetchParams.controller.dispatcher.isMockActive ? request.body && request.body.source : body, headers: [...request.headersList].flat(), maxRedirections: 0, bodyTimeout: 3e5,