feat(tauri-app): restart kubo on reconnect | fix: concurrency issue f…

…ixed on start_ipfs

src-tauri/src/ipfs.rs

@@ -80,14 +80,19 @@ pub fn start_ipfs() -> Result<(), IpfsError> {
         .map_err(|e| IpfsError::Other(e.to_string()))?;
 
     if is_running.status.success() {
-        return Err(IpfsError::AlreadyRunning);
+        println!("IPFS is already running.");
+        return Ok(()); // If it's already running, don't try to start it again
     }
 
     // Start the IPFS daemon
     Command::new(&ipfs_binary)
         .arg("daemon")
         .spawn()
         .map_err(|e| IpfsError::Other(e.to_string()))?;
+    println!("IPFS daemon started");
+
+    // Give IPFS a moment to start up properly
+    std::thread::sleep(std::time::Duration::from_secs(2));
 
     // Configure IPFS to allow all origins
     let config_output1 = Command::new(&ipfs_binary)

src/components/btnGrd/index.tsx

@@ -32,7 +32,7 @@ const playAudioClick = () => {
 // };
 
 export interface Props extends Partial<HTMLButtonElement> {
-  disabled: boolean;
+  disabled?: boolean;
   text?: string | JSX.Element;
   img?: $TsFixMe;
   pending?: boolean;

src/features/ipfs/ipfsSettings/index.tsx

@@ -8,6 +8,7 @@ import { AdviserColors } from 'src/features/adviser/Adviser/Adviser';
 import { useAdviser } from 'src/features/adviser/context';
 import { getIpfsOpts } from 'src/services/ipfs/config';
 import { IPFSNodes } from 'src/services/ipfs/types';
+import { invoke } from '@tauri-apps/api/tauri';
 import BtnPassport from '../../../containers/portal/pasport/btnPasport';
 import Drive from '../Drive';
 import ErrorIpfsSettings from './ErrorIpfsSettings';
@@ -46,7 +47,7 @@ function IpfsSettings() {
 
   useEffect(() => {
     let text;
-    let status: AdviserColors = undefined;
+    let status: AdviserColors;
     if (!isIpfsInitialized) {
       text = 'trying to connect to ipfs...';
       status = 'yellow';
@@ -75,11 +76,22 @@ function IpfsSettings() {
     updateUserGatewayUrl(valueInputGateway);
   }, [valueInputGateway]);
 
-  const onClickReConnect = () => {
-    ipfsApi
-      ?.stop()
-      .then(() => ipfsApi?.start(getIpfsOpts()))
-      .then();
+  const onClickReConnect = async () => {
+    if (process.env.IS_TAURI) {
+      try {
+        console.log('Restarting IPFS');
+
+        await invoke('stop_ipfs');
+        await invoke('start_ipfs');
+
+        console.log('IPFS restarted');
+      } catch (error) {
+        console.error('Error restarting IPFS', error);
+      }
+    }
+
+    await ipfsApi?.stop().catch(console.error);
+    await ipfsApi?.start(getIpfsOpts()).catch(console.error);
   };
 
   const stateProps = {