refactor search query

app.js

@@ -34,7 +34,7 @@ app.get( '/', controllers.index() );
 app.get( '/suggest', sanitisers.suggest.middleware, controllers.suggest() );
 
 // search API
-app.get( '/search', sanitisers.search.middleware, middlewares.search.middleware, controllers.search() );
+app.get( '/search', sanitisers.search.middleware, controllers.search() );
 
 // reverse API
 app.get( '/reverse', sanitisers.reverse.middleware, controllers.search(undefined, require('./query/reverse')) );

query/search.js

@@ -1,46 +1,26 @@
-var logger = require('../src/logger');
 
-// Build pelias search query
+var logger = require('../src/logger'),
+    queries = require('geopipes-elasticsearch-backend').queries;
+
 function generate( params ){
 
-  var cmd = {
-    "query":{
-      "query_string" : {
-          "query": params.input,
-          "fields": ['name.default'],
-          "default_operator": 'OR'
-        }
-      },
-      "filter": {
-        "geo_bounding_box": {
-          "center_point": {
-            "bottom_left": {
-              "lat": params.bbox.bottom_left.lat,
-              "lon": params.bbox.bottom_left.lon
-            },
-            "top_right": {
-              "lat": params.bbox.top_right.lat,
-              "lon": params.bbox.top_right.lon
-            }
-          }
-        }
-      },
-      "sort" : [{
-          "_geo_distance" : {
-              "center_point" : {
-                "lat": params.lat, 
-                "lon": params.lon 
-              },
-              "order": 'asc',
-              "unit": 'km'
-          }
-      }],
-    "size": params.size
+  var centroid = {
+    lat: params.lat,
+    lon: params.lon
   };
 
-  // logger.log( 'cmd', JSON.stringify( cmd, null, 2 ) );
-  return cmd;
+  var query = queries.distance( centroid, { size: params.size } );
+
+  // add search condition to distance query
+  query.query.filtered.query = {
+    query_string : {
+      query: params.input,
+      fields: ['name.default'],
+      default_operator: 'OR'
+    }
+  };
 
+  return query;
 }
 
 module.exports = generate;

test/unit/query/search.js

@@ -27,41 +27,54 @@ module.exports.tests.query = function(test, common) {
       },
       layers: ['test']
     });
+
     var expected = {
-      query:{
-        query_string : {
-            query: 'test',
-            fields: ['name.default'],
-            default_operator: 'OR'
-          }
-        },
-        filter: {
-          geo_bounding_box: {
-            center_point: {
-              bottom_left: {
-                lat: 11.51053655297385,
-                lon: -103.16362455862279
-              },
-              top_right: {
-                lat: 47.472183447026154,
-                lon: -61.84881544137721
-              }
+      "query": {
+        "filtered": {
+          "query": {
+            "query_string": {
+              "query": "test",
+              "fields": [
+                "name.default"
+              ],
+              "default_operator": "OR"
             }
-          }
-        },
-        sort : [{
-            _geo_distance : {
-                center_point : {
-                  lat: 29.49136, 
-                  lon: -82.50622 
-                },
-                order: 'asc',
-                unit: 'km'
+          },
+          "filter": {
+            "bool": {
+              "must": [
+                {
+                  "geo_distance": {
+                    "distance": "50km",
+                    "distance_type": "plane",
+                    "optimize_bbox": "indexed",
+                    "_cache": true,
+                    "center_point": {
+                      "lat": "29.49",
+                      "lon": "-82.51"
+                    }
+                  }
+                }
+              ]
             }
-        }],
-      size: 10
+           }
+        }
+      },
+      "sort": [
+        {
+          "_geo_distance": {
+            "center_point": {
+              "lat": 29.49136,
+              "lon": -82.50622
+            },
+            "order": "asc",
+            "unit": "km"
+          }
+        }
+      ],
+      "size": 10
     };
-    
+
     t.deepEqual(query, expected, 'valid search query');
     t.end();
   });