msgpack_client_async.hpp

Go to the documentation of this file.

#pragma once
 
#include "barretenberg/ipc/ipc_client.hpp"
#include "napi.h"
#include <atomic>
#include <mutex>
#include <thread>
 
namespace bb::nodejs::msgpack_client {
 
class MsgpackClientAsync : public Napi::ObjectWrap<MsgpackClientAsync> {
  public:
    MsgpackClientAsync(const Napi::CallbackInfo& info);
 
    Napi::Value setResponseCallback(const Napi::CallbackInfo& info);
 
    Napi::Value call(const Napi::CallbackInfo& info);
 
    Napi::Value acquire(const Napi::CallbackInfo& info);
 
    Napi::Value release(const Napi::CallbackInfo& info);
 
    static Napi::Function get_class(Napi::Env env);
 
  private:
    void poll_responses();
 
    // IPC client for shared memory communication
    std::unique_ptr<bb::ipc::IpcClient> client_;
 
    // Background polling thread (detached - will be cleaned up by OS on process exit)
    std::thread poll_thread_;
 
    // Mutex protecting TSFN access from multiple threads
    std::mutex tsfn_mutex_;
 
    // JavaScript callback stored for lazy TSFN creation
    Napi::FunctionReference js_callback_;
 
    // ThreadSafeFunction for invoking JavaScript callback from background thread
    // Created lazily when first needed, destroyed when no longer needed
    Napi::ThreadSafeFunction tsfn_;
 
    // Reference count for TSFN lifecycle management
    // When 0→1: create TSFN, when 1→0: destroy TSFN
    int ref_count_ = 0;
};
 
} // namespace bb::nodejs::msgpack_client