api/helper/geojsonify.js

var GeoJSON = require('geojson');
var extent = require('geojson-extent');
var outputGenerator = require('./outputGenerator');
var logger = require('pelias-logger').get('api');


// Properties to be copied when details=true
var DETAILS_PROPS = [
  'housenumber',
  'street',
  'category',
  'postalcode',
  'country_a',
  'country',
  'region',
  'region_a',
  'county',
  'localadmin',
  'locality',
  'neighbourhood',
  'confidence',
  'distance'
];


var SOURCES = {
  'geoname': 'gn',
  'osmnode': 'osm',
  'osmway': 'osm',
  'admin0': 'qs',
  'admin1': 'qs',
  'admin2': 'qs',
  'neighborhood': 'qs',
  'locality': 'qs',
  'local_admin': 'qs',
  'osmaddress': 'osm',
  'openaddresses': 'oa'
};

function lookupSource(src) {
  return SOURCES.hasOwnProperty(src._type) ? SOURCES[src._type] : src._type;
}

function lookupLayer(src) {
  switch(src._type) {
    case 'osmnode':
    case 'osmway':
      return 'venue';
    case 'admin0':
      return 'country';
    case 'admin1':
      return 'region';
    case 'admin2':
      return 'county';
    case 'neighborhood':
      return 'neighbourhood';
    case 'locality':
      return 'locality';
    case 'local_admin':
      return 'localadmin';
    case 'osmaddress':
    case 'openaddresses':
      return 'address';
    case 'geoname':
      if (src.category && src.category.indexOf('admin') !== -1) {
        if (src.category.indexOf('admin:city') !== -1) { return 'locality'; }
        if (src.category.indexOf('admin:admin1') !== -1) { return 'region'; }
        if (src.category.indexOf('admin:admin2') !== -1) { return 'county'; }
        return 'neighbourhood'; // this could also be 'local_admin'
      }

      if (src.name) { return 'venue'; }
      if (src.address) { return 'address'; }
  }

  logger.warn('[geojsonify]: could not map _type ', src._type);

  return src._type;
}

function geojsonifyPlaces( docs, params ){

  var details = params ? params.details : {};
  details = details === true || details === 1;

  // flatten & expand data for geojson conversion
  var geodata = docs
    .map(geojsonifyPlace.bind(null, details))
    .filter( function( doc ){
      return !!doc;
    });

  // convert to geojson
  var geojson = GeoJSON.parse( geodata, { Point: ['lat', 'lng'] });

  // bounding box calculations
  computeBBox(geojson);

  return geojson;
}

function geojsonifyPlace(details, place) {

  // something went very wrong
  if( !place || !place.hasOwnProperty( 'center_point' ) ) {
    return warning('No doc or center_point property');
  }

  var geocoding = {};

  addMetaData(place, geocoding);
  addDetails(details, place, geocoding);
  addLabel(place, geocoding);

  var output = {};

  output.geocoding = geocoding;
  // map center_point for GeoJSON to work properly
  // these should not show up in the final feature properties
  output.lat = parseFloat(place.center_point.lat);
  output.lng = parseFloat(place.center_point.lon);

  return output;
}

/**
 * Add details properties when needed
 *
 * @param {boolean} details
 * @param {object} src
 * @param {object} dst
 */
function addDetails(details, src, dst) {
  if (details) {
    // map name
    if( !src.name || !src.name.default ) { return warning(src); }
    dst.name = src.name.default;

    copyProperties(src, DETAILS_PROPS, dst);
  }
}

/**
 * Add region-specific label string
 *
 * @param {object} src
 * @param {object} dst
 */
function addLabel(src, dst) {
  dst.label = outputGenerator(src);
}

/**
 * Compute bbox that encompasses all features in the result set.
 * Set bbox property on the geojson object.
 *
 * @param {object} geojson
 */
function computeBBox(geojson) {
  // @note: extent() sometimes throws Errors for unusual data
  // eg: https://github.com/pelias/pelias/issues/84
  try {
    var bbox = extent( geojson );
    if( !!bbox ){
      geojson.bbox = bbox;
    }
  } catch( e ){
    console.error( 'bbox error', e.message, e.stack );
    console.error( 'geojson', JSON.stringify( geojson, null, 2 ) );
  }
}

/**
 * Copy specified properties from source to dest.
 * Ignore missing properties.
 *
 * @param {object} source
 * @param {[]} props
 * @param {object} dst
 */
function copyProperties( source, props, dst ) {
  props.forEach( function ( prop ) {
    if ( source.hasOwnProperty( prop ) ) {
      dst[prop] = source[prop];
    }
  });
}

/**
 * Determine and set place id, type, and source
 *
 * @param {object} src
 * @param {object} dst
 */
function addMetaData(src, dst) {
  dst.id = src._id;
  dst.layer = lookupLayer(src);
  dst.source = lookupSource(src);
}

/**
 * emit a warning if the doc format is invalid
 *
 * @note: if you see this error, fix it ASAP!
 */
function warning( doc ) {
  console.error( 'error: invalid doc', __filename, doc);
  return false; // remove offending doc from results
}


module.exports.search = geojsonifyPlaces;