Merge pull request #583 from jonnynfb/fix-Android-downloadFile-overflow

fix Android downloadFile overflow contentLength and bytesWritten

Author: itinance

android/src/main/java/com/rnfs/DownloadParams.java

@@ -12,11 +12,11 @@ public interface OnTaskCompleted {
   }
 
   public interface OnDownloadBegin {
-    void onDownloadBegin(int statusCode, int contentLength, Map<String, String> headers);
+    void onDownloadBegin(int statusCode, long contentLength, Map<String, String> headers);
   }
 
   public interface OnDownloadProgress {
-    void onDownloadProgress(int contentLength, int bytesWritten);
+    void onDownloadProgress(long contentLength, long bytesWritten);
   }
 
   public URL src;

android/src/main/java/com/rnfs/DownloadResult.java

@@ -2,6 +2,6 @@
 
 public class DownloadResult {
   public int statusCode;
-  public int bytesWritten;
+  public long bytesWritten;
   public Exception exception;
 }

android/src/main/java/com/rnfs/Downloader.java

@@ -19,7 +19,7 @@
 
 import com.facebook.react.bridge.ReadableMapKeySetIterator;
 
-public class Downloader extends AsyncTask<DownloadParams, int[], DownloadResult> {
+public class Downloader extends AsyncTask<DownloadParams, long[], DownloadResult> {
   private DownloadParams mParam;
   private AtomicBoolean mAbort = new AtomicBoolean(false);
   DownloadResult res;
@@ -64,7 +64,7 @@ private void download(DownloadParams param, DownloadResult res) throws Exception
       connection.connect();
 
       int statusCode = connection.getResponseCode();
-      int lengthOfFile = connection.getContentLength();
+      long lengthOfFile = connection.getContentLengthLong();
 
       boolean isRedirect = (
         statusCode != HttpURLConnection.HTTP_OK &&
@@ -85,7 +85,7 @@ private void download(DownloadParams param, DownloadResult res) throws Exception
         connection.connect();
 
         statusCode = connection.getResponseCode();
-        lengthOfFile = connection.getContentLength();
+        lengthOfFile = connection.getContentLengthLong();
       }
       if(statusCode >= 200 && statusCode < 300) {
         Map<String, List<String>> headers = connection.getHeaderFields();
@@ -107,7 +107,7 @@ private void download(DownloadParams param, DownloadResult res) throws Exception
         output = new FileOutputStream(param.dest);
 
         byte data[] = new byte[8 * 1024];
-        int total = 0;
+        long total = 0;
         int count;
         double lastProgressValue = 0;
 
@@ -116,14 +116,14 @@ private void download(DownloadParams param, DownloadResult res) throws Exception
 
           total += count;
           if (param.progressDivider <= 0) {
-            publishProgress(new int[]{lengthOfFile, total});
+            publishProgress(new long[]{lengthOfFile, total});
           } else {
             double progress = Math.round(((double) total * 100) / lengthOfFile);
             if (progress % param.progressDivider == 0) {
               if ((progress != lastProgressValue) || (total == lengthOfFile)) {
                 Log.d("Downloader", "EMIT: " + String.valueOf(progress) + ", TOTAL:" + String.valueOf(total));
                 lastProgressValue = progress;
-                publishProgress(new int[]{lengthOfFile, total});
+                publishProgress(new long[]{lengthOfFile, total});
               }
             }
           }
@@ -146,7 +146,7 @@ protected void stop() {
   }
 
   @Override
-  protected void onProgressUpdate(int[]... values) {
+  protected void onProgressUpdate(long[]... values) {
     super.onProgressUpdate(values);
     mParam.onDownloadProgress.onDownloadProgress(values[0][0], values[0][1]);
   }

android/src/main/java/com/rnfs/RNFSManager.java

@@ -654,7 +654,7 @@ public void onTaskCompleted(DownloadResult res) {
 
             infoMap.putInt("jobId", jobId);
             infoMap.putInt("statusCode", res.statusCode);
-            infoMap.putInt("bytesWritten", res.bytesWritten);
+            infoMap.putDouble("bytesWritten", (double)res.bytesWritten);
 
             promise.resolve(infoMap);
           } else {
@@ -664,7 +664,7 @@ public void onTaskCompleted(DownloadResult res) {
       };
 
       params.onDownloadBegin = new DownloadParams.OnDownloadBegin() {
-        public void onDownloadBegin(int statusCode, int contentLength, Map<String, String> headers) {
+        public void onDownloadBegin(int statusCode, long contentLength, Map<String, String> headers) {
           WritableMap headersMap = Arguments.createMap();
 
           for (Map.Entry<String, String> entry : headers.entrySet()) {
@@ -675,20 +675,20 @@ public void onDownloadBegin(int statusCode, int contentLength, Map<String, Strin
 
           data.putInt("jobId", jobId);
           data.putInt("statusCode", statusCode);
-          data.putInt("contentLength", contentLength);
+          data.putDouble("contentLength", (double)contentLength);
           data.putMap("headers", headersMap);
 
           sendEvent(getReactApplicationContext(), "DownloadBegin-" + jobId, data);
         }
       };
 
       params.onDownloadProgress = new DownloadParams.OnDownloadProgress() {
-        public void onDownloadProgress(int contentLength, int bytesWritten) {
+        public void onDownloadProgress(long contentLength, long bytesWritten) {
           WritableMap data = Arguments.createMap();
 
           data.putInt("jobId", jobId);
-          data.putInt("contentLength", contentLength);
-          data.putInt("bytesWritten", bytesWritten);
+          data.putDouble("contentLength", (double)contentLength);
+          data.putDouble("bytesWritten", (double)bytesWritten);
 
           sendEvent(getReactApplicationContext(), "DownloadProgress-" + jobId, data);
         }