Merge pull request #282 from boostcampwm-2024/dev-back

[BE] Merge to main

Author: sjy2335

backend/proxy-server/src/server/fastify.server.ts

@@ -1,6 +1,6 @@
+import type { FastifyInstance, FastifyReply, FastifyRequest } from 'fastify';
 import fastify from 'fastify';
 import { fastifyConfig, replyFromConfig } from './config/fastify.config';
-import type { FastifyInstance, FastifyReply, FastifyRequest } from 'fastify';
 import type { Logger } from 'common/logger/createFastifyLogger';
 import { createFastifyLogger } from 'common/logger/createFastifyLogger';
 import { createErrorLog } from 'common/error/system.error';
@@ -17,6 +17,10 @@ interface FastifyServer {
     stop: (server: FastifyInstance, logger: Logger) => Promise<void>;
 }
 
+export interface Locals {
+    originalContentType?: string;
+}
+
 export const fastifyServer: FastifyServer = {
     listen: () => startFastifyServer(),
     stop: (server: FastifyInstance, logger: Logger) => stopFastifyServer(server, logger),
@@ -79,6 +83,11 @@ const initialize = (server: FastifyInstance, logger: Logger) => {
 
 const addPlugins = (server: FastifyInstance) => {
     server.register(replyFrom, replyFromConfig);
+    server.addHook('preHandler', async (request) => {
+        (request as any).locals = {
+            originalContentType: request.headers['content-type'],
+        };
+    });
 };
 
 const addRouters = (server: FastifyInstance, logger: Logger) => {

backend/proxy-server/src/server/handler/proxy.handler.ts

@@ -5,6 +5,7 @@ import type { ProjectAdapter } from 'server/adapter/project.adapter';
 import { logHandler } from 'server/handler/log.handler';
 import type { LogAdapter } from 'server/adapter/log.adapter';
 import type { Logger } from 'common/logger/createFastifyLogger';
+import type { Locals } from 'server/fastify.server';
 
 export const proxyHandler = async (
     request: FastifyRequest,
@@ -15,16 +16,28 @@ export const proxyHandler = async (
 ) => {
     const targetUrl = await projectAdapter.resolveTargetUrl(request);
 
-    return sendProxyRequest(targetUrl, reply, logAdapter, logger);
+    const locals = (request as any).locals as Locals;
+    const extraHeaders: { [header: string]: string } = {};
+
+    if (locals.originalContentType) {
+        extraHeaders['content-type'] = locals.originalContentType;
+    }
+
+    return sendProxyRequest(targetUrl, reply, logAdapter, logger, extraHeaders);
 };
 
 const sendProxyRequest = async (
     targetUrl: string,
     reply: FastifyReply,
     logAdapter: LogAdapter,
     logger: Logger,
+    extraHeaders: { [header: string]: string },
 ): Promise<void> => {
     return reply.from(targetUrl, {
+        rewriteRequestHeaders: (req, headers) => ({
+            ...headers,
+            ...extraHeaders,
+        }),
         onError: (reply, error) => {
             throw new ProxyError('프록시 요청 처리 중 오류가 발생했습니다.', 502, error.error);
         },