From 2cdbd60c7e76e78d09c44dbdc96fb8a1b9891982 Mon Sep 17 00:00:00 2001
From: Patrick Malouin <p.malouin@gmail.com>
Date: Thu, 11 Jun 2015 16:20:54 -0400
Subject: [PATCH] Add test for the logging event deserialization

---
 test/clusteredAppender-test.js | 35 +++++++++++++++++++++++++++++-----
 1 file changed, 30 insertions(+), 5 deletions(-)

diff --git a/test/clusteredAppender-test.js b/test/clusteredAppender-test.js
index f36748c..ea3355d 100755
--- a/test/clusteredAppender-test.js
+++ b/test/clusteredAppender-test.js
@@ -12,18 +12,30 @@ vows.describe('log4js cluster appender').addBatch({
 
 			var registeredClusterEvents = [];
 			var loggingEvents = [];
+			var onChildProcessForked;
+			var onMasterReceiveChildMessage;
 			
-			// Fake cluster module, so no cluster listeners be really added 
+			// Fake cluster module, so no real cluster listeners be really added 
 			var fakeCluster = {
 			
 				on: function(event, callback) {
 					registeredClusterEvents.push(event);
+					onChildProcessForked = callback;
 				},
 				
 				isMaster: true,
 				isWorker: false,
 				
 			};
+			var fakeWorker = {
+				on: function(event, callback) {
+					onMasterReceiveChildMessage = callback;
+				},
+				process: {
+					pid: 123
+				},
+				id: 'workerid'
+			};
 		
 			var fakeActualAppender = function(loggingEvent) {
 				loggingEvents.push(loggingEvent);
@@ -38,12 +50,21 @@ vows.describe('log4js cluster appender').addBatch({
 		
 			var masterAppender = appenderModule.appender({
 				actualAppenders: [fakeActualAppender, fakeActualAppender, fakeActualAppender],
-                                appenders: [{}, {category: "test"}, {category: "wovs"}]
+				appenders: [{}, {category: "test"}, {category: "wovs"}]
 			});
 
 			// Actual test - log message using masterAppender
 			masterAppender(new LoggingEvent('wovs', 'Info', ['masterAppender test']));
-			
+
+			// Simulate a 'fork' event to register the master's message handler on our fake worker.
+			onChildProcessForked(fakeWorker);
+			// Simulate a cluster message received by the masterAppender.
+			var simulatedLoggingEvent = new LoggingEvent('wovs', 'Error', ['message deserialization test', {stack: 'my wrapped stack'}]);
+			onMasterReceiveChildMessage({
+				type : '::log-message',
+				event : JSON.stringify(simulatedLoggingEvent)
+			});
+
 			var returnValue = {
 				registeredClusterEvents: registeredClusterEvents,
 				loggingEvents: loggingEvents,
@@ -57,9 +78,13 @@ vows.describe('log4js cluster appender').addBatch({
 		},
 		
 		"should log using actual appender": function(topic) {
-                        assert.equal(topic.loggingEvents.length, 2)
+			assert.equal(topic.loggingEvents.length, 4);
 			assert.equal(topic.loggingEvents[0].data[0], 'masterAppender test');
-                        assert.equal(topic.loggingEvents[1].data[0], 'masterAppender test');
+			assert.equal(topic.loggingEvents[1].data[0], 'masterAppender test');
+			assert.equal(topic.loggingEvents[2].data[0], 'message deserialization test');
+			assert.equal(topic.loggingEvents[2].data[1], 'my wrapped stack');
+			assert.equal(topic.loggingEvents[3].data[0], 'message deserialization test');
+			assert.equal(topic.loggingEvents[3].data[1], 'my wrapped stack');
 		},
 		
 	},