diff --git a/package.json b/package.json index 8be8f1002..ab3624f9b 100644 --- a/package.json +++ b/package.json @@ -100,4 +100,4 @@ "resolutions": { "strip-ansi": "6.0.1" } -} \ No newline at end of file +} diff --git a/src/cli.ts b/src/cli.ts index f580a624f..fd15b259d 100644 --- a/src/cli.ts +++ b/src/cli.ts @@ -73,6 +73,7 @@ async function runServer(port: number | null) { version: "0.1.0", }, { + capabilities: {}, }, ); @@ -142,6 +143,7 @@ switch (command) { } runClient(args[1], args.slice(2)).catch((error) => { + console.log("hi") console.error(error); process.exit(1); }); @@ -150,7 +152,9 @@ switch (command) { case "server": { const port = args[1] ? parseInt(args[1]) : null; + runServer(port).catch((error) => { + console.error(error); process.exit(1); }); diff --git a/src/client/streamableHttp.ts b/src/client/streamableHttp.ts index 12714ea44..84fc52207 100644 --- a/src/client/streamableHttp.ts +++ b/src/client/streamableHttp.ts @@ -208,6 +208,7 @@ export class StreamableHTTPClientTransport implements Transport { } const response = await (this._fetch ?? fetch)(this._url, { + ...this._requestInit, method: "GET", headers, signal: this._abortController?.signal, diff --git a/src/examples/client/multipleClientsParallel.ts b/src/examples/client/multipleClientsParallel.ts index cc01fc06e..276766ba9 100644 --- a/src/examples/client/multipleClientsParallel.ts +++ b/src/examples/client/multipleClientsParallel.ts @@ -35,7 +35,11 @@ async function createAndRunClient(config: ClientConfig): Promise<{ id: string; r version: '1.0.0' }); - const transport = new StreamableHTTPClientTransport(new URL(serverUrl)); + const transport = new StreamableHTTPClientTransport(new URL(serverUrl), { + requestInit: { + credentials: "include", // ensures cookies/auth headers are sent + }, + }); // Set up client-specific error handler client.onerror = (error) => { diff --git a/src/server/streamableHttp.ts b/src/server/streamableHttp.ts index 3bf84e430..9c60fdcda 100644 --- a/src/server/streamableHttp.ts +++ b/src/server/streamableHttp.ts @@ -236,6 +236,7 @@ export class StreamableHTTPServerTransport implements Transport { private async handleGetRequest(req: IncomingMessage, res: ServerResponse): Promise { // The client MUST include an Accept header, listing text/event-stream as a supported content type. const acceptHeader = req.headers.accept; + console.log('GET cookies:', req.headers.cookie); if (!acceptHeader?.includes("text/event-stream")) { res.writeHead(406).end(JSON.stringify({ jsonrpc: "2.0",