/opt/canhelp/node_modules/next/dist/server/app-render
Edit: /opt/canhelp/node_modules/next/dist/server/app-render/use-flight-response.js (6844B)
"use strict";
Object.defineProperty(exports, "__esModule", {
value: true
});
0 && (module.exports = {
createInlinedDataReadableStream: null,
useFlightStream: null
});
function _export(target, all) {
for(var name in all)Object.defineProperty(target, name, {
enumerable: true,
get: all[name]
});
}
_export(exports, {
createInlinedDataReadableStream: function() {
return createInlinedDataReadableStream;
},
useFlightStream: function() {
return useFlightStream;
}
});
const _htmlescape = require("../htmlescape");
const _workunitasyncstorageexternal = require("./work-unit-async-storage.external");
const _invarianterror = require("../../shared/lib/invariant-error");
const isEdgeRuntime = process.env.NEXT_RUNTIME === 'edge';
const INLINE_FLIGHT_PAYLOAD_BOOTSTRAP = 0;
const INLINE_FLIGHT_PAYLOAD_DATA = 1;
const INLINE_FLIGHT_PAYLOAD_FORM_STATE = 2;
const INLINE_FLIGHT_PAYLOAD_BINARY = 3;
const flightResponses = new WeakMap();
const encoder = new TextEncoder();
const findSourceMapURL = process.env.NODE_ENV !== 'production' ? require('../lib/source-maps').findSourceMapURLDEV : undefined;
function useFlightStream(flightStream, clientReferenceManifest, nonce) {
const response = flightResponses.get(flightStream);
if (response) {
return response;
}
// react-server-dom-webpack/client.edge must not be hoisted for require cache clearing to work correctly
const { createFromReadableStream } = // eslint-disable-next-line import/no-extraneous-dependencies
require('react-server-dom-webpack/client');
const newResponse = createFromReadableStream(flightStream, {
findSourceMapURL,
serverConsumerManifest: {
moduleLoading: clientReferenceManifest.moduleLoading,
moduleMap: isEdgeRuntime ? clientReferenceManifest.edgeSSRModuleMapping : clientReferenceManifest.ssrModuleMapping,
serverModuleMap: null
},
nonce
});
// Edge pages are never prerendered so they necessarily cannot have a workUnitStore type
// that requires the nextTick behavior. This is why it is safe to access a node only API here
if (process.env.NEXT_RUNTIME !== 'edge') {
const workUnitStore = _workunitasyncstorageexternal.workUnitAsyncStorage.getStore();
if (!workUnitStore) {
throw Object.defineProperty(new _invarianterror.InvariantError('Expected workUnitAsyncStorage to have a store.'), "__NEXT_ERROR_CODE", {
value: "E696",
enumerable: false,
configurable: true
});
}
switch(workUnitStore.type){
case 'prerender-client':
const responseOnNextTick = new Promise((resolve)=>{
process.nextTick(()=>resolve(newResponse));
});
flightResponses.set(flightStream, responseOnNextTick);
return responseOnNextTick;
case 'prerender':
case 'prerender-runtime':
case 'prerender-ppr':
case 'prerender-legacy':
case 'request':
case 'cache':
case 'private-cache':
case 'unstable-cache':
break;
default:
workUnitStore;
}
}
flightResponses.set(flightStream, newResponse);
return newResponse;
}
function createInlinedDataReadableStream(flightStream, nonce, formState) {
const startScriptTag = nonce ? ``));
} else {
controller.enqueue(encoder.encode(`${scriptStart}(self.__next_f=self.__next_f||[]).push(${(0, _htmlescape.htmlEscapeJsonString)(JSON.stringify([
INLINE_FLIGHT_PAYLOAD_BOOTSTRAP
]))})`));
}
}
function writeFlightDataInstruction(controller, scriptStart, chunk) {
let htmlInlinedData;
if (typeof chunk === 'string') {
htmlInlinedData = (0, _htmlescape.htmlEscapeJsonString)(JSON.stringify([
INLINE_FLIGHT_PAYLOAD_DATA,
chunk
]));
} else {
// The chunk cannot be embedded as a UTF-8 string in the script tag.
// Instead let's inline it in base64.
// Credits to Devon Govett (devongovett) for the technique.
// https://github.com/devongovett/rsc-html-stream
const base64 = btoa(String.fromCodePoint(...chunk));
htmlInlinedData = (0, _htmlescape.htmlEscapeJsonString)(JSON.stringify([
INLINE_FLIGHT_PAYLOAD_BINARY,
base64
]));
}
controller.enqueue(encoder.encode(`${scriptStart}self.__next_f.push(${htmlInlinedData})`));
}
//# sourceMappingURL=use-flight-response.js.map