Update app.py

app.py

@@ -20,7 +20,7 @@ for module_name, pip_name in REQUIRED_PACKAGES.items():
         print(f"✅ {pip_name} установлен!")
 
 # ============================================
-# 👑 TOMIRIS SPACE 24 v2.0 — ECOSYSTEM AGGREGATOR PRO (Async, Dynamic Weights, No MT5)
+# 👑 TOMIRIS SPACE 24 v2.1 — ECOSYSTEM AGGREGATOR PRO (Hub-Connected)
 # ============================================
 import os, time, json, logging, asyncio
 from typing import Dict, Any, List, Optional
@@ -36,7 +36,6 @@ logger = logging.getLogger("Space24_EcosystemAggregator")
 # ================= КОНФИГУРАЦИЯ =================
 SYMBOLS = ["XAU/USD", "ETH/USD", "SOL/USD"]
 
-# Реальные URL'ы экосистемных Space'ов
 ECOSYSTEM_SPACES = {
     "space_19_sol": {
         "url": "https://tomirisai80-tomirisanal.hf.space",
@@ -76,7 +75,6 @@ ECOSYSTEM_SPACES = {
 }
 
 HUB_URL = os.getenv("SPACE17_URL", "https://tomiris-ai-name5-5.hf.space")
-ARBITER_URL = os.getenv("SPACE18_URL", "https://tomiris-ai-name6-6.hf.space")
 SPACE31_URL = os.getenv("SPACE31_URL", "https://nuxotetotmailsvoboden-tomiris-perf.hf.space")
 
 # ================= HTTP КЛИЕНТ =================
@@ -107,8 +105,6 @@ def breaker_record(name: str, success: bool):
 
 # ================= ДИНАМИЧЕСКИЕ ВЕСА =================
 async def fetch_dynamic_weights() -> Dict[str, float]:
-    """Пытается получить веса из Space 31, затем из Space 17. Если нет — базовые."""
-    # Space 31
     if SPACE31_URL:
         try:
             r = await http_client.get(f"{SPACE31_URL}/weights", timeout=8)
@@ -118,7 +114,6 @@ async def fetch_dynamic_weights() -> Dict[str, float]:
                     return {k: v.get("weight", 0.1) for k, v in data.items() if k in ECOSYSTEM_SPACES}
         except:
             pass
-    # Space 17 (analyst_metrics)
     try:
         r = await http_client.get(f"{HUB_URL}/metrics", timeout=8)
         if r.status_code == 200:
@@ -133,7 +128,6 @@ async def fetch_dynamic_weights() -> Dict[str, float]:
             return weights
     except:
         pass
-    # Базовые
     return {name: cfg["weight"] for name, cfg in ECOSYSTEM_SPACES.items()}
 
 # ================= ОПРОС ОДНОГО SPACE =================
@@ -216,7 +210,6 @@ async def aggregate_ecosystem(symbol: str) -> Dict[str, Any]:
         }
 
     if total_weight == 0:
-        # Ни одного активного Space
         return {
             "ecosystem_score": 50.0,
             "direction": "WAIT",
@@ -227,12 +220,10 @@ async def aggregate_ecosystem(symbol: str) -> Dict[str, Any]:
             "votes": {"LONG": 0.0, "SHORT": 0.0, "WAIT": 0.0}
         }
 
-    # Баланс голосов
     bias = (long_votes - short_votes) / total_weight
     ecosystem_score = 50.0 + bias * 50.0
     ecosystem_score = max(0, min(100, ecosystem_score))
 
-    # Определение направления с учётом WAIT
     wait_ratio = wait_votes / total_weight
     if wait_ratio > 0.6:
         direction = "WAIT"
@@ -247,7 +238,6 @@ async def aggregate_ecosystem(symbol: str) -> Dict[str, Any]:
         direction = "WAIT"
         confidence = max(long_votes, short_votes) / total_weight
 
-    # Снижаем confidence при малом числе активных Space
     active_ratio = len(signals) / len(space_names) if space_names else 0
     confidence *= 0.5 + 0.5 * active_ratio
 
@@ -265,12 +255,29 @@ async def aggregate_ecosystem(symbol: str) -> Dict[str, Any]:
         }
     }
 
+# ================= ОТПРАВКА В 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_24_eco_agg",
+            "symbol": symbol,
+            "direction": direction,
+            "confidence": confidence,
+            "raw": json.dumps({"source": "space_24_eco_agg"})
+        })
+        logger.info(f"📤 {symbol}: {direction} conf={confidence:.3f} отправлен в Hub")
+    except Exception as e:
+        logger.error(f"Ошибка отправки в Hub: {e}")
+
 # ================= ГЛАВНЫЙ СИГНАЛ =================
 async def get_ecosystem_aggregate(symbol: str = "XAU/USD") -> Dict[str, Any]:
     start = time.time()
     agg = await aggregate_ecosystem(symbol)
     latency = int((time.time() - start) * 1000)
 
+    # Отправка агрегированного сигнала в Hub
+    await send_signal_to_hub(symbol, agg['direction'], agg['confidence'])
+
     result = {
         "space": "space_24_ecosystem_aggregator",
         "timestamp": int(time.time()),
@@ -289,22 +296,11 @@ async def get_ecosystem_aggregate(symbol: str = "XAU/USD") -> Dict[str, Any]:
         "latency_ms": latency
     }
 
-    # Отправка в Arbiter
-    try:
-        await http_client.post(f"{ARBITER_URL}/log_signal", json={
-            "space": "space_24_ecosystem",
-            "symbol": symbol,
-            "signal": result["signal"],
-            "ecosystem_details": result["ecosystem_analysis"]
-        })
-    except:
-        pass
-
     logger.info(f"🌐 Ecosystem Agg: {symbol} {agg['direction']} conf={agg['confidence']:.3f} score={agg['ecosystem_score']:.1f} active={agg['active_spaces']}")
     return result
 
 # ================= FASTAPI =================
-app = FastAPI(title="Tomiris Space 24 v2.0 — Ecosystem Aggregator Pro")
+app = FastAPI(title="Tomiris Space 24 v2.1 — Ecosystem Aggregator Pro (Hub)")
 
 @app.on_event("startup")
 async def startup():
@@ -318,11 +314,10 @@ async def shutdown():
 async def health():
     return {
         "status": "operational",
-        "version": "2.0",
+        "version": "2.1",
         "symbols": SYMBOLS,
         "ecosystem_spaces": list(ECOSYSTEM_SPACES.keys()),
-        "no_mt5": True,
-        "async": True
+        "hub_connected": True
     }
 
 @app.get("/consilium")
@@ -347,4 +342,4 @@ if __name__ == "__main__":
     import uvicorn
     uvicorn.run(app, host="0.0.0.0", port=7860)
 
-print("🚀 SPACE 24 v2.0 — ECOSYSTEM AGGREGATOR PRO ЗАПУЩЕН!")
+print("🚀 SPACE 24 v2.1 — ECOSYSTEM AGGREGATOR PRO (Hub-Connected) ЗАПУЩЕН!")