@events/server/build/index.js

'use strict';

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

var _microBoom = require('micro-boom');

var _microrouter = require('microrouter');

var _microCors = require('micro-cors');

var _microCors2 = _interopRequireDefault(_microCors);

var _micro = require('micro');

var _micro2 = _interopRequireDefault(_micro);

var _redisClient = require('../build/redis-client');

var _commit = require('./commit');

var _commit2 = _interopRequireDefault(_commit);

var _subscribe2 = require('./subscribe');

var _subscribe3 = _interopRequireDefault(_subscribe2);

var _query = require('./query');

var _query2 = _interopRequireDefault(_query);

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

var cors = (0, _microCors2.default)();

exports.default = function (config) {
  var statusClient = (0, _redisClient.createClient)(config.redis, { debug: true });
  var committer = (0, _commit2.default)(config);

  var _subscribe = (0, _subscribe3.default)(config),
      subscriber = _subscribe.service,
      unsubscribe = _subscribe.unsubscribe;

  var querier = (0, _query2.default)(config);

  var service = (0, _microBoom.handleErrors)(cors((0, _microrouter.router)((0, _microrouter.get)('/subscribe', subscriber), (0, _microrouter.post)('/commit', committer), (0, _microrouter.get)('/query', querier), function () {
    throw (0, _microBoom.createError)(404);
  })), config.debug);

  var server = (0, _micro2.default)(service);

  server.on('close', unsubscribe);

  return server;
};