api/query/search.js

var queries = require('geopipes-elasticsearch-backend').queries,
    sort = require('../query/sort');

function generate( params ){
  var centroid = null;

  if ( params.lat && params.lon ){
    centroid = {
      lat: params.lat,
      lon: params.lon
    };
  } 
  
  var query = queries.distance( centroid, { size: params.size } );
  
  if (params.bbox) {
    query = queries.bbox ( centroid, { size: params.size, bbox: params.bbox } );
  }

  // add search condition to filtered query
  query.query.filtered.query = {
    'bool': {
      'must': [{ 
        'match': {
          'name.default': params.input
        }
      }]
    }
  };

  // should query contitions
  query.query.filtered.query.bool.should = [];

  if (params.input_admin) {
    var admin_fields = ['admin0', 'admin1', 'admin1_abbr', 'admin2', 'alpha3'];

    admin_fields.forEach(function(admin_field) {
      var match = {};
      match[admin_field] = params.input_admin;
      query.query.filtered.query.bool.should.push({
        'match': match
      });
    });
  }

  // add category mapping
  if (params.categories) {
    query.query.filtered.filter.bool.must.push({
      terms: { category: params.categories }
    });
  }

  // add phrase matching query
  // note: this is required for shingle/phrase matching
  query.query.filtered.query.bool.should.push({
    'match': {
      'phrase.default': params.input
    }
  });

  query.sort = query.sort.concat( sort( params ) );

  return query;
}

module.exports = generate;