mongodb-js / mongodb-mcp-server / 16347477296

import logger, { LogId } from "./common/logger.js";

import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";

import { config } from "./common/config.js";

import { Session } from "./common/session.js";

import { Server } from "./server.js";

import { packageInfo } from "./common/packageInfo.js";

import { Telemetry } from "./telemetry/telemetry.js";

import { createEJsonTransport } from "./helpers/EJsonTransport.js";

try {

    const session = new Session({

        apiBaseUrl: config.apiBaseUrl,

        apiClientId: config.apiClientId,

        apiClientSecret: config.apiClientSecret,

    });

    const mcpServer = new McpServer({

        name: packageInfo.mcpServerName,

        version: packageInfo.version,

    });

    const telemetry = Telemetry.create(session, config);

    const server = new Server({

        mcpServer,

        session,

        telemetry,

        userConfig: config,

    });

    const transport = createEJsonTransport();

    const shutdown = () => {

        logger.info(LogId.serverCloseRequested, "server", `Server close requested`);

        server

            .close()

            .then(() => {

                logger.info(LogId.serverClosed, "server", `Server closed successfully`);

                process.exit(0);

            })

            .catch((err: unknown) => {

                const error = err instanceof Error ? err : new Error(String(err));

                logger.error(LogId.serverCloseFailure, "server", `Error closing server: ${error.message}`);

                process.exit(1);

            });

    };

    process.once("SIGINT", shutdown);

    process.once("SIGTERM", shutdown);

    process.once("SIGQUIT", shutdown);

    await server.connect(transport);

} catch (error: unknown) {

    logger.emergency(LogId.serverStartFailure, "server", `Fatal error running server: ${error as string}`);

    process.exit(1);

}