Nenhuma descrição

RNFetchBlobFS.m 27KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768
  1. // RNFetchBlobFS.m
  2. // RNFetchBlob
  3. //
  4. // Created by Ben Hsieh on 2016/6/6.
  5. // Copyright © 2016年 suzuri04x2. All rights reserved.
  6. //
  7. #import <Foundation/Foundation.h>
  8. #import "RCTBridge.h"
  9. #import "RNFetchBlob.h"
  10. #import "RCTEventDispatcher.h"
  11. #import "RNFetchBlobFS.h"
  12. #import "RNFetchBlobConst.h"
  13. #import "IOS7Polyfill.h"
  14. @import AssetsLibrary;
  15. NSMutableDictionary *fileStreams = nil;
  16. ////////////////////////////////////////
  17. //
  18. // File system access methods
  19. //
  20. ////////////////////////////////////////
  21. @interface RNFetchBlobFS() {
  22. UIDocumentInteractionController * docCtrl;
  23. }
  24. @end
  25. @implementation RNFetchBlobFS
  26. @synthesize outStream;
  27. @synthesize inStream;
  28. @synthesize encoding;
  29. @synthesize callback;
  30. @synthesize taskId;
  31. @synthesize path;
  32. @synthesize appendData;
  33. @synthesize bufferSize;
  34. - (id)init {
  35. self = [super init];
  36. return self;
  37. }
  38. - (id)initWithCallback:(RCTResponseSenderBlock)callback {
  39. self = [super init];
  40. self.callback = callback;
  41. return self;
  42. }
  43. - (id)initWithBridgeRef:(RCTBridge *)bridgeRef {
  44. self = [super init];
  45. self.bridge = bridgeRef;
  46. return self;
  47. }
  48. // static member getter
  49. + (NSArray *) getFileStreams {
  50. if(fileStreams == nil)
  51. fileStreams = [[NSMutableDictionary alloc] init];
  52. return fileStreams;
  53. }
  54. +(void) setFileStream:(RNFetchBlobFS *) instance withId:(NSString *) uuid {
  55. if(fileStreams == nil)
  56. fileStreams = [[NSMutableDictionary alloc] init];
  57. [fileStreams setValue:instance forKey:uuid];
  58. }
  59. +(NSString *) getPathOfAsset:(NSString *)assetURI
  60. {
  61. // get file path of an app asset
  62. if([assetURI hasPrefix:ASSET_PREFIX])
  63. {
  64. assetURI = [assetURI stringByReplacingOccurrencesOfString:ASSET_PREFIX withString:@""];
  65. assetURI = [[NSBundle mainBundle] pathForResource: [assetURI stringByDeletingPathExtension]
  66. ofType: [assetURI pathExtension]];
  67. }
  68. return assetURI;
  69. }
  70. #pragma mark - system directories
  71. + (NSString *) getMainBundleDir {
  72. return [[NSBundle mainBundle] bundlePath];
  73. }
  74. + (NSString *) getCacheDir {
  75. return [NSSearchPathForDirectoriesInDomains(NSCachesDirectory, NSUserDomainMask, YES) firstObject];
  76. }
  77. + (NSString *) getDocumentDir {
  78. return [NSSearchPathForDirectoriesInDomains(NSDocumentDirectory, NSUserDomainMask, YES) firstObject];
  79. }
  80. + (NSString *) getMusicDir {
  81. return [NSSearchPathForDirectoriesInDomains(NSMusicDirectory, NSUserDomainMask, YES) firstObject];
  82. }
  83. + (NSString *) getMovieDir {
  84. return [NSSearchPathForDirectoriesInDomains(NSMoviesDirectory, NSUserDomainMask, YES) firstObject];
  85. }
  86. + (NSString *) getPictureDir {
  87. return [NSSearchPathForDirectoriesInDomains(NSPicturesDirectory, NSUserDomainMask, YES) firstObject];
  88. }
  89. + (NSString *) getTempPath {
  90. return NSTemporaryDirectory();
  91. }
  92. + (NSString *) getTempPath:(NSString*)taskId withExtension:(NSString *)ext {
  93. NSString * documentDir = [NSSearchPathForDirectoriesInDomains(NSDocumentDirectory, NSUserDomainMask, YES) firstObject];
  94. NSString * filename = [NSString stringWithFormat:@"/RNFetchBlob_tmp/RNFetchBlobTmp_%@", taskId];
  95. if(ext != nil)
  96. filename = [filename stringByAppendingString: [NSString stringWithFormat:@".%@", ext]];
  97. NSString * tempPath = [documentDir stringByAppendingString: filename];
  98. return tempPath;
  99. }
  100. #pragma margk - readStream
  101. + (void) readStream:(NSString *)uri
  102. encoding:(NSString * )encoding
  103. bufferSize:(int)bufferSize
  104. tick:(int)tick
  105. streamId:(NSString *)streamId
  106. bridgeRef:(RCTBridge *)bridgeRef
  107. {
  108. [[self class] getPathFromUri:uri completionHandler:^(NSString *path, ALAssetRepresentation *asset) {
  109. __block RCTEventDispatcher * event = bridgeRef.eventDispatcher;
  110. __block int read = 0;
  111. __block int backoff = tick *1000;
  112. __block int chunkSize = bufferSize;
  113. // allocate buffer in heap instead of stack
  114. uint8_t * buffer;
  115. @try
  116. {
  117. buffer = (uint8_t *) malloc(bufferSize);
  118. if(path != nil)
  119. {
  120. if([[NSFileManager defaultManager] fileExistsAtPath:path] == NO)
  121. {
  122. NSString * message = [NSString stringWithFormat:@"File not exists at path %@", path];
  123. NSDictionary * payload = @{ @"event": FS_EVENT_ERROR, @"detail": message };
  124. [event sendDeviceEventWithName:streamId body:payload];
  125. free(buffer);
  126. return ;
  127. }
  128. NSInputStream * stream = [[NSInputStream alloc] initWithFileAtPath:path];
  129. [stream open];
  130. while((read = [stream read:buffer maxLength:bufferSize]) > 0)
  131. {
  132. [[self class] emitDataChunks:[NSData dataWithBytes:buffer length:read] encoding:encoding streamId:streamId event:event];
  133. if(tick > 0)
  134. {
  135. usleep(backoff);
  136. }
  137. }
  138. [stream close];
  139. }
  140. else if (asset != nil)
  141. {
  142. int cursor = 0;
  143. NSError * err;
  144. while((read = [asset getBytes:buffer fromOffset:cursor length:bufferSize error:&err]) > 0)
  145. {
  146. cursor += read;
  147. [[self class] emitDataChunks:[NSData dataWithBytes:buffer length:read] encoding:encoding streamId:streamId event:event];
  148. if(tick > 0)
  149. {
  150. usleep(backoff);
  151. }
  152. }
  153. }
  154. else
  155. {
  156. NSDictionary * payload = @{ @"event": FS_EVENT_ERROR, @"detail": @"RNFetchBlob.readStream unable to resolve URI" };
  157. [event sendDeviceEventWithName:streamId body:payload];
  158. }
  159. // release buffer
  160. if(buffer != nil)
  161. free(buffer);
  162. }
  163. @catch (NSError * err)
  164. {
  165. NSDictionary * payload = @{ @"event": FS_EVENT_ERROR, @"detail": [NSString stringWithFormat:@"RNFetchBlob.readStream error %@", [err description]] };
  166. [event sendDeviceEventWithName:streamId body:payload];
  167. }
  168. @finally
  169. {
  170. NSDictionary * payload = @{ @"event": FS_EVENT_END, @"detail": @"" };
  171. [event sendDeviceEventWithName:streamId body:payload];
  172. }
  173. }];
  174. }
  175. // send read stream chunks via native event emitter
  176. + (void) emitDataChunks:(NSData *)data encoding:(NSString *) encoding streamId:(NSString *)streamId event:(RCTEventDispatcher *)event
  177. {
  178. NSString * encodedChunk = @"";
  179. if([[encoding lowercaseString] isEqualToString:@"utf8"])
  180. {
  181. NSDictionary * payload = @{ @"event": FS_EVENT_DATA, @"detail" : [[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding] };
  182. [event sendDeviceEventWithName:streamId body:payload];
  183. }
  184. else if ([[encoding lowercaseString] isEqualToString:@"base64"])
  185. {
  186. NSDictionary * payload = @{ @"event": FS_EVENT_DATA, @"detail" : [data base64EncodedStringWithOptions:0] };
  187. [event sendDeviceEventWithName:streamId body:payload];
  188. }
  189. else if([[encoding lowercaseString] isEqualToString:@"ascii"])
  190. {
  191. // RCTBridge only emits string data, so we have to create JSON byte array string
  192. NSMutableArray * asciiArray = [NSMutableArray array];
  193. unsigned char *bytePtr;
  194. if (data.length > 0)
  195. {
  196. bytePtr = (unsigned char *)[data bytes];
  197. NSInteger byteLen = data.length/sizeof(uint8_t);
  198. for (int i = 0; i < byteLen; i++)
  199. {
  200. [asciiArray addObject:[NSNumber numberWithChar:bytePtr[i]]];
  201. }
  202. }
  203. NSDictionary * payload = @{ @"event": FS_EVENT_DATA, @"detail" : asciiArray };
  204. [event sendDeviceEventWithName:streamId body:payload];
  205. }
  206. }
  207. # pragma write file from file
  208. + (NSNumber *) writeFileFromFile:(NSString *)src toFile:(NSString *)dest append:(BOOL)append callback:(void(^)(NSString * errMsg, NSNumber *size))callback
  209. {
  210. [[self class] getPathFromUri:src completionHandler:^(NSString *path, ALAssetRepresentation *asset) {
  211. if(path != nil)
  212. {
  213. __block NSInputStream * is = [[NSInputStream alloc] initWithFileAtPath:path];
  214. __block NSOutputStream * os = [[NSOutputStream alloc] initToFileAtPath:dest append:append];
  215. [is open];
  216. [os open];
  217. uint8_t buffer[10240];
  218. __block long written = 0;
  219. int read = [is read:buffer maxLength:10240];
  220. written += read;
  221. while(read > 0) {
  222. [os write:buffer maxLength:read];
  223. read = [is read:buffer maxLength:10240];
  224. written += read;
  225. }
  226. [os close];
  227. [is close];
  228. __block NSNumber * size = [NSNumber numberWithLong:written];
  229. callback(nil, size);
  230. }
  231. else if(asset != nil)
  232. {
  233. __block NSOutputStream * os = [[NSOutputStream alloc] initToFileAtPath:dest append:append];
  234. int read = 0;
  235. int cursor = 0;
  236. __block long written = 0;
  237. uint8_t buffer[10240];
  238. [os open];
  239. while((read = [asset getBytes:buffer fromOffset:cursor length:10240 error:nil]) > 0)
  240. {
  241. cursor += read;
  242. [os write:buffer maxLength:read];
  243. }
  244. __block NSNumber * size = [NSNumber numberWithLong:written];
  245. [os close];
  246. callback(nil, size);
  247. }
  248. else
  249. callback(@"failed to resolve path", nil);
  250. }];
  251. return 0;
  252. }
  253. # pragma mark - write file
  254. + (void) writeFile:(NSString *)path encoding:(NSString *)encoding data:(NSString *)data append:(BOOL)append resolver:(RCTPromiseResolveBlock)resolve rejecter:(RCTPromiseRejectBlock)reject
  255. {
  256. @try {
  257. NSFileManager * fm = [NSFileManager defaultManager];
  258. NSError * err = nil;
  259. // check if the folder exists, if not exists, create folders recursively
  260. // after the folders created, write data into the file
  261. NSString * folder = [path stringByDeletingLastPathComponent];
  262. encoding = [encoding lowercaseString];
  263. if(![fm fileExistsAtPath:folder]) {
  264. [fm createDirectoryAtPath:folder withIntermediateDirectories:YES attributes:NULL error:&err];
  265. [fm createFileAtPath:path contents:nil attributes:nil];
  266. }
  267. if(err != nil) {
  268. reject(@"RNFetchBlob writeFile Error", @"could not create file at path", nil);
  269. return;
  270. }
  271. NSFileHandle *fileHandle = [NSFileHandle fileHandleForWritingAtPath:path];
  272. NSData * content = nil;
  273. if([encoding RNFBContainsString:@"base64"]) {
  274. content = [[NSData alloc] initWithBase64EncodedString:data options:0];
  275. }
  276. else if([encoding isEqualToString:@"uri"]) {
  277. NSNumber* size = [[self class] writeFileFromFile:data toFile:path append:append callback:^(NSString *errMsg, NSNumber *size) {
  278. if(errMsg != nil)
  279. reject(@"RNFetchBlob writeFile Error", errMsg, nil);
  280. else
  281. resolve(size);
  282. }];
  283. return;
  284. }
  285. else {
  286. content = [data dataUsingEncoding:NSUTF8StringEncoding];
  287. }
  288. if(append == YES) {
  289. [fileHandle seekToEndOfFile];
  290. [fileHandle writeData:content];
  291. [fileHandle closeFile];
  292. }
  293. else {
  294. [content writeToFile:path atomically:YES];
  295. }
  296. fm = nil;
  297. resolve([NSNumber numberWithInteger:[content length]]);
  298. }
  299. @catch (NSException * e)
  300. {
  301. reject(@"RNFetchBlob writeFile Error", @"Error", [e description]);
  302. }
  303. }
  304. # pragma mark - write file (array)
  305. + (void) writeFileArray:(NSString *)path data:(NSArray *)data append:(BOOL)append resolver:(RCTPromiseResolveBlock)resolve rejecter:(RCTPromiseRejectBlock)reject {
  306. @try {
  307. NSFileManager * fm = [NSFileManager defaultManager];
  308. NSError * err = nil;
  309. // check if the folder exists, if not exists, create folders recursively
  310. // after the folders created, write data into the file
  311. NSString * folder = [path stringByDeletingLastPathComponent];
  312. if(![fm fileExistsAtPath:folder]) {
  313. [fm createDirectoryAtPath:folder withIntermediateDirectories:YES attributes:NULL error:&err];
  314. }
  315. NSMutableData * fileContent = [NSMutableData alloc];
  316. // prevent stack overflow, alloc on heap
  317. char * bytes = (char*) malloc([data count]);
  318. for(int i = 0; i < data.count; i++) {
  319. bytes[i] = [[data objectAtIndex:i] charValue];
  320. }
  321. [fileContent appendBytes:bytes length:data.count];
  322. if(![fm fileExistsAtPath:path]) {
  323. [fm createFileAtPath:path contents:fileContent attributes:NULL];
  324. }
  325. // if file exists, write file
  326. else {
  327. if(append == YES) {
  328. NSFileHandle *fileHandle = [NSFileHandle fileHandleForWritingAtPath:path];
  329. [fileHandle seekToEndOfFile];
  330. [fileHandle writeData:fileContent];
  331. [fileHandle closeFile];
  332. }
  333. else {
  334. [fileContent writeToFile:path atomically:YES];
  335. }
  336. }
  337. free(bytes);
  338. fm = nil;
  339. resolve([NSNumber numberWithInteger: data.count]);
  340. }
  341. @catch (NSException * e)
  342. {
  343. reject(@"RNFetchBlob writeFile Error", @"Error", [e description]);
  344. }
  345. }
  346. # pragma mark - read file
  347. + (void) readFile:(NSString *)path encoding:(NSString *)encoding
  348. resolver:(RCTPromiseResolveBlock)resolve
  349. rejecter:(RCTPromiseRejectBlock)reject
  350. onComplete:(void (^)(NSData * content))onComplete
  351. {
  352. @try
  353. {
  354. [[self class] getPathFromUri:path completionHandler:^(NSString *path, ALAssetRepresentation *asset) {
  355. __block NSData * fileContent;
  356. NSError * err;
  357. __block Byte * buffer;
  358. if(asset != nil)
  359. {
  360. buffer = malloc(asset.size);
  361. [asset getBytes:buffer fromOffset:0 length:asset.size error:&err];
  362. if(err != nil)
  363. {
  364. reject(@"RNFetchBlobFS readFile error", @"failed to read asset", [err localizedDescription]);
  365. return;
  366. }
  367. fileContent = [NSData dataWithBytes:buffer length:asset.size];
  368. free(buffer);
  369. }
  370. else
  371. {
  372. if(![[NSFileManager defaultManager] fileExistsAtPath:path]) {
  373. reject(@"RNFetchBlobFS readFile error", @"file not exists", nil);
  374. return;
  375. }
  376. fileContent = [NSData dataWithContentsOfFile:path];
  377. }
  378. if(onComplete != nil)
  379. onComplete(fileContent);
  380. if([[encoding lowercaseString] isEqualToString:@"utf8"]) {
  381. if(resolve != nil) {
  382. NSString * utf8 = [[NSString alloc] initWithData:fileContent encoding:NSUTF8StringEncoding];
  383. if(utf8 == nil)
  384. resolve([[NSString alloc] initWithData:fileContent encoding:NSISOLatin1StringEncoding]);
  385. else
  386. resolve(utf8);
  387. }
  388. }
  389. else if ([[encoding lowercaseString] isEqualToString:@"base64"]) {
  390. if(resolve != nil)
  391. resolve([fileContent base64EncodedStringWithOptions:0]);
  392. }
  393. else if ([[encoding lowercaseString] isEqualToString:@"ascii"]) {
  394. NSMutableArray * resultArray = [NSMutableArray array];
  395. char * bytes = [fileContent bytes];
  396. for(int i=0;i<[fileContent length];i++) {
  397. [resultArray addObject:[NSNumber numberWithChar:bytes[i]]];
  398. }
  399. if(resolve != nil)
  400. resolve(resultArray);
  401. }
  402. }];
  403. }
  404. @catch(NSException * e)
  405. {
  406. if(reject != nil)
  407. reject(@"RNFetchBlobFS readFile error", @"error", [e description]);
  408. }
  409. }
  410. # pragma mark - mkdir
  411. + (BOOL) mkdir:(NSString *) path {
  412. BOOL isDir;
  413. NSError * err = nil;
  414. // if temp folder not exists, create one
  415. if(![[NSFileManager defaultManager] fileExistsAtPath: path isDirectory:&isDir]) {
  416. [[NSFileManager defaultManager] createDirectoryAtPath:path withIntermediateDirectories:YES attributes:nil error:&err];
  417. }
  418. return err == nil;
  419. }
  420. # pragma mark - stat
  421. + (NSDictionary *) stat:(NSString *) path error:(NSError **) error {
  422. BOOL isDir = NO;
  423. NSFileManager * fm = [NSFileManager defaultManager];
  424. if([fm fileExistsAtPath:path isDirectory:&isDir] == NO) {
  425. return nil;
  426. }
  427. NSDictionary * info = [fm attributesOfItemAtPath:path error:&error];
  428. NSString * size = [NSString stringWithFormat:@"%d", [info fileSize]];
  429. NSString * filename = [path lastPathComponent];
  430. NSDate * lastModified;
  431. [[NSURL fileURLWithPath:path] getResourceValue:&lastModified forKey:NSURLContentModificationDateKey error:&error];
  432. return @{
  433. @"size" : size,
  434. @"filename" : filename,
  435. @"path" : path,
  436. @"lastModified" : [NSString stringWithFormat:@"%d", [lastModified timeIntervalSince1970]],
  437. @"type" : isDir ? @"directory" : @"file"
  438. };
  439. }
  440. # pragma mark - exists
  441. + (void) exists:(NSString *) path callback:(RCTResponseSenderBlock)callback
  442. {
  443. [[self class] getPathFromUri:path completionHandler:^(NSString *path, ALAssetRepresentation *asset) {
  444. if(path != nil)
  445. {
  446. BOOL isDir = NO;
  447. BOOL exists = NO;
  448. exists = [[NSFileManager defaultManager] fileExistsAtPath:path isDirectory: &isDir];
  449. callback(@[@(exists), @(isDir)]);
  450. }
  451. else if(asset != nil)
  452. {
  453. callback(@[@YES, @NO]);
  454. }
  455. else
  456. {
  457. callback(@[@NO, @NO]);
  458. }
  459. }];
  460. }
  461. # pragma mark - open file stream
  462. // Create file stream for write data
  463. - (NSString *)openWithPath:(NSString *)destPath encode:(nullable NSString *)encode appendData:(BOOL)append {
  464. self.outStream = [[NSOutputStream alloc] initToFileAtPath:destPath append:append];
  465. self.encoding = encode;
  466. [self.outStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSRunLoopCommonModes];
  467. [self.outStream open];
  468. NSString *uuid = [[NSUUID UUID] UUIDString];
  469. self.streamId = uuid;
  470. [RNFetchBlobFS setFileStream:self withId:uuid];
  471. return uuid;
  472. }
  473. # pragma mark - file stream write chunk
  474. // Write file chunk into an opened stream
  475. - (void)writeEncodeChunk:(NSString *) chunk {
  476. NSMutableData * decodedData = [NSData alloc];
  477. if([[self.encoding lowercaseString] isEqualToString:@"base64"]) {
  478. decodedData = [[NSData alloc] initWithBase64EncodedData:chunk options:0];
  479. }
  480. if([[self.encoding lowercaseString] isEqualToString:@"utf8"]) {
  481. decodedData = [chunk dataUsingEncoding:NSUTF8StringEncoding];
  482. }
  483. else if([[self.encoding lowercaseString] isEqualToString:@"ascii"]) {
  484. decodedData = [chunk dataUsingEncoding:NSASCIIStringEncoding];
  485. }
  486. NSUInteger left = [decodedData length];
  487. NSUInteger nwr = 0;
  488. do {
  489. nwr = [self.outStream write:[decodedData bytes] maxLength:left];
  490. if (-1 == nwr) break;
  491. left -= nwr;
  492. } while (left > 0);
  493. if (left) {
  494. NSLog(@"stream error: %@", [self.outStream streamError]);
  495. }
  496. }
  497. // Write file chunk into an opened stream
  498. - (void)write:(NSData *) chunk {
  499. NSUInteger left = [chunk length];
  500. NSUInteger nwr = 0;
  501. do {
  502. nwr = [self.outStream write:[chunk bytes] maxLength:left];
  503. if (-1 == nwr) break;
  504. left -= nwr;
  505. } while (left > 0);
  506. if (left) {
  507. NSLog(@"stream error: %@", [self.outStream streamError]);
  508. }
  509. }
  510. // close file write stream
  511. - (void)closeOutStream {
  512. if(self.outStream != nil) {
  513. [self.outStream close];
  514. self.outStream = nil;
  515. }
  516. }
  517. // Slice a file into another file, generally for support Blob implementation.
  518. + (void)slice:(NSString *)path
  519. dest:(NSString *)dest
  520. start:(nonnull NSNumber *)start
  521. end:(nonnull NSNumber *)end
  522. encode:(NSString *)encode
  523. resolver:(RCTPromiseResolveBlock)resolve
  524. rejecter:(RCTPromiseRejectBlock)reject
  525. {
  526. [[self class] getPathFromUri:path completionHandler:^(NSString *path, ALAssetRepresentation *asset)
  527. {
  528. if(path != nil)
  529. {
  530. long expected = [end longValue] - [start longValue];
  531. long read = 0;
  532. NSFileHandle * handle = [NSFileHandle fileHandleForReadingAtPath:path];
  533. NSFileManager * fm = [NSFileManager defaultManager];
  534. NSOutputStream * os = [[NSOutputStream alloc] initToFileAtPath:dest append:NO];
  535. [os open];
  536. // abort for the source file not exists
  537. if([fm fileExistsAtPath:path] == NO)
  538. {
  539. reject(@"RNFetchBlob slice failed : the file does not exists", path, nil);
  540. return;
  541. }
  542. long size = [fm attributesOfItemAtPath:path error:nil].fileSize;
  543. long max = MIN(size, [end longValue]);
  544. if(![fm fileExistsAtPath:dest]) {
  545. [fm createFileAtPath:dest contents:@"" attributes:nil];
  546. }
  547. [handle seekToFileOffset:[start longValue]];
  548. while(read < expected)
  549. {
  550. NSData * chunk;
  551. long chunkSize = 0;
  552. if([start longValue] + read + 10240 > max)
  553. {
  554. NSLog(@"read chunk %lu", max - read - [start longValue]);
  555. chunkSize = max - read - [start longValue];
  556. chunk = [handle readDataOfLength:chunkSize];
  557. }
  558. else
  559. {
  560. NSLog(@"read chunk %lu", 10240);
  561. chunkSize = 10240;
  562. chunk = [handle readDataOfLength:10240];
  563. }
  564. if([chunk length] <= 0)
  565. break;
  566. long remain = expected - read;
  567. [os write:[chunk bytes] maxLength:chunkSize];
  568. read += [chunk length];
  569. }
  570. [handle closeFile];
  571. [os close];
  572. resolve(dest);
  573. }
  574. else if (asset != nil)
  575. {
  576. long expected = [end longValue] - [start longValue];
  577. long read = 0;
  578. long chunkRead = 0;
  579. NSOutputStream * os = [[NSOutputStream alloc] initToFileAtPath:dest append:NO];
  580. [os open];
  581. long size = asset.size;
  582. long max = MIN(size, [end longValue]);
  583. while(read < expected)
  584. {
  585. uint8_t * chunk[10240];
  586. long chunkSize = 0;
  587. if([start longValue] + read + 10240 > max)
  588. {
  589. NSLog(@"read chunk %lu", max - read - [start longValue]);
  590. chunkSize = max - read - [start longValue];
  591. chunkRead = [asset getBytes:chunk fromOffset:[start longValue] + read length:chunkSize error:nil];
  592. }
  593. else
  594. {
  595. NSLog(@"read chunk %lu", 10240);
  596. chunkSize = 10240;
  597. chunkRead = [asset getBytes:chunk fromOffset:[start longValue] + read length:chunkSize error:nil];
  598. }
  599. if( chunkRead <= 0)
  600. break;
  601. long remain = expected - read;
  602. [os write:chunk maxLength:chunkSize];
  603. read += chunkRead;
  604. }
  605. [os close];
  606. resolve(dest);
  607. }
  608. else
  609. {
  610. reject(@"slice error", [NSString stringWithFormat: @"could not resolve URI %@", path ], nil);
  611. }
  612. }];
  613. }
  614. // close file read stream
  615. - (void)closeInStream
  616. {
  617. if(self.inStream != nil) {
  618. [self.inStream close];
  619. [self.inStream removeFromRunLoop:[NSRunLoop currentRunLoop] forMode:NSRunLoopCommonModes];
  620. [[RNFetchBlobFS getFileStreams] setValue:nil forKey:self.streamId];
  621. self.streamId = nil;
  622. }
  623. }
  624. # pragma mark - get absolute path of resource
  625. + (void) getPathFromUri:(NSString *)uri completionHandler:(void(^)(NSString * path, ALAssetRepresentation *asset)) onComplete
  626. {
  627. if([uri hasPrefix:AL_PREFIX])
  628. {
  629. NSURL *asseturl = [NSURL URLWithString:uri];
  630. __block ALAssetsLibrary* assetslibrary = [[ALAssetsLibrary alloc] init];
  631. [assetslibrary assetForURL:asseturl
  632. resultBlock:^(ALAsset *asset) {
  633. __block ALAssetRepresentation * present = [asset defaultRepresentation];
  634. onComplete(nil, present);
  635. }
  636. failureBlock:^(NSError *error) {
  637. onComplete(nil, nil);
  638. }];
  639. }
  640. else
  641. {
  642. onComplete([[self class] getPathOfAsset:uri], nil);
  643. }
  644. }
  645. #pragma mark - get disk space
  646. +(void) df:(RCTResponseSenderBlock)callback
  647. {
  648. uint64_t totalSpace = 0;
  649. uint64_t totalFreeSpace = 0;
  650. NSError *error = nil;
  651. NSArray *paths = NSSearchPathForDirectoriesInDomains(NSDocumentDirectory, NSUserDomainMask, YES);
  652. NSDictionary *dictionary = [[NSFileManager defaultManager] attributesOfFileSystemForPath:[paths lastObject] error: &error];
  653. if (dictionary) {
  654. NSNumber *fileSystemSizeInBytes = [dictionary objectForKey: NSFileSystemSize];
  655. NSNumber *freeFileSystemSizeInBytes = [dictionary objectForKey:NSFileSystemFreeSize];
  656. totalSpace = [fileSystemSizeInBytes unsignedLongLongValue];
  657. totalFreeSpace = [freeFileSystemSizeInBytes unsignedLongLongValue];
  658. callback(@[[NSNull null], @{
  659. @"free" : [NSString stringWithFormat:@"%d", totalFreeSpace],
  660. @"total" : [NSString stringWithFormat:@"%d", totalSpace]
  661. }]);
  662. } else {
  663. callback(@[@"failed to get storage usage."]);
  664. }
  665. }
  666. + (void) writeAssetToPath:(ALAssetRepresentation * )rep dest:(NSString *)dest
  667. {
  668. int read = 0;
  669. int cursor = 0;
  670. Byte * buffer = (Byte *)malloc(10240);
  671. NSOutputStream * ostream = [[NSOutputStream alloc] initToFileAtPath:dest append:NO];
  672. [ostream open];
  673. while((read = [rep getBytes:buffer fromOffset:cursor length:10240 error:nil]) > 0)
  674. {
  675. cursor+=10240;
  676. [ostream write:buffer maxLength:read];
  677. }
  678. [ostream close];
  679. free(buffer);
  680. return;
  681. }
  682. @end