actions/setup-uv
2
0
Fork 0
mirror of https://github.com/astral-sh/setup-uv.git synced 2026-06-09 11:30:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore(deps): roll up dependabot updates (#901)

Browse Source 
Rolls up the current open Dependabot npm updates:

- #848 esbuild from 0.27.4 to 0.27.5
- #847 undici from 7.24.2 to 8.0.0
- #846 ts-jest from 29.4.6 to 29.4.9
- #841 @biomejs/biome from 2.4.7 to 2.4.10, including the matching
biome.json schema URL update
- #834 smol-toml from 1.6.0 to 1.6.1

Validation:

- npm run all
This commit is contained in:
Kevin Stillhammer
2026-06-03 09:49:40 +02:00
committed by GitHub
parent c4fcbafce4
commit 363c64a728
6 changed files with 1595 additions and 1321 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1116
dist/update-known-checksums/index.cjs generated vendored
View File

@@ -20784,16 +20784,7 @@ var require_util9 = __commonJS({
return obj && typeof obj === "object" && typeof obj.pipe === "function" && typeof obj.on === "function";
}
function isBlobLike(object) {
if (object === null) {
return false;
} else if (object instanceof Blob) {
return true;
} else if (typeof object !== "object") {
return false;
} else {
const sTag = object[Symbol.toStringTag];
return (sTag === "Blob" || sTag === "File") && ("stream" in object && typeof object.stream === "function" || "arrayBuffer" in object && typeof object.arrayBuffer === "function");
}
return object instanceof Blob;
}
function pathHasQueryOrFragment(url) {
return url.includes("?") || url.includes("#");
@@ -20953,19 +20944,29 @@ var require_util9 = __commonJS({
for (let i = 0; i < headers.length; i += 2) {
const key = headerNameToString(headers[i]);
let val = obj[key];
if (val) {
if (typeof val === "string") {
val = [val];
obj[key] = val;
}
val.push(headers[i + 1].toString("latin1"));
} else {
const headersValue = headers[i + 1];
if (typeof headersValue === "string") {
obj[key] = headersValue;
if (val !== void 0) {
if (!Object.hasOwn(obj, key)) {
const headersValue = typeof headers[i + 1] === "string" ? headers[i + 1] : Array.isArray(headers[i + 1]) ? headers[i + 1].map((x) => x.toString("latin1")) : headers[i + 1].toString("latin1");
if (key === "__proto__") {
Object.defineProperty(obj, key, {
value: headersValue,
enumerable: true,
configurable: true,
writable: true
});
} else {
obj[key] = headersValue;
}
} else {
obj[key] = Array.isArray(headersValue) ? headersValue.map((x) => x.toString("latin1")) : headersValue.toString("latin1");
if (typeof val === "string") {
val = [val];
obj[key] = val;
}
val.push(headers[i + 1].toString("latin1"));
}
} else {
const headersValue = typeof headers[i + 1] === "string" ? headers[i + 1] : Array.isArray(headers[i + 1]) ? headers[i + 1].map((x) => x.toString("latin1")) : headers[i + 1].toString("latin1");
obj[key] = headersValue;
}
}
return obj;
@@ -20985,6 +20986,19 @@ var require_util9 = __commonJS({
}
return ret;
}
function toRawHeaders(headers) {
const rawHeaders = [];
for (const [name, value] of Object.entries(headers)) {
if (Array.isArray(value)) {
for (const entry of value) {
rawHeaders.push(Buffer.from(name, "latin1"), Buffer.from(`${entry}`, "latin1"));
}
} else {
rawHeaders.push(Buffer.from(name, "latin1"), Buffer.from(`${value}`, "latin1"));
}
}
return rawHeaders;
}
function encodeRawHeaders(headers) {
if (!Array.isArray(headers)) {
throw new TypeError("expected headers to be an array");
@@ -20998,31 +21012,31 @@ var require_util9 = __commonJS({
if (!handler || typeof handler !== "object") {
throw new InvalidArgumentError("handler must be an object");
}
if (typeof handler.onRequestStart === "function") {
return;
if (typeof handler.onRequestStart !== "function") {
throw new InvalidArgumentError("invalid onRequestStart method");
}
if (typeof handler.onConnect !== "function") {
throw new InvalidArgumentError("invalid onConnect method");
}
if (typeof handler.onError !== "function") {
throw new InvalidArgumentError("invalid onError method");
if (typeof handler.onResponseError !== "function") {
throw new InvalidArgumentError("invalid onResponseError method");
}
if (typeof handler.onBodySent !== "function" && handler.onBodySent !== void 0) {
throw new InvalidArgumentError("invalid onBodySent method");
}
if (typeof handler.onRequestSent !== "function" && handler.onRequestSent !== void 0) {
throw new InvalidArgumentError("invalid onRequestSent method");
}
if (upgrade || method === "CONNECT") {
if (typeof handler.onUpgrade !== "function") {
throw new InvalidArgumentError("invalid onUpgrade method");
if (typeof handler.onRequestUpgrade !== "function") {
throw new InvalidArgumentError("invalid onRequestUpgrade method");
}
} else {
if (typeof handler.onHeaders !== "function") {
throw new InvalidArgumentError("invalid onHeaders method");
if (typeof handler.onResponseStart !== "function") {
throw new InvalidArgumentError("invalid onResponseStart method");
}
if (typeof handler.onData !== "function") {
throw new InvalidArgumentError("invalid onData method");
if (typeof handler.onResponseData !== "function") {
throw new InvalidArgumentError("invalid onResponseData method");
}
if (typeof handler.onComplete !== "function") {
throw new InvalidArgumentError("invalid onComplete method");
if (typeof handler.onResponseEnd !== "function") {
throw new InvalidArgumentError("invalid onResponseEnd method");
}
}
}
@@ -21402,7 +21416,7 @@ var require_util9 = __commonJS({
}
function errorRequest(client, request, err) {
try {
request.onError(err);
request.onResponseError(err);
assert(request.aborted);
} catch (err2) {
client.emit("error", err2);
@@ -21506,6 +21520,7 @@ var require_util9 = __commonJS({
removeAllListeners,
errorRequest,
parseRawHeaders,
toRawHeaders,
encodeRawHeaders,
parseHeaders,
parseKeepAliveTimeout,
@@ -21736,10 +21751,12 @@ var require_diagnostics2 = __commonJS({
diagnosticsChannel.subscribe(
"undici:websocket:open",
(evt) => {
const {
address: { address, port }
} = evt;
debugLog("connection opened %s%s", address, port ? `:${port}` : "");
if (evt.address != null) {
const { address, port } = evt.address;
debugLog("connection opened %s%s", address, port ? `:${port}` : "");
} else {
debugLog("connection opened");
}
}
);
diagnosticsChannel.subscribe(
@@ -21807,6 +21824,7 @@ var require_request3 = __commonJS({
hasSafeIterator,
isBlobLike,
serializePathWithQuery,
parseHeaders,
assertRequestHandler,
getServerName,
normalizedMethodRecords,
@@ -21816,6 +21834,45 @@ var require_request3 = __commonJS({
var { headerNameLowerCasedRecord } = require_constants6();
var invalidPathRegex = /[^\u0021-\u00ff]/;
var kHandler = /* @__PURE__ */ Symbol("handler");
var kController = /* @__PURE__ */ Symbol("controller");
var kResume = /* @__PURE__ */ Symbol("resume");
var RequestController = class {
#paused = false;
#reason = null;
#aborted = false;
#abort;
[kResume] = null;
rawHeaders = null;
rawTrailers = null;
constructor(abort) {
this.#abort = abort;
}
pause() {
this.#paused = true;
}
resume() {
if (this.#paused) {
this.#paused = false;
this[kResume]?.();
}
}
abort(reason) {
if (!this.#aborted) {
this.#aborted = true;
this.#reason = reason;
this.#abort(reason);
}
}
get aborted() {
return this.#aborted;
}
get reason() {
return this.#reason;
}
get paused() {
return this.#paused;
}
};
var Request = class {
constructor(origin, {
path,
@@ -21980,50 +22037,66 @@ var require_request3 = __commonJS({
}
}
}
onConnect(abort) {
onRequestStart(abort, context) {
assert(!this.aborted);
assert(!this.completed);
this[kController] = new RequestController(abort);
if (this.error) {
abort(this.error);
} else {
this.abort = abort;
return this[kHandler].onConnect(abort);
this[kController].abort(this.error);
return;
}
this.abort = abort;
return this[kHandler].onRequestStart(this[kController], context);
}
onResponseStarted() {
return this[kHandler].onResponseStarted?.();
}
onHeaders(statusCode, headers, resume, statusText) {
onResponseStart(statusCode, headers, resume, statusText) {
assert(!this.aborted);
assert(!this.completed);
if (channels.headers.hasSubscribers) {
channels.headers.publish({ request: this, response: { statusCode, headers, statusText } });
}
try {
return this[kHandler].onHeaders(statusCode, headers, resume, statusText);
} catch (err) {
this.abort(err);
}
}
onData(chunk) {
assert(!this.aborted);
assert(!this.completed);
if (channels.bodyChunkReceived.hasSubscribers) {
channels.bodyChunkReceived.publish({ request: this, chunk });
const controller = this[kController];
if (controller) {
controller[kResume] = resume;
controller.rawHeaders = headers;
}
const parsedHeaders = Array.isArray(headers) ? parseHeaders(headers) : headers;
try {
return this[kHandler].onData(chunk);
this[kHandler].onResponseStart?.(controller, statusCode, parsedHeaders, statusText);
return !controller?.paused;
} catch (err) {
this.abort(err);
return false;
}
}
onUpgrade(statusCode, headers, socket) {
onResponseData(chunk) {
assert(!this.aborted);
assert(!this.completed);
return this[kHandler].onUpgrade(statusCode, headers, socket);
if (channels.bodyChunkReceived.hasSubscribers) {
channels.bodyChunkReceived.publish({ request: this, chunk });
}
const controller = this[kController];
try {
this[kHandler].onResponseData?.(controller, chunk);
return !controller?.paused;
} catch (err) {
this.abort(err);
return false;
}
}
onComplete(trailers) {
onRequestUpgrade(statusCode, headers, socket) {
assert(!this.aborted);
assert(!this.completed);
const controller = this[kController];
if (controller) {
controller.rawHeaders = headers;
}
const parsedHeaders = Array.isArray(headers) ? parseHeaders(headers) : headers;
return this[kHandler].onRequestUpgrade?.(controller, statusCode, parsedHeaders, socket);
}
onResponseEnd(trailers) {
this.onFinally();
assert(!this.aborted);
assert(!this.completed);
@@ -22031,13 +22104,18 @@ var require_request3 = __commonJS({
if (channels.trailers.hasSubscribers) {
channels.trailers.publish({ request: this, trailers });
}
const controller = this[kController];
if (controller) {
controller.rawTrailers = trailers;
}
const parsedTrailers = Array.isArray(trailers) ? parseHeaders(trailers) : trailers;
try {
return this[kHandler].onComplete(trailers);
return this[kHandler].onResponseEnd?.(controller, parsedTrailers);
} catch (err) {
this.onError(err);
this.onResponseError(err);
}
}
onError(error2) {
onResponseError(error2) {
this.onFinally();
if (channels.error.hasSubscribers) {
channels.error.publish({ request: this, error: error2 });
@@ -22046,7 +22124,8 @@ var require_request3 = __commonJS({
return;
}
this.aborted = true;
return this[kHandler].onError(error2);
const controller = this[kController];
return this[kHandler].onResponseError?.(controller, error2);
}
onFinally() {
if (this.errorHandler) {
@@ -22124,12 +22203,18 @@ var require_request3 = __commonJS({
} else if (headerName === "transfer-encoding" || headerName === "keep-alive" || headerName === "upgrade") {
throw new InvalidArgumentError(`invalid ${headerName} header`);
} else if (headerName === "connection") {
const value = typeof val === "string" ? val.toLowerCase() : null;
if (value !== "close" && value !== "keep-alive") {
const value = typeof val === "string" ? val : null;
if (value === null) {
throw new InvalidArgumentError("invalid connection header");
}
if (value === "close") {
request.reset = true;
for (const token of value.toLowerCase().split(",")) {
const trimmed = token.trim();
if (!isValidHTTPToken(trimmed)) {
throw new InvalidArgumentError("invalid connection header");
}
if (trimmed === "close") {
request.reset = true;
}
}
} else if (headerName === "expect") {
throw new NotSupportedError("expect header not supported");
@@ -22141,96 +22226,11 @@ var require_request3 = __commonJS({
}
});
// node_modules/undici/lib/handler/wrap-handler.js
var require_wrap_handler = __commonJS({
"node_modules/undici/lib/handler/wrap-handler.js"(exports2, module2) {
"use strict";
var { InvalidArgumentError } = require_errors2();
module2.exports = class WrapHandler {
#handler;
constructor(handler) {
this.#handler = handler;
}
static wrap(handler) {
return handler.onRequestStart ? handler : new WrapHandler(handler);
}
// Unwrap Interface
onConnect(abort, context) {
return this.#handler.onConnect?.(abort, context);
}
onResponseStarted() {
return this.#handler.onResponseStarted?.();
}
onHeaders(statusCode, rawHeaders, resume, statusMessage) {
return this.#handler.onHeaders?.(statusCode, rawHeaders, resume, statusMessage);
}
onUpgrade(statusCode, rawHeaders, socket) {
return this.#handler.onUpgrade?.(statusCode, rawHeaders, socket);
}
onData(data) {
return this.#handler.onData?.(data);
}
onComplete(trailers) {
return this.#handler.onComplete?.(trailers);
}
onError(err) {
if (!this.#handler.onError) {
throw err;
}
return this.#handler.onError?.(err);
}
// Wrap Interface
onRequestStart(controller, context) {
this.#handler.onConnect?.((reason) => controller.abort(reason), context);
}
onRequestUpgrade(controller, statusCode, headers, socket) {
const rawHeaders = [];
for (const [key, val] of Object.entries(headers)) {
rawHeaders.push(Buffer.from(key, "latin1"), toRawHeaderValue(val));
}
this.#handler.onUpgrade?.(statusCode, rawHeaders, socket);
}
onResponseStart(controller, statusCode, headers, statusMessage) {
const rawHeaders = [];
for (const [key, val] of Object.entries(headers)) {
rawHeaders.push(Buffer.from(key, "latin1"), toRawHeaderValue(val));
}
if (this.#handler.onHeaders?.(statusCode, rawHeaders, () => controller.resume(), statusMessage) === false) {
controller.pause();
}
}
onResponseData(controller, data) {
if (this.#handler.onData?.(data) === false) {
controller.pause();
}
}
onResponseEnd(controller, trailers) {
const rawTrailers = [];
for (const [key, val] of Object.entries(trailers)) {
rawTrailers.push(Buffer.from(key, "latin1"), toRawHeaderValue(val));
}
this.#handler.onComplete?.(rawTrailers);
}
onResponseError(controller, err) {
if (!this.#handler.onError) {
throw new InvalidArgumentError("invalid onError method");
}
this.#handler.onError?.(err);
}
};
function toRawHeaderValue(value) {
return Array.isArray(value) ? value.map((item) => Buffer.from(item, "latin1")) : Buffer.from(value, "latin1");
}
}
});
// node_modules/undici/lib/dispatcher/dispatcher.js
var require_dispatcher2 = __commonJS({
"node_modules/undici/lib/dispatcher/dispatcher.js"(exports2, module2) {
"use strict";
var EventEmitter = require("node:events");
var WrapHandler = require_wrap_handler();
var wrapInterceptor = (dispatch) => (opts, handler) => dispatch(opts, WrapHandler.wrap(handler));
var Dispatcher = class extends EventEmitter {
dispatch() {
throw new Error("not implemented");
@@ -22252,7 +22252,6 @@ var require_dispatcher2 = __commonJS({
throw new TypeError(`invalid interceptor, expected function received ${typeof interceptor}`);
}
dispatch = interceptor(dispatch);
dispatch = wrapInterceptor(dispatch);
if (dispatch == null || typeof dispatch !== "function" || dispatch.length !== 2) {
throw new TypeError("invalid interceptor");
}
@@ -22266,95 +22265,11 @@ var require_dispatcher2 = __commonJS({
}
});
// node_modules/undici/lib/handler/unwrap-handler.js
var require_unwrap_handler = __commonJS({
"node_modules/undici/lib/handler/unwrap-handler.js"(exports2, module2) {
"use strict";
var { parseHeaders } = require_util9();
var { InvalidArgumentError } = require_errors2();
var kResume = /* @__PURE__ */ Symbol("resume");
var UnwrapController = class {
#paused = false;
#reason = null;
#aborted = false;
#abort;
[kResume] = null;
constructor(abort) {
this.#abort = abort;
}
pause() {
this.#paused = true;
}
resume() {
if (this.#paused) {
this.#paused = false;
this[kResume]?.();
}
}
abort(reason) {
if (!this.#aborted) {
this.#aborted = true;
this.#reason = reason;
this.#abort(reason);
}
}
get aborted() {
return this.#aborted;
}
get reason() {
return this.#reason;
}
get paused() {
return this.#paused;
}
};
module2.exports = class UnwrapHandler {
#handler;
#controller;
constructor(handler) {
this.#handler = handler;
}
static unwrap(handler) {
return !handler.onRequestStart ? handler : new UnwrapHandler(handler);
}
onConnect(abort, context) {
this.#controller = new UnwrapController(abort);
this.#handler.onRequestStart?.(this.#controller, context);
}
onResponseStarted() {
return this.#handler.onResponseStarted?.();
}
onUpgrade(statusCode, rawHeaders, socket) {
this.#handler.onRequestUpgrade?.(this.#controller, statusCode, parseHeaders(rawHeaders), socket);
}
onHeaders(statusCode, rawHeaders, resume, statusMessage) {
this.#controller[kResume] = resume;
this.#handler.onResponseStart?.(this.#controller, statusCode, parseHeaders(rawHeaders), statusMessage);
return !this.#controller.paused;
}
onData(data) {
this.#handler.onResponseData?.(this.#controller, data);
return !this.#controller.paused;
}
onComplete(rawTrailers) {
this.#handler.onResponseEnd?.(this.#controller, parseHeaders(rawTrailers));
}
onError(err) {
if (!this.#handler.onResponseError) {
throw new InvalidArgumentError("invalid onError method");
}
this.#handler.onResponseError?.(this.#controller, err);
}
};
}
});
// node_modules/undici/lib/dispatcher/dispatcher-base.js
var require_dispatcher_base2 = __commonJS({
"node_modules/undici/lib/dispatcher/dispatcher-base.js"(exports2, module2) {
"use strict";
var Dispatcher = require_dispatcher2();
var UnwrapHandler = require_unwrap_handler();
var {
ClientDestroyedError,
ClientClosedError,
@@ -22458,7 +22373,6 @@ var require_dispatcher_base2 = __commonJS({
if (!handler || typeof handler !== "object") {
throw new InvalidArgumentError("handler must be an object");
}
handler = UnwrapHandler.unwrap(handler);
try {
if (!opts || typeof opts !== "object") {
throw new InvalidArgumentError("opts must be an object.");
@@ -22471,10 +22385,10 @@ var require_dispatcher_base2 = __commonJS({
}
return this[kDispatch](opts, handler);
} catch (err) {
if (typeof handler.onError !== "function") {
if (typeof handler.onResponseError !== "function") {
throw err;
}
handler.onError(err);
handler.onResponseError(null, err);
return false;
}
}
@@ -22525,7 +22439,7 @@ var require_connect2 = __commonJS({
const options = { path: socketPath, ...opts };
const sessionCache = new SessionCache(maxCachedSessions == null ? 100 : maxCachedSessions);
timeout = timeout == null ? 1e4 : timeout;
allowH2 = allowH2 != null ? allowH2 : false;
allowH2 = allowH2 != null ? allowH2 : true;
return function connect({ hostname, host, protocol, port, servername, localAddress, httpSocket }, callback) {
let socket;
if (protocol === "https:") {
@@ -25580,9 +25494,9 @@ var require_formdata_parser2 = __commonJS({
var { webidl } = require_webidl2();
var assert = require("node:assert");
var { isomorphicDecode } = require_infra();
var { utf8DecodeBytes } = require_encoding2();
var dd = Buffer.from("--");
var decoder = new TextDecoder();
var decoderIgnoreBOM = new TextDecoder("utf-8", { ignoreBOM: true });
function isAsciiString(chars) {
for (let i = 0; i < chars.length; ++i) {
if ((chars.charCodeAt(i) & ~127) !== 0) {
@@ -25659,7 +25573,7 @@ var require_formdata_parser2 = __commonJS({
}
value = new File([body], filename, { type: contentType });
} else {
value = utf8DecodeBytes(Buffer.from(body));
value = decoderIgnoreBOM.decode(Buffer.from(body));
}
assert(webidl.is.USVString(name));
assert(typeof value === "string" && webidl.is.USVString(value) || webidl.is.File(value));
@@ -26604,7 +26518,7 @@ var require_client_h12 = __commonJS({
client[kQueue][client[kRunningIdx]++] = null;
client.emit("disconnect", client[kUrl], [client], new InformationalError("upgrade"));
try {
request.onUpgrade(statusCode, headers, socket);
request.onRequestUpgrade(statusCode, headers, socket);
} catch (err) {
util.destroy(socket, err);
}
@@ -26678,7 +26592,7 @@ var require_client_h12 = __commonJS({
} else {
socket[kReset] = true;
}
const pause = request.onHeaders(statusCode, headers, this.resume, statusText) === false;
const pause = request.onResponseStart(statusCode, headers, this.resume, statusText) === false;
if (request.aborted) {
return -1;
}
@@ -26717,7 +26631,7 @@ var require_client_h12 = __commonJS({
return -1;
}
this.bytesRead += buf.length;
if (request.onData(buf) === false) {
if (request.onResponseData(buf) === false) {
return constants3.ERROR.PAUSED;
}
return 0;
@@ -26752,7 +26666,7 @@ var require_client_h12 = __commonJS({
util.destroy(socket, new ResponseContentLengthMismatchError());
return -1;
}
request.onComplete(headers);
request.onResponseEnd(headers);
client[kQueue][client[kRunningIdx]++] = null;
if (socket[kWriting]) {
assert(client[kRunning] === 0);
@@ -26991,7 +26905,7 @@ var require_client_h12 = __commonJS({
util.destroy(socket, new InformationalError("aborted"));
};
try {
request.onConnect(abort);
request.onRequestStart(abort, null);
} catch (err) {
util.errorRequest(client, request, err);
}
@@ -27720,7 +27634,7 @@ var require_client_h22 = __commonJS({
util.destroy(body, err);
};
try {
request.onConnect(abort);
request.onRequestStart(abort, null);
} catch (err) {
util.errorRequest(client, request, err);
}
@@ -27747,7 +27661,7 @@ var require_client_h22 = __commonJS({
stream[kHTTP2Stream] = true;
stream.once("response", (headers2, _flags) => {
const { [HTTP2_HEADER_STATUS]: statusCode, ...realHeaders } = headers2;
request.onUpgrade(statusCode, parseH2Headers(realHeaders), stream);
request.onRequestUpgrade(statusCode, parseH2Headers(realHeaders), stream);
++session[kOpenStreams];
client[kQueue][client[kRunningIdx]++] = null;
});
@@ -27767,7 +27681,7 @@ var require_client_h22 = __commonJS({
stream[kHTTP2Stream] = true;
stream.on("response", (headers2) => {
const { [HTTP2_HEADER_STATUS]: statusCode, ...realHeaders } = headers2;
request.onUpgrade(statusCode, parseH2Headers(realHeaders), stream);
request.onRequestUpgrade(statusCode, parseH2Headers(realHeaders), stream);
++session[kOpenStreams];
client[kQueue][client[kRunningIdx]++] = null;
});
@@ -27843,23 +27757,23 @@ var require_client_h22 = __commonJS({
stream.removeAllListeners("data");
return;
}
if (request.onHeaders(Number(statusCode), parseH2Headers(realHeaders), stream.resume.bind(stream), "") === false) {
stream.pause();
}
});
stream.on("data", (chunk) => {
if (request.aborted || request.completed) {
return;
}
if (request.onData(chunk) === false) {
if (request.onResponseStart(Number(statusCode), parseH2Headers(realHeaders), stream.resume.bind(stream), "") === false) {
stream.pause();
}
stream.on("data", (chunk) => {
if (request.aborted || request.completed) {
return;
}
if (request.onResponseData(chunk) === false) {
stream.pause();
}
});
});
stream.once("end", () => {
stream.removeAllListeners("data");
if (responseReceived) {
if (!request.aborted && !request.completed) {
request.onComplete({});
request.onResponseEnd({});
}
client[kQueue][client[kRunningIdx]++] = null;
client[kResume]();
@@ -27901,8 +27815,7 @@ var require_client_h22 = __commonJS({
if (request.aborted || request.completed) {
return;
}
stream.removeAllListeners("data");
request.onComplete(trailers);
request.onResponseEnd(trailers);
});
return true;
function writeBodyH2() {
@@ -28438,56 +28351,61 @@ var require_client2 = __commonJS({
connector: client[kConnector]
});
}
client[kConnector]({
host,
hostname,
protocol,
port,
servername: client[kServerName],
localAddress: client[kLocalAddress]
}, (err, socket) => {
if (err) {
handleConnectError(client, err, { host, hostname, protocol, port });
try {
client[kConnector]({
host,
hostname,
protocol,
port,
servername: client[kServerName],
localAddress: client[kLocalAddress]
}, (err, socket) => {
if (err) {
handleConnectError(client, err, { host, hostname, protocol, port });
client[kResume]();
return;
}
if (client.destroyed) {
util.destroy(socket.on("error", noop), new ClientDestroyedError());
client[kResume]();
return;
}
assert(socket);
try {
client[kHTTPContext] = socket.alpnProtocol === "h2" ? connectH2(client, socket) : connectH1(client, socket);
} catch (err2) {
socket.destroy().on("error", noop);
handleConnectError(client, err2, { host, hostname, protocol, port });
client[kResume]();
return;
}
client[kConnecting] = false;
socket[kCounter] = 0;
socket[kMaxRequests] = client[kMaxRequests];
socket[kClient] = client;
socket[kError] = null;
if (channels.connected.hasSubscribers) {
channels.connected.publish({
connectParams: {
host,
hostname,
protocol,
port,
version: client[kHTTPContext]?.version,
servername: client[kServerName],
localAddress: client[kLocalAddress]
},
connector: client[kConnector],
socket
});
}
client.emit("connect", client[kUrl], [client]);
client[kResume]();
return;
}
if (client.destroyed) {
util.destroy(socket.on("error", noop), new ClientDestroyedError());
client[kResume]();
return;
}
assert(socket);
try {
client[kHTTPContext] = socket.alpnProtocol === "h2" ? connectH2(client, socket) : connectH1(client, socket);
} catch (err2) {
socket.destroy().on("error", noop);
handleConnectError(client, err2, { host, hostname, protocol, port });
client[kResume]();
return;
}
client[kConnecting] = false;
socket[kCounter] = 0;
socket[kMaxRequests] = client[kMaxRequests];
socket[kClient] = client;
socket[kError] = null;
if (channels.connected.hasSubscribers) {
channels.connected.publish({
connectParams: {
host,
hostname,
protocol,
port,
version: client[kHTTPContext]?.version,
servername: client[kServerName],
localAddress: client[kLocalAddress]
},
connector: client[kConnector],
socket
});
}
client.emit("connect", client[kUrl], [client]);
});
} catch (err) {
handleConnectError(client, err, { host, hostname, protocol, port });
client[kResume]();
});
}
}
function handleConnectError(client, err, { host, hostname, protocol, port }) {
if (client.destroyed) {
@@ -28800,7 +28718,7 @@ var require_pool_base2 = __commonJS({
if (!item) {
break;
}
item.handler.onError(err);
item.handler.onResponseError(null, err);
}
const destroyAll = new Array(this[kClients].length);
for (let i = 0; i < this[kClients].length; i++) {
@@ -29353,6 +29271,88 @@ var require_agent2 = __commonJS({
}
});
// node_modules/undici/lib/dispatcher/dispatcher1-wrapper.js
var require_dispatcher1_wrapper = __commonJS({
"node_modules/undici/lib/dispatcher/dispatcher1-wrapper.js"(exports2, module2) {
"use strict";
var Dispatcher = require_dispatcher2();
var { InvalidArgumentError } = require_errors2();
var { toRawHeaders } = require_util9();
var LegacyHandlerWrapper = class {
#handler;
constructor(handler) {
this.#handler = handler;
}
onRequestStart(controller, context) {
this.#handler.onConnect?.((reason) => controller.abort(reason), context);
}
onRequestUpgrade(controller, statusCode, headers, socket) {
const rawHeaders = controller?.rawHeaders ?? toRawHeaders(headers ?? {});
this.#handler.onUpgrade?.(statusCode, rawHeaders, socket);
}
onResponseStart(controller, statusCode, headers, statusMessage) {
const rawHeaders = controller?.rawHeaders ?? toRawHeaders(headers ?? {});
if (this.#handler.onHeaders?.(statusCode, rawHeaders, () => controller.resume(), statusMessage) === false) {
controller.pause();
}
}
onResponseData(controller, chunk) {
if (this.#handler.onData?.(chunk) === false) {
controller.pause();
}
}
onResponseEnd(controller, trailers) {
const rawTrailers = controller?.rawTrailers ?? toRawHeaders(trailers ?? {});
this.#handler.onComplete?.(rawTrailers);
}
onResponseError(_controller, err) {
if (!this.#handler.onError) {
throw err;
}
this.#handler.onError(err);
}
onBodySent(chunk) {
this.#handler.onBodySent?.(chunk);
}
onRequestSent() {
this.#handler.onRequestSent?.();
}
onResponseStarted() {
this.#handler.onResponseStarted?.();
}
};
var Dispatcher1Wrapper = class _Dispatcher1Wrapper extends Dispatcher {
#dispatcher;
constructor(dispatcher) {
super();
if (!dispatcher || typeof dispatcher.dispatch !== "function") {
throw new InvalidArgumentError("Argument dispatcher must implement dispatch");
}
this.#dispatcher = dispatcher;
}
static wrapHandler(handler) {
if (!handler || typeof handler !== "object") {
throw new InvalidArgumentError("handler must be an object");
}
if (typeof handler.onRequestStart === "function") {
return handler;
}
return new LegacyHandlerWrapper(handler);
}
dispatch(opts, handler) {
return this.#dispatcher.dispatch(opts, _Dispatcher1Wrapper.wrapHandler(handler));
}
close(...args) {
return this.#dispatcher.close(...args);
}
destroy(...args) {
return this.#dispatcher.destroy(...args);
}
};
module2.exports = Dispatcher1Wrapper;
}
});
// node_modules/undici/lib/core/socks5-utils.js
var require_socks5_utils = __commonJS({
"node_modules/undici/lib/core/socks5-utils.js"(exports2, module2) {
@@ -30063,15 +30063,15 @@ var require_proxy_agent2 = __commonJS({
}
}
[kDispatch](opts, handler) {
const onHeaders = handler.onHeaders;
handler.onHeaders = function(statusCode, data, resume) {
const onResponseStart = handler.onResponseStart;
handler.onResponseStart = function(controller, statusCode, data, statusMessage) {
if (statusCode === 407) {
if (typeof handler.onError === "function") {
handler.onError(new InvalidArgumentError("Proxy Authentication Required (407)"));
if (typeof handler.onResponseError === "function") {
handler.onResponseError(controller, new InvalidArgumentError("Proxy Authentication Required (407)"));
}
return;
}
if (onHeaders) onHeaders.call(this, statusCode, data, resume);
if (onResponseStart) onResponseStart.call(this, controller, statusCode, data, statusMessage);
};
const {
origin,
@@ -30282,6 +30282,11 @@ var require_env_http_proxy_agent2 = __commonJS({
"http:": 80,
"https:": 443
};
function normalizeProxyUrl(proxyUrl, defaultScheme) {
if (!proxyUrl) return proxyUrl;
if (/^[a-z][a-z0-9+\-.]*:\/\//i.test(proxyUrl)) return proxyUrl;
return `${defaultScheme}://${proxyUrl}`;
}
var EnvHttpProxyAgent = class extends DispatcherBase {
#noProxyValue = null;
#noProxyEntries = null;
@@ -30291,13 +30296,19 @@ var require_env_http_proxy_agent2 = __commonJS({
this.#opts = opts;
const { httpProxy, httpsProxy, noProxy, ...agentOpts } = opts;
this[kNoProxyAgent] = new Agent(agentOpts);
const HTTP_PROXY = httpProxy ?? process.env.http_proxy ?? process.env.HTTP_PROXY;
const HTTP_PROXY = normalizeProxyUrl(
httpProxy ?? process.env.http_proxy ?? process.env.HTTP_PROXY,
"http"
);
if (HTTP_PROXY) {
this[kHttpProxyAgent] = new ProxyAgent3({ ...agentOpts, uri: HTTP_PROXY });
} else {
this[kHttpProxyAgent] = this[kNoProxyAgent];
}
const HTTPS_PROXY = httpsProxy ?? process.env.https_proxy ?? process.env.HTTPS_PROXY;
const HTTPS_PROXY = normalizeProxyUrl(
httpsProxy ?? process.env.https_proxy ?? process.env.HTTPS_PROXY,
"https"
);
if (HTTPS_PROXY) {
this[kHttpsProxyAgent] = new ProxyAgent3({ ...agentOpts, uri: HTTPS_PROXY });
} else {
@@ -30400,7 +30411,6 @@ var require_retry_handler2 = __commonJS({
var assert = require("node:assert");
var { kRetryHandlerDefaultRetry } = require_symbols6();
var { RequestRetryError } = require_errors2();
var WrapHandler = require_wrap_handler();
var {
isDisturbed,
parseRangeHeader,
@@ -30429,7 +30439,7 @@ var require_retry_handler2 = __commonJS({
} = retryOptions ?? {};
this.error = null;
this.dispatch = dispatch;
this.handler = WrapHandler.wrap(handler);
this.handler = handler;
this.opts = { ...dispatchOpts, body: wrapRequestBody(opts.body) };
this.retryOpts = {
throwOnError: throwOnError ?? true,
@@ -31231,6 +31241,7 @@ var require_api_request2 = __commonJS({
this.body = body;
this.trailers = {};
this.context = null;
this.controller = null;
this.onInfo = onInfo || null;
this.highWaterMark = highWaterMark;
this.reason = null;
@@ -31248,30 +31259,32 @@ var require_api_request2 = __commonJS({
});
}
}
onConnect(abort, context) {
onRequestStart(controller, context) {
if (this.reason) {
abort(this.reason);
controller.abort(this.reason);
return;
}
assert(this.callback);
this.abort = abort;
this.controller = controller;
this.abort = (reason) => controller.abort(reason);
this.context = context;
}
onHeaders(statusCode, rawHeaders, resume, statusMessage) {
const { callback, opaque, abort, context, responseHeaders, highWaterMark } = this;
const headers = responseHeaders === "raw" ? util.parseRawHeaders(rawHeaders) : util.parseHeaders(rawHeaders);
onResponseStart(controller, statusCode, headers, statusText) {
const { callback, opaque, context, responseHeaders, highWaterMark } = this;
const rawHeaders = controller?.rawHeaders;
const responseHeaderData = responseHeaders === "raw" ? Array.isArray(rawHeaders) ? util.parseRawHeaders(rawHeaders) : [] : headers;
if (statusCode < 200) {
if (this.onInfo) {
this.onInfo({ statusCode, headers });
this.onInfo({ statusCode, headers: responseHeaderData });
}
return;
}
const parsedHeaders = responseHeaders === "raw" ? util.parseHeaders(rawHeaders) : headers;
const contentType = parsedHeaders["content-type"];
const contentLength = parsedHeaders["content-length"];
const parsedHeaders = headers;
const contentType = parsedHeaders?.["content-type"];
const contentLength = parsedHeaders?.["content-length"];
const res = new Readable({
resume,
abort,
resume: () => controller.resume(),
abort: (reason) => controller.abort(reason),
contentType,
contentLength: this.method !== "HEAD" && contentLength ? Number(contentLength) : null,
highWaterMark
@@ -31286,8 +31299,8 @@ var require_api_request2 = __commonJS({
try {
this.runInAsyncScope(callback, null, null, {
statusCode,
statusText: statusMessage,
headers,
statusText,
headers: responseHeaderData,
trailers: this.trailers,
opaque,
body: res,
@@ -31302,14 +31315,32 @@ var require_api_request2 = __commonJS({
}
}
}
onData(chunk) {
return this.res.push(chunk);
onResponseData(controller, chunk) {
if (!this.res) {
return;
}
if (this.res.push(chunk) === false) {
controller.pause();
}
}
onComplete(trailers) {
util.parseHeaders(trailers, this.trailers);
this.res.push(null);
onResponseEnd(_controller, trailers) {
if (trailers && typeof trailers === "object") {
for (const key of Object.keys(trailers)) {
if (key === "__proto__") {
Object.defineProperty(this.trailers, key, {
value: trailers[key],
enumerable: true,
configurable: true,
writable: true
});
} else {
this.trailers[key] = trailers[key];
}
}
}
this.res?.push(null);
}
onError(err) {
onResponseError(_controller, err) {
const { res, callback, body, opaque } = this;
if (callback) {
this.callback = null;
@@ -31460,31 +31491,34 @@ var require_api_stream2 = __commonJS({
this.res = null;
this.abort = null;
this.context = null;
this.controller = null;
this.trailers = null;
this.body = body;
this.onInfo = onInfo || null;
if (util.isStream(body)) {
body.on("error", (err) => {
this.onError(err);
this.onResponseError(this.controller, err);
});
}
addSignal(this, signal);
}
onConnect(abort, context) {
onRequestStart(controller, context) {
if (this.reason) {
abort(this.reason);
controller.abort(this.reason);
return;
}
assert(this.callback);
this.abort = abort;
this.controller = controller;
this.abort = (reason) => controller.abort(reason);
this.context = context;
}
onHeaders(statusCode, rawHeaders, resume, statusMessage) {
onResponseStart(controller, statusCode, headers, _statusMessage) {
const { factory, opaque, context, responseHeaders } = this;
const headers = responseHeaders === "raw" ? util.parseRawHeaders(rawHeaders) : util.parseHeaders(rawHeaders);
const rawHeaders = controller?.rawHeaders;
const responseHeaderData = responseHeaders === "raw" ? Array.isArray(rawHeaders) ? util.parseRawHeaders(rawHeaders) : [] : headers;
if (statusCode < 200) {
if (this.onInfo) {
this.onInfo({ statusCode, headers });
this.onInfo({ statusCode, headers: responseHeaderData });
}
return;
}
@@ -31494,7 +31528,7 @@ var require_api_stream2 = __commonJS({
}
const res = this.runInAsyncScope(factory, null, {
statusCode,
headers,
headers: responseHeaderData,
opaque,
context
});
@@ -31513,25 +31547,34 @@ var require_api_stream2 = __commonJS({
abort();
}
});
res.on("drain", resume);
res.on("drain", () => controller.resume());
this.res = res;
const needDrain = res.writableNeedDrain !== void 0 ? res.writableNeedDrain : res._writableState?.needDrain;
return needDrain !== true;
if (needDrain === true) {
controller.pause();
}
}
onData(chunk) {
onResponseData(controller, chunk) {
const { res } = this;
return res ? res.write(chunk) : true;
if (!res) {
return;
}
if (res.write(chunk) === false) {
controller.pause();
}
}
onComplete(trailers) {
onResponseEnd(_controller, trailers) {
const { res } = this;
removeSignal(this);
if (!res) {
return;
}
this.trailers = util.parseHeaders(trailers);
if (trailers && typeof trailers === "object") {
this.trailers = trailers;
}
res.end();
}
onError(err) {
onResponseError(_controller, err) {
const { res, callback, opaque, body } = this;
removeSignal(this);
this.factory = null;
@@ -31690,33 +31733,35 @@ var require_api_pipeline2 = __commonJS({
this.res = null;
addSignal(this, signal);
}
onConnect(abort, context) {
onRequestStart(controller, context) {
const { res } = this;
if (this.reason) {
abort(this.reason);
controller.abort(this.reason);
return;
}
assert(!res, "pipeline cannot be retried");
this.abort = abort;
this.abort = (reason) => controller.abort(reason);
this.context = context;
}
onHeaders(statusCode, rawHeaders, resume) {
onResponseStart(controller, statusCode, headers, _statusMessage) {
const { opaque, handler, context } = this;
if (statusCode < 200) {
if (this.onInfo) {
const headers = this.responseHeaders === "raw" ? util.parseRawHeaders(rawHeaders) : util.parseHeaders(rawHeaders);
this.onInfo({ statusCode, headers });
const rawHeaders = controller?.rawHeaders;
const responseHeaders = this.responseHeaders === "raw" ? Array.isArray(rawHeaders) ? util.parseRawHeaders(rawHeaders) : [] : headers;
this.onInfo({ statusCode, headers: responseHeaders });
}
return;
}
this.res = new PipelineResponse(resume);
this.res = new PipelineResponse(() => controller.resume());
let body;
try {
this.handler = null;
const headers = this.responseHeaders === "raw" ? util.parseRawHeaders(rawHeaders) : util.parseHeaders(rawHeaders);
const rawHeaders = controller?.rawHeaders;
const responseHeaders = this.responseHeaders === "raw" ? Array.isArray(rawHeaders) ? util.parseRawHeaders(rawHeaders) : [] : headers;
body = this.runInAsyncScope(handler, null, {
statusCode,
headers,
headers: responseHeaders,
opaque,
body: this.res,
context
@@ -31747,15 +31792,17 @@ var require_api_pipeline2 = __commonJS({
});
this.body = body;
}
onData(chunk) {
onResponseData(controller, chunk) {
const { res } = this;
return res.push(chunk);
if (res.push(chunk) === false) {
controller.pause();
}
}
onComplete(trailers) {
onResponseEnd(_controller, _trailers) {
const { res } = this;
res.push(null);
}
onError(err) {
onResponseError(_controller, err) {
const { ret } = this;
this.handler = null;
util.destroy(ret, err);
@@ -31804,32 +31851,33 @@ var require_api_upgrade2 = __commonJS({
this.context = null;
addSignal(this, signal);
}
onConnect(abort, context) {
onRequestStart(controller, context) {
if (this.reason) {
abort(this.reason);
controller.abort(this.reason);
return;
}
assert(this.callback);
this.abort = abort;
this.context = null;
this.abort = (reason) => controller.abort(reason);
this.context = context;
}
onHeaders() {
onResponseStart() {
throw new SocketError("bad upgrade", null);
}
onUpgrade(statusCode, rawHeaders, socket) {
onRequestUpgrade(controller, statusCode, headers, socket) {
assert(socket[kHTTP2Stream] === true ? statusCode === 200 : statusCode === 101);
const { callback, opaque, context } = this;
removeSignal(this);
this.callback = null;
const headers = this.responseHeaders === "raw" ? util.parseRawHeaders(rawHeaders) : util.parseHeaders(rawHeaders);
const rawHeaders = controller?.rawHeaders;
const responseHeaders = this.responseHeaders === "raw" ? Array.isArray(rawHeaders) ? util.parseRawHeaders(rawHeaders) : [] : headers;
this.runInAsyncScope(callback, null, null, {
headers,
headers: responseHeaders,
socket,
opaque,
context
});
}
onError(err) {
onResponseError(_controller, err) {
const { callback, opaque } = this;
removeSignal(this);
if (callback) {
@@ -31896,35 +31944,36 @@ var require_api_connect2 = __commonJS({
this.abort = null;
addSignal(this, signal);
}
onConnect(abort, context) {
onRequestStart(controller, context) {
if (this.reason) {
abort(this.reason);
controller.abort(this.reason);
return;
}
assert(this.callback);
this.abort = abort;
this.abort = (reason) => controller.abort(reason);
this.context = context;
}
onHeaders() {
onResponseStart() {
throw new SocketError("bad connect", null);
}
onUpgrade(statusCode, rawHeaders, socket) {
onRequestUpgrade(controller, statusCode, headers, socket) {
const { callback, opaque, context } = this;
removeSignal(this);
this.callback = null;
let headers = rawHeaders;
if (headers != null) {
headers = this.responseHeaders === "raw" ? util.parseRawHeaders(rawHeaders) : util.parseHeaders(rawHeaders);
let responseHeaders = headers;
const rawHeaders = controller?.rawHeaders;
if (responseHeaders != null) {
responseHeaders = this.responseHeaders === "raw" ? Array.isArray(rawHeaders) ? util.parseRawHeaders(rawHeaders) : [] : headers;
}
this.runInAsyncScope(callback, null, null, {
statusCode,
headers,
headers: responseHeaders,
socket,
opaque,
context
});
}
onError(err) {
onResponseError(_controller, err) {
const { callback, opaque } = this;
removeSignal(this);
if (callback) {
@@ -32028,7 +32077,8 @@ var require_mock_symbols2 = __commonJS({
kMockAgentAddCallHistoryLog: /* @__PURE__ */ Symbol("mock agent add call history log"),
kMockAgentIsCallHistoryEnabled: /* @__PURE__ */ Symbol("mock agent is call history enabled"),
kMockAgentAcceptsNonStandardSearchParameters: /* @__PURE__ */ Symbol("mock agent accepts non standard search parameters"),
kMockCallHistoryAddLog: /* @__PURE__ */ Symbol("mock call history add log")
kMockCallHistoryAddLog: /* @__PURE__ */ Symbol("mock call history add log"),
kTotalDispatchCount: /* @__PURE__ */ Symbol("total dispatch count")
};
}
});
@@ -32043,9 +32093,10 @@ var require_mock_utils2 = __commonJS({
kMockAgent,
kOriginalDispatch,
kOrigin,
kGetNetConnect
kGetNetConnect,
kTotalDispatchCount
} = require_mock_symbols2();
var { serializePathWithQuery } = require_util9();
var { serializePathWithQuery, parseHeaders } = require_util9();
var { STATUS_CODES } = require("node:http");
var {
types: {
@@ -32203,6 +32254,7 @@ var require_mock_utils2 = __commonJS({
const replyData = typeof data === "function" ? { callback: data } : { ...data };
const newMockDispatch = { ...baseData, ...key, pending: true, data: { error: null, ...replyData } };
mockDispatches.push(newMockDispatch);
mockDispatches[kTotalDispatchCount] = (mockDispatches[kTotalDispatchCount] || 0) + 1;
return newMockDispatch;
}
function deleteMockDispatch(mockDispatches, key) {
@@ -32275,23 +32327,34 @@ var require_mock_utils2 = __commonJS({
mockDispatch2.pending = timesInvoked < times;
if (error2 !== null) {
deleteMockDispatch(this[kDispatches], key);
handler.onError(error2);
handler.onResponseError(null, error2);
return true;
}
let aborted = false;
let timer = null;
function abort(err) {
if (aborted) {
return;
const controller = {
paused: false,
rawHeaders: null,
rawTrailers: null,
pause() {
this.paused = true;
},
resume() {
this.paused = false;
},
abort: (reason) => {
if (aborted) {
return;
}
aborted = true;
if (timer !== null) {
clearTimeout(timer);
timer = null;
}
handler.onResponseError?.(controller, reason);
}
aborted = true;
if (timer !== null) {
clearTimeout(timer);
timer = null;
}
handler.onError(err);
}
handler.onConnect?.(abort, null);
};
handler.onRequestStart?.(controller, null);
if (typeof delay === "number" && delay > 0) {
timer = setTimeout(() => {
timer = null;
@@ -32315,13 +32378,13 @@ var require_mock_utils2 = __commonJS({
const responseData = getResponseData(body);
const responseHeaders = generateKeyValues(headers);
const responseTrailers = generateKeyValues(trailers);
handler.onHeaders?.(statusCode, responseHeaders, resume, getStatusText(statusCode));
handler.onData?.(Buffer.from(responseData));
handler.onComplete?.(responseTrailers);
controller.rawHeaders = responseHeaders;
controller.rawTrailers = responseTrailers;
handler.onResponseStart?.(controller, statusCode, parseHeaders(responseHeaders), getStatusText(statusCode));
handler.onResponseData?.(controller, Buffer.from(responseData));
handler.onResponseEnd?.(controller, parseHeaders(responseTrailers));
deleteMockDispatch(mockDispatches, key);
}
function resume() {
}
return true;
}
function buildMockDispatch() {
@@ -32335,13 +32398,16 @@ var require_mock_utils2 = __commonJS({
} catch (error2) {
if (error2.code === "UND_MOCK_ERR_MOCK_NOT_MATCHED") {
const netConnect = agent[kGetNetConnect]();
const totalInterceptsCount = this[kDispatches][kTotalDispatchCount] || this[kDispatches].length;
const pendingInterceptsCount = this[kDispatches].filter(({ consumed }) => !consumed).length;
const interceptsMessage = `, ${pendingInterceptsCount} interceptor(s) remaining out of ${totalInterceptsCount} defined`;
if (netConnect === false) {
throw new MockNotMatchedError(`${error2.message}: subsequent request to origin ${origin} was not allowed (net.connect disabled)`);
throw new MockNotMatchedError(`${error2.message}: subsequent request to origin ${origin} was not allowed (net.connect disabled)${interceptsMessage}`);
}
if (checkNetConnect(netConnect, origin)) {
originalDispatch.call(this, opts, handler);
} else {
throw new MockNotMatchedError(`${error2.message}: subsequent request to origin ${origin} was not allowed (net.connect is not enabled for this origin)`);
throw new MockNotMatchedError(`${error2.message}: subsequent request to origin ${origin} was not allowed (net.connect is not enabled for this origin)${interceptsMessage}`);
}
} else {
throw error2;
@@ -33585,8 +33651,8 @@ var require_snapshot_agent = __commonJS({
var Agent = require_agent2();
var MockAgent = require_mock_agent2();
var { SnapshotRecorder } = require_snapshot_recorder();
var WrapHandler = require_wrap_handler();
var { InvalidArgumentError, UndiciError } = require_errors2();
var util = require_util9();
var { validateSnapshotMode } = require_snapshot_utils();
var kSnapshotRecorder = /* @__PURE__ */ Symbol("kSnapshotRecorder");
var kSnapshotMode = /* @__PURE__ */ Symbol("kSnapshotMode");
@@ -33641,7 +33707,6 @@ var require_snapshot_agent = __commonJS({
}
}
dispatch(opts, handler) {
handler = WrapHandler.wrap(handler);
const mode = this[kSnapshotMode];
if (this[kSnapshotRecorder].isUrlExcluded(opts)) {
return this[kRealAgent].dispatch(opts, handler);
@@ -33657,8 +33722,8 @@ var require_snapshot_agent = __commonJS({
return this.#recordAndReplay(opts, handler);
} else {
const error2 = new UndiciError(`No snapshot found for ${opts.method || "GET"} ${opts.path}`);
if (handler.onError) {
handler.onError(error2);
if (handler.onResponseError) {
handler.onResponseError(null, error2);
return;
}
throw error2;
@@ -33710,6 +33775,9 @@ var require_snapshot_agent = __commonJS({
body: responseBody,
trailers: responseData.trailers
}).then(() => handler.onResponseEnd(controller, trailers)).catch((error2) => handler.onResponseError(controller, error2));
},
onResponseError(controller, error2) {
return handler.onResponseError(controller, error2);
}
};
const agent = this[kRealAgent];
@@ -33725,7 +33793,11 @@ var require_snapshot_agent = __commonJS({
#replaySnapshot(snapshot, handler) {
try {
const { response } = snapshot;
const rawHeaders = response.headers ? util.toRawHeaders(response.headers) : [];
const rawTrailers = response.trailers ? util.toRawHeaders(response.trailers) : [];
const controller = {
rawHeaders,
rawTrailers,
pause() {
},
resume() {
@@ -33738,12 +33810,12 @@ var require_snapshot_agent = __commonJS({
paused: false
};
handler.onRequestStart(controller);
handler.onResponseStart(controller, response.statusCode, response.headers);
handler.onResponseStart(controller, response.statusCode, response.headers, response.statusMessage);
const body = Buffer.from(response.body, "base64");
handler.onResponseData(controller, body);
handler.onResponseEnd(controller, response.trailers);
} catch (error2) {
handler.onError?.(error2);
handler.onResponseError?.(null, error2);
}
}
/**
@@ -33869,9 +33941,12 @@ var require_snapshot_agent = __commonJS({
var require_global4 = __commonJS({
"node_modules/undici/lib/global.js"(exports2, module2) {
"use strict";
var globalDispatcher = /* @__PURE__ */ Symbol.for("undici.globalDispatcher.1");
var globalDispatcher = /* @__PURE__ */ Symbol.for("undici.globalDispatcher.2");
var legacyGlobalDispatcher = /* @__PURE__ */ Symbol.for("undici.globalDispatcher.1");
var { InvalidArgumentError } = require_errors2();
var Agent = require_agent2();
var Dispatcher1Wrapper = require_dispatcher1_wrapper();
var nodeMajor = Number(process.versions.node.split(".", 1)[0]);
if (getGlobalDispatcher() === void 0) {
setGlobalDispatcher(new Agent());
}
@@ -33885,6 +33960,15 @@ var require_global4 = __commonJS({
enumerable: false,
configurable: false
});
if (nodeMajor === 22) {
const legacyAgent = agent instanceof Dispatcher1Wrapper ? agent : new Dispatcher1Wrapper(agent);
Object.defineProperty(globalThis, legacyGlobalDispatcher, {
value: legacyAgent,
writable: true,
enumerable: false,
configurable: false
});
}
}
function getGlobalDispatcher() {
return globalThis[globalDispatcher];
@@ -33917,7 +34001,6 @@ var require_decorator_handler2 = __commonJS({
"node_modules/undici/lib/handler/decorator-handler.js"(exports2, module2) {
"use strict";
var assert = require("node:assert");
var WrapHandler = require_wrap_handler();
module2.exports = class DecoratorHandler {
#handler;
#onCompleteCalled = false;
@@ -33927,7 +34010,7 @@ var require_decorator_handler2 = __commonJS({
if (typeof handler !== "object" || handler === null) {
throw new TypeError("handler must be an object");
}
this.#handler = WrapHandler.wrap(handler);
this.#handler = handler;
}
onRequestStart(...args) {
this.#handler.onRequestStart?.(...args);
@@ -35650,7 +35733,7 @@ var require_cache_handler = __commonJS({
return downstreamOnHeaders();
}
const cacheControlDirectives = cacheControlHeader ? parseCacheControlHeader(cacheControlHeader) : {};
if (!canCacheResponse(this.#cacheType, statusCode, resHeaders, cacheControlDirectives)) {
if (!canCacheResponse(this.#cacheType, statusCode, resHeaders, cacheControlDirectives, this.#cacheKey.headers)) {
return downstreamOnHeaders();
}
const now = Date.now();
@@ -35675,7 +35758,8 @@ var require_cache_handler = __commonJS({
return downstreamOnHeaders();
}
}
const deleteAt = determineDeleteAt(baseTime, cacheControlDirectives, absoluteStaleAt);
const cachedAt = resAge ? now - resAge : now;
const deleteAt = determineDeleteAt(baseTime, cachedAt, cacheControlDirectives, absoluteStaleAt);
const strippedHeaders = stripNecessaryHeaders(resHeaders, cacheControlDirectives);
const value = {
statusCode,
@@ -35683,7 +35767,7 @@ var require_cache_handler = __commonJS({
headers: strippedHeaders,
vary: varyDirectives,
cacheControlDirectives,
cachedAt: resAge ? now - resAge : now,
cachedAt,
staleAt: absoluteStaleAt,
deleteAt
};
@@ -35785,7 +35869,7 @@ var require_cache_handler = __commonJS({
this.#handler.onResponseError?.(controller, err);
}
};
function canCacheResponse(cacheType, statusCode, resHeaders, cacheControlDirectives) {
function canCacheResponse(cacheType, statusCode, resHeaders, cacheControlDirectives, reqHeaders) {
if (statusCode < 200 || NOT_UNDERSTOOD_STATUS_CODES.includes(statusCode)) {
return false;
}
@@ -35802,8 +35886,11 @@ var require_cache_handler = __commonJS({
if (resHeaders.vary?.includes("*")) {
return false;
}
if (resHeaders.authorization) {
if (!cacheControlDirectives.public || typeof resHeaders.authorization !== "string") {
if (reqHeaders?.authorization) {
if (!cacheControlDirectives.public && !cacheControlDirectives["s-maxage"] && !cacheControlDirectives["must-revalidate"]) {
return false;
}
if (typeof reqHeaders.authorization !== "string") {
return false;
}
if (Array.isArray(cacheControlDirectives["no-cache"]) && cacheControlDirectives["no-cache"].includes("authorization")) {
@@ -35862,7 +35949,7 @@ var require_cache_handler = __commonJS({
}
return void 0;
}
function determineDeleteAt(now, cacheControlDirectives, staleAt) {
function determineDeleteAt(baseTime, cachedAt, cacheControlDirectives, staleAt) {
let staleWhileRevalidate = -Infinity;
let staleIfError = -Infinity;
let immutable = -Infinity;
@@ -35872,8 +35959,13 @@ var require_cache_handler = __commonJS({
if (cacheControlDirectives["stale-if-error"]) {
staleIfError = staleAt + cacheControlDirectives["stale-if-error"] * 1e3;
}
if (staleWhileRevalidate === -Infinity && staleIfError === -Infinity) {
immutable = now + 31536e6;
if (cacheControlDirectives.immutable && staleWhileRevalidate === -Infinity && staleIfError === -Infinity) {
immutable = cachedAt + 31536e6;
}
if (staleWhileRevalidate === -Infinity && staleIfError === -Infinity && immutable === -Infinity) {
const freshnessLifetime = staleAt - baseTime;
const datePrecisionPadding = Math.min(Math.max(cachedAt - baseTime, 0), 1e3);
return staleAt + freshnessLifetime + datePrecisionPadding;
}
return Math.max(staleAt, staleWhileRevalidate, staleIfError, immutable);
}
@@ -36249,27 +36341,34 @@ var require_cache3 = __commonJS({
function handleUncachedResponse(dispatch, globalOpts, cacheKey, handler, opts, reqCacheControl) {
if (reqCacheControl?.["only-if-cached"]) {
let aborted = false;
const controller = {
paused: false,
rawHeaders: [],
rawTrailers: [],
pause() {
this.paused = true;
},
resume() {
this.paused = false;
},
abort: (reason) => {
aborted = true;
handler.onResponseError?.(controller, reason ?? new AbortError());
}
};
try {
if (typeof handler.onConnect === "function") {
handler.onConnect(() => {
aborted = true;
});
if (aborted) {
return;
}
handler.onRequestStart?.(controller, null);
if (aborted) {
return;
}
if (typeof handler.onHeaders === "function") {
handler.onHeaders(504, [], nop, "Gateway Timeout");
if (aborted) {
return;
}
}
if (typeof handler.onComplete === "function") {
handler.onComplete([]);
handler.onResponseStart?.(controller, 504, {}, "Gateway Timeout");
if (aborted) {
return;
}
handler.onResponseEnd?.(controller, {});
} catch (err) {
if (typeof handler.onError === "function") {
handler.onError(err);
if (typeof handler.onResponseError === "function") {
handler.onResponseError(controller, err);
}
}
return true;
@@ -36281,6 +36380,8 @@ var require_cache3 = __commonJS({
assert(!stream.destroyed, "stream should not be destroyed");
assert(!stream.readableDidRead, "stream should not be readableDidRead");
const controller = {
rawHeaders: [],
rawTrailers: [],
resume() {
stream.resume();
},
@@ -36321,6 +36422,7 @@ var require_cache3 = __commonJS({
if (isStale2) {
headers.warning = '110 - "response is stale"';
}
controller.rawHeaders = util.toRawHeaders(headers);
handler.onResponseStart?.(controller, result.statusCode, headers, result.statusMessage);
if (opts.method === "HEAD") {
stream.destroy();
@@ -36667,6 +36769,29 @@ var require_decompress = __commonJS({
}
this.#decompressors = decompressors;
const { "content-encoding": _, "content-length": __, ...newHeaders } = headers;
if (controller?.rawHeaders) {
const rawHeaders = controller.rawHeaders;
if (Array.isArray(rawHeaders)) {
const filteredHeaders = [];
for (let i = 0; i < rawHeaders.length; i += 2) {
const headerName = rawHeaders[i];
const name = Buffer.isBuffer(headerName) ? headerName.toString("latin1") : `${headerName}`;
const lowerName = name.toLowerCase();
if (lowerName === "content-encoding" || lowerName === "content-length") {
continue;
}
filteredHeaders.push(rawHeaders[i], rawHeaders[i + 1]);
}
controller.rawHeaders = filteredHeaders;
} else if (typeof rawHeaders === "object") {
for (const name of Object.keys(rawHeaders)) {
const lowerName = name.toLowerCase();
if (lowerName === "content-encoding" || lowerName === "content-length") {
delete rawHeaders[name];
}
}
}
}
if (this.#decompressors.length === 1) {
this.#setupSingleDecompressor(controller);
} else {
@@ -40270,9 +40395,11 @@ var require_fetch2 = __commonJS({
function dispatch({ body }) {
const url = requestCurrentURL(request);
const agent = fetchParams.controller.dispatcher;
const path = url.pathname + url.search;
const hasTrailingQuestionMark = url.search.length === 0 && url.href[url.href.length - url.hash.length - 1] === "?";
return new Promise((resolve, reject) => agent.dispatch(
{
path: url.href.slice(url.href.indexOf(url.host) + url.host.length, url.hash.length ? -url.hash.length : void 0),
path: hasTrailingQuestionMark ? `${path}?` : path,
origin: url.origin,
method: request.method,
body: agent.isMockActive ? request.body && (request.body.source || request.body.stream) : body,
@@ -40283,9 +40410,10 @@ var require_fetch2 = __commonJS({
{
body: null,
abort: null,
onConnect(abort) {
onRequestStart(controller) {
const { connection } = fetchParams.controller;
timingInfo.finalConnectionTimingInfo = clampAndCoarsenConnectionTimingInfo(void 0, timingInfo.postRedirectStartTime, fetchParams.crossOriginIsolatedCapability);
const abort = (reason) => controller.abort(reason);
if (connection.destroyed) {
abort(new DOMException("The operation was aborted.", "AbortError"));
} else {
@@ -40297,16 +40425,25 @@ var require_fetch2 = __commonJS({
onResponseStarted() {
timingInfo.finalNetworkResponseStartTime = coarsenedSharedCurrentTime(fetchParams.crossOriginIsolatedCapability);
},
onHeaders(status, rawHeaders, resume, statusText) {
onResponseStart(controller, status, _headers, statusText) {
if (status < 200) {
return false;
return;
}
const rawHeaders = controller?.rawHeaders ?? [];
const headersList = new HeadersList();
for (let i = 0; i < rawHeaders.length; i += 2) {
headersList.append(bufferToLowerCasedHeaderName(rawHeaders[i]), rawHeaders[i + 1].toString("latin1"), true);
const nameStr = bufferToLowerCasedHeaderName(rawHeaders[i]);
const value = rawHeaders[i + 1];
if (Array.isArray(value) && !Buffer.isBuffer(rawHeaders[i + 1])) {
for (const val of value) {
headersList.append(nameStr, val.toString("latin1"), true);
}
} else {
headersList.append(nameStr, value.toString("latin1"), true);
}
}
const location = headersList.get("location", true);
this.body = new Readable({ read: resume });
this.body = new Readable({ read: () => controller.resume() });
const willFollow = location && request.redirect === "follow" && redirectStatusSet.has(status);
const decoders = [];
if (request.method !== "HEAD" && request.method !== "CONNECT" && !nullBodyStatus.includes(status) && !willFollow) {
@@ -40315,7 +40452,7 @@ var require_fetch2 = __commonJS({
const maxContentEncodings = 5;
if (codings.length > maxContentEncodings) {
reject(new Error(`too many content-encodings in response: ${codings.length}, maximum allowed is ${maxContentEncodings}`));
return true;
return;
}
for (let i = codings.length - 1; i >= 0; --i) {
const coding = codings[i].trim();
@@ -40349,35 +40486,36 @@ var require_fetch2 = __commonJS({
}
}
}
const onError = this.onError.bind(this);
const onError = (err) => this.onResponseError(controller, err);
resolve({
status,
statusText,
headersList,
body: decoders.length ? pipeline(this.body, ...decoders, (err) => {
if (err) {
this.onError(err);
this.onResponseError(controller, err);
}
}).on("error", onError) : this.body.on("error", onError)
});
return true;
},
onData(chunk) {
onResponseData(controller, chunk) {
if (fetchParams.controller.dump) {
return;
}
const bytes = chunk;
timingInfo.encodedBodySize += bytes.byteLength;
return this.body.push(bytes);
if (this.body.push(bytes) === false) {
controller.pause();
}
},
onComplete() {
onResponseEnd() {
if (this.abort) {
fetchParams.controller.off("terminated", this.abort);
}
fetchParams.controller.ended = true;
this.body.push(null);
this.body?.push(null);
},
onError(error2) {
onResponseError(_controller, error2) {
if (this.abort) {
fetchParams.controller.off("terminated", this.abort);
}
@@ -40385,39 +40523,22 @@ var require_fetch2 = __commonJS({
fetchParams.controller.terminate(error2);
reject(error2);
},
onRequestUpgrade(_controller, status, headers, socket) {
if (socket.session != null && status !== 200 || socket.session == null && status !== 101) {
return false;
}
const headersList = new HeadersList();
for (const [name, value] of Object.entries(headers)) {
if (value == null) {
continue;
}
const headerName = name.toLowerCase();
if (Array.isArray(value)) {
for (const entry of value) {
headersList.append(headerName, String(entry), true);
}
} else {
headersList.append(headerName, String(value), true);
}
}
resolve({
status,
statusText: STATUS_CODES[status],
headersList,
socket
});
return true;
},
onUpgrade(status, rawHeaders, socket) {
onRequestUpgrade(controller, status, _headers, socket) {
if (socket.session != null && status !== 200 || socket.session == null && status !== 101) {
return false;
}
const rawHeaders = controller?.rawHeaders ?? [];
const headersList = new HeadersList();
for (let i = 0; i < rawHeaders.length; i += 2) {
headersList.append(bufferToLowerCasedHeaderName(rawHeaders[i]), rawHeaders[i + 1].toString("latin1"), true);
const nameStr = bufferToLowerCasedHeaderName(rawHeaders[i]);
const value = rawHeaders[i + 1];
if (Array.isArray(value) && !Buffer.isBuffer(rawHeaders[i + 1])) {
for (const val of value) {
headersList.append(nameStr, val.toString("latin1"), true);
}
} else {
headersList.append(nameStr, value.toString("latin1"), true);
}
}
resolve({
status,
@@ -42876,6 +42997,15 @@ var require_websocket2 = __commonJS({
var { SendQueue } = require_sender2();
var { WebsocketFrameSend } = require_frame2();
var { channels } = require_diagnostics2();
function getSocketAddress(socket) {
if (typeof socket?.address === "function") {
return socket.address();
}
if (typeof socket?.session?.socket?.address === "function") {
return socket.session.socket.address();
}
return null;
}
var WebSocket = class _WebSocket extends EventTarget {
#events = {
open: null,
@@ -43147,7 +43277,7 @@ var require_websocket2 = __commonJS({
if (channels.open.hasSubscribers) {
const headers = response.headersList.entries;
channels.open.publish({
address: response.socket.address(),
address: getSocketAddress(response.socket),
protocol: this.#protocol,
extensions: this.#extensions,
websocket: this,
@@ -44294,6 +44424,7 @@ var require_undici2 = __commonJS({
var BalancedPool = require_balanced_pool2();
var RoundRobinPool = require_round_robin_pool();
var Agent = require_agent2();
var Dispatcher1Wrapper = require_dispatcher1_wrapper();
var ProxyAgent3 = require_proxy_agent2();
var Socks5ProxyAgent = require_socks5_proxy_agent();
var EnvHttpProxyAgent = require_env_http_proxy_agent2();
@@ -44321,6 +44452,7 @@ var require_undici2 = __commonJS({
module2.exports.BalancedPool = BalancedPool;
module2.exports.RoundRobinPool = RoundRobinPool;
module2.exports.Agent = Agent;
module2.exports.Dispatcher1Wrapper = Dispatcher1Wrapper;
module2.exports.ProxyAgent = ProxyAgent3;
module2.exports.Socks5ProxyAgent = Socks5ProxyAgent;
module2.exports.EnvHttpProxyAgent = EnvHttpProxyAgent;