Update app.py

app.py

@@ -1,5 +1,6 @@
-# app.py (V25.2 - GEM-Architect: Bulletproof Gradio UI)
-# تم إزالة جميع معاملات التنسيق (theme, css) من Constructor لضمان العمل على أي إصدار.
+# app.py (V25.3 - GEM-Architect: Full Stats Table & Sensitive Whale Scoring)
+# - تم استعادة الجدول التفصيلي (Titan, Pattern, MC).
+# - تم تعديل حساسية الحيتان لتعطي نقاطاً حتى على التحركات المتوسطة.
 
 import os
 import sys
@@ -155,7 +156,7 @@ async def auto_pilot_loop():
 @asynccontextmanager
 async def lifespan(app: FastAPI):
     global r2, data_manager, ml_processor, hub_manager, trade_manager, whale_monitor, news_fetcher, senti_analyzer, sys_state
-    logger.info("\n🚀 [System] Startup Sequence Initiated (Titan V25.2)...")
+    logger.info("\n🚀 [System] Startup Sequence Initiated (Titan V25.3)...")
     try:
         logger.info("   [1/7] Initializing R2 & Data Services...")
         r2 = R2Service()
@@ -164,10 +165,8 @@ async def lifespan(app: FastAPI):
         await data_manager.load_contracts_from_r2()
         
         logger.info("   [2/7] Starting Auxiliary Services (Whale & News)...")
-        # 1. تهيئة مراقب الحيتان
         whale_monitor = EnhancedWhaleMonitor(contracts_db=data_manager.get_contracts_db(), r2_service=r2)
         
-        # 2. تهيئة وحقن مدير الاتصالات (RPC Manager)
         rpc_mgr = AdaptiveRpcManager(data_manager.http_client)
         whale_monitor.set_rpc_manager(rpc_mgr)
         logger.info("   ✅ [System] RPC Manager injected into Whale Monitor.")
@@ -233,7 +232,7 @@ async def _analyze_symbol_task(symbol: str) -> Dict[str, Any]:
 # ==============================================================================
 async def run_unified_cycle():
     """
-    الدورة الموحدة الكاملة (6 طبقات)
+    الدورة الموحدة الكاملة (Enterprise Logic)
     """
     log_buffer = StringIO()
     def log_and_print(message):
@@ -288,7 +287,7 @@ async def run_unified_cycle():
             log_and_print("⚠️ No valid L2 candidates.")
             sys_state.set_cycle_end(logs=log_buffer.getvalue()); return
 
-        # 4. 🔥 L2.5 Enrichment & Boosting (Numeric) 🔥
+        # 4. 🔥 L2.5 Enrichment & Boosting (Whales & News) 🔥
         log_and_print(f"   [3/5] 🚀 L2.5 Boosting (Whales & News)...")
         boosted_candidates = []
         
@@ -296,20 +295,34 @@ async def run_unified_cycle():
             symbol = cand['symbol']
             current_score = cand['enhanced_final_score']
             
-            # [CRITICAL] استخراج السعر المعروف لتمريره لمراقب الحيتان
+            # استخراج السعر
             known_price = cand.get('current_price', 0.0)
             if known_price == 0.0:
                 known_price = await data_manager.get_latest_price_async(symbol)
 
-            # أ. تعزيز الحيتان
+            # أ. تعزيز الحيتان (Scoring Update)
             whale_score = 0.0
             try:
                 w_data = await whale_monitor.get_symbol_whale_activity(symbol, known_price=known_price)
+                
+                # استخدام بيانات التراكم 24س
                 net_flow = w_data.get('accumulation_analysis_24h', {}).get('net_flow_usd', 0)
+                whale_count = w_data.get('summary', {}).get('total_transfers_scanned', 0)
+                
+                # [UPDATED] منطق أكثر حساسية:
+                # - يكافئ العدد (Activity)
+                # - يكافئ صافي التدفق الإيجابي حتى لو كان صغيراً
+                
+                # 1. مكافأة النشاط (Activity Boost)
+                if whale_count >= 10: whale_score += 0.05
+                elif whale_count >= 3: whale_score += 0.02
+                
+                # 2. مكافأة التدفق (Flow Boost)
+                if net_flow > 500_000: whale_score += 0.10 # حوت قوي
+                elif net_flow > 50_000: whale_score += 0.05 # تجميع متوسط
+                elif net_flow < -500_000: whale_score -= 0.10 # بيع قوي
+                elif net_flow < -50_000: whale_score -= 0.05 # تصريف
                 
-                if net_flow > 1_000_000: whale_score = 0.15 
-                elif net_flow > 250_000: whale_score = 0.08
-                elif net_flow < -1_000_000: whale_score = -0.10
             except Exception: pass
             
             # ب. تعزيز الأخبار
@@ -321,6 +334,7 @@ async def run_unified_cycle():
                     if sentiment['compound'] > 0.2: news_score = 0.05
             except: pass
             
+            # تحديث الدرجة وتخزين القيم
             new_final = current_score + whale_score + news_score
             cand['enhanced_final_score'] = new_final
             cand['whale_score'] = whale_score 
@@ -330,11 +344,16 @@ async def run_unified_cycle():
 
         final_top_10 = sorted(boosted_candidates, key=lambda x: x['enhanced_final_score'], reverse=True)
 
-        log_and_print(f"{'SYMBOL':<10} | {'FINAL':<6} | {'BASE':<6} | {'BOOST (W/N)'}")
-        log_and_print("-" * 45)
+        # [RESTORED] عرض الجدول التفصيلي الكامل
+        log_and_print(f"{'SYMBOL':<10} | {'FINAL':<6} | {'TITAN':<5} | {'PATT':<5} | {'MC':<5} | {'BOOST (W/N)'}")
+        log_and_print("-" * 65)
         for c in final_top_10:
-            base_s = c['enhanced_final_score'] - c.get('whale_score', 0.0) - c.get('news_score', 0.0)
-            log_and_print(f"{c['symbol']:<10} | {c['enhanced_final_score']:.3f}  | {base_s:.3f}   | {c['boost_info']}")
+            # استخراج الدرجات الفرعية (مع التحقق من وجودها)
+            titan_s = c.get('titan_score', 0.0)
+            patt_s = c.get('pattern_score', 0.0)
+            mc_s = c.get('monte_carlo_score', 0.0)
+            
+            log_and_print(f"{c['symbol']:<10} | {c['enhanced_final_score']:.3f}  | {titan_s:.2f}  | {patt_s:.2f}  | {mc_s:.2f}  | {c['boost_info']}")
 
         # 5. L3 Oracle
         log_and_print(f"   [4/5] 🔮 L3 Oracle Check...")
@@ -536,17 +555,15 @@ async def check_live_pnl_and_status(selected_view="Hybrid System"):
         return "Error", "Error", empty_chart, "0", "0", "0", "0", "0%", wl_df_empty, "Err", "Err", "Err"
 
 # ==============================================================================
-# 🎨 Gradio UI (Bulletproof Style Injection)
+# 🎨 Gradio UI (Bulletproof)
 # ==============================================================================
 def create_gradio_ui():
     custom_css = ".gradio-container {background:#0b0f19} .dataframe {background:#1a1a1a!important} .html-box {min-height:180px}"
     
-    # [CRITICAL FIX] إزالة جميع المعاملات الاختيارية من Blocks()
-    with gr.Blocks(title="Titan V25.2") as demo:
-        # حقن الـ CSS هنا
+    with gr.Blocks(title="Titan V25.3") as demo:
         gr.HTML(f"<style>{custom_css}</style>")
         
-        gr.Markdown("# 🚀 Titan V25.2 (Full Architecture - Web3 Enabled)")
+        gr.Markdown("# 🚀 Titan V25.3 (Full Architecture - Web3 Enabled)")
         
         with gr.Row():
             with gr.Column(scale=3):
@@ -595,7 +612,7 @@ def create_gradio_ui():
 # ==============================================================================
 # 🏁 Server
 # ==============================================================================
-fast_api_server = FastAPI(lifespan=lifespan, title="Titan V25.2 Pro", description="Titan Enterprise Trading System")
+fast_api_server = FastAPI(lifespan=lifespan, title="Titan V25.3 Pro", description="Titan Enterprise Trading System")
 gradio_dashboard = create_gradio_ui()
 app = gr.mount_gradio_app(app=fast_api_server, blocks=gradio_dashboard, path="/")