From 9db5b8363c25507473b23835e70726730f8b050e Mon Sep 17 00:00:00 2001 From: ihrpr Date: Wed, 23 Apr 2025 22:32:56 +0100 Subject: [PATCH] fix sse examples --- src/examples/server/simpleSseServer.ts | 4 ---- src/examples/server/sseAndStreamableHttpCompatibleServer.ts | 2 +- 2 files changed, 1 insertion(+), 5 deletions(-) diff --git a/src/examples/server/simpleSseServer.ts b/src/examples/server/simpleSseServer.ts index cae3be30..c3417920 100644 --- a/src/examples/server/simpleSseServer.ts +++ b/src/examples/server/simpleSseServer.ts @@ -102,10 +102,6 @@ app.get('/mcp', async (req: Request, res: Response) => { const server = getServer(); await server.connect(transport); - // Start the SSE transport to begin streaming - // This sends an initial 'endpoint' event with the session ID in the URL - await transport.start(); - console.log(`Established SSE stream with session ID: ${sessionId}`); } catch (error) { console.error('Error establishing SSE stream:', error); diff --git a/src/examples/server/sseAndStreamableHttpCompatibleServer.ts b/src/examples/server/sseAndStreamableHttpCompatibleServer.ts index 7a0ab04e..ded110a1 100644 --- a/src/examples/server/sseAndStreamableHttpCompatibleServer.ts +++ b/src/examples/server/sseAndStreamableHttpCompatibleServer.ts @@ -194,7 +194,7 @@ app.post("/messages", async (req: Request, res: Response) => { return; } if (transport) { - await transport.handlePostMessage(req, res); + await transport.handlePostMessage(req, res, req.body); } else { res.status(400).send('No transport found for sessionId'); }