🔧 fix: #14

Author: SaltyAom

CHANGELOG.md

@@ -1,3 +1,8 @@
+# 1.2.4 - 9 Jan 2024
+Bug fix:
+- Support Elysia 1.2.11
+- [#14](https://github.com/elysiajs/node/issues/14) ReadableStream has already been used if request is reference multiple time
+
 # 1.2.3 - 27 Dec 2024
 Bug fix:
 - async module doesn't load (eg. @elysiajs/swagger)

bun.lock

@@ -1,17 +1,22 @@
 import { Elysia } from 'elysia'
 import { node } from '../src'
 
-new Elysia({ adapter: node() })
-	.ws('/', {
-		upgrade({ set }) {
-			set.headers['a'] = 'b'
-		},
-		open(ws) {
-			ws.subscribe('topic')
-			ws.publish('topic', 'Hello')
-		},
-		message(ws, message) {
-			ws.publish('topic', message)
+const plugin = new Elysia({ prefix: '/api/v1' }).post(
+	'/',
+	async ({ body, store, error, request }) => {
+		return {
+			message: 'Hello World'
 		}
+	}
+)
+
+const app = new Elysia({
+	adapter: node()
+})
+	.use(plugin)
+	.listen(8000, ({ port }) => {
+		console.log(`Server is running on http://localhost:${port}`)
 	})
-	.listen(3000)
+
+// console.log(app._handle.toString())
+// console.log(app.routes[0].compile().toString())

bun.lockb

@@ -1,6 +1,6 @@
 {
 	"name": "@elysiajs/node",
-	"version": "1.2.3",
+	"version": "1.2.4",
 	"description": "Plugin for Elysia for retreiving Bearer token",
 	"license": "MIT",
 	"scripts": {
@@ -31,7 +31,7 @@
 		"@types/formidable": "^3.4.5",
 		"@types/node": "^22.10.2",
 		"@types/ws": "^8.5.13",
-		"elysia": "1.2.7",
+		"elysia": "1.2.10",
 		"eslint": "9.17.0",
 		"light-my-request": "^6.4.0",
 		"tsup": "^8.3.5",

example/c.ts

@@ -76,16 +76,16 @@ export const node = () => {
 			mapCompactResponse
 		},
 		composeHandler: {
-			declare(inference) {
-				if (inference.request)
-					return (
-						`Object.defineProperty(c,'request',{` +
-						`get(){` +
-						`return nodeRequestToWebstand(c[ElysiaNodeContext].req)` +
-						`}` +
-						`})\n`
-					)
-			},
+			// declare(inference) {
+			// 	if (inference.request)
+			// 		return (
+			// 			`Object.defineProperty(c,'request',{` +
+			// 			`get(){` +
+			// 			`return nodeRequestToWebstand(c[ElysiaNodeContext].req)` +
+			// 			`}` +
+			// 			`})\n`
+			// 		)
+			// },
 			mapResponseContext: 'c[ElysiaNodeContext].res',
 			headers: `c.headers=c[ElysiaNodeContext].req.headers\n`,
 			inject: {
@@ -201,7 +201,7 @@ export const node = () => {
 				for (const key of Object.keys(app.singleton.decorator))
 					decoratorsLiteral += `,${key}: decorator['${key}']`
 
-				const hasTrace = app.event.trace.length > 0
+				const hasTrace = !!app.event.trace?.length
 
 				if (hasTrace) fnLiteral += `const id=randomId()\n`
 
@@ -313,7 +313,7 @@ export const node = () => {
 				hooks: lifecycle,
 				websocket: options
 			})
-			app.router.ws.history.push(['$INTERNALWS', path, options])
+			app.router.http.history.push(['$INTERNALWS', path, options])
 		},
 		listen(app) {
 			return (options, callback) => {
@@ -445,7 +445,7 @@ export const node = () => {
 							try {
 								serverInfo.reload(
 									typeof options === 'object'
-										? options as any
+										? (options as any)
 										: {
 												port: options
 											}
@@ -455,20 +455,25 @@ export const node = () => {
 					}
 				)
 
+				// @ts-ignore
+				app.router.http.build?.()
+
 				if (
 					isNotEmpty(app.router.static.ws) ||
-					app.router.ws.history.length
+					app.router.http.history.find((x) => x[0] === 'ws')
 				)
 					attachWebSocket(app, server)
 
-				for (let i = 0; i < app.event.start.length; i++)
-					app.event.start[i].fn(this)
+				if (app.event.start)
+					for (let i = 0; i < app.event.start.length; i++)
+						app.event.start[i].fn(this)
 
 				process.on('beforeExit', () => {
 					server.close()
 
-					for (let i = 0; i < app.event.stop.length; i++)
-						app.event.stop[i].fn(this)
+					if (app.event.stop)
+						for (let i = 0; i < app.event.stop.length; i++)
+							app.event.stop[i].fn(this)
 				})
 			}
 		}

package.json

@@ -53,4 +53,49 @@ describe('Node - Core', () => {
 			}
 		)
 	})
+
+	it('handle plugin', () => {
+		const plugin = new Elysia({ prefix: '/api/v1' }).post(
+			'/',
+			async ({ request }) => {
+				return {
+					message: 'Yugiri'
+				}
+			},
+			{
+				beforeHandle({ request }) {
+					request
+				}
+			}
+		)
+
+		const app = new Elysia({
+			adapter: node()
+		})
+			.use(plugin)
+			.listen(8000, ({ port }) => {
+				console.log(`Server is running on http://localhost:${port}`)
+			})
+
+		inject(
+			// @ts-ignore
+			app._handle,
+			{
+				path: '/api/v1',
+				method: 'POST',
+				headers: {
+					'Content-Type': 'application/json'
+				},
+				body: JSON.stringify({ message: 'Hello Yugiri' })
+			},
+			(error, res) => {
+				expect(error).toBeNull()
+
+				expect(res?.body).toBe(JSON.stringify({ message: 'Yugiri' }))
+				expect(res?.headers['content-type']).toBe(
+					'application/json;charset=utf8'
+				)
+			}
+		)
+	})
 })