log4js-logstash-tcp
Advanced tools
Comparing version 2.0.3 to 2.0.4
@@ -103,3 +103,7 @@ "use strict"; | ||
} | ||
close() { | ||
for(let key in this.tcpConnections) { | ||
this.tcpConnections[key].destroy(); | ||
} | ||
} | ||
} | ||
@@ -106,0 +110,0 @@ |
21
index.js
'use strict'; | ||
const util = require('util'); | ||
const TcpConnectionPool = require("./classes/TcpConnectionPool").TcpConnectionPool; | ||
@@ -37,7 +35,3 @@ | ||
if ((!logUnderFields) && (argsValue === 'direct')) { | ||
return true; | ||
} | ||
return false; | ||
return (!logUnderFields) && (argsValue === 'direct'); | ||
} | ||
@@ -68,2 +62,14 @@ | ||
}); | ||
// adding context to log messages as separate fields added by logger.addContext(key, value) | ||
if(loggingEvent.context) { | ||
if(loggingEvent.data.length === 1 || !loggingEvent.data[1]) { | ||
loggingEvent.data[1] = {} | ||
} | ||
if(typeof loggingEvent.data[1] === 'object') { | ||
loggingEvent.data[1] = { | ||
...loggingEvent.context, | ||
...loggingEvent.data[1] | ||
} | ||
} | ||
} | ||
@@ -101,2 +107,3 @@ /* eslint no-prototype-builtins:1,no-restricted-syntax:[1, "ForInStatement"] */ | ||
log.shutdown = function (cb) { | ||
tcpConnectionPool.close(); | ||
cb(); | ||
@@ -103,0 +110,0 @@ }; |
{ | ||
"name": "log4js-logstash-tcp", | ||
"version": "2.0.3", | ||
"version": "2.0.4", | ||
"author": "Aigent B.V.", | ||
@@ -15,2 +15,7 @@ "description": "This is a copy of the logstashUDP appender but instead sending via UDP send via TCP to avoid the maximum 64k bytes message size with the logstashUDP appender.", | ||
"email": "sebastian@aigent.com" | ||
}, | ||
{ | ||
"name": "Sebastian Lagemann", | ||
"email": "sebastian@slab.rocks", | ||
"url": "https://slab.rocks" | ||
} | ||
@@ -29,12 +34,12 @@ ], | ||
"devDependencies": { | ||
"log4js": "^2.4.1", | ||
"nodeunit": "^0.11.2" | ||
"jest": "^29.5.0", | ||
"log4js": "^6.9.1" | ||
}, | ||
"scripts": { | ||
"test": "nodeunit tests" | ||
"test": "jest --coverage --detectOpenHandles" | ||
}, | ||
"engines": { | ||
"node": "0.10.x" | ||
"node": ">=6.4.0" | ||
}, | ||
"main": "./index.js" | ||
} |
@@ -54,2 +54,4 @@ log4js-logstash-tcp | ||
var log = log4js.getLogger('tests'); | ||
// adding context and add it as additional field to each log entry | ||
log.addContext('customer', {id: 123, name: 'John Doe'}); | ||
@@ -63,2 +65,2 @@ log.error('hello hello'); | ||
## License | ||
[![FOSSA Status](https://app.fossa.io/api/projects/git%2Bgithub.com%2FAigent%2Flog4js-logstash-tcp.svg?type=large)](https://app.fossa.io/projects/git%2Bgithub.com%2FAigent%2Flog4js-logstash-tcp?ref=badge_large) | ||
[![FOSSA Status](https://app.fossa.io/api/projects/git%2Bgithub.com%2FAigent%2Flog4js-logstash-tcp.svg?type=large)](https://app.fossa.io/projects/git%2Bgithub.com%2FAigent%2Flog4js-logstash-tcp?ref=badge_large) |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
144261
22
916
65
3