Add peers status to the app

AhmedHanafy725 · AhmedHanafy725 · commit 890f605957a2 · 2025-09-16T12:12:59.000+03:00
diff --git a/android/app/src/main/kotlin/tech/threefold/mycelium/MainActivity.kt b/android/app/src/main/kotlin/tech/threefold/mycelium/MainActivity.kt
@@ -15,6 +15,7 @@ import io.flutter.embedding.engine.FlutterEngine
 import io.flutter.plugin.common.MethodChannel
 import tech.threefold.mycelium.rust.uniffi.mycelmob.addressFromSecretKey
 import tech.threefold.mycelium.rust.uniffi.mycelmob.generateSecretKey
+import tech.threefold.mycelium.rust.uniffi.mycelmob.getPeerStatus
 
 private const val tag = "[Myceliumflut]"
 
@@ -56,6 +57,15 @@ class MainActivity: FlutterActivity() {
                     Log.d(tag,  "stopping VPN")
                     result.success(stopCmdSent)
                 }
+                "getPeerStatus" -> {
+                    try {
+                        val peerStatus = getPeerStatus()
+                        result.success(peerStatus)
+                    } catch (e: Exception) {
+                        Log.e(tag, "Error getting peer status: ${e.message}")
+                        result.error("PEER_STATUS_ERROR", e.message, null)
+                    }
+                }
                 else -> result.notImplemented()
             }
         }
diff --git a/android/app/src/main/kotlin/tech/threefold/mycelium/rust/uniffi/mycelmob/mycelmob.kt b/android/app/src/main/kotlin/tech/threefold/mycelium/rust/uniffi/mycelmob/mycelmob.kt
@@ -720,6 +720,8 @@ internal interface UniffiForeignFutureCompleteVoid : com.sun.jna.Callback {
 
 
 
+
+
 
 
 
@@ -742,6 +744,8 @@ internal interface UniffiLib : Library {
     ): RustBuffer.ByValue
     fun uniffi_mycelmob_fn_func_generate_secret_key(uniffi_out_err: UniffiRustCallStatus, 
     ): RustBuffer.ByValue
+    fun uniffi_mycelmob_fn_func_get_peer_status(uniffi_out_err: UniffiRustCallStatus, 
+    ): RustBuffer.ByValue
     fun uniffi_mycelmob_fn_func_hello_int(uniffi_out_err: UniffiRustCallStatus, 
     ): Int
     fun uniffi_mycelmob_fn_func_hello_mycelios(uniffi_out_err: UniffiRustCallStatus, 
@@ -866,6 +870,8 @@ internal interface UniffiLib : Library {
     ): Short
     fun uniffi_mycelmob_checksum_func_generate_secret_key(
     ): Short
+    fun uniffi_mycelmob_checksum_func_get_peer_status(
+    ): Short
     fun uniffi_mycelmob_checksum_func_hello_int(
     ): Short
     fun uniffi_mycelmob_checksum_func_hello_mycelios(
@@ -897,6 +903,9 @@ private fun uniffiCheckApiChecksums(lib: UniffiLib) {
     if (lib.uniffi_mycelmob_checksum_func_generate_secret_key() != 63601.toShort()) {
         throw RuntimeException("UniFFI API checksum mismatch: try cleaning and rebuilding your project")
     }
+    if (lib.uniffi_mycelmob_checksum_func_get_peer_status() != 1198.toShort()) {
+        throw RuntimeException("UniFFI API checksum mismatch: try cleaning and rebuilding your project")
+    }
     if (lib.uniffi_mycelmob_checksum_func_hello_int() != 31063.toShort()) {
         throw RuntimeException("UniFFI API checksum mismatch: try cleaning and rebuilding your project")
     }
@@ -1099,6 +1108,15 @@ public object FfiConverterSequenceString: FfiConverterRustBuffer<List<kotlin.Str
     )
     }
     
+ fun `getPeerStatus`(): List<kotlin.String> {
+            return FfiConverterSequenceString.lift(
+    uniffiRustCall() { _status ->
+    UniffiLib.INSTANCE.uniffi_mycelmob_fn_func_get_peer_status(
+        _status)
+}
+    )
+    }
+    
  fun `helloInt`(): kotlin.Int {
             return FfiConverterInt.lift(
     uniffiRustCall() { _status ->
diff --git a/lib/main.dart b/lib/main.dart
@@ -50,6 +50,7 @@ class _MyAppState extends State<MyApp> {
   String _nodeAddr = '';
   var privKey = Uint8List(0);
   List<String> peers = [];
+  List<String> _connectedPeers = [];
   late TextEditingController textEditController;
   final _flutterDesktopSleepPlugin = FlutterDesktopSleep();
   final ScrollController _scrollController = ScrollController();
@@ -366,6 +367,79 @@ class _MyAppState extends State<MyApp> {
                     ),
                   ),
                 ),
+                // Connected Peers Section
+                Visibility(
+                  visible: _isStarted && _connectedPeers.isNotEmpty,
+                  child: Column(
+                    children: [
+                      const SizedBox(height: sizedBoxHeight),
+                      const Align(
+                        alignment: Alignment.centerLeft,
+                        child: Text("Connected Peers:",
+                            style: TextStyle(
+                                fontSize: 16,
+                                color: Color(0xFF7D7E7E),
+                                fontWeight: FontWeight.w500)),
+                      ),
+                      const SizedBox(height: 10),
+                      Container(
+                        width: double.infinity,
+                        constraints: const BoxConstraints(maxHeight: 200),
+                        decoration: BoxDecoration(
+                          color: const Color.fromARGB(255, 245, 241, 241),
+                          border: Border.all(color: Colors.grey),
+                          borderRadius: BorderRadius.circular(10.0),
+                        ),
+                        child: SingleChildScrollView(
+                          padding: const EdgeInsets.all(8.0),
+                          child: Column(
+                            crossAxisAlignment: CrossAxisAlignment.start,
+                            children: _connectedPeers.map((peerInfo) {
+                              // Parse peer info: "protocol,address,connection_state"
+                              final parts = peerInfo.split(',');
+                              if (parts.length >= 3) {
+                                final protocol = parts[0];
+                                final address = parts[1];
+                                final state = parts[2];
+                                return Padding(
+                                  padding: const EdgeInsets.symmetric(vertical: 2.0),
+                                  child: Row(
+                                    children: [
+                                      Icon(
+                                        state.toLowerCase() == 'connected' 
+                                          ? Icons.check_circle 
+                                          : Icons.radio_button_unchecked,
+                                        color: state.toLowerCase() == 'connected' 
+                                          ? Colors.green 
+                                          : Colors.orange,
+                                        size: 16,
+                                      ),
+                                      const SizedBox(width: 8),
+                                      Expanded(
+                                        child: Text(
+                                          '$protocol://$address ($state)',
+                                          style: const TextStyle(fontSize: 12),
+                                        ),
+                                      ),
+                                    ],
+                                  ),
+                                );
+                              } else {
+                                return Padding(
+                                  padding: const EdgeInsets.symmetric(vertical: 2.0),
+                                  child: Text(
+                                    peerInfo,
+                                    style: const TextStyle(fontSize: 12),
+                                  ),
+                                );
+                              }
+                            }).toList(),
+                          ),
+                        ),
+                      ),
+                    ],
+                  ),
+                ),
               ],
             ),
           ),
@@ -474,6 +548,7 @@ class _MyAppState extends State<MyApp> {
       _startStopButtonColor = colorDarkBlue;
       _myceliumStatusColor = colorMycelRed;
       isRestartVisible = false;
+      _connectedPeers.clear(); // Clear connected peers when stopped
     });
   }
 
@@ -486,6 +561,45 @@ class _MyAppState extends State<MyApp> {
       _myceliumStatusColor = colorDarkBlue;
       isRestartVisible = true;
     });
+    // Start periodic peer status updates
+    _startPeerStatusUpdates();
+  }
+
+  void _startPeerStatusUpdates() {
+    Timer.periodic(const Duration(seconds: 5), (timer) {
+      if (!_isStarted) {
+        timer.cancel();
+        return;
+      }
+      _updatePeerStatus();
+    });
+  }
+
+  void _updatePeerStatus() async {
+    if (!_isStarted) return;
+    
+    try {
+      List<String> peerStatus;
+      if (isUseDylib()) {
+        // Windows platform - use FFI
+        peerStatus = await myFFGetPeerStatus();
+      } else {
+        // Android/iOS platform - use platform channel
+        final result = await platform.invokeMethod<List<dynamic>>('getPeerStatus');
+        peerStatus = result?.cast<String>() ?? [];
+      }
+      
+      // Filter out the first element if it's "ok" (status indicator)
+      if (peerStatus.isNotEmpty && peerStatus[0] == "ok") {
+        peerStatus = peerStatus.sublist(1);
+      }
+      
+      setState(() {
+        _connectedPeers = peerStatus;
+      });
+    } catch (e) {
+      _logger.warning("Failed to get peer status: $e");
+    }
   }
 }
 
diff --git a/lib/myceliumflut_ffi_binding.dart b/lib/myceliumflut_ffi_binding.dart
@@ -155,3 +155,48 @@ Future<bool> myFFStopMycelium() async {
   final result = stopMycelium();
   return result != 0;
 }
+
+typedef FuncRustGetPeerStatus = ffi.Void Function(
+    ffi.Pointer<ffi.Pointer<ffi.Pointer<ffi.Int8>>>, ffi.Pointer<ffi.IntPtr>);
+typedef FuncDartGetPeerStatus = void Function(
+    ffi.Pointer<ffi.Pointer<ffi.Pointer<ffi.Int8>>>, ffi.Pointer<ffi.IntPtr>);
+typedef FuncRustFreePeerStatus = ffi.Void Function(
+    ffi.Pointer<ffi.Pointer<ffi.Int8>>, ffi.IntPtr);
+typedef FuncDartFreePeerStatus = void Function(
+    ffi.Pointer<ffi.Pointer<ffi.Int8>>, int);
+
+Future<List<String>> myFFGetPeerStatus() async {
+  // Load the dynamic library
+  final dylib = loadDll();
+
+  final FuncDartGetPeerStatus getPeerStatus = dylib
+      .lookup<ffi.NativeFunction<FuncRustGetPeerStatus>>('ff_get_peer_status')
+      .asFunction();
+  final FuncDartFreePeerStatus freePeerStatus = dylib
+      .lookup<ffi.NativeFunction<FuncRustFreePeerStatus>>('free_peer_status')
+      .asFunction();
+
+  final outPtr = malloc<ffi.Pointer<ffi.Pointer<ffi.Int8>>>();
+  final outLen = malloc<ffi.IntPtr>();
+
+  getPeerStatus(outPtr, outLen);
+
+  final ptr = outPtr.value;
+  final len = outLen.value;
+
+  List<String> peerStatusList = [];
+  for (int i = 0; i < len; i++) {
+    final stringPtr = ptr[i];
+    if (stringPtr != ffi.nullptr) {
+      final dartString = stringPtr.cast<Utf8>().toDartString();
+      peerStatusList.add(dartString);
+    }
+  }
+
+  // Free the allocated memory
+  freePeerStatus(ptr, len);
+  malloc.free(outPtr);
+  malloc.free(outLen);
+
+  return peerStatusList;
+}
diff --git a/mycelffi/src/lib.rs b/mycelffi/src/lib.rs
@@ -73,3 +73,45 @@ pub extern "C" fn ff_stop_mycelium() -> bool {
     let result = mobile::stop_mycelium();
     result == "ok"
 }
+
+#[no_mangle]
+pub extern "C" fn ff_get_peer_status(out_ptr: *mut *mut *mut c_char, out_len: *mut usize) {
+    let peer_status = mobile::get_peer_status();
+    let len = peer_status.len();
+    
+    // Convert Vec<String> to Vec<*mut c_char>
+    let c_strings: Vec<*mut c_char> = peer_status
+        .into_iter()
+        .map(|s| CString::new(s).unwrap().into_raw())
+        .collect();
+    
+    let ptr = c_strings.as_ptr() as *mut *mut c_char;
+    
+    // Transfer ownership to the caller
+    std::mem::forget(c_strings);
+    
+    unsafe {
+        *out_ptr = ptr;
+        *out_len = len;
+    }
+}
+
+#[no_mangle]
+pub extern "C" fn free_peer_status(ptr: *mut *mut c_char, len: usize) {
+    unsafe {
+        if ptr.is_null() {
+            return;
+        }
+        
+        // Free each C string
+        for i in 0..len {
+            let c_str_ptr = *ptr.add(i);
+            if !c_str_ptr.is_null() {
+                let _ = CString::from_raw(c_str_ptr);
+            }
+        }
+        
+        // Free the array of pointers
+        Vec::from_raw_parts(ptr, len, len);
+    }
+}
diff --git a/mycelmob/src/lib.rs b/mycelmob/src/lib.rs
@@ -30,4 +30,9 @@ pub fn generate_secret_key() -> Vec<u8> {
 #[uniffi::export]
 pub fn address_from_secret_key(data: Vec<u8>) -> String {
     mobile::address_from_secret_key(data)
+}
+
+#[uniffi::export]
+pub fn get_peer_status() -> Vec<String> {
+    mobile::get_peer_status()
 }
