Merge pull request #80 from functionland/registerLifecycleListener

Register lifecycle listener

Author: ehsan6sha

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

@@ -14,6 +14,7 @@
 import com.facebook.react.bridge.Arguments;
 import com.facebook.react.bridge.WritableArray;
 import com.facebook.react.bridge.ReadableArray;
+import com.facebook.react.bridge.LifecycleEventListener;
 
 
 import org.apache.commons.io.FileUtils;
@@ -183,6 +184,33 @@ private byte[] convertStringToByte(@NonNull String data) {
     return convertIntToByte(keyInt);
   }
 
+  @ReactMethod
+  public void registerLifecycleListener(Promise promise) {
+      getReactApplicationContext().addLifecycleEventListener(new LifecycleEventListener() {
+          @Override
+          public void onHostResume() {
+              // App is in the foreground
+          }
+
+          @Override
+          public void onHostPause() {
+              // App is in the background
+          }
+
+          @Override
+          public void onHostDestroy() {
+              // Attempt to shut down Fula cleanly
+              try {
+                  Log.e("ReactNative", "shutting down Fula onHostDestroy");
+                  shutdownInternal();
+              } catch (Exception e) {
+                  Log.e("ReactNative", "Error shutting down Fula", e);
+              }
+          }
+      });
+      promise.resolve(true);
+  }
+
   @ReactMethod
   public void checkConnection(int timeout, Promise promise) {
     Log.d("ReactNative", "checkConnection started");

example/src/App.tsx

@@ -1,4 +1,4 @@
-import React from 'react';
+import React, { useEffect } from 'react';
 import { StyleSheet, Text, View, Button } from 'react-native';
 
 import {
@@ -21,6 +21,19 @@ const App = () => {
     { peerId: string; rootCid: string; private_ref: string } | {}
   >({});
 
+  useEffect(() => {
+    if (!__DEV__) {
+      console.log = () => null;
+      //console.error = () => null
+    }
+    fula
+      .registerLifecycleListener()
+      .then(() => console.log('Lifecycle listener registered'))
+      .catch((error) =>
+        console.error('Failed to register lifecycle listener', error)
+      );
+  }, []);
+
   let RNFS = require('react-native-fs');
   const readFile = () => {
     RNFS.readDir(RNFS.DocumentDirectoryPath)

ios/Fula.mm

@@ -2,6 +2,8 @@
 
 @interface RCT_EXTERN_MODULE(FulaModule, NSObject)
 
+RCT_EXTERN_METHOD(registerLifecycleListener)
+
 RCT_EXTERN_METHOD(checkConnection: (nonnull NSNumber *) timeout
                   withResolver:(RCTPromiseResolveBlock)resolve
                   withRejecter:(RCTPromiseRejectBlock)reject)

ios/Fula.swift

@@ -135,6 +135,48 @@ class FulaModule: NSObject {
         return convertIntToByte(keyInt)
     }
 
+    @objc func registerLifecycleListener() {
+        NotificationCenter.default.addObserver(
+            self,
+            selector: #selector(applicationWillResignActive),
+            name: UIApplication.willResignActiveNotification,
+            object: nil)
+
+        NotificationCenter.default.addObserver(
+            self,
+            selector: #selector(applicationDidEnterBackground),
+            name: UIApplication.didEnterBackgroundNotification,
+            object: nil)
+
+        NotificationCenter.default.addObserver(
+            self,
+            selector: #selector(applicationWillTerminate),
+            name: UIApplication.willTerminateNotification,
+            object: nil)
+    }
+
+    deinit {
+        NotificationCenter.default.removeObserver(self)
+    }
+
+    @objc func applicationWillResignActive() {
+        // Handle app will resign active (similar to onHostPause)
+    }
+
+    @objc func applicationDidEnterBackground() {
+        // Handle app entered background
+    }
+
+    @objc func applicationWillTerminate() {
+        // Attempt to shut down Fula cleanly (similar to onHostDestroy)
+        do {
+            try shutdownInternal()
+        } catch {
+            print("Error shutting down Fula: \(error)")
+        }
+    }
+
+
     @objc(checkConnection:withResolver:withRejecter:)
     func checkConnection(timeout: NSNumber, resolve: @escaping RCTPromiseResolveBlock, reject: @escaping RCTPromiseRejectBlock) {
         OSLog.viewCycle.info("ReactNative checkConnection started with timeout=\(timeout)")

package.json

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

@@ -1,6 +1,7 @@
 import { NativeModules, Platform } from 'react-native';
 
 interface FulaNativeModule {
+  registerLifecycleListener: () => Promise<void>;
   initFula: (
     identity: string, //Private key of did identity
     storePath: string, //You can leave empty

src/protocols/fula.ts

@@ -7,6 +7,14 @@ import {
 } from './chain-api';
 import { ApiPromise } from '@polkadot/api';
 
+/**
+ * Register the app's lifecycle listeners to handle foreground, background, and termination states.
+ */
+export const registerLifecycleListener = (): Promise<void> => {
+  console.log('called registerLifecycleListener');
+  return Fula.registerLifecycleListener();
+};
+
 /**
  * Get gets the value corresponding to the given key from the local datastore.
 // The key must be a valid ipld.Link.