diff --git a/src/client.js b/src/client.js index 3b4c6d0..bd9b2ad 100644 --- a/src/client.js +++ b/src/client.js @@ -84,7 +84,10 @@ function getStreams(config) { streams.push({ name: 'logentries', level: config.level, - stream: new ClientLogentriesLogger({ token: config.logentriesToken }), + stream: new ClientLogentriesLogger({ + name: config.name, + token: config.logentriesToken + }), type: 'raw' }); } diff --git a/src/node.js b/src/node.js index 1e5a421..bf8ff1d 100644 --- a/src/node.js +++ b/src/node.js @@ -80,6 +80,7 @@ function getStreams(config) { // Transport server logs if (config.logentriesToken) { streams.push(new ServerLogentriesLogger({ + name: config.name, token: config.logentriesToken, level: config.level })); diff --git a/src/util/client/logentriesLogger.js b/src/util/client/logentriesLogger.js index b7b44da..1b9531e 100644 --- a/src/util/client/logentriesLogger.js +++ b/src/util/client/logentriesLogger.js @@ -7,12 +7,19 @@ import LE from 'le_js'; * @param {String} options.token * @param {String} options.level */ -export default function ClientLogentriesLogger({ token }) { - LE.init({ - token, - no_format: true, - page_info: 'per-page' - }); +export default function ClientLogentriesLogger({ name, token }) { + try { + // If a LE logger does not exist with this name, this will throw + LE.to(name); + } catch (err) { + // Init the LE logger + LE.init({ + name, + token, + no_format: true, + page_info: 'per-page' + }); + } } /** diff --git a/src/util/server/logentriesLogger.js b/src/util/server/logentriesLogger.js index 007156d..3942d84 100644 --- a/src/util/server/logentriesLogger.js +++ b/src/util/server/logentriesLogger.js @@ -7,8 +7,9 @@ import Logentries from 'le_node'; * @param {String} options.level * @returns {Object} - bunyan stream config */ -export default function ServerLogentriesLogger({ token, level }) { +export default function ServerLogentriesLogger({ name, token, level }) { const loggerDefinition = Logentries.bunyanStream({ + name, token, secure: true, withStack: true