fix: move logger

Author: fmenezes

src/common/logger.ts

@@ -12,6 +12,7 @@ export const LogId = {
     serverCloseRequested: mongoLogId(1_000_003),
     serverClosed: mongoLogId(1_000_004),
     serverCloseFailure: mongoLogId(1_000_005),
+    serverDuplicateLoggers: mongoLogId(1_000_006),
 
     atlasCheckCredentials: mongoLogId(1_001_001),
     atlasDeleteDatabaseUserFailure: mongoLogId(1_001_002),

src/index.ts

@@ -26,18 +26,6 @@ try {
         version: packageInfo.version,
     });
 
-    let loggers: LoggerBase[] = [];
-    if (config.loggers.includes("mcp")) {
-        loggers.push(new McpLogger(mcpServer));
-    }
-    if (config.loggers.includes("disk")) {
-        loggers.push(await DiskLogger.fromPath(config.logPath));
-    }
-    if (config.loggers.includes("stderr")) {
-        loggers.push(new ConsoleLogger());
-    }
-    logger.setLoggers(...loggers);
-
     const server = new Server({
         mcpServer,
         session,

src/server.ts

@@ -3,7 +3,7 @@ import { Session } from "./common/session.js";
 import { Transport } from "@modelcontextprotocol/sdk/shared/transport.js";
 import { AtlasTools } from "./tools/atlas/tools.js";
 import { MongoDbTools } from "./tools/mongodb/tools.js";
-import logger, { LogId } from "./common/logger.js";
+import logger, { LogId, LoggerBase, McpLogger, DiskLogger, ConsoleLogger } from "./common/logger.js";
 import { ObjectId } from "mongodb";
 import { Telemetry } from "./telemetry/telemetry.js";
 import { UserConfig } from "./common/config.js";
@@ -67,6 +67,18 @@ export class Server {
             return existingHandler(request, extra);
         });
 
+        const loggers: LoggerBase[] = [];
+        if (this.userConfig.loggers.includes("mcp")) {
+            loggers.push(new McpLogger(this.mcpServer));
+        }
+        if (this.userConfig.loggers.includes("disk")) {
+            loggers.push(await DiskLogger.fromPath(this.userConfig.logPath));
+        }
+        if (this.userConfig.loggers.includes("stderr")) {
+            loggers.push(new ConsoleLogger());
+        }
+        logger.setLoggers(...loggers);
+        
         this.mcpServer.server.oninitialized = () => {
             this.session.setAgentRunner(this.mcpServer.server.getClientVersion());
             this.session.sessionId = new ObjectId().toString();
@@ -189,6 +201,21 @@ export class Server {
             throw new Error(`Invalid httpPort: ${this.userConfig.httpPort}`);
         }
 
+        if (this.userConfig.loggers.length === 0) {
+            throw new Error("No loggers found in config");
+        }
+
+        const loggerTypes = new Set(this.userConfig.loggers);
+        if (loggerTypes.size !== this.userConfig.loggers.length) {
+            throw new Error("Duplicate loggers found in config");
+        }
+
+        for (const loggerType of this.userConfig.loggers) {
+            if (loggerType !== "mcp" && loggerType !== "disk" && loggerType !== "stderr") {
+                throw new Error(`Invalid logger: ${loggerType}`);
+            }
+        }
+
         if (this.userConfig.connectionString) {
             try {
                 await this.session.connectToMongoDB(this.userConfig.connectionString, this.userConfig.connectOptions);