[DI] Add more debug logs related to queuing and flushing payloads (#5130)

watson · web-flow · commit ae0674c6f732 · 2025-01-21T09:44:12.000+01:00
diff --git a/packages/dd-trace/src/debugger/devtools_client/send.js b/packages/dd-trace/src/debugger/devtools_client/send.js
@@ -60,6 +60,8 @@ function send (message, logger, dd, snapshot) {
 }
 
 function onFlush (payload) {
+  log.debug('[debugger:devtools_client] Flushing probe payload buffer')
+
   const opts = {
     method: 'POST',
     url: config.url,
diff --git a/packages/dd-trace/src/debugger/devtools_client/status.js b/packages/dd-trace/src/debugger/devtools_client/status.js
@@ -37,20 +37,26 @@ const STATUSES = {
 }
 
 function ackReceived ({ id: probeId, version }) {
+  log.debug('[debugger:devtools_client] Queueing RECEIVED status for probe %s (version: %d)', probeId, version)
+
   onlyUniqueUpdates(
     STATUSES.RECEIVED, probeId, version,
     () => send(statusPayload(probeId, version, STATUSES.RECEIVED))
   )
 }
 
 function ackInstalled ({ id: probeId, version }) {
+  log.debug('[debugger:devtools_client] Queueing INSTALLED status for probe %s (version: %d)', probeId, version)
+
   onlyUniqueUpdates(
     STATUSES.INSTALLED, probeId, version,
     () => send(statusPayload(probeId, version, STATUSES.INSTALLED))
   )
 }
 
 function ackEmitting ({ id: probeId, version }) {
+  log.debug('[debugger:devtools_client] Queueing EMITTING status for probe %s (version: %d)', probeId, version)
+
   onlyUniqueUpdates(
     STATUSES.EMITTING, probeId, version,
     () => send(statusPayload(probeId, version, STATUSES.EMITTING))
@@ -78,6 +84,8 @@ function send (payload) {
 }
 
 function onFlush (payload) {
+  log.debug('[debugger:devtools_client] Flushing diagnostics payload buffer')
+
   const form = new FormData()
 
   form.append(

Original file line number	Diff line number	Diff line change
`@@ -60,6 +60,8 @@ function send (message, logger, dd, snapshot) {`
`60`	`60`	`}`
`61`	`61`
`62`	`62`	`function onFlush (payload) {`
	`63`	`+ log.debug('[debugger:devtools_client] Flushing probe payload buffer')`
	`64`	`+`
`63`	`65`	`const opts = {`
`64`	`66`	`method: 'POST',`
`65`	`67`	`url: config.url,`
Original file line number	Diff line number	Diff line change
`@@ -37,20 +37,26 @@ const STATUSES = {`
`37`	`37`	`}`
`38`	`38`
`39`	`39`	`function ackReceived ({ id: probeId, version }) {`
	`40`	`+ log.debug('[debugger:devtools_client] Queueing RECEIVED status for probe %s (version: %d)', probeId, version)`
	`41`	`+`
`40`	`42`	`onlyUniqueUpdates(`
`41`	`43`	`STATUSES.RECEIVED, probeId, version,`
`42`	`44`	`() => send(statusPayload(probeId, version, STATUSES.RECEIVED))`
`43`	`45`	`)`
`44`	`46`	`}`
`45`	`47`
`46`	`48`	`function ackInstalled ({ id: probeId, version }) {`
	`49`	`+ log.debug('[debugger:devtools_client] Queueing INSTALLED status for probe %s (version: %d)', probeId, version)`
	`50`	`+`
`47`	`51`	`onlyUniqueUpdates(`
`48`	`52`	`STATUSES.INSTALLED, probeId, version,`
`49`	`53`	`() => send(statusPayload(probeId, version, STATUSES.INSTALLED))`
`50`	`54`	`)`
`51`	`55`	`}`
`52`	`56`
`53`	`57`	`function ackEmitting ({ id: probeId, version }) {`
	`58`	`+ log.debug('[debugger:devtools_client] Queueing EMITTING status for probe %s (version: %d)', probeId, version)`
	`59`	`+`
`54`	`60`	`onlyUniqueUpdates(`
`55`	`61`	`STATUSES.EMITTING, probeId, version,`
`56`	`62`	`() => send(statusPayload(probeId, version, STATUSES.EMITTING))`
`@@ -78,6 +84,8 @@ function send (payload) {`
`78`	`84`	`}`
`79`	`85`
`80`	`86`	`function onFlush (payload) {`
	`87`	`+ log.debug('[debugger:devtools_client] Flushing diagnostics payload buffer')`
	`88`	`+`
`81`	`89`	`const form = new FormData()`
`82`	`90`
`83`	`91`	`form.append(`