elysia - npm Package Compare versions

Comparing version 1.1.5 to 1.1.6

dist/cjs/handler.d.ts

@@ -5,2 +5,3 @@ import type { Context } from './context';
 export declare const serializeCookie: (cookies: Context["set"]["cookie"]) => string | string[] | undefined;
+export declare function streamResponse(response: Response): AsyncGenerator<string, void, unknown>;
 export declare const mapResponse: (response: unknown, set: Context["set"], request?: Request) => Response;
@@ -7,0 +8,0 @@ export declare const mapEarlyResponse: (response: unknown, set: Context["set"], request?: Request) => Response | undefined;

dist/cjs/handler.js

@@ -39,3 +39,4 @@ "use strict";
   parseSetCookies: () => parseSetCookies,
-  serializeCookie: () => serializeCookie
+  serializeCookie: () => serializeCookie,
+  streamResponse: () => streamResponse
 });
@@ -985,3 +986,5 @@ module.exports = __toCommonJS(handler_exports);
             } catch {
-              controller.enqueue(Buffer.from(init.value.toString()));
+              controller.enqueue(
+                Buffer.from(init.value.toString())
+              );
             }
@@ -1023,2 +1026,17 @@ else controller.enqueue(Buffer.from(init.value.toString()));
 };
+async function* streamResponse(response) {
+  const body = response.body;
+  if (!body) return;
+  const reader = body.getReader();
+  const decoder = new TextDecoder();
+  try {
+    while (true) {
+      const { done, value } = await reader.read();
+      if (done) break;
+      yield decoder.decode(value);
+    }
+  } finally {
+    reader.releaseLock();
+  }
+}
 var mapResponse = (response, set, request) => {
@@ -1119,2 +1137,8 @@ if (isNotEmpty(set.headers) || set.status !== 200 || set.redirect || set.cookie) {
           set.status = response.status;
+        if (response.headers.get("transfer-encoding") === "chunked")
+          return handleStream(
+            streamResponse(response),
+            set,
+            request
+          );
         return response;
@@ -1251,2 +1275,8 @@ case "Error":
       case "Response":
+        if (response.headers.get("transfer-encoding") === "chunked")
+          return handleStream(
+            streamResponse(response),
+            set,
+            request
+          );
         return response;
@@ -1399,2 +1429,8 @@ case "Error":
           set.status = response.status;
+        if (response.headers.get("transfer-encoding") === "chunked")
+          return handleStream(
+            streamResponse(response),
+            set,
+            request
+          );
         return response;
@@ -1529,2 +1565,6 @@ case "Promise":
       case "Response":
+        if (response.headers.get("transfer-encoding") === "chunked")
+          return handleStream(
+            streamResponse(response)
+          );
         return response;
@@ -1632,2 +1672,4 @@ case "Promise":
     case "Response":
+      if (response.headers.get("transfer-encoding") === "chunked")
+        return handleStream(streamResponse(response));
       return response;
@@ -1696,3 +1738,4 @@ case "Error":
   parseSetCookies,
-  serializeCookie
+  serializeCookie,
+  streamResponse
 });
@@ -1699,0 +1742,0 @@ /**

dist/cjs/types.d.ts

@@ -439,3 +439,8 @@ import type { Elysia } from '.';
 };
-export type DocumentDecoration = Partial<OpenAPIV3.OperationObject>;
+export type DocumentDecoration = Partial<OpenAPIV3.OperationObject> & {
+    /**
+     * Pass `true` to hide route from OpenAPI/swagger document
+     * */
+    hide?: boolean;
+};
 export type LocalHook<LocalSchema extends InputSchema, Schema extends RouteSchema, Singleton extends SingletonBase, Errors extends Record<string, Error>, Extension extends BaseMacro, Path extends string = '', TypedRoute extends RouteSchema = Schema extends {
@@ -442,0 +447,0 @@ params: Record<string, unknown>;

dist/handler.d.ts

@@ -5,2 +5,3 @@ import type { Context } from './context';
 export declare const serializeCookie: (cookies: Context["set"]["cookie"]) => string | string[] | undefined;
+export declare function streamResponse(response: Response): AsyncGenerator<string, void, unknown>;
 export declare const mapResponse: (response: unknown, set: Context["set"], request?: Request) => Response;
@@ -7,0 +8,0 @@ export declare const mapEarlyResponse: (response: unknown, set: Context["set"], request?: Request) => Response | undefined;

dist/types.d.ts

@@ -439,3 +439,8 @@ import type { Elysia } from '.';
 };
-export type DocumentDecoration = Partial<OpenAPIV3.OperationObject>;
+export type DocumentDecoration = Partial<OpenAPIV3.OperationObject> & {
+    /**
+     * Pass `true` to hide route from OpenAPI/swagger document
+     * */
+    hide?: boolean;
+};
 export type LocalHook<LocalSchema extends InputSchema, Schema extends RouteSchema, Singleton extends SingletonBase, Errors extends Record<string, Error>, Extension extends BaseMacro, Path extends string = '', TypedRoute extends RouteSchema = Schema extends {
@@ -442,0 +447,0 @@ params: Record<string, unknown>;

package.json

 {
 	"name": "elysia",
 	"description": "Ergonomic Framework for Human",
-	"version": "1.1.5",
+	"version": "1.1.6",
 	"author": {
@@ -6,0 +6,0 @@ "name": "saltyAom",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

2561905

increased by0.53%

Lines of code

54923

increased by0.65%

No dependency changes