From 8bb65258fe23b2f3a182d0ad24fc4a89f17b760e Mon Sep 17 00:00:00 2001 From: Tadas Antanavicius <3900899+tadasant@users.noreply.github.com> Date: Thu, 16 Jan 2025 00:41:58 -0800 Subject: [PATCH 1/2] Fix --- docs/concepts/transports.mdx | 19 +++++++++++++++++-- 1 file changed, 17 insertions(+), 2 deletions(-) diff --git a/docs/concepts/transports.mdx b/docs/concepts/transports.mdx index 0c921db..6731f41 100644 --- a/docs/concepts/transports.mdx +++ b/docs/concepts/transports.mdx @@ -126,15 +126,30 @@ Use SSE when: ```typescript + import express from "express"; + + let transport: SSEServerTransport | null = null; + const app = express(); + const server = new Server({ name: "example-server", version: "1.0.0" }, { capabilities: {} }); + + app.get("/sse", (req, res) => { + transport = new SSEServerTransport("/messages", res); + server.connect(transport); + }); - const transport = new SSEServerTransport("/message", response); - await server.connect(transport); + app.post("/messages", (req, res) => { + if (transport) { + transport.handlePostMessage(req, res); + } + }); + + app.listen(3000); ``` From b1f4f72aa50553a8bad9636c37087e0bb94c5bb2 Mon Sep 17 00:00:00 2001 From: Tadas Antanavicius <3900899+tadasant@users.noreply.github.com> Date: Thu, 16 Jan 2025 00:59:51 -0800 Subject: [PATCH 2/2] Fix formatting --- docs/concepts/transports.mdx | 19 ++++++++++--------- 1 file changed, 10 insertions(+), 9 deletions(-) diff --git a/docs/concepts/transports.mdx b/docs/concepts/transports.mdx index 6731f41..08c2768 100644 --- a/docs/concepts/transports.mdx +++ b/docs/concepts/transports.mdx @@ -128,7 +128,6 @@ Use SSE when: ```typescript import express from "express"; - let transport: SSEServerTransport | null = null; const app = express(); const server = new Server({ @@ -138,18 +137,20 @@ Use SSE when: capabilities: {} }); + let transport: SSEServerTransport | null = null; + app.get("/sse", (req, res) => { - transport = new SSEServerTransport("/messages", res); - server.connect(transport); - }); + transport = new SSEServerTransport("/messages", res); + server.connect(transport); + }); app.post("/messages", (req, res) => { - if (transport) { - transport.handlePostMessage(req, res); - } - }); + if (transport) { + transport.handlePostMessage(req, res); + } + }); - app.listen(3000); + app.listen(3000); ```