Method _execute_captcha

src/services/browser_captcha.py:1822–1871

在给定 context 中执行打码逻辑

(self, context, project_id: str, website_key: str, action: str)

            await self.recycle_browser(reason="force_close_all", rotate_profile=False)

    async def _execute_captcha(self, context, project_id: str, website_key: str, action: str) -> Optional[str]:
        """在给定 context 中执行打码逻辑"""
        page = None
        try:
            page = await context.new_page()
            await self._apply_browser_environment_patch(page, label="captcha_page")
            await page.add_init_script("Object.defineProperty(navigator, 'webdriver', {get: () => undefined});")
            ready = await self._prepare_flow_runtime_page(
                page,
                project_id,
                website_key,
                action,
                context_label="打码",
            )
            if not ready:
                return None

            token = await asyncio.wait_for(
                page.evaluate(f"""
                    (actionName) => {{
                        return new Promise((resolve, reject) => {{
                            const timeout = setTimeout(() => reject(new Error('timeout')), 25000);
                            grecaptcha.enterprise.execute('{website_key}', {{action: actionName}})
                                .then(t => {{ clearTimeout(timeout); resolve(t); }})
                                .catch(e => {{ clearTimeout(timeout); reject(e); }});
                        }});
                    }}
                """, action),
                timeout=30
            )

            # 额外等待几秒，确保 enterprise 请求链路完全稳定
            post_wait_seconds = float(getattr(config, "browser_recaptcha_settle_seconds", 3) or 3)
            if post_wait_seconds > 0:
                debug_logger.log_info(
                    f"[BrowserCaptcha] Token-{self.token_id} token已获取，额外等待 {post_wait_seconds:.1f}s 后返回"
                )
                await asyncio.sleep(post_wait_seconds)

            return token
        except Exception as e:
            msg = f"{type(e).__name__}: {str(e)}"
            debug_logger.log_warning(f"[BrowserCaptcha] Token-{self.token_id} 打码失败: {msg[:200]}")
            return None
        finally:
            if page:
                try:
                    await page.close()
                except:
                    pass

    async def _execute_custom_captcha(
        self,