Update app.py

app.py

@@ -1,181 +1,389 @@
 
-# app.py
-# OKX BTC-USDT Historical Data Downloader
-# Gradio + OKX Public API + CSV
-
+import os
 import time
+import tempfile
 import requests
 import pandas as pd
 import gradio as gr
-import tempfile
-import os
+
 from datetime import datetime, timedelta, timezone
+from groq import Groq
 
-API_URL = "https://www.okx.com/api/v5/market/history-candles"
+# =====================================
+# CONFIG
+# =====================================
 
-TIMEFRAMES = [
-    "1m", "3m", "5m", "15m", "30m",
-    "1H", "2H", "4H", "6H", "12H", "1D"
-]
+OKX_URL = "https://www.okx.com/api/v5/market/history-candles"
 
-def download_data(days, timeframe, symbol, progress=gr.Progress()):
+GROQ_API_KEY = os.getenv("GROQ_API_KEY")
 
-    try:
-        days = int(days)
-        symbol = symbol.strip().upper()
+GROQ_MODEL = os.getenv(
+    "GROQ_MODEL",
+    "llama-3.3-70b-versatile"
+)
 
-        if not symbol:
-            raise ValueError("Trading pair boş olamaz.")
+# =====================================
+# OKX DATA ENGINE
+# =====================================
 
-        end_time = datetime.now(timezone.utc)
-        start_time = end_time - timedelta(days=days)
+def get_okx_data(days, timeframe, symbol, progress=gr.Progress()):
 
-        start_ms = int(start_time.timestamp() * 1000)
+    days = int(days)
+    symbol = symbol.strip().upper()
 
-        all_data = []
-        after = None
-        seen = set()
+    if not symbol:
+        raise ValueError("Trading pair gerekli.")
 
-        session = requests.Session()
+    end = datetime.now(timezone.utc)
+    start = end - timedelta(days=days)
 
-        while True:
+    start_ms = int(start.timestamp() * 1000)
+    end_ms = int(end.timestamp() * 1000)
 
-            params = {
-                "instId": symbol,
-                "bar": timeframe,
-                "limit": "300"
-            }
+    all_data = []
+    seen = set()
+    after = None
 
-            if after is not None:
-                params["after"] = str(after)
+    session = requests.Session()
 
-            response = session.get(
-                API_URL,
-                params=params,
-                timeout=30
-            )
+    while True:
 
-            response.raise_for_status()
-            result = response.json()
+        params = {
+            "instId": symbol,
+            "bar": timeframe,
+            "limit": "300"
+        }
 
-            if result.get("code") != "0":
-                raise RuntimeError(result.get("msg", "OKX API error"))
+        if after is not None:
+            params["after"] = str(after)
 
-            data = result.get("data", [])
+        response = session.get(
+            OKX_URL,
+            params=params,
+            timeout=30
+        )
 
-            if not data:
-                break
+        response.raise_for_status()
 
-            new_count = 0
+        result = response.json()
 
-            for candle in data:
-                timestamp = int(candle[0])
+        if result.get("code") != "0":
+            raise RuntimeError(result.get("msg", "OKX API error"))
 
-                if timestamp < start_ms:
-                    continue
+        data = result.get("data", [])
 
-                if timestamp not in seen:
-                    seen.add(timestamp)
-                    all_data.append(candle)
-                    new_count += 1
+        if not data:
+            break
 
-            oldest = min(int(x[0]) for x in data)
+        for candle in data:
 
-            progress(
-                min(0.99, max(0.01,
-                1 - (oldest - start_ms) /
-                max(1, int(end_time.timestamp() * 1000) - start_ms))),
-                desc=f"Veri çekiliyor: {len(all_data)} mum"
-            )
+            ts = int(candle[0])
 
-            if oldest <= start_ms:
-                break
+            if start_ms <= ts <= end_ms and ts not in seen:
+                seen.add(ts)
+                all_data.append(candle)
 
-            if new_count == 0 and after == oldest:
-                break
+        oldest = min(int(x[0]) for x in data)
 
-            after = oldest
+        progress(
+            min(
+                0.99,
+                max(
+                    0.01,
+                    1 - (oldest - start_ms) /
+                    max(1, end_ms - start_ms)
+                )
+            ),
+            desc=f"OKX verisi: {len(all_data)} mum"
+        )
 
-            time.sleep(0.12)
+        if oldest <= start_ms:
+            break
 
-        if not all_data:
-            raise ValueError("Veri bulunamadı.")
+        after = oldest
 
-        columns = [
-            "timestamp", "open", "high", "low", "close",
-            "volume", "volume_currency", "volume_quote",
-            "confirm"
-        ]
+        time.sleep(0.15)
+
+    if not all_data:
+        raise ValueError("OKX verisi bulunamadı.")
+
+    columns = [
+        "timestamp",
+        "open",
+        "high",
+        "low",
+        "close",
+        "volume",
+        "volume_currency",
+        "volume_quote",
+        "confirm"
+    ]
+
+    df = pd.DataFrame(all_data, columns=columns)
+
+    df["timestamp"] = pd.to_datetime(
+        df["timestamp"].astype("int64"),
+        unit="ms",
+        utc=True
+    )
+
+    numeric_columns = [
+        "open", "high", "low", "close",
+        "volume", "volume_currency", "volume_quote"
+    ]
+
+    for col in numeric_columns:
+        df[col] = pd.to_numeric(df[col])
+
+    df["confirm"] = pd.to_numeric(df["confirm"])
+
+    df = (
+        df.sort_values("timestamp")
+        .drop_duplicates("timestamp")
+        .reset_index(drop=True)
+    )
+
+    return df
+
+
+# =====================================
+# TECHNICAL INDICATORS
+# =====================================
+
+def add_indicators(df):
+
+    df = df.copy()
+
+    df["return_pct"] = df["close"].pct_change() * 100
+
+    df["EMA20"] = df["close"].ewm(
+        span=20, adjust=False
+    ).mean()
+
+    df["EMA50"] = df["close"].ewm(
+        span=50, adjust=False
+    ).mean()
+
+    delta = df["close"].diff()
+
+    gain = delta.clip(lower=0).ewm(
+        alpha=1/14, adjust=False
+    ).mean()
+
+    loss = (-delta.clip(upper=0)).ewm(
+        alpha=1/14, adjust=False
+    ).mean()
+
+    rs = gain / loss.replace(0, float("nan"))
 
-        df = pd.DataFrame(all_data, columns=columns)
+    df["RSI"] = 100 - (100 / (1 + rs))
 
-        df["timestamp"] = pd.to_datetime(
-            pd.to_numeric(df["timestamp"]),
-            unit="ms",
-            utc=True
+    previous_close = df["close"].shift(1)
+
+    tr = pd.concat(
+        [
+            df["high"] - df["low"],
+            (df["high"] - previous_close).abs(),
+            (df["low"] - previous_close).abs()
+        ],
+        axis=1
+    ).max(axis=1)
+
+    df["ATR"] = tr.ewm(
+        alpha=1/14, adjust=False
+    ).mean()
+
+    df["volume_sma"] = df["volume"].rolling(20).mean()
+
+    return df
+
+
+# =====================================
+# GROQ AI ENGINE
+# =====================================
+
+def groq_analysis(df):
+
+    if not GROQ_API_KEY:
+        raise ValueError(
+            "GROQ_API_KEY bulunamadı. "
+            "Hugging Face Spaces Secrets bölümüne ekle."
         )
 
-        numeric_columns = [
-            "open", "high", "low", "close",
-            "volume", "volume_currency", "volume_quote"
+    client = Groq(api_key=GROQ_API_KEY)
+
+    latest = df.tail(30).copy()
+
+    market_data = latest[
+        [
+            "timestamp",
+            "open",
+            "high",
+            "low",
+            "close",
+            "volume",
+            "return_pct",
+            "EMA20",
+            "EMA50",
+            "RSI",
+            "ATR"
         ]
+    ].round(4).to_string(index=False)
+
+    prompt = f"""
+BTC-USDT piyasa analizini yap.
+
+Aşağıdaki veriler OKX Public API üzerinden alınmıştır.
+
+VERİLER:
+{market_data}
+
+ANALİZ:
+
+1. Genel trend.
+2. EMA20 ve EMA50.
+3. RSI momentum.
+4. ATR volatilitesi.
+5. Hacim davranışı.
+6. Destek bölgeleri.
+7. Direnç bölgeleri.
+8. Bullish senaryo.
+9. Bearish senaryo.
+10. Neutral senaryo.
+11. Risk analizi.
+
+ÇIKTI:
+
+YÖN: BULLISH / BEARISH / NEUTRAL
+MODEL GÜVENİ: 0-100
+TREND:
+MOMENTUM:
+DESTEK:
+DİRENÇ:
+YÜKSELİŞ SENARYOSU:
+DÜŞÜŞ SENARYOSU:
+RİSK:
+NİHAİ ANALİZ:
+
+ÖNEMLİ:
+- Yalnızca verilen verileri kullan.
+- Olmayan fiyatları uydurma.
+- Güven puanının kalibre edilmiş olasılık olmadığını belirt.
+- Kesin kazanç veya yön garantisi verme.
+"""
+
+    response = client.chat.completions.create(
+        model=GROQ_MODEL,
+        messages=[
+            {
+                "role": "system",
+                "content": (
+                    "Sen profesyonel ve ihtiyatlı "
+                    "bir kripto piyasa analiz AI sistemisin."
+                )
+            },
+            {
+                "role": "user",
+                "content": prompt
+            }
+        ],
+        temperature=0.2,
+        max_completion_tokens=1800
+    )
+
+    return response.choices[0].message.content
+
+
+# =====================================
+# MAIN APPLICATION
+# =====================================
+
+def run_system(days, timeframe, symbol):
 
-        for col in numeric_columns:
-            df[col] = pd.to_numeric(df[col])
+    try:
+
+        df = get_okx_data(
+            days,
+            timeframe,
+            symbol
+        )
 
-        df["confirm"] = pd.to_numeric(df["confirm"])
+        df = add_indicators(df)
 
-        df = df.sort_values("timestamp")
-        df = df.drop_duplicates(subset=["timestamp"])
-        df = df.reset_index(drop=True)
+        analysis = groq_analysis(df)
 
         temp = tempfile.NamedTemporaryFile(
             suffix=".csv",
-            prefix="BTCUSD_OKX_",
+            prefix="OKX_BTC_",
             delete=False
         )
 
-        file_path = temp.name
+        csv_path = temp.name
         temp.close()
 
-        df.to_csv(file_path, index=False)
+        df.to_csv(csv_path, index=False)
+
+        last = df.iloc[-1]
 
-        summary = f"""
-### İndirme tamamlandı
+        info = f"""
+## MARKET DATA
 
-- Sembol: {symbol}
-- Zaman aralığı: {timeframe}
-- İstenen geçmiş: {days} gün
-- Toplam mum: {len(df)}
-- İlk tarih: {df['timestamp'].min()}
-- Son tarih: {df['timestamp'].max()}
-- CSV boyutu: {os.path.getsize(file_path) / 1024:.2f} KB
+- Symbol: {symbol}
+- Timeframe: {timeframe}
+- Candle count: {len(df)}
+- Last close: {last['close']:.2f}
+- RSI: {last['RSI']:.2f}
+- EMA20: {last['EMA20']:.2f}
+- EMA50: {last['EMA50']:.2f}
+- ATR: {last['ATR']:.2f}
 """
 
-        return file_path, summary, df.tail(20)
+        return (
+            info,
+            analysis,
+            csv_path,
+            df.tail(20)
+        )
 
     except Exception as e:
-        return None, f"Hata: {str(e)}", pd.DataFrame()
 
+        return (
+            f"ERROR: {str(e)}",
+            "",
+            None,
+            pd.DataFrame()
+        )
+
+
+# =====================================
+# GRADIO UI
+# =====================================
 
-with gr.Blocks(title="OKX BTCUSD Data Downloader") as demo:
+with gr.Blocks(
+    title="OKX Groq BTC AI"
+) as demo:
 
     gr.Markdown("""
-    # OKX BTC-USDT Data Downloader
+    # BTC-USDT AI ANALYSIS ENGINE
 
-    OKX Public API üzerinden geçmiş kripto para verilerini indir.
+    ### OKX Public API + Groq Llama
 
-    API Key gerekmez.
+    Historical Data | Technical Analysis | AI Report | CSV
     """)
 
     with gr.Row():
+
         symbol = gr.Textbox(
             label="Trading Pair",
             value="BTC-USDT"
         )
 
         timeframe = gr.Dropdown(
-            choices=TIMEFRAMES,
+            choices=[
+                "1m", "3m", "5m", "15m",
+                "30m", "1H", "2H", "4H",
+                "6H", "12H", "1D"
+            ],
             value="1H",
             label="Timeframe"
         )
@@ -185,37 +393,44 @@ with gr.Blocks(title="OKX BTCUSD Data Downloader") as demo:
             maximum=90,
             value=30,
             step=1,
-            label="Geçmiş Gün"
+            label="Historical Days"
         )
 
-    download_btn = gr.Button(
-        "BTC Verilerini İndir",
+    run = gr.Button(
+        "RUN GROQ BTC AI",
         variant="primary"
     )
 
-    output_file = gr.File(label="CSV Dosyası")
+    market_info = gr.Markdown()
 
-    status = gr.Markdown()
+    ai_output = gr.Markdown()
 
-    preview = gr.Dataframe(
-        label="Son 20 Mum",
-        interactive=False
+    csv_output = gr.File(
+        label="Download BTC CSV"
     )
 
-    download_btn.click(
-        fn=download_data,
-        inputs=[days, timeframe, symbol],
-        outputs=[output_file, status, preview]
+    data_preview = gr.Dataframe(
+        label="Market Data Preview",
+        interactive=False
     )
 
-    gr.Markdown("""
-    **Veri:** OKX Public Market API
-
-    **CSV sütunları:** Timestamp, Open, High, Low,
-    Close, Volume, Volume Currency, Volume Quote, Confirm.
+    run.click(
+        fn=run_system,
+        inputs=[
+            days,
+            timeframe,
+            symbol
+        ],
+        outputs=[
+            market_info,
+            ai_output,
+            csv_output,
+            data_preview
+        ]
+    )
 
-    Not: OKX BTC-USDT spot verisidir; BTC-USD ile aynı
-    işlem çifti değildir. USDT bazlı fiyat kullanır.
-    """)
 
-demo.queue().launch(server_name="0.0.0.0", server_port=7860)
+demo.queue().launch(
+    server_name="0.0.0.0",
+    server_port=7860
+)