test(eio): bump uWebSockets.js to version 20.48.0

package.json

@@ -68,7 +68,7 @@
     "ts-node": "^10.9.2",
     "tsd": "^0.31.1",
     "typescript": "^5.5.3",
-    "uWebSockets.js": "github:uNetworking/uWebSockets.js#v20.30.0",
+    "uWebSockets.js": "github:uNetworking/uWebSockets.js#v20.48.0",
     "wdio-geckodriver-service": "^5.0.2"
   }
 }

packages/engine.io/test/common.js

@@ -4,6 +4,17 @@ const { Socket } =
     ? require("engine.io-client-v3")
     : require("engine.io-client");
 
+switch (process.env.EIO_WS_ENGINE) {
+  case "uws":
+    console.log(
+      "[WARN] testing with uWebSockets.js instead of Node.js built-in HTTP server",
+    );
+    break;
+  case "eiows":
+    console.log("[WARN] testing with eiows instead of ws");
+    break;
+}
+
 /**
  * Listen shortcut that fires a callback on an ephemeral port.
  */

packages/engine.io/test/server.js

@@ -817,7 +817,7 @@ describe("server", () => {
           .end((err, res) => {
             if (process.env.EIO_WS_ENGINE === "uws") {
               expect(err).to.not.be(null);
-              expect(err.message).to.be("socket hang up");
+              expect(err.status).to.be(404);
             } else {
               expect(err).to.be(null);
               // this should not work, but it is kept for backward-compatibility

packages/socket.io/lib/uws.ts

@@ -135,25 +135,27 @@ export function serveFile(res /* : HttpResponse */, filepath: string) {
   const onDataChunk = (chunk: Buffer) => {
     const arrayBufferChunk = toArrayBuffer(chunk);
 
-    const lastOffset = res.getWriteOffset();
-    const [ok, done] = res.tryEnd(arrayBufferChunk, size);
+    res.cork(() => {
+      const lastOffset = res.getWriteOffset();
+      const [ok, done] = res.tryEnd(arrayBufferChunk, size);
 
-    if (!done && !ok) {
-      readStream.pause();
+      if (!done && !ok) {
+        readStream.pause();
 
-      res.onWritable((offset) => {
-        const [ok, done] = res.tryEnd(
-          arrayBufferChunk.slice(offset - lastOffset),
-          size,
-        );
+        res.onWritable((offset) => {
+          const [ok, done] = res.tryEnd(
+            arrayBufferChunk.slice(offset - lastOffset),
+            size,
+          );
 
-        if (!done && ok) {
-          readStream.resume();
-        }
+          if (!done && ok) {
+            readStream.resume();
+          }
 
-        return ok;
-      });
-    }
+          return ok;
+        });
+      }
+    });
   };
 
   res.onAborted(destroyReadStream);