Merge remote-tracking branch 'origin/main' into feature/trustworthiness

Author: FerTV

nebula/controller.py

@@ -67,7 +67,7 @@ class NebulaEventHandler(PatternMatchingEventHandler):
     def __init__(self):
         super(NebulaEventHandler, self).__init__()
         self.last_processed = {}
-        self.timeout_ns = 10 * 1e9
+        self.timeout_ns = 5 * 1e9
         self.processing_files = set()
         self.lock = threading.Lock()
 

nebula/core/network/connection.py

@@ -171,7 +171,7 @@ async def reconnect(self, max_retries: int = 5, delay: int = 5) -> None:
             except Exception as e:
                 logging.error(f"Reconnection attempt {attempt + 1} failed: {e}")
                 await asyncio.sleep(delay)
-        logging.error(f"Failed to reconnect to {self.addr} after {max_retries} attempts")
+        logging.error(f"Failed to reconnect to {self.addr} after {max_retries} attempts. Stopping connection...")
         await self.stop()
 
     async def send(self, data: Any, pb: bool = True, encoding_type: str = "utf-8", is_compressed: bool = False) -> None:
@@ -194,7 +194,7 @@ async def send(self, data: Any, pb: bool = True, encoding_type: str = "utf-8", i
             await self._send_chunks(message_id, data_to_send)
         except Exception as e:
             logging.error(f"Error sending data: {e}")
-            await self.stop()
+            await self.reconnect()
 
     def _prepare_data(self, data: Any, pb: bool, encoding_type: str) -> tuple[bytes, bytes]:
         if pb:
@@ -267,8 +267,6 @@ async def handle_incoming_message(self) -> None:
             await self.reconnect()
         except Exception as e:
             logging.error(f"Error handling incoming message: {e}")
-        finally:
-            await self.stop()
 
     async def _read_exactly(self, num_bytes: int, max_retries: int = 3) -> bytes:
         data = b""

nebula/frontend/app.py

@@ -1161,7 +1161,7 @@ async def run_scenarios(data, role):
             trust_metric_manager = TrustMetricManager(scenario[1])
             trust_metric_manager.evaluate(scenario, weights, use_weights=True)
 
-        await asyncio.sleep(1)
+        await asyncio.sleep(5)
 
 
 @app.post("/nebula/dashboard/deployment/run")