diff --git a/lib/core/diagnostics.js b/lib/core/diagnostics.js index 35b825ec453..260721b44c5 100644 --- a/lib/core/diagnostics.js +++ b/lib/core/diagnostics.js @@ -1,4 +1,5 @@ 'use strict' + const diagnosticsChannel = require('node:diagnostics_channel') const util = require('node:util') @@ -35,7 +36,8 @@ function trackClientEvents (debugLog = undiciDebugLog) { isTrackingClientEvents = true - diagnosticsChannel.channel('undici:client:beforeConnect').subscribe(evt => { + diagnosticsChannel.subscribe('undici:client:beforeConnect', + evt => { const { connectParams: { version, protocol, port, host } } = evt @@ -48,7 +50,8 @@ function trackClientEvents (debugLog = undiciDebugLog) { ) }) - diagnosticsChannel.channel('undici:client:connected').subscribe(evt => { + diagnosticsChannel.subscribe('undici:client:connected', + evt => { const { connectParams: { version, protocol, port, host } } = evt @@ -61,7 +64,8 @@ function trackClientEvents (debugLog = undiciDebugLog) { ) }) - diagnosticsChannel.channel('undici:client:connectError').subscribe(evt => { + diagnosticsChannel.subscribe('undici:client:connectError', + evt => { const { connectParams: { version, protocol, port, host }, error @@ -76,7 +80,8 @@ function trackClientEvents (debugLog = undiciDebugLog) { ) }) - diagnosticsChannel.channel('undici:client:sendHeaders').subscribe(evt => { + diagnosticsChannel.subscribe('undici:client:sendHeaders', + evt => { const { request: { method, path, origin } } = evt @@ -93,7 +98,8 @@ function trackRequestEvents (debugLog = undiciDebugLog) { isTrackingRequestEvents = true - diagnosticsChannel.channel('undici:request:headers').subscribe(evt => { + diagnosticsChannel.subscribe('undici:request:headers', + evt => { const { request: { method, path, origin }, response: { statusCode } @@ -107,14 +113,16 @@ function trackRequestEvents (debugLog = undiciDebugLog) { ) }) - diagnosticsChannel.channel('undici:request:trailers').subscribe(evt => { + diagnosticsChannel.subscribe('undici:request:trailers', + evt => { const { request: { method, path, origin } } = evt debugLog('trailers received from %s %s/%s', method, origin, path) }) - diagnosticsChannel.channel('undici:request:error').subscribe(evt => { + diagnosticsChannel.subscribe('undici:request:error', + evt => { const { request: { method, path, origin }, error @@ -138,14 +146,16 @@ function trackWebSocketEvents (debugLog = websocketDebuglog) { isTrackingWebSocketEvents = true - diagnosticsChannel.channel('undici:websocket:open').subscribe(evt => { + diagnosticsChannel.subscribe('undici:websocket:open', + evt => { const { address: { address, port } } = evt debugLog('connection opened %s%s', address, port ? `:${port}` : '') }) - diagnosticsChannel.channel('undici:websocket:close').subscribe(evt => { + diagnosticsChannel.subscribe('undici:websocket:close', + evt => { const { websocket, code, reason } = evt debugLog( 'closed connection to %s - %s %s', @@ -155,15 +165,18 @@ function trackWebSocketEvents (debugLog = websocketDebuglog) { ) }) - diagnosticsChannel.channel('undici:websocket:socket_error').subscribe(err => { + diagnosticsChannel.subscribe('undici:websocket:socket_error', + err => { debugLog('connection errored - %s', err.message) }) - diagnosticsChannel.channel('undici:websocket:ping').subscribe(evt => { + diagnosticsChannel.subscribe('undici:websocket:ping', + evt => { debugLog('ping received') }) - diagnosticsChannel.channel('undici:websocket:pong').subscribe(evt => { + diagnosticsChannel.subscribe('undici:websocket:pong', + evt => { debugLog('pong received') }) }