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.0 — ON-CHAIN ANOMALY SENTINEL (Async, Real On-Chain, No MT5)
+# 👑 TOMIRIS SPACE 23 v2.1 — ON-CHAIN ANOMALY SENTINEL (Hub-Connected)
 # ============================================
 import os, time, json, logging, asyncio
 from typing import Dict, Any, List, Optional
@@ -36,25 +36,23 @@ logger = logging.getLogger("Space23_AnomalySentinel")
 # ================= КОНФИГУРАЦИЯ =================
 TRACKED_SYMBOLS = ["ETH/USD", "SOL/USD"]
 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")
 ETHERSCAN_KEY = os.getenv("ETHERSCAN_KEY", "TZGVD58I2HZ9G4BBD548KX11E4JFH4J5GX")
 SOLSCAN_KEY = os.getenv("SOLSCAN_KEY", "")  # опционально
 
-# Известные кошельки бирж/китов (Ethereum)
 ETH_WHALE_WALLETS = [
-    "0x28C6c06298d514089D2Bd15f6A8a38c5d8d3a6B2",  # Binance 7
-    "0xA274C1e7D16E7e6F7C0e68b9f5A1a1BCc6E39509",  # Kraken
-    "0xBE0eB53F46cDf7F88F0E6F9D4D1D08B42DAbcD17"   # крупный кит
+    "0x28C6c06298d514089D2Bd15f6A8a38c5d8d3a6B2",
+    "0xA274C1e7D16E7e6F7C0e68b9f5A1a1BCc6E39509",
+    "0xBE0eB53F46cDf7F88F0E6F9D4D1D08B42DAbcD17"
 ]
 SOL_WHALE_WALLETS = [
-    "9L4rU4mZJ2o8H6h2Xw3V3vJ2x9f7DqFtRt3y5j7",   # пример адреса валидатора
-    "8k3WkRLGkR9mZ9z3X3a3o5v3h5p7u5j3n4b5v6c"    # биржа
+    "9L4rU4mZJ2o8H6h2Xw3V3vJ2x9f7DqFtRt3y5j7",
+    "8k3WkRLGkR9mZ9z3X3a3o5v3h5p7u5j3n4b5v6c"
 ]
 
 CACHE_TTL = {"gas": 60, "whales": 300, "stablecoin": 300, "active": 600}
 HISTORY_FILE = "anomaly_history.json"
+ACTIVE_HISTORY_FILE = "active_history.json"
 
-# Circuit breaker
 CIRCUIT_BREAKER = {}
 
 def breaker_open(name: str) -> bool:
@@ -85,15 +83,13 @@ if os.path.exists(HISTORY_FILE):
 else:
     ANOMALY_HISTORY = deque(maxlen=500)
 
-# История активных адресов
-ACTIVE_HISTORY_FILE = "active_history.json"
 if os.path.exists(ACTIVE_HISTORY_FILE):
     with open(ACTIVE_HISTORY_FILE) as f:
         active_history = json.load(f)
 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}
@@ -114,13 +110,12 @@ async def fetch_gas_oracle() -> Dict[str, Any]:
     return {'avg_gas': 45, 'gas_level': 'NORMAL', 'is_anomaly': False}
 
 async def fetch_large_transactions(network: str) -> Dict[str, Any]:
-    """Крупные транзакции из отслеживаемых кошельков."""
     if network == "ethereum":
         wallets = ETH_WHALE_WALLETS
         api_url = f"https://api.etherscan.io/api?module=account&action=txlist&apikey={ETHERSCAN_KEY}"
     else:
         wallets = SOL_WHALE_WALLETS
-        api_url = f"https://api.solscan.io/api?module=account&action=txlist"  # заглушка, если нет ключа
+        api_url = f"https://api.solscan.io/api?module=account&action=txlist"
     if breaker_open(f"whale_{network}"):
         return {'large_transactions': [], 'count': 0, 'is_anomaly': False, 'signal': 'NORMAL'}
 
@@ -132,7 +127,7 @@ async def fetch_large_transactions(network: str) -> Dict[str, Any]:
                 txs = r.json().get('result', [])
                 for tx in txs:
                     value = float(tx.get('value', 0))
-                    if network == "ethereum" and value > 100e18:  # > 100 ETH
+                    if network == "ethereum" and value > 100e18:
                         large_txs.append({
                             'hash': tx.get('hash', '')[:10],
                             'value_eth': round(value / 1e18, 2),
@@ -151,21 +146,16 @@ async def fetch_large_transactions(network: str) -> Dict[str, Any]:
     }
 
 async def fetch_stablecoin_flows(network: str) -> Dict[str, Any]:
-    """Отслеживаем крупные транзакции USDT/USDC (mint/burn) как прокси ликвидности."""
     if breaker_open(f"stablecoin_{network}"):
         return {'signal': 'BALANCED', 'is_anomaly': False}
-    # Для Ethereum используем Etherscan токен-трансферы
     if network == "ethereum":
-        # USDT контракт: 0xdAC17F958D2ee523a2206206994597C13D831ec7
-        # USDC контракт: 0xA0b86991c6218b36c1d19D4a2e9Eb0cE3606eB48
         usdt_url = f"https://api.etherscan.io/api?module=account&action=tokentx&address=0xdAC17F958D2ee523a2206206994597C13D831ec7&page=1&offset=10&sort=desc&apikey={ETHERSCAN_KEY}"
         try:
             r = await http_client.get(usdt_url)
             if r.status_code == 200 and r.json().get('status') == '1':
                 txs = r.json().get('result', [])
-                # Считае�� объём
-                total_value = sum(int(tx['value']) for tx in txs) / 1e6  # USDT decimals=6
-                anomaly = total_value > 10_000_000  # > 10 млн USDT за 10 транзакций
+                total_value = sum(int(tx['value']) for tx in txs) / 1e6
+                anomaly = total_value > 10_000_000
                 breaker_record("stablecoin_ethereum", True)
                 return {
                     'token': 'USDT',
@@ -175,7 +165,6 @@ async def fetch_stablecoin_flows(network: str) -> Dict[str, Any]:
                 }
         except:
             breaker_record("stablecoin_ethereum", False)
-    # Для Solana используем Solscan (заглушка, можно расширить)
     return {'signal': 'BALANCED', 'is_anomaly': False}
 
 async def fetch_active_addresses(chain: str) -> Dict[str, Any]:
@@ -189,7 +178,6 @@ async def fetch_active_addresses(chain: str) -> Dict[str, Any]:
             prev = active_history.get(chain, current)
             change = ((current - prev) / prev * 100) if prev > 0 else 0
             active_history[chain] = current
-            # Сохраняем в файл
             with open(ACTIVE_HISTORY_FILE, 'w') as f:
                 json.dump(active_history, f)
             is_anomaly = abs(change) > 20
@@ -208,7 +196,6 @@ async def fetch_active_addresses(chain: str) -> Dict[str, Any]:
 # ================= ДЕТЕКТОР АНОМАЛИЙ =================
 async def detect_anomalies(symbol: str) -> Dict[str, Any]:
     chain = "ethereum" if "ETH" in symbol else "solana"
-    native = "ETH" if chain == "ethereum" else "SOL"
 
     gas = await fetch_gas_oracle() if chain == "ethereum" else {'is_anomaly': False}
     whales = await fetch_large_transactions(chain)
@@ -240,7 +227,6 @@ async def detect_anomalies(symbol: str) -> Dict[str, Any]:
     else:
         level, direction = "NORMAL", "NEUTRAL"
 
-    # Сохраняем в историю
     record = {
         "timestamp": datetime.now(timezone.utc).isoformat(),
         "symbol": symbol,
@@ -271,39 +257,49 @@ 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={
+            "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")
+    except Exception as e:
+        logger.error(f"Ошибка отправки в Hub: {e}")
+
 # ================= ГЛАВНЫЙ СИГНАЛ =================
 async def get_anomaly_signal(symbol: str = "ETH/USD") -> Dict[str, Any]:
     start = time.time()
     analysis = await detect_anomalies(symbol)
     latency = int((time.time() - start) * 1000)
 
+    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 = {
         "space": "space_23_anomaly",
         "timestamp": int(time.time()),
         "symbol": symbol,
         "signal": {
-            "direction": analysis['signal'],
-            "confidence": round(analysis['anomaly_score'] / 100, 4) if analysis['anomaly_score'] > 0 else 0.0
+            "direction": direction,
+            "confidence": confidence
         },
         "anomaly_analysis": analysis,
         "latency_ms": latency
     }
 
-    # Отправка в Arbiter (сигнал WAIT/NEUTRAL)
-    try:
-        await http_client.post(f"{ARBITER_URL}/log_signal", json={
-            "space": "space_23_anomaly",
-            "symbol": symbol,
-            "signal": result["signal"]
-        })
-    except:
-        pass
-
     logger.info(f"🔍 Anomaly {symbol}: {analysis['anomaly_level']} | Score={analysis['anomaly_score']}")
     return result
 
 # ================= FASTAPI =================
-app = FastAPI(title="Tomiris Space 23 v2.0 — On-Chain Anomaly Sentinel")
+app = FastAPI(title="Tomiris Space 23 v2.1 — On-Chain Anomaly Sentinel (Hub)")
 
 @app.on_event("startup")
 async def startup():
@@ -317,10 +313,10 @@ async def shutdown():
 async def health():
     return {
         "status": "operational",
-        "version": "2.0",
+        "version": "2.1",
         "symbols": TRACKED_SYMBOLS,
         "anomaly_history": len(ANOMALY_HISTORY),
-        "no_mt5": True
+        "hub_connected": True
     }
 
 @app.get("/consilium")
@@ -361,4 +357,4 @@ if __name__ == "__main__":
     import uvicorn
     uvicorn.run(app, host="0.0.0.0", port=7860)
 
-print("🚀 SPACE 23 v2.0 — ON-CHAIN ANOMALY SENTINEL ЗАПУЩЕН!")
+print("🚀 SPACE 23 v2.1 — ON-CHAIN ANOMALY SENTINEL (Hub-Connected) ЗАПУЩЕН!")