Add node.js bindings

.gitignore

@@ -2,3 +2,5 @@
 .idea/
 build
 .vscode
+node_modules
+dist

CMakeLists.txt

@@ -13,6 +13,7 @@ option(ENABLE_EXAMPLES "Enable examples" OFF)
 option(ENABLE_DOC "Build documentation" ON)
 option(ENABLE_CLIENT "Enable client application for parsing HawkTracer stream" ON)
 option(ENABLE_PYTHON_BINDINGS "Enable Python bindings (requires ENABLE_CLIENT=ON)" OFF)
+option(ENABLE_NODEJS_BINDINGS "Enable Node.js bindings (requires ENABLE_CLIENT=ON)" OFF)
 option(ENABLE_TCP_LISTENER "Enable TCP listener in a core library" ON)
 
 option(ENABLE_POSITION_INDEPENDENT_CODE "Enable position independent code of

bindings/CMakeLists.txt

@@ -1,3 +1,7 @@
 if(ENABLE_PYTHON_BINDINGS)
     add_subdirectory(python3)
 endif()
+
+if(ENABLE_NODEJS_BINDINGS)
+    add_subdirectory(nodejs)
+endif()

bindings/nodejs/CMakeLists.txt

@@ -0,0 +1,46 @@
+if (NOT ENABLE_CLIENT)
+    # Currently, we only support client bindings.
+    return()
+endif()
+
+# https://www.npmjs.com/package/cmake-js#general
+if (CMAKE_JS_SRC)
+    add_library(cmake_js STATIC ${CMAKE_JS_SRC})
+else()
+    add_library(cmake_js INTERFACE)
+endif()
+target_include_directories(cmake_js INTERFACE SYSTEM ${CMAKE_JS_INC})
+target_link_libraries(cmake_js ${CMAKE_JS_LIB})
+
+# https://www.npmjs.com/package/cmake-js#n-api-and-node-addon-api
+add_library(node_addon_api INTERFACE)
+if (NOT NODE_RUNTIME)
+    find_program(NODE_RUNTIME NAMES node HINTS /usr)
+endif()
+execute_process(COMMAND ${NODE_RUNTIME} -p "require('node-addon-api').include"
+        WORKING_DIRECTORY ${CMAKE_SOURCE_DIR}
+        OUTPUT_VARIABLE NODE_ADDON_API_DIR
+        )
+if (NOT NODE_ADDON_API_DIR)
+    message(FATAL_ERROR "Failed to find node-addon-api headers with node command \"${NODE_RUNTIME}\"")
+endif()
+string(REPLACE "\n" "" NODE_ADDON_API_DIR "${NODE_ADDON_API_DIR}")
+string(REPLACE "\"" "" NODE_ADDON_API_DIR "${NODE_ADDON_API_DIR}")
+target_include_directories(node_addon_api INTERFACE SYSTEM ${NODE_ADDON_API_DIR})
+target_link_libraries(node_addon_api INTERFACE cmake_js)
+
+# Supports Node version >= 12.11.0 https://nodejs.org/api/n-api.html#n_api_n_api_version_matrix
+target_compile_definitions(node_addon_api INTERFACE NAPI_VERSION=5)
+
+add_library(nodejs_bindings_client SHARED
+        hawktracer_client_nodejs.cpp
+        hawktracer_client_nodejs.hpp
+        client_context.cpp
+        client_context.hpp)
+set_target_properties(nodejs_bindings_client PROPERTIES PREFIX "" OUTPUT_NAME hawk_tracer_client SUFFIX .node)
+target_link_libraries(nodejs_bindings_client PUBLIC node_addon_api hawktracer_parser hawktracer_client_utils)
+
+# cmake-js specifies CMAKE_LIBRARY_OUTPUT_DIRECTORY.
+add_custom_target(make_directory_for_nodejs_bindings_client
+        COMMAND ${CMAKE_COMMAND} -E make_directory ${CMAKE_LIBRARY_OUTPUT_DIRECTORY})
+add_dependencies(nodejs_bindings_client make_directory_for_nodejs_bindings_client)

bindings/nodejs/client_context.cpp

@@ -0,0 +1,73 @@
+#include "client_context.hpp"
+
+#include "hawktracer/client_utils/stream_factory.hpp"
+#include "hawktracer/parser/make_unique.hpp"
+#include <iostream>
+#include <utility>
+
+namespace HawkTracer
+{
+namespace Nodejs
+{
+
+std::unique_ptr<ClientContext>
+ClientContext::create(const std::string& source, const std::string& map_files, EventCallback event_callback)
+{
+    std::unique_ptr<parser::Stream> stream = ClientUtils::make_stream_from_string(source);
+    if (!stream) {
+        return nullptr;
+    }
+
+    auto klass_register = parser::make_unique<parser::KlassRegister>();
+    auto reader = parser::make_unique<parser::ProtocolReader>(klass_register.get(), std::move(stream), true);
+    auto converter = parser::make_unique<ClientUtils::Converter>();
+    converter->set_tracepoint_map(map_files);
+
+    std::unique_ptr<ClientContext> context{new ClientContext(std::move(reader),
+                                                             std::move(klass_register),
+                                                             std::move(converter),
+                                                             std::move(event_callback))};
+    return context;
+}
+
+ClientContext::ClientContext(std::unique_ptr<parser::ProtocolReader> reader,
+                             std::unique_ptr<parser::KlassRegister> klass_register,
+                             std::unique_ptr<ClientUtils::Converter> converter,
+                             EventCallback event_callback)
+    : _klass_register(std::move(klass_register)), _reader(std::move(reader)), _label_mapper(std::move(converter)),
+      _event_callback(std::move(event_callback))
+{
+    _reader->register_events_listener(
+        [this](const parser::Event& event)
+        {
+            {
+                std::lock_guard<std::mutex> lock{_buffer_mutex};
+                _buffer.emplace_back(event, _label_mapper->get_label(event));  // Event is copied once.
+            }
+            _event_callback();
+        });
+
+    _reader->start();
+}
+
+ClientContext::~ClientContext()
+{
+    _reader->stop();
+
+    if (!_buffer.empty()) {
+        std::cerr << _buffer.size() << " events were not processed." << std::endl;
+    }
+}
+
+// This method can be called from any thread, while the event listener is called from reader thread.
+std::vector<LabeledEvent> ClientContext::take_events()
+{
+    std::lock_guard<std::mutex> lock{_buffer_mutex};
+    std::vector<LabeledEvent> new_buffer;
+    std::swap(new_buffer, _buffer);
+    return new_buffer;
+}
+
+} // namespace Nodejs
+} // namespace HawkTracer
+

bindings/nodejs/client_context.hpp

@@ -0,0 +1,56 @@
+#ifndef CLIENT_CONTEXT_HPP
+#define CLIENT_CONTEXT_HPP
+
+#include <string>
+
+#include "hawktracer/client_utils/converter.hpp"
+#include "hawktracer/parser/event.hpp"
+#include "hawktracer/parser/protocol_reader.hpp"
+#include "hawktracer/parser/klass_register.hpp"
+
+namespace HawkTracer
+{
+namespace Nodejs
+{
+
+class LabeledEvent: public parser::Event
+{
+public:
+    LabeledEvent(const Event& event, std::string label_string)
+        : Event(event), _label_string(std::move(label_string))
+    {}
+    std::string get_label_string() const { return _label_string; }
+private:
+    std::string _label_string;
+};
+
+class ClientContext
+{
+public:
+    using EventCallback = std::function<void()>;
+    static std::unique_ptr<ClientContext>
+    create(const std::string& source, const std::string& map_files, EventCallback event_callback);
+
+    ~ClientContext();
+
+    std::vector<LabeledEvent> take_events();
+
+private:
+    ClientContext(std::unique_ptr<parser::ProtocolReader> reader,
+                  std::unique_ptr<parser::KlassRegister> klass_register,
+                  std::unique_ptr<ClientUtils::Converter> converter,
+                  EventCallback event_callback);
+
+    const std::unique_ptr<const parser::KlassRegister> _klass_register; // needs to be destructed after _reader
+    const std::unique_ptr<parser::ProtocolReader> _reader;
+    const std::unique_ptr<ClientUtils::Converter> _label_mapper;
+    const EventCallback _event_callback;
+
+    std::vector<LabeledEvent> _buffer;
+    std::mutex _buffer_mutex;
+};
+
+} // namespace Nodejs
+} // namespace HawkTracer
+
+#endif //CLIENT_CONTEXT_HPP

bindings/nodejs/hawktracer_client_nodejs.cpp

@@ -0,0 +1,143 @@
+#include "hawktracer_client_nodejs.hpp"
+
+#include <iostream>
+
+namespace HawkTracer
+{
+namespace Nodejs
+{
+
+Object Client::init_bindings(const class Env& env, Object exports)
+{
+    HandleScope scope(env);
+
+    Function constructor = DefineClass(
+        env,
+        "HawkTracerClient",
+        {
+            InstanceMethod("start", &Client::start),
+            InstanceMethod("onEvents", &Client::set_on_events),
+            InstanceMethod("stop", &Client::stop)
+        });
+    Persistent(constructor).SuppressDestruct();
+    exports.Set("HawkTracerClient", constructor);
+    return exports;
+}
+
+Client::Client(const CallbackInfo& info)
+    : ObjectWrap<Client>(info)
+{
+    _source = info[0].As<String>();
+    _maps = info.Length() >= 2 && !info[1].IsUndefined() ? info[1].As<String>() : std::string{};
+}
+
+Value Client::start(const CallbackInfo& info)
+{
+    _state.start(
+        ClientContext::create(
+            _source,
+            _maps,
+            [this]()
+            {
+                _notify_new_event();
+            }));
+    if (_state.is_started()) {
+        Ref();
+    }
+    else {
+        throw Error::New(info.Env(), "Failed to start");
+    }
+    return Boolean::New(info.Env(), _state.is_started());
+}
+
+void Client::stop(const CallbackInfo&)
+{
+    _state.stop();
+    Reset();
+}
+
+void Client::set_on_events(const CallbackInfo& info)
+{
+    // maxQueueSize is set to 2 so that even though the first callback is already running there's room for a new callback.
+    // If 2 slots are already filled up, the second callback will pick up the new events with take_events(),
+    // in which case we can ignore napi_queue_full.
+    _state.set_function(ThreadSafeFunction::New(info.Env(),
+                                                info[0].As<Napi::Function>(),
+                                                "HawkTracerClientOnEvent",
+                                                2,
+                                                1));
+}
+
+// This method is called from reader thread, while all other methods are called from js main thread.
+void Client::_notify_new_event()
+{
+    auto status = _state.use_function(
+        [this](ThreadSafeFunction f)
+        {
+            return f.NonBlockingCall(this, &Client::_convert_and_callback);
+        });
+
+    if (status != napi_ok && status != napi_queue_full) {
+        std::cerr << "Request for callback failed with error code: " << status << std::endl;
+    }
+}
+
+Value Client::_convert_field_value(const class Env& env, const parser::Event::Value& value)
+{
+    switch (value.field->get_type_id()) {
+        case parser::FieldTypeId::UINT8:
+            return Number::New(env, value.value.f_UINT8);
+        case parser::FieldTypeId::INT8:
+            return Number::New(env, value.value.f_INT8);
+        case parser::FieldTypeId::UINT16:
+            return Number::New(env, value.value.f_UINT16);
+        case parser::FieldTypeId::INT16:
+            return Number::New(env, value.value.f_INT16);
+        case parser::FieldTypeId::UINT32:
+            return Number::New(env, value.value.f_UINT32);
+        case parser::FieldTypeId::INT32:
+            return Number::New(env, value.value.f_INT32);
+        case parser::FieldTypeId::UINT64:
+            return Number::New(env, value.value.f_UINT64);
+        case parser::FieldTypeId::INT64:
+            return Number::New(env, value.value.f_INT64);
+        case parser::FieldTypeId::STRING:
+            return String::New(env, value.value.f_STRING);
+        case parser::FieldTypeId::POINTER:
+            return String::New(env, "(pointer)");
+        default:
+            assert(0);
+    }
+}
+
+Object Client::_convert_event(const class Env& env, const LabeledEvent& event)
+{
+    auto o = Object::New(env);
+    for (const auto& it: event.get_values()) {
+        o.Set(it.first, _convert_field_value(env, it.second));
+    }
+    if (!event.get_label_string().empty()) {
+        o.Set("label", String::New(env, event.get_label_string()));
+    }
+    return o;
+}
+
+void Client::_convert_and_callback(const class Env& env, Function real_callback, Client* calling_object)
+{
+    std::vector<LabeledEvent> events = calling_object->_state.take_events();
+
+    if (!events.empty()) {
+        Array array = Array::New(env);
+        int i = 0;
+        std::for_each(events.cbegin(),
+                      events.cend(),
+                      [env, &array, &i](const LabeledEvent& e)
+                      {
+                          array[i++] = _convert_event(env, e);
+                      });
+        real_callback.Call({array});
+    }
+}
+
+} // namespace Nodejs
+} // namespace HawkTracer