remove contentRange validation since part size could different

Author: Fred1155

services/s3/src/main/java/software/amazon/awssdk/services/s3/internal/multipart/MultipartDownloaderSubscriber.java

@@ -77,16 +77,6 @@ public class MultipartDownloaderSubscriber implements Subscriber<AsyncResponseTr
      */
     private volatile String eTag;
 
-    /**
-     * The size of each part of the object being downloaded.
-     */
-    private volatile Long partSize;
-
-    /**
-     * The total size of the object being downloaded.
-     */
-    private volatile Long totalContentLength;
-
     /**
      * The Subscription lock
      */
@@ -174,15 +164,6 @@ private void requestMoreIfNeeded(GetObjectResponse response) {
             totalParts = partCount;
         }
 
-        String actualContentRange = response.contentRange();
-        if (actualContentRange != null && partSize == null) {
-            getRangeInfo(actualContentRange);
-            log.debug(() -> String.format("Part size of the object to download: " + partSize));
-            log.debug(() -> String.format("Total Content Length of the object to download: " + totalContentLength));
-        }
-
-        validateContentRange(totalComplete, actualContentRange);
-
         synchronized (lock) {
             if (totalParts != null && totalParts > 1 && totalComplete < totalParts) {
                 subscription.request(1);
@@ -231,34 +212,4 @@ private void validatePartsCount(int currentGetCount) {
             onError(exception);
         }
     }
-
-    private void validateContentRange(int partNumber, String contentRange) {
-        if (contentRange == null) {
-            return;
-        }
-
-        long expectedStart = (partNumber - 1) * partSize;
-        long expectedEnd = partNumber == totalParts ? totalContentLength - 1 : expectedStart + partSize - 1;
-
-        String expectedContentRange = String.format("bytes %d-%d/%d", expectedStart, expectedEnd, totalContentLength);
-
-        if (!expectedContentRange.equals(contentRange)) {
-            String errorMessage = String.format(
-                "Content-Range validation failed for part %d. Expected: %s, Actual: %s",
-                partNumber, expectedContentRange, contentRange);
-            log.error(() -> errorMessage);
-            onError(SdkClientException.create(errorMessage));
-        }
-    }
-
-    private void getRangeInfo(String contentRange) {
-        String rangeInfo = contentRange.substring(6);
-        String[] parts = rangeInfo.split("/");
-
-        this.totalContentLength = Long.parseLong(parts[1]);
-        String[] rangeParts = parts[0].split("-");
-        long startByte = Long.parseLong(rangeParts[0]);
-        long endByte = Long.parseLong(rangeParts[1]);
-        this.partSize = endByte - startByte + 1;
-    }
 }

services/s3/src/test/java/software/amazon/awssdk/services/s3/internal/multipart/MultipartDownloaderSubscriberWiremockTest.java

@@ -160,32 +160,6 @@ <T> void errorOnThirdRequest_shouldCompleteExceptionallyOnlyPartsGreaterThanTwo(
         }
     }
 
-    @ParameterizedTest
-    @MethodSource("argumentsProvider")
-    <T> void wrongContentRangeOnSecondRequest_should(AsyncResponseTransformerTestSupplier<T> supplier,
-                                                     int amountOfPartToTest,
-                                                     int partSize) {
-        util.stubForPart(testBucket, testKey, 1, 3, partSize);
-        util.stubForPartwithWrongContentRange(testBucket, testKey, 2, 3, partSize);
-        util.stubForPart(testBucket, testKey, 3, 3, partSize);
-        //byte[] expectedBody = util.stubAllParts(testBucket, testKey, amountOfPartToTest, partSize);
-        AsyncResponseTransformer<GetObjectResponse, T> transformer = supplier.transformer();
-        AsyncResponseTransformer.SplitResult<GetObjectResponse, T> split = transformer.split(
-            SplittingTransformerConfiguration.builder()
-                                             .bufferSizeInBytes(1024 * 32L)
-                                             .build());
-        Subscriber<AsyncResponseTransformer<GetObjectResponse, GetObjectResponse>> subscriber = new MultipartDownloaderSubscriber(
-            s3AsyncClient,
-            GetObjectRequest.builder()
-                            .bucket(testBucket)
-                            .key(testKey)
-                            .build());
-
-        split.publisher().subscribe(subscriber);
-        T response = split.resultFuture().join();
-
-    }
-
     private static Stream<Arguments> argumentsProvider() {
         // amount of part, individual part size
         List<Pair<Integer, Integer>> partSizes = Arrays.asList(