in src/MessageId.cc [102:120]
Napi::Value MessageId::Deserialize(const Napi::CallbackInfo &info) {
Napi::Env env = info.Env();
if (!info[0].IsBuffer()) {
Napi::Error::New(env, "Expected buffer as first argument").ThrowAsJavaScriptException();
return env.Undefined();
}
Napi::Object obj = NewInstance(info[0]);
MessageId *msgId = Unwrap(obj);
Napi::Buffer<char> buf = info[0].As<Napi::Buffer<char>>();
char *data = buf.Data();
std::shared_ptr<pulsar_message_id_t> cMessageId(pulsar_message_id_deserialize(data, buf.Length()),
pulsar_message_id_free);
msgId->cMessageId = cMessageId;
return obj;
}