api/controller/place.js

var service = { mget: require('../service/mget') };

function setup( backend ){

  // allow overriding of dependencies
  backend = backend || require('../src/backend');

  function controller( req, res, next ){

    // do not run controller when a request
    // validation error has occurred.
    if( req.errors && req.errors.length ){
      return next();
    }

    var query = req.clean.ids.map( function(id) {
      return {
        _index: 'pelias',
        /*
         * some gids aren't resolvable to a single type (ex: osmnode and osmway
         * both have source osm and layer venue), so expect an array of
         * possible values. */
        _type: id.types,
        _id: id.id
      };
    });

    service.mget( backend, query, function( err, docs ) {

      // error handler
      if( err ){
        req.errors.push( err.message ? err.message : err );
      }
      // set response data
      else {
        res.data = docs;
      }

      next();
    });
  }

  return controller;
}

module.exports = setup;