Introduce logging.

commands.js

@@ -1,6 +1,7 @@
 var cmd   = exports,
     fs    = require('fs'),
     irc   = require('./irc.js'),
+    log   = require('./log.js'),
     authd = {}; // People authentified
 
 cmd.prefix = '.';
@@ -18,6 +19,8 @@ function tokenize(msg) {
 
 cmd.load = function (dispatcherName, context) {
 
+    log.debug('Loading dispatcher ' + dispatcherName + '.');
+
     var dispatcherFile = context.options.dispatcherDir + 
 			 '/' + dispatcherName + '.js',
 	absolutePath   = require.resolve(dispatcherFile);
@@ -29,6 +32,7 @@ cmd.load = function (dispatcherName, context) {
 
 cmd.unload = function (dispatcherName) {
 
+    log.debug('Unloading dispatcher ' + dispatcherName + '.');
     return delete cmd[dispatcherName];
 
 };
@@ -55,6 +59,8 @@ cmd.dispatch = function (context) {
     commandFunc = cmd[dispatcher][name];
 
     if (typeof commandFunc === 'undefined') {
+	log.debug('Command "' + name + 
+		  '" not found on dispatcher ' + dispatcherName);
 	return;
     }
 

config.json

@@ -10,4 +10,5 @@
     "ignore":        ["punk", "phunk"],
     "gBooksAPIKey":  "gbk",
     "dispatcherDir": "./dispatchers"
+    "logDir":        "./logs"
 }

dispatchers/public.js

@@ -2,6 +2,7 @@ var pub    = exports,
     irc    = require('../irc.js'),
     rfc    = require('./modules/ietf.js'),
     gbk    = require('./modules/gbooks.js'),
+    log    = require('./log.js'),
     interp = require('../util.js').interp;
 
 
@@ -10,13 +11,24 @@ function reply(context, message) {
 	irc.outbound.say(context.channel, 
 			 context.sender + ': ' + message)
     );
+
+    log.publicmsg({
+	channel: context.channel,
+	message: message,
+	sender:  context.sender
+    });
 }
 
 
 function replyQuery(context, message) {
     context.network.send(
 	irc.outbound.say(context.sender, message)
     );
+
+    log.query({
+	message: message,
+	sender:  context.sender
+    });
 }
 
 
@@ -72,7 +84,7 @@ pub.quit = function (tokens, context) {
 
     var quitmsg = tokens[1] || "";
 
-    console.log('-- Quitting by order of ' + context.sender);
+    log.debug('Quitting by order of ' + context.sender);
     context.network.send(irc.outbound.quit(quitmsg));
     process.exit();
 };

dispatchers/query.js

@@ -1,18 +1,26 @@
 var qry    = exports,
     irc    = require('../irc.js'),
     rfc    = require('./modules/ietf.js'),
+    log    = require('./log.js'),
     interp = require('../util.js').interp;
 
 
 function reply(context, message) {
+
     context.network.send(
 	irc.outbound.say(context.sender, message)
     );
+
+    log.query({
+	sender:  context.sender,
+	message: message
+    });
 }
 
 
 
 qry.load = function (tokens, context) {
+
     try {
 	context.cmd.load(tokens[1], context);
 	reply(context, 
@@ -107,7 +115,7 @@ qry.quit = function (tokens, context) {
 
     var quitmsg = tokens[1] || "";
 
-    console.log('-- Quitting by order of ' + context.sender);
+    log.debug('Quitting by order of ' + context.sender);
     context.network.send(irc.outbound.quit(quitmsg));
     process.exit();
 };

log.js

@@ -0,0 +1,104 @@
+var fs  = require('fs'),
+    log = exports,
+    dir = './logs';
+
+
+log.setDir = function (directory) {
+    dir = directory;
+};
+
+
+log.publicmsg = function (params) {
+
+    var now  = getTime();
+	path = dir + '/'   + params.channel + '.log',
+	line = now + '| <' + params.sender  + '> ' + 
+	       params.message + '\n';
+
+
+    append(path, line);
+};
+
+
+log.query = function (params) {
+
+    var now  = getTime();
+	path = dir + '/'   + params.sender + '.log',
+	line = now + '| <' + params.sender + '> ' + params.message;
+
+    append(path, line);
+};
+
+
+log.debug = function (params) {
+
+    var now  = getTime();
+	path = './debug.log',
+	line = now + '| ' + params.message;
+
+    console.log('-- ' + params.message);
+    append(path, line);
+
+}
+
+
+log.joined = function (params) {
+
+    var now  = getTime();
+	path = dir + '/'  + params.channel + '.log',
+	line = now + '| ' + params.who     + ' joined channel ' + 
+	       params.channel + '.';
+
+    append(path, line);
+}
+
+
+log.parted = function (params) {
+
+    var now  = getTime(); 
+	path = dir + '/'  + params.channel + '.log',
+	line = now + '| ' + params.who     + ' parted channel ' +
+	       params.channel + '.';
+
+    append(path, line);
+}
+
+
+log.renamed = function (params) {
+
+    var now  = getTime();
+	path = dir + '/'  + params.channel + '.log',
+	line = now + '| ' + params.old     + ' changed nick to ' +
+	       params.new_ + '.';
+
+    append(path, line);
+}
+
+
+function getTime() {
+
+    return new Date().toString().match(/[^G]+/);
+
+}
+
+function append(path, line) {
+
+    console.log(line);
+
+/* 
+    fs.open(path, 'a', 438, function (err, fd) {
+
+	var buffer;
+
+	if (err) {
+	    console.log('Error trying to log public message.');
+	    return;
+	}
+
+	buffer = new Buffer('' + line, 'utf8');
+	// writeAll(fd, buffer, 0, buffer.length);
+	// need ' write ' - check node documentation when on the Internet.
+
+    });
+*/
+}

mutalirc.js

@@ -2,6 +2,7 @@ var nwk = require('./network.js'),
     cfg = require('./config.js'),
     cmd = require('./commands.js'),
     irc = require('./irc.js'),
+    log = require('./log.js'),
     opt,
     ignored = {};
 
@@ -20,6 +21,8 @@ function init(options) {
 	ignored[nickOrHostmask] = true;
     });
 
+    log.setDir(opt.logDir);
+
     nwk.connect(opt, react);
 }
 
@@ -33,10 +36,12 @@ function react(data) {
 
 	case 'ping':
 	    nwk.send(resp.pong(parsed.content));
+	    log.debug('PONG: ' + parsed.content);
 	    break;
 
 	case 'version':
 	    nwk.send(resp.version(parsed.requester, opt.version));
+	    log.debug('Providing version information to: ' + parsed.requester);
 	    break;
 
 	case 'privmsg':
@@ -52,7 +57,7 @@ function react(data) {
 		};
 
 		if (ignoring(parsed.sender) || ignoring(parsed.hostmask))) {
-		    console.log('-- Ignoring query from ' + parsed.hostmask);
+		    log.debug('Ignoring query from ' + parsed.hostmask);
 		    return;
 		}
 
@@ -73,7 +78,7 @@ function react(data) {
 		};
 
 		if (ignoring(parsed.sender) || ignoring(parsed.hostmask))) {
-		    console.log('-- Ignoring message from ' + parsed.hostmask);
+		    log.debug('Ignoring message from ' + parsed.hostmask);
 		    return;
 		}
 

network.js

@@ -1,6 +1,7 @@
 var net = require('net'),
     irc = require('./irc.js'),
     utl = require('./util.js'),
+    log = require('./log.js'),
     nwk = exports,
     server;
 
@@ -17,22 +18,22 @@ nwk.send = function (text) {
 
 nwk.connect = function (opt, callback) {
 
-    console.log(utl.interp('-- Connecting to {srv} on port {prt}',
+    log.debug(utl.interp('Connecting to {srv} on port {prt}',
 			   {
 			       srv: opt.server,
 			       prt: opt.port
 			   }));
 
     server = net.connect(opt.port, opt.server, function () {
 
-	console.log('-- Connected.');
+	log.debug('Connected.');
 
 	nwk.send(irc.outbound.pass(opt.pass));
 	nwk.send(irc.outbound.nick(opt.nick));
 	nwk.send(irc.outbound.user(opt.nick, opt.owner));
 
 	opt.channels.forEach(function (channel) {
-	    console.log('Joining channel ' + channel);
+	    log.debug('Joining channel ' + channel);
 	    nwk.send(irc.outbound.join(channel));
 	});