clusteredAppender-test.js

"use strict";
var assert = require('assert');
var vows = require('vows');
var layouts = require('../lib/layouts');
var sandbox = require('sandboxed-module');
var LoggingEvent = require('../lib/logger').LoggingEvent;
var cluster = require('cluster');

vows.describe('log4js cluster appender').addBatch({
	'when in master mode': {
		topic: function() {

			var registeredClusterEvents = [];
			var loggingEvents = [];
			
			// Fake cluster module, so no cluster listeners be really added 
			var fakeCluster = {
			
				on: function(event, callback) {
					registeredClusterEvents.push(event);
				},
				
				isMaster: true,
				isWorker: false,
				
			};
		
			var fakeActualAppender = function(loggingEvent) {
				loggingEvents.push(loggingEvent);
			}
			
			// Load appender and fake modules in it
			var appenderModule = sandbox.require('../lib/appenders/clustered', {
				requires: {
					'cluster': fakeCluster,
				}
			});
		
			var masterAppender = appenderModule.appender({
				actualAppenders: [fakeActualAppender, fakeActualAppender, fakeActualAppender],
                                appenders: [{}, {category: "test"}, {category: "wovs"}]
			});

			// Actual test - log message using masterAppender
			masterAppender(new LoggingEvent('wovs', 'Info', ['masterAppender test']));
			
			var returnValue = {
				registeredClusterEvents: registeredClusterEvents,
				loggingEvents: loggingEvents,
			};
		
			return returnValue;
		}, 
		
		"should register 'fork' event listener on 'cluster'": function(topic) { 
			assert.equal(topic.registeredClusterEvents[0], 'fork');
		},
		
		"should log using actual appender": function(topic) {
                        assert.equal(topic.loggingEvents.length, 2)
			assert.equal(topic.loggingEvents[0].data[0], 'masterAppender test');
                        assert.equal(topic.loggingEvents[1].data[0], 'masterAppender test');
		},
		
	},
	
	'when in worker mode': {
		
		topic: function() {
			
			var registeredProcessEvents = [];
			
			// Fake cluster module, to fake we're inside a worker process
			var fakeCluster = {
			
				isMaster: false,
				isWorker: true,
				
			};
			
			var fakeProcess = {
			
				send: function(data) {
					registeredProcessEvents.push(data);
				},
				
			};
			
			// Load appender and fake modules in it
			var appenderModule = sandbox.require('../lib/appenders/clustered', {
				requires: {
					'cluster': fakeCluster,
				},
				globals: {
					'process': fakeProcess,
				}
			});
			
			var workerAppender = appenderModule.appender();

			// Actual test - log message using masterAppender
			workerAppender(new LoggingEvent('wovs', 'Info', ['workerAppender test']));
			workerAppender(new LoggingEvent('wovs', 'Info', [new Error('Error test')]));
			
			var returnValue = {
				registeredProcessEvents: registeredProcessEvents,
			};
			
			return returnValue;
		
		},
		
		"worker appender should call process.send" : function(topic) {
			assert.equal(topic.registeredProcessEvents[0].type, '::log-message');
			assert.equal(JSON.parse(topic.registeredProcessEvents[0].event).data[0], "workerAppender test");
		},
		
		"worker should serialize an Error correctly" : function(topic) {
			assert.equal(topic.registeredProcessEvents[1].type, '::log-message');
			assert(JSON.parse(topic.registeredProcessEvents[1].event).data[0].stack);
			var actual = JSON.parse(topic.registeredProcessEvents[1].event).data[0].stack;
			var expectedRegex = /^Error: Error test/;
			assert(actual.match(expectedRegex), "Expected: \n\n " + actual + "\n\n to match " + expectedRegex);
		}
		
	}

}).exportTo(module);