🔧 fix: #1353 normalize encodeSchema with Transform

Author: SaltyAom

CHANGELOG.md

@@ -1,4 +1,8 @@
-# 1.3.16 - 22 Aug 2025
+# 1.3.17 - 23 Aug 2025
+Bug fix:
+- [#1353](https://github.com/elysiajs/elysia/issues/1353) normalize encodeSchema with Transform
+
+# 1.3.16 - 23 Aug 2025
 Improvement:
 - `sse` now infer type
 - `sse` now accepts `ReadableStream` to return stream as `text/event-stream`

example/a.ts

@@ -1,23 +1,34 @@
 import { Elysia, sse, t } from '../src'
-import { streamResponse } from '../src/adapter/utils'
 import { req } from '../test/utils'
 
-const app = new Elysia()
-	.get('/', function () {
-		return new ReadableStream({
-			async start(controller) {
-				controller.enqueue('a')
-				await Bun.sleep(100)
-				controller.enqueue('b')
-				await Bun.sleep(100)
-				controller.close()
-			}
+const app = new Elysia().get(
+	'/',
+	() => ({
+		hasMore: true,
+		total: 1,
+		offset: 0,
+		totalPages: 1,
+		currentPage: 1,
+		items: [{ username: 'Bob', secret: 'shhh' }]
+	}),
+	{
+		response: t.Object({
+			hasMore: t.Boolean(),
+			items: t.Array(
+				t.Object({
+					username: t.String()
+				})
+			),
+			total: t
+				.Transform(t.Number())
+				.Decode((x) => x)
+				.Encode((x) => x),
+			offset: t.Number({ minimum: 0 }),
+			totalPages: t.Number(),
+			currentPage: t.Number({ minimum: 1 })
 		})
-	})
-	.listen(3000)
+	}
+)
+.listen(3000)
 
-const response = await app.handle(req('/'))
-
-for await (const a of streamResponse(response)) {
-	console.log(a)
-}
+const data = await app.handle(req('/')).then((x) => x.text())

package.json

@@ -1,7 +1,7 @@
 {
 	"name": "elysia",
 	"description": "Ergonomic Framework for Human",
-	"version": "1.3.16",
+	"version": "1.3.17",
 	"author": {
 		"name": "saltyAom",
 		"url": "https://github.com/SaltyAom",

src/compose.ts

@@ -262,10 +262,14 @@ const composeValidationFactory = ({
 				!appliedCleaner && normalize && !noValidate
 
 			// Encode call TypeCheck.Check internally
-			if (encodeSchema && value.hasTransform)
+			if (encodeSchema && value.hasTransform) {
 				code +=
 					`try{` +
-					`${name}=validator.response[${status}].Encode(${name})\n` +
+					`${name}=validator.response[${status}].Encode(${name})\n`
+
+				if (!appliedCleaner) code += clean({ ignoreTryCatch: true })
+
+				code +=
 					`c.set.status=${status}` +
 					`}catch{` +
 					(applyErrorCleaner
@@ -277,7 +281,7 @@ const composeValidationFactory = ({
 							`}`
 						: `throw new ValidationError('response',validator.response[${status}],${name})`) +
 					`}`
-			else {
+			} else {
 				if (!appliedCleaner) code += clean()
 
 				if (!noValidate)

test/core/normalize.test.ts

@@ -508,6 +508,53 @@ describe('Normalize', () => {
 		])
 	})
 
+	it('normalize encodeSchema with Transform', async () => {
+		const app = new Elysia().get(
+			'/',
+			() => ({
+				hasMore: true,
+				total: 1,
+				offset: 0,
+				totalPages: 1,
+				currentPage: 1,
+				items: [{ username: 'Bob', secret: 'shhh' }]
+			}),
+			{
+				// I don't know why but it must be this exact shape
+				response: t.Object({
+					hasMore: t.Boolean(),
+					items: t.Array(
+						t.Object({
+							username: t.String()
+						})
+					),
+					total: t
+						.Transform(t.Number())
+						.Decode((x) => x)
+						.Encode((x) => x),
+					offset: t.Number({ minimum: 0 }),
+					totalPages: t.Number(),
+					currentPage: t.Number({ minimum: 1 })
+				})
+			}
+		)
+
+		const data = await app.handle(req('/')).then((x) => x.json())
+
+		expect(data).toEqual({
+			hasMore: true,
+			items: [
+				{
+					username: 'Bob'
+				}
+			],
+			total: 1,
+			offset: 0,
+			totalPages: 1,
+			currentPage: 1
+		})
+	})
+
 	// it('normalize response with getter fields on class', async () => {
 	// 	const app = new Elysia({
 	// 		normalize: true