batch.js

var Parse = require('parse/node').Parse;

// These methods handle batch requests.
var batchPath = '/batch';

// Mounts a batch-handler onto a PromiseRouter.
function mountOnto(router) {
  router.route('POST', batchPath, (req) => {
    return handleBatch(router, req);
  });
}

// Returns a promise for a {response} object.
// TODO: pass along auth correctly
function handleBatch(router, req) {
  if (!req.body.requests instanceof Array) {
    throw new Parse.Error(Parse.Error.INVALID_JSON,
                          'requests must be an array');
  }

  // The batch paths are all from the root of our domain.
  // That means they include the API prefix, that the API is mounted
  // to. However, our promise router does not route the api prefix. So
  // we need to figure out the API prefix, so that we can strip it
  // from all the subrequests.
  if (!req.originalUrl.endsWith(batchPath)) {
    throw 'internal routing problem - expected url to end with batch';
  }
  var apiPrefixLength = req.originalUrl.length - batchPath.length;
  var apiPrefix = req.originalUrl.slice(0, apiPrefixLength);

  var promises = [];
  for (var restRequest of req.body.requests) {
    // The routablePath is the path minus the api prefix
    if (restRequest.path.slice(0, apiPrefixLength) != apiPrefix) {
      throw new Parse.Error(
        Parse.Error.INVALID_JSON,
        'cannot route batch path ' + restRequest.path);
    }
    var routablePath = restRequest.path.slice(apiPrefixLength);

    // Use the router to figure out what handler to use
    var match = router.match(restRequest.method, routablePath);
    if (!match) {
      throw new Parse.Error(
        Parse.Error.INVALID_JSON,
        'cannot route ' + restRequest.method + ' ' + routablePath);
    }

    // Construct a request that we can send to a handler
    var request = {
      body: restRequest.body,
      params: match.params,
      config: req.config,
      auth: req.auth
    };

    promises.push(match.handler(request).then((response) => {
      return {success: response.response};
    }, (error) => {
      return {error: {code: error.code, error: error.message}};
    }));
  }

  return Promise.all(promises).then((results) => {
    return {response: results};
  });
}

module.exports = {
  mountOnto: mountOnto
};