server.js

import * as rtc from "#src/services/rtc.js";
import * as http from "#src/services/http.js";
import * as auth from "#src/services/auth.js";
import { Logger } from "#src/utils/utils.js";
import { Channel } from "#src/models/channel.js";

const logger = new Logger("SERVER", { logLevel: "all" });

async function run() {
    await auth.start();
    await rtc.start();
    await http.start();
    logger.info(`ready - PID: ${process.pid}`);
}

function cleanup() {
    Channel.closeAll();
    http.close();
    rtc.close();
    logger.info("cleanup complete");
}

const processHandlers = {
    exit: cleanup,
    uncaughtException: (error) => {
        logger.error(`uncaught exception ${error.name}: ${error.message} ${error.stack ?? ""}`);
    },
    SIGINT: cleanup,
    // 8, restarts the server
    SIGFPE: async () => {
        cleanup();
        await run();
    },
    // 14, soft reset: only kicks all sessions, but keeps services alive
    SIGALRM: () => {
        Channel.closeAll();
    },
    // 29, prints server stats
    SIGIO: async () => {
        let globalIncomingBitrate = 0;
        const proms = [];
        for (const channel of Channel.records.values()) {
            proms.push(
                (async () => {
                    const {
                        sessionsStats: {
                            incomingBitRate: { audio, camera, screen, total },
                            count,
                        },
                    } = await channel.getStats();
                    globalIncomingBitrate += total;
                    logger.info(`Channel ${channel.name}: ${count} sessions`);
                    logger.info(`-- audio: ${audio} bps`);
                    logger.info(`-- camera: ${camera} bps`);
                    logger.info(`-- screen: ${screen} bps`);
                    logger.info(`-- total: ${total} bps`);
                })()
            );
        }
        await Promise.all(proms);
        logger.info(`${Channel.records.size} channels total`);
        logger.info(`Global incoming bitrate: ${globalIncomingBitrate} bps`);
    },
};

// ==================== PROCESS ====================
process.name = "odoo_sfu";
for (const [signal, handler] of Object.entries(processHandlers)) {
    process.on(signal, handler);
}
await run();
// ==================== ======= ====================