Merge branch 'master' into 0.5.5

README.md

@@ -1,4 +1,4 @@
-# react-native-fetch-blob [![npm version](https://img.shields.io/badge/npm package-0.5.4-brightgreen.svg)](https://badge.fury.io/js/react-native-fetch-blob) ![](https://img.shields.io/badge/PR-Welcome-brightgreen.svg) ![](https://img.shields.io/badge/in progress-0.6.0-yellow.svg)
+# react-native-fetch-blob [![npm version](https://img.shields.io/badge/npm package-0.5.5-brightgreen.svg)](https://badge.fury.io/js/react-native-fetch-blob) ![](https://img.shields.io/badge/PR-Welcome-brightgreen.svg) ![](https://img.shields.io/badge/in progress-0.6.0-yellow.svg)
 
 A module provides upload, download, and files access API. Supports file stream read/write for process large files.
 
@@ -26,7 +26,7 @@ This update is `backward-compatible` generally you don't have to change existing
  * [File access](#user-content-file-access)
  * [File stream](#user-content-file-stream)
  * [Manage cached files](#user-content-manage-cached-files)
- * [Self-Signed SSL Server](#user-content-selfsigned-ssl-server)
+ * [Self-Signed SSL Server](#user-content-self-signed-ssl-server)
 * [API](#user-content-api)
  * [config](#user-content-configoptionsrnfetchblobconfigfetch)
  * [fetch](#user-content-fetchmethod-url-headers-bodypromisefetchblobresponse)
@@ -847,7 +847,8 @@ A `session` is an object that helps you manage files. It simply maintains a list
 
 | Version | |
 |---|---|
-| 0.5.4 | Fix #30 #31 build build error, and improve memory efficiency. | 
+| 0.5.5 | Remove work in progress code added in 0.5.2 which may cause memory leaks. |
+| 0.5.4 | Fix #30 #31 build build error, and improve memory efficiency. |
 | 0.5.3 | Add API for access untrusted SSL server |
 | 0.5.2 | Fix improper url params bug [#26](https://github.com/wkh237/react-native-fetch-blob/issues/26) and change IOS HTTP implementation from NSURLConnection to NSURLSession |
 | 0.5.0 | Upload/download with direct access to file storage, and also added file access APIs |

package.json

@@ -1,6 +1,6 @@
 {
   "name": "fetchblob",
-  "version": "0.5.4",
+  "version": "0.5.5",
   "private": true,
   "scripts": {
     "start": "node node_modules/react-native/local-cli/cli.js start",

src/README.md

@@ -1,4 +1,4 @@
-# react-native-fetch-blob [![npm version](https://img.shields.io/badge/npm package-0.5.4-brightgreen.svg)](https://badge.fury.io/js/react-native-fetch-blob) ![](https://img.shields.io/badge/PR-Welcome-brightgreen.svg) ![](https://img.shields.io/badge/in progress-0.6.0-yellow.svg)
+# react-native-fetch-blob [![npm version](https://img.shields.io/badge/npm package-0.5.5-brightgreen.svg)](https://badge.fury.io/js/react-native-fetch-blob) ![](https://img.shields.io/badge/PR-Welcome-brightgreen.svg) ![](https://img.shields.io/badge/in progress-0.6.0-yellow.svg)
 
 A module provides upload, download, and files access API. Supports file stream read/write for process large files.
 
@@ -26,7 +26,7 @@ This update is `backward-compatible` generally you don't have to change existing
  * [File access](#user-content-file-access)
  * [File stream](#user-content-file-stream)
  * [Manage cached files](#user-content-manage-cached-files)
- * [Self-Signed SSL Server](#user-content-selfsigned-ssl-server)
+ * [Self-Signed SSL Server](#user-content-self-signed-ssl-server)
 * [API](#user-content-api)
  * [config](#user-content-configoptionsrnfetchblobconfigfetch)
  * [fetch](#user-content-fetchmethod-url-headers-bodypromisefetchblobresponse)
@@ -847,6 +847,7 @@ A `session` is an object that helps you manage files. It simply maintains a list
 
 | Version | |
 |---|---|
+| 0.5.5 | Remove work in progress code added in 0.5.2 which may cause memory leaks. |
 | 0.5.4 | Fix #30 #31 build build error, and improve memory efficiency. |
 | 0.5.3 | Add API for access untrusted SSL server |
 | 0.5.2 | Fix improper url params bug [#26](https://github.com/wkh237/react-native-fetch-blob/issues/26) and change IOS HTTP implementation from NSURLConnection to NSURLSession |

src/ios/RNFetchBlob.xcodeproj/project.pbxproj

@@ -233,6 +233,7 @@
 			isa = XCBuildConfiguration;
 			buildSettings = {
 				ALWAYS_SEARCH_USER_PATHS = NO;
+				GCC_INPUT_FILETYPE = automatic;
 				HEADER_SEARCH_PATHS = (
 					"$(inherited)",
 					"$(SRCROOT)/Libraries/**",
@@ -253,6 +254,7 @@
 			isa = XCBuildConfiguration;
 			buildSettings = {
 				ALWAYS_SEARCH_USER_PATHS = NO;
+				GCC_INPUT_FILETYPE = automatic;
 				HEADER_SEARCH_PATHS = (
 					"$(inherited)",
 					"$(SRCROOT)/Libraries/**",

src/ios/RNFetchBlob/RNFetchBlob.m

@@ -130,6 +130,7 @@ RCT_EXPORT_METHOD(fetchBlobForm:(NSDictionary *)options
         // send HTTP request
         RNFetchBlobNetwork * utils = [[RNFetchBlobNetwork alloc] init];
         [utils sendRequest:options bridge:self.bridge taskId:taskId withRequest:request callback:callback];
+        utils = nil;
     });
 }
 
@@ -178,6 +179,7 @@ RCT_EXPORT_METHOD(fetchBlob:(NSDictionary *)options
         // send HTTP request
         RNFetchBlobNetwork * utils = [[RNFetchBlobNetwork alloc] init];
         [utils sendRequest:options bridge:self.bridge taskId:taskId withRequest:request callback:callback];
+        utils = nil;
     });
 }
 

src/ios/RNFetchBlobFS.m

@@ -258,19 +258,18 @@ void runOnMainQueueWithoutDeadlocking(void (^block)(void))
             // read stream incoming chunk
         case NSStreamEventHasBytesAvailable:
         {
-            NSMutableData * chunkData = [[NSMutableData data] init];
+            NSMutableData * chunkData = [[NSMutableData alloc] init];
             NSInteger chunkSize = 4096;
             if([[self.encoding lowercaseString] isEqualToString:@"base64"])
                 chunkSize = 4095;
             if(self.bufferSize > 0)
                 chunkSize = self.bufferSize;
-            uint8_t buf[chunkSize];
+            uint8_t * buf = (uint8_t *)malloc(chunkSize);
             unsigned int len = 0;
-            
             len = [(NSInputStream *)stream read:buf maxLength:chunkSize];
             // still have data in stream
             if(len) {
-                [chunkData appendBytes:(const void *)buf length:len];
+                [chunkData appendBytes:buf length:len];
                 // dispatch data event
                 NSString * encodedChunk = [NSString alloc];
                 if( [[self.encoding lowercaseString] isEqualToString:@"utf8"] ) {
@@ -286,7 +285,6 @@ void runOnMainQueueWithoutDeadlocking(void (^block)(void))
                         NSInteger byteLen = chunkData.length/sizeof(uint8_t);
                         for (int i = 0; i < byteLen; i++)
                         {
-                            uint8_t * byteFromArray = chunkData.bytes;
                             NSInteger val = bytePtr[i];
                             if(i+1 < byteLen)
                                 asciiStr = [asciiStr stringByAppendingFormat:@"%d,", val];
@@ -298,18 +296,22 @@ void runOnMainQueueWithoutDeadlocking(void (^block)(void))
                     asciiStr = [asciiStr stringByAppendingString:@"]"];
                     [self.bridge.eventDispatcher
                      sendDeviceEventWithName:streamEventCode
-                     body:@{
-                            @"event": FS_EVENT_DATA,
-                            @"detail": asciiStr
+                     body: @{
+                             @"event": FS_EVENT_DATA,
+                             @"detail": asciiStr
                             }
                      ];
+                    free(buf);
+                    asciiStr = nil;
+                    buf = nil;
+                    chunkData = nil;
                     return;
                 }
                 // convert byte array to base64 data chunks
                 else if ( [[self.encoding lowercaseString] isEqualToString:@"base64"] ) {
                     encodedChunk = [chunkData base64EncodedStringWithOptions:0];
                 }
-                // unknown encoding, send erro event
+                // unknown encoding, send error event
                 else {
                     [self.bridge.eventDispatcher
                      sendDeviceEventWithName:streamEventCode
@@ -328,7 +330,8 @@ void runOnMainQueueWithoutDeadlocking(void (^block)(void))
                         @"detail": encodedChunk
                         }
                  ];
-                
+                chunkData = nil;
+                free(buf);
             }
             // end of stream
             else {
@@ -339,6 +342,8 @@ void runOnMainQueueWithoutDeadlocking(void (^block)(void))
                         @"detail": @""
                         }
                  ];
+                chunkData = nil;
+                free(buf);
             }
             break;
         }

src/ios/RNFetchBlobNetwork.h

@@ -25,8 +25,8 @@ typedef void(^DataTaskCompletionHander) (NSData * _Nullable resp, NSURLResponse
 @property (nullable, nonatomic) RCTBridge * bridge;
 @property (nullable, nonatomic) NSDictionary * options;
 @property (nullable, nonatomic) RNFetchBlobFS * fileStream;
-@property (strong, nonatomic) CompletionHander fileTaskCompletionHandler;
-@property (strong, nonatomic) DataTaskCompletionHander dataTaskCompletionHandler;
+//@property (strong, nonatomic) CompletionHander fileTaskCompletionHandler;
+//@property (strong, nonatomic) DataTaskCompletionHander dataTaskCompletionHandler;
 @property (nullable, nonatomic) NSError * error;
 
 

src/ios/RNFetchBlobNetwork.m

@@ -32,8 +32,8 @@ NSOperationQueue *taskQueue;
 @synthesize callback;
 @synthesize bridge;
 @synthesize options;
-@synthesize fileTaskCompletionHandler;
-@synthesize dataTaskCompletionHandler;
+//@synthesize fileTaskCompletionHandler;
+//@synthesize dataTaskCompletionHandler;
 @synthesize error;
 
 
@@ -88,7 +88,8 @@ NSOperationQueue *taskQueue;
     // file will be stored at a specific path
     if( path != nil) {
         
-        self.fileTaskCompletionHandler = ^(NSURL * _Nullable location, NSURLResponse * _Nullable response, NSError * _Nullable error) {
+//        self.fileTaskCompletionHandler = ;
+        NSURLSessionDownloadTask * task = [session downloadTaskWithRequest:req completionHandler:^(NSURL * _Nullable location, NSURLResponse * _Nullable response, NSError * _Nullable error) {
             if(error != nil) {
                 callback(@[[error localizedDescription]]);
                 return;
@@ -102,14 +103,16 @@ NSOperationQueue *taskQueue;
                 return;
             }
             callback(@[[NSNull null], path]);
-        };
-        NSURLSessionDownloadTask * task = [session downloadTaskWithRequest:req completionHandler:fileTaskCompletionHandler];
+            // prevent memory leaks
+            self.respData = nil;
+        }];
         [task resume];
     }
     // file will be stored at tmp path
     else if ( [self.options valueForKey:CONFIG_USE_TEMP]!= nil ) {
         
-        self.fileTaskCompletionHandler = ^(NSURL * _Nullable location, NSURLResponse * _Nullable response, NSError * _Nullable error) {
+//        self.fileTaskCompletionHandler;
+        NSURLSessionDownloadTask * task = [session downloadTaskWithRequest:req completionHandler:^(NSURL * _Nullable location, NSURLResponse * _Nullable response, NSError * _Nullable error) {
             if(error != nil) {
                 callback(@[[error localizedDescription]]);
                 return;
@@ -124,13 +127,15 @@ NSOperationQueue *taskQueue;
                 return;
             }
             callback(@[[NSNull null], tmpPath]);
-        };
-        NSURLSessionDownloadTask * task = [session downloadTaskWithRequest:req completionHandler:fileTaskCompletionHandler];
+            // prevent memory leaks
+            self.respData = nil;
+        }];
         [task resume];
     }
     // base64 response
     else {
-        self.dataTaskCompletionHandler = ^(NSData * _Nullable resp, NSURLResponse * _Nullable response, NSError * _Nullable error) {
+//        self.dataTaskCompletionHandler = ;
+        NSURLSessionDataTask * task = [session dataTaskWithRequest:req completionHandler:^(NSData * _Nullable resp, NSURLResponse * _Nullable response, NSError * _Nullable error) {
             if(error != nil) {
                 callback(@[[error localizedDescription]]);
                 return;
@@ -138,8 +143,7 @@ NSOperationQueue *taskQueue;
             else {
                 callback(@[[NSNull null], [resp base64EncodedStringWithOptions:0]]);
             }
-        };
-        NSURLSessionDataTask * task = [session dataTaskWithRequest:req completionHandler:dataTaskCompletionHandler];
+        }];
         [task resume];
     }
 }
@@ -205,17 +209,17 @@ NSOperationQueue *taskQueue;
     
 }
 
-- (void) URLSessionDidFinishEventsForBackgroundURLSession:(NSURLSession *)session
-{
-    if(self.dataTaskCompletionHandler != nil)
-    {
-        dataTaskCompletionHandler(self.respData, nil, error);
-    }
-    else if(self.fileTaskCompletionHandler != nil)
-    {
-        fileTaskCompletionHandler(nil, nil, self.error);
-    }
-}
+//- (void) URLSessionDidFinishEventsForBackgroundURLSession:(NSURLSession *)session
+//{
+//    if(self.dataTaskCompletionHandler != nil)
+//    {
+//        dataTaskCompletionHandler(self.respData, nil, error);
+//    }
+//    else if(self.fileTaskCompletionHandler != nil)
+//    {
+//        fileTaskCompletionHandler(nil, nil, self.error);
+//    }
+//}
 
 - (void) URLSession:(NSURLSession *)session task:(NSURLSessionTask *)task didReceiveChallenge:(NSURLAuthenticationChallenge *)challenge completionHandler:(void (^)(NSURLSessionAuthChallengeDisposition, NSURLCredential * _Nullable))completionHandler
 {

src/package.json

@@ -1,6 +1,6 @@
 {
   "name": "react-native-fetch-blob",
-  "version": "0.5.4",
+  "version": "0.5.5",
   "description": "A module provides upload, download, and files access API. Supports file stream read/write for process large files.",
   "main": "index.js",
   "scripts": {