설명 없음

RNFetchBlobFS.m 26KB

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