Update app.py

app.py

@@ -21,7 +21,7 @@ for module_name, pip_name in REQUIRED_PACKAGES.items():
         print(f"✅ {pip_name} установлен!")
 
 # ============================================
-# 👑 TOMIRIS SPACE 26 v2.2 — OPTIONS & DERIVATIVES ENGINE (Async, Real Data, No MT5)
+# 👑 TOMIRIS SPACE 26 v2.3 — OPTIONS & DERIVATIVES ENGINE (Hub-Connected)
 # ============================================
 import os, time, json, logging, asyncio
 from typing import Dict, Any, List, Optional
@@ -37,7 +37,6 @@ logger = logging.getLogger("Space26_Options")
 
 # ================= КОНФИГУРАЦИЯ =================
 SYMBOLS = ["XAU/USD", "ETH/USD", "SOL/USD"]
-ARBITER_URL = os.getenv("SPACE18_URL", "https://tomiris-ai-name6-6.hf.space")
 HUB_URL = os.getenv("SPACE17_URL", "https://tomiris-ai-name5-5.hf.space")
 TWELVE_DATA_KEY = os.getenv("TWELVE_DATA_KEY", "58e67e0008e24161ac9b1671b7c2d2d0")
 FRED_KEY = os.getenv("FRED_KEY", "faa11c8e2e4beee08c5b966e8b63a513")
@@ -87,7 +86,7 @@ def save_history():
     with open(HISTORY_FILE, 'w') as f:
         json.dump(list(OPTIONS_HISTORY), f)
 
-# ================= ЗАГРУЗКА ДАННЫХ =================
+# ================= ЗАГРУЗКА ДАННЫХ (без изменений) =================
 async def fetch_vix() -> Dict[str, Any]:
     if breaker_open("vix"): return {"vix": 20.0, "level": "NORMAL", "signal": "NEUTRAL"}
     try:
@@ -208,7 +207,6 @@ async def analyze_derivatives(symbol: str) -> Dict[str, Any]:
     native = "XAU" if "XAU" in symbol else ("ETH" if "ETH" in symbol else "SOL")
     bin_sym = "" if native == "XAU" else (native + "USDT")
 
-    # Запускаем сбор параллельно
     tasks = []
     if bin_sym:
         tasks.extend([fetch_funding_rate(bin_sym), fetch_open_interest(bin_sym), fetch_long_short_ratio(bin_sym)])
@@ -219,7 +217,6 @@ async def analyze_derivatives(symbol: str) -> Dict[str, Any]:
     tasks.append(fetch_vix())
 
     results = await asyncio.gather(*tasks)
-    # Распределяем результаты
     idx = 0
     metrics = {}
     if bin_sym:
@@ -230,19 +227,17 @@ async def analyze_derivatives(symbol: str) -> Dict[str, Any]:
         metrics['options'] = results[idx]; idx += 1
     if native == "XAU":
         metrics['gold_derivatives'] = results[idx]; idx += 1
-    vix_data = results[idx]  # последний
+    vix_data = results[idx]
 
     signals = []
     score = 50.0
 
-    # VIX
     if vix_data["vix"] > 30:
         signals.append({"source": "VIX", "signal": "BEARISH_RISK", "reason": f"VIX={vix_data['vix']:.1f}"})
         score += 15 if native == "XAU" else -10
     elif vix_data["vix"] > 25:
         score += 5
 
-    # Funding
     fund = metrics.get('funding_rate', {})
     if fund.get('signal') == 'BEARISH':
         signals.append({"source": "FUNDING", "signal": "BEARISH", "reason": f"Перегретый лонг ({fund.get('funding_rate_pct')}%)"})
@@ -251,7 +246,6 @@ async def analyze_derivatives(symbol: str) -> Dict[str, Any]:
         signals.append({"source": "FUNDING", "signal": "BULLISH", "reason": f"Перегретый шорт ({fund.get('funding_rate_pct')}%)"})
         score += 15
 
-    # OI
     oi = metrics.get('open_interest', {})
     if oi.get('signal') == 'BEARISH':
         signals.append({"source": "OI", "signal": "BEARISH", "reason": f"OI перегрет ({oi.get('change_pct')}%)"})
@@ -260,7 +254,6 @@ async def analyze_derivatives(symbol: str) -> Dict[str, Any]:
         signals.append({"source": "OI", "signal": "BULLISH", "reason": f"OI растёт ({oi.get('change_pct')}%)"})
         score += 10
 
-    # L/S
     lsr = metrics.get('long_short_ratio', {})
     if lsr.get('signal') == 'BEARISH':
         signals.append({"source": "L/S", "signal": "BEARISH", "reason": f"Слишком много лонгов ({lsr.get('long_pct')}%)"})
@@ -269,7 +262,6 @@ async def analyze_derivatives(symbol: str) -> Dict[str, Any]:
         signals.append({"source": "L/S", "signal": "BULLISH", "reason": f"Много шортов ({lsr.get('short_pct')}%)"})
         score += 10
 
-    # Options
     options = metrics.get('options', {})
     if options.get('signal') == 'BEARISH':
         signals.append({"source": "OPTIONS", "signal": "BEARISH", "reason": f"PCR={options.get('put_call_ratio_volume')}"})
@@ -278,7 +270,6 @@ async def analyze_derivatives(symbol: str) -> Dict[str, Any]:
         signals.append({"source": "OPTIONS", "signal": "BULLISH", "reason": f"PCR={options.get('put_call_ratio_volume')}"})
         score += 8
 
-    # Gold
     gold = metrics.get('gold_derivatives', {})
     if gold.get('signal') == 'BULLISH':
         signals.append({"source": "COT/DXY/TIPS", "signal": "BULLISH", "reason": "Макро-факторы за золото"})
@@ -287,7 +278,6 @@ async def analyze_derivatives(symbol: str) -> Dict[str, Any]:
         signals.append({"source": "COT/DXY/TIPS", "signal": "BEARISH", "reason": "Макро-факторы против золота"})
         score -= 12
 
-    # Max Pain (если цена известна)
     price = await get_current_price(symbol) if native != "XAU" else 0
     max_pain = calculate_max_pain(price) if price > 0 else 0
     if max_pain > 0 and price < max_pain:
@@ -317,12 +307,29 @@ async def analyze_derivatives(symbol: str) -> Dict[str, Any]:
     save_history()
     return analysis
 
+# ================= ОТПРАВКА В HUB =================
+async def send_signal_to_hub(symbol: str, direction: str, confidence: float):
+    try:
+        await http_client.post(f"{HUB_URL}/signal", json={
+            "space": "space_26_options",
+            "symbol": symbol,
+            "direction": direction,
+            "confidence": confidence,
+            "raw": json.dumps({"source": "space_26_options"})
+        })
+        logger.info(f"📤 {symbol}: {direction} conf={confidence:.3f} отправлен в Hub")
+    except Exception as e:
+        logger.error(f"Ошибка отправки в Hub: {e}")
+
 # ================= ГЛАВНЫЙ СИГНАЛ =================
 async def get_derivative_signal(symbol: str = "ETH/USD") -> Dict[str, Any]:
     start = time.time()
     analysis = await analyze_derivatives(symbol)
     latency = int((time.time() - start) * 1000)
 
+    # Отправка в Hub
+    await send_signal_to_hub(symbol, analysis['direction'], analysis['confidence'])
+
     result = {
         "space": "space_26_options",
         "timestamp": int(time.time()),
@@ -332,21 +339,11 @@ async def get_derivative_signal(symbol: str = "ETH/USD") -> Dict[str, Any]:
         "latency_ms": latency
     }
 
-    try:
-        await http_client.post(f"{ARBITER_URL}/log_signal", json={
-            "space": "space_26_options",
-            "symbol": symbol,
-            "signal": result["signal"],
-            "options_details": {"score": analysis['derivative_score'], "signals": analysis['signals']}
-        })
-    except:
-        pass
-
     logger.info(f"📊 Options {symbol}: {analysis['direction']} conf={analysis['confidence']:.3f} score={analysis['derivative_score']}")
     return result
 
 # ================= FASTAPI =================
-app = FastAPI(title="Tomiris Space 26 v2.2 — Options & Derivatives Engine")
+app = FastAPI(title="Tomiris Space 26 v2.3 — Options & Derivatives Engine (Hub)")
 
 @app.on_event("startup")
 async def startup(): pass
@@ -356,7 +353,7 @@ async def shutdown(): await http_client.aclose()
 
 @app.get("/health")
 async def health():
-    return {"status": "operational", "version": "2.2", "async": True, "no_mt5": True, "features": ["VIX", "Funding", "OI", "L/S", "Options PCR", "COT/DXY/TIPS", "Max Pain"]}
+    return {"status": "operational", "version": "2.3", "hub_connected": True, "features": ["VIX", "Funding", "OI", "L/S", "Options PCR", "COT/DXY/TIPS", "Max Pain"]}
 
 @app.get("/consilium")
 async def consilium(symbol: str = Query("ETH/USD")):
@@ -394,4 +391,4 @@ if __name__ == "__main__":
     import uvicorn
     uvicorn.run(app, host="0.0.0.0", port=7860)
 
-print("🚀 SPACE 26 v2.2 — OPTIONS & DERIVATIVES ENGINE (FULL) ЗАПУЩЕН!")
+print("🚀 SPACE 26 v2.3 — OPTIONS & DERIVATIVES ENGINE (Hub-Connected) ЗАПУЩЕН!")