Rename app/aternos_api.py to app/byps_logic.py

app/aternos_api.py

@@ -1,111 +0,0 @@
-import asyncio
-import random
-from playwright.async_api import async_playwright
-
-class AternosAPI:
-    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 run_action(self, user, pwd, action_type="login"):
-        if not self.playwright:
-            await self.start()
-
-        browser = await self.playwright.chromium.launch(
-            headless=False, 
-            proxy=self.proxy_config,
-            args=["--no-sandbox", "--disable-blink-features=AutomationControlled"]
-        )
-        
-        context = await browser.new_context(
-            viewport={'width': 1366, 'height': 768},
-            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"
-        )
-        page = await context.new_page()
-
-        try:
-            # 1. Vượt Cloudflare
-            print("[INFO] Truy cập Aternos...")
-            await page.goto("https://aternos.org/go", wait_until="domcontentloaded", timeout=60000)
-            
-            for i in range(15):
-                title = await page.title()
-                if "just a moment" not in title.lower():
-                    break
-                await page.mouse.move(random.randint(100, 600), random.randint(100, 600))
-                await asyncio.sleep(2)
-
-            # 2. Nhập liệu
-            print("[INFO] Đang điền form...")
-            user_input = await page.wait_for_selector("input.username", state="visible", timeout=20000)
-            await user_input.click(click_count=3)
-            await page.keyboard.press("Backspace")
-            await page.type("input.username", user, delay=100)
-            
-            await page.type("input.password", pwd, delay=100)
-            
-            # 3. Click Đăng nhập & Đợi chuyển hướng
-            print("[INFO] Click Login...")
-            login_btn = await page.wait_for_selector("button.login-button")
-            
-            # Kết hợp vừa bấm vừa đợi URL thay đổi
-            try:
-                await asyncio.gather(
-                    page.wait_for_url("**/server*", timeout=20000),
-                    login_btn.click(force=True)
-                )
-            except:
-                print("[WARN] Timeout hoặc kẹt chuyển hướng")
-
-            await asyncio.sleep(3)
-            final_url = page.url
-            
-            # Xử lý nếu có danh sách server
-            if "/servers/" in final_url:
-                await page.click(".server-body")
-                await page.wait_for_url("**/server/**", timeout=10000)
-                final_url = page.url
-
-            is_success = "/server" in final_url and "go" not in final_url
-
-            # 4. Thực hiện Action Start/Stop
-            msg = "Login thành công" if is_success else "Thất bại"
-            if is_success and action_type in ["start", "stop"]:
-                target_btn = f"#{action_type}"
-                btn = await page.query_selector(target_btn)
-                if btn and await btn.is_visible():
-                    await btn.click()
-                    if action_type == "start":
-                        try:
-                            confirm = await page.wait_for_selector(".btn-success", timeout=5000)
-                            await confirm.click()
-                            msg = "Server đang khởi động (EULA accepted)"
-                        except:
-                            msg = "Server đang khởi động"
-                    else:
-                        msg = "Server đã bấm dừng"
-
-            return {
-                "ok": is_success,
-                "msg": msg,
-                "url": final_url,
-                "title": await page.title()
-            }
-
-        except Exception as e:
-            return {"ok": False, "error": str(e)}
-        finally:
-            await browser.close()

app/byps_logic.py

@@ -0,0 +1,74 @@
+import asyncio
+import random
+from playwright.async_api import async_playwright
+
+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 = await self.playwright.chromium.launch(
+            headless=False, 
+            proxy=self.proxy_config,
+            args=[
+                "--no-sandbox",
+                "--disable-blink-features=AutomationControlled",
+                "--disable-dev-shm-usage"
+            ]
+        )
+
+        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 page.add_init_script("Object.defineProperty(navigator, 'webdriver', {get: () => undefined})")
+
+        try:
+            print(f"[BYPS] Accessing: {url}")
+            await page.goto(url, wait_until="commit", timeout=60000)
+            
+            for i in range(10):
+                content = await page.content()
+                title = await page.title()
+                
+                if "just a moment" not in title.lower() and "cloudflare" not in content.lower():
+                    break
+                
+                print(f"[BYPS] Chờ Cloudflare... {i+1}s")
+                await page.mouse.move(random.randint(0, 500), random.randint(0, 500))
+                await asyncio.sleep(2)
+
+            await asyncio.sleep(2)
+            
+            final_content = await page.content()
+            
+            try:
+                json_content = await page.evaluate("() => JSON.parse(document.querySelector('body').innerText)")
+                return {"ok": True, "type": "json", "data": json_content}
+            except:
+                return {"ok": True, "type": "html", "data": final_content}
+
+        except Exception as e:
+            return {"ok": False, "error": str(e)}
+        finally:
+            await browser.close()