Update app.py

app.py

@@ -1,3 +1,4 @@
+# app.py (Runflare Combined Server Core)
 import os
 import asyncio
 import requests
@@ -234,7 +235,7 @@ async def serve_ttspro():
     for path in ["ttspro.html", "templates/ttspro.html"]:
         if os.path.exists(path):
             return FileResponse(path)
-    return HTMLResponse("<h1>خطا: فایل ttspro.html پیدا نشد! لطفا آن را آپلود کنید.</h1>", status_code=404)
+    return HTMLResponse("<h1>خطا: فایل ttspro.html پیدا نشد!</h1>", status_code=404)
 
 
 # =================================================================
@@ -304,15 +305,16 @@ async def chat_proxy_bridge(request: Request):
     except Exception as e:
         return JSONResponse({"status": "error", "message": "سرور موقتا در دسترس نیست."}, status_code=500)
 
-# 🟢 اضافه شدن فوروارد اختصاصی برای ساخت مقاله
+# 🟢 اندپوینت جدید: پروکسی استریمینگ و فوق‌العاده پایدار ساخت فایل (مقاله) از سرور چت اصلی
 @app.post("/api/create_file")
-async def create_file_bridge(request: Request):
+async def create_file_proxy_bridge(request: Request):
     try:
         body_bytes = await request.body()
 
         async def stream_generator():
             try:
-                async with httpx.AsyncClient(timeout=180.0) as client:
+                # اتصال مستقیم به سرور چت با تنظیم تایم‌اوت ۵ دقیقه‌ای برای مقالات طولانی
+                async with httpx.AsyncClient(timeout=httpx.Timeout(120.0, read=300.0)) as client:
                     async with client.stream(
                         "POST", 
                         f"{CHAT_SPACE_URL}/api/create_file",
@@ -323,13 +325,14 @@ async def create_file_bridge(request: Request):
                             if chunk:
                                 yield chunk
             except Exception as e:
-                err = {"type": "error", "message": f"خطا در ارتباط رانفلر با سرور اصلی: {str(e)}"}
-                yield (f"data: {json.dumps(err)}\n\n").encode('utf-8')
+                err = f"data: {json.dumps({'type': 'error', 'message': f'خطا در ارتباط رانفلر با سرور اصلی: {str(e)}'})}\n\n"
+                yield err.encode('utf-8')
 
         headers = {
             "Cache-Control": "no-cache, no-transform",
             "X-Accel-Buffering": "no",
-            "Connection": "keep-alive"
+            "Connection": "keep-alive",
+            "Transfer-Encoding": "chunked"
         }
         return StreamingResponse(stream_generator(), media_type="text/event-stream", headers=headers)
     except Exception as e:
@@ -448,7 +451,7 @@ def get_hf_headers(request: Request):
         "Accept": "application/json"
     }
     
-    # کپی کردن هدر Content-Type برای پارس شدن صحیح فایل‌های ارسالی کاربران در فلاسک
+    # 🟢 کپی کردن هدر Content-Type برای پارس شدن صحیح فایل‌های ارسالی کاربران در فلاسک
     if "content-type" in request.headers:
         headers["Content-Type"] = request.headers["content-type"]
         
@@ -459,17 +462,20 @@ def get_hf_headers(request: Request):
         headers["X-Forwarded-For"] = request.client.host
     return headers
 
-HF_PODCAST_SPACE_URL = "https://sada8888-tts2.hf.space"
+
+# =================================================================
+# 4. بازنشانی آدرس‌ها و وب‌هوک‌های محلی اکشنز (جایگزین sada8888-tts3)
+# =================================================================
 
 @app.post("/api/generate")
 async def submit_job(request: Request, background_tasks: BackgroundTasks):
     payload = await request.json()
     headers = get_hf_headers(request)
 
-    # تشخیص هوشمند درخواست تولید عکس (فراخوانی همگام و ایمن فلاسکِ اکشن)
+    # 🟢 تشخیص هوشمند درخواست تولید عکس (فراخوانی همگام و ایمن فلاسکِ اکشن)
     if "action_name" in payload and "prompt" in payload:
         try:
-            # استفاده از ترنسپورت همگامِ WSGITransport به همراه Client معمولی جهت پیشگیری از خطای ناهمگامی
+            # 🟢 استفاده از ترنسپورت همگامِ WSGITransport به همراه Client معمولی جهت پیشگیری از خطای ناهمگامی
             transport = httpx.WSGITransport(app=action.app)
             with httpx.Client(transport=transport, base_url="http://local", timeout=120.0) as client:
                 resp = client.post("/api/generate", json=payload, headers=headers)
@@ -581,7 +587,7 @@ async def smart_check_credit(request: Request):
                 resp = await client.post(url, json=payload, headers=headers)
                 return JSONResponse(resp.json(), status_code=resp.status_code)
         else:
-            # فراخوانی مستقیم و داخلی فلاسک رانفلر با WSGITransport و کلاینت همگام
+            # 🟢 فراخوانی مستقیم و داخلی فلاسک رانفلر با WSGITransport و کلاینت همگام
             transport = httpx.WSGITransport(app=action.app)
             with httpx.Client(transport=transport, base_url="http://local", timeout=30.0) as client:
                 resp = client.post("/api/check-credit", json=payload, headers=headers)
@@ -602,7 +608,7 @@ async def smart_use_credit(request: Request):
                 resp = await client.post(url, json=payload, headers=headers)
                 return JSONResponse(resp.json(), status_code=resp.status_code)
         else:
-            # فراخوانی مستقیم و داخلی فلاسک رانفلر با WSGITransport و کلاینت همگام
+            # 🟢 فراخوانی مستقیم و داخلی فلاسک رانفلر با WSGITransport و کلاینت همگام
             transport = httpx.WSGITransport(app=action.app)
             with httpx.Client(transport=transport, base_url="http://local", timeout=30.0) as client:
                 resp = client.post("/api/use-credit", json=payload, headers=headers)
@@ -694,6 +700,14 @@ async def serve_edit_studio():
             return FileResponse(path)
     return HTMLResponse("<h1>خطا: فایل edit.html پیدا نشد!</h1>", status_code=404)
 
+@app.get("/ttspro", response_class=HTMLResponse)
+@app.get("/ttspro/", response_class=HTMLResponse)
+async def serve_ttspro():
+    for path in ["ttspro.html", "templates/ttspro.html"]:
+        if os.path.exists(path):
+            return FileResponse(path)
+    return HTMLResponse("<h1>خطا: فایل ttspro.html پیدا نشد!</h1>", status_code=404)
+
 # --- مسیرهای اعتبار اختصاصی تصاویر ---
 @app.post("/api/check-image-credit")
 async def proxy_check_image_credit(request: Request):