balanceofsatoshis/commands/fetch_request.js

const {stringify} = require('querystring');

const {AbortController} = require('abort-controller');

const encodeQs = qs => !qs ? '' : '?' + stringify(qs);
const timeoutSignals = new WeakMap();

/** Derive a request function that uses fetch to simulate request behavior

  {
    fetch: <Node Fetch Function>
  }

  @returns
  {
    request: <Request Function>
  }
*/
module.exports = ({fetch}, cbk) => {
  return (options, cbk) => {
    (async () => {
    	const controller = new AbortController();

      // Setup the timeout controller
      if (!!options.timeout) {
        const timeout = setTimeout(() => controller.abort(), options.timeout);

        timeoutSignals.set(controller.signal, timeout);
      }

      const url = options.url + encodeQs(options.qs);

      try {
        // Make the request
        const response = await fetch(url, {
          body: options.body || undefined,
          method: options.method || undefined,
          signal: controller.signal,
        });

        const res = {statusCode: response.status};

        if (!!options.json) {
          return cbk(null, res, await response.json());
        } else {
          return cbk(null, res, await response.text());
        }
      } catch (err) {
        // Return request errors back
        return cbk(err);
      } finally {
        // Reset the timeout since the request is over
        if (!!options.timeout) {
          clearTimeout(timeoutSignals.get(controller.signal));
        }
      }
    })();
  };
};