File tree Expand file tree Collapse file tree 1 file changed +21
-4
lines changed Expand file tree Collapse file tree 1 file changed +21
-4
lines changed Original file line number Diff line number Diff line change @@ -76,9 +76,26 @@ const handleStreamRequest = async <T extends ServerLike>({
76
76
77
77
const body = await getBody ( req ) ;
78
78
79
- if ( sessionId && activeTransports [ sessionId ] ) {
80
- transport = activeTransports [ sessionId ] . transport ;
81
- server = activeTransports [ sessionId ] . server ;
79
+ if ( sessionId ) {
80
+ const activeTransport = activeTransports [ sessionId ] ;
81
+ if ( ! activeTransport ) {
82
+ res . setHeader ( "Content-Type" , "application/json" ) ;
83
+ res . writeHead ( 404 ) . end (
84
+ JSON . stringify ( {
85
+ error : {
86
+ code : - 32001 ,
87
+ message : "Session not found" ,
88
+ } ,
89
+ id : null ,
90
+ jsonrpc : "2.0" ,
91
+ } )
92
+ ) ;
93
+
94
+ return true ;
95
+ }
96
+
97
+ transport = activeTransport . transport ;
98
+ server = activeTransport . server ;
82
99
} else if ( ! sessionId && isInitializeRequest ( body ) ) {
83
100
// Create a new transport for the session
84
101
transport = new StreamableHTTPServerTransport ( {
@@ -146,7 +163,7 @@ const handleStreamRequest = async <T extends ServerLike>({
146
163
} ,
147
164
id : null ,
148
165
jsonrpc : "2.0" ,
149
- } ) ,
166
+ } )
150
167
) ;
151
168
152
169
return true ;
You can’t perform that action at this time.
0 commit comments