start and stop services.

Author: ionut.stan

package.json

@@ -1,7 +1,7 @@
 {
   "name": "jsonrpc-bidirectional",
   "description": "Bidirectional JSONRPC over web sockets or HTTP with extensive plugin support.",
-  "version": "5.7.0",
+  "version": "5.7.1",
   "scripts": {
     "build": "node build.js",
     "test": "node --expose-gc --max-old-space-size=1024 tests/main.js",

src/NodeClusterBase/MasterEndpoint.js

@@ -64,6 +64,41 @@ class MasterEndpoint extends JSONRPC.EndpointBase
 	}
 
 
+	/**
+	 * This overridable function is called and awaited inside startWorker().
+	 * 
+	 * This mustn't be called through JSONRPC.
+	 * 
+	 * @param {undefined} incomingRequest
+	 */
+	async _startServices(incomingRequest)
+	{
+		if(incomingRequest)
+		{
+			throw new Error("This mustn't be called through JSONRPC.");
+		}
+
+		// this.masterClient is available here.
+	}
+
+
+	/**
+	 * This overridable function is called and awaited inside gracefulExit().
+	 * Careful, gracefulExit() will timeout waiting after services to stop after a while.
+	 * 
+	 * This mustn't be called through JSONRPC.
+	 * 
+	 * @param {undefined} incomingRequest
+	 */
+	async _stopServices(incomingRequest)
+	{
+		if(incomingRequest)
+		{
+			throw new Error("This mustn't be called through JSONRPC.");
+		}
+	}
+
+
 	/**
 	 * Starts the JSONRPC server over cluster IPC, and forks worker processes.
 	 */
@@ -142,6 +177,8 @@ class MasterEndpoint extends JSONRPC.EndpointBase
 			}
 		);
 
+		await this._startServices();
+
 		for (let i = 0; i < Math.max(os.cpus().length, 2); i++)
 		{
 			cluster.fork();
@@ -280,6 +317,7 @@ class MasterEndpoint extends JSONRPC.EndpointBase
 		}
 		console.log("All workers have exited.");
 
+		await this._stopServices();
 
 		console.log("[" + process.pid + "] Master process exiting gracefully.");
 		process.exit(0);