testing

integration-tests/helpers.js

@@ -341,22 +341,38 @@ function telemetryForwarder (expectedTelemetryPoints) {
 
   let retries = 0
 
+  const tryAgain = async function () {
+    retries += 1
+    await new Promise(resolve => setTimeout(resolve, 100))
+    return cleanup()
+  }
+
   const cleanup = async function () {
     let msgs
     try {
       msgs = (await fs.readFile(process.env.FORWARDER_OUT, 'utf8')).trim().split('\n')
     } catch (e) {
       if (expectedTelemetryPoints.length && e.code === 'ENOENT' && retries < 10) {
-        retries += 1
-        await new Promise(resolve => setTimeout(resolve, 100))
-        return cleanup()
+        return tryAgain()
       }
       return []
     }
-    msgs = msgs.map(msg => {
-      const [telemetryType, data] = msg.split('\t')
-      return [telemetryType, JSON.parse(data)]
-    })
+    for (let i = 0; i < msgs.length; i++) {
+      const [telemetryType, data] = msgs[i].split('\t')
+      if (!data && retries < 10) {
+        return tryAgain()
+      }
+      let parsed
+      try {
+        parsed = JSON.parse(data)
+      } catch (e) {
+        if (!data && retries < 10) {
+          return tryAgain()
+        }
+        throw new SyntaxError(`error parsing data: ${e.message}\n${data}`)
+      }
+      msgs[i] = [telemetryType, JSON.parse(data)]
+    }
     await fs.unlink(process.env.FORWARDER_OUT)
     delete process.env.FORWARDER_OUT
     delete process.env.DD_TELEMETRY_FORWARDER_PATH

integration-tests/init.spec.js

@@ -124,7 +124,7 @@ true
   })
 }
 
-describe('init.js', () => {
+describe.only('init.js', () => {
   useSandbox()
 
   testInjectionScenarios('require', 'init.js', false)

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

@@ -60,5 +60,6 @@ function sendTelemetry (name, tags = []) {
     stdio: 'pipe',
     shell: true
   })
-  proc.stdin.end(JSON.stringify({ metadata, points }))
+  const bytes = JSON.stringify({ metadata, points })
+  proc.stdin.end(bytes)
 }