@@ -98,7 +98,7 @@ const createTransport = async (req: express.Request): Promise<Transport> => {
98
98
return transport ;
99
99
} else if ( transportType === "streamable - http ") {
100
100
const headers : HeadersInit = {
101
- Accept : "text/event-stream, application/json"
101
+ Accept : "text/event-stream, application/json" ,
102
102
} ;
103
103
104
104
for ( const key of STREAMABLE_HTTP_HEADERS_PASSTHROUGH ) {
@@ -129,7 +129,6 @@ const createTransport = async (req: express.Request): Promise<Transport> => {
129
129
130
130
let backingServerTransport : Transport | undefined ;
131
131
132
-
133
132
app . get ( "/mcp" , async ( req , res ) => {
134
133
try {
135
134
console . log ( "New streamable-http connection" ) ;
@@ -227,15 +226,18 @@ app.get("/stdio", async (req, res) => {
227
226
console . log ( "Created web app transport" ) ;
228
227
229
228
await webAppTransport . start ( ) ;
230
- ( backingServerTransport as StdioClientTransport ) . stderr ! . on ( "data" , ( chunk ) => {
229
+ ( backingServerTransport as StdioClientTransport ) . stderr ! . on (
230
+ "data" ,
231
+ ( chunk ) => {
231
232
webAppTransport . send ( {
232
233
jsonrpc : "2.0" ,
233
234
method : "notifications/stderr" ,
234
235
params : {
235
236
content : chunk . toString ( ) ,
236
237
} ,
237
238
} ) ;
238
- } ) ;
239
+ } ,
240
+ ) ;
239
241
240
242
mcpProxy ( {
241
243
transportToClient : webAppTransport ,
@@ -251,7 +253,9 @@ app.get("/stdio", async (req, res) => {
251
253
252
254
app . get ( "/sse" , async ( req , res ) => {
253
255
try {
254
- console . log ( "New SSE connection. NOTE: The sse transport is deprecated and has been replaced by streamable-http" ) ;
256
+ console . log (
257
+ "New SSE connection. NOTE: The sse transport is deprecated and has been replaced by streamable-http" ,
258
+ ) ;
255
259
256
260
try {
257
261
await backingServerTransport ?. close ( ) ;
0 commit comments