feat: added support for sse

Author: MathurAditya724

biome.json

@@ -9,6 +9,9 @@
       "recommended": true,
       "style": {
         "noNonNullAssertion": "off"
+      },
+      "suspicious": {
+        "noExplicitAny": "warn"
       }
     }
   },
@@ -22,4 +25,4 @@
     "clientKind": "git",
     "useIgnoreFile": true
   }
-}
+}

examples/mcp-sdk/src/index.ts

@@ -1,16 +1,23 @@
-import { StdioServerTransport } from "./transport";
 import { Hono } from "hono";
 import {
   muppet,
   describeTool,
   describePrompt,
   mValidator,
   registerResources,
+  bridge,
 } 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";
 
 const app = new Hono();
+const logger = pino(
+  pino.destination(
+    "/Users/adityamathur/dev/muppet-dev/muppet/examples/mcp-sdk/dist/main.log",
+  ),
+);
 
 // Define a simple hello world tool
 app.post(
@@ -84,12 +91,7 @@ app.post(
 muppet(app, {
   name: "My Muppet",
   version: "1.0.0",
-  transport: new StdioServerTransport(),
-  logger: {
-    stream: pino.destination(
-      "/Users/adityamathur/dev/muppet-dev/muppet/examples/mcp-sdk/dist/main.log",
-    ),
-  },
+  logger,
   resources: {
     https: () => {
       return [
@@ -116,4 +118,14 @@ muppet(app, {
       ];
     },
   },
+}).then((mcp) => {
+  if (!mcp) {
+    throw new Error("MCP not initialized");
+  }
+
+  bridge({
+    mcp,
+    transport: new StdioServerTransport(),
+    logger,
+  });
 });

examples/mcp-sdk/src/transport.ts

@@ -42,8 +42,7 @@
     "@standard-community/standard-json": "^0.1.2",
     "@standard-schema/spec": "^1.0.0",
     "@types/json-schema": "^7.0.15",
-    "hono": "^4.6.13",
-    "pino": "^9.6.0"
+    "hono": "^4.6.13"
   },
   "peerDependenciesMeta": {
     "@hono/node-server": {
@@ -57,9 +56,6 @@
     },
     "@standard-schema/spec": {
       "optional": true
-    },
-    "pino": {
-      "optional": true
     }
   },
   "exports": {
@@ -74,6 +70,7 @@
   },
   "devDependencies": {
     "@hono/event-emitter": "^2.0.0",
+    "pino": "^9.6.0",
     "pkgroll": "^2.5.1"
   }
 }

packages/core/package.json

@@ -4,3 +4,4 @@ export * from "./resources.js";
 export type * from "./types.js";
 export * from "./utils.js";
 export * from "./validator.js";
+export * from "./transport.js";