65 lines
2.4 KiB
JavaScript
65 lines
2.4 KiB
JavaScript
import v8 from "v8";
|
|
import http from "http";
|
|
// This is required before other imports to ensure the require hook is setup.
|
|
import "../require-hook";
|
|
import "../node-polyfill-fetch";
|
|
import { warn } from "../../build/output/log";
|
|
process.on("unhandledRejection", (err)=>{
|
|
console.error(err);
|
|
});
|
|
process.on("uncaughtException", (err)=>{
|
|
console.error(err);
|
|
});
|
|
export const RESTART_EXIT_CODE = 77;
|
|
const MAXIMUM_HEAP_SIZE_ALLOWED = v8.getHeapStatistics().heap_size_limit / 1024 / 1024 * 0.9;
|
|
export async function initializeServerWorker(requestHandler, upgradeHandler, opts) {
|
|
const server = http.createServer((req, res)=>{
|
|
return requestHandler(req, res).catch((err)=>{
|
|
res.statusCode = 500;
|
|
res.end("Internal Server Error");
|
|
console.error(err);
|
|
}).finally(()=>{
|
|
if (process.memoryUsage().heapUsed / 1024 / 1024 > MAXIMUM_HEAP_SIZE_ALLOWED) {
|
|
warn("The server is running out of memory, restarting to free up memory.");
|
|
server.close();
|
|
process.exit(RESTART_EXIT_CODE);
|
|
}
|
|
});
|
|
});
|
|
if (opts.keepAliveTimeout) {
|
|
server.keepAliveTimeout = opts.keepAliveTimeout;
|
|
}
|
|
return new Promise(async (resolve, reject)=>{
|
|
server.on("error", (err)=>{
|
|
console.error(`Invariant: failed to start server worker`, err);
|
|
process.exit(1);
|
|
});
|
|
if (upgradeHandler) {
|
|
server.on("upgrade", (req, socket, upgrade)=>{
|
|
upgradeHandler(req, socket, upgrade);
|
|
});
|
|
}
|
|
let hostname = opts.hostname || "localhost";
|
|
server.on("listening", async ()=>{
|
|
try {
|
|
const addr = server.address();
|
|
const host = addr ? typeof addr === "object" ? addr.address : addr : undefined;
|
|
const port = addr && typeof addr === "object" ? addr.port : 0;
|
|
if (!port || !host) {
|
|
console.error(`Invariant failed to detect render worker host/port`, addr);
|
|
process.exit(1);
|
|
}
|
|
resolve({
|
|
server,
|
|
port,
|
|
hostname: host
|
|
});
|
|
} catch (err) {
|
|
return reject(err);
|
|
}
|
|
});
|
|
server.listen(0, hostname);
|
|
});
|
|
}
|
|
|
|
//# sourceMappingURL=setup-server-worker.js.map
|