Add support for uploading remote urls through Uploader.uploadLarge()

Author: nitzanj

cloudinary-core/src/main/java/com/cloudinary/Uploader.java

@@ -112,6 +112,7 @@ public Map uploadLarge(Object file, Map options, int bufferSize) throws IOExcept
     public Map uploadLarge(Object file, Map options, int bufferSize, ProgressCallback progressCallback) throws IOException {
         InputStream input;
         long length = -1;
+        boolean remote = false;
         if (file instanceof InputStream) {
             input = (InputStream) file;
         } else if (file instanceof File) {
@@ -121,15 +122,27 @@ public Map uploadLarge(Object file, Map options, int bufferSize, ProgressCallbac
             length = ((byte[]) file).length;
             input = new ByteArrayInputStream((byte[]) file);
         } else {
-            File f = new File(file.toString());
-            length = f.length();
-            input = new FileInputStream(f);
+            if (StringUtils.isRemoteUrl(file.toString())){
+                remote = true;
+                input = null;
+            } else {
+                File f = new File(file.toString());
+                length = f.length();
+                input = new FileInputStream(f);
+            }
         }
         try {
-            Map result = uploadLargeParts(input, options, bufferSize, length, progressCallback);
+            final Map result;
+            if (remote) {
+                result = upload(file, options);
+            } else {
+                result = uploadLargeParts(input, options, bufferSize, length, progressCallback);
+            }
             return result;
         } finally {
-            input.close();
+            if (input != null) {
+                input.close();
+            }
         }
     }
 

cloudinary-core/src/main/java/com/cloudinary/utils/StringUtils.java

@@ -113,4 +113,8 @@ public static String read(InputStream in) throws IOException {
         return new String(baos.toByteArray());
     }
 
+    public static boolean isRemoteUrl(String file) {
+        return file.matches("ftp:.*|https?:.*|s3:.*|data:[^;]*;base64,([a-zA-Z0-9/+\n=]+)");
+    }
+
 }

cloudinary-http44/src/main/java/com/cloudinary/http44/UploaderStrategy.java

@@ -102,7 +102,7 @@ public Map callApi(String action, Map<String, Object> params, Map options, Objec
             }
         }
 
-        if (file instanceof String && !((String) file).matches("ftp:.*|https?:.*|s3:.*|data:[^;]*;base64,([a-zA-Z0-9/+\n=]+)")) {
+        if (file instanceof String && !StringUtils.isRemoteUrl((String) file)) {
             File _file = new File((String) file);
             if (!_file.isFile() && !_file.canRead()) {
                 throw new IOException("File not found or unreadable: " + file);

cloudinary-test-common/src/main/java/com/cloudinary/test/AbstractUploaderTest.java

@@ -119,6 +119,18 @@ public void testUploadUrl() throws IOException {
         assertEquals(result.get("signature"), expected_signature);
     }
 
+    @Test
+    public void testUploadLargeUrl() throws IOException {
+        Map result = cloudinary.uploader().uploadLarge(REMOTE_TEST_IMAGE, asMap("tags", SDK_TEST_TAG));
+        assertEquals(result.get("width"), SRC_TEST_IMAGE_W);
+        assertEquals(result.get("height"), SRC_TEST_IMAGE_H);
+        Map<String, Object> to_sign = new HashMap<String, Object>();
+        to_sign.put("public_id", result.get("public_id"));
+        to_sign.put("version", ObjectUtils.asString(result.get("version")));
+        String expected_signature = cloudinary.apiSignRequest(to_sign, cloudinary.config.apiSecret);
+        assertEquals(result.get("signature"), expected_signature);
+    }
+
     @Test
     public void testUploadDataUri() throws IOException {
         Map result = cloudinary.uploader().upload("data:image/png;base64,iVBORw0KGgoAA\nAANSUhEUgAAABAAAAAQAQMAAAAlPW0iAAAABlBMVEUAAAD///+l2Z/dAAAAM0l\nEQVR4nGP4/5/h/1+G/58ZDrAz3D/McH8yw83NDDeNGe4Ug9C9zwz3gVLMDA/A6\nP9/AFGGFyjOXZtQAAAAAElFTkSuQmCC", asMap("tags", Arrays.asList(SDK_TEST_TAG, UPLOADER_TAG)));