Delete templates/app.py

templates/app.py

@@ -1,861 +0,0 @@
-import os
-import asyncio
-import requests
-import httpx
-import json
-import uuid
-import time
-from datetime import date
-from fastapi import FastAPI, Request, BackgroundTasks
-from fastapi.responses import HTMLResponse, FileResponse, JSONResponse, RedirectResponse, StreamingResponse
-
-# 🟢 ایمپورت و فراخوانی ماژول مستقل روبیکا بات
-from rubikabot import router as rubikabot_router
-from soti import router as soti_router
-
-app = FastAPI()
-app.include_router(rubikabot_router) # 🟢 ثبت تمام آدرس‌های آپلود و دانلودد روبیکا به صورت یکپارچه
-app.include_router(soti_router)
-
-# ایجاد پوشه‌ههای مشترک برای وضعیت‌ها، فایل‌های صوتی و دیتای مصرف کاربران
-JOBS_DIR = "./tts_jobs"
-USAGE_DIR = "./tts_usage"
-os.makedirs(JOBS_DIR, exist_ok=True)
-os.makedirs(USAGE_DIR, exist_ok=True)
-
-# 🔒 متغیرها و دیتابیس حافظه موقت رانفلر برای قفل دوگانه (IP + Fingerprint)
-CLONE_USAGE_LIMIT = 1
-EDIT_USAGE_LIMIT = 5
-
-def get_client_ip(request: Request) -> str:
-    """استخراج دقیق آی‌پی واقعی کاربر از پشت پروکسی‌های Cloudflare و هاست رانفلر"""
-    cf_ip = request.headers.get("CF-Connecting-IP")
-    if cf_ip:
-        return cf_ip.strip()
-    x_forwarded_for = request.headers.get("X-Forwarded-For")
-    if x_forwarded_for:
-        return x_forwarded_for.split(",")[0].strip()
-    if request.client and request.client.host:
-        return request.client.host
-    return "0.0.0.0"
-
-# --- بخش مدیریت دائمی اعتبار کلون صدا (ذخیره روی دیسک رانفلر) ---
-def get_local_clone_usage(key: str) -> dict:
-    today_str = date.today().isoformat()
-    # تولید آدرس فایل ذخیره بر اساس اثر انگشت یا آی‌پی کاربر
-    safe_key = "".join([c for c in key if c.isalnum() or c in ["-", "_", "."]])
-    file_path = os.path.join(USAGE_DIR, f"clone_{safe_key}.json")
-    if os.path.exists(file_path):
-        try:
-            with open(file_path, "r", encoding="utf-8") as f:
-                data = json.load(f)
-                if data.get("date") == today_str:
-                    return data
-        except: pass
-    return {"count": 0, "date": today_str}
-
-def save_local_clone_usage(key: str, data: dict):
-    safe_key = "".join([c for c in key if c.isalnum() or c in ["-", "_", "."]])
-    file_path = os.path.join(USAGE_DIR, f"clone_{safe_key}.json")
-    try:
-        with open(file_path, "w", encoding="utf-8") as f:
-            json.dump(data, f)
-    except: pass
-
-def check_local_clone_limit(fingerprint: str, ip: str) -> bool:
-    """بررسی محدودیت کلون صدا: اگر اثر انگشت یا آی‌پی سهمیه‌اش پر باشد، بلاک می‌کند"""
-    for key in [fingerprint, ip]:
-        if not key: continue
-        data = get_local_clone_usage(key)
-        if data["count"] >= CLONE_USAGE_LIMIT:
-            return True
-    return False
-
-def use_local_clone(fingerprint: str, ip: str):
-    """ثبت مصرف سهمیه کلون صدا روی هارد دیسک رانفلر"""
-    for key in [fingerprint, ip]:
-        if not key: continue
-        data = get_local_clone_usage(key)
-        data["count"] += 1
-        save_local_clone_usage(key, data)
-
-# --- بخش مدیریت دائمی اعتبار ویرایش تصاویر (ذخیره روی دیسک رانفلر) ---
-def get_local_edit_usage(key: str) -> dict:
-    current_week = date.today().isocalendar()[1]
-    safe_key = "".join([c for c in key if c.isalnum() or c in ["-", "_", "."]])
-    file_path = os.path.join(USAGE_DIR, f"edit_{safe_key}.json")
-    if os.path.exists(file_path):
-        try:
-            with open(file_path, "r", encoding="utf-8") as f:
-                data = json.load(f)
-                if data.get("week") == current_week:
-                    return data
-        except: pass
-    return {"count": 0, "week": current_week}
-
-def save_local_edit_usage(key: str, data: dict):
-    safe_key = "".join([c for c in key if c.isalnum() or c in ["-", "_", "."]])
-    file_path = os.path.join(USAGE_DIR, f"edit_{safe_key}.json")
-    try:
-        with open(file_path, "w", encoding="utf-8") as f:
-            json.dump(data, f)
-    except: pass
-
-def check_local_edit_limit(fingerprint: str, ip: str) -> bool:
-    """بررسی محدودیت ادیت عکس: اگر اثر انگشت یا آی‌پی سهمیه هفتگی‌اش پر باشد، بلاک می‌کند"""
-    for key in [fingerprint, ip]:
-        if not key: continue
-        data = get_local_edit_usage(key)
-        if data["count"] >= EDIT_USAGE_LIMIT:
-            return True
-    return False
-
-def use_local_edit(fingerprint: str, ip: str):
-    """ثبت مصرف سهمیه ویرایش عکس روی هارد دیسک رانفلر"""
-    for key in [fingerprint, ip]:
-        if not key: continue
-        data = get_local_edit_usage(key)
-        data["count"] += 1
-        save_local_edit_usage(key, data)
-
-
-def clean_old_files():
-    """پاکسازی خودکار فایل‌های قدیمی برای جلوگیری از پر شدن حافظه سرور"""
-    now = time.time()
-    
-    # فایل‌های صوتی و جاب‌ها بعد از ۳۰ دقیقه (۱۸۰۰ ثانیه) حذف می‌شوند
-    try:
-        for f in os.listdir(JOBS_DIR):
-            fpath = os.path.join(JOBS_DIR, f)
-            if os.path.isfile(fpath) and os.stat(fpath).st_mtime < now - 1800:
-                os.remove(fpath)
-    except: pass
-    
-    # لاگ‌های اعتبار روزانه کاربران بعد از ۴۸ ساعت (۱۷۲۸۰۰ ثانیه) حذف می‌شوند
-    try:
-        for f in os.listdir(USAGE_DIR):
-            fpath = os.path.join(USAGE_DIR, f)
-            if os.path.isfile(fpath) and os.stat(fpath).st_mtime < now - 172800:
-                os.remove(fpath)
-    except: pass
-
-def save_job_state(job_id: str, status: str, audio_data: bytes = None, error_message: str = None):
-    """ذخیره وضعیت کار در فایل متنی مشترک دیسک"""
-    clean_old_files()
-
-    state = {
-        "status": status,
-        "error_message": error_message,
-        "has_audio": audio_data is not None
-    }
-    state_file = os.path.join(JOBS_DIR, f"{job_id}.json")
-    with open(state_file, "w", encoding="utf-8") as f:
-        json.dump(state, f, ensure_ascii=False)
-    
-    if audio_data:
-        audio_file = os.path.join(JOBS_DIR, f"{job_id}.mp3")
-        with open(audio_file, "wb") as f:
-            f.write(audio_data)
-
-def get_job_state(job_id: str):
-    """خواندن وضعیت کار از فایل متنی مشترک دیسک"""
-    state_file = os.path.join(JOBS_DIR, f"{job_id}.json")
-    if not os.path.exists(state_file):
-        return None
-    try:
-        with open(state_file, "r", encoding="utf-8") as f:
-            return json.load(f)
-    except:
-        return None
-
-def get_job_audio(job_id: str):
-    """خواندن دیتای باینری صوتی ذخیره شده روی دیسک"""
-    audio_file = os.path.join(JOBS_DIR, f"{job_id}.mp3")
-    if os.path.exists(audio_file):
-        try:
-            with open(audio_file, "rb") as f:
-                return f.read()
-        except:
-            return None
-    return None
-
-async def run_tts_background(job_id: str, payload: dict, headers: dict):
-    try:
-        # برای ارتباط با sada8888-tts2 فقط متن، گوینده و خلاقیت فرستاده می‌شود (مشابه پادکست)
-        target_payload = {
-            "text": payload.get("text"),
-            "speaker": payload.get("speaker"),
-            "temperature": payload.get("temperature", 1.5)
-        }
-        
-        async with httpx.AsyncClient(timeout=180.0) as client:
-            resp = await client.post(
-                "https://sada8888-tts2.hf.space/api/generate",
-                json=target_payload,
-                headers={"Content-Type": "application/json"}
-            )
-            if resp.status_code == 200:
-                save_job_state(job_id, "completed", audio_data=resp.content)
-            else:
-                save_job_state(job_id, "error", error_message=f"خطا از سرور تولید صدا: {resp.text}")
-    except Exception as e:
-        save_job_state(job_id, "error", error_message=str(e))
-
-# =================================================================
-# 1. مسیرهای اصلی و بخش متن به صدا (TTS PRO)
-# =================================================================
-@app.get("/")
-async def root_path():
-    # صفحه اصلی چیزی نشان نمی‌دهد و دایرکت هم نمی‌شود
-    return HTMLResponse("Alpha API Server is running.", status_code=200)
-
-@app.get("/tts")
-@app.get("/tts/")
-async def old_tts_path():
-    # لینک قدیمی غیرفعال شد
-    return HTMLResponse("<h1>این مسیر تغییر یافته است. لطفا از ttspro استفاده کنید.</h1>", status_code=404)
-
-@app.get("/ttspro", response_class=HTMLResponse)
-@app.get("/ttspro/", response_class=HTMLResponse)
-async def serve_ttspro():
-    # فقط این آدرس فایل ttspro.html را باز میکند
-    if os.path.exists("ttspro.html"):
-        return FileResponse("ttspro.html")
-    return HTMLResponse("<h1>خطا: فایل ttspro.html پیدا نشد! لطفا آن را آپلود کنید.</h1>", status_code=404)
-
-
-# =================================================================
-# 2. آینه چت بات (پروکسی خام و بدون بافر برای سرعت حداکثری)
-# =================================================================
-CHAT_SPACE_URL = "https://sada8888-ttslive-chat.hf.space"
-
-@app.get("/chat", response_class=HTMLResponse)
-async def serve_chat():
-    if os.path.exists("chat.html"):
-        return FileResponse("chat.html")
-    return HTMLResponse("<h1>خطا: فایل chat.html ��یدا نشد!</h1>", status_code=404)
-
-@app.get("/audio/{filename}")
-async def serve_chat_audio(filename: str):
-    # اگر فایل صوتی مربوط به درخواست‌های متن به صدای استاندارد ما بود
-    if filename.startswith("standard_"):
-        job_id = filename.replace("standard_", "").replace(".mp3", "").replace(".wav", "")
-        audio_data = get_job_audio(job_id)
-        if audio_data:
-            return StreamingResponse(
-                iter([audio_data]),
-                media_type="audio/mpeg"
-            )
-        return HTMLResponse("<h1>فایل صوتی یافت نشد</h1>", status_code=404)
-
-    # روال عادی برای چت‌پروکسی
-    async def iterfile():
-        try:
-            async with httpx.AsyncClient(timeout=10.0) as client:
-                async with client.stream("GET", f"{CHAT_SPACE_URL}/audio/{filename}") as r:
-                    r.raise_for_status()
-                    async for chunk in r.aiter_bytes(chunk_size=8192):
-                        if chunk: yield chunk
-        except Exception:
-            yield b""
-    return StreamingResponse(iterfile(), media_type="audio/wav")
-
-@app.post("/api/chat_proxy")
-async def chat_proxy_bridge(request: Request):
-    try:
-        body_bytes = await request.body()
-
-        async def stream_generator():
-            try:
-                # اتصال مستقیم به هاگینگ فیس با httpx برای جلوگیری از مسدود شدن ورکرها
-                async with httpx.AsyncClient(timeout=60.0) as client:
-                    async with client.stream(
-                        "POST", 
-                        f"{CHAT_SPACE_URL}/api/chat_proxy",
-                        content=body_bytes,
-                        headers={"Content-Type": "application/json"}
-                    ) as resp:
-                        async for line in resp.aiter_lines():
-                            if line:
-                                yield (line + "\n").encode('utf-8')
-            except Exception as e:
-                err = {"status": "error", "message": f"خطا در ارتباط رانفلر با سرور اصلی: {str(e)}"}
-                yield (json.dumps(err) + "\n").encode('utf-8')
-
-        headers = {
-            "Cache-Control": "no-cache, no-transform",
-            "X-Accel-Buffering": "no",
-            "Connection": "keep-alive",
-            "Transfer-Encoding": "chunked"
-        }
-        return StreamingResponse(stream_generator(), media_type="application/json", headers=headers)
-    except Exception as e:
-        return JSONResponse({"status": "error", "message": "سرور موقتا در دسترس نیست."}, status_code=500)
-
-
-# =================================================================
-# 3. دور زدن فیلترینگ برای API های متن به صدا (TTS Proxy) با کش یکپارچه
-# =================================================================
-HF_SPACE_BASE_URL_TTS = "https://ezmarynoori-tts.hf.space"
-USAGE_LIMIT_GENERATE = 10
-
-def get_user_usage(fingerprint: str):
-    """خواندن آمار مصرف کاربر از دیسک مشترک سرور"""
-    today_str = date.today().isoformat()
-    usage_file = os.path.join(USAGE_DIR, f"usage_{fingerprint}.json")
-    if os.path.exists(usage_file):
-        try:
-            with open(usage_file, "r", encoding="utf-8") as f:
-                data = json.load(f)
-                if data.get("last_reset") == today_str:
-                    return data
-        except: pass
-    return {"count": 0, "last_reset": today_str}
-
-def increment_user_usage(fingerprint: str):
-    """افزایش آمار مصرف کاربر و ذخیره روی دیسک مشترک"""
-    data = get_user_usage(fingerprint)
-    data["count"] += 1
-    usage_file = os.path.join(USAGE_DIR, f"usage_{fingerprint}.json")
-    try:
-        with open(usage_file, "w", encoding="utf-8") as f:
-            json.dump(data, f)
-    except: pass
-
-def check_limit_tts(payload):
-    if payload.get('subscriptionStatus') != 'paid':
-        fingerprint = payload.get('fingerprint')
-        if not fingerprint:
-            return False
-        
-        record = get_user_usage(fingerprint)
-        if record["count"] >= USAGE_LIMIT_GENERATE:
-            return False
-            
-        increment_user_usage(fingerprint)
-    return True
-
-@app.post("/api/check-credit-tts")
-async def check_credit_tts(request: Request):
-    try:
-        data = await request.json()
-        fingerprint = data.get('fingerprint')
-        subscription_status = data.get('subscriptionStatus')
-        
-        if not fingerprint: 
-            return JSONResponse({"message": "Fingerprint required."}, status_code=400)
-            
-        if subscription_status == 'paid': 
-            return JSONResponse({"credits_remaining": "unlimited", "limit_reached": False})
-            
-        record = get_user_usage(fingerprint)
-        credits = max(0, USAGE_LIMIT_GENERATE - record["count"])
-        return JSONResponse({"credits_remaining": credits, "limit_reached": credits <= 0})
-    except:
-        return JSONResponse({"message": "Server Error"}, status_code=500)
-
-@app.post("/api/check-clone-credit")
-async def check_clone_credit(request: Request):
-    """بررسی و شارژ خودکار اعتبار شبیه‌سازی صدا بر اساس قفل دوگانه دائمی (IP + Fingerprint)"""
-    try:
-        data = await request.json()
-        fingerprint = data.get('fingerprint')
-        subscription_status = data.get('subscriptionStatus')
-        client_ip = get_client_ip(request)
-        
-        if not fingerprint: 
-            return JSONResponse({"message": "Fingerprint required."}, status_code=400)
-            
-        if subscription_status == 'paid': 
-            return JSONResponse({"credits_remaining": "unlimited", "limit_reached": False})
-            
-        # بررسی قفل دوگانه دیسکی
-        limit_reached = check_local_clone_limit(fingerprint, client_ip)
-        
-        today_str = date.today().isoformat()
-        
-        # محاسبه اعتبار باقیمانده بر اساس بدترین سناریو دیسک رانفلر
-        rec = get_local_clone_usage(fingerprint)
-        rem_fp = max(0, CLONE_USAGE_LIMIT - rec["count"])
-            
-        rec = get_local_clone_usage(client_ip)
-        rem_ip = max(0, CLONE_USAGE_LIMIT - rec["count"])
-            
-        credits_remaining = min(rem_fp, rem_ip)
-        
-        return JSONResponse({
-            "credits_remaining": credits_remaining,
-            "limit_reached": limit_reached or (credits_remaining <= 0)
-        })
-    except Exception as e:
-        return JSONResponse({"message": f"Server Error: {str(e)}"}, status_code=500)
-
-@app.post("/api/use-clone-credit")
-async def use_clone_credit(request: Request):
-    """ثبت و کسر یک واحد اعتبار شبیه‌سازی صدا در سیستم قفل دوگانه دیسک رانفلر"""
-    try:
-        data = await request.json()
-        fingerprint = data.get('fingerprint')
-        subscription_status = data.get('subscriptionStatus')
-        client_ip = get_client_ip(request)
-        
-        if not fingerprint or subscription_status == 'paid':
-            return JSONResponse({"status": "success"})
-            
-        use_local_clone(fingerprint, client_ip)
-        return JSONResponse({"status": "success"})
-    except Exception as e:
-        return JSONResponse({"message": f"Server Error: {str(e)}"}, status_code=500)
-
-def get_hf_headers(request: Request):
-    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"
-    }
-    client_ip = request.headers.get("X-Forwarded-For")
-    if client_ip:
-        headers["X-Forwarded-For"] = client_ip
-    elif request.client and request.client.host:
-        headers["X-Forwarded-For"] = request.client.host
-    return headers
-
-HF_VIDEO_SPACE_URL = "https://sada8888-tts3.hf.space"
-
-@app.post("/api/generate")
-async def submit_job(request: Request, background_tasks: BackgroundTasks):
-    payload = await request.json()
-    headers = get_hf_headers(request)
-
-    # --- تشخیص هوشمند درخواست تولید عکس (Flux Pro و غیره) ---
-    if "action_name" in payload and "prompt" in payload:
-        try:
-            resp = await asyncio.to_thread(requests.post, f"{HF_VIDEO_SPACE_URL}/api/generate", json=payload, headers=headers, timeout=120)
-            return JSONResponse(resp.json(), status_code=resp.status_code)
-        except Exception as e:
-            return JSONResponse({"status": "error", "message": f"خطای سرور تصویر: {str(e)}"}, status_code=500)
-    
-    # --- تشخیص هوشمند درخواست‌های پادکست (متصل به اسپیس جدید) ---
-    if "fingerprint" not in payload and "subscriptionStatus" not in payload:
-        try:
-            # ارسال امن به اسپیس جدید پادکست
-            resp = await asyncio.to_thread(
-                requests.post, 
-                "https://sada8888-tts2.hf.space/api/generate", 
-                json=payload, 
-                headers=headers, 
-                timeout=180
-            )
-            # اگر خطای سرور ابری دریافت کردیم با فرمت درست به کلاینت ارور می‌دهیم
-            if resp.status_code != 200:
-                return JSONResponse({"error": f"خطا از سرور تولید پادکست: {resp.text}"}, status_code=resp.status_code)
-            
-            # بازگرداندن فایل صوتی تولید شده به کلاینت
-            return StreamingResponse(
-                iter([resp.content]), 
-                media_type="audio/mpeg"
-            )
-        except Exception as e:
-            return JSONResponse({"error": f"قطعی ارتباط با سرور ابری: {str(e)}"}, status_code=500)
-
-    # --- درخواست‌های عادی TTS از صفحه اصلی (متصل به همان اسپیس پادکست جدید) ---
-    if not check_limit_tts(payload): return JSONResponse({"message": "سقف تکمیل شده"}, status_code=429)
-    try:
-        job_id = f"job_{uuid.uuid4().hex}"
-        save_job_state(job_id, "processing")
-        background_tasks.add_task(run_tts_background, job_id, payload, headers)
-        return JSONResponse({"job_id": job_id}, status_code=200)
-    except Exception as e:
-        return JSONResponse({"message": f"خطا در شروع فرآیند: {str(e)}"}, status_code=500)
-
-@app.post("/api/check_status")
-async def check_status(request: Request):
-    try:
-        payload = await request.json()
-        job_id = payload.get("job_id")
-        
-        # بررسی وضعیت وظیفه از دیسک مشترک (سازگار با چند ورکر همزمان)
-        job_state = get_job_state(job_id) if job_id else None
-        
-        if job_state:
-            if job_state["status"] == "completed":
-                return JSONResponse({
-                    "status": "completed",
-                    "proxy_url": f"/audio/standard_{job_id}.mp3"
-                })
-            elif job_state["status"] == "error":
-                return JSONResponse({
-                    "status": "error",
-                    "result": job_state.get("error_message", "خطا در تولید صدا")
-                })
-            else:
-                return JSONResponse({"status": "processing"})
-                
-        # در غیر این صورت (سایر کارهای مربوط به فضاهای دیگر)
-        resp = await asyncio.to_thread(requests.post, f"{HF_SPACE_BASE_URL_TTS}/api/check_status", json=payload, timeout=30)
-        return JSONResponse(resp.json(), status_code=resp.status_code)
-    except: return JSONResponse({"status": "error"}, status_code=500)
-
-@app.post("/api/generate_podcast")
-async def generate_podcast_proxy(request: Request):
-    payload = await request.json()
-    if not check_limit_tts(payload): return JSONResponse({"message": "سقف تکمیل شده"}, status_code=429)
-    try:
-        resp = await asyncio.to_thread(requests.post, f"{HF_SPACE_BASE_URL_TTS}/api/generate_podcast", json=payload, timeout=30)
-        return JSONResponse(resp.json(), status_code=resp.status_code)
-    except: return JSONResponse({"message": "خطا"}, status_code=500)
-
-@app.post("/api/podcast_status")
-async def podcast_status_proxy(request: Request):
-    try:
-        payload = await request.json()
-        resp = await asyncio.to_thread(requests.post, f"{HF_SPACE_BASE_URL_TTS}/api/podcast_status", json=payload, timeout=30)
-        return JSONResponse(resp.json(), status_code=resp.status_code)
-    except: return JSONResponse({"status": "error"}, status_code=500)
-
-
-# =================================================================
-# 4. سرویس استودیوی پادکست و مسیریابی هوشمند دیتابیس‌ها
-# =================================================================
-# لینک اسپیس جدید پادکست
-HF_PODCAST_SPACE_URL = "https://sada8888-tts2.hf.space"
-
-@app.get("/podcast", response_class=HTMLResponse)
-@app.get("/podcast/", response_class=HTMLResponse)
-async def serve_podcast():
-    if os.path.exists("podcast.html"):
-        return FileResponse("podcast.html")
-    return HTMLResponse("<h1>خطا: فایل podcast.html پیدا نشد!</h1>", status_code=404)
-
-@app.post("/api/check-credit")
-async def smart_check_credit(request: Request):
-    try:
-        payload = await request.json()
-        headers = get_hf_headers(request)
-        referer = request.headers.get("referer", "").lower()
-        
-        if "podcast" in referer:
-            url = f"{HF_PODCAST_SPACE_URL}/api/check-credit"
-        else:
-            url = f"{HF_VIDEO_SPACE_URL}/api/check-credit"
-            
-        resp = await asyncio.to_thread(requests.post, url, json=payload, headers=headers, timeout=30)
-        return JSONResponse(resp.json(), status_code=resp.status_code)
-    except Exception as e: 
-        return JSONResponse({"status": "error", "message": f"خطا در ارتباط با سرور: {str(e)}"}, status_code=500)
-
-@app.post("/api/use-credit")
-async def smart_use_credit(request: Request):
-    try:
-        payload = await request.json()
-        headers = get_hf_headers(request)
-        referer = request.headers.get("referer", "").lower()
-        
-        if "podcast" in referer:
-            url = f"{HF_PODCAST_SPACE_URL}/api/use-credit"
-        else:
-            url = f"{HF_VIDEO_SPACE_URL}/api/use-credit"
-            
-        resp = await asyncio.to_thread(requests.post, url, json=payload, headers=headers, timeout=30)
-        return JSONResponse(resp.json(), status_code=resp.status_code)
-    except: return JSONResponse({"status": "error"}, status_code=500)
-
-@app.post("/api/create-full-podcast")
-async def podgen_create_full(request: Request):
-    try:
-        payload = await request.json()
-        headers = get_hf_headers(request)
-        resp = await asyncio.to_thread(requests.post, f"{HF_PODCAST_SPACE_URL}/api/create-full-podcast", json=payload, headers=headers, timeout=60)
-        return JSONResponse(resp.json(), status_code=resp.status_code)
-    except: return JSONResponse({"error": "ارتباط با سرور قطع شد"}, status_code=500)
-
-@app.get("/api/podcast-status/{task_id}")
-async def podgen_status(request: Request, task_id: str):
-    try:
-        headers = get_hf_headers(request)
-        resp = await asyncio.to_thread(requests.get, f"{HF_PODCAST_SPACE_URL}/api/podcast-status/{task_id}", headers=headers, timeout=30)
-        return JSONResponse(resp.json(), status_code=resp.status_code)
-    except: return JSONResponse({"status": "error"}, status_code=500)
-
-@app.post("/api/auto-podcast")
-async def podgen_auto(request: Request):
-    try:
-        payload = await request.json()
-        headers = get_hf_headers(request)
-        resp = await asyncio.to_thread(requests.post, f"{HF_PODCAST_SPACE_URL}/api/auto-podcast", json=payload, headers=headers, timeout=60)
-        return JSONResponse(resp.json(), status_code=resp.status_code)
-    except: return JSONResponse({"error": "ارتباط قطع شد"}, status_code=500)
-
-@app.get("/api/auto-podcast-status/{task_id}")
-async def podgen_auto_status(request: Request, task_id: str):
-    try:
-        headers = get_hf_headers(request)
-        resp = await asyncio.to_thread(requests.get, f"{HF_PODCAST_SPACE_URL}/api/auto-podcast-status/{task_id}", headers=headers, timeout=30)
-        return JSONResponse(resp.json(), status_code=resp.status_code)
-    except: return JSONResponse({"status": "error"}, status_code=500)
-
-@app.get("/api/download-podcast/{filename}")
-async def podgen_download(request: Request, filename: str):
-    async def iterfile():
-        try:
-            headers = get_hf_headers(request)
-            async with httpx.AsyncClient(timeout=120.0) as client:
-                async with client.stream("GET", f"{HF_PODCAST_SPACE_URL}/api/download-podcast/{filename}", headers=headers) as r:
-                    r.raise_for_status()
-                    async for chunk in r.aiter_bytes(chunk_size=65536):
-                        if chunk: yield chunk
-        except Exception:
-            yield b""
-    return StreamingResponse(iterfile(), media_type="audio/mpeg")
-
-
-# =================================================================
-# 5. سرویس‌های ساخت ویدیو، تصویر و ویرایش تصویر (اتصال مستقیم خام)
-# =================================================================
-@app.get("/video", response_class=HTMLResponse)
-@app.get("/video/", response_class=HTMLResponse)
-async def serve_video_studio():
-    if os.path.exists("video.html"):
-        return FileResponse("video.html")
-    return HTMLResponse("<h1>خطا: فایل video.html پیدا نشد!</h1>", status_code=404)
-
-@app.get("/flux", response_class=HTMLResponse)
-@app.get("/flux/", response_class=HTMLResponse)
-async def serve_flux_studio():
-    if os.path.exists("flux.html"):
-        return FileResponse("flux.html")
-    return HTMLResponse("<h1>خطا: فایل flux.html پیدا نشد!</h1>", status_code=404)
-
-@app.get("/image", response_class=HTMLResponse)
-@app.get("/image/", response_class=HTMLResponse)
-async def serve_image_studio():
-    if os.path.exists("image.html"):
-        return FileResponse("image.html")
-    elif os.path.exists("flux.html"):
-        return FileResponse("flux.html")
-    return HTMLResponse("<h1>خطا: فایل image.html پیدا نشد!</h1>", status_code=404)
-
-@app.get("/edit", response_class=HTMLResponse)
-@app.get("/edit/", response_class=HTMLResponse)
-async def serve_edit_studio():
-    if os.path.exists("edit.html"):
-        return FileResponse("edit.html")
-    return HTMLResponse("<h1>خطا: فایل edit.html پیدا نشد!</h1>", status_code=404)
-
-# --- مسیرهای اعتبار اختصاصی تصاویر ---
-@app.post("/api/check-image-credit")
-async def proxy_check_image_credit(request: Request):
-    try:
-        body = await request.body()
-        headers = get_hf_headers(request)
-        if "content-type" in request.headers:
-            headers["Content-Type"] = request.headers["content-type"]
-        resp = await asyncio.to_thread(requests.post, f"{HF_VIDEO_SPACE_URL}/api/check-image-credit", data=body, headers=headers, timeout=30)
-        return JSONResponse(resp.json(), status_code=resp.status_code)
-    except Exception as e:
-        return JSONResponse({"status": "error", "message": f"خطا در ارتباط رانفلر: {str(e)}"}, status_code=500)
-
-@app.post("/api/use-image-credit")
-async def proxy_use_image_credit(request: Request):
-    try:
-        body = await request.body()
-        headers = get_hf_headers(request)
-        if "content-type" in request.headers:
-            headers["Content-Type"] = request.headers["content-type"]
-        resp = await asyncio.to_thread(requests.post, f"{HF_VIDEO_SPACE_URL}/api/use-image-credit", data=body, headers=headers, timeout=30)
-        return JSONResponse(resp.json(), status_code=resp.status_code)
-    except Exception as e:
-        return JSONResponse({"status": "error", "message": f"خطا در ارتباط رانفلر: {str(e)}"}, status_code=500)
-
-# --- مسیرهای اعتبار اختصاصی ویرایش تصویر (فتوشاپ هوش مصنوعی) با قفل دوگانه دائمی رانفلر ---
-@app.post("/api/check-edit-credit")
-async def proxy_check_edit_credit(request: Request):
-    try:
-        data = await request.json()
-        fingerprint = data.get('fingerprint')
-        subscription_status = data.get('subscriptionStatus')
-        client_ip = get_client_ip(request)
-
-        if subscription_status == 'paid':
-            return JSONResponse({"credits_remaining": "unlimited", "limit_reached": False})
-
-        # بررسی دائمی قفل دوگانه (آی‌پی + اثر انگشت) از دیسک رانفلر
-        limit_reached = check_local_edit_limit(fingerprint, client_ip)
-        
-        current_week = date.today().isocalendar()[1]
-        
-        # بررسی بدترین سناریوی سهمیه هفتگی دیسکی
-        rem_fp = 0
-        if fingerprint:
-            rec = get_local_edit_usage(fingerprint)
-            if rec["week"] == current_week:
-                rem_fp = max(0, EDIT_USAGE_LIMIT - rec["count"])
-            else:
-                rem_fp = EDIT_USAGE_LIMIT
-        else:
-            rem_fp = EDIT_USAGE_LIMIT
-            
-        rec = get_local_edit_usage(client_ip)
-        if rec["week"] == current_week:
-            rem_ip = max(0, EDIT_USAGE_LIMIT - rec["count"])
-        else:
-            rem_ip = EDIT_USAGE_LIMIT
-        
-        credits_remaining = min(rem_fp, rem_ip)
-        
-        return JSONResponse({
-            "credits_remaining": credits_remaining,
-            "limit_reached": limit_reached or (credits_remaining <= 0)
-        })
-    except Exception as e:
-        return JSONResponse({"status": "error", "message": f"error: {str(e)}"}, status_code=500)
-
-@app.post("/api/use-edit-credit")
-async def proxy_use_edit_credit(request: Request):
-    try:
-        data = await request.json()
-        fingerprint = data.get('fingerprint')
-        subscription_status = data.get('subscriptionStatus')
-        client_ip = get_client_ip(request)
-
-        if subscription_status != 'paid':
-            use_local_edit(fingerprint, client_ip)
-        return JSONResponse({"status": "success"})
-    except Exception as e:
-        return JSONResponse({"status": "error", "message": f"error: {str(e)}"}, status_code=500)
-
-# --- پروکسی درخواست‌های تولید و ویرایش ---
-@app.post("/api/generate-video")
-async def proxy_generate_video(request: Request):
-    try:
-        body = await request.body()
-        headers = get_hf_headers(request)
-        
-        if "content-type" in request.headers:
-            headers["Content-Type"] = request.headers["content-type"]
-            
-        resp = await asyncio.to_thread(
-            requests.post, 
-            f"{HF_VIDEO_SPACE_URL}/api/generate-video", 
-            data=body, 
-            headers=headers,
-            timeout=300
-        )
-        try:
-            return JSONResponse(resp.json(), status_code=resp.status_code)
-        except:
-            return JSONResponse({"status": "error", "message": "خطا در سرور ابری", "details": resp.text}, status_code=502)
-    except Exception as e:
-        return JSONResponse({"status": "error", "message": f"خطا در ارتباط رانفلر: {str(e)}"}, status_code=500)
-
-@app.post("/api/merge-videos")
-async def proxy_merge_videos(request: Request):
-    try:
-        body = await request.body()
-        headers = get_hf_headers(request)
-        if "content-type" in request.headers:
-            headers["Content-Type"] = request.headers["content-type"]
-            
-        resp = await asyncio.to_thread(
-            requests.post, 
-            f"{HF_VIDEO_SPACE_URL}/api/merge-videos", 
-            data=body, 
-            headers=headers,
-            timeout=400
-        )
-        
-        if resp.status_code == 200:
-            return StreamingResponse(
-                iter([resp.content]), 
-                media_type=resp.headers.get("Content-Type", "video/mp4"),
-                headers={"Content-Disposition": resp.headers.get("Content-Disposition", "attachment; filename=merged_video.mp4")}
-            )
-        else:
-            try:
-                err_json = resp.json()
-                return JSONResponse({"status": "error", "message": err_json.get("error", "خطا در پردازش ویدیو")}, status_code=resp.status_code)
-            except:
-                return JSONResponse({"status": "error", "message": "خطا در پردازش و میکس ویدیو"}, status_code=resp.status_code)
-    except Exception as e:
-        return JSONResponse({"status": "error", "message": f"خطا در ارتباط رانفلر: {str(e)}"}, status_code=500)
-
-@app.get("/api/status/{run_id}")
-async def proxy_video_status(request: Request, run_id: str):
-    try:
-        headers = get_hf_headers(request)
-        resp = await asyncio.to_thread(requests.get, f"{HF_VIDEO_SPACE_URL}/api/status/{run_id}", headers=headers, timeout=30)
-        return JSONResponse(resp.json(), status_code=resp.status_code)
-    except Exception as e:
-        return JSONResponse({"status": "processing"}, status_code=500)
-
-@app.get("/static/images/{filename}")
-async def proxy_static_images(request: Request, filename: str):
-    headers = get_hf_headers(request)
-    url = f"{HF_VIDEO_SPACE_URL}/static/images/{filename}"
-    
-    async def async_iterfile():
-        try:
-            async with httpx.AsyncClient(timeout=120.0) as client:
-                async with client.stream("GET", url, headers=headers) as response:
-                    response.raise_for_status()
-                    async for chunk in response.aiter_bytes(chunk_size=65536):
-                        if chunk:
-                            yield chunk
-        except Exception:
-            yield b""
-            
-    media_type = "application/octet-stream"
-    if filename.endswith(".mp4"): media_type = "video/mp4"
-    elif filename.endswith(".png"): media_type = "image/png"
-    elif filename.endswith(".webp"): media_type = "image/webp"
-    elif filename.endswith(".jpg") or filename.endswith(".jpeg"): media_type = "image/jpeg"
-    elif filename.endswith(".txt"): media_type = "text/plain"
-    
-    response_headers = {
-        "Cache-Control": "public, max-age=86400"
-    }
-    
-    return StreamingResponse(async_iterfile(), media_type=media_type, headers=response_headers)
-
-@app.post("/api/edit")
-async def proxy_edit_image(request: Request):
-    try:
-        body = await request.body()
-        headers = get_hf_headers(request)
-        if "content-type" in request.headers:
-            headers["Content-Type"] = request.headers["content-type"]
-            
-        resp = await asyncio.to_thread(requests.post, f"{HF_VIDEO_SPACE_URL}/api/edit", data=body, headers=headers, timeout=120)
-        try:
-            return JSONResponse(resp.json(), status_code=resp.status_code)
-        except:
-            return JSONResponse({"status": "error", "message": "خطا در سرور ابری", "details": resp.text}, status_code=502)
-    except Exception as e:
-        return JSONResponse({"status": "error", "message": f"خطا در ارتباط رانفلر: {str(e)}"}, status_code=500)
-
-@app.post("/api/chat")
-async def proxy_gemma_chat(request: Request):
-    try:
-        body = await request.body()
-        headers = get_hf_headers(request)
-        if "content-type" in request.headers:
-            headers["Content-Type"] = request.headers["content-type"]
-            
-        resp = await asyncio.to_thread(requests.post, f"{HF_VIDEO_SPACE_URL}/api/chat", data=body, headers=headers, timeout=120)
-        try:
-            return JSONResponse(resp.json(), status_code=resp.status_code)
-        except:
-            return JSONResponse({"status": "error", "message": "خطا در سرور ابری", "details": resp.text}, status_code=502)
-    except Exception as e:
-        return JSONResponse({"status": "error", "message": f"خطا در ارتباط رانفلر: {str(e)}"}, status_code=500)
-
-# alphattspro-main/app.py -> انتهای فایل
-
-# =================================================================
-# 6. مسیر استاتیک (باید همیشه در انتهای کد باشد)
-# =================================================================
-@app.get("/{path:path}")
-async def serve_static(path: str):
-    # کلمات "soti" و "sotifree" به استثناها اضافه شدند تا رانفلر آن‌ها را فایل فرض نکند
-    if os.path.exists(path) and path not in ["chat", "tts", "ws", "podcast", "video", "flux", "image", "edit", "ttspro", "soti", "sotifree"]:
-        return FileResponse(path)
-    return HTMLResponse("Not Found", status_code=404)