Function fetch

packages/fetch/src/node-fetch-patch.js:71–453

(url, options_)

 * @return  {Promise<import('./response').default>}
 */
export default async function fetch(url, options_) {
  return new Promise((resolve, reject) => {
    // Build request object
    const request = new Request(url, options_);
    const { parsedURL, options } = getNodeRequestOptions(request);
    if (!supportedSchemas.has(parsedURL.protocol)) {
      throw new TypeError(
        `node-fetch cannot load ${url}. URL scheme "${parsedURL.protocol.replace(/:$/, "")}" is not supported.`,
      );
    }

    if (parsedURL.protocol === "data:") {
      const data = dataUriToBuffer(request.url);
      const response = new Response(data, {
        headers: { "Content-Type": data.typeFull },
      });
      resolve(response);
      return;
    }

    // Wrap http.request into fetch
    const send = (parsedURL.protocol === "https:" ? https : http).request;
    const { signal } = request;
    let response = null;

    const abort = () => {
      const error = new AbortError("The operation was aborted.");
      reject(error);
      if (request.body && request.body instanceof Stream.Readable) {
        request.body.destroy(error);
      }

      if (!response || !response.body) {
        return;
      }

      response.body.emit("error", error);
    };

    if (signal && signal.aborted) {
      abort();
      return;
    }

    const abortAndFinalize = () => {
      abort();
      finalize();
    };

    // Send request
    const request_ = send(parsedURL.toString(), options);

    if (signal) {
      signal.addEventListener("abort", abortAndFinalize);
    }

    const finalize = () => {
      request_.abort();