Update app.py

app.py

@@ -20,7 +20,7 @@ for module_name, pip_name in REQUIRED_PACKAGES.items():
         print(f"✅ {pip_name} установлен!")
 
 # ============================================
-# 👑 TOMIRIS SPACE 23 v2.1 — ON-CHAIN ANOMALY SENTINEL (Hub-Connected)
+# 👑 TOMIRIS SPACE 23 v2.2 — ON-CHAIN ANOMALY SENTINEL (АВТО-ОТПРАВКА)
 # ============================================
 import os, time, json, logging, asyncio
 from typing import Dict, Any, List, Optional
@@ -37,7 +37,10 @@ logger = logging.getLogger("Space23_AnomalySentinel")
 TRACKED_SYMBOLS = ["ETH/USD", "SOL/USD"]
 HUB_URL = os.getenv("SPACE17_URL", "https://tomiris-ai-name5-5.hf.space")
 ETHERSCAN_KEY = os.getenv("ETHERSCAN_KEY", "TZGVD58I2HZ9G4BBD548KX11E4JFH4J5GX")
-SOLSCAN_KEY = os.getenv("SOLSCAN_KEY", "")  # опционально
+SOLSCAN_KEY = os.getenv("SOLSCAN_KEY", "")
+
+# Интервал авто-отправки
+AUTO_SEND_INTERVAL = int(os.getenv("AUTO_SEND_INTERVAL", "300"))
 
 ETH_WHALE_WALLETS = [
     "0x28C6c06298d514089D2Bd15f6A8a38c5d8d3a6B2",
@@ -89,7 +92,7 @@ if os.path.exists(ACTIVE_HISTORY_FILE):
 else:
     active_history = {}
 
-# ================= ЗАГРУЗКА ДАННЫХ (без изменений) =================
+# ================= ЗАГРУЗКА ДАННЫХ =================
 async def fetch_gas_oracle() -> Dict[str, Any]:
     if breaker_open("etherscan"):
         return {'avg_gas': 45, 'gas_level': 'NORMAL', 'is_anomaly': False}
@@ -225,7 +228,7 @@ async def detect_anomalies(symbol: str) -> Dict[str, Any]:
     elif score >= 30:
         level, direction = "ELEVATED", "WAIT"
     else:
-        level, direction = "NORMAL", "NEUTRAL"
+        level, direction = "NORMAL", "LONG"
 
     record = {
         "timestamp": datetime.now(timezone.utc).isoformat(),
@@ -238,7 +241,6 @@ async def detect_anomalies(symbol: str) -> Dict[str, Any]:
     with open(HISTORY_FILE, 'w') as f:
         json.dump(list(ANOMALY_HISTORY), f)
 
-    # Отправляем в Space 17 (если доступен)
     try:
         await http_client.post(f"{HUB_URL}/anomaly", json=record, timeout=5)
     except:
@@ -260,14 +262,17 @@ async def detect_anomalies(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_23_anomaly",
             "symbol": symbol,
             "direction": direction,
             "confidence": confidence,
             "raw": json.dumps({"source": "space_23_anomaly"})
-        })
-        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}")
 
@@ -280,7 +285,6 @@ async def get_anomaly_signal(symbol: str = "ETH/USD") -> Dict[str, Any]:
     direction = analysis['signal']
     confidence = round(analysis['anomaly_score'] / 100, 4) if analysis['anomaly_score'] > 0 else 0.0
 
-    # Отправка в Hub
     await send_signal_to_hub(symbol, direction, confidence)
 
     result = {
@@ -298,12 +302,27 @@ async def get_anomaly_signal(symbol: str = "ETH/USD") -> Dict[str, Any]:
     logger.info(f"🔍 Anomaly {symbol}: {analysis['anomaly_level']} | Score={analysis['anomaly_score']}")
     return result
 
+# ================= АВТО-ОТПРАВКА =================
+async def auto_send_loop():
+    logger.info(f"🔄 Авто-отправка Anomaly Sentinel запущена (интервал {AUTO_SEND_INTERVAL}с)")
+    await asyncio.sleep(30)
+    while True:
+        try:
+            for symbol in TRACKED_SYMBOLS:
+                await get_anomaly_signal(symbol)
+                await asyncio.sleep(2)
+            logger.info("✅ Anomaly Sentinel авто-отправка завершена")
+        except Exception as e:
+            logger.error(f"Ошибка авто-отправки: {e}")
+        await asyncio.sleep(AUTO_SEND_INTERVAL)
+
 # ================= FASTAPI =================
-app = FastAPI(title="Tomiris Space 23 v2.1 — On-Chain Anomaly Sentinel (Hub)")
+app = FastAPI(title="Tomiris Space 23 v2.2 — On-Chain Anomaly Sentinel (Auto-Hub)")
 
 @app.on_event("startup")
 async def startup():
-    pass
+    asyncio.create_task(auto_send_loop())
+    logger.info("🚀 Space 23 v2.2 запущен с авто-отправкой в Hub")
 
 @app.on_event("shutdown")
 async def shutdown():
@@ -313,10 +332,11 @@ 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": TRACKED_SYMBOLS,
-        "anomaly_history": len(ANOMALY_HISTORY),
-        "hub_connected": True
+        "anomaly_history": len(ANOMALY_HISTORY)
     }
 
 @app.get("/consilium")
@@ -353,8 +373,16 @@ async def active(chain: str = "ethereum"):
 async def history(limit: int = 50):
     return list(ANOMALY_HISTORY)[-limit:]
 
+@app.get("/send_now")
+async def send_now():
+    results = {}
+    for symbol in TRACKED_SYMBOLS:
+        analysis = await get_anomaly_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 23 v2.1 — ON-CHAIN ANOMALY SENTINEL (Hub-Connected) ЗАПУЩЕН!")
+print("🚀 SPACE 23 v2.2 — ON-CHAIN ANOMALY SENTINEL (АВТО-ОТПРАВКА) ЗАПУЩЕН!")