Spaces:

Opera8
/

Tsj

Sleeping

App Files Files Community

Opera8 commited on 26 days ago

Commit

0db564c

verified ·

1 Parent(s): 6b67ee9

Update app.py

Browse files

Files changed (1) hide show

app.py +28 -27

app.py CHANGED Viewed

@@ -17,7 +17,7 @@ HTML_CHAT_INTERFACE = """
 <head>
     <meta charset="UTF-8">
     <meta name="viewport" content="width=device-width, initial-scale=1.0">
-    <title>Google AI Free Chatbot + Hybrid Streaming</title>
     <style>
         :root {
             --bg-gradient: linear-gradient(135deg, #0f172a 0%, #1e293b 100%);
@@ -153,7 +153,7 @@ HTML_CHAT_INTERFACE = """
             try {
                 const response = await fetch('/api/chat', { method: 'POST', body: formData });
                 if (!response.ok) {
-                    aiMessageDiv.innerText = "خطا در ارتباط با گوگل یا مسدود شدن آی‌پورت سرور.";
                     setLoading(false);
                     return;
                 }
@@ -210,37 +210,40 @@ HTML_CHAT_INTERFACE = """
 </html>
 """
-# الگوریتم فیلتر رادیکال و هوشمند کلمات ناوبری گوگل سرچ بر اساس ساختار Substring
 def clean_text(full_text: str, message: str) -> str:
     if "ترافیک غیر عادی" in full_text or "Our systems have detected unusual traffic" in full_text:
         return "🚨 سیستم امنیتی گوگل فعال شد و آی‌پی سرور هاگینگ‌فیس را مسدود کرد (کپچا رخ داد)."
     lines = full_text.split('\n')
-    # کلمات کلیدی مخرب و زائد هدر و فوتر لایه‌های موبایل گوگل
     junk_keywords = [
         "حالت هوشواره", "هوژواره", "ایمیل کنید", "تصاویر", "ویدیو", "ویدئو", "اخبار",
         "نقشه", "خرید", "کتاب", "مالی", "موضوع‌محور", "ورود", "ارسال", "همه",
-        "آماده است", "items removed", "بیشتر بدانید", "محتمل است", "هویشواره", "هرچه می‌خواهید"
     ]
-    # فاز اول: فیلتر اولیه خطوط بر اساس کلمات کلیدی زائد و متوقف کردن اسکن در بخش فوتر
     filtered_lines = []
     for line in lines:
         line_str = line.strip()
         if not line_str:
             continue
-        if "هوشواره ممکن است اشتباه" in line_str or "در پاسخ‌های" in line_str or "بیشتر بدانید" in line_str:
             break
         if any(junk in line_str for junk in junk_keywords):
             continue
         filtered_lines.append(line_str)
-    # فاز دوم: برش قطعی از بالای سرِ پیام کاربر برای پاکسازی کامل لایه‌های بالایی
     final_lines = []
     found_query_anchor = False
     for line in filtered_lines:
-        # اگر خط جاری شامل یا بخشی از پیام کاربر بود، کل دیتای فیلتر شده قبلی (هدرها) را پاک کن
         if not found_query_anchor and (message.lower() in line.lower() or line.lower() in message.lower()):
             found_query_anchor = True
             final_lines = []
@@ -267,7 +270,6 @@ 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():
         async with async_playwright() as p:
             browser = await p.chromium.launch(
@@ -294,44 +296,44 @@ async def chat_endpoint(message: str = Form(...), image: UploadFile = File(None)
             page = await context.new_page()
             try:
-                # 🧭 پیاده‌سازی معماری ترکیبی (Hybrid Routing)
                 if saved_image_path and os.path.exists(saved_image_path):
-                    # اگر تصویر وجود دارد: ابتدا لود کردن صفحه خالی چت‌باکس هوشواره گوگل
-                    print("🖼 روند آپلود و تحلیل تصویر مالتی‌مدال فعال شد.")
                     await page.goto("https://www.google.com/search?q=سلام&udm=50", wait_until="domcontentloaded", timeout=30000)
                     await page.wait_for_timeout(1000)
-                    # کلیک روی کادر متنی برای مطمئن شدن از ظاهر شدن دکمه پلاس/دوربین در لایه وب گوگل
                     init_input = await page.query_selector("textarea, input[type='text'], [contenteditable='true']")
                     if init_input:
-                        await init_input.click()
                         await page.wait_for_timeout(500)
-                    # آپلود مطمئن تصویر به المان فایل آپلودر گوگل لنز
                     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)
-                    # نوشتن دستور متنی مربوط به تصویر درون کادر اصلی
                     input_box = await page.query_selector("textarea, input[type='text'], [contenteditable='true']")
                     if input_box:
                         await input_box.focus()
                         await input_box.fill(message)
-                        await page.wait_for_timeout(200)
                         await input_box.press("Enter")
                 else:
-                    # اگر فقط متن است: لود ضربتی و آنی مستقیماً از طریق آدرس URL (سرعت زیر ۲ ثانیه)
-                    print("📝 روند لود مستقیم کوئری متنی فعال شد.")
                     url = f"https://www.google.com/search?q={message}&udm=50"
                     await page.goto(url, wait_until="domcontentloaded", timeout=30000)
-                # ⚡ فرآیند شنود و استریمینگ آنی کلمات (Real-time Scraping Pool)
                 last_sent_text = ""
                 no_change_count = 0
                 for _ in range(50):
-                    await page.wait_for_timeout(300) # فایر کردن هر ۳۰۰ میلی‌ثانیه برای استریم کلمات
                     full_text = await page.evaluate("() => document.body.innerText")
                     current_clean_text = clean_text(full_text, message)
@@ -339,7 +341,7 @@ async def chat_endpoint(message: str = Form(...), image: UploadFile = File(None)
                         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
@@ -349,7 +351,6 @@ async def chat_endpoint(message: str = Form(...), image: UploadFile = File(None)
                         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)
@@ -361,7 +362,7 @@ async def chat_endpoint(message: str = Form(...), image: UploadFile = File(None)
                         break
             except Exception as e:
-                yield f"خطای پردازش هوش مصنوعی: {str(e)}"
             finally:
                 await context.close()
                 await browser.close()

 <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%);
             try {
                 const response = await fetch('/api/chat', { method: 'POST', body: formData });
                 if (!response.ok) {
+                    aiMessageDiv.innerText = "خطا در ارتباط با گوگل یا مسدود شدن آی‌پی سرور.";
                     setLoading(false);
                     return;
                 }
 </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 "🚨 سیستم امنیتی گوگل فعال شد و آی‌پی سرور هاگینگ‌فیس را مسدود کرد (کپچا رخ داد)."
     lines = full_text.split('\n')
+    # کلمات کلیدی و جملات خوش‌آمدگویی پیش‌فرض گوگل که کلاً باید فیلتر شوند
     junk_keywords = [
         "حالت هوشواره", "هوژواره", "ایمیل کنید", "تصاویر", "ویدیو", "ویدئو", "اخبار",
         "نقشه", "خرید", "کتاب", "مالی", "موضوع‌محور", "ورود", "ارسال", "همه",
+        "آماده است", "items removed", "بیشتر بدانید", "محتمل است", "هویشواره", "هرچه می‌خواهید",
+        "پاسخ به سوالات علمی", "نگارش، ویرایش یا ترجمه", "برنامه‌نویسی و حل مسائل",
+        "ایده‌پردازی و کارهای خلاقانه", "لطفاً موضوع مورد نظرتون", "روزتون بخیر. من دستیار هوش مصنوعی",
+        "امروز چطور می‌تونم کمکتون کنم", "نیاز به راهنمایی دارید", "در چه زمینه‌ای نیاز",
+        "شما تصویر، متن یا فایلی ارسال نکردید", "متوجه منظور دقیق شما نشدم"
     ]
+    # فاز ۱: فیلتر کلمات هدر و متوقف شدن حلقه در ابتدای بدنه فوتر سلب مسئولیت
     filtered_lines = []
     for line in lines:
         line_str = line.strip()
         if not line_str:
             continue
+        if "هوشواره ممکن است اشتباه" in line_str or "در پاسخ‌های" in line_str or "بیشتر بدانید" in line_str or "پاسخ «حالت" in line_str:
             break
         if any(junk in line_str for junk in junk_keywords):
             continue
         filtered_lines.append(line_str)
+    # فاز ۲: برش قطعی لایه‌های بالای متن پاسخ بر اساس تطابق لنگر پیام کاربر
     final_lines = []
     found_query_anchor = False
     for line in filtered_lines:
         if not found_query_anchor and (message.lower() in line.lower() or line.lower() in message.lower()):
             found_query_anchor = True
             final_lines = []
         except Exception as e:
             return StreamingResponse(iter([f"خطا در ذخیره تصویر روی داکر: {str(e)}"]), media_type="text/plain")
     async def response_generator():
         async with async_playwright() as p:
             browser = await p.chromium.launch(
             page = await context.new_page()
             try:
+                # مانیتورینگ مسیر ترکیبی بر اساس وجود فایل مالتی‌مدال
                 if saved_image_path and os.path.exists(saved_image_path):
+                    # اگر تصویر وجود دارد: ابتدا لود کردن کادر چت اصلی گوگل هوشواره
                     await page.goto("https://www.google.com/search?q=سلام&udm=50", wait_until="domcontentloaded", timeout=30000)
                     await page.wait_for_timeout(1000)
+                    # فعال‌سازی کادر چت با کلیک اجباری (بدون ارور تایم‌اوت)
                     init_input = await page.query_selector("textarea, input[type='text'], [contenteditable='true']")
                     if init_input:
+                        await init_input.click(force=True, timeout=2000)
                         await page.wait_for_timeout(500)
+                    # تزریق مستقیم فایل به لایه آپلودر بومی
                     file_input = await page.query_selector("input[type='file']")
                     if file_input:
                         await file_input.set_input_files(saved_image_path)
+                        # شلیک دستی رویداد change به کامپوننت لنز گوگل تا فورا متوجه حضور عکس بشود
+                        await page.evaluate("el => el.dispatchEvent(new Event('change', { bubbles: true }))", file_input)
+                        await page.wait_for_timeout(2000)
+                    # نوشتن پیام متنی کاربر
                     input_box = await page.query_selector("textarea, input[type='text'], [contenteditable='true']")
                     if input_box:
                         await input_box.focus()
                         await input_box.fill(message)
+                        await page.wait_for_timeout(300)
                         await input_box.press("Enter")
                 else:
+                    # اگر فقط متن است: لود سریع و مستقیم از طریق URL کوئری (سرعت زیر ۲ ثانیه)
                     url = f"https://www.google.com/search?q={message}&udm=50"
                     await page.goto(url, wait_until="domcontentloaded", timeout=30000)
+                # ⚡ حلقه شنود استریم فوق سریع
                 last_sent_text = ""
                 no_change_count = 0
                 for _ in range(50):
+                    await page.wait_for_timeout(300)
                     full_text = await page.evaluate("() => document.body.innerText")
                     current_clean_text = clean_text(full_text, message)
                         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
                         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)
                         break
             except Exception as e:
+                yield f"خطای پردازش مرورگر: {str(e)}"
             finally:
                 await context.close()
                 await browser.close()