@@ -22,7 +22,7 @@ export function createHttpTransport(): StreamableHTTPServerTransport {
2222 logger . error (
2323 LogId . streamableHttpTransportRequestFailure ,
2424 "streamableHttpTransport" ,
25- `Error handling request: ${ error } `
25+ `Error handling request: ${ error instanceof Error ? error . message : String ( error ) } `
2626 ) ;
2727 res . sendStatus ( 400 ) ;
2828 }
@@ -35,7 +35,7 @@ export function createHttpTransport(): StreamableHTTPServerTransport {
3535 logger . error (
3636 LogId . streamableHttpTransportRequestFailure ,
3737 "streamableHttpTransport" ,
38- `Error handling request: ${ error } `
38+ `Error handling request: ${ error instanceof Error ? error . message : String ( error ) } `
3939 ) ;
4040 res . sendStatus ( 400 ) ;
4141 }
@@ -48,7 +48,7 @@ export function createHttpTransport(): StreamableHTTPServerTransport {
4848 logger . error (
4949 LogId . streamableHttpTransportRequestFailure ,
5050 "streamableHttpTransport" ,
51- `Error handling request: ${ error } `
51+ `Error handling request: ${ error instanceof Error ? error . message : String ( error ) } `
5252 ) ;
5353 res . sendStatus ( 400 ) ;
5454 }
@@ -62,26 +62,19 @@ export function createHttpTransport(): StreamableHTTPServerTransport {
6262 ) ;
6363 } ) ;
6464
65- transport . onclose = async ( ) => {
66- try {
67- logger . info ( LogId . streamableHttpTransportCloseRequested , "streamableHttpTransport" , `Closing server` ) ;
68- await new Promise < void > ( ( resolve , reject ) => {
69- server . close ( ( err ?: Error ) => {
70- if ( err ) {
71- reject ( err ) ;
72- } else {
73- resolve ( ) ;
74- }
75- } ) ;
76- } ) ;
65+ transport . onclose = ( ) => {
66+ logger . info ( LogId . streamableHttpTransportCloseRequested , "streamableHttpTransport" , `Closing server` ) ;
67+ server . close ( ( err ?: Error ) => {
68+ if ( err ) {
69+ logger . error (
70+ LogId . streamableHttpTransportCloseFailure ,
71+ "streamableHttpTransport" ,
72+ `Error closing server: ${ err . message } `
73+ ) ;
74+ return ;
75+ }
7776 logger . info ( LogId . streamableHttpTransportCloseSuccess , "streamableHttpTransport" , `Server closed` ) ;
78- } catch ( error : unknown ) {
79- logger . error (
80- LogId . streamableHttpTransportCloseFailure ,
81- "streamableHttpTransport" ,
82- `Error closing server: ${ error instanceof Error ? error . message : String ( error ) } `
83- ) ;
84- }
77+ } ) ;
8578 } ;
8679
8780 return transport ;
0 commit comments