Compare commits
8 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
 copilot-swe-agent[bot]
|
110b0922d8 | ||
|
copilot-swe-agent[bot]
|
79276a64ee | ||
|
dependabot[bot]
|
0d162d7f79 | ||
|
dependabot[bot]
|
f9866974af | ||
|
dependabot[bot]
|
64ae95268e | ||
|
dependabot[bot]
|
df49dd906d | ||
|
dependabot[bot]
|
b834a23b59 | ||
|
dependabot[bot]
|
e642766382 |
@@ -70,7 +70,7 @@ jobs:
|
||||
- if: ${{ failure() && steps.diff.outcome == 'failure' }}
|
||||
name: Upload Artifact
|
||||
id: upload
|
||||
uses: actions/upload-artifact@v6
|
||||
uses: actions/upload-artifact@v7
|
||||
with:
|
||||
name: dist
|
||||
path: dist/
|
||||
|
||||
+12
-100
@@ -932,24 +932,6 @@ function requireErrors () {
|
||||
[kSecureProxyConnectionError] = true
|
||||
}
|
||||
|
||||
const kMessageSizeExceededError = Symbol.for('undici.error.UND_ERR_WS_MESSAGE_SIZE_EXCEEDED');
|
||||
class MessageSizeExceededError 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
|
||||
}
|
||||
}
|
||||
|
||||
errors = {
|
||||
AbortError,
|
||||
HTTPParserError,
|
||||
@@ -973,8 +955,7 @@ function requireErrors () {
|
||||
ResponseExceededMaxSizeError,
|
||||
RequestRetryError,
|
||||
ResponseError,
|
||||
SecureProxyConnectionError,
|
||||
MessageSizeExceededError
|
||||
SecureProxyConnectionError
|
||||
};
|
||||
return errors;
|
||||
}
|
||||
@@ -2275,10 +2256,6 @@ function requireRequest$1 () {
|
||||
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')
|
||||
}
|
||||
@@ -2573,19 +2550,13 @@ function requireRequest$1 () {
|
||||
val = `${val}`;
|
||||
}
|
||||
|
||||
if (headerName === 'host') {
|
||||
if (request.host !== null) {
|
||||
throw new InvalidArgumentError('duplicate host header')
|
||||
}
|
||||
if (request.host === null && headerName === 'host') {
|
||||
if (typeof val !== 'string') {
|
||||
throw new InvalidArgumentError('invalid host header')
|
||||
}
|
||||
// Consumed by Client
|
||||
request.host = val;
|
||||
} else if (headerName === 'content-length') {
|
||||
if (request.contentLength !== null) {
|
||||
throw new InvalidArgumentError('duplicate content-length header')
|
||||
}
|
||||
} else if (request.contentLength === null && headerName === 'content-length') {
|
||||
request.contentLength = parseInt(val, 10);
|
||||
if (!Number.isFinite(request.contentLength)) {
|
||||
throw new InvalidArgumentError('invalid content-length header')
|
||||
@@ -24942,12 +24913,6 @@ function requireUtil$1 () {
|
||||
* @param {string} value
|
||||
*/
|
||||
function isValidClientWindowBits (value) {
|
||||
// Must have at least one character
|
||||
if (value.length === 0) {
|
||||
return false
|
||||
}
|
||||
|
||||
// Check all characters are ASCII digits
|
||||
for (let i = 0; i < value.length; i++) {
|
||||
const byte = value.charCodeAt(i);
|
||||
|
||||
@@ -24956,9 +24921,7 @@ function requireUtil$1 () {
|
||||
}
|
||||
}
|
||||
|
||||
// Check numeric range: zlib requires windowBits in range 8-15
|
||||
const num = Number.parseInt(value, 10);
|
||||
return num >= 8 && num <= 15
|
||||
return true
|
||||
}
|
||||
|
||||
// https://nodejs.org/api/intl.html#detecting-internationalization-support
|
||||
@@ -25488,30 +25451,17 @@ function requirePermessageDeflate () {
|
||||
|
||||
const { createInflateRaw, Z_DEFAULT_WINDOWBITS } = require$$1$2;
|
||||
const { isValidClientWindowBits } = requireUtil$1();
|
||||
const { MessageSizeExceededError } = requireErrors();
|
||||
|
||||
const tail = Buffer.from([0x00, 0x00, 0xff, 0xff]);
|
||||
const kBuffer = Symbol('kBuffer');
|
||||
const kLength = Symbol('kLength');
|
||||
|
||||
// Default maximum decompressed message size: 4 MB
|
||||
const kDefaultMaxDecompressedSize = 4 * 1024 * 1024;
|
||||
|
||||
class PerMessageDeflate {
|
||||
/** @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');
|
||||
@@ -25523,11 +25473,6 @@ function requirePermessageDeflate () {
|
||||
// payload of the message.
|
||||
// 2. Decompress the resulting data using DEFLATE.
|
||||
|
||||
if (this.#aborted) {
|
||||
callback(new MessageSizeExceededError());
|
||||
return
|
||||
}
|
||||
|
||||
if (!this.#inflate) {
|
||||
let windowBits = Z_DEFAULT_WINDOWBITS;
|
||||
|
||||
@@ -25540,37 +25485,13 @@ function requirePermessageDeflate () {
|
||||
windowBits = Number.parseInt(this.#options.serverMaxWindowBits);
|
||||
}
|
||||
|
||||
try {
|
||||
this.#inflate = createInflateRaw({ windowBits });
|
||||
} catch (err) {
|
||||
callback(err);
|
||||
return
|
||||
}
|
||||
this.#inflate = createInflateRaw({ windowBits });
|
||||
this.#inflate[kBuffer] = [];
|
||||
this.#inflate[kLength] = 0;
|
||||
|
||||
this.#inflate.on('data', (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[kLength] += data.length;
|
||||
});
|
||||
|
||||
this.#inflate.on('error', (err) => {
|
||||
@@ -25579,22 +25500,16 @@ function requirePermessageDeflate () {
|
||||
});
|
||||
}
|
||||
|
||||
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);
|
||||
});
|
||||
@@ -25649,10 +25564,6 @@ function requireReceiver () {
|
||||
/** @type {Map<string, PerMessageDeflate>} */
|
||||
#extensions
|
||||
|
||||
/**
|
||||
* @param {import('./websocket').WebSocket} ws
|
||||
* @param {Map<string, string>|null} extensions
|
||||
*/
|
||||
constructor (ws, extensions) {
|
||||
super();
|
||||
|
||||
@@ -25795,7 +25706,6 @@ function requireReceiver () {
|
||||
|
||||
const buffer = this.consume(8);
|
||||
const upper = buffer.readUInt32BE(0);
|
||||
const lower = buffer.readUInt32BE(4);
|
||||
|
||||
// 2^31 is the maximum bytes an arraybuffer can contain
|
||||
// on 32-bit systems. Although, on 64-bit systems, this is
|
||||
@@ -25803,12 +25713,14 @@ function requireReceiver () {
|
||||
// https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Errors/Invalid_array_length
|
||||
// https://source.chromium.org/chromium/chromium/src/+/main:v8/src/common/globals.h;drc=1946212ac0100668f14eb9e2843bdd846e510a1e;bpv=1;bpt=1;l=1275
|
||||
// https://source.chromium.org/chromium/chromium/src/+/main:v8/src/objects/js-array-buffer.h;l=34;drc=1946212ac0100668f14eb9e2843bdd846e510a1e
|
||||
if (upper !== 0 || lower > 2 ** 31 - 1) {
|
||||
if (upper > 2 ** 31 - 1) {
|
||||
failWebsocketConnection(this.ws, 'Received payload length > 2^31 bytes.');
|
||||
return
|
||||
}
|
||||
|
||||
this.#info.payloadLength = lower;
|
||||
const lower = buffer.readUInt32BE(4);
|
||||
|
||||
this.#info.payloadLength = (upper << 8) + lower;
|
||||
this.#state = parserStates.READ_DATA;
|
||||
} else if (this.#state === parserStates.READ_DATA) {
|
||||
if (this.#byteOffset < this.#info.payloadLength) {
|
||||
@@ -25838,7 +25750,7 @@ function requireReceiver () {
|
||||
} else {
|
||||
this.#extensions.get('permessage-deflate').decompress(body, this.#info.fin, (error, data) => {
|
||||
if (error) {
|
||||
failWebsocketConnection(this.ws, error.message);
|
||||
closeWebSocketConnection(this.ws, 1007, error.message, error.message.length);
|
||||
return
|
||||
}
|
||||
|
||||
@@ -26590,7 +26502,7 @@ function requireWebsocket () {
|
||||
* @see https://websockets.spec.whatwg.org/#feedback-from-the-protocol
|
||||
*/
|
||||
#onConnectionEstablished (response, parsedExtensions) {
|
||||
// processResponse is called when the "response's header list has been received and initialized."
|
||||
// processResponse is called when the "response’s header list has been received and initialized."
|
||||
// once this happens, the connection is open
|
||||
this[kResponse] = response;
|
||||
|
||||
|
||||
+1
-1
File diff suppressed because one or more lines are too long
Generated
+666
-622
File diff suppressed because it is too large
Load Diff
+11
-11
@@ -40,26 +40,26 @@
|
||||
"@actions/core": "^3.0.0"
|
||||
},
|
||||
"devDependencies": {
|
||||
"@eslint/compat": "^2.0.2",
|
||||
"@eslint/eslintrc": "^3.3.3",
|
||||
"@eslint/compat": "^2.0.4",
|
||||
"@eslint/eslintrc": "^3.3.5",
|
||||
"@eslint/js": "^10.0.1",
|
||||
"@github/local-action": "^7.0.1",
|
||||
"@jest/globals": "^30.2.0",
|
||||
"@rollup/plugin-commonjs": "^29.0.0",
|
||||
"@jest/globals": "^30.3.0",
|
||||
"@rollup/plugin-commonjs": "^29.0.2",
|
||||
"@rollup/plugin-node-resolve": "^16.0.3",
|
||||
"@rollup/plugin-typescript": "^12.3.0",
|
||||
"@types/jest": "^30.0.0",
|
||||
"@types/node": "^25.2.3",
|
||||
"@typescript-eslint/eslint-plugin": "^8.56.0",
|
||||
"eslint": "^10.0.0",
|
||||
"@types/node": "^25.5.2",
|
||||
"@typescript-eslint/eslint-plugin": "^8.58.0",
|
||||
"eslint": "^10.2.0",
|
||||
"eslint-config-prettier": "^10.1.8",
|
||||
"eslint-plugin-jest": "^29.15.0",
|
||||
"eslint-plugin-jest": "^29.15.1",
|
||||
"eslint-plugin-prettier": "^5.5.5",
|
||||
"jest": "^30.2.0",
|
||||
"jest": "^30.3.0",
|
||||
"make-coverage-badge": "^1.2.0",
|
||||
"prettier": "^3.8.1",
|
||||
"rollup": "^4.57.1",
|
||||
"ts-jest": "^29.4.6",
|
||||
"rollup": "^4.60.1",
|
||||
"ts-jest": "^29.4.9",
|
||||
"ts-jest-resolver": "^2.0.1",
|
||||
"typescript": "^5.9.3"
|
||||
},
|
||||
|
||||
Reference in New Issue
Block a user