@@ -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
@@ -446,7 +446,7 @@ app.get(
446
446
async ( req , res ) => {
447
447
try {
448
448
console . log (
449
- "New SSE connection request. NOTE: The sse transport is deprecated and has been replaced by StreamableHttp" ,
449
+ "New SSE connection request. NOTE: The SSE transport is deprecated and has been replaced by StreamableHttp" ,
450
450
) ;
451
451
let serverTransport : Transport | undefined ;
452
452
try {
@@ -480,6 +480,7 @@ app.get(
480
480
const webAppTransport = new SSEServerTransport ( endpoint , res ) ;
481
481
webAppTransports . set ( webAppTransport . sessionId , webAppTransport ) ;
482
482
console . log ( "Created client transport" ) ;
483
+
483
484
serverTransports . set ( webAppTransport . sessionId , serverTransport ! ) ;
484
485
console . log ( "Created server transport" ) ;
485
486
0 commit comments