http.js

const config = require('./config');
const fetch = require('node-fetch');
const querystring = require('querystring');

module.exports = {
  get,
  post,
  put,
  delete: httpDelete, // function name can't be 'delete'
  fetchJsonWithAuth,
  fetchWithAuth,
};

function get(uri, queryParams) {
  return fetchJsonWithAuth(
    uri + '?' + querystring.stringify(queryParams),
    {method: 'GET'}
  );
}

function post(uri, body = {}) {
  return fetchJsonWithAuth(uri, {
    method: 'POST',
    body: JSON.stringify(body),
    headers: {'Content-Type': 'application/json'},
  });
}

function put(uri, body) {
  return fetchJsonWithAuth(uri, {
    method: 'PUT',
    body: JSON.stringify(body),
    headers: {'Content-Type': 'application/json'},
  });
}

function httpDelete(uri, queryParams) {
  return fetchJsonWithAuth(
    uri + '?' + querystring.stringify(queryParams),
    {method: 'DELETE'}
  );
}

function fetchJsonWithAuth(uri, options = {}) {
  if (!('headers' in options)) {
    options.headers = {};
  }
  if (!('Accept') in options.headers) {
    options.headers.Accept = 'application/json';
  }
  return fetchWithAuth(uri, options)
    .then((response) => response.text())
    .then((text) => {
      try {
        return JSON.parse(text);
      } catch (error) {
        return text;
      }
    });
}

function fetchWithAuth(uri, options = {}) {
  if (!('headers' in options)) {
    options.headers = {};
  }
  options.headers['X-API-TOKEN'] = config.apiToken;
  return fetch(config.baseUrl + uri, options)
    .then(_throwOnBadStatusCode);
}

function _throwOnBadStatusCode(response) {
  if (!response.ok) {
    return response.text()
      .then((text) => {
        throw new Error(text);
      });
  } else {
    return response;
  }
}