chore: rename agentRunner to mcpClient

Author: blva

src/common/connectionManager.ts

@@ -88,7 +88,9 @@ export class ConnectionManager extends EventEmitter<ConnectionManagerEvents> {
                 connectionString: settings.connectionString,
                 components: {
                     appName: `${packageInfo.mcpServerName} ${packageInfo.version}`,
-                    // clientName: this.agentRunner?.name || "unknown", //TODO: MCP-68 - get client name from session
+                    // deviceId: deviceId, //TODO: MCP-68 - get deviceId from session
+                    // clientName: this.clientInfo?.name || "unknown",
+                    clientName: "unknown", //TODO: MCP-68 - get client name from session
                 },
             });
 

src/common/logger.ts

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

src/common/session.ts

@@ -34,9 +34,10 @@ export class Session extends EventEmitter<SessionEvents> {
     readonly exportsManager: ExportsManager;
     readonly connectionManager: ConnectionManager;
     readonly apiClient: ApiClient;
-    agentRunner?: {
-        name: string;
-        version: string;
+    mcpClient?: {
+        name?: string;
+        version?: string;
+        title?: string;
     };
 
     public logger: CompositeLogger;
@@ -69,13 +70,22 @@ export class Session extends EventEmitter<SessionEvents> {
         this.connectionManager.on("connection-errored", (error) => this.emit("connection-error", error.errorReason));
     }
 
-    setAgentRunner(agentRunner: Implementation | undefined): void {
-        if (agentRunner?.name && agentRunner?.version) {
-            this.agentRunner = {
-                name: agentRunner.name,
-                version: agentRunner.version,
-            };
+    setMcpClient(mcpClient: Implementation | undefined): void {
+        if (!mcpClient) {
+            this.mcpClient = undefined;
+            this.logger.debug({
+                id: LogId.serverMcpClientSet,
+                context: "session",
+                message: "MCP client info not found",
+            });
+            return;
         }
+
+        this.mcpClient = {
+            name: mcpClient.name || "unknown",
+            version: mcpClient.version || "unknown",
+            title: mcpClient.title || "unknown",
+        };
     }
 
     async disconnect(): Promise<void> {

src/helpers/deviceId.ts

@@ -1,6 +1,6 @@
 import { getDeviceId } from "@mongodb-js/device-id";
 import nodeMachineId from "node-machine-id";
-import logger, { LogId } from "../common/logger.js";
+import { LogId, CompositeLogger } from "../common/logger.js";
 
 export const DEVICE_ID_TIMEOUT = 3000;
 
@@ -13,11 +13,11 @@ export const DEVICE_ID_TIMEOUT = 3000;
  *
  * @example
  * ```typescript
- * const deviceId = await getDeviceIdForConnection();
+ * const deviceId = await getDeviceIdForConnection(logger);
  * console.log(deviceId); // Outputs the device ID or "unknown" in case of failure
  * ```
  */
-export async function getDeviceIdForConnection(): Promise<string> {
+export async function getDeviceIdForConnection(logger: CompositeLogger): Promise<string> {
     const controller = new AbortController();
 
     try {

src/server.ts

@@ -97,12 +97,12 @@ export class Server {
         });
 
         this.mcpServer.server.oninitialized = (): void => {
-            this.session.setAgentRunner(this.mcpServer.server.getClientVersion());
+            this.session.setMcpClient(this.mcpServer.server.getClientVersion());
 
             this.session.logger.info({
                 id: LogId.serverInitialized,
                 context: "server",
-                message: `Server started with transport ${transport.constructor.name} and agent runner ${this.session.agentRunner?.name}`,
+                message: `Server started with transport ${transport.constructor.name} and agent runner ${this.session.mcpClient?.name}`,
             });
 
             this.emitServerEvent("start", Date.now() - this.startTime);

src/telemetry/telemetry.ts

@@ -98,8 +98,8 @@ export class Telemetry {
         return {
             ...this.commonProperties,
             transport: this.userConfig.transport,
-            mcp_client_version: this.session.agentRunner?.version,
-            mcp_client_name: this.session.agentRunner?.name,
+            mcp_client_version: this.session.mcpClient?.version,
+            mcp_client_name: this.session.mcpClient?.name,
             session_id: this.session.sessionId,
             config_atlas_auth: this.session.apiClient.hasCredentials() ? "true" : "false",
             config_connection_string: this.userConfig.connectionString ? "true" : "false",

tests/unit/common/session.test.ts

@@ -85,7 +85,7 @@ describe("Session", () => {
         });
 
         it("should include client name when agent runner is set", async () => {
-            session.setAgentRunner({ name: "test-client", version: "1.0.0" });
+            session.setMcpClient({ name: "test-client", version: "1.0.0" });
 
             await session.connectToMongoDB("mongodb://localhost:27017", config.connectOptions);
             expect(session.serviceProvider).toBeDefined();