var Timeout = require('node-timeout'); var request = require('request'); module.exports = function () { this.paramsToString = (params) => { var paramString = ''; if (params.coordinates !== undefined && params.output !== undefined) { paramString = params.coordinates.join(';') + '.' + params.output; delete params.coordinates; delete params.output; } if (Object.keys(params).length) { paramString += '?' + Object.keys(params).map(k => k + '=' + params[k]).join('&'); } return paramString; }; this.sendRequest = (baseUri, parameters, callback) => { var limit = Timeout(this.OSRM_TIMEOUT, { err: { statusCode: 408 } }); var runRequest = (cb) => { var params = this.paramsToString(parameters); this.query = baseUri + (params.length ? '/' + params : ''); var options = this.httpMethod === 'POST' ? { method: 'POST', body: params, url: baseUri } : this.query; request(options, (err, res, body) => { if (err && err.code === 'ECONNREFUSED') { throw new Error('*** osrm-routed is not running.'); } else if (err && err.statusCode === 408) { throw new Error(); } return cb(err, res, body); }); }; runRequest(limit((err, res, body) => { if (err) { if (err.statusCode === 408) return callback(this.RoutedError('*** osrm-routed did not respond')); else if (err.code === 'ECONNREFUSED') return callback(this.RoutedError('*** osrm-routed is not running')); } return callback(err, res, body); })); }; };