Update app.py

app.py

@@ -21,7 +21,9 @@ for module_name, pip_name in REQUIRED_PACKAGES.items():
         print(f"✅ {pip_name} установлен!")
 
 # ============================================
-# 👑 TOMIRIS SPACE 26 v2.4 — OPTIONS & DERIVATIVES ENGINE (АВТО-ОТПРАВКА)
+# 👑 TOMIRIS SPACE 26 v3.0 — OPTIONS & DERIVATIVES ENGINE (PRO-8/tomiris-options)
+# Миграция с v2.4. Все функции сохранены.
+# HUB_URL обновлён, HUB_SECRET во всех запросах.
 # ============================================
 import os, time, json, logging, asyncio
 from typing import Dict, Any, List, Optional
@@ -37,12 +39,19 @@ logger = logging.getLogger("Space26_Options")
 
 # ================= КОНФИГУРАЦИЯ =================
 SYMBOLS = ["XAU/USD", "ETH/USD", "SOL/USD"]
-HUB_URL = os.getenv("SPACE17_URL", "https://tomiris-ai-name5-5.hf.space")
+
+# ================= ОБНОВЛЁННЫЙ HUB URL =================
+HUB_URL = "https://pro-3-tomiris-hub.hf.space"
+HUB_SECRET = os.getenv("HUB_SECRET", "TomyrisUltraSecret2026!")
+
 TWELVE_DATA_KEY = os.getenv("TWELVE_DATA_KEY", "58e67e0008e24161ac9b1671b7c2d2d0")
 FRED_KEY = os.getenv("FRED_KEY", "faa11c8e2e4beee08c5b966e8b63a513")
 
+# ================= СТАРТОВЫЙ СОН =================
+STARTUP_SLEEP = int(os.getenv("STARTUP_SLEEP", 600))  # 10 минут
+
 # Интервал авто-отправки
-AUTO_SEND_INTERVAL = int(os.getenv("AUTO_SEND_INTERVAL", "300"))
+AUTO_SEND_INTERVAL = int(os.getenv("AUTO_SEND_INTERVAL", "600"))  # 10 минут
 
 HISTORY_FILE = "options_history.json"
 CACHE_TTL = {
@@ -53,6 +62,10 @@ CACHE_TTL = {
 # ================= HTTP КЛИЕНТ =================
 http_client = httpx.AsyncClient(timeout=15.0)
 
+# ================= ЗАГОЛОВКИ ДЛЯ ХАБА =================
+def hub_headers():
+    return {"X-Hub-Secret": HUB_SECRET} if HUB_SECRET else {}
+
 # ================= ГЛОБАЛЬНЫЙ КЭШ И BREAKER =================
 cache_store = {}
 cache_times = {}
@@ -172,8 +185,10 @@ async def fetch_gold_derivatives() -> Dict[str, Any]:
 
 async def get_current_price(symbol: str) -> float:
     try:
-        r = await http_client.get(f"{HUB_URL}/price/{symbol}")
-        if r.status_code == 200: return float(r.json().get("mid", 0))
+        r = await http_client.get(f"{HUB_URL}/price/{symbol}", headers=hub_headers())
+        if r.status_code == 200: 
+            data = r.json()
+            return float(data.get("price", data.get("mid", 0)))
     except: pass
     bin_symbol = symbol.replace("/", "")
     try:
@@ -263,14 +278,29 @@ async def analyze_derivatives(symbol: str) -> Dict[str, Any]:
 # ================= ОТПРАВКА В HUB =================
 async def send_signal_to_hub(symbol: str, direction: str, confidence: float):
     try:
-        resp = 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"})
-        }, timeout=10)
-        if resp.status_code == 200: logger.info(f"📤 {symbol}: {direction} conf={confidence:.3f} отправлен в Hub")
-        else: logger.warning(f"Hub вернул {resp.status_code}")
-    except Exception as e: logger.error(f"Ошибка отправки в Hub: {e}")
+        payload = {
+            "space": "space_26_options",
+            "space_name": "space_26_options",
+            "symbol": symbol,
+            "direction": direction,
+            "confidence": confidence,
+            "features": {},
+            "metadata": {"version": "3.0", "source": "PRO-8/tomiris-options"}
+        }
+        r = await http_client.post(f"{HUB_URL}/signals", json=payload, timeout=10, headers=hub_headers())
+        if r.status_code == 200:
+            logger.info(f"📤 {symbol}: {direction} conf={confidence:.3f} отправлен в Hub")
+        else:
+            r = await http_client.post(f"{HUB_URL}/signal", json={
+                "space": "space_26_options", "symbol": symbol,
+                "direction": direction, "confidence": confidence
+            }, timeout=10, headers=hub_headers())
+            if r.status_code == 200:
+                logger.info(f"📤 {symbol}: {direction} conf={confidence:.3f} (через /signal)")
+            else:
+                logger.warning(f"Hub вернул {r.status_code}")
+    except Exception as e:
+        logger.error(f"Ошибка отправки в Hub: {e}")
 
 # ================= ГЛАВНЫЙ СИГНАЛ =================
 async def get_derivative_signal(symbol: str = "ETH/USD") -> Dict[str, Any]:
@@ -283,8 +313,9 @@ async def get_derivative_signal(symbol: str = "ETH/USD") -> Dict[str, Any]:
 
 # ================= АВТО-ОТПРАВКА =================
 async def auto_send_loop():
+    logger.info(f"⏳ Стартовый сон {STARTUP_SLEEP} секунд...")
+    await asyncio.sleep(STARTUP_SLEEP)
     logger.info(f"🔄 Авто-отправка Options Engine запущена (интервал {AUTO_SEND_INTERVAL}с)")
-    await asyncio.sleep(30)
     while True:
         try:
             for symbol in SYMBOLS:
@@ -294,19 +325,24 @@ async def auto_send_loop():
         await asyncio.sleep(AUTO_SEND_INTERVAL)
 
 # ================= FASTAPI =================
-app = FastAPI(title="Tomiris Space 26 v2.4 — Options & Derivatives Engine (Auto-Hub)")
+app = FastAPI(title="Tomiris Space 26 v3.0 — Options & Derivatives Engine (PRO-8)")
 
 @app.on_event("startup")
 async def startup():
     asyncio.create_task(auto_send_loop())
-    logger.info("🚀 Space 26 v2.4 запущен с авто-отправкой в Hub")
+    logger.info("🚀 Space 26 v3.0 запущен на PRO-8/tomiris-options")
 
 @app.on_event("shutdown")
 async def shutdown(): await http_client.aclose()
 
 @app.get("/health")
 async def health():
-    return {"status": "operational", "version": "2.4", "hub_url": HUB_URL, "auto_send_interval": AUTO_SEND_INTERVAL, "features": ["VIX", "Funding", "OI", "L/S", "Options PCR", "COT/DXY/TIPS", "Max Pain"]}
+    return {
+        "status": "operational", "version": "3.0",
+        "space": "PRO-8/tomiris-options",
+        "hub_url": HUB_URL, "auto_send_interval": AUTO_SEND_INTERVAL,
+        "startup_sleep": STARTUP_SLEEP
+    }
 
 @app.get("/consilium")
 async def consilium(symbol: str = Query("ETH/USD")):
@@ -339,8 +375,12 @@ async def send_now():
         results[symbol] = analysis.get("signal", {}).get("direction", "WAIT")
     return {"status": "sent", "results": results}
 
+@app.get("/")
+async def root():
+    return {"name": "Options Engine v3.0", "space": "PRO-8/tomiris-options", "hub": HUB_URL}
+
 if __name__ == "__main__":
     import uvicorn
     uvicorn.run(app, host="0.0.0.0", port=7860)
 
-print("🚀 SPACE 26 v2.4 — OPTIONS & DERIVATIVES ENGINE (АВТО-ОТПРАВКА) ЗАПУЩЕН!")
+print("🚀 SPACE 26 v3.0 — OPTIONS & DERIVATIVES ENGINE (PRO-8/tomiris-options) ЗАПУЩЕН!")