Update app.py

app.py

@@ -8,6 +8,13 @@ PROFILE = "/tmp/uc-profile"
 UA = os.getenv("UA", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/129.0.0.0 Safari/537.36")
 CHROME_BIN = os.getenv("CHROME_BIN", "/usr/bin/chromium")
 
+SIGNS = (
+    "/sorry/", "consent.google.com", "detected unusual traffic",
+    "unusual traffic", "to continue, please verify", "recaptcha",
+    "g-recaptcha", "hcaptcha", "i'm not a robot", "are you a robot",
+    "ระบบของเราตรวจพบการรับส่งข้อมูลผิดปกติ", "ยืนยันว่าคุณไม่ใช่โปรแกรมอัตโนมัติ"
+)
+
 app = FastAPI()
 drv = None
 queue = None
@@ -16,11 +23,25 @@ worker = None
 class OpenPayload(BaseModel):
     url: HttpUrl
 
+def _check_captcha():
+    u = (drv.current_url or "").lower()
+    t = (drv.title or "").lower()
+    h = (drv.page_source or "")[:2000].lower()
+    for s in SIGNS:
+        if s in u or s in t or s in h:
+            return True, s
+    return False, ""
+
 async def _worker():
     while True:
         url = await queue.get()
         try:
             await asyncio.to_thread(drv.get, url)
+            bad, sig = _check_captcha()
+            if bad:
+                print("[check] captcha=True", {"url": drv.current_url, "sig": sig})
+            else:
+                print("[check] captcha=False", {"url": drv.current_url, "title": drv.title[:80] if drv.title else ""})
             print("[open] done", url)
         finally:
             queue.task_done()