@@ -378,7 +378,6 @@ app.get(
378
378
let serverTransport : Transport | undefined ;
379
379
try {
380
380
serverTransport = await createTransport ( req ) ;
381
- console . log ( "Created server transport" ) ;
382
381
} catch ( error ) {
383
382
if ( error instanceof SseError && error . code === 401 ) {
384
383
console . error (
@@ -396,10 +395,11 @@ app.get(
396
395
const endpoint = `${ prefix } /message` ;
397
396
398
397
const webAppTransport = new SSEServerTransport ( endpoint , res ) ;
398
+ webAppTransports . set ( webAppTransport . sessionId , webAppTransport ) ;
399
399
console . log ( "Created client transport" ) ;
400
400
401
- webAppTransports . set ( webAppTransport . sessionId , webAppTransport ) ;
402
401
serverTransports . set ( webAppTransport . sessionId , serverTransport ) ;
402
+ console . log ( "Created server transport" ) ;
403
403
404
404
await webAppTransport . start ( ) ;
405
405
@@ -488,7 +488,7 @@ app.get(
488
488
async ( req , res ) => {
489
489
try {
490
490
console . log (
491
- "New SSE connection request. NOTE: The sse transport is deprecated and has been replaced by StreamableHttp" ,
491
+ "New SSE connection request. NOTE: The SSE transport is deprecated and has been replaced by StreamableHttp" ,
492
492
) ;
493
493
let serverTransport : Transport | undefined ;
494
494
try {
@@ -522,6 +522,7 @@ app.get(
522
522
const webAppTransport = new SSEServerTransport ( endpoint , res ) ;
523
523
webAppTransports . set ( webAppTransport . sessionId , webAppTransport ) ;
524
524
console . log ( "Created client transport" ) ;
525
+
525
526
serverTransports . set ( webAppTransport . sessionId , serverTransport ! ) ;
526
527
console . log ( "Created server transport" ) ;
527
528
0 commit comments