Update app.py

app.py

@@ -18,64 +18,65 @@ if api_key:
     client = Groq(api_key=api_key)
 
 # ==========================================
-# 📡 2. MEXC PUBLIC API
+# 📡 2. OKX PUBLIC API (openapi alan adı)
 # ==========================================
-MEXC_BASE = "https://api.mexc.com"
+# HF'de www.okx.com engellenmiş olabilir; openapi.okx.com küresel REST alan adıdır
+OKX_BASE = "https://openapi.okx.com"
 
-# Akamai WAF'ın Python varsayılan UA'sını engellemesini aşmak için
-MEXC_HEADERS = {
+# Cloudflare istemci imzası engellemesini aşmak için tarayıcı benzeri başlıklar
+OKX_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 fetch_mexc_ticker(symbol="BTCUSDT"):
-    """MEXC spot son fiyat. 3 kez dener."""
+def fetch_okx_ticker(inst_id="BTC-USDT"):
+    """OKX anlık fiyat. 3 kez dener."""
     for attempt in range(3):
         try:
             r = requests.get(
-                f"{MEXC_BASE}/api/v3/ticker/24hr",
-                params={"symbol": symbol},
-                headers=MEXC_HEADERS,
+                f"{OKX_BASE}/api/v5/market/ticker",
+                params={"instId": inst_id},
+                headers=OKX_HEADERS,
                 timeout=15
             )
             r.raise_for_status()
-            d = r.json()
+            d = r.json()["data"][0]
             return {
-                "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"]),
+                "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"MEXC ticker attempt {attempt+1} failed: {e}")
+            print(f"OKX ticker attempt {attempt+1} failed: {e}")
             if attempt < 2:
                 time.sleep(2)
     return None
 
-def fetch_mexc_klines(symbol="BTCUSDT", interval="1h", limit=100):
-    """MEXC spot K-line. 3 kez dener."""
+def fetch_okx_candles(inst_id="BTC-USDT", bar="1H", limit=100):
+    """OKX mum verisi. 3 kez dener."""
     for attempt in range(3):
         try:
             r = requests.get(
-                f"{MEXC_BASE}/api/v3/klines",
-                params={"symbol": symbol, "interval": interval, "limit": limit},
-                headers=MEXC_HEADERS,
+                f"{OKX_BASE}/api/v5/market/candles",
+                params={"instId": inst_id, "bar": bar, "limit": limit},
+                headers=OKX_HEADERS,
                 timeout=15
             )
             r.raise_for_status()
-            raw = r.json()
-            cols = ["ts","open","high","low","close","vol","close_time","qvol","trades","tb","tq","ignore"]
-            df = pd.DataFrame(raw, columns=cols)
-            for c in ["open","high","low","close","vol"]:
-                df[c] = df[c].astype(float)
+            raw = r.json()["data"]
+            # OKX formatı: [ts, open, high, low, close, vol, ...]
+            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")
-            return df[["ts","open","high","low","close","vol"]].sort_values("ts").reset_index(drop=True)
+            return df.sort_values("ts").reset_index(drop=True)
         except Exception as e:
-            print(f"MEXC klines attempt {attempt+1} failed: {e}")
+            print(f"OKX candles attempt {attempt+1} failed: {e}")
             if attempt < 2:
                 time.sleep(2)
     return None
@@ -90,9 +91,9 @@ def compute_rsi(series, period=14):
     rs = gain / loss
     return 100 - (100 / (1 + rs))
 
-def train_models_from_mexc():
-    """MEXC'ten çekilen mum verisiyle XGBoost ve KNN eğitir."""
-    df = fetch_mexc_klines(limit=500)
+def train_models_from_okx():
+    """OKX mum verisiyle XGBoost ve KNN eğitir."""
+    df = fetch_okx_candles(limit=500)
     if df is None or len(df) < 50:
         return None, None, None, None
 
@@ -123,11 +124,11 @@ def train_models_from_mexc():
 
     return xgb_model, knn_model, scaler, features
 
-# Başlangıçta modelleri MEXC verisiyle eğit
-xgb_model, knn_model, scaler, feature_cols = train_models_from_mexc()
+# Başlangıçta modelleri OKX verisiyle eğit
+xgb_model, knn_model, scaler, feature_cols = train_models_from_okx()
 
 if xgb_model is None:
-    print("MEXC erişilemedi, dummy modeller kullanılıyor.")
+    print("OKX erişilemedi, dummy modeller kullan��lıyor.")
     dummy_X = np.random.rand(50, 5)
     dummy_y = np.random.randint(0, 2, 50)
     xgb_model = xgb.XGBClassifier(n_estimators=10, max_depth=2)
@@ -135,17 +136,17 @@ if xgb_model is None:
     scaler = StandardScaler()
     knn_model = KNeighborsClassifier(n_neighbors=5)
     knn_model.fit(scaler.fit_transform(dummy_X), dummy_y)
-    feature_cols = ["ma_5","ma_20","rsi","macd","vol"]
+    feature_cols = ["ma_5", "ma_20", "rsi", "macd", "vol"]
 
 # ==========================================
 # 🧠 4. ANALİZ MOTORU (XGB + KNN Ensemble)
 # ==========================================
 def predict_and_analyze():
-    ticker = fetch_mexc_ticker()
-    candles = fetch_mexc_klines(limit=30)
+    ticker = fetch_okx_ticker()
+    candles = fetch_okx_candles(limit=30)
 
     if ticker is None or candles is None:
-        return "❌ MEXC API'sine erişilemedi (Akamai WAF veya Hugging Face ağ kısıtlaması). Lütfen sonra tekrar deneyin.", {}
+        return "❌ OKX API'sine erişilemedi (openapi alan adı + tarayıcı UA denendi). Lütfen sonra tekrar deneyin.", {}
 
     last_price = ticker["last"]
     change_pct = ticker["change_pct"]
@@ -176,7 +177,7 @@ def predict_and_analyze():
     prompt = f"""
     Sen uzman bir kripto para analisti ve teknik analiz uzmanısın.
 
-    📡 MEXC Canlı Verileri (BTC/USDT):
+    📡 OKX Canlı Verileri (BTC/USDT):
     - Son Fiyat: ${last_price:,.2f}
     - 24s Değişim: %{change_pct:+.2f}
     - 24s Hacim: {vol24h:,.0f} BTC
@@ -216,7 +217,7 @@ def predict_and_analyze():
         analysis_result = "GROQ_API_KEY bulunamadı! Hugging Face Secrets'a ekleyin."
 
     header = (
-        f"**MEXC Canlı: ${last_price:,.2f}** (%{change_pct:+.2f}) | RSI: {rsi:.1f} | "
+        f"**OKX Canlı: ${last_price:,.2f}** (%{change_pct:+.2f}) | RSI: {rsi:.1f} | "
         f"MA5: ${ma5:,.0f} | MA20: ${ma20:,.0f}\n\n"
         f"**XGB:** %{xgb_prob_up*100:.1f} | **KNN:** %{knn_prob_up*100:.1f} | "
         f"**Ensemble:** %{ensemble_prob_up*100:.1f}\n\n---\n\n"
@@ -229,17 +230,17 @@ def predict_and_analyze():
 with gr.Blocks(theme=gr.themes.Soft(primary_hue="orange", secondary_hue="slate")) as demo:
     gr.Markdown(
         """
-        # ₿ BTC/USD XGBoost + KNN & Groq AI Tahmin Radarı (MEXC Canlı)
-        Fiyat ve mum verileri **MEXC halka açık API**'sinden otomatik çekilir. **XGBoost + KNN** ensemble tahmini yapar, **Groq** analiz raporu üretir.
+        # ₿ BTC/USD XGBoost + KNN & Groq AI Tahmin Radarı (OKX Canlı)
+        Fiyat ve mum verileri **OKX halka açık API**'sinden (`openapi.okx.com`) otomatik çekilir. **XGBoost + KNN** ensemble tahmini yapar, **Groq** analiz raporu üretir.
         """
     )
     with gr.Row():
         with gr.Column():
-            analyze_btn = gr.Button("🔄 MEXC'ten Veri Çek ve Analiz Et", variant="primary", size="lg")
-            gr.Markdown("**Not**: MEXC API'si Akamai WAF koruması altındadır; kod tarayıcı UA ve 3 deneme içerir.")
+            analyze_btn = gr.Button("🔄 OKX'ten Veri Çek ve Analiz Et", variant="primary", size="lg")
+            gr.Markdown("**Not**: `openapi.okx.com` + tarayıcı UA + 3 deneme kullanılıyor.")
         with gr.Column():
             prob_output = gr.Label(label="Model Tahminleri (XGB + KNN)")
-            analysis_output = gr.Markdown(value="Butona basarak MEXC'ten canlı veri çekip analizi başlatın.")
+            analysis_output = gr.Markdown(value="Butona basarak OKX'ten canlı veri çekip analizi başlatın.")
     analyze_btn.click(fn=predict_and_analyze, inputs=[], outputs=[analysis_output, prob_output])
     gr.Markdown("---\n⚠️ **Yatırım Tavsiyesi Değildir**: Bu uygulama eğitim amaçlıdır.")