Added a feature that kills worker flow instances when the main process is terminated.

Author: petersirka

changelog.txt

@@ -8,6 +8,7 @@
 - added `PYPELINE(name, [options])` method starts a python process
 - added support for custom View engine helpers `DEF.helpers.myhelper`
 - fixed killing workers and pypelines
+- added a feature that kills worker flow instances when the main process is terminated
 
 ========================
 0.0.12

flow-flowstream.js

@@ -198,7 +198,7 @@ Instance.prototype.httprouting = function() {
 					if (index !== -1) {
 						try {
 							opt.cookies[line.substring(0, index)] = decodeURIComponent(line.substring(index + 1));
-						} catch (e) {}
+						} catch {}
 					}
 				}
 			}
@@ -412,6 +412,7 @@ Instance.prototype.kill = Instance.prototype.destroy = function() {
 	setTimeout(() => exports.refresh(self.id, 'destroy'), 500);
 	self.flow.$destroyed = true;
 	self.flow.$terminated = true;
+	self.flow.$socket && self.flow.$socket.close();
 
 	if (self.flow.isworkerthread) {
 
@@ -1972,7 +1973,8 @@ function MAKEFLOWSTREAM(meta) {
 	var saveforce = function() {
 		saveid && clearTimeout(saveid);
 		saveid = null;
-		flow.proxy.save(flow.export2());
+		if (!flow.$destroyed)
+			flow.proxy.save(flow.export2());
 	};
 
 	var save = function() {
@@ -2008,9 +2010,9 @@ function MAKEFLOWSTREAM(meta) {
 
 	var refresh_components_force = function() {
 		timeoutrefresh = null;
-		if (flow.proxy.online) {
+		if (!flow.$destroyed && flow.proxy.online) {
 			flow.proxy.send({ TYPE: 'flow/components', data: flow.components(true) });
-			var instances = flow.export();
+			let instances = flow.export();
 			flow.proxy.send({ TYPE: 'flow/design', data: instances });
 		}
 	};
@@ -2753,10 +2755,12 @@ function MAKEFLOWSTREAM(meta) {
 				flow.proxy.send({ TYPE: 'flow/design', data: flow.export() }, 1, clientid);
 				flow.proxy.send({ TYPE: 'flow/errors', data: flow.errors }, 1, clientid);
 				setTimeout(function() {
-					flow.instances().wait(function(com, next) {
-						com.status();
-						setImmediate(next);
-					}, 3);
+					if (!flow.$destroyed) {
+						flow.instances().wait(function(com, next) {
+							com.status();
+							setImmediate(next);
+						}, 3);
+					}
 				}, 1500);
 			}
 		}

flowstream.js

@@ -751,6 +751,7 @@ FP.destroy = function() {
 
 	self.inc(1);
 	self.unload(function() {
+		self.$destroyed = true;
 		self.inc(-1);
 		self.emit('destroy');
 		self.meta = null;

index.js

@@ -274,7 +274,7 @@ global.DEF = {};
 		try {
 			if (!pathexists(path))
 				F.Fs.mkdirSync(path, { recursive: true });
-		} catch (e) {}
+		} catch {}
 	};
 
 })(global.F);
@@ -287,7 +287,7 @@ function pathexists(filename, isfile) {
 	try {
 		var val = F.Fs.statSync(filename);
 		return val ? (isfile ? val.isFile() : true) : false;
-	} catch (e) {
+	} catch {
 		return false;
 	}
 }
@@ -905,7 +905,7 @@ F.require = function(name) {
 
 	try {
 		mod = require(name);
-	} catch (e) {
+	} catch {
 		mod = require(F.Path.join(F.config.$nodemodules, name));
 	}
 
@@ -1155,8 +1155,11 @@ F.loadservices = function() {
 		F.internal.ticks++;
 		global.NOW = new Date();
 
-		for (let key in F.flowstreams)
-			F.flowstreams[key].service(F.internal.ticks);
+		for (let key in F.flowstreams) {
+			let flow = F.flowstreams[key];
+			if (!flow.$destroyed)
+				flow.service(F.internal.ticks);
+		}
 
 		if (F.internal.ticks == 6 || F.internal.ticks == 12)
 			F.TWebSocket.ping();
@@ -1258,7 +1261,7 @@ F.httpload = function(opt) {
 
 		try {
 			F.Fs.unlinkSync(unixsocket);
-		} catch (e) {}
+		} catch {}
 
 		if (F.isWindows && unixsocket.indexOf(SOCKETWINDOWS) === -1)
 			unixsocket = F.Path.join(SOCKETWINDOWS, unixsocket);
@@ -1897,7 +1900,7 @@ F.memorize = function(name, delay, skip) {
 
 	try {
 		data = F.Fs.readFileSync(filename, 'utf8').parseJSON(true);
-	} catch (e) {}
+	} catch {}
 
 	var replacer;
 	var timeout;
@@ -2496,13 +2499,18 @@ F.exit = function(signal = 15) {
 		} catch {}
 	}
 
-
 	for (let m of F.pypelines) {
 		try {
 			m.kill(signal);
 		} catch {}
 	}
 
+	for (let key in Flow.instances) {
+		try {
+			Flow.instances[key].destroy();
+		} catch {}
+	}
+
 	let key = 'exit';
 
 	F.$events[key] && F.emit(key, signal);
@@ -2583,7 +2591,7 @@ F.decrypt = function(value, key, tojson = true) {
 			CONCAT[0] = decipher.update(Buffer.from(value || '', 'hex'));
 			CONCAT[1] = decipher.final();
 			response = Buffer.concat(CONCAT).toString('utf8');
-		} catch (e) {
+		} catch {
 			response = null;
 		}
 	} else