Skip to content

chore(deps): bump undici from 6.23.0 to 6.24.1 #622

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
willmurphyscode merged 2 commits into from
Mar 18, 2026
Merged

chore(deps): bump undici from 6.23.0 to 6.24.1 #622

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
bd3e1c2
chore(deps): bump undici from 6.23.0 to 6.24.1
dependabot[bot] Mar 18, 2026
74a0fb3
chore: commit dist
willmurphyscode Mar 18, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
91 changes: 81 additions & 10 deletions dist/index.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -937,6 +937,21 @@ var require_errors = __commonJS({
}
[kSecureProxyConnectionError] = true;
};
var kMessageSizeExceededError = /* @__PURE__ */ Symbol.for("undici.error.UND_ERR_WS_MESSAGE_SIZE_EXCEEDED");
var MessageSizeExceededError = class extends UndiciError {
constructor(message) {
super(message);
this.name = "MessageSizeExceededError";
this.message = message || "Max decompressed message size exceeded";
this.code = "UND_ERR_WS_MESSAGE_SIZE_EXCEEDED";
}
static [Symbol.hasInstance](instance) {
return instance && instance[kMessageSizeExceededError] === true;
}
get [kMessageSizeExceededError]() {
return true;
}
};
module2.exports = {
AbortError: AbortError3,
HTTPParserError,
Expand All @@ -960,7 +975,8 @@ var require_errors = __commonJS({
ResponseExceededMaxSizeError,
RequestRetryError,
ResponseError,
SecureProxyConnectionError
SecureProxyConnectionError,
MessageSizeExceededError
};
}
});
Expand Down Expand Up @@ -1970,6 +1986,9 @@ var require_request = __commonJS({
if (upgrade && typeof upgrade !== "string") {
throw new InvalidArgumentError("upgrade must be a string");
}
if (upgrade && !isValidHeaderValue(upgrade)) {
throw new InvalidArgumentError("invalid upgrade header");
}
if (headersTimeout != null && (!Number.isFinite(headersTimeout) || headersTimeout < 0)) {
throw new InvalidArgumentError("invalid headersTimeout");
}
Expand Down Expand Up @@ -2202,12 +2221,18 @@ var require_request = __commonJS({
} else {
val = `${val}`;
}
if (request.host === null && headerName === "host") {
if (headerName === "host") {
if (request.host !== null) {
throw new InvalidArgumentError("duplicate host header");
}
if (typeof val !== "string") {
throw new InvalidArgumentError("invalid host header");
}
request.host = val;
} else if (request.contentLength === null && headerName === "content-length") {
} else if (headerName === "content-length") {
if (request.contentLength !== null) {
throw new InvalidArgumentError("duplicate content-length header");
}
request.contentLength = parseInt(val, 10);
if (!Number.isFinite(request.contentLength)) {
throw new InvalidArgumentError("invalid content-length header");
Expand Down Expand Up @@ -16979,13 +17004,17 @@ var require_util7 = __commonJS({
return extensionList;
}
function isValidClientWindowBits(value) {
if (value.length === 0) {
return false;
}
for (let i = 0; i < value.length; i++) {
const byte = value.charCodeAt(i);
if (byte < 48 || byte > 57) {
return false;
}
}
return true;
const num = Number.parseInt(value, 10);
return num >= 8 && num <= 15;
}
var hasIntl = typeof process.versions.icu === "string";
var fatalDecoder = hasIntl ? new TextDecoder("utf-8", { fatal: true }) : void 0;
Expand Down Expand Up @@ -17284,18 +17313,31 @@ var require_permessage_deflate = __commonJS({
"use strict";
var { createInflateRaw, Z_DEFAULT_WINDOWBITS } = require("node:zlib");
var { isValidClientWindowBits } = require_util7();
var { MessageSizeExceededError } = require_errors();
var tail = Buffer.from([0, 0, 255, 255]);
var kBuffer = /* @__PURE__ */ Symbol("kBuffer");
var kLength = /* @__PURE__ */ Symbol("kLength");
var kDefaultMaxDecompressedSize = 4 * 1024 * 1024;
var PerMessageDeflate = class {
/** @type {import('node:zlib').InflateRaw} */
#inflate;
#options = {};
/** @type {boolean} */
#aborted = false;
/** @type {Function|null} */
#currentCallback = null;
/**
* @param {Map<string, string>} extensions
*/
constructor(extensions) {
this.#options.serverNoContextTakeover = extensions.has("server_no_context_takeover");
this.#options.serverMaxWindowBits = extensions.get("server_max_window_bits");
}
decompress(chunk, fin, callback) {
if (this.#aborted) {
callback(new MessageSizeExceededError());
return;
}
if (!this.#inflate) {
let windowBits = Z_DEFAULT_WINDOWBITS;
if (this.#options.serverMaxWindowBits) {
Expand All @@ -17305,26 +17347,51 @@ var require_permessage_deflate = __commonJS({
}
windowBits = Number.parseInt(this.#options.serverMaxWindowBits);
}
this.#inflate = createInflateRaw({ windowBits });
try {
this.#inflate = createInflateRaw({ windowBits });
} catch (err) {
callback(err);
return;
}
this.#inflate[kBuffer] = [];
this.#inflate[kLength] = 0;
this.#inflate.on("data", (data) => {
this.#inflate[kBuffer].push(data);
if (this.#aborted) {
return;
}
this.#inflate[kLength] += data.length;
if (this.#inflate[kLength] > kDefaultMaxDecompressedSize) {
this.#aborted = true;
this.#inflate.removeAllListeners();
this.#inflate.destroy();
this.#inflate = null;
if (this.#currentCallback) {
const cb = this.#currentCallback;
this.#currentCallback = null;
cb(new MessageSizeExceededError());
}
return;
}
this.#inflate[kBuffer].push(data);
});
this.#inflate.on("error", (err) => {
this.#inflate = null;
callback(err);
});
}
this.#currentCallback = callback;
this.#inflate.write(chunk);
if (fin) {
this.#inflate.write(tail);
}
this.#inflate.flush(() => {
if (this.#aborted || !this.#inflate) {
return;
}
const full = Buffer.concat(this.#inflate[kBuffer], this.#inflate[kLength]);
this.#inflate[kBuffer].length = 0;
this.#inflate[kLength] = 0;
this.#currentCallback = null;
callback(null, full);
});
}
Expand Down Expand Up @@ -17364,6 +17431,10 @@ var require_receiver = __commonJS({
#fragments = [];
/** @type {Map<string, PerMessageDeflate>} */
#extensions;
/**
* @param {import('./websocket').WebSocket} ws
* @param {Map<string, string>|null} extensions
*/
constructor(ws, extensions) {
super();
this.ws = ws;
Expand Down Expand Up @@ -17467,12 +17538,12 @@ var require_receiver = __commonJS({
}
const buffer3 = this.consume(8);
const upper = buffer3.readUInt32BE(0);
if (upper > 2 ** 31 - 1) {
const lower = buffer3.readUInt32BE(4);
if (upper !== 0 || lower > 2 ** 31 - 1) {
failWebsocketConnection(this.ws, "Received payload length > 2^31 bytes.");
return;
}
const lower = buffer3.readUInt32BE(4);
this.#info.payloadLength = (upper << 8) + lower;
this.#info.payloadLength = lower;
this.#state = parserStates.READ_DATA;
} else if (this.#state === parserStates.READ_DATA) {
if (this.#byteOffset < this.#info.payloadLength) {
Expand All @@ -17494,7 +17565,7 @@ var require_receiver = __commonJS({
} else {
this.#extensions.get("permessage-deflate").decompress(body2, this.#info.fin, (error2, data) => {
if (error2) {
closeWebSocketConnection(this.ws, 1007, error2.message, error2.message.length);
failWebsocketConnection(this.ws, error2.message);
return;
}
this.#fragments.push(data);
Expand Down
12 changes: 6 additions & 6 deletions package-lock.json
View file
Open in desktop

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Loading