Code review, cleanup

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

@@ -382,10 +382,7 @@ private boolean reload(int minimumToLoad) throws IOException {
       start += end;
 
       // Keep track of all bytes read for this multipart stream. Fail if the length has been exceeded.
-      if (read > 0) {
-        bytesRead += read;
-      }
-
+      bytesRead += read;
       long maximumRequestSize = multipartConfiguration.getMaxRequestSize();
       if (bytesRead > maximumRequestSize) {
         String detailedMessage = "The maximum request size of multipart stream has been exceeded. The maximum request size is [" + maximumRequestSize + "] bytes.";

src/test/java/io/fusionauth/http/io/MultipartStreamTest.java

@@ -33,6 +33,7 @@
 import org.testng.annotations.DataProvider;
 import org.testng.annotations.Test;
 import static org.testng.Assert.assertEquals;
+import static org.testng.FileAssert.fail;
 
 /**
  * @author Brian Pontarelli
@@ -216,6 +217,23 @@ public void separateParts(@SuppressWarnings("unused") int index, byte[][] parts)
     Files.delete(files.get(0).file);
   }
 
+  @Test
+  public void truncated() throws IOException {
+    ByteArrayInputStream is = new ByteArrayInputStream("""
+        ------WebKitFormBoundaryTWfMVJErBoLURJIe\r
+        """.getBytes());
+    Map<String, List<String>> parameters = new HashMap<>();
+    List<FileInfo> files = new LinkedList<>();
+    MultipartStream stream = new MultipartStream(is, "----WebKitFormBoundaryTWfMVJErBoLURJIe".getBytes(), fileManager, new MultipartConfiguration().withFileUploadPolicy(MultipartFileUploadPolicy.Allow));
+    try {
+      stream.process(parameters, files);
+      fail("Expected to fail with a ParseException");
+
+    } catch (ParseException e) {
+      assertEquals(e.getMessage(), "Invalid multipart body. Ran out of data while processing.");
+    }
+  }
+
   public static class PartInputStream extends InputStream {
     private final byte[][] parts;