diff --git a/.github/local-actions/branch-manager/main.js b/.github/local-actions/branch-manager/main.js index cd26f6685..170e609cb 100644 --- a/.github/local-actions/branch-manager/main.js +++ b/.github/local-actions/branch-manager/main.js @@ -41481,7 +41481,6 @@ var require_client_h2 = __commonJS({ } = require_symbols6(); var kOpenStreams = Symbol("open streams"); var extractBody; - var h2ExperimentalWarned = false; var http2; try { http2 = __require("node:http2"); @@ -41514,12 +41513,6 @@ var require_client_h2 = __commonJS({ } async function connectH2(client, socket) { client[kSocket] = socket; - if (!h2ExperimentalWarned) { - h2ExperimentalWarned = true; - process.emitWarning("H2 support is experimental, expect them to change at any time.", { - code: "UNDICI-H2" - }); - } const session = http2.connect(client[kUrl], { createConnection: () => socket, peerMaxConcurrentStreams: client[kMaxConcurrentStreams], @@ -45565,61 +45558,55 @@ var require_decorator_handler = __commonJS({ ""(exports, module) { "use strict"; var assert2 = __require("node:assert"); + var WrapHandler = require_wrap_handler(); module.exports = class DecoratorHandler { #handler; #onCompleteCalled = false; #onErrorCalled = false; + #onResponseStartCalled = false; constructor(handler2) { if (typeof handler2 !== "object" || handler2 === null) { throw new TypeError("handler must be an object"); } - this.#handler = handler2; - } - onConnect(...args) { - var _a, _b; - return (_b = (_a = this.#handler).onConnect) == null ? void 0 : _b.call(_a, ...args); - } - onError(...args) { - var _a, _b; - this.#onErrorCalled = true; - return (_b = (_a = this.#handler).onError) == null ? void 0 : _b.call(_a, ...args); + this.#handler = WrapHandler.wrap(handler2); } - onUpgrade(...args) { + onRequestStart(...args) { var _a, _b; - assert2(!this.#onCompleteCalled); - assert2(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onUpgrade) == null ? void 0 : _b.call(_a, ...args); + (_b = (_a = this.#handler).onRequestStart) == null ? void 0 : _b.call(_a, ...args); } - onResponseStarted(...args) { + onRequestUpgrade(...args) { var _a, _b; assert2(!this.#onCompleteCalled); assert2(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onResponseStarted) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onRequestUpgrade) == null ? void 0 : _b.call(_a, ...args); } - onHeaders(...args) { + onResponseStart(...args) { var _a, _b; assert2(!this.#onCompleteCalled); assert2(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onHeaders) == null ? void 0 : _b.call(_a, ...args); + assert2(!this.#onResponseStartCalled); + this.#onResponseStartCalled = true; + return (_b = (_a = this.#handler).onResponseStart) == null ? void 0 : _b.call(_a, ...args); } - onData(...args) { + onResponseData(...args) { var _a, _b; assert2(!this.#onCompleteCalled); assert2(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onData) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onResponseData) == null ? void 0 : _b.call(_a, ...args); } - onComplete(...args) { + onResponseEnd(...args) { var _a, _b; assert2(!this.#onCompleteCalled); assert2(!this.#onErrorCalled); this.#onCompleteCalled = true; - return (_b = (_a = this.#handler).onComplete) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onResponseEnd) == null ? void 0 : _b.call(_a, ...args); } - onBodySent(...args) { + onResponseError(...args) { var _a, _b; - assert2(!this.#onCompleteCalled); - assert2(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onBodySent) == null ? void 0 : _b.call(_a, ...args); + this.#onErrorCalled = true; + return (_b = (_a = this.#handler).onResponseError) == null ? void 0 : _b.call(_a, ...args); + } + onBodySent() { } }; } @@ -45810,50 +45797,47 @@ var require_redirect = __commonJS({ var require_response_error = __commonJS({ ""(exports, module) { "use strict"; - var { parseHeaders } = require_util8(); var DecoratorHandler = require_decorator_handler(); var { ResponseError } = require_errors2(); var ResponseErrorHandler = class extends DecoratorHandler { - #handler; #statusCode; #contentType; #decoder; #headers; #body; - constructor(opts, { handler: handler2 }) { + constructor(_opts, { handler: handler2 }) { super(handler2); - this.#handler = handler2; } - onConnect(abort) { + #checkContentType(contentType) { + return this.#contentType.indexOf(contentType) === 0; + } + onRequestStart(controller, context2) { this.#statusCode = 0; this.#contentType = null; this.#decoder = null; this.#headers = null; this.#body = ""; - return this.#handler.onConnect(abort); + return super.onRequestStart(controller, context2); } - #checkContentType(contentType) { - return this.#contentType.indexOf(contentType) === 0; - } - onHeaders(statusCode, rawHeaders, resume, statusMessage, headers = parseHeaders(rawHeaders)) { + onResponseStart(controller, statusCode, headers, statusMessage) { this.#statusCode = statusCode; this.#headers = headers; this.#contentType = headers["content-type"]; if (this.#statusCode < 400) { - return this.#handler.onHeaders(statusCode, rawHeaders, resume, statusMessage, headers); + return super.onResponseStart(controller, statusCode, headers, statusMessage); } if (this.#checkContentType("application/json") || this.#checkContentType("text/plain")) { this.#decoder = new TextDecoder("utf-8"); } } - onData(chunk) { + onResponseData(controller, chunk) { var _a; if (this.#statusCode < 400) { - return this.#handler.onData(chunk); + return super.onResponseData(controller, chunk); } this.#body += ((_a = this.#decoder) == null ? void 0 : _a.decode(chunk, { stream: true })) ?? ""; } - onComplete(rawTrailers) { + onResponseEnd(controller, trailers) { var _a; if (this.#statusCode >= 400) { this.#body += ((_a = this.#decoder) == null ? void 0 : _a.decode(void 0, { stream: false })) ?? ""; @@ -45874,13 +45858,13 @@ var require_response_error = __commonJS({ } finally { Error.stackTraceLimit = stackTraceLimit; } - this.#handler.onError(err); + super.onResponseError(controller, err); } else { - this.#handler.onComplete(rawTrailers); + super.onResponseEnd(controller, trailers); } } - onError(err) { - this.#handler.onError(err); + onResponseError(err) { + super.onResponseError(err); } }; module.exports = () => { @@ -45921,79 +45905,71 @@ var require_retry = __commonJS({ var require_dump = __commonJS({ ""(exports, module) { "use strict"; - var util = require_util8(); var { InvalidArgumentError, RequestAbortedError } = require_errors2(); var DecoratorHandler = require_decorator_handler(); var DumpHandler = class extends DecoratorHandler { #maxSize = 1024 * 1024; - #abort = null; #dumped = false; - #aborted = false; #size = 0; - #reason = null; - #handler = null; - constructor({ maxSize }, handler2) { + #controller = null; + aborted = false; + reason = false; + constructor({ maxSize, signal }, handler2) { if (maxSize != null && (!Number.isFinite(maxSize) || maxSize < 1)) { throw new InvalidArgumentError("maxSize must be a number greater than 0"); } super(handler2); this.#maxSize = maxSize ?? this.#maxSize; - this.#handler = handler2; } - onConnect(abort) { - this.#abort = abort; - this.#handler.onConnect(this.#customAbort.bind(this)); + #abort(reason) { + this.aborted = true; + this.reason = reason; } - #customAbort(reason) { - this.#aborted = true; - this.#reason = reason; + onRequestStart(controller, context2) { + controller.abort = this.#abort.bind(this); + this.#controller = controller; + return super.onRequestStart(controller, context2); } - onHeaders(statusCode, rawHeaders, resume, statusMessage) { - const headers = util.parseHeaders(rawHeaders); + onResponseStart(controller, statusCode, headers, statusMessage) { const contentLength = headers["content-length"]; if (contentLength != null && contentLength > this.#maxSize) { throw new RequestAbortedError( `Response size (${contentLength}) larger than maxSize (${this.#maxSize})` ); } - if (this.#aborted) { + if (this.aborted === true) { return true; } - return this.#handler.onHeaders( - statusCode, - rawHeaders, - resume, - statusMessage - ); + return super.onResponseStart(controller, statusCode, headers, statusMessage); } - onError(err) { + onResponseError(controller, err) { if (this.#dumped) { return; } - err = this.#reason ?? err; - this.#handler.onError(err); + err = this.#controller.reason ?? err; + super.onResponseError(controller, err); } - onData(chunk) { + onResponseData(controller, chunk) { this.#size = this.#size + chunk.length; if (this.#size >= this.#maxSize) { this.#dumped = true; - if (this.#aborted) { - this.#handler.onError(this.#reason); + if (this.aborted === true) { + super.onResponseError(controller, this.reason); } else { - this.#handler.onComplete([]); + super.onResponseEnd(controller, {}); } } return true; } - onComplete(trailers) { + onResponseEnd(controller, trailers) { if (this.#dumped) { return; } - if (this.#aborted) { - this.#handler.onError(this.reason); + if (this.#controller.aborted === true) { + super.onResponseError(controller, this.reason); return; } - this.#handler.onComplete(trailers); + super.onResponseEnd(controller, trailers); } }; function createDumpInterceptor({ maxSize: defaultMaxSize } = { @@ -46002,10 +45978,7 @@ var require_dump = __commonJS({ return (dispatch) => { return function Intercept(opts, handler2) { const { dumpMaxSize = defaultMaxSize } = opts; - const dumpHandler = new DumpHandler( - { maxSize: dumpMaxSize }, - handler2 - ); + const dumpHandler = new DumpHandler({ maxSize: dumpMaxSize, signal: opts.signal }, handler2); return dispatch(opts, dumpHandler); }; }; @@ -46193,24 +46166,24 @@ var require_dns = __commonJS({ #state = null; #opts = null; #dispatch = null; - #handler = null; #origin = null; + #controller = null; constructor(state, { origin, handler: handler2, dispatch }, opts) { super(handler2); this.#origin = origin; - this.#handler = handler2; this.#opts = { ...opts }; this.#state = state; this.#dispatch = dispatch; } - onError(err) { + onResponseError(controller, err) { switch (err.code) { case "ETIMEDOUT": case "ECONNREFUSED": { if (this.#state.dualStack) { this.#state.runLookup(this.#origin, this.#opts, (err2, newOrigin) => { if (err2) { - return this.#handler.onError(err2); + super.onResponseError(controller, err2); + return; } const dispatchOpts = { ...this.#opts, @@ -46220,13 +46193,13 @@ var require_dns = __commonJS({ }); return; } - this.#handler.onError(err); - return; + super.onResponseError(controller, err); + break; } case "ENOTFOUND": this.#state.deleteRecord(this.#origin); default: - this.#handler.onError(err); + super.onResponseError(controller, err); break; } } @@ -53582,9 +53555,6 @@ var require_undici2 = __commonJS({ const SqliteCacheStore = require_sqlite_cache_store(); module.exports.cacheStores.SqliteCacheStore = SqliteCacheStore; } catch (err) { - if (err.code !== "ERR_UNKNOWN_BUILTIN_MODULE") { - throw err; - } } module.exports.buildConnector = buildConnector; module.exports.errors = errors; diff --git a/.github/local-actions/labels-sync/main.js b/.github/local-actions/labels-sync/main.js index c4079c302..9f27ea0ab 100644 --- a/.github/local-actions/labels-sync/main.js +++ b/.github/local-actions/labels-sync/main.js @@ -26004,7 +26004,6 @@ var require_client_h2 = __commonJS({ } = require_symbols6(); var kOpenStreams = Symbol("open streams"); var extractBody; - var h2ExperimentalWarned = false; var http2; try { http2 = __require("node:http2"); @@ -26037,12 +26036,6 @@ var require_client_h2 = __commonJS({ } async function connectH2(client, socket) { client[kSocket] = socket; - if (!h2ExperimentalWarned) { - h2ExperimentalWarned = true; - process.emitWarning("H2 support is experimental, expect them to change at any time.", { - code: "UNDICI-H2" - }); - } const session = http2.connect(client[kUrl], { createConnection: () => socket, peerMaxConcurrentStreams: client[kMaxConcurrentStreams], @@ -30088,61 +30081,55 @@ var require_decorator_handler = __commonJS({ ""(exports, module) { "use strict"; var assert = __require("node:assert"); + var WrapHandler = require_wrap_handler(); module.exports = class DecoratorHandler { #handler; #onCompleteCalled = false; #onErrorCalled = false; + #onResponseStartCalled = false; constructor(handler2) { if (typeof handler2 !== "object" || handler2 === null) { throw new TypeError("handler must be an object"); } - this.#handler = handler2; - } - onConnect(...args) { - var _a, _b; - return (_b = (_a = this.#handler).onConnect) == null ? void 0 : _b.call(_a, ...args); - } - onError(...args) { - var _a, _b; - this.#onErrorCalled = true; - return (_b = (_a = this.#handler).onError) == null ? void 0 : _b.call(_a, ...args); + this.#handler = WrapHandler.wrap(handler2); } - onUpgrade(...args) { + onRequestStart(...args) { var _a, _b; - assert(!this.#onCompleteCalled); - assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onUpgrade) == null ? void 0 : _b.call(_a, ...args); + (_b = (_a = this.#handler).onRequestStart) == null ? void 0 : _b.call(_a, ...args); } - onResponseStarted(...args) { + onRequestUpgrade(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onResponseStarted) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onRequestUpgrade) == null ? void 0 : _b.call(_a, ...args); } - onHeaders(...args) { + onResponseStart(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onHeaders) == null ? void 0 : _b.call(_a, ...args); + assert(!this.#onResponseStartCalled); + this.#onResponseStartCalled = true; + return (_b = (_a = this.#handler).onResponseStart) == null ? void 0 : _b.call(_a, ...args); } - onData(...args) { + onResponseData(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onData) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onResponseData) == null ? void 0 : _b.call(_a, ...args); } - onComplete(...args) { + onResponseEnd(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); this.#onCompleteCalled = true; - return (_b = (_a = this.#handler).onComplete) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onResponseEnd) == null ? void 0 : _b.call(_a, ...args); } - onBodySent(...args) { + onResponseError(...args) { var _a, _b; - assert(!this.#onCompleteCalled); - assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onBodySent) == null ? void 0 : _b.call(_a, ...args); + this.#onErrorCalled = true; + return (_b = (_a = this.#handler).onResponseError) == null ? void 0 : _b.call(_a, ...args); + } + onBodySent() { } }; } @@ -30333,50 +30320,47 @@ var require_redirect = __commonJS({ var require_response_error = __commonJS({ ""(exports, module) { "use strict"; - var { parseHeaders } = require_util8(); var DecoratorHandler = require_decorator_handler(); var { ResponseError } = require_errors2(); var ResponseErrorHandler = class extends DecoratorHandler { - #handler; #statusCode; #contentType; #decoder; #headers; #body; - constructor(opts, { handler: handler2 }) { + constructor(_opts, { handler: handler2 }) { super(handler2); - this.#handler = handler2; } - onConnect(abort) { + #checkContentType(contentType) { + return this.#contentType.indexOf(contentType) === 0; + } + onRequestStart(controller, context3) { this.#statusCode = 0; this.#contentType = null; this.#decoder = null; this.#headers = null; this.#body = ""; - return this.#handler.onConnect(abort); + return super.onRequestStart(controller, context3); } - #checkContentType(contentType) { - return this.#contentType.indexOf(contentType) === 0; - } - onHeaders(statusCode, rawHeaders, resume, statusMessage, headers = parseHeaders(rawHeaders)) { + onResponseStart(controller, statusCode, headers, statusMessage) { this.#statusCode = statusCode; this.#headers = headers; this.#contentType = headers["content-type"]; if (this.#statusCode < 400) { - return this.#handler.onHeaders(statusCode, rawHeaders, resume, statusMessage, headers); + return super.onResponseStart(controller, statusCode, headers, statusMessage); } if (this.#checkContentType("application/json") || this.#checkContentType("text/plain")) { this.#decoder = new TextDecoder("utf-8"); } } - onData(chunk) { + onResponseData(controller, chunk) { var _a; if (this.#statusCode < 400) { - return this.#handler.onData(chunk); + return super.onResponseData(controller, chunk); } this.#body += ((_a = this.#decoder) == null ? void 0 : _a.decode(chunk, { stream: true })) ?? ""; } - onComplete(rawTrailers) { + onResponseEnd(controller, trailers) { var _a; if (this.#statusCode >= 400) { this.#body += ((_a = this.#decoder) == null ? void 0 : _a.decode(void 0, { stream: false })) ?? ""; @@ -30397,13 +30381,13 @@ var require_response_error = __commonJS({ } finally { Error.stackTraceLimit = stackTraceLimit; } - this.#handler.onError(err); + super.onResponseError(controller, err); } else { - this.#handler.onComplete(rawTrailers); + super.onResponseEnd(controller, trailers); } } - onError(err) { - this.#handler.onError(err); + onResponseError(err) { + super.onResponseError(err); } }; module.exports = () => { @@ -30444,79 +30428,71 @@ var require_retry = __commonJS({ var require_dump = __commonJS({ ""(exports, module) { "use strict"; - var util = require_util8(); var { InvalidArgumentError, RequestAbortedError } = require_errors2(); var DecoratorHandler = require_decorator_handler(); var DumpHandler = class extends DecoratorHandler { #maxSize = 1024 * 1024; - #abort = null; #dumped = false; - #aborted = false; #size = 0; - #reason = null; - #handler = null; - constructor({ maxSize }, handler2) { + #controller = null; + aborted = false; + reason = false; + constructor({ maxSize, signal }, handler2) { if (maxSize != null && (!Number.isFinite(maxSize) || maxSize < 1)) { throw new InvalidArgumentError("maxSize must be a number greater than 0"); } super(handler2); this.#maxSize = maxSize ?? this.#maxSize; - this.#handler = handler2; } - onConnect(abort) { - this.#abort = abort; - this.#handler.onConnect(this.#customAbort.bind(this)); + #abort(reason) { + this.aborted = true; + this.reason = reason; } - #customAbort(reason) { - this.#aborted = true; - this.#reason = reason; + onRequestStart(controller, context3) { + controller.abort = this.#abort.bind(this); + this.#controller = controller; + return super.onRequestStart(controller, context3); } - onHeaders(statusCode, rawHeaders, resume, statusMessage) { - const headers = util.parseHeaders(rawHeaders); + onResponseStart(controller, statusCode, headers, statusMessage) { const contentLength = headers["content-length"]; if (contentLength != null && contentLength > this.#maxSize) { throw new RequestAbortedError( `Response size (${contentLength}) larger than maxSize (${this.#maxSize})` ); } - if (this.#aborted) { + if (this.aborted === true) { return true; } - return this.#handler.onHeaders( - statusCode, - rawHeaders, - resume, - statusMessage - ); + return super.onResponseStart(controller, statusCode, headers, statusMessage); } - onError(err) { + onResponseError(controller, err) { if (this.#dumped) { return; } - err = this.#reason ?? err; - this.#handler.onError(err); + err = this.#controller.reason ?? err; + super.onResponseError(controller, err); } - onData(chunk) { + onResponseData(controller, chunk) { this.#size = this.#size + chunk.length; if (this.#size >= this.#maxSize) { this.#dumped = true; - if (this.#aborted) { - this.#handler.onError(this.#reason); + if (this.aborted === true) { + super.onResponseError(controller, this.reason); } else { - this.#handler.onComplete([]); + super.onResponseEnd(controller, {}); } } return true; } - onComplete(trailers) { + onResponseEnd(controller, trailers) { if (this.#dumped) { return; } - if (this.#aborted) { - this.#handler.onError(this.reason); + if (this.#controller.aborted === true) { + super.onResponseError(controller, this.reason); return; } - this.#handler.onComplete(trailers); + super.onResponseEnd(controller, trailers); } }; function createDumpInterceptor({ maxSize: defaultMaxSize } = { @@ -30525,10 +30501,7 @@ var require_dump = __commonJS({ return (dispatch) => { return function Intercept(opts, handler2) { const { dumpMaxSize = defaultMaxSize } = opts; - const dumpHandler = new DumpHandler( - { maxSize: dumpMaxSize }, - handler2 - ); + const dumpHandler = new DumpHandler({ maxSize: dumpMaxSize, signal: opts.signal }, handler2); return dispatch(opts, dumpHandler); }; }; @@ -30716,24 +30689,24 @@ var require_dns = __commonJS({ #state = null; #opts = null; #dispatch = null; - #handler = null; #origin = null; + #controller = null; constructor(state, { origin, handler: handler2, dispatch }, opts) { super(handler2); this.#origin = origin; - this.#handler = handler2; this.#opts = { ...opts }; this.#state = state; this.#dispatch = dispatch; } - onError(err) { + onResponseError(controller, err) { switch (err.code) { case "ETIMEDOUT": case "ECONNREFUSED": { if (this.#state.dualStack) { this.#state.runLookup(this.#origin, this.#opts, (err2, newOrigin) => { if (err2) { - return this.#handler.onError(err2); + super.onResponseError(controller, err2); + return; } const dispatchOpts = { ...this.#opts, @@ -30743,13 +30716,13 @@ var require_dns = __commonJS({ }); return; } - this.#handler.onError(err); - return; + super.onResponseError(controller, err); + break; } case "ENOTFOUND": this.#state.deleteRecord(this.#origin); default: - this.#handler.onError(err); + super.onResponseError(controller, err); break; } } @@ -38105,9 +38078,6 @@ var require_undici2 = __commonJS({ const SqliteCacheStore = require_sqlite_cache_store(); module.exports.cacheStores.SqliteCacheStore = SqliteCacheStore; } catch (err) { - if (err.code !== "ERR_UNKNOWN_BUILTIN_MODULE") { - throw err; - } } module.exports.buildConnector = buildConnector; module.exports.errors = errors; diff --git a/.github/local-actions/lock-closed/main.js b/.github/local-actions/lock-closed/main.js index 526e75d0f..3efcf92cd 100644 --- a/.github/local-actions/lock-closed/main.js +++ b/.github/local-actions/lock-closed/main.js @@ -26004,7 +26004,6 @@ var require_client_h2 = __commonJS({ } = require_symbols6(); var kOpenStreams = Symbol("open streams"); var extractBody; - var h2ExperimentalWarned = false; var http2; try { http2 = __require("node:http2"); @@ -26037,12 +26036,6 @@ var require_client_h2 = __commonJS({ } async function connectH2(client, socket) { client[kSocket] = socket; - if (!h2ExperimentalWarned) { - h2ExperimentalWarned = true; - process.emitWarning("H2 support is experimental, expect them to change at any time.", { - code: "UNDICI-H2" - }); - } const session = http2.connect(client[kUrl], { createConnection: () => socket, peerMaxConcurrentStreams: client[kMaxConcurrentStreams], @@ -30088,61 +30081,55 @@ var require_decorator_handler = __commonJS({ ""(exports, module) { "use strict"; var assert = __require("node:assert"); + var WrapHandler = require_wrap_handler(); module.exports = class DecoratorHandler { #handler; #onCompleteCalled = false; #onErrorCalled = false; + #onResponseStartCalled = false; constructor(handler2) { if (typeof handler2 !== "object" || handler2 === null) { throw new TypeError("handler must be an object"); } - this.#handler = handler2; - } - onConnect(...args) { - var _a, _b; - return (_b = (_a = this.#handler).onConnect) == null ? void 0 : _b.call(_a, ...args); - } - onError(...args) { - var _a, _b; - this.#onErrorCalled = true; - return (_b = (_a = this.#handler).onError) == null ? void 0 : _b.call(_a, ...args); + this.#handler = WrapHandler.wrap(handler2); } - onUpgrade(...args) { + onRequestStart(...args) { var _a, _b; - assert(!this.#onCompleteCalled); - assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onUpgrade) == null ? void 0 : _b.call(_a, ...args); + (_b = (_a = this.#handler).onRequestStart) == null ? void 0 : _b.call(_a, ...args); } - onResponseStarted(...args) { + onRequestUpgrade(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onResponseStarted) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onRequestUpgrade) == null ? void 0 : _b.call(_a, ...args); } - onHeaders(...args) { + onResponseStart(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onHeaders) == null ? void 0 : _b.call(_a, ...args); + assert(!this.#onResponseStartCalled); + this.#onResponseStartCalled = true; + return (_b = (_a = this.#handler).onResponseStart) == null ? void 0 : _b.call(_a, ...args); } - onData(...args) { + onResponseData(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onData) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onResponseData) == null ? void 0 : _b.call(_a, ...args); } - onComplete(...args) { + onResponseEnd(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); this.#onCompleteCalled = true; - return (_b = (_a = this.#handler).onComplete) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onResponseEnd) == null ? void 0 : _b.call(_a, ...args); } - onBodySent(...args) { + onResponseError(...args) { var _a, _b; - assert(!this.#onCompleteCalled); - assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onBodySent) == null ? void 0 : _b.call(_a, ...args); + this.#onErrorCalled = true; + return (_b = (_a = this.#handler).onResponseError) == null ? void 0 : _b.call(_a, ...args); + } + onBodySent() { } }; } @@ -30333,50 +30320,47 @@ var require_redirect = __commonJS({ var require_response_error = __commonJS({ ""(exports, module) { "use strict"; - var { parseHeaders } = require_util8(); var DecoratorHandler = require_decorator_handler(); var { ResponseError } = require_errors2(); var ResponseErrorHandler = class extends DecoratorHandler { - #handler; #statusCode; #contentType; #decoder; #headers; #body; - constructor(opts, { handler: handler2 }) { + constructor(_opts, { handler: handler2 }) { super(handler2); - this.#handler = handler2; } - onConnect(abort) { + #checkContentType(contentType) { + return this.#contentType.indexOf(contentType) === 0; + } + onRequestStart(controller, context3) { this.#statusCode = 0; this.#contentType = null; this.#decoder = null; this.#headers = null; this.#body = ""; - return this.#handler.onConnect(abort); + return super.onRequestStart(controller, context3); } - #checkContentType(contentType) { - return this.#contentType.indexOf(contentType) === 0; - } - onHeaders(statusCode, rawHeaders, resume, statusMessage, headers = parseHeaders(rawHeaders)) { + onResponseStart(controller, statusCode, headers, statusMessage) { this.#statusCode = statusCode; this.#headers = headers; this.#contentType = headers["content-type"]; if (this.#statusCode < 400) { - return this.#handler.onHeaders(statusCode, rawHeaders, resume, statusMessage, headers); + return super.onResponseStart(controller, statusCode, headers, statusMessage); } if (this.#checkContentType("application/json") || this.#checkContentType("text/plain")) { this.#decoder = new TextDecoder("utf-8"); } } - onData(chunk) { + onResponseData(controller, chunk) { var _a; if (this.#statusCode < 400) { - return this.#handler.onData(chunk); + return super.onResponseData(controller, chunk); } this.#body += ((_a = this.#decoder) == null ? void 0 : _a.decode(chunk, { stream: true })) ?? ""; } - onComplete(rawTrailers) { + onResponseEnd(controller, trailers) { var _a; if (this.#statusCode >= 400) { this.#body += ((_a = this.#decoder) == null ? void 0 : _a.decode(void 0, { stream: false })) ?? ""; @@ -30397,13 +30381,13 @@ var require_response_error = __commonJS({ } finally { Error.stackTraceLimit = stackTraceLimit; } - this.#handler.onError(err); + super.onResponseError(controller, err); } else { - this.#handler.onComplete(rawTrailers); + super.onResponseEnd(controller, trailers); } } - onError(err) { - this.#handler.onError(err); + onResponseError(err) { + super.onResponseError(err); } }; module.exports = () => { @@ -30444,79 +30428,71 @@ var require_retry = __commonJS({ var require_dump = __commonJS({ ""(exports, module) { "use strict"; - var util = require_util8(); var { InvalidArgumentError, RequestAbortedError } = require_errors2(); var DecoratorHandler = require_decorator_handler(); var DumpHandler = class extends DecoratorHandler { #maxSize = 1024 * 1024; - #abort = null; #dumped = false; - #aborted = false; #size = 0; - #reason = null; - #handler = null; - constructor({ maxSize }, handler2) { + #controller = null; + aborted = false; + reason = false; + constructor({ maxSize, signal }, handler2) { if (maxSize != null && (!Number.isFinite(maxSize) || maxSize < 1)) { throw new InvalidArgumentError("maxSize must be a number greater than 0"); } super(handler2); this.#maxSize = maxSize ?? this.#maxSize; - this.#handler = handler2; } - onConnect(abort) { - this.#abort = abort; - this.#handler.onConnect(this.#customAbort.bind(this)); + #abort(reason) { + this.aborted = true; + this.reason = reason; } - #customAbort(reason) { - this.#aborted = true; - this.#reason = reason; + onRequestStart(controller, context3) { + controller.abort = this.#abort.bind(this); + this.#controller = controller; + return super.onRequestStart(controller, context3); } - onHeaders(statusCode, rawHeaders, resume, statusMessage) { - const headers = util.parseHeaders(rawHeaders); + onResponseStart(controller, statusCode, headers, statusMessage) { const contentLength = headers["content-length"]; if (contentLength != null && contentLength > this.#maxSize) { throw new RequestAbortedError( `Response size (${contentLength}) larger than maxSize (${this.#maxSize})` ); } - if (this.#aborted) { + if (this.aborted === true) { return true; } - return this.#handler.onHeaders( - statusCode, - rawHeaders, - resume, - statusMessage - ); + return super.onResponseStart(controller, statusCode, headers, statusMessage); } - onError(err) { + onResponseError(controller, err) { if (this.#dumped) { return; } - err = this.#reason ?? err; - this.#handler.onError(err); + err = this.#controller.reason ?? err; + super.onResponseError(controller, err); } - onData(chunk) { + onResponseData(controller, chunk) { this.#size = this.#size + chunk.length; if (this.#size >= this.#maxSize) { this.#dumped = true; - if (this.#aborted) { - this.#handler.onError(this.#reason); + if (this.aborted === true) { + super.onResponseError(controller, this.reason); } else { - this.#handler.onComplete([]); + super.onResponseEnd(controller, {}); } } return true; } - onComplete(trailers) { + onResponseEnd(controller, trailers) { if (this.#dumped) { return; } - if (this.#aborted) { - this.#handler.onError(this.reason); + if (this.#controller.aborted === true) { + super.onResponseError(controller, this.reason); return; } - this.#handler.onComplete(trailers); + super.onResponseEnd(controller, trailers); } }; function createDumpInterceptor({ maxSize: defaultMaxSize } = { @@ -30525,10 +30501,7 @@ var require_dump = __commonJS({ return (dispatch) => { return function Intercept(opts, handler2) { const { dumpMaxSize = defaultMaxSize } = opts; - const dumpHandler = new DumpHandler( - { maxSize: dumpMaxSize }, - handler2 - ); + const dumpHandler = new DumpHandler({ maxSize: dumpMaxSize, signal: opts.signal }, handler2); return dispatch(opts, dumpHandler); }; }; @@ -30716,24 +30689,24 @@ var require_dns = __commonJS({ #state = null; #opts = null; #dispatch = null; - #handler = null; #origin = null; + #controller = null; constructor(state, { origin, handler: handler2, dispatch }, opts) { super(handler2); this.#origin = origin; - this.#handler = handler2; this.#opts = { ...opts }; this.#state = state; this.#dispatch = dispatch; } - onError(err) { + onResponseError(controller, err) { switch (err.code) { case "ETIMEDOUT": case "ECONNREFUSED": { if (this.#state.dualStack) { this.#state.runLookup(this.#origin, this.#opts, (err2, newOrigin) => { if (err2) { - return this.#handler.onError(err2); + super.onResponseError(controller, err2); + return; } const dispatchOpts = { ...this.#opts, @@ -30743,13 +30716,13 @@ var require_dns = __commonJS({ }); return; } - this.#handler.onError(err); - return; + super.onResponseError(controller, err); + break; } case "ENOTFOUND": this.#state.deleteRecord(this.#origin); default: - this.#handler.onError(err); + super.onResponseError(controller, err); break; } } @@ -38105,9 +38078,6 @@ var require_undici2 = __commonJS({ const SqliteCacheStore = require_sqlite_cache_store(); module.exports.cacheStores.SqliteCacheStore = SqliteCacheStore; } catch (err) { - if (err.code !== "ERR_UNKNOWN_BUILTIN_MODULE") { - throw err; - } } module.exports.buildConnector = buildConnector; module.exports.errors = errors; diff --git a/.github/ng-renovate/package.json b/.github/ng-renovate/package.json index 1d6292534..2821acacf 100644 --- a/.github/ng-renovate/package.json +++ b/.github/ng-renovate/package.json @@ -3,6 +3,6 @@ "packageManager": "yarn@4.5.3", "type": "commonjs", "dependencies": { - "renovate": "39.45.0" + "renovate": "39.49.1" } } diff --git a/.github/ng-renovate/yarn.lock b/.github/ng-renovate/yarn.lock index dadf3fae5..90b3a6156 100644 --- a/.github/ng-renovate/yarn.lock +++ b/.github/ng-renovate/yarn.lock @@ -2974,14 +2974,14 @@ __metadata: languageName: node linkType: hard -"better-sqlite3@npm:11.5.0": - version: 11.5.0 - resolution: "better-sqlite3@npm:11.5.0" +"better-sqlite3@npm:11.6.0": + version: 11.6.0 + resolution: "better-sqlite3@npm:11.6.0" dependencies: bindings: "npm:^1.5.0" node-gyp: "npm:latest" prebuild-install: "npm:^7.1.1" - checksum: 10c0/c24200972e11f6f99c4e6538122bd7ec8b31b92b2fa095f4b595cc39fedf924cb0a93fd326f0900415eccdf634367f7bba2ba4eaa4d164edd7352f4cfaaaec51 + checksum: 10c0/cafa207b40c42624d767a35f24fb16769d106486371b2e23497e9417505fa1fdedd94313b50508bd67f85713a996a0a9134458987c9b80a0a2b243d4db0d1259 languageName: node linkType: hard @@ -5568,12 +5568,12 @@ __metadata: languageName: node linkType: hard -"nanoid@npm:3.3.7": - version: 3.3.7 - resolution: "nanoid@npm:3.3.7" +"nanoid@npm:3.3.8": + version: 3.3.8 + resolution: "nanoid@npm:3.3.8" bin: nanoid: bin/nanoid.cjs - checksum: 10c0/e3fb661aa083454f40500473bb69eedb85dc160e763150b9a2c567c7e9ff560ce028a9f833123b618a6ea742e311138b591910e795614a629029e86e180660f3 + checksum: 10c0/4b1bb29f6cfebf3be3bc4ad1f1296fb0a10a3043a79f34fbffe75d1621b4318319211cd420549459018ea3592f0d2f159247a6f874911d6d26eaaadda2478120 languageName: node linkType: hard @@ -5618,7 +5618,7 @@ __metadata: version: 0.0.0-use.local resolution: "ng-renovate@workspace:." dependencies: - renovate: "npm:39.45.0" + renovate: "npm:39.49.1" languageName: unknown linkType: soft @@ -6049,12 +6049,12 @@ __metadata: languageName: node linkType: hard -"prettier@npm:3.3.3": - version: 3.3.3 - resolution: "prettier@npm:3.3.3" +"prettier@npm:3.4.1": + version: 3.4.1 + resolution: "prettier@npm:3.4.1" bin: prettier: bin/prettier.cjs - checksum: 10c0/b85828b08e7505716324e4245549b9205c0cacb25342a030ba8885aba2039a115dbcf75a0b7ca3b37bc9d101ee61fab8113fc69ca3359f2a226f1ecc07ad2e26 + checksum: 10c0/2d6cc3101ad9de72b49c59339480b0983e6ff6742143da0c43f476bf3b5ef88ede42ebd9956d7a0a8fa59f7a5990e8ef03c9ad4c37f7e4c9e5db43ee0853156c languageName: node linkType: hard @@ -6332,9 +6332,9 @@ __metadata: languageName: node linkType: hard -"renovate@npm:39.45.0": - version: 39.45.0 - resolution: "renovate@npm:39.45.0" +"renovate@npm:39.49.1": + version: 39.49.1 + resolution: "renovate@npm:39.49.1" dependencies: "@aws-sdk/client-codecommit": "npm:3.699.0" "@aws-sdk/client-ec2": "npm:3.701.0" @@ -6369,7 +6369,7 @@ __metadata: auth-header: "npm:1.0.0" aws4: "npm:1.13.2" azure-devops-node-api: "npm:14.1.0" - better-sqlite3: "npm:11.5.0" + better-sqlite3: "npm:11.6.0" bunyan: "npm:1.8.15" cacache: "npm:19.0.1" chalk: "npm:4.1.2" @@ -6415,7 +6415,7 @@ __metadata: minimatch: "npm:10.0.1" moo: "npm:0.5.2" ms: "npm:2.1.3" - nanoid: "npm:3.3.7" + nanoid: "npm:3.3.8" neotraverse: "npm:0.6.18" node-html-parser: "npm:6.1.13" openpgp: "npm:6.0.1" @@ -6424,7 +6424,7 @@ __metadata: p-queue: "npm:6.6.2" p-throttle: "npm:4.1.1" parse-link-header: "npm:2.0.0" - prettier: "npm:3.3.3" + prettier: "npm:3.4.1" protobufjs: "npm:7.4.0" punycode: "npm:2.3.1" re2: "npm:1.21.4" @@ -6458,7 +6458,7 @@ __metadata: bin: renovate: dist/renovate.js renovate-config-validator: dist/config-validator.js - checksum: 10c0/5920ab80a62eb93f790e03dcfd0414f05996016282d52968f1223ba002b665770f5858fa705a3177aa8db20051fd5f18aeda983e3053bbb815fa75521a50c545 + checksum: 10c0/72fa8163b74b7730f8bfaf8bcf8a610d18a9e03e678bce80f75ad0d70047ebad9cd5f93975b6716b2c727ae2efeb225a44b5b732cefddc86d701d11d5b589a47 languageName: node linkType: hard diff --git a/.github/workflows/codeql.yml b/.github/workflows/codeql.yml index 2b7434ce6..ceeeaa23b 100644 --- a/.github/workflows/codeql.yml +++ b/.github/workflows/codeql.yml @@ -27,10 +27,10 @@ jobs: - name: Checkout repository uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 # v4.2.2 - name: Initialize CodeQL - uses: github/codeql-action/init@f09c1c0a94de965c15400f5634aa42fac8fb8f88 # v3.27.5 + uses: github/codeql-action/init@aa578102511db1f4524ed59b8cc2bae4f6e88195 # v3.27.6 with: languages: ${{ matrix.language }} - name: Perform CodeQL Analysis - uses: github/codeql-action/analyze@f09c1c0a94de965c15400f5634aa42fac8fb8f88 # v3.27.5 + uses: github/codeql-action/analyze@aa578102511db1f4524ed59b8cc2bae4f6e88195 # v3.27.6 with: category: '/language:${{matrix.language}}' diff --git a/github-actions/branch-manager/main.js b/github-actions/branch-manager/main.js index 816abbda8..76a2505ce 100644 --- a/github-actions/branch-manager/main.js +++ b/github-actions/branch-manager/main.js @@ -26004,7 +26004,6 @@ var require_client_h2 = __commonJS({ } = require_symbols6(); var kOpenStreams = Symbol("open streams"); var extractBody; - var h2ExperimentalWarned = false; var http2; try { http2 = __require("node:http2"); @@ -26037,12 +26036,6 @@ var require_client_h2 = __commonJS({ } async function connectH2(client, socket) { client[kSocket] = socket; - if (!h2ExperimentalWarned) { - h2ExperimentalWarned = true; - process.emitWarning("H2 support is experimental, expect them to change at any time.", { - code: "UNDICI-H2" - }); - } const session = http2.connect(client[kUrl], { createConnection: () => socket, peerMaxConcurrentStreams: client[kMaxConcurrentStreams], @@ -30088,61 +30081,55 @@ var require_decorator_handler = __commonJS({ ""(exports, module) { "use strict"; var assert = __require("node:assert"); + var WrapHandler = require_wrap_handler(); module.exports = class DecoratorHandler { #handler; #onCompleteCalled = false; #onErrorCalled = false; + #onResponseStartCalled = false; constructor(handler2) { if (typeof handler2 !== "object" || handler2 === null) { throw new TypeError("handler must be an object"); } - this.#handler = handler2; - } - onConnect(...args) { - var _a, _b; - return (_b = (_a = this.#handler).onConnect) == null ? void 0 : _b.call(_a, ...args); - } - onError(...args) { - var _a, _b; - this.#onErrorCalled = true; - return (_b = (_a = this.#handler).onError) == null ? void 0 : _b.call(_a, ...args); + this.#handler = WrapHandler.wrap(handler2); } - onUpgrade(...args) { + onRequestStart(...args) { var _a, _b; - assert(!this.#onCompleteCalled); - assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onUpgrade) == null ? void 0 : _b.call(_a, ...args); + (_b = (_a = this.#handler).onRequestStart) == null ? void 0 : _b.call(_a, ...args); } - onResponseStarted(...args) { + onRequestUpgrade(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onResponseStarted) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onRequestUpgrade) == null ? void 0 : _b.call(_a, ...args); } - onHeaders(...args) { + onResponseStart(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onHeaders) == null ? void 0 : _b.call(_a, ...args); + assert(!this.#onResponseStartCalled); + this.#onResponseStartCalled = true; + return (_b = (_a = this.#handler).onResponseStart) == null ? void 0 : _b.call(_a, ...args); } - onData(...args) { + onResponseData(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onData) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onResponseData) == null ? void 0 : _b.call(_a, ...args); } - onComplete(...args) { + onResponseEnd(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); this.#onCompleteCalled = true; - return (_b = (_a = this.#handler).onComplete) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onResponseEnd) == null ? void 0 : _b.call(_a, ...args); } - onBodySent(...args) { + onResponseError(...args) { var _a, _b; - assert(!this.#onCompleteCalled); - assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onBodySent) == null ? void 0 : _b.call(_a, ...args); + this.#onErrorCalled = true; + return (_b = (_a = this.#handler).onResponseError) == null ? void 0 : _b.call(_a, ...args); + } + onBodySent() { } }; } @@ -30333,50 +30320,47 @@ var require_redirect = __commonJS({ var require_response_error = __commonJS({ ""(exports, module) { "use strict"; - var { parseHeaders } = require_util8(); var DecoratorHandler = require_decorator_handler(); var { ResponseError } = require_errors2(); var ResponseErrorHandler = class extends DecoratorHandler { - #handler; #statusCode; #contentType; #decoder; #headers; #body; - constructor(opts, { handler: handler2 }) { + constructor(_opts, { handler: handler2 }) { super(handler2); - this.#handler = handler2; } - onConnect(abort) { + #checkContentType(contentType) { + return this.#contentType.indexOf(contentType) === 0; + } + onRequestStart(controller, context3) { this.#statusCode = 0; this.#contentType = null; this.#decoder = null; this.#headers = null; this.#body = ""; - return this.#handler.onConnect(abort); + return super.onRequestStart(controller, context3); } - #checkContentType(contentType) { - return this.#contentType.indexOf(contentType) === 0; - } - onHeaders(statusCode, rawHeaders, resume, statusMessage, headers = parseHeaders(rawHeaders)) { + onResponseStart(controller, statusCode, headers, statusMessage) { this.#statusCode = statusCode; this.#headers = headers; this.#contentType = headers["content-type"]; if (this.#statusCode < 400) { - return this.#handler.onHeaders(statusCode, rawHeaders, resume, statusMessage, headers); + return super.onResponseStart(controller, statusCode, headers, statusMessage); } if (this.#checkContentType("application/json") || this.#checkContentType("text/plain")) { this.#decoder = new TextDecoder("utf-8"); } } - onData(chunk) { + onResponseData(controller, chunk) { var _a; if (this.#statusCode < 400) { - return this.#handler.onData(chunk); + return super.onResponseData(controller, chunk); } this.#body += ((_a = this.#decoder) == null ? void 0 : _a.decode(chunk, { stream: true })) ?? ""; } - onComplete(rawTrailers) { + onResponseEnd(controller, trailers) { var _a; if (this.#statusCode >= 400) { this.#body += ((_a = this.#decoder) == null ? void 0 : _a.decode(void 0, { stream: false })) ?? ""; @@ -30397,13 +30381,13 @@ var require_response_error = __commonJS({ } finally { Error.stackTraceLimit = stackTraceLimit; } - this.#handler.onError(err); + super.onResponseError(controller, err); } else { - this.#handler.onComplete(rawTrailers); + super.onResponseEnd(controller, trailers); } } - onError(err) { - this.#handler.onError(err); + onResponseError(err) { + super.onResponseError(err); } }; module.exports = () => { @@ -30444,79 +30428,71 @@ var require_retry = __commonJS({ var require_dump = __commonJS({ ""(exports, module) { "use strict"; - var util = require_util8(); var { InvalidArgumentError, RequestAbortedError } = require_errors2(); var DecoratorHandler = require_decorator_handler(); var DumpHandler = class extends DecoratorHandler { #maxSize = 1024 * 1024; - #abort = null; #dumped = false; - #aborted = false; #size = 0; - #reason = null; - #handler = null; - constructor({ maxSize }, handler2) { + #controller = null; + aborted = false; + reason = false; + constructor({ maxSize, signal }, handler2) { if (maxSize != null && (!Number.isFinite(maxSize) || maxSize < 1)) { throw new InvalidArgumentError("maxSize must be a number greater than 0"); } super(handler2); this.#maxSize = maxSize ?? this.#maxSize; - this.#handler = handler2; } - onConnect(abort) { - this.#abort = abort; - this.#handler.onConnect(this.#customAbort.bind(this)); + #abort(reason) { + this.aborted = true; + this.reason = reason; } - #customAbort(reason) { - this.#aborted = true; - this.#reason = reason; + onRequestStart(controller, context3) { + controller.abort = this.#abort.bind(this); + this.#controller = controller; + return super.onRequestStart(controller, context3); } - onHeaders(statusCode, rawHeaders, resume, statusMessage) { - const headers = util.parseHeaders(rawHeaders); + onResponseStart(controller, statusCode, headers, statusMessage) { const contentLength = headers["content-length"]; if (contentLength != null && contentLength > this.#maxSize) { throw new RequestAbortedError( `Response size (${contentLength}) larger than maxSize (${this.#maxSize})` ); } - if (this.#aborted) { + if (this.aborted === true) { return true; } - return this.#handler.onHeaders( - statusCode, - rawHeaders, - resume, - statusMessage - ); + return super.onResponseStart(controller, statusCode, headers, statusMessage); } - onError(err) { + onResponseError(controller, err) { if (this.#dumped) { return; } - err = this.#reason ?? err; - this.#handler.onError(err); + err = this.#controller.reason ?? err; + super.onResponseError(controller, err); } - onData(chunk) { + onResponseData(controller, chunk) { this.#size = this.#size + chunk.length; if (this.#size >= this.#maxSize) { this.#dumped = true; - if (this.#aborted) { - this.#handler.onError(this.#reason); + if (this.aborted === true) { + super.onResponseError(controller, this.reason); } else { - this.#handler.onComplete([]); + super.onResponseEnd(controller, {}); } } return true; } - onComplete(trailers) { + onResponseEnd(controller, trailers) { if (this.#dumped) { return; } - if (this.#aborted) { - this.#handler.onError(this.reason); + if (this.#controller.aborted === true) { + super.onResponseError(controller, this.reason); return; } - this.#handler.onComplete(trailers); + super.onResponseEnd(controller, trailers); } }; function createDumpInterceptor({ maxSize: defaultMaxSize } = { @@ -30525,10 +30501,7 @@ var require_dump = __commonJS({ return (dispatch) => { return function Intercept(opts, handler2) { const { dumpMaxSize = defaultMaxSize } = opts; - const dumpHandler = new DumpHandler( - { maxSize: dumpMaxSize }, - handler2 - ); + const dumpHandler = new DumpHandler({ maxSize: dumpMaxSize, signal: opts.signal }, handler2); return dispatch(opts, dumpHandler); }; }; @@ -30716,24 +30689,24 @@ var require_dns = __commonJS({ #state = null; #opts = null; #dispatch = null; - #handler = null; #origin = null; + #controller = null; constructor(state, { origin, handler: handler2, dispatch }, opts) { super(handler2); this.#origin = origin; - this.#handler = handler2; this.#opts = { ...opts }; this.#state = state; this.#dispatch = dispatch; } - onError(err) { + onResponseError(controller, err) { switch (err.code) { case "ETIMEDOUT": case "ECONNREFUSED": { if (this.#state.dualStack) { this.#state.runLookup(this.#origin, this.#opts, (err2, newOrigin) => { if (err2) { - return this.#handler.onError(err2); + super.onResponseError(controller, err2); + return; } const dispatchOpts = { ...this.#opts, @@ -30743,13 +30716,13 @@ var require_dns = __commonJS({ }); return; } - this.#handler.onError(err); - return; + super.onResponseError(controller, err); + break; } case "ENOTFOUND": this.#state.deleteRecord(this.#origin); default: - this.#handler.onError(err); + super.onResponseError(controller, err); break; } } @@ -38105,9 +38078,6 @@ var require_undici2 = __commonJS({ const SqliteCacheStore = require_sqlite_cache_store(); module.exports.cacheStores.SqliteCacheStore = SqliteCacheStore; } catch (err) { - if (err.code !== "ERR_UNKNOWN_BUILTIN_MODULE") { - throw err; - } } module.exports.buildConnector = buildConnector; module.exports.errors = errors; diff --git a/github-actions/commit-message-based-labels/main.js b/github-actions/commit-message-based-labels/main.js index 5d3f21c5c..16c372527 100644 --- a/github-actions/commit-message-based-labels/main.js +++ b/github-actions/commit-message-based-labels/main.js @@ -26004,7 +26004,6 @@ var require_client_h2 = __commonJS({ } = require_symbols6(); var kOpenStreams = Symbol("open streams"); var extractBody; - var h2ExperimentalWarned = false; var http2; try { http2 = __require("node:http2"); @@ -26037,12 +26036,6 @@ var require_client_h2 = __commonJS({ } async function connectH2(client, socket) { client[kSocket] = socket; - if (!h2ExperimentalWarned) { - h2ExperimentalWarned = true; - process.emitWarning("H2 support is experimental, expect them to change at any time.", { - code: "UNDICI-H2" - }); - } const session = http2.connect(client[kUrl], { createConnection: () => socket, peerMaxConcurrentStreams: client[kMaxConcurrentStreams], @@ -30088,61 +30081,55 @@ var require_decorator_handler = __commonJS({ ""(exports, module) { "use strict"; var assert = __require("node:assert"); + var WrapHandler = require_wrap_handler(); module.exports = class DecoratorHandler { #handler; #onCompleteCalled = false; #onErrorCalled = false; + #onResponseStartCalled = false; constructor(handler2) { if (typeof handler2 !== "object" || handler2 === null) { throw new TypeError("handler must be an object"); } - this.#handler = handler2; - } - onConnect(...args) { - var _a2, _b; - return (_b = (_a2 = this.#handler).onConnect) == null ? void 0 : _b.call(_a2, ...args); - } - onError(...args) { - var _a2, _b; - this.#onErrorCalled = true; - return (_b = (_a2 = this.#handler).onError) == null ? void 0 : _b.call(_a2, ...args); + this.#handler = WrapHandler.wrap(handler2); } - onUpgrade(...args) { + onRequestStart(...args) { var _a2, _b; - assert(!this.#onCompleteCalled); - assert(!this.#onErrorCalled); - return (_b = (_a2 = this.#handler).onUpgrade) == null ? void 0 : _b.call(_a2, ...args); + (_b = (_a2 = this.#handler).onRequestStart) == null ? void 0 : _b.call(_a2, ...args); } - onResponseStarted(...args) { + onRequestUpgrade(...args) { var _a2, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a2 = this.#handler).onResponseStarted) == null ? void 0 : _b.call(_a2, ...args); + return (_b = (_a2 = this.#handler).onRequestUpgrade) == null ? void 0 : _b.call(_a2, ...args); } - onHeaders(...args) { + onResponseStart(...args) { var _a2, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a2 = this.#handler).onHeaders) == null ? void 0 : _b.call(_a2, ...args); + assert(!this.#onResponseStartCalled); + this.#onResponseStartCalled = true; + return (_b = (_a2 = this.#handler).onResponseStart) == null ? void 0 : _b.call(_a2, ...args); } - onData(...args) { + onResponseData(...args) { var _a2, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a2 = this.#handler).onData) == null ? void 0 : _b.call(_a2, ...args); + return (_b = (_a2 = this.#handler).onResponseData) == null ? void 0 : _b.call(_a2, ...args); } - onComplete(...args) { + onResponseEnd(...args) { var _a2, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); this.#onCompleteCalled = true; - return (_b = (_a2 = this.#handler).onComplete) == null ? void 0 : _b.call(_a2, ...args); + return (_b = (_a2 = this.#handler).onResponseEnd) == null ? void 0 : _b.call(_a2, ...args); } - onBodySent(...args) { + onResponseError(...args) { var _a2, _b; - assert(!this.#onCompleteCalled); - assert(!this.#onErrorCalled); - return (_b = (_a2 = this.#handler).onBodySent) == null ? void 0 : _b.call(_a2, ...args); + this.#onErrorCalled = true; + return (_b = (_a2 = this.#handler).onResponseError) == null ? void 0 : _b.call(_a2, ...args); + } + onBodySent() { } }; } @@ -30333,50 +30320,47 @@ var require_redirect = __commonJS({ var require_response_error = __commonJS({ ""(exports, module) { "use strict"; - var { parseHeaders } = require_util8(); var DecoratorHandler = require_decorator_handler(); var { ResponseError } = require_errors2(); var ResponseErrorHandler = class extends DecoratorHandler { - #handler; #statusCode; #contentType; #decoder; #headers; #body; - constructor(opts, { handler: handler2 }) { + constructor(_opts, { handler: handler2 }) { super(handler2); - this.#handler = handler2; } - onConnect(abort) { + #checkContentType(contentType) { + return this.#contentType.indexOf(contentType) === 0; + } + onRequestStart(controller, context3) { this.#statusCode = 0; this.#contentType = null; this.#decoder = null; this.#headers = null; this.#body = ""; - return this.#handler.onConnect(abort); + return super.onRequestStart(controller, context3); } - #checkContentType(contentType) { - return this.#contentType.indexOf(contentType) === 0; - } - onHeaders(statusCode, rawHeaders, resume, statusMessage, headers = parseHeaders(rawHeaders)) { + onResponseStart(controller, statusCode, headers, statusMessage) { this.#statusCode = statusCode; this.#headers = headers; this.#contentType = headers["content-type"]; if (this.#statusCode < 400) { - return this.#handler.onHeaders(statusCode, rawHeaders, resume, statusMessage, headers); + return super.onResponseStart(controller, statusCode, headers, statusMessage); } if (this.#checkContentType("application/json") || this.#checkContentType("text/plain")) { this.#decoder = new TextDecoder("utf-8"); } } - onData(chunk) { + onResponseData(controller, chunk) { var _a2; if (this.#statusCode < 400) { - return this.#handler.onData(chunk); + return super.onResponseData(controller, chunk); } this.#body += ((_a2 = this.#decoder) == null ? void 0 : _a2.decode(chunk, { stream: true })) ?? ""; } - onComplete(rawTrailers) { + onResponseEnd(controller, trailers) { var _a2; if (this.#statusCode >= 400) { this.#body += ((_a2 = this.#decoder) == null ? void 0 : _a2.decode(void 0, { stream: false })) ?? ""; @@ -30397,13 +30381,13 @@ var require_response_error = __commonJS({ } finally { Error.stackTraceLimit = stackTraceLimit; } - this.#handler.onError(err); + super.onResponseError(controller, err); } else { - this.#handler.onComplete(rawTrailers); + super.onResponseEnd(controller, trailers); } } - onError(err) { - this.#handler.onError(err); + onResponseError(err) { + super.onResponseError(err); } }; module.exports = () => { @@ -30444,79 +30428,71 @@ var require_retry = __commonJS({ var require_dump = __commonJS({ ""(exports, module) { "use strict"; - var util = require_util8(); var { InvalidArgumentError, RequestAbortedError } = require_errors2(); var DecoratorHandler = require_decorator_handler(); var DumpHandler = class extends DecoratorHandler { #maxSize = 1024 * 1024; - #abort = null; #dumped = false; - #aborted = false; #size = 0; - #reason = null; - #handler = null; - constructor({ maxSize }, handler2) { + #controller = null; + aborted = false; + reason = false; + constructor({ maxSize, signal }, handler2) { if (maxSize != null && (!Number.isFinite(maxSize) || maxSize < 1)) { throw new InvalidArgumentError("maxSize must be a number greater than 0"); } super(handler2); this.#maxSize = maxSize ?? this.#maxSize; - this.#handler = handler2; } - onConnect(abort) { - this.#abort = abort; - this.#handler.onConnect(this.#customAbort.bind(this)); + #abort(reason) { + this.aborted = true; + this.reason = reason; } - #customAbort(reason) { - this.#aborted = true; - this.#reason = reason; + onRequestStart(controller, context3) { + controller.abort = this.#abort.bind(this); + this.#controller = controller; + return super.onRequestStart(controller, context3); } - onHeaders(statusCode, rawHeaders, resume, statusMessage) { - const headers = util.parseHeaders(rawHeaders); + onResponseStart(controller, statusCode, headers, statusMessage) { const contentLength = headers["content-length"]; if (contentLength != null && contentLength > this.#maxSize) { throw new RequestAbortedError( `Response size (${contentLength}) larger than maxSize (${this.#maxSize})` ); } - if (this.#aborted) { + if (this.aborted === true) { return true; } - return this.#handler.onHeaders( - statusCode, - rawHeaders, - resume, - statusMessage - ); + return super.onResponseStart(controller, statusCode, headers, statusMessage); } - onError(err) { + onResponseError(controller, err) { if (this.#dumped) { return; } - err = this.#reason ?? err; - this.#handler.onError(err); + err = this.#controller.reason ?? err; + super.onResponseError(controller, err); } - onData(chunk) { + onResponseData(controller, chunk) { this.#size = this.#size + chunk.length; if (this.#size >= this.#maxSize) { this.#dumped = true; - if (this.#aborted) { - this.#handler.onError(this.#reason); + if (this.aborted === true) { + super.onResponseError(controller, this.reason); } else { - this.#handler.onComplete([]); + super.onResponseEnd(controller, {}); } } return true; } - onComplete(trailers) { + onResponseEnd(controller, trailers) { if (this.#dumped) { return; } - if (this.#aborted) { - this.#handler.onError(this.reason); + if (this.#controller.aborted === true) { + super.onResponseError(controller, this.reason); return; } - this.#handler.onComplete(trailers); + super.onResponseEnd(controller, trailers); } }; function createDumpInterceptor({ maxSize: defaultMaxSize } = { @@ -30525,10 +30501,7 @@ var require_dump = __commonJS({ return (dispatch) => { return function Intercept(opts, handler2) { const { dumpMaxSize = defaultMaxSize } = opts; - const dumpHandler = new DumpHandler( - { maxSize: dumpMaxSize }, - handler2 - ); + const dumpHandler = new DumpHandler({ maxSize: dumpMaxSize, signal: opts.signal }, handler2); return dispatch(opts, dumpHandler); }; }; @@ -30716,24 +30689,24 @@ var require_dns = __commonJS({ #state = null; #opts = null; #dispatch = null; - #handler = null; #origin = null; + #controller = null; constructor(state, { origin, handler: handler2, dispatch }, opts) { super(handler2); this.#origin = origin; - this.#handler = handler2; this.#opts = { ...opts }; this.#state = state; this.#dispatch = dispatch; } - onError(err) { + onResponseError(controller, err) { switch (err.code) { case "ETIMEDOUT": case "ECONNREFUSED": { if (this.#state.dualStack) { this.#state.runLookup(this.#origin, this.#opts, (err2, newOrigin) => { if (err2) { - return this.#handler.onError(err2); + super.onResponseError(controller, err2); + return; } const dispatchOpts = { ...this.#opts, @@ -30743,13 +30716,13 @@ var require_dns = __commonJS({ }); return; } - this.#handler.onError(err); - return; + super.onResponseError(controller, err); + break; } case "ENOTFOUND": this.#state.deleteRecord(this.#origin); default: - this.#handler.onError(err); + super.onResponseError(controller, err); break; } } @@ -38105,9 +38078,6 @@ var require_undici2 = __commonJS({ const SqliteCacheStore = require_sqlite_cache_store(); module.exports.cacheStores.SqliteCacheStore = SqliteCacheStore; } catch (err) { - if (err.code !== "ERR_UNKNOWN_BUILTIN_MODULE") { - throw err; - } } module.exports.buildConnector = buildConnector; module.exports.errors = errors; diff --git a/github-actions/create-pr-for-changes/main.js b/github-actions/create-pr-for-changes/main.js index f321a4614..d9c6305e7 100644 --- a/github-actions/create-pr-for-changes/main.js +++ b/github-actions/create-pr-for-changes/main.js @@ -25999,7 +25999,6 @@ var require_client_h2 = __commonJS({ } = require_symbols6(); var kOpenStreams = Symbol("open streams"); var extractBody; - var h2ExperimentalWarned = false; var http2; try { http2 = __require("node:http2"); @@ -26032,12 +26031,6 @@ var require_client_h2 = __commonJS({ } async function connectH2(client, socket) { client[kSocket] = socket; - if (!h2ExperimentalWarned) { - h2ExperimentalWarned = true; - process.emitWarning("H2 support is experimental, expect them to change at any time.", { - code: "UNDICI-H2" - }); - } const session = http2.connect(client[kUrl], { createConnection: () => socket, peerMaxConcurrentStreams: client[kMaxConcurrentStreams], @@ -30083,61 +30076,55 @@ var require_decorator_handler = __commonJS({ ""(exports, module) { "use strict"; var assert2 = __require("node:assert"); + var WrapHandler = require_wrap_handler(); module.exports = class DecoratorHandler { #handler; #onCompleteCalled = false; #onErrorCalled = false; + #onResponseStartCalled = false; constructor(handler2) { if (typeof handler2 !== "object" || handler2 === null) { throw new TypeError("handler must be an object"); } - this.#handler = handler2; - } - onConnect(...args) { - var _a, _b; - return (_b = (_a = this.#handler).onConnect) == null ? void 0 : _b.call(_a, ...args); - } - onError(...args) { - var _a, _b; - this.#onErrorCalled = true; - return (_b = (_a = this.#handler).onError) == null ? void 0 : _b.call(_a, ...args); + this.#handler = WrapHandler.wrap(handler2); } - onUpgrade(...args) { + onRequestStart(...args) { var _a, _b; - assert2(!this.#onCompleteCalled); - assert2(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onUpgrade) == null ? void 0 : _b.call(_a, ...args); + (_b = (_a = this.#handler).onRequestStart) == null ? void 0 : _b.call(_a, ...args); } - onResponseStarted(...args) { + onRequestUpgrade(...args) { var _a, _b; assert2(!this.#onCompleteCalled); assert2(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onResponseStarted) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onRequestUpgrade) == null ? void 0 : _b.call(_a, ...args); } - onHeaders(...args) { + onResponseStart(...args) { var _a, _b; assert2(!this.#onCompleteCalled); assert2(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onHeaders) == null ? void 0 : _b.call(_a, ...args); + assert2(!this.#onResponseStartCalled); + this.#onResponseStartCalled = true; + return (_b = (_a = this.#handler).onResponseStart) == null ? void 0 : _b.call(_a, ...args); } - onData(...args) { + onResponseData(...args) { var _a, _b; assert2(!this.#onCompleteCalled); assert2(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onData) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onResponseData) == null ? void 0 : _b.call(_a, ...args); } - onComplete(...args) { + onResponseEnd(...args) { var _a, _b; assert2(!this.#onCompleteCalled); assert2(!this.#onErrorCalled); this.#onCompleteCalled = true; - return (_b = (_a = this.#handler).onComplete) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onResponseEnd) == null ? void 0 : _b.call(_a, ...args); } - onBodySent(...args) { + onResponseError(...args) { var _a, _b; - assert2(!this.#onCompleteCalled); - assert2(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onBodySent) == null ? void 0 : _b.call(_a, ...args); + this.#onErrorCalled = true; + return (_b = (_a = this.#handler).onResponseError) == null ? void 0 : _b.call(_a, ...args); + } + onBodySent() { } }; } @@ -30328,50 +30315,47 @@ var require_redirect = __commonJS({ var require_response_error = __commonJS({ ""(exports, module) { "use strict"; - var { parseHeaders } = require_util8(); var DecoratorHandler = require_decorator_handler(); var { ResponseError } = require_errors2(); var ResponseErrorHandler = class extends DecoratorHandler { - #handler; #statusCode; #contentType; #decoder; #headers; #body; - constructor(opts, { handler: handler2 }) { + constructor(_opts, { handler: handler2 }) { super(handler2); - this.#handler = handler2; } - onConnect(abort) { + #checkContentType(contentType) { + return this.#contentType.indexOf(contentType) === 0; + } + onRequestStart(controller, context2) { this.#statusCode = 0; this.#contentType = null; this.#decoder = null; this.#headers = null; this.#body = ""; - return this.#handler.onConnect(abort); + return super.onRequestStart(controller, context2); } - #checkContentType(contentType) { - return this.#contentType.indexOf(contentType) === 0; - } - onHeaders(statusCode, rawHeaders, resume, statusMessage, headers = parseHeaders(rawHeaders)) { + onResponseStart(controller, statusCode, headers, statusMessage) { this.#statusCode = statusCode; this.#headers = headers; this.#contentType = headers["content-type"]; if (this.#statusCode < 400) { - return this.#handler.onHeaders(statusCode, rawHeaders, resume, statusMessage, headers); + return super.onResponseStart(controller, statusCode, headers, statusMessage); } if (this.#checkContentType("application/json") || this.#checkContentType("text/plain")) { this.#decoder = new TextDecoder("utf-8"); } } - onData(chunk) { + onResponseData(controller, chunk) { var _a; if (this.#statusCode < 400) { - return this.#handler.onData(chunk); + return super.onResponseData(controller, chunk); } this.#body += ((_a = this.#decoder) == null ? void 0 : _a.decode(chunk, { stream: true })) ?? ""; } - onComplete(rawTrailers) { + onResponseEnd(controller, trailers) { var _a; if (this.#statusCode >= 400) { this.#body += ((_a = this.#decoder) == null ? void 0 : _a.decode(void 0, { stream: false })) ?? ""; @@ -30392,13 +30376,13 @@ var require_response_error = __commonJS({ } finally { Error.stackTraceLimit = stackTraceLimit; } - this.#handler.onError(err); + super.onResponseError(controller, err); } else { - this.#handler.onComplete(rawTrailers); + super.onResponseEnd(controller, trailers); } } - onError(err) { - this.#handler.onError(err); + onResponseError(err) { + super.onResponseError(err); } }; module.exports = () => { @@ -30439,79 +30423,71 @@ var require_retry = __commonJS({ var require_dump = __commonJS({ ""(exports, module) { "use strict"; - var util = require_util8(); var { InvalidArgumentError, RequestAbortedError } = require_errors2(); var DecoratorHandler = require_decorator_handler(); var DumpHandler = class extends DecoratorHandler { #maxSize = 1024 * 1024; - #abort = null; #dumped = false; - #aborted = false; #size = 0; - #reason = null; - #handler = null; - constructor({ maxSize }, handler2) { + #controller = null; + aborted = false; + reason = false; + constructor({ maxSize, signal }, handler2) { if (maxSize != null && (!Number.isFinite(maxSize) || maxSize < 1)) { throw new InvalidArgumentError("maxSize must be a number greater than 0"); } super(handler2); this.#maxSize = maxSize ?? this.#maxSize; - this.#handler = handler2; } - onConnect(abort) { - this.#abort = abort; - this.#handler.onConnect(this.#customAbort.bind(this)); + #abort(reason) { + this.aborted = true; + this.reason = reason; } - #customAbort(reason) { - this.#aborted = true; - this.#reason = reason; + onRequestStart(controller, context2) { + controller.abort = this.#abort.bind(this); + this.#controller = controller; + return super.onRequestStart(controller, context2); } - onHeaders(statusCode, rawHeaders, resume, statusMessage) { - const headers = util.parseHeaders(rawHeaders); + onResponseStart(controller, statusCode, headers, statusMessage) { const contentLength = headers["content-length"]; if (contentLength != null && contentLength > this.#maxSize) { throw new RequestAbortedError( `Response size (${contentLength}) larger than maxSize (${this.#maxSize})` ); } - if (this.#aborted) { + if (this.aborted === true) { return true; } - return this.#handler.onHeaders( - statusCode, - rawHeaders, - resume, - statusMessage - ); + return super.onResponseStart(controller, statusCode, headers, statusMessage); } - onError(err) { + onResponseError(controller, err) { if (this.#dumped) { return; } - err = this.#reason ?? err; - this.#handler.onError(err); + err = this.#controller.reason ?? err; + super.onResponseError(controller, err); } - onData(chunk) { + onResponseData(controller, chunk) { this.#size = this.#size + chunk.length; if (this.#size >= this.#maxSize) { this.#dumped = true; - if (this.#aborted) { - this.#handler.onError(this.#reason); + if (this.aborted === true) { + super.onResponseError(controller, this.reason); } else { - this.#handler.onComplete([]); + super.onResponseEnd(controller, {}); } } return true; } - onComplete(trailers) { + onResponseEnd(controller, trailers) { if (this.#dumped) { return; } - if (this.#aborted) { - this.#handler.onError(this.reason); + if (this.#controller.aborted === true) { + super.onResponseError(controller, this.reason); return; } - this.#handler.onComplete(trailers); + super.onResponseEnd(controller, trailers); } }; function createDumpInterceptor({ maxSize: defaultMaxSize } = { @@ -30520,10 +30496,7 @@ var require_dump = __commonJS({ return (dispatch) => { return function Intercept(opts, handler2) { const { dumpMaxSize = defaultMaxSize } = opts; - const dumpHandler = new DumpHandler( - { maxSize: dumpMaxSize }, - handler2 - ); + const dumpHandler = new DumpHandler({ maxSize: dumpMaxSize, signal: opts.signal }, handler2); return dispatch(opts, dumpHandler); }; }; @@ -30711,24 +30684,24 @@ var require_dns = __commonJS({ #state = null; #opts = null; #dispatch = null; - #handler = null; #origin = null; + #controller = null; constructor(state, { origin, handler: handler2, dispatch }, opts) { super(handler2); this.#origin = origin; - this.#handler = handler2; this.#opts = { ...opts }; this.#state = state; this.#dispatch = dispatch; } - onError(err) { + onResponseError(controller, err) { switch (err.code) { case "ETIMEDOUT": case "ECONNREFUSED": { if (this.#state.dualStack) { this.#state.runLookup(this.#origin, this.#opts, (err2, newOrigin) => { if (err2) { - return this.#handler.onError(err2); + super.onResponseError(controller, err2); + return; } const dispatchOpts = { ...this.#opts, @@ -30738,13 +30711,13 @@ var require_dns = __commonJS({ }); return; } - this.#handler.onError(err); - return; + super.onResponseError(controller, err); + break; } case "ENOTFOUND": this.#state.deleteRecord(this.#origin); default: - this.#handler.onError(err); + super.onResponseError(controller, err); break; } } @@ -38100,9 +38073,6 @@ var require_undici2 = __commonJS({ const SqliteCacheStore = require_sqlite_cache_store(); module.exports.cacheStores.SqliteCacheStore = SqliteCacheStore; } catch (err) { - if (err.code !== "ERR_UNKNOWN_BUILTIN_MODULE") { - throw err; - } } module.exports.buildConnector = buildConnector; module.exports.errors = errors; diff --git a/github-actions/feature-request/main.js b/github-actions/feature-request/main.js index 42968ee50..189a9a902 100644 --- a/github-actions/feature-request/main.js +++ b/github-actions/feature-request/main.js @@ -26004,7 +26004,6 @@ var require_client_h2 = __commonJS({ } = require_symbols6(); var kOpenStreams = Symbol("open streams"); var extractBody; - var h2ExperimentalWarned = false; var http2; try { http2 = __require("node:http2"); @@ -26037,12 +26036,6 @@ var require_client_h2 = __commonJS({ } async function connectH2(client, socket) { client[kSocket] = socket; - if (!h2ExperimentalWarned) { - h2ExperimentalWarned = true; - process.emitWarning("H2 support is experimental, expect them to change at any time.", { - code: "UNDICI-H2" - }); - } const session = http2.connect(client[kUrl], { createConnection: () => socket, peerMaxConcurrentStreams: client[kMaxConcurrentStreams], @@ -30088,61 +30081,55 @@ var require_decorator_handler = __commonJS({ ""(exports, module) { "use strict"; var assert = __require("node:assert"); + var WrapHandler = require_wrap_handler(); module.exports = class DecoratorHandler { #handler; #onCompleteCalled = false; #onErrorCalled = false; + #onResponseStartCalled = false; constructor(handler2) { if (typeof handler2 !== "object" || handler2 === null) { throw new TypeError("handler must be an object"); } - this.#handler = handler2; - } - onConnect(...args) { - var _a, _b; - return (_b = (_a = this.#handler).onConnect) == null ? void 0 : _b.call(_a, ...args); - } - onError(...args) { - var _a, _b; - this.#onErrorCalled = true; - return (_b = (_a = this.#handler).onError) == null ? void 0 : _b.call(_a, ...args); + this.#handler = WrapHandler.wrap(handler2); } - onUpgrade(...args) { + onRequestStart(...args) { var _a, _b; - assert(!this.#onCompleteCalled); - assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onUpgrade) == null ? void 0 : _b.call(_a, ...args); + (_b = (_a = this.#handler).onRequestStart) == null ? void 0 : _b.call(_a, ...args); } - onResponseStarted(...args) { + onRequestUpgrade(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onResponseStarted) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onRequestUpgrade) == null ? void 0 : _b.call(_a, ...args); } - onHeaders(...args) { + onResponseStart(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onHeaders) == null ? void 0 : _b.call(_a, ...args); + assert(!this.#onResponseStartCalled); + this.#onResponseStartCalled = true; + return (_b = (_a = this.#handler).onResponseStart) == null ? void 0 : _b.call(_a, ...args); } - onData(...args) { + onResponseData(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onData) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onResponseData) == null ? void 0 : _b.call(_a, ...args); } - onComplete(...args) { + onResponseEnd(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); this.#onCompleteCalled = true; - return (_b = (_a = this.#handler).onComplete) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onResponseEnd) == null ? void 0 : _b.call(_a, ...args); } - onBodySent(...args) { + onResponseError(...args) { var _a, _b; - assert(!this.#onCompleteCalled); - assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onBodySent) == null ? void 0 : _b.call(_a, ...args); + this.#onErrorCalled = true; + return (_b = (_a = this.#handler).onResponseError) == null ? void 0 : _b.call(_a, ...args); + } + onBodySent() { } }; } @@ -30333,50 +30320,47 @@ var require_redirect = __commonJS({ var require_response_error = __commonJS({ ""(exports, module) { "use strict"; - var { parseHeaders } = require_util8(); var DecoratorHandler = require_decorator_handler(); var { ResponseError } = require_errors2(); var ResponseErrorHandler = class extends DecoratorHandler { - #handler; #statusCode; #contentType; #decoder; #headers; #body; - constructor(opts, { handler: handler2 }) { + constructor(_opts, { handler: handler2 }) { super(handler2); - this.#handler = handler2; } - onConnect(abort) { + #checkContentType(contentType) { + return this.#contentType.indexOf(contentType) === 0; + } + onRequestStart(controller, context3) { this.#statusCode = 0; this.#contentType = null; this.#decoder = null; this.#headers = null; this.#body = ""; - return this.#handler.onConnect(abort); + return super.onRequestStart(controller, context3); } - #checkContentType(contentType) { - return this.#contentType.indexOf(contentType) === 0; - } - onHeaders(statusCode, rawHeaders, resume, statusMessage, headers = parseHeaders(rawHeaders)) { + onResponseStart(controller, statusCode, headers, statusMessage) { this.#statusCode = statusCode; this.#headers = headers; this.#contentType = headers["content-type"]; if (this.#statusCode < 400) { - return this.#handler.onHeaders(statusCode, rawHeaders, resume, statusMessage, headers); + return super.onResponseStart(controller, statusCode, headers, statusMessage); } if (this.#checkContentType("application/json") || this.#checkContentType("text/plain")) { this.#decoder = new TextDecoder("utf-8"); } } - onData(chunk) { + onResponseData(controller, chunk) { var _a; if (this.#statusCode < 400) { - return this.#handler.onData(chunk); + return super.onResponseData(controller, chunk); } this.#body += ((_a = this.#decoder) == null ? void 0 : _a.decode(chunk, { stream: true })) ?? ""; } - onComplete(rawTrailers) { + onResponseEnd(controller, trailers) { var _a; if (this.#statusCode >= 400) { this.#body += ((_a = this.#decoder) == null ? void 0 : _a.decode(void 0, { stream: false })) ?? ""; @@ -30397,13 +30381,13 @@ var require_response_error = __commonJS({ } finally { Error.stackTraceLimit = stackTraceLimit; } - this.#handler.onError(err); + super.onResponseError(controller, err); } else { - this.#handler.onComplete(rawTrailers); + super.onResponseEnd(controller, trailers); } } - onError(err) { - this.#handler.onError(err); + onResponseError(err) { + super.onResponseError(err); } }; module.exports = () => { @@ -30444,79 +30428,71 @@ var require_retry = __commonJS({ var require_dump = __commonJS({ ""(exports, module) { "use strict"; - var util = require_util8(); var { InvalidArgumentError, RequestAbortedError } = require_errors2(); var DecoratorHandler = require_decorator_handler(); var DumpHandler = class extends DecoratorHandler { #maxSize = 1024 * 1024; - #abort = null; #dumped = false; - #aborted = false; #size = 0; - #reason = null; - #handler = null; - constructor({ maxSize }, handler2) { + #controller = null; + aborted = false; + reason = false; + constructor({ maxSize, signal }, handler2) { if (maxSize != null && (!Number.isFinite(maxSize) || maxSize < 1)) { throw new InvalidArgumentError("maxSize must be a number greater than 0"); } super(handler2); this.#maxSize = maxSize ?? this.#maxSize; - this.#handler = handler2; } - onConnect(abort) { - this.#abort = abort; - this.#handler.onConnect(this.#customAbort.bind(this)); + #abort(reason) { + this.aborted = true; + this.reason = reason; } - #customAbort(reason) { - this.#aborted = true; - this.#reason = reason; + onRequestStart(controller, context3) { + controller.abort = this.#abort.bind(this); + this.#controller = controller; + return super.onRequestStart(controller, context3); } - onHeaders(statusCode, rawHeaders, resume, statusMessage) { - const headers = util.parseHeaders(rawHeaders); + onResponseStart(controller, statusCode, headers, statusMessage) { const contentLength = headers["content-length"]; if (contentLength != null && contentLength > this.#maxSize) { throw new RequestAbortedError( `Response size (${contentLength}) larger than maxSize (${this.#maxSize})` ); } - if (this.#aborted) { + if (this.aborted === true) { return true; } - return this.#handler.onHeaders( - statusCode, - rawHeaders, - resume, - statusMessage - ); + return super.onResponseStart(controller, statusCode, headers, statusMessage); } - onError(err) { + onResponseError(controller, err) { if (this.#dumped) { return; } - err = this.#reason ?? err; - this.#handler.onError(err); + err = this.#controller.reason ?? err; + super.onResponseError(controller, err); } - onData(chunk) { + onResponseData(controller, chunk) { this.#size = this.#size + chunk.length; if (this.#size >= this.#maxSize) { this.#dumped = true; - if (this.#aborted) { - this.#handler.onError(this.#reason); + if (this.aborted === true) { + super.onResponseError(controller, this.reason); } else { - this.#handler.onComplete([]); + super.onResponseEnd(controller, {}); } } return true; } - onComplete(trailers) { + onResponseEnd(controller, trailers) { if (this.#dumped) { return; } - if (this.#aborted) { - this.#handler.onError(this.reason); + if (this.#controller.aborted === true) { + super.onResponseError(controller, this.reason); return; } - this.#handler.onComplete(trailers); + super.onResponseEnd(controller, trailers); } }; function createDumpInterceptor({ maxSize: defaultMaxSize } = { @@ -30525,10 +30501,7 @@ var require_dump = __commonJS({ return (dispatch) => { return function Intercept(opts, handler2) { const { dumpMaxSize = defaultMaxSize } = opts; - const dumpHandler = new DumpHandler( - { maxSize: dumpMaxSize }, - handler2 - ); + const dumpHandler = new DumpHandler({ maxSize: dumpMaxSize, signal: opts.signal }, handler2); return dispatch(opts, dumpHandler); }; }; @@ -30716,24 +30689,24 @@ var require_dns = __commonJS({ #state = null; #opts = null; #dispatch = null; - #handler = null; #origin = null; + #controller = null; constructor(state, { origin, handler: handler2, dispatch }, opts) { super(handler2); this.#origin = origin; - this.#handler = handler2; this.#opts = { ...opts }; this.#state = state; this.#dispatch = dispatch; } - onError(err) { + onResponseError(controller, err) { switch (err.code) { case "ETIMEDOUT": case "ECONNREFUSED": { if (this.#state.dualStack) { this.#state.runLookup(this.#origin, this.#opts, (err2, newOrigin) => { if (err2) { - return this.#handler.onError(err2); + super.onResponseError(controller, err2); + return; } const dispatchOpts = { ...this.#opts, @@ -30743,13 +30716,13 @@ var require_dns = __commonJS({ }); return; } - this.#handler.onError(err); - return; + super.onResponseError(controller, err); + break; } case "ENOTFOUND": this.#state.deleteRecord(this.#origin); default: - this.#handler.onError(err); + super.onResponseError(controller, err); break; } } @@ -38105,9 +38078,6 @@ var require_undici2 = __commonJS({ const SqliteCacheStore = require_sqlite_cache_store(); module.exports.cacheStores.SqliteCacheStore = SqliteCacheStore; } catch (err) { - if (err.code !== "ERR_UNKNOWN_BUILTIN_MODULE") { - throw err; - } } module.exports.buildConnector = buildConnector; module.exports.errors = errors; diff --git a/github-actions/google-internal-tests/main.js b/github-actions/google-internal-tests/main.js index 51992aaaf..e8992c461 100644 --- a/github-actions/google-internal-tests/main.js +++ b/github-actions/google-internal-tests/main.js @@ -26003,7 +26003,6 @@ var require_client_h2 = __commonJS({ } = require_symbols6(); var kOpenStreams = Symbol("open streams"); var extractBody; - var h2ExperimentalWarned = false; var http2; try { http2 = __require("node:http2"); @@ -26036,12 +26035,6 @@ var require_client_h2 = __commonJS({ } async function connectH2(client, socket) { client[kSocket] = socket; - if (!h2ExperimentalWarned) { - h2ExperimentalWarned = true; - process.emitWarning("H2 support is experimental, expect them to change at any time.", { - code: "UNDICI-H2" - }); - } const session = http2.connect(client[kUrl], { createConnection: () => socket, peerMaxConcurrentStreams: client[kMaxConcurrentStreams], @@ -30087,61 +30080,55 @@ var require_decorator_handler = __commonJS({ ""(exports, module) { "use strict"; var assert = __require("node:assert"); + var WrapHandler = require_wrap_handler(); module.exports = class DecoratorHandler { #handler; #onCompleteCalled = false; #onErrorCalled = false; + #onResponseStartCalled = false; constructor(handler2) { if (typeof handler2 !== "object" || handler2 === null) { throw new TypeError("handler must be an object"); } - this.#handler = handler2; - } - onConnect(...args) { - var _a, _b; - return (_b = (_a = this.#handler).onConnect) == null ? void 0 : _b.call(_a, ...args); - } - onError(...args) { - var _a, _b; - this.#onErrorCalled = true; - return (_b = (_a = this.#handler).onError) == null ? void 0 : _b.call(_a, ...args); + this.#handler = WrapHandler.wrap(handler2); } - onUpgrade(...args) { + onRequestStart(...args) { var _a, _b; - assert(!this.#onCompleteCalled); - assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onUpgrade) == null ? void 0 : _b.call(_a, ...args); + (_b = (_a = this.#handler).onRequestStart) == null ? void 0 : _b.call(_a, ...args); } - onResponseStarted(...args) { + onRequestUpgrade(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onResponseStarted) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onRequestUpgrade) == null ? void 0 : _b.call(_a, ...args); } - onHeaders(...args) { + onResponseStart(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onHeaders) == null ? void 0 : _b.call(_a, ...args); + assert(!this.#onResponseStartCalled); + this.#onResponseStartCalled = true; + return (_b = (_a = this.#handler).onResponseStart) == null ? void 0 : _b.call(_a, ...args); } - onData(...args) { + onResponseData(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onData) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onResponseData) == null ? void 0 : _b.call(_a, ...args); } - onComplete(...args) { + onResponseEnd(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); this.#onCompleteCalled = true; - return (_b = (_a = this.#handler).onComplete) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onResponseEnd) == null ? void 0 : _b.call(_a, ...args); } - onBodySent(...args) { + onResponseError(...args) { var _a, _b; - assert(!this.#onCompleteCalled); - assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onBodySent) == null ? void 0 : _b.call(_a, ...args); + this.#onErrorCalled = true; + return (_b = (_a = this.#handler).onResponseError) == null ? void 0 : _b.call(_a, ...args); + } + onBodySent() { } }; } @@ -30332,50 +30319,47 @@ var require_redirect = __commonJS({ var require_response_error = __commonJS({ ""(exports, module) { "use strict"; - var { parseHeaders } = require_util8(); var DecoratorHandler = require_decorator_handler(); var { ResponseError } = require_errors2(); var ResponseErrorHandler = class extends DecoratorHandler { - #handler; #statusCode; #contentType; #decoder; #headers; #body; - constructor(opts, { handler: handler2 }) { + constructor(_opts, { handler: handler2 }) { super(handler2); - this.#handler = handler2; } - onConnect(abort) { + #checkContentType(contentType) { + return this.#contentType.indexOf(contentType) === 0; + } + onRequestStart(controller, context2) { this.#statusCode = 0; this.#contentType = null; this.#decoder = null; this.#headers = null; this.#body = ""; - return this.#handler.onConnect(abort); + return super.onRequestStart(controller, context2); } - #checkContentType(contentType) { - return this.#contentType.indexOf(contentType) === 0; - } - onHeaders(statusCode, rawHeaders, resume, statusMessage, headers = parseHeaders(rawHeaders)) { + onResponseStart(controller, statusCode, headers, statusMessage) { this.#statusCode = statusCode; this.#headers = headers; this.#contentType = headers["content-type"]; if (this.#statusCode < 400) { - return this.#handler.onHeaders(statusCode, rawHeaders, resume, statusMessage, headers); + return super.onResponseStart(controller, statusCode, headers, statusMessage); } if (this.#checkContentType("application/json") || this.#checkContentType("text/plain")) { this.#decoder = new TextDecoder("utf-8"); } } - onData(chunk) { + onResponseData(controller, chunk) { var _a; if (this.#statusCode < 400) { - return this.#handler.onData(chunk); + return super.onResponseData(controller, chunk); } this.#body += ((_a = this.#decoder) == null ? void 0 : _a.decode(chunk, { stream: true })) ?? ""; } - onComplete(rawTrailers) { + onResponseEnd(controller, trailers) { var _a; if (this.#statusCode >= 400) { this.#body += ((_a = this.#decoder) == null ? void 0 : _a.decode(void 0, { stream: false })) ?? ""; @@ -30396,13 +30380,13 @@ var require_response_error = __commonJS({ } finally { Error.stackTraceLimit = stackTraceLimit; } - this.#handler.onError(err); + super.onResponseError(controller, err); } else { - this.#handler.onComplete(rawTrailers); + super.onResponseEnd(controller, trailers); } } - onError(err) { - this.#handler.onError(err); + onResponseError(err) { + super.onResponseError(err); } }; module.exports = () => { @@ -30443,79 +30427,71 @@ var require_retry = __commonJS({ var require_dump = __commonJS({ ""(exports, module) { "use strict"; - var util = require_util8(); var { InvalidArgumentError, RequestAbortedError } = require_errors2(); var DecoratorHandler = require_decorator_handler(); var DumpHandler = class extends DecoratorHandler { #maxSize = 1024 * 1024; - #abort = null; #dumped = false; - #aborted = false; #size = 0; - #reason = null; - #handler = null; - constructor({ maxSize }, handler2) { + #controller = null; + aborted = false; + reason = false; + constructor({ maxSize, signal }, handler2) { if (maxSize != null && (!Number.isFinite(maxSize) || maxSize < 1)) { throw new InvalidArgumentError("maxSize must be a number greater than 0"); } super(handler2); this.#maxSize = maxSize ?? this.#maxSize; - this.#handler = handler2; } - onConnect(abort) { - this.#abort = abort; - this.#handler.onConnect(this.#customAbort.bind(this)); + #abort(reason) { + this.aborted = true; + this.reason = reason; } - #customAbort(reason) { - this.#aborted = true; - this.#reason = reason; + onRequestStart(controller, context2) { + controller.abort = this.#abort.bind(this); + this.#controller = controller; + return super.onRequestStart(controller, context2); } - onHeaders(statusCode, rawHeaders, resume, statusMessage) { - const headers = util.parseHeaders(rawHeaders); + onResponseStart(controller, statusCode, headers, statusMessage) { const contentLength = headers["content-length"]; if (contentLength != null && contentLength > this.#maxSize) { throw new RequestAbortedError( `Response size (${contentLength}) larger than maxSize (${this.#maxSize})` ); } - if (this.#aborted) { + if (this.aborted === true) { return true; } - return this.#handler.onHeaders( - statusCode, - rawHeaders, - resume, - statusMessage - ); + return super.onResponseStart(controller, statusCode, headers, statusMessage); } - onError(err) { + onResponseError(controller, err) { if (this.#dumped) { return; } - err = this.#reason ?? err; - this.#handler.onError(err); + err = this.#controller.reason ?? err; + super.onResponseError(controller, err); } - onData(chunk) { + onResponseData(controller, chunk) { this.#size = this.#size + chunk.length; if (this.#size >= this.#maxSize) { this.#dumped = true; - if (this.#aborted) { - this.#handler.onError(this.#reason); + if (this.aborted === true) { + super.onResponseError(controller, this.reason); } else { - this.#handler.onComplete([]); + super.onResponseEnd(controller, {}); } } return true; } - onComplete(trailers) { + onResponseEnd(controller, trailers) { if (this.#dumped) { return; } - if (this.#aborted) { - this.#handler.onError(this.reason); + if (this.#controller.aborted === true) { + super.onResponseError(controller, this.reason); return; } - this.#handler.onComplete(trailers); + super.onResponseEnd(controller, trailers); } }; function createDumpInterceptor({ maxSize: defaultMaxSize } = { @@ -30524,10 +30500,7 @@ var require_dump = __commonJS({ return (dispatch) => { return function Intercept(opts, handler2) { const { dumpMaxSize = defaultMaxSize } = opts; - const dumpHandler = new DumpHandler( - { maxSize: dumpMaxSize }, - handler2 - ); + const dumpHandler = new DumpHandler({ maxSize: dumpMaxSize, signal: opts.signal }, handler2); return dispatch(opts, dumpHandler); }; }; @@ -30715,24 +30688,24 @@ var require_dns = __commonJS({ #state = null; #opts = null; #dispatch = null; - #handler = null; #origin = null; + #controller = null; constructor(state, { origin, handler: handler2, dispatch }, opts) { super(handler2); this.#origin = origin; - this.#handler = handler2; this.#opts = { ...opts }; this.#state = state; this.#dispatch = dispatch; } - onError(err) { + onResponseError(controller, err) { switch (err.code) { case "ETIMEDOUT": case "ECONNREFUSED": { if (this.#state.dualStack) { this.#state.runLookup(this.#origin, this.#opts, (err2, newOrigin) => { if (err2) { - return this.#handler.onError(err2); + super.onResponseError(controller, err2); + return; } const dispatchOpts = { ...this.#opts, @@ -30742,13 +30715,13 @@ var require_dns = __commonJS({ }); return; } - this.#handler.onError(err); - return; + super.onResponseError(controller, err); + break; } case "ENOTFOUND": this.#state.deleteRecord(this.#origin); default: - this.#handler.onError(err); + super.onResponseError(controller, err); break; } } @@ -38104,9 +38077,6 @@ var require_undici2 = __commonJS({ const SqliteCacheStore = require_sqlite_cache_store(); module.exports.cacheStores.SqliteCacheStore = SqliteCacheStore; } catch (err) { - if (err.code !== "ERR_UNKNOWN_BUILTIN_MODULE") { - throw err; - } } module.exports.buildConnector = buildConnector; module.exports.errors = errors; diff --git a/github-actions/org-file-sync/main.js b/github-actions/org-file-sync/main.js index 4d6184b01..d2db4826f 100644 --- a/github-actions/org-file-sync/main.js +++ b/github-actions/org-file-sync/main.js @@ -26004,7 +26004,6 @@ var require_client_h2 = __commonJS({ } = require_symbols6(); var kOpenStreams = Symbol("open streams"); var extractBody; - var h2ExperimentalWarned = false; var http2; try { http2 = __require("node:http2"); @@ -26037,12 +26036,6 @@ var require_client_h2 = __commonJS({ } async function connectH2(client, socket) { client[kSocket] = socket; - if (!h2ExperimentalWarned) { - h2ExperimentalWarned = true; - process.emitWarning("H2 support is experimental, expect them to change at any time.", { - code: "UNDICI-H2" - }); - } const session = http2.connect(client[kUrl], { createConnection: () => socket, peerMaxConcurrentStreams: client[kMaxConcurrentStreams], @@ -30088,61 +30081,55 @@ var require_decorator_handler = __commonJS({ ""(exports, module) { "use strict"; var assert = __require("node:assert"); + var WrapHandler = require_wrap_handler(); module.exports = class DecoratorHandler { #handler; #onCompleteCalled = false; #onErrorCalled = false; + #onResponseStartCalled = false; constructor(handler2) { if (typeof handler2 !== "object" || handler2 === null) { throw new TypeError("handler must be an object"); } - this.#handler = handler2; - } - onConnect(...args) { - var _a, _b; - return (_b = (_a = this.#handler).onConnect) == null ? void 0 : _b.call(_a, ...args); - } - onError(...args) { - var _a, _b; - this.#onErrorCalled = true; - return (_b = (_a = this.#handler).onError) == null ? void 0 : _b.call(_a, ...args); + this.#handler = WrapHandler.wrap(handler2); } - onUpgrade(...args) { + onRequestStart(...args) { var _a, _b; - assert(!this.#onCompleteCalled); - assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onUpgrade) == null ? void 0 : _b.call(_a, ...args); + (_b = (_a = this.#handler).onRequestStart) == null ? void 0 : _b.call(_a, ...args); } - onResponseStarted(...args) { + onRequestUpgrade(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onResponseStarted) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onRequestUpgrade) == null ? void 0 : _b.call(_a, ...args); } - onHeaders(...args) { + onResponseStart(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onHeaders) == null ? void 0 : _b.call(_a, ...args); + assert(!this.#onResponseStartCalled); + this.#onResponseStartCalled = true; + return (_b = (_a = this.#handler).onResponseStart) == null ? void 0 : _b.call(_a, ...args); } - onData(...args) { + onResponseData(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onData) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onResponseData) == null ? void 0 : _b.call(_a, ...args); } - onComplete(...args) { + onResponseEnd(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); this.#onCompleteCalled = true; - return (_b = (_a = this.#handler).onComplete) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onResponseEnd) == null ? void 0 : _b.call(_a, ...args); } - onBodySent(...args) { + onResponseError(...args) { var _a, _b; - assert(!this.#onCompleteCalled); - assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onBodySent) == null ? void 0 : _b.call(_a, ...args); + this.#onErrorCalled = true; + return (_b = (_a = this.#handler).onResponseError) == null ? void 0 : _b.call(_a, ...args); + } + onBodySent() { } }; } @@ -30333,50 +30320,47 @@ var require_redirect = __commonJS({ var require_response_error = __commonJS({ ""(exports, module) { "use strict"; - var { parseHeaders } = require_util8(); var DecoratorHandler = require_decorator_handler(); var { ResponseError } = require_errors2(); var ResponseErrorHandler = class extends DecoratorHandler { - #handler; #statusCode; #contentType; #decoder; #headers; #body; - constructor(opts, { handler: handler2 }) { + constructor(_opts, { handler: handler2 }) { super(handler2); - this.#handler = handler2; } - onConnect(abort) { + #checkContentType(contentType) { + return this.#contentType.indexOf(contentType) === 0; + } + onRequestStart(controller, context3) { this.#statusCode = 0; this.#contentType = null; this.#decoder = null; this.#headers = null; this.#body = ""; - return this.#handler.onConnect(abort); + return super.onRequestStart(controller, context3); } - #checkContentType(contentType) { - return this.#contentType.indexOf(contentType) === 0; - } - onHeaders(statusCode, rawHeaders, resume, statusMessage, headers = parseHeaders(rawHeaders)) { + onResponseStart(controller, statusCode, headers, statusMessage) { this.#statusCode = statusCode; this.#headers = headers; this.#contentType = headers["content-type"]; if (this.#statusCode < 400) { - return this.#handler.onHeaders(statusCode, rawHeaders, resume, statusMessage, headers); + return super.onResponseStart(controller, statusCode, headers, statusMessage); } if (this.#checkContentType("application/json") || this.#checkContentType("text/plain")) { this.#decoder = new TextDecoder("utf-8"); } } - onData(chunk) { + onResponseData(controller, chunk) { var _a; if (this.#statusCode < 400) { - return this.#handler.onData(chunk); + return super.onResponseData(controller, chunk); } this.#body += ((_a = this.#decoder) == null ? void 0 : _a.decode(chunk, { stream: true })) ?? ""; } - onComplete(rawTrailers) { + onResponseEnd(controller, trailers) { var _a; if (this.#statusCode >= 400) { this.#body += ((_a = this.#decoder) == null ? void 0 : _a.decode(void 0, { stream: false })) ?? ""; @@ -30397,13 +30381,13 @@ var require_response_error = __commonJS({ } finally { Error.stackTraceLimit = stackTraceLimit; } - this.#handler.onError(err); + super.onResponseError(controller, err); } else { - this.#handler.onComplete(rawTrailers); + super.onResponseEnd(controller, trailers); } } - onError(err) { - this.#handler.onError(err); + onResponseError(err) { + super.onResponseError(err); } }; module.exports = () => { @@ -30444,79 +30428,71 @@ var require_retry = __commonJS({ var require_dump = __commonJS({ ""(exports, module) { "use strict"; - var util = require_util8(); var { InvalidArgumentError, RequestAbortedError } = require_errors2(); var DecoratorHandler = require_decorator_handler(); var DumpHandler = class extends DecoratorHandler { #maxSize = 1024 * 1024; - #abort = null; #dumped = false; - #aborted = false; #size = 0; - #reason = null; - #handler = null; - constructor({ maxSize }, handler2) { + #controller = null; + aborted = false; + reason = false; + constructor({ maxSize, signal }, handler2) { if (maxSize != null && (!Number.isFinite(maxSize) || maxSize < 1)) { throw new InvalidArgumentError("maxSize must be a number greater than 0"); } super(handler2); this.#maxSize = maxSize ?? this.#maxSize; - this.#handler = handler2; } - onConnect(abort) { - this.#abort = abort; - this.#handler.onConnect(this.#customAbort.bind(this)); + #abort(reason) { + this.aborted = true; + this.reason = reason; } - #customAbort(reason) { - this.#aborted = true; - this.#reason = reason; + onRequestStart(controller, context3) { + controller.abort = this.#abort.bind(this); + this.#controller = controller; + return super.onRequestStart(controller, context3); } - onHeaders(statusCode, rawHeaders, resume, statusMessage) { - const headers = util.parseHeaders(rawHeaders); + onResponseStart(controller, statusCode, headers, statusMessage) { const contentLength = headers["content-length"]; if (contentLength != null && contentLength > this.#maxSize) { throw new RequestAbortedError( `Response size (${contentLength}) larger than maxSize (${this.#maxSize})` ); } - if (this.#aborted) { + if (this.aborted === true) { return true; } - return this.#handler.onHeaders( - statusCode, - rawHeaders, - resume, - statusMessage - ); + return super.onResponseStart(controller, statusCode, headers, statusMessage); } - onError(err) { + onResponseError(controller, err) { if (this.#dumped) { return; } - err = this.#reason ?? err; - this.#handler.onError(err); + err = this.#controller.reason ?? err; + super.onResponseError(controller, err); } - onData(chunk) { + onResponseData(controller, chunk) { this.#size = this.#size + chunk.length; if (this.#size >= this.#maxSize) { this.#dumped = true; - if (this.#aborted) { - this.#handler.onError(this.#reason); + if (this.aborted === true) { + super.onResponseError(controller, this.reason); } else { - this.#handler.onComplete([]); + super.onResponseEnd(controller, {}); } } return true; } - onComplete(trailers) { + onResponseEnd(controller, trailers) { if (this.#dumped) { return; } - if (this.#aborted) { - this.#handler.onError(this.reason); + if (this.#controller.aborted === true) { + super.onResponseError(controller, this.reason); return; } - this.#handler.onComplete(trailers); + super.onResponseEnd(controller, trailers); } }; function createDumpInterceptor({ maxSize: defaultMaxSize } = { @@ -30525,10 +30501,7 @@ var require_dump = __commonJS({ return (dispatch) => { return function Intercept(opts, handler2) { const { dumpMaxSize = defaultMaxSize } = opts; - const dumpHandler = new DumpHandler( - { maxSize: dumpMaxSize }, - handler2 - ); + const dumpHandler = new DumpHandler({ maxSize: dumpMaxSize, signal: opts.signal }, handler2); return dispatch(opts, dumpHandler); }; }; @@ -30716,24 +30689,24 @@ var require_dns = __commonJS({ #state = null; #opts = null; #dispatch = null; - #handler = null; #origin = null; + #controller = null; constructor(state, { origin, handler: handler2, dispatch }, opts) { super(handler2); this.#origin = origin; - this.#handler = handler2; this.#opts = { ...opts }; this.#state = state; this.#dispatch = dispatch; } - onError(err) { + onResponseError(controller, err) { switch (err.code) { case "ETIMEDOUT": case "ECONNREFUSED": { if (this.#state.dualStack) { this.#state.runLookup(this.#origin, this.#opts, (err2, newOrigin) => { if (err2) { - return this.#handler.onError(err2); + super.onResponseError(controller, err2); + return; } const dispatchOpts = { ...this.#opts, @@ -30743,13 +30716,13 @@ var require_dns = __commonJS({ }); return; } - this.#handler.onError(err); - return; + super.onResponseError(controller, err); + break; } case "ENOTFOUND": this.#state.deleteRecord(this.#origin); default: - this.#handler.onError(err); + super.onResponseError(controller, err); break; } } @@ -38105,9 +38078,6 @@ var require_undici2 = __commonJS({ const SqliteCacheStore = require_sqlite_cache_store(); module.exports.cacheStores.SqliteCacheStore = SqliteCacheStore; } catch (err) { - if (err.code !== "ERR_UNKNOWN_BUILTIN_MODULE") { - throw err; - } } module.exports.buildConnector = buildConnector; module.exports.errors = errors; diff --git a/github-actions/post-approval-changes/main.js b/github-actions/post-approval-changes/main.js index 9dc657c77..b3b80ae47 100644 --- a/github-actions/post-approval-changes/main.js +++ b/github-actions/post-approval-changes/main.js @@ -26004,7 +26004,6 @@ var require_client_h2 = __commonJS({ } = require_symbols6(); var kOpenStreams = Symbol("open streams"); var extractBody; - var h2ExperimentalWarned = false; var http2; try { http2 = __require("node:http2"); @@ -26037,12 +26036,6 @@ var require_client_h2 = __commonJS({ } async function connectH2(client, socket) { client[kSocket] = socket; - if (!h2ExperimentalWarned) { - h2ExperimentalWarned = true; - process.emitWarning("H2 support is experimental, expect them to change at any time.", { - code: "UNDICI-H2" - }); - } const session = http2.connect(client[kUrl], { createConnection: () => socket, peerMaxConcurrentStreams: client[kMaxConcurrentStreams], @@ -30088,61 +30081,55 @@ var require_decorator_handler = __commonJS({ ""(exports, module) { "use strict"; var assert = __require("node:assert"); + var WrapHandler = require_wrap_handler(); module.exports = class DecoratorHandler { #handler; #onCompleteCalled = false; #onErrorCalled = false; + #onResponseStartCalled = false; constructor(handler2) { if (typeof handler2 !== "object" || handler2 === null) { throw new TypeError("handler must be an object"); } - this.#handler = handler2; - } - onConnect(...args) { - var _a, _b; - return (_b = (_a = this.#handler).onConnect) == null ? void 0 : _b.call(_a, ...args); - } - onError(...args) { - var _a, _b; - this.#onErrorCalled = true; - return (_b = (_a = this.#handler).onError) == null ? void 0 : _b.call(_a, ...args); + this.#handler = WrapHandler.wrap(handler2); } - onUpgrade(...args) { + onRequestStart(...args) { var _a, _b; - assert(!this.#onCompleteCalled); - assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onUpgrade) == null ? void 0 : _b.call(_a, ...args); + (_b = (_a = this.#handler).onRequestStart) == null ? void 0 : _b.call(_a, ...args); } - onResponseStarted(...args) { + onRequestUpgrade(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onResponseStarted) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onRequestUpgrade) == null ? void 0 : _b.call(_a, ...args); } - onHeaders(...args) { + onResponseStart(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onHeaders) == null ? void 0 : _b.call(_a, ...args); + assert(!this.#onResponseStartCalled); + this.#onResponseStartCalled = true; + return (_b = (_a = this.#handler).onResponseStart) == null ? void 0 : _b.call(_a, ...args); } - onData(...args) { + onResponseData(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onData) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onResponseData) == null ? void 0 : _b.call(_a, ...args); } - onComplete(...args) { + onResponseEnd(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); this.#onCompleteCalled = true; - return (_b = (_a = this.#handler).onComplete) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onResponseEnd) == null ? void 0 : _b.call(_a, ...args); } - onBodySent(...args) { + onResponseError(...args) { var _a, _b; - assert(!this.#onCompleteCalled); - assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onBodySent) == null ? void 0 : _b.call(_a, ...args); + this.#onErrorCalled = true; + return (_b = (_a = this.#handler).onResponseError) == null ? void 0 : _b.call(_a, ...args); + } + onBodySent() { } }; } @@ -30333,50 +30320,47 @@ var require_redirect = __commonJS({ var require_response_error = __commonJS({ ""(exports, module) { "use strict"; - var { parseHeaders } = require_util8(); var DecoratorHandler = require_decorator_handler(); var { ResponseError } = require_errors2(); var ResponseErrorHandler = class extends DecoratorHandler { - #handler; #statusCode; #contentType; #decoder; #headers; #body; - constructor(opts, { handler: handler2 }) { + constructor(_opts, { handler: handler2 }) { super(handler2); - this.#handler = handler2; } - onConnect(abort) { + #checkContentType(contentType) { + return this.#contentType.indexOf(contentType) === 0; + } + onRequestStart(controller, context3) { this.#statusCode = 0; this.#contentType = null; this.#decoder = null; this.#headers = null; this.#body = ""; - return this.#handler.onConnect(abort); + return super.onRequestStart(controller, context3); } - #checkContentType(contentType) { - return this.#contentType.indexOf(contentType) === 0; - } - onHeaders(statusCode, rawHeaders, resume, statusMessage, headers = parseHeaders(rawHeaders)) { + onResponseStart(controller, statusCode, headers, statusMessage) { this.#statusCode = statusCode; this.#headers = headers; this.#contentType = headers["content-type"]; if (this.#statusCode < 400) { - return this.#handler.onHeaders(statusCode, rawHeaders, resume, statusMessage, headers); + return super.onResponseStart(controller, statusCode, headers, statusMessage); } if (this.#checkContentType("application/json") || this.#checkContentType("text/plain")) { this.#decoder = new TextDecoder("utf-8"); } } - onData(chunk) { + onResponseData(controller, chunk) { var _a; if (this.#statusCode < 400) { - return this.#handler.onData(chunk); + return super.onResponseData(controller, chunk); } this.#body += ((_a = this.#decoder) == null ? void 0 : _a.decode(chunk, { stream: true })) ?? ""; } - onComplete(rawTrailers) { + onResponseEnd(controller, trailers) { var _a; if (this.#statusCode >= 400) { this.#body += ((_a = this.#decoder) == null ? void 0 : _a.decode(void 0, { stream: false })) ?? ""; @@ -30397,13 +30381,13 @@ var require_response_error = __commonJS({ } finally { Error.stackTraceLimit = stackTraceLimit; } - this.#handler.onError(err); + super.onResponseError(controller, err); } else { - this.#handler.onComplete(rawTrailers); + super.onResponseEnd(controller, trailers); } } - onError(err) { - this.#handler.onError(err); + onResponseError(err) { + super.onResponseError(err); } }; module.exports = () => { @@ -30444,79 +30428,71 @@ var require_retry = __commonJS({ var require_dump = __commonJS({ ""(exports, module) { "use strict"; - var util = require_util8(); var { InvalidArgumentError, RequestAbortedError } = require_errors2(); var DecoratorHandler = require_decorator_handler(); var DumpHandler = class extends DecoratorHandler { #maxSize = 1024 * 1024; - #abort = null; #dumped = false; - #aborted = false; #size = 0; - #reason = null; - #handler = null; - constructor({ maxSize }, handler2) { + #controller = null; + aborted = false; + reason = false; + constructor({ maxSize, signal }, handler2) { if (maxSize != null && (!Number.isFinite(maxSize) || maxSize < 1)) { throw new InvalidArgumentError("maxSize must be a number greater than 0"); } super(handler2); this.#maxSize = maxSize ?? this.#maxSize; - this.#handler = handler2; } - onConnect(abort) { - this.#abort = abort; - this.#handler.onConnect(this.#customAbort.bind(this)); + #abort(reason) { + this.aborted = true; + this.reason = reason; } - #customAbort(reason) { - this.#aborted = true; - this.#reason = reason; + onRequestStart(controller, context3) { + controller.abort = this.#abort.bind(this); + this.#controller = controller; + return super.onRequestStart(controller, context3); } - onHeaders(statusCode, rawHeaders, resume, statusMessage) { - const headers = util.parseHeaders(rawHeaders); + onResponseStart(controller, statusCode, headers, statusMessage) { const contentLength = headers["content-length"]; if (contentLength != null && contentLength > this.#maxSize) { throw new RequestAbortedError( `Response size (${contentLength}) larger than maxSize (${this.#maxSize})` ); } - if (this.#aborted) { + if (this.aborted === true) { return true; } - return this.#handler.onHeaders( - statusCode, - rawHeaders, - resume, - statusMessage - ); + return super.onResponseStart(controller, statusCode, headers, statusMessage); } - onError(err) { + onResponseError(controller, err) { if (this.#dumped) { return; } - err = this.#reason ?? err; - this.#handler.onError(err); + err = this.#controller.reason ?? err; + super.onResponseError(controller, err); } - onData(chunk) { + onResponseData(controller, chunk) { this.#size = this.#size + chunk.length; if (this.#size >= this.#maxSize) { this.#dumped = true; - if (this.#aborted) { - this.#handler.onError(this.#reason); + if (this.aborted === true) { + super.onResponseError(controller, this.reason); } else { - this.#handler.onComplete([]); + super.onResponseEnd(controller, {}); } } return true; } - onComplete(trailers) { + onResponseEnd(controller, trailers) { if (this.#dumped) { return; } - if (this.#aborted) { - this.#handler.onError(this.reason); + if (this.#controller.aborted === true) { + super.onResponseError(controller, this.reason); return; } - this.#handler.onComplete(trailers); + super.onResponseEnd(controller, trailers); } }; function createDumpInterceptor({ maxSize: defaultMaxSize } = { @@ -30525,10 +30501,7 @@ var require_dump = __commonJS({ return (dispatch) => { return function Intercept(opts, handler2) { const { dumpMaxSize = defaultMaxSize } = opts; - const dumpHandler = new DumpHandler( - { maxSize: dumpMaxSize }, - handler2 - ); + const dumpHandler = new DumpHandler({ maxSize: dumpMaxSize, signal: opts.signal }, handler2); return dispatch(opts, dumpHandler); }; }; @@ -30716,24 +30689,24 @@ var require_dns = __commonJS({ #state = null; #opts = null; #dispatch = null; - #handler = null; #origin = null; + #controller = null; constructor(state, { origin, handler: handler2, dispatch }, opts) { super(handler2); this.#origin = origin; - this.#handler = handler2; this.#opts = { ...opts }; this.#state = state; this.#dispatch = dispatch; } - onError(err) { + onResponseError(controller, err) { switch (err.code) { case "ETIMEDOUT": case "ECONNREFUSED": { if (this.#state.dualStack) { this.#state.runLookup(this.#origin, this.#opts, (err2, newOrigin) => { if (err2) { - return this.#handler.onError(err2); + super.onResponseError(controller, err2); + return; } const dispatchOpts = { ...this.#opts, @@ -30743,13 +30716,13 @@ var require_dns = __commonJS({ }); return; } - this.#handler.onError(err); - return; + super.onResponseError(controller, err); + break; } case "ENOTFOUND": this.#state.deleteRecord(this.#origin); default: - this.#handler.onError(err); + super.onResponseError(controller, err); break; } } @@ -38105,9 +38078,6 @@ var require_undici2 = __commonJS({ const SqliteCacheStore = require_sqlite_cache_store(); module.exports.cacheStores.SqliteCacheStore = SqliteCacheStore; } catch (err) { - if (err.code !== "ERR_UNKNOWN_BUILTIN_MODULE") { - throw err; - } } module.exports.buildConnector = buildConnector; module.exports.errors = errors; diff --git a/github-actions/unified-status-check/main.js b/github-actions/unified-status-check/main.js index dba8a7e4c..c3c391cfb 100644 --- a/github-actions/unified-status-check/main.js +++ b/github-actions/unified-status-check/main.js @@ -26004,7 +26004,6 @@ var require_client_h2 = __commonJS({ } = require_symbols6(); var kOpenStreams = Symbol("open streams"); var extractBody; - var h2ExperimentalWarned = false; var http2; try { http2 = __require("node:http2"); @@ -26037,12 +26036,6 @@ var require_client_h2 = __commonJS({ } async function connectH2(client, socket) { client[kSocket] = socket; - if (!h2ExperimentalWarned) { - h2ExperimentalWarned = true; - process.emitWarning("H2 support is experimental, expect them to change at any time.", { - code: "UNDICI-H2" - }); - } const session = http2.connect(client[kUrl], { createConnection: () => socket, peerMaxConcurrentStreams: client[kMaxConcurrentStreams], @@ -30088,61 +30081,55 @@ var require_decorator_handler = __commonJS({ ""(exports, module) { "use strict"; var assert = __require("node:assert"); + var WrapHandler = require_wrap_handler(); module.exports = class DecoratorHandler { #handler; #onCompleteCalled = false; #onErrorCalled = false; + #onResponseStartCalled = false; constructor(handler2) { if (typeof handler2 !== "object" || handler2 === null) { throw new TypeError("handler must be an object"); } - this.#handler = handler2; - } - onConnect(...args) { - var _a, _b; - return (_b = (_a = this.#handler).onConnect) == null ? void 0 : _b.call(_a, ...args); - } - onError(...args) { - var _a, _b; - this.#onErrorCalled = true; - return (_b = (_a = this.#handler).onError) == null ? void 0 : _b.call(_a, ...args); + this.#handler = WrapHandler.wrap(handler2); } - onUpgrade(...args) { + onRequestStart(...args) { var _a, _b; - assert(!this.#onCompleteCalled); - assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onUpgrade) == null ? void 0 : _b.call(_a, ...args); + (_b = (_a = this.#handler).onRequestStart) == null ? void 0 : _b.call(_a, ...args); } - onResponseStarted(...args) { + onRequestUpgrade(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onResponseStarted) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onRequestUpgrade) == null ? void 0 : _b.call(_a, ...args); } - onHeaders(...args) { + onResponseStart(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onHeaders) == null ? void 0 : _b.call(_a, ...args); + assert(!this.#onResponseStartCalled); + this.#onResponseStartCalled = true; + return (_b = (_a = this.#handler).onResponseStart) == null ? void 0 : _b.call(_a, ...args); } - onData(...args) { + onResponseData(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onData) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onResponseData) == null ? void 0 : _b.call(_a, ...args); } - onComplete(...args) { + onResponseEnd(...args) { var _a, _b; assert(!this.#onCompleteCalled); assert(!this.#onErrorCalled); this.#onCompleteCalled = true; - return (_b = (_a = this.#handler).onComplete) == null ? void 0 : _b.call(_a, ...args); + return (_b = (_a = this.#handler).onResponseEnd) == null ? void 0 : _b.call(_a, ...args); } - onBodySent(...args) { + onResponseError(...args) { var _a, _b; - assert(!this.#onCompleteCalled); - assert(!this.#onErrorCalled); - return (_b = (_a = this.#handler).onBodySent) == null ? void 0 : _b.call(_a, ...args); + this.#onErrorCalled = true; + return (_b = (_a = this.#handler).onResponseError) == null ? void 0 : _b.call(_a, ...args); + } + onBodySent() { } }; } @@ -30333,50 +30320,47 @@ var require_redirect = __commonJS({ var require_response_error = __commonJS({ ""(exports, module) { "use strict"; - var { parseHeaders } = require_util8(); var DecoratorHandler = require_decorator_handler(); var { ResponseError } = require_errors2(); var ResponseErrorHandler = class extends DecoratorHandler { - #handler; #statusCode; #contentType; #decoder; #headers; #body; - constructor(opts, { handler: handler2 }) { + constructor(_opts, { handler: handler2 }) { super(handler2); - this.#handler = handler2; } - onConnect(abort) { + #checkContentType(contentType) { + return this.#contentType.indexOf(contentType) === 0; + } + onRequestStart(controller, context3) { this.#statusCode = 0; this.#contentType = null; this.#decoder = null; this.#headers = null; this.#body = ""; - return this.#handler.onConnect(abort); + return super.onRequestStart(controller, context3); } - #checkContentType(contentType) { - return this.#contentType.indexOf(contentType) === 0; - } - onHeaders(statusCode, rawHeaders, resume, statusMessage, headers = parseHeaders(rawHeaders)) { + onResponseStart(controller, statusCode, headers, statusMessage) { this.#statusCode = statusCode; this.#headers = headers; this.#contentType = headers["content-type"]; if (this.#statusCode < 400) { - return this.#handler.onHeaders(statusCode, rawHeaders, resume, statusMessage, headers); + return super.onResponseStart(controller, statusCode, headers, statusMessage); } if (this.#checkContentType("application/json") || this.#checkContentType("text/plain")) { this.#decoder = new TextDecoder("utf-8"); } } - onData(chunk) { + onResponseData(controller, chunk) { var _a; if (this.#statusCode < 400) { - return this.#handler.onData(chunk); + return super.onResponseData(controller, chunk); } this.#body += ((_a = this.#decoder) == null ? void 0 : _a.decode(chunk, { stream: true })) ?? ""; } - onComplete(rawTrailers) { + onResponseEnd(controller, trailers) { var _a; if (this.#statusCode >= 400) { this.#body += ((_a = this.#decoder) == null ? void 0 : _a.decode(void 0, { stream: false })) ?? ""; @@ -30397,13 +30381,13 @@ var require_response_error = __commonJS({ } finally { Error.stackTraceLimit = stackTraceLimit; } - this.#handler.onError(err); + super.onResponseError(controller, err); } else { - this.#handler.onComplete(rawTrailers); + super.onResponseEnd(controller, trailers); } } - onError(err) { - this.#handler.onError(err); + onResponseError(err) { + super.onResponseError(err); } }; module.exports = () => { @@ -30444,79 +30428,71 @@ var require_retry = __commonJS({ var require_dump = __commonJS({ ""(exports, module) { "use strict"; - var util = require_util8(); var { InvalidArgumentError, RequestAbortedError } = require_errors2(); var DecoratorHandler = require_decorator_handler(); var DumpHandler = class extends DecoratorHandler { #maxSize = 1024 * 1024; - #abort = null; #dumped = false; - #aborted = false; #size = 0; - #reason = null; - #handler = null; - constructor({ maxSize }, handler2) { + #controller = null; + aborted = false; + reason = false; + constructor({ maxSize, signal }, handler2) { if (maxSize != null && (!Number.isFinite(maxSize) || maxSize < 1)) { throw new InvalidArgumentError("maxSize must be a number greater than 0"); } super(handler2); this.#maxSize = maxSize ?? this.#maxSize; - this.#handler = handler2; } - onConnect(abort) { - this.#abort = abort; - this.#handler.onConnect(this.#customAbort.bind(this)); + #abort(reason) { + this.aborted = true; + this.reason = reason; } - #customAbort(reason) { - this.#aborted = true; - this.#reason = reason; + onRequestStart(controller, context3) { + controller.abort = this.#abort.bind(this); + this.#controller = controller; + return super.onRequestStart(controller, context3); } - onHeaders(statusCode, rawHeaders, resume, statusMessage) { - const headers = util.parseHeaders(rawHeaders); + onResponseStart(controller, statusCode, headers, statusMessage) { const contentLength = headers["content-length"]; if (contentLength != null && contentLength > this.#maxSize) { throw new RequestAbortedError( `Response size (${contentLength}) larger than maxSize (${this.#maxSize})` ); } - if (this.#aborted) { + if (this.aborted === true) { return true; } - return this.#handler.onHeaders( - statusCode, - rawHeaders, - resume, - statusMessage - ); + return super.onResponseStart(controller, statusCode, headers, statusMessage); } - onError(err) { + onResponseError(controller, err) { if (this.#dumped) { return; } - err = this.#reason ?? err; - this.#handler.onError(err); + err = this.#controller.reason ?? err; + super.onResponseError(controller, err); } - onData(chunk) { + onResponseData(controller, chunk) { this.#size = this.#size + chunk.length; if (this.#size >= this.#maxSize) { this.#dumped = true; - if (this.#aborted) { - this.#handler.onError(this.#reason); + if (this.aborted === true) { + super.onResponseError(controller, this.reason); } else { - this.#handler.onComplete([]); + super.onResponseEnd(controller, {}); } } return true; } - onComplete(trailers) { + onResponseEnd(controller, trailers) { if (this.#dumped) { return; } - if (this.#aborted) { - this.#handler.onError(this.reason); + if (this.#controller.aborted === true) { + super.onResponseError(controller, this.reason); return; } - this.#handler.onComplete(trailers); + super.onResponseEnd(controller, trailers); } }; function createDumpInterceptor({ maxSize: defaultMaxSize } = { @@ -30525,10 +30501,7 @@ var require_dump = __commonJS({ return (dispatch) => { return function Intercept(opts, handler2) { const { dumpMaxSize = defaultMaxSize } = opts; - const dumpHandler = new DumpHandler( - { maxSize: dumpMaxSize }, - handler2 - ); + const dumpHandler = new DumpHandler({ maxSize: dumpMaxSize, signal: opts.signal }, handler2); return dispatch(opts, dumpHandler); }; }; @@ -30716,24 +30689,24 @@ var require_dns = __commonJS({ #state = null; #opts = null; #dispatch = null; - #handler = null; #origin = null; + #controller = null; constructor(state, { origin, handler: handler2, dispatch }, opts) { super(handler2); this.#origin = origin; - this.#handler = handler2; this.#opts = { ...opts }; this.#state = state; this.#dispatch = dispatch; } - onError(err) { + onResponseError(controller, err) { switch (err.code) { case "ETIMEDOUT": case "ECONNREFUSED": { if (this.#state.dualStack) { this.#state.runLookup(this.#origin, this.#opts, (err2, newOrigin) => { if (err2) { - return this.#handler.onError(err2); + super.onResponseError(controller, err2); + return; } const dispatchOpts = { ...this.#opts, @@ -30743,13 +30716,13 @@ var require_dns = __commonJS({ }); return; } - this.#handler.onError(err); - return; + super.onResponseError(controller, err); + break; } case "ENOTFOUND": this.#state.deleteRecord(this.#origin); default: - this.#handler.onError(err); + super.onResponseError(controller, err); break; } } @@ -38105,9 +38078,6 @@ var require_undici2 = __commonJS({ const SqliteCacheStore = require_sqlite_cache_store(); module.exports.cacheStores.SqliteCacheStore = SqliteCacheStore; } catch (err) { - if (err.code !== "ERR_UNKNOWN_BUILTIN_MODULE") { - throw err; - } } module.exports.buildConnector = buildConnector; module.exports.errors = errors; diff --git a/package.json b/package.json index 065b9473b..f172f12ae 100644 --- a/package.json +++ b/package.json @@ -38,7 +38,7 @@ "@types/ws": "8.5.13", "@types/yargs": "^17.0.0", "browser-sync": "^3.0.0", - "prettier": "3.4.1", + "prettier": "3.4.2", "protractor": "^7.0.0", "selenium-webdriver": "^4.18.1", "send": "^1.0.0", @@ -125,8 +125,8 @@ "gcip-cloud-functions": "0.2.0", "git-raw-commits": "^4.0.0", "husky": "^9.0.0", - "jasmine": "~5.4.0", - "jasmine-core": "~5.4.0", + "jasmine": "~5.5.0", + "jasmine-core": "~5.5.0", "jsdom": "^25.0.0", "jsonc-parser": "^3.2.0", "karma": "^6.3.15", diff --git a/yarn.lock b/yarn.lock index 0ac852faa..f5b1e4ddb 100644 --- a/yarn.lock +++ b/yarn.lock @@ -342,8 +342,8 @@ __metadata: gcip-cloud-functions: "npm:0.2.0" git-raw-commits: "npm:^4.0.0" husky: "npm:^9.0.0" - jasmine: "npm:~5.4.0" - jasmine-core: "npm:~5.4.0" + jasmine: "npm:~5.5.0" + jasmine-core: "npm:~5.5.0" jsdom: "npm:^25.0.0" jsonc-parser: "npm:^3.2.0" karma: "npm:^6.3.15" @@ -359,7 +359,7 @@ __metadata: multimatch: "npm:^7.0.0" nock: "npm:beta" opener: "npm:^1.5.2" - prettier: "npm:3.4.1" + prettier: "npm:3.4.2" protobufjs: "npm:^7.0.0" protractor: "npm:^7.0.0" requirejs: "npm:^2.3.6" @@ -9946,10 +9946,10 @@ __metadata: languageName: node linkType: hard -"jasmine-core@npm:~5.4.0": - version: 5.4.0 - resolution: "jasmine-core@npm:5.4.0" - checksum: 10c0/d936de0df50a69bb269c734d5efc73d124c3051037d55609c30fcc146736ae281b1c2d658e7da583eee96a4eb2c240a3b672b70375e51d6c28c5626639eda292 +"jasmine-core@npm:~5.5.0": + version: 5.5.0 + resolution: "jasmine-core@npm:5.5.0" + checksum: 10c0/9914f45ce6bcc016d61ee591a8a71dd0d88902ddf5fa887b11966040ce0916379bc4d5f446c07c58226b16f8a0f9719fa201cd92a3f07b02e8c8aa4169448600 languageName: node linkType: hard @@ -9976,15 +9976,15 @@ __metadata: languageName: node linkType: hard -"jasmine@npm:~5.4.0": - version: 5.4.0 - resolution: "jasmine@npm:5.4.0" +"jasmine@npm:~5.5.0": + version: 5.5.0 + resolution: "jasmine@npm:5.5.0" dependencies: glob: "npm:^10.2.2" - jasmine-core: "npm:~5.4.0" + jasmine-core: "npm:~5.5.0" bin: jasmine: bin/jasmine.js - checksum: 10c0/8169c6ee448e39769946e43cf04647826c17be0a999465441bed525063e0208ac51615d2ce4e185c35aece0224b51dd7cfa4530f13a83a7deeb1aa019d655b75 + checksum: 10c0/3b86e6f19987c9d49092dac783ac84a0429ba3786580573d57ffdca6bc21468476613ca94748cfc282f0adbcc2810c20420bee78ef8f37a897f34dd4cd83107e languageName: node linkType: hard @@ -12544,12 +12544,12 @@ __metadata: languageName: node linkType: hard -"prettier@npm:3.4.1": - version: 3.4.1 - resolution: "prettier@npm:3.4.1" +"prettier@npm:3.4.2": + version: 3.4.2 + resolution: "prettier@npm:3.4.2" bin: prettier: bin/prettier.cjs - checksum: 10c0/2d6cc3101ad9de72b49c59339480b0983e6ff6742143da0c43f476bf3b5ef88ede42ebd9956d7a0a8fa59f7a5990e8ef03c9ad4c37f7e4c9e5db43ee0853156c + checksum: 10c0/99e076a26ed0aba4ebc043880d0f08bbb8c59a4c6641cdee6cdadf2205bdd87aa1d7823f50c3aea41e015e99878d37c58d7b5f0e663bba0ef047f94e36b96446 languageName: node linkType: hard @@ -15196,9 +15196,9 @@ __metadata: linkType: hard "undici@npm:^7.0.0": - version: 7.0.0 - resolution: "undici@npm:7.0.0" - checksum: 10c0/6d91d5ea5f858ac9ea8b8e28722167dcb4606dc8f3886b6768de94de96fb0817a7fec974ecbc51c1fec03131e2cc44df49a2ab966f5d2d191f32163776f36d91 + version: 7.1.0 + resolution: "undici@npm:7.1.0" + checksum: 10c0/6fd0a63ca5e585128d67324e29cc49c903bf1752fd3b6f318627bb3765326df6f80c02f9c6fb2636ce3934706920c0b7fe4fe8ae19afe0a698f9ffbd7ef57548 languageName: node linkType: hard