Spaces:

Opera8
/

Tsj

Sleeping

App Files Files Community

Opera8 commited on 20 days ago

Commit

66d9fd6

verified ·

1 Parent(s): 8bd13e5

Update app.py

Browse files

Files changed (1) hide show

app.py +120 -132

app.py CHANGED Viewed

@@ -5,46 +5,19 @@ import uvicorn
 from fastapi import FastAPI, Form, File, UploadFile
 from fastapi.responses import HTMLResponse, StreamingResponse
 from playwright.async_api import async_playwright
-from contextlib import asynccontextmanager
 UPLOAD_DIR = "temp_uploads"
 os.makedirs(UPLOAD_DIR, exist_ok=True)
-global_browser = None
-pw_instance = None
-@asynccontextmanager
-async def lifespan(app: FastAPI):
-    global global_browser, pw_instance
-    print("⚡ در حال راه‌اندازی مرورگر سراسری کروم...")
-    pw_instance = await async_playwright().start()
-    global_browser = await pw_instance.chromium.launch(
-        headless=True,
-        args=[
-            "--no-sandbox",
-            "--disable-setuid-sandbox",
-            "--disable-dev-shm-usage",
-            "--disable-blink-features=AutomationControlled"
-        ]
-    )
-    print("🚀 مرورگر سراسری با موفقیت لود شد.")
-    yield
-    print("🛑 در حال بستن مرورگر سراسری...")
-    if global_browser:
-        await global_browser.close()
-    if pw_instance:
-        await pw_instance.stop()
-app = FastAPI(lifespan=lifespan)
-# رابط کاربری با قابلیت خواندن استریم باینری پاسخ‌ها با استفاده از ReadableStream فرچ
 HTML_CHAT_INTERFACE = """
 <!DOCTYPE html>
 <html lang="fa" dir="rtl">
 <head>
     <meta charset="UTF-8">
     <meta name="viewport" content="width=device-width, initial-scale=1.0">
-    <title>Google AI Free Chatbot + Streaming</title>
     <style>
         :root {
             --bg-gradient: linear-gradient(135deg, #0f172a 0%, #1e293b 100%);
@@ -173,25 +146,20 @@ HTML_CHAT_INTERFACE = """
             formData.append('message', text || "این تصویر را تحلیل کن");
             if (file) formData.append('image', file);
-            // ایجاد حباب خالی هوش مصنوعی برای آماده‌سازی فرآیند تایپ زنده
             const aiMessageDiv = document.createElement('div');
             aiMessageDiv.classList.add('message', 'ai');
             messagesBox.appendChild(aiMessageDiv);
             try {
                 const response = await fetch('/api/chat', { method: 'POST', body: formData });
                 if (!response.ok) {
-                    aiMessageDiv.innerText = "خطا در برقراری ارتباط با سرور گوگل.";
                     setLoading(false);
                     return;
                 }
-                // خواندن باینری استریم کلمه به کلمه خروجی پایتون
                 const reader = response.body.getReader();
                 const decoder = new TextDecoder("utf-8");
-                // پنهان کردن انیمیشن لودینگ به محض شروع اولین کلمه دریافتی
                 let firstChunk = true;
                 while (true) {
@@ -201,7 +169,6 @@ HTML_CHAT_INTERFACE = """
                     const chunk = decoder.decode(value, { stream: true });
                     if (chunk) {
                         if (firstChunk) {
-                            // حذف لودینگ سه نقطه‌ای
                             const indicator = document.getElementById('typingIndicator');
                             if (indicator) indicator.remove();
                             firstChunk = false;
@@ -243,20 +210,23 @@ HTML_CHAT_INTERFACE = """
 </html>
 """
-# الگوریتم مهندسی معکوس برای استخراج و تصفیه متن خالص پاسخ هوش مصنوعی
 def clean_text(full_text: str, message: str) -> str:
     lines = full_text.split('\n')
     cleaned_lines = []
-    # واژه‌های کاربری منوهای ناوبری که نباید به هیچ وجه نشت پیدا کنند
     global_junk = ["تصاویر", "ویدیوها", "اخبار", "نقشه‌ها", "خرید کردن", "کتاب‌ها", "مالی", "حالت موضوع‌محور", "ورود", "همه", "ویدئوها", "ارسال", "پاسخ «حالت هوشواره‌ای» آماده است", "All items removed", message]
     for line in lines:
         line_str = line.strip()
         if not line_str or line_str in global_junk:
             continue
-        # به محض رسیدن به لایه فوتر سلب مسئولیت، کلاً خواندن را قطع کن
-        if "هوشواره ممکن است اشتباه" in line_str or "در پاسخ‌های" in line_str or "بیشتر بدانید" in line_str:
             break
         cleaned_lines.append(line_str)
@@ -268,10 +238,6 @@ async def chat_interface():
 @app.post("/api/chat")
 async def chat_endpoint(message: str = Form(...), image: UploadFile = File(None)):
-    global global_browser
-    if not global_browser:
-        return StreamingResponse(iter(["خطا: وب سرور کروم فعال نیست."]), media_type="text/plain")
     saved_image_path = None
     if image:
         try:
@@ -281,103 +247,125 @@ async def chat_endpoint(message: str = Form(...), image: UploadFile = File(None)
         except Exception as e:
             return StreamingResponse(iter([f"خطا در ذخیره تصویر روی داکر: {str(e)}"]), media_type="text/plain")
-    # ساخت سشن ژنراتور استریمینگ زنده کلمات برای پاسخ در لحظه
     async def response_generator():
-        # استفاده از domcontentloaded برای بالا بردن سرعت اولیه رندر فرم‌ها بدون معطلی تصاویر حجیم
-        context = await global_browser.new_context(
-            user_agent="Mozilla/5.0 (Linux; Android 10; K) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/122.0.0.0 Mobile Safari/537.36",
-            viewport={"width": 412, "height": 915},
-            locale="fa-IR", timezone_id="Asia/Tehran"
-        )
-        page = await context.new_page()
-        try:
-            url = "https://www.google.com/search?q=سلام&udm=50"
-            await page.goto(url, wait_until="domcontentloaded", timeout=30000)
-            # تزریق ۱۰۰٪ پناهنده فایل به اینپوت‌های مخفی لایه وب گوگل
-            if saved_image_path and os.path.exists(saved_image_path):
-                try:
-                    file_input = await page.query_selector("input[type='file']")
-                    if file_input:
-                        await file_input.set_input_files(saved_image_path)
-                        await page.wait_for_timeout(1500)
-                except Exception as e:
-                    print(f"Bypassed image setup: {e}")
-            # درج کوئری متنی کاربر درون کادر چت
-            input_box = None
-            candidates = await page.query_selector_all("textarea, input, [contenteditable='true']")
-            for el in candidates:
-                try:
-                    if await el.is_visible():
-                        placeholder = await el.get_attribute("placeholder") or ""
-                        if any(w in placeholder for w in ["بپرسید", "ask", "پیام", "چطور", "هرچه"]):
-                            input_box = el
-                            break
-                except:
-                    continue
-            if not input_box:
-                input_box = await page.query_selector("textarea") or await page.query_selector("input[type='text']")
-            if input_box:
-                await input_box.focus()
-                await input_box.fill(message)
-                await page.wait_for_timeout(300)
-                await input_box.press("Enter")
-                # فایر کردن دکمه فیزیکی ارسال جهت اطمینان فرم در کلاینت‌های کند
-                try:
-                    send_buttons = await page.query_selector_all("button, [role='button']")
-                    for btn in send_buttons:
-                        if await btn.is_visible():
-                            aria = (await btn.get_attribute("aria-label") or "").lower()
-                            if any(w in aria for w in ["send", "ارسال", "arrow", "up"]):
-                                await btn.click(timeout=1000)
                                 break
-                except:
-                    pass
-            # 🚀 حلقه مانیتورینگ استریمینگ: واکشی کلمات در زمان واقعی بدون ثانیه‌ای معطلی ثمر بخش
-            last_sent_text = ""
-            no_change_count = 0
-            for _ in range(40): # حداکثر ۱۶ ثانیه پایش زنده صفحه
-                await page.wait_for_timeout(400) # بررسی صفحه هر ۴۰۰ میلی‌ثانیه برای استریم فوق سریع
-                full_text = await page.evaluate("() => document.body.innerText")
-                current_clean_text = clean_text(full_text, message)
-                # اگر متن جدیدی تایپ شده بود، تفاوت آن را فوراً روانه کلاینت کن
-                if len(current_clean_text) > len(last_sent_text):
-                    new_chunk = current_clean_text[len(last_sent_text):]
-                    yield new_chunk
-                    last_sent_text = current_clean_text
-                    no_change_count = 0
-                else:
-                    if len(current_clean_text) > 0:
-                        no_change_count += 1
-                # اگر کادر هشدار گوگل لود شده بود یا تایپ متن به پایان رسیده بود، استریم را ببند
-                if "هوشواره ممکن است اشتباه" in full_text or "بیشتر بدانید" in full_text or "پاسخ‌های مربوط به افراد" in full_text:
-                    # ارسال نهایی باقیمانده کاراکترها برای احتیاط
                     full_text = await page.evaluate("() => document.body.innerText")
                     current_clean_text = clean_text(full_text, message)
                     if len(current_clean_text) > len(last_sent_text):
-                        yield current_clean_text[len(last_sent_text):]
-                    break
-                # اگر برای ۳ ثانیه هیچ متنی اضافه نشد یعنی پاسخ متوقف شده است
-                if no_change_count > 7 and len(last_sent_text) > 0:
-                    break
-        except Exception as e:
-            yield f"خطای پردازش هوش مصنوعی: {str(e)}"
-        finally:
-            await context.close()
-            if saved_image_path and os.path.exists(saved_image_path):
-                try: os.remove(saved_image_path)
-                except: pass
     return StreamingResponse(response_generator(), media_type="text/event-stream")

 from fastapi import FastAPI, Form, File, UploadFile
 from fastapi.responses import HTMLResponse, StreamingResponse
 from playwright.async_api import async_playwright
+app = FastAPI()
 UPLOAD_DIR = "temp_uploads"
 os.makedirs(UPLOAD_DIR, exist_ok=True)
+# رابط کاربری شیشه‌ای (Glassmorphism) با فرانت‌اند پایدار
 HTML_CHAT_INTERFACE = """
 <!DOCTYPE html>
 <html lang="fa" dir="rtl">
 <head>
     <meta charset="UTF-8">
     <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <title>Google AI Free Chatbot + Stealth Streaming</title>
     <style>
         :root {
             --bg-gradient: linear-gradient(135deg, #0f172a 0%, #1e293b 100%);
             formData.append('message', text || "این تصویر را تحلیل کن");
             if (file) formData.append('image', file);
             const aiMessageDiv = document.createElement('div');
             aiMessageDiv.classList.add('message', 'ai');
             messagesBox.appendChild(aiMessageDiv);
             try {
                 const response = await fetch('/api/chat', { method: 'POST', body: formData });
                 if (!response.ok) {
+                    aiMessageDiv.innerText = "خطا در برقراری ارتباط با سرور یا مسدود شدن آی‌پی توسط گوگل.";
                     setLoading(false);
                     return;
                 }
                 const reader = response.body.getReader();
                 const decoder = new TextDecoder("utf-8");
                 let firstChunk = true;
                 while (true) {
                     const chunk = decoder.decode(value, { stream: true });
                     if (chunk) {
                         if (firstChunk) {
                             const indicator = document.getElementById('typingIndicator');
                             if (indicator) indicator.remove();
                             firstChunk = false;
 </html>
 """
+# الگوریتم تصفیه رادیکال: فیلتر کامل المان‌های زائد هدر/فوتر و استخراج متن ۱۰۰٪ خالص
 def clean_text(full_text: str, message: str) -> str:
+    if "ترافیک غیر عادی" in full_text or "Our systems have detected unusual traffic" in full_text:
+        return "🚨 سیستم امنیتی گوگل فعال شد و آی‌پی سرور هاگینگ‌فیس را مسدود کرد (کپچا رخ داد).\nبرای حل دائمی این مشکل باید روی داکر از پراکسی مسکونی (Residential Proxy) استفاده کنیم."
     lines = full_text.split('\n')
     cleaned_lines = []
+    # واژه‌های منوهای سرچ گوگل که نباید وارد پاسخ چت‌باکس شوند
     global_junk = ["تصاویر", "ویدیوها", "اخبار", "نقشه‌ها", "خرید کردن", "کتاب‌ها", "مالی", "حالت موضوع‌محور", "ورود", "همه", "ویدئوها", "ارسال", "پاسخ «حالت هوشواره‌ای» آماده است", "All items removed", message]
     for line in lines:
         line_str = line.strip()
         if not line_str or line_str in global_junk:
             continue
+        # کات کردن پاسخ به محض رسیدن به پاپ‌آپ‌ها یا فوتر سلب مسئولیت گوگل
+        if "هوشواره ممکن است اشتباه" in line_str or "در پاسخ‌های" in line_str or "بیشتر بدانید" in line_str or "پاسخ «حالت" in line_str:
             break
         cleaned_lines.append(line_str)
 @app.post("/api/chat")
 async def chat_endpoint(message: str = Form(...), image: UploadFile = File(None)):
     saved_image_path = None
     if image:
         try:
         except Exception as e:
             return StreamingResponse(iter([f"خطا در ذخیره تصویر روی داکر: {str(e)}"]), media_type="text/plain")
+    # ساخت سشن داینامیک: لود مرورگر واقعی و تازه برای هر درخواست کلاینت (عین گام اول برای فرار از ردگیری سشن)
     async def response_generator():
+        async with async_playwright() as p:
+            # لانچ مرورگر نو با لایه‌های ضد ردگیری (Anti-Automation Footprint)
+            browser = await p.chromium.launch(
+                headless=True,
+                args=[
+                    "--no-sandbox",
+                    "--disable-setuid-sandbox",
+                    "--disable-dev-shm-usage",
+                    "--disable-blink-features=AutomationControlled",
+                    "--disable-web-security"
+                ]
+            )
+            # فیک کردن دقیق یوزر ایجنت و هدرهای اورجینال کروم اندروید ۱۳ سامسونگ
+            context = await browser.new_context(
+                user_agent="Mozilla/5.0 (Linux; Android 13; SM-S908B) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/122.0.0.0 Mobile Safari/537.36",
+                viewport={"width": 412, "height": 915},
+                locale="fa-IR", timezone_id="Asia/Tehran",
+                extra_http_headers={
+                    "Accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8",
+                    "Accept-Language": "fa-IR,fa;q=0.9,en-US;q=0.8,en;q=0.7",
+                    "Upgrade-Insecure-Requests": "1"
+                }
+            )
+            page = await context.new_page()
+            try:
+                url = "https://www.google.com/search?q=سلام&udm=50"
+                await page.goto(url, wait_until="domcontentloaded", timeout=30000)
+                # بررسی زنده لود تصویر روی لایه فایل آپلودر گوگل لنز
+                if saved_image_path and os.path.exists(saved_image_path):
+                    try:
+                        file_input = await page.query_selector("input[type='file']")
+                        if file_input:
+                            await file_input.set_input_files(saved_image_path)
+                            await page.wait_for_timeout(1500)
+                    except Exception as e:
+                        print(f"Bypassed image file setup: {e}")
+                # واکشی المنت کادر گفتگو
+                input_box = None
+                candidates = await page.query_selector_all("textarea, input, [contenteditable='true']")
+                for el in candidates:
+                    try:
+                        if await el.is_visible():
+                            placeholder = await el.get_attribute("placeholder") or ""
+                            if any(w in placeholder for w in ["بپرسید", "ask", "پیام", "چطور", "هرچه"]):
+                                input_box = el
                                 break
+                    except:
+                        continue
+                if not input_box:
+                    input_box = await page.query_selector("textarea") or await page.query_selector("input[type='text']")
+                if input_box:
+                    await input_box.focus()
+                    await input_box.fill(message)
+                    await page.wait_for_timeout(300)
+                    await input_box.press("Enter")
+                    # سابمیت مکمل فرم برای کلاینت‌های دیتاسنتری
+                    try:
+                        send_buttons = await page.query_selector_all("button, [role='button']")
+                        for btn in send_buttons:
+                            if await btn.is_visible():
+                                aria = (await btn.get_attribute("aria-label") or "").lower()
+                                if any(w in aria for w in ["send", "ارسال", "arrow", "up"]):
+                                    await btn.click(timeout=1000)
+                                    break
+                    except:
+                        pass
+                # ⚡ حلقه استریم فوق سریع: واکشی خطوط بدون تاخیرهای استاتیک با چکاپ هر ۳۰۰ میلی‌ثانیه
+                last_sent_text = ""
+                no_change_count = 0
+                for _ in range(45):
+                    await page.wait_for_timeout(300)
                     full_text = await page.evaluate("() => document.body.innerText")
                     current_clean_text = clean_text(full_text, message)
+                    # مدیریت خروجی کپچا
+                    if "سیستم امنیتی گوگل فعال شد" in current_clean_text:
+                        yield current_clean_text
+                        break
+                    # استریم کلمات جدید رندر شده روی مرورگر داکر
                     if len(current_clean_text) > len(last_sent_text):
+                        new_chunk = current_clean_text[len(last_sent_text):]
+                        yield new_chunk
+                        last_sent_text = current_clean_text
+                        no_change_count = 0
+                    else:
+                        if len(current_clean_text) > 0:
+                            no_change_count += 1
+                    # خروج سریع به محض پایان یافتن پردازش گوگل
+                    if "هوشواره ممکن است اشتباه" in full_text or "بیشتر بدانید" in full_text or "پاسخ‌های مربوط به افراد" in full_text:
+                        full_text = await page.evaluate("() => document.body.innerText")
+                        current_clean_text = clean_text(full_text, message)
+                        if len(current_clean_text) > len(last_sent_text):
+                            yield current_clean_text[len(last_sent_text):]
+                        break
+                    if no_change_count > 8 and len(last_sent_text) > 0:
+                        break
+            except Exception as e:
+                yield f"خطای پردازش هوش مصنوعی: {str(e)}"
+            finally:
+                await context.close()
+                await browser.close()
+                if saved_image_path and os.path.exists(saved_image_path):
+                    try: os.remove(saved_image_path)
+                    except: pass
     return StreamingResponse(response_generator(), media_type="text/event-stream")