Add some basic logging functionality for "service.js".

Author: timwienk

.gitignore

@@ -3,3 +3,4 @@ node_modules/
 *.tern-port
 config/api_keys.json
 config/databases.json
+config/log.json

config/init.d/mootools-website

@@ -73,6 +73,18 @@ do_stop() {
 	return "$RETVAL"
 }
 
+#
+# Function that sends a SIGUSR2 to the daemon/service
+#
+do_reload_logs() {
+	# Return
+	#   0 if the signal was sent
+	#   1 if the signal could not be sent
+	start-stop-daemon --stop --signal USR2 --quiet --pidfile $PIDFILE --exec $DAEMON --test > /dev/null || return 1
+	start-stop-daemon --stop --signal USR2 --quiet --pidfile $PIDFILE --exec $DAEMON
+	return 0
+}
+
 #
 # Function that sends a SIGHUP to the daemon/service
 #
@@ -106,6 +118,11 @@ case "$1" in
 	status)
 		status_of_proc "$DAEMON" "$NAME" && exit 0 || exit $?
 		;;
+	reload-logs)
+		log_daemon_msg "Reloading logs of $DESC" "$NAME"
+		do_reload_logs
+		log_end_msg $?
+		;;
 	reload|force-reload)
 		log_daemon_msg "Reloading $DESC" "$NAME"
 		do_reload
@@ -130,7 +147,7 @@ case "$1" in
 		esac
 		;;
 	*)
-		echo "Usage: $SCRIPTNAME {start|stop|status|restart|reload|force-reload}" >&2
+		echo "Usage: $SCRIPTNAME {start|stop|status|restart|reload|reload-logs|force-reload}" >&2
 		exit 3
 		;;
 esac

config/log.sample.json

@@ -0,0 +1,4 @@
+{
+	"outFile": "tests/out.log",
+	"errFile": "tests/err.log"
+}

config/logrotate.d/mootools-website

@@ -0,0 +1,13 @@
+/var/opt/mootools/log/mootools-website.*.log {
+	weekly
+	missingok
+	rotate 52
+	compress
+	delaycompress
+	notifempty
+	create 0640 www-data adm
+	sharedscripts
+	postrotate
+		service mootools-website reload-logs
+	endscript
+}

lib/log.js

@@ -0,0 +1,96 @@
+"use strict";
+
+var fs = require('fs');
+
+var silent = false,
+	monitors = [],
+	files = {},
+	streams = {};
+
+function close(type){
+	if (streams[type]){
+		streams[type].end();
+		streams[type] = null;
+	}
+}
+
+function open(type, file){
+	if (file){
+		files[type] = file;
+	} else {
+		file = files[type];
+	}
+
+	close(type);
+
+	if (file){
+		var stream = fs.createWriteStream(file, {
+			flags: 'a+',
+			defaultEncoding: 'utf8',
+			mode: parseInt('640', 8)
+		});
+		stream.addListener('error', function(error){
+			stream.end();
+			streams[type] = null;
+			if (monitors.length){
+				for (var i = 0, l = monitors.length; i < l; ++i){
+					monitors[i].emit('error', error);
+				}
+			} else {
+				throw error;
+			}
+		});
+		streams[type] = stream;
+	}
+}
+
+function write(type, data){
+	var stream = streams[type];
+	if (stream){
+		stream.write('[' + (new Date()).toISOString() +  '] ' + data);
+	}
+}
+
+function configure(configuration){
+	if (configuration.silent != null) silent = configuration.silent;
+	if (configuration.outFile) open('out', configuration.outFile);
+	if (configuration.errFile) open('err', configuration.errFile);
+}
+
+function reload(){
+	var types = Object.keys(files);
+	for (var i = 0, l = types.length; i < l; ++i){
+		open(types[i]);
+	}
+}
+
+function attach(monitor){
+	if (monitors.indexOf(monitor) == -1) monitors.push(monitor);
+	monitor.addListener('stdout', log);
+	monitor.addListener('stderr', logError);
+}
+
+function detach(monitor){
+	var index = monitors.indexOf(monitor);
+	if (index > -1) monitors.splice(index, 1);
+	monitor.removeListener('stdout', log);
+	monitor.removeListener('stderr', logError);
+}
+
+function log(data){
+	write('out', data);
+	if (!silent) process.stdout.write(data);
+}
+
+function logError(data){
+	write('err', data);
+	if (!silent) process.stderr.write(data);
+}
+
+exports.configure = configure;
+exports.reload = reload;
+exports.attach = attach;
+exports.detach = detach;
+
+exports.write = function(data){ return log(data + '\n'); };
+exports.error = function(data){ return logError(data + '\n'); };

service.js

@@ -3,51 +3,66 @@
 var app = 'index',
 	name = 'mootools-website';
 
-var Monitor = require('forever-monitor').Monitor;
+var Monitor = require('forever-monitor').Monitor,
+	log = require('./lib/log.js');
 
 var monitor = new Monitor(__dirname + '/' + app + '.js', {
+	silent: true,
 	minUptime: 2000,
 	args: process.argv.splice(2)
 });
 
+log.attach(monitor);
+try {
+	log.configure(require('./config/log.json'));
+} catch (error){
+}
+
 function stop(){
-	console.error('** Requested stop of ' + name);
+	log.error('** Requested stop of ' + name);
 	monitor.stop();
 }
 
 function reload(){
-	console.error('** Requested reload of ' + name);
+	log.error('** Requested reload of ' + name);
+	log.reload();
 	monitor.restart();
 }
 
+function reloadLogs(){
+	log.error('** Requested log reload of ' + name);
+	log.reload();
+}
+
 process.addListener('SIGINT', stop);
 process.addListener('SIGTERM', stop);
 process.addListener('SIGHUP', reload);
+process.addListener('SIGUSR2', reloadLogs);
 
 monitor.addListener('start', function(){
-	console.error('** Starting ' + name + ' monitor');
+	log.error('** Starting ' + name + ' monitor');
 });
 
 monitor.addListener('stop', function(){
-	console.error('** Stopping ' + name + ' monitor');
+	log.error('** Stopping ' + name + ' monitor');
 });
 
 monitor.addListener('exit:code', function(code){
 	if (code == null) code = 0;
-	console.error('** Detected ' + name + ' process exited (exit code ' + code + ')');
+	log.error('** Detected ' + name + ' process exited (exit code ' + code + ')');
 });
 
 monitor.addListener('restart', function(){
-	console.error('** Restarting ' + name + ' process (#' + monitor.times + ')');
+	log.error('** Restarting ' + name + ' process (#' + monitor.times + ')');
 });
 
 monitor.addListener('error', function(error){
 	if (error.stack){
-		console.error('** ' + error.stack);
+		log.error('** ' + error.stack);
 	} else if (error.message) {
-		console.error('** Error: ' + error.message);
+		log.error('** Error: ' + error.message);
 	} else {
-		console.error('** Error: ' + error);
+		log.error('** Error: ' + error);
 	}
 });