add tests for AsyncProgressQueueWorker

mkrufky · kkoopa · commit 2ef579e09b5b · 2017-10-06T11:22:09.000+03:00
diff --git a/test/binding.gyp b/test/binding.gyp
@@ -43,6 +43,10 @@
         "target_name" : "returnemptystring"
       , "sources"     : [ "cpp/returnemptystring.cpp" ]
     }
+  , {
+        "target_name" : "asyncprogressqueueworker"
+      , "sources"     : [ "cpp/asyncprogressqueueworker.cpp" ]
+    }
   , {
         "target_name" : "asyncworker"
       , "sources"     : [ "cpp/asyncworker.cpp" ]
diff --git a/test/cpp/asyncprogressqueueworker.cpp b/test/cpp/asyncprogressqueueworker.cpp
@@ -0,0 +1,69 @@
+/*********************************************************************
+ * NAN - Native Abstractions for Node.js
+ *
+ * Copyright (c) 2017 NAN contributors
+ *
+ * MIT License <https://github.com/nodejs/nan/blob/master/LICENSE.md>
+ ********************************************************************/
+
+#ifndef _WIN32
+#include <unistd.h>
+#define Sleep(x) usleep((x)*1000)
+#endif
+#include <nan.h>
+
+using namespace Nan;  // NOLINT(build/namespaces)
+
+class ProgressQueueWorker : public AsyncProgressQueueWorker<char> {
+ public:
+  ProgressQueueWorker(
+      Callback *callback
+    , Callback *progress
+    , int milliseconds
+    , int iters)
+    : AsyncProgressQueueWorker(callback), progress(progress)
+    , milliseconds(milliseconds), iters(iters) {}
+
+  ~ProgressQueueWorker() {
+    delete progress;
+  }
+
+  void Execute (const AsyncProgressQueueWorker::ExecutionProgress& progress) {
+    for (int i = 0; i < iters; ++i) {
+      progress.Send(reinterpret_cast<const char*>(&i), sizeof(int));
+      Sleep(milliseconds);
+    }
+  }
+
+  void HandleProgressCallback(const char *data, size_t count) {
+    HandleScope scope;
+
+    v8::Local<v8::Value> argv[] = {
+        New<v8::Integer>(*reinterpret_cast<int*>(const_cast<char*>(data)))
+    };
+    progress->Call(1, argv);
+  }
+
+ private:
+  Callback *progress;
+  int milliseconds;
+  int iters;
+};
+
+NAN_METHOD(DoProgress) {
+  Callback *progress = new Callback(info[2].As<v8::Function>());
+  Callback *callback = new Callback(info[3].As<v8::Function>());
+  AsyncQueueWorker(new ProgressQueueWorker(
+      callback
+    , progress
+    , To<uint32_t>(info[0]).FromJust()
+    , To<uint32_t>(info[1]).FromJust()));
+}
+
+NAN_MODULE_INIT(Init) {
+  Set(target
+    , New<v8::String>("a").ToLocalChecked()
+    , New<v8::FunctionTemplate>(DoProgress)->GetFunction());
+}
+
+NODE_MODULE(asyncprogressqueueworker, Init)
diff --git a/test/js/asyncprogressqueueworker-1ms-test.js b/test/js/asyncprogressqueueworker-1ms-test.js
@@ -0,0 +1,24 @@
+/*********************************************************************
+ * NAN - Native Abstractions for Node.js
+ *
+ * Copyright (c) 2017 NAN contributors
+ *
+ * MIT License <https://github.com/nodejs/nan/blob/master/LICENSE.md>
+ ********************************************************************/
+
+const test     = require('tap').test
+    , testRoot = require('path').resolve(__dirname, '..')
+    , bindings = require('bindings')({ module_root: testRoot, bindings: 'asyncprogressqueueworker' });
+
+test('asyncprogressqueueworker1ms', function (t) {
+  // test with 1 ms sleep
+  var worker = bindings.a
+    , progressed = 0
+  worker(1, 500, function(i) {
+    t.ok(i === progressed, 'got the progress updates #' + i);
+    progressed++;
+  }, function () {
+    t.ok(progressed === 500, 'got all progress updates')
+    t.end()
+  })
+})
diff --git a/test/js/asyncprogressqueueworker-test.js b/test/js/asyncprogressqueueworker-test.js
@@ -0,0 +1,24 @@
+/*********************************************************************
+ * NAN - Native Abstractions for Node.js
+ *
+ * Copyright (c) 2017 NAN contributors
+ *
+ * MIT License <https://github.com/nodejs/nan/blob/master/LICENSE.md>
+ ********************************************************************/
+
+const test     = require('tap').test
+    , testRoot = require('path').resolve(__dirname, '..')
+    , bindings = require('bindings')({ module_root: testRoot, bindings: 'asyncprogressqueueworker' });
+
+test('asyncprogressqueueworker', function (t) {
+  // test with 100 ms sleep
+  var worker = bindings.a
+    , progressed = 0
+  worker(100, 5, function(i) {
+    t.ok(i === progressed, 'got the progress updates #' + i);
+    progressed++;
+  }, function () {
+    t.ok(progressed === 5, 'got all progress updates')
+    t.end()
+  })
+})
