fix(server): Compression Plugin (fetch) response invalid status

Author: dinwwwh

packages/server/src/adapters/fetch/compression-plugin.test.ts

@@ -1,3 +1,4 @@
+import { ORPCError } from '@orpc/client'
 import { os } from '../../builder'
 import { CompressionPlugin } from './compression-plugin'
 import { RPCHandler } from './rpc-handler'
@@ -617,4 +618,31 @@ describe('compressionPlugin', () => {
     expect(text).toContain('event1')
     expect(text).toContain('event2')
   })
+
+  it('can compress error response', async () => {
+    const error = new ORPCError('UNAUTHORIZED')
+
+    const handler = new RPCHandler(os.handler(() => {
+      throw error
+    }), {
+      plugins: [
+        new CompressionPlugin(),
+      ],
+    })
+
+    const { response } = await handler.handle(new Request('https://example.com/', {
+      method: 'POST',
+      headers: {
+        'content-type': 'application/json',
+        'accept-encoding': 'gzip',
+      },
+      body: JSON.stringify({}),
+    }))
+
+    const decompressed = response?.body?.pipeThrough(new DecompressionStream('gzip'))
+    const text = await new Response(decompressed).text()
+    expect(text).toContain(error.code)
+    expect(response?.headers.get('content-encoding')).toBe('gzip')
+    expect(response?.status).toBe(error.status)
+  })
 })

packages/server/src/adapters/fetch/compression-plugin.ts

@@ -119,7 +119,8 @@ export class CompressionPlugin<T extends Context> implements FetchHandlerPlugin<
       return {
         ...result,
         response: new Response(compressedBody, {
-          ...response,
+          status: response.status,
+          statusText: response.statusText,
           headers: compressedHeaders,
         }),
       }