hdiff() ok

Author: sisong

.gitignore

@@ -104,3 +104,4 @@ dist
 # TernJS port file
 .tern-port
 .idea
+.vscode/

binding.gyp

@@ -6,7 +6,6 @@
         "src/main.cc",
         "src/hdiff.cpp",
         "HDiffPatch/libHDiffPatch/HPatch/patch.c",
-        "HDiffPatch/file_for_patch.c",
         "HDiffPatch/libHDiffPatch/HDiff/diff.cpp",
         "HDiffPatch/libHDiffPatch/HDiff/private_diff/bytes_rle.cpp",
         "HDiffPatch/libHDiffPatch/HDiff/private_diff/suffix_string.cpp",

src/hdiff.cpp

@@ -0,0 +1,26 @@
+/**
+ * Created by housisong on 2021.04.07.
+ */
+#include "hdiff.h"
+#include "HDiffPatch/libHDiffPatch/HDiff/diff.h"
+
+#define _CompressPlugin_lzma2
+#define _IsNeedIncludeDefaultCompressHead 0
+#include "lzma/C/LzmaEnc.h"
+#include "lzma/C/Lzma2Enc.h"
+#include "lzma/C/MtCoder.h"
+#include "HDiffPatch/compress_plugin_demo.h"
+
+void hdiff(const uint8_t* old,size_t oldsize,const uint8_t* _new,size_t newsize,
+ 	 	       std::vector<uint8_t>& out_codeBuf){
+    const int myBestSingleMatchScore=3;
+    const size_t myBestStepMemSize=kDefaultStepMemSize;
+    const size_t myBestDictSize=(1<<20)*8; //8MB mem
+
+    TCompressPlugin_lzma2 compressPlugin=lzma2CompressPlugin;
+    compressPlugin.compress_level=9;
+    compressPlugin.dict_size=myBestDictSize;
+    compressPlugin.thread_num=1;
+    create_single_compressed_diff(_new,_new+newsize,old,old+oldsize,out_codeBuf,0,
+                                  &compressPlugin.base,myBestSingleMatchScore,myBestStepMemSize);
+}

src/hdiff.h

@@ -0,0 +1,13 @@
+/**
+ * Created by housisong on 2021.04.07.
+ */
+
+#ifndef HDIFFPATCH_DIFF_H
+#define HDIFFPATCH_DIFF_H
+#include <stdint.h>
+#include <vector>
+
+voif hdiff(const uint8_t* old,size_t oldsize,const uint8_t* _new,size_t newsize,
+		   std::vector<uint8_t>& out_codeBuf);
+
+#endif

src/main.cc

@@ -0,0 +1,85 @@
+/**
+ * Created by housisong on 2021.04.07.
+ */
+#include <nan.h>
+#include <node.h>
+#include <node_buffer.h>
+#include <cstdlib>
+#include "hdiff.h"
+
+using namespace std;
+
+namespace hdiffpatchNode
+{
+    using v8::FunctionCallbackInfo;
+    using v8::HandleScope;
+    using v8::Isolate;
+    using v8::Local;
+    using v8::Object;
+    using v8::String;
+    using v8::Value;
+    using v8::Function;
+    using v8::MaybeLocal;
+    using v8::Null;
+    using v8::Boolean;
+    using v8::Exception;
+
+    struct DiffStreamOpaque {
+        Isolate* isolate;
+        Local<Function> cb;
+    };
+
+    static int callback_write(DiffStreamOpaque* opaque, const void* buffer, size_t size)
+    {
+
+      Local<Object> returnObj = node::Buffer::Copy(opaque->isolate, (const char*)buffer, size).ToLocalChecked();
+
+      Local<Value> argv[1] = { returnObj };
+      // opaque->cb->Call(Nan::GetCurrentContext()->Global(), Null(opaque->isolate), 1, argv);
+
+      Nan::MakeCallback(Nan::GetCurrentContext()->Global(), opaque->cb, 1, argv);
+
+      return 0;
+    }
+
+    void diff(const FunctionCallbackInfo<Value>& args) {
+        Isolate* isolate = args.GetIsolate();
+        HandleScope scope(isolate);
+
+        if (!node::Buffer::HasInstance(args[0]) || !node::Buffer::HasInstance(args[1]) || !args[2]->IsFunction()) {
+          Nan::ThrowError("Invalid arguments.");
+        }
+
+        char*         oldData   = node::Buffer::Data(args[0]);
+        size_t        oldLength = node::Buffer::Length(args[0]);
+        char*         newData   = node::Buffer::Data(args[1]);
+        size_t        newLength = node::Buffer::Length(args[1]);
+
+        DiffStreamOpaque streamOpaque;
+        streamOpaque.isolate = isolate;
+        streamOpaque.cb = Local<Function>::Cast(args[2]);
+
+        std::vector<uint8_t> codeBuf;
+        try{
+            hdiff((const uint8_t*)oldData,oldLength,(const uint8_t*)newData,newLength,codeBuf);
+        }catch(const std::exception& e){
+            Nan::ThrowError("Create hdiff failed.");
+        }
+        if (0!=callback_write(&streamOpaque,codeBuf.data(),codeBuf.size()))
+            Nan::ThrowError("Write DiffStreamOpaque failed.");
+
+//        args.GetReturnValue().Set(returnObj);
+//        args.GetReturnValue().Set(String::NewFromUtf8(isolate, bufferData, String::kNormalString, bufferLength));
+    }
+
+    void init(Local<Object> exports)
+    {
+        Isolate* isolate = exports->GetIsolate();
+        HandleScope scope(isolate);
+
+        NODE_SET_METHOD(exports, "diff", diff);
+    }
+
+    NODE_MODULE(hdiffpatch, init)
+
+} // namespace hdiffpatch