WebStandardStreamableHTTPServerTransport

Implements the MCP Streamable HTTP transport using Web Standard APIs, handling POST/GET/DELETE, SSE streams, JSON responses, session validation, and resumability.

export class WebStandardStreamableHTTPServerTransport implements Transport {
    // when sessionId is not set (undefined), it means the transport is in stateless mode
    private sessionIdGenerator: (() => string) | undefined;
    private _started: boolean = false;
    private _closed: boolean = false;
    private _streamMapping: Map<string, StreamMapping> = new Map();
    private _requestToStreamMapping: Map<RequestId, string> = new Map();
    private _requestResponseMap: Map<RequestId, JSONRPCMessage> = new Map();
    private _initialized: boolean = false;
    private _enableJsonResponse: boolean = false;
    private _standaloneSseStreamId: string = '_GET_stream';
    private _eventStore?: EventStore;
    private _onsessioninitialized?: ((sessionId: string) => void | Promise<void>) | und

... (truncated -- full source via MCP)