[PARKED] Collect timeout feature

.gitignore

@@ -1,3 +1,4 @@
 node_modules
 .nyc_output
 .vscode
+.DS_Store

README.md

@@ -9,7 +9,7 @@ Programmable interface to [Clinic.js][clinic-url] Flame. Learn more about Clinic
 
 ## Supported node versions
 
-* Node.js 8 and above
+* Node.js 10 and above
 
 ## Example
 
@@ -41,6 +41,7 @@ const flame = new ClinicFlame()
     **Default**: false
   * dest [`<String>`][] The folder where the collected data is stored.
     **Default**: '.'
+  * collectDelay [`<Number>`][] **Default**: 0
 
 #### `flame.collect(args, callback)`
 
@@ -76,5 +77,6 @@ possible error.
 [`<Object>`]: https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Object
 [`<boolean>`]: https://developer.mozilla.org/en-US/docs/Web/JavaScript/Data_structures#Boolean_type
 [`<String>`]: https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/String
+[`<Number>`]: https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Number
 [azure-status]: https://dev.azure.com/node-clinic/node-clinic/_apis/build/status/nearform.node-clinic-doctor
 [azure-url]: https://dev.azure.com/node-clinic/node-clinic/_apis/build/status/nearform.node-clinic-doctor?branchName=master

index.js

@@ -19,11 +19,13 @@ class ClinicFlame extends events.EventEmitter {
     super()
 
     const {
+      collectDelay = 0,
       detectPort = false,
       debug = false,
       dest = null
     } = settings
 
+    this.collectDelay = collectDelay
     this.detectPort = detectPort
     this.debug = debug
     this.path = dest
@@ -37,7 +39,6 @@ class ClinicFlame extends events.EventEmitter {
       path: this.path,
       identifier: '{pid}' // replaced with actual pid by 0x
     })
-
     callbackify(x({
       argv,
       onPort: this.detectPort ? onPort : undefined,
@@ -48,7 +49,8 @@ class ClinicFlame extends events.EventEmitter {
       collectOnly: true,
       writeTicks: true,
       outputDir: paths['/0x-data/'],
-      workingDir: '.' // 0x temporary working files, doesn't support placeholders like {pid}
+      workingDir: '.', // 0x temporary working files, doesn't support placeholders like {pid}
+      collectDelay: this.collectDelay
     }), done)
 
     function done (err, dir) {

package.json

@@ -28,7 +28,7 @@
   "author": "",
   "license": "GPL-3.0-or-later",
   "dependencies": {
-    "0x": "^4.9.1",
+    "0x": "DylanC/0x#collect_timeout_feature",
     "@nearform/clinic-common": "^2.2.0",
     "copy-to-clipboard": "^3.0.8",
     "d3-array": "^2.0.2",

test/cmd-collect-delay.test.js

@@ -0,0 +1,47 @@
+const path = require('path')
+const { test } = require('tap')
+const rimraf = require('rimraf')
+const ClinicFlame = require('../index.js')
+
+test('cmd - test collect - 1s collect delay', (t) => {
+  const tool = new ClinicFlame({ debug: true, collectDelay: 1000 })
+
+  function cleanup (err, dirname) {
+    t.ifError(err)
+    t.match(dirname, /^[0-9]+\.clinic-flame$/)
+
+    rimraf(dirname, (err) => {
+      t.ifError(err)
+      t.end()
+    })
+  }
+
+  const searchTree = (tree, target) => {
+    if (tree.name.includes(target)) {
+      return tree
+    }
+    for (const child of tree.children) {
+      const res = searchTree(child, target)
+
+      if (res) {
+        return res
+      }
+    }
+  }
+
+  tool.collect(
+    [process.execPath, path.join('test', 'fixtures', 'delay.js')],
+    function (err, dirname) {
+      if (err) return cleanup(err, dirname)
+
+      const getLoggingPaths = require('../collect/get-logging-paths')
+      const analyse = require('../analysis')
+      const paths = getLoggingPaths({ path: dirname })
+      analyse(paths).then((result) => {
+        t.equal(searchTree(result.merged, 'delayOneSecond'), null)
+        t.equal(searchTree(result.merged, 'delayTwoSecond').functionName, 'delayTwoSecond')
+        cleanup(null, dirname)
+      })
+    }
+  )
+})

test/fixtures/delay.js

@@ -0,0 +1,17 @@
+const syncWait = ms => {
+  const end = Date.now() + ms
+  while (Date.now() < end) continue
+}
+
+function delayOneSecond () {
+  syncWait(1000)
+  console.log('return after one second')
+}
+
+function delayTwoSecond () {
+  syncWait(2000)
+  console.log('return after two seconds')
+}
+
+delayOneSecond()
+delayTwoSecond()