Added methods U.downloadUrl(url, fileName) and U.decompressGzip(source, target).

Author: javadev

src/main/java/com/github/underscore/lodash/U.java

@@ -28,7 +28,16 @@
 import com.github.underscore.PredicateIndexed;
 import com.github.underscore.Tuple;
 import com.github.underscore.Underscore;
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.net.URL;
+import java.nio.channels.Channels;
+import java.nio.channels.ReadableByteChannel;
 import java.nio.charset.StandardCharsets;
+import java.nio.file.Files;
+import java.nio.file.Paths;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collection;
@@ -48,6 +57,7 @@
 import java.util.function.Consumer;
 import java.util.function.Function;
 import java.util.function.Predicate;
+import java.util.zip.GZIPInputStream;
 
 public class U<T> extends Underscore<T> {
     private static final int DEFAULT_TRUNC_LENGTH = 30;
@@ -1948,6 +1958,22 @@ public Map<String, Object> xmlMap() {
         }
     }
 
+    public static long downloadUrl(final String url, final String fileName) throws IOException {
+        final URL website = new URL(url);
+        try (ReadableByteChannel rbc = Channels.newChannel(website.openStream());
+                final FileOutputStream fos = new FileOutputStream(fileName)) {
+            return fos.getChannel().transferFrom(rbc, 0, Long.MAX_VALUE);
+        }
+    }
+
+    public static void decompressGzip(final String sourceFileName, final String targetFileName)
+            throws IOException {
+        try (GZIPInputStream gis =
+                new GZIPInputStream(new FileInputStream(new File(sourceFileName)))) {
+            Files.copy(gis, Paths.get(targetFileName));
+        }
+    }
+
     public static FetchResponse fetch(final String url) {
         return fetch(url, null, null, DEFAULT_HEADER_FIELDS, null, null);
     }
@@ -2156,8 +2182,14 @@ && nonNull(timeBetweenRetry)
                 UnsupportedOperationException saveException;
                 do {
                     try {
-                        final FetchResponse fetchResponse = U.fetch(
-                                url, method, body, headerFields, connectTimeout, readTimeout);
+                        final FetchResponse fetchResponse =
+                                U.fetch(
+                                        url,
+                                        method,
+                                        body,
+                                        headerFields,
+                                        connectTimeout,
+                                        readTimeout);
                         if (fetchResponse.getStatus() == 429) {
                             saveException = new UnsupportedOperationException("Too Many Requests");
                         } else {

src/test/java/com/github/underscore/lodash/LodashTest.java

@@ -31,6 +31,10 @@
 import static org.junit.jupiter.api.Assertions.assertThrows;
 
 import com.github.underscore.Tuple;
+
+import java.io.IOException;
+import java.nio.file.Files;
+import java.nio.file.Paths;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collections;
@@ -492,6 +496,21 @@ void fetchGet() {
                 .fetch();
     }
 
+    @Test
+    void downloadUrl() throws IOException {
+        long result =
+                U.downloadUrl(
+                        "https://support.oneskyapp.com/hc/en-us/article_attachments/202761627/example_1.json", "test.json");
+        assertEquals(65, result);
+    }
+
+    @Test
+    void decompressGzip() throws IOException {
+        Files.deleteIfExists(Paths.get("file.txt"));
+        U.decompressGzip("src/test/resources/file.gz", "file.txt");
+        assertEquals(65, Files.readAllBytes(Paths.get("file.txt")).length);
+    }
+
     @Test
     void fetchGetWithTimeouts() {
         U.FetchResponse result =