controller_clicks.js

//could look more like 


function _getGeoJson(req, res) {
  GeoJsonModel.findByOptions(req.params.lsad, req.query)
  .then(function success (stream) {
    if (req.query.asGeoJSON === true) {
      utils.streamApiDataAsGeoJson(res, stream);
    } else {
      utils.streamApiDataAsArray(res, stream);
    }
  })
  .fail(function error (msg) {
    utils.sendApiData(res, null, msg);
  });
}

idea.js

//we know we need something like...

{
  "query": {
    "filtered": {
      "query": {
        "field": {
          "action" : action
        }
      },
      "filter": {
        "and" : {
          "filters" : [
            {
              "term" : { "target" : Number(termId) }
            },
            {
              "term" : { "state_region.name" : parentLsad }
            }
          ],
          "_cache": true
        }
      },
      "boost": 1.2
    }
  },
  "facets": {
    "facet_result": {
      "terms": {
        "fields": [
          "county"
        ],
        "order": "count",
        "size": 100
      }
    }
  }
}

// queryBuilder is a given
// a filter fn could look like this.

  // "filter": {
  //   "and" : {
  //     "filters" : [
  //       {
  //         "term" : { "target" : Number(termId) }
  //       },
  //       {
  //         "term" : { "state_region.name" : parentLsad }
  //       }
  //     ],
  //     "_cache": true
  //   }
  // },
function _addFilters(ob, params) {
  var obClone = _.clone(ob),
      filtersOb = {
        filter: {
          and: {
            filters: []
          }
        }
      },
      frag;

  if (params.filters) {
    params.filters.forEach(function(filter) {
      frag = {term: {target: filter}}
      filtersOb.filter.and.filters.push(frag)
    })
  }

  obClone.query.filters = filterOb;
  return obClone;
}

model_clicks.js

Clicks.getActionShowsByLocation = function getActionShowsByLocation(action, lat, lng) {
  var deferred = Q.defer();

  elastic
  .index('clicks')
  .find({
      "query": {
        "filtered" : {
          "query" : {
            "field" : {
              "action" : action
            }
          },
          "filter" : {
            "geo_distance" : {
              "distance" : "50miles",
              "pin.location" : [Number(lat), Number(lng)]
            }
          }
        }
      },
      "facets" : {
        "facet_result": {
          "terms": {
            "fields": ["target"],
            "order": "count",
            "size": 15
          }
        }
      }

    },
    function(err, data) { _resolveOrReject(err, data, action, deferred); });
  return deferred.promise;
};

//could be

Clicks.getActionShowsByLocation = function getActionShowsByLocation(action, lat, lng) {
  var deferred = Q.defer(),
      // query = queryBuilderStuff....;

  //
  //
  //
  //
  //
  //
  
  try {
    elastic
    .index('clicks')
    .find(query, function(err, data) { _resolveOrReject(err, data, action, deferred); });
  } catch(err) deferred.reject(err);

  return deferred.promise;
};