Support new method BlobContainer#move()

This has been added in elasticsearch 2.0.0. See #8782

Wondering if this PR should be split in two parts:

* one that clean the code and which is portable to 1.4, 1.x and master
* one that simply add move() method for master branch

@imotov WDYT?

Closes #49.

Author: dadoonet

src/main/java/org/elasticsearch/cloud/azure/AzureStorageService.java

@@ -59,4 +59,6 @@ static public final class Fields {
     OutputStream getOutputStream(String container, String blob) throws URISyntaxException, StorageException;
 
     ImmutableMap<String,BlobMetaData> listBlobsByPrefix(String container, String keyPath, String prefix) throws URISyntaxException, StorageException, ServiceException;
+
+    void moveBlob(String container, String sourceBlob, String targetBlob) throws URISyntaxException, StorageException;
 }

src/main/java/org/elasticsearch/cloud/azure/AzureStorageServiceImpl.java

@@ -214,6 +214,19 @@ public ImmutableMap<String, BlobMetaData> listBlobsByPrefix(String container, St
         return blobsBuilder.build();
     }
 
+    @Override
+    public void moveBlob(String container, String sourceBlob, String targetBlob) throws URISyntaxException, StorageException {
+        logger.debug("moveBlob container [{}], sourceBlob [{}], targetBlob [{}]", container, sourceBlob, targetBlob);
+        CloudBlobContainer blob_container = client.getContainerReference(container);
+        CloudBlockBlob blobSource = blob_container.getBlockBlobReference(sourceBlob);
+        if (blobSource.exists()) {
+            CloudBlockBlob blobTarget = blob_container.getBlockBlobReference(targetBlob);
+            blobTarget.copyFromBlob(blobSource);
+            blobSource.delete();
+            logger.debug("moveBlob container [{}], sourceBlob [{}], targetBlob [{}] -> done", container, sourceBlob, targetBlob);
+        }
+    }
+
     @Override
     protected void doStart() throws ElasticsearchException {
         logger.debug("starting azure storage client instance");

src/main/java/org/elasticsearch/cloud/azure/blobstore/AzureBlobContainer.java

@@ -118,6 +118,24 @@ public ImmutableMap<String, BlobMetaData> listBlobsByPrefix(@Nullable String pre
         }
     }
 
+    @Override
+    public void move(String sourceBlobName, String targetBlobName) throws IOException {
+        try {
+            String source = keyPath + sourceBlobName;
+            String target = keyPath + targetBlobName;
+
+            logger.debug("moving blob [{}] to [{}] in container {{}}", source, target, blobStore.container());
+
+            blobStore.client().moveBlob(blobStore.container(), source, target);
+        } catch (URISyntaxException e) {
+            logger.warn("can not move blob [{}] to [{}] in container {{}}: {}", sourceBlobName, targetBlobName, blobStore.container(), e.getMessage());
+            throw new IOException(e);
+        } catch (StorageException e) {
+            logger.warn("can not move blob [{}] to [{}] in container {{}}: {}", sourceBlobName, targetBlobName, blobStore.container(), e.getMessage());
+            throw new IOException(e);
+        }
+    }
+
     @Override
     public ImmutableMap<String, BlobMetaData> listBlobs() throws IOException {
         return listBlobsByPrefix(null);

src/test/java/org/elasticsearch/repositories/azure/AzureStorageServiceMock.java

@@ -99,6 +99,17 @@ public ImmutableMap<String, BlobMetaData> listBlobsByPrefix(String container, St
         return map;
     }
 
+    @Override
+    public void moveBlob(String container, String sourceBlob, String targetBlob) throws URISyntaxException, StorageException {
+        for (String blobName : blobs.keySet()) {
+            if (endsWithIgnoreCase(blobName, sourceBlob)) {
+                ByteArrayOutputStream outputStream = blobs.get(blobName);
+                blobs.put(blobName.replace(sourceBlob, targetBlob), outputStream);
+                blobs.remove(blobName);
+            }
+        }
+    }
+
     @Override
     protected void doStart() throws ElasticsearchException {
     }
@@ -133,4 +144,27 @@ public static boolean startsWithIgnoreCase(String str, String prefix) {
         String lcPrefix = prefix.toLowerCase(Locale.ROOT);
         return lcStr.equals(lcPrefix);
     }
+
+    /**
+     * Test if the given String ends with the specified suffix,
+     * ignoring upper/lower case.
+     *
+     * @param str    the String to check
+     * @param suffix the suffix to look for
+     * @see java.lang.String#startsWith
+     */
+    public static boolean endsWithIgnoreCase(String str, String suffix) {
+        if (str == null || suffix == null) {
+            return false;
+        }
+        if (str.endsWith(suffix)) {
+            return true;
+        }
+        if (str.length() < suffix.length()) {
+            return false;
+        }
+        String lcStr = str.substring(0, suffix.length()).toLowerCase(Locale.ROOT);
+        String lcPrefix = suffix.toLowerCase(Locale.ROOT);
+        return lcStr.equals(lcPrefix);
+    }
 }