Code refactor

Author: wkh237

src/class/RNFetchBlobFile.js

@@ -0,0 +1,12 @@
+import {
+  NativeModules,
+  DeviceEventEmitter,
+  NativeAppEventEmitter,
+} from 'react-native'
+
+const RNFetchBlob = NativeModules.RNFetchBlob
+const emitter = DeviceEventEmitter
+
+export default class RNFetchBlobFile {
+
+}

src/class/RNFetchBlobReadStream.js

@@ -0,0 +1,76 @@
+import {
+  NativeModules,
+  DeviceEventEmitter,
+  NativeAppEventEmitter,
+} from 'react-native'
+
+const RNFetchBlob = NativeModules.RNFetchBlob
+const emitter = DeviceEventEmitter
+
+export default class RNFetchBlobReadStream {
+
+  path : string;
+  encoding : 'utf8' | 'ascii' | 'base64';
+  bufferSize : ?number;
+  closed : boolean;
+
+  constructor(path:string, encoding:string, bufferSize?:?number) {
+    if(!path)
+      throw Error('RNFetchBlob could not open file stream with empty `path`')
+    this.encoding = encoding || 'utf8'
+    this.bufferSize = bufferSize
+    this.path = path
+    this.closed = false
+    this._onData = () => {}
+    this._onEnd = () => {}
+    this._onError = () => {}
+
+    // register for file stream event
+    let subscription = emitter.addListener(`RNFetchBlobStream+${this.path}`, (e) => {
+    
+      let {event, detail} = e
+      if(this._onData && event === 'data')
+        this._onData(detail)
+      else if (this._onEnd && event === 'end') {
+        this._onEnd(detail)
+      }
+      else {
+        if(this._onError)
+          this._onError(detail)
+        else
+          throw new Error(detail)
+      }
+      // when stream closed or error, remove event handler
+      if (event === 'error' || event === 'end') {
+        subscription.remove()
+        this.closed = true
+      }
+    })
+
+  }
+
+  open() {
+    if(!this.closed)
+      RNFetchBlob.readStream(this.path, this.encoding, this.bufferSize || 0)
+    else
+      throw new Error('Stream closed')
+  }
+
+  onData(fn) {
+    if(this.encoding.toLowerCase() === 'ascii')
+      this._onData = (data) => {
+        fn(JSON.parse(data))
+      }
+    else
+      this._onData = fn
+  }
+
+  onError(fn) {
+    this._onError = fn
+  }
+
+  onEnd (fn) {
+    this._onEnd = fn
+  }
+
+}

src/class/RNFetchBlobSession.js

@@ -0,0 +1,66 @@
+/**
+ * Session class
+ * @class RNFetchBlobSession
+ */
+
+import {
+ NativeModules,
+ DeviceEventEmitter,
+ NativeAppEventEmitter,
+} from 'react-native'
+
+const RNFetchBlob = NativeModules.RNFetchBlob
+const emitter = DeviceEventEmitter
+
+export default class RNFetchBlobSession {
+
+  add : (path:string) => RNFetchBlobSession;
+  remove : (path:string) => RNFetchBlobSession;
+  dispose : () => Promise;
+  list : () => Array<string>;
+  name : string;
+
+  constructor(name:string, list:Array<string>) {
+    this.name = name
+    if(!sessions[name]) {
+      if(Array.isArray(list))
+      sessions[name] = list
+      else
+      sessions[name] = []
+    }
+  }
+
+  add(path:string):RNFetchBlobSession {
+    sessions[this.name].push(path)
+    return this
+  }
+
+  remove(path:string):RNFetchBlobSession {
+    let list = sessions[this.name]
+    for(let i in list) {
+      if(list[i] === path) {
+        sessions[this.name].splice(i, 1)
+        break;
+      }
+    }
+    return this
+  }
+
+  list():Array<string> {
+    return sessions[this.name]
+  }
+
+  dispose():Promise {
+    return new Promise((resolve, reject) => {
+      RNFetchBlob.removeSession(sessions[this.name], (err) => {
+        if(err)
+          reject(err)
+        else {
+          delete sessions[this.name]
+          resolve()
+        }
+      })
+    })
+  }
+
+}

src/class/RNFetchBlobWriteStream.js

@@ -0,0 +1,54 @@
+import {
+ NativeModules,
+ DeviceEventEmitter,
+ NativeAppEventEmitter,
+} from 'react-native'
+
+const RNFetchBlob = NativeModules.RNFetchBlob
+const emitter = DeviceEventEmitter
+
+export default class RNFetchBlobWriteStream {
+
+  id : string;
+  encoding : string;
+  append : bool;
+
+  constructor(streamId:string, encoding:string, append:string) {
+    this.id = streamId
+    this.encoding = encoding
+    this.append = append
+  }
+
+  write(data:string) {
+    return new Promise((resolve, reject) => {
+      try {
+        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
+            resolve()
+        })
+      } catch(err) {
+        reject(err)
+      }
+    })
+  }
+
+  close() {
+    return new Promise((resolve, reject) => {
+      try {
+        RNFetchBlob.closeStream(this.id, () => {
+          resolve()
+        })
+      } catch (err) {
+        reject(err)
+      }
+    })
+  }
+
+}