test_runner: validate inner v8 header before deserializing

Check that a framed payload starts with the inner v8 header before
handing it to the deserializer, so stray stdout that mimics a frame is
rejected as output while genuine deserialize failures still surface.

Signed-off-by: Muhammad Faizan Uddin <faizan.uddin94@gmail.com>

Author: faizanu94

lib/internal/test_runner/runner.js

@@ -508,25 +508,23 @@ class FileTest extends Test {
       const concatenatedBuffer = this.#rawBuffer.length === 1 ?
         this.#rawBuffer[0] : Buffer.concat(this.#rawBuffer, this.#rawBufferSize);
 
+      // A real frame repeats the v8 header at the start of its payload, right
+      // before the serialized value. If that inner header is missing, these
+      // are stray stdout bytes that only look like a frame, so stop here and
+      // let #drainRawBuffer emit them as stdout and resync on the next real
+      // header. A genuine frame that fails to deserialize is left to throw, so
+      // real report-protocol regressions are not silently hidden.
+      if (fullMessageSize - kSerializedSizeHeader < kV8HeaderLength ||
+          concatenatedBuffer.indexOf(v8Header, kSerializedSizeHeader) !== kSerializedSizeHeader) {
+        break;
+      }
+
       const deserializer = new DefaultDeserializer(
         TypedArrayPrototypeSubarray(concatenatedBuffer, kSerializedSizeHeader, fullMessageSize),
       );
+      deserializer.readHeader();
+      const item = deserializer.readValue();
 
-      let item;
-      try {
-        deserializer.readHeader();
-        item = deserializer.readValue();
-      } catch {
-        // The bytes begin with the v8 header magic and a plausible size, but
-        // the payload is not a real serialized message. This happens when a
-        // test writes raw bytes to stdout that look like a frame. Leave the
-        // buffer untouched and stop parsing frames here. #drainRawBuffer then
-        // emits the stray byte as stdout and rescans for the next real header.
-        break;
-      }
-
-      // Only advance past the frame once it has been read successfully, so a
-      // failed read above cannot drop real frames that follow the stray bytes.
       bufferHead = TypedArrayPrototypeSubarray(concatenatedBuffer, fullMessageSize);
       this.#rawBufferSize = TypedArrayPrototypeGetLength(bufferHead);
       this.#rawBuffer = this.#rawBufferSize !== 0 ? [bufferHead] : [];

test/parallel/test-runner-v8-deserializer.mjs

@@ -40,16 +40,28 @@ const oversizedLengthStdout = String.fromCharCode(oversizedLengthHeader[0]) +
 const unsignedOversizedLengthStdout = String.fromCharCode(unsignedOversizedLengthHeader[0]) +
   Buffer.from(unsignedOversizedLengthHeader.subarray(1)).toString('utf-8');
 // FF 0F followed by a small, plausible size (8) and 8 payload bytes. Unlike the
-// oversized headers above, this passes the size check and reaches the
-// deserializer, which throws because the payload is not a real message.
+// oversized headers above, this passes the size check, but its payload does not
+// begin with the inner v8 header a real frame carries, so it is treated as
+// stdout instead of reaching the deserializer.
 // Regression fixture for https://github.com/nodejs/node/issues/66164
 const plausibleSizeFalseHeader = Buffer.from([
-  0xff, 0x0f,             // v8 serializer header magic
-  0x00, 0x00, 0x00, 0x08, // payload size of 8 bytes
+  0xff, 0x0f,             // V8 serializer header magic
+  0x00, 0x00, 0x00, 0x08, // Payload size of 8 bytes
   0x41, 0x42, 0x43, 0x44, 0x45, 0x46, 0x47, 0x48, // "ABCDEFGH", not a real payload
 ]);
 const plausibleSizeFalseHeaderStdout = String.fromCharCode(plausibleSizeFalseHeader[0]) +
   Buffer.from(plausibleSizeFalseHeader.subarray(1)).toString('utf-8');
+// FF 0F, a valid size, then the inner v8 header a real frame repeats, followed
+// by a byte that is not a valid serialized value. This passes the inner header
+// check and reaches the deserializer, which throws. This is what a genuine
+// report-protocol regression looks like, so the parser must let the error
+// surface instead of hiding it as stdout.
+const headeredCorruptFrame = Buffer.from([
+  0xff, 0x0f,             // Outer v8 serializer header magic
+  0x00, 0x00, 0x00, 0x03, // Payload size of 3 bytes
+  0xff, 0x0f,             // Inner v8 header that a real frame repeats
+  0xee,                   // Not a valid serialized value
+]);
 
 function collectStdout(reported) {
   return reported
@@ -182,16 +194,17 @@ describe('v8 deserializer', common.mustCall(() => {
 
   it('should not crash when stdout mimics a v8 frame with a plausible size', async () => {
     // Regression test for https://github.com/nodejs/node/issues/66164
-    // The bytes reach the deserializer and it throws. The parser must emit
-    // them as stdout instead of letting the error abort the whole run.
+    // The payload does not start with the inner v8 header that a real frame
+    // carries, so the parser treats the bytes as stdout instead of handing
+    // them to the deserializer and aborting the whole run.
     const reported = await collectReported([plausibleSizeFalseHeader]);
     assert(reported.every((event) => event.type === 'test:stdout'));
     assert.strictEqual(collectStdout(reported), plausibleSizeFalseHeaderStdout);
   });
 
   it('should resync and parse a real message after a plausible-size false frame', async () => {
     // The poison bytes followed by a real serialized message. The parser must
-    // recover from the failed deserialize and still report the real event.
+    // reject the poison as stdout and still report the real event.
     const reported = await collectReported([
       plausibleSizeFalseHeader,
       ...chunks,
@@ -226,6 +239,14 @@ describe('v8 deserializer', common.mustCall(() => {
     assert.strictEqual(collectStdout(reported), plausibleSizeFalseHeaderStdout);
   });
 
+  it('should surface a genuinely corrupt frame instead of hiding it', () => {
+    // A frame with both v8 headers and a valid size but an invalid value is
+    // what a real report-protocol regression looks like, not stray stdout.
+    // The parser must let the deserialize error surface instead of silently
+    // turning it into stdout.
+    assert.throws(() => fileTest.parseMessage(headeredCorruptFrame), /deserialize/);
+  });
+
   const headerPosition = headerLength * 2 + 4;
   for (let i = 0; i < headerPosition + 5; i++) {
     const message = `should deserialize a serialized message split into two chunks {...${i},${i + 1}...}`;