FM / step_definitions

/srv/osrm/osrm-backend/features/step_definitions/

/srv/osrm/osrm-backend/features/step_definitions

Name	Size	Mode	Actions
data.js	11464	0644	edit dl rm
distance_matrix.js	6524	0644	edit dl rm
matching.js	12093	0644	edit dl rm
nearest.js	4339	0644	edit dl rm
options.js	3554	0644	edit dl rm
requests.js	1781	0644	edit dl rm
routability.js	9203	0644	edit dl rm
routing.js	544	0644	edit dl rm
timestamp.js	430	0644	edit dl rm
trip.js	7733	0644	edit dl rm

Edit: /srv/osrm/osrm-backend/features/step_definitions/data.js (11464B)

'use strict';

var util = require('util');
var path = require('path');
var fs = require('fs');
var d3 = require('d3-queue');
var OSM = require('../lib/osm');

module.exports = function () {
    this.Given(/^the profile "([^"]*)"$/, (profile, callback) => {
        this.profile = this.OSRM_PROFILE || profile;
        this.profileFile = path.join(this.PROFILES_PATH, this.profile + '.lua');
        callback();
    });

this.Given(/^the extract extra arguments "(.*?)"$/, (args, callback) => {
        this.extractArgs = this.expandOptions(args);
        callback();
    });

this.Given(/^the contract extra arguments "(.*?)"$/, (args, callback) => {
        this.contractArgs = this.expandOptions(args);
        callback();
    });

this.Given(/^the partition extra arguments "(.*?)"$/, (args, callback) => {
        this.partitionArgs = this.expandOptions(args);
        callback();
    });

this.Given(/^the customize extra arguments "(.*?)"$/, (args, callback) => {
        this.customizeArgs = this.expandOptions(args);
        callback();
    });

this.Given(/^a grid size of ([0-9.]+) meters$/, (meters, callback) => {
        this.setGridSize(meters);
        callback();
    });

this.Given(/^the origin ([-+]?[0-9]*\.?[0-9]+),([-+]?[0-9]*\.?[0-9]+)$/, (lon, lat, callback) => {
        this.setOrigin([parseFloat(lon), parseFloat(lat)]);
        callback();
    });

this.Given(/^the shortcuts$/, (table, callback) => {
        let q = d3.queue();

let addShortcut = (row, cb) => {
            this.shortcutsHash[row.key] = row.value;
            cb();
        };

table.hashes().forEach((row) => {
            q.defer(addShortcut, row);
        });

q.awaitAll(callback);
    });

this.Given(/^the node map$/, (docstring, callback) => {
        var q = d3.queue();

docstring.split(/\n/).forEach( (row,ri) => {
            row.split('').forEach( (cell,ci) => {
                if( cell.match(/[a-z0-9]/) ) {
                    q.defer(addNode, cell, ri, ci*0.5);
                }
            });
        });

q.awaitAll(callback);
    });

this.Given(/^the node locations$/, (table, callback) => {
        let q = d3.queue();

let addNodeLocations = (row, cb) => {
            let name = row.node;
            if (this.findNodeByName(name)) throw new Error(util.format('*** duplicate node %s', name));

if (name.match(/[a-z]/)) {
                let id = row.id && parseInt(row.id);
                this.addOSMNode(name, row.lon, row.lat, id);
            } else {
                this.addLocation(name, row.lon, row.lat);
            }

cb();
        };

table.hashes().forEach((row) => q.defer(addNodeLocations, row));

q.awaitAll(callback);
    });

this.Given(/^the nodes$/, (table, callback) => {
        let q = d3.queue();

table.hashes().forEach((row) => q.defer(addNode, row));

q.awaitAll(callback);
    });

this.Given(/^the ways( with locations)?$/, (add_locations, table, callback) => {
        if (this.osm_str) throw new Error('*** Map data already defined - did you pass an input file in this scenario?');

let q = d3.queue();

let addWay = (row, cb) => {
            let way = new OSM.Way(this.makeOSMId(), this.OSM_USER, this.OSM_TIMESTAMP, this.OSM_UID, !!add_locations);

let nodes = row.nodes;
            if (this.nameWayHash.nodes) throw new Error(util.format('*** duplicate way %s', nodes));

for (let i=0; i<nodes.length; i++) {
                let c = nodes[i];
                if (!c.match(/[a-z]/)) throw new Error(util.format('*** ways can only use names a-z (%s)', c));
                let node = this.findNodeByName(c);
                if (!node) throw new Error(util.format('*** unknown node %s', c));
                way.addNode(node);
            }

let tags = {
                highway: 'primary'
            };

for (let key in row) {
                tags[key] = row[key];
            }

delete tags.nodes;

if (row.highway === '(nil)') delete tags.highway;

if (row.name === undefined)
                tags.name = nodes;
            else if (row.name === '""' || row.name === "''") // eslint-disable-line quotes
                tags.name = '';
            else if (row.name === '' || row.name === '(nil)')
                delete tags.name;
            else
                tags.name = row.name;

way.setTags(tags);
            this.OSMDB.addWay(way);
            this.nameWayHash[nodes] = way;
            cb();
        };

table.hashes().forEach((row) => q.defer(addWay, row));

q.awaitAll(callback);
    });

this.Given(/^the relations$/, (table, callback) => {
        if (this.osm_str) throw new Error('*** Map data already defined - did you pass an input file in this scenario?');

let q = d3.queue();

let addRelation = (headers, row, cb) => {
            let relation = new OSM.Relation(this.makeOSMId(), this.OSM_USER, this.OSM_TIMESTAMP, this.OSM_UID);

var name = null;
            for (let index in row) {

if (name) {
                this.nameRelationHash[name] = relation;
            }

this.OSMDB.addRelation(relation);

cb();
        };

var headers = table.raw()[0];
        table.rows().forEach((row) => q.defer(addRelation, headers, row));

q.awaitAll(callback);
    });

this.Given(/^the input file ([^"]*)$/, (file, callback) => {
        if (path.extname(file) !== '.osm') throw new Error('*** Input file must be in .osm format');
        fs.readFile(file, 'utf8', (err, data) => {
            if (!err) this.osm_str = data.toString();
            callback(err);
        });
    });

this.Given(/^the raster source$/, (data, callback) => {
        // TODO: Don't overwrite if it exists
        fs.writeFile(this.rasterCacheFile, data, callback);
        // we need this to pass it to the profiles
        this.environment = Object.assign({OSRM_RASTER_SOURCE: this.rasterCacheFile}, this.environment);
    });

this.Given(/^the speed file$/, (data, callback) => {
        // TODO: Don't overwrite if it exists
        fs.writeFile(this.speedsCacheFile, data, callback);
    });

this.Given(/^the turn penalty file$/, (data, callback) => {
        // TODO: Don't overwrite if it exists
        fs.writeFile(this.penaltiesCacheFile, data, callback);
    });

this.Given(/^the profile file(?: "([^"]*)" initialized with)?$/, (profile, data, callback) => {
        const lua_profiles_path = this.PROFILES_PATH.split(path.sep).join('/');
        let text = 'package.path = "' + lua_profiles_path + '/?.lua;" .. package.path\n';
        if (profile == null) {
            text += data + '\n';
        } else {
            text += 'local functions = require("' + profile + '")\n';
            text += 'functions.setup_parent = functions.setup\n';
            text += 'functions.setup = function()\n';
            text += 'local profile = functions.setup_parent()\n';
            text += data + '\n';
            text += 'return profile\n';
            text += 'end\n';
            text += 'return functions\n';
        }
        this.profileFile = this.profileCacheFile;
        // TODO: Don't overwrite if it exists
        fs.writeFile(this.profileCacheFile, text, callback);
    });

this.Given(/^the data has been saved to disk$/, (callback) => {
        this.writeAndLinkOSM(callback);
    });

this.Given(/^the data has been (extract|contract|partition|customiz)ed$/, (step, callback) => {
        this.reprocess(callback);
    });

this.Given(/^osrm-routed is stopped$/, (callback) => {
        this.OSRMLoader.shutdown(callback);
    });

this.Given(/^data is loaded directly/, (callback) => {
        this.osrmLoader.setLoadMethod('directly');
        callback();
    });

this.Given(/^data is loaded with datastore$/, (callback) => {
        this.osrmLoader.setLoadMethod('datastore');
        callback();
    });

this.Given(/^the HTTP method "([^"]*)"$/, (method, callback) => {
        this.httpMethod = method;
        callback();
    });
};

cmd: