${appOnline ? "Open DeerFlow Workspace →" : "DeerFlow is starting…"}
`;
}
// ── Request handler ────────────────────────────────────────────────────────
const server = http.createServer(async (req, res) => {
const url = parseUrl(req.url || "/");
const pathname = url.pathname;
// Health — JSON for HEALTHCHECK and load balancers
if (pathname === "/health") {
const [backendUp, frontendUp] = await Promise.all([
probe(NGINX_HOST, BACKEND_PORT, "/health"),
tcpProbe(NGINX_HOST, FRONTEND_PORT),
]);
const ok = backendUp && frontendUp;
res.writeHead(ok ? 200 : 503, { "Content-Type": "application/json" });
return res.end(JSON.stringify({
status: ok ? "ok" : "degraded",
backendUp, frontendUp,
uptime: formatUptime(Date.now() - startTime),
sync: getSyncStatus(),
keepalive: getKeepaliveStatus(),
}));
}
// Status — full JSON payload
if (pathname === "/status") {
const [backendUp, frontendUp] = await Promise.all([
probe(NGINX_HOST, BACKEND_PORT, "/health"),
tcpProbe(NGINX_HOST, FRONTEND_PORT),
]);
res.writeHead(200, { "Content-Type": "application/json" });
return res.end(JSON.stringify({
model: LLM_MODEL,
search: SEARCH_LABEL,
uptime: formatUptime(Date.now() - startTime),
backendUp, frontendUp,
sync: getSyncStatus(),
keepalive: getKeepaliveStatus(),
}));
}
// Dashboard — HTML status page (served at / and /dashboard)
if (pathname === "/" || pathname === "/dashboard") {
const [backendUp, frontendUp] = await Promise.all([
probe(NGINX_HOST, BACKEND_PORT, "/health"),
tcpProbe(NGINX_HOST, FRONTEND_PORT),
]);
res.writeHead(200, { "Content-Type": "text/html; charset=utf-8", "Cache-Control": "no-store" });
return res.end(renderDashboard({
backendUp, frontendUp,
uptimeHuman: formatUptime(Date.now() - startTime),
sync: getSyncStatus(),
keepalive: getKeepaliveStatus(),
}));
}
// Everything else → proxy to nginx
const proxyHeaders = {
...req.headers,
host: `${NGINX_HOST}:${NGINX_PORT}`,
"x-forwarded-for": req.socket?.remoteAddress || "",
"x-forwarded-host": req.headers.host || "",
"x-forwarded-proto": "https",
};
const proxyReq = http.request(
{ hostname: NGINX_HOST, port: NGINX_PORT, path: pathname + url.search, method: req.method, headers: proxyHeaders },
proxyRes => {
res.writeHead(proxyRes.statusCode, proxyRes.headers);
proxyRes.pipe(res);
proxyRes.on("error", () => res.end());
},
);
proxyReq.on("error", err => {
if (!res.headersSent) {
res.writeHead(503, { "Content-Type": "application/json" });
res.end(JSON.stringify({ status: "starting", message: "DeerFlow is initializing…" }));
} else {
res.end();
}
});
req.on("error", () => proxyReq.destroy());
res.on("error", () => proxyReq.destroy());
req.pipe(proxyReq);
});
// WebSocket upgrade passthrough
server.on("upgrade", (req, socket, head) => {
const url = parseUrl(req.url || "/");
const upstream = net.connect(NGINX_PORT, NGINX_HOST, () => {
upstream.write(
`${req.method} ${url.pathname}${url.search} HTTP/${req.httpVersion}\r\n` +
req.rawHeaders.reduce((acc, v, i) => acc + (i % 2 === 0 ? `${v}: ` : `${v}\r\n`), "") +
"\r\n",
);
if (head?.length) upstream.write(head);
upstream.pipe(socket).pipe(upstream);
});
upstream.on("error", () => socket.destroy());
socket.on("error", () => upstream.destroy());
});
server.timeout = 0;
server.keepAliveTimeout = 65000;
server.listen(PUBLIC_PORT, "0.0.0.0", () =>
console.log(`🦌 HuggingFlow health-server :${PUBLIC_PORT} → nginx :${NGINX_PORT}`)
);