android fs events

Author: Ron Radtke

android/src/main/java/com/ReactNativeBlobUtil/ReactNativeBlobUtilConst.java

@@ -6,6 +6,7 @@ public class ReactNativeBlobUtilConst {
     public static final String EVENT_PROGRESS = "ReactNativeBlobUtilProgress";
     public static final String EVENT_HTTP_STATE = "ReactNativeBlobUtilState";
     public static final String EVENT_MESSAGE = "ReactNativeBlobUtilMessage";
+    public static final String EVENT_FILESYSTEM = "ReactNativeBlobUtilFilesystem";
     public static final String FILE_PREFIX = "ReactNativeBlobUtil-file://";
     public static final String CONTENT_PREFIX = "ReactNativeBlobUtil-content://";
     public static final String FILE_PREFIX_BUNDLE_ASSET = "bundle-assets://";

android/src/main/java/com/ReactNativeBlobUtil/ReactNativeBlobUtilFS.java

@@ -19,6 +19,8 @@
 import com.facebook.react.bridge.WritableArray;
 import com.facebook.react.bridge.WritableMap;
 import com.facebook.react.modules.core.DeviceEventManagerModule;
+import com.facebook.react.uimanager.UIManagerHelper;
+import com.facebook.react.uimanager.events.EventDispatcher;
 
 import java.io.File;
 import java.io.FileInputStream;
@@ -37,9 +39,6 @@ class ReactNativeBlobUtilFS {
 
     private ReactApplicationContext mCtx;
     private DeviceEventManagerModule.RCTDeviceEventEmitter emitter;
-    private String encoding = "base64";
-    private OutputStream writeStreamInstance = null;
-    private static HashMap<String, ReactNativeBlobUtilFS> fileStreams = new HashMap<>();
 
     ReactNativeBlobUtilFS(ReactApplicationContext ctx) {
         this.mCtx = ctx;

android/src/main/java/com/ReactNativeBlobUtil/ReactNativeBlobUtilStream.java

@@ -1,5 +1,7 @@
 package com.ReactNativeBlobUtil;
 
+import static com.ReactNativeBlobUtil.ReactNativeBlobUtilConst.EVENT_FILESYSTEM;
+
 import android.net.Uri;
 import android.os.SystemClock;
 import android.util.Base64;
@@ -249,15 +251,17 @@ private void emitStreamEvent(String streamName, String event, String data) {
         WritableMap eventData = Arguments.createMap();
         eventData.putString("event", event);
         eventData.putString("detail", data);
-        this.emitter.emit(streamName, eventData);
+        eventData.putString("streamId", streamName);
+        this.emitter.emit(EVENT_FILESYSTEM, eventData);
     }
 
     // "event" always is "data"...
     private void emitStreamEvent(String streamName, String event, WritableArray data) {
         WritableMap eventData = Arguments.createMap();
         eventData.putString("event", event);
         eventData.putArray("detail", data);
-        this.emitter.emit(streamName, eventData);
+        eventData.putString("streamId", streamName);
+        this.emitter.emit(EVENT_FILESYSTEM, eventData);
     }
 
     // "event" always is "error"...
@@ -266,7 +270,8 @@ private void emitStreamEvent(String streamName, String event, String code, Strin
         eventData.putString("event", event);
         eventData.putString("code", code);
         eventData.putString("detail", message);
-        this.emitter.emit(streamName, eventData);
+        eventData.putString("streamId", streamName);
+        this.emitter.emit(EVENT_FILESYSTEM, eventData);
     }
 
     /**