FazBrowse GitHub Viewer | Trending |
URL:
| Home
Tools: [Download Repo ZIP]   [Original HTTPS Page]

diagnostics_channel: capture console messages · nodejs/node@28bec2d · GitHub

/ node Public

Commit 28bec2d

Browse files
Qard
authored and
aduh95
committed
diagnostics_channel: capture console messages
PR-URL: #56292 Reviewed-By: Rafael Gonzaga <rafael.nunu@hotmail.com> Reviewed-By: Gerhard Stöbich <deb2001-github@yahoo.de> Reviewed-By: Kohei Ueno <kohei.ueno119@gmail.com> Reviewed-By: Chengzhong Wu <legendecas@gmail.com> Reviewed-By: James M Snell <jasnell@gmail.com> Reviewed-By: Chemi Atlow <chemi@atlow.co.il>
1 parent 2042628 commit 28bec2d

4 files changed

Lines changed: 149 additions & 6 deletions

File tree

‎doc/api/diagnostics_channel.md‎

Lines changed: 37 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1120,6 +1120,43 @@ While the diagnostics\_channel API is now considered stable, the built-in
11201120
channels currently available are not. Each channel must be declared stable
11211121
independently.
11221122

1123+
#### Console
1124+
1125+
`console.log`
1126+
1127+
* `args` {any\[]}
1128+
1129+
Emitted when `console.log()` is called. Receives and array of the arguments
1130+
passed to `console.log()`.
1131+
1132+
`console.info`
1133+
1134+
* `args` {any\[]}
1135+
1136+
Emitted when `console.info()` is called. Receives and array of the arguments
1137+
passed to `console.info()`.
1138+
1139+
`console.debug`
1140+
1141+
* `args` {any\[]}
1142+
1143+
Emitted when `console.debug()` is called. Receives and array of the arguments
1144+
passed to `console.debug()`.
1145+
1146+
`console.warn`
1147+
1148+
* `args` {any\[]}
1149+
1150+
Emitted when `console.warn()` is called. Receives and array of the arguments
1151+
passed to `console.warn()`.
1152+
1153+
`console.error`
1154+
1155+
* `args` {any\[]}
1156+
1157+
Emitted when `console.error()` is called. Receives and array of the arguments
1158+
passed to `console.error()`.
1159+
11231160
#### HTTP
11241161

11251162
`http.client.request.created`

‎lib/internal/console/constructor.js‎

Lines changed: 32 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,13 @@ const {
6161
} = require('internal/constants');
6262
const kCounts = Symbol('counts');
6363
const { time, timeLog, timeEnd, kNone } = require('internal/util/debuglog');
64+
const { channel } = require('diagnostics_channel');
65+
66+
const onLog = channel('console.log');
67+
const onWarn = channel('console.warn');
68+
const onError = channel('console.error');
69+
const onInfo = channel('console.info');
70+
const onDebug = channel('console.debug');
6471

6572
const kTraceConsoleCategory = 'node,node.console';
6673

@@ -371,14 +378,39 @@ function timeLogImpl(consoleRef, label, formatted, args) {
371378

372379
const consoleMethods = {
373380
log(...args) {
381+
if (onLog.hasSubscribers) {
382+
onLog.publish(args);
383+
}
374384
this[kWriteToConsole](kUseStdout, this[kFormatForStdout](args));
375385
},
376386

387+
info(...args) {
388+
if (onInfo.hasSubscribers) {
389+
onInfo.publish(args);
390+
}
391+
this[kWriteToConsole](kUseStdout, this[kFormatForStdout](args));
392+
},
393+
394+
debug(...args) {
395+
if (onDebug.hasSubscribers) {
396+
onDebug.publish(args);
397+
}
398+
this[kWriteToConsole](kUseStdout, this[kFormatForStdout](args));
399+
},
377400

378401
warn(...args) {
402+
if (onWarn.hasSubscribers) {
403+
onWarn.publish(args);
404+
}
379405
this[kWriteToConsole](kUseStderr, this[kFormatForStderr](args));
380406
},
381407

408+
error(...args) {
409+
if (onError.hasSubscribers) {
410+
onError.publish(args);
411+
}
412+
this[kWriteToConsole](kUseStderr, this[kFormatForStderr](args));
413+
},
382414

383415
dir(object, options) {
384416
this[kWriteToConsole](kUseStdout, inspect(object, {
@@ -614,10 +646,7 @@ function noop() {}
614646
for (const method of ReflectOwnKeys(consoleMethods))
615647
Console.prototype[method] = consoleMethods[method];
616648

617-
Console.prototype.debug = Console.prototype.log;
618-
Console.prototype.info = Console.prototype.log;
619649
Console.prototype.dirxml = Console.prototype.log;
620-
Console.prototype.error = Console.prototype.warn;
621650
Console.prototype.groupCollapsed = Console.prototype.group;
622651

623652
function initializeGlobalConsole(globalConsole) {

‎test/parallel/test-console-diagnostics-channels.js‎

Lines changed: 77 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,77 @@
1+
'use strict';
2+
3+
const { mustCall } = require('../common');
4+
const { deepStrictEqual, ok, strictEqual } = require('assert');
5+
6+
const { channel } = require('diagnostics_channel');
7+
8+
const {
9+
hijackStdout,
10+
hijackStderr,
11+
restoreStdout,
12+
restoreStderr
13+
} = require('../common/hijackstdio');
14+
15+
const stdoutMethods = [
16+
'log',
17+
'info',
18+
'debug',
19+
];
20+
21+
const stderrMethods = [
22+
'warn',
23+
'error',
24+
];
25+
26+
const methods = [
27+
...stdoutMethods,
28+
...stderrMethods,
29+
];
30+
31+
const channels = {
32+
log: channel('console.log'),
33+
info: channel('console.info'),
34+
debug: channel('console.debug'),
35+
warn: channel('console.warn'),
36+
error: channel('console.error')
37+
};
38+
39+
process.stdout.isTTY = false;
40+
process.stderr.isTTY = false;
41+
42+
for (const method of methods) {
43+
let intercepted = false;
44+
let formatted = false;
45+
46+
const isStdout = stdoutMethods.includes(method);
47+
const hijack = isStdout ? hijackStdout : hijackStderr;
48+
const restore = isStdout ? restoreStdout : restoreStderr;
49+
50+
const foo = 'string';
51+
const bar = { key: /value/ };
52+
const baz = [ 1, 2, 3 ];
53+
54+
channels[method].subscribe(mustCall((args) => {
55+
// Should not have been formatted yet.
56+
intercepted = true;
57+
ok(!formatted);
58+
59+
// Should receive expected log message args.
60+
deepStrictEqual(args, [foo, bar, baz]);
61+
62+
// Should be able to mutate message args and have it reflected in output.
63+
bar.added = true;
64+
}));
65+
66+
hijack(mustCall((output) => {
67+
// Should have already been intercepted.
68+
formatted = true;
69+
ok(intercepted);
70+
71+
// Should produce expected formatted output with mutated message args.
72+
strictEqual(output, 'string { key: /value/, added: true } [ 1, 2, 3 ]\n');
73+
}));
74+
75+
console[method](foo, bar, baz);
76+
restore();
77+
}

‎test/parallel/test-repl.js‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -792,7 +792,10 @@ const errorTests = [
792792
expect: [
793793
'Object [console] {',
794794
' log: [Function: log],',
795+
' info: [Function: info],',
796+
' debug: [Function: debug],',
795797
' warn: [Function: warn],',
798+
' error: [Function: error],',
796799
' dir: [Function: dir],',
797800
' time: [Function: time],',
798801
' timeEnd: [Function: timeEnd],',
@@ -805,10 +808,7 @@ const errorTests = [
805808
' group: [Function: group],',
806809
' groupEnd: [Function: groupEnd],',
807810
' table: [Function: table],',
808-
/ {2}debug: \[Function: (debug|log)],/,
809-
/ {2}info: \[Function: (info|log)],/,
810811
/ {2}dirxml: \[Function: (dirxml|log)],/,
811-
/ {2}error: \[Function: (error|warn)],/,
812812
/ {2}groupCollapsed: \[Function: (groupCollapsed|group)],/,
813813
/ {2}Console: \[Function: Console],?/,
814814
...process.features.inspector ? [

0 commit comments

Comments
 (0)
Back | FazBrowse Home | New Git URL