Working

Author: robotdan

src/main/java/io/fusionauth/http/io/ChunkedInputStream.java

@@ -74,7 +74,10 @@ private int processChunk(byte[] destination, int offset, int length) throws IOEx
         // We need to push back any remaining bytes to the InputStream since we may have read more bytes than we needed.
         int leftOver = bufferLength - bufferIndex;
         if (leftOver > 0) {
-          ((PushbackInputStream) delegate).push(buffer, bufferIndex, leftOver);
+          // TODO : Daniel : Review : This doesn't seem like a good idea. It will fail silently, but this is required.
+          if (delegate instanceof PushbackInputStream pis) {
+            pis.push(buffer, bufferIndex, leftOver);
+          }
         }
 
         return -1;
@@ -106,7 +109,10 @@ private int processChunk(byte[] destination, int offset, int length) throws IOEx
           // We need to push back any remaining bytes to the InputStream since we may have read more bytes than we needed.
           int leftOver = bufferLength - bufferIndex;
           if (leftOver > 0) {
-            ((PushbackInputStream) delegate).push(buffer, bufferIndex, leftOver);
+            // TODO : Daniel : Review : This doesn't seem like a good idea. It will fail silently, but this is required.
+            if (delegate instanceof PushbackInputStream pis) {
+              pis.push(buffer, bufferIndex, leftOver);
+            }
           }
           return -1;
         }

src/main/java/io/fusionauth/http/server/io/HTTPInputStream.java

@@ -157,8 +157,10 @@ public int read(byte[] buffer, int offset, int length) throws IOException {
     if (!request.isChunked()) {
       int extraBytes = (int) (read - bytesRemaining);
       if (extraBytes > 0) {
-        // TODO : Daniel : I could set the ref type to PushBackInputStream so I don't have to cast.
-        ((PushbackInputStream) delegate).push(buffer, (int) bytesRemaining, extraBytes);
+        // TODO : Daniel : Review : This doesn't seem like a good idea. It will fail silently, but this is required.
+        if (delegate instanceof PushbackInputStream pis) {
+          pis.push(buffer, (int) bytesRemaining, extraBytes);
+        }
       }
     }
 
@@ -182,7 +184,6 @@ private void commit() {
     } else if (request.isChunked()) {
       logger.trace("Client indicated it was sending an entity-body in the request. Handling body using chunked encoding.");
       delegate = new ChunkedInputStream(delegate, chunkedBufferSize);
-
       if (instrumenter != null) {
         instrumenter.chunkedRequest();
       }