node fetch future

fetch.js

const R = require('ramda');
const {
  Future, resolve, reject,
} = require('fluture');

const fetch = require('node-fetch');

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

const ConstructAbort = R.construct(AbortController);
const ConstructRequest = R.constructN(2, Request);

const construct = R.curryN(2, (options = {}, uri) => Future((rej, res) => {
  const controller = ConstructAbort();
  const { timeout = 5000 } = options;
  const request = (R.compose(
    ConstructRequest(uri),
    R.mergeDeepRight({ signal: controller.signal }),
    R.omit(['timeout']),
  )(options));

  const timer = setTimeout(() => { controller.abort(); }, timeout);

  fetch(request)
    .then(res)
    .catch((error) => {
      if (error.message === 'The user aborted a request.') {
        rej(`Request timed out at ${timeout}ms`);
      } else {
        rej(error);
      }
    })
    .finally(() => {
      clearTimeout(timer);
    });

  return () => {
    clearTimeout(timer);
    controller.abort();
  };
}));

module.exports = R.compose(
  R.chain((response) => (response.ok ? resolve(response) : reject(response.statusText))),
  construct,
);