react-server-dom-turbopack - npm Package Compare versions

Comparing version 0.0.0-experimental-3208e73e-20240730 to 0.0.0-experimental-32b0cad8-20250213

cjs/react-server-dom-turbopack-client.browser.production.js

@@ -17,6 +17,6 @@ /**
     var moduleExports = bundlerConfig[metadata[0]];
-    if ((bundlerConfig = moduleExports[metadata[2]]))
+    if ((bundlerConfig = moduleExports && moduleExports[metadata[2]]))
       moduleExports = bundlerConfig.name;
     else {
-      bundlerConfig = moduleExports["*"];
+      bundlerConfig = moduleExports && moduleExports["*"];
       if (!bundlerConfig)
@@ -26,3 +26,3 @@ throw Error(
             metadata[0] +
-            '" in the React SSR Manifest. This is probably a bug in the React Server Components bundler.'
+            '" in the React Server Consumer Manifest. This is probably a bug in the React Server Components bundler.'
         );
@@ -37,2 +37,20 @@ moduleExports = metadata[2];
 }
+function resolveServerReference(bundlerConfig, id) {
+  var name = "",
+    resolvedModuleData = bundlerConfig[id];
+  if (resolvedModuleData) name = resolvedModuleData.name;
+  else {
+    var idx = id.lastIndexOf("#");
+    -1 !== idx &&
+      ((name = id.slice(idx + 1)),
+      (resolvedModuleData = bundlerConfig[id.slice(0, idx)]));
+    if (!resolvedModuleData)
+      throw Error(
+        'Could not find the module "' +
+          id +
+          '" in the React Server Manifest. This is probably a bug in the React Server Components bundler.'
+      );
+  }
+  return [resolvedModuleData.id, resolvedModuleData.chunks, name];
+}
 var chunkCache = new Map();
@@ -78,2 +96,16 @@ function requireAsyncModule(id) {
 }
+function requireModule(metadata) {
+  var moduleExports = __turbopack_require__(metadata[0]);
+  if (4 === metadata.length && "function" === typeof moduleExports.then)
+    if ("fulfilled" === moduleExports.status)
+      moduleExports = moduleExports.value;
+    else throw moduleExports.reason;
+  return "*" === metadata[2]
+    ? moduleExports
+    : "" === metadata[2]
+      ? moduleExports.__esModule
+        ? moduleExports.default
+        : moduleExports
+      : moduleExports[metadata[2]];
+}
 var ReactDOMSharedInternals =
@@ -383,3 +415,3 @@ ReactDOM.__DOM_INTERNALS_DO_NOT_USE_OR_WARN_USERS_THEY_CANNOT_UPGRADE,
           throw Error(
-            "Only plain objects, and a few built-ins, can be passed to Server Actions. Classes or null prototypes are not supported."
+            "Only plain objects, and a few built-ins, can be passed to Server Functions. Classes or null prototypes are not supported."
           );
@@ -456,8 +488,13 @@ return "$T";
     writtenObjects = new WeakMap(),
-    modelRoot = root;
-  root = serializeModel(root, 0);
+    modelRoot = root,
+    json = serializeModel(root, 0);
   null === formData
-    ? resolve(root)
-    : (formData.set(formFieldPrefix + "0", root),
+    ? resolve(json)
+    : (formData.set(formFieldPrefix + "0", json),
       0 === pendingParts && resolve(formData));
+  return function () {
+    0 < pendingParts &&
+      ((pendingParts = 0),
+      null === formData ? resolve(json) : resolve(formData));
+  };
 }
@@ -467,3 +504,19 @@ function registerServerReference(proxy, reference) {
 }
-function Chunk(status, value, reason, response) {
+function createBoundServerReference(metaData, callServer) {
+  function action() {
+    var args = Array.prototype.slice.call(arguments);
+    return bound
+      ? "fulfilled" === bound.status
+        ? callServer(id, bound.value.concat(args))
+        : Promise.resolve(bound).then(function (boundArgs) {
+            return callServer(id, boundArgs.concat(args));
+          })
+      : callServer(id, args);
+  }
+  var id = metaData.id,
+    bound = metaData.bound;
+  registerServerReference(action, { id: id, bound: bound });
+  return action;
+}
+function ReactPromise(status, value, reason, response) {
   this.status = status;
@@ -474,4 +527,4 @@ this.value = value;
 }
-Chunk.prototype = Object.create(Promise.prototype);
-Chunk.prototype.then = function (resolve, reject) {
+ReactPromise.prototype = Object.create(Promise.prototype);
+ReactPromise.prototype.then = function (resolve, reject) {
   switch (this.status) {
@@ -518,4 +571,7 @@ case "resolved_model":
 function createPendingChunk(response) {
-  return new Chunk("pending", null, null, response);
+  return new ReactPromise("pending", null, null, response);
 }
+function createErrorChunk(response, error) {
+  return new ReactPromise("rejected", null, error, response);
+}
 function wakeChunk(listeners, value) {
@@ -560,3 +616,3 @@ for (var i = 0; i < listeners.length; i++) (0, listeners[i])(value);
 function createResolvedIteratorResultChunk(response, value, done) {
-  return new Chunk(
+  return new ReactPromise(
     "resolved_model",
@@ -630,18 +686,5 @@ (done ? '{"done":true,"value":' : '{"done":false,"value":') + value + "}",
   try {
-    var metadata = chunk.value,
-      moduleExports = __turbopack_require__(metadata[0]);
-    if (4 === metadata.length && "function" === typeof moduleExports.then)
-      if ("fulfilled" === moduleExports.status)
-        moduleExports = moduleExports.value;
-      else throw moduleExports.reason;
-    var JSCompiler_inline_result =
-      "*" === metadata[2]
-        ? moduleExports
-        : "" === metadata[2]
-          ? moduleExports.__esModule
-            ? moduleExports.default
-            : moduleExports
-          : moduleExports[metadata[2]];
+    var value = requireModule(chunk.value);
     chunk.status = "fulfilled";
-    chunk.value = JSCompiler_inline_result;
+    chunk.value = value;
   } catch (error) {
@@ -652,2 +695,4 @@ (chunk.status = "rejected"), (chunk.reason = error);
 function reportGlobalError(response, error) {
+  response._closed = !0;
+  response._closedReason = error;
   response._chunks.forEach(function (chunk) {
@@ -663,3 +708,7 @@ "pending" === chunk.status && triggerErrorOnChunk(chunk, error);
     chunk = chunks.get(id);
-  chunk || ((chunk = createPendingChunk(response)), chunks.set(id, chunk));
+  chunk ||
+    ((chunk = response._closed
+      ? createErrorChunk(response, response._closedReason)
+      : createPendingChunk(response)),
+    chunks.set(id, chunk));
   return chunk;
@@ -688,11 +737,15 @@ }
     }
-    parentObject[key] = map(response, value);
-    "" === key && null === handler.value && (handler.value = parentObject[key]);
-    parentObject[0] === REACT_ELEMENT_TYPE &&
-      "3" === key &&
+    i = map(response, value, parentObject, key);
+    parentObject[key] = i;
+    "" === key && null === handler.value && (handler.value = i);
+    if (
+      parentObject[0] === REACT_ELEMENT_TYPE &&
       "object" === typeof handler.value &&
       null !== handler.value &&
-      handler.value.$$typeof === REACT_ELEMENT_TYPE &&
-      null === handler.value.props &&
-      (handler.value.props = parentObject[key]);
+      handler.value.$$typeof === REACT_ELEMENT_TYPE
+    )
+      switch (((value = handler.value), key)) {
+        case "3":
+          value.props = i;
+      }
     handler.deps--;
@@ -732,17 +785,66 @@ 0 === handler.deps &&
 }
-function createServerReferenceProxy(response, metaData) {
-  function proxy() {
-    var args = Array.prototype.slice.call(arguments),
-      p = metaData.bound;
-    return p
-      ? "fulfilled" === p.status
-        ? callServer(metaData.id, p.value.concat(args))
-        : Promise.resolve(p).then(function (bound) {
-            return callServer(metaData.id, bound.concat(args));
-          })
-      : callServer(metaData.id, args);
-  }
-  var callServer = response._callServer;
-  knownServerReferences.set(proxy, metaData);
-  return proxy;
+function loadServerReference(response, metaData, parentObject, key) {
+  if (!response._serverReferenceConfig)
+    return createBoundServerReference(metaData, response._callServer);
+  var serverReference = resolveServerReference(
+    response._serverReferenceConfig,
+    metaData.id
+  );
+  if ((response = preloadModule(serverReference)))
+    metaData.bound && (response = Promise.all([response, metaData.bound]));
+  else if (metaData.bound) response = Promise.resolve(metaData.bound);
+  else return requireModule(serverReference);
+  if (initializingHandler) {
+    var handler = initializingHandler;
+    handler.deps++;
+  } else
+    handler = initializingHandler = {
+      parent: null,
+      chunk: null,
+      value: null,
+      deps: 1,
+      errored: !1
+    };
+  response.then(
+    function () {
+      var resolvedValue = requireModule(serverReference);
+      if (metaData.bound) {
+        var boundArgs = metaData.bound.value.slice(0);
+        boundArgs.unshift(null);
+        resolvedValue = resolvedValue.bind.apply(resolvedValue, boundArgs);
+      }
+      parentObject[key] = resolvedValue;
+      "" === key && null === handler.value && (handler.value = resolvedValue);
+      if (
+        parentObject[0] === REACT_ELEMENT_TYPE &&
+        "object" === typeof handler.value &&
+        null !== handler.value &&
+        handler.value.$$typeof === REACT_ELEMENT_TYPE
+      )
+        switch (((boundArgs = handler.value), key)) {
+          case "3":
+            boundArgs.props = resolvedValue;
+        }
+      handler.deps--;
+      0 === handler.deps &&
+        ((resolvedValue = handler.chunk),
+        null !== resolvedValue &&
+          "blocked" === resolvedValue.status &&
+          ((boundArgs = resolvedValue.value),
+          (resolvedValue.status = "fulfilled"),
+          (resolvedValue.value = handler.value),
+          null !== boundArgs && wakeChunk(boundArgs, handler.value)));
+    },
+    function (error) {
+      if (!handler.errored) {
+        handler.errored = !0;
+        handler.value = error;
+        var chunk = handler.chunk;
+        null !== chunk &&
+          "blocked" === chunk.status &&
+          triggerErrorOnChunk(chunk, error);
+      }
+    }
+  );
+  return null;
 }
@@ -763,6 +865,4 @@ function getOutlinedModel(response, reference, parentObject, key, map) {
       var value = id.value;
-      for (id = 1; id < reference.length; id++)
-        if (
-          ((value = value[reference[id]]), value.$$typeof === REACT_LAZY_TYPE)
-        )
+      for (id = 1; id < reference.length; id++) {
+        for (; value.$$typeof === REACT_LAZY_TYPE; )
           if (((value = value._payload), "fulfilled" === value.status))
@@ -777,5 +877,7 @@ value = value.value;
               map,
-              reference.slice(id)
+              reference.slice(id - 1)
             );
-      return map(response, value);
+        value = value[reference[id]];
+      }
+      return map(response, value, parentObject, key);
     case "pending":
@@ -859,3 +961,3 @@ case "blocked":
             key,
-            createServerReferenceProxy
+            loadServerReference
           )
@@ -891,2 +993,4 @@ );
         );
+      case "Z":
+        return resolveErrorProd();
       case "i":
@@ -925,2 +1029,3 @@ return (
   bundlerConfig,
+  serverReferenceConfig,
   moduleLoading,
@@ -934,2 +1039,3 @@ callServer,
   this._bundlerConfig = bundlerConfig;
+  this._serverReferenceConfig = serverReferenceConfig;
   this._moduleLoading = moduleLoading;
@@ -944,2 +1050,4 @@ this._callServer = void 0 !== callServer ? callServer : missingCall;
   this._buffer = [];
+  this._closed = !1;
+  this._closedReason = null;
   this._tempRefs = temporaryReferences;
@@ -953,3 +1061,3 @@ this._fromJSON = createFromJSONCallback(this);
     ? chunk.reason.enqueueValue(buffer)
-    : chunks.set(id, new Chunk("fulfilled", buffer, null, response));
+    : chunks.set(id, new ReactPromise("fulfilled", buffer, null, response));
 }
@@ -966,3 +1074,3 @@ function resolveModule(response, id, model) {
     } else
-      (blockedChunk = new Chunk("blocked", null, null, response)),
+      (blockedChunk = new ReactPromise("blocked", null, null, response)),
         chunks.set(id, blockedChunk);
@@ -982,3 +1090,3 @@ model.then(
           id,
-          new Chunk("resolved_module", clientReference, null, response)
+          new ReactPromise("resolved_module", clientReference, null, response)
         );
@@ -996,3 +1104,6 @@ }
       null !== response && wakeChunk(response, chunk.value))
-    : chunks.set(id, new Chunk("fulfilled", stream, controller, response));
+    : chunks.set(
+        id,
+        new ReactPromise("fulfilled", stream, controller, response)
+      );
 }
@@ -1018,3 +1129,3 @@ function startReadableStream(response, id, type) {
       if (null === previousBlockedChunk) {
-        var chunk = new Chunk("resolved_model", json, null, response);
+        var chunk = new ReactPromise("resolved_model", json, null, response);
         initializeModelChunk(chunk);
@@ -1095,3 +1206,3 @@ "fulfilled" === chunk.status
           if (closed)
-            return new Chunk(
+            return new ReactPromise(
               "fulfilled",
@@ -1115,3 +1226,3 @@ { done: !0, value: void 0 },
         if (nextWriteIndex === buffer.length)
-          buffer[nextWriteIndex] = new Chunk(
+          buffer[nextWriteIndex] = new ReactPromise(
             "fulfilled",
@@ -1172,2 +1283,9 @@ { done: !1, value: value },
 }
+function resolveErrorProd() {
+  var error = Error(
+    "An error occurred in the Server Components render. The specific message is omitted in production builds to avoid leaking sensitive details. A digest property is included on this error instance which may provide additional details about the nature of the error."
+  );
+  error.stack = "Error: " + error.message;
+  return error;
+}
 function mergeBuffer(buffer, lastChunk) {
@@ -1308,12 +1426,9 @@ for (var l = buffer.length, byteLength = lastChunk.length, i = 0; i < l; i++)
     case 69:
-      tag = JSON.parse(buffer).digest;
-      buffer = Error(
-        "An error occurred in the Server Components render. The specific message is omitted in production builds to avoid leaking sensitive details. A digest property is included on this error instance which may provide additional details about the nature of the error."
-      );
-      buffer.stack = "Error: " + buffer.message;
-      buffer.digest = tag;
+      tag = JSON.parse(buffer);
+      buffer = resolveErrorProd();
+      buffer.digest = tag.digest;
       tag = response._chunks;
       (chunk = tag.get(id))
         ? triggerErrorOnChunk(chunk, buffer)
-        : tag.set(id, new Chunk("rejected", null, buffer, response));
+        : tag.set(id, createErrorChunk(response, buffer));
       break;
@@ -1324,4 +1439,5 @@ case 84:
         ? chunk.reason.enqueueValue(buffer)
-        : tag.set(id, new Chunk("fulfilled", buffer, null, response));
+        : tag.set(id, new ReactPromise("fulfilled", buffer, null, response));
       break;
+    case 78:
     case 68:
@@ -1358,3 +1474,3 @@ case 87:
         ? triggerErrorOnChunk(chunk, buffer)
-        : tag.set(id, new Chunk("rejected", null, buffer, response));
+        : tag.set(id, createErrorChunk(response, buffer));
       break;
@@ -1365,3 +1481,6 @@ default:
           ? resolveModelChunk(chunk, buffer)
-          : tag.set(id, new Chunk("resolved_model", buffer, null, response));
+          : tag.set(
+              id,
+              new ReactPromise("resolved_model", buffer, null, response)
+            );
   }
@@ -1390,6 +1509,11 @@ }
           )
-            (key = new Chunk("rejected", null, value.value, response)),
+            (key = createErrorChunk(response, value.value)),
               (key = createLazyChunkWrapper(key));
           else if (0 < value.deps) {
-            var blockedChunk = new Chunk("blocked", null, null, response);
+            var blockedChunk = new ReactPromise(
+              "blocked",
+              null,
+              null,
+              response
+            );
             value.value = key;
@@ -1409,2 +1533,3 @@ value.chunk = blockedChunk;
     null,
+    null,
     options && options.callServer ? options.callServer : void 0,
@@ -1461,2 +1586,3 @@ void 0,
               : (64 < rowState && 91 > rowState) ||
+                  35 === rowState ||
                   114 === rowState ||
@@ -1527,8 +1653,8 @@ 120 === rowState
 exports.createServerReference = function (id, callServer) {
-  function proxy() {
+  function action() {
     var args = Array.prototype.slice.call(arguments);
     return callServer(id, args);
   }
-  registerServerReference(proxy, { id: id, bound: null });
-  return proxy;
+  registerServerReference(action, { id: id, bound: null });
+  return action;
 };
@@ -1540,3 +1666,3 @@ exports.createTemporaryReferenceSet = function () {
   return new Promise(function (resolve, reject) {
-    processReply(
+    var abort = processReply(
       value,
@@ -1550,3 +1676,14 @@ "",
     );
+    if (options && options.signal) {
+      var signal = options.signal;
+      if (signal.aborted) abort(signal.reason);
+      else {
+        var listener = function () {
+          abort(signal.reason);
+          signal.removeEventListener("abort", listener);
+        };
+        signal.addEventListener("abort", listener);
+      }
+    }
   });
 };

cjs/react-server-dom-turbopack-client.edge.production.js

@@ -17,6 +17,6 @@ /**
     var moduleExports = bundlerConfig[metadata[0]];
-    if ((bundlerConfig = moduleExports[metadata[2]]))
+    if ((bundlerConfig = moduleExports && moduleExports[metadata[2]]))
       moduleExports = bundlerConfig.name;
     else {
-      bundlerConfig = moduleExports["*"];
+      bundlerConfig = moduleExports && moduleExports["*"];
       if (!bundlerConfig)
@@ -26,3 +26,3 @@ throw Error(
             metadata[0] +
-            '" in the React SSR Manifest. This is probably a bug in the React Server Components bundler.'
+            '" in the React Server Consumer Manifest. This is probably a bug in the React Server Components bundler.'
         );
@@ -37,2 +37,20 @@ moduleExports = metadata[2];
 }
+function resolveServerReference(bundlerConfig, id) {
+  var name = "",
+    resolvedModuleData = bundlerConfig[id];
+  if (resolvedModuleData) name = resolvedModuleData.name;
+  else {
+    var idx = id.lastIndexOf("#");
+    -1 !== idx &&
+      ((name = id.slice(idx + 1)),
+      (resolvedModuleData = bundlerConfig[id.slice(0, idx)]));
+    if (!resolvedModuleData)
+      throw Error(
+        'Could not find the module "' +
+          id +
+          '" in the React Server Manifest. This is probably a bug in the React Server Components bundler.'
+      );
+  }
+  return [resolvedModuleData.id, resolvedModuleData.chunks, name];
+}
 var chunkCache = new Map();
@@ -78,2 +96,16 @@ function requireAsyncModule(id) {
 }
+function requireModule(metadata) {
+  var moduleExports = __turbopack_require__(metadata[0]);
+  if (4 === metadata.length && "function" === typeof moduleExports.then)
+    if ("fulfilled" === moduleExports.status)
+      moduleExports = moduleExports.value;
+    else throw moduleExports.reason;
+  return "*" === metadata[2]
+    ? moduleExports
+    : "" === metadata[2]
+      ? moduleExports.__esModule
+        ? moduleExports.default
+        : moduleExports
+      : moduleExports[metadata[2]];
+}
 function prepareDestinationWithChunks(moduleLoading, chunks, nonce$jscomp$0) {
@@ -404,3 +436,3 @@ if (null !== moduleLoading)
           throw Error(
-            "Only plain objects, and a few built-ins, can be passed to Server Actions. Classes or null prototypes are not supported."
+            "Only plain objects, and a few built-ins, can be passed to Server Functions. Classes or null prototypes are not supported."
           );
@@ -477,8 +509,13 @@ return "$T";
     writtenObjects = new WeakMap(),
-    modelRoot = root;
-  root = serializeModel(root, 0);
+    modelRoot = root,
+    json = serializeModel(root, 0);
   null === formData
-    ? resolve(root)
-    : (formData.set(formFieldPrefix + "0", root),
+    ? resolve(json)
+    : (formData.set(formFieldPrefix + "0", json),
       0 === pendingParts && resolve(formData));
+  return function () {
+    0 < pendingParts &&
+      ((pendingParts = 0),
+      null === formData ? resolve(json) : resolve(formData));
+  };
 }
@@ -622,11 +659,27 @@ var boundCache = new WeakMap();
 }
+function createBoundServerReference(metaData, callServer, encodeFormAction) {
+  function action() {
+    var args = Array.prototype.slice.call(arguments);
+    return bound
+      ? "fulfilled" === bound.status
+        ? callServer(id, bound.value.concat(args))
+        : Promise.resolve(bound).then(function (boundArgs) {
+            return callServer(id, boundArgs.concat(args));
+          })
+      : callServer(id, args);
+  }
+  var id = metaData.id,
+    bound = metaData.bound;
+  registerServerReference(action, { id: id, bound: bound }, encodeFormAction);
+  return action;
+}
 function createServerReference$1(id, callServer, encodeFormAction) {
-  function proxy() {
+  function action() {
     var args = Array.prototype.slice.call(arguments);
     return callServer(id, args);
   }
-  registerServerReference(proxy, { id: id, bound: null }, encodeFormAction);
-  return proxy;
+  registerServerReference(action, { id: id, bound: null }, encodeFormAction);
+  return action;
 }
-function Chunk(status, value, reason, response) {
+function ReactPromise(status, value, reason, response) {
   this.status = status;
@@ -637,4 +690,4 @@ this.value = value;
 }
-Chunk.prototype = Object.create(Promise.prototype);
-Chunk.prototype.then = function (resolve, reject) {
+ReactPromise.prototype = Object.create(Promise.prototype);
+ReactPromise.prototype.then = function (resolve, reject) {
   switch (this.status) {
@@ -681,4 +734,7 @@ case "resolved_model":
 function createPendingChunk(response) {
-  return new Chunk("pending", null, null, response);
+  return new ReactPromise("pending", null, null, response);
 }
+function createErrorChunk(response, error) {
+  return new ReactPromise("rejected", null, error, response);
+}
 function wakeChunk(listeners, value) {
@@ -723,3 +779,3 @@ for (var i = 0; i < listeners.length; i++) (0, listeners[i])(value);
 function createResolvedIteratorResultChunk(response, value, done) {
-  return new Chunk(
+  return new ReactPromise(
     "resolved_model",
@@ -793,18 +849,5 @@ (done ? '{"done":true,"value":' : '{"done":false,"value":') + value + "}",
   try {
-    var metadata = chunk.value,
-      moduleExports = __turbopack_require__(metadata[0]);
-    if (4 === metadata.length && "function" === typeof moduleExports.then)
-      if ("fulfilled" === moduleExports.status)
-        moduleExports = moduleExports.value;
-      else throw moduleExports.reason;
-    var JSCompiler_inline_result =
-      "*" === metadata[2]
-        ? moduleExports
-        : "" === metadata[2]
-          ? moduleExports.__esModule
-            ? moduleExports.default
-            : moduleExports
-          : moduleExports[metadata[2]];
+    var value = requireModule(chunk.value);
     chunk.status = "fulfilled";
-    chunk.value = JSCompiler_inline_result;
+    chunk.value = value;
   } catch (error) {
@@ -815,2 +858,4 @@ (chunk.status = "rejected"), (chunk.reason = error);
 function reportGlobalError(response, error) {
+  response._closed = !0;
+  response._closedReason = error;
   response._chunks.forEach(function (chunk) {
@@ -826,3 +871,7 @@ "pending" === chunk.status && triggerErrorOnChunk(chunk, error);
     chunk = chunks.get(id);
-  chunk || ((chunk = createPendingChunk(response)), chunks.set(id, chunk));
+  chunk ||
+    ((chunk = response._closed
+      ? createErrorChunk(response, response._closedReason)
+      : createPendingChunk(response)),
+    chunks.set(id, chunk));
   return chunk;
@@ -851,11 +900,15 @@ }
     }
-    parentObject[key] = map(response, value);
-    "" === key && null === handler.value && (handler.value = parentObject[key]);
-    parentObject[0] === REACT_ELEMENT_TYPE &&
-      "3" === key &&
+    i = map(response, value, parentObject, key);
+    parentObject[key] = i;
+    "" === key && null === handler.value && (handler.value = i);
+    if (
+      parentObject[0] === REACT_ELEMENT_TYPE &&
       "object" === typeof handler.value &&
       null !== handler.value &&
-      handler.value.$$typeof === REACT_ELEMENT_TYPE &&
-      null === handler.value.props &&
-      (handler.value.props = parentObject[key]);
+      handler.value.$$typeof === REACT_ELEMENT_TYPE
+    )
+      switch (((value = handler.value), key)) {
+        case "3":
+          value.props = i;
+      }
     handler.deps--;
@@ -895,17 +948,70 @@ 0 === handler.deps &&
 }
-function createServerReferenceProxy(response, metaData) {
-  function proxy() {
-    var args = Array.prototype.slice.call(arguments),
-      p = metaData.bound;
-    return p
-      ? "fulfilled" === p.status
-        ? callServer(metaData.id, p.value.concat(args))
-        : Promise.resolve(p).then(function (bound) {
-            return callServer(metaData.id, bound.concat(args));
-          })
-      : callServer(metaData.id, args);
-  }
-  var callServer = response._callServer;
-  registerServerReference(proxy, metaData, response._encodeFormAction);
-  return proxy;
+function loadServerReference(response, metaData, parentObject, key) {
+  if (!response._serverReferenceConfig)
+    return createBoundServerReference(
+      metaData,
+      response._callServer,
+      response._encodeFormAction
+    );
+  var serverReference = resolveServerReference(
+    response._serverReferenceConfig,
+    metaData.id
+  );
+  if ((response = preloadModule(serverReference)))
+    metaData.bound && (response = Promise.all([response, metaData.bound]));
+  else if (metaData.bound) response = Promise.resolve(metaData.bound);
+  else return requireModule(serverReference);
+  if (initializingHandler) {
+    var handler = initializingHandler;
+    handler.deps++;
+  } else
+    handler = initializingHandler = {
+      parent: null,
+      chunk: null,
+      value: null,
+      deps: 1,
+      errored: !1
+    };
+  response.then(
+    function () {
+      var resolvedValue = requireModule(serverReference);
+      if (metaData.bound) {
+        var boundArgs = metaData.bound.value.slice(0);
+        boundArgs.unshift(null);
+        resolvedValue = resolvedValue.bind.apply(resolvedValue, boundArgs);
+      }
+      parentObject[key] = resolvedValue;
+      "" === key && null === handler.value && (handler.value = resolvedValue);
+      if (
+        parentObject[0] === REACT_ELEMENT_TYPE &&
+        "object" === typeof handler.value &&
+        null !== handler.value &&
+        handler.value.$$typeof === REACT_ELEMENT_TYPE
+      )
+        switch (((boundArgs = handler.value), key)) {
+          case "3":
+            boundArgs.props = resolvedValue;
+        }
+      handler.deps--;
+      0 === handler.deps &&
+        ((resolvedValue = handler.chunk),
+        null !== resolvedValue &&
+          "blocked" === resolvedValue.status &&
+          ((boundArgs = resolvedValue.value),
+          (resolvedValue.status = "fulfilled"),
+          (resolvedValue.value = handler.value),
+          null !== boundArgs && wakeChunk(boundArgs, handler.value)));
+    },
+    function (error) {
+      if (!handler.errored) {
+        handler.errored = !0;
+        handler.value = error;
+        var chunk = handler.chunk;
+        null !== chunk &&
+          "blocked" === chunk.status &&
+          triggerErrorOnChunk(chunk, error);
+      }
+    }
+  );
+  return null;
 }
@@ -926,6 +1032,4 @@ function getOutlinedModel(response, reference, parentObject, key, map) {
       var value = id.value;
-      for (id = 1; id < reference.length; id++)
-        if (
-          ((value = value[reference[id]]), value.$$typeof === REACT_LAZY_TYPE)
-        )
+      for (id = 1; id < reference.length; id++) {
+        for (; value.$$typeof === REACT_LAZY_TYPE; )
           if (((value = value._payload), "fulfilled" === value.status))
@@ -940,5 +1044,7 @@ value = value.value;
               map,
-              reference.slice(id)
+              reference.slice(id - 1)
             );
-      return map(response, value);
+        value = value[reference[id]];
+      }
+      return map(response, value, parentObject, key);
     case "pending":
@@ -1022,3 +1128,3 @@ case "blocked":
             key,
-            createServerReferenceProxy
+            loadServerReference
           )
@@ -1054,2 +1160,4 @@ );
         );
+      case "Z":
+        return resolveErrorProd();
       case "i":
@@ -1088,2 +1196,3 @@ return (
   bundlerConfig,
+  serverReferenceConfig,
   moduleLoading,
@@ -1097,2 +1206,3 @@ callServer,
   this._bundlerConfig = bundlerConfig;
+  this._serverReferenceConfig = serverReferenceConfig;
   this._moduleLoading = moduleLoading;
@@ -1107,2 +1217,4 @@ this._callServer = void 0 !== callServer ? callServer : missingCall;
   this._buffer = [];
+  this._closed = !1;
+  this._closedReason = null;
   this._tempRefs = temporaryReferences;
@@ -1116,3 +1228,3 @@ this._fromJSON = createFromJSONCallback(this);
     ? chunk.reason.enqueueValue(buffer)
-    : chunks.set(id, new Chunk("fulfilled", buffer, null, response));
+    : chunks.set(id, new ReactPromise("fulfilled", buffer, null, response));
 }
@@ -1134,3 +1246,3 @@ function resolveModule(response, id, model) {
     } else
-      (blockedChunk = new Chunk("blocked", null, null, response)),
+      (blockedChunk = new ReactPromise("blocked", null, null, response)),
         chunks.set(id, blockedChunk);
@@ -1150,3 +1262,3 @@ model.then(
           id,
-          new Chunk("resolved_module", clientReference, null, response)
+          new ReactPromise("resolved_module", clientReference, null, response)
         );
@@ -1164,3 +1276,6 @@ }
       null !== response && wakeChunk(response, chunk.value))
-    : chunks.set(id, new Chunk("fulfilled", stream, controller, response));
+    : chunks.set(
+        id,
+        new ReactPromise("fulfilled", stream, controller, response)
+      );
 }
@@ -1186,3 +1301,3 @@ function startReadableStream(response, id, type) {
       if (null === previousBlockedChunk) {
-        var chunk = new Chunk("resolved_model", json, null, response);
+        var chunk = new ReactPromise("resolved_model", json, null, response);
         initializeModelChunk(chunk);
@@ -1263,3 +1378,3 @@ "fulfilled" === chunk.status
           if (closed)
-            return new Chunk(
+            return new ReactPromise(
               "fulfilled",
@@ -1283,3 +1398,3 @@ { done: !0, value: void 0 },
         if (nextWriteIndex === buffer.length)
-          buffer[nextWriteIndex] = new Chunk(
+          buffer[nextWriteIndex] = new ReactPromise(
             "fulfilled",
@@ -1340,2 +1455,9 @@ { done: !1, value: value },
 }
+function resolveErrorProd() {
+  var error = Error(
+    "An error occurred in the Server Components render. The specific message is omitted in production builds to avoid leaking sensitive details. A digest property is included on this error instance which may provide additional details about the nature of the error."
+  );
+  error.stack = "Error: " + error.message;
+  return error;
+}
 function mergeBuffer(buffer, lastChunk) {
@@ -1476,12 +1598,9 @@ for (var l = buffer.length, byteLength = lastChunk.length, i = 0; i < l; i++)
     case 69:
-      tag = JSON.parse(buffer).digest;
-      buffer = Error(
-        "An error occurred in the Server Components render. The specific message is omitted in production builds to avoid leaking sensitive details. A digest property is included on this error instance which may provide additional details about the nature of the error."
-      );
-      buffer.stack = "Error: " + buffer.message;
-      buffer.digest = tag;
+      tag = JSON.parse(buffer);
+      buffer = resolveErrorProd();
+      buffer.digest = tag.digest;
       tag = response._chunks;
       (chunk = tag.get(id))
         ? triggerErrorOnChunk(chunk, buffer)
-        : tag.set(id, new Chunk("rejected", null, buffer, response));
+        : tag.set(id, createErrorChunk(response, buffer));
       break;
@@ -1492,4 +1611,5 @@ case 84:
         ? chunk.reason.enqueueValue(buffer)
-        : tag.set(id, new Chunk("fulfilled", buffer, null, response));
+        : tag.set(id, new ReactPromise("fulfilled", buffer, null, response));
       break;
+    case 78:
     case 68:
@@ -1526,3 +1646,3 @@ case 87:
         ? triggerErrorOnChunk(chunk, buffer)
-        : tag.set(id, new Chunk("rejected", null, buffer, response));
+        : tag.set(id, createErrorChunk(response, buffer));
       break;
@@ -1533,3 +1653,6 @@ default:
           ? resolveModelChunk(chunk, buffer)
-          : tag.set(id, new Chunk("resolved_model", buffer, null, response));
+          : tag.set(
+              id,
+              new ReactPromise("resolved_model", buffer, null, response)
+            );
   }
@@ -1558,6 +1681,11 @@ }
           )
-            (key = new Chunk("rejected", null, value.value, response)),
+            (key = createErrorChunk(response, value.value)),
               (key = createLazyChunkWrapper(key));
           else if (0 < value.deps) {
-            var blockedChunk = new Chunk("blocked", null, null, response);
+            var blockedChunk = new ReactPromise(
+              "blocked",
+              null,
+              null,
+              response
+            );
             value.value = key;
@@ -1580,4 +1708,5 @@ value.chunk = blockedChunk;
   return new ResponseInstance(
-    options.ssrManifest.moduleMap,
-    options.ssrManifest.moduleLoading,
+    options.serverConsumerManifest.moduleMap,
+    options.serverConsumerManifest.serverModuleMap,
+    options.serverConsumerManifest.moduleLoading,
     noServerCall,
@@ -1634,2 +1763,3 @@ options.encodeFormAction,
               : (64 < rowState && 91 > rowState) ||
+                  35 === rowState ||
                   114 === rowState ||
@@ -1707,3 +1837,3 @@ 120 === rowState
   return new Promise(function (resolve, reject) {
-    processReply(
+    var abort = processReply(
       value,
@@ -1717,3 +1847,14 @@ "",
     );
+    if (options && options.signal) {
+      var signal = options.signal;
+      if (signal.aborted) abort(signal.reason);
+      else {
+        var listener = function () {
+          abort(signal.reason);
+          signal.removeEventListener("abort", listener);
+        };
+        signal.addEventListener("abort", listener);
+      }
+    }
   });
 };

cjs/react-server-dom-turbopack-client.node.production.js

@@ -18,6 +18,6 @@ /**
     var moduleExports = bundlerConfig[metadata[0]];
-    if ((bundlerConfig = moduleExports[metadata[2]]))
+    if ((bundlerConfig = moduleExports && moduleExports[metadata[2]]))
       moduleExports = bundlerConfig.name;
     else {
-      bundlerConfig = moduleExports["*"];
+      bundlerConfig = moduleExports && moduleExports["*"];
       if (!bundlerConfig)
@@ -27,3 +27,3 @@ throw Error(
             metadata[0] +
-            '" in the React SSR Manifest. This is probably a bug in the React Server Components bundler.'
+            '" in the React Server Consumer Manifest. This is probably a bug in the React Server Components bundler.'
         );
@@ -38,2 +38,20 @@ moduleExports = metadata[2];
 }
+function resolveServerReference(bundlerConfig, id) {
+  var name = "",
+    resolvedModuleData = bundlerConfig[id];
+  if (resolvedModuleData) name = resolvedModuleData.name;
+  else {
+    var idx = id.lastIndexOf("#");
+    -1 !== idx &&
+      ((name = id.slice(idx + 1)),
+      (resolvedModuleData = bundlerConfig[id.slice(0, idx)]));
+    if (!resolvedModuleData)
+      throw Error(
+        'Could not find the module "' +
+          id +
+          '" in the React Server Manifest. This is probably a bug in the React Server Components bundler.'
+      );
+  }
+  return [resolvedModuleData.id, resolvedModuleData.chunks, name];
+}
 var chunkCache = new Map();
@@ -79,2 +97,16 @@ function requireAsyncModule(id) {
 }
+function requireModule(metadata) {
+  var moduleExports = __turbopack_require__(metadata[0]);
+  if (4 === metadata.length && "function" === typeof moduleExports.then)
+    if ("fulfilled" === moduleExports.status)
+      moduleExports = moduleExports.value;
+    else throw moduleExports.reason;
+  return "*" === metadata[2]
+    ? moduleExports
+    : "" === metadata[2]
+      ? moduleExports.__esModule
+        ? moduleExports.default
+        : moduleExports
+      : moduleExports[metadata[2]];
+}
 function prepareDestinationWithChunks(moduleLoading, chunks, nonce$jscomp$0) {
@@ -405,3 +437,3 @@ if (null !== moduleLoading)
           throw Error(
-            "Only plain objects, and a few built-ins, can be passed to Server Actions. Classes or null prototypes are not supported."
+            "Only plain objects, and a few built-ins, can be passed to Server Functions. Classes or null prototypes are not supported."
           );
@@ -478,8 +510,13 @@ return "$T";
     writtenObjects = new WeakMap(),
-    modelRoot = root;
-  root = serializeModel(root, 0);
+    modelRoot = root,
+    json = serializeModel(root, 0);
   null === formData
-    ? resolve(root)
-    : (formData.set(formFieldPrefix + "0", root),
+    ? resolve(json)
+    : (formData.set(formFieldPrefix + "0", json),
       0 === pendingParts && resolve(formData));
+  return function () {
+    0 < pendingParts &&
+      ((pendingParts = 0),
+      null === formData ? resolve(json) : resolve(formData));
+  };
 }
@@ -623,11 +660,27 @@ var boundCache = new WeakMap();
 }
+function createBoundServerReference(metaData, callServer, encodeFormAction) {
+  function action() {
+    var args = Array.prototype.slice.call(arguments);
+    return bound
+      ? "fulfilled" === bound.status
+        ? callServer(id, bound.value.concat(args))
+        : Promise.resolve(bound).then(function (boundArgs) {
+            return callServer(id, boundArgs.concat(args));
+          })
+      : callServer(id, args);
+  }
+  var id = metaData.id,
+    bound = metaData.bound;
+  registerServerReference(action, { id: id, bound: bound }, encodeFormAction);
+  return action;
+}
 function createServerReference$1(id, callServer, encodeFormAction) {
-  function proxy() {
+  function action() {
     var args = Array.prototype.slice.call(arguments);
     return callServer(id, args);
   }
-  registerServerReference(proxy, { id: id, bound: null }, encodeFormAction);
-  return proxy;
+  registerServerReference(action, { id: id, bound: null }, encodeFormAction);
+  return action;
 }
-function Chunk(status, value, reason, response) {
+function ReactPromise(status, value, reason, response) {
   this.status = status;
@@ -638,4 +691,4 @@ this.value = value;
 }
-Chunk.prototype = Object.create(Promise.prototype);
-Chunk.prototype.then = function (resolve, reject) {
+ReactPromise.prototype = Object.create(Promise.prototype);
+ReactPromise.prototype.then = function (resolve, reject) {
   switch (this.status) {
@@ -682,4 +735,7 @@ case "resolved_model":
 function createPendingChunk(response) {
-  return new Chunk("pending", null, null, response);
+  return new ReactPromise("pending", null, null, response);
 }
+function createErrorChunk(response, error) {
+  return new ReactPromise("rejected", null, error, response);
+}
 function wakeChunk(listeners, value) {
@@ -724,3 +780,3 @@ for (var i = 0; i < listeners.length; i++) (0, listeners[i])(value);
 function createResolvedIteratorResultChunk(response, value, done) {
-  return new Chunk(
+  return new ReactPromise(
     "resolved_model",
@@ -794,18 +850,5 @@ (done ? '{"done":true,"value":' : '{"done":false,"value":') + value + "}",
   try {
-    var metadata = chunk.value,
-      moduleExports = __turbopack_require__(metadata[0]);
-    if (4 === metadata.length && "function" === typeof moduleExports.then)
-      if ("fulfilled" === moduleExports.status)
-        moduleExports = moduleExports.value;
-      else throw moduleExports.reason;
-    var JSCompiler_inline_result =
-      "*" === metadata[2]
-        ? moduleExports
-        : "" === metadata[2]
-          ? moduleExports.__esModule
-            ? moduleExports.default
-            : moduleExports
-          : moduleExports[metadata[2]];
+    var value = requireModule(chunk.value);
     chunk.status = "fulfilled";
-    chunk.value = JSCompiler_inline_result;
+    chunk.value = value;
   } catch (error) {
@@ -816,2 +859,4 @@ (chunk.status = "rejected"), (chunk.reason = error);
 function reportGlobalError(response, error) {
+  response._closed = !0;
+  response._closedReason = error;
   response._chunks.forEach(function (chunk) {
@@ -827,3 +872,7 @@ "pending" === chunk.status && triggerErrorOnChunk(chunk, error);
     chunk = chunks.get(id);
-  chunk || ((chunk = createPendingChunk(response)), chunks.set(id, chunk));
+  chunk ||
+    ((chunk = response._closed
+      ? createErrorChunk(response, response._closedReason)
+      : createPendingChunk(response)),
+    chunks.set(id, chunk));
   return chunk;
@@ -852,11 +901,15 @@ }
     }
-    parentObject[key] = map(response, value);
-    "" === key && null === handler.value && (handler.value = parentObject[key]);
-    parentObject[0] === REACT_ELEMENT_TYPE &&
-      "3" === key &&
+    i = map(response, value, parentObject, key);
+    parentObject[key] = i;
+    "" === key && null === handler.value && (handler.value = i);
+    if (
+      parentObject[0] === REACT_ELEMENT_TYPE &&
       "object" === typeof handler.value &&
       null !== handler.value &&
-      handler.value.$$typeof === REACT_ELEMENT_TYPE &&
-      null === handler.value.props &&
-      (handler.value.props = parentObject[key]);
+      handler.value.$$typeof === REACT_ELEMENT_TYPE
+    )
+      switch (((value = handler.value), key)) {
+        case "3":
+          value.props = i;
+      }
     handler.deps--;
@@ -896,17 +949,70 @@ 0 === handler.deps &&
 }
-function createServerReferenceProxy(response, metaData) {
-  function proxy() {
-    var args = Array.prototype.slice.call(arguments),
-      p = metaData.bound;
-    return p
-      ? "fulfilled" === p.status
-        ? callServer(metaData.id, p.value.concat(args))
-        : Promise.resolve(p).then(function (bound) {
-            return callServer(metaData.id, bound.concat(args));
-          })
-      : callServer(metaData.id, args);
-  }
-  var callServer = response._callServer;
-  registerServerReference(proxy, metaData, response._encodeFormAction);
-  return proxy;
+function loadServerReference(response, metaData, parentObject, key) {
+  if (!response._serverReferenceConfig)
+    return createBoundServerReference(
+      metaData,
+      response._callServer,
+      response._encodeFormAction
+    );
+  var serverReference = resolveServerReference(
+    response._serverReferenceConfig,
+    metaData.id
+  );
+  if ((response = preloadModule(serverReference)))
+    metaData.bound && (response = Promise.all([response, metaData.bound]));
+  else if (metaData.bound) response = Promise.resolve(metaData.bound);
+  else return requireModule(serverReference);
+  if (initializingHandler) {
+    var handler = initializingHandler;
+    handler.deps++;
+  } else
+    handler = initializingHandler = {
+      parent: null,
+      chunk: null,
+      value: null,
+      deps: 1,
+      errored: !1
+    };
+  response.then(
+    function () {
+      var resolvedValue = requireModule(serverReference);
+      if (metaData.bound) {
+        var boundArgs = metaData.bound.value.slice(0);
+        boundArgs.unshift(null);
+        resolvedValue = resolvedValue.bind.apply(resolvedValue, boundArgs);
+      }
+      parentObject[key] = resolvedValue;
+      "" === key && null === handler.value && (handler.value = resolvedValue);
+      if (
+        parentObject[0] === REACT_ELEMENT_TYPE &&
+        "object" === typeof handler.value &&
+        null !== handler.value &&
+        handler.value.$$typeof === REACT_ELEMENT_TYPE
+      )
+        switch (((boundArgs = handler.value), key)) {
+          case "3":
+            boundArgs.props = resolvedValue;
+        }
+      handler.deps--;
+      0 === handler.deps &&
+        ((resolvedValue = handler.chunk),
+        null !== resolvedValue &&
+          "blocked" === resolvedValue.status &&
+          ((boundArgs = resolvedValue.value),
+          (resolvedValue.status = "fulfilled"),
+          (resolvedValue.value = handler.value),
+          null !== boundArgs && wakeChunk(boundArgs, handler.value)));
+    },
+    function (error) {
+      if (!handler.errored) {
+        handler.errored = !0;
+        handler.value = error;
+        var chunk = handler.chunk;
+        null !== chunk &&
+          "blocked" === chunk.status &&
+          triggerErrorOnChunk(chunk, error);
+      }
+    }
+  );
+  return null;
 }
@@ -927,6 +1033,4 @@ function getOutlinedModel(response, reference, parentObject, key, map) {
       var value = id.value;
-      for (id = 1; id < reference.length; id++)
-        if (
-          ((value = value[reference[id]]), value.$$typeof === REACT_LAZY_TYPE)
-        )
+      for (id = 1; id < reference.length; id++) {
+        for (; value.$$typeof === REACT_LAZY_TYPE; )
           if (((value = value._payload), "fulfilled" === value.status))
@@ -941,5 +1045,7 @@ value = value.value;
               map,
-              reference.slice(id)
+              reference.slice(id - 1)
             );
-      return map(response, value);
+        value = value[reference[id]];
+      }
+      return map(response, value, parentObject, key);
     case "pending":
@@ -1023,3 +1129,3 @@ case "blocked":
             key,
-            createServerReferenceProxy
+            loadServerReference
           )
@@ -1055,2 +1161,4 @@ );
         );
+      case "Z":
+        return resolveErrorProd();
       case "i":
@@ -1089,2 +1197,3 @@ return (
   bundlerConfig,
+  serverReferenceConfig,
   moduleLoading,
@@ -1098,2 +1207,3 @@ callServer,
   this._bundlerConfig = bundlerConfig;
+  this._serverReferenceConfig = serverReferenceConfig;
   this._moduleLoading = moduleLoading;
@@ -1108,2 +1218,4 @@ this._callServer = void 0 !== callServer ? callServer : missingCall;
   this._buffer = [];
+  this._closed = !1;
+  this._closedReason = null;
   this._tempRefs = temporaryReferences;
@@ -1117,3 +1229,3 @@ this._fromJSON = createFromJSONCallback(this);
     ? chunk.reason.enqueueValue(buffer)
-    : chunks.set(id, new Chunk("fulfilled", buffer, null, response));
+    : chunks.set(id, new ReactPromise("fulfilled", buffer, null, response));
 }
@@ -1135,3 +1247,3 @@ function resolveModule(response, id, model) {
     } else
-      (blockedChunk = new Chunk("blocked", null, null, response)),
+      (blockedChunk = new ReactPromise("blocked", null, null, response)),
         chunks.set(id, blockedChunk);
@@ -1151,3 +1263,3 @@ model.then(
           id,
-          new Chunk("resolved_module", clientReference, null, response)
+          new ReactPromise("resolved_module", clientReference, null, response)
         );
@@ -1165,3 +1277,6 @@ }
       null !== response && wakeChunk(response, chunk.value))
-    : chunks.set(id, new Chunk("fulfilled", stream, controller, response));
+    : chunks.set(
+        id,
+        new ReactPromise("fulfilled", stream, controller, response)
+      );
 }
@@ -1187,3 +1302,3 @@ function startReadableStream(response, id, type) {
       if (null === previousBlockedChunk) {
-        var chunk = new Chunk("resolved_model", json, null, response);
+        var chunk = new ReactPromise("resolved_model", json, null, response);
         initializeModelChunk(chunk);
@@ -1264,3 +1379,3 @@ "fulfilled" === chunk.status
           if (closed)
-            return new Chunk(
+            return new ReactPromise(
               "fulfilled",
@@ -1284,3 +1399,3 @@ { done: !0, value: void 0 },
         if (nextWriteIndex === buffer.length)
-          buffer[nextWriteIndex] = new Chunk(
+          buffer[nextWriteIndex] = new ReactPromise(
             "fulfilled",
@@ -1341,2 +1456,9 @@ { done: !1, value: value },
 }
+function resolveErrorProd() {
+  var error = Error(
+    "An error occurred in the Server Components render. The specific message is omitted in production builds to avoid leaking sensitive details. A digest property is included on this error instance which may provide additional details about the nature of the error."
+  );
+  error.stack = "Error: " + error.message;
+  return error;
+}
 function mergeBuffer(buffer, lastChunk) {
@@ -1477,12 +1599,9 @@ for (var l = buffer.length, byteLength = lastChunk.length, i = 0; i < l; i++)
     case 69:
-      tag = JSON.parse(buffer).digest;
-      buffer = Error(
-        "An error occurred in the Server Components render. The specific message is omitted in production builds to avoid leaking sensitive details. A digest property is included on this error instance which may provide additional details about the nature of the error."
-      );
-      buffer.stack = "Error: " + buffer.message;
-      buffer.digest = tag;
+      tag = JSON.parse(buffer);
+      buffer = resolveErrorProd();
+      buffer.digest = tag.digest;
       tag = response._chunks;
       (chunk = tag.get(id))
         ? triggerErrorOnChunk(chunk, buffer)
-        : tag.set(id, new Chunk("rejected", null, buffer, response));
+        : tag.set(id, createErrorChunk(response, buffer));
       break;
@@ -1493,4 +1612,5 @@ case 84:
         ? chunk.reason.enqueueValue(buffer)
-        : tag.set(id, new Chunk("fulfilled", buffer, null, response));
+        : tag.set(id, new ReactPromise("fulfilled", buffer, null, response));
       break;
+    case 78:
     case 68:
@@ -1527,3 +1647,3 @@ case 87:
         ? triggerErrorOnChunk(chunk, buffer)
-        : tag.set(id, new Chunk("rejected", null, buffer, response));
+        : tag.set(id, createErrorChunk(response, buffer));
       break;
@@ -1534,3 +1654,6 @@ default:
           ? resolveModelChunk(chunk, buffer)
-          : tag.set(id, new Chunk("resolved_model", buffer, null, response));
+          : tag.set(
+              id,
+              new ReactPromise("resolved_model", buffer, null, response)
+            );
   }
@@ -1559,6 +1682,11 @@ }
           )
-            (key = new Chunk("rejected", null, value.value, response)),
+            (key = createErrorChunk(response, value.value)),
               (key = createLazyChunkWrapper(key));
           else if (0 < value.deps) {
-            var blockedChunk = new Chunk("blocked", null, null, response);
+            var blockedChunk = new ReactPromise(
+              "blocked",
+              null,
+              null,
+              response
+            );
             value.value = key;
@@ -1579,6 +1707,11 @@ value.chunk = blockedChunk;
 }
-exports.createFromNodeStream = function (stream, ssrManifest, options) {
+exports.createFromNodeStream = function (
+  stream,
+  serverConsumerManifest,
+  options
+) {
   var response = new ResponseInstance(
-    ssrManifest.moduleMap,
-    ssrManifest.moduleLoading,
+    serverConsumerManifest.moduleMap,
+    serverConsumerManifest.serverModuleMap,
+    serverConsumerManifest.moduleLoading,
     noServerCall,
@@ -1628,2 +1761,3 @@ options ? options.encodeFormAction : void 0,
             : (64 < rowState && 91 > rowState) ||
+                35 === rowState ||
                 114 === rowState ||
@@ -1630,0 +1764,0 @@ 120 === rowState

package.json

 {
   "name": "react-server-dom-turbopack",
   "description": "React Server Components bindings for DOM using Turbopack. This is intended to be integrated into meta-frameworks. It is not intended to be imported directly.",
-  "version": "0.0.0-experimental-3208e73e-20240730",
+  "version": "0.0.0-experimental-32b0cad8-20250213",
   "keywords": [
@@ -19,3 +19,2 @@ "react"
     "client.node.js",
-    "client.node.unbundled.js",
     "server.js",
@@ -25,6 +24,7 @@ "server.browser.js",
     "server.node.js",
-    "server.node.unbundled.js",
-    "node-register.js",
-    "cjs/",
-    "esm/"
+    "static.js",
+    "static.browser.js",
+    "static.edge.js",
+    "static.node.js",
+    "cjs/"
   ],
@@ -37,7 +37,3 @@ "exports": {
       "worker": "./client.edge.js",
-      "node": {
-        "turbopack": "./client.node.js",
-        "webpack": "./client.node.js",
-        "default": "./client.node.unbundled.js"
-      },
+      "node": "./client.node.js",
       "edge-light": "./client.edge.js",
@@ -50,3 +46,2 @@ "browser": "./client.browser.js",
     "./client.node": "./client.node.js",
-    "./client.node.unbundled": "./client.node.unbundled.js",
     "./server": {
@@ -56,7 +51,3 @@ "react-server": {
         "deno": "./server.browser.js",
-        "node": {
-          "turbopack": "./server.node.js",
-          "webpack": "./server.node.js",
-          "default": "./server.node.unbundled.js"
-        },
+        "node": "./server.node.js",
         "edge-light": "./server.edge.js",
@@ -70,5 +61,15 @@ "browser": "./server.browser.js"
     "./server.node": "./server.node.js",
-    "./server.node.unbundled": "./server.node.unbundled.js",
-    "./node-loader": "./esm/react-server-dom-turbopack-node-loader.production.js",
-    "./node-register": "./node-register.js",
+    "./static": {
+      "react-server": {
+        "workerd": "./static.edge.js",
+        "deno": "./static.browser.js",
+        "node": "./static.node.js",
+        "edge-light": "./static.edge.js",
+        "browser": "./static.browser.js"
+      },
+      "default": "./static.js"
+    },
+    "./static.browser": "./static.browser.js",
+    "./static.edge": "./static.edge.js",
+    "./static.node": "./static.node.js",
     "./package.json": "./package.json"
@@ -86,4 +87,4 @@ },
   "peerDependencies": {
-    "react": "0.0.0-experimental-3208e73e-20240730",
-    "react-dom": "0.0.0-experimental-3208e73e-20240730"
+    "react": "0.0.0-experimental-32b0cad8-20250213",
+    "react-dom": "0.0.0-experimental-32b0cad8-20250213"
   },
@@ -90,0 +91,0 @@ "dependencies": {

server.browser.js

 'use strict';
 
+var s;
 if (process.env.NODE_ENV === 'production') {
-  module.exports = require('./cjs/react-server-dom-turbopack-server.browser.production.js');
+  s = require('./cjs/react-server-dom-turbopack-server.browser.production.js');
 } else {
-  module.exports = require('./cjs/react-server-dom-turbopack-server.browser.development.js');
+  s = require('./cjs/react-server-dom-turbopack-server.browser.development.js');
 }
+
+exports.renderToReadableStream = s.renderToReadableStream;
+exports.decodeReply = s.decodeReply;
+exports.decodeAction = s.decodeAction;
+exports.decodeFormState = s.decodeFormState;
+exports.registerServerReference = s.registerServerReference;
+exports.registerClientReference = s.registerClientReference;
+exports.createClientModuleProxy = s.createClientModuleProxy;
+exports.createTemporaryReferenceSet = s.createTemporaryReferenceSet;

server.edge.js

 'use strict';
 
+var s;
 if (process.env.NODE_ENV === 'production') {
-  module.exports = require('./cjs/react-server-dom-turbopack-server.edge.production.js');
+  s = require('./cjs/react-server-dom-turbopack-server.edge.production.js');
 } else {
-  module.exports = require('./cjs/react-server-dom-turbopack-server.edge.development.js');
+  s = require('./cjs/react-server-dom-turbopack-server.edge.development.js');
 }
+
+exports.renderToReadableStream = s.renderToReadableStream;
+exports.decodeReply = s.decodeReply;
+exports.decodeReplyFromAsyncIterable = s.decodeReplyFromAsyncIterable;
+exports.decodeAction = s.decodeAction;
+exports.decodeFormState = s.decodeFormState;
+exports.registerServerReference = s.registerServerReference;
+exports.registerClientReference = s.registerClientReference;
+exports.createClientModuleProxy = s.createClientModuleProxy;
+exports.createTemporaryReferenceSet = s.createTemporaryReferenceSet;

server.node.js

 'use strict';
 
+var s;
 if (process.env.NODE_ENV === 'production') {
-  module.exports = require('./cjs/react-server-dom-turbopack-server.node.production.js');
+  s = require('./cjs/react-server-dom-turbopack-server.node.production.js');
 } else {
-  module.exports = require('./cjs/react-server-dom-turbopack-server.node.development.js');
+  s = require('./cjs/react-server-dom-turbopack-server.node.development.js');
 }
+
+exports.renderToPipeableStream = s.renderToPipeableStream;
+exports.decodeReplyFromBusboy = s.decodeReplyFromBusboy;
+exports.decodeReply = s.decodeReply;
+exports.decodeAction = s.decodeAction;
+exports.decodeFormState = s.decodeFormState;
+exports.registerServerReference = s.registerServerReference;
+exports.registerClientReference = s.registerClientReference;
+exports.createClientModuleProxy = s.createClientModuleProxy;
+exports.createTemporaryReferenceSet = s.createTemporaryReferenceSet;

Fixed alerts

Debug access

Supply chain risk

Uses debug, reflection and dynamic code execution features.

Found 1 instance in 1 package

Improved metrics

Number of low supply chain risk alerts

17

-19.05%

Worsened metrics

Total package byte prevSize

1274213

-17.25%

Number of package files

28

-17.65%

Lines of code

36282

-17.09%

Number of medium supply chain risk alerts

9

12.5%

No dependency changes