luster - npm Package Compare versions

Comparing version 2.0.2 to 2.1.0

lib/rpc.js

@@ -51,3 +51,4 @@ /**
             broadcastMasterEvent: 'core.worker.broadcastMasterEvent',
-            applyForeignProperties: 'core.worker.applyForeignProperties'
+            applyForeignProperties: 'core.worker.applyForeignProperties',
+            suspend: 'core.worker.suspend'
         },
@@ -54,0 +55,0 @@ master: {

lib/worker_wrapper.js

@@ -424,3 +424,9 @@ const cluster = require('cluster'),
             if (this.isRunning()) {
-                this._worker.disconnect();
+                this.remoteCallWithCallback({
+                    command: RPC.fns.worker.suspend,
+                    callback: () => {
+                        this._worker.disconnect();
+                    }
+                });
+
                 this._scheduleForceStop();
@@ -427,0 +433,0 @@ }

lib/worker.js

@@ -37,2 +37,6 @@ const cluster = require('cluster'),
         this.registerRemoteCommand(RPC.fns.worker.broadcastMasterEvent, this.broadcastMasterEvent.bind(this));
+
+        this._suspendFunctions = [];
+        this.registerRemoteCommandWithCallback(RPC.fns.worker.suspend, this._suspend.bind(this));
+        this._suspendPromise = null;
     }
@@ -165,2 +169,33 @@
     }
+
+    /**
+     * @callback SuspendFunction
+     * @returns void|Promise<void>
+     */
+
+    /**
+     * This adds new function that will be called before stopping worker.
+     * Worker will wait for returned promise to resolve and then report to master it suspended successfully.
+     * Rejects will emit 'error' event, no report to master will happen.
+     * All suspend functions are called simultaneously.
+     * Suspend function will not be called more than once.
+     * @param {SuspendFunction} func
+     * @public
+     */
+    registerSuspendFunction(func) {
+        this._suspendFunctions.push(func);
+    }
+
+    _suspend(callback) {
+        if (!this._suspendPromise) {
+            this._suspendPromise = Promise.all(this._suspendFunctions.map(func => func()));
+        }
+
+        this._suspendPromise.then(
+            callback,
+            error => {
+                this.emit('error', error);
+            }
+        );
+    }
 }
@@ -167,0 +202,0 @@

package.json

 {
   "name": "luster",
-  "version": "2.0.2",
+  "version": "2.1.0",
   "description": "Node.js cluster wrapper",
@@ -47,2 +47,3 @@ "main": "./lib/luster.js",
     "mocha": "^3.1.2",
+    "p-event": "^4.1.0",
     "sinon": "^1.17.6",
@@ -49,0 +50,0 @@ "sinon-chai": "^2.8.0"

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

New author

Supply chain risk

A new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

87481

increased by1.58%

Lines of code

2218

increased by1.65%

Number of medium supply chain risk alerts

0

decreased by-100%

Worsened metrics

Dev dependency count

8

increased by14.29%

No dependency changes