Update main.py

main.py

@@ -1,5 +1,7 @@
 import os
 import requests
+import sqlite3
+import gradio as gr
 from fastapi import FastAPI, Header, HTTPException
 from pydantic import BaseModel
 
@@ -9,21 +11,65 @@ MY_SECRET_KEY = os.getenv("MY_SECRET_KEY", "hilman-secret-2026")
 OPENROUTER_API_KEY = os.getenv("OPENROUTER_API_KEY")
 ANTIGRAVITY_API_KEY = os.getenv("ANTIGRAVITY_API_KEY")
 
+# --- VERİTABANI VE KALICI HAFIZA ---
+DB_PATH = "hilman_space_memory.db"
+
+def init_db():
+    try:
+        conn = sqlite3.connect(DB_PATH)
+        cursor = conn.cursor()
+        cursor.execute("""
+            CREATE TABLE IF NOT EXISTS messages (
+                id INTEGER PRIMARY KEY AUTOINCREMENT,
+                role TEXT,
+                content TEXT,
+                timestamp DATETIME DEFAULT CURRENT_TIMESTAMP
+            )
+        """)
+        conn.commit()
+        conn.close()
+    except Exception as e:
+        print(f"DB Başlatma Hatası: {e}")
+
+init_db()
+
+def save_message(role, content):
+    try:
+        conn = sqlite3.connect(DB_PATH)
+        cursor = conn.cursor()
+        cursor.execute("INSERT INTO messages (role, content) VALUES (?, ?)", (role, content))
+        conn.commit()
+        conn.close()
+    except Exception as e:
+        print(f"DB Kayıt Hatası: {e}")
+
+def get_chat_history():
+    try:
+        conn = sqlite3.connect(DB_PATH)
+        cursor = conn.cursor()
+        cursor.execute("SELECT role, content FROM messages ORDER BY id ASC")
+        rows = cursor.fetchall()
+        conn.close()
+        
+        history = []
+        for role, content in rows:
+            history.append({"role": role, "content": content})
+        return history
+    except Exception:
+        return []
+
 class ChatRequest(BaseModel):
     provider: str = "antigravity"
     model: str = "gemini-2.0-flash"
     messages: list
 
-@app.get("/")
+@app.get("/status")
 def status():
     return {"status": "HilmanAI Core Online", "system": "7/24 Active"}
 
-@app.post("/v1/chat/completions")
-def chat_proxy(req: ChatRequest, authorization: str = Header(None)):
-    if authorization != f"Bearer {MY_SECRET_KEY}":
-        raise HTTPException(status_code=401, detail="Yetkisiz erişim!")
-
-    compressed_messages = req.messages[-4:] if len(req.messages) > 4 else req.messages
+# --- ORTAK YAPAY ZEKA ÇALIŞTIRICI (API & Web Arayüzü İçin) ---
+def call_ai_backend(messages_list):
+    compressed_messages = messages_list[-4:] if len(messages_list) > 4 else messages_list
 
     system_instruction = {
         "role": "system",
@@ -38,7 +84,7 @@ def chat_proxy(req: ChatRequest, authorization: str = Header(None)):
 
     full_messages = [system_instruction] + compressed_messages
 
-    # --- 1. ANTIGRAVITY DENEMESİ (MAX 4 SANİYE BEKLE) ---
+    # --- 1. ANTIGRAVITY DENEMESİ ---
     if ANTIGRAVITY_API_KEY:
         ag_headers = {
             "Authorization": f"Bearer {ANTIGRAVITY_API_KEY.strip()}",
@@ -54,13 +100,12 @@ def chat_proxy(req: ChatRequest, authorization: str = Header(None)):
             ag_res = requests.post("https://api.antigravity.dev/v1/chat/completions", json=ag_payload, headers=ag_headers, timeout=4)
             if ag_res.status_code == 200:
                 print("[BAŞARILI]: Antigravity yanıt verdi!")
-                return ag_res.json()
-            else:
-                print(f"[ANTIGRAVITY ATLANDI]: HTTP {ag_res.status_code}")
+                data = ag_res.json()
+                return data["choices"][0]["message"]["content"]
         except Exception as e:
-            print(f"[ANTIGRAVITY YANIT VERMEDİ - GEÇİLİYOR]: {e}")
+            print(f"[ANTIGRAVITY YANIT VERMEDİ]: {e}")
 
-    # --- 2. OPENROUTER DÜŞME ALANI (IŞIK HIZINDA YEDEK) ---
+    # --- 2. OPENROUTER YEDEK ---
     if OPENROUTER_API_KEY:
         or_headers = {
             "Authorization": f"Bearer {OPENROUTER_API_KEY.strip()}",
@@ -85,11 +130,77 @@ def chat_proxy(req: ChatRequest, authorization: str = Header(None)):
                 )
                 if or_res.status_code == 200:
                     print(f"[BAŞARILI]: OpenRouter ({m}) yanıt verdi!")
-                    return or_res.json()
-                else:
-                    print(f"[OPENROUTER MODEL HATASI]: {m} -> {or_res.status_code}")
-            except Exception as e:
-                print(f"[OPENROUTER MODEL ZAMANAŞIMI]: {m} -> {e}")
+                    data = or_res.json()
+                    return data["choices"][0]["message"]["content"]
+            except Exception:
                 continue
 
-    raise HTTPException(status_code=503, detail="Tüm yapay zeka servisleri meşgul veya ulaşılamıyor.")
+    return "Tüm yapay zeka servisleri şu an meşgul, Hilman."
+
+# --- API ENDPOINT ---
+@app.post("/v1/chat/completions")
+def chat_proxy(req: ChatRequest, authorization: str = Header(None)):
+    if authorization != f"Bearer {MY_SECRET_KEY}":
+        raise HTTPException(status_code=401, detail="Yetkisiz erişim!")
+
+    # Gelen mesajları veritabanına kaydet
+    for m in req.messages:
+        if isinstance(m, dict) and "role" in m and "content" in m:
+            save_message(m["role"], m["content"])
+
+    # Yapay zekadan yanıt al
+    ai_response_text = call_ai_backend(req.messages)
+
+    # Asistan yanıtını kaydet
+    save_message("assistant", ai_response_text)
+
+    # OpenAI formatında yanıt dön
+    return {
+        "choices": [
+            {
+                "message": {
+                    "role": "assistant",
+                    "content": ai_response_text
+                }
+            }
+        ]
+    }
+
+# --- GRADIO WEB ARAYÜZÜ ---
+def gradio_predict(message, history):
+    if not message.strip():
+        return ""
+    
+    # Kullanıcı mesajını kaydet
+    save_message("user", message)
+    
+    # Geçmişi veritabanından al ve yapay zekaya gönder
+    current_history = get_chat_history()
+    response_text = call_ai_backend(current_history)
+    
+    # Asistan yanıtını kaydet
+    save_message("assistant", response_text)
+    
+    return response_text
+
+with gr.Blocks(theme=gr.themes.Dark()) as demo:
+    gr.Markdown("# ⚡ HILMAN AI - Cloud Jarvis Core")
+    gr.Markdown("7/24 Aktif, SQLite Veritabanı Destekli Güvenli Bulut Paneli")
+    
+    gr.ChatInterface(
+        fn=gradio_predict,
+        title="",
+        description="HilmanAI Güvenli Web Arayüzü",
+        textbox=gr.Textbox(placeholder="Komutunuzu girin Hilman...", container=False, scale=7),
+        submit_btn="GÖNDER",
+        chatbot=gr.Chatbot(height=550, value=get_chat_history(), type="messages")
+    )
+
+# Gradio Arayüzünü FastAPI'ye şifre korumasıyla (Giriş Ekranı) bağla
+app = gr.mount_gradio_app(
+    app, 
+    demo, 
+    path="/", 
+    auth=("patron", "hilman2026"),
+    auth_message="HILMAN AI Güvenli Giriş Paneli - Kimlik Doğrulayın"
+)