Update app.py

app.py

@@ -1,21 +1,21 @@
 from fastapi import FastAPI, Request
 from fastapi.responses import JSONResponse
 from fastapi.middleware.cors import CORSMiddleware
+import json
 import os
-import requests
+import random
+from datetime import datetime, date
 
-# =========================
-# CONFIG
-# =========================
-HF_MODEL = "tiiuae/falcon-1b-instruct"
-HF_API_URL = "https://router.huggingface.co/hf-inference/models/" + HF_MODEL
-HF_TOKEN = os.getenv("HF_TOKEN")
-
-# =========================
-# FASTAPI
-# =========================
-app = FastAPI(title="ZenkaMind API")
+# =============================================================================
+# APP INIT
+# =============================================================================
+app = FastAPI(
+    title="ZenkaMind API",
+    version="1.0.0",
+    description="ZenkaMind AI Asistan API"
+)
 
+# CORS
 app.add_middleware(
     CORSMiddleware,
     allow_origins=["*"],
@@ -23,63 +23,274 @@ app.add_middleware(
     allow_headers=["*"],
 )
 
-@app.get("/")
-def root():
-    return {"status": "ZenkaMind API çalışıyor"}
-
-@app.post("/api/chat")
-async def chat(req: Request):
-    data = await req.json()
-    message = data.get("message", "").strip()
+# =============================================================================
+# CONFIG
+# =============================================================================
+DB_PATH = "users.json"
+FREE_DAILY_LIMIT = 30
+PREMIUM_PRICE = 499
+SHOPIER_LINK = "https://shopier.com/42153760"
 
-    if not message:
-        return {"response": "Mesaj boş olamaz."}
+# =============================================================================
+# DATABASE
+# =============================================================================
+def load_db():
+    """Veritabanını yükle"""
+    try:
+        if os.path.exists(DB_PATH):
+            with open(DB_PATH, "r", encoding="utf-8") as f:
+                return json.load(f)
+    except:
+        pass
+    return {}
 
-    if not HF_TOKEN:
-        return {"response": "HF_TOKEN tanımlı değil."}
+def save_db(data):
+    """Veritabanını kaydet"""
+    try:
+        with open(DB_PATH, "w", encoding="utf-8") as f:
+            json.dump(data, f, indent=2, ensure_ascii=False)
+    except:
+        pass
 
-    prompt = f"""Sen ZenkaMind'sin.
-Sadece Türkçe konuş.
-Kısa ve net cevap ver.
+# =============================================================================
+# AI RESPONSES
+# =============================================================================
+class AIResponder:
+    def __init__(self):
+        self.responses = {
+            "greeting": [
+                "Merhaba! Ben ZenkaMind AI. Size nasıl yardımcı olabilirim? 🤖",
+                "Hoş geldiniz! ZenkaMind AI asistanınız burada. 💫",
+                "Selam! Bugün sizin için nasıl faydalı olabilirim? ✨"
+            ],
+            "help": [
+                "Size yardımcı olmak için buradayım. Sorunuz nedir? 📝",
+                "Hangi konuda destek almak istiyorsunuz? 🔍",
+                "Sorunuzu anlatın, en iyi çözümü bulalım. 💡"
+            ],
+            "business": [
+                "Freelance işler için: Portföy oluşturun, net fiyat belirleyin. 💼",
+                "Müşteri bulma: Networking, referans, portfolio önemli. 📈",
+                "Proje yönetimi: Deadline'lara sadık kalın, iletişimi açık tutun. 🗓️"
+            ],
+            "general": [
+                "İlginç bir konu! Biraz daha açıklayabilir misiniz? 🤔",
+                "Bu konuda size yardımcı olabilirim. 📚",
+                "Anladım. Size nasıl destek olabilirim? 💭"
+            ]
+        }
+    
+    def generate(self, message, is_premium=False):
+        """Yanıt oluştur"""
+        msg_lower = message.lower()
+        
+        # Kategori belirle
+        if any(word in msg_lower for word in ["merhaba", "selam", "hi", "hello"]):
+            category = "greeting"
+        elif any(word in msg_lower for word in ["yardım", "help", "nasıl", "yapayım"]):
+            category = "help"
+        elif any(word in msg_lower for word in ["iş", "business", "para", "kazan", "freelance"]):
+            category = "business"
+        else:
+            category = "general"
+        
+        # Yanıt seç
+        response = random.choice(self.responses[category])
+        
+        # Premium teşvik
+        if not is_premium:
+            response += f"\n\n💎 **Premium ile daha iyi yanıtlar:** {SHOPIER_LINK}"
+        
+        return response
 
-Kullanıcı: {message}
-ZenkaMind:"""
+# =============================================================================
+# ENDPOINTS
+# =============================================================================
+ai = AIResponder()
 
-    headers = {
-        "Authorization": f"Bearer {HF_TOKEN}",
-        "Content-Type": "application/json"
+@app.get("/")
+async def root():
+    return {
+        "service": "ZenkaMind API",
+        "version": "1.0.0",
+        "status": "running",
+        "endpoints": {
+            "chat": "POST /api/chat",
+            "health": "GET /health",
+            "stats": "GET /api/stats"
+        }
     }
 
-    payload = {
-        "inputs": prompt,
-        "parameters": {
-            "max_new_tokens": 120,
-            "temperature": 0.7,
-            "top_p": 0.9,
-            "do_sample": True
-        }
+@app.get("/health")
+async def health():
+    return {
+        "status": "healthy",
+        "timestamp": datetime.now().isoformat(),
+        "service": "ZenkaMind API"
     }
 
+@app.post("/api/chat")
+async def chat(request: Request):
     try:
-        r = requests.post(
-            HF_API_URL,
-            headers=headers,
-            json=payload,
-            timeout=30
-        )
-
-        if r.status_code != 200:
-            return {
-                "response": f"❌ HF Router Hatası ({r.status_code}): {r.text}"
+        # JSON verisini al
+        data = await request.json()
+        email = data.get("email", "").strip().lower()
+        message = data.get("message", "").strip()
+        
+        # Validasyon
+        if not email or "@" not in email:
+            return JSONResponse(
+                status_code=400,
+                content={"error": "Geçerli email adresi gerekli"}
+            )
+        
+        if not message:
+            return JSONResponse(
+                status_code=400,
+                content={"error": "Mesaj boş olamaz"}
+            )
+        
+        # Veritabanını yükle
+        db = load_db()
+        
+        # Kullanıcı kontrolü
+        if email not in db:
+            db[email] = {
+                "premium": False,
+                "daily_count": 0,
+                "total_messages": 0,
+                "created_at": datetime.now().isoformat(),
+                "last_reset": date.today().isoformat()
             }
+        
+        user = db[email]
+        is_premium = user["premium"]
+        
+        # Günlük reset kontrolü
+        today = date.today().isoformat()
+        if user["last_reset"] != today:
+            user["daily_count"] = 0
+            user["last_reset"] = today
+        
+        # Limit kontrolü (free kullanıcılar için)
+        if not is_premium and user["daily_count"] >= FREE_DAILY_LIMIT:
+            return JSONResponse(
+                status_code=402,
+                content={
+                    "response": f"""
+🚫 **GÜNLÜK LİMİT DOLDU**
 
-        result = r.json()
+Bugün {user['daily_count']}/{FREE_DAILY_LIMIT} mesaj kullandınız.
 
-        if isinstance(result, list) and len(result) > 0:
-            text = result[0].get("generated_text", "").strip()
-            return {"response": text or "Cevap üretilemedi."}
+💎 **Premium avantajları:**
+✓ Sınırsız mesaj
+✓ Gelişmiş AI
+✓ Özel destek
+
+🔗 **Hemen başlayın:** {SHOPIER_LINK}
+""",
+                    "status": "limit_exceeded",
+                    "premium": False
+                }
+            )
+        
+        # AI yanıtı oluştur
+        ai_response = ai.generate(message, is_premium)
+        
+        # Mesaj sayacını artır
+        user["daily_count"] += 1
+        user["total_messages"] += 1
+        
+        # Veritabanını kaydet
+        save_db(db)
+        
+        # Kalan mesaj hesapla
+        remaining = FREE_DAILY_LIMIT - user["daily_count"] if not is_premium else "unlimited"
+        
+        # Başarılı yanıt
+        return {
+            "response": ai_response,
+            "status": "success",
+            "premium": is_premium,
+            "user_info": {
+                "email": email,
+                "plan": "premium" if is_premium else "free",
+                "limits": {
+                    "daily_limit": FREE_DAILY_LIMIT,
+                    "used_today": user["daily_count"],
+                    "remaining": remaining
+                },
+                "total_messages": user["total_messages"]
+            }
+        }
+        
+    except json.JSONDecodeError:
+        return JSONResponse(
+            status_code=400,
+            content={"error": "Geçersiz JSON formatı"}
+        )
+    except Exception as e:
+        return JSONResponse(
+            status_code=500,
+            content={"error": f"Sunucu hatası: {str(e)}"}
+        )
 
-        return {"response": "Geçersiz yanıt alındı."}
+@app.get("/api/stats")
+async def stats():
+    db = load_db()
+    
+    premium_count = sum(1 for user in db.values() if user.get("premium", False))
+    total_messages = sum(user.get("total_messages", 0) for user in db.values())
+    
+    return {
+        "total_users": len(db),
+        "premium_users": premium_count,
+        "free_users": len(db) - premium_count,
+        "total_messages": total_messages,
+        "daily_limit": FREE_DAILY_LIMIT,
+        "premium_price": PREMIUM_PRICE,
+        "status": "active"
+    }
 
+@app.post("/api/user/info")
+async def user_info(request: Request):
+    try:
+        data = await request.json()
+        email = data.get("email", "").strip().lower()
+        
+        if not email or "@" not in email:
+            return JSONResponse(
+                status_code=400,
+                content={"error": "Geçerli email gerekli"}
+            )
+        
+        db = load_db()
+        
+        if email not in db:
+            return JSONResponse(
+                status_code=404,
+                content={"error": "Kullanıcı bulunamadı"}
+            )
+        
+        user = db[email]
+        is_premium = user["premium"]
+        remaining = FREE_DAILY_LIMIT - user["daily_count"] if not is_premium else "unlimited"
+        
+        return {
+            "email": email,
+            "premium": is_premium,
+            "plan": "premium" if is_premium else "free",
+            "limits": {
+                "daily_limit": FREE_DAILY_LIMIT,
+                "used_today": user["daily_count"],
+                "remaining": remaining
+            },
+            "total_messages": user.get("total_messages", 0),
+            "created_at": user.get("created_at")
+        }
+        
     except Exception as e:
-        return {"response": f"Sunucu hatası: {str(e)}"}
+        return JSONResponse(
+            status_code=500,
+            content={"error": str(e)}
+        )