@@ -254,14 +254,16 @@ app.get("/stdio", async (req, res) => {
254
254
console . log ( "Created web app transport" ) ;
255
255
256
256
await webAppTransport . start ( ) ;
257
-
257
+
258
258
// Handle client disconnection
259
- res . on ( 'close' , ( ) => {
260
- console . log ( `Client disconnected from session ${ webAppTransport . sessionId } ` ) ;
259
+ res . on ( "close" , ( ) => {
260
+ console . log (
261
+ `Client disconnected from session ${ webAppTransport . sessionId } ` ,
262
+ ) ;
261
263
// Clean up the transport map
262
264
webAppTransports . delete ( webAppTransport . sessionId ) ;
263
265
} ) ;
264
-
266
+
265
267
// Create a stderr handler that checks connection state
266
268
const stderrHandler = ( chunk : Buffer ) => {
267
269
try {
@@ -281,14 +283,19 @@ app.get("/stdio", async (req, res) => {
281
283
webAppTransports . delete ( webAppTransport . sessionId ) ;
282
284
}
283
285
} ;
284
-
286
+
285
287
if ( ( backingServerTransport as StdioClientTransport ) . stderr ) {
286
- ( backingServerTransport as StdioClientTransport ) . stderr ! . on ( "data" , stderrHandler ) ;
288
+ ( backingServerTransport as StdioClientTransport ) . stderr ! . on (
289
+ "data" ,
290
+ stderrHandler ,
291
+ ) ;
287
292
288
293
// Store the handler reference so we can remove it when client disconnects
289
- res . on ( ' close' , ( ) => {
294
+ res . on ( " close" , ( ) => {
290
295
if ( ( backingServerTransport as StdioClientTransport ) . stderr ) {
291
- ( backingServerTransport as StdioClientTransport ) . stderr ! . removeListener ( "data" , stderrHandler ) ;
296
+ (
297
+ backingServerTransport as StdioClientTransport
298
+ ) . stderr ! . removeListener ( "data" , stderrHandler ) ;
292
299
}
293
300
} ) ;
294
301
}
0 commit comments