diff --git a/src/server/streamableHttp.ts b/src/server/streamableHttp.ts index 022d1a47..bf3a93c9 100644 --- a/src/server/streamableHttp.ts +++ b/src/server/streamableHttp.ts @@ -133,6 +133,7 @@ export class StreamableHTTPServerTransport implements Transport { sessionId?: string; onclose?: () => void; + ondelete?: (sessionId: string) => void; onerror?: (error: Error) => void; onmessage?: (message: JSONRPCMessage, extra?: MessageExtraInfo) => void; @@ -538,6 +539,7 @@ export class StreamableHTTPServerTransport implements Transport { if (!this.validateProtocolVersion(req, res)) { return; } + this.ondelete?.(this.sessionId!); await this.close(); res.writeHead(200).end(); }