Update app.py

app.py

@@ -21,7 +21,7 @@ for module_name, pip_name in REQUIRED_PACKAGES.items():
         print(f"✅ {pip_name} установлен!")
 
 # ============================================
-# 👑 TOMIRIS SPACE 25 v2.1 — INTERMARKET CORRELATION ENGINE (Hub-Connected)
+# 👑 TOMIRIS SPACE 25 v2.2 — INTERMARKET CORRELATION ENGINE (АВТО-ОТПРАВКА)
 # ============================================
 import os, time, json, logging, asyncio
 from typing import Dict, Any, List, Optional, Tuple
@@ -58,6 +58,9 @@ TICKER_MAP = {
 HUB_URL = os.getenv("SPACE17_URL", "https://tomiris-ai-name5-5.hf.space")
 TWELVE_DATA_KEY = os.getenv("TWELVE_DATA_KEY", "e3740c072fda4fe8b8539d40b07e445e")
 
+# Интервал авто-отправки
+AUTO_SEND_INTERVAL = int(os.getenv("AUTO_SEND_INTERVAL", "300"))
+
 HISTORY_FILE = "correlation_history.json"
 CACHE_TTL = 300
 
@@ -275,14 +278,17 @@ async def analyze_correlations(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={
+        resp = await http_client.post(f"{HUB_URL}/signal", json={
             "space": "space_25_correlation",
             "symbol": symbol,
             "direction": direction,
             "confidence": confidence,
             "raw": json.dumps({"source": "space_25_correlation"})
-        })
-        logger.info(f"📤 {symbol}: {direction} conf={confidence:.3f} отправлен в Hub")
+        }, 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}")
 
@@ -292,7 +298,6 @@ async def get_correlation_signal(symbol: str = "XAU/USD") -> Dict[str, Any]:
     analysis = await analyze_correlations(symbol)
     latency = int((time.time() - start) * 1000)
 
-    # Отправка в Hub
     await send_signal_to_hub(symbol, analysis['direction'], analysis['confidence'])
 
     result = {
@@ -314,15 +319,30 @@ async def get_correlation_signal(symbol: str = "XAU/USD") -> Dict[str, Any]:
         "latency_ms": latency
     }
 
-    logger.info(f"🔗 Correlation {symbol}: {analysis['direction']} conf={analysis['confidence']:.3f} divs={analysis['divergence_count']}")
+    logger.info(f"🔗 Correlation {symbol}: {analysis['direction']} conf={analysis['confidence']:.3f}")
     return result
 
+# ================= АВТО-ОТПРАВКА =================
+async def auto_send_loop():
+    logger.info(f"🔄 Авто-отправка Correlation Engine запущена (интервал {AUTO_SEND_INTERVAL}с)")
+    await asyncio.sleep(30)
+    while True:
+        try:
+            for symbol in SYMBOLS:
+                await get_correlation_signal(symbol)
+                await asyncio.sleep(2)
+            logger.info("✅ Correlation Engine авто-отправка завершена")
+        except Exception as e:
+            logger.error(f"Ошибка авто-отправки: {e}")
+        await asyncio.sleep(AUTO_SEND_INTERVAL)
+
 # ================= FASTAPI =================
-app = FastAPI(title="Tomiris Space 25 v2.1 — Intermarket Correlation Engine (Hub)")
+app = FastAPI(title="Tomiris Space 25 v2.2 — Intermarket Correlation Engine (Auto-Hub)")
 
 @app.on_event("startup")
 async def startup():
-    pass
+    asyncio.create_task(auto_send_loop())
+    logger.info("🚀 Space 25 v2.2 запущен с авто-отправкой в Hub")
 
 @app.on_event("shutdown")
 async def shutdown():
@@ -332,9 +352,10 @@ async def shutdown():
 async def health():
     return {
         "status": "operational",
-        "version": "2.1",
+        "version": "2.2",
+        "hub_url": HUB_URL,
+        "auto_send_interval": AUTO_SEND_INTERVAL,
         "symbols": SYMBOLS,
-        "hub_connected": True,
         "history_length": len(DIVERGENCE_HISTORY)
     }
 
@@ -369,8 +390,16 @@ async def all_correlations():
         results[sym] = await analyze_correlations(sym)
     return results
 
+@app.get("/send_now")
+async def send_now():
+    results = {}
+    for symbol in SYMBOLS:
+        analysis = await get_correlation_signal(symbol)
+        results[symbol] = analysis.get("signal", {}).get("direction", "WAIT")
+    return {"status": "sent", "results": results}
+
 if __name__ == "__main__":
     import uvicorn
     uvicorn.run(app, host="0.0.0.0", port=7860)
 
-print("🚀 SPACE 25 v2.1 — INTERMARKET CORRELATION ENGINE (Hub-Connected) ЗАПУЩЕН!")
+print("🚀 SPACE 25 v2.2 — INTERMARKET CORRELATION ENGINE (АВТО-ОТПРАВКА) ЗАПУЩЕН!")