Compare commits

..

1 Commits

Author SHA1 Message Date
Rahul Padigela 0ec8c532c4 perf: defer log processing if not log level 2016-06-16 16:34:20 -07:00
31 changed files with 598 additions and 1413 deletions

View File

@ -1 +1,13 @@
{ "extends": "scality" } {
"extends": "airbnb",
"env": {
"node": true,
"mocha": true
},
"rules": {
"indent": [2,4],
"no-multi-spaces": [2, { exceptions: { "SwitchCase": true, "CallExpression": true } } ],
"valid-jsdoc": 2,
"strict": 0
}
}

View File

@ -1,31 +0,0 @@
name: Tests
on:
push:
branches-ignore:
- development/**
- q/*/**
jobs:
tests:
runs-on: ubuntu-latest
steps:
- name: Checkokut
uses: actions/checkout@v4
- name: Install deps
run: sudo apt-get update -q
- uses: actions/setup-node@v4
with:
node-version: '16'
- name: Install Yarn
run: npm install -g yarn
- name: install dependencies
run: yarn install --frozen-lockfile
- name: run lint
run: echo "linter is disabled temporarily ()" || yarn run --silent lint -- --max-warnings 0
- name: run lint_md
run: yarn --silent lint_md
- name: run test
run: yarn test
- name: run coverage
run: yarn coverage

View File

@ -41,7 +41,6 @@ as it means that whenever the errors happen, depending on your log level, you
might have already lost quite a bit of priceless information about the error might have already lost quite a bit of priceless information about the error
encountered, and the code path the request went through. To address this, we encountered, and the code path the request went through. To address this, we
offer multiple features: offer multiple features:
* [Request ID namespacing](###request-id-namespacing) * [Request ID namespacing](###request-id-namespacing)
* [Request unit Logs](###request-unit-logs) * [Request unit Logs](###request-unit-logs)
@ -88,3 +87,5 @@ error (or higher level logging operation) is logged before the log context is
freed, then the full set of buffered logging messages is freed, not taking freed, then the full set of buffered logging messages is freed, not taking
any logging resources for the log entries not considered 'useless' by a given any logging resources for the log entries not considered 'useless' by a given
log level configuration. log level configuration.

View File

@ -1,5 +1,6 @@
# WereLogs # WereLogs
[![CircleCI][badgepub]](https://circleci.com/gh/scality/werelogs)
[![Scality CI][badgepriv]](http://ci.ironmann.io/gh/scality/werelogs) [![Scality CI][badgepriv]](http://ci.ironmann.io/gh/scality/werelogs)
This repository provides a NodeJS Library that aims to be an efficient logging This repository provides a NodeJS Library that aims to be an efficient logging
@ -18,8 +19,7 @@ https://github.com/scality/Guidelines/blob/master/CONTRIBUTING.md).
In order to install WereLogs, you can use NPM with github's HTTP url, and save In order to install WereLogs, you can use NPM with github's HTTP url, and save
it in your own package.json: it in your own package.json:
```
```sh
$> npm i --save scality/werelogs $> npm i --save scality/werelogs
``` ```
@ -157,3 +157,11 @@ In order to find out the known issues, it is advised to take a look at the
[project's github page](http://github.com/scality/werelogs). There, you should [project's github page](http://github.com/scality/werelogs). There, you should
be able to find the issues, tagged with the releases they are impacting, be able to find the issues, tagged with the releases they are impacting,
whether they're open or closed. whether they're open or closed.
## Contributing
The contributing rules for this project are defined in the associated
CONTRIBUTING.md file.
[badgepub]: https://circleci.com/gh/scality/werelogs.svg?style=svg
[badgepriv]: http://ci.ironmann.io/gh/scality/werelogs.svg?style=svg&circle-token=a946e81ad65b99814403b5e57f017d9ecbe93f0a

23
circle.yml Normal file
View File

@ -0,0 +1,23 @@
general:
branches:
ignore:
- /^ultron\/.*/ # Ignore ultron/* branches
artifacts:
- coverage/
- doc/
machine:
node:
version: 4.1.0
test:
override:
- npm run lint_md
- npm run lint
- npm run gendoc
- npm run coverage
# running ft_test packs werelogs and installs it + deps into
# tests/functional. Pack is like publishing werelogs in a local tgz
# archive that can be installed.
# This step shall ensure that no issue is encountered when installing
# the package, and allows to functionally test werelogs.
- npm run ft_test

65
index.d.ts vendored
View File

@ -1,65 +0,0 @@
interface WerelogsConfigOptions {
level?: 'trace' | 'debug' | 'info' | 'warn' | 'error' | 'fatal';
dump?: 'trace' | 'debug' | 'info' | 'warn' | 'error' | 'fatal';
streams?: object[];
}
declare class WerelogsConfig {
constructor(config?: WerelogsConfigOptions);
reset(): WerelogsConfig;
update(config: WerelogsConfig): WerelogsConfig;
logger: any;
level: 'trace' | 'debug' | 'info' | 'warn' | 'error' | 'fatal';
dump: 'trace' | 'debug' | 'info' | 'warn' | 'error' | 'fatal';
end: 'trace' | 'debug' | 'info' | 'warn' | 'error' | 'fatal';
}
interface LogDictionary {
httpMethod?: string;
httpURL?: string;
[field: string]: any;
}
declare module 'werelogs' {
export class RequestLogger {
constructor(
logger: any,
logLevel: string,
dumpThreshold: string,
endLevel: string,
uids?: string|Array<string>
);
getUids(): Array<string>;
getSerializedUids(): string;
addDefaultFields(fields: LogDictionary): LogDictionary;
trace(msg: string, data?: LogDictionary): void;
debug(msg: string, data?: LogDictionary): void;
info(msg: string, data?: LogDictionary): void;
warn(msg: string, data?: LogDictionary): void;
error(msg: string, data?: LogDictionary): void;
fatal(msg: string, data?: LogDictionary): void;
end(msg: string, data?: LogDictionary): void;
errorEnd(msg: string, data?:LogDictionary): void;
}
export class Logger {
name: string;
constructor(name: string);
newRequestLogger(uids?: string|Array<string>): RequestLogger;
newRequestLoggerFromSerializedUids(uids: string): RequestLogger;
trace(msg: string, data?: LogDictionary): void;
debug(msg: string, data?: LogDictionary): void;
info(msg: string, data?: LogDictionary): void;
warn(msg: string, data?: LogDictionary): void;
error(msg: string, data?: LogDictionary): void;
fatal(msg: string, data?: LogDictionary): void;
}
export function configure(config: WerelogsConfigOptions): void;
export class API {
constructor(config: WerelogsConfigOptions);
reconfigure(config: WerelogsConfigOptions): void;
Logger: Logger;
}
}

View File

@ -1,51 +1 @@
const API = require('./lib/api.js'); module.exports = require('./lib/Logger.js');
const stderrUtils = require('./lib/stderrUtils');
/*
* For convenience purposes, we provide an already instanciated API; so that
* old uses of the imported Logger class can be kept as-is. For quick logging,
* this also provides a hassle-free way to log using werelogs.
*/
const werelogs = new API();
module.exports = {
Logger: werelogs.Logger,
configure: werelogs.reconfigure.bind(werelogs),
Werelogs: API,
/**
* Timestamp logs going to stderr
*
* @example <caption>Simplest usage</caption>
* ```
* const { stderrUtils } = require('werelogs');
* stderrUtils.catchAndTimestampStderr();
* ```
*
* @example <caption>Manage process exit</caption>
* ```
* const { stderrUtils } = require('werelogs');
* // set exitCode to null to keep process running on uncaughtException
* stderrUtils.catchAndTimestampStderr(undefined, null);
* // application init
* process.on('uncaughtException', (err) => {
* // custom handling, close connections, files
* this.worker.kill(); // or process.exit(1);
* });
* // Note you could use prependListener to execute your callback first
* // and then let stderrUtils exit the process.
* ```
*
* @example <caption>Custom listener</caption>
* ```
* const { stderrUtils } = require('werelogs');
* stderrUtils.catchAndTimestampWarning();
* // application init
* process.on('uncaughtException', (err, origin) => {
* stderrUtils.printErrorWithTimestamp(err, origin);
* // close and stop everything
* process.exit(1);
* });
* ```
*/
stderrUtils,
};

View File

@ -1,5 +1,5 @@
'use strict';
// eslint-disable-line strict
const LogLevel = require('./LogLevel.js'); const LogLevel = require('./LogLevel.js');
const SimpleLogger = require('./SimpleLogger.js'); const SimpleLogger = require('./SimpleLogger.js');
@ -15,31 +15,10 @@ class Config {
* This is the default constructor of the Config Object, and the only way * This is the default constructor of the Config Object, and the only way
* to instanciate it (with default parameters). * to instanciate it (with default parameters).
* *
* @param {object} conf - A configuration object for werelogs.
* @param {string} conf.level - The string name of the logging level
* ('trace', 'debug', 'info', 'warn',
* 'error' and 'fatal' in order of
* importance.)
* @param {string} conf.dump - The string name of the log dumping
* level ('trace', 'debug', 'info',
* 'warn', 'error' and 'fatal' in order
* of importance.)
* @param {object[]} conf.streams - The array of streams into which to
* log. This is an Array of objects
* which have a field named 'stream',
* which is writeable.
*
* @returns {undefined} * @returns {undefined}
*/ */
constructor(conf) { constructor() {
this.logLevel = 'info'; this.reset();
this.dumpThreshold = 'error';
this.endLevel = 'info';
this.streams = [{ level: 'trace', stream: process.stdout }];
this.simpleLogger = new SimpleLogger('werelogs', this.streams);
if (conf) {
this.update(conf);
}
} }
/** /**
@ -71,10 +50,12 @@ class Config {
* ('trace', 'debug', 'info', 'warn', * ('trace', 'debug', 'info', 'warn',
* 'error' and 'fatal' in order of * 'error' and 'fatal' in order of
* importance.) * importance.)
* @param {object[]} config.streams - The array of streams into which to * @param {object[]} config.streams - The array of streams into which to log.
* log. This is an Array of objects * Their configuration is directly
* which have a field named 'stream', * related to the expected bunyan
* which is writeable. * streams array, for compatibility
* purposes (except that the 'level'
* field is not accounted for)
* *
* @see [Bunyan's documentation]{@link * @see [Bunyan's documentation]{@link
* https://github.com/trentm/node-bunyan/blob/master/README.md#streams} for * https://github.com/trentm/node-bunyan/blob/master/README.md#streams} for
@ -89,46 +70,30 @@ class Config {
const checkedConfig = config || {}; const checkedConfig = config || {};
if (Object.prototype.hasOwnProperty.call(checkedConfig, 'level')) { if (checkedConfig.hasOwnProperty('level')) {
LogLevel.throwIfInvalid(checkedConfig.level); LogLevel.throwIfInvalid(checkedConfig.level);
}
if (Object.prototype.hasOwnProperty.call(checkedConfig, 'dump')) {
LogLevel.throwIfInvalid(checkedConfig.dump);
}
// for check log level vs. log dump level
const newLogLevel = checkedConfig.level || this.logLevel;
const newLogDumpLevel = checkedConfig.dump || this.dumpThreshold;
if (newLogDumpLevel
&& !LogLevel.shouldLog(newLogDumpLevel, newLogLevel)) {
throw new Error(
'Logging level should be at most logging dump level',
);
}
if (Object.prototype.hasOwnProperty.call(checkedConfig, 'level')) {
this.logLevel = checkedConfig.level; this.logLevel = checkedConfig.level;
} }
if (Object.prototype.hasOwnProperty.call(checkedConfig, 'dump')) { if (checkedConfig.hasOwnProperty('dump')) {
LogLevel.throwIfInvalid(checkedConfig.dump);
this.dumpThreshold = checkedConfig.dump; this.dumpThreshold = checkedConfig.dump;
} }
if (Object.prototype.hasOwnProperty.call(checkedConfig, 'end')) { if (checkedConfig.hasOwnProperty('end')) {
LogLevel.throwIfInvalid(checkedConfig.end); LogLevel.throwIfInvalid(checkedConfig.end);
this.endLevel = checkedConfig.end; this.endLevel = checkedConfig.end;
} }
if (Object.prototype.hasOwnProperty.call(checkedConfig, 'streams')) { if (checkedConfig.hasOwnProperty('streams')) {
if (!Array.isArray(checkedConfig.streams)) { if (!Array.isArray(checkedConfig.streams)) {
throw new TypeError('WereLogs config.streams must be an Array ' throw new Error('WereLogs config.streams must be an Array of Writeable Streams.');
+ 'of Writeable Streams.');
} }
if (!checkedConfig.streams.length) { if (!checkedConfig.streams.length) {
throw new Error('Werelogs config.streams must contain at ' throw new Error('Werelogs config.streams must contain at least one stream.');
+ 'least one stream.');
} }
this.streams = checkedConfig.streams.map(stream => { this.streams = checkedConfig.streams.map((stream) => {
stream.level = 'trace'; // eslint-disable-line no-param-reassign stream.level = 'trace';
return stream; return stream;
}); });
@ -188,4 +153,4 @@ class Config {
} }
} }
module.exports = Config; module.exports = new Config();

View File

@ -1,5 +1,4 @@
'use strict';
// eslint-disable-line strict
const logLevels = [ const logLevels = [
'trace', 'trace',
@ -19,15 +18,10 @@ const logLevels = [
* *
* @throw {Error} A human-readable message that tells which log * @throw {Error} A human-readable message that tells which log
* levels are supported. * levels are supported.
* @throw {TypeError} A human-readable message indicating that the
* provided logging level was not a string
* *
* @returns {undefined} * @returns {undefined}
*/ */
function throwIfInvalid(level) { function throwIfInvalid(level) {
if (typeof level !== 'string') {
throw new TypeError('Logging level should be a string');
}
if (logLevels.indexOf(level) === -1) { if (logLevels.indexOf(level) === -1) {
throw new RangeError(`Invalid logging level: ${level} is neither` throw new RangeError(`Invalid logging level: ${level} is neither`
+ ` ${logLevels.join(', ')}.`); + ` ${logLevels.join(', ')}.`);

View File

@ -1,32 +1,52 @@
'use strict';
// eslint-disable-line strict
const LogLevel = require('./LogLevel.js'); const LogLevel = require('./LogLevel.js');
const RequestLogger = require('./RequestLogger.js'); const RequestLogger = require('./RequestLogger.js');
const { unserializeUids } = require('./Utils.js'); const unserializeUids = require('./Utils.js').unserializeUids;
const Config = require('./Config.js'); const Config = require('./Config.js');
class Logger { class Logger {
/** /**
* This is the constructor of the Logger class. It takes optional * This is the constructor of the Logger class. It takes optional
* configuration parameters, that allow to modify its behavior. * configuration parameters, that allow to modify its behavior.
* *
* @param {Werelogs.Config} config - An instanciated Werelogs Config object * @param {string} name - The name of the Logger. It can be found later on in
* the log entries.
* *
* @param {string} name - The name of the Logger. It can be found later on * @param {object} config - A configuration object for werelogs.
* in the log entries. * @param {string} config.level - The string name of the logging level
* ('trace', 'debug', 'info', 'warn',
* 'error' and 'fatal' in order of
* importance.)
* @param {string} config.dump - The string name of the log dumping level
* ('trace', 'debug', 'info', 'warn',
* 'error' and 'fatal' in order of
* importance.)
* @param {object[]} config.streams - The array of streams into which to log.
* Their configuration is directly
* related to the expected bunyan
* streams array, for compatibility
* purposes (except that the 'level'
* field is not accounted for)
*
* @see [Bunyan's documentation]{@link
* https://github.com/trentm/node-bunyan/blob/master/README.md#streams} for
* a more detailed description of the streams array configuration.
* *
* @returns {undefined} * @returns {undefined}
*/ */
constructor(config, name) { constructor(name, config) {
if (!(config instanceof Config)) {
throw new TypeError('Invalid parameter Type for "config".');
}
if (!(typeof name === 'string' || name instanceof String)) {
throw new TypeError('Invalid parameter Type for "name".');
}
this.config = config;
this.name = name; this.name = name;
Config.update(config);
}
setLevel(levelName) {
Config.update({ level: levelName });
}
setDumpThreshold(levelName) {
Config.update({ dump: levelName });
} }
/** /**
@ -38,9 +58,9 @@ class Logger {
* @returns {RequestLogger} A Valid Request Logger * @returns {RequestLogger} A Valid Request Logger
*/ */
newRequestLogger(uids) { newRequestLogger(uids) {
const rLog = new RequestLogger(this.config.logger, const rLog = new RequestLogger(Config.logger,
this.config.level, this.config.dump, Config.level, Config.dump, Config.end,
this.config.end, uids); uids);
rLog.addDefaultFields({name: this.name}); rLog.addDefaultFields({name: this.name});
return rLog; return rLog;
} }
@ -54,32 +74,30 @@ class Logger {
* @returns {RequestLogger} A Valid Request Logger * @returns {RequestLogger} A Valid Request Logger
*/ */
newRequestLoggerFromSerializedUids(serializedUids) { newRequestLoggerFromSerializedUids(serializedUids) {
const rLog = new RequestLogger(this.config.logger, const rLog = new RequestLogger(Config.logger,
this.config.level, this.config.dump, Config.level, Config.dump, Config.end,
this.config.end,
unserializeUids(serializedUids)); unserializeUids(serializedUids));
rLog.addDefaultFields({name: this.name}); rLog.addDefaultFields({name: this.name});
return rLog; return rLog;
} }
_doLog(levelName, msg, data) { _doLog(levelName, msg, data) {
const sLogger = this.config.logger; const sLogger = Config.logger;
const finalData = { name: this.name, time: Date.now() }; const finalData = { name: this.name };
if (!LogLevel.shouldLog(levelName, this.config.level)) { if (!LogLevel.shouldLog(levelName, Config.level)) {
return; return;
} }
if (data !== undefined && typeof data !== 'object') { if (data !== undefined && typeof data !== 'object') {
sLogger.fatal( sLogger.fatal(
{ {
callparams: [msg, data], 'callparams': [ msg, data ],
}, },
'Werelogs API was mis-used.' 'Werelogs API was mis-used.'
+ ' This development error should be fixed ASAP.', + ' This development error should be fixed ASAP.');
);
return; return;
} }
if (data) { if (data) {
Object.keys(data).forEach(k => { Object.keys(data).forEach((k) => {
finalData[k] = data[k]; finalData[k] = data[k];
}); });
} }

View File

@ -1,15 +1,16 @@
'use strict';
// eslint-disable-line strict const assert = require('assert');
const LogLevel = require('./LogLevel.js'); const LogLevel = require('./LogLevel.js');
const Utils = require('./Utils.js'); const Utils = require('./Utils.js');
const serializeUids = Utils.serializeUids;
const { serializeUids, generateUid, objectCopy } = Utils; const generateUid = Utils.generateUid;
const objectCopy = Utils.objectCopy;
function ensureUidValidity(uid) { function ensureUidValidity(uid) {
if (uid.indexOf(':') !== -1) { if (uid.indexOf(':') !== -1) {
throw new Error(`RequestLogger UID "${uid}" contains an illegal ` throw new Error(`RequestLogger UID "${uid}" contains an illegal character: ':'.`);
+ 'character: \':\'.');
} }
return uid; return uid;
} }
@ -21,6 +22,9 @@ class EndLogger {
} }
augmentedLog(level, msg, data) { augmentedLog(level, msg, data) {
assert.strictEqual(this.logger.elapsedTime, null, 'The logger\'s'
+ 'end() wrapper should not be called more than'
+ ' once.');
// We can alter current instance, as it won't be usable after this // We can alter current instance, as it won't be usable after this
// call. // call.
this.fields = objectCopy(this.fields, data || {}); this.fields = objectCopy(this.fields, data || {});
@ -138,6 +142,7 @@ class EndLogger {
* request. * request.
*/ */
class RequestLogger { class RequestLogger {
/** /**
* Constructor of the WereLogs Request Logger. * Constructor of the WereLogs Request Logger.
* This function takes a logger instance, a logging level, and a last * This function takes a logger instance, a logging level, and a last
@ -173,7 +178,7 @@ class RequestLogger {
* @returns {undefined} * @returns {undefined}
*/ */
constructor(logger, logLevel, dumpThreshold, endLevel, uids) { constructor(logger, logLevel, dumpThreshold, endLevel, uids) {
let uidList; let uidList = undefined;
if (!LogLevel.shouldLog(dumpThreshold, logLevel)) { if (!LogLevel.shouldLog(dumpThreshold, logLevel)) {
throw new Error('Logging Dump level should be equal or' throw new Error('Logging Dump level should be equal or'
@ -183,7 +188,7 @@ class RequestLogger {
if (uids !== undefined && Array.isArray(uids)) { if (uids !== undefined && Array.isArray(uids)) {
uidList = uids.map(uid => ensureUidValidity(uid)); uidList = uids.map(uid => ensureUidValidity(uid));
uidList.push(generateUid()); uidList.push(generateUid());
} else if (uids !== undefined && typeof uids === 'string') { } else if (uids !== undefined && typeof(uids) === 'string') {
uidList = [ ensureUidValidity(uids) ]; uidList = [ ensureUidValidity(uids) ];
} }
this.uids = uidList || [ generateUid() ]; this.uids = uidList || [ generateUid() ];
@ -365,6 +370,8 @@ class RequestLogger {
if (msg === undefined && data === undefined) { if (msg === undefined && data === undefined) {
return this.endLogger; return this.endLogger;
} }
assert.strictEqual(this.elapsedTime, null, 'The "end()" logging method '
+ 'should not be called more than once.');
return this.log(this.endLevel, msg, data, true); return this.log(this.endLevel, msg, data, true);
} }
@ -381,6 +388,8 @@ class RequestLogger {
* @returns {undefined} * @returns {undefined}
*/ */
errorEnd(msg, data) { errorEnd(msg, data) {
assert.strictEqual(this.elapsedTime, null, 'The "end()" logging method '
+ 'should not be called more than once.');
return this.log('error', msg, data, true); return this.log('error', msg, data, true);
} }
@ -421,45 +430,38 @@ class RequestLogger {
'Werelogs API was mis-used.' 'Werelogs API was mis-used.'
+ ' This development error should be fixed ASAP.', + ' This development error should be fixed ASAP.',
{ {
callparams: [msg, logFields], 'callparams': [ msg, logFields ],
}, });
);
return; return;
} }
const fields = objectCopy({}, this.fields, logFields || {}); // removes object references
const endFlag = isEnd || false; const _logFields = logFields ?
JSON.parse(JSON.stringify(logFields)) : {};
/* /*
* using Date.now() as it's faster than new Date(). logstash component * using Date.now() as it's faster than new Date(). logstash component
* uses this field to generate ISO 8601 timestamp * uses this field to generate ISO 8601 timestamp
*/ */
if (fields.time === undefined) { if (_logFields.time === undefined) {
fields.time = Date.now(); _logFields.time = Date.now();
} }
_logFields.req_id = serializeUids(this.uids);
// eslint-disable-next-line camelcase const endFlag = isEnd || false;
fields.req_id = serializeUids(this.uids);
if (endFlag) { if (endFlag) {
if (this.elapsedTime !== null) {
// reset elapsedTime to avoid an infinite recursion
// while logging the error
this.elapsedTime = null;
this.error('RequestLogger.end() has been called more than once');
}
this.elapsedTime = process.hrtime(this.startTime); this.elapsedTime = process.hrtime(this.startTime);
// eslint-disable-next-line camelcase _logFields.elapsed_ms = this.elapsedTime[0] * 1000
fields.elapsed_ms = this.elapsedTime[0] * 1000
+ this.elapsedTime[1] / 1000000; + this.elapsedTime[1] / 1000000;
} }
// const fields = objectCopy({}, this.fields, _logFields || {});
const logEntry = { const logEntry = {
level, level,
fields, fields: _logFields,
msg, msg,
}; };
this.entries.push(logEntry); this.entries.push(logEntry);
if (LogLevel.shouldLog(level, this.dumpThreshold)) { if (LogLevel.shouldLog(level, this.dumpThreshold)) {
this.entries.forEach(entry => { this.entries.forEach((entry) => {
this.doLogIO(entry); this.doLogIO(entry);
}); });
this.entries = []; this.entries = [];
@ -484,24 +486,25 @@ class RequestLogger {
* @returns {undefined} * @returns {undefined}
*/ */
doLogIO(logEntry) { doLogIO(logEntry) {
const fields = objectCopy({}, this.fields, logEntry.fields);
switch (logEntry.level) { switch (logEntry.level) {
case 'trace': case 'trace':
this.sLogger.trace(logEntry.fields, logEntry.msg); this.sLogger.trace(fields, logEntry.msg);
break; break;
case 'debug': case 'debug':
this.sLogger.debug(logEntry.fields, logEntry.msg); this.sLogger.debug(fields, logEntry.msg);
break; break;
case 'info': case 'info':
this.sLogger.info(logEntry.fields, logEntry.msg); this.sLogger.info(fields, logEntry.msg);
break; break;
case 'warn': case 'warn':
this.sLogger.warn(logEntry.fields, logEntry.msg); this.sLogger.warn(fields, logEntry.msg);
break; break;
case 'error': case 'error':
this.sLogger.error(logEntry.fields, logEntry.msg); this.sLogger.error(fields, logEntry.msg);
break; break;
case 'fatal': case 'fatal':
this.sLogger.fatal(logEntry.fields, logEntry.msg); this.sLogger.fatal(fields, logEntry.msg);
break; break;
default: default:
throw new Error(`Unexpected log level: ${logEntry.level}`); throw new Error(`Unexpected log level: ${logEntry.level}`);

View File

@ -1,17 +1,6 @@
'use strict';
// eslint-disable-line strict
const os = require('os'); const os = require('os');
const safeJSONStringify = require('safe-json-stringify'); const safeJSONStringify = require('safe-json-stringify');
const fastJSONStringify = require('fast-safe-stringify')
function errorStackReplacer(key, value) {
if (value instanceof Error) {
return value.stack;
}
return value;
}
/* /*
* This function safely stringifies JSON. If an exception occcurs (due to * This function safely stringifies JSON. If an exception occcurs (due to
* circular references, exceptions thrown from object getters etc.), the module * circular references, exceptions thrown from object getters etc.), the module
@ -23,13 +12,11 @@ function errorStackReplacer(key, value) {
function safeStringify(obj) { function safeStringify(obj) {
let str; let str;
try { try {
// Try to stringify the object (fast version) str = JSON.stringify(obj);
str = fastJSONStringify(obj, errorStackReplacer);
} catch (e) { } catch (e) {
// fallback to remove circular object references or other exceptions // fallback to remove circular object references or other exceptions
// eslint-disable-next-line no-param-reassign
obj.unsafeJSON = true; obj.unsafeJSON = true;
return safeJSONStringify(obj, errorStackReplacer); return safeJSONStringify(obj);
} }
return str; return str;
} }
@ -45,11 +32,11 @@ function isWriteableStream(s) {
class SimpleLogger { class SimpleLogger {
constructor(name, streams) { constructor(name, streams) {
this.name = name; this.name = name;
this.streams = [{ level: 'trace', stream: process.stdout }]; this.streams = [ { level: 'info', stream: process.stdout } ];
if (streams) { if (streams) {
if (!Array.isArray(streams)) { if (!Array.isArray(streams)) {
throw new Error('Invalid streams. streams must be an array' throw new Error('Invalid streams. streams must be an array list' +
+ ' list of writeable streams'); ' of writeable streams');
} }
/* /*
* This is for backwards compatibility. current config in projects * This is for backwards compatibility. current config in projects
@ -60,7 +47,6 @@ class SimpleLogger {
*/ */
this.streams = streams.filter(isWriteableStream); this.streams = streams.filter(isWriteableStream);
} }
this.hostname = os.hostname();
} }
log(level, fields, message) { log(level, fields, message) {
@ -76,12 +62,11 @@ class SimpleLogger {
// TODO - Protect these fields from being overwritten // TODO - Protect these fields from being overwritten
logFields.level = level; logFields.level = level;
logFields.message = logMsg; logFields.message = logMsg;
logFields.hostname = this.hostname; logFields.hostname = os.hostname();
logFields.pid = process.pid; logFields.pid = process.pid;
const safeString = safeStringify(logFields);
this.streams.forEach( s => s.stream this.streams.forEach( s => s.stream
.write(`${safeString}\n`)); .write(safeStringify(logFields) + '\n'));
} }
info(fields, message) { info(fields, message) {

View File

@ -1,38 +1,18 @@
'use strict';
// eslint-disable-line strict
/**
* @constant
* @type {String[]} - The lookup table to generate the UID
*/
const lut = [];
for (let i = 0; i < 256; i++) {
lut[i] = (i < 16 ? '0' : '') + (i).toString(16);
}
/** /**
* This function generates a string uid. * This function generates a string uid.
* *
* The base algorithm is taken from here: http://jcward.com/UUID.js
* And is explained here: http://stackoverflow.com/a/21963136
*
* @returns {string} An hexadecimal string representation of an unique * @returns {string} An hexadecimal string representation of an unique
* id made of 80 bits.of entropy. * id made of 80 bits.of entropy.
*/ */
function generateUid() { function generateUid() {
const d0 = Math.random() * 0xffffffff | 0; function s4() {
const d1 = Math.random() * 0xffffffff | 0; return Math.floor((1 + Math.random()) * 0x10000)
const d2 = Math.random() * 0xffffffff | 0; .toString(16)
return lut[d0 & 0xff] .substring(1);
+ lut[d0 >> 8 & 0xff] }
+ lut[d0 >> 16 & 0xff] return s4() + s4() + s4() + s4() + s4();
+ lut[d1 & 0xff]
+ lut[d1 >> 8 & 0xff]
+ lut[d1 >> 16 & 0x0f | 0x40]
+ lut[d2 & 0x3f | 0x80]
+ lut[d2 >> 8 & 0xff]
+ lut[d2 >> 16 & 0xff]
+ lut[d2 >> 24 & 0xff];
} }
/** /**
@ -54,33 +34,27 @@ function serializeUids(uidList) {
* *
* @param {string} stringdata - The string data of the serialized array of UIDs * @param {string} stringdata - The string data of the serialized array of UIDs
* *
* @returns {string[]} - The unserialized array of string UIDs * @returns {string[]} The unserialized array of string UIDs
*/ */
function unserializeUids(stringdata) { function unserializeUids(stringdata) {
return stringdata.split(':'); return stringdata.split(':');
} }
/** /**
* This function copies the properties from the source object to the target * This function copies the properties from the source object to the target object
* object.
*
* @param {...object} target - object to be copied to * @param {...object} target - object to be copied to
* @returns {object} - target object * @returns {object} - target object
*/ */
function objectCopy(target) { function objectCopy(target) {
const result = target; const result = target;
/* eslint-disable prefer-rest-params */ let source;
const nb = arguments.length; function copy(f) {
for (let i = 1; i < nb; i++) { result[f] = source[f];
const source = arguments[i];
const keys = Object.keys(source);
const keysNb = keys.length;
for (let j = 0; j < keysNb; j++) {
const key = keys[j];
result[key] = source[key];
} }
for (let i = 1; i < arguments.length; i++) {
source = arguments[i];
Object.keys(source).forEach(copy);
} }
/* eslint-enable prefer-rest-params */
return result; return result;
} }

View File

@ -1,72 +0,0 @@
// eslint-disable-line strict
const Config = require('./Config.js');
const Logger = require('./Logger.js');
class API {
/**
* This is the constructor of the Logger class. It takes optional
* configuration parameters, that allow to modify its behavior.
*
* @param {object} config - A configuration object for werelogs.
* @param {string} config.level - The name of the logging level ('trace',
* 'debug', 'info', 'warn', 'error' and
* 'fatal' in order of importance.)
* @param {string} config.dump - The name of the log dumping level
* ('trace', 'debug', 'info', 'warn',
* 'error' and 'fatal' in order of
* importance.)
* @param {object[]} config.streams - The streams into which to log. This
* is an Array of objects which have a
* field named 'stream', which is
* writeable.
*/
constructor(config) {
this.config = new Config(config);
this.preboundLogger = Logger.bind(null, this.config);
}
/**
* This is a thunk function that allows reconfiguring the streams and log
* levels of all Logger and future RequestLogger objects. Note that
* existing RequestLogger will live their lifespan retaining the old
* configuration.
* If the provided configuration is erroneous, the function may throw
* exceptions depending on the detected configuration error. Please see the
* Config class's documentation about that.
*
* @throws {TypeError} - One of the provided arguments is not of the
* expected type
* @throws {RangeError} - The logging level provided is not part of the
* supported logging levels
* @throws {Error} - A human-readable message providing details about
* a logic error due to the input parameters
* provided.
*
* @param {object} config - A configuration object for werelogs.
* @param {string} config.level - The name of the logging level ('trace',
* 'debug', 'info', 'warn', 'error' and
* 'fatal' in order of importance.)
* @param {string} config.dump - The name of the log dumping level
* ('trace', 'debug', 'info', 'warn',
* 'error' and 'fatal' in order of
* importance.)
* @param {object[]} config.streams - The streams into which to log. This
* is an Array of objects which have a
* field named 'stream', which is
* writeable.
*
* @returns {undefined}
*
*/
reconfigure(config) {
this.config.update(config);
}
get Logger() {
return this.preboundLogger;
}
}
module.exports = API;

View File

@ -1,106 +0,0 @@
/**
* @returns {string} a timestamp in ISO format YYYY-MM-DDThh:mm:ss.sssZ
*/
const defaultTimestamp = () => new Date().toISOString();
/**
* Prints on stderr a timestamp, the origin and the error
*
* If no other instructions are needed on uncaughtException,
* consider using `catchAndTimestampStderr` directly.
*
* @example
* process.on('uncaughtException', (err, origin) => {
* printErrorWithTimestamp(err, origin);
* // server.close();
* // file.close();
* process.nextTick(() => process.exit(1));
* });
* // Don't forget to timestamp warning
* catchAndTimestampWarning();
* @param {Error} err see process event uncaughtException
* @param {uncaughtException|unhandledRejection} origin see process event
* @param {string} [date=`defaultTimestamp()`] Date to print
* @returns {boolean} see process.stderr.write
*/
function printErrorWithTimestamp(
err, origin, date = defaultTimestamp(),
) {
return process.stderr.write(`${date}: ${origin}:\n${err.stack}\n`);
}
/**
* Prefer using `catchAndTimestampStderr` instead of this function.
*
* Adds listener for uncaughtException to print with timestamp.
*
* If you want to manage the end of the process, you can set exitCode to null.
* Or use `printErrorWithTimestamp` in your own uncaughtException listener.
*
* @param {Function} [dateFct=`defaultTimestamp`] Fct returning a formatted date
* @param {*} [exitCode=1] On uncaughtException, if not null, `process.exit`
* will be called with this value
* @returns {undefined}
*/
function catchAndTimestampUncaughtException(
dateFct = defaultTimestamp, exitCode = 1,
) {
process.on('uncaughtException', (err, origin) => {
printErrorWithTimestamp(err, origin, dateFct());
if (exitCode !== null) {
process.nextTick(() => process.exit(exitCode));
}
});
}
/**
* Forces the use of `--trace-warnings` and adds a date in warning.detail
* The warning will be printed by the default `onWarning`
*
* @param {string} [dateFct=`defaultTimestamp`] Fct returning a formatted date
* @returns {undefined}
*/
function catchAndTimestampWarning(dateFct = defaultTimestamp) {
process.traceProcessWarnings = true;
// must be executed first, before the default `onWarning`
process.prependListener('warning', warning => {
if (warning.detail) {
// eslint-disable-next-line no-param-reassign
warning.detail += `\nAbove Warning Date: ${dateFct()}`;
} else {
// eslint-disable-next-line no-param-reassign
warning.detail = `Above Warning Date: ${dateFct()}`;
}
});
}
/**
* Adds listener for uncaughtException and warning to print them with timestamp.
*
* If you want to manage the end of the process, you can set exitCode to null.
* Or use `printErrorWithTimestamp` in your own uncaughtException listener.
*
* @example
* const { stderrUtils } = require('werelogs');
* // first instruction in your index.js or entrypoint
* stderrUtils.catchAndTimestampStderr();
*
* @param {Function} [dateFct=`defaultTimestamp`] Fct returning a formatted date
* @param {*} [exitCode=1] On uncaughtException, if not null, `process.exit`
* will be called with this value
* @returns {undefined}
*/
function catchAndTimestampStderr(
dateFct = defaultTimestamp, exitCode = 1,
) {
catchAndTimestampUncaughtException(dateFct, exitCode);
catchAndTimestampWarning(dateFct);
}
module.exports = {
defaultTimestamp,
printErrorWithTimestamp,
catchAndTimestampUncaughtException,
catchAndTimestampWarning,
catchAndTimestampStderr,
};

View File

@ -1,18 +1,15 @@
{ {
"name": "werelogs", "name": "werelogs",
"engines": { "version": "1.1.0",
"node": ">=10"
},
"version": "8.1.5",
"description": "An efficient raw JSON logging library aimed at micro-services architectures.", "description": "An efficient raw JSON logging library aimed at micro-services architectures.",
"main": "index.js", "main": "index.js",
"scripts": { "scripts": {
"gendoc": "jsdoc $(git ls-files 'lib/*.js') -d doc", "gendoc": "jsdoc $(git ls-files 'lib/*.js') -d doc",
"lint": "eslint $(git ls-files '*.js')", "lint": "eslint $(git ls-files '*.js')",
"lint_md": "markdownlint $(git ls-files '*.md')", "lint_md": "mdlint $(git ls-files '*.md')",
"test": "mocha tests/unit/", "test": "mocha tests/unit/",
"ft_test": "(npm pack && cp werelogs-*.tgz tests/functional && cd tests/functional && cp -R ../../node_modules/ node_modules/ && npm install werelogs-*.tgz && ./node_modules/.bin/mocha . multi-modules/ && rm -rf tests/functional/node_modules tests/functional/werelogs-*.tgz tests/functional/*lock*)", "ft_test": "rm -rf tests/functional/node_modules && npm pack && cp -R node_modules werelogs-*.tgz tests/functional && cd tests/functional && npm install werelogs-*.tgz && ./node_modules/.bin/mocha . multi-modules/ && cd -",
"coverage": "nyc ./node_modules/.bin/_mocha tests/unit" "coverage": "istanbul cover ./node_modules/.bin/_mocha tests/unit"
}, },
"repository": { "repository": {
"type": "git", "type": "git",
@ -33,20 +30,16 @@
}, },
"homepage": "https://github.com/scality/werelogs#readme", "homepage": "https://github.com/scality/werelogs#readme",
"dependencies": { "dependencies": {
"fast-safe-stringify": "^2.1.1", "safe-json-stringify": "^1.0.3"
"safe-json-stringify": "^1.2.0"
}, },
"devDependencies": { "devDependencies": {
"eslint": "^7.32.0", "eslint": "^1.10.1",
"eslint-config-airbnb": "^18.2.1", "eslint-config-airbnb": "^1.0.2",
"eslint-config-scality": "git+https://git.yourcmc.ru/vitalif/zenko-eslint-config-scality.git", "eslint-plugin-react": "^3.10.0",
"eslint-plugin-import": "^2.22.1", "istanbul": "^1.0.0-alpha",
"eslint-plugin-jsx-a11y": "^6.4.1", "istanbul-api": "==1.0.0-alpha.9",
"eslint-plugin-react": "^7.26.0", "jsdoc": "^3.4.0",
"eslint-plugin-react-hooks": "^4.2.0", "mdlint": "^0.1.0",
"jsdoc": "^3.4.3", "mocha": "^2.3.4"
"markdownlint-cli": "^0.27.1",
"mocha": ">=3.1.2",
"nyc": "^15.1.0"
} }
} }

View File

@ -1,20 +1,20 @@
'use strict';
// eslint-disable-line strict
const assert = require('assert'); const assert = require('assert');
const LogLevel = require('../lib/LogLevel.js'); const LogLevel = require('../lib/LogLevel.js');
class DummyLogger { class DummyLogger {
constructor() { constructor() {
this.ops = []; this.ops = [];
this.counts = { this.counts = {
trace: 0, 'trace': 0,
debug: 0, 'debug': 0,
info: 0, 'info': 0,
warn: 0, 'warn': 0,
error: 0, 'error': 0,
fatal: 0, 'fatal': 0,
}; };
} }
@ -57,8 +57,7 @@ function computeBehavior(filterLevel, logLevel, testLevel) {
return { return {
value, value,
msg: `Expected ${logLevel} to be called ${value} times with ` 'msg': `Expected ${logLevel} to be called ${value} times with filter level ${filterLevel}.`,
+ `filter level ${filterLevel}.`,
}; };
} }
@ -69,14 +68,12 @@ function genericFilterGenerator(filterLevel, testLevel, createLogger) {
const logger = createLogger(dummyLogger, filterLevel); const logger = createLogger(dummyLogger, filterLevel);
switch (testLevel) { switch (testLevel) {
/* eslint-disable no-multi-spaces */
case 'trace': logger.trace('test trace'); break; case 'trace': logger.trace('test trace'); break;
case 'debug': logger.debug('test debug'); break; case 'debug': logger.debug('test debug'); break;
case 'info': logger.info('test info'); break; case 'info': logger.info('test info'); break;
case 'warn': logger.warn('test warn'); break; case 'warn': logger.warn('test warn'); break;
case 'error': logger.error('test error'); break; case 'error': logger.error('test error'); break;
case 'fatal': logger.fatal('test fatal'); break; case 'fatal': logger.fatal('test fatal'); break;
/* eslint-enable no-multi-spaces */
default: default:
done(new Error('Unexpected testLevel name: ', testLevel)); done(new Error('Unexpected testLevel name: ', testLevel));
} }
@ -107,8 +104,7 @@ function loggingMisuseGenerator(test, createLogger) {
logger.info.apply(logger, test.args); logger.info.apply(logger, test.args);
}, },
Error, Error,
`Werelogs should not throw with ${test.desc}`, 'Werelogs should not throw with ' + test.desc);
);
assert(dummyLogger.ops[0][0], 'fatal', assert(dummyLogger.ops[0][0], 'fatal',
'Expected the Module Logger to have logged a fatal message.'); 'Expected the Module Logger to have logged a fatal message.');
done(); done();

View File

@ -1,12 +1,10 @@
'use strict';
// eslint-disable-line strict
const assert = require('assert'); const assert = require('assert');
const { PassThrough } = require('stream'); const PassThrough = require('stream').PassThrough;
const pass = new PassThrough;
const pass = new PassThrough(); const Logger = require('werelogs');
const werelogs = require('werelogs'); // eslint-disable-line
// With PassThrough, SimpleLogger can use it as Writeable stream and all the // With PassThrough, SimpleLogger can use it as Writeable stream and all the
// data being written can be read into a variable // data being written can be read into a variable
@ -17,7 +15,8 @@ pass.on('data', data => {
logBuffer.records.push(data.toString()); logBuffer.records.push(data.toString());
}); });
werelogs.configure({ function createModuleLogger() {
return new Logger('FT-test', {
level: 'info', level: 'info',
dump: 'error', dump: 'error',
streams: [ { streams: [ {
@ -25,15 +24,13 @@ werelogs.configure({
type: 'raw', type: 'raw',
} ], } ],
}); });
function createModuleLogger() {
return new werelogs.Logger('FT-test');
} }
function checkFields(fields) { function checkFields(fields) {
const record = JSON.parse(logBuffer.records[0].trim()); const record = JSON.parse(logBuffer.records[0].trim());
Object.keys(fields).forEach(k => { Object.keys(fields).forEach((k) => {
if (Object.prototype.hasOwnProperty.call(fields, k)) { if (fields.hasOwnProperty(k)) {
assert.deepStrictEqual(record[k], fields[k]); assert.deepStrictEqual(record[k], fields[k]);
} }
}); });
@ -48,16 +45,16 @@ describe('Werelogs is usable as a dependency', () => {
afterEach(() => { afterEach(() => {
logBuffer.records = []; logBuffer.records = [];
}); });
it('Should be able to create a logger', done => { it('Should be able to create a logger', (done) => {
assert.doesNotThrow( assert.doesNotThrow(
createModuleLogger, createModuleLogger,
Error, Error,
'Werelogs threw an exception trying to create a ModuleLogger.', 'Werelogs threw an exception trying to create a ModuleLogger.'
); );
done(); done();
}); });
it('Should be able to log a simple message', done => { it('Should be able to log a simple message', (done) => {
const logger = createModuleLogger(); const logger = createModuleLogger();
const msg = 'This is a simple message'; const msg = 'This is a simple message';
logger.info(msg); logger.info(msg);
@ -65,14 +62,10 @@ describe('Werelogs is usable as a dependency', () => {
done(); done();
}); });
it('Should be able to log a message and additional fields', done => { it('Should be able to log a message and additional fields', (done) => {
const logger = createModuleLogger(); const logger = createModuleLogger();
const msg = 'This is a message with added fields'; const msg = 'This is a message with added fields';
const fields = { const fields = { errorCode: 9, description: 'TestError', options: { dump: false } };
errorCode: 9,
description: 'TestError',
options: { dump: false },
};
logger.info(msg, fields); logger.info(msg, fields);
assert.strictEqual(parseLogEntry().message, msg); assert.strictEqual(parseLogEntry().message, msg);
checkFields(fields); checkFields(fields);
@ -84,16 +77,18 @@ describe('Werelogs is usable as a dependency', () => {
afterEach(() => { afterEach(() => {
logBuffer.records = []; logBuffer.records = [];
}); });
it('Should be able to create a logger', done => { it('Should be able to create a logger', (done) => {
assert.doesNotThrow( assert.doesNotThrow(
() => createModuleLogger().newRequestLogger(), () => {
return createModuleLogger().newRequestLogger();
},
Error, Error,
'Werelogs threw an exception trying to create a ModuleLogger.', 'Werelogs threw an exception trying to create a ModuleLogger.'
); );
done(); done();
}); });
it('Should be able to log a simple message', done => { it('Should be able to log a simple message', (done) => {
const logger = createModuleLogger().newRequestLogger(); const logger = createModuleLogger().newRequestLogger();
const msg = 'This is a simple message'; const msg = 'This is a simple message';
logger.info(msg); logger.info(msg);
@ -101,14 +96,10 @@ describe('Werelogs is usable as a dependency', () => {
done(); done();
}); });
it('Should be able to log a message and additional fields', done => { it('Should be able to log a message and additional fields', (done) => {
const logger = createModuleLogger().newRequestLogger(); const logger = createModuleLogger().newRequestLogger();
const msg = 'This is a message with added fields'; const msg = 'This is a message with added fields';
const fields = { const fields = { errorCode: 9, description: 'TestError', options: { dump: false } };
errorCode: 9,
description: 'TestError',
options: { dump: false },
};
logger.info(msg, fields); logger.info(msg, fields);
assert.strictEqual(parseLogEntry().message, msg); assert.strictEqual(parseLogEntry().message, msg);
checkFields(fields); checkFields(fields);

View File

@ -1,14 +1,13 @@
const assert = require('assert'); const assert = require('assert');
const { PassThrough } = require('stream'); const PassThrough = require('stream').PassThrough;
const Werelogs = require('werelogs'); // eslint-disable-line const Werelogs = require('werelogs');
const modules = [ const modules = [
require('./module1.js'), require('./module1.js'),
require('./module2.js'), require('./module2.js'),
require('./module3.js'), require('./module3.js'),
]; ];
const pass = new PassThrough;
const pass = new PassThrough();
const logBuffer = { const logBuffer = {
records: [], records: [],
@ -17,10 +16,9 @@ pass.on('data', data => {
logBuffer.records.push(JSON.parse(data.toString().trim())); logBuffer.records.push(JSON.parse(data.toString().trim()));
}); });
describe('Config is shared and unique within one API', () => { describe('Config is shared and unique within one program', () => {
it('should find all log entries in the RingBuffer with the right ' it('should find all log entries in the RingBuffer with the right module name', (done) => {
+ 'module name', done => { const log = new Werelogs('test-index', {
Werelogs.configure({
level: 'debug', level: 'debug',
dump: 'fatal', dump: 'fatal',
streams: [{ streams: [{
@ -28,12 +26,10 @@ describe('Config is shared and unique within one API', () => {
stream: pass, stream: pass,
}], }],
}); });
const log = new Werelogs.Logger('test-index'); modules.forEach((mod) => { mod(); });
modules.forEach(mod => { mod(); });
log.warn('Logging as warn'); log.warn('Logging as warn');
const rLog = log.newRequestLogger(); const rLog = log.newRequestLogger();
rLog.info('Logging request as info'); rLog.info('Logging request as info');
/* eslint-disable max-len */
assert.deepStrictEqual(logBuffer.records.length, 5, 'Expected to see 5 log entries in the ring buffer.'); assert.deepStrictEqual(logBuffer.records.length, 5, 'Expected to see 5 log entries in the ring buffer.');
assert.deepStrictEqual(logBuffer.records[0].message, 'Logging as info'); assert.deepStrictEqual(logBuffer.records[0].message, 'Logging as info');
assert.deepStrictEqual(logBuffer.records[0].name, 'test-mod1'); assert.deepStrictEqual(logBuffer.records[0].name, 'test-mod1');
@ -51,7 +47,6 @@ describe('Config is shared and unique within one API', () => {
assert.deepStrictEqual(logBuffer.records[4].name, 'test-index'); assert.deepStrictEqual(logBuffer.records[4].name, 'test-index');
assert.deepStrictEqual(logBuffer.records[4].level, 'info'); assert.deepStrictEqual(logBuffer.records[4].level, 'info');
assert.notStrictEqual(logBuffer.records[4].req_id, undefined); assert.notStrictEqual(logBuffer.records[4].req_id, undefined);
/* eslint-enable max-len */
done(); done();
}); });
}); });

View File

@ -1,4 +1,4 @@
const Werelogs = require('werelogs').Logger; // eslint-disable-line const Werelogs = require('werelogs');
const log = new Werelogs('test-mod1'); const log = new Werelogs('test-mod1');

View File

@ -1,4 +1,4 @@
const Werelogs = require('werelogs').Logger; // eslint-disable-line const Werelogs = require('werelogs');
const log = new Werelogs('test-mod2'); const log = new Werelogs('test-mod2');

View File

@ -1,4 +1,4 @@
const Werelogs = require('werelogs').Logger; // eslint-disable-line const Werelogs = require('werelogs');
const log = new Werelogs('test-mod3'); const log = new Werelogs('test-mod3');

View File

@ -1,58 +1,53 @@
/* eslint-disable max-len */
const assert = require('assert'); const assert = require('assert');
const Config = require('../../lib/Config.js'); const Config = require('../../lib/Config.js');
describe('Config', () => { describe('Config', () => {
const config = new Config();
beforeEach(() => { beforeEach(() => {
config.reset(); Config.reset();
}); });
it('should work with default configuration', done => { it('should work with default configuration', (done) => {
assert.doesNotThrow( assert.doesNotThrow(
() => { () => {
config.logger.info('test message'); Config.logger.info('test message');
}, },
Error, Error);
);
done(); done();
}); });
it('log level should be updateable', done => { it('log level should be updateable', (done) => {
config.update({ level: 'debug' }); Config.update({ level: 'debug' });
assert.strictEqual(config.level, 'debug', 'Expected config\'s log level to be updated.'); assert.strictEqual(Config.level, 'debug', 'Expected Config\'s log level to be updated.');
done(); done();
}); });
it('dump threshold should be updateable', done => { it('dump threshold should be updateable', (done) => {
const origDump = config.dump; const origDump = Config.dump;
assert.notStrictEqual(origDump, 'warn', 'Expected original config.dump to differ from value to update.'); assert.notStrictEqual(origDump, 'warn', 'Expected original Config.dump to differ from value to update.');
config.update({ dump: 'warn' }); Config.update({ dump: 'warn' });
assert.strictEqual(config.dump, 'warn', 'Expected config\'s dump threshold to be updated.'); assert.strictEqual(Config.dump, 'warn', 'Expected Config\'s dump threshold to be updated.');
done(); done();
}); });
it('end logging level should be updateable', done => { it('end logging level should be updateable', (done) => {
const origEnd = config.end; const origEnd = Config.end;
assert.notStrictEqual(origEnd, 'trace', 'Expected original config.end to differ from value to update.'); assert.notStrictEqual(origEnd, 'trace', 'Expected original Config.end to differ from value to update.');
config.update({ end: 'trace' }); Config.update({ end: 'trace' });
assert.strictEqual(config.end, 'trace', 'Expected config\'s end log level to be updated.'); assert.strictEqual(Config.end, 'trace', 'Expected Config\'s end log level to be updated.');
done(); done();
}); });
it('should not be modified by an empty config object', done => { it('should not be modified by an empty config object', (done) => {
const origLevel = config.level; const origLevel = Config.level;
const origDump = config.dump; const origDump = Config.dump;
const origLogger = config.logger; const origLogger = Config.logger;
const origStreams = config.streams; const origStreams = Config.streams;
config.update({}); Config.update({});
assert.deepStrictEqual(origLevel, config.level, 'Expected logging level not to have changed.'); assert.deepStrictEqual(origLevel, Config.level, 'Expected logging level not to have changed.');
assert.deepStrictEqual(origDump, config.dump, 'Expected dump threshold not to have changed.'); assert.deepStrictEqual(origDump, Config.dump, 'Expected dump threshold not to have changed.');
assert.strictEqual(origLogger, config.logger, 'Expected logger not to have changed.'); assert.strictEqual(origLogger, Config.logger, 'Expected logger not to have changed.');
assert.deepStrictEqual(origStreams, config.streams, 'Expected streams not to have changed.'); assert.deepStrictEqual(origStreams, Config.streams, 'Expected streams not to have changed.');
done(); done();
}); });
}); });

View File

@ -1,5 +1,4 @@
'use strict';
// eslint-disable-line strict
const assert = require('assert'); const assert = require('assert');
@ -13,23 +12,21 @@ function generateValidThrowTest(level) {
}, },
Error, Error,
'Expected level to be valid and ' 'Expected level to be valid and '
+ 'the function not to throw an Error.', + 'the function not to throw an Error.');
);
done(); done();
}; };
} }
describe('LogLevel', () => { describe('LogLevel', () => {
describe('throwIfInvalid(level)', () => { describe('throwIfInvalid(level)', () => {
it('should throw on invalid string', done => { it('should throw on invalid string', (done) => {
assert.throws( assert.throws(
() => { () => {
LogLevel.throwIfInvalid('invalid'); LogLevel.throwIfInvalid('invalid');
}, },
RangeError, RangeError,
'Expected function to throw an Error instance due to ' 'Expected function to throw an Error instance due to '
+ 'invalid log level.', + 'invalid log level.');
);
done(); done();
}); });
@ -53,57 +50,51 @@ describe('LogLevel', () => {
}); });
describe('shouldLog(level, floor)', () => { describe('shouldLog(level, floor)', () => {
it('should return true on "trace" parameters', done => { it('should return true on "trace" parameters', (done) => {
assert.strictEqual( assert.strictEqual(
LogLevel.shouldLog('trace', 'trace'), LogLevel.shouldLog('trace', 'trace'),
true, true,
'Expected trace floor to allow logging trace level.', 'Expected trace floor to allow logging trace level.');
);
done(); done();
}); });
it('should return true on "debug" parameters', done => { it('should return true on "debug" parameters', (done) => {
assert.strictEqual( assert.strictEqual(
LogLevel.shouldLog('debug', 'debug'), LogLevel.shouldLog('debug', 'debug'),
true, true,
'Expected debug floor to allow logging debug level.', 'Expected debug floor to allow logging debug level.');
);
done(); done();
}); });
it('should return true on "info" parameters', done => { it('should return true on "info" parameters', (done) => {
assert.strictEqual( assert.strictEqual(
LogLevel.shouldLog('info', 'info'), LogLevel.shouldLog('info', 'info'),
true, true,
'Expected info floor to allow logging info level.', 'Expected info floor to allow logging info level.');
);
done(); done();
}); });
it('should return true on "warn" parameters', done => { it('should return true on "warn" parameters', (done) => {
assert.strictEqual( assert.strictEqual(
LogLevel.shouldLog('warn', 'warn'), LogLevel.shouldLog('warn', 'warn'),
true, true,
'Expected warn floor to allow logging warn level.', 'Expected warn floor to allow logging warn level.');
);
done(); done();
}); });
it('should return true on "error" parameters', done => { it('should return true on "error" parameters', (done) => {
assert.strictEqual( assert.strictEqual(
LogLevel.shouldLog('error', 'error'), LogLevel.shouldLog('error', 'error'),
true, true,
'Expected error floor to allow logging error level.', 'Expected error floor to allow logging error level.');
);
done(); done();
}); });
it('should return true on "fatal" parameters', done => { it('should return true on "fatal" parameters', (done) => {
assert.strictEqual( assert.strictEqual(
LogLevel.shouldLog('fatal', 'fatal'), LogLevel.shouldLog('fatal', 'fatal'),
true, true,
'Expected fatal floor to allow logging fatal level.', 'Expected fatal floor to allow logging fatal level.');
);
done(); done();
}); });
}); });

View File

@ -1,15 +1,15 @@
'use strict';
// eslint-disable-line strict
const assert = require('assert'); const assert = require('assert');
const { genericFilterGenerator, loggingMisuseGenerator, DummyLogger } = require('../Utils'); const Utils = require('../Utils.js');
const genericFilterGenerator = Utils.genericFilterGenerator;
const loggingMisuseGenerator = Utils.loggingMisuseGenerator;
const DummyLogger = Utils.DummyLogger;
const Config = require('../../lib/Config.js'); const Config = require('../../lib/Config.js');
const RequestLogger = require('../../lib/RequestLogger.js'); const RequestLogger = require('../../lib/RequestLogger.js');
const Logger = require('../../lib/Logger.js'); const Logger = require('../../index.js');
const config = new Config();
/* /*
* This function is a thunk-function calling the Utils' filterGenerator with * This function is a thunk-function calling the Utils' filterGenerator with
@ -18,107 +18,163 @@ const config = new Config();
*/ */
function filterGenerator(logLevel, callLevel) { function filterGenerator(logLevel, callLevel) {
function createModuleLogger(dummyLogger, filterLevel) { function createModuleLogger(dummyLogger, filterLevel) {
const logger = new Logger('TestModuleLogger',
{
level: filterLevel,
dump: 'fatal',
});
/* /*
* Here, patch the config by setting a specifically designed dummyLogger * Here, patch the Config by setting a specificly designed dummyLogger
* for testing purposes that will help us collect runtime data. * for testing purposes that will help us collect runtime data.
*/ */
const testConfig = new Config({ level: filterLevel, dump: 'fatal' }); Config.simpleLogger = dummyLogger;
testConfig.simpleLogger = dummyLogger;
return new Logger(testConfig, 'TestModuleLogger'); return logger;
} }
return genericFilterGenerator(logLevel, callLevel, createModuleLogger); return genericFilterGenerator(logLevel, callLevel, createModuleLogger);
} }
function checkFields(src, result) { function checkFields(src, result) {
Object.keys(src).forEach(k => { Object.keys(src).forEach((k) => {
if (Object.prototype.hasOwnProperty.call(src, k)) { if (src.hasOwnProperty(k)) {
assert.deepStrictEqual(result[k], src[k]); assert.deepStrictEqual(result[k], src[k]);
} }
}); });
assert.ok(Object.prototype.hasOwnProperty.call(result, 'time'));
// Time field should be current give or take 1s
assert.ok((Date.now() - result.time) < 1000);
} }
describe('Logger is usable:', () => { describe('WereLogs Logger is usable:', () => {
beforeEach(() => { beforeEach(() => {
config.reset(); Config.reset();
}); });
it('Cannot be instanciated without parameters', done => { it('Can be instanciated with only a name', (done) => {
assert.throws( assert.doesNotThrow(
() => new Logger(), () => {
TypeError, return new Logger('WereLogsTest');
'Logger Instanciation should not succeed without parameter.', },
); Error,
'WereLogs Instanciation should not throw any kind of error.');
done(); done();
}); });
it('Cannot be instanciated with only a config', done => { it('Cannot be instanciated with invalid log level', (done) => {
assert.throws( assert.throws(
() => new Logger(config), () => {
TypeError, return new Logger('test', {level: 'invalidlevel'});
'Logger Instanciation should not be succeed without a name.', },
); RangeError,
'WereLogs should not be instanciable without the proper logging levels.');
done(); done();
}); });
it('Cannot be instanciated with a bad config type', done => { it('Cannot be instanciated with invalid dump threshold level', (done) => {
assert.throws( assert.throws(
() => new Logger({ level: 'info' }, 'WereLogsTest'), () => {
TypeError, return new Logger('test', {level: 'trace', dump: 'invalidlevel'});
'Logger Instanciation should not succeed with a bad config type.', },
); RangeError,
'WereLogs should not be instanciable without the proper dumping threshold levels.');
done(); done();
}); });
it('Cannot be instanciated with only a name', done => { it('Cannot be instanciated with a non-Array in config.streams', (done) => {
assert.throws( assert.throws(
() => new Logger('WereLogsTest'), () => {
TypeError, return new Logger('test', {streams: process.stdout});
'Logger Instanciation should not succeed with only a name.', },
); Error,
'Werelogs should not be instanciable with a stream option that is not an array.');
done(); done();
}); });
it('Can create Per-Request Loggers', done => { it('Cannot be instanciated with an empty Array in config.streams', (done) => {
const logger = new Logger(config, 'test'); assert.throws(
() => {
return new Logger('test', {streams: []});
},
Error,
'Werelogs should not be instanciable with an empty array for the streams option.');
done();
});
it('Cannot set logging level to invalid level at runtime', (done) => {
const logger = new Logger('test');
assert.throws(
() => {
logger.setLevel('invalidLevel');
},
RangeError,
'WereLogs should not be able to set log level to an invalid level.');
done();
});
it('Can set logging level at runtime', (done) => {
const logger = new Logger('test');
assert.doesNotThrow(
() => {
logger.setLevel('fatal');
},
RangeError,
'WereLogs should be able to set log level at runtime.');
done();
});
it('Cannot set dump threshold to invalid level at runtime', (done) => {
const logger = new Logger('test');
assert.throws(
() => {
logger.setDumpThreshold('invalidLevel');
},
RangeError,
'WereLogs should not be able to set dump threshold to an invalid level.');
done();
});
it('Can set dump threshold at runtime', (done) => {
const logger = new Logger('test');
assert.doesNotThrow(
() => {
logger.setDumpThreshold('fatal');
},
RangeError,
'WereLogs should be able to set dump threshold at runtime.');
done();
});
it('Can create Per-Request Loggers', (done) => {
const logger = new Logger('test');
assert.doesNotThrow( assert.doesNotThrow(
() => { () => {
logger.newRequestLogger(); logger.newRequestLogger();
}, },
Error, Error,
'Werelogs should not throw when creating a request logger.', 'Werelogs should not throw when creating a request logger.');
); const reqLogger = logger.newRequestLogger();
done();
});
it('Can create Per-Request Loggers from a Serialized UID Array', done => {
const logger = new Logger(config, 'test');
assert.doesNotThrow(
() => {
logger.newRequestLogger();
},
Error,
// eslint-disable-next-line max-len
'Werelogs should not throw when creating a request logger from a Serialized UID Array.',
);
const reqLogger = logger.newRequestLoggerFromSerializedUids(
'OneUID:SecondUID:TestUID:YouWinUID',
);
assert(reqLogger instanceof RequestLogger, 'RequestLogger'); assert(reqLogger instanceof RequestLogger, 'RequestLogger');
assert.deepStrictEqual(reqLogger.getUids().slice(0, -1),
['OneUID', 'SecondUID', 'TestUID', 'YouWinUID']);
done(); done();
}); });
it('Uses the additional fields as expected', done => { it('Can create Per-Request Loggers from a Serialized UID Array', (done) => {
const logger = new Logger('test');
assert.doesNotThrow(
() => {
logger.newRequestLogger();
},
Error,
'Werelogs should not throw when creating a request logger from a Serialized UID Array.');
const reqLogger = logger.newRequestLoggerFromSerializedUids('OneUID:SecondUID:TestUID:YouWinUID');
assert(reqLogger instanceof RequestLogger, 'RequestLogger');
assert.deepStrictEqual(reqLogger.getUids().slice(0, -1), ['OneUID', 'SecondUID', 'TestUID', 'YouWinUID']);
done();
});
it('Uses the additional fields as expected', (done) => {
const dummyLogger = new DummyLogger(); const dummyLogger = new DummyLogger();
config.simpleLogger = dummyLogger; const logger = new Logger('test');
const logger = new Logger(config, 'test'); Config.simpleLogger = dummyLogger;
const fields = { const fields = {
ip: '127.0.0.1', ip: '127.0.0.1',
method: 'GET', method: 'GET',
@ -130,31 +186,28 @@ describe('Logger is usable:', () => {
done(); done();
}); });
/* eslint-disable max-len */
describe('Does not crash and logs a fatal message when mis-using its logging API', () => { describe('Does not crash and logs a fatal message when mis-using its logging API', () => {
const testValues = [ const testValues = [
{ desc: 'a string as second argument', args: [ 'test', 'second-param-string' ] }, { desc: 'a string as second argument', args: [ 'test', 'second-param-string' ] },
{ desc: 'a function as second argument', args: ['test', () => { }] }, // eslint-disable-line arrow-body-style { desc: 'a function as second argument', args: [ 'test', () => { return; } ] },
{ desc: 'a Number as second argument', args: [ 'test', 1 ] }, { desc: 'a Number as second argument', args: [ 'test', 1 ] },
{ desc: 'more than 2 arguments', args: [ 'test', 2, 3, 4 ] }, { desc: 'more than 2 arguments', args: [ 'test', 2, 3, 4 ] },
]; ];
/* eslint-enable max-len */
function createMisusableLogger(dummyLogger) { function createMisusableLogger(dummyLogger) {
config.simpleLogger = dummyLogger; const logger = new Logger('test');
const logger = new Logger(config, 'test'); Config.simpleLogger = dummyLogger;
return logger; return logger;
} }
for (let i = 0; i < testValues.length; ++i) { for (let i = 0; i < testValues.length; ++i) {
const test = testValues[i]; const test = testValues[i];
it(`Does not crash with ${test.desc}`, it('Does not crash with ' + test.desc,
loggingMisuseGenerator(test, createMisusableLogger)); loggingMisuseGenerator(test, createMisusableLogger));
} }
}); });
}); });
/* eslint-disable no-multi-spaces, max-len */ describe('Werelogs Module-level Logger can log as specified by the log level', () => {
describe('Logger can log as specified by the log level', () => {
it('Trace level does not filter trace level out', filterGenerator('trace', 'trace')); it('Trace level does not filter trace level out', filterGenerator('trace', 'trace'));
it('Trace level does not filter debug level out', filterGenerator('trace', 'debug')); it('Trace level does not filter debug level out', filterGenerator('trace', 'debug'));
it('Trace level does not filter info level out', filterGenerator('trace', 'info')); it('Trace level does not filter info level out', filterGenerator('trace', 'info'));
@ -197,4 +250,3 @@ describe('Logger can log as specified by the log level', () => {
it('Fatal level filters error level out', filterGenerator('fatal', 'error')); it('Fatal level filters error level out', filterGenerator('fatal', 'error'));
it('Fatal level does not filter fatal level out', filterGenerator('fatal', 'fatal')); it('Fatal level does not filter fatal level out', filterGenerator('fatal', 'fatal'));
}); });
/* eslint-enable no-multi-spaces, max-len */

View File

@ -1,9 +1,11 @@
'use strict';
// eslint-disable-line strict
const assert = require('assert'); const assert = require('assert');
const { DummyLogger, genericFilterGenerator, loggingMisuseGenerator } = require('../Utils.js'); const Utils = require('../Utils.js');
const DummyLogger = Utils.DummyLogger;
const genericFilterGenerator = Utils.genericFilterGenerator;
const loggingMisuseGenerator = Utils.loggingMisuseGenerator;
const RequestLogger = require('../../lib/RequestLogger.js'); const RequestLogger = require('../../lib/RequestLogger.js');
@ -21,21 +23,18 @@ function filterGenerator(logLevel, callLevel) {
} }
function runLoggingDumpTest(commandHistory, expectedHistory, expectedCounts, function runLoggingDumpTest(commandHistory, expectedHistory, expectedCounts, done) {
done) {
const dummyLogger = new DummyLogger(); const dummyLogger = new DummyLogger();
const reqLogger = new RequestLogger(dummyLogger, 'trace', 'error', 'info'); const reqLogger = new RequestLogger(dummyLogger, 'trace', 'error', 'info');
commandHistory.every((val, index) => { commandHistory.every(function doLogWithLevel(val, index) {
switch (val) { switch (val) {
/* eslint-disable no-multi-spaces */
case 'trace': reqLogger.trace(index); break; case 'trace': reqLogger.trace(index); break;
case 'debug': reqLogger.debug(index); break; case 'debug': reqLogger.debug(index); break;
case 'info': reqLogger.info(index); break; case 'info': reqLogger.info(index); break;
case 'warn': reqLogger.warn(index); break; case 'warn': reqLogger.warn(index); break;
case 'error': reqLogger.error(index); break; case 'error': reqLogger.error(index); break;
case 'fatal': reqLogger.fatal(index); break; case 'fatal': reqLogger.fatal(index); break;
/* eslint-enable no-multi-spaces */
default: default:
done(new Error('Unexpected logging level name: ', val)); done(new Error('Unexpected logging level name: ', val));
} }
@ -43,40 +42,40 @@ function runLoggingDumpTest(commandHistory, expectedHistory, expectedCounts,
}); });
expectedHistory.every((val, index) => { expectedHistory.every((val, index) => {
assert.strictEqual(dummyLogger.ops[index][0], val[0], assert.strictEqual(dummyLogger.ops[index][0], val[0], 'Expected log entry levels to match.');
'Expected log entry levels to match.'); assert.strictEqual(dummyLogger.ops[index][1][1], val[1], 'Expected log entry values to match.');
assert.strictEqual(dummyLogger.ops[index][1][1], val[1],
'Expected log entry values to match.');
return true; return true;
}); });
assert.deepEqual(dummyLogger.counts, expectedCounts); assert.deepEqual(dummyLogger.counts, expectedCounts);
} }
/* eslint-disable no-multi-spaces, max-len */
describe('RequestLogger', () => { describe('RequestLogger', () => {
describe('Object Instanciation', () => { describe('Object Instanciation', () => {
describe('Logging Levels Initialization', () => { describe('Logging Levels Initialization', () => {
it('Throws if LogLevel is higher than dumpThreshold', done => { it('Throws if LogLevel is higher than dumpThreshold', (done) => {
assert.throws( assert.throws(
() => new RequestLogger(undefined, 'fatal', 'debug', 'info'), () => {
return new RequestLogger(undefined, 'fatal', 'debug', 'info');
},
Error, Error,
'Dump level "debug" should not be valid with logging level "fatal".', 'Dump level "debug" should not be valid with logging level "fatal".');
);
done(); done();
}); });
it('Works with LogLevel lesser or equal to DumpLevel', done => { it('Works with LogLevel lesser or equal to DumpLevel', (done) => {
assert.doesNotThrow( assert.doesNotThrow(
() => new RequestLogger(undefined, 'debug', 'fatal', 'info'), () => {
return new RequestLogger(undefined, 'debug', 'fatal', 'info');
},
Error, Error,
'Dump level "fatal" should be valid with logging level "debug".', 'Dump level "fatal" should be valid with logging level "debug".');
);
done(); done();
}); });
}); });
describe('UID Initialization', () => { describe('UID Initialization', () => {
it('defines an UID when none provided', done => { it('defines an UID when none provided', (done) => {
const dummyLogger = new DummyLogger(); const dummyLogger = new DummyLogger();
const reqLogger = new RequestLogger(dummyLogger, 'debug', 'fatal', 'info'); const reqLogger = new RequestLogger(dummyLogger, 'debug', 'fatal', 'info');
assert.strictEqual(Array.isArray(reqLogger.uids), true, 'Expected uid list to be an Array.'); assert.strictEqual(Array.isArray(reqLogger.uids), true, 'Expected uid list to be an Array.');
@ -84,7 +83,7 @@ describe('RequestLogger', () => {
done(); done();
}); });
it('creates an UID array out of the provided UID string', done => { it('creates an UID array out of the provided UID string', (done) => {
const dummyLogger = new DummyLogger(); const dummyLogger = new DummyLogger();
const uids = 'BasicUid'; const uids = 'BasicUid';
const reqLogger = new RequestLogger(dummyLogger, 'debug', 'fatal', 'info', uids); const reqLogger = new RequestLogger(dummyLogger, 'debug', 'fatal', 'info', uids);
@ -94,16 +93,17 @@ describe('RequestLogger', () => {
done(); done();
}); });
it('throws when UID string provided contains a colon', done => { it('throws when UID string provided contains a colon', (done) => {
assert.throws( assert.throws(
() => new RequestLogger(undefined, 'debug', 'fatal', 'info', 'pouet:tata'), () => {
return new RequestLogger(undefined, 'debug', 'fatal', 'info', 'pouet:tata');
},
Error, Error,
'UID string "pouet:tata" should be rejected by the RequestLogger constructor.', 'UID string "pouet:tata" should be rejected by the RequestLogger constructor.');
);
done(); done();
}); });
it('expands the UID array when one is provided', done => { it('expands the UID array when one is provided', (done) => {
const dummyLogger = new DummyLogger(); const dummyLogger = new DummyLogger();
const uids = ['oneuid', 'twouid', 'threeuids']; const uids = ['oneuid', 'twouid', 'threeuids'];
const reqLogger = new RequestLogger(dummyLogger, 'debug', 'fatal', 'info', uids); const reqLogger = new RequestLogger(dummyLogger, 'debug', 'fatal', 'info', uids);
@ -113,18 +113,19 @@ describe('RequestLogger', () => {
done(); done();
}); });
it('throws when UID string Array provided contains an UID that contains a colon', done => { it('throws when UID string Array provided contains an UID that contains a colon', (done) => {
assert.throws( assert.throws(
() => new RequestLogger(undefined, 'debug', 'fatal', 'info', ['OneUID', 'SecondUID', 'Test:DashUID']), () => {
return new RequestLogger(undefined, 'debug', 'fatal', 'info', ['OneUID', 'SecondUID', 'Test:DashUID']);
},
Error, Error,
'UID string "Test:DashUID" should be rejected by the RequestLogger constructor.', 'UID string "Test:DashUID" should be rejected by the RequestLogger constructor.');
);
done(); done();
}); });
}); });
describe('getUids() method', () => { describe('getUids() method', () => {
it('retrieves a list of string UID', done => { it('retrieves a list of string UID', (done) => {
const dummyLogger = new DummyLogger(); const dummyLogger = new DummyLogger();
const reqLogger = new RequestLogger(dummyLogger, 'info', 'error', 'info'); const reqLogger = new RequestLogger(dummyLogger, 'info', 'error', 'info');
const uidlist = reqLogger.getUids(); const uidlist = reqLogger.getUids();
@ -134,7 +135,7 @@ describe('RequestLogger', () => {
}); });
describe('Length of the UIDs array', () => { describe('Length of the UIDs array', () => {
it('default constructor yields a one-item UID list', done => { it('default constructor yields a one-item UID list', (done) => {
const dummyLogger = new DummyLogger(); const dummyLogger = new DummyLogger();
const reqLogger = new RequestLogger(dummyLogger, 'info', 'error', 'info'); const reqLogger = new RequestLogger(dummyLogger, 'info', 'error', 'info');
const uidlist = reqLogger.getUids(); const uidlist = reqLogger.getUids();
@ -142,7 +143,7 @@ describe('RequestLogger', () => {
done(); done();
}); });
it('manually-set UID constructor yields a one-item UID list', done => { it('manually-set UID constructor yields a one-item UID list', (done) => {
const dummyLogger = new DummyLogger(); const dummyLogger = new DummyLogger();
const myUid = 'ThisIsMyUid'; const myUid = 'ThisIsMyUid';
const reqLogger = new RequestLogger(dummyLogger, 'info', 'error', 'info', myUid); const reqLogger = new RequestLogger(dummyLogger, 'info', 'error', 'info', myUid);
@ -152,7 +153,7 @@ describe('RequestLogger', () => {
done(); done();
}); });
it('manually-set parent UID List constructor yields a n+1 item UID list', done => { it('manually-set parent UID List constructor yields a n+1 item UID list', (done) => {
const dummyLogger = new DummyLogger(); const dummyLogger = new DummyLogger();
const myParentUidList = [ 'ThisIsMyOriginUid', 'ThisIsMySecondGenUid', 'ThisIsMyThirdGenUid' ]; const myParentUidList = [ 'ThisIsMyOriginUid', 'ThisIsMySecondGenUid', 'ThisIsMyThirdGenUid' ];
const reqLogger = new RequestLogger(dummyLogger, 'info', 'error', 'info', myParentUidList); const reqLogger = new RequestLogger(dummyLogger, 'info', 'error', 'info', myParentUidList);
@ -163,7 +164,7 @@ describe('RequestLogger', () => {
}); });
}); });
it('internal data cannot be set through returned UID List', done => { it('internal data cannot be set through returned UID List', (done) => {
const dummyLogger = new DummyLogger(); const dummyLogger = new DummyLogger();
const reqLogger = new RequestLogger(dummyLogger, 'info', 'error', 'info'); const reqLogger = new RequestLogger(dummyLogger, 'info', 'error', 'info');
const uidlist = reqLogger.getUids(); const uidlist = reqLogger.getUids();
@ -174,11 +175,11 @@ describe('RequestLogger', () => {
}); });
describe('getSerializedUids()', () => { describe('getSerializedUids()', () => {
it('Should return a properly serialized UID Array', done => { it('Should return a properly serialized UID Array', (done) => {
const dummyLogger = new DummyLogger(); const dummyLogger = new DummyLogger();
const uidList = [ 'FirstUID', 'SecondUID', 'ThirdUID', 'TestUID' ]; const uidList = [ 'FirstUID', 'SecondUID', 'ThirdUID', 'TestUID' ];
const reqLogger = new RequestLogger(dummyLogger, 'info', 'error', 'info', uidList); const reqLogger = new RequestLogger(dummyLogger, 'info', 'error', 'info', uidList);
const expectedString = `FirstUID:SecondUID:ThirdUID:TestUID:${reqLogger.getUids()[4]}`; const expectedString = 'FirstUID:SecondUID:ThirdUID:TestUID:' + reqLogger.getUids()[4];
assert.strictEqual(reqLogger.getSerializedUids(), expectedString, 'Expected serialized UID List to match expected data.'); assert.strictEqual(reqLogger.getSerializedUids(), expectedString, 'Expected serialized UID List to match expected data.');
done(); done();
}); });
@ -188,7 +189,7 @@ describe('RequestLogger', () => {
describe('Does not crash when mis-using its logging API', () => { describe('Does not crash when mis-using its logging API', () => {
const testValues = [ const testValues = [
{ desc: 'a string as second argument', args: [ 'test', 'second-param-string' ] }, { desc: 'a string as second argument', args: [ 'test', 'second-param-string' ] },
{ desc: 'a function as second argument', args: ['test', function f() { }] }, { desc: 'a function as second argument', args: [ 'test', () => { return; } ] },
{ desc: 'a Number as second argument', args: [ 'test', 1 ] }, { desc: 'a Number as second argument', args: [ 'test', 1 ] },
{ desc: 'more than 2 arguments', args: [ 'test', 2, 3, 4 ] }, { desc: 'more than 2 arguments', args: [ 'test', 2, 3, 4 ] },
]; ];
@ -198,7 +199,7 @@ describe('RequestLogger', () => {
for (let i = 0; i < testValues.length; ++i) { for (let i = 0; i < testValues.length; ++i) {
const test = testValues[i]; const test = testValues[i];
it(`Does not crash with ${test.desc}`, it('Does not crash with ' + test.desc,
loggingMisuseGenerator(test, createMisusableRequestLogger)); loggingMisuseGenerator(test, createMisusableRequestLogger));
} }
}); });
@ -246,39 +247,33 @@ describe('RequestLogger', () => {
it('Fatal level filters error level out', filterGenerator('fatal', 'error')); it('Fatal level filters error level out', filterGenerator('fatal', 'error'));
it('Fatal level does not filter fatal level out', filterGenerator('fatal', 'fatal')); it('Fatal level does not filter fatal level out', filterGenerator('fatal', 'fatal'));
}); });
/* eslint-enable no-multi-spaces, max-len */
describe('Logging API regression testing', () => { describe('Logging API regression testing', () => {
it('Should not alter the input fields when not actually logging', it('Should not alter the input fields when not actually logging', (done) => {
done => {
const dummyLogger = new DummyLogger(); const dummyLogger = new DummyLogger();
const reqLogger = new RequestLogger(dummyLogger, const reqLogger = new RequestLogger(dummyLogger, 'info', 'fatal', 'info');
'info', 'fatal', 'info'); const refFields = { 'hits': 45, 'count': 32 };
const refFields = { hits: 45, count: 32 }; const usedFields = Object.assign({}, refFields);
const usedFields = { ...refFields };
reqLogger.debug('test', usedFields); reqLogger.debug('test', usedFields);
assert.deepStrictEqual(usedFields, refFields); assert.deepStrictEqual(usedFields, refFields);
done(); done();
}); });
it('Should not alter the input fields when actually logging', it('Should not alter the input fields when actually logging', (done) => {
done => {
const dummyLogger = new DummyLogger(); const dummyLogger = new DummyLogger();
const reqLogger = new RequestLogger(dummyLogger, const reqLogger = new RequestLogger(dummyLogger, 'info', 'fatal', 'info');
'info', 'fatal', 'info'); const refFields = { 'hits': 45, 'count': 32 };
const refFields = { hits: 45, count: 32 }; const usedFields = Object.assign({}, refFields);
const usedFields = { ...refFields };
reqLogger.info('test', usedFields); reqLogger.info('test', usedFields);
assert.deepStrictEqual(usedFields, refFields); assert.deepStrictEqual(usedFields, refFields);
done(); done();
}); });
it('Should not alter the input fields when dumping', done => { it('Should not alter the input fields when dumping', (done) => {
const dummyLogger = new DummyLogger(); const dummyLogger = new DummyLogger();
const reqLogger = new RequestLogger(dummyLogger, const reqLogger = new RequestLogger(dummyLogger, 'info', 'fatal', 'info');
'info', 'fatal', 'info'); const refFields = { 'hits': 45, 'count': 32 };
const refFields = { hits: 45, count: 32 }; const usedFields = Object.assign({}, refFields);
const usedFields = { ...refFields };
reqLogger.error('test', usedFields); reqLogger.error('test', usedFields);
assert.deepStrictEqual(usedFields, refFields); assert.deepStrictEqual(usedFields, refFields);
done(); done();
@ -286,7 +281,7 @@ describe('RequestLogger', () => {
}); });
describe('Default Fields', () => { describe('Default Fields', () => {
it('should not modify the object passed as a parameter', done => { it('should not modify the object passed as a parameter', (done) => {
const add1 = { const add1 = {
attr1: 0, attr1: 0,
}; };
@ -294,8 +289,7 @@ describe('RequestLogger', () => {
attr2: 'string', attr2: 'string',
}; };
const dummyLogger = new DummyLogger(); const dummyLogger = new DummyLogger();
const reqLogger = new RequestLogger(dummyLogger, const reqLogger = new RequestLogger(dummyLogger, 'info', 'fatal', 'info');
'info', 'fatal', 'info');
reqLogger.addDefaultFields(add1); reqLogger.addDefaultFields(add1);
reqLogger.addDefaultFields(add2); reqLogger.addDefaultFields(add2);
assert.deepStrictEqual(add1, { attr1: 0 }); assert.deepStrictEqual(add1, { attr1: 0 });
@ -303,22 +297,19 @@ describe('RequestLogger', () => {
done(); done();
}); });
it('should add one added default field to the log entries', done => { it('should add one added default field to the log entries', (done) => {
const clientInfo = { const clientInfo = {
clientIP: '127.0.0.1', clientIP: '127.0.0.1',
}; };
const dummyLogger = new DummyLogger(); const dummyLogger = new DummyLogger();
const reqLogger = new RequestLogger(dummyLogger, const reqLogger = new RequestLogger(dummyLogger, 'info', 'fatal', 'info');
'info', 'fatal', 'info');
reqLogger.addDefaultFields(clientInfo); reqLogger.addDefaultFields(clientInfo);
reqLogger.info('test message'); reqLogger.info('test message');
assert.strictEqual(clientInfo.clientIP, assert.strictEqual(clientInfo.clientIP, dummyLogger.ops[0][1][0].clientIP);
dummyLogger.ops[0][1][0].clientIP);
done(); done();
}); });
it('should add multiple added default fields to the log entries', it('should add multiple added default fields to the log entries', (done) => {
done => {
const clientInfo = { const clientInfo = {
clientIP: '127.0.0.1', clientIP: '127.0.0.1',
clientPort: '1337', clientPort: '1337',
@ -328,79 +319,63 @@ describe('RequestLogger', () => {
creator: 'Joddy', creator: 'Joddy',
}; };
const dummyLogger = new DummyLogger(); const dummyLogger = new DummyLogger();
const reqLogger = new RequestLogger(dummyLogger, const reqLogger = new RequestLogger(dummyLogger, 'info', 'fatal', 'info');
'info', 'fatal', 'info');
reqLogger.addDefaultFields(clientInfo); reqLogger.addDefaultFields(clientInfo);
reqLogger.addDefaultFields(requestInfo); reqLogger.addDefaultFields(requestInfo);
reqLogger.info('test message'); reqLogger.info('test message');
assert.strictEqual(clientInfo.clientIP, assert.strictEqual(clientInfo.clientIP, dummyLogger.ops[0][1][0].clientIP);
dummyLogger.ops[0][1][0].clientIP); assert.strictEqual(clientInfo.clientPort, dummyLogger.ops[0][1][0].clientPort);
assert.strictEqual(clientInfo.clientPort, assert.strictEqual(requestInfo.object, dummyLogger.ops[0][1][0].object);
dummyLogger.ops[0][1][0].clientPort); assert.strictEqual(requestInfo.creator, dummyLogger.ops[0][1][0].creator);
assert.strictEqual(requestInfo.object,
dummyLogger.ops[0][1][0].object);
assert.strictEqual(requestInfo.creator,
dummyLogger.ops[0][1][0].creator);
done(); done();
}); });
}); });
describe('Automatic Elapsed Time computation', () => { describe('Automatic Elapsed Time computation', () => {
describe('Deprecated API:', () => { describe('Deprecated API:', () => {
it('should include an "elapsed_ms" field in the last log entry', it('should include an "elapsed_ms" field in the last log entry', (done) => {
done => {
const dummyLogger = new DummyLogger(); const dummyLogger = new DummyLogger();
const reqLogger = new RequestLogger(dummyLogger, const reqLogger = new RequestLogger(dummyLogger, 'info', 'fatal', 'info');
'info', 'fatal', 'info');
reqLogger.end('Last message'); reqLogger.end('Last message');
assert.strictEqual(dummyLogger.ops[0][1][1], 'Last message'); assert.strictEqual(dummyLogger.ops[0][1][1], 'Last message');
assert.notStrictEqual(dummyLogger.ops[0][1][0].elapsed_ms, assert.notStrictEqual(dummyLogger.ops[0][1][0].elapsed_ms, undefined);
undefined); assert.strictEqual(typeof(dummyLogger.ops[0][1][0].elapsed_ms), 'number');
assert.strictEqual(typeof dummyLogger.ops[0][1][0]
.elapsed_ms, 'number');
done(); done();
}); });
// eslint-disable-next-line max-len
it('should include an "elapsed_ms" field in the last log entry and be error level', () => { it('should include an "elapsed_ms" field in the last log entry and be error level', () => {
const dummyLogger = new DummyLogger(); const dummyLogger = new DummyLogger();
const reqLogger = new RequestLogger(dummyLogger, const reqLogger = new RequestLogger(dummyLogger, 'info', 'fatal', 'info');
'info', 'fatal', 'info');
reqLogger.errorEnd('Last message failed'); reqLogger.errorEnd('Last message failed');
assert.strictEqual(dummyLogger.ops[0][1][1], assert.strictEqual(dummyLogger.ops[0][1][1], 'Last message failed');
'Last message failed'); assert.notStrictEqual(dummyLogger.ops[0][1][0].elapsed_ms, undefined);
assert.notStrictEqual(dummyLogger.ops[0][1][0].elapsed_ms, assert.strictEqual(typeof(dummyLogger.ops[0][1][0].elapsed_ms), 'number');
undefined);
assert.strictEqual(typeof dummyLogger.ops[0][1][0].elapsed_ms,
'number');
assert.strictEqual(dummyLogger.ops[0][0], 'error'); assert.strictEqual(dummyLogger.ops[0][0], 'error');
}); });
}); });
const endLogging = { const endLogging = {
trace: endLogger => endLogger.trace.bind(endLogger), trace: (endLogger) => { return endLogger.trace.bind(endLogger); },
debug: endLogger => endLogger.debug.bind(endLogger), debug: (endLogger) => { return endLogger.debug.bind(endLogger); },
info: endLogger => endLogger.info.bind(endLogger), info: (endLogger) => { return endLogger.info.bind(endLogger); },
warn: endLogger => endLogger.warn.bind(endLogger), warn: (endLogger) => { return endLogger.warn.bind(endLogger); },
error: endLogger => endLogger.error.bind(endLogger), error: (endLogger) => { return endLogger.error.bind(endLogger); },
fatal: endLogger => endLogger.fatal.bind(endLogger), fatal: (endLogger) => { return endLogger.fatal.bind(endLogger); },
}; };
/* eslint-disable max-len */ Object.keys(endLogging).forEach((level) => {
Object.keys(endLogging).forEach(level => { it(`should include an "elapsed_ms" field in the last log entry with level ${level}`, (done) => {
it(`should include an "elapsed_ms" field in the last log entry with level ${level}`, done => {
const dummyLogger = new DummyLogger(); const dummyLogger = new DummyLogger();
const reqLogger = new RequestLogger(dummyLogger, 'trace', 'fatal'); const reqLogger = new RequestLogger(dummyLogger, 'trace', 'fatal');
endLogging[level](reqLogger.end())('Last message'); endLogging[level](reqLogger.end())('Last message');
assert.strictEqual(dummyLogger.ops[0][1][1], 'Last message'); assert.strictEqual(dummyLogger.ops[0][1][1], 'Last message');
assert.notStrictEqual(dummyLogger.ops[0][1][0].elapsed_ms, undefined); assert.notStrictEqual(dummyLogger.ops[0][1][0].elapsed_ms, undefined);
assert.strictEqual(typeof dummyLogger.ops[0][1][0].elapsed_ms, 'number'); assert.strictEqual(typeof(dummyLogger.ops[0][1][0].elapsed_ms), 'number');
assert.strictEqual(dummyLogger.ops[0][0], level); assert.strictEqual(dummyLogger.ops[0][0], level);
done(); done();
}); });
}); });
/* eslint-enable max-len */
it('should be augmentable through addDefaultFields', done => { it('should be augmentable through addDefaultFields', (done) => {
const dummyLogger = new DummyLogger(); const dummyLogger = new DummyLogger();
const reqLogger = new RequestLogger(dummyLogger, 'trace', 'fatal'); const reqLogger = new RequestLogger(dummyLogger, 'trace', 'fatal');
reqLogger.end().addDefaultFields({endFlag: true}); reqLogger.end().addDefaultFields({endFlag: true});
@ -408,86 +383,42 @@ describe('RequestLogger', () => {
// end() logging // end() logging
reqLogger.end().error('Test Augmented END', {endValue: 42}); reqLogger.end().error('Test Augmented END', {endValue: 42});
assert.strictEqual(dummyLogger.ops[0][1][1], 'Test Augmented END'); assert.strictEqual(dummyLogger.ops[0][1][1], 'Test Augmented END');
assert.strictEqual(typeof dummyLogger.ops[0][1][0].elapsed_ms, assert.strictEqual(typeof(dummyLogger.ops[0][1][0].elapsed_ms), 'number');
'number');
assert.strictEqual(dummyLogger.ops[0][1][0].endFlag, true); assert.strictEqual(dummyLogger.ops[0][1][0].endFlag, true);
assert.strictEqual(dummyLogger.ops[0][1][0].endValue, 42); assert.strictEqual(dummyLogger.ops[0][1][0].endValue, 42);
done(); done();
}); });
it('should log an error in addition to request logs when end() called more than once',
done => {
const dummyLogger = new DummyLogger();
const reqLogger = new RequestLogger(dummyLogger, 'trace', 'fatal');
reqLogger.end().info('after first call to end()');
reqLogger.end().debug('after second call to end()');
assert.strictEqual(dummyLogger.ops.length, 3);
assert.strictEqual(dummyLogger.ops[0][0], 'info');
assert.strictEqual(dummyLogger.ops[0][1][1], 'after first call to end()');
assert.strictEqual(dummyLogger.ops[1][0], 'error');
assert.strictEqual(dummyLogger.ops[2][0], 'debug');
assert.strictEqual(dummyLogger.ops[2][1][1], 'after second call to end()');
done();
});
}); });
describe('Log History dumped when logging floor level reached', () => { describe('Log History dumped when logging floor level reached', () => {
it('Dumping duplicates log entries', done => { it('Dumping duplicates log entries', (done) => {
const commandHistory = ['info', 'error']; const commandHistory = ['info', 'error'];
const expectedHistory = [['info', 0], ['info', 0], ['error', 1]]; const expectedHistory = [['info', 0], ['info', 0], ['error', 1]];
const expectedCounts = { const expectedCounts = { trace: 0, debug: 0, info: 2, warn: 0, error: 1, fatal: 0 };
trace: 0,
debug: 0,
info: 2,
warn: 0,
error: 1,
fatal: 0,
};
runLoggingDumpTest(commandHistory, expectedHistory, expectedCounts, runLoggingDumpTest(commandHistory, expectedHistory, expectedCounts, done);
done);
done(); done();
}); });
it('Dumping Keeps logging history order', done => { it('Dumping Keeps logging history order', (done) => {
const commandHistory = ['trace', 'info', 'debug', 'error']; const commandHistory = ['trace', 'info', 'debug', 'error'];
const expectedHistory = [['trace', 0], ['info', 1], ['debug', 2], const expectedHistory = [['trace', 0], ['info', 1], ['debug', 2], ['trace', 0], ['info', 1], ['debug', 2], ['error', 3]];
['trace', 0], ['info', 1], ['debug', 2], const expectedCounts = { trace: 2, debug: 2, info: 2, warn: 0, error: 1, fatal: 0 };
['error', 3]];
const expectedCounts = {
trace: 2,
debug: 2,
info: 2,
warn: 0,
error: 1,
fatal: 0,
};
runLoggingDumpTest(commandHistory, expectedHistory, expectedCounts, runLoggingDumpTest(commandHistory, expectedHistory, expectedCounts, done);
done);
done(); done();
}); });
it('Dumping multiple times does not re-dump already-dumped entries', it('Dumping multiple times does not re-dump already-dumped entries', (done) => {
done => {
const commandHistory = ['trace', 'info', 'debug', 'error', const commandHistory = ['trace', 'info', 'debug', 'error',
'warn', 'debug', 'fatal']; 'warn', 'debug', 'fatal'];
const expectedHistory = [['trace', 0], ['info', 1], ['debug', 2], const expectedHistory = [['trace', 0], ['info', 1], ['debug', 2],
['trace', 0], ['info', 1], ['debug', 2], ['trace', 0], ['info', 1], ['debug', 2], ['error', 3],
['error', 3], ['warn', 4], ['debug', 5],
['warn', 4], ['debug', 5], ['warn', 4], ['debug', 5],
['fatal', 6]]; ['warn', 4], ['debug', 5], ['fatal', 6]];
const expectedCounts = { const expectedCounts = { trace: 2, debug: 4, info: 2, warn: 2, error: 1, fatal: 1 };
trace: 2,
debug: 4,
info: 2,
warn: 2,
error: 1,
fatal: 1,
};
runLoggingDumpTest(commandHistory, expectedHistory, runLoggingDumpTest(commandHistory, expectedHistory, expectedCounts, done);
expectedCounts, done);
done(); done();
}); });
}); });

View File

@ -1,20 +1,19 @@
'use strict';
// eslint-disable-line strict
const assert = require('assert'); const assert = require('assert');
const Utils = require('../../lib/Utils.js');
const { const generateUid = Utils.generateUid;
generateUid, serializeUids, unserializeUids, objectCopy, const serializeUids = Utils.serializeUids;
} = require('../../lib/Utils'); const unserializeUids = Utils.unserializeUids;
const objectCopy = Utils.objectCopy;
describe('Utils: generateUid', () => { describe('Utils: generateUid', () => {
it('generates a string-typed ID', done => { it('generates a string-typed ID', (done) => {
const uid = generateUid(); const uid = generateUid();
assert.strictEqual(typeof uid, 'string', assert.strictEqual(typeof(uid), 'string', 'The generated ID is not a String (' + typeof(uid) + ')');
`The generated ID is not a String (${typeof uid})`);
done(); done();
}); });
it('generate roughly unique IDs', done => { it('generate roughly unique IDs', (done) => {
const generated = {}; const generated = {};
let count = 0; let count = 0;
for (let i = 0; i < 10000; ++i) { for (let i = 0; i < 10000; ++i) {
@ -22,77 +21,47 @@ describe('Utils: generateUid', () => {
count = generated[uid] ? generated[uid] + 1 : 1; count = generated[uid] ? generated[uid] + 1 : 1;
generated[uid] = count; generated[uid] = count;
} }
Object.keys(generated).every(uid => { Object.keys(generated).every((uid) => {
assert.strictEqual(generated[uid], 1, assert.strictEqual(generated[uid], 1, `Uid ${uid} was generated ${generated[uid]} times: It is not even remotely unique.`);
`Uid ${uid} was generated ${generated[uid]} `
+ 'times: It is not even remotely unique.');
return {};
}); });
done(); done();
}); });
}); });
describe('Utils: serializeUids', () => { describe('Utils: serializeUids', () => {
it('serializes to the expected string data', done => { it('serializes to the expected string data', (done) => {
const uidList = [ 'FirstUID', 'SecondUID', 'ThirdUID']; const uidList = [ 'FirstUID', 'SecondUID', 'ThirdUID'];
const serializedUIDs = serializeUids(uidList); const serializedUIDs = serializeUids(uidList);
assert.strictEqual(serializedUIDs, 'FirstUID:SecondUID:ThirdUID', assert.strictEqual(serializedUIDs, 'FirstUID:SecondUID:ThirdUID', 'Serialized UID List should match expected value.');
'Serialized UID List should match expected value.');
done(); done();
}); });
it('unserializes the expected number of UIDs', done => { it('unserializes the expected number of UIDs', (done) => {
const refUidList = [ 'FirstUID', 'SecondUID', 'ThirdUID']; const refUidList = [ 'FirstUID', 'SecondUID', 'ThirdUID'];
const unserializedUIDs = unserializeUids('FirstUID:SecondUID:ThirdUID'); const unserializedUIDs = unserializeUids('FirstUID:SecondUID:ThirdUID');
assert.deepStrictEqual(unserializedUIDs, refUidList, assert.deepStrictEqual(unserializedUIDs, refUidList, 'Unserialized UID List should match expected value.');
'Unserialized UID List should match expected value.');
done(); done();
}); });
}); });
describe('Utils: objectCopy', () => { describe('Utils: objectCopy', () => {
it('copies all the properties from source to target object', done => { it('copies all the properties from source to target object', (done) => {
const target = { foo: 'bar' }; const target = { foo: 'bar' };
const source = { id: 1, name: 'demo', value: { a: 1, b: 2, c: 3 } }; const source = { id: 1, name: 'demo', value: { a: 1, b: 2, c: 3 } };
const result = { const result = { foo: 'bar', id: 1, name: 'demo', value: { a: 1, b: 2, c: 3 } };
foo: 'bar',
id: 1,
name: 'demo',
value: { a: 1, b: 2, c: 3 },
};
objectCopy(target, source); objectCopy(target, source);
assert.deepStrictEqual(target, result, assert.deepStrictEqual(target, result, 'target should have the same properties as source');
'target should have the same properties as source');
done(); done();
}); });
it('copies all the properties from multiple sources to target object', it('copies all the properties from multiple sources to target object', (done) => {
done => {
const target = { foo: 'bar' }; const target = { foo: 'bar' };
const source1 = { const source1 = { id: 1, name: 'demo1', value: { a: 1, b: 2, c: 3 } };
id: 1, const source2 = { req_id: 2, method: 'test', err: { code: 'error', msg: 'test' } };
name: 'demo1', const result = { foo: 'bar', id: 1, name: 'demo1', value: { a: 1, b: 2, c: 3 },
value: { a: 1, b: 2, c: 3 }, req_id: 2, method: 'test', err: { code: 'error', msg: 'test' }};
};
// eslint-disable-next-line camelcase
const source2 = {
req_id: 2,
method: 'test',
err: { code: 'error', msg: 'test' },
};
const result = {
foo: 'bar',
id: 1,
name: 'demo1',
value: { a: 1, b: 2, c: 3 },
// eslint-disable-next-line camelcase
req_id: 2,
method: 'test',
err: { code: 'error', msg: 'test' },
};
objectCopy(target, source1, source2); objectCopy(target, source1, source2);
assert.deepStrictEqual(target, result, assert.deepStrictEqual(target, result, 'target should have the same properties as source');
'target should have the same properties as source');
done(); done();
}); });
}); });

View File

@ -1,17 +0,0 @@
#!/usr/bin/env node
// Convert string args into primitive value
const fromStr = (str, primitive) => (str === `${primitive}` ? primitive : str);
const date = fromStr(process.argv[2], undefined);
const exitCode = fromStr(fromStr(process.argv[3], null), undefined);
const { stderrUtils } = require('../../../../index');
stderrUtils.catchAndTimestampStderr(
date ? () => date : undefined,
exitCode,
);
process.emitWarning('TestWarningMessage');
// This will print warning after printing error before exit
throw new Error('TestingError');

View File

@ -1,23 +0,0 @@
#!/usr/bin/env node
// Convert string args into primitive value
const fromStr = (str, primitive) => (str === `${primitive}` ? primitive : str);
const date = fromStr(process.argv[2], undefined);
const exitCode = fromStr(fromStr(process.argv[3], null), undefined);
const promise = fromStr(process.argv[4], true);
const { stderrUtils } = require('../../../../index');
stderrUtils.catchAndTimestampUncaughtException(
date ? () => date : undefined,
exitCode,
);
// Executed if process does not exit, process is in undefined behavior (bad)
// eslint-disable-next-line no-console
setTimeout(() => console.log('EXECUTED AFTER UNCAUGHT EXCEPTION'), 1);
if (promise === true) {
Promise.reject();
} else {
throw new Error('TestingError');
}

View File

@ -1,38 +0,0 @@
#!/usr/bin/env node
// Convert string args into primitive value
const fromStr = (str, primitive) => (str === `${primitive}` ? primitive : str);
const date = fromStr(process.argv[2], undefined);
const name = fromStr(process.argv[3], undefined);
const code = fromStr(process.argv[4], undefined);
const detail = fromStr(process.argv[5], undefined);
const { stderrUtils } = require('../../../../index');
stderrUtils.catchAndTimestampWarning(
date ? () => date : undefined,
);
const warning = new Error('TestWarningMessage');
if (name) warning.name = name;
if (code) warning.code = code;
if (detail) warning.detail = detail;
process.emitWarning(warning);
/*
Examples:
(node:203831) Error: TestWarningMessage
at Object.<anonymous> (catchWarning.js:15:17)
...
at node:internal/main/run_main_module:22:47
Above Warning Date: 2024-06-26T16:32:55.505Z
(node:205151) [TEST01] CUSTOM: TestWarningMessage
at Object.<anonymous> (catchWarning.js:15:17)
...
at node:internal/main/run_main_module:22:47
Some additional detail
Above Warning Date: Tue, 31 Dec 2024 10:20:30 GMT
*/

View File

@ -1,309 +0,0 @@
const assert = require('assert');
const { execFile } = require('child_process');
const stderrUtils = require('../../lib/stderrUtils');
/** Simple regex for ISO YYYY-MM-DDThh:mm:ss.sssZ */
// eslint-disable-next-line max-len
const defaultDateRegex = /\d{4}-[01]\d-[0-3]\dT[0-2]\d:[0-5]\d:[0-5]\d\.\d+(?:[+-][0-2]\d:[0-5]\d|Z)/;
// eslint-disable-next-line valid-jsdoc
/** another format: Tue, 31 Dec 2024 10:20:30 GMT */
const customDate = () => new Date('2024-12-31T10:20:30.444Z').toUTCString();
describe('stderrUtils', () => {
const errStackRegex = /Error: TestingError\n(?:.*\sat\s.*\n)+/;
describe('defaultTimestamp', () => {
it('should match ISO format', () => {
assert.match(stderrUtils.defaultTimestamp(), defaultDateRegex);
});
});
describe('printErrorWithTimestamp', () => {
let stderrText;
const originalStderrWrite = process.stderr.write;
const mockedStderrWrite = text => { stderrText = text; return true; };
const err = new Error('TestingError');
const origin = 'uncaughtException';
beforeEach(() => {
stderrText = undefined;
process.stderr.write = mockedStderrWrite;
});
afterEach(() => {
process.stderr.write = originalStderrWrite;
stderrText = undefined;
});
it(
'should write to stderr with current date, origin and stacktrace',
() => {
const written = stderrUtils
.printErrorWithTimestamp(err, origin);
assert.strictEqual(written, true);
const [firstLine, errStack] = stderrText.split(':\n');
const [errDate, errOrigin] = firstLine.split(': ');
assert.match(errDate, defaultDateRegex);
assert.strictEqual(errOrigin, origin);
assert.strictEqual(errStack, `${err.stack}\n`);
},
);
it(
'should write to stderr with custom date, origin and stacktrace',
() => {
const written = stderrUtils
.printErrorWithTimestamp(err, origin, customDate());
assert.strictEqual(written, true);
const [firstLine, errStack] = stderrText.split(':\n');
const [errDate, errOrigin] = firstLine.split(': ');
assert.strictEqual(errDate, customDate());
assert.strictEqual(errOrigin, origin);
assert.strictEqual(errStack, `${err.stack}\n`);
},
);
});
const execOptions = {
cwd: __dirname,
// Subprocess should always stop alone
// But just in case, kill subprocess after 500ms.
// Leave enough time for `nyc` that runs slower.
timeout: 500,
};
// Execute in another process to notice the process exit
// Therefore, looks more like a functional test
const timeoutHint = (ms, retries) =>
`Test fixture process timed out after ${ms}ms with ${retries} retries.\n` +
'Due to nyc coverage first run slowing down process.\nIncrease execOptions.timeout to fix';
describe('catchAndTimestampUncaughtException', () => {
[
{ desc: 'with default date' },
{ desc: 'with custom date', date: customDate() },
{ desc: 'with custom exitCode 42', exitCode: 42 },
{ desc: 'without exit on uncaught exception', exitCode: null },
{ desc: 'for unhandled promise', promise: true },
].forEach(({
desc, date, exitCode, promise,
}) => describe(desc, () => {
/** for before all hook that doesn't support this.retries */
let retries = 4;
let err;
let stdout;
let stderr;
let errStack;
let errDate;
let errOrigin;
before('run process catchUncaughtException', function beforeAllHook(done) {
execFile(
'./fixtures/stderrUtils/catchUncaughtException.js',
[`${date}`, `${exitCode}`, `${promise}`],
execOptions,
(subErr, subStdout, subStderr) => {
if (subErr?.killed) {
retries--;
if (retries <= 0) {
assert.fail(timeoutHint(execOptions.timeout, retries));
}
execOptions.timeout *= 2;
return beforeAllHook(done);
}
err = subErr;
stdout = subStdout;
stderr = subStderr;
let firstLine;
[firstLine, errStack] = stderr.split(':\n');
[errDate, errOrigin] = firstLine.split(': ');
done();
},
);
});
if (exitCode === null) {
it('should not be an error (or timeout)',
() => assert.ifError(err));
it('should have stdout (printed after uncaught exception)',
() => assert.match(stdout,
/^.*EXECUTED AFTER UNCAUGHT EXCEPTION(?:.|\n)*$/));
} else {
it('should be an error',
() => assert.ok(err));
it(`should have exitCode ${exitCode || 1}`,
() => assert.strictEqual(err.code, exitCode || 1));
it('should have empty stdout',
() => assert.strictEqual(stdout, ''));
}
it('should have stderr',
() => assert.ok(stderr));
it('should have date in stderr first line',
() => (date
? assert.strictEqual(errDate, date)
: assert.match(errDate, defaultDateRegex)));
it('should have origin in stderr first line',
() => (promise === true
? assert.strictEqual(errOrigin, 'unhandledRejection')
: assert.strictEqual(errOrigin, 'uncaughtException')));
if (!promise) {
it('should have stack trace on stderr',
() => assert.match(errStack, errStackRegex));
}
}));
});
describe('catchAndTimestampWarning (also tests node onWarning)', () => {
[
{ desc: 'with default date' },
{ desc: 'with custom date', date: customDate() },
{ desc: 'with deprecation warning', name: 'DeprecationWarning' },
{
desc: 'with custom warning',
name: 'CUSTOM',
code: 'TEST01',
detail: 'Some additional detail',
},
].forEach(({
desc, date, name, code, detail,
}) => describe(desc, () => {
/** for before all hook that doesn't support this.retries */
let retries = 4;
let err;
let stdout;
let stderr;
before('run process catchWarning', function beforeAllHook(done) {
execFile(
'./fixtures/stderrUtils/catchWarning.js',
[`${date}`, `${name}`, `${code}`, `${detail}`],
execOptions,
(subErr, subStdout, subStderr) => {
if (subErr?.killed) {
retries--;
if (retries <= 0) {
assert.fail(timeoutHint(execOptions.timeout, retries));
}
execOptions.timeout *= 2;
return beforeAllHook(done);
}
err = subErr;
stdout = subStdout;
stderr = subStderr;
done();
},
);
});
it('should not be an error (or timeout)',
() => assert.ifError(err));
it('should have empty stdout',
() => assert.strictEqual(stdout, ''));
it('should have stderr',
() => assert.ok(stderr));
it('should have message on stderr first line, then stack trace',
() => assert.match(stderr,
/^.*TestWarningMessage\n(?:\s+at\s.*\n)+/));
if (code) {
it('should have code on stderr first line',
() => assert.match(stderr, new RegExp(`^.*[${code}]`)));
}
if (name) {
it('should have name on stderr first line',
() => assert.match(stderr, new RegExp(`^.*${name}:`)));
}
if (detail) {
it('should have detail on stderr',
() => assert.match(stderr, new RegExp(`.*${detail}.*`)));
}
it(`should have ${date ? 'custom' : 'default'} date on stderr`,
() => assert.match(stderr, new RegExp(
`\nAbove Warning Date: ${
date || defaultDateRegex.source}\n`,
)));
}));
});
describe('catchAndTimestampStderr', () => {
[
{ desc: 'with default date' },
{ desc: 'with custom date', date: customDate() },
{ desc: 'with exit code', exitCode: 42 },
].forEach(({
desc, date, exitCode,
}) => describe(desc, () => {
/** for before all hook that doesn't support this.retries */
let retries = 4;
let err;
let stdout;
let stderr;
before('run process catchStderr', function beforeAllHook(done) {
execFile(
'./fixtures/stderrUtils/catchStderr.js',
[`${date}`, `${exitCode}`],
execOptions,
(subErr, subStdout, subStderr) => {
if (subErr?.killed) {
retries--;
if (retries <= 0) {
assert.fail(timeoutHint(execOptions.timeout, retries));
}
execOptions.timeout *= 2;
return beforeAllHook(done);
}
err = subErr;
stdout = subStdout;
stderr = subStderr;
done();
},
);
});
it('should be an error',
() => assert.ok(err));
it(`should have exitCode ${exitCode || 1}`,
() => assert.strictEqual(err.code, exitCode || 1));
it('should have empty stdout',
() => assert.strictEqual(stdout, ''));
it('should have stderr',
() => assert.ok(stderr));
// 2024-06-26T15:04:55.364Z: uncaughtException:
// Error: TestingError
// at Object.<anonymous> (catchStderr.js:16:7)
// at node:internal/main/run_main_module:22:47
it('should have error date, origin and stacktrace in stderr',
() => assert.match(stderr,
new RegExp(`${date || defaultDateRegex.source
}: uncaughtException:\n${errStackRegex.source}`)));
// (node:171245) Warning: TestWarningMessage
// at Object.<anonymous> (catchStderr.js:14:9)
// at node:internal/main/run_main_module:22:47
// Above Warning Date: 2024-06-26T15:04:55.365Z
it('should have warning with stacktrace in stderr', () => {
const trace = 'Warning: TestWarningMessage\n(?:\\s+at\\s.*\n)+';
const detail = `(?:.|\n)*?(?<=\n)Above Warning Date: ${
date || defaultDateRegex.source}\n`;
assert.match(stderr,
new RegExp(`${trace}${detail}`));
});
}));
});
});