Update learning_hub/adaptive_hub.py

learning_hub/adaptive_hub.py

@@ -1,6 +1,6 @@
 # ==============================================================================
 # 🧠 learning_hub/adaptive_hub.py 
-# (V55.2 - GEM-Architect: Fixed Guardian Threshold Injection)
+# (V55.3 - GEM-Architect: Full Learning Loop - Oracle & Sniper Included)
 # ==============================================================================
 
 import json
@@ -15,7 +15,8 @@ class StrategyDNA:
         self.name = name
         self.model_weights = model_weights
         self.ob_settings = ob_settings
-        self.filters = filters
+        # filters now includes: l1_min_score, l3_oracle_thresh, l4_sniper_thresh
+        self.filters = filters 
         self.guard_settings = guard_settings if guard_settings else {}
         
         self.backtest_performance = backtest_performance if backtest_performance else {
@@ -41,10 +42,10 @@ class StrategyDNA:
 class AdaptiveHub:
     def __init__(self, r2_service=None):
         self.r2 = r2_service
-        self.dna_file_key = "learning/strategic_dna_v5_struct.json" 
+        self.dna_file_key = "learning/strategic_dna_v6_full.json" 
         self.current_market_regime = "RANGE"
         self.strategies: Dict[str, StrategyDNA] = {}
-        print("🧠 [AdaptiveHub V55.2] Core Initialized.")
+        print("🧠 [AdaptiveHub V55.3] Full Learning Loop (Titan+Oracle+Sniper+Guards).")
 
     async def initialize(self):
         try:
@@ -62,12 +63,41 @@ class AdaptiveHub:
             self._create_default_dna()
 
     def _create_default_dna(self):
-        default_guards = {"hydra_crash": 0.85, "hydra_giveback": 0.70, "legacy_v2": 0.95, "legacy_v3": 0.95}
+        # Default Guardians
+        d_guards = {"hydra_crash": 0.85, "hydra_giveback": 0.70, "legacy_v2": 0.95}
         
-        self.strategies["BULL"] = StrategyDNA("BULL", {"titan": 0.50, "structure": 0.30, "sniper": 0.20}, {"wall_ratio_limit": 0.60, "imbalance_thresh": 0.5}, {"l1_min_score": 0.55, "l3_conf_thresh": 0.60}, default_guards)
-        self.strategies["BEAR"] = StrategyDNA("BEAR", {"titan": 0.30, "structure": 0.40, "sniper": 0.30}, {"wall_ratio_limit": 0.30, "imbalance_thresh": 0.7}, {"l1_min_score": 0.75, "l3_conf_thresh": 0.75}, default_guards)
-        self.strategies["RANGE"] = StrategyDNA("RANGE", {"titan": 0.40, "structure": 0.40, "sniper": 0.20}, {"wall_ratio_limit": 0.40, "imbalance_thresh": 0.6}, {"l1_min_score": 0.65, "l3_conf_thresh": 0.65}, default_guards)
-        self.strategies["DEAD"] = StrategyDNA("DEAD", {"titan": 0.25, "structure": 0.25, "sniper": 0.25}, {"wall_ratio_limit": 0.20, "imbalance_thresh": 0.8}, {"l1_min_score": 0.85, "l3_conf_thresh": 0.80}, default_guards)
+        # Default Filters (Now includes Oracle & Sniper defaults)
+        # l3_oracle_thresh: 0.65 (Default)
+        # l4_sniper_thresh: 0.40 (Default)
+        
+        self.strategies["BULL"] = StrategyDNA(
+            "BULL", 
+            {"titan": 0.50, "structure": 0.30}, 
+            {"wall_ratio_limit": 0.60}, 
+            {"l1_min_score": 0.55, "l3_oracle_thresh": 0.60, "l4_sniper_thresh": 0.40}, 
+            d_guards
+        )
+        self.strategies["BEAR"] = StrategyDNA(
+            "BEAR", 
+            {"titan": 0.30, "structure": 0.40}, 
+            {"wall_ratio_limit": 0.30}, 
+            {"l1_min_score": 0.75, "l3_oracle_thresh": 0.75, "l4_sniper_thresh": 0.50}, 
+            d_guards
+        )
+        self.strategies["RANGE"] = StrategyDNA(
+            "RANGE", 
+            {"titan": 0.40, "structure": 0.40}, 
+            {"wall_ratio_limit": 0.40}, 
+            {"l1_min_score": 0.65, "l3_oracle_thresh": 0.65, "l4_sniper_thresh": 0.40}, 
+            d_guards
+        )
+        self.strategies["DEAD"] = StrategyDNA(
+            "DEAD", 
+            {"titan": 0.25, "structure": 0.25}, 
+            {"wall_ratio_limit": 0.20}, 
+            {"l1_min_score": 0.85, "l3_oracle_thresh": 0.80, "l4_sniper_thresh": 0.60}, 
+            d_guards
+        )
 
     def _load_from_dict(self, data):
         for key, val in data.get("strategies", {}).items():
@@ -100,11 +130,17 @@ class AdaptiveHub:
             
         if is_winner:
             print(f"   ✅ [JUDGE] Challenger WINS! Updating DNA.")
+            
+            # 1. Update Core Weights
             champion.model_weights['titan'] = new_config['w_titan']
             champion.model_weights['structure'] = new_config['w_struct']
+            
+            # 2. Update Filters (L1 + Oracle + Sniper)
             champion.filters['l1_min_score'] = new_config['thresh']
+            champion.filters['l3_oracle_thresh'] = new_config.get('oracle_thresh', 0.65)
+            champion.filters['l4_sniper_thresh'] = new_config.get('sniper_thresh', 0.40)
             
-            # ✅ Fix: Actually Save the New Guard Thresholds
+            # 3. Update Guardians
             champion.guard_settings['hydra_crash'] = new_config['hydra_thresh']
             champion.guard_settings['legacy_v2'] = new_config['legacy_thresh']
             
@@ -131,43 +167,47 @@ class AdaptiveHub:
         except Exception: traceback.print_exc()
 
     def _inject_current_parameters(self):
-        """ ✅ Injects ALL Parameters (Including Guardian Thresholds) into SystemLimits """
+        """ ✅ Injects ALL Parameters into SystemLimits (Live System) """
         if self.current_market_regime not in self.strategies: return
         active_dna = self.strategies[self.current_market_regime]
         
         mw = active_dna.model_weights
         total_w = sum(mw.values()) if sum(mw.values()) > 0 else 1.0
         
+        # 1. Weights
         SystemLimits.L2_WEIGHT_TITAN = mw.get("titan", 0.4) / total_w
         SystemLimits.L2_WEIGHT_PATTERNS = mw.get("structure", 0.3) / total_w
         
+        # 2. Thresholds (L1, Oracle, Sniper)
         raw_score_limit = (active_dna.filters.get("l1_min_score", 0.65) * 100.0) - 20.0
         SystemLimits.L1_MIN_AFFINITY_SCORE = raw_score_limit
+        SystemLimits.L3_CONFIDENCE_THRESHOLD = active_dna.filters.get("l3_oracle_thresh", 0.65)
+        SystemLimits.L4_ENTRY_THRESHOLD = active_dna.filters.get("l4_sniper_thresh", 0.40)
+        
+        # 3. Settings
         SystemLimits.CURRENT_REGIME = self.current_market_regime
-        SystemLimits.L3_CONFIDENCE_THRESHOLD = active_dna.filters.get("l3_conf_thresh", 0.65)
         SystemLimits.L4_OB_WALL_RATIO = active_dna.ob_settings.get("wall_ratio_limit", 0.4)
 
-        # ✅ Fix: Inject Guardian Thresholds
+        # 4. Guardians
         SystemLimits.HYDRA_CRASH_THRESH = active_dna.guard_settings.get('hydra_crash', 0.85)
         SystemLimits.LEGACY_V2_PANIC_THRESH = active_dna.guard_settings.get('legacy_v2', 0.95)
         
-        # print(f"   💉 DNA Injected: Hydra={SystemLimits.HYDRA_CRASH_THRESH}, Legacy={SystemLimits.LEGACY_V2_PANIC_THRESH}")
+        # print(f"   💉 DNA Injected: Regime={self.current_market_regime}, Oracle={SystemLimits.L3_CONFIDENCE_THRESHOLD}, Sniper={SystemLimits.L4_ENTRY_THRESHOLD}")
 
     def get_status(self) -> str:
-        """
-        Returns status summary for UI.
-        """
         dna = self.strategies.get(self.current_market_regime)
         if not dna: return "System Initializing..."
         
-        thresh_ratio = dna.filters.get('l1_min_score', 0)
         titan_w = dna.model_weights.get('titan', 0)
+        oracle_t = dna.filters.get('l3_oracle_thresh', 0.65)
+        sniper_t = dna.filters.get('l4_sniper_thresh', 0.40)
         hydra_t = dna.guard_settings.get('hydra_crash', 0.85)
         
         return (f"Regime: {self.current_market_regime} | "
-                f"L1 Thresh: {thresh_ratio:.0%} | "
                 f"Titan: {titan_w:.2f} | "
-                f"HydraGuard: {hydra_t:.2f}")
+                f"Oracle: {oracle_t:.2f} | "
+                f"Sniper: {sniper_t:.2f} | "
+                f"Hydra: {hydra_t:.2f}")
 
     async def _save_state_to_r2(self):
         if not self.r2: return