chore: bring ctor back on runner implementations

Author: himanshusinghs

src/transports/base.ts

@@ -22,7 +22,7 @@ export abstract class TransportRunnerBase<ConnectParams extends MCPConnectParams
     constructor(
         protected readonly userConfig: UserConfig,
         private readonly createConnectionManager: CreateConnectionManagerFn<ConnectParams>,
-        additionalLoggers: LoggerBase[] = []
+        additionalLoggers: LoggerBase[]
     ) {
         const loggers: LoggerBase[] = [...additionalLoggers];
         if (this.userConfig.loggers.includes("stderr")) {

src/transports/stdio.ts

@@ -2,9 +2,10 @@ import { EJSON } from "bson";
 import type { JSONRPCMessage } from "@modelcontextprotocol/sdk/types.js";
 import { JSONRPCMessageSchema } from "@modelcontextprotocol/sdk/types.js";
 import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js";
-import { LogId } from "../common/logger.js";
+import { type LoggerBase, LogId } from "../common/logger.js";
 import type { Server } from "../server.js";
-import { TransportRunnerBase } from "./base.js";
+import { type CreateConnectionManagerFn, TransportRunnerBase } from "./base.js";
+import { type UserConfig } from "../common/config.js";
 import type { MCPConnectParams } from "../common/connectionManager.js";
 
 // This is almost a copy of ReadBuffer from @modelcontextprotocol/sdk
@@ -54,6 +55,14 @@ export function createStdioTransport(): StdioServerTransport {
 export class StdioRunner<ConnectParams extends MCPConnectParams> extends TransportRunnerBase<ConnectParams> {
     private server: Server | undefined;
 
+    constructor(
+        userConfig: UserConfig,
+        createConnectionManager: CreateConnectionManagerFn<ConnectParams>,
+        additionalLoggers: LoggerBase[] = []
+    ) {
+        super(userConfig, createConnectionManager, additionalLoggers);
+    }
+
     async start(): Promise<void> {
         try {
             this.server = await this.setupServer();

src/transports/streamableHttp.ts

@@ -3,10 +3,11 @@ import type http from "http";
 import { randomUUID } from "crypto";
 import { StreamableHTTPServerTransport } from "@modelcontextprotocol/sdk/server/streamableHttp.js";
 import { isInitializeRequest } from "@modelcontextprotocol/sdk/types.js";
-import { TransportRunnerBase } from "./base.js";
-import { LogId } from "../common/logger.js";
+import { LogId, type LoggerBase } from "../common/logger.js";
+import { type UserConfig } from "../common/config.js";
 import { SessionStore } from "../common/sessionStore.js";
 import type { MCPConnectParams } from "../common/connectionManager.js";
+import { type CreateConnectionManagerFn, TransportRunnerBase } from "./base.js";
 
 const JSON_RPC_ERROR_CODE_PROCESSING_REQUEST_FAILED = -32000;
 const JSON_RPC_ERROR_CODE_SESSION_ID_REQUIRED = -32001;
@@ -18,6 +19,14 @@ export class StreamableHttpRunner<ConnectParams extends MCPConnectParams> extend
     private httpServer: http.Server | undefined;
     private sessionStore!: SessionStore;
 
+    constructor(
+        userConfig: UserConfig,
+        createConnectionManager: CreateConnectionManagerFn<ConnectParams>,
+        additionalLoggers: LoggerBase[] = []
+    ) {
+        super(userConfig, createConnectionManager, additionalLoggers);
+    }
+
     public get serverAddress(): string {
         const result = this.httpServer?.address();
         if (typeof result === "string") {