force reload feature

Author: L3P3

README.md

@@ -112,11 +112,13 @@ in both file types (dynamic served and services), you can use all node/bun metho
 - `service_require(service path)`: returns the matching service object
 - `service_require_try(service path)`: returns the matching service object or null if not found or if disabled
 - `rtjscomp`: has these properties/methods:
-  - `actions`: an object with methods for server control (http[s]_[start|stop|kill], log_clear, halt, exit)
+  - `actions`: an object with methods for server control (http[s]_[start|stop|kill], log_clear, file_watch_force_all, halt, exit)
   - `async data_load(path)`: reads the file in data directory and returns its content or null
   - `async data_load_watch(path, callback(content))`: executes callback first and on every change
   - `async data_save(path, content)`: writes the content to the file in data directory
 
+most file updates are handled automatically, but some updates cannot be detected, for example by git, so you can force a reload of all files by calling `rtjscomp.actions.reload_force()` or sending a `SIGHUP` signal to the process (done by systemctl reload).
+
 ## environment variables
 - `rtjscomp_path_data`: path to data directory, default is `./data`
 - `rtjscomp_path_public`: path to public directory, default is `./public`

package.json

@@ -1,6 +1,6 @@
 {
 	"name": "rtjscomp",
-	"version": "0.11.2",
+	"version": "0.12.0",
 	"description": "php-like server but with javascript",
 	"repository": {
 		"type": "git",

rtjscomp.js

@@ -139,8 +139,9 @@ const type_raws = new Set([
 	'zip',
 ]);
 
-/// compiled file handlers
+/// state
 const file_cache_functions = new Map;
+const watch_callbacks = new Set;
 
 const actions = {};
 const rtjscomp = global.rtjscomp = {
@@ -200,6 +201,21 @@ rtjscomp.escape_html = str => (
 	:	str
 );
 
+const file_watch = (path, callback) => {
+	watch_callbacks.add(callback);
+	const watcher = fs.watch(path, WATCH_OPTIONS, callback);
+	return {
+		close: () => {
+			watch_callbacks.delete(callback);
+			watcher.close();
+		},
+	};
+};
+actions.reload_force = () => {
+	log('force file reload');
+	for (const callback of watch_callbacks) callback();
+}
+
 /**
 	hack to guess the line number of an error
 */
@@ -370,7 +386,7 @@ const service_update = async service_object => {
 			if (service_object.status !== SERVICE_STATUS_PENDING) return;
 			if (!service_object.watcher) {
 				let timeout = 0;
-				service_object.watcher = fs.watch(path_real, WATCH_OPTIONS, () => (
+				service_object.watcher = file_watch(path_real, () => (
 					clearTimeout(timeout),
 					timeout = setTimeout(() => (
 						log_verbose && log('file updated: ' + path),
@@ -605,7 +621,7 @@ const service_require_try = path => {
 }
 
 const file_watch_once = (path, callback) => {
-	const watcher = fs.watch(path, WATCH_OPTIONS, () => (
+	const watcher = file_watch(path, () => (
 		watcher.close(),
 		log_verbose && log('file updated: ' + path),
 		callback()
@@ -623,7 +639,7 @@ const file_keep_new = async (path, callback) => {
 	}
 
 	let timeout = 0;
-	return fs.watch(path, WATCH_OPTIONS, () => (
+	return file_watch(path, () => (
 		clearTimeout(timeout),
 		timeout = setTimeout(() => exiting || (
 			log_verbose && log('file updated: ' + path),
@@ -1706,6 +1722,7 @@ process.on('SIGINT', actions.exit);
 //process.on('SIGUSR1', actions.exit);
 process.on('SIGUSR2', actions.exit);
 process.on('SIGTERM', actions.exit);
+process.on('SIGHUP', actions.reload_force);
 
 log(`rtjscomp v${
 	VERSION