/opt/canhelp/node_modules/next/dist/esm/server/lib
Edit: /opt/canhelp/node_modules/next/dist/esm/server/lib/render-server.js (2988B)
import next from '../next';
let initializations = {};
let sandboxContext;
if (process.env.NODE_ENV !== 'production') {
sandboxContext = require('../web/sandbox/context');
}
export function clearAllModuleContexts() {
return sandboxContext == null ? void 0 : sandboxContext.clearAllModuleContexts();
}
export function clearModuleContext(target) {
return sandboxContext == null ? void 0 : sandboxContext.clearModuleContext(target);
}
export async function getServerField(dir, field) {
const initialization = await initializations[dir];
if (!initialization) {
throw Object.defineProperty(new Error('Invariant cant propagate server field, no app initialized'), "__NEXT_ERROR_CODE", {
value: "E116",
enumerable: false,
configurable: true
});
}
const { server } = initialization;
let wrappedServer = server['server']// NextServer.server is private
;
return wrappedServer[field];
}
export async function propagateServerField(dir, field, value) {
const initialization = await initializations[dir];
if (!initialization) {
throw Object.defineProperty(new Error('Invariant cant propagate server field, no app initialized'), "__NEXT_ERROR_CODE", {
value: "E116",
enumerable: false,
configurable: true
});
}
const { server } = initialization;
let wrappedServer = server['server'];
const _field = field;
if (wrappedServer) {
if (typeof wrappedServer[_field] === 'function') {
// @ts-expect-error
await wrappedServer[_field].apply(wrappedServer, Array.isArray(value) ? value : []);
} else {
// @ts-expect-error
wrappedServer[_field] = value;
}
}
}
async function initializeImpl(opts) {
const type = process.env.__NEXT_PRIVATE_RENDER_WORKER;
if (type) {
process.title = 'next-render-worker-' + type;
}
let requestHandler;
let upgradeHandler;
const server = next({
...opts,
hostname: opts.hostname || 'localhost',
customServer: false,
httpServer: opts.server,
port: opts.port
})// should return a NextServer when `customServer: false`
;
requestHandler = server.getRequestHandler();
upgradeHandler = server.getUpgradeHandler();
await server.prepare(opts.serverFields);
return {
requestHandler,
upgradeHandler,
server,
closeUpgraded () {
var _opts_bundlerService;
(_opts_bundlerService = opts.bundlerService) == null ? void 0 : _opts_bundlerService.close();
}
};
}
export async function initialize(opts) {
// if we already setup the server return as we only need to do
// this on first worker boot
if (initializations[opts.dir]) {
return initializations[opts.dir];
}
return initializations[opts.dir] = initializeImpl(opts);
}
//# sourceMappingURL=render-server.js.map