@hono/node-server - npm Package Compare versions

Comparing version 1.18.1 to 1.18.2

dist/index.js

@@ -451,29 +451,31 @@ "use strict";
     let currentReadPromise = void 0;
-    let maxReadCount = 2;
-    for (let i = 0; i < maxReadCount; i++) {
-      currentReadPromise ||= reader.read();
-      const chunk = await readWithoutBlocking(currentReadPromise).catch((e) => {
-        console.error(e);
-        done = true;
-      });
-      if (!chunk) {
-        if (i === 1 && resHeaderRecord["transfer-encoding"] !== "chunked") {
-          await new Promise((resolve) => setTimeout(resolve));
-          maxReadCount = 3;
-          continue;
+    if (resHeaderRecord["transfer-encoding"] !== "chunked") {
+      let maxReadCount = 2;
+      for (let i = 0; i < maxReadCount; i++) {
+        currentReadPromise ||= reader.read();
+        const chunk = await readWithoutBlocking(currentReadPromise).catch((e) => {
+          console.error(e);
+          done = true;
+        });
+        if (!chunk) {
+          if (i === 1) {
+            await new Promise((resolve) => setTimeout(resolve));
+            maxReadCount = 3;
+            continue;
+          }
+          break;
         }
-        break;
+        currentReadPromise = void 0;
+        if (chunk.value) {
+          values.push(chunk.value);
+        }
+        if (chunk.done) {
+          done = true;
+          break;
+        }
       }
-      currentReadPromise = void 0;
-      if (chunk.value) {
-        values.push(chunk.value);
+      if (done && !("content-length" in resHeaderRecord)) {
+        resHeaderRecord["content-length"] = values.reduce((acc, value) => acc + value.length, 0);
       }
-      if (chunk.done) {
-        done = true;
-        break;
-      }
     }
-    if (done && !("content-length" in resHeaderRecord)) {
-      resHeaderRecord["content-length"] = values.reduce((acc, value) => acc + value.length, 0);
-    }
     outgoing.writeHead(res.status, resHeaderRecord);
@@ -480,0 +482,0 @@ values.forEach((value) => {

dist/index.mjs

@@ -412,29 +412,31 @@ // src/server.ts
     let currentReadPromise = void 0;
-    let maxReadCount = 2;
-    for (let i = 0; i < maxReadCount; i++) {
-      currentReadPromise ||= reader.read();
-      const chunk = await readWithoutBlocking(currentReadPromise).catch((e) => {
-        console.error(e);
-        done = true;
-      });
-      if (!chunk) {
-        if (i === 1 && resHeaderRecord["transfer-encoding"] !== "chunked") {
-          await new Promise((resolve) => setTimeout(resolve));
-          maxReadCount = 3;
-          continue;
+    if (resHeaderRecord["transfer-encoding"] !== "chunked") {
+      let maxReadCount = 2;
+      for (let i = 0; i < maxReadCount; i++) {
+        currentReadPromise ||= reader.read();
+        const chunk = await readWithoutBlocking(currentReadPromise).catch((e) => {
+          console.error(e);
+          done = true;
+        });
+        if (!chunk) {
+          if (i === 1) {
+            await new Promise((resolve) => setTimeout(resolve));
+            maxReadCount = 3;
+            continue;
+          }
+          break;
         }
-        break;
+        currentReadPromise = void 0;
+        if (chunk.value) {
+          values.push(chunk.value);
+        }
+        if (chunk.done) {
+          done = true;
+          break;
+        }
       }
-      currentReadPromise = void 0;
-      if (chunk.value) {
-        values.push(chunk.value);
+      if (done && !("content-length" in resHeaderRecord)) {
+        resHeaderRecord["content-length"] = values.reduce((acc, value) => acc + value.length, 0);
       }
-      if (chunk.done) {
-        done = true;
-        break;
-      }
     }
-    if (done && !("content-length" in resHeaderRecord)) {
-      resHeaderRecord["content-length"] = values.reduce((acc, value) => acc + value.length, 0);
-    }
     outgoing.writeHead(res.status, resHeaderRecord);
@@ -441,0 +443,0 @@ values.forEach((value) => {

dist/listener.js

@@ -443,29 +443,31 @@ "use strict";
     let currentReadPromise = void 0;
-    let maxReadCount = 2;
-    for (let i = 0; i < maxReadCount; i++) {
-      currentReadPromise ||= reader.read();
-      const chunk = await readWithoutBlocking(currentReadPromise).catch((e) => {
-        console.error(e);
-        done = true;
-      });
-      if (!chunk) {
-        if (i === 1 && resHeaderRecord["transfer-encoding"] !== "chunked") {
-          await new Promise((resolve) => setTimeout(resolve));
-          maxReadCount = 3;
-          continue;
+    if (resHeaderRecord["transfer-encoding"] !== "chunked") {
+      let maxReadCount = 2;
+      for (let i = 0; i < maxReadCount; i++) {
+        currentReadPromise ||= reader.read();
+        const chunk = await readWithoutBlocking(currentReadPromise).catch((e) => {
+          console.error(e);
+          done = true;
+        });
+        if (!chunk) {
+          if (i === 1) {
+            await new Promise((resolve) => setTimeout(resolve));
+            maxReadCount = 3;
+            continue;
+          }
+          break;
         }
-        break;
+        currentReadPromise = void 0;
+        if (chunk.value) {
+          values.push(chunk.value);
+        }
+        if (chunk.done) {
+          done = true;
+          break;
+        }
       }
-      currentReadPromise = void 0;
-      if (chunk.value) {
-        values.push(chunk.value);
+      if (done && !("content-length" in resHeaderRecord)) {
+        resHeaderRecord["content-length"] = values.reduce((acc, value) => acc + value.length, 0);
       }
-      if (chunk.done) {
-        done = true;
-        break;
-      }
     }
-    if (done && !("content-length" in resHeaderRecord)) {
-      resHeaderRecord["content-length"] = values.reduce((acc, value) => acc + value.length, 0);
-    }
     outgoing.writeHead(res.status, resHeaderRecord);
@@ -472,0 +474,0 @@ values.forEach((value) => {

dist/listener.mjs

@@ -409,29 +409,31 @@ // src/listener.ts
     let currentReadPromise = void 0;
-    let maxReadCount = 2;
-    for (let i = 0; i < maxReadCount; i++) {
-      currentReadPromise ||= reader.read();
-      const chunk = await readWithoutBlocking(currentReadPromise).catch((e) => {
-        console.error(e);
-        done = true;
-      });
-      if (!chunk) {
-        if (i === 1 && resHeaderRecord["transfer-encoding"] !== "chunked") {
-          await new Promise((resolve) => setTimeout(resolve));
-          maxReadCount = 3;
-          continue;
+    if (resHeaderRecord["transfer-encoding"] !== "chunked") {
+      let maxReadCount = 2;
+      for (let i = 0; i < maxReadCount; i++) {
+        currentReadPromise ||= reader.read();
+        const chunk = await readWithoutBlocking(currentReadPromise).catch((e) => {
+          console.error(e);
+          done = true;
+        });
+        if (!chunk) {
+          if (i === 1) {
+            await new Promise((resolve) => setTimeout(resolve));
+            maxReadCount = 3;
+            continue;
+          }
+          break;
         }
-        break;
+        currentReadPromise = void 0;
+        if (chunk.value) {
+          values.push(chunk.value);
+        }
+        if (chunk.done) {
+          done = true;
+          break;
+        }
       }
-      currentReadPromise = void 0;
-      if (chunk.value) {
-        values.push(chunk.value);
+      if (done && !("content-length" in resHeaderRecord)) {
+        resHeaderRecord["content-length"] = values.reduce((acc, value) => acc + value.length, 0);
       }
-      if (chunk.done) {
-        done = true;
-        break;
-      }
     }
-    if (done && !("content-length" in resHeaderRecord)) {
-      resHeaderRecord["content-length"] = values.reduce((acc, value) => acc + value.length, 0);
-    }
     outgoing.writeHead(res.status, resHeaderRecord);
@@ -438,0 +440,0 @@ values.forEach((value) => {

dist/server.js

@@ -447,29 +447,31 @@ "use strict";
     let currentReadPromise = void 0;
-    let maxReadCount = 2;
-    for (let i = 0; i < maxReadCount; i++) {
-      currentReadPromise ||= reader.read();
-      const chunk = await readWithoutBlocking(currentReadPromise).catch((e) => {
-        console.error(e);
-        done = true;
-      });
-      if (!chunk) {
-        if (i === 1 && resHeaderRecord["transfer-encoding"] !== "chunked") {
-          await new Promise((resolve) => setTimeout(resolve));
-          maxReadCount = 3;
-          continue;
+    if (resHeaderRecord["transfer-encoding"] !== "chunked") {
+      let maxReadCount = 2;
+      for (let i = 0; i < maxReadCount; i++) {
+        currentReadPromise ||= reader.read();
+        const chunk = await readWithoutBlocking(currentReadPromise).catch((e) => {
+          console.error(e);
+          done = true;
+        });
+        if (!chunk) {
+          if (i === 1) {
+            await new Promise((resolve) => setTimeout(resolve));
+            maxReadCount = 3;
+            continue;
+          }
+          break;
         }
-        break;
+        currentReadPromise = void 0;
+        if (chunk.value) {
+          values.push(chunk.value);
+        }
+        if (chunk.done) {
+          done = true;
+          break;
+        }
       }
-      currentReadPromise = void 0;
-      if (chunk.value) {
-        values.push(chunk.value);
+      if (done && !("content-length" in resHeaderRecord)) {
+        resHeaderRecord["content-length"] = values.reduce((acc, value) => acc + value.length, 0);
       }
-      if (chunk.done) {
-        done = true;
-        break;
-      }
     }
-    if (done && !("content-length" in resHeaderRecord)) {
-      resHeaderRecord["content-length"] = values.reduce((acc, value) => acc + value.length, 0);
-    }
     outgoing.writeHead(res.status, resHeaderRecord);
@@ -476,0 +478,0 @@ values.forEach((value) => {

dist/server.mjs

@@ -412,29 +412,31 @@ // src/server.ts
     let currentReadPromise = void 0;
-    let maxReadCount = 2;
-    for (let i = 0; i < maxReadCount; i++) {
-      currentReadPromise ||= reader.read();
-      const chunk = await readWithoutBlocking(currentReadPromise).catch((e) => {
-        console.error(e);
-        done = true;
-      });
-      if (!chunk) {
-        if (i === 1 && resHeaderRecord["transfer-encoding"] !== "chunked") {
-          await new Promise((resolve) => setTimeout(resolve));
-          maxReadCount = 3;
-          continue;
+    if (resHeaderRecord["transfer-encoding"] !== "chunked") {
+      let maxReadCount = 2;
+      for (let i = 0; i < maxReadCount; i++) {
+        currentReadPromise ||= reader.read();
+        const chunk = await readWithoutBlocking(currentReadPromise).catch((e) => {
+          console.error(e);
+          done = true;
+        });
+        if (!chunk) {
+          if (i === 1) {
+            await new Promise((resolve) => setTimeout(resolve));
+            maxReadCount = 3;
+            continue;
+          }
+          break;
         }
-        break;
+        currentReadPromise = void 0;
+        if (chunk.value) {
+          values.push(chunk.value);
+        }
+        if (chunk.done) {
+          done = true;
+          break;
+        }
       }
-      currentReadPromise = void 0;
-      if (chunk.value) {
-        values.push(chunk.value);
+      if (done && !("content-length" in resHeaderRecord)) {
+        resHeaderRecord["content-length"] = values.reduce((acc, value) => acc + value.length, 0);
       }
-      if (chunk.done) {
-        done = true;
-        break;
-      }
     }
-    if (done && !("content-length" in resHeaderRecord)) {
-      resHeaderRecord["content-length"] = values.reduce((acc, value) => acc + value.length, 0);
-    }
     outgoing.writeHead(res.status, resHeaderRecord);
@@ -441,0 +443,0 @@ values.forEach((value) => {

dist/vercel.js

@@ -445,29 +445,31 @@ "use strict";
     let currentReadPromise = void 0;
-    let maxReadCount = 2;
-    for (let i = 0; i < maxReadCount; i++) {
-      currentReadPromise ||= reader.read();
-      const chunk = await readWithoutBlocking(currentReadPromise).catch((e) => {
-        console.error(e);
-        done = true;
-      });
-      if (!chunk) {
-        if (i === 1 && resHeaderRecord["transfer-encoding"] !== "chunked") {
-          await new Promise((resolve) => setTimeout(resolve));
-          maxReadCount = 3;
-          continue;
+    if (resHeaderRecord["transfer-encoding"] !== "chunked") {
+      let maxReadCount = 2;
+      for (let i = 0; i < maxReadCount; i++) {
+        currentReadPromise ||= reader.read();
+        const chunk = await readWithoutBlocking(currentReadPromise).catch((e) => {
+          console.error(e);
+          done = true;
+        });
+        if (!chunk) {
+          if (i === 1) {
+            await new Promise((resolve) => setTimeout(resolve));
+            maxReadCount = 3;
+            continue;
+          }
+          break;
         }
-        break;
+        currentReadPromise = void 0;
+        if (chunk.value) {
+          values.push(chunk.value);
+        }
+        if (chunk.done) {
+          done = true;
+          break;
+        }
       }
-      currentReadPromise = void 0;
-      if (chunk.value) {
-        values.push(chunk.value);
+      if (done && !("content-length" in resHeaderRecord)) {
+        resHeaderRecord["content-length"] = values.reduce((acc, value) => acc + value.length, 0);
       }
-      if (chunk.done) {
-        done = true;
-        break;
-      }
     }
-    if (done && !("content-length" in resHeaderRecord)) {
-      resHeaderRecord["content-length"] = values.reduce((acc, value) => acc + value.length, 0);
-    }
     outgoing.writeHead(res.status, resHeaderRecord);
@@ -474,0 +476,0 @@ values.forEach((value) => {

dist/vercel.mjs

@@ -409,29 +409,31 @@ // src/listener.ts
     let currentReadPromise = void 0;
-    let maxReadCount = 2;
-    for (let i = 0; i < maxReadCount; i++) {
-      currentReadPromise ||= reader.read();
-      const chunk = await readWithoutBlocking(currentReadPromise).catch((e) => {
-        console.error(e);
-        done = true;
-      });
-      if (!chunk) {
-        if (i === 1 && resHeaderRecord["transfer-encoding"] !== "chunked") {
-          await new Promise((resolve) => setTimeout(resolve));
-          maxReadCount = 3;
-          continue;
+    if (resHeaderRecord["transfer-encoding"] !== "chunked") {
+      let maxReadCount = 2;
+      for (let i = 0; i < maxReadCount; i++) {
+        currentReadPromise ||= reader.read();
+        const chunk = await readWithoutBlocking(currentReadPromise).catch((e) => {
+          console.error(e);
+          done = true;
+        });
+        if (!chunk) {
+          if (i === 1) {
+            await new Promise((resolve) => setTimeout(resolve));
+            maxReadCount = 3;
+            continue;
+          }
+          break;
         }
-        break;
+        currentReadPromise = void 0;
+        if (chunk.value) {
+          values.push(chunk.value);
+        }
+        if (chunk.done) {
+          done = true;
+          break;
+        }
       }
-      currentReadPromise = void 0;
-      if (chunk.value) {
-        values.push(chunk.value);
+      if (done && !("content-length" in resHeaderRecord)) {
+        resHeaderRecord["content-length"] = values.reduce((acc, value) => acc + value.length, 0);
       }
-      if (chunk.done) {
-        done = true;
-        break;
-      }
     }
-    if (done && !("content-length" in resHeaderRecord)) {
-      resHeaderRecord["content-length"] = values.reduce((acc, value) => acc + value.length, 0);
-    }
     outgoing.writeHead(res.status, resHeaderRecord);
@@ -438,0 +440,0 @@ values.forEach((value) => {

package.json

 {
   "name": "@hono/node-server",
-  "version": "1.18.1",
+  "version": "1.18.2",
   "description": "Node.js Adapter for Hono",
@@ -5,0 +5,0 @@ "main": "dist/index.js",

New alerts

Network access

Supply chain risk

This module accesses the network.

Found 3 instances in 1 package

Filesystem access

Supply chain risk

Accesses the file system, and could potentially read sensitive data.

Found 1 instance in 1 package

Fixed alerts

Network access

Supply chain risk

This module accesses the network.

Found 3 instances in 1 package

Filesystem access

Supply chain risk

Accesses the file system, and could potentially read sensitive data.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

200906

0.27%

Lines of code

5917

0.27%

No dependency changes