@mainframe/bot-sdk/lib/context.js

'use strict';

Object.defineProperty(exports, "__esModule", {
  value: true
});
exports.createContext = undefined;

var _nodeFetch = require('node-fetch');

var _nodeFetch2 = _interopRequireDefault(_nodeFetch);

var _log = require('./log');

var _log2 = _interopRequireDefault(_log);

function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }

const createContext = exports.createContext = config => {
  const callMainframe = (endpoint, data = {}) => {
    const url = config.mainframe_url + endpoint;
    (0, _log2.default)('call %s', url);
    return (0, _nodeFetch2.default)(url, {
      body: JSON.stringify(data),
      method: 'post',
      headers: {
        Authorization: `Mainframe-Bot ${config.mainframe_secret}`,
        'Content-Type': 'application/json'
      }
    }).then(res => {
      if (res.ok) {
        return res.status === 204 ? null : res.json();
      }

      const error = new Error(res.statusText);
      error.status = res.status;
      error.enpoint = endpoint;
      error.data = data;

      if (res.headers.get('Content-Type').indexOf('application/json') !== -1) {
        return res.json().then(json => {
          error.response = json;
          throw error;
        });
      } else {
        return res.text().then(text => {
          error.response = text;
          throw error;
        });
      }
    });
  };

  const sendMessage = payload => callMainframe('/send_message', payload);

  const setupSubscription = payload => callMainframe('/setup_subscription', payload);

  const editSubscription = payload => callMainframe('/edit_subscription', payload);

  return {
    config,
    callMainframe,
    sendMessage,
    setupSubscription,
    editSubscription
  };
};