mirror of
https://github.com/GopeedLab/gopeed.git
synced 2026-11-04 15:49:49 +00:00
899 lines
35 KiB
JavaScript
899 lines
35 KiB
JavaScript
(function () {
|
|
const fetchOpen = globalThis.__gopeed_fetch_open;
|
|
const fetchRead = globalThis.__gopeed_fetch_read;
|
|
const fetchClose = globalThis.__gopeed_fetch_close;
|
|
const fetchAbort = globalThis.__gopeed_fetch_abort;
|
|
|
|
class FormData {
|
|
constructor(form) {
|
|
if (form !== undefined) throw new TypeError("FormData HTML form construction is not available in an extension worker");
|
|
this._entries = [];
|
|
}
|
|
|
|
_normalizeValue(value) {
|
|
if (typeof Blob !== "undefined" && value instanceof Blob) return value;
|
|
if (value && typeof value === "object" && "name" in value && "size" in value) return value;
|
|
return String(value);
|
|
}
|
|
|
|
append(name, value) {
|
|
this._entries.push([String(name), this._normalizeValue(value)]);
|
|
}
|
|
|
|
delete(name) {
|
|
name = String(name);
|
|
this._entries = this._entries.filter((entry) => entry[0] !== name);
|
|
}
|
|
|
|
get(name) {
|
|
name = String(name);
|
|
const entry = this._entries.find((item) => item[0] === name);
|
|
return entry ? entry[1] : null;
|
|
}
|
|
|
|
getAll(name) {
|
|
name = String(name);
|
|
return this._entries.filter((entry) => entry[0] === name).map((entry) => entry[1]);
|
|
}
|
|
|
|
has(name) {
|
|
name = String(name);
|
|
return this._entries.some((entry) => entry[0] === name);
|
|
}
|
|
|
|
set(name, value) {
|
|
name = String(name);
|
|
value = this._normalizeValue(value);
|
|
const first = this._entries.findIndex((entry) => entry[0] === name);
|
|
if (first < 0) {
|
|
this._entries.push([name, value]);
|
|
return;
|
|
}
|
|
this._entries[first] = [name, value];
|
|
this._entries = this._entries.filter((entry, index) => index === first || entry[0] !== name);
|
|
}
|
|
|
|
_iterator(kind) {
|
|
const data = this;
|
|
let index = 0;
|
|
return {
|
|
next() {
|
|
if (index >= data._entries.length) return { value: undefined, done: true };
|
|
const entry = data._entries[index++];
|
|
if (kind === "key") return { value: entry[0], done: false };
|
|
if (kind === "value") return { value: entry[1], done: false };
|
|
return { value: [entry[0], entry[1]], done: false };
|
|
},
|
|
[Symbol.iterator]() { return this; },
|
|
};
|
|
}
|
|
|
|
entries() { return this._iterator("entry"); }
|
|
keys() { return this._iterator("key"); }
|
|
values() { return this._iterator("value"); }
|
|
[Symbol.iterator]() { return this.entries(); }
|
|
|
|
forEach(callback, thisArg) {
|
|
for (const [name, value] of this) callback.call(thisArg, value, name, this);
|
|
}
|
|
}
|
|
Object.defineProperty(FormData.prototype, Symbol.toStringTag, { configurable: true, value: "FormData" });
|
|
globalThis.FormData = FormData;
|
|
|
|
const headerNamePattern = /^[!#$%&'*+\-.^_`|~0-9A-Za-z]+$/;
|
|
const headersIteratorBase = Object.getPrototypeOf(Object.getPrototypeOf([][Symbol.iterator]()));
|
|
const headersIteratorPrototype = Object.create(headersIteratorBase);
|
|
|
|
function normalizeHeaderName(name) {
|
|
if (typeof name === "symbol") throw new TypeError("HTTP header names must be ByteStrings");
|
|
name = String(name);
|
|
for (let index = 0; index < name.length; index++) {
|
|
if (name.charCodeAt(index) > 0xFF) throw new TypeError("HTTP header names must be ByteStrings");
|
|
}
|
|
if (!headerNamePattern.test(name)) throw new TypeError("Invalid HTTP header name");
|
|
return name.toLowerCase();
|
|
}
|
|
|
|
function normalizeHeaderValue(value) {
|
|
value = String(value);
|
|
for (let index = 0; index < value.length; index++) {
|
|
if (value.charCodeAt(index) > 0xFF) throw new TypeError("HTTP header values must be ByteStrings");
|
|
}
|
|
value = value.replace(/^[\t\n\r ]+|[\t\n\r ]+$/g, "");
|
|
if (/[\0\n\r]/.test(value)) throw new TypeError("Invalid HTTP header value");
|
|
return value;
|
|
}
|
|
|
|
function normalizeStatusText(value) {
|
|
value = String(value);
|
|
for (let index = 0; index < value.length; index++) {
|
|
const code = value.charCodeAt(index);
|
|
if (code > 0xFF || (code !== 0x09 && (code < 0x20 || code === 0x7F))) {
|
|
throw new TypeError("Invalid response status text");
|
|
}
|
|
}
|
|
return value;
|
|
}
|
|
|
|
function sortedHeaderEntries(headers) {
|
|
const result = [];
|
|
for (const name of Array.from(headers._values.keys()).sort()) {
|
|
const values = headers._values.get(name);
|
|
if (name === "set-cookie") {
|
|
for (const value of values) result.push([name, value]);
|
|
} else {
|
|
result.push([name, values.join(", ")]);
|
|
}
|
|
}
|
|
return result;
|
|
}
|
|
|
|
Object.defineProperty(headersIteratorPrototype, "next", {
|
|
configurable: true,
|
|
enumerable: true,
|
|
writable: true,
|
|
value: function () {
|
|
const entries = sortedHeaderEntries(this._headers);
|
|
if (this._index >= entries.length) return { value: undefined, done: true };
|
|
const entry = entries[this._index++];
|
|
if (this._kind === "key") return { value: entry[0], done: false };
|
|
if (this._kind === "value") return { value: entry[1], done: false };
|
|
return { value: entry, done: false };
|
|
},
|
|
});
|
|
Object.defineProperty(headersIteratorPrototype, Symbol.iterator, {
|
|
configurable: true,
|
|
enumerable: false,
|
|
writable: true,
|
|
value: function () { return this; },
|
|
});
|
|
|
|
function createHeadersIterator(headers, kind) {
|
|
const iterator = Object.create(headersIteratorPrototype);
|
|
Object.defineProperties(iterator, {
|
|
_headers: { value: headers },
|
|
_kind: { value: kind },
|
|
_index: { value: 0, writable: true },
|
|
});
|
|
return iterator;
|
|
}
|
|
|
|
function forbiddenRequestHeader(name, value) {
|
|
if (name.startsWith("proxy-") || name.startsWith("sec-")) return true;
|
|
if ([
|
|
"accept-charset", "accept-encoding", "access-control-request-headers",
|
|
"access-control-request-method", "connection", "content-length", "cookie",
|
|
"cookie2", "date", "dnt", "expect", "host", "keep-alive", "origin",
|
|
"permissions-policy", "referer", "te", "trailer", "transfer-encoding",
|
|
"set-cookie", "upgrade", "via",
|
|
].includes(name)) return true;
|
|
if (["x-http-method", "x-http-method-override", "x-method-override"].includes(name)) {
|
|
return String(value).split(",").some((method) => {
|
|
method = method.trim().toUpperCase();
|
|
return method === "CONNECT" || method === "TRACE" || method === "TRACK";
|
|
});
|
|
}
|
|
return false;
|
|
}
|
|
|
|
function noCORSSafelistedRequestHeader(name, value) {
|
|
if (value.length > 128) return false;
|
|
const hasUnsafeByte = /[\x00-\x08\x0A-\x1F\x7F"():<>?@\[\\\]{}]/.test(value);
|
|
if (name === "accept") return !hasUnsafeByte;
|
|
if (name === "accept-language" || name === "content-language") {
|
|
return /^[0-9A-Za-z *,\-.;=]*$/.test(value);
|
|
}
|
|
if (name === "content-type") {
|
|
if (hasUnsafeByte) return false;
|
|
const essence = value.split(";", 1)[0].trim().toLowerCase();
|
|
return essence === "application/x-www-form-urlencoded" ||
|
|
essence === "multipart/form-data" || essence === "text/plain";
|
|
}
|
|
if (name === "range") return /^bytes=[0-9]+-[0-9]*$/.test(value);
|
|
return false;
|
|
}
|
|
|
|
function blockedByGuard(headers, name, value) {
|
|
if (headers._guard === "immutable") throw new TypeError("Headers are immutable");
|
|
if (headers._guard === "request") return forbiddenRequestHeader(name, value);
|
|
if (headers._guard === "request-no-cors") {
|
|
return forbiddenRequestHeader(name, value) || !noCORSSafelistedRequestHeader(name, value);
|
|
}
|
|
if (headers._guard === "response") return name === "set-cookie" || name === "set-cookie2";
|
|
return false;
|
|
}
|
|
|
|
class Headers {
|
|
constructor(init, guard) {
|
|
this._values = new Map();
|
|
this._guard = guard || "none";
|
|
if (init === undefined) return;
|
|
if (init === null || (typeof init !== "object" && typeof init !== "function")) {
|
|
throw new TypeError("Headers init must be a sequence or record");
|
|
}
|
|
const iterator = init[Symbol.iterator];
|
|
if (typeof iterator === "function") {
|
|
for (const pair of init) {
|
|
if (pair == null || typeof pair[Symbol.iterator] !== "function") {
|
|
throw new TypeError("Header pair must be iterable");
|
|
}
|
|
const values = Array.from(pair);
|
|
if (values.length !== 2) throw new TypeError("Header pair must contain exactly two items");
|
|
this.append(values[0], values[1]);
|
|
}
|
|
return;
|
|
}
|
|
for (const name of Reflect.ownKeys(init)) {
|
|
const descriptor = Reflect.getOwnPropertyDescriptor(init, name);
|
|
if (!descriptor || !descriptor.enumerable) continue;
|
|
const normalizedName = normalizeHeaderName(name);
|
|
this.append(normalizedName, init[name]);
|
|
}
|
|
}
|
|
|
|
append(name, value) {
|
|
name = normalizeHeaderName(name);
|
|
value = normalizeHeaderValue(value);
|
|
const values = this._values.get(name);
|
|
const combinedValue = values && name !== "set-cookie" ? values.join(", ") + ", " + value : value;
|
|
if (blockedByGuard(this, name, combinedValue)) return;
|
|
if (values) values.push(value);
|
|
else this._values.set(name, [value]);
|
|
}
|
|
|
|
delete(name) {
|
|
name = normalizeHeaderName(name);
|
|
if (this._guard === "immutable") throw new TypeError("Headers are immutable");
|
|
if (this._guard === "request-no-cors") {
|
|
if (forbiddenRequestHeader(name, "") || !["accept", "accept-language", "content-language", "content-type", "range"].includes(name)) return;
|
|
this._values.delete(name);
|
|
return;
|
|
}
|
|
if (blockedByGuard(this, name, "")) return;
|
|
this._values.delete(name);
|
|
}
|
|
|
|
get(name) {
|
|
const values = this._values.get(normalizeHeaderName(name));
|
|
return values ? values.join(", ") : null;
|
|
}
|
|
|
|
getSetCookie() {
|
|
const values = this._values.get("set-cookie");
|
|
return values ? values.slice() : [];
|
|
}
|
|
|
|
has(name) {
|
|
return this._values.has(normalizeHeaderName(name));
|
|
}
|
|
|
|
set(name, value) {
|
|
name = normalizeHeaderName(name);
|
|
value = normalizeHeaderValue(value);
|
|
if (blockedByGuard(this, name, value)) return;
|
|
this._values.set(name, [value]);
|
|
}
|
|
|
|
keys() { return createHeadersIterator(this, "key"); }
|
|
values() { return createHeadersIterator(this, "value"); }
|
|
entries() { return createHeadersIterator(this, "entry"); }
|
|
[Symbol.iterator]() { return this.entries(); }
|
|
|
|
forEach(callback, thisArg) {
|
|
for (const [name, value] of this) callback.call(thisArg, value, name, this);
|
|
}
|
|
}
|
|
|
|
globalThis.Headers = Headers;
|
|
|
|
const forbiddenMethods = new Set(["CONNECT", "TRACE", "TRACK"]);
|
|
|
|
function normalizeMethod(method) {
|
|
method = String(method);
|
|
if (!headerNamePattern.test(method)) throw new TypeError("Invalid HTTP method");
|
|
method = method.toUpperCase();
|
|
if (forbiddenMethods.has(method)) throw new TypeError("Forbidden HTTP method");
|
|
return method;
|
|
}
|
|
|
|
function resolveURL(value) {
|
|
const base = globalThis.location && globalThis.location.href ? globalThis.location.href : "http://localhost/";
|
|
const parsed = new URL(String(value), base);
|
|
if (parsed.username || parsed.password) throw new TypeError("Request URLs cannot contain credentials");
|
|
return parsed.href;
|
|
}
|
|
|
|
function normalizeEnum(value, allowed, name) {
|
|
value = String(value);
|
|
if (!allowed.includes(value)) throw new TypeError("Invalid Request " + name);
|
|
return value;
|
|
}
|
|
|
|
function normalizeReferrer(value) {
|
|
value = String(value);
|
|
if (value === "") return "no-referrer";
|
|
if (value === "about:client") return value;
|
|
return resolveURL(value);
|
|
}
|
|
|
|
function copyArrayBuffer(value) {
|
|
if (value instanceof ArrayBuffer) return value.slice(0);
|
|
return value.buffer.slice(value.byteOffset, value.byteOffset + value.byteLength);
|
|
}
|
|
|
|
function initializeBody(owner, body) {
|
|
owner._bodyInit = body == null ? null : body;
|
|
owner._bodyText = null;
|
|
owner._bodyArrayBuffer = null;
|
|
owner._bodyBlob = null;
|
|
owner._bodyFormData = null;
|
|
owner._bodyFormDataBoundary = "";
|
|
owner._bodyStream = null;
|
|
owner._bodyUsed = false;
|
|
if (body == null) return;
|
|
if (typeof ReadableStream !== "undefined" && body instanceof ReadableStream) {
|
|
owner._bodyStream = body;
|
|
body.__gopeedMarkBodyUsed = () => { owner._bodyUsed = true; };
|
|
} else if (typeof body === "string") {
|
|
owner._bodyText = body;
|
|
} else if (typeof Blob !== "undefined" && body instanceof Blob) {
|
|
owner._bodyBlob = body;
|
|
} else if (typeof FormData !== "undefined" && body instanceof FormData) {
|
|
owner._bodyFormData = body;
|
|
const suffix = crypto.randomUUID ? crypto.randomUUID() : String(Date.now()) + String(Math.random()).slice(2);
|
|
owner._bodyFormDataBoundary = "----gopeed-" + suffix;
|
|
} else if (body instanceof ArrayBuffer || (ArrayBuffer.isView && ArrayBuffer.isView(body))) {
|
|
owner._bodyArrayBuffer = copyArrayBuffer(body);
|
|
} else if (typeof URLSearchParams !== "undefined" && body instanceof URLSearchParams) {
|
|
owner._bodyText = body.toString();
|
|
} else {
|
|
owner._bodyText = String(body);
|
|
}
|
|
}
|
|
|
|
function bodyContentType(owner) {
|
|
if (owner._bodyText != null) {
|
|
if (typeof URLSearchParams !== "undefined" && owner._bodyInit instanceof URLSearchParams) {
|
|
return "application/x-www-form-urlencoded;charset=UTF-8";
|
|
}
|
|
return "text/plain;charset=UTF-8";
|
|
}
|
|
if (owner._bodyBlob && owner._bodyBlob.type) return owner._bodyBlob.type;
|
|
if (owner._bodyFormData) return "multipart/form-data; boundary=" + owner._bodyFormDataBoundary;
|
|
return "";
|
|
}
|
|
|
|
function decodeFormComponent(value) {
|
|
return decodeURIComponent(String(value).replace(/\+/g, " "));
|
|
}
|
|
|
|
function installBodyMethods(prototype) {
|
|
Object.defineProperties(prototype, {
|
|
body: {
|
|
configurable: true,
|
|
enumerable: true,
|
|
get() {
|
|
if (this._bodyInit == null && !this.__gopeedBodyStream) return null;
|
|
if (this.__gopeedBodyStream) return this.__gopeedBodyStream;
|
|
if (!this._bodyStream) this._bodyStream = createBodyReadableStream(this);
|
|
return this._bodyStream;
|
|
},
|
|
},
|
|
bodyUsed: {
|
|
configurable: true,
|
|
enumerable: true,
|
|
get() { return Boolean(this._bodyUsed || this.__gopeedBodyConsumed); },
|
|
},
|
|
});
|
|
prototype.text = async function () {
|
|
if (this.bodyUsed) throw new TypeError("Already read");
|
|
if (this.body == null) return "";
|
|
return readAllFromStream(this.body, true);
|
|
};
|
|
prototype.arrayBuffer = async function () {
|
|
if (this.bodyUsed) throw new TypeError("Already read");
|
|
if (this.body == null) return new ArrayBuffer(0);
|
|
const bytes = await readAllFromStream(this.body, false);
|
|
return bytes.buffer.slice(bytes.byteOffset, bytes.byteOffset + bytes.byteLength);
|
|
};
|
|
prototype.bytes = async function () {
|
|
if (this.bodyUsed) throw new TypeError("Already read");
|
|
if (this.body == null) return new Uint8Array(0);
|
|
return readAllFromStream(this.body, false);
|
|
};
|
|
prototype.blob = async function () {
|
|
const data = await this.arrayBuffer();
|
|
return new Blob([data], { type: this.headers.get("content-type") || "" });
|
|
};
|
|
prototype.json = async function () { return JSON.parse(await this.text()); };
|
|
prototype.formData = async function () {
|
|
const contentType = this.headers.get("content-type") || "";
|
|
const essence = contentType.split(";", 1)[0].trim().toLowerCase();
|
|
if (essence === "multipart/form-data" && this._bodyFormData) {
|
|
if (this.bodyUsed) throw new TypeError("Already read");
|
|
await readAllFromStream(this.body, false);
|
|
const result = new FormData();
|
|
for (const entry of Array.from(this._bodyFormData.entries())) result.append(entry[0], entry[1]);
|
|
return result;
|
|
}
|
|
if (essence !== "application/x-www-form-urlencoded") {
|
|
throw new TypeError("Body is not URL-encoded form data");
|
|
}
|
|
if (this.body == null) return new FormData();
|
|
const text = await this.text();
|
|
const result = new FormData();
|
|
for (const entry of text.split("&")) {
|
|
if (!entry) continue;
|
|
const parts = entry.split("=");
|
|
const name = parts.shift();
|
|
result.append(decodeFormComponent(name), decodeFormComponent(parts.join("=")));
|
|
}
|
|
return result;
|
|
};
|
|
}
|
|
|
|
function transferReadableStream(stream) {
|
|
let reader = null;
|
|
return new ReadableStream({
|
|
async pull(controller) {
|
|
if (!reader) reader = stream.getReader();
|
|
const result = await reader.read();
|
|
if (result.done) {
|
|
reader.releaseLock();
|
|
controller.close();
|
|
} else {
|
|
controller.enqueue(result.value);
|
|
}
|
|
},
|
|
cancel(reason) {
|
|
if (!reader) reader = stream.getReader();
|
|
return reader.cancel(reason);
|
|
},
|
|
});
|
|
}
|
|
|
|
class Request {
|
|
constructor(input, init) {
|
|
if (arguments.length < 1) throw new TypeError("Request requires an input");
|
|
init = init || {};
|
|
if (init.window !== undefined && init.window !== null) throw new TypeError("Request window must be null");
|
|
const source = input instanceof Request ? input : null;
|
|
const bodyWasOverridden = Object.prototype.hasOwnProperty.call(init, "body");
|
|
if (source && source.bodyUsed && !bodyWasOverridden) throw new TypeError("Request body is already used");
|
|
this._url = source ? source.url : resolveURL(input);
|
|
this._method = normalizeMethod(init.method !== undefined ? init.method : (source ? source.method : "GET"));
|
|
this._destination = "";
|
|
this._referrer = init.referrer !== undefined ? normalizeReferrer(init.referrer) : (source ? source.referrer : "about:client");
|
|
this._referrerPolicy = normalizeEnum(init.referrerPolicy !== undefined ? init.referrerPolicy : (source ? source.referrerPolicy : ""), ["", "no-referrer", "no-referrer-when-downgrade", "origin", "origin-when-cross-origin", "same-origin", "strict-origin", "strict-origin-when-cross-origin", "unsafe-url"], "referrerPolicy");
|
|
this._mode = normalizeEnum(init.mode !== undefined ? init.mode : (source ? source.mode : "cors"), ["same-origin", "no-cors", "cors"], "mode");
|
|
this._credentials = normalizeEnum(init.credentials !== undefined ? init.credentials : (source ? source.credentials : "same-origin"), ["omit", "same-origin", "include"], "credentials");
|
|
this._cache = normalizeEnum(init.cache !== undefined ? init.cache : (source ? source.cache : "default"), ["default", "no-store", "reload", "no-cache", "force-cache", "only-if-cached"], "cache");
|
|
this._redirect = normalizeEnum(init.redirect !== undefined ? init.redirect : (source ? source.redirect : "follow"), ["follow", "error", "manual"], "redirect");
|
|
if (this._mode === "no-cors" && !["GET", "HEAD", "POST"].includes(this._method)) {
|
|
throw new TypeError("no-cors requests require a CORS-safelisted method");
|
|
}
|
|
if (this._cache === "only-if-cached" && this._mode !== "same-origin") {
|
|
throw new TypeError("only-if-cached requires same-origin mode");
|
|
}
|
|
this._integrity = init.integrity !== undefined ? String(init.integrity) : (source ? source.integrity : "");
|
|
this._keepalive = init.keepalive !== undefined ? Boolean(init.keepalive) : (source ? source.keepalive : false);
|
|
this._priority = normalizeEnum(init.priority !== undefined ? init.priority : (source ? source._priority : "auto"), ["high", "low", "auto"], "priority");
|
|
this._signal = init.signal || (source && source.signal) || new AbortController().signal;
|
|
if (init.duplex !== undefined && String(init.duplex) !== "half") {
|
|
throw new TypeError("Request duplex must be 'half'");
|
|
}
|
|
this._duplex = "half";
|
|
const headerInit = init.headers !== undefined ? init.headers : (source ? source.headers : undefined);
|
|
this._headers = new Headers(headerInit, this._mode === "no-cors" ? "request-no-cors" : "request");
|
|
let body = init.body !== undefined ? init.body : (source ? source._bodyInit : null);
|
|
if (source && !bodyWasOverridden && source.body) body = transferReadableStream(source.body);
|
|
const bodyIsStream = typeof ReadableStream !== "undefined" && body instanceof ReadableStream;
|
|
if (bodyIsStream && (body.locked || body._disturbed)) {
|
|
throw new TypeError("ReadableStream body is locked or disturbed");
|
|
}
|
|
if (bodyIsStream && init.body !== undefined && init.duplex === undefined) {
|
|
throw new TypeError("ReadableStream request bodies require duplex: 'half'");
|
|
}
|
|
if (bodyIsStream && this._keepalive) {
|
|
throw new TypeError("keepalive requests cannot have a ReadableStream body");
|
|
}
|
|
if (source && !bodyWasOverridden && source.body && (source.body.locked || source.body._disturbed)) {
|
|
throw new TypeError("Request body is locked or disturbed");
|
|
}
|
|
if ((this._method === "GET" || this._method === "HEAD") && body != null) {
|
|
throw new TypeError("Body not allowed for GET or HEAD requests");
|
|
}
|
|
initializeBody(this, body);
|
|
const contentType = bodyContentType(this);
|
|
if (contentType && !this._headers.has("content-type")) this._headers.set("content-type", contentType);
|
|
if (source && source.body) source._bodyUsed = true;
|
|
}
|
|
|
|
get method() { return this._method; }
|
|
get url() { return this._url; }
|
|
get headers() { return this._headers; }
|
|
get destination() { return this._destination; }
|
|
get referrer() { return this._referrer; }
|
|
get referrerPolicy() { return this._referrerPolicy; }
|
|
get mode() { return this._mode; }
|
|
get credentials() { return this._credentials; }
|
|
get cache() { return this._cache; }
|
|
get redirect() { return this._redirect; }
|
|
get integrity() { return this._integrity; }
|
|
get keepalive() { return this._keepalive; }
|
|
get signal() { return this._signal; }
|
|
get isReloadNavigation() { return false; }
|
|
get isHistoryNavigation() { return false; }
|
|
get duplex() { return this._duplex; }
|
|
clone() {
|
|
if (this.bodyUsed) throw new TypeError("Request body is already used");
|
|
let body = null;
|
|
if (this.body) {
|
|
const branches = this.body.tee();
|
|
this._bodyInit = branches[0];
|
|
this._bodyStream = branches[0];
|
|
if (this.__gopeedBodyStream) this.__gopeedBodyStream = branches[0];
|
|
branches[0].__gopeedMarkBodyUsed = () => { this._bodyUsed = true; };
|
|
body = branches[1];
|
|
}
|
|
return new Request(this.url, {
|
|
method: this.method,
|
|
headers: this.headers,
|
|
body,
|
|
mode: this.mode,
|
|
credentials: this.credentials,
|
|
cache: this.cache,
|
|
redirect: this.redirect,
|
|
referrer: this.referrer,
|
|
referrerPolicy: this.referrerPolicy,
|
|
integrity: this.integrity,
|
|
keepalive: this.keepalive,
|
|
signal: this.signal,
|
|
duplex: "half",
|
|
});
|
|
}
|
|
}
|
|
installBodyMethods(Request.prototype);
|
|
|
|
const nullBodyStatuses = new Set([101, 103, 204, 205, 304]);
|
|
|
|
class Response {
|
|
constructor(body, init) {
|
|
init = init || {};
|
|
const status = init.status === undefined ? 200 : Number(init.status);
|
|
if (!Number.isInteger(status) || status < 200 || status > 599) {
|
|
throw new RangeError("Invalid response status");
|
|
}
|
|
if (body != null && nullBodyStatuses.has(status)) {
|
|
throw new TypeError("Response with null-body status cannot have a body");
|
|
}
|
|
const statusText = init.statusText === undefined ? "" : normalizeStatusText(init.statusText);
|
|
this._type = "default";
|
|
this._url = init.url ? String(init.url) : "";
|
|
this._redirected = Boolean(init.redirected);
|
|
this._status = status;
|
|
this._statusText = statusText;
|
|
this._headers = new Headers(init.headers, "response");
|
|
if (typeof ReadableStream !== "undefined" && body instanceof ReadableStream && (body.locked || body._disturbed)) {
|
|
throw new TypeError("ReadableStream body is locked or disturbed");
|
|
}
|
|
initializeBody(this, body == null ? null : body);
|
|
const contentType = bodyContentType(this);
|
|
if (contentType && !this._headers.has("content-type")) this._headers.set("content-type", contentType);
|
|
}
|
|
|
|
get type() { return this._type; }
|
|
get url() { return this._url; }
|
|
get redirected() { return this._redirected; }
|
|
get status() { return this._status; }
|
|
get ok() { return this._status >= 200 && this._status <= 299; }
|
|
get statusText() { return this._statusText; }
|
|
get headers() { return this._headers; }
|
|
clone() {
|
|
if (this.bodyUsed) throw new TypeError("Response body is already used");
|
|
let body = null;
|
|
if (this.body) {
|
|
const branches = this.body.tee();
|
|
this._bodyInit = branches[0];
|
|
this._bodyStream = branches[0];
|
|
if (this.__gopeedBodyStream) this.__gopeedBodyStream = branches[0];
|
|
branches[0].__gopeedMarkBodyUsed = () => { this._bodyUsed = true; };
|
|
body = branches[1];
|
|
}
|
|
return new Response(body, {
|
|
status: this.status,
|
|
statusText: this.statusText,
|
|
headers: this.headers,
|
|
url: this.url,
|
|
redirected: this.redirected,
|
|
});
|
|
}
|
|
|
|
static error() {
|
|
const response = Object.create(Response.prototype);
|
|
response._type = "error";
|
|
response._url = "";
|
|
response._redirected = false;
|
|
response._status = 0;
|
|
response._statusText = "";
|
|
response._headers = new Headers(undefined, "immutable");
|
|
initializeBody(response, null);
|
|
return response;
|
|
}
|
|
|
|
static redirect(url, status) {
|
|
status = status === undefined ? 302 : Number(status);
|
|
if (![301, 302, 303, 307, 308].includes(status)) throw new RangeError("Invalid redirect status");
|
|
return new Response(null, { status, headers: { location: resolveURL(url) } });
|
|
}
|
|
|
|
static json(data, init) {
|
|
const body = JSON.stringify(data);
|
|
if (body === undefined) throw new TypeError("Value is not JSON serializable");
|
|
init = Object.assign({}, init || {});
|
|
const headers = new Headers(init.headers);
|
|
if (!headers.has("content-type")) headers.set("content-type", "application/json");
|
|
init.headers = headers;
|
|
return new Response(body, init);
|
|
}
|
|
}
|
|
installBodyMethods(Response.prototype);
|
|
|
|
globalThis.Request = Request;
|
|
globalThis.Response = Response;
|
|
|
|
function toUint8Array(chunk) {
|
|
if (chunk == null) return new Uint8Array(0);
|
|
if (chunk instanceof Uint8Array) return chunk;
|
|
if (typeof chunk === "string") return new TextEncoder().encode(chunk);
|
|
if (chunk instanceof ArrayBuffer) return new Uint8Array(chunk);
|
|
if (typeof ArrayBuffer !== "undefined" && ArrayBuffer.isView && ArrayBuffer.isView(chunk)) {
|
|
return new Uint8Array(chunk.buffer, chunk.byteOffset, chunk.byteLength);
|
|
}
|
|
if (typeof Blob !== "undefined" && chunk instanceof Blob && chunk._buffer instanceof Uint8Array) {
|
|
return chunk._buffer;
|
|
}
|
|
return new Uint8Array(0);
|
|
}
|
|
|
|
function createBodyReadableStream(owner) {
|
|
const stream = new ReadableStream({
|
|
start(controller) {
|
|
Promise.resolve().then(async () => {
|
|
if (owner._noBody) {
|
|
controller.close();
|
|
return;
|
|
}
|
|
if (owner._bodyArrayBuffer) {
|
|
controller.enqueue(toUint8Array(owner._bodyArrayBuffer));
|
|
controller.close();
|
|
return;
|
|
}
|
|
if (owner._bodyBlob) {
|
|
const data = await owner._bodyBlob.arrayBuffer();
|
|
controller.enqueue(new Uint8Array(data));
|
|
controller.close();
|
|
return;
|
|
}
|
|
if (owner._bodyFormData) {
|
|
const boundary = owner._bodyFormDataBoundary;
|
|
const entries = Array.from(owner._bodyFormData.entries());
|
|
if (entries.length === 0) {
|
|
controller.close();
|
|
return;
|
|
}
|
|
let serialized = "";
|
|
for (const entry of entries) {
|
|
const name = String(entry[0]).replace(/\r|\n|"/g, (character) =>
|
|
character === "\r" ? "%0D" : character === "\n" ? "%0A" : "%22");
|
|
serialized += "--" + boundary + "\r\nContent-Disposition: form-data; name=\"" + name + "\"\r\n\r\n";
|
|
serialized += String(entry[1]) + "\r\n";
|
|
}
|
|
serialized += "--" + boundary + "--\r\n";
|
|
controller.enqueue(toUint8Array(serialized));
|
|
controller.close();
|
|
return;
|
|
}
|
|
if (owner._bodyText != null) {
|
|
controller.enqueue(toUint8Array(owner._bodyText));
|
|
controller.close();
|
|
return;
|
|
}
|
|
if (owner._bodyInit != null) controller.enqueue(toUint8Array(owner._bodyInit));
|
|
controller.close();
|
|
}).catch((error) => controller.error(error));
|
|
},
|
|
});
|
|
stream.__gopeedMarkBodyUsed = () => { owner._bodyUsed = true; };
|
|
return stream;
|
|
}
|
|
|
|
async function readAllFromStream(stream, asText) {
|
|
if (!stream) return asText ? "" : new Uint8Array(0);
|
|
const reader = stream.getReader();
|
|
const chunks = [];
|
|
let total = 0;
|
|
try {
|
|
while (true) {
|
|
const { done, value } = await reader.read();
|
|
if (done) break;
|
|
if (!(value instanceof Uint8Array)) {
|
|
throw new TypeError("Fetch body stream chunks must be Uint8Array values");
|
|
}
|
|
const chunk = value;
|
|
chunks.push(chunk);
|
|
total += chunk.byteLength;
|
|
}
|
|
} finally {
|
|
reader.releaseLock();
|
|
}
|
|
const merged = new Uint8Array(total);
|
|
let offset = 0;
|
|
for (const chunk of chunks) {
|
|
merged.set(chunk, offset);
|
|
offset += chunk.byteLength;
|
|
}
|
|
return asText ? new TextDecoder().decode(merged) : merged;
|
|
}
|
|
|
|
function attachResponseStreaming(response, stream) {
|
|
response.__gopeedBodyStream = stream;
|
|
response.__gopeedBodyConsumed = false;
|
|
const ensureUnused = () => {
|
|
if (response.__gopeedBodyConsumed) throw new TypeError("Already read");
|
|
};
|
|
const markBodyUsed = () => {
|
|
ensureUnused();
|
|
response.__gopeedBodyConsumed = true;
|
|
response.bodyUsed = true;
|
|
};
|
|
if (stream) {
|
|
stream.__gopeedMarkBodyUsed = () => {
|
|
if (!response.__gopeedBodyConsumed) {
|
|
response.__gopeedBodyConsumed = true;
|
|
response.bodyUsed = true;
|
|
}
|
|
};
|
|
}
|
|
response.text = async function () {
|
|
markBodyUsed();
|
|
return readAllFromStream(this.body, true);
|
|
};
|
|
response.arrayBuffer = async function () {
|
|
markBodyUsed();
|
|
const bytes = await readAllFromStream(this.body, false);
|
|
return bytes.buffer.slice(bytes.byteOffset, bytes.byteOffset + bytes.byteLength);
|
|
};
|
|
response.bytes = async function () {
|
|
markBodyUsed();
|
|
return readAllFromStream(this.body, false);
|
|
};
|
|
response.blob = async function () {
|
|
markBodyUsed();
|
|
const contentType = this.headers && this.headers.get ? (this.headers.get("content-type") || "") : "";
|
|
const bytes = await readAllFromStream(this.body, false);
|
|
return new Blob([bytes], { type: contentType });
|
|
};
|
|
response.json = async function () {
|
|
return JSON.parse(await this.text());
|
|
};
|
|
return response;
|
|
}
|
|
|
|
if (typeof globalThis.Response === "function") {
|
|
const responseProto = globalThis.Response.prototype;
|
|
const bodyDescriptor = Object.getOwnPropertyDescriptor(responseProto, "body");
|
|
if (!bodyDescriptor || typeof bodyDescriptor.get !== "function") {
|
|
Object.defineProperty(responseProto, "body", {
|
|
configurable: true,
|
|
enumerable: true,
|
|
get() {
|
|
if (!this.__gopeedBodyStream) this.__gopeedBodyStream = createBodyReadableStream(this);
|
|
return this.__gopeedBodyStream;
|
|
},
|
|
});
|
|
}
|
|
}
|
|
|
|
if (typeof fetchOpen !== "function") return;
|
|
|
|
globalThis.fetch = async function (input, init) {
|
|
const request = new Request(input, init);
|
|
const requestID = crypto.randomUUID ? crypto.randomUUID() : String(Date.now()) + "-" + String(Math.random());
|
|
const signal = request.signal;
|
|
let abortHandler = null;
|
|
const cleanupAbort = () => {
|
|
if (signal && abortHandler && typeof signal.removeEventListener === "function") {
|
|
signal.removeEventListener("abort", abortHandler);
|
|
}
|
|
abortHandler = null;
|
|
};
|
|
if (signal) {
|
|
if (signal.aborted) throw new DOMException("Aborted", "AbortError");
|
|
abortHandler = () => fetchAbort(requestID, signal.reason == null ? "" : String(signal.reason));
|
|
signal.addEventListener("abort", abortHandler, { once: true });
|
|
}
|
|
|
|
let body = null;
|
|
if (request._bodyStream && !request._bodyFormData) {
|
|
const bytes = await readAllFromStream(request._bodyStream, false);
|
|
body = bytes.buffer.slice(bytes.byteOffset, bytes.byteOffset + bytes.byteLength);
|
|
} else if (request._bodyFormData) {
|
|
body = request._bodyFormData._entries;
|
|
} else if (request._bodyArrayBuffer) {
|
|
body = request._bodyArrayBuffer;
|
|
} else if (request._bodyBlob) {
|
|
body = await request._bodyBlob.arrayBuffer();
|
|
} else if (request._bodyInit != null && typeof request._bodyInit === "object") {
|
|
body = request._bodyInit;
|
|
} else if (request._bodyText != null) {
|
|
body = request._bodyText;
|
|
} else if (request._bodyInit != null) {
|
|
body = request._bodyInit;
|
|
}
|
|
|
|
const headers = [];
|
|
request.headers.forEach((value, key) => headers.push([key, value]));
|
|
let metadata;
|
|
try {
|
|
metadata = await fetchOpen({
|
|
id: requestID,
|
|
url: request.url,
|
|
method: request.method,
|
|
headers,
|
|
body,
|
|
bodyType: request._bodyFormData ? "formdata" : "",
|
|
bodyBoundary: request._bodyFormDataBoundary,
|
|
redirect: request.redirect,
|
|
credentials: request.credentials,
|
|
});
|
|
} catch (error) {
|
|
cleanupAbort();
|
|
if (signal && signal.aborted) throw new DOMException("Aborted", "AbortError");
|
|
throw error instanceof Error ? error : new TypeError(String(error));
|
|
}
|
|
|
|
const stream = new ReadableStream({
|
|
async pull(controller) {
|
|
let chunk;
|
|
try {
|
|
chunk = await fetchRead(metadata.id, 64 * 1024);
|
|
} catch (error) {
|
|
fetchClose(metadata.id);
|
|
cleanupAbort();
|
|
controller.error(error instanceof Error ? error : new TypeError(String(error)));
|
|
return;
|
|
}
|
|
if (chunk == null) {
|
|
fetchClose(metadata.id);
|
|
cleanupAbort();
|
|
controller.close();
|
|
return;
|
|
}
|
|
const bytes = chunk instanceof Uint8Array ? chunk : new Uint8Array(chunk);
|
|
if (bytes.byteLength === 0) {
|
|
fetchClose(metadata.id);
|
|
cleanupAbort();
|
|
controller.close();
|
|
return;
|
|
}
|
|
controller.enqueue(bytes);
|
|
},
|
|
cancel(reason) {
|
|
cleanupAbort();
|
|
fetchAbort(metadata.id, reason == null ? "" : String(reason));
|
|
},
|
|
});
|
|
const response = new Response(null, {
|
|
status: metadata.status,
|
|
statusText: metadata.statusText,
|
|
headers: metadata.headers,
|
|
url: metadata.url,
|
|
redirected: metadata.redirected,
|
|
});
|
|
response._type = "basic";
|
|
response._headers._guard = "immutable";
|
|
return attachResponseStreaming(response, stream);
|
|
};
|
|
})();
|