Update app.py

app.py

@@ -1,8 +1,5 @@
 import os
-import time
-import requests
 import numpy as np
-import pandas as pd
 import gradio as gr
 import xgboost as xgb
 from groq import Groq
@@ -16,191 +13,44 @@ if api_key:
     client = Groq(api_key=api_key)
 
 # ==========================================
-# 📡 2. API İSTEK BAŞLIKLARI (Cloudflare engelini aşmak için)
+# 🤖 2. XGBOOST MODEL EĞİTİMİ (Sanal Veri)
 # ==========================================
-HEADERS = {
-    "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 "
-                  "(KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36",
-    "Accept": "application/json",
-    "Accept-Language": "en-US,en;q=0.9",
-}
+def train_dummy_model():
+    """API olmadan çalışabilmesi için sanal veriyle hızlı eğitim."""
+    np.random.seed(42)
+    n = 300
+    # Sanal BTC verisi (gerçekçi aralıkta)
+    ma5 = np.random.uniform(55000, 75000, n)
+    ma20 = ma5 + np.random.normal(0, 500, n)
+    rsi = np.random.uniform(20, 80, n)
+    macd = np.random.normal(0, 200, n)
+    vol = np.random.uniform(100, 1000, n)
+
+    X = np.column_stack([ma5, ma20, rsi, macd, vol])
+    # Hedef: MA5 > MA20 ve RSI < 70 ise yukarı eğilim (sanal mantık)
+    y = ((ma5 > ma20) & (rsi < 70)).astype(int)
 
-OKX_BASE = "https://www.okx.com/api/v5"
-BINANCE_BASE = "https://api.binance.com/api/v3"
-
-# ==========================================
-# 📡 3. VERİ ÇEKME FONKSİYONLARI (Retry + Fallback)
-# ==========================================
-def fetch_okx_ticker(inst_id="BTC-USDT"):
-    """OKX'ten anlık fiyat çeker. 3 kez dener."""
-    for attempt in range(3):
-        try:
-            r = requests.get(f"{OKX_BASE}/market/ticker",
-                             params={"instId": inst_id},
-                             headers=HEADERS, timeout=15)
-            r.raise_for_status()
-            d = r.json()["data"][0]
-            return {
-                "source": "OKX",
-                "last": float(d["last"]),
-                "open24h": float(d["open24h"]),
-                "high24h": float(d["high24h"]),
-                "low24h": float(d["low24h"]),
-                "vol24h": float(d["vol24h"]),
-                "change_pct": (float(d["last"]) / float(d["open24h"]) - 1) * 100
-            }
-        except Exception as e:
-            print(f"OKX ticker attempt {attempt+1} failed: {e}")
-            if attempt < 2:
-                time.sleep(2)
-    return None
-
-
-def fetch_binance_ticker(symbol="BTCUSDT"):
-    """OKX başarısız olursa Binance'ten fiyat çeker (yedek)."""
-    try:
-        r = requests.get(f"{BINANCE_BASE}/ticker/24hr",
-                         params={"symbol": symbol},
-                         headers=HEADERS, timeout=15)
-        r.raise_for_status()
-        d = r.json()
-        return {
-            "source": "Binance",
-            "last": float(d["lastPrice"]),
-            "open24h": float(d["openPrice"]),
-            "high24h": float(d["highPrice"]),
-            "low24h": float(d["lowPrice"]),
-            "vol24h": float(d["volume"]),
-            "change_pct": float(d["priceChangePercent"])
-        }
-    except Exception as e:
-        print(f"Binance ticker failed: {e}")
-        return None
-
-
-def fetch_okx_candles(inst_id="BTC-USDT", bar="1H", limit=100):
-    """OKX'ten mum verisi çeker."""
-    for attempt in range(3):
-        try:
-            r = requests.get(f"{OKX_BASE}/market/candles",
-                             params={"instId": inst_id, "bar": bar, "limit": limit},
-                             headers=HEADERS, timeout=15)
-            r.raise_for_status()
-            raw = r.json()["data"]
-            df = pd.DataFrame(raw, columns=["ts", "open", "high", "low", "close", "vol"])
-            for col in ["open", "high", "low", "close", "vol"]:
-                df[col] = df[col].astype(float)
-            df["ts"] = pd.to_datetime(df["ts"].astype(int), unit="ms")
-            df = df.sort_values("ts").reset_index(drop=True)
-            return df
-        except Exception as e:
-            print(f"OKX candles attempt {attempt+1} failed: {e}")
-            if attempt < 2:
-                time.sleep(2)
-    return None
-
-
-def fetch_binance_candles(symbol="BTCUSDT", interval="1h", limit=100):
-    """OKX başarısız olursa Binance'ten mum verisi çeker."""
-    try:
-        r = requests.get(f"{BINANCE_BASE}/klines",
-                         params={"symbol": symbol, "interval": interval, "limit": limit},
-                         headers=HEADERS, timeout=15)
-        r.raise_for_status()
-        raw = r.json()
-        df = pd.DataFrame(raw, columns=[
-            "ts", "open", "high", "low", "close", "vol",
-            "close_time", "quote_vol", "trades", "buy_base", "buy_quote", "ignore"
-        ])
-        for col in ["open", "high", "low", "close", "vol"]:
-            df[col] = df[col].astype(float)
-        df["ts"] = pd.to_datetime(df["ts"].astype(int), unit="ms")
-        return df[["ts", "open", "high", "low", "close", "vol"]]
-    except Exception as e:
-        print(f"Binance candles failed: {e}")
-        return None
-
-
-def fetch_market_data():
-    """Önce OKX'i dener, başarısız olursa Binance'e geçer."""
-    ticker = fetch_okx_ticker()
-    candles = fetch_okx_candles()
-
-    if ticker is not None and candles is not None:
-        return ticker, candles
-
-    print("OKX failed, switching to Binance fallback...")
-    ticker = fetch_binance_ticker()
-    candles = fetch_binance_candles()
-    return ticker, candles
-
-
-def compute_rsi(series, period=14):
-    delta = series.diff()
-    gain = delta.clip(lower=0).rolling(period).mean()
-    loss = -delta.clip(upper=0).rolling(period).mean()
-    rs = gain / loss
-    return 100 - (100 / (1 + rs))
-
-# ==========================================
-# 🤖 4. XGBOOST MODEL EĞİTİMİ
-# ==========================================
-def train_model():
-    """Çekilen mum verisiyle XGBoost modelini eğitir."""
-    df = fetch_okx_candles(limit=500)
-    if df is None:
-        df = fetch_binance_candles(limit=500)
-
-    if df is None or len(df) < 50:
-        return None
-
-    df["ma_5"] = df["close"].rolling(5).mean()
-    df["ma_20"] = df["close"].rolling(20).mean()
-    df["rsi"] = compute_rsi(df["close"], 14)
-    df["macd"] = df["close"].ewm(span=12).mean() - df["close"].ewm(span=26).mean()
-    df["target"] = (df["close"].shift(-1) > df["close"]).astype(int)
-    df = df.dropna().reset_index(drop=True)
-
-    features = ["ma_5", "ma_20", "rsi", "macd", "vol"]
     model = xgb.XGBClassifier(
         n_estimators=50, max_depth=3, learning_rate=0.1,
         objective="binary:logistic", eval_metric="logloss", random_state=42
     )
-    model.fit(df[features], df["target"])
+    model.fit(X, y)
     return model
 
-
-# Uygulama başlarken modeli eğit
-xgb_model = train_model()
-if xgb_model is None:
-    # Fallback: API hiç çalışmazsa dummy model
-    xgb_model = xgb.XGBClassifier(n_estimators=10, max_depth=2)
-    xgb_model.fit(np.random.rand(20, 5), np.random.randint(0, 2, 20))
+xgb_model = train_dummy_model()
 
 # ==========================================
-# 🧠 5. ANALİZ MOTORU
+# 🧠 3. ANALİZ MOTORU (Manuel Giriş)
 # ==========================================
-def predict_and_analyze():
-    ticker, candles = fetch_market_data()
-
-    if ticker is None or candles is None:
-        return "❌ Hem OKX hem de Binance API'sine erişilemedi. Lütfen daha sonra tekrar deneyin.", {}
-
-    last_price = ticker["last"]
-    change_pct = ticker["change_pct"]
-    vol24h = ticker["vol24h"]
-    source = ticker["source"]
-
-    close = candles["close"]
-    ma5 = close.rolling(5).mean().iloc[-1]
-    ma20 = close.rolling(20).mean().iloc[-1]
-    rsi = compute_rsi(close, 14).iloc[-1]
-    macd = (close.ewm(span=12).mean() - close.ewm(span=26).mean()).iloc[-1]
+def predict_and_analyze(last_price, rsi, ma5, ma20, macd, vol):
+    if not last_price or last_price <= 0:
+        return "Lütfen geçerli bir BTC/USD fiyatı giriniz.", {}
 
     # XGBoost tahmini
-    features = np.array([[ma5, ma20, rsi, macd, vol24h]])
+    features = np.array([[ma5, ma20, rsi, macd, vol]])
     prob_up = float(xgb_model.predict_proba(features)[0][1])
     prob_down = 1 - prob_up
+
     direction = "YUKARI 📈" if prob_up > 0.5 else "AŞAĞI 📉"
     confidence = max(prob_up, prob_down) * 100
 
@@ -212,16 +62,12 @@ def predict_and_analyze():
     prompt = f"""
     Sen uzman bir kripto para analisti ve teknik analiz uzmanısın.
 
-    📡 Canlı Veri Kaynağı: {source} (BTC/USDT)
+    📊 BTC/USD Piyasa Verileri (Manuel Giriş):
     - Son Fiyat: ${last_price:,.2f}
-    - 24s Değişim: %{change_pct:+.2f}
-    - 24s Hacim: {vol24h:,.0f} BTC
-    - 24s Yüksek/Düşük: ${ticker['high24h']:,.2f} / ${ticker['low24h']:,.2f}
-
-    📊 Teknik Göstergeler (1H):
     - RSI (14): {rsi:.2f}
     - MA5: ${ma5:,.2f} | MA20: ${ma20:,.2f}
     - MACD: {macd:.4f}
+    - Hacim: {vol:,.2f}
 
     🤖 XGBoost Model Sonucu:
     - Yükseliş Olasılığı: %{prob_up*100:.1f}
@@ -230,7 +76,7 @@ def predict_and_analyze():
 
     Türkçe bir teknik analiz raporu hazırla. Şu başlıklar bulunsun:
     1. 🎯 Model Yorumu (XGBoost + teknik göstergelerin mantığı)
-    2. 📈 Teknik Analiz (RSI, MA, MACD; destek/direnç)
+    2. 📈 Teknik Analiz (RSI, MA, MACD; destek/direnç seviyeleri)
     3. 💡 İşlem Stratejisi (Long/Short, stop-loss, take-profit, risk yönetimi)
 
     Yatırım tavsiyesi olmadığını vurgula. Rasyonel ve profesyonel ol.
@@ -251,43 +97,54 @@ def predict_and_analyze():
         analysis_result = "GROQ_API_KEY bulunamadı! Hugging Face Secrets'a ekleyin."
 
     header = (
-        f"**Kaynak: {source}** | **Canlı: ${last_price:,.2f}** (%{change_pct:+.2f}) | "
+        f"**Manuel Veri** | **Fiyat: ${last_price:,.2f}** | "
         f"RSI: {rsi:.1f} | MA5: ${ma5:,.0f} | MA20: ${ma20:,.0f}\n\n---\n\n"
     )
     return header + analysis_result, prob_dict
 
 # ==========================================
-# 🎨 6. GRADIO ARAYÜZÜ
+# 🎨 4. GRADIO ARAYÜZÜ
 # ==========================================
 with gr.Blocks(theme=gr.themes.Soft(primary_hue="orange", secondary_hue="slate")) as demo:
     gr.Markdown(
         """
-        # ₿ BTC/USD XGBoost & Groq AI Tahmin Radarı (Canlı)
-        Veriler **OKX halka açık API**'sinden çekilir; OKX'e erişilemezse otomatik olarak **Binance**'e geçilir. **XGBoost** yön tahmini yapar, **Groq** analiz raporu üretir.
+        # ₿ BTC/USD XGBoost & Groq AI Tahmin Radarı (Manuel Giriş)
+        API erişim sorunları nedeniyle verileri **manuel** giriyorsunuz. **XGBoost** yön tahmini yapar, **Groq** analiz raporu üretir.
         """
     )
 
     with gr.Row():
         with gr.Column():
-            analyze_btn = gr.Button("🔄 Canlı Veri Çek ve Analiz Et", variant="primary", size="lg")
-            gr.Markdown(
-                "**Not**: API rate limit nedeniyle butona çok hızlı basmayın."
-            )
+            gr.Markdown("### 📊 Piyasa Verileri")
+            price_input = gr.Number(label="Güncel BTC/USD Fiyatı ($)", value=65000.0)
+            vol_input = gr.Number(label="24s Hacim (BTC)", value=500.0)
+
+            gr.Markdown("### 📈 Teknik Göstergeler")
+            rsi_input = gr.Slider(label="RSI (14)", minimum=0, maximum=100, value=55.0, step=0.1)
+            with gr.Row():
+                ma5_input = gr.Number(label="MA5 ($)", value=64800.0)
+                ma20_input = gr.Number(label="MA20 ($)", value=64000.0)
+            macd_input = gr.Number(label="MACD Değeri", value=150.0)
+
+            submit_btn = gr.Button("Analiz Et ve Tahmin Üret", variant="primary")
 
         with gr.Column():
-            prob_output = gr.Label(label="XGBoost Yön Tahmini")
-            analysis_output = gr.Markdown(value="Butona basarak canlı veri çekip analizi başlatın.")
+            gr.Markdown("### 📈 XGBoost Yön Tahmini")
+            prob_output = gr.Label(label="Olasılık Dağılımı")
+
+            gr.Markdown("### 🧠 Groq Yapay Zeka Analiz Raporu")
+            analysis_output = gr.Markdown(value="Verileri girdikten sonra butona basarak analizi başlatabilirsiniz.")
 
-    analyze_btn.click(
+    submit_btn.click(
         fn=predict_and_analyze,
-        inputs=[],
+        inputs=[price_input, rsi_input, ma5_input, ma20_input, macd_input, vol_input],
         outputs=[analysis_output, prob_output]
     )
 
     gr.Markdown(
         """
         ---
-        ⚠️ **Yatırım Tavsiyesi Değildir**: Bu uygulama eğitim amaçlıdır. Kripto paralar yüksek risk içerir.
+        ⚠️ **Yatırım Tavsiyesi Değildir**: Bu uygulama eğitim amaçlıdır.
         """
     )