Merge pull request #145 from shabtaisharon/full_payload_test

add a test to verify we recived the full payload on Gets

Author: rpmoore

ds3-sdk/src/test/java/com/spectralogic/ds3client/Ds3Client_Test.java

@@ -19,6 +19,7 @@
 import com.google.common.collect.Multimap;
 import com.google.common.collect.TreeMultimap;
 import com.spectralogic.ds3client.commands.*;
+import com.spectralogic.ds3client.exceptions.ContentLengthNotMatchException;
 import com.spectralogic.ds3client.models.*;
 import com.spectralogic.ds3client.models.bulk.*;
 import com.spectralogic.ds3client.models.bulk.Objects;
@@ -919,4 +920,24 @@ public void getTape() throws IOException, SignatureException {
         assertThat(tape.getId(), is(notNullValue()));
         assertThat(tape.getId(), is(UUID.fromString("c7c431df-f95d-4533-b350-ffd7a8a5caac")));
     }
+
+    @Test(expected = ContentLengthNotMatchException.class)
+    public void getObjectVerifyFullPayload() throws IOException, SignatureException {
+        final String jobIdString = "a4a586a1-cb80-4441-84e2-48974e982d51";
+        final Map<String, String> queryParams = new HashMap<>();
+        queryParams.put("job", jobIdString);
+        queryParams.put("offset", Long.toString(0));
+
+        final Map<String, String> responseHeaders = new HashMap<>();
+        responseHeaders.put("Content-Length", "4");
+
+        final ByteArraySeekableByteChannel resultChannel = new ByteArraySeekableByteChannel();
+        final String stringResponse = "Response";
+
+        MockNetwork
+                .expecting(HttpVerb.GET, "/bucketName/object", queryParams, null)
+                .returning(200, stringResponse, responseHeaders)
+                .asClient()
+                .getObject(new GetObjectRequest("bucketName", "object", 0, UUID.fromString(jobIdString), resultChannel));
+    }
 }