fix: worker infinite logging

Author: toderian

extensions/business/cybersec/red_mesh/pentester_api_01.py

@@ -669,16 +669,20 @@ def _maybe_close_jobs(self):
         if not job.thread.is_alive() or job.state.get("done"):
           if job_id not in self.completed_jobs_reports:
             self.completed_jobs_reports[job_id] = {}
+          # Check if this worker was already reported
+          already_reported = local_worker_id in self.completed_jobs_reports[job_id]
           # Prepare final report for this job
           local_worker_report = job.get_status()
           any_canceled_worker = any_canceled_worker or local_worker_report.get("canceled", False)
           # Save completed report
           self.completed_jobs_reports[job_id][local_worker_id] = local_worker_report
           reports[local_worker_id] = local_worker_report
-          self.P("Worker {} has finished job_id {} for target {}:\n{}".format(
-            local_worker_id, job_id, local_worker_report['target'],
-            self.json_dumps(local_worker_report, indent=2)
-          ))
+          # Only log once when worker first finishes
+          if not already_reported:
+            self.P("Worker {} has finished job_id {} for target {}:\n{}".format(
+              local_worker_id, job_id, local_worker_report['target'],
+              self.json_dumps(local_worker_report, indent=2)
+            ))
         else:
           all_workers_done = False
         initiator = job.initiator

extensions/business/cybersec/red_mesh/redmesh_utils.py

@@ -6,6 +6,7 @@
 import ftplib
 import requests
 import traceback
+import time
 
 from copy import deepcopy
 
@@ -316,21 +317,20 @@ def _check_stopped(self):
 
   def _interruptible_sleep(self):
     """
-    Sleep for a random interval (Dune sand walking), interruptible by stop_event.
-
-    Uses stop_event.wait(timeout) instead of time.sleep() so that stop requests
-    are handled immediately rather than waiting for the sleep to complete.
+    Sleep for a random interval (Dune sand walking).
 
     Returns
     -------
     bool
-      True if stop was requested during sleep (should exit), False otherwise.
+      True if stop was requested (should exit), False otherwise.
     """
     if self.scan_max_delay <= 0:
       return False  # Delays disabled
     delay = random.uniform(self.scan_min_delay, self.scan_max_delay)
-    # wait() returns True if event is set (stop requested), False on timeout
-    return self.stop_event.wait(timeout=delay)
+    self.P(f"[DUNE] Sleeping {delay:.2f}s (min={self.scan_min_delay}, max={self.scan_max_delay})")
+    time.sleep(delay)
+    # Check if stop was requested during sleep
+    return self.stop_event.is_set()
 
 
   def execute_job(self):