v0.3.21-beta.2

Author: viktormarinho

channel.ts

@@ -207,21 +207,28 @@ export const makeChanStream = (
   const reader = stream.getReader();
   const processStream = async () => {
     try {
+      console.log("[makeChanStream] Starting to process stream");
       while (true) {
         const { done, value } = await reader.read();
-        if (done) break;
+        if (done) {
+          console.log("[makeChanStream] Stream done");
+          break;
+        }
+        console.log(`[makeChanStream] Sending chunk of size ${value.length}`);
         await chan.send(value);
       }
+      console.log("[makeChanStream] Closing channel");
       chan.close();
     } catch (err) {
       // Handle errors gracefully, especially for Node.js/undici
+      console.error("[makeChanStream] Error processing stream:", err);
       if (!chan.signal.aborted) {
-        console.error("error processing stream", err);
         chan.close();
       }
     }
   };
   processStream().catch((err) => {
+    console.error("[makeChanStream] Unhandled error in processStream:", err);
     if (!chan.signal.aborted) {
       console.error("error processing stream", err);
     }

handlers.client.ts

@@ -279,6 +279,7 @@ async function doFetch(
       headers[key].push(value);
     });
 
+    console.log(`[doFetch] Sending response-start for ${request.id}, status: ${response.status}`);
     await clientCh.send({
       type: "response-start",
       id: request.id,
@@ -288,17 +289,35 @@ async function doFetch(
     });
 
     const body = response?.body;
-    const stream = body ? makeChanStream(body) : undefined;
-    for await (const chunk of stream?.recv(signal) ?? []) {
-      await clientCh.send({
-        type: "data",
-        id: request.id,
-        chunk,
-      });
+    console.log(`[doFetch] Response body for ${request.id}:`, body ? 'present' : 'null');
+    
+    if (body) {
+      try {
+        const stream = makeChanStream(body);
+        console.log(`[doFetch] Reading response stream for ${request.id}`);
+        for await (const chunk of stream.recv(signal)) {
+          console.log(`[doFetch] Sending chunk for ${request.id}, size: ${chunk.length}`);
+          await clientCh.send({
+            type: "data",
+            id: request.id,
+            chunk,
+          });
+        }
+        console.log(`[doFetch] Finished reading response stream for ${request.id}`);
+      } catch (streamError) {
+        console.error(`[doFetch] Stream error for ${request.id}:`, streamError);
+        if (!signal.aborted) {
+          throw streamError;
+        }
+      }
     }
+    
     if (signal.aborted) {
+      console.log(`[doFetch] Request ${request.id} was aborted`);
       return;
     }
+    
+    console.log(`[doFetch] Sending data-end for ${request.id}`);
     await clientCh.send({
       type: "data-end",
       id: request.id,

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@deco-cx/warp-node",
-  "version": "0.3.21-beta.1",
+  "version": "0.3.21-beta.2",
   "description": "WebSocket tunneling library for Node.js and other runtimes",
   "type": "module",
   "main": "dist/mod.js",