fix(pool): throw if user's tests use process.send() (#8125)

Author: AriPerkkio

packages/vitest/src/node/pools/forks.ts

@@ -30,7 +30,21 @@ function createChildProcessChannel(project: TestProject, collect = false) {
   const rpc = createBirpc<RunnerRPC, RuntimeRPC>(createMethodsRPC(project, { cacheFs: true, collect }), {
     eventNames: ['onCancel'],
     serialize: v8.serialize,
-    deserialize: v => v8.deserialize(Buffer.from(v)),
+    deserialize: (v) => {
+      try {
+        return v8.deserialize(Buffer.from(v))
+      }
+      catch (error) {
+        let stringified = ''
+
+        try {
+          stringified = `\nReceived value: ${JSON.stringify(v)}`
+        }
+        catch {}
+
+        throw new Error(`[vitest-pool]: Unexpected call to process.send(). Make sure your test cases are not interfering with process's channel.${stringified}`, { cause: error })
+      }
+    },
     post(v) {
       emitter.emit(events.message, v)
     },

packages/vitest/src/node/pools/vmForks.ts

@@ -35,7 +35,21 @@ function createChildProcessChannel(project: TestProject, collect: boolean) {
     {
       eventNames: ['onCancel'],
       serialize: v8.serialize,
-      deserialize: v => v8.deserialize(Buffer.from(v)),
+      deserialize: (v) => {
+        try {
+          return v8.deserialize(Buffer.from(v))
+        }
+        catch (error) {
+          let stringified = ''
+
+          try {
+            stringified = `\nReceived value: ${JSON.stringify(v)}`
+          }
+          catch {}
+
+          throw new Error(`[vitest-pool]: Unexpected call to process.send(). Make sure your test cases are not interfering with process's channel.${stringified}`, { cause: error })
+        }
+      },
       post(v) {
         emitter.emit(events.message, v)
       },

test/cli/fixtures/forks-channel/process-send.test.ts

@@ -0,0 +1,9 @@
+import { test } from "vitest";
+
+test("calls IPC channel", () => {
+  if (!process.send) {
+    throw new Error("Expected test case to run inside child_process")
+  }
+
+  process.send({ "not serialized": "with v8 serializer" })
+})

test/cli/fixtures/forks-channel/vitest.config.ts

@@ -0,0 +1 @@
+export default {}

test/cli/test/forks-channel.test.ts

@@ -0,0 +1,12 @@
+import { expect, test } from 'vitest'
+import { runVitest } from '../../test-utils'
+
+test.each(['forks', 'vmForks'] as const)('test case\'s process.send() calls are handled', async (pool) => {
+  const { stderr } = await runVitest({
+    root: './fixtures/forks-channel',
+    pool,
+  })
+
+  expect(stderr).toContain('⎯⎯⎯⎯ Unhandled Rejection ⎯⎯⎯⎯⎯')
+  expect(stderr).toContain('Error: [vitest-pool]: Unexpected call to process.send(). Make sure your test cases are not interfering with process\'s channel.')
+})