✨ Implement RawBodyAccessor in BsonRequest and JsonRequest for raw body retrieval

Author: mkjsix

commons/src/main/java/org/restheart/exchange/BsonRequest.java

@@ -33,7 +33,10 @@
  *
  * @author Andrea Di Cesare {@literal <[email protected]>}
  */
-public class BsonRequest extends ServiceRequest<BsonValue> {
+public class BsonRequest extends ServiceRequest<BsonValue> implements RawBodyAccessor<String> {
+
+    private String rawBody;
+
     protected BsonRequest(HttpServerExchange exchange) {
         super(exchange);
     }
@@ -49,9 +52,15 @@ public static BsonRequest of(HttpServerExchange exchange) {
     @Override
     public BsonValue parseContent() throws IOException, BadRequestException {
         try {
-            return BsonUtils.parse(ChannelReader.readString(wrapped));
-        } catch(JsonParseException jpe) {
+            rawBody = ChannelReader.readString(wrapped);
+            return BsonUtils.parse(rawBody);
+        } catch (JsonParseException jpe) {
             throw new BadRequestException(jpe.getMessage(), jpe);
         }
     }
+
+    @Override
+    public final String getRawBody() {
+        return rawBody;
+    }
 }

commons/src/main/java/org/restheart/exchange/JsonRequest.java

@@ -33,7 +33,10 @@
  *
  * @author Andrea Di Cesare {@literal <[email protected]>}
  */
-public class JsonRequest extends ServiceRequest<JsonElement> {
+public class JsonRequest extends ServiceRequest<JsonElement> implements RawBodyAccessor<String> {
+
+    private String rawBody;
+
     protected JsonRequest(HttpServerExchange exchange) {
         super(exchange);
     }
@@ -50,12 +53,18 @@ public static JsonRequest of(HttpServerExchange exchange) {
     public JsonElement parseContent() throws IOException, BadRequestException {
         if (wrapped.getRequestContentLength() > 0) {
             try {
-                return JsonParser.parseString(ChannelReader.readString(wrapped));
+                rawBody = ChannelReader.readString(wrapped);
+                return JsonParser.parseString(rawBody);
             } catch(JsonSyntaxException jse) {
                 throw new BadRequestException(jse.getMessage(), jse);
             }
         } else {
             return null;
         }
     }
+
+    @Override
+    public String getRawBody() {
+        return rawBody;
+    }
 }