Live automation progress tracking with real-time output panels

Author: Nezreka

core/automation_engine.py

@@ -49,6 +49,10 @@ def __init__(self, db):
         # Format: {type: {'handler': fn(config)->dict, 'guard': fn()->bool or None}}
         self._action_handlers = {}
 
+        # Progress tracking callbacks (registered by web_server.py)
+        self._progress_init_fn = None
+        self._progress_finish_fn = None
+
         # Event trigger cache: trigger_type → [automation_id, ...]
         self._event_automations = {}
         self._event_cache_dirty = True
@@ -73,6 +77,11 @@ def register_action_handler(self, action_type, handler_fn, guard_fn=None):
         }
         logger.debug(f"Registered action handler: {action_type}")
 
+    def register_progress_callbacks(self, init_fn, finish_fn):
+        """Register callbacks for live progress tracking from web_server.py."""
+        self._progress_init_fn = init_fn
+        self._progress_finish_fn = finish_fn
+
     # --- System Automations ---
 
     def ensure_system_automations(self):
@@ -278,6 +287,11 @@ def _run_event_automation(self, auto, automation_id, event_data):
             action_config = json.loads(auto.get('action_config') or '{}')
         except json.JSONDecodeError:
             action_config = {}
+
+        # Inject automation identity for progress tracking
+        action_config['_automation_id'] = automation_id
+        action_config['_automation_name'] = auto.get('name', '')
+
         delay_minutes = action_config.get('delay', 0)
         if delay_minutes and delay_minutes > 0:
             logger.info(f"Event automation '{auto.get('name')}' delaying {delay_minutes}m before action")
@@ -299,12 +313,20 @@ def _run_event_automation(self, auto, automation_id, event_data):
                     result = {'status': 'skipped', 'reason': f'{action_type} already running'}
                     logger.info(f"Event automation '{auto.get('name')}' skipped — {action_type} busy")
                 else:
+                    # Initialize progress tracking
+                    if self._progress_init_fn:
+                        try: self._progress_init_fn(automation_id, auto.get('name', ''), action_type)
+                        except Exception: pass
                     try:
                         result = handler_info['handler'](action_config) or {}
                         logger.info(f"Event automation '{auto.get('name')}' executed: {result.get('status', 'ok')}")
                     except Exception as e:
                         result = {'status': 'error', 'error': str(e)}
                         logger.error(f"Event automation '{auto.get('name')}' action failed: {e}")
+                    # Finalize progress tracking
+                    if self._progress_finish_fn:
+                        try: self._progress_finish_fn(automation_id, result)
+                        except Exception: pass
 
         # Merge event data into result for notification variables
         merged = {**event_data, **result}
@@ -353,6 +375,10 @@ def run_automation(self, automation_id, skip_delay=False):
         except json.JSONDecodeError:
             action_config = {}
 
+        # Inject automation identity for progress tracking
+        action_config['_automation_id'] = automation_id
+        action_config['_automation_name'] = auto.get('name', '')
+
         # Action delay (skipped for manual run_now)
         delay_minutes = action_config.get('delay', 0)
         if not skip_delay and delay_minutes and delay_minutes > 0:
@@ -369,6 +395,11 @@ def run_automation(self, automation_id, skip_delay=False):
             self._finish_run(auto, automation_id, result, error=None)
             return
 
+        # Initialize progress tracking
+        if self._progress_init_fn:
+            try: self._progress_init_fn(automation_id, auto.get('name', ''), action_type)
+            except Exception: pass
+
         # Execute the action
         error = None
         result = {}
@@ -380,6 +411,11 @@ def run_automation(self, automation_id, skip_delay=False):
             result = {'status': 'error', 'error': error}
             logger.error(f"Automation '{auto['name']}' (id={automation_id}) failed: {e}")
 
+        # Finalize progress tracking
+        if self._progress_finish_fn:
+            try: self._progress_finish_fn(automation_id, result)
+            except Exception: pass
+
         # Send notification if configured
         try:
             self._send_notification(auto, result)