Update app/byps_logic.py

app/byps_logic.py

@@ -1,55 +1,92 @@
-import aiohttp
 import asyncio
-import json
-
-CF_KEYWORDS = [
-    "cloudflare",
-    "__cf_bm",
-    "cf-challenge",
-    "Just a moment"
-]
-
-def is_cloudflare(text: str) -> bool:
-    t = text.lower()
-    return any(k in t for k in CF_KEYWORDS)
-
-
-async def fetch_api(url: str, timeout=15):
-    headers = {
-        "User-Agent": (
-            "Mozilla/5.0 (Windows NT 10.0; Win64; x64) "
-            "AppleWebKit/537.36 (KHTML, like Gecko) "
-            "Chrome/121.0.0.0 Safari/537.36"
-        ),
-        "Accept": "application/json, text/plain, */*",
-        "Accept-Language": "en-US,en;q=0.9",
-        "Referer": "https://ihentai.dog/",
-        "Origin": "https://ihentai.dog",
-        "Connection": "keep-alive",
-    }
-
-    async with aiohttp.ClientSession(headers=headers) as session:
-        async with session.get(url, timeout=timeout) as resp:
-            text = await resp.text()
-
-            # Cloudflare silent bot fight
-            if resp.status in (403, 429) or is_cloudflare(text):
-                return {
-                    "ok": False,
-                    "error": "cloudflare_bot_fight",
-                    "status": resp.status
-                }
-
-            # Try JSON
-            try:
-                data = json.loads(text)
-                return {
-                    "ok": True,
-                    "data": data
-                }
-            except json.JSONDecodeError:
-                return {
-                    "ok": False,
-                    "error": "invalid_json",
-                    "raw": text[:200]
-                }
+import random
+from playwright.async_api import async_playwright
+from playwright_stealth import stealth_async
+
+
+class BypsApp:
+    def __init__(self):
+        self.playwright = None
+        self.proxy_config = {
+            "server": "http://p.webshare.io:80",
+            "username": "szusjfnw-rotate",
+            "password": "mftzj9sljp5t"
+        }
+
+    async def start(self):
+        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()
+
+        browser = None
+        try:
+            browser = await self.playwright.chromium.launch(
+                headless=False,
+                proxy=self.proxy_config,
+                args=[
+                    "--no-sandbox",
+                    "--disable-setuid-sandbox",
+                    "--disable-dev-shm-usage",
+                    "--disable-blink-features=AutomationControlled",
+                ]
+            )
+
+            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()
+
+            await stealth_async(page)
+
+            await page.goto(url, wait_until="domcontentloaded", timeout=60000)
+
+            for i in range(15):
+                title = await page.title()
+                html = await page.content()
+
+                if "just a moment" not in title.lower() and "cloudflare" not in html.lower():
+                    break
+
+                try:
+                    for frame in page.frames:
+                        if "challenge" in frame.url or "turnstile" in frame.url:
+                            box = await page.locator(
+                                'iframe[src*="challenge"], iframe[src*="turnstile"]'
+                            ).bounding_box()
+                            if box:
+                                await page.mouse.click(
+                                    box["x"] + box["width"] / 2,
+                                    box["y"] + box["height"] / 2
+                                )
+                except:
+                    pass
+
+                await page.mouse.move(
+                    random.randint(100, 600),
+                    random.randint(100, 600)
+                )
+                await asyncio.sleep(3)
+
+            content = await page.content()
+            return {"ok": True, "data": content}
+
+        except Exception as e:
+            return {"ok": False, "error": str(e)}
+
+        finally:
+            if browser:
+                await browser.close()