@@ -6,7 +6,8 @@ import { logHandler } from 'server/handler/log.handler';
6
6
import type { LogAdapter } from 'server/adapter/log.adapter' ;
7
7
import type { Logger } from 'common/logger/createFastifyLogger' ;
8
8
import { HOST_HEADER } from 'common/constant/http.constant' ;
9
- // import type { Locals } from 'server/fastify.server';
9
+ import type { Locals } from 'server/fastify.server' ;
10
+
10
11
11
12
export const proxyHandler = async (
12
13
request : FastifyRequest ,
@@ -17,14 +18,14 @@ export const proxyHandler = async (
17
18
) => {
18
19
const targetUrl = await projectAdapter . resolveTargetUrl ( request ) ;
19
20
20
- // const locals = (request as any).locals as Locals;
21
- // const extraHeaders: { [header: string]: string } = {};
22
- //
23
- // if (locals.originalContentType) {
24
- // extraHeaders['content-type'] = locals.originalContentType;
25
- // }
21
+ const locals = ( request as any ) . locals as Locals ;
22
+ const extraHeaders : { [ header : string ] : string } = { } ;
23
+
24
+ if ( locals . originalContentType ) {
25
+ extraHeaders [ 'content-type' ] = locals . originalContentType ;
26
+ }
26
27
const host = request . headers [ HOST_HEADER ] as string ;
27
- return sendProxyRequest ( host , targetUrl , reply , logAdapter , logger ) ;
28
+ return sendProxyRequest ( host , targetUrl , reply , logAdapter , logger , extraHeaders ) ;
28
29
} ;
29
30
30
31
const sendProxyRequest = async (
@@ -33,10 +34,12 @@ const sendProxyRequest = async (
33
34
reply : FastifyReply ,
34
35
logAdapter : LogAdapter ,
35
36
logger : Logger ,
37
+ extraHeaders : { [ header : string ] : string } ,
36
38
) : Promise < void > => {
37
39
return reply . from ( targetUrl , {
38
40
rewriteRequestHeaders : ( req , headers ) => ( {
39
41
...headers ,
42
+ ...extraHeaders ,
40
43
host,
41
44
} ) ,
42
45
onError : ( reply , error ) => {
0 commit comments