Fix Android implementation #140

src/android/src/main/java/com/RNFetchBlob/RNFetchBlobBody.java

@@ -372,16 +372,16 @@ public class RNFetchBlobBody extends RequestBody{
      */
     private void emitUploadProgress(int written) {
         RNFetchBlobProgressConfig config = RNFetchBlobReq.getReportUploadProgress(mTaskId);
-        if(!config.enable)
-            return;
-        WritableMap args = Arguments.createMap();
-        args.putString("taskId", mTaskId);
-        args.putString("written", String.valueOf(written));
-        args.putString("total", String.valueOf(contentLength));
-
-        // emit event to js context
-        RNFetchBlob.RCTContext.getJSModule(DeviceEventManagerModule.RCTDeviceEventEmitter.class)
-                .emit(RNFetchBlobConst.EVENT_UPLOAD_PROGRESS, args);
+        if(config.enable && config.shouldReport((float)written/contentLength)) {
+            WritableMap args = Arguments.createMap();
+            args.putString("taskId", mTaskId);
+            args.putString("written", String.valueOf(written));
+            args.putString("total", String.valueOf(contentLength));
+
+            // emit event to js context
+            RNFetchBlob.RCTContext.getJSModule(DeviceEventManagerModule.RCTDeviceEventEmitter.class)
+                    .emit(RNFetchBlobConst.EVENT_UPLOAD_PROGRESS, args);
+        }
     }
 
 }

src/android/src/main/java/com/RNFetchBlob/RNFetchBlobProgressConfig.java

@@ -5,26 +5,12 @@ package com.RNFetchBlob;
  */
 public class RNFetchBlobProgressConfig {
 
-    public boolean shouldReport() {
-        boolean checkCount = true;
-        if(count > 0)
-            checkCount = Math.floor(progress*100/count)> tick;
-        return (lastTick - System.currentTimeMillis() > interval) && enable && checkCount;
-    }
-
-    public void tick(float progress) {
-        this.progress = progress;
-        this.tick ++;
-        this.lastTick = System.currentTimeMillis();
-    }
-
     public enum ReportType {
         Upload,
         Download
     };
 
     long lastTick = 0;
-    float progress = 0;
     int tick = 0;
     int count = -1;
     public int interval = -1;
@@ -38,4 +24,16 @@ public class RNFetchBlobProgressConfig {
         this.count = count;
     }
 
+    public boolean shouldReport(float progress) {
+        boolean checkCount = true;
+        if(count > 0 && progress > 0)
+            checkCount = Math.floor(progress*count)> tick;
+        boolean result = (System.currentTimeMillis() - lastTick> interval) && enable && checkCount;
+        if(result) {
+            tick++;
+            lastTick = System.currentTimeMillis();
+        }
+        return result;
+    }
+
 }

src/android/src/main/java/com/RNFetchBlob/Response/RNFetchBlobDefaultResp.java

@@ -63,8 +63,7 @@ public class RNFetchBlobDefaultResp extends ResponseBody {
             long read =  mOriginalSource.read(sink, byteCount);
             bytesRead += read > 0 ? read : 0;
             RNFetchBlobProgressConfig reportConfig = RNFetchBlobReq.getReportProgress(mTaskId);
-            if(reportConfig != null && reportConfig.shouldReport()) {
-                reportConfig.tick(bytesRead/contentLength());
+            if(reportConfig != null && reportConfig.shouldReport(bytesRead/contentLength())) {
                 WritableMap args = Arguments.createMap();
                 args.putString("taskId", mTaskId);
                 args.putString("written", String.valueOf(bytesRead));

src/android/src/main/java/com/RNFetchBlob/Response/RNFetchBlobFileResp.java

@@ -71,24 +71,27 @@ public class RNFetchBlobFileResp extends ResponseBody {
     private class ProgressReportingSource implements Source {
         @Override
         public long read(Buffer sink, long byteCount) throws IOException {
-            byte [] bytes = new byte[(int) byteCount];
-            long read = originalBody.byteStream().read(bytes, 0, (int) byteCount);
-            bytesDownloaded += read > 0 ? read : 0;
-            Log.i("bytes downloaded", String.valueOf(byteCount) +"/"+ String.valueOf(read) + "=" + String.valueOf(bytesDownloaded));
-            if(read > 0 ) {
-                ofStream.write(bytes, 0, (int) read);
+            try {
+                byte[] bytes = new byte[(int) byteCount];
+                long read = originalBody.byteStream().read(bytes, 0, (int) byteCount);
+                bytesDownloaded += read > 0 ? read : 0;
+                Log.i("bytes downloaded", String.valueOf(byteCount) + "/" + String.valueOf(read) + "=" + String.valueOf(bytesDownloaded));
+                if (read > 0) {
+                    ofStream.write(bytes, 0, (int) read);
+                }
+                RNFetchBlobProgressConfig reportConfig = RNFetchBlobReq.getReportProgress(mTaskId);
+                if (reportConfig != null && reportConfig.shouldReport(bytesDownloaded / contentLength())) {
+                    WritableMap args = Arguments.createMap();
+                    args.putString("taskId", mTaskId);
+                    args.putString("written", String.valueOf(bytesDownloaded));
+                    args.putString("total", String.valueOf(contentLength()));
+                    rctContext.getJSModule(DeviceEventManagerModule.RCTDeviceEventEmitter.class)
+                            .emit(RNFetchBlobConst.EVENT_PROGRESS, args);
+                }
+                return read;
+            } catch(Exception ex) {
+                return -1;
             }
-            RNFetchBlobProgressConfig reportConfig = RNFetchBlobReq.getReportProgress(mTaskId);
-            if(reportConfig != null && reportConfig.shouldReport()) {
-                reportConfig.tick(bytesDownloaded/contentLength());
-                WritableMap args = Arguments.createMap();
-                args.putString("taskId", mTaskId);
-                args.putString("written", String.valueOf(bytesDownloaded));
-                args.putString("total", String.valueOf(contentLength()));
-                rctContext.getJSModule(DeviceEventManagerModule.RCTDeviceEventEmitter.class)
-                        .emit(RNFetchBlobConst.EVENT_PROGRESS, args);
-            }
-            return read;
         }
 
         @Override

src/ios/RNFetchBlob/RNFetchBlob.m

@@ -414,13 +414,14 @@ RCT_EXPORT_METHOD(cancelRequest:(NSString *)taskId callback:(RCTResponseSenderBl
 }
 
 #pragma mark - net.enableProgressReport
-RCT_EXPORT_METHOD(enableProgressReport:(NSString *)taskId interval:(NSNumber*)interval count:(NSNumber*)count  {
+RCT_EXPORT_METHOD(enableProgressReport:(NSString *)taskId interval:(nonnull NSNumber*)interval count:(nonnull NSNumber*)count  {
+    
     RNFetchBlobProgress * cfg = [[RNFetchBlobProgress alloc] initWithType:Download interval:interval count:count];
     [RNFetchBlobNetwork enableProgressReport:taskId config:cfg];
 })
 
 #pragma mark - net.enableUploadProgressReport
-RCT_EXPORT_METHOD(enableUploadProgressReport:(NSString *)taskId interval:(NSNumber*)interval count:(NSNumber*)count{
+RCT_EXPORT_METHOD(enableUploadProgressReport:(NSString *)taskId interval:(nonnull NSNumber*)interval count:(nonnull NSNumber*)count{
     RNFetchBlobProgress * cfg = [[RNFetchBlobProgress alloc] initWithType:Upload interval:interval count:count];
     [RNFetchBlobNetwork enableUploadProgress:taskId config:cfg];
 })

src/ios/RNFetchBlobNetwork.h

@@ -37,8 +37,8 @@ typedef void(^DataTaskCompletionHander) (NSData * _Nullable resp, NSURLResponse
 
 + (NSMutableDictionary  * _Nullable ) normalizeHeaders:(NSDictionary * _Nullable)headers;
 + (void) cancelRequest:(NSString *)taskId;
-+ (void) enableProgressReport:(NSString *) taskId config:(RNFetchBlobProgress*)config;
-+ (void) enableUploadProgress:(NSString *) taskId config:(RNFetchBlobProgress*)config;
++ (void) enableProgressReport:(NSString *) taskId config:(RNFetchBlobProgress *)config;
++ (void) enableUploadProgress:(NSString *) taskId config:(RNFetchBlobProgress *)config;
 - (void) sendRequest:(NSDictionary  * _Nullable )options contentLength:(long)contentLength bridge:(RCTBridge * _Nullable)bridgeRef taskId:(NSString * _Nullable)taskId withRequest:(NSURLRequest * _Nullable)req callback:(_Nullable RCTResponseSenderBlock) callback;
 
 

src/ios/RNFetchBlobNetwork.m

@@ -85,14 +85,14 @@ NSOperationQueue *taskQueue;
     return self;
 }
 
-+ (void) enableProgressReport:(NSString *) taskId
++ (void) enableProgressReport:(NSString *) taskId config:(RNFetchBlobProgress *)config
 {
-    [progressTable setValue:@YES forKey:taskId];
+    [progressTable setValue:config forKey:taskId];
 }
 
-+ (void) enableUploadProgress:(NSString *) taskId
++ (void) enableUploadProgress:(NSString *) taskId config:(RNFetchBlobProgress *)config
 {
-    [uploadProgressTable setValue:@YES forKey:taskId];
+    [uploadProgressTable setValue:config forKey:taskId];
 }
 
 // removing case from headers
@@ -221,11 +221,6 @@ NSOperationQueue *taskQueue;
     if ([response respondsToSelector:@selector(allHeaderFields)])
     {
         NSDictionary *headers = [httpResponse allHeaderFields];
-        if(expectedBytes < 0)
-        {
-            expectedBytes = [[headers valueForKey:@"Content-Length"] intValue];
-            
-        }
         NSString * respCType = [[RNFetchBlobReqBuilder getHeaderIgnoreCases:@"Content-Type" fromHeaders:headers] lowercaseString];
         if(respCType != nil)
         {
@@ -329,8 +324,9 @@ NSOperationQueue *taskQueue;
     {
         [writeStream write:[data bytes] maxLength:[data length]];
     }
-
-    if([progressTable valueForKey:taskId] == @YES)
+    RNFetchBlobProgress * pconfig = [progressTable valueForKey:taskId];
+    NSNumber * now =[NSNumber numberWithFloat:((float)receivedBytes/(float)expectedBytes)];
+    if(pconfig != nil && [pconfig shouldReport:now])
     {
         [self.bridge.eventDispatcher
          sendDeviceEventWithName:EVENT_PROGRESS
@@ -433,13 +429,15 @@ NSOperationQueue *taskQueue;
 // upload progress handler
 - (void) URLSession:(NSURLSession *)session task:(NSURLSessionTask *)task didSendBodyData:(int64_t)bytesSent totalBytesSent:(int64_t)totalBytesWritten totalBytesExpectedToSend:(int64_t)totalBytesExpectedToWrite
 {
-    if([uploadProgressTable valueForKey:taskId] == @YES) {
+    RNFetchBlobProgress * pconfig = [uploadProgressTable valueForKey:taskId];
+    NSNumber * now = [NSNumber numberWithFloat:((float)totalBytesWritten/(float)totalBytesExpectedToWrite)];
+    if(pconfig != nil && [pconfig shouldReport:now]) {
         [self.bridge.eventDispatcher
          sendDeviceEventWithName:EVENT_PROGRESS_UPLOAD
          body:@{
                 @"taskId": taskId,
                 @"written": [NSString stringWithFormat:@"%d", totalBytesWritten],
-                @"total": [NSString stringWithFormat:@"%d", bodyLength]
+                @"total": [NSString stringWithFormat:@"%d", totalBytesExpectedToWrite]
                 }
          ];
     }

src/ios/RNFetchBlobProgress.h

@@ -31,8 +31,7 @@ typedef NS_ENUM(NSUInteger, ProgressType) {
 @property (nonatomic) BOOL enable;
 
 -(id)initWithType:(ProgressType)type interval:(NSNumber*)interval count:(NSNumber *)count;
--(BOOL)shouldReport;
--(void)tick;
+-(BOOL)shouldReport:(NSNumber *) nextProgress;
 
 
 @end

src/ios/RNFetchBlobProgress.m

@@ -12,7 +12,7 @@
 {
     float progress;
     int tick;
-    long lastTick;
+    double lastTick;
 }
 @end
 
@@ -22,33 +22,34 @@
 {
     self = [super init];
     self.count = count;
-    self.interval = interval;
+    self.interval = [NSNumber numberWithFloat:[interval floatValue] /1000];
     self.type = type;
     self.enable = YES;
+    lastTick = 0;
+    tick = 1;
     return self;
 }
 
--(void)tick:(NSNumber *) nextProgress
-{
-    progress = [nextProgress floatValue];
-    tick++;
-    NSTimeInterval timeStamp = [[NSDate date] timeIntervalSince1970];
-    // NSTimeInterval is defined as double
-    NSNumber *timeStampObj = [NSNumber numberWithDouble: timeStamp];
-    lastTick = [timeStampObj longValue];
-}
-
--(BOOL)shouldReport
+-(BOOL)shouldReport:(NSNumber *)nextProgress
 {
     BOOL result = YES;
-    if(self.count > 0)
+    float countF = [self.count floatValue];
+    if(countF > 0 && [nextProgress floatValue] > 0)
     {
-        result = floorf(progress*100/[count floatValue]) > tick;
+        result = (int)(floorf([nextProgress floatValue]*countF)) >= tick;
     }
+    
     NSTimeInterval timeStamp = [[NSDate date] timeIntervalSince1970];
     // NSTimeInterval is defined as double
     NSNumber *timeStampObj = [NSNumber numberWithDouble: timeStamp];
-    return lastTick - [timeStampObj longValue] > [self.interval longValue] && self.enable && result;
+    float delta = [timeStampObj doubleValue] - lastTick;
+    BOOL shouldReport = delta > [self.interval doubleValue] && self.enable && result;
+    if(shouldReport)
+    {
+        tick++;
+        lastTick = [timeStampObj doubleValue];
+    }
+    return shouldReport;
     
 }
 

src/polyfill/XMLHttpRequest.js

@@ -33,7 +33,7 @@ export default class XMLHttpRequest extends XMLHttpRequestEventTarget{
   _response : any = '';
   _responseText : any = null;
   _responseHeaders : any = {};
-  _responseType : '' | 'arraybuffer' | 'blob' | 'document' | 'json' | 'text' = '';
+  _responseType : '' | 'arraybuffer' | 'blob'  | 'json' | 'text' = '';
   // TODO : not suppoted ATM
   _responseURL : null = '';
   _responseXML : null = '';
@@ -331,6 +331,13 @@ export default class XMLHttpRequest extends XMLHttpRequestEventTarget{
             responseDataReady()
           })
         break;
+        case 'arraybuffer':
+          // TODO : to array buffer
+        break
+        case 'json':
+          this._response = resp.json()
+          this._responseText = resp.text()
+        break
         default :
           this._responseText = resp.text()
           this._response = this.responseText