chore: remove sideeffect from ctor

Author: himanshusinghs

src/common/exportsManager.ts

@@ -63,22 +63,17 @@ type ExportsManagerEvents = {
 };
 
 export class ExportsManager extends EventEmitter<ExportsManagerEvents> {
+    private wasInitialized: boolean = false;
     private storedExports: Record<StoredExport["exportName"], StoredExport> = {};
     private exportsCleanupInProgress: boolean = false;
-    private exportsCleanupInterval: NodeJS.Timeout;
-    private exportsDirectoryPath: string;
+    private exportsCleanupInterval?: NodeJS.Timeout;
 
-    constructor(
-        sessionId: string,
+    private constructor(
+        private readonly exportsDirectoryPath: string,
         private readonly config: ExportsManagerConfig,
         private readonly logger: LoggerBase
     ) {
         super();
-        this.exportsDirectoryPath = path.join(this.config.exportsPath, sessionId);
-        this.exportsCleanupInterval = setInterval(
-            () => void this.cleanupExpiredExports(),
-            this.config.exportCleanupIntervalMs
-        );
     }
 
     public get availableExports(): AvailableExport[] {
@@ -96,6 +91,17 @@ export class ExportsManager extends EventEmitter<ExportsManagerEvents> {
             }));
     }
 
+    protected init(): void {
+        if (!this.wasInitialized) {
+            this.exportsCleanupInterval = setInterval(
+                () => void this.cleanupExpiredExports(),
+                this.config.exportCleanupIntervalMs
+            );
+
+            this.wasInitialized = true;
+        }
+    }
+
     public async close(): Promise<void> {
         try {
             clearInterval(this.exportsCleanupInterval);
@@ -302,6 +308,13 @@ export class ExportsManager extends EventEmitter<ExportsManagerEvents> {
             }
         }
     }
+
+    static init(sessionId: string, config: ExportsManagerConfig, logger: LoggerBase): ExportsManager {
+        const exportsDirectoryPath = path.join(config.exportsPath, sessionId);
+        const exportsManager = new ExportsManager(exportsDirectoryPath, config, logger);
+        exportsManager.init();
+        return exportsManager;
+    }
 }
 
 /**

src/transports/base.ts

@@ -44,7 +44,7 @@ export abstract class TransportRunnerBase {
 
         const logger = new CompositeLogger(...loggers);
         const sessionId = new ObjectId().toString();
-        const exportsManager = new ExportsManager(sessionId, userConfig, logger);
+        const exportsManager = ExportsManager.init(sessionId, userConfig, logger);
         const connectionManager = new ConnectionManager();
 
         const session = new Session({

tests/integration/helpers.ts

@@ -59,7 +59,7 @@ export function setupIntegrationTest(getUserConfig: () => UserConfig): Integrati
 
         const logger = new CompositeLogger();
         const sessionId = new ObjectId().toString();
-        const exportsManager = new ExportsManager(sessionId, userConfig, logger);
+        const exportsManager = ExportsManager.init(sessionId, userConfig, logger);
         const connectionManager = new ConnectionManager();
 
         const session = new Session({

tests/integration/resources/exportedData.test.ts

@@ -1,9 +1,19 @@
+import path from "path";
+import fs from "fs/promises";
 import { Long } from "bson";
-import { describe, expect, it, beforeEach } from "vitest";
+import { describe, expect, it, beforeEach, afterAll } from "vitest";
 import { CallToolResult } from "@modelcontextprotocol/sdk/types.js";
 import { defaultTestConfig, resourceChangedNotification, timeout } from "../helpers.js";
 import { describeWithMongoDB } from "../tools/mongodb/mongodbHelpers.js";
 import { contentWithResourceURILink } from "../tools/mongodb/read/export.test.js";
+import { UserConfig } from "../../../src/lib.js";
+
+const userConfig: UserConfig = {
+    ...defaultTestConfig,
+    exportsPath: path.join(path.dirname(defaultTestConfig.exportsPath), `exports-${Date.now()}`),
+    exportTimeoutMs: 200,
+    exportCleanupIntervalMs: 300,
+};
 
 describeWithMongoDB(
     "exported-data resource",
@@ -19,6 +29,10 @@ describeWithMongoDB(
                 ]);
         });
 
+        afterAll(async () => {
+            await fs.rm(userConfig.exportsPath, { recursive: true, force: true });
+        });
+
         it("should be able to list resource template", async () => {
             await integration.connectMcpClient();
             const response = await integration.mcpClient().listResourceTemplates();
@@ -123,11 +137,5 @@ describeWithMongoDB(
             });
         });
     },
-    () => {
-        return {
-            ...defaultTestConfig,
-            exportTimeoutMs: 200,
-            exportCleanupIntervalMs: 300,
-        };
-    }
+    () => userConfig
 );

tests/integration/telemetry.test.ts

@@ -20,7 +20,7 @@ describe("Telemetry", () => {
                 apiBaseUrl: "",
                 logger: new CompositeLogger(),
                 sessionId: "1FOO",
-                exportsManager: new ExportsManager("1FOO", config, logger),
+                exportsManager: ExportsManager.init("1FOO", config, logger),
                 connectionManager: new ConnectionManager(),
             }),
             config