@elysiajs/node - npm Package Compare versions

Comparing version 1.4.2 to 1.4.3

dist/cjs/handle.js

@@ -31,3 +31,3 @@ "use strict";
 var import_srvx2 = require("srvx");
-var import_utils2 = require("elysia/adapter/utils");
+var import_utils3 = require("elysia/adapter/utils");
 
@@ -37,2 +37,3 @@ // src/utils.ts
 var import_utils = require("elysia/utils");
+var import_utils2 = require("elysia/adapter/utils");
 var handleFile = (response, set2) => {
@@ -79,6 +80,26 @@ if (response instanceof Promise)
 };
+var createResponseHandler = (handler) => {
+  const handleStream2 = (0, import_utils2.createStreamHandler)(handler);
+  return (response, set2, request) => {
+    const newResponse = new import_srvx.FastResponse(response.body, {
+      headers: Object.assign(
+        // @ts-ignore
+        Object.fromEntries(response.headers.entries()),
+        set2.headers
+      ),
+      status: response.status ?? set2.status
+    });
+    if (!newResponse.headers.has("content-length") && newResponse.headers.get("transfer-encoding") === "chunked")
+      return handleStream2(
+        (0, import_utils2.streamResponse)(newResponse),
+        (0, import_utils2.responseToSetHeaders)(newResponse, set2),
+        request
+      );
+    return newResponse;
+  };
+};
 
 // src/handle.ts
 var import_file = require("elysia/universal/file");
-var import_utils4 = require("elysia/utils");
+var import_utils5 = require("elysia/utils");
 var import_cookies = require("elysia/cookies");
@@ -104,4 +125,4 @@ var import_error = require("elysia/error");
 var mapResponse = (response, set2, request) => {
-  if ((0, import_utils4.isNotEmpty)(set2.headers) || set2.status !== 200 || set2.cookie) {
-    (0, import_utils2.handleSet)(set2);
+  if ((0, import_utils5.isNotEmpty)(set2.headers) || set2.status !== 200 || set2.cookie) {
+    (0, import_utils3.handleSet)(set2);
     switch (response?.constructor?.name) {
@@ -208,4 +229,4 @@ case "String":
     return handleStream(
-      (0, import_utils2.streamResponse)(response),
-      (0, import_utils2.responseToSetHeaders)(response, set2),
+      (0, import_utils3.streamResponse)(response),
+      (0, import_utils3.responseToSetHeaders)(response, set2),
       request
@@ -222,4 +243,4 @@ );
   if (response === void 0 || response === null) return;
-  if ((0, import_utils4.isNotEmpty)(set2.headers) || set2.status !== 200 || set2.cookie) {
-    (0, import_utils2.handleSet)(set2);
+  if ((0, import_utils5.isNotEmpty)(set2.headers) || set2.status !== 200 || set2.cookie) {
+    (0, import_utils3.handleSet)(set2);
     switch (response?.constructor?.name) {
@@ -373,4 +394,4 @@ case "String":
           return handleStream(
-            (0, import_utils2.streamResponse)(response),
-            (0, import_utils2.responseToSetHeaders)(response),
+            (0, import_utils3.streamResponse)(response),
+            (0, import_utils3.responseToSetHeaders)(response),
             request
@@ -488,4 +509,4 @@ );
         return handleStream(
-          (0, import_utils2.streamResponse)(response),
-          (0, import_utils2.responseToSetHeaders)(response),
+          (0, import_utils3.streamResponse)(response),
+          (0, import_utils3.responseToSetHeaders)(response),
           request
@@ -562,7 +583,7 @@ );
 };
-var handleResponse = (0, import_utils2.createResponseHandler)({
+var handleResponse = createResponseHandler({
   mapResponse,
   mapCompactResponse
 });
-var handleStream = (0, import_utils2.createStreamHandler)({
+var handleStream = (0, import_utils3.createStreamHandler)({
   mapResponse,
@@ -569,0 +590,0 @@ mapCompactResponse

dist/cjs/index.js

@@ -28,3 +28,3 @@ "use strict";
 var import_web_standard = require("elysia/adapter/web-standard");
-var import_utils7 = require("elysia/utils");
+var import_utils8 = require("elysia/utils");
 var import_crossws = require("crossws");
@@ -214,3 +214,3 @@ var import_server = require("crossws/server");
 var import_srvx2 = require("srvx");
-var import_utils4 = require("elysia/adapter/utils");
+var import_utils5 = require("elysia/adapter/utils");
 
@@ -220,2 +220,3 @@ // src/utils.ts
 var import_utils3 = require("elysia/utils");
+var import_utils4 = require("elysia/adapter/utils");
 var handleFile = (response, set2) => {
@@ -262,6 +263,26 @@ if (response instanceof Promise)
 };
+var createResponseHandler = (handler) => {
+  const handleStream2 = (0, import_utils4.createStreamHandler)(handler);
+  return (response, set2, request) => {
+    const newResponse = new import_srvx.FastResponse(response.body, {
+      headers: Object.assign(
+        // @ts-ignore
+        Object.fromEntries(response.headers.entries()),
+        set2.headers
+      ),
+      status: response.status ?? set2.status
+    });
+    if (!newResponse.headers.has("content-length") && newResponse.headers.get("transfer-encoding") === "chunked")
+      return handleStream2(
+        (0, import_utils4.streamResponse)(newResponse),
+        (0, import_utils4.responseToSetHeaders)(newResponse, set2),
+        request
+      );
+    return newResponse;
+  };
+};
 
 // src/handle.ts
 var import_file = require("elysia/universal/file");
-var import_utils6 = require("elysia/utils");
+var import_utils7 = require("elysia/utils");
 var import_cookies = require("elysia/cookies");
@@ -287,4 +308,4 @@ var import_error = require("elysia/error");
 var mapResponse = (response, set2, request) => {
-  if ((0, import_utils6.isNotEmpty)(set2.headers) || set2.status !== 200 || set2.cookie) {
-    (0, import_utils4.handleSet)(set2);
+  if ((0, import_utils7.isNotEmpty)(set2.headers) || set2.status !== 200 || set2.cookie) {
+    (0, import_utils5.handleSet)(set2);
     switch (response?.constructor?.name) {
@@ -391,4 +412,4 @@ case "String":
     return handleStream(
-      (0, import_utils4.streamResponse)(response),
-      (0, import_utils4.responseToSetHeaders)(response, set2),
+      (0, import_utils5.streamResponse)(response),
+      (0, import_utils5.responseToSetHeaders)(response, set2),
       request
@@ -405,4 +426,4 @@ );
   if (response === void 0 || response === null) return;
-  if ((0, import_utils6.isNotEmpty)(set2.headers) || set2.status !== 200 || set2.cookie) {
-    (0, import_utils4.handleSet)(set2);
+  if ((0, import_utils7.isNotEmpty)(set2.headers) || set2.status !== 200 || set2.cookie) {
+    (0, import_utils5.handleSet)(set2);
     switch (response?.constructor?.name) {
@@ -556,4 +577,4 @@ case "String":
           return handleStream(
-            (0, import_utils4.streamResponse)(response),
-            (0, import_utils4.responseToSetHeaders)(response),
+            (0, import_utils5.streamResponse)(response),
+            (0, import_utils5.responseToSetHeaders)(response),
             request
@@ -671,4 +692,4 @@ );
         return handleStream(
-          (0, import_utils4.streamResponse)(response),
-          (0, import_utils4.responseToSetHeaders)(response),
+          (0, import_utils5.streamResponse)(response),
+          (0, import_utils5.responseToSetHeaders)(response),
           request
@@ -745,7 +766,7 @@ );
 };
-var handleResponse = (0, import_utils4.createResponseHandler)({
+var handleResponse = createResponseHandler({
   mapResponse,
   mapCompactResponse
 });
-var handleStream = (0, import_utils4.createStreamHandler)({
+var handleStream = (0, import_utils5.createStreamHandler)({
   mapResponse,
@@ -771,3 +792,3 @@ mapCompactResponse
         if (typeof options === "string") {
-          if (!(0, import_utils7.isNumericString)(options))
+          if (!(0, import_utils8.isNumericString)(options))
             throw new Error("Port must be a numeric value");
@@ -778,3 +799,3 @@ options = parseInt(options);
           async upgrade(request) {
-            const id = request.wsId = (0, import_utils7.randomId)();
+            const id = request.wsId = (0, import_utils8.randomId)();
             const response = await app.handle(request);
@@ -830,3 +851,3 @@ const context = ws.context[id];
           ...server,
-          id: (0, import_utils7.randomId)(),
+          id: (0, import_utils8.randomId)(),
           development: process.env.NODE_ENV !== "production",
@@ -833,0 +854,0 @@ fetch: app.fetch,

dist/cjs/utils.d.ts

 import type { ReadStream } from 'fs';
 import type { Context } from 'elysia/context';
 export declare const handleFile: (response: ReadStream | File | Blob, set?: Context["set"]) => Response;
+interface CreateHandlerParameter {
+    mapResponse(response: unknown, set: Context['set'], request?: Request): Response;
+    mapCompactResponse(response: unknown, request?: Request): Response;
+}
+export declare const createResponseHandler: (handler: CreateHandlerParameter) => (response: Response, set: Context["set"], request?: Request) => any;
+export {};

dist/cjs/utils.js

@@ -23,2 +23,3 @@ "use strict";
 __export(utils_exports, {
+  createResponseHandler: () => createResponseHandler,
   handleFile: () => handleFile
@@ -29,2 +30,3 @@ });
 var import_utils = require("elysia/utils");
+var import_utils2 = require("elysia/adapter/utils");
 var handleFile = (response, set) => {
@@ -71,5 +73,26 @@ if (response instanceof Promise)
 };
+var createResponseHandler = (handler) => {
+  const handleStream = (0, import_utils2.createStreamHandler)(handler);
+  return (response, set, request) => {
+    const newResponse = new import_srvx.FastResponse(response.body, {
+      headers: Object.assign(
+        // @ts-ignore
+        Object.fromEntries(response.headers.entries()),
+        set.headers
+      ),
+      status: response.status ?? set.status
+    });
+    if (!newResponse.headers.has("content-length") && newResponse.headers.get("transfer-encoding") === "chunked")
+      return handleStream(
+        (0, import_utils2.streamResponse)(newResponse),
+        (0, import_utils2.responseToSetHeaders)(newResponse, set),
+        request
+      );
+    return newResponse;
+  };
+};
 // Annotate the CommonJS export names for ESM import in node:
 0 && (module.exports = {
+  createResponseHandler,
   handleFile
 });

dist/handle.mjs

 // src/handle.ts
 import { FastResponse as Response2 } from "srvx";
 import {
-  createResponseHandler,
-  createStreamHandler,
+  createStreamHandler as createStreamHandler2,
   handleSet,
-  responseToSetHeaders,
-  streamResponse
+  responseToSetHeaders as responseToSetHeaders2,
+  streamResponse as streamResponse2
 } from "elysia/adapter/utils";
@@ -14,2 +13,7 @@
 import { isNotEmpty } from "elysia/utils";
+import {
+  createStreamHandler,
+  responseToSetHeaders,
+  streamResponse
+} from "elysia/adapter/utils";
 var handleFile = (response, set2) => {
@@ -56,2 +60,22 @@ if (response instanceof Promise)
 };
+var createResponseHandler = (handler) => {
+  const handleStream2 = createStreamHandler(handler);
+  return (response, set2, request) => {
+    const newResponse = new Response(response.body, {
+      headers: Object.assign(
+        // @ts-ignore
+        Object.fromEntries(response.headers.entries()),
+        set2.headers
+      ),
+      status: response.status ?? set2.status
+    });
+    if (!newResponse.headers.has("content-length") && newResponse.headers.get("transfer-encoding") === "chunked")
+      return handleStream2(
+        streamResponse(newResponse),
+        responseToSetHeaders(newResponse, set2),
+        request
+      );
+    return newResponse;
+  };
+};
 
@@ -184,4 +208,4 @@ // src/handle.ts
     return handleStream(
-      streamResponse(response),
-      responseToSetHeaders(response, set2),
+      streamResponse2(response),
+      responseToSetHeaders2(response, set2),
       request
@@ -348,4 +372,4 @@ );
           return handleStream(
-            streamResponse(response),
-            responseToSetHeaders(response),
+            streamResponse2(response),
+            responseToSetHeaders2(response),
             request
@@ -463,4 +487,4 @@ );
         return handleStream(
-          streamResponse(response),
-          responseToSetHeaders(response),
+          streamResponse2(response),
+          responseToSetHeaders2(response),
           request
@@ -541,3 +565,3 @@ );
 });
-var handleStream = createStreamHandler({
+var handleStream = createStreamHandler2({
   mapResponse,
@@ -544,0 +568,0 @@ mapCompactResponse

dist/index.mjs

@@ -197,7 +197,6 @@ // src/index.ts
 import {
-  createResponseHandler,
-  createStreamHandler,
+  createStreamHandler as createStreamHandler2,
   handleSet,
-  responseToSetHeaders,
-  streamResponse
+  responseToSetHeaders as responseToSetHeaders2,
+  streamResponse as streamResponse2
 } from "elysia/adapter/utils";
@@ -208,2 +207,7 @@
 import { isNotEmpty as isNotEmpty2 } from "elysia/utils";
+import {
+  createStreamHandler,
+  responseToSetHeaders,
+  streamResponse
+} from "elysia/adapter/utils";
 var handleFile = (response, set2) => {
@@ -250,2 +254,22 @@ if (response instanceof Promise)
 };
+var createResponseHandler = (handler) => {
+  const handleStream2 = createStreamHandler(handler);
+  return (response, set2, request) => {
+    const newResponse = new Response(response.body, {
+      headers: Object.assign(
+        // @ts-ignore
+        Object.fromEntries(response.headers.entries()),
+        set2.headers
+      ),
+      status: response.status ?? set2.status
+    });
+    if (!newResponse.headers.has("content-length") && newResponse.headers.get("transfer-encoding") === "chunked")
+      return handleStream2(
+        streamResponse(newResponse),
+        responseToSetHeaders(newResponse, set2),
+        request
+      );
+    return newResponse;
+  };
+};
 
@@ -378,4 +402,4 @@ // src/handle.ts
     return handleStream(
-      streamResponse(response),
-      responseToSetHeaders(response, set2),
+      streamResponse2(response),
+      responseToSetHeaders2(response, set2),
       request
@@ -542,4 +566,4 @@ );
           return handleStream(
-            streamResponse(response),
-            responseToSetHeaders(response),
+            streamResponse2(response),
+            responseToSetHeaders2(response),
             request
@@ -657,4 +681,4 @@ );
         return handleStream(
-          streamResponse(response),
-          responseToSetHeaders(response),
+          streamResponse2(response),
+          responseToSetHeaders2(response),
           request
@@ -735,3 +759,3 @@ );
 });
-var handleStream = createStreamHandler({
+var handleStream = createStreamHandler2({
   mapResponse,
@@ -738,0 +762,0 @@ mapCompactResponse

dist/utils.d.ts

 import type { ReadStream } from 'fs';
 import type { Context } from 'elysia/context';
 export declare const handleFile: (response: ReadStream | File | Blob, set?: Context["set"]) => Response;
+interface CreateHandlerParameter {
+    mapResponse(response: unknown, set: Context['set'], request?: Request): Response;
+    mapCompactResponse(response: unknown, request?: Request): Response;
+}
+export declare const createResponseHandler: (handler: CreateHandlerParameter) => (response: Response, set: Context["set"], request?: Request) => any;
+export {};

dist/utils.mjs

 // src/utils.ts
 import { FastResponse as Response } from "srvx";
 import { isNotEmpty } from "elysia/utils";
+import {
+  createStreamHandler,
+  responseToSetHeaders,
+  streamResponse
+} from "elysia/adapter/utils";
 var handleFile = (response, set) => {
@@ -45,4 +50,25 @@ if (response instanceof Promise)
 };
+var createResponseHandler = (handler) => {
+  const handleStream = createStreamHandler(handler);
+  return (response, set, request) => {
+    const newResponse = new Response(response.body, {
+      headers: Object.assign(
+        // @ts-ignore
+        Object.fromEntries(response.headers.entries()),
+        set.headers
+      ),
+      status: response.status ?? set.status
+    });
+    if (!newResponse.headers.has("content-length") && newResponse.headers.get("transfer-encoding") === "chunked")
+      return handleStream(
+        streamResponse(newResponse),
+        responseToSetHeaders(newResponse, set),
+        request
+      );
+    return newResponse;
+  };
+};
 export {
+  createResponseHandler,
   handleFile
 };

package.json

 {
 	"name": "@elysiajs/node",
-	"version": "1.4.2",
+	"version": "1.4.3",
 	"description": "Elysia adapter to run Elysia on Node.js",
@@ -15,3 +15,3 @@ "license": "MIT",
 		"crossws": "^0.4.1",
-		"srvx": "^0.9.4"
+		"srvx": "^0.10.0"
 	},
@@ -26,3 +26,3 @@ "peerDependencies": {
 		"@types/node": "^22.10.2",
-		"elysia": "^1.4.15",
+		"elysia": "^1.4.21",
 		"eslint": "9.17.0",
@@ -29,0 +29,0 @@ "tsup": "^8.3.5",

New alerts

Network access

Supply chain risk

This module accesses the network.

Found 1 instance in 1 package

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 1 instance in 1 package

Fixed alerts

Network access

Supply chain risk

This module accesses the network.

Found 1 instance in 1 package

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

194033

2.96%

Lines of code

3692

4.26%

Dependency changes

• + Added

  srvx@0.10.1
  (transitive)

• - Removed

  srvx@0.9.8
  (transitive)

• Updated

  srvx@^0.10.0