Reduce number of failed connections

Author: javizqh

react_frontend/package.json

@@ -62,7 +62,7 @@
     "@types/styled-components": "^5.1.34",
     "axios": "^1.12.0",
     "glob": "^8.0.3",
-    "jderobot-commsmanager": "1.0.16",
+    "jderobot-commsmanager": "1.0.24",
     "jderobot-ide-interface": "0.2.137",
     "jszip": "^3.10.1",
     "react-router-dom": "^7.12.0",

react_frontend/src/components/exercise/WebGUIContainer.tsx

@@ -44,7 +44,7 @@ export const connectApplication = (
   resizeRef?: MutableRefObject<HTMLImageElement | null>,
   resizeObserver?: ResizeObserver
 ) => {
-  const ref = useRef<NodeJS.Timer>();
+  const intRef = useRef<number | null>(null);
 
   const onStateChange = (message: ManagerMsg) => {
     const state = message.data.state as string;
@@ -95,19 +95,20 @@ export const connectApplication = (
       return;
     }
 
-    ref.current = setInterval(() => {
+    const timer = window.setInterval(async () => {
       try {
-        manager.send("gui", "start");
+        await manager.send("gui", "start");
       } catch {
-        end();
+        window.clearInterval(timer);
       }
     }, 1000);
+    intRef.current = timer;
   };
 
   const end = () => {
-    if (ref.current !== undefined) {
-      clearInterval(ref.current);
-      ref.current = undefined;
+    if (intRef.current !== null) {
+      window.clearInterval(intRef.current);
+      intRef.current = null;
     }
   };
 };

react_frontend/src/components/layouts/ExerciseContainer.tsx

@@ -47,6 +47,9 @@ const ExerciseContainer = ({
   multiLanguage: boolean;
   children: JSX.Element;
 }) => {
+  const hasTriedToConnect = useRef(false);
+  const timeoutRef = useRef<number | null>(null);
+  const connectTimeoutRef = useRef<number | null>(null);
   const [manager, setManager] = useState<CommsManager | null>(null);
   const [universes, setUniverses] = useState<string[] | undefined>(undefined);
   const toolsList = getTools(manager, tools, children);
@@ -76,15 +79,26 @@ const ExerciseContainer = ({
   };
 
   useEffect(() => {
-    const manager = CommsManager.getInstance();
-    setManager(manager);
     subscribe("CommsManagerStateChange", resetUniverse);
 
     return () => {
       unsubscribe("CommsManagerStateChange", () => {});
-      const currManager = CommsManager.getInstance();
-      if (currManager) {
-        currManager.disconnect();
+
+      if (hasTriedToConnect.current) {
+        const currManager = CommsManager.getInstance();
+        if (currManager) {
+          currManager.disconnect();
+          CommsManager.deleteInstance();
+          setManager(null);
+        }
+      }
+
+      if (timeoutRef.current) {
+        window.clearTimeout(timeoutRef.current);
+      }
+
+      if (connectTimeoutRef.current) {
+        window.clearTimeout(connectTimeoutRef.current);
       }
     };
   }, []);
@@ -93,13 +107,9 @@ const ExerciseContainer = ({
     desiredState?: string,
     callback?: () => void
   ) => {
-    console.log(manager?.getState(), CommsManager.getInstance().getState());
-    if (!manager || manager?.getState() != "idle") {
-      return;
-    }
     try {
       const currManager = CommsManager.getInstance();
-      console.log(currManager);
+      hasTriedToConnect.current = true;
       await currManager.connect();
       getUniverseList(project);
       console.log("Connected!", currManager.getState());
@@ -110,15 +120,26 @@ const ExerciseContainer = ({
       }
     } catch {
       console.log("Connection failed, trying again!");
-      setTimeout(connectWithRetry, 2000, desiredState, callback);
+      timeoutRef.current = window.setTimeout(
+        connectWithRetry,
+        2000,
+        desiredState,
+        callback
+      );
     }
   };
 
   const waitManagerState = async (state: string, callback: () => void) => {
-    if (manager?.getState() === state) {
+    const currManager = CommsManager.getInstance();
+    if (currManager?.getState() === state) {
       callback();
     } else {
-      return setTimeout(waitManagerState, 100, state, callback);
+      connectTimeoutRef.current = window.setTimeout(
+        waitManagerState,
+        100,
+        state,
+        callback
+      );
     }
   };
 

react_frontend/yarn.lock

@@ -3976,10 +3976,10 @@ jackspeak@^3.1.2:
   optionalDependencies:
     "@pkgjs/parseargs" "^0.11.0"
 
-jderobot-commsmanager@1.0.16:
-  version "1.0.16"
-  resolved "https://registry.npmjs.org/jderobot-commsmanager/-/jderobot-commsmanager-1.0.16.tgz"
-  integrity sha512-rEMr1DRqcexrtvyzNvLsWW4+DOVj+V8l4eI8HP7IAWc25NbK+OtexXJZ1Fk+v+WSdffE8n0J0k17rIryzFEm3w==
+jderobot-commsmanager@1.0.24:
+  version "1.0.24"
+  resolved "https://registry.yarnpkg.com/jderobot-commsmanager/-/jderobot-commsmanager-1.0.24.tgz#b6e7a0ff0e886ee051c4693ccfd0de54b8eca72e"
+  integrity sha512-mbdgWG+O6cWPxQs16jdTbVjHQ65/lANJyVCEgzr1FZKi9bHPNrJFjGQW0qqVksIzuVwr4+zmg2PCFcTIAe2seQ==
   dependencies:
     uuid "^11.1.0"