Create app.py

app.py

@@ -0,0 +1,491 @@
+# ============================================
+# АВТО-УСТАНОВКА ПАКЕТОВ
+# ============================================
+import subprocess
+import sys
+import importlib
+
+REQUIRED_PACKAGES = {
+    'numpy': 'numpy',
+    'pandas': 'pandas',
+    'requests': 'requests'
+}
+
+for module_name, pip_name in REQUIRED_PACKAGES.items():
+    try:
+        importlib.import_module(module_name)
+    except ImportError:
+        print(f"📦 Устанавливаю {pip_name}...")
+        subprocess.check_call([sys.executable, "-m", "pip", "install", pip_name])
+        print(f"✅ {pip_name} установлен!")
+
+# ============================================
+# 👑 TOMIRIS SPACE 20 v1.0 — ETHEREUM L2 & DEFI PULSE
+# ============================================
+# Мониторит L2-сети (Arbitrum, Optimism, Base, zkSync) и DeFi-метрики.
+# TVL, DEX-объёмы, активность разработчиков, стейкинг, сжигание ETH.
+# Сигнализирует о трендах в экосистеме Ethereum.
+# ============================================
+
+from fastapi import FastAPI, Query
+from typing import Optional, Dict, Any, List
+import time
+import requests
+import threading
+import numpy as np
+from datetime import datetime
+from collections import deque
+import warnings
+warnings.filterwarnings('ignore')
+
+# ================= КОНФИГУРАЦИЯ =================
+SYMBOL: str = "ETH/USD"
+
+L2_CHAINS: Dict[str, str] = {
+    "Arbitrum": "Arbitrum",
+    "Optimism": "Optimism",
+    "Base": "Base",
+    "Polygon ZkEVM": "Polygon ZkEVM"
+}
+
+DEFI_PROTOCOLS: List[str] = [
+    "Lido", "MakerDAO", "Aave", "Uniswap", "Curve",
+    "EigenLayer", "Rocket Pool"
+]
+
+SPACE_18_ARBITER: str = "https://tomiris-ai-name6-6.hf.space"
+
+# ================= ГЛОБАЛЬНЫЕ ПЕРЕМЕННЫЕ =================
+CACHE: Dict[str, Dict[str, Any]] = {}
+CACHE_TIMES: Dict[str, float] = {}
+FEATURES_STORE: Dict[str, Dict[str, Any]] = {}
+MT5_MAX_AGE_SEC: int = 300
+
+def send_to_arbiter(signal_data: Dict[str, Any]) -> None:
+    try:
+        requests.post(
+            f"{SPACE_18_ARBITER}/log_signal",
+            json={'space': 'space_20_l2_defi', 'symbol': SYMBOL, 'signal': signal_data.get('signal', {})},
+            timeout=5
+        )
+    except:
+        pass
+
+# ================= ЗАГРУЗКА ДАННЫХ DeFiLlama =================
+def fetch_chain_tvl(chain: str) -> Optional[Dict[str, Any]]:
+    cache_key = f"tvl_{chain}"
+    if cache_key in CACHE and time.time() - CACHE_TIMES.get(cache_key, 0) < 300:
+        return CACHE[cache_key]
+
+    try:
+        r = requests.get(f"https://api.llama.fi/v2/tvl/{chain}", timeout=10)
+        if r.status_code == 200:
+            data = r.json()
+            result = {
+                'chain': chain,
+                'tvl': data.get('tvl', 0),
+                'tvl_billions': round(data.get('tvl', 0) / 1e9, 2),
+                'change_24h': data.get('change_1d', 0),
+                'change_7d': data.get('change_7d', 0),
+                'trend': 'UP' if data.get('change_1d', 0) > 0 else 'DOWN'
+            }
+            CACHE[cache_key] = result
+            CACHE_TIMES[cache_key] = time.time()
+            return result
+    except Exception as e:
+        print(f"⚠️ TVL {chain}: {e}")
+    return None
+
+def fetch_all_l2_tvl() -> Dict[str, Any]:
+    l2_data: Dict[str, Any] = {}
+    total_tvl = 0.0
+    total_change = 0.0
+    active_chains = 0
+
+    for chain, name in L2_CHAINS.items():
+        data = fetch_chain_tvl(chain)
+        if data:
+            l2_data[chain] = data
+            total_tvl += data['tvl']
+            total_change += data['change_24h']
+            active_chains += 1
+        else:
+            l2_data[chain] = {"error": "no_data"}
+
+    avg_change = total_change / active_chains if active_chains > 0 else 0
+
+    return {
+        'chains': l2_data,
+        'total_l2_tvl': round(total_tvl, 2),
+        'total_l2_tvl_billions': round(total_tvl / 1e9, 2),
+        'avg_change_24h': round(avg_change, 2),
+        'trend': 'GROWING' if avg_change > 2 else 'SHRINKING' if avg_change < -2 else 'STABLE',
+        'signal': 'BULLISH' if avg_change > 2 else 'BEARISH' if avg_change < -2 else 'NEUTRAL'
+    }
+
+def fetch_ethereum_tvl() -> Dict[str, Any]:
+    cache_key = "tvl_ethereum"
+    if cache_key in CACHE and time.time() - CACHE_TIMES.get(cache_key, 0) < 300:
+        return CACHE[cache_key]
+
+    try:
+        r = requests.get("https://api.llama.fi/v2/tvl/ethereum", timeout=10)
+        if r.status_code == 200:
+            data = r.json()
+            result = {
+                'tvl': data.get('tvl', 0),
+                'tvl_billions': round(data.get('tvl', 0) / 1e9, 2),
+                'change_24h': data.get('change_1d', 0),
+                'change_7d': data.get('change_7d', 0),
+                'trend': 'UP' if data.get('change_1d', 0) > 0 else 'DOWN'
+            }
+            CACHE[cache_key] = result
+            CACHE_TIMES[cache_key] = time.time()
+            return result
+    except:
+        pass
+    return {'tvl': 0, 'trend': 'STABLE'}
+
+# ================= СТЕЙКИНГ =================
+def fetch_staking_metrics() -> Dict[str, Any]:
+    """Доля ETH в стейкинге, APR, ликвидный стейкинг."""
+    cache_key = "staking"
+    if cache_key in CACHE and time.time() - CACHE_TIMES.get(cache_key, 0) < 300:
+        return CACHE[cache_key]
+
+    result: Dict[str, Any] = {}
+
+    # Lido TVL как прокси ликвидного стейкинга
+    try:
+        r = requests.get("https://api.llama.fi/v2/tvl/lido", timeout=10)
+        if r.status_code == 200:
+            data = r.json()
+            result['lido_tvl'] = data.get('tvl', 0)
+            result['lido_tvl_billions'] = round(data.get('tvl', 0) / 1e9, 2)
+            result['lido_change_24h'] = data.get('change_1d', 0)
+    except:
+        result['lido_tvl'] = 0
+
+    # EigenLayer TVL
+    try:
+        r = requests.get("https://api.llama.fi/v2/tvl/eigenlayer", timeout=10)
+        if r.status_code == 200:
+            data = r.json()
+            result['eigenlayer_tvl'] = data.get('tvl', 0)
+            result['eigenlayer_change_24h'] = data.get('change_1d', 0)
+            result['restaking_growth'] = 'HIGH' if data.get('change_1d', 0) > 5 else 'MODERATE' if data.get('change_1d', 0) > 0 else 'DECLINING'
+    except:
+        result['eigenlayer_tvl'] = 0
+
+    result['signal'] = 'BULLISH' if result.get('lido_change_24h', 0) > 0 else 'NEUTRAL'
+
+    CACHE[cache_key] = result
+    CACHE_TIMES[cache_key] = time.time()
+    return result
+
+# ================= DEX ОБЪЁМЫ =================
+def fetch_dex_volumes() -> Dict[str, Any]:
+    cache_key = "dex_eth"
+    if cache_key in CACHE and time.time() - CACHE_TIMES.get(cache_key, 0) < 300:
+        return CACHE[cache_key]
+
+    try:
+        r = requests.get(
+            "https://api.llama.fi/overview/dexs/ethereum?excludeTotalDataChart=true&excludeTotalDataChartBreakdown=true",
+            timeout=10
+        )
+        if r.status_code == 200:
+            data = r.json()
+            result = {
+                'total_volume_24h': data.get('total24h', 0),
+                'volume_billions': round(data.get('total24h', 0) / 1e9, 2),
+                'change_24h': data.get('change_1d', 0),
+                'trend': 'UP' if data.get('change_1d', 0) > 0 else 'DOWN',
+                'signal': 'BULLISH' if data.get('change_1d', 0) > 10 else 'BEARISH' if data.get('change_1d', 0) < -10 else 'NEUTRAL'
+            }
+            CACHE[cache_key] = result
+            CACHE_TIMES[cache_key] = time.time()
+            return result
+    except:
+        pass
+    return {'total_volume_24h': 0, 'signal': 'NEUTRAL'}
+
+# ================= СЖИГАНИЕ ETH =================
+def fetch_ultrasound_money() -> Dict[str, Any]:
+    cache_key = "ultrasound"
+    if cache_key in CACHE and time.time() - CACHE_TIMES.get(cache_key, 0) < 300:
+        return CACHE[cache_key]
+
+    try:
+        r = requests.get("https://ultrasound.money/api/overview", timeout=10)
+        if r.status_code == 200:
+            data = r.json()
+            result = {
+                'burn_24h': data.get("burn24h", 0),
+                'supply_growth_24h': data.get("supplyGrowth24h", 0),
+                'is_deflationary': data.get("supplyGrowth24h", 0) < 0,
+                'signal': 'BULLISH' if data.get("supplyGrowth24h", 0) < 0 else 'BEARISH'
+            }
+            CACHE[cache_key] = result
+            CACHE_TIMES[cache_key] = time.time()
+            return result
+    except:
+        pass
+    return {'is_deflationary': False, 'signal': 'NEUTRAL'}
+
+# ================= РАЗРАБОТЧИКИ =================
+def fetch_developer_activity() -> Dict[str, Any]:
+    """Активность разработчиков через Electric Capital (заглушка)."""
+    try:
+        r = requests.get("https://api.coingecko.com/api/v3/coins/ethereum?developer_data=true", timeout=10)
+        if r.status_code == 200:
+            dev = r.json().get('developer_data', {})
+            return {
+                'stars': dev.get('stars', 0),
+                'commits_4w': dev.get('commit_count_4_weeks', 0),
+                'activity': 'HIGH' if dev.get('commit_count_4_weeks', 0) > 100 else 'MODERATE'
+            }
+    except:
+        pass
+    return {'activity': 'MODERATE'}
+
+# ================= АНАЛИЗ ИЗ MT5 =================
+def analyze_from_mt5(mt5_features: Dict[str, Any]) -> Optional[Dict[str, Any]]:
+    try:
+        score = 50.0
+        signals = []
+
+        vol = mt5_features.get('H1_volume', 0)
+        if isinstance(vol, (int, float)) and vol > 1000:
+            signals.append({"signal": "BULLISH", "reason": "Высокий объём на H1"})
+            score += 5
+
+        ema = mt5_features.get('H1_price_vs_ema_21', 0)
+        if isinstance(ema, (int, float)):
+            if ema > 1.0:
+                score += 10
+            elif ema < -1.0:
+                score -= 10
+
+        score = max(0, min(100, score))
+
+        if score > 60:
+            direction, confidence = "LONG", score / 100
+        elif score < 40:
+            direction, confidence = "SHORT", (100 - score) / 100
+        else:
+            direction, confidence = "WAIT", 0.0
+
+        return {
+            "direction": direction,
+            "confidence": round(confidence, 4),
+            "ecosystem_score": score,
+            "signals": signals,
+            "source": "MT5"
+        }
+    except:
+        return None
+
+# ================= ГЛАВНЫЙ АНАЛИЗ =================
+def analyze_ecosystem() -> Dict[str, Any]:
+    l2 = fetch_all_l2_tvl()
+    eth_tvl = fetch_ethereum_tvl()
+    staking = fetch_staking_metrics()
+    dex = fetch_dex_volumes()
+    ultrasound = fetch_ultrasound_money()
+    dev = fetch_developer_activity()
+
+    signals = []
+    score = 50.0
+
+    # L2 тренд
+    if l2.get('trend') == 'GROWING':
+        signals.append({"signal": "BULLISH", "reason": f"L2 растёт (+{l2.get('avg_change_24h', 0):.1f}%)"})
+        score += 15
+    elif l2.get('trend') == 'SHRINKING':
+        signals.append({"signal": "BEARISH", "reason": "L2 падает"})
+        score -= 15
+
+    # TVL Ethereum
+    if eth_tvl.get('trend') == 'UP' and eth_tvl.get('change_24h', 0) > 2:
+        signals.append({"signal": "BULLISH", "reason": "TVL ETH растёт"})
+        score += 10
+    elif eth_tvl.get('trend') == 'DOWN' and eth_tvl.get('change_24h', 0) < -2:
+        signals.append({"signal": "BEARISH", "reason": "TVL ETH падает"})
+        score -= 10
+
+    # Стейкинг
+    if staking.get('restaking_growth') == 'HIGH':
+        signals.append({"signal": "BULLISH", "reason": "Рестейкинг растёт"})
+        score += 5
+
+    # DEX
+    if dex.get('signal') == 'BULLISH':
+        signals.append({"signal": "BULLISH", "reason": "DEX объёмы растут"})
+        score += 8
+    elif dex.get('signal') == 'BEARISH':
+        signals.append({"signal": "BEARISH", "reason": "DEX объёмы падают"})
+        score -= 8
+
+    # Ultrasound
+    if ultrasound.get('is_deflationary'):
+        signals.append({"signal": "BULLISH", "reason": "ETH дефляционный"})
+        score += 8
+
+    # Разработчики
+    if dev.get('activity') == 'HIGH':
+        signals.append({"signal": "BULLISH", "reason": "Высокая активность разработчиков"})
+        score += 3
+
+    score = max(0, min(100, score))
+
+    if score > 60:
+        direction, confidence = "LONG", score / 100
+    elif score < 40:
+        direction, confidence = "SHORT", (100 - score) / 100
+    else:
+        direction, confidence = "WAIT", 0.0
+
+    return {
+        "ecosystem_score": score,
+        "direction": direction,
+        "confidence": round(confidence, 4),
+        "signals": signals,
+        "metrics": {
+            "l2": l2,
+            "ethereum_tvl": eth_tvl,
+            "staking": staking,
+            "dex": dex,
+            "ultrasound": ultrasound,
+            "developer_activity": dev
+        }
+    }
+
+# ================= ГЛАВНЫЙ СИГНАЛ =================
+def get_ecosystem_signal() -> Dict[str, Any]:
+    start = time.time()
+
+    # Проверка MT5
+    if SYMBOL in FEATURES_STORE:
+        fs = FEATURES_STORE[SYMBOL]
+        age = time.time() - fs.get("timestamp", 0)
+        if age < MT5_MAX_AGE_SEC:
+            mt5_features = fs.get("features", {})
+            if mt5_features:
+                mt5_result = analyze_from_mt5(mt5_features)
+                if mt5_result:
+                    result = {
+                        "space": "space_20_l2_defi_pulse",
+                        "timestamp": int(time.time()),
+                        "symbol": SYMBOL,
+                        "signal": {
+                            "direction": mt5_result["direction"],
+                            "confidence": mt5_result["confidence"]
+                        },
+                        "ecosystem_analysis": {
+                            "score": mt5_result["ecosystem_score"],
+                            "signals": mt5_result["signals"]
+                        },
+                        "data_source": "MT5",
+                        "meta": {"latency_ms": int((time.time() - start) * 1000)}
+                    }
+                    send_to_arbiter(result)
+                    print(f"🔷 L2+DeFi: {mt5_result['direction']} | Score={mt5_result['ecosystem_score']} (MT5)")
+                    return result
+
+    # Fallback
+    analysis = analyze_ecosystem()
+    latency = int((time.time() - start) * 1000)
+
+    result = {
+        "space": "space_20_l2_defi_pulse",
+        "timestamp": int(time.time()),
+        "symbol": SYMBOL,
+        "signal": {
+            "direction": analysis['direction'],
+            "confidence": analysis['confidence']
+        },
+        "ecosystem_analysis": {
+            "score": analysis['ecosystem_score'],
+            "signals": analysis['signals'],
+            "metrics": analysis['metrics']
+        },
+        "data_source": "DeFiLlama",
+        "meta": {"latency_ms": latency}
+    }
+
+    send_to_arbiter(result)
+    print(f"🔷 L2+DeFi v1: {analysis['direction']} | Score={analysis['ecosystem_score']} | L2 TVL=${analysis['metrics']['l2'].get('total_l2_tvl_billions', 0)}B")
+    return result
+
+# ================= KEEP-ALIVE =================
+def keep_alive():
+    while True:
+        time.sleep(840)
+        try:
+            requests.get("http://localhost:7860/health", timeout=5)
+        except:
+            pass
+
+threading.Thread(target=keep_alive, daemon=True).start()
+
+# ================= FASTAPI =================
+app = FastAPI(title="TOMIRIS SPACE 20 v1.0 — ETHEREUM L2 & DEFI PULSE")
+
+@app.get("/health")
+@app.head("/health")
+async def health():
+    return {
+        "space": "Space 20 - Ethereum L2 & DeFi Pulse v1.0",
+        "status": "operational",
+        "symbol": SYMBOL,
+        "l2_chains": list(L2_CHAINS.keys()),
+        "features": ["L2 TVL", "Ethereum TVL", "Staking", "DEX Volumes", "Ultrasound Money", "Developer Activity"]
+    }
+
+@app.get("/consilium")
+async def consilium():
+    return get_ecosystem_signal()
+
+@app.get("/l2")
+async def l2_status():
+    return fetch_all_l2_tvl()
+
+@app.get("/tvl")
+async def tvl():
+    return fetch_ethereum_tvl()
+
+@app.get("/staking")
+async def staking():
+    return fetch_staking_metrics()
+
+@app.get("/dex")
+async def dex():
+    return fetch_dex_volumes()
+
+@app.get("/ultrasound")
+async def ultrasound():
+    return fetch_ultrasound_money()
+
+@app.get("/developers")
+async def developers():
+    return fetch_developer_activity()
+
+@app.get("/full")
+async def full_analysis():
+    return analyze_ecosystem()
+
+@app.post("/features")
+async def receive_features(data: Dict[str, Any]):
+    symbol = data.get("symbol", SYMBOL)
+    FEATURES_STORE[symbol] = {
+        "features": data.get("features", {}),
+        "price": data.get("price", 0.0),
+        "timestamp": time.time()
+    }
+    print(f"📥 MT5 {symbol}: {len(data.get('features', {}))} признаков")
+    return {"status": "ok"}
+
+print(f"🚀 SPACE 20 v1.0 — ETHEREUM L2 & DEFI PULSE ЗАПУЩЕН!")
+print(f"🔷 Мониторинг: Arbitrum, Optimism, Base, Polygon ZkEVM | DEX | Staking | Ultrasound")
+print(f"✅ Готов к бою!")