tmp

Author: watson

integration-tests/helpers/index.js

@@ -258,6 +258,7 @@ function telemetryForwarder (shouldExpectTelemetryPoints = true) {
     try {
       msgs = fs.readFileSync(process.env.FORWARDER_OUT, 'utf8').trim().split('\n')
     } catch (e) {
+      console.log('-- error 1', e)
       if (shouldExpectTelemetryPoints && e.code === 'ENOENT' && retries < 10) {
         return tryAgain()
       }
@@ -272,13 +273,18 @@ function telemetryForwarder (shouldExpectTelemetryPoints = true) {
       try {
         parsed = JSON.parse(data)
       } catch (e) {
+        console.log('-- error 2', e)
         if (!data && retries < 10) {
           return tryAgain()
         }
         throw new SyntaxError(`error parsing data: ${e.message}\n${data}`)
       }
       msgs[i] = [telemetryType, parsed]
     }
+    console.log('telemetryForwarder', process.env.FORWARDER_OUT)
+    console.log('--------------------------------')
+    console.log(fs.readFileSync(process.env.FORWARDER_OUT, 'utf8'))
+    console.log('--------------------------------')
     fs.unlinkSync(process.env.FORWARDER_OUT)
     delete process.env.FORWARDER_OUT
     delete process.env.DD_TELEMETRY_FORWARDER_PATH

packages/dd-trace/src/guardrails/telemetry.js

@@ -45,32 +45,40 @@ function shouldSend (point) {
 }
 
 function sendTelemetry (name, tags) {
+  console.log('-- sendTelemetry', name, tags)
   var points = name
   if (typeof name === 'string') {
     points = [{ name: name, tags: tags || [] }]
+    console.log('-- points 1', points)
   }
   if (['1', 'true', 'True'].indexOf(process.env.DD_INJECT_FORCE) !== -1) {
     points = points.filter(function (p) { return ['error', 'complete'].indexOf(p.name) !== -1 })
+    console.log('-- points 2', points)
   }
   points = points.filter(function (p) { return shouldSend(p) })
+  console.log('-- points 3', points)
   for (var i = 0; i < points.length; i++) {
     points[i].name = 'library_entrypoint.' + points[i].name
   }
+  console.log('-- points 4', points)
   if (points.length === 0) {
     return
   }
   var proc = spawn(process.env.DD_TELEMETRY_FORWARDER_PATH, ['library_entrypoint'], {
     stdio: 'pipe'
   })
   proc.on('error', function () {
+    console.log('Failed to spawn telemetry forwarder')
     log.error('Failed to spawn telemetry forwarder')
   })
   proc.on('exit', function (code) {
+    console.log('Telemetry forwarder exited with code', code)
     if (code !== 0) {
       log.error('Telemetry forwarder exited with code', code)
     }
   })
   proc.stdin.on('error', function () {
+    console.log('Failed to write telemetry data to telemetry forwarder')
     log.error('Failed to write telemetry data to telemetry forwarder')
   })
   proc.stdin.end(JSON.stringify({ metadata: metadata, points: points }))

packages/dd-trace/test/guardrails/telemetry.spec.js

@@ -1,6 +1,9 @@
 'use strict'
 
+console.log('--- HELLO WORLD ---')
+
 process.env.DD_INJECTION_ENABLED = 'true'
+process.env.DD_TRACE_DEBUG = 'true'
 
 const { telemetryForwarder, assertTelemetryPoints } = require('../../../../integration-tests/helpers')