Update app/byps_logic.py

app/byps_logic.py

@@ -1,12 +1,13 @@
 import asyncio
 import random
 from playwright.async_api import async_playwright
-# Sửa cách import này để tránh lỗi 'module' object
-from playwright_stealth import stealth_async 
+# Import hàm stealth (hàm này hỗ trợ cả async)
+from playwright_stealth import stealth 
 
 class BypsApp:
     def __init__(self):
         self.playwright = None
+        # Proxy config của bạn
         self.proxy_config = {
             "server": "http://p.webshare.io:80", 
             "username": "szusjfnw-rotate",
@@ -28,6 +29,7 @@ class BypsApp:
 
         browser = None
         try:
+            # Khởi chạy browser với Xvfb (headless=False)
             browser = await self.playwright.chromium.launch(
                 headless=False,
                 args=[
@@ -45,30 +47,32 @@ class BypsApp:
             
             page = await context.new_page()
             
-            # SỬ DỤNG ĐÚNG HÀM ASYNC
-            await stealth_async(page)
+            # Sử dụng await stealth(page) - ĐÂY LÀ DÒNG QUAN TRỌNG
+            await stealth(page)
 
-            print(f"[BYPS] Đang truy cập: {url}")
+            print(f"[BYPS] Đang mở trang: {url}")
             await page.goto(url, wait_until="commit", timeout=60000)
             
-            # Vòng lặp chờ Cloudflare
+            # Logic vượt Cloudflare (giữ nguyên)
             for i in range(15):
-                content = await page.content()
                 title = await page.title()
+                content = await page.content()
                 
                 if "just a moment" not in title.lower() and "cloudflare" not in content.lower():
-                    print(f"[BYPS] Success!")
+                    print("[BYPS] Đã vượt Cloudflare!")
                     break
                 
-                # Click Turnstile nếu có
+                print(f"[BYPS] Đang chờ giải thử thách... ({i}s)")
+                
+                # Thử click vào checkbox của Turnstile nếu nó hiện ra
                 try:
-                    # Tìm tất cả iframe và thử click vào cái có chứa challenge
-                    frames = page.frames
-                    for frame in frames:
-                        if "challenge" in frame.url:
-                            # Click vào giữa màn hình nếu không xác định được tọa độ chính xác
-                            # Hoặc dùng selector cụ thể hơn
-                            await page.mouse.click(250, 250) 
+                    # Tìm frame chứa challenge
+                    for frame in page.frames:
+                        if "challenge" in frame.url or "turnstile" in frame.url:
+                            # Click đại vào tâm của iframe đó
+                            box = await page.locator('iframe[src*="challenge"]').bounding_box()
+                            if box:
+                                await page.mouse.click(box['x'] + box['width']/2, box['y'] + box['height']/2)
                 except:
                     pass
 
@@ -76,14 +80,12 @@ class BypsApp:
                 await asyncio.sleep(3)
 
             await asyncio.sleep(2)
-            final_content = await page.content()
-            
-            # Trả về kết quả
-            return {"ok": True, "data": final_content}
+            result = await page.content()
+            return {"ok": True, "data": result}
 
         except Exception as e:
             print(f"[BYPS ERROR] {str(e)}")
             return {"ok": False, "error": str(e)}
         finally:
             if browser:
-                await browser.close()
+                await browser.close()