commit 1869d2fa466385da537e49051e8bedf95b77ed09
author hrsakai <hsakai@yahoo-corp.jp> Thu Jul 18 10:56:55 2019 +0900
committer GitHub <noreply@github.com> Thu Jul 18 10:56:55 2019 +0900
tree fb00c45827c34112989e4283e71e23d2e4fc3eb1
parent 006871d205a4a3f8919a8537c4d1a4b10c45849b
parent 3e60959609c1b6ef72a35f8d98bb776148646fca

Merge pull request #37 from freeart/master

added serialize/deserialize methods to set custom startMessageId in createReader 

src/MessageId.cc

diff --git a/src/MessageId.cc b/src/MessageId.cc
index a0b520f..62cd1c8 100644
--- a/src/MessageId.cc
+++ b/src/MessageId.cc
@@ -31,7 +31,9 @@
                                         StaticMethod("earliest", &MessageId::Earliest, napi_static),
                                         StaticMethod("latest", &MessageId::Latest, napi_static),
                                         StaticMethod("finalize", &MessageId::Finalize, napi_static),
-                                        InstanceMethod("toString", &MessageId::ToString),
+                                        InstanceMethod("serialize", &MessageId::Serialize),
+                                        StaticMethod("deserialize", &MessageId::Deserialize, napi_static),
+                                        InstanceMethod("toString", &MessageId::ToString)
                                     });
 
   constructor = Napi::Persistent(func);
@@ -78,6 +80,33 @@
   return obj;
 }
 
+Napi::Value MessageId::Serialize(const Napi::CallbackInfo &info) {
+  Napi::Env env = info.Env();
+
+  int len;
+  void *ptr = pulsar_message_id_serialize(GetCMessageId(), &len);
+
+  return Napi::Buffer<char>::New(env, (char *)ptr, len);
+}
+
+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();
+  msgId->cMessageId = (pulsar_message_id_t *)pulsar_message_id_deserialize(data, buf.Length());
+
+  return obj;
+}
+
 pulsar_message_id_t *MessageId::GetCMessageId() { return this->cMessageId; }
 
 Napi::Value MessageId::ToString(const Napi::CallbackInfo &info) {

src/MessageId.h

diff --git a/src/MessageId.h b/src/MessageId.h
index 09c59e2..f65b1b4 100644
--- a/src/MessageId.h
+++ b/src/MessageId.h
@@ -31,6 +31,8 @@
   static Napi::Object NewInstanceFromMessage(const Napi::CallbackInfo &info, pulsar_message_t *cMessage);
   static Napi::Value Earliest(const Napi::CallbackInfo &info);
   static Napi::Value Latest(const Napi::CallbackInfo &info);
+  Napi::Value Serialize(const Napi::CallbackInfo &info);
+  static Napi::Value Deserialize(const Napi::CallbackInfo &info);
   static void Finalize(const Napi::CallbackInfo &info);
   MessageId(const Napi::CallbackInfo &info);
   ~MessageId();