mirror of https://github.com/pelias/api.git
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
221 lines
6.6 KiB
221 lines
6.6 KiB
8 years ago
|
/* eslint-disable */
|
||
|
|
|
||
|
|
//
|
||
|
|
// 'use strict';
|
||
|
|
//
|
||
|
|
// const peliasQuery = require('pelias-query');
|
||
|
|
// const defaults = require('./search_defaults');
|
||
|
|
// const textParser = require('./text_parser');
|
||
|
|
// const check = require('check-types');
|
||
|
|
// const logger = require('pelias-logger').get('api');
|
||
|
|
//
|
||
|
|
// //------------------------------
|
||
|
|
// // general-purpose search query
|
||
|
|
// //------------------------------
|
||
|
|
// var fallbackQuery = new peliasQuery.layout.FallbackQuery();
|
||
|
|
//
|
||
|
|
// // scoring boost
|
||
|
|
// fallbackQuery.score( peliasQuery.view.focus_only_function( peliasQuery.view.phrase ) );
|
||
|
|
// fallbackQuery.score( peliasQuery.view.popularity_only_function );
|
||
|
|
// fallbackQuery.score( peliasQuery.view.population_only_function );
|
||
|
|
// // --------------------------------
|
||
|
|
//
|
||
|
|
// // non-scoring hard filters
|
||
|
|
// fallbackQuery.filter( peliasQuery.view.boundary_country );
|
||
|
|
// fallbackQuery.filter( peliasQuery.view.boundary_circle );
|
||
|
|
// fallbackQuery.filter( peliasQuery.view.boundary_rect );
|
||
|
|
// fallbackQuery.filter( peliasQuery.view.sources );
|
||
|
|
// fallbackQuery.filter( peliasQuery.view.layers );
|
||
|
|
// fallbackQuery.filter( peliasQuery.view.categories );
|
||
|
|
// // --------------------------------
|
||
|
|
//
|
||
|
|
// /**
|
||
|
|
// map request variables to query variables for all inputs
|
||
|
|
// provided by this HTTP request.
|
||
|
|
// **/
|
||
|
|
// function generateQuery( clean ){
|
||
|
|
//
|
||
|
|
// console.log("I am in intersections query");
|
||
|
|
//
|
||
|
|
// const vs = new peliasQuery.Vars( defaults );
|
||
|
|
//
|
||
|
|
// let logStr = '[query:search] [parser:intersections_parser] ';
|
||
|
|
//
|
||
|
|
// // input text
|
||
|
|
// vs.var( 'input:name', clean.text );
|
||
|
|
//
|
||
|
|
// // sources
|
||
|
|
// if( check.array(clean.sources) && clean.sources.length ) {
|
||
|
|
// vs.var( 'sources', clean.sources);
|
||
|
|
// logStr += '[param:sources] ';
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// // layers
|
||
|
|
// if( check.array(clean.layers) && clean.layers.length ) {
|
||
|
|
// vs.var('layers', clean.layers);
|
||
|
|
// logStr += '[param:layers] ';
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// // categories
|
||
|
|
// if (clean.categories) {
|
||
|
|
// vs.var('input:categories', clean.categories);
|
||
|
|
// logStr += '[param:categories] ';
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// // size
|
||
|
|
// if( clean.querySize ) {
|
||
|
|
// vs.var( 'size', clean.querySize );
|
||
|
|
// logStr += '[param:querySize] ';
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// // focus point
|
||
|
|
// if( check.number(clean['focus.point.lat']) &&
|
||
|
|
// check.number(clean['focus.point.lon']) ){
|
||
|
|
// vs.set({
|
||
|
|
// 'focus:point:lat': clean['focus.point.lat'],
|
||
|
|
// 'focus:point:lon': clean['focus.point.lon']
|
||
|
|
// });
|
||
|
|
// logStr += '[param:focus_point] ';
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// // boundary rect
|
||
|
|
// if( check.number(clean['boundary.rect.min_lat']) &&
|
||
|
|
// check.number(clean['boundary.rect.max_lat']) &&
|
||
|
|
// check.number(clean['boundary.rect.min_lon']) &&
|
||
|
|
// check.number(clean['boundary.rect.max_lon']) ){
|
||
|
|
// vs.set({
|
||
|
|
// 'boundary:rect:top': clean['boundary.rect.max_lat'],
|
||
|
|
// 'boundary:rect:right': clean['boundary.rect.max_lon'],
|
||
|
|
// 'boundary:rect:bottom': clean['boundary.rect.min_lat'],
|
||
|
|
// 'boundary:rect:left': clean['boundary.rect.min_lon']
|
||
|
|
// });
|
||
|
|
// logStr += '[param:boundary_rect] ';
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// // boundary circle
|
||
|
|
// // @todo: change these to the correct request variable names
|
||
|
|
// if( check.number(clean['boundary.circle.lat']) &&
|
||
|
|
// check.number(clean['boundary.circle.lon']) ){
|
||
|
|
// vs.set({
|
||
|
|
// 'boundary:circle:lat': clean['boundary.circle.lat'],
|
||
|
|
// 'boundary:circle:lon': clean['boundary.circle.lon']
|
||
|
|
// });
|
||
|
|
//
|
||
|
|
// if( check.number(clean['boundary.circle.radius']) ){
|
||
|
|
// vs.set({
|
||
|
|
// 'boundary:circle:radius': Math.round( clean['boundary.circle.radius'] ) + 'km'
|
||
|
|
// });
|
||
|
|
// }
|
||
|
|
// logStr += '[param:boundary_circle] ';
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// // boundary country
|
||
|
|
// if( check.string(clean['boundary.country']) ){
|
||
|
|
// vs.set({
|
||
|
|
// 'boundary:country': clean['boundary.country']
|
||
|
|
// });
|
||
|
|
// logStr += '[param:boundary_country] ';
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// // run the address parser
|
||
|
|
// if( clean.parsed_text ){
|
||
|
|
// textParser( clean.parsed_text, vs );
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// var q = getQuery(vs);
|
||
|
|
//
|
||
|
|
// //console.log(JSON.stringify(q, null, 2));
|
||
|
|
//
|
||
|
|
// if (q !== undefined) {
|
||
|
|
// logger.info(logStr);
|
||
|
|
// }
|
||
|
|
// else {
|
||
|
|
// logger.info('[parser:intersections] query type not supported');
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// return q;
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// function getQuery(vs) {
|
||
|
|
//
|
||
|
|
// logger.info(`[query:search] [search_input_type:${determineQueryType(vs)}]`);
|
||
|
|
//
|
||
|
|
// if (hasStreet(vs) || isPostalCodeOnly(vs)) {
|
||
|
|
// return {
|
||
|
|
// type: 'fallback',
|
||
|
|
// body: fallbackQuery.render(vs)
|
||
|
|
// };
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// // returning undefined is a signal to a later step that the addressit-parsed
|
||
|
|
// // query should be queried for
|
||
|
|
// return undefined;
|
||
|
|
//
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// function determineQueryType(vs) {
|
||
|
|
// if (vs.isset('input:housenumber') && vs.isset('input:street')) {
|
||
|
|
// return 'address';
|
||
|
|
// }
|
||
|
|
// else if (vs.isset('input:street')) {
|
||
|
|
// return 'street';
|
||
|
|
// }
|
||
|
|
// else if (vs.isset('input:street1') || vs.isset('input:street2')) {
|
||
|
|
// return 'intersection';
|
||
|
|
// }
|
||
|
|
// else if (vs.isset('input:query')) {
|
||
|
|
// return 'venue';
|
||
|
|
// }
|
||
|
|
// else if (['neighbourhood', 'borough', 'postcode', 'county', 'region','country'].some(
|
||
|
|
// layer => vs.isset(`input:${layer}`)
|
||
|
|
// )) {
|
||
|
|
// return 'admin';
|
||
|
|
// }
|
||
|
|
// return 'other';
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// function hasStreet(vs) {
|
||
|
|
// return vs.isset('input:street') || vs.isset('input:street1') || vs.isset('input:street2');
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// function isPostalCodeOnly(vs) {
|
||
|
|
// var isSet = layer => vs.isset(`input:${layer}`);
|
||
|
|
//
|
||
|
|
// var allowedFields = ['postcode'];
|
||
|
|
// var disallowedFields = ['query', 'category', 'housenumber', 'street',
|
||
|
|
// 'neighbourhood', 'borough', 'county', 'region', 'country'];
|
||
|
|
//
|
||
|
|
// return allowedFields.every(isSet) &&
|
||
|
|
// !disallowedFields.some(isSet);
|
||
|
|
//
|
||
|
|
// }
|
||
|
|
|
||
|
|
function generateQuery(clean) {
|
||
|
|
return {
|
||
|
|
type: 'fallback',
|
||
|
|
body: {
|
||
|
|
'size': 2,
|
||
|
|
'query': {
|
||
|
|
'or': [{
|
||
|
|
'bool' : {
|
||
|
|
'must': [
|
||
|
|
{ 'match': { 'layer' : 'intersection'} },
|
||
|
|
{ 'match': { 'address_parts.street1' : clean.parsed_text.street1} },
|
||
|
|
{ 'match': { 'address_parts.street2' : clean.parsed_text.street2} }
|
||
|
|
]
|
||
|
|
} }, {
|
||
|
|
'bool' : {
|
||
|
|
'must': [
|
||
|
|
{ 'match': { 'layer' : 'intersection'} },
|
||
|
|
{ 'match': { 'address_parts.street1' : clean.parsed_text.street2} },
|
||
|
|
{ 'match': { 'address_parts.street2' : clean.parsed_text.street1} }
|
||
|
|
]
|
||
|
|
} }
|
||
|
|
]
|
||
|
|
}
|
||
|
|
}
|
||
|
|
};
|
||
|
|
}
|
||
|
|
|
||
|
|
module.exports = generateQuery;
|