feat: created the example for sse

Author: MathurAditya724

examples/mcp-sdk/package.json

@@ -3,11 +3,11 @@
   "version": "0.0.1",
   "bin": "./dist/index.js",
   "scripts": {
-    "dev": "tsx ./src/index.ts",
+    "dev": "tsx --watch ./src/index.ts",
     "build": "pkgroll --minify"
   },
   "dependencies": {
-    "@hono/node-server": "^1.13.8",
+    "express": "^4.21.2",
     "@modelcontextprotocol/sdk": "^1.7.0",
     "hono": "^4.7.4",
     "muppet": "workspace:*",
@@ -18,6 +18,7 @@
     "@types/node": "^22.13.10",
     "pkgroll": "^2.11.2",
     "tsx": "^4.19.3",
-    "typescript": "^5.8.2"
+    "typescript": "^5.8.2",
+    "@types/express": "^5.0.1"
   }
-}
+}

examples/mcp-sdk/src/index.ts

@@ -9,8 +9,9 @@ import {
 } from "muppet";
 import z from "zod";
 import pino from "pino";
-// import { SSEServerTransport } from "@modelcontextprotocol/sdk/server/sse.js";
-import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js";
+import { SSEServerTransport } from "@modelcontextprotocol/sdk/server/sse.js";
+import express from "express";
+// import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js";
 
 const app = new Hono();
 const logger = pino(
@@ -88,7 +89,7 @@ app.post(
 
 // "E:/dev/muppet/muppet/examples/mcp-sdk/dist/main.log"
 
-muppet(app, {
+const mcpServer = muppet(app, {
   name: "My Muppet",
   version: "1.0.0",
   logger,
@@ -118,14 +119,56 @@ muppet(app, {
       ];
     },
   },
-}).then((mcp) => {
+});
+
+/**
+ * For Stdio transport
+ */
+// mcpServer.then((mcp) => {
+//   if (!mcp) {
+//     throw new Error("MCP not initialized");
+//   }
+
+//   bridge({
+//     mcp,
+//     transport: new StdioServerTransport(),
+//     logger,
+//   });
+// });
+
+/**
+ * For SSE transport
+ */
+let transport: SSEServerTransport | null = null;
+
+const server = express().use((req, res, next) => {
+  console.log("Request received", req.url);
+
+  next();
+});
+
+server.get("/", async (req, res) => {
+  transport = new SSEServerTransport("/messages", res);
+
+  const mcp = await mcpServer;
+
   if (!mcp) {
     throw new Error("MCP not initialized");
   }
 
   bridge({
     mcp,
-    transport: new StdioServerTransport(),
+    transport,
     logger,
   });
 });
+
+server.post("/messages", (req, res) => {
+  if (transport) {
+    transport.handlePostMessage(req, res);
+  }
+});
+
+server.listen(3001, () => {
+  console.log("Server started on port 3001");
+});

packages/core/src/transport.ts

@@ -31,7 +31,7 @@ export type BridgeOptions<
  * Bridge aka Bifrost, the connection between the app and the transport
  * @param options
  */
-export async function bridge(options: BridgeOptions) {
+export function bridge(options: BridgeOptions) {
   const { mcp: app, transport, logger } = options;
 
   let messageId = 0;
@@ -102,7 +102,7 @@ export async function handleMessage(options: HandleMessageOptions) {
   // If there's no payload, we don't need to send a response. Eg. Notifications
   if (response.status === 204) return null;
 
-  const payload = await response.json();
+  const payload = (await response.json()) as JSONRPCMessage;
 
   logger?.info({ payload }, "Response payload");