Merges node-osrm into repo.

Author: daniel-j-h

.gitignore

@@ -47,6 +47,7 @@ Thumbs.db
 /build/
 /example/build/
 /test/data/monaco*
+/test/bindings/node/data/berlin*
 /cmake/postinst
 
 # Eclipse related files #
@@ -96,4 +97,7 @@ node_modules
 *.swp
 
 # local lua debugging file
-debug.lua
+debug.lua
+
+# node-osrm artifacts
+lib/binding

.npmignore

@@ -0,0 +1,10 @@
+*
+!README.md
+!CHANGELOG.md
+!CONTRIBUTING.MD
+!LICENCE.TXT
+!package.json
+!example
+!lib/*.js
+!profiles/*
+!profiles/lib/*

CMakeLists.txt

@@ -24,6 +24,7 @@ option(ENABLE_SANITIZER "Use memory sanitizer for Debug build" OFF)
 option(ENABLE_LTO "Use LTO if available" OFF)
 option(ENABLE_FUZZING "Fuzz testing using LLVM's libFuzzer" OFF)
 option(ENABLE_GOLD_LINKER "Use GNU gold linker if available" ON)
+option(ENABLE_NODE_BINDINGS "Build NodeJs bindings" OFF)
 
 list(APPEND CMAKE_MODULE_PATH "${CMAKE_CURRENT_SOURCE_DIR}/cmake")
 
@@ -733,6 +734,11 @@ add_custom_target(uninstall
 add_subdirectory(unit_tests)
 add_subdirectory(src/benchmarks)
 
+if (ENABLE_NODE_BINDINGS)
+  add_subdirectory(src/bindings/node)
+endif()
+
+
 if (ENABLE_FUZZING)
   # Requires libosrm being built with sanitizers; make configurable and default to ubsan
   set(FUZZ_SANITIZER "undefined" CACHE STRING "Sanitizer to be used for Fuzz testing")

example/example.js

@@ -0,0 +1,32 @@
+process.env.UV_THREADPOOL_SIZE = Math.ceil(require('os').cpus().length * 1.5);
+
+var express = require('express');
+var OSRM = require('..');
+var path = require('path');
+
+var app = express();
+var osrm = new OSRM(path.join(__dirname,"../test/data/monaco.osrm"));
+
+// Accepts a query like:
+// http://localhost:8888?start=13.438640,52.519930&end=13.415852,52.513191
+app.get('/', function(req, res) {
+    if (!req.query.start || !req.query.end) {
+        return res.json({"error":"invalid start and end query"});
+    }
+    var coordinates = [];
+    var start = req.query.start.split(',');
+    coordinates.push([+start[0],+start[1]]);
+    var end = req.query.end.split(',');
+    coordinates.push([+end[0],+end[1]]);
+    var query = {
+        coordinates: coordinates,
+        alternateRoute: req.query.alternatives !== 'false'
+    };
+    osrm.route(query, function(err, result) {
+        if (err) return res.json({"error":err.message});
+        return res.json(result);
+    });
+});
+
+console.log('Listening on port: ' + 8888);
+app.listen(8888);

include/bindings/node/json_v8_renderer.hpp

@@ -0,0 +1,65 @@
+#ifndef OSRM_BINDINGS_NODE_JSON_V8_RENDERER_HPP
+#define OSRM_BINDINGS_NODE_JSON_V8_RENDERER_HPP
+
+#include "osrm/json_container.hpp"
+
+#include <nan.h>
+
+#include <functional>
+
+namespace node_osrm
+{
+
+struct V8Renderer
+{
+    explicit V8Renderer(v8::Local<v8::Value> &_out) : out(_out) {}
+
+    void operator()(const osrm::json::String &string) const
+    {
+        out = Nan::New(std::cref(string.value)).ToLocalChecked();
+    }
+
+    void operator()(const osrm::json::Number &number) const { out = Nan::New(number.value); }
+
+    void operator()(const osrm::json::Object &object) const
+    {
+        v8::Local<v8::Object> obj = Nan::New<v8::Object>();
+        for (const auto &keyValue : object.values)
+        {
+            v8::Local<v8::Value> child;
+            mapbox::util::apply_visitor(V8Renderer(child), keyValue.second);
+            obj->Set(Nan::New(keyValue.first).ToLocalChecked(), child);
+        }
+        out = obj;
+    }
+
+    void operator()(const osrm::json::Array &array) const
+    {
+        v8::Local<v8::Array> a = Nan::New<v8::Array>(array.values.size());
+        for (auto i = 0u; i < array.values.size(); ++i)
+        {
+            v8::Local<v8::Value> child;
+            mapbox::util::apply_visitor(V8Renderer(child), array.values[i]);
+            a->Set(i, child);
+        }
+        out = a;
+    }
+
+    void operator()(const osrm::json::True &) const { out = Nan::New(true); }
+
+    void operator()(const osrm::json::False &) const { out = Nan::New(false); }
+
+    void operator()(const osrm::json::Null &) const { out = Nan::Null(); }
+
+  private:
+    v8::Local<v8::Value> &out;
+};
+
+inline void renderToV8(v8::Local<v8::Value> &out, const osrm::json::Object &object)
+{
+    osrm::json::Value value = object;
+    mapbox::util::apply_visitor(V8Renderer(out), value);
+}
+}
+
+#endif // JSON_V8_RENDERER_HPP

include/bindings/node/node_osrm.hpp

@@ -0,0 +1,41 @@
+#ifndef OSRM_BINDINGS_NODE_HPP
+#define OSRM_BINDINGS_NODE_HPP
+
+#include "osrm/osrm_fwd.hpp"
+
+#include <nan.h>
+
+#include <memory>
+
+namespace node_osrm
+{
+
+struct Engine final : public Nan::ObjectWrap
+{
+    using Base = Nan::ObjectWrap;
+
+    static NAN_MODULE_INIT(Init);
+
+    static NAN_METHOD(New);
+
+    static NAN_METHOD(route);
+    static NAN_METHOD(nearest);
+    static NAN_METHOD(table);
+    static NAN_METHOD(tile);
+    static NAN_METHOD(match);
+    static NAN_METHOD(trip);
+
+    Engine(osrm::EngineConfig &config);
+
+    // Thread-safe singleton accessor
+    static Nan::Persistent<v8::Function> &constructor();
+
+    // Ref-counted OSRM alive even after shutdown until last callback is done
+    std::shared_ptr<osrm::OSRM> this_;
+};
+
+} // ns node_osrm
+
+NODE_MODULE(osrm, node_osrm::Engine::Init)
+
+#endif