Spaces:

HilmanBey
/

hilmanhosting

Sleeping

App Files Files Community

HilmanBey commited on 5 days ago

Commit

95e544d

verified ·

1 Parent(s): de49f0b

Update main.py

Browse files

Files changed (1) hide show

main.py +97 -252

main.py CHANGED Viewed

@@ -2,18 +2,18 @@ import os
 import requests
 import sqlite3
 from fastapi import FastAPI, Header, HTTPException, Request
-from fastapi.responses import HTMLResponse, JSONResponse
 from pydantic import BaseModel
 from duckduckgo_search import DDGS
-app = FastAPI(title="HilmanAI Cloud Proxy Gateway")
-# --- ÇEVRE DEĞİŞKENLERİ ---
-MY_SECRET_KEY = os.getenv("MY_SECRET_KEY", "sk-hilman-cloud-proxy-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():
@@ -45,7 +45,7 @@ def save_message(role, content):
     except Exception as e:
         print(f"DB Kayıt Hatası: {e}")
-# --- İNTERNET ARAMA MOTORU (DuckDuckGo) ---
 def web_search(query: str) -> str:
     try:
         print(f"[İNTERNET ARAMASI]: '{query}' aranıyor...")
@@ -63,278 +63,123 @@ def web_search(query: str) -> str:
         return f"Arama sırasında hata oluştu: {e}"
 class ChatRequest(BaseModel):
-    provider: str = "antigravity"
-    model: str = "gemini-2.0-flash"
     messages: list
-# --- GÖNDERDİĞİN EKRANIN BİREBİR HTML/CSS KODU ---
-HTML_DASHBOARD = """
-<!DOCTYPE html>
-<html lang="tr">
-<head>
-    <meta charset="UTF-8">
-    <title>HilmanAI - Hizmet Yapılandırması (Cloud VDS)</title>
-    <style>
-        body { background-color: #0B0F17; color: #F3F4F6; font-family: 'Segoe UI', Tahoma, Geneva, Verdana, sans-serif; margin: 0; padding: 40px; display: flex; justify-content: center; }
-        .container { width: 100%; max-width: 900px; background: #111827; border: 1px solid #1F2937; border-radius: 16px; padding: 30px; box-shadow: 0 20px 40px rgba(0,0,0,0.8); }
-        .header { display: flex; justify-content: space-between; align-items: center; border-bottom: 1px solid #1F2937; padding-bottom: 20px; margin-bottom: 25px; flex-wrap: wrap; gap: 15px; }
-        .title-area { display: flex; align-items: center; gap: 10px; font-size: 18px; font-weight: bold; color: #F3F4F6; }
-        .status-badge { background: rgba(34, 197, 94, 0.1); color: #22C55E; padding: 6px 14px; border-radius: 20px; font-size: 13px; font-weight: bold; display: flex; align-items: center; gap: 8px; border: 1px solid rgba(34, 197, 94, 0.2); }
-        .stop-btn { background: #DC2626; color: white; border: none; padding: 10px 18px; border-radius: 8px; font-weight: bold; cursor: pointer; display: flex; align-items: center; gap: 6px; transition: 0.2s; }
-        .stop-btn:hover { background: #B91C1C; }
-        .grid-2 { display: grid; grid-template-columns: 1fr 1fr; gap: 20px; margin-bottom: 20px; }
-        @media (max-width: 600px) { .grid-2 { grid-template-columns: 1fr; } }
-        .section { background: #0D131F; border: 1px solid #1F2937; border-radius: 12px; padding: 18px; margin-bottom: 20px; }
-        label { display: block; color: #9CA3AF; font-size: 11px; font-weight: bold; margin-bottom: 8px; text-transform: uppercase; letter-spacing: 0.5px; }
-        input, select { width: 100%; padding: 12px; background: #111827; border: 1px solid #1F2937; color: #F3F4F6; border-radius: 8px; box-sizing: border-box; font-size: 14px; outline: none; }
-        input:focus { border-color: #3B82F6; }
-        .footer-note { color: #6B7280; font-size: 11px; margin-top: 6px; }
-        .warning-text { color: #F59E0B; font-size: 11px; margin-top: 6px; }
-        .input-group { display: flex; gap: 8px; }
-        .icon-btn { background: #1F2937; border: none; color: #F3F4F6; padding: 0 14px; border-radius: 8px; cursor: pointer; transition: 0.2s; font-size: 14px; }
-        .icon-btn:hover { background: #374151; }
-        .toggle-row { display: flex; justify-content: space-between; align-items: center; }
-        .switch { position: relative; display: inline-block; width: 44px; height: 24px; }
-        .switch input { opacity: 0; width: 0; height: 0; }
-        .slider { position: absolute; cursor: pointer; top: 0; left: 0; right: 0; bottom: 0; background-color: #374151; transition: .3s; border-radius: 24px; }
-        .slider:before { position: absolute; content: ""; height: 18px; width: 18px; left: 3px; bottom: 3px; background-color: white; transition: .3s; border-radius: 50%; }
-        input:checked + .slider { background-color: #2563EB; }
-        input:checked + .slider:before { transform: translateX(20px); }
-    </style>
-</head>
-<body>
-    <div class="container">
-        <div class="header">
-            <div class="title-area">
-                ⚙️ Hizmet Yapılandırması
-            </div>
-            <div class="status-badge">
-                ● Hizmet Çalışıyor (7/24 Bulut Aktif)
-            </div>
-            <button class="stop-btn" onclick="alert('Bulut sunucu 7/24 kesintisiz çalışmaktadır, Halil!')">
-                ⛔ Hizmeti Durdur
-            </button>
-        </div>
-        <div class="grid-2">
-            <div class="section" style="margin-bottom:0;">
-                <label>Dinleme Portu ⓘ</label>
-                <input type="text" value="7860 (Hugging Face Cloud)" readonly>
-                <div class="footer-note">Bulut sunucu varsayılan portu aktif.</div>
-            </div>
-            <div class="section" style="margin-bottom:0;">
-                <label>İstek Zaman Aşımı ⓘ</label>
-                <input type="text" value="120" readonly>
-                <div class="footer-note">Varsayılan 120s, aralık 30-7200s.</div>
-            </div>
-        </div>
-        <div class="grid-2" style="margin-top: 20px;">
-            <div class="section" style="margin-bottom:0;">
-                <div class="toggle-row">
-                    <div>
-                        <label style="margin-bottom:0;">LAN Erişimine İzin Ver ⓘ</label>
-                        <div class="footer-note">Bulut ortamında dış ağa açık.</div>
-                    </div>
-                    <label class="switch">
-                        <input type="checkbox" checked disabled>
-                        <span class="slider"></span>
-                    </label>
-                </div>
-            </div>
-            <div class="section" style="margin-bottom:0;">
-                <div class="toggle-row">
-                    <div>
-                        <label style="margin-bottom:0;">Yetkilendirme ⓘ</label>
-                        <div class="footer-note">Bearer Token koruması aktif.</div>
-                    </div>
-                    <label class="switch">
-                        <input type="checkbox" checked disabled>
-                        <span class="slider"></span>
-                    </label>
-                </div>
-                <div style="margin-top: 10px;">
-                    <select disabled>
-                        <option>Otomatik (Önerilen)</option>
-                    </select>
-                </div>
-            </div>
-        </div>
-        <div class="section" style="margin-top: 20px;">
-            <label>API Anahtarı (Secret Key) ⓘ</label>
-            <div class="input-group">
-                <input type="password" id="apiKey" value="%SECRET_KEY%" readonly>
-                <button class="icon-btn" onclick="togglePass()" title="Göster/Gizle">👁️</button>
-                <button class="icon-btn" onclick="copyKey()" title="Kopyala">📋</button>
-            </div>
-            <div class="warning-text">Not: API anahtarınızı güvende tutun. Paylaşmayın, Halil.</div>
-        </div>
-        <div class="section" style="margin-top: 20px;">
-            <label>Web UI Yönetici Parolası ⓘ</label>
-            <div class="input-group">
-                <input type="text" value="(API Anahtarı ile aynı)" readonly>
-                <button class="icon-btn" onclick="alert('API Anahtarınız ile korunmaktadır.')" title="Düzenle">✏️</button>
-                <button class="icon-btn" onclick="copyAdminKey()" title="Kopyala">📋</button>
-            </div>
-            <div class="footer-note">İpucu: Bulut dağıtım senaryolarında API anahtarınız güvenlik için esastır.</div>
-        </div>
-        <div class="section" style="margin-top: 20px; margin-bottom: 0;">
-            <div class="toggle-row">
-                <div>
-                    <label style="margin-bottom:0;">User-Agent Override ⓘ</label>
-                    <div class="footer-note">Proxy yönlendirmesi için optimize edilmiştir.</div>
-                </div>
-                <label class="switch">
-                    <input type="checkbox" checked disabled>
-                    <span class="slider"></span>
-                </label>
-            </div>
-        </div>
-    </div>
-    <script>
-        function togglePass() {
-            var x = document.getElementById("apiKey");
-            x.type = x.type === "password" ? "text" : "password";
-        }
-        function copyKey() {
-            var x = document.getElementById("apiKey");
-            navigator.clipboard.writeText(x.value);
-            alert("API Anahtarı panoya kopyalandı Halil!");
-        }
-        function copyAdminKey() {
-            var x = document.getElementById("apiKey");
-            navigator.clipboard.writeText(x.value);
-            alert("Yönetici Parolası panoya kopyalandı Halil!");
         }
-    </script>
-</body>
-</html>
-"""
-# --- ROUTE'LAR ---
-@app.get("/", response_class=HTMLResponse)
-def serve_dashboard():
-    return HTML_DASHBOARD.replace("%SECRET_KEY%", MY_SECRET_KEY)
 @app.get("/server-status")
 def server_status():
-    return {"status": "Active", "mode": "Cloud VDS Proxy Gateway"}
-# --- ORTAK YAPAY ZEKA VE ARAMA ENTEGRASYONU ---
-def call_ai_backend(messages_list):
-    last_user_msg = ""
-    for m in reversed(messages_list):
-        if isinstance(m, dict) and m.get("role") == "user":
-            last_user_msg = m.get("content", "")
-            break
     search_keywords = ["bul", "ara", "fiyat", "en ucuz", "nerede", "satın al", "karşılaştır", "incele"]
     search_context = ""
     if any(kw in last_user_msg.lower() for kw in search_keywords):
         search_results = web_search(last_user_msg)
-        search_context = f"\n\n[CANLI İNTERNET ARAMA SONUÇLARI]:\n{search_results}\nYukarıdaki güncel internet verilerini kullanarak Halil'e net, fiyatlı, site isimli ve kargo süreleriyle ilgili detaylı bir liste sun."
-    compressed_messages = messages_list[-4:] if len(messages_list) > 4 else messages_list
     system_instruction = {
         "role": "system",
         "content": (
             "Sen HilmanAI'sın. Kullanıcıya her zaman 'Halil' diye hitap edeceksin. "
             "İşletim sistemi WINDOWS'tur. "
-            "ÖNEMLİ KURAL 1: Halil internetten ürün, fiyat veya araştırma istediğinde, sana sağlanan [CANLI İNTERNET ARAMA SONUÇLARI]'nı incele. "
-            "ÖNEMLİ KURAL 2: Ürün arama isteklerinde şu formatta detaylı bir liste sun:\n"
-            "- **Ürün Adı ve Markası**\n- **Site Adı** (Hangi e-ticaret sitesinde olduğu)\n- **Fiyat**\n- **Yorumlar / Güvenilirlik**\n- **Kargo / Gönderim Süresi**\n- **Ürün Linki**\n"
-            "ÖNEMLİ KURAL 3: Matematiksel hesaplamalarda veya bilgi isteklerinde ASLA komut çalıştırma. "
-            "ÖNEMLİ KURAL 4: Yalnızca Halil doğrudan bir uygulama/site açmanı veya sistem işlemi yapmanı isterse Windows CMD/PowerShell komut bloğu üret."
         )
     }
-    full_messages = [system_instruction] + compressed_messages
     if search_context and len(full_messages) > 1:
-        full_messages[-1]["content"] += search_context
-    # --- 1. ANTIGRAVITY ---
     if ANTIGRAVITY_API_KEY:
-        ag_headers = {
-            "Authorization": f"Bearer {ANTIGRAVITY_API_KEY.strip()}",
-            "Content-Type": "application/json"
-        }
-        ag_payload = {
-            "model": "gemini-2.0-flash",
-            "messages": full_messages,
-            "temperature": 0.2
-        }
         try:
-            print("[SİSTEM]: Antigravity API deneniyor...")
-            ag_res = requests.post("https://api.antigravity.dev/v1/chat/completions", json=ag_payload, headers=ag_headers, timeout=12)
-            if ag_res.status_code == 200:
-                print("[BAŞARILI]: Antigravity yanıt verdi!")
-                data = ag_res.json()
-                return data["choices"][0]["message"]["content"]
         except Exception as e:
-            print(f"[ANTIGRAVITY YANIT VERMEDİ]: {e}")
-    # --- 2. OPENROUTER ---
     if OPENROUTER_API_KEY:
-        or_headers = {
-            "Authorization": f"Bearer {OPENROUTER_API_KEY.strip()}",
-            "Content-Type": "application/json",
-            "HTTP-Referer": "https://huggingface.co",
-            "X-Title": "HilmanAI"
-        }
-        or_models = [
-            "google/gemini-2.0-flash-lite-001",
-            "meta-llama/llama-3.3-70b-instruct",
-            "deepseek/deepseek-r1-distill-llama-70b"
-        ]
-        for m in or_models:
-            try:
-                print(f"[SİSTEM]: OpenRouter ({m}) deneniyor...")
-                or_res = requests.post(
-                    "https://openrouter.ai/api/v1/chat/completions",
-                    json={"model": m, "messages": full_messages, "temperature": 0.2},
-                    headers=or_headers,
-                    timeout=12
-                )
-                if or_res.status_code == 200:
-                    print(f"[BAŞARILI]: OpenRouter ({m}) yanıt verdi!")
-                    data = or_res.json()
-                    return data["choices"][0]["message"]["content"]
-            except Exception:
-                continue
-    return "Tüm yapay zeka servisleri şu an meşgul veya internet araması yapılamadı, Halil."
-# --- ASIL PROXY ENDPOINT ---
-@app.post("/v1/chat/completions")
-def chat_proxy(req: ChatRequest, authorization: str = Header(None)):
-    if not authorization or authorization != f"Bearer {MY_SECRET_KEY}":
-        raise HTTPException(status_code=401, detail="Yetkisiz erişim! Geçersiz Secret Key.")
-    for m in req.messages:
-        if isinstance(m, dict) and "role" in m and "content" in m:
-            save_message(m["role"], m["content"])
-    ai_response_text = call_ai_backend(req.messages)
-    save_message("assistant", ai_response_text)
-    return {
-        "choices": [
-            {
-                "message": {
-                    "role": "assistant",
-                    "content": ai_response_text
-                }
             }
-        ]
-    }

 import requests
 import sqlite3
 from fastapi import FastAPI, Header, HTTPException, Request
+from fastapi.responses import JSONResponse
 from pydantic import BaseModel
 from duckduckgo_search import DDGS
+app = FastAPI(title="HilmanAI Real Cloud Proxy Gateway")
+# --- ÇEVRE DEĞİŞKENLERİ (Hugging Face Secrets'tan çekilir) ---
+MY_SECRET_KEY = os.getenv("MY_SECRET_KEY", "sk-hilman-proxy-2026")
 OPENROUTER_API_KEY = os.getenv("OPENROUTER_API_KEY")
 ANTIGRAVITY_API_KEY = os.getenv("ANTIGRAVITY_API_KEY")
+# --- VERİTABANI (İstek Logları ve Hafıza) ---
 DB_PATH = "hilman_space_memory.db"
 def init_db():
     except Exception as e:
         print(f"DB Kayıt Hatası: {e}")
+# --- İNTERNET ARAMA MOTORU ---
 def web_search(query: str) -> str:
     try:
         print(f"[İNTERNET ARAMASI]: '{query}' aranıyor...")
         return f"Arama sırasında hata oluştu: {e}"
 class ChatRequest(BaseModel):
+    model: str = "google/gemini-2.0-flash-lite-001"
     messages: list
+    temperature: float = 0.2
+# --- SUNUCU SAĞLIK VE DURUM KONTROLÜ ---
+@app.get("/")
+def root():
+    return {
+        "status": "online",
+        "message": "HilmanAI Cloud Proxy is active and running 24/7, Halil.",
+        "endpoints": {
+            "chat_completions": "/v1/chat/completions",
+            "status": "/server-status"
         }
+    }
 @app.get("/server-status")
 def server_status():
+    return {
+        "service": "Running",
+        "port": 7860,
+        "auth_enabled": True,
+        "providers_loaded": {
+            "openrouter": bool(OPENROUTER_API_KEY),
+            "antigravity": bool(ANTIGRAVITY_API_KEY)
+        }
+    }
+# --- GERÇEK PROXY İSTEK YÖNLENDİRİCİSİ ---
+@app.post("/v1/chat/completions")
+def proxy_chat_completions(req: ChatRequest, authorization: str = Header(None)):
+    # 1. Güvenlik ve Yetkilendirme Kontrolü
+    if not authorization or authorization != f"Bearer {MY_SECRET_KEY}":
+        raise HTTPException(status_code=401, detail="Yetkisiz erişim! Geçersiz Secret Key.")
+    # 2. Gelen Mesajları Veritabanına Kaydet
+    last_user_msg = ""
+    for m in req.messages:
+        if isinstance(m, dict):
+            role = m.get("role", "user")
+            content = m.get("content", "")
+            if role == "user":
+                last_user_msg = content
+            save_message(role, content)
+    # 3. Canlı İnternet Arama Tetikleyicisi
     search_keywords = ["bul", "ara", "fiyat", "en ucuz", "nerede", "satın al", "karşılaştır", "incele"]
     search_context = ""
     if any(kw in last_user_msg.lower() for kw in search_keywords):
         search_results = web_search(last_user_msg)
+        search_context = f"\n\n[CANLI İNTERNET ARAMA SONUÇLARI]:\n{search_results}\nYukarıdaki güncel internet verilerini kullanarak Halil'e net, fiyatlı ve detaylı bilgi sun."
+    # Sistem Talimatı Ekleme
     system_instruction = {
         "role": "system",
         "content": (
             "Sen HilmanAI'sın. Kullanıcıya her zaman 'Halil' diye hitap edeceksin. "
             "İşletim sistemi WINDOWS'tur. "
+            "Halil internetten ürün, fiyat veya araştırma istediğinde sana sağlanan [CANLI İNTERNET ARAMA SONUÇLARI]'nı kullan."
         )
     }
+    full_messages = [system_instruction] + req.messages
     if search_context and len(full_messages) > 1:
+        if isinstance(full_messages[-1], dict):
+            full_messages[-1]["content"] += search_context
+    ai_response_text = "Tüm yapay zeka servisleri şu an yanıt vermiyor."
+    # 4. Antigravity API Üzerinden Proxy İsteği
     if ANTIGRAVITY_API_KEY:
         try:
+            headers = {
+                "Authorization": f"Bearer {ANTIGRAVITY_API_KEY.strip()}",
+                "Content-Type": "application/json"
+            }
+            payload = {
+                "model": "gemini-2.0-flash",
+                "messages": full_messages,
+                "temperature": req.temperature
+            }
+            res = requests.post("https://api.antigravity.dev/v1/chat/completions", json=payload, headers=headers, timeout=15)
+            if res.status_code == 200:
+                data = res.json()
+                ai_response_text = data["choices"][0]["message"]["content"]
+                save_message("assistant", ai_response_text)
+                return res.json()
         except Exception as e:
+            print(f"Antigravity Proxy Hatası: {e}")
+    # 5. OpenRouter API Üzerinden Proxy İsteği (Yedek)
     if OPENROUTER_API_KEY:
+        try:
+            headers = {
+                "Authorization": f"Bearer {OPENROUTER_API_KEY.strip()}",
+                "Content-Type": "application/json",
+                "HTTP-Referer": "https://huggingface.co",
+                "X-Title": "HilmanAI"
             }
+            fallback_models = [
+                req.model,
+                "google/gemini-2.0-flash-lite-001",
+                "meta-llama/llama-3.3-70b-instruct"
+            ]
+            for model_name in fallback_models:
+                payload = {
+                    "model": model_name,
+                    "messages": full_messages,
+                    "temperature": req.temperature
+                }
+                res = requests.post("https://openrouter.ai/api/v1/chat/completions", json=payload, headers=headers, timeout=15)
+                if res.status_code == 200:
+                    data = res.json()
+                    ai_response_text = data["choices"][0]["message"]["content"]
+                    save_message("assistant", ai_response_text)
+                    return res.json()
+        except Exception as e:
+            print(f"OpenRouter Proxy Hatası: {e}")
+    raise HTTPException(status_code=500, detail="Hiçbir AI Sağlayıcısından yanıt alınamadı.")