Implement ios ASCII encoded data fs method

Author: wkh237

src/fs.js

@@ -56,13 +56,23 @@ function session(name:string):RNFetchBlobSession {
 }
 
 function createFile(path:string, data:string, encoding: 'base64' | 'ascii' | 'utf8'):Promise {
+  encoding = encoding || 'utf8'
   return new Promise((resolve, reject) => {
-    RNFetchBlob.createFile(path, data, encoding, (err) => {
+    let handler = (err) => {
       if(err)
-        reject(err)
+      reject(err)
       else
-        resolve()
-    })
+      resolve()
+    }
+    if(encoding.toLowerCase() === 'ascii') {
+      if(Array.isArray(data))
+        RNFetchBlob.createFileASCII(path, data, handler)
+      else
+        reject('`data` of ASCII file must be an array contains numbers')
+    }
+    else {
+      RNFetchBlob.createFile(path, data, encoding, handler)
+    }
   })
 }
 
@@ -80,13 +90,13 @@ function writeStream(
 ):Promise<WriteStream> {
   if(!path)
     throw Error('RNFetchBlob could not open file stream with empty `path`')
-  encoding = encoding || 'base64'
+
   return new Promise((resolve, reject) => {
     RNFetchBlob.writeStream(path, encoding || 'base64', append || false, (err, streamId:string) => {
       if(err)
         reject(err)
       else
-        resolve(new WriteStream(streamId))
+        resolve(new WriteStream(streamId, encoding))
     })
   })
 }
@@ -108,8 +118,14 @@ function readStream(
     throw Error('RNFetchBlob could not open file stream with empty `path`')
   encoding = encoding || 'utf8'
   let stream:RNFetchBlobStream = {
+    // parse JSON array when encoding is ASCII
     onData : function(fn) {
-      this._onData = fn
+      if(encoding.toLowerCase() === 'ascii')
+        this._onData = (data) => {
+          fn(JSON.parse(data))
+        }
+      else
+        this._onData = fn
     },
     onError : function(fn) {
       this._onError = fn
@@ -313,7 +329,12 @@ class WriteStream {
   write(data:string) {
     return new Promise((resolve, reject) => {
       try {
-        RNFetchBlob.writeChunk(this.id, data, (error) => {
+        let method = this.encoding === 'ascii' ? 'writeArrayChunk' : 'writeChunk'
+        if(this.encoding.toLocaleLowerCase() === 'ascii' && !Array.isArray(data)) {
+            reject('ascii input data must be an Array')
+            return
+        }
+        RNFetchBlob[method](this.id, data, (error) => {
           if(error)
             reject(error)
           else

src/ios/RNFetchBlob/RNFetchBlob.m

@@ -261,18 +261,44 @@ - (void)stream:(NSStream *)stream handleEvent:(NSStreamEvent)eventCode {
             // still have data in stream
             if(len) {
                 [chunkData appendBytes:(const void *)buf length:len];
-                // TODO : file read progress ?
                 // dispatch data event
                 NSString * encodedChunk = [NSString alloc];
                 if( [[self.encoding lowercaseString] isEqualToString:@"utf8"] ) {
                     encodedChunk = [encodedChunk initWithData:chunkData encoding:NSUTF8StringEncoding];
                 }
+                // when encoding is ASCII, send byte array data
                 else if ( [[self.encoding lowercaseString] isEqualToString:@"ascii"] ) {
-                    encodedChunk = [encodedChunk initWithData:chunkData encoding:NSASCIIStringEncoding];
+                    // RCTBridge only emits string data, so we have to create JSON byte array string
+                    NSString * asciiStr = @"[";
+                    if (chunkData.length > 0)
+                    {
+                        unsigned char *bytePtr = (unsigned char *)[chunkData bytes];
+                        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];
+                            else
+                                asciiStr = [asciiStr stringByAppendingFormat:@"%d", val];
+                        }
+                    }
+                    asciiStr = [asciiStr stringByAppendingString:@"]"];
+                    [self.bridge.eventDispatcher
+                     sendDeviceEventWithName:streamEventCode
+                     body:@{
+                            @"event": FS_EVENT_DATA,
+                            @"detail": asciiStr
+                        }
+                     ];
+                    return;
                 }
+                // convert byte array to base64 data chunks
                 else if ( [[self.encoding lowercaseString] isEqualToString:@"base64"] ) {
                     encodedChunk = [chunkData base64EncodedStringWithOptions:0];
                 }
+                // unknown encoding, send erro event
                 else {
                     [self.bridge.eventDispatcher
                         sendDeviceEventWithName:streamEventCode
@@ -676,6 +702,26 @@ - (id) init {
 
 }
 
+// method for create file with ASCII content
+RCT_EXPORT_METHOD(createFileASCII:(NSString *)path data:(NSArray *)dataArray callback:(RCTResponseSenderBlock)callback) {
+    
+    NSFileManager * fm = [NSFileManager defaultManager];
+    NSMutableData * fileContent = [NSMutableData alloc];
+    
+    char bytes[[dataArray count]];
+    for(int i = 0; i < dataArray.count; i++) {
+        bytes[i] = [[dataArray objectAtIndex:i] charValue];
+    }
+    [fileContent appendBytes:bytes length:dataArray.count];
+    BOOL success = [fm createFileAtPath:path contents:fileContent attributes:NULL];
+    
+    if(success == YES)
+        callback(@[[NSNull null]]);
+    else
+        callback(@[[NSString stringWithFormat:@"failed to create new file at path %@ please ensure the folder exists"]]);
+    
+}
+
 
 RCT_EXPORT_METHOD(exists:(NSString *)path callback:(RCTResponseSenderBlock)callback) {
     BOOL isDir = NO;
@@ -709,6 +755,18 @@ - (id) init {
     callback(@[[NSNull null], streamId]);
 }
 
+RCT_EXPORT_METHOD(writeArrayChunk:(NSString *)streamId withArray:(NSArray *)dataArray callback:(RCTResponseSenderBlock) callback) {
+    FetchBlobFS *fs = [[FetchBlobFS getFileStreams] valueForKey:streamId];
+    char bytes[[dataArray count]];
+    for(int i = 0; i < dataArray.count; i++) {
+        bytes[i] = [[dataArray objectAtIndex:i] charValue];
+    }
+    NSMutableData * data = [NSMutableData alloc];
+    [data appendBytes:bytes length:dataArray.count];
+    [fs write:data];
+    callback(@[[NSNull null]]);
+}
+
 RCT_EXPORT_METHOD(writeChunk:(NSString *)streamId withData:(NSString *)data callback:(RCTResponseSenderBlock) callback) {
     FetchBlobFS *fs = [[FetchBlobFS getFileStreams] valueForKey:streamId];
     [fs writeEncodeChunk:data];