58 lines
2.0 KiB
TypeScript
58 lines
2.0 KiB
TypeScript
|
import http from "http";
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Запускает HTTP-сервер для проверки здоровья.
|
||
|
|
* @param controller - AbortController для управления состоянием здоровья.
|
||
|
|
* @param defaultPort - Порт для сервера по умолчанию (если не указан в ENV HEALTH_PORT).
|
||
|
|
* @param defaultHostName - Имя хоста для сервера по умолчанию (если не указан в ENV HEALTH_HOST).
|
||
|
|
*/
|
||
|
|
export function startHealthServer(
|
||
|
|
controller: AbortController,
|
||
|
|
defaultPort: number = 8000,
|
||
|
|
defaultHostName: string = "127.0.0.1",
|
||
|
|
): void {
|
||
|
|
const port = parseInt(process.env.HEALTH_PORT || `${defaultPort}`, 10);
|
||
|
|
const hostname = process.env.HEALTH_HOST || defaultHostName;
|
||
|
|
|
||
|
|
const server = http.createServer((req, res) => {
|
||
|
|
if (req.url === "/health") {
|
||
|
|
const signal = controller.signal;
|
||
|
|
|
||
|
|
// Если сигнал отмены активирован, сервер помечается как "unhealthy"
|
||
|
|
if (signal.aborted) {
|
||
|
|
res.writeHead(500, { "Content-Type": "application/json" });
|
||
|
|
res.end(
|
||
|
|
JSON.stringify({
|
||
|
|
status: "unhealthy",
|
||
|
|
reason: "Service aborted",
|
||
|
|
}),
|
||
|
|
);
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
// Возвращаем стандартный статус "ok", если всё нормально
|
||
|
|
res.writeHead(200, { "Content-Type": "application/json" });
|
||
|
|
res.end(
|
||
|
|
JSON.stringify({
|
||
|
|
status: "ok",
|
||
|
|
}),
|
||
|
|
);
|
||
|
|
} else {
|
||
|
|
res.writeHead(404, { "Content-Type": "text/plain" });
|
||
|
|
res.end("Not Found");
|
||
|
|
}
|
||
|
|
});
|
||
|
|
|
||
|
|
server.listen(port, hostname, () => {
|
||
|
|
console.log(
|
||
|
|
`Healthcheck server running on http://${hostname}:${port}/health`,
|
||
|
|
);
|
||
|
|
});
|
||
|
|
|
||
|
|
// Закрываем сервер при активации AbortController
|
||
|
|
controller.signal.addEventListener("abort", () => {
|
||
|
|
console.log("Healthcheck server shutting down due to abort signal.");
|
||
|
|
server.close();
|
||
|
|
});
|
||
|
|
}
|