Update app/byps_logic.py

app/byps_logic.py

@@ -1,6 +1,7 @@
 import asyncio
 import random
 from playwright.async_api import async_playwright
+from playwright_stealth import stealth_async
 
 class BypsApp:
     def __init__(self):
@@ -15,60 +16,67 @@ 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, 
+            headless=False, # Bắt buộc dùng Xvfb
             proxy=self.proxy_config,
-            args=[
-                "--no-sandbox",
-                "--disable-blink-features=AutomationControlled",
-                "--disable-dev-shm-usage"
-            ]
+            args=["--no-sandbox", "--disable-setuid-sandbox"]
         )
 
         context = await browser.new_context(
-            viewport={'width': 1280, 'height': 720},
+            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()
-
-        await page.add_init_script("Object.defineProperty(navigator, 'webdriver', {get: () => undefined})")
+        # Áp dụng Stealth để giả lập trình duyệt người dùng thật
+        await stealth_async(page)
 
         try:
-            print(f"[BYPS] Accessing: {url}")
-            await page.goto(url, wait_until="commit", timeout=60000)
+            await page.goto(url, wait_until="domcontentloaded", timeout=60000)
             
-            for i in range(10):
+            # Vòng lặp cực mạnh để xử lý Turnstile
+            for i in range(20):
                 content = await page.content()
                 title = await page.title()
                 
                 if "just a moment" not in title.lower() and "cloudflare" not in content.lower():
+                    print("[BYPS] Đã vượt thành công!")
                     break
                 
-                print(f"[BYPS] Chờ Cloudflare... {i+1}s")
-                await page.mouse.move(random.randint(0, 500), random.randint(0, 500))
+                # THÀNH BẠI Ở ĐÂY: Tìm Iframe của Turnstile và Click
+                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()
+                            if box:
+                                await page.mouse.click(box['x'] + box['width']/2, box['y'] + box['height']/2)
+                                print("[BYPS] Đã click vào Verify Checkbox")
+                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)
 
-            await asyncio.sleep(2)
+            # Chờ thêm 1 chút để dữ liệu tải xong
+            await page.wait_for_load_state("networkidle", timeout=5000)
             
             final_content = await page.content()
             
+            # Check JSON
             try:
-                json_content = await page.evaluate("() => JSON.parse(document.querySelector('body').innerText)")
-                return {"ok": True, "type": "json", "data": json_content}
+                json_data = await page.evaluate("() => JSON.parse(document.querySelector('pre').innerText)")
+                return {"ok": True, "type": "json", "data": json_data}
             except:
                 return {"ok": True, "type": "html", "data": final_content}
 
         except Exception as e:
             return {"ok": False, "error": str(e)}
         finally:
-            await browser.close()
+            await browser.close()