MythEclipse
7108f6bb47
Improve system reliability and real-time capabilities by implementing a robust lifecycle management system and adding new broadcast events for attachments and voice recordings. - Implement asynchronous graceful shutdown in backend to close HTTP, WebSocket, Redis, and database connections. - Add new WebSocket broadcast events: `attachment_created`, `voice_recording_started`, `voice_recording_stopped`, `voice_recording_uploaded`, and `analysis_queue_status`. - Refactor media status handling to use boolean `playing` state instead of string-based status. - Centralize `PageResult` and `VoiceRecording` types to improve consistency between frontend and backend. - Update frontend API client to include `listRecordings` and handle new WebSocket event types. - Fix type mismatches in voice command handling and media status reporting.
78 lines
2.1 KiB
TypeScript
78 lines
2.1 KiB
TypeScript
import type { Server } from "node:http";
|
|
import { createChildLogger } from "@bete/shared/logger";
|
|
import { startHttpServer } from "./http/server.js";
|
|
import { closeDatabase } from "./shared/database/index.js";
|
|
import { stopCommandBridge } from "./shared/redis/index.js";
|
|
import { stopRedisBridge as stopEventBridge } from "./ws/redis-bridge.js";
|
|
import { closeWebSocketServer } from "./ws/server.js";
|
|
|
|
const logger = createChildLogger("backend");
|
|
|
|
let httpServer: Server | undefined;
|
|
|
|
async function main() {
|
|
try {
|
|
logger.info("Starting Discord Moderation Backend Service");
|
|
httpServer = await startHttpServer();
|
|
logger.info("Backend service ready");
|
|
} catch (err) {
|
|
logger.error({ err }, "Failed to start backend service");
|
|
process.exit(1);
|
|
}
|
|
}
|
|
|
|
async function shutdown(signal: string) {
|
|
logger.info({ signal }, "Shutting down gracefully");
|
|
|
|
try {
|
|
// 1. Stop accepting new HTTP connections
|
|
if (httpServer) {
|
|
await new Promise<void>((resolve) => {
|
|
httpServer!.close(() => {
|
|
logger.info("HTTP server closed");
|
|
resolve();
|
|
});
|
|
});
|
|
}
|
|
|
|
// 2. Close WebSocket server
|
|
closeWebSocketServer();
|
|
|
|
// 3. Stop Redis bridges (event subscriptions + command channel)
|
|
await Promise.allSettled([
|
|
stopEventBridge().catch((err) =>
|
|
logger.warn({ err }, "Error stopping event bridge"),
|
|
),
|
|
stopCommandBridge().catch((err) =>
|
|
logger.warn({ err }, "Error stopping command bridge"),
|
|
),
|
|
]);
|
|
|
|
// 4. Close database pool
|
|
await closeDatabase().catch((err) =>
|
|
logger.warn({ err }, "Error closing database"),
|
|
);
|
|
|
|
logger.info("Graceful shutdown completed");
|
|
process.exit(0);
|
|
} catch (err) {
|
|
logger.error({ err }, "Error during graceful shutdown");
|
|
process.exit(1);
|
|
}
|
|
}
|
|
|
|
process.on("SIGINT", () => shutdown("SIGINT"));
|
|
process.on("SIGTERM", () => shutdown("SIGTERM"));
|
|
|
|
process.on("uncaughtException", (err) => {
|
|
logger.error({ err }, "Uncaught exception");
|
|
shutdown("uncaughtException");
|
|
});
|
|
|
|
process.on("unhandledRejection", (reason) => {
|
|
logger.error({ reason }, "Unhandled rejection");
|
|
shutdown("unhandledRejection");
|
|
});
|
|
|
|
main();
|