Merge pull request #84 from functionland/partition-command

added partition command

Author: ehsan6sha

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

@@ -1522,6 +1522,22 @@ public void reboot(Promise promise) {
     });
   }
 
+  @ReactMethod
+  public void partition(Promise promise) {
+    ThreadUtils.runOnExecutor(() -> {
+      Log.d("ReactNative", "partition");
+      try {
+        byte[] result = this.fula.partition();
+        String resultString = toString(result);
+        Log.d("ReactNative", "result string="+resultString);
+        promise.resolve(resultString);
+      } catch (Exception e) {
+        Log.d("ReactNative", e.getMessage());
+        promise.reject(e);
+      }
+    });
+  }
+
   @ReactMethod
   public void eraseBlData(Promise promise) {
     ThreadUtils.runOnExecutor(() -> {

example/src/App.tsx

@@ -67,13 +67,13 @@ const App = () => {
     153, 106, 217, 201, 106, 9, 66, 33, 214, 195, 255, 234, 178, 244, 203, 112,
     62, 91, 140, 55, 179, 10, 208, 210, 177, 111, 61, 46, 73, 148, 14, 62,
   ];
-  //const bloxPeerId = '12D3KooWDiBNebfFD4QwJ1qDZaeapKcbr72cJfHE8foooTX25Z1V'; //tower
-  const bloxPeerId = '12D3KooWRTzN7HfmjoUBHokyRZuKdyohVVSGqKBMF24ZC3tGK78Q'; //laptop
+  const bloxPeerId = '12D3KooWACVcVsQh18jM9UudRQzeYEjxCJQJgFUaAgs41tayjxC4'; //tower
+  // const bloxPeerId = '12D3KooWRTzN7HfmjoUBHokyRZuKdyohVVSGqKBMF24ZC3tGK78Q'; //laptop
   // const bloxPeerId = '12D3KooWQZBdE5zNUVTE2Aayajyy9cJDmK4bJwMZG52ieHt2f6nb'; //laptop2
   //const bloxPeerId = '12D3KooWAN5FaAnC4d1GhAvoYxyUXdrkCGqux1NB6Pr4cZXn813E'; //test aws server
 
-  const bloxAddr = '/dns/delta-relay.dev.fx.land/tcp/4001/p2p/12D3KooWDtA7kecHAGEB8XYEKHBUTt8GsRfMen1yMs7V85vrpMzC/p2p-circuit/p2p/' + bloxPeerId;
-  //const bloxAddr = '/ip4/192.168.2.14/tcp/40001/p2p/' + bloxPeerId;
+  // const bloxAddr = '/dns/delta-relay.dev.fx.land/tcp/4001/p2p/12D3KooWDtA7kecHAGEB8XYEKHBUTt8GsRfMen1yMs7V85vrpMzC/p2p-circuit/p2p/' + bloxPeerId;
+  const bloxAddr = '/ip4/192.168.2.88/tcp/40001/p2p/' + bloxPeerId;
 
   const initFula = async () => {
     try {
@@ -721,6 +721,38 @@ const App = () => {
           color={inprogress ? 'green' : 'blue'}
         />
 
+        <Button
+          title={inprogress ? 'Getting...' : 'Partition'}
+          onPress={async () => {
+            try {
+              if (initComplete) {
+                fula.checkConnection().then((r: any) => {
+                  console.log('connection check');
+                  console.log(r);
+                  if (r) {
+                    console.log(
+                      'initialization is completed. send partition command'
+                    );
+                    fxblox
+                      .partition()
+                      .then((res: any) => {
+                        console.log('partition received');
+                        console.log(res);
+                      })
+                      .catch((e: any) => {
+                        console.log('partition failed');
+                        console.log(e);
+                      });
+                  }
+                });
+              } else {
+                console.log('wait for init to complete');
+              }
+            } catch (e) {}
+          }}
+          color={inprogress ? 'green' : 'blue'}
+        />
+
         <Button
           title={inprogress ? 'Putting & Getting...' : 'List Pools'}
           onPress={async () => {

ios/Fula.mm

@@ -158,6 +158,8 @@ @interface RCT_EXTERN_MODULE(FulaModule, NSObject)
 
 RCT_EXTERN_METHOD(reboot:(RCTPromiseResolveBlock)resolve withRejecter:(RCTPromiseRejectBlock)reject)
 
+RCT_EXTERN_METHOD(partition:(RCTPromiseResolveBlock)resolve withRejecter:(RCTPromiseRejectBlock)reject)
+
 RCT_EXTERN_METHOD(assetsBalance:(NSString *)account withAssetId:(NSString *)assetId withClassId:(NSString *)classId withResolver:(RCTPromiseResolveBlock)resolve withRejecter:(RCTPromiseRejectBlock)reject)
 
 RCT_EXTERN_METHOD(getAccount:(RCTPromiseResolveBlock)resolve withRejecter:(RCTPromiseRejectBlock)reject)

ios/Fula.swift

@@ -1286,6 +1286,18 @@ class FulaModule: NSObject {
       }
   }
 
+  @objc(partition:withRejecter:)
+  func partition(resolve: @escaping RCTPromiseResolveBlock, reject: @escaping RCTPromiseRejectBlock) -> Void {
+      do {
+          let result = try fula!.partition()
+          let resultString = result.toUTF8String()!
+          resolve(resultString)
+      } catch let error {
+          print("partition", error.localizedDescription)
+          reject("ERR_FULA", "partition", error)
+      }
+  }
+
   @objc(wifiRemoveall:withRejecter:)
   func wifiRemoveall(resolve: @escaping RCTPromiseResolveBlock, reject: @escaping RCTPromiseRejectBlock) -> Void {
       do {

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@functionland/react-native-fula",
-  "version": "1.44.1",
+  "version": "1.44.2",
   "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

@@ -123,6 +123,7 @@ interface FulaNativeModule {
   bloxFreeSpace: () => Promise<string>;
   wifiRemoveall: () => Promise<string>;
   reboot: () => Promise<string>;
+  partition: () => Promise<string>;
 }
 
 const LINKING_ERROR =

src/protocols/fxblox.ts

@@ -48,6 +48,27 @@ export const reboot = (): Promise<BType.rebootResponse> => {
   return res2;
 };
 
+export const partition = (): Promise<BType.partitionResponse> => {
+  console.log('partition in react-native started');
+  let res2 = Fula.partition()
+    .then((res) => {
+      try {
+        let jsonRes: BType.partitionResponse = JSON.parse(res);
+        return jsonRes;
+      } catch (e) {
+        try {
+          return JSON.parse(res);
+        } catch (e2) {
+          return res;
+        }
+      }
+    })
+    .catch((err) => {
+      return err;
+    });
+  return res2;
+};
+
 export const eraseBlData = (): Promise<BType.rebootResponse> => {
   console.log('eraseBlData in react-native started');
   let res2 = Fula.eraseBlData()

src/types/fxblox.ts

@@ -6,6 +6,10 @@ export interface rebootResponse {
   status: boolean;
   msg: string;
 }
+export interface partitionResponse {
+  status: boolean;
+  msg: string;
+}
 
 export interface eraseBlDataResponse {
   status: boolean;