߲jdZddlZddlZddlmZddlmZddlmZ de de fdZ de fd Z de fd Z dee effd Zd e ddfd Zd e ddfdZy)uUser-supplied CDP endpoint resolution (browser.cdp_url / real-profile), dialog-policy config and the per-task CDP supervisor lifecycle. Split out of ``tools/browser_tool.py``. Facade-owned state is read through ``_bt`` (``tools.browser_tool``, resolved per call) — no import cycle.N)Tuple)loopback_request_kwargs) origin_modulecdp_urlreturnc <t}|xsdj}|sy|j}d|vr|S|}|jdr|j ddk(rI|j dj dddjrd|jdddvs|S|jd rd nd |jd ddz}|jjd r|n|j dd z}|j} ddl }|j|fddit|}|j|j} t'| jdxsdj} | r+|j"j)d|||| | S|j"j%d|||S#t $r<} |j"j%d|||||| |cYd} ~ Sd} ~ wwxYw)u,Normalize a user-supplied CDP endpoint into a concrete websocket URL. Full ``ws://.../devtools/browser/...`` endpoints pass through; HTTP discovery roots and bare ``ws://host:port`` resolve via ``/json/version`` → ``webSocketDebuggerUrl`` (falls back to the raw value with a warning). z/devtools/browser/)ws://zwss://:/r zhttp://zhttps://z://z /json/versionrNtimeout z,Failed to resolve CDP endpoint %s via %s: %swebSocketDebuggerUrlzResolved CDP endpoint %s -> %szKCDP discovery at %s did not return webSocketDebuggerUrl; using raw endpoint)_originstriplower startswithcountrstriprsplitisdigitsplitendswith_sanitize_url_for_logsrequestsgetrraise_for_statusjson Exceptionloggerwarningstrinfo) r_btrawlowered discovery_url version_urlsanrresponsepayloadexcws_urls ;/home/ubuntu/.hermes/hermes-agent/tools/browser_tool_cdp.py_resolve_cdp_overrider2 s )C =b   !C iikGw& M-. #!# 3(>(>sA(Fr(J(R(R(TY\dgdmdmnqstduvxdyYyJ&-&8&8&AzUXU^U^_dfgUhijUkk #0#6#6#8#A#A/#R-XeXlXlmpXquDYDK $ $C8<< `R`;RS^;_`!!#--/34: ; A A CF  8#c(CKP JJdfijufvw J  I3s8UXYdUegjkngop sAG H1HHHctjjddj}|xst j ddddS)aReturn the *configured* CDP override without any network I/O. Precedence: ``BROWSER_CDP_URL`` env (live ``/browser connect``), then ``browser.cdp_url``. Is-it-configured gates (check_fns, ``_is_local_mode`` / ``_is_local_backend``, ``hermes doctor``) MUST use this, not :func:`_get_cdp_override`: its 10s HTTP discovery against a stale ``cdp_url`` would stall every startup's schema build with no error. BROWSER_CDP_URLr rc<t|xsdjS)Nr )r%r)vs r1z'_get_cdp_override_raw..<s3qwTV>"3R8>>@L  7911)RA_a~r8cHt}tx}r t|SdS)uResolved CDP URL override, or "" (skips cloud AND local launch). May perform HTTP ``/json/version`` discovery — only call on paths about to *connect*; pure gates must use :func:`_get_cdp_override_raw`. r )rr=r2)r'r(s r1_get_cdp_overrider??s) )C1F1H*H#*H  %QrQr8ct}ddlm}m}m}||}} ddlm}|}t|tr|jdini}t|ts||fSt|jdxs|} | |vr| }n|jjd| |jd} | t| n|}|dkr|}||fS#ttf$r|}YwxYw#t $r||fcYSwxYw)zgRead ``browser.dialog_policy`` + ``browser.dialog_timeout_s``; supervisor defaults when absent/invalid.r)DEFAULT_DIALOG_POLICYDEFAULT_DIALOG_TIMEOUT_S_VALID_POLICIES)read_raw_configbrowser dialog_policyz/Invalid browser.dialog_policy=%r; using defaultdialog_timeout_s)r tools.browser_supervisor_dialogsrArBrChermes_cli.configrD isinstancedictrr%r#debugfloat TypeError ValueErrorr") r'rArBrCpolicy timeout_srDcfg browser_cfg candidate timeout_raws r1_get_dialog_policy_configrVIs  )Cqq-/GIF?50:30Ecggi,2 +t,9$ $ 8Q>>?s=AC#AC#2C C# C C#C  C## C32C3task_idct}t}|s\|j5|jj |i}dddt j dxsd}|r t |}|sy ddlm}t\}}|j||||y#1swYaxYw#t$r'}|jjd||Yd}~yd}~wwxYw)uStart a CDP supervisor for ``task_id`` if an endpoint is reachable. Idempotent (``get_or_start`` skips an existing ``(task_id, cdp_url)`` and restarts on URL change), so safe on every navigate / ``/browser connect``. URL precedence: the CDP override, then the session's own ``cdp_url`` (cloud providers, e.g. Browserbase). Swallows all errors — a failed attach must not break the session; snapshots just lack ``pending_dialogs`` / ``frame_tree``. Nrr rSUPERVISOR_REGISTRY)rWrrFrGz8CDP supervisor attach for task=%s failed (non-fatal): %s)rr? _cleanup_lock_active_sessionsrr%r2tools.browser_supervisorrZrV get_or_startr"r#rL) rWr'r session_infomayberZrPrQr/s r1_ensure_cdp_supervisorrafs )C!G     A//33GR@L AL$$Y/526 +E2G c@57 (('Y_r{(| A A c SU\^abbcs#B 7(B, B), C5CCc ddlm}|j|y#t$r/}t j j d||Yd}~yd}~wwxYw)zGStop the CDP supervisor for ``task_id`` if one exists. No-op otherwise.rrYz6CDP supervisor stop for task=%s failed (non-fatal): %sN)r]rZstopr"rr#rL)rWrZr/s r1_stop_cdp_supervisorrdsKg@  ) g WY`beffgs A%A  A)__doc__ contextlibr9typingragent.proxy_bypassrtools.browser_tool_originrrr%r2r=r?rMrVrardr8r1rksW 6>#3#3#L @s @R3R?5e#4?:cCcDc4g#g$gr8