Upgrade reported Node.js version to 26.3.0

scripts/bootstrap.ps1

@@ -1,4 +1,4 @@
-# Version: 19
+# Version: 20
 # A script that installs the dependencies needed to build and test Bun on Windows.
 # Supports both x64 and ARM64 using Scoop for package management.
 # Used by Azure [build images] pipeline.

scripts/bootstrap.sh

@@ -1,5 +1,5 @@
 #!/bin/sh
-# Version: 34
+# Version: 35
 
 # A script that installs the dependencies needed to build and test Bun.
 # This should work on macOS and Linux with a POSIX shell.

src/js/builtins/CompressionStream.ts

@@ -1,6 +1,11 @@
 export function initializeCompressionStream(this, format) {
   const zlib = require("node:zlib");
-  const stream = require("node:stream");
+  const {
+    newReadableWritablePairFromDuplex,
+    kValidateChunk,
+    kDestroyOnSyncError,
+  } = require("internal/webstreams_adapters");
+  const { isArrayBufferView, isSharedArrayBuffer } = require("node:util/types");
 
   const builders = {
     "deflate": zlib.createDeflate,
@@ -14,8 +19,18 @@ export function initializeCompressionStream(this, format) {
     throw $ERR_INVALID_ARG_VALUE("format", format, "must be one of: " + Object.keys(builders).join(", "));
 
   const handle = builders[format]();
-  $putByIdDirectPrivate(this, "readable", stream.Readable.toWeb(handle));
-  $putByIdDirectPrivate(this, "writable", stream.Writable.toWeb(handle));
+  const transform = newReadableWritablePairFromDuplex(handle, {
+    // Per the Compression Streams spec, chunks must be BufferSource
+    // (ArrayBuffer or ArrayBufferView not backed by SharedArrayBuffer).
+    [kValidateChunk]: function validateBufferSourceChunk(chunk) {
+      if (isSharedArrayBuffer(isArrayBufferView(chunk) ? chunk.buffer : chunk)) {
+        throw $ERR_INVALID_ARG_TYPE("chunk", ["ArrayBuffer", "Buffer", "TypedArray", "DataView"], chunk);
+      }
+    },
+    [kDestroyOnSyncError]: true,
+  });
+  $putByIdDirectPrivate(this, "readable", transform.readable);
+  $putByIdDirectPrivate(this, "writable", transform.writable);
 
   return this;
 }

src/js/builtins/DecompressionStream.ts

@@ -1,6 +1,11 @@
 export function initializeDecompressionStream(this, format) {
   const zlib = require("node:zlib");
-  const stream = require("node:stream");
+  const {
+    newReadableWritablePairFromDuplex,
+    kValidateChunk,
+    kDestroyOnSyncError,
+  } = require("internal/webstreams_adapters");
+  const { isArrayBufferView, isSharedArrayBuffer } = require("node:util/types");
 
   const builders = {
     "deflate": zlib.createInflate,
@@ -14,8 +19,18 @@ export function initializeDecompressionStream(this, format) {
     throw $ERR_INVALID_ARG_VALUE("format", format, "must be one of: " + Object.keys(builders).join(", "));
 
   const handle = builders[format]();
-  $putByIdDirectPrivate(this, "readable", stream.Readable.toWeb(handle));
-  $putByIdDirectPrivate(this, "writable", stream.Writable.toWeb(handle));
+  const transform = newReadableWritablePairFromDuplex(handle, {
+    // Per the Compression Streams spec, chunks must be BufferSource
+    // (ArrayBuffer or ArrayBufferView not backed by SharedArrayBuffer).
+    [kValidateChunk]: function validateBufferSourceChunk(chunk) {
+      if (isSharedArrayBuffer(isArrayBufferView(chunk) ? chunk.buffer : chunk)) {
+        throw $ERR_INVALID_ARG_TYPE("chunk", ["ArrayBuffer", "Buffer", "TypedArray", "DataView"], chunk);
+      }
+    },
+    [kDestroyOnSyncError]: true,
+  });
+  $putByIdDirectPrivate(this, "readable", transform.readable);
+  $putByIdDirectPrivate(this, "writable", transform.writable);
 
   return this;
 }

src/js/builtins/ReadableStreamInternals.ts

@@ -1606,6 +1606,19 @@ export function readableStreamCancel(stream: ReadableStream, reason: any) {
   if (state === $streamErrored) return Promise.$reject($getByIdDirectPrivate(stream, "storedError"));
   $readableStreamClose(stream);
 
+  // https://streams.spec.whatwg.org/#readable-stream-cancel step 5: a BYOB
+  // reader's pending read requests are closed with undefined ($readableStreamClose
+  // only settles default-reader read requests; respond(0) is not coming after cancel).
+  const reader = $getByIdDirectPrivate(stream, "reader");
+  if (reader && $isReadableStreamBYOBReader(reader)) {
+    const requests = $getByIdDirectPrivate(reader, "readIntoRequests");
+    if (requests.isNotEmpty()) {
+      $putByIdDirectPrivate(reader, "readIntoRequests", $createFIFO());
+      for (var request = requests.shift(); request; request = requests.shift())
+        $fulfillPromise(request, { value: undefined, done: true });
+    }
+  }
+
   const controller = $getByIdDirectPrivate(stream, "readableStreamController");
   if (controller === null) return Promise.$resolve();
 

src/js/internal/http.ts

@@ -353,6 +353,8 @@ function emitErrorNt(msg, err, callback) {
 const setMaxHTTPHeaderSize = $newZigFunction("node_http_binding.zig", "setMaxHTTPHeaderSize", 1);
 const getMaxHTTPHeaderSize = $newZigFunction("node_http_binding.zig", "getMaxHTTPHeaderSize", 0);
 const kOutHeaders = Symbol("kOutHeaders");
+const kProxyConfig = Symbol("kProxyConfig");
+const kWaitForProxyTunnel = Symbol("kWaitForProxyTunnel");
 
 function ipToInt(ip) {
   const octets = ip.split(".");
@@ -532,6 +534,7 @@ export {
   kPendingCallbacks,
   kPort,
   kProtocol,
+  kProxyConfig,
   kRealListen,
   kRequest,
   kRes,
@@ -542,6 +545,7 @@ export {
   kTls,
   kUpgradeOrConnect,
   kUseDefaultPort,
+  kWaitForProxyTunnel,
   noBodySymbol,
   optionsSymbol,
   parseProxyConfigFromEnv,

src/js/internal/primordials.js

@@ -96,6 +96,24 @@ const arrayToSafePromiseIterable = (promises, mapFn) =>
 const PromiseAll = Promise.all;
 const PromiseResolve = Promise.$resolve.bind(Promise);
 const SafePromiseAll = (promises, mapFn) => PromiseAll(arrayToSafePromiseIterable(promises, mapFn));
+const SafePromiseAllReturnVoid = (promises, mapFn) =>
+  new Promise((resolve, reject) => {
+    const { length } = promises;
+
+    if (length === 0) resolve();
+
+    let pendingPromises = length;
+    for (let i = 0; i < length; i++) {
+      const promise = mapFn != null ? mapFn(promises[i], i) : promises[i];
+      PromisePrototypeThen.$call(
+        PromiseResolve(promise),
+        () => {
+          if (--pendingPromises === 0) resolve();
+        },
+        reject,
+      );
+    }
+  });
 const SafePromiseAllReturnArrayLike = (promises, mapFn) =>
   new Promise((resolve, reject) => {
     const { length } = promises;
@@ -136,6 +154,7 @@ export default {
   ),
   SafePromiseAll,
   SafePromiseAllReturnArrayLike,
+  SafePromiseAllReturnVoid,
   SafeSet: makeSafe(
     Set,
     class SafeSet extends Set {

src/js/internal/streams/duplex.ts

@@ -140,8 +140,8 @@ Duplex.fromWeb = function (pair, options) {
   return lazyWebStreams().newStreamDuplexFromReadableWritablePair(pair, options);
 };
 
-Duplex.toWeb = function (duplex) {
-  return lazyWebStreams().newReadableWritablePairFromDuplex(duplex);
+Duplex.toWeb = function (duplex, options) {
+  return lazyWebStreams().newReadableWritablePairFromDuplex(duplex, options);
 };
 
 let duplexify;

src/js/internal/streams/duplexify.ts

@@ -312,7 +312,7 @@ function _duplexify(pair) {
     eos(r, err => {
       readable = false;
       if (err) {
-        destroyer(r, err);
+        destroyer(w, err);
       }
       onfinished(err);
     });