ts_callback_utils.hpp

Go to the documentation of this file.

#pragma once
 
#include <chrono>
#include <functional>
#include <future>
#include <napi.h>
#include <optional>
#include <string>
#include <vector>
 
#include "barretenberg/vm2/common/aztec_types.hpp"
 
namespace bb::nodejs {
 
struct CallbackResults {
    std::promise<std::optional<std::vector<uint8_t>>> result_promise;
    std::string error_message;
};
 
std::string extract_error_from_napi_value(const Napi::CallbackInfo& cb_info);
 
Napi::Function create_buffer_resolve_handler(Napi::Env env, std::shared_ptr<CallbackResults> cb_results);
 
Napi::Function create_string_resolve_handler(Napi::Env env, std::shared_ptr<CallbackResults> cb_results);
 
Napi::Function create_void_resolve_handler(Napi::Env env, std::shared_ptr<CallbackResults> cb_results);
 
Napi::Function create_reject_handler(Napi::Env env, std::shared_ptr<CallbackResults> cb_results);
 
void attach_promise_handlers(Napi::Promise promise, Napi::Function resolve_handler, Napi::Function reject_handler);
 
template <typename T> std::vector<uint8_t> serialize_to_msgpack(const T& data);
 
template <typename T> T deserialize_from_msgpack(const std::vector<uint8_t>& data, const std::string& type_name);
 
std::optional<std::vector<uint8_t>> invoke_ts_callback_with_promise(
    const Napi::ThreadSafeFunction& callback,
    const std::string& operation_name,
    std::function<void(Napi::Env, Napi::Function, std::shared_ptr<CallbackResults>)> call_js_function,
    std::chrono::seconds timeout = std::chrono::seconds(30));
 
std::optional<std::vector<uint8_t>> invoke_single_string_callback(const Napi::ThreadSafeFunction& callback,
                                                                  const std::string& input_str,
                                                                  const std::string& operation_name);
 
std::optional<std::vector<uint8_t>> invoke_double_string_callback(const Napi::ThreadSafeFunction& callback,
                                                                  const std::string& input_str1,
                                                                  const std::string& input_str2,
                                                                  const std::string& operation_name);
 
void invoke_buffer_void_callback(const Napi::ThreadSafeFunction& callback,
                                 std::vector<uint8_t> buffer_data,
                                 const std::string& operation_name);
 
std::string ff_to_string(const bb::avm2::FF& value);
 
} // namespace bb::nodejs