added refresh to newClient

Author: ehsan6sha

android/src/main/java/land/fx/fula/FulaModule.java

@@ -170,14 +170,14 @@ public void checkConnection(Promise promise) {
   }
 
   @ReactMethod
-  public void newClient(String identityString, String storePath, String bloxAddr, String exchange, boolean autoFlush, boolean useRelay, Promise promise) {
+  public void newClient(String identityString, String storePath, String bloxAddr, String exchange, boolean autoFlush, boolean useRelay, boolean refresh, Promise promise) {
     Log.d("ReactNative", "newClient started");
     ThreadUtils.runOnExecutor(() -> {
       try {
         Log.d("ReactNative", "newClient storePath= " + storePath);
         byte[] identity = toByte(identityString);
         Log.d("ReactNative", "newClient identity= " + identityString);
-        this.newClientInternal(identity, storePath, bloxAddr, exchange, autoFlush, useRelay);
+        this.newClientInternal(identity, storePath, bloxAddr, exchange, autoFlush, useRelay, refresh);
         //String objString = Arrays.toString(obj);
         String peerId = this.fula.id();
         promise.resolve(peerId);
@@ -474,7 +474,7 @@ public fulamobile.Client getFulaClient() {
   }
 
   @NonNull
-  private byte[] newClientInternal(byte[] identity, String storePath, String bloxAddr, String exchange, boolean autoFlush, boolean useRelay) throws Exception {
+  private byte[] newClientInternal(byte[] identity, String storePath, String bloxAddr, String exchange, boolean autoFlush, boolean useRelay, boolean refresh) throws Exception {
     try {
       fulaConfig = new Config();
       if (storePath == null || storePath.trim().isEmpty()) {
@@ -495,7 +495,7 @@ private byte[] newClientInternal(byte[] identity, String storePath, String bloxA
         fulaConfig.setAllowTransientConnection(true);
         fulaConfig.setForceReachabilityPrivate(true);
       }
-      if (this.fula == null) {
+      if (this.fula == null || refresh) {
         Log.d("ReactNative", "Creating a new Fula instance");
         this.fula = Fulamobile.newClient(fulaConfig);
       }
@@ -513,7 +513,7 @@ private byte[] newClientInternal(byte[] identity, String storePath, String bloxA
   private String[] initInternal(byte[] identity, String storePath, String bloxAddr, String exchange, boolean autoFlush, String rootCid, boolean useRelay, boolean refresh) throws Exception {
     try {
       if (this.fula == null || refresh) {
-        this.newClientInternal(identity, storePath, bloxAddr, exchange, autoFlush, useRelay);
+        this.newClientInternal(identity, storePath, bloxAddr, exchange, autoFlush, useRelay, refresh);
       }
       if(this.client == null || refresh) {
         this.client = new Client(this.fula);

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@functionland/react-native-fula",
-  "version": "1.1.4",
+  "version": "1.1.5",
   "description": "This package is a bridge to use the Fula libp2p protocols in the react-native which is using wnfs",
   "main": "lib/commonjs/index",
   "module": "lib/module/index",

src/interfaces/fulaNativeModule.ts

@@ -17,7 +17,8 @@ interface FulaNativeModule {
     bloxAddr: string, //Blox multiadddr needs to be manually entered now
     exchange: string, //set to 'noope' for testing
     autoFlush: boolean, //set to false always unless you know what you are doing. This is to write actions to disk explicitly after each write
-    useRelay: boolean | null // if true it forces the use of relay
+    useRelay: boolean | null, // if true it forces the use of relay
+    refresh: boolean // if true it forces to refresh the fula object
     ) => Promise<string>;
   isReady: (filesystemCheck: boolean) => Promise<boolean>;
   logout: (identity: string, storePath: string) => Promise<boolean>;

src/protocols/fula.ts

@@ -42,7 +42,8 @@ export const newClient = (
   bloxAddr: string,
   exchange: string,
   autoFlush: boolean = false,
-  useRelay: boolean = true
+  useRelay: boolean = true,
+  refresh: boolean = false
 ): Promise<string> => {
   console.log(
     'newClient in react-native started',
@@ -51,9 +52,10 @@ export const newClient = (
     bloxAddr,
     exchange,
     autoFlush,
-    useRelay
+    useRelay,
+    refresh
   );
-  return Fula.newClient(identity, storePath, bloxAddr, exchange, autoFlush, useRelay);
+  return Fula.newClient(identity, storePath, bloxAddr, exchange, autoFlush, useRelay, refresh);
 };
 
 /**