[18/50] [abbrv] git commit: Prefer ByteSource payload

[an...@apache.org]

Prefer ByteSource payload

Also use randomByteSource for test input.


Project: http://git-wip-us.apache.org/repos/asf/jclouds/repo
Commit: http://git-wip-us.apache.org/repos/asf/jclouds/commit/0e3d1475
Tree: http://git-wip-us.apache.org/repos/asf/jclouds/tree/0e3d1475
Diff: http://git-wip-us.apache.org/repos/asf/jclouds/diff/0e3d1475

Branch: refs/heads/fix-jclouds-538
Commit: 0e3d1475ab50e1232d5eac16eee1d3a207e36f42
Parents: a73340a
Author: Andrew Gaul <ga...@apache.org>
Authored: Tue Sep 9 15:28:55 2014 -0700
Committer: Andrew Gaul <ga...@apache.org>
Committed: Tue Sep 9 15:32:39 2014 -0700

----------------------------------------------------------------------
 .../internal/BaseContainerLiveTest.java           | 18 ++++++++++++------
 1 file changed, 12 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/jclouds/blob/0e3d1475/blobstore/src/test/java/org/jclouds/blobstore/integration/internal/BaseContainerLiveTest.java
----------------------------------------------------------------------
diff --git a/blobstore/src/test/java/org/jclouds/blobstore/integration/internal/BaseContainerLiveTest.java b/blobstore/src/test/java/org/jclouds/blobstore/integration/internal/BaseContainerLiveTest.java
index b2f7d68..5564d42 100644
--- a/blobstore/src/test/java/org/jclouds/blobstore/integration/internal/BaseContainerLiveTest.java
+++ b/blobstore/src/test/java/org/jclouds/blobstore/integration/internal/BaseContainerLiveTest.java
@@ -25,6 +25,7 @@ import static org.testng.Assert.assertTrue;
 
 import java.io.IOException;
 import java.net.MalformedURLException;
+import java.nio.charset.StandardCharsets;
 import java.util.Collections;
 import java.util.List;
 import java.util.logging.Logger;
@@ -35,16 +36,18 @@ import org.jclouds.blobstore.domain.BlobMetadata;
 import org.jclouds.blobstore.domain.StorageMetadata;
 import org.jclouds.domain.Location;
 import org.jclouds.javax.annotation.Nullable;
+import org.jclouds.io.ByteStreams2;
 import org.jclouds.predicates.SocketOpen;
 import org.jclouds.util.Strings2;
+import org.jclouds.utils.TestUtils;
 import org.testng.SkipException;
 import org.testng.annotations.Test;
 
 import com.google.common.base.Predicate;
 import com.google.common.base.Predicates;
-import com.google.common.base.Strings;
 import com.google.common.collect.Iterables;
 import com.google.common.collect.Lists;
+import com.google.common.io.ByteSource;
 
 public class BaseContainerLiveTest extends BaseBlobStoreIntegrationTest {
 
@@ -100,7 +103,7 @@ public class BaseContainerLiveTest extends BaseBlobStoreIntegrationTest {
    public void testPublicAccessInNonDefaultLocation() throws InterruptedException, MalformedURLException, IOException {
       Location nonDefault = findNonDefaultLocationOrSkip(view.getBlobStore(), defaultLocation);
 
-      String payload = "my data";
+      ByteSource payload = ByteSource.wrap("my data".getBytes(StandardCharsets.UTF_8));
       runCreateContainerInLocation(payload, nonDefault);
    }
 
@@ -108,11 +111,11 @@ public class BaseContainerLiveTest extends BaseBlobStoreIntegrationTest {
    public void testPublicAccessInNonDefaultLocationWithBigBlob() throws InterruptedException, MalformedURLException,
             IOException {
       Location nonDefault = findNonDefaultLocationOrSkip(view.getBlobStore(), defaultLocation);
-      String payload = Strings.repeat("a", 1024 * 1024); // 1MB
+      ByteSource payload = TestUtils.randomByteSource().slice(0, 1024 * 1024);
       runCreateContainerInLocation(payload, nonDefault);
    }
 
-   private void runCreateContainerInLocation(String payload, Location nonDefault) throws InterruptedException,
+   private void runCreateContainerInLocation(ByteSource payload, Location nonDefault) throws InterruptedException,
             IOException {
       String blobName = "hello";
       BlobStore blobStore = view.getBlobStore();
@@ -124,12 +127,15 @@ public class BaseContainerLiveTest extends BaseBlobStoreIntegrationTest {
          assertConsistencyAwareContainerExists(containerName);
          assertConsistencyAwareContainerInLocation(containerName, nonDefault);
 
-         blobStore.putBlob(containerName, blobStore.blobBuilder(blobName).payload(payload).build());
+         blobStore.putBlob(containerName, blobStore.blobBuilder(blobName)
+            .payload(payload)
+            .contentLength(payload.size())
+            .build());
 
          assertConsistencyAwareContainerSize(containerName, 1);
 
          BlobMetadata metadata = view.getBlobStore().blobMetadata(containerName, blobName);
-         assertEquals(Strings2.toStringAndClose(view.utils().http().get(metadata.getPublicUri())), payload);
+         assertEquals(ByteStreams2.toByteArrayAndClose(view.utils().http().get(metadata.getPublicUri())), payload.read());
 
          assertConsistencyAwareBlobInLocation(containerName, blobName, nonDefault);