138 lines
4.6 KiB
JavaScript
138 lines
4.6 KiB
JavaScript
var vows = require('vows')
|
|
, assert = require('assert')
|
|
, sandbox = require('sandboxed-module')
|
|
, log4js = require('../lib/log4js')
|
|
, setupLogging = function(options, category, compressedLength) {
|
|
var fakeDgram = {
|
|
sent: false,
|
|
socket: {
|
|
packetLength: 0,
|
|
close: function() {
|
|
},
|
|
send: function(pkt, offset, pktLength, port, host) {
|
|
fakeDgram.sent = true;
|
|
this.packet = pkt;
|
|
this.offset = offset;
|
|
this.packetLength = pktLength;
|
|
this.port = port;
|
|
this.host = host;
|
|
}
|
|
},
|
|
createSocket: function(type) {
|
|
this.type = type;
|
|
return this.socket;
|
|
}
|
|
}
|
|
, fakeCompressBuffer = {
|
|
compress: function(objectToCompress) {
|
|
fakeCompressBuffer.uncompressed = objectToCompress;
|
|
if (compressedLength) {
|
|
return { length: compressedLength };
|
|
} else {
|
|
return "I've been compressed";
|
|
}
|
|
}
|
|
}
|
|
, appender = sandbox.require('../lib/appenders/gelf', {
|
|
requires: {
|
|
dgram: fakeDgram,
|
|
"compress-buffer": fakeCompressBuffer
|
|
}
|
|
});
|
|
|
|
log4js.clearAppenders();
|
|
log4js.addAppender(appender.configure(options || {}), category || "gelf-test");
|
|
return {
|
|
dgram: fakeDgram,
|
|
compress: fakeCompressBuffer,
|
|
logger: log4js.getLogger(category || "gelf-test")
|
|
};
|
|
};
|
|
|
|
//log4js.configure({ doNotReplaceConsole: true });
|
|
|
|
vows.describe('log4js gelfAppender').addBatch({
|
|
|
|
'with default gelfAppender settings': {
|
|
topic: function() {
|
|
var setup = setupLogging();
|
|
setup.logger.info("This is a test");
|
|
return setup;
|
|
},
|
|
'the dgram packet': {
|
|
topic: function(setup) {
|
|
return setup.dgram;
|
|
},
|
|
'should be sent via udp to the localhost gelf server': function(dgram) {
|
|
assert.equal(dgram.type, "udp4");
|
|
assert.equal(dgram.socket.host, "localhost");
|
|
assert.equal(dgram.socket.port, 12201);
|
|
assert.equal(dgram.socket.offset, 0);
|
|
assert.ok(dgram.socket.packetLength > 0, "Received blank message");
|
|
},
|
|
'should be compressed': function(dgram) {
|
|
assert.equal(dgram.socket.packet, "I've been compressed");
|
|
}
|
|
},
|
|
'the uncompressed log message': {
|
|
topic: function(setup) {
|
|
var message = JSON.parse(setup.compress.uncompressed);
|
|
return message;
|
|
},
|
|
'should be in the gelf format': function(message) {
|
|
assert.equal(message.version, '1.0');
|
|
assert.equal(message.host, require('os').hostname());
|
|
assert.equal(message.level, 6); //INFO
|
|
assert.equal(message.facility, 'nodejs-server');
|
|
assert.equal(message.full_message, message.short_message);
|
|
assert.equal(message.full_message, 'This is a test');
|
|
}
|
|
}
|
|
},
|
|
'with a message longer than 8k': {
|
|
topic: function() {
|
|
var setup = setupLogging(undefined, undefined, 10240);
|
|
setup.logger.info("Blah.");
|
|
return setup;
|
|
},
|
|
'the dgram packet': {
|
|
topic: function(setup) {
|
|
return setup.dgram;
|
|
},
|
|
'should not be sent': function(dgram) {
|
|
assert.equal(dgram.sent, false);
|
|
}
|
|
}
|
|
},
|
|
'with non-default options': {
|
|
topic: function() {
|
|
var setup = setupLogging({
|
|
host: 'somewhere',
|
|
port: 12345,
|
|
hostname: 'cheese',
|
|
facility: 'nonsense'
|
|
});
|
|
setup.logger.debug("Just testing.");
|
|
return setup;
|
|
},
|
|
'the dgram packet': {
|
|
topic: function(setup) {
|
|
return setup.dgram;
|
|
},
|
|
'should pick up the options': function(dgram) {
|
|
assert.equal(dgram.socket.host, 'somewhere');
|
|
assert.equal(dgram.socket.port, 12345);
|
|
}
|
|
},
|
|
'the uncompressed packet': {
|
|
topic: function(setup) {
|
|
var message = JSON.parse(setup.compress.uncompressed);
|
|
return message;
|
|
},
|
|
'should pick up the options': function(message) {
|
|
assert.equal(message.host, 'cheese');
|
|
assert.equal(message.facility, 'nonsense');
|
|
}
|
|
}
|
|
}
|
|
}).export(module); |