api/controller/search.js

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

function setup( backend, query ){

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

  function controller( req, res, next ){

    // backend command
    var cmd = {
      index: 'pelias',
      searchType: 'dfs_query_then_fetch',
      body: query( req.clean )
    };

    if (req.clean.types && req.clean.types.from_layers) {
      cmd.type = req.clean.types.from_layers;
    }

    // set type if input suggests targeting a layer(s)
    if (req.clean.default_layers_set && req.clean.parsed_input) {
      cmd.type = req.clean.parsed_input.target_layer || cmd.type;
    }

    // query backend
    service.search( backend, cmd, function( err, docs ){

      // error handler
      if( err ){ return next( err ); }

      req.results = {
        data: docs
      };

      next();
    });

  }

  return controller;
}

module.exports = setup;