Update app/byps_logic.py

app/byps_logic.py

@@ -16,67 +16,87 @@ class BypsApp:
         if not self.playwright:
             self.playwright = await async_playwright().start()
 
+    async def stop(self):
+        if self.playwright:
+            await self.playwright.stop()
+            self.playwright = None
+
     async def fetch(self, url: str):
-        if not self.playwright: await self.start()
+        if not self.playwright:
+            await self.start()
 
-        browser = await self.playwright.chromium.launch(
-            headless=False, # Bắt buộc dùng Xvfb
-            proxy=self.proxy_config,
-            args=["--no-sandbox", "--disable-setuid-sandbox"]
-        )
+        browser = None
+        try:
+            # Khởi tạo browser với các tham số chống bot mạnh nhất
+            browser = await self.playwright.chromium.launch(
+                headless=False, # Phải dùng False vì chạy qua Xvfb
+                args=[
+                    "--no-sandbox",
+                    "--disable-setuid-sandbox",
+                    "--disable-dev-shm-usage",
+                    "--disable-blink-features=AutomationControlled",
+                    "--use-gl=egl", 
+                ]
+            )
 
-        context = await browser.new_context(
-            viewport={'width': 1920, 'height': 1080},
-            user_agent="Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/122.0.0.0 Safari/537.36"
-        )
-        
-        page = await context.new_page()
-        # Áp dụng Stealth để giả lập trình duyệt người dùng thật
-        await stealth(page)
+            context = await browser.new_context(
+                viewport={'width': 1280, 'height': 720},
+                user_agent="Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/122.0.0.0 Safari/537.36"
+            )
+            
+            page = await context.new_page()
+            
+            # Kích hoạt Stealth mode chống detect Playwright
+            await stealth(page)
 
-        try:
-            await page.goto(url, wait_until="domcontentloaded", timeout=60000)
+            print(f"[BYPS] Đang truy cập: {url}")
+            # Tăng timeout lên 90s vì Cloudflare giải rất lâu
+            await page.goto(url, wait_until="commit", timeout=90000)
             
-            # Vòng lặp cực mạnh để xử lý Turnstile
-            for i in range(20):
+            # Vòng lặp kiểm tra và giải Challenge
+            for i in range(15):
                 content = await page.content()
                 title = await page.title()
                 
+                # Check nếu đã vượt qua lớp bảo vệ
                 if "just a moment" not in title.lower() and "cloudflare" not in content.lower():
-                    print("[BYPS] Đã vượt thành công!")
+                    print(f"[BYPS] Thành công sau {i*2}s")
                     break
                 
-                # THÀNH BẠI Ở ĐÂY: Tìm Iframe của Turnstile và Click
+                # Thử tìm và click vào checkbox Turnstile nếu có
                 try:
-                    # Cloudflare thường giấu checkbox trong một iframe
-                    frames = page.frames
-                    for frame in frames:
-                        if "turnstile" in frame.url or "challenges" in frame.url:
-                            # Thử click vào tọa độ giữa của iframe đó
-                            box = await page.locator('iframe[src*="challenge"]').bounding_box()
+                    for frame in page.frames:
+                        if "challenge" in frame.url or "turnstile" in frame.url:
+                            # Lấy vị trí của iframe để click vào giữa
+                            target = page.locator('iframe[src*="challenge"]')
+                            box = await target.bounding_box()
                             if box:
                                 await page.mouse.click(box['x'] + box['width']/2, box['y'] + box['height']/2)
-                                print("[BYPS] Đã click vào Verify Checkbox")
+                                print("[BYPS] Đã click vào tọa độ Captcha")
                 except:
                     pass
 
-                # Di chuyển chuột ngẫu nhiên để mô phỏng người thật
-                await page.mouse.move(random.randint(100, 700), random.randint(100, 700))
-                await asyncio.sleep(2)
+                # Giả lập hành vi người dùng: di chuyển chuột và cuộn
+                await page.mouse.move(random.randint(100, 600), random.randint(100, 600))
+                await page.mouse.wheel(0, 200)
+                await asyncio.sleep(3)
 
-            # Chờ thêm 1 chút để dữ liệu tải xong
-            await page.wait_for_load_state("networkidle", timeout=5000)
+            # Đợi một chút cho dữ liệu load hết sau khi bypass
+            await asyncio.sleep(2)
             
             final_content = await page.content()
             
-            # Check JSON
+            # Kiểm tra xem kết quả là JSON hay HTML
             try:
-                json_data = await page.evaluate("() => JSON.parse(document.querySelector('pre').innerText)")
+                # Nếu trang trả về JSON thô (thường nằm trong thẻ <pre>)
+                json_data = await page.evaluate("() => JSON.parse(document.querySelector('body').innerText)")
                 return {"ok": True, "type": "json", "data": json_data}
             except:
                 return {"ok": True, "type": "html", "data": final_content}
 
         except Exception as e:
+            print(f"[BYPS ERROR] {str(e)}")
             return {"ok": False, "error": str(e)}
         finally:
-            await browser.close()
+            if browser:
+                await browser.close()