handleRequest

import bodyParser from 'body-parser';
import url from 'url';

const handleRequest = (method, path, cb) => {
  WebApp.rawConnectHandlers.use(path, (req, res, next) => {
    if (req.method !== method) {
      next();
      return;
    }

    const queryString = url.parse(req.url).query || '';
    const queryParams = { query: {} };
    queryString.split('&').forEach(pair => {
      queryParams.query[pair.split('=')[0]] = pair.split('=')[1];
    });

    Promise.resolve()
      .then(
        () =>
          new Promise(resolve => {
            bodyParser.urlencoded({ extended: false })(req, res, resolve);
          }),
      )
      .then(
        () =>
          new Promise(resolve => {
            bodyParser.json({ limit: '30mb' }).call(null, req, res, resolve);
          }),
      )
      .then(() => cb(queryParams, req, res, next))
      .catch(e => {
        console.error('Exception unhandled:', e.stack);
        next();
      });
  });
};

export default handleRequest;