diff --git a/src/main/java/com/degressly/proxy/downstream/dto/CachePopulationRequest.java b/src/main/java/com/degressly/proxy/downstream/dto/CachePopulationRequest.java index c7996c8..0903c4f 100644 --- a/src/main/java/com/degressly/proxy/downstream/dto/CachePopulationRequest.java +++ b/src/main/java/com/degressly/proxy/downstream/dto/CachePopulationRequest.java @@ -22,7 +22,7 @@ public class CachePopulationRequest { private int statusCode; - private String body; + private Object body; // Headers are modeled as a LinkedMultiValueMap to handle the list of strings private Map> headers; diff --git a/src/main/java/com/degressly/proxy/downstream/dto/DownstreamResponse.java b/src/main/java/com/degressly/proxy/downstream/dto/DownstreamResponse.java index 8a11f19..c418115 100644 --- a/src/main/java/com/degressly/proxy/downstream/dto/DownstreamResponse.java +++ b/src/main/java/com/degressly/proxy/downstream/dto/DownstreamResponse.java @@ -18,7 +18,7 @@ public class DownstreamResponse { private int statusCode; - private String body; + private Object body; // Headers are modeled as a LinkedMultiValueMap to handle the list of strings private Map> headers; diff --git a/src/main/java/com/degressly/proxy/downstream/service/impl/ProxyCoordinatorServiceImpl.java b/src/main/java/com/degressly/proxy/downstream/service/impl/ProxyCoordinatorServiceImpl.java index 74f8e39..618bc61 100644 --- a/src/main/java/com/degressly/proxy/downstream/service/impl/ProxyCoordinatorServiceImpl.java +++ b/src/main/java/com/degressly/proxy/downstream/service/impl/ProxyCoordinatorServiceImpl.java @@ -78,7 +78,7 @@ public ResponseEntity fetch(RequestContext requestContext) { var downstreamResponse = DownstreamResponse.builder() .statusCode(response.getStatusCode().value()) .headers(new LinkedMultiValueMap<>(response.getHeaders())) - .body(response.getBody() != null ? Objects.requireNonNull(response.getBody()).toString() : null) + .body(response.getBody() != null ? response.getBody() : null) .build(); updatedRequestCacheObject = requestCacheService.storeResponse(requestContext, downstreamResponse);