Update app/api/deps.py

app/api/deps.py

@@ -4,16 +4,66 @@ from slowapi import Limiter
 from slowapi.util import get_remote_address
 from app.core.config import settings
 
-# ARF core engine imports
-from agentic_reliability_framework.core.governance.risk_engine import RiskEngine
-from agentic_reliability_framework.core.decision.decision_engine import DecisionEngine
-from agentic_reliability_framework.core.governance.stability_controller import LyapunovStabilityController
-from agentic_reliability_framework.core.governance.causal_explainer import CausalExplainer
-from agentic_reliability_framework.runtime.memory.rag_graph import RAGGraphMemory
-from agentic_reliability_framework.core.models.event import ReliabilityEvent, HealingAction
+# ---------------------------------------------------------------------------
+# Local dummy implementations that replace the private engine classes.
+# They provide the same interface as the originals but perform no real work.
+# ---------------------------------------------------------------------------
+class RiskEngine:
+    def __init__(self, *args, **kwargs):
+        pass
+    def calculate_risk(self, *args, **kwargs):
+        return (0.38, "mock", {"conjugate_mean": 0.38})
+    def update_outcome(self, *args, **kwargs):
+        pass
+
+class DecisionEngine:
+    def __init__(self, *args, **kwargs):
+        pass
+    def select_optimal_action(self, *args, **kwargs):
+        class Result:
+            best_action = type('Action', (), {'value': 'NO_ACTION'})()
+            expected_utility = 0.0
+            alternatives = []
+            explanation = "mock"
+            raw_data = {}
+        return Result()
+    def compute_risk(self, *args, **kwargs):
+        return 0.0
+
+class LyapunovStabilityController:
+    def __init__(self, *args, **kwargs):
+        pass
+
+class CausalExplainer:
+    def __init__(self, *args, **kwargs):
+        pass
+
+class RAGGraphMemory:
+    def __init__(self, *args, **kwargs):
+        pass
+    def has_historical_data(self):
+        return False
+    def record_outcome(self, *args, **kwargs):
+        pass
+
+class ReliabilityEvent:
+    def __init__(self, component, latency_p99, error_rate, service_mesh="default"):
+        self.component = component
+        self.latency_p99 = latency_p99
+        self.error_rate = error_rate
+        self.service_mesh = service_mesh
+
+class HealingAction:
+    NO_ACTION = "NO_ACTION"
+    RESTART_CONTAINER = "RESTART_CONTAINER"
+    SCALE_OUT = "SCALE_OUT"
+    ROLLBACK = "ROLLBACK"
+    CIRCUIT_BREAKER = "CIRCUIT_BREAKER"
+    TRAFFIC_SHIFT = "TRAFFIC_SHIFT"
+    ALERT_TEAM = "ALERT_TEAM"
+# ---------------------------------------------------------------------------
 
 
-# Dependency to get DB session
 def get_db():
     db = SessionLocal()
     try:
@@ -22,11 +72,10 @@ def get_db():
         db.close()
 
 
-# Rate limiter with default limit from settings
 limiter = Limiter(key_func=get_remote_address, default_limits=[settings.RATE_LIMIT])
 
 
-# ARF engine dependencies (singletons for simplicity)
+# Singletons (now using local dummies)
 _risk_engine = None
 _decision_engine = None
 _stability_controller = None
@@ -35,36 +84,8 @@ _rag_graph = None
 
 
 def _seed_rag_graph(rag):
-    """Seed the RAG graph with historical healing action outcomes."""
-    seed_data = [
-        ("seed_restart_1", "test", HealingAction.RESTART_CONTAINER.value, True, 2),
-        ("seed_restart_2", "test", HealingAction.RESTART_CONTAINER.value, True, 3),
-        ("seed_restart_3", "test", HealingAction.RESTART_CONTAINER.value, False, 10),
-        ("seed_rollback_1", "test", HealingAction.ROLLBACK.value, True, 1),
-        ("seed_rollback_2", "test", HealingAction.ROLLBACK.value, True, 2),
-        ("seed_rollback_3", "test", HealingAction.ROLLBACK.value, False, 5),
-        ("seed_scale_1", "test", HealingAction.SCALE_OUT.value, True, 5),
-        ("seed_scale_2", "test", HealingAction.SCALE_OUT.value, False, 15),
-        ("seed_cb_1", "test", HealingAction.CIRCUIT_BREAKER.value, True, 1),
-        ("seed_cb_2", "test", HealingAction.CIRCUIT_BREAKER.value, True, 2),
-        ("seed_ts_1", "test", HealingAction.TRAFFIC_SHIFT.value, True, 4),
-        ("seed_ts_2", "test", HealingAction.TRAFFIC_SHIFT.value, False, 8),
-    ]
-    for inc_id, comp, action, success, res_time in seed_data:
-        event = ReliabilityEvent(
-            component=comp,
-            latency_p99=500,
-            error_rate=0.1,
-            service_mesh="default"
-        )
-        rag.record_outcome(
-            incident_id=inc_id,
-            event=event,
-            action_taken=action,
-            success=success,
-            resolution_time_minutes=res_time
-        )
-    print("Seeded RAG graph with historical data", file=sys.stderr)
+    # Mock seed – no real data
+    print("RAG seed skipped (sandbox mode)", file=sys.stderr)
 
 
 def get_rag_graph():
@@ -101,4 +122,4 @@ def get_causal_explainer():
     global _causal_explainer
     if _causal_explainer is None:
         _causal_explainer = CausalExplainer()
-    return _causal_explainer
+    return _causal_explainer