Method submit_flow_request

src/services/browser_captcha.py:2159–2342

在同一浏览器上下文中完成打码并直接提交 Flow 请求。

(
        self,
        project_id: str,
        website_key: str,
        action: str,
        url: str,
        at_token: str,
        json_data: Dict[str, Any],
        timeout: int,
        token_proxy_url: Optional[str] = None,
        token_id: Optional[int] = None,
    )

                TokenBrowser._inject_recaptcha_token(item, token)

    async def submit_flow_request(
        self,
        project_id: str,
        website_key: str,
        action: str,
        url: str,
        at_token: str,
        json_data: Dict[str, Any],
        timeout: int,
        token_proxy_url: Optional[str] = None,
        token_id: Optional[int] = None,
    ) -> Dict[str, Any]:
        """在同一浏览器上下文中完成打码并直接提交 Flow 请求。"""
        async with self._semaphore:
            self._solve_inflight += 1
            max_retries = max(3, int(getattr(config, "browser_captcha_max_retries", 5) or 5))

            try:
                for attempt in range(max_retries):
                    page = None
                    try:
                        start_ts = time.time()
                        _, _, context = await self._get_or_create_shared_browser(
                            token_proxy_url=token_proxy_url,
                            token_id=token_id,
                        )

                        page = await context.new_page()
                        await self._apply_browser_environment_patch(page, label="browser_submit_page")
                        await page.add_init_script(
                            "Object.defineProperty(navigator, 'webdriver', {get: () => undefined});"
                        )

                        debug_logger.log_info(
                            f"[BrowserCaptcha] Token-{self.token_id} 浏览器内提交 Flow 请求: "
                            f"action={action}, project_id={project_id}"
                        )
                        ready = await self._prepare_flow_runtime_page(
                            page,
                            project_id,
                            website_key,
                            action,
                            context_label="浏览器内提交",
                        )
                        if not ready:
                            raise RuntimeError("grecaptcha.enterprise 未就绪")

                        payload_for_submit = deepcopy(json_data)
                        response_payload = await asyncio.wait_for(
                            page.evaluate(
                                """
                                async ({ websiteKey, actionName, targetUrl, bearerToken, payload, timeoutMs }) => {
                                    const solveToken = () => new Promise((resolve, reject) => {
                                        const timer = setTimeout(() => reject(new Error('captcha_timeout')), 25000);
                                        try {
                                            grecaptcha.enterprise.execute(websiteKey, { action: actionName })
                                                .then((token) => {
                                                    clearTimeout(timer);