fix: POST 요청시 Body가 전달안되던 오류

kookmin-sw · May 22, 2024 · f8d3faa · f8d3faa
1 parent e18f418
commit f8d3faa
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 4 deletions.
diff --git a/back-gateway/src/main/java/com/gateway/backgateway/filter/GlobalLoggingFilter.java b/back-gateway/src/main/java/com/gateway/backgateway/filter/GlobalLoggingFilter.java
@@ -7,8 +7,11 @@
 import org.springframework.context.annotation.Configuration;
 import org.springframework.core.Ordered;
 import org.springframework.core.annotation.Order;
+import org.springframework.core.io.buffer.DataBuffer;
 import org.springframework.core.io.buffer.DataBufferUtils;
 import org.springframework.http.server.reactive.ServerHttpRequest;
+import org.springframework.http.server.reactive.ServerHttpRequestDecorator;
+import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
 import java.nio.charset.StandardCharsets;
@@ -28,11 +31,11 @@ public GlobalFilter preLoggingFilter() {
             log.info("Global Filter Start: request id -> {}", request.getId());
             log.info("Request: {} {}", request.getMethod(), request.getURI());
 
-            if(request.getHeaders().containsKey("Authorization")) {
+            if (request.getHeaders().containsKey("Authorization")) {
                 log.info("Authorization: {}", request.getHeaders().get("Authorization"));
             }
 
-            if(request.getMethod().toString().equals("GET")) {
+            if (request.getMethod().toString().equals("GET")) {
                 return chain.filter(exchange);
             }
 
@@ -53,7 +56,15 @@ public GlobalFilter preLoggingFilter() {
 
                         log.info("Request Body: {}", jsonBody);
 
-                        return chain.filter(exchange);
+                        ServerHttpRequest mutatedRequest = new ServerHttpRequestDecorator(request) {
+                            @Override
+                            public Flux<DataBuffer> getBody() {
+                                DataBuffer buffer = exchange.getResponse().bufferFactory().wrap(bodyBytes);
+                                return Flux.just(buffer);
+                            }
+                        };
+
+                        return chain.filter(exchange.mutate().request(mutatedRequest).build());
                     });
         };
     }

diff --git a/...main/java/com/example/capstone/domain/announcement/controller/AnnouncementController.java b/...main/java/com/example/capstone/domain/announcement/controller/AnnouncementController.java
@@ -2,7 +2,6 @@
 
 import com.example.capstone.domain.announcement.dto.AnnouncementListResponse;
 import com.example.capstone.domain.announcement.dto.AnnouncementListWrapper;
-import com.example.capstone.domain.announcement.dto.AnnouncementSearchListRequest;
 import com.example.capstone.domain.announcement.entity.Announcement;
 import com.example.capstone.domain.announcement.service.AnnouncementCallerService;
 import com.example.capstone.domain.announcement.service.AnnouncementSearchService;