File tree Expand file tree Collapse file tree 4 files changed +9
-9
lines changed
Expand file tree Collapse file tree 4 files changed +9
-9
lines changed Original file line number Diff line number Diff line change @@ -6,12 +6,12 @@ import { StdioRunner } from "./transports/stdio.js";
66import { StreamableHttpRunner } from "./transports/streamableHttp.js" ;
77
88async function main ( ) {
9- const runner = config . transport === "stdio" ? new StdioRunner ( ) : new StreamableHttpRunner ( ) ;
9+ const transportRunner = config . transport === "stdio" ? new StdioRunner ( ) : new StreamableHttpRunner ( ) ;
1010
1111 const shutdown = ( ) => {
1212 logger . info ( LogId . serverCloseRequested , "server" , `Server close requested` ) ;
1313
14- runner
14+ transportRunner
1515 . close ( )
1616 . then ( ( ) => {
1717 process . exit ( 0 ) ;
@@ -28,11 +28,11 @@ async function main() {
2828 process . once ( "SIGQUIT" , shutdown ) ;
2929
3030 try {
31- await runner . run ( ) ;
31+ await transportRunner . run ( ) ;
3232 } catch ( error : unknown ) {
3333 logger . emergency ( LogId . serverStartFailure , "server" , `Fatal error running server: ${ error as string } ` ) ;
3434 try {
35- await runner . close ( ) ;
35+ await transportRunner . close ( ) ;
3636 } catch ( error : unknown ) {
3737 logger . error ( LogId . serverCloseFailure , "server" , `Error closing server: ${ error as string } ` ) ;
3838 } finally {
Original file line number Diff line number Diff line change @@ -5,7 +5,7 @@ import { Session } from "../common/session.js";
55import { Telemetry } from "../telemetry/telemetry.js" ;
66import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js" ;
77
8- export abstract class Runner {
8+ export abstract class TransportRunnerBase {
99 protected setupServer ( ) : Server {
1010 const session = new Session ( {
1111 apiBaseUrl : config . apiBaseUrl ,
Original file line number Diff line number Diff line change 11import logger , { LogId } from "../common/logger.js" ;
22import { Server } from "../server.js" ;
3- import { Runner } from "./base.js" ;
3+ import { TransportRunnerBase } from "./base.js" ;
44import { JSONRPCMessage , JSONRPCMessageSchema } from "@modelcontextprotocol/sdk/types.js" ;
55import { EJSON } from "bson" ;
66import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js" ;
@@ -49,7 +49,7 @@ export function createStdioTransport(): StdioServerTransport {
4949 return server ;
5050}
5151
52- export class StdioRunner extends Runner {
52+ export class StdioRunner extends TransportRunnerBase {
5353 private server : Server | undefined ;
5454
5555 async run ( ) {
Original file line number Diff line number Diff line change 11import express from "express" ;
22import http from "http" ;
33import { StreamableHTTPServerTransport } from "@modelcontextprotocol/sdk/server/streamableHttp.js" ;
4- import { Runner } from "./base.js" ;
4+ import { TransportRunnerBase } from "./base.js" ;
55import { config } from "../common/config.js" ;
66import logger , { LogId } from "../common/logger.js" ;
77
@@ -16,7 +16,7 @@ function promiseHandler(
1616 } ;
1717}
1818
19- export class StreamableHttpRunner extends Runner {
19+ export class StreamableHttpRunner extends TransportRunnerBase {
2020 private httpServer : http . Server | undefined ;
2121
2222 async run ( ) {
You can’t perform that action at this time.
0 commit comments