Update to 3.1.1

Author: andr-bot1

dist/ProtoSSChe.js

@@ -44,6 +44,13 @@ const ERRORS = {
 	WARNING: "warning",
 	ABORT: "abort",
 };
+const PROCESS_EVENTS = {
+	EXIT: "exit",
+	BEFORE_EXIT: "beforeExit",
+	DISCONNECT: "disconnect",
+	MESSAGE: "message",
+	WORKER_MESSAGE: "workerMessage",
+};
 const EVENTS = {
 	DATA: "data",
 	ERROR: "error",
@@ -77,9 +84,11 @@ function updateEnv() {
 	}
 }
 const globalExceptionsAndErrors = {};
+const globalProcessListeners = [];
 function onGlobalError(error) {
 	process.on(error, function (err) {
 		pushGlobalError(error, err);
+		globalProcessListeners.forEach((cb) => cb(error, err));
 	});
 }
 function pushGlobalError(error, err) {
@@ -92,12 +101,18 @@ function uncaughtExceptionGlobal() {
 		global.onGlobalError = onGlobalError;
 		global.pushGlobalError = pushGlobalError;
 		global.globalExceptionsAndErrors = globalExceptionsAndErrors;
+		global.globalProcessListeners = globalProcessListeners;
 	} else return;
 	onGlobalError(ERRORS.UNCAUGHT_EXCEPTION);
 	onGlobalError(ERRORS.UNCAUGHT_EXCEPTION_MONITOR);
 	onGlobalError(ERRORS.UNHANDLED_REJECTION);
 	onGlobalError(ERRORS.UNHANDLED_PROMISE_REJECTION_WARNING);
 	onGlobalError(ERRORS.WARNING);
+	onGlobalError(PROCESS_EVENTS.EXIT);
+	onGlobalError(PROCESS_EVENTS.BEFORE_EXIT);
+	onGlobalError(PROCESS_EVENTS.DISCONNECT);
+	onGlobalError(PROCESS_EVENTS.MESSAGE);
+	onGlobalError(PROCESS_EVENTS.WORKER_MESSAGE);
 }
 function resetFSInterval() {
 	clearInterval(sid);

dist/modules/XProtoSSChe.js

@@ -105,12 +105,13 @@ function getExtendedServerProtoSS(ProtoSSChe) {
 				};
 				let firstin = o.collectionRR[0][0];
 				let lastout = o.collectionRR[count - 1][1];
-				stats.time = lastout.__timestamp - firstin.__timestamp;
 				o.collectionRR.forEach((e) => {
 					stats.avrgTime += e[1].__timestamp - e[0].__timestamp;
 					stats.units += e[0].__units || 0;
 					stats.units += e[1].__units || 0;
+					if (e[1].__timestamp > lastout.__timestamp) lastout = e[1];
 				});
+				stats.time = lastout.__timestamp - firstin.__timestamp;
 				stats.average = stats.avrgTime / count;
 				o.collectionRR = [];
 				o.collectionStats.push(stats);
@@ -233,7 +234,7 @@ function getExtendedServerProtoSS(ProtoSSChe) {
 			if (!response.headersSent) response.writeHead(response.__rcode || 200, headers);
 			response.end(input, response.__encoding);
 			response.__timestamp = new Date().getTime();
-			o.collectionRR.push([request, response]);
+			if (o.collectionMax > 0) o.collectionRR.push([request, response]);
 			return o;
 		}
 	};

package.json

@@ -1,6 +1,6 @@
 {
 	"name": "protoss-nodejs-basic",
-	"version": "3.1.0",
+	"version": "3.1.1",
 	"author": "Zeta Ret",
 	"license": "MIT",
 	"type": "commonjs",
@@ -21,6 +21,6 @@
 		"start-ts": "node dist/indexTS.js"
 	},
 	"dependencies": {
-		"@types/protoss-nodejs-basic": "git+https://github.com/ZetaRet/protoss-nodejs-basic-types.git#v3.1.0"
+		"@types/protoss-nodejs-basic": "git+https://github.com/ZetaRet/protoss-nodejs-basic-types.git#v3.1.1"
 	}
 }

protossdox.json

@@ -9,6 +9,6 @@
 	"relative": true,
 	"markdown": true,
 	"ext": ["js", "ts"],
-	"version": "3.1.0",
+	"version": "3.1.1",
 	"license": "MIT"
 }

src/ProtoSSChe.ts

@@ -56,6 +56,14 @@ const ERRORS = {
 	ABORT: "abort",
 };
 
+const PROCESS_EVENTS = {
+	EXIT: "exit",
+	BEFORE_EXIT: "beforeExit",
+	DISCONNECT: "disconnect",
+	MESSAGE: "message",
+	WORKER_MESSAGE: "workerMessage",
+};
+
 const EVENTS = {
 	DATA: "data",
 	ERROR: "error",
@@ -94,9 +102,11 @@ function updateEnv() {
 }
 
 const globalExceptionsAndErrors: any = {};
+const globalProcessListeners: any[] = [];
 function onGlobalError(error: any) {
 	process.on(error, function (err) {
 		pushGlobalError(error, err);
+		globalProcessListeners.forEach((cb) => cb(error, err));
 	});
 }
 function pushGlobalError(error: any, err: any) {
@@ -109,12 +119,18 @@ function uncaughtExceptionGlobal() {
 		(global as zetaret.node.BasicServerGlobal).onGlobalError = onGlobalError;
 		(global as zetaret.node.BasicServerGlobal).pushGlobalError = pushGlobalError;
 		(global as zetaret.node.BasicServerGlobal).globalExceptionsAndErrors = globalExceptionsAndErrors;
+		(global as zetaret.node.BasicServerGlobal).globalProcessListeners = globalProcessListeners;
 	} else return;
 	onGlobalError(ERRORS.UNCAUGHT_EXCEPTION);
 	onGlobalError(ERRORS.UNCAUGHT_EXCEPTION_MONITOR);
 	onGlobalError(ERRORS.UNHANDLED_REJECTION);
 	onGlobalError(ERRORS.UNHANDLED_PROMISE_REJECTION_WARNING);
 	onGlobalError(ERRORS.WARNING);
+	onGlobalError(PROCESS_EVENTS.EXIT);
+	onGlobalError(PROCESS_EVENTS.BEFORE_EXIT);
+	onGlobalError(PROCESS_EVENTS.DISCONNECT);
+	onGlobalError(PROCESS_EVENTS.MESSAGE);
+	onGlobalError(PROCESS_EVENTS.WORKER_MESSAGE);
 }
 
 function resetFSInterval() {

src/modules/XProtoSSChe.ts

@@ -118,12 +118,13 @@ function getExtendedServerProtoSS(ProtoSSChe: zetaret.node.ProtoSSCheCTOR): zeta
 				};
 				let firstin = o.collectionRR[0][0];
 				let lastout = o.collectionRR[count - 1][1];
-				stats.time = lastout.__timestamp - firstin.__timestamp;
 				o.collectionRR.forEach((e: any) => {
 					stats.avrgTime += e[1].__timestamp - e[0].__timestamp;
 					stats.units += e[0].__units || 0;
 					stats.units += e[1].__units || 0;
+					if (e[1].__timestamp > lastout.__timestamp) lastout = e[1];
 				});
+				stats.time = lastout.__timestamp - firstin.__timestamp;
 				stats.average = stats.avrgTime / count;
 				o.collectionRR = [];
 				o.collectionStats.push(stats);
@@ -262,7 +263,7 @@ function getExtendedServerProtoSS(ProtoSSChe: zetaret.node.ProtoSSCheCTOR): zeta
 			if (!response.headersSent) (response as Http2Response).writeHead((response as zetaret.node.AugmentResponse).__rcode || 200, headers);
 			response.end(input, (response as zetaret.node.AugmentResponse).__encoding as any);
 			(response as zetaret.node.AugmentResponse).__timestamp = new Date().getTime();
-			o.collectionRR.push([request, response]);
+			if (o.collectionMax > 0) o.collectionRR.push([request, response]);
 			return o;
 		}
 	};