Bring ReactFlightClient fixes to FlightReplyServer

We did a bunch of refactors to ReactFlightClient in PRs like #29823 and #33664.
This brings a bunch of those related refactors to the equivalent FlightReplyServer. Such as deep resolution of cycles and deferred error handling.

Author: sebmarkbage

packages/react-server-dom-esm/src/server/ReactFlightDOMServerNode.js

@@ -348,31 +348,42 @@ function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-parcel/src/client/ReactFlightClientConfigBundlerParcel.js

@@ -19,6 +19,8 @@ import {
 }from'../shared/ReactFlightImportMetadata';
 import{prepareDestinationWithChunks}from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerManifest={
 [string]: Array<string>,
 };
@@ -78,7 +80,10 @@ export function preloadModule<T>(
 
 exportfunctionrequireModule<T>(metadata: ClientReference<T>): T{
 const moduleExports =parcelRequire(metadata[ID]);
-returnmoduleExports[metadata[NAME]];
+if(hasOwnProperty.call(moduleExports,metadata[NAME])){
+returnmoduleExports[metadata[NAME]];
+}
+return(undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(

packages/react-server-dom-parcel/src/server/ReactFlightDOMServerNode.js

@@ -578,31 +578,42 @@ export function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-turbopack/src/client/ReactFlightClientConfigBundlerTurbopack.js

@@ -34,6 +34,8 @@ import {
 addChunkDebugInfo,
 }from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerConsumerModuleMap=null|{
 [clientId: string]: {
 [clientExportName: string]: ClientReferenceManifestEntry,
@@ -245,7 +247,10 @@ export function requireModule<T>(metadata: ClientReference<T>): T {
 // default property of this if it was an ESM interop module.
 returnmoduleExports.__esModule ? moduleExports.default : moduleExports;
 }
- return moduleExports[metadata[NAME]];
+ if (hasOwnProperty.call(moduleExports, metadata[NAME])) {
+returnmoduleExports[metadata[NAME]];
+}
+ return (undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(

packages/react-server-dom-turbopack/src/server/ReactFlightDOMServerNode.js

@@ -570,31 +570,42 @@ function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-webpack/src/client/ReactFlightClientConfigBundlerNode.js

@@ -24,6 +24,8 @@ import {
 }from'../shared/ReactFlightImportMetadata';
 import{prepareDestinationWithChunks}from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerConsumerModuleMap={
 [clientId: string]: {
 [clientExportName: string]: ClientReference<any>,
@@ -158,7 +160,10 @@ export function requireModule<T>(metadata: ClientReference<T>): T {
 // default property of this if it was an ESM interop module.
 returnmoduleExports.default;
 }
-returnmoduleExports[metadata.name];
+if(hasOwnProperty.call(moduleExports,metadata.name)){
+returnmoduleExports[metadata.name];
+}
+return(undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(metadata: ClientReference<T>): null{

packages/react-server-dom-webpack/src/client/ReactFlightClientConfigBundlerWebpack.js

@@ -34,6 +34,8 @@ import {
 addChunkDebugInfo,
 }from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerConsumerModuleMap=null|{
 [clientId: string]: {
 [clientExportName: string]: ClientReferenceManifestEntry,
@@ -253,7 +255,10 @@ export function requireModule<T>(metadata: ClientReference<T>): T {
 // default property of this if it was an ESM interop module.
 returnmoduleExports.__esModule ? moduleExports.default : moduleExports;
 }
-returnmoduleExports[metadata[NAME]];
+if(hasOwnProperty.call(moduleExports,metadata[NAME])){
+returnmoduleExports[metadata[NAME]];
+}
+return(undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(

packages/react-server-dom-webpack/src/server/ReactFlightDOMServerNode.js

@@ -570,31 +570,42 @@ function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-esm/src/server/ReactFlightDOMServerNode.js

@@ -348,31 +348,42 @@ function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-parcel/src/client/ReactFlightClientConfigBundlerParcel.js

@@ -19,6 +19,8 @@ import {
 }from'../shared/ReactFlightImportMetadata';
 import{prepareDestinationWithChunks}from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerManifest={
 [string]: Array<string>,
 };
@@ -78,7 +80,10 @@ export function preloadModule<T>(
 
 exportfunctionrequireModule<T>(metadata: ClientReference<T>): T{
 const moduleExports =parcelRequire(metadata[ID]);
-returnmoduleExports[metadata[NAME]];
+if(hasOwnProperty.call(moduleExports,metadata[NAME])){
+returnmoduleExports[metadata[NAME]];
+}
+return(undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(

packages/react-server-dom-parcel/src/server/ReactFlightDOMServerNode.js

@@ -578,31 +578,42 @@ export function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-turbopack/src/client/ReactFlightClientConfigBundlerTurbopack.js

@@ -34,6 +34,8 @@ import {
 addChunkDebugInfo,
 }from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerConsumerModuleMap=null|{
 [clientId: string]: {
 [clientExportName: string]: ClientReferenceManifestEntry,
@@ -245,7 +247,10 @@ export function requireModule<T>(metadata: ClientReference<T>): T {
 // default property of this if it was an ESM interop module.
 returnmoduleExports.__esModule ? moduleExports.default : moduleExports;
 }
- return moduleExports[metadata[NAME]];
+ if (hasOwnProperty.call(moduleExports, metadata[NAME])) {
+returnmoduleExports[metadata[NAME]];
+}
+ return (undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(

packages/react-server-dom-turbopack/src/server/ReactFlightDOMServerNode.js

@@ -570,31 +570,42 @@ function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-webpack/src/client/ReactFlightClientConfigBundlerNode.js

@@ -24,6 +24,8 @@ import {
 }from'../shared/ReactFlightImportMetadata';
 import{prepareDestinationWithChunks}from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerConsumerModuleMap={
 [clientId: string]: {
 [clientExportName: string]: ClientReference<any>,
@@ -158,7 +160,10 @@ export function requireModule<T>(metadata: ClientReference<T>): T {
 // default property of this if it was an ESM interop module.
 returnmoduleExports.default;
 }
-returnmoduleExports[metadata.name];
+if(hasOwnProperty.call(moduleExports,metadata.name)){
+returnmoduleExports[metadata.name];
+}
+return(undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(metadata: ClientReference<T>): null{

packages/react-server-dom-webpack/src/client/ReactFlightClientConfigBundlerWebpack.js

@@ -34,6 +34,8 @@ import {
 addChunkDebugInfo,
 }from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerConsumerModuleMap=null|{
 [clientId: string]: {
 [clientExportName: string]: ClientReferenceManifestEntry,
@@ -253,7 +255,10 @@ export function requireModule<T>(metadata: ClientReference<T>): T {
 // default property of this if it was an ESM interop module.
 returnmoduleExports.__esModule ? moduleExports.default : moduleExports;
 }
-returnmoduleExports[metadata[NAME]];
+if(hasOwnProperty.call(moduleExports,metadata[NAME])){
+returnmoduleExports[metadata[NAME]];
+}
+return(undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(

packages/react-server-dom-webpack/src/server/ReactFlightDOMServerNode.js

@@ -570,31 +570,42 @@ function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-esm/src/server/ReactFlightDOMServerNode.js

@@ -348,31 +348,42 @@ function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-parcel/src/client/ReactFlightClientConfigBundlerParcel.js

@@ -19,6 +19,8 @@ import {
 }from'../shared/ReactFlightImportMetadata';
 import{prepareDestinationWithChunks}from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerManifest={
 [string]: Array<string>,
 };
@@ -78,7 +80,10 @@ export function preloadModule<T>(
 
 exportfunctionrequireModule<T>(metadata: ClientReference<T>): T{
 const moduleExports =parcelRequire(metadata[ID]);
-returnmoduleExports[metadata[NAME]];
+if(hasOwnProperty.call(moduleExports,metadata[NAME])){
+returnmoduleExports[metadata[NAME]];
+}
+return(undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(

packages/react-server-dom-parcel/src/server/ReactFlightDOMServerNode.js

@@ -578,31 +578,42 @@ export function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-turbopack/src/client/ReactFlightClientConfigBundlerTurbopack.js

@@ -34,6 +34,8 @@ import {
 addChunkDebugInfo,
 }from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerConsumerModuleMap=null|{
 [clientId: string]: {
 [clientExportName: string]: ClientReferenceManifestEntry,
@@ -245,7 +247,10 @@ export function requireModule<T>(metadata: ClientReference<T>): T {
 // default property of this if it was an ESM interop module.
 returnmoduleExports.__esModule ? moduleExports.default : moduleExports;
 }
- return moduleExports[metadata[NAME]];
+ if (hasOwnProperty.call(moduleExports, metadata[NAME])) {
+returnmoduleExports[metadata[NAME]];
+}
+ return (undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(

packages/react-server-dom-turbopack/src/server/ReactFlightDOMServerNode.js

@@ -570,31 +570,42 @@ function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-webpack/src/client/ReactFlightClientConfigBundlerNode.js

@@ -24,6 +24,8 @@ import {
 }from'../shared/ReactFlightImportMetadata';
 import{prepareDestinationWithChunks}from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerConsumerModuleMap={
 [clientId: string]: {
 [clientExportName: string]: ClientReference<any>,
@@ -158,7 +160,10 @@ export function requireModule<T>(metadata: ClientReference<T>): T {
 // default property of this if it was an ESM interop module.
 returnmoduleExports.default;
 }
-returnmoduleExports[metadata.name];
+if(hasOwnProperty.call(moduleExports,metadata.name)){
+returnmoduleExports[metadata.name];
+}
+return(undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(metadata: ClientReference<T>): null{

packages/react-server-dom-webpack/src/client/ReactFlightClientConfigBundlerWebpack.js

@@ -34,6 +34,8 @@ import {
 addChunkDebugInfo,
 }from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerConsumerModuleMap=null|{
 [clientId: string]: {
 [clientExportName: string]: ClientReferenceManifestEntry,
@@ -253,7 +255,10 @@ export function requireModule<T>(metadata: ClientReference<T>): T {
 // default property of this if it was an ESM interop module.
 returnmoduleExports.__esModule ? moduleExports.default : moduleExports;
 }
-returnmoduleExports[metadata[NAME]];
+if(hasOwnProperty.call(moduleExports,metadata[NAME])){
+returnmoduleExports[metadata[NAME]];
+}
+return(undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(

packages/react-server-dom-webpack/src/server/ReactFlightDOMServerNode.js

@@ -570,31 +570,42 @@ function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-esm/src/server/ReactFlightDOMServerNode.js

@@ -348,31 +348,42 @@ function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-parcel/src/client/ReactFlightClientConfigBundlerParcel.js

@@ -19,6 +19,8 @@ import {
 }from'../shared/ReactFlightImportMetadata';
 import{prepareDestinationWithChunks}from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerManifest={
 [string]: Array<string>,
 };
@@ -78,7 +80,10 @@ export function preloadModule<T>(
 
 exportfunctionrequireModule<T>(metadata: ClientReference<T>): T{
 const moduleExports =parcelRequire(metadata[ID]);
-returnmoduleExports[metadata[NAME]];
+if(hasOwnProperty.call(moduleExports,metadata[NAME])){
+returnmoduleExports[metadata[NAME]];
+}
+return(undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(

packages/react-server-dom-parcel/src/server/ReactFlightDOMServerNode.js

@@ -578,31 +578,42 @@ export function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-turbopack/src/client/ReactFlightClientConfigBundlerTurbopack.js

@@ -34,6 +34,8 @@ import {
 addChunkDebugInfo,
 }from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerConsumerModuleMap=null|{
 [clientId: string]: {
 [clientExportName: string]: ClientReferenceManifestEntry,
@@ -245,7 +247,10 @@ export function requireModule<T>(metadata: ClientReference<T>): T {
 // default property of this if it was an ESM interop module.
 returnmoduleExports.__esModule ? moduleExports.default : moduleExports;
 }
- return moduleExports[metadata[NAME]];
+ if (hasOwnProperty.call(moduleExports, metadata[NAME])) {
+returnmoduleExports[metadata[NAME]];
+}
+ return (undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(

packages/react-server-dom-turbopack/src/server/ReactFlightDOMServerNode.js

@@ -570,31 +570,42 @@ function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-webpack/src/client/ReactFlightClientConfigBundlerNode.js

@@ -24,6 +24,8 @@ import {
 }from'../shared/ReactFlightImportMetadata';
 import{prepareDestinationWithChunks}from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerConsumerModuleMap={
 [clientId: string]: {
 [clientExportName: string]: ClientReference<any>,
@@ -158,7 +160,10 @@ export function requireModule<T>(metadata: ClientReference<T>): T {
 // default property of this if it was an ESM interop module.
 returnmoduleExports.default;
 }
-returnmoduleExports[metadata.name];
+if(hasOwnProperty.call(moduleExports,metadata.name)){
+returnmoduleExports[metadata.name];
+}
+return(undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(metadata: ClientReference<T>): null{

packages/react-server-dom-webpack/src/client/ReactFlightClientConfigBundlerWebpack.js

@@ -34,6 +34,8 @@ import {
 addChunkDebugInfo,
 }from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerConsumerModuleMap=null|{
 [clientId: string]: {
 [clientExportName: string]: ClientReferenceManifestEntry,
@@ -253,7 +255,10 @@ export function requireModule<T>(metadata: ClientReference<T>): T {
 // default property of this if it was an ESM interop module.
 returnmoduleExports.__esModule ? moduleExports.default : moduleExports;
 }
-returnmoduleExports[metadata[NAME]];
+if(hasOwnProperty.call(moduleExports,metadata[NAME])){
+returnmoduleExports[metadata[NAME]];
+}
+return(undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(

packages/react-server-dom-webpack/src/server/ReactFlightDOMServerNode.js

@@ -570,31 +570,42 @@ function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-esm/src/server/ReactFlightDOMServerNode.js

@@ -348,31 +348,42 @@ function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-parcel/src/client/ReactFlightClientConfigBundlerParcel.js

@@ -19,6 +19,8 @@ import {
 }from'../shared/ReactFlightImportMetadata';
 import{prepareDestinationWithChunks}from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerManifest={
 [string]: Array<string>,
 };
@@ -78,7 +80,10 @@ export function preloadModule<T>(
 
 exportfunctionrequireModule<T>(metadata: ClientReference<T>): T{
 const moduleExports =parcelRequire(metadata[ID]);
-returnmoduleExports[metadata[NAME]];
+if(hasOwnProperty.call(moduleExports,metadata[NAME])){
+returnmoduleExports[metadata[NAME]];
+}
+return(undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(

packages/react-server-dom-parcel/src/server/ReactFlightDOMServerNode.js

@@ -578,31 +578,42 @@ export function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-turbopack/src/client/ReactFlightClientConfigBundlerTurbopack.js

@@ -34,6 +34,8 @@ import {
 addChunkDebugInfo,
 }from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerConsumerModuleMap=null|{
 [clientId: string]: {
 [clientExportName: string]: ClientReferenceManifestEntry,
@@ -245,7 +247,10 @@ export function requireModule<T>(metadata: ClientReference<T>): T {
 // default property of this if it was an ESM interop module.
 returnmoduleExports.__esModule ? moduleExports.default : moduleExports;
 }
- return moduleExports[metadata[NAME]];
+ if (hasOwnProperty.call(moduleExports, metadata[NAME])) {
+returnmoduleExports[metadata[NAME]];
+}
+ return (undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(

packages/react-server-dom-turbopack/src/server/ReactFlightDOMServerNode.js

@@ -570,31 +570,42 @@ function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-webpack/src/client/ReactFlightClientConfigBundlerNode.js

@@ -24,6 +24,8 @@ import {
 }from'../shared/ReactFlightImportMetadata';
 import{prepareDestinationWithChunks}from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerConsumerModuleMap={
 [clientId: string]: {
 [clientExportName: string]: ClientReference<any>,
@@ -158,7 +160,10 @@ export function requireModule<T>(metadata: ClientReference<T>): T {
 // default property of this if it was an ESM interop module.
 returnmoduleExports.default;
 }
-returnmoduleExports[metadata.name];
+if(hasOwnProperty.call(moduleExports,metadata.name)){
+returnmoduleExports[metadata.name];
+}
+return(undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(metadata: ClientReference<T>): null{

packages/react-server-dom-webpack/src/client/ReactFlightClientConfigBundlerWebpack.js

@@ -34,6 +34,8 @@ import {
 addChunkDebugInfo,
 }from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerConsumerModuleMap=null|{
 [clientId: string]: {
 [clientExportName: string]: ClientReferenceManifestEntry,
@@ -253,7 +255,10 @@ export function requireModule<T>(metadata: ClientReference<T>): T {
 // default property of this if it was an ESM interop module.
 returnmoduleExports.__esModule ? moduleExports.default : moduleExports;
 }
-returnmoduleExports[metadata[NAME]];
+if(hasOwnProperty.call(moduleExports,metadata[NAME])){
+returnmoduleExports[metadata[NAME]];
+}
+return(undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(

packages/react-server-dom-webpack/src/server/ReactFlightDOMServerNode.js

@@ -570,31 +570,42 @@ function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-esm/src/server/ReactFlightDOMServerNode.js

@@ -348,31 +348,42 @@ function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-parcel/src/client/ReactFlightClientConfigBundlerParcel.js

@@ -19,6 +19,8 @@ import {
 }from'../shared/ReactFlightImportMetadata';
 import{prepareDestinationWithChunks}from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerManifest={
 [string]: Array<string>,
 };
@@ -78,7 +80,10 @@ export function preloadModule<T>(
 
 exportfunctionrequireModule<T>(metadata: ClientReference<T>): T{
 const moduleExports =parcelRequire(metadata[ID]);
-returnmoduleExports[metadata[NAME]];
+if(hasOwnProperty.call(moduleExports,metadata[NAME])){
+returnmoduleExports[metadata[NAME]];
+}
+return(undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(

packages/react-server-dom-parcel/src/server/ReactFlightDOMServerNode.js

@@ -578,31 +578,42 @@ export function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-turbopack/src/client/ReactFlightClientConfigBundlerTurbopack.js

@@ -34,6 +34,8 @@ import {
 addChunkDebugInfo,
 }from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerConsumerModuleMap=null|{
 [clientId: string]: {
 [clientExportName: string]: ClientReferenceManifestEntry,
@@ -245,7 +247,10 @@ export function requireModule<T>(metadata: ClientReference<T>): T {
 // default property of this if it was an ESM interop module.
 returnmoduleExports.__esModule ? moduleExports.default : moduleExports;
 }
- return moduleExports[metadata[NAME]];
+ if (hasOwnProperty.call(moduleExports, metadata[NAME])) {
+returnmoduleExports[metadata[NAME]];
+}
+ return (undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(

packages/react-server-dom-turbopack/src/server/ReactFlightDOMServerNode.js

@@ -570,31 +570,42 @@ function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-webpack/src/client/ReactFlightClientConfigBundlerNode.js

@@ -24,6 +24,8 @@ import {
 }from'../shared/ReactFlightImportMetadata';
 import{prepareDestinationWithChunks}from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerConsumerModuleMap={
 [clientId: string]: {
 [clientExportName: string]: ClientReference<any>,
@@ -158,7 +160,10 @@ export function requireModule<T>(metadata: ClientReference<T>): T {
 // default property of this if it was an ESM interop module.
 returnmoduleExports.default;
 }
-returnmoduleExports[metadata.name];
+if(hasOwnProperty.call(moduleExports,metadata.name)){
+returnmoduleExports[metadata.name];
+}
+return(undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(metadata: ClientReference<T>): null{

packages/react-server-dom-webpack/src/client/ReactFlightClientConfigBundlerWebpack.js

@@ -34,6 +34,8 @@ import {
 addChunkDebugInfo,
 }from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerConsumerModuleMap=null|{
 [clientId: string]: {
 [clientExportName: string]: ClientReferenceManifestEntry,
@@ -253,7 +255,10 @@ export function requireModule<T>(metadata: ClientReference<T>): T {
 // default property of this if it was an ESM interop module.
 returnmoduleExports.__esModule ? moduleExports.default : moduleExports;
 }
-returnmoduleExports[metadata[NAME]];
+if(hasOwnProperty.call(moduleExports,metadata[NAME])){
+returnmoduleExports[metadata[NAME]];
+}
+return(undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(

packages/react-server-dom-webpack/src/server/ReactFlightDOMServerNode.js

@@ -570,31 +570,42 @@ function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-esm/src/server/ReactFlightDOMServerNode.js

@@ -348,31 +348,42 @@ function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-parcel/src/client/ReactFlightClientConfigBundlerParcel.js

@@ -19,6 +19,8 @@ import {
 }from'../shared/ReactFlightImportMetadata';
 import{prepareDestinationWithChunks}from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerManifest={
 [string]: Array<string>,
 };
@@ -78,7 +80,10 @@ export function preloadModule<T>(
 
 exportfunctionrequireModule<T>(metadata: ClientReference<T>): T{
 const moduleExports =parcelRequire(metadata[ID]);
-returnmoduleExports[metadata[NAME]];
+if(hasOwnProperty.call(moduleExports,metadata[NAME])){
+returnmoduleExports[metadata[NAME]];
+}
+return(undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(

packages/react-server-dom-parcel/src/server/ReactFlightDOMServerNode.js

@@ -578,31 +578,42 @@ export function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-turbopack/src/client/ReactFlightClientConfigBundlerTurbopack.js

@@ -34,6 +34,8 @@ import {
 addChunkDebugInfo,
 }from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerConsumerModuleMap=null|{
 [clientId: string]: {
 [clientExportName: string]: ClientReferenceManifestEntry,
@@ -245,7 +247,10 @@ export function requireModule<T>(metadata: ClientReference<T>): T {
 // default property of this if it was an ESM interop module.
 returnmoduleExports.__esModule ? moduleExports.default : moduleExports;
 }
- return moduleExports[metadata[NAME]];
+ if (hasOwnProperty.call(moduleExports, metadata[NAME])) {
+returnmoduleExports[metadata[NAME]];
+}
+ return (undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(

packages/react-server-dom-turbopack/src/server/ReactFlightDOMServerNode.js

@@ -570,31 +570,42 @@ function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-webpack/src/client/ReactFlightClientConfigBundlerNode.js

@@ -24,6 +24,8 @@ import {
 }from'../shared/ReactFlightImportMetadata';
 import{prepareDestinationWithChunks}from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerConsumerModuleMap={
 [clientId: string]: {
 [clientExportName: string]: ClientReference<any>,
@@ -158,7 +160,10 @@ export function requireModule<T>(metadata: ClientReference<T>): T {
 // default property of this if it was an ESM interop module.
 returnmoduleExports.default;
 }
-returnmoduleExports[metadata.name];
+if(hasOwnProperty.call(moduleExports,metadata.name)){
+returnmoduleExports[metadata.name];
+}
+return(undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(metadata: ClientReference<T>): null{

packages/react-server-dom-webpack/src/client/ReactFlightClientConfigBundlerWebpack.js

@@ -34,6 +34,8 @@ import {
 addChunkDebugInfo,
 }from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerConsumerModuleMap=null|{
 [clientId: string]: {
 [clientExportName: string]: ClientReferenceManifestEntry,
@@ -253,7 +255,10 @@ export function requireModule<T>(metadata: ClientReference<T>): T {
 // default property of this if it was an ESM interop module.
 returnmoduleExports.__esModule ? moduleExports.default : moduleExports;
 }
-returnmoduleExports[metadata[NAME]];
+if(hasOwnProperty.call(moduleExports,metadata[NAME])){
+returnmoduleExports[metadata[NAME]];
+}
+return(undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(

packages/react-server-dom-webpack/src/server/ReactFlightDOMServerNode.js

@@ -570,31 +570,42 @@ function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-esm/src/server/ReactFlightDOMServerNode.js

@@ -348,31 +348,42 @@ function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-parcel/src/client/ReactFlightClientConfigBundlerParcel.js

@@ -19,6 +19,8 @@ import {
 }from'../shared/ReactFlightImportMetadata';
 import{prepareDestinationWithChunks}from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerManifest={
 [string]: Array<string>,
 };
@@ -78,7 +80,10 @@ export function preloadModule<T>(
 
 exportfunctionrequireModule<T>(metadata: ClientReference<T>): T{
 const moduleExports =parcelRequire(metadata[ID]);
-returnmoduleExports[metadata[NAME]];
+if(hasOwnProperty.call(moduleExports,metadata[NAME])){
+returnmoduleExports[metadata[NAME]];
+}
+return(undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(

packages/react-server-dom-parcel/src/server/ReactFlightDOMServerNode.js

@@ -578,31 +578,42 @@ export function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-turbopack/src/client/ReactFlightClientConfigBundlerTurbopack.js

@@ -34,6 +34,8 @@ import {
 addChunkDebugInfo,
 }from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerConsumerModuleMap=null|{
 [clientId: string]: {
 [clientExportName: string]: ClientReferenceManifestEntry,
@@ -245,7 +247,10 @@ export function requireModule<T>(metadata: ClientReference<T>): T {
 // default property of this if it was an ESM interop module.
 returnmoduleExports.__esModule ? moduleExports.default : moduleExports;
 }
- return moduleExports[metadata[NAME]];
+ if (hasOwnProperty.call(moduleExports, metadata[NAME])) {
+returnmoduleExports[metadata[NAME]];
+}
+ return (undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(

packages/react-server-dom-turbopack/src/server/ReactFlightDOMServerNode.js

@@ -570,31 +570,42 @@ function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });

packages/react-server-dom-webpack/src/client/ReactFlightClientConfigBundlerNode.js

@@ -24,6 +24,8 @@ import {
 }from'../shared/ReactFlightImportMetadata';
 import{prepareDestinationWithChunks}from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerConsumerModuleMap={
 [clientId: string]: {
 [clientExportName: string]: ClientReference<any>,
@@ -158,7 +160,10 @@ export function requireModule<T>(metadata: ClientReference<T>): T {
 // default property of this if it was an ESM interop module.
 returnmoduleExports.default;
 }
-returnmoduleExports[metadata.name];
+if(hasOwnProperty.call(moduleExports,metadata.name)){
+returnmoduleExports[metadata.name];
+}
+return(undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(metadata: ClientReference<T>): null{

packages/react-server-dom-webpack/src/client/ReactFlightClientConfigBundlerWebpack.js

@@ -34,6 +34,8 @@ import {
 addChunkDebugInfo,
 }from'react-client/src/ReactFlightClientConfig';
 
+importhasOwnPropertyfrom'shared/hasOwnProperty';
+
 exporttypeServerConsumerModuleMap=null|{
 [clientId: string]: {
 [clientExportName: string]: ClientReferenceManifestEntry,
@@ -253,7 +255,10 @@ export function requireModule<T>(metadata: ClientReference<T>): T {
 // default property of this if it was an ESM interop module.
 returnmoduleExports.__esModule ? moduleExports.default : moduleExports;
 }
-returnmoduleExports[metadata[NAME]];
+if(hasOwnProperty.call(moduleExports,metadata[NAME])){
+returnmoduleExports[metadata[NAME]];
+}
+return(undefined: any);
 }
 
 exportfunctiongetModuleDebugInfo<T>(

packages/react-server-dom-webpack/src/server/ReactFlightDOMServerNode.js

@@ -570,31 +570,42 @@ function decodeReplyFromBusboy<T>(
 // we queue any fields we receive until the previous file is done.
 queuedFields.push(name,value);
 }else{
-resolveField(response,name,value);
+try{
+resolveField(response,name,value);
+}catch(error){
+busboyStream.destroy(error);
+}
 }
 });
 busboyStream.on('file',(name,value,{filename, encoding, mimeType})=>{
 if(encoding.toLowerCase()==='base64'){
-thrownewError(
-"React doesn't accept base64 encoded file uploads because we don't expect "+
-"form data passed from a browser to ever encode data that way. If that's "+
-'the wrong assumption, we can easily fix it.',
+busboyStream.destroy(
+newError(
+"React doesn't accept base64 encoded file uploads because we don't expect "+
+"form data passed from a browser to ever encode data that way. If that's "+
+'the wrong assumption, we can easily fix it.',
+),
 );
+return;
 }
 pendingFiles++;
 constfile=resolveFileInfo(response,name,filename,mimeType);
 value.on('data',chunk=>{
 resolveFileChunk(response,file,chunk);
 });
 value.on('end',()=>{
-resolveFileComplete(response,name,file);
-pendingFiles--;
-if(pendingFiles===0){
-// Release any queued fields
-for(leti=0;i<queuedFields.length;i+=2){
-resolveField(response,queuedFields[i],queuedFields[i+1]);
+try{
+resolveFileComplete(response,name,file);
+pendingFiles--;
+if(pendingFiles===0){
+// Release any queued fields
+for(leti=0;i<queuedFields.length;i+=2){
+resolveField(response,queuedFields[i],queuedFields[i+1]);
+}
+queuedFields.length=0;
 }
-queuedFields.length=0;
+}catch(error){
+busboyStream.destroy(error);
 }
 });
 });