Add support for SSE notifications endpoint

Signed-off-by: Marcos Candeia <[email protected]>

Author: mcandeia

deno.json

@@ -1,6 +1,6 @@
 {
   "name": "@deco/mcp",
-  "version": "0.2.2",
+  "version": "0.2.3",
   "exports": "./mod.ts",
   "tasks": {
     "check": "deno fmt && deno lint && deno check mod.ts"

mcp/stateless-client.ts

@@ -158,7 +158,7 @@ export class StatelessClientTransport implements Transport {
 
       // Handle streaming responses
       if (response.headers.get("content-type")?.includes("text/event-stream")) {
-        await this._handleStreamingResponse(response);
+        this._handleStreamingResponse(response);
         return;
       }
 

mcp/stateless.ts

@@ -76,20 +76,17 @@ export class StatelessServerTransport implements Transport {
   /**
    * Determines if a request should be upgraded to streaming based on message type
    */
-  private shouldUpgradeToStreaming(_message: JSONRPCMessage): boolean {
+  private shouldUpgradeToStreaming(message: JSONRPCMessage): boolean {
     // Implement logic to determine if streaming is needed
     // For example, based on method name or parameters
-    return false; // Default to non-streaming
+    return message.method === "notifications/initialized"; // Default to non-streaming
   }
 
   start(): Promise<void> {
     return Promise.resolve();
   }
 
   close(): Promise<void> {
-    this._controller?.close();
-    this._controller = undefined;
-    this.onclose?.();
     return Promise.resolve();
   }