Create app.py

app.py

@@ -0,0 +1,540 @@
+# ============================================
+# АВТО-УСТАНОВКА ПАКЕТОВ
+# ============================================
+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 21 v1.0 — GOLD MACRO & FLOW ANALYZER
+# ============================================
+# Специализируется на золоте: ETF-потоки (GLD/IAU/GDX),
+# COT-отчёты (Commitment of Traders), DXY, TIPS, GPR, потоки капитала.
+# Сигнализирует о притоке/оттоке "умных денег" в золото.
+# ============================================
+
+from fastapi import FastAPI, Query
+from typing import Optional, Dict, Any, List, Tuple
+import time
+import requests
+import threading
+import numpy as np
+import pandas as pd
+from datetime import datetime
+from collections import deque
+import warnings
+warnings.filterwarnings('ignore')
+
+# ================= КОНФИГУРАЦИЯ =================
+SYMBOL: str = "XAU/USD"
+
+# ETF тикеры для отслеживания
+GOLD_ETFS: Dict[str, str] = {
+    "GLD": "GLD",      # SPDR Gold Trust (крупнейший)
+    "IAU": "IAU",      # iShares Gold Trust
+    "GDX": "GDX",      # Gold Miners ETF
+    "GDXJ": "GDXJ"     # Junior Gold Miners
+}
+
+SPACE_18_ARBITER: str = "https://tomiris-ai-name6-6.hf.space"
+
+# API ключи
+TWELVE_KEYS: List[str] = [
+    "f33e660d8c1945d19e3c4ded72a2875e",
+    "03737d2862224ac6a10ed601d053cce5"
+]
+FRED_KEYS: List[str] = ["faa11c8e2e4beee08c5b966e8b63a513"]
+
+CACHE: Dict[str, Dict[str, Any]] = {}
+CACHE_TIMES: Dict[str, float] = {}
+FEATURES_STORE: Dict[str, Dict[str, Any]] = {}
+MT5_MAX_AGE_SEC: int = 300
+
+twelve_counter: int = 0
+fred_counter: int = 0
+api_lock = threading.Lock()
+
+def get_next_twelve_key() -> str:
+    global twelve_counter
+    with api_lock:
+        key = TWELVE_KEYS[twelve_counter % len(TWELVE_KEYS)]
+        twelve_counter += 1
+        return key
+
+def get_next_fred_key() -> str:
+    global fred_counter
+    with api_lock:
+        key = FRED_KEYS[fred_counter % len(FRED_KEYS)]
+        fred_counter += 1
+        return key
+
+def send_to_arbiter(signal_data: Dict[str, Any]) -> None:
+    try:
+        requests.post(
+            f"{SPACE_18_ARBITER}/log_signal",
+            json={'space': 'space_21_gold_macro', 'symbol': SYMBOL, 'signal': signal_data.get('signal', {})},
+            timeout=5
+        )
+    except:
+        pass
+
+# ================= FRED ДАННЫЕ =================
+def fetch_fred_series(series_id: str, days: int = 30) -> List[Dict[str, Any]]:
+    cache_key = f"fred_{series_id}_{days}"
+    if cache_key in CACHE and time.time() - CACHE_TIMES.get(cache_key, 0) < 3600:
+        return CACHE[cache_key]
+
+    try:
+        key = get_next_fred_key()
+        url = f"https://api.stlouisfed.org/fred/series/observations?series_id={series_id}&api_key={key}&file_type=json&sort_order=desc&limit={days}"
+        r = requests.get(url, timeout=10)
+        if r.status_code == 200:
+            data = r.json()
+            values = [
+                {'date': obs['date'], 'value': float(obs['value'])}
+                for obs in data.get('observations', []) if obs['value'] != '.'
+            ]
+            CACHE[cache_key] = values
+            CACHE_TIMES[cache_key] = time.time()
+            return values
+    except:
+        pass
+    return []
+
+def fetch_dxy() -> Dict[str, Any]:
+    """Индекс доллара DXY."""
+    values = fetch_fred_series("DTWEXBGS", 30)
+    if len(values) >= 2:
+        current = values[0]['value']
+        month_ago = values[-1]['value']
+        change = ((current - month_ago) / month_ago) * 100
+        return {
+            'dxy': round(current, 2),
+            'change_1m': round(change, 2),
+            'trend': 'STRENGTHENING' if change > 2 else 'WEAKENING' if change < -2 else 'STABLE',
+            'gold_signal': 'BEARISH' if change > 2 else 'BULLISH' if change < -2 else 'NEUTRAL'
+        }
+    return {'dxy': 104.5, 'trend': 'STABLE', 'gold_signal': 'NEUTRAL'}
+
+def fetch_tips_yield() -> Dict[str, Any]:
+    """Реальная доходность TIPS (Treasury Inflation-Protected Securities)."""
+    values = fetch_fred_series("DFII10", 30)
+    if values:
+        current = values[0]['value']
+        return {
+            'tips_yield': round(current, 4),
+            'gold_signal': 'BULLISH' if current < 0 else 'BEARISH',
+            'analysis': 'Отрицательная реальная доходность = золото растёт' if current < 0 else 'Положительная доходность = давление на золото'
+        }
+    return {'tips_yield': 0.5, 'gold_signal': 'NEUTRAL'}
+
+# ================= ETF ПОТОКИ =================
+def fetch_etf_data(ticker: str) -> Optional[Dict[str, Any]]:
+    cache_key = f"etf_{ticker}"
+    if cache_key in CACHE and time.time() - CACHE_TIMES.get(cache_key, 0) < 900:
+        return CACHE[cache_key]
+
+    try:
+        key = get_next_twelve_key()
+        url = f"https://api.twelvedata.com/quote?symbol={ticker}&apikey={key}"
+        r = requests.get(url, timeout=10)
+        if r.status_code == 200:
+            data = r.json()
+            result = {
+                'ticker': ticker,
+                'price': float(data.get('close', 0)),
+                'change_pct': float(data.get('change_percent', 0)),
+                'volume': int(data.get('volume', 0)),
+                'signal': 'INFLOW' if float(data.get('change_percent', 0)) > 0 else 'OUTFLOW'
+            }
+            CACHE[cache_key] = result
+            CACHE_TIMES[cache_key] = time.time()
+            return result
+    except:
+        pass
+    return None
+
+def analyze_etf_flows() -> Dict[str, Any]:
+    etf_data: Dict[str, Any] = {}
+    inflow_count = 0
+    outflow_count = 0
+
+    for name, ticker in GOLD_ETFS.items():
+        data = fetch_etf_data(ticker)
+        if data:
+            etf_data[name] = data
+            if data['signal'] == 'INFLOW':
+                inflow_count += 1
+            else:
+                outflow_count += 1
+        else:
+            etf_data[name] = {"error": "no_data"}
+
+    total = inflow_count + outflow_count
+    inflow_pct = (inflow_count / total * 100) if total > 0 else 50
+
+    if inflow_pct >= 75:
+        signal = "STRONG_INFLOW"
+        gold_signal = "BULLISH"
+    elif inflow_pct >= 50:
+        signal = "MODERATE_INFLOW"
+        gold_signal = "SLIGHTLY_BULLISH"
+    elif inflow_pct >= 25:
+        signal = "MODERATE_OUTFLOW"
+        gold_signal = "SLIGHTLY_BEARISH"
+    else:
+        signal = "STRONG_OUTFLOW"
+        gold_signal = "BEARISH"
+
+    return {
+        'etfs': etf_data,
+        'inflow_count': inflow_count,
+        'outflow_count': outflow_count,
+        'inflow_pct': round(inflow_pct, 1),
+        'flow_signal': signal,
+        'gold_signal': gold_signal
+    }
+
+# ================= COT REPORT =================
+def fetch_cot_report() -> Dict[str, Any]:
+    cache_key = "cot_gold"
+    if cache_key in CACHE and time.time() - CACHE_TIMES.get(cache_key, 0) < 86400:
+        return CACHE[cache_key]
+
+    try:
+        url = "https://raw.githubusercontent.com/datasets/cftc-commitment-of-traders/main/data/gold.csv"
+        df = pd.read_csv(url)
+        if not df.empty:
+            latest = df.iloc[-1]
+            comm_long = latest.get('Commercial_Long', 0)
+            comm_short = latest.get('Commercial_Short', 0)
+            noncomm_long = latest.get('Noncommercial_Long', 0)
+            noncomm_short = latest.get('Noncommercial_Short', 0)
+
+            comm_net = comm_long - comm_short
+            noncomm_net = noncomm_long - noncomm_short
+
+            # Спекулянты в лонг + хеджеры сокращают шорт = бычий сигнал
+            if noncomm_net > 0 and comm_net > 0:
+                cot_signal = "BULLISH"
+            elif noncomm_net < 0 and comm_net < 0:
+                cot_signal = "BEARISH"
+            else:
+                cot_signal = "MIXED"
+
+            result = {
+                'report_date': str(latest.get('Date', 'Unknown')),
+                'commercial_net': int(comm_net),
+                'noncommercial_net': int(noncomm_net),
+                'cot_signal': cot_signal,
+                'gold_signal': 'BULLISH' if cot_signal == 'BULLISH' else 'BEARISH' if cot_signal == 'BEARISH' else 'NEUTRAL'
+            }
+            CACHE[cache_key] = result
+            CACHE_TIMES[cache_key] = time.time()
+            return result
+    except:
+        pass
+
+    return {'cot_signal': 'NEUTRAL', 'gold_signal': 'NEUTRAL'}
+
+# ================= GPR (ГЕОПОЛИТИЧЕСКИЙ РИСК) =================
+def fetch_gpr() -> Dict[str, Any]:
+    """Геополитический риск — качественная оценка."""
+    try:
+        # Используем новости как прокси GPR
+        r = requests.get(
+            "https://newsapi.org/v2/everything?q=geopolitical+war+sanctions&pageSize=10&apiKey=948c7816beea47baa23b054592472d0e",
+            timeout=10
+        )
+        if r.status_code == 200:
+            total = r.json().get('totalResults', 0)
+            if total > 1000:
+                level = "HIGH"
+                gold_signal = "BULLISH"
+            elif total > 500:
+                level = "ELEVATED"
+                gold_signal = "SLIGHTLY_BULLISH"
+            else:
+                level = "LOW"
+                gold_signal = "NEUTRAL"
+
+            return {
+                'gpr_level': level,
+                'mentions_24h': total,
+                'gold_signal': gold_signal
+            }
+    except:
+        pass
+
+    return {'gpr_level': 'LOW', 'gold_signal': 'NEUTRAL'}
+
+# ================= ЦЕНТРАЛЬНЫЕ БАНКИ =================
+def fetch_central_bank_demand() -> Dict[str, Any]:
+    """Спрос на золото со стороны центробанков."""
+    try:
+        r = requests.get("https://api.coingecko.com/api/v3/coins/gold?community_data=true", timeout=10)
+        if r.status_code == 200:
+            data = r.json()
+            community = data.get('community_data', {})
+            # Используем упоминания как прокси интереса
+            mentions = community.get('twitter_followers', 0)
+            return {
+                'interest_level': 'HIGH' if mentions > 100000 else 'MODERATE',
+                'gold_signal': 'BULLISH'
+            }
+    except:
+        pass
+    return {'interest_level': 'MODERATE', 'gold_signal': 'NEUTRAL'}
+
+# ================= АНАЛИЗ ИЗ MT5 =================
+def analyze_from_mt5(mt5_features: Dict[str, Any]) -> Optional[Dict[str, Any]]:
+    try:
+        score = 50.0
+
+        rsi = mt5_features.get('H1_rsi', 50)
+        if isinstance(rsi, (int, float)):
+            if rsi > 70:
+                score -= 10
+            elif rsi < 30:
+                score += 10
+
+        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),
+            "macro_score": score,
+            "source": "MT5"
+        }
+    except:
+        return None
+
+# ================= ГЛАВНЫЙ АНАЛИЗ =================
+def analyze_gold_macro() -> Dict[str, Any]:
+    dxy = fetch_dxy()
+    tips = fetch_tips_yield()
+    etf = analyze_etf_flows()
+    cot = fetch_cot_report()
+    gpr = fetch_gpr()
+    central_bank = fetch_central_bank_demand()
+
+    signals = []
+    score = 50.0
+
+    # DXY
+    if dxy.get('gold_signal') == 'BULLISH':
+        signals.append({"factor": "DXY", "signal": "BULLISH", "reason": "Доллар слабеет"})
+        score += 10
+    elif dxy.get('gold_signal') == 'BEARISH':
+        signals.append({"factor": "DXY", "signal": "BEARISH", "reason": "Доллар укрепляется"})
+        score -= 10
+
+    # TIPS
+    if tips.get('gold_signal') == 'BULLISH':
+        signals.append({"factor": "TIPS", "signal": "BULLISH", "reason": "Отрицательная реальная доходность"})
+        score += 15
+    elif tips.get('gold_signal') == 'BEARISH':
+        signals.append({"factor": "TIPS", "signal": "BEARISH", "reason": "Положительная реальная доходность"})
+        score -= 10
+
+    # ETF
+    if etf.get('gold_signal') == 'BULLISH' or etf.get('gold_signal') == 'SLIGHTLY_BULLISH':
+        signals.append({"factor": "ETF", "signal": "BULLISH", "reason": f"Приток в ETF ({etf.get('inflow_pct', 0)}% в плюсе)"})
+        score += 15
+    elif etf.get('gold_signal') == 'BEARISH' or etf.get('gold_signal') == 'SLIGHTLY_BEARISH':
+        signals.append({"factor": "ETF", "signal": "BEARISH", "reason": f"Отток из ETF"})
+        score -= 15
+
+    # COT
+    if cot.get('gold_signal') == 'BULLISH':
+        signals.append({"factor": "COT", "signal": "BULLISH", "reason": "Крупные игроки в лонг"})
+        score += 12
+    elif cot.get('gold_signal') == 'BEARISH':
+        signals.append({"factor": "COT", "signal": "BEARISH", "reason": "Крупные игроки в шорт"})
+        score -= 12
+
+    # GPR
+    if gpr.get('gold_signal') == 'BULLISH':
+        signals.append({"factor": "GPR", "signal": "BULLISH", "reason": f"Геополитический риск: {gpr.get('gpr_level')}"})
+        score += 10
+
+    # Центробанки
+    if central_bank.get('gold_signal') == 'BULLISH':
+        signals.append({"factor": "CENTRAL_BANKS", "signal": "BULLISH", "reason": "Спрос центробанков"})
+        score += 5
+
+    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 {
+        "macro_score": score,
+        "direction": direction,
+        "confidence": round(confidence, 4),
+        "signals": signals,
+        "metrics": {
+            "dxy": dxy,
+            "tips": tips,
+            "etf_flows": etf,
+            "cot_report": cot,
+            "geopolitical_risk": gpr,
+            "central_bank_demand": central_bank
+        }
+    }
+
+# ================= ГЛАВНЫЙ СИГНАЛ =================
+def get_gold_macro_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_21_gold_macro",
+                        "timestamp": int(time.time()),
+                        "symbol": SYMBOL,
+                        "signal": {
+                            "direction": mt5_result["direction"],
+                            "confidence": mt5_result["confidence"]
+                        },
+                        "macro_analysis": {
+                            "score": mt5_result["macro_score"],
+                            "signals": [{"factor": "MT5", "signal": mt5_result["direction"], "reason": "Технический анализ"}]
+                        },
+                        "data_source": "MT5",
+                        "meta": {"latency_ms": int((time.time() - start) * 1000)}
+                    }
+                    send_to_arbiter(result)
+                    print(f"🥇 GOLD MACRO: {mt5_result['direction']} | Score={mt5_result['macro_score']} (MT5)")
+                    return result
+
+    # Fallback
+    analysis = analyze_gold_macro()
+    latency = int((time.time() - start) * 1000)
+
+    result = {
+        "space": "space_21_gold_macro",
+        "timestamp": int(time.time()),
+        "symbol": SYMBOL,
+        "signal": {
+            "direction": analysis['direction'],
+            "confidence": analysis['confidence']
+        },
+        "macro_analysis": {
+            "score": analysis['macro_score'],
+            "signals": analysis['signals'],
+            "metrics": analysis['metrics']
+        },
+        "data_source": "FRED+ETF+COT",
+        "meta": {"latency_ms": latency}
+    }
+
+    send_to_arbiter(result)
+    print(f"🥇 GOLD MACRO v1: {analysis['direction']} | Score={analysis['macro_score']} | ETF={analysis['metrics']['etf_flows'].get('flow_signal')} | COT={analysis['metrics']['cot_report'].get('cot_signal')}")
+    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 21 v1.0 — GOLD MACRO & FLOW ANALYZER")
+
+@app.get("/health")
+@app.head("/health")
+async def health():
+    return {
+        "space": "Space 21 - Gold Macro & Flow Analyzer v1.0",
+        "status": "operational",
+        "symbol": SYMBOL,
+        "features": ["DXY", "TIPS Yield", "ETF Flows", "COT Report", "GPR", "Central Bank Demand"]
+    }
+
+@app.get("/consilium")
+async def consilium():
+    return get_gold_macro_signal()
+
+@app.get("/dxy")
+async def dxy():
+    return fetch_dxy()
+
+@app.get("/tips")
+async def tips():
+    return fetch_tips_yield()
+
+@app.get("/etf")
+async def etf():
+    return analyze_etf_flows()
+
+@app.get("/cot")
+async def cot():
+    return fetch_cot_report()
+
+@app.get("/gpr")
+async def gpr():
+    return fetch_gpr()
+
+@app.get("/full")
+async def full():
+    return analyze_gold_macro()
+
+@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 21 v1.0 — GOLD MACRO & FLOW ANALYZER ЗАПУЩЕН!")
+print(f"🥇 Анализ: DXY | TIPS | ETF GLD/IAU/GDX | COT | GPR | Центробанки")
+print(f"✅ Готов к бою!")