Merge pull request #53 from atf-inc/feat-slack-integration

slack notification added

Author: samar-703

worker/worker.py

@@ -16,6 +16,7 @@
 from behavior import BehaviorEngine
 from semantic import ImprovedSemanticDetector
 from fusion import ImprovedFusionEngine
+from slack_notifier import SlackNotifier
 
 # Configuration
 REDIS_HOST = os.getenv("REDIS_HOST", "localhost")
@@ -35,6 +36,7 @@ def __init__(self):
         self._semantic_engine: Optional[ImprovedSemanticDetector] = None
         self._behavior_engine: Optional[BehaviorEngine] = None
         self._fusion_engine: Optional[ImprovedFusionEngine] = None
+        self._slack_notifier: Optional[SlackNotifier] = None
         self._processed_count = 0
         self._alert_count = 0
 
@@ -98,6 +100,10 @@ def _init_engines(self) -> bool:
             self._fusion_engine = ImprovedFusionEngine()
             print("[ENGINE] Fusion Engine ready")
 
+            print("[ENGINE] Initializing Slack Notifier...")
+            self._slack_notifier = SlackNotifier()
+
+
             return True
         except Exception as e:
             print(f"[ENGINE] Initialization failed: {e}")
@@ -257,6 +263,10 @@ def _handle_message(self, message: dict):
             print(self._format_alert(result, log_data, processing_time_ms))
             # Save alert to Redis for dashboard
             self._save_alert_to_redis(result)
+            
+            # Send Slack Alert
+            if self._slack_notifier:
+                self._slack_notifier.send_alert(result)
         else:
             self._log_processed(result, processing_time_ms)