fix: Fix the issue of incorrect data type of ReadableStream on edge platform

Author: Amery2010

package.json

@@ -1,7 +1,7 @@
 {
   "name": "deep-research",
   "description": "Use any LLMs (Large Language Models) for Deep Research. Support SSE API and MCP server.",
-  "version": "0.9.4",
+  "version": "0.9.5",
   "license": "MIT",
   "repository": {
     "url": "https://github.com/u14app/deep-research"

src/libs/mcp-server/sse.ts

@@ -112,7 +112,7 @@ const nanoid = customAlphabet("1234567890abcdef");
  */
 export class SSEServerTransport implements Transport {
   // Store the ReadableStream controller for the SSE stream
-  private _sseController?: ReadableStreamController<string>;
+  private _sseController?: ReadableStreamController<Uint8Array>;
   private _started: boolean = false;
   private _sessionId: string;
   // Counter for generating SSE event IDs (optional but good practice for SSE)
@@ -169,7 +169,8 @@ export class SSEServerTransport implements Transport {
     };
 
     // Create the ReadableStream for the SSE body
-    const stream = new ReadableStream<string>({
+    const encoder = new TextEncoder();
+    const stream = new ReadableStream<Uint8Array>({
       start: (controller) => {
         this._sseController = controller; // Store the controller to send messages later
         console.log(`[${this._sessionId}] SSE stream started.`);
@@ -189,7 +190,7 @@ export class SSEServerTransport implements Transport {
         // Let's add a simple auto-incrementing ID to all events for consistency.
         const endpointEventData = `event: endpoint\ndata: ${relativeUrlWithSession}\n\n`;
         try {
-          controller.enqueue(endpointEventData);
+          controller.enqueue(encoder.encode(endpointEventData));
           console.log(
             `[${this._sessionId}] Sent 'endpoint' event: ${relativeUrlWithSession}`
           );
@@ -407,6 +408,7 @@ export class SSEServerTransport implements Transport {
       throw error;
     }
 
+    const encoder = new TextEncoder();
     // Format the message as an SSE event
     const eventData = `event: message\nid: ${this
       ._messageIdCounter++}\ndata: ${JSON.stringify(message)}\n\n`;
@@ -425,7 +427,7 @@ export class SSEServerTransport implements Transport {
         this._sseController = undefined;
         throw error;
       }
-      this._sseController.enqueue(eventData);
+      this._sseController.enqueue(encoder.encode(eventData));
       // console.log(`[${this._sessionId}] Sent message (SSE event ID: ${this._messageIdCounter - 1})`); // Debug log
     } catch (error) {
       // Catch synchronous errors during enqueue (e.g. controller already errored)

src/libs/mcp-server/streamableHttp.ts

@@ -170,7 +170,7 @@ export class StreamableHTTPServerTransport implements Transport {
   private sessionIdGenerator: (() => string) | undefined;
   private _started: boolean = false;
   // Map streamId to the ReadableStream controller for SSE streams
-  private _streamMapping: Map<string, ReadableStreamController<string>> =
+  private _streamMapping: Map<string, ReadableStreamController<Uint8Array>> =
     new Map();
   // Maps request ID to stream ID for POST requests resulting in SSE streams
   private _requestToStreamMapping: Map<RequestId, string> = new Map();
@@ -366,10 +366,10 @@ export class StreamableHTTPServerTransport implements Transport {
   private createSSEStream(
     streamId: string,
     options?: { lastEventId?: string }
-  ): ReadableStream<string> {
-    let controller: ReadableStreamController<string>;
+  ): ReadableStream<Uint8Array> {
+    let controller: ReadableStreamController<Uint8Array>;
 
-    const stream = new ReadableStream<string>({
+    const stream = new ReadableStream<Uint8Array>({
       start: async (c) => {
         controller = c;
         // Store the controller keyed by streamId
@@ -478,7 +478,7 @@ export class StreamableHTTPServerTransport implements Transport {
    * Returns false if the enqueue fails (e.g., stream is closed or full).
    */
   private writeSSEEvent(
-    controller: ReadableStreamController<string>,
+    controller: ReadableStreamController<Uint8Array>,
     message: JSONRPCMessage,
     eventId?: string
   ): boolean {
@@ -506,7 +506,8 @@ export class StreamableHTTPServerTransport implements Transport {
 
     // enqueue returns void, success is implied unless it throws or controller is closed asynchronously
     try {
-      controller.enqueue(eventData);
+      const encoder = new TextEncoder();
+      controller.enqueue(encoder.encode(eventData));
       return true; // Indicate success
     } catch (error) {
       // Catch synchronous errors during enqueue (e.g. controller is already errored)