Update app/aternos_api.py

app/aternos_api.py

@@ -5,11 +5,12 @@ from playwright_stealth import stealth_async
 class AternosAPI:
     def __init__(self):
         self.playwright = None
+        # Dùng giao thức HTTP để tránh lỗi "SOCKS5 auth support"
         self.proxy_config = {
-          "server": "http://p.webshare.io:80", 
-          "username": "szusjfnw-rotate",
-          "password": "mftzj9sljp5t"
-    }
+            "server": "http://p.webshare.io:80",
+            "username": "szusjfnw-rotate",
+            "password": "mftzj9sljp5t"
+        }
 
     async def start(self):
         if not self.playwright:
@@ -21,58 +22,76 @@ class AternosAPI:
             self.playwright = None
 
     async def check_access(self):
-        """Hàm chính để FastAPI gọi vào"""
         if not self.playwright:
             await self.start()
 
-        browser = await self.playwright.chromium.launch(
-            headless=True,
-            proxy=self.proxy_config,
-            args=[
-                "--no-sandbox",
-                "--disable-blink-features=AutomationControlled",
-                "--disable-dev-shm-usage"
-            ]
-        )
+        browser = None
+        try:
+            browser = await self.playwright.chromium.launch(
+                headless=True,
+                proxy=self.proxy_config,
+                args=[
+                    "--disable-blink-features=AutomationControlled",
+                    "--no-sandbox",
+                    "--disable-dev-shm-usage"
+                ]
+            )
 
-        # Giả lập vân tay trình duyệt thật
-        context = await browser.new_context(
-            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",
-            viewport={'width': 1920, 'height': 1080}
-        )
-        
-        page = await context.new_page()
-        # Xóa dấu vết bot
-        await stealth_async(page)
+            context = await browser.new_context(
+                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()
+            # Bật chế độ tàng hình
+            await stealth_async(page)
 
-        try:
-            # Bước 1: Truy cập trang chủ để lấy "vía" (cookies nền)
+            # --- BẮT ĐẦU QUY TRÌNH VƯỢT CLOUDFLARE ---
+            
+            # Bước 1: Vào trang chủ để "nhử" Cloudflare hiện thử thách
+            print("[INFO] Đang truy cập Aternos...")
             await page.goto("https://aternos.org/go/", wait_until="networkidle", timeout=60000)
-            await asyncio.sleep(3) 
 
-            # Bước 2: Vào thẳng trang server
-            response = await page.goto("https://aternos.org/server/", wait_until="domcontentloaded", timeout=60000)
+            # Bước 2: Cơ chế "kiên nhẫn" - Đợi tối đa 15 giây để Cloudflare tự giải quyết
+            for i in range(15):
+                content = await page.content()
+                title = (await page.title()).lower()
+                
+                # Nếu không còn thấy dấu hiệu của Cloudflare thì thoát vòng lặp
+                if "just a moment" not in title and "cloudflare" not in content.lower():
+                    print(f"[INFO] Cloudflare đã thông qua sau {i} giây!")
+                    break
+                
+                print(f"[INFO] Đang đợi Cloudflare giải quyết... ({i}s)")
+                # Giả lập di chuyển chuột nhẹ để trông giống người thật
+                await page.mouse.move(100 + i*10, 100 + i*10)
+                await asyncio.sleep(1)
+
+            # Bước 3: Sau khi đã lọt qua lớp bảo vệ, tiến vào trang đích
+            response = await page.goto("https://aternos.org/server/", wait_until="networkidle", timeout=60000)
             
-            # Đợi thêm chút nếu gặp màn hình chờ của Cloudflare
-            await asyncio.sleep(5)
+            # Đợi thêm 2 giây để trang render xong hoàn toàn
+            await asyncio.sleep(2)
 
-            title = await page.title()
-            content = await page.content()
+            final_title = await page.title()
+            final_content = await page.content()
             status = response.status if response else 0
 
-            # Logic kiểm tra chuẩn xác
-            is_cf_challenge = "just a moment" in title.lower() or "cloudflare" in content.lower()
-            is_success = status == 200 and not is_cf_challenge
+            # Kiểm tra xem thực sự đã vào được trang quản lý server chưa
+            # Nếu title chứa "Login" hoặc "Sign up" là vẫn chưa đăng nhập, nhưng ít nhất đã vượt được CF
+            is_blocked = "just a moment" in final_title.lower() or "cloudflare" in final_content.lower()
 
             return {
-                "ok": is_success,
+                "ok": status == 200 and not is_blocked,
                 "status": status,
-                "title": title,
+                "title": final_title,
                 "proxy_working": status != 407,
-                "cloudflare_blocked": is_cf_challenge
+                "cloudflare_blocked": is_blocked,
+                "url": page.url
             }
 
         except Exception as e:
+            print(f"[ERROR] Có lỗi xảy ra: {str(e)}")
             return {"ok": False, "error": str(e)}
         finally:
-            await browser.close()
+            if browser:
+                await browser.close()