GM Fetch

A fetch API for GM_xmlhttpRequest / GM.xmlHttpRequest
当前为 2023-09-12 提交的版本，查看最新版本。
此脚本不应直接安装。它是供其他脚本使用的外部库，要使用该库请加入元指令 // @require https://update.cn-greasyfork.org/scripts/472236/1249483/GM%20Fetch.js
换行
// ==UserScript==
// @name         GM Fetch
// @namespace    https://github.com/Sec-ant/gm-fetch
// @version      1.1.6
// @author       Ze-Zheng Wu
// @description  A fetch API for GM_xmlhttpRequest / GM.xmlHttpRequest
// @license      MIT
// @homepage     https://github.com/Sec-ant/gm-fetch
// @homepageURL  https://github.com/Sec-ant/gm-fetch
// @source       https://github.com/Sec-ant/gm-fetch.git
// @supportURL   https://github.com/Sec-ant/gm-fetch/issues
// @match        *://*/*
// @grant        GM.xmlHttpRequest
// @grant        GM_xmlhttpRequest
// ==/UserScript==
 
(function () {
  'use strict';
 
  (function(global, factory) {
    (global = typeof globalThis !== "undefined" ? globalThis : global || self, global.gmFetch = factory());
  })(globalThis, function() {
    var _GM = /* @__PURE__ */ (() => typeof GM != "undefined" ? GM : void 0)();
    var _GM_xmlhttpRequest = /* @__PURE__ */ (() => typeof GM_xmlhttpRequest != "undefined" ? GM_xmlhttpRequest : void 0)();
    function parseHeaders(rawHeaders) {
      const headers = new Headers();
      const preProcessedHeaders = rawHeaders.replace(/\r?\n[\t ]+/g, " ");
      preProcessedHeaders.split(/\r?\n/).forEach(function(line) {
        var _a;
        const parts = line.split(":");
        const key = (_a = parts.shift()) == null ? void 0 : _a.trim();
        if (key) {
          const value = parts.join(":").trim();
          try {
            headers.append(key, value);
          } catch (error) {
            console.warn("Response " + error.message);
          }
        }
      });
      return headers;
    }
    const gmFetch = async function(input, init) {
      const gmXhr = _GM_xmlhttpRequest || _GM.xmlHttpRequest;
      if (typeof gmXhr !== "function") {
        throw new DOMException(
          "GM_xmlhttpRequest or GM.xmlHttpRequest is not granted.",
          "NotFoundError"
        );
      }
      const request = new Request(input, init);
      if (request.signal.aborted) {
        throw new DOMException("Network request aborted.", "AbortError");
      }
      const dataBuffer = await request.arrayBuffer();
      const data = dataBuffer.byteLength ? new TextDecoder().decode(dataBuffer) : void 0;
      const headers = Object.fromEntries(request.headers);
      new Headers(init == null ? void 0 : init.headers).forEach((value, key) => {
        headers[key] = value;
      });
      return new Promise((resolve, reject) => {
        let settled = false;
        const responseBlobPromise = new Promise((resolveBlob) => {
          const { abort } = gmXhr({
            method: request.method.toUpperCase(),
            url: request.url || location.href,
            headers,
            data,
            redirect: request.redirect,
            binary: true,
            nocache: request.cache === "no-store",
            revalidate: request.cache === "reload",
            timeout: 3e5,
            responseType: gmXhr.RESPONSE_TYPE_STREAM ?? "blob",
            overrideMimeType: request.headers.get("Content-Type") ?? void 0,
            anonymous: request.credentials === "omit",
            onload: ({ response: responseBody }) => {
              if (settled) {
                resolveBlob(null);
                return;
              }
              resolveBlob(responseBody);
            },
            async onreadystatechange({
              readyState,
              responseHeaders,
              status,
              statusText,
              finalUrl,
              response: responseBody
            }) {
              if (readyState === XMLHttpRequest.DONE) {
                request.signal.removeEventListener("abort", abort);
              } else if (readyState !== XMLHttpRequest.HEADERS_RECEIVED) {
                return;
              }
              if (settled) {
                resolveBlob(null);
                return;
              }
              const parsedHeaders = parseHeaders(responseHeaders);
              const redirected = request.url !== finalUrl;
              const response = new Response(
                responseBody instanceof ReadableStream ? responseBody : await responseBlobPromise,
                {
                  headers: parsedHeaders,
                  status,
                  statusText
                }
              );
              Object.defineProperties(response, {
                url: {
                  value: finalUrl
                },
                type: {
                  value: "basic"
                },
                ...response.redirected !== redirected ? {
                  redirected: {
                    value: redirected
                  }
                } : {},
                // https://fetch.spec.whatwg.org/#forbidden-response-header-name
                ...parsedHeaders.has("set-cookie") || parsedHeaders.has("set-cookie2") ? {
                  headers: {
                    value: parsedHeaders
                  }
                } : {}
              });
              resolve(response);
              settled = true;
            },
            onerror: ({ statusText, error }) => {
              reject(
                new TypeError(statusText || error || "Network request failed.")
              );
              resolveBlob(null);
            },
            ontimeout() {
              reject(new TypeError("Network request timeout."));
              resolveBlob(null);
            },
            onabort() {
              reject(new DOMException("Network request aborted.", "AbortError"));
              resolveBlob(null);
            }
          });
          request.signal.addEventListener("abort", abort);
        });
      });
    };
    return gmFetch;
  });
 
})();