crasher tests

Author: maidh91

test/crasher.test.js

@@ -1,7 +1,68 @@
 'use strict'
 
 const { test } = require('brittle')
+const path = require('bare-path')
+const fs = require('bare-fs')
+const os = require('bare-os')
 
-test('crasher', async function (t) {
-  // TODO: write tests
+const Helper = require('./helper')
+
+const dirname = __dirname
+
+test('crasher uncaught exception', async function (t) {
+  const dir = path.join(dirname, 'fixtures', 'run-crasher-uncaught-exception')
+
+  const teardown = Helper.rig({ runtimeArgv: [dir] })
+  t.teardown(teardown)
+
+  const swap = path.join(os.tmpdir(), `${Date.now()}`)
+  await fs.promises.mkdir(swap)
+  const pipe = Pear.run(dir, [swap])
+  pipe.on('error', (err) => {
+    if (err.code === 'ENOTCONN') return // when the other side destroys the pipe
+    throw err
+  })
+
+  const pid = await Helper.untilResult(pipe)
+  await Helper.untilExit(pid)
+
+  const crashlogPath = path.join(swap, 'testProcess.crash.log')
+  await Helper.untilExists(crashlogPath)
+  t.ok(fs.existsSync(crashlogPath), 'Crash log file should be created')
+
+  await Helper.untilHandler(async () => {
+    const logContent = await fs.promises.readFile(crashlogPath, 'utf8')
+    return logContent.includes('Test uncaught exception')
+  })
+  const logContent = await fs.promises.readFile(crashlogPath, 'utf8')
+  t.ok(logContent.includes('Test uncaught exception'), 'Log should contain the error message')
+})
+
+test('crasher unhandled rejection', async function (t) {
+  const dir = path.join(dirname, 'fixtures', 'run-crasher-unhandled-rejection')
+
+  const teardown = Helper.rig({ runtimeArgv: [dir] })
+  t.teardown(teardown)
+
+  const swap = path.join(os.tmpdir(), `${Date.now()}`)
+  await fs.promises.mkdir(swap)
+  const pipe = Pear.run(dir, [swap])
+  pipe.on('error', (err) => {
+    if (err.code === 'ENOTCONN') return // when the other side destroys the pipe
+    throw err
+  })
+
+  const pid = await Helper.untilResult(pipe)
+  await Helper.untilExit(pid)
+
+  const crashlogPath = path.join(swap, 'testProcess.crash.log')
+  await Helper.untilExists(crashlogPath)
+  t.ok(fs.existsSync(crashlogPath), 'Crash log file should be created')
+
+  await Helper.untilHandler(async () => {
+    const logContent = await fs.promises.readFile(crashlogPath, 'utf8')
+    return logContent.includes('Test unhandled rejection')
+  })
+  const logContent = await fs.promises.readFile(crashlogPath, 'utf8')
+  t.ok(logContent.includes('Test unhandled rejection'), 'Log should contain the error message')
 })

test/fixtures/run-crasher-uncaught-exception/index.js

@@ -0,0 +1,16 @@
+const Helper = require('../../helper')
+
+Helper.rig({ state: { config: { args: Bare.argv.slice(4) } } })
+const [swap] = Pear.config.args
+
+const setupCrashHandlers = require('../../../crasher')
+setupCrashHandlers('testProcess', swap, true)
+
+const main = async () => {
+  const pipe = Pear.pipe
+  pipe.write(`${Bare.pid}\n`)
+
+  await new Promise((resolve) => setTimeout(resolve, 1000))
+  throw new Error('Test uncaught exception')
+}
+main()

test/fixtures/run-crasher-unhandled-rejection/index.js

@@ -0,0 +1,16 @@
+const Helper = require('../../helper')
+
+Helper.rig({ state: { config: { args: Bare.argv.slice(4) } } })
+const [swap] = Pear.config.args
+
+const setupCrashHandlers = require('../../../crasher')
+setupCrashHandlers('testProcess', swap, true)
+
+const main = async () => {
+  const pipe = Pear.pipe
+  pipe.write(`${Bare.pid}\n`)
+
+  await new Promise((resolve) => setTimeout(resolve, 1000))
+  await new Promise((resolve, reject) => reject(new Error('Test unhandled rejection')))
+}
+main()

test/helper.js

@@ -3,6 +3,7 @@ global.Pear = null
 
 const { isWindows } = require('which-runtime')
 const IPC = require('pear-ipc')
+const fs = require('bare-fs')
 
 const dirname = __dirname
 const socketPath = isWindows ? '\\\\.\\pipe\\pear-api-test-ipc' : 'test.sock'
@@ -109,6 +110,28 @@ class Helper {
     }
   }
 
+  static async untilExists (path, timeout = 5000, start = Date.now()) {
+    if (Date.now() - start > timeout) throw new Error('timed out')
+    try {
+      await fs.promises.stat(path)
+      return true
+    } catch (err) {
+      if (err.code !== 'ENOENT') throw err
+    }
+    await new Promise((resolve) => setTimeout(resolve, 100))
+    await Helper.untilExists(path, timeout, start)
+  }
+
+  static async untilHandler (handler, timeout = 5000, start = Date.now()) {
+    if (Date.now() - start > timeout) throw new Error('timed out')
+    try {
+      const res = await handler()
+      if (res) return res
+    } catch {}
+    await new Promise((resolve) => setTimeout(resolve, 100))
+    await Helper.untilHandler(handler, timeout, start)
+  }
+
   static async startIpcClient () {
     const client = new IPC.Client({
       socketPath

test/index.test.js

@@ -2,7 +2,7 @@
 
 const { test } = require('brittle')
 const { isWindows } = require('which-runtime')
-const path = require('path')
+const path = require('bare-path')
 const os = require('bare-os')
 const Iambus = require('iambus')
 

test/worker.test.js

@@ -1,7 +1,7 @@
 'use strict'
 
 const { test } = require('brittle')
-const path = require('path')
+const path = require('bare-path')
 
 const dirname = __dirname
 global.Pear = null