Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
45 changes: 28 additions & 17 deletions .github/local-actions/branch-manager/main.js
Original file line number Diff line number Diff line change
Expand Up @@ -36579,15 +36579,15 @@ var require_wrap_handler = __commonJS({
var _a, _b;
const rawHeaders = [];
for (const [key, val] of Object.entries(headers)) {
rawHeaders.push(Buffer.from(key), Buffer.from(val));
rawHeaders.push(Buffer.from(key), Array.isArray(val) ? val.map((v) => Buffer.from(v)) : Buffer.from(val));
}
(_b = (_a = this.#handler).onUpgrade) == null ? void 0 : _b.call(_a, statusCode, rawHeaders, socket);
}
onResponseStart(controller, statusCode, headers, statusMessage) {
var _a, _b;
const rawHeaders = [];
for (const [key, val] of Object.entries(headers)) {
rawHeaders.push(Buffer.from(key), Buffer.from(val));
rawHeaders.push(Buffer.from(key), Array.isArray(val) ? val.map((v) => Buffer.from(v)) : Buffer.from(val));
}
if (((_b = (_a = this.#handler).onHeaders) == null ? void 0 : _b.call(_a, statusCode, rawHeaders, () => controller.resume(), statusMessage)) === false) {
controller.pause();
Expand All @@ -36603,7 +36603,7 @@ var require_wrap_handler = __commonJS({
var _a, _b;
const rawTrailers = [];
for (const [key, val] of Object.entries(trailers)) {
rawTrailers.push(Buffer.from(key), Buffer.from(val));
rawTrailers.push(Buffer.from(key), Array.isArray(val) ? val.map((v) => Buffer.from(v)) : Buffer.from(val));
}
(_b = (_a = this.#handler).onComplete) == null ? void 0 : _b.call(_a, rawTrailers);
}
Expand Down Expand Up @@ -38083,7 +38083,7 @@ var require_data_url = __commonJS({
if (type.length === 0 || !HTTP_TOKEN_CODEPOINTS.test(type)) {
return "failure";
}
if (position.position > input.length) {
if (position.position >= input.length) {
return "failure";
}
position.position++;
Expand Down Expand Up @@ -38123,7 +38123,7 @@ var require_data_url = __commonJS({
}
position.position++;
}
if (position.position > input.length) {
if (position.position >= input.length) {
break;
}
let parameterValue = null;
Expand Down Expand Up @@ -41479,6 +41479,7 @@ var require_client_h2 = __commonJS({
kClosed,
kBodyTimeout
} = require_symbols6();
var { channels } = require_diagnostics();
var kOpenStreams = Symbol("open streams");
var extractBody;
var http2;
Expand Down Expand Up @@ -41755,6 +41756,14 @@ var require_client_h2 = __commonJS({
headers[HTTP2_HEADER_CONTENT_LENGTH] = `${contentLength}`;
}
session.ref();
if (channels.sendHeaders.hasSubscribers) {
let header = "";
for (const key in headers) {
header += `${key}: ${headers[key]}\r
`;
}
channels.sendHeaders.publish({ request: request2, headers: header, socket: session[kSocket] });
}
const shouldEndStream = method === "GET" || method === "HEAD" || body === null;
if (expectContinue) {
headers[HTTP2_HEADER_EXPECT] = "100-continue";
Expand Down Expand Up @@ -45809,7 +45818,7 @@ var require_response_error = __commonJS({
super(handler2);
}
#checkContentType(contentType) {
return this.#contentType.indexOf(contentType) === 0;
return (this.#contentType ?? "").indexOf(contentType) === 0;
}
onRequestStart(controller, context2) {
this.#statusCode = 0;
Expand Down Expand Up @@ -45863,8 +45872,8 @@ var require_response_error = __commonJS({
super.onResponseEnd(controller, trailers);
}
}
onResponseError(err) {
super.onResponseError(err);
onResponseError(controller, err) {
super.onResponseError(controller, err);
}
};
module.exports = () => {
Expand Down Expand Up @@ -46257,7 +46266,7 @@ var require_dns = __commonJS({
servername: origin.hostname,
origin: newOrigin,
headers: {
host: origin.hostname,
host: origin.host,
...origDispatchOpts.headers
}
};
Expand Down Expand Up @@ -47099,9 +47108,11 @@ var require_cache3 = __commonJS({
}
let headers = {
...opts.headers,
"if-modified-since": new Date(result.cachedAt).toUTCString(),
"if-none-match": result.etag
"if-modified-since": new Date(result.cachedAt).toUTCString()
};
if (result.etag) {
headers["if-none-match"] = result.etag;
}
if (result.vary) {
headers = {
...headers,
Expand Down Expand Up @@ -47204,9 +47215,9 @@ var require_cache3 = __commonJS({
var require_sqlite_cache_store = __commonJS({
""(exports, module) {
"use strict";
var { DatabaseSync } = __require("node:sqlite");
var { Writable } = __require("stream");
var { assertCacheKey, assertCacheValue } = require_cache2();
var DatabaseSync;
var VERSION13 = 3;
var MAX_ENTRY_SIZE = 2 * 1e3 * 1e3 * 1e3;
module.exports = class SqliteCacheStore {
Expand Down Expand Up @@ -47241,6 +47252,9 @@ var require_sqlite_cache_store = __commonJS({
this.#maxCount = opts.maxCount;
}
}
if (!DatabaseSync) {
DatabaseSync = __require("node:sqlite").DatabaseSync;
}
this.#db = new DatabaseSync((opts == null ? void 0 : opts.location) ?? ":memory:");
this.#db.exec(`
CREATE TABLE IF NOT EXISTS cacheInterceptorV${VERSION13} (
Expand Down Expand Up @@ -53551,11 +53565,8 @@ var require_undici2 = __commonJS({
module.exports.cacheStores = {
MemoryCacheStore: require_memory_cache_store()
};
try {
const SqliteCacheStore = require_sqlite_cache_store();
module.exports.cacheStores.SqliteCacheStore = SqliteCacheStore;
} catch (err) {
}
var SqliteCacheStore = require_sqlite_cache_store();
module.exports.cacheStores.SqliteCacheStore = SqliteCacheStore;
module.exports.buildConnector = buildConnector;
module.exports.errors = errors;
module.exports.util = {
Expand Down
45 changes: 28 additions & 17 deletions .github/local-actions/labels-sync/main.js
Original file line number Diff line number Diff line change
Expand Up @@ -21102,15 +21102,15 @@ var require_wrap_handler = __commonJS({
var _a, _b;
const rawHeaders = [];
for (const [key, val] of Object.entries(headers)) {
rawHeaders.push(Buffer.from(key), Buffer.from(val));
rawHeaders.push(Buffer.from(key), Array.isArray(val) ? val.map((v) => Buffer.from(v)) : Buffer.from(val));
}
(_b = (_a = this.#handler).onUpgrade) == null ? void 0 : _b.call(_a, statusCode, rawHeaders, socket);
}
onResponseStart(controller, statusCode, headers, statusMessage) {
var _a, _b;
const rawHeaders = [];
for (const [key, val] of Object.entries(headers)) {
rawHeaders.push(Buffer.from(key), Buffer.from(val));
rawHeaders.push(Buffer.from(key), Array.isArray(val) ? val.map((v) => Buffer.from(v)) : Buffer.from(val));
}
if (((_b = (_a = this.#handler).onHeaders) == null ? void 0 : _b.call(_a, statusCode, rawHeaders, () => controller.resume(), statusMessage)) === false) {
controller.pause();
Expand All @@ -21126,7 +21126,7 @@ var require_wrap_handler = __commonJS({
var _a, _b;
const rawTrailers = [];
for (const [key, val] of Object.entries(trailers)) {
rawTrailers.push(Buffer.from(key), Buffer.from(val));
rawTrailers.push(Buffer.from(key), Array.isArray(val) ? val.map((v) => Buffer.from(v)) : Buffer.from(val));
}
(_b = (_a = this.#handler).onComplete) == null ? void 0 : _b.call(_a, rawTrailers);
}
Expand Down Expand Up @@ -22606,7 +22606,7 @@ var require_data_url = __commonJS({
if (type.length === 0 || !HTTP_TOKEN_CODEPOINTS.test(type)) {
return "failure";
}
if (position.position > input.length) {
if (position.position >= input.length) {
return "failure";
}
position.position++;
Expand Down Expand Up @@ -22646,7 +22646,7 @@ var require_data_url = __commonJS({
}
position.position++;
}
if (position.position > input.length) {
if (position.position >= input.length) {
break;
}
let parameterValue = null;
Expand Down Expand Up @@ -26002,6 +26002,7 @@ var require_client_h2 = __commonJS({
kClosed,
kBodyTimeout
} = require_symbols6();
var { channels } = require_diagnostics();
var kOpenStreams = Symbol("open streams");
var extractBody;
var http2;
Expand Down Expand Up @@ -26278,6 +26279,14 @@ var require_client_h2 = __commonJS({
headers[HTTP2_HEADER_CONTENT_LENGTH] = `${contentLength}`;
}
session.ref();
if (channels.sendHeaders.hasSubscribers) {
let header = "";
for (const key in headers) {
header += `${key}: ${headers[key]}\r
`;
}
channels.sendHeaders.publish({ request: request2, headers: header, socket: session[kSocket] });
}
const shouldEndStream = method === "GET" || method === "HEAD" || body === null;
if (expectContinue) {
headers[HTTP2_HEADER_EXPECT] = "100-continue";
Expand Down Expand Up @@ -30332,7 +30341,7 @@ var require_response_error = __commonJS({
super(handler2);
}
#checkContentType(contentType) {
return this.#contentType.indexOf(contentType) === 0;
return (this.#contentType ?? "").indexOf(contentType) === 0;
}
onRequestStart(controller, context3) {
this.#statusCode = 0;
Expand Down Expand Up @@ -30386,8 +30395,8 @@ var require_response_error = __commonJS({
super.onResponseEnd(controller, trailers);
}
}
onResponseError(err) {
super.onResponseError(err);
onResponseError(controller, err) {
super.onResponseError(controller, err);
}
};
module.exports = () => {
Expand Down Expand Up @@ -30780,7 +30789,7 @@ var require_dns = __commonJS({
servername: origin.hostname,
origin: newOrigin,
headers: {
host: origin.hostname,
host: origin.host,
...origDispatchOpts.headers
}
};
Expand Down Expand Up @@ -31622,9 +31631,11 @@ var require_cache3 = __commonJS({
}
let headers = {
...opts.headers,
"if-modified-since": new Date(result.cachedAt).toUTCString(),
"if-none-match": result.etag
"if-modified-since": new Date(result.cachedAt).toUTCString()
};
if (result.etag) {
headers["if-none-match"] = result.etag;
}
if (result.vary) {
headers = {
...headers,
Expand Down Expand Up @@ -31727,9 +31738,9 @@ var require_cache3 = __commonJS({
var require_sqlite_cache_store = __commonJS({
""(exports, module) {
"use strict";
var { DatabaseSync } = __require("node:sqlite");
var { Writable } = __require("stream");
var { assertCacheKey, assertCacheValue } = require_cache2();
var DatabaseSync;
var VERSION13 = 3;
var MAX_ENTRY_SIZE = 2 * 1e3 * 1e3 * 1e3;
module.exports = class SqliteCacheStore {
Expand Down Expand Up @@ -31764,6 +31775,9 @@ var require_sqlite_cache_store = __commonJS({
this.#maxCount = opts.maxCount;
}
}
if (!DatabaseSync) {
DatabaseSync = __require("node:sqlite").DatabaseSync;
}
this.#db = new DatabaseSync((opts == null ? void 0 : opts.location) ?? ":memory:");
this.#db.exec(`
CREATE TABLE IF NOT EXISTS cacheInterceptorV${VERSION13} (
Expand Down Expand Up @@ -38074,11 +38088,8 @@ var require_undici2 = __commonJS({
module.exports.cacheStores = {
MemoryCacheStore: require_memory_cache_store()
};
try {
const SqliteCacheStore = require_sqlite_cache_store();
module.exports.cacheStores.SqliteCacheStore = SqliteCacheStore;
} catch (err) {
}
var SqliteCacheStore = require_sqlite_cache_store();
module.exports.cacheStores.SqliteCacheStore = SqliteCacheStore;
module.exports.buildConnector = buildConnector;
module.exports.errors = errors;
module.exports.util = {
Expand Down
Loading
Loading