osrm-backend/features/support/http.js

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);
        }));
    };
};