web: mark as uncloneable when possible

This tells node that the marked instances from undici are not cloneable,
so that attempts to cloning those throw `DataCloneError`.

lib/core/util.js

@@ -6,6 +6,7 @@ const { IncomingMessage } = require('node:http')
 const stream = require('node:stream')
 const net = require('node:net')
 const { Blob } = require('node:buffer')
+const { markAsUncloneable } = require('node:worker_threads')
 const nodeUtil = require('node:util')
 const { stringify } = require('node:querystring')
 const { EventEmitter: EE } = require('node:events')
@@ -816,6 +817,12 @@ function errorRequest (client, request, err) {
   }
 }
 
+function maybeMarkAsUncloneable (target) {
+  if (markAsUncloneable !== undefined) {
+    markAsUncloneable(target)
+  }
+}
+
 const kEnumerableProperty = Object.create(null)
 kEnumerableProperty.enumerable = true
 
@@ -875,6 +882,7 @@ module.exports = {
   isFormDataLike,
   serializePathWithQuery,
   addAbortListener,
+  maybeMarkAsUncloneable,
   isValidHTTPToken,
   isValidHeaderValue,
   isTokenCharCode,

lib/web/eventsource/eventsource.js

@@ -9,7 +9,7 @@ const { parseMIMEType } = require('../fetch/data-url')
 const { createFastMessageEvent } = require('../websocket/events')
 const { isNetworkError } = require('../fetch/response')
 const { delay } = require('./util')
-const { kEnumerableProperty } = require('../../core/util')
+const { kEnumerableProperty, maybeMarkAsUncloneable } = require('../../core/util')
 const { environmentSettingsObject } = require('../fetch/util')
 
 let experimentalWarned = false
@@ -109,6 +109,8 @@ class EventSource extends EventTarget {
     // 1. Let ev be a new EventSource object.
     super()
 
+    maybeMarkAsUncloneable(this)
+
     const prefix = 'EventSource constructor'
     webidl.argumentLengthCheck(arguments, 1, prefix)
 

lib/web/fetch/formdata.js

@@ -1,7 +1,7 @@
 'use strict'
 
 const { iteratorMixin } = require('./util')
-const { kEnumerableProperty } = require('../../core/util')
+const { kEnumerableProperty, maybeMarkAsUncloneable } = require('../../core/util')
 const { webidl } = require('./webidl')
 const { File: NativeFile } = require('node:buffer')
 const nodeUtil = require('node:util')
@@ -14,6 +14,8 @@ class FormData {
   #state = []
 
   constructor (form) {
+    maybeMarkAsUncloneable(this)
+
     if (form !== undefined) {
       throw webidl.errors.conversionFailed({
         prefix: 'FormData constructor',

lib/web/fetch/headers.js

@@ -3,7 +3,7 @@
 'use strict'
 
 const { kConstruct } = require('../../core/symbols')
-const { kEnumerableProperty } = require('../../core/util')
+const { kEnumerableProperty, maybeMarkAsUncloneable } = require('../../core/util')
 const {
   iteratorMixin,
   isValidHeaderName,
@@ -189,6 +189,8 @@ class HeadersList {
   headersMap
 
   constructor (init) {
+    maybeMarkAsUncloneable(this)
+
     if (init instanceof HeadersList) {
       this.headersMap = new Map(init.headersMap)
       this.sortedMap = init.sortedMap

lib/web/fetch/request.js

@@ -22,7 +22,7 @@ const {
   requestCache,
   requestDuplex
 } = require('./constants')
-const { kEnumerableProperty, normalizedMethodRecordsBase, normalizedMethodRecords } = util
+const { kEnumerableProperty, maybeMarkAsUncloneable, normalizedMethodRecordsBase, normalizedMethodRecords } = util
 const { webidl } = require('./webidl')
 const { URLSerializer } = require('./data-url')
 const { kConstruct } = require('../../core/symbols')
@@ -92,6 +92,8 @@ class Request {
 
   // https://fetch.spec.whatwg.org/#dom-request
   constructor (input, init = undefined) {
+    maybeMarkAsUncloneable(this)
+
     if (input === kConstruct) {
       return
     }

lib/web/fetch/response.js

@@ -4,7 +4,7 @@ const { Headers, HeadersList, fill, getHeadersGuard, setHeadersGuard, setHeaders
 const { extractBody, cloneBody, mixinBody, hasFinalizationRegistry, streamRegistry, bodyUnusable } = require('./body')
 const util = require('../../core/util')
 const nodeUtil = require('node:util')
-const { kEnumerableProperty } = util
+const { kEnumerableProperty, maybeMarkAsUncloneable } = util
 const {
   isValidReasonPhrase,
   isCancelled,
@@ -113,6 +113,8 @@ class Response {
 
   // https://fetch.spec.whatwg.org/#dom-response
   constructor (body = null, init = undefined) {
+    maybeMarkAsUncloneable(this)
+
     if (body === kConstruct) {
       return
     }

lib/web/websocket/events.js

@@ -1,7 +1,7 @@
 'use strict'
 
 const { webidl } = require('../fetch/webidl')
-const { kEnumerableProperty } = require('../../core/util')
+const { kEnumerableProperty, maybeMarkAsUncloneable } = require('../../core/util')
 const { kConstruct } = require('../../core/symbols')
 const { MessagePort } = require('node:worker_threads')
 
@@ -14,6 +14,7 @@ class MessageEvent extends Event {
   constructor (type, eventInitDict = {}) {
     if (type === kConstruct) {
       super(arguments[1], arguments[2])
+      maybeMarkAsUncloneable(this)
       return
     }
 
@@ -26,6 +27,7 @@ class MessageEvent extends Event {
     super(type, eventInitDict)
 
     this.#eventInit = eventInitDict
+    maybeMarkAsUncloneable(this)
   }
 
   get data () {
@@ -112,6 +114,7 @@ class CloseEvent extends Event {
     super(type, eventInitDict)
 
     this.#eventInit = eventInitDict
+    maybeMarkAsUncloneable(this)
   }
 
   get wasClean () {

lib/web/websocket/websocket.js

@@ -17,7 +17,7 @@ const {
 } = require('./util')
 const { establishWebSocketConnection, closeWebSocketConnection } = require('./connection')
 const { ByteParser } = require('./receiver')
-const { kEnumerableProperty } = require('../../core/util')
+const { kEnumerableProperty, maybeMarkAsUncloneable } = require('../../core/util')
 const { getGlobalDispatcher } = require('../../global')
 const { types } = require('node:util')
 const { ErrorEvent, CloseEvent, createFastMessageEvent } = require('./events')
@@ -100,6 +100,8 @@ class WebSocket extends EventTarget {
   constructor (url, protocols = []) {
     super()
 
+    maybeMarkAsUncloneable(this)
+
     const prefix = 'WebSocket constructor'
     webidl.argumentLengthCheck(arguments, 1, prefix)