eiHW ~UdZddlmZddlZddlZddlZddlZddlmZm Z m Z ddl m Z m Z ejeZdZ ddlZddlmZdZn#e$r dZeZd ZYnwxYwd Zd6d Zd7dZd8dZ d9d:dZddedd d!d"d#d d$idd%d!d&d#d!d'd#d(d)d*d+d,dgd-d.Zded/<d;d1Ze j dd2ed3ed45dS)>&DDD$,RWWYY JJJJJJJJJjoo774==I--#~~*KS\KK"%2!6!6!:!:;!G!GJ%*N% ,1 l    *)C ggdjoo&&&&&&&&&)++0022W< - 7#9#;#;#@#@#B#BBIA~~"AAA (IFFFFFFFFFC*S//Cwwt}}''c>>&'CS\'C'CDDDwwx,,KE-E-E-E-E-E-E-E-E-E-E-E-E-E-t -uE-E-E-E-E-E-E-E-E-E-E-E-E-E-E-E-sJKK K!$K!task_idframe_idOptional[Dict[str, Any]]c ddlm}n*#t$r}td|dcYd}~Sd}~wwxYw||td|dS}|jd}d} |r|d |kr|} n=|jd gpgD]} | d |kr| } n | Oj5j|} dddn #1swxYwY| | } | td |d S| d std |dSddl } j } | | stdSfd} | || }|dz}nE#t$r8}tdt|jd|t"cYd}~Sd}~wwxYwd||did}t%j|dS)a\Route a CDP call through the live supervisor session for an OOPIF frame. Looks up the frame in the supervisor's snapshot, extracts its child ``cdp_session_id``, and dispatches ``method`` with that sessionId via the supervisor's already-connected WebSocket (using ``asyncio.run_coroutine_threadsafe`` onto the supervisor loop). r)SUPERVISOR_REGISTRYz!CDP supervisor is not available: zp. frame_id routing requires a running supervisor attached via /browser connect or an active Browserbase session.Nz'No CDP supervisor is attached for task=z. Call browser_navigate or /browser connect first so the supervisor can attach. Once attached, browser_snapshot will populate frame_tree with frame_ids you can pass here.toprVchildrenz frame_id zP not found in supervisor state. Call browser_snapshot to see current frame_tree.rLz is not an out-of-process iframe (no dedicated CDP session). For same-origin iframes, use `browser_cdp(method='Runtime.evaluate', params={'expression': "document.querySelector('iframe').contentDocument.title"})` at the top-level page instead.zKCDP supervisor loop is not running. Try reconnecting with /browser connect.cJKpid{VS)N)rLr0)_cdp) child_sidr+r, supervisorr0sr_do_cdpz,_browser_cdp_via_supervisor.._do_cdp sP__  Lb  %         r;z CDP call via supervisor failed: : cdp_docsTr)successr+rVrLrF ensure_ascii)tools.browser_supervisorrYr%rrIsnapshot frame_tree _state_lock_framesto_dictr _looprrun_coroutine_threadsafertype__name__ CDP_DOCS_URLrArB)rUrVr+r,r0rYr(snaprZ frame_infochildrP_asynciorr`fut result_msgpayloadr^r_s ``` @@r_browser_cdp_via_supervisorr{s @@@@@@@     $ $ $ $         %((11J B  Eyy$$00" 1  # 3 3$((22C 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 ?J @ @ @ @   |,,I    . . . .     D |4??,,|              // 4@@ZZ! Z44     JtCyy/A J JS J J!          ..2.. G :gE 2 2 22sD 50556DD!$D!77G// H19-H,&H1,H1>@c |rt|pd||||S~|rt|tstdtSt stdSt }|stdtS|dstd|d S|pi}t|ts$td t|j S |rt|nd }n#ttf$rd }YnwxYwtd t|d } t!t#|||||} n#t$j$r!} td|d| |cYd} ~ Sd} ~ wt&$r(} tt| |cYd} ~ Sd} ~ wt($r(} tt| |cYd} ~ Sd} ~ wt*$r"} td|d| d|cYd} ~ Sd} ~ wt,$rM} t.dtdt| j d| |cYd} ~ Sd} ~ wwxYwd|| d} |r|| d<t3j| dS)unSend a raw CDP command. See ``CDP_DOCS_URL`` for method documentation. Args: method: CDP method name, e.g. ``"Target.getTargets"``. params: Method-specific parameters; defaults to ``{}``. target_id: Optional target/tab ID for page-level methods. When set, we first attach to the target (``flatten=True``) and send ``method`` with the resulting ``sessionId``. Uses a fresh stateless CDP connection. frame_id: Optional cross-origin (OOPIF) iframe ``frame_id`` from ``browser_snapshot.frame_tree.children[]``. When set (and the frame is an OOPIF with a live session tracked by the CDP supervisor), routes the call through the supervisor's existing WebSocket — which is how you Runtime.evaluate *inside* an iframe on backends where per-call fresh CDP connections would hit signed-URL expiry (Browserbase) or expensive reattach. timeout: Seconds to wait for the call to complete. task_id: Task identifier for supervisor lookup. When ``frame_id`` is set, this identifies which task's supervisor to use; the handler will default to ``"default"`` otherwise. Returns: JSON string ``{"success": True, "method": ..., "result": {...}}`` on success, or ``{"error": "..."}`` on failure. default)rUrVr+r,r0z/'method' is required (e.g. 'Target.getTargets')rdzfThe 'websockets' Python package is required but not installed. Install it with: pip install websocketszNo CDP endpoint is available. Run '/browser connect' to attach to a running Chrome, or set 'browser.cdp_url' in config.yaml. The Camofox backend is REST-only and does not expose CDP.)zws://zwss://z%CDP endpoint is not a WebSocket URL: u. Expected ws://... or wss://... — the /browser connect resolver should have rewritten this. Check that Chrome is actually listening on the debug port.z%'params' must be an object/dict, got r|g?gr@zCDP call timed out after zs: )r+Nz"WebSocket error talking to CDP at rcuE. The browser may have disconnected — try '/browser connect' again.zbrowser_cdp unexpected errorzUnexpected error: T)rfr+rr.Frg)r{ isinstancerrrs _WS_AVAILABLEr) startswithdictrqrrr1 TypeError ValueErrormaxminrrTr rErr r%r& exceptionrArB) r+r,r.rVr0rUendpoint call_params safe_timeoutrr(rzs r browser_cdpr(sD *(y        FC00  =!      6   %&&H   H"        2 3 3  4H 4 4 4   #),BK k4 ( (  PD4E4E4N P P   )0:uW~~~d z " sC e4455L  h Y M M        > > > > >          333#c((6222222222 333#c((6222222222     N N NS N N N            7888 <c!3 < - Get all cookies: method='Network.getAllCookies', params={} - Eval in a specific tab: method='Runtime.evaluate', params={'expression': '...', 'returnByValue': true}, target_id= - Set viewport for a tab: method='Emulation.setDeviceMetricsOverride', params={'width': 1280, 'height': 720, 'deviceScaleFactor': 1, 'mobile': false}, target_id= **Usage rules:** - Browser-level methods (Target.*, Browser.*, Storage.*): omit target_id and frame_id. - Page-level methods (Page.*, Runtime.*, DOM.*, Emulation.*, Network.* scoped to a tab): pass target_id from Target.getTargets. - **Cross-origin iframe scope** (Runtime.evaluate inside an OOPIF, Page.* targeting a frame target, etc.): pass frame_id from the browser_snapshot frame_tree output. This routes through the CDP supervisor's live connection — the only reliable way on Browserbase where stateless CDP calls hit signed-URL expiry. - Each stateless call (without frame_id) is independent — sessions and event subscriptions do not persist between calls. For stateful workflows, prefer the dedicated browser tools or use frame_id routing.objectstringz]CDP method name, e.g. 'Target.getTargets', 'Runtime.evaluate', 'Page.handleJavaScriptDialog'.)rq descriptionzaMethod-specific parameters as a JSON object. Omit or pass {} for methods that take no parameters.)rqr propertiesadditionalPropertieszOptional. Target/tab ID from Target.getTargets result (each entry's 'targetId'). Use for page-level methods at the top-level tab scope. Mutually exclusive with frame_id.aOptional. Out-of-process iframe (OOPIF) frame_id from browser_snapshot.frame_tree.children[] where is_oopif=true. When set, routes the call through the CDP supervisor's live session for that iframe. Essential for Runtime.evaluate inside cross-origin iframes, especially on Browserbase where fresh per-call CDP connections can't keep up with signed URL rotation. For same-origin iframes, use parent contentWindow/contentDocument from Runtime.evaluate at the top-level page instead.numberz)Timeout in seconds (default 30, max 300).)rqrr~)r+r,r.rVr0)rqrrequired)namer parametersBROWSER_CDP_SCHEMAboolc ddlm}m}n3#t$r&}td|Yd}~dSd}~wwxYw|sdSt |S)u*Availability check for browser_cdp. The tool is only offered when the Python side can actually reach a CDP endpoint right now — meaning a static URL is set via ``/browser connect`` (``BROWSER_CDP_URL``) or ``browser.cdp_url`` in ``config.yaml``. Backends that do *not* currently expose CDP to us — Camofox (REST-only), the default local agent-browser mode (Playwright hides its internal CDP port), and cloud providers whose per-session ``cdp_url`` is not yet surfaced — are gated out so the model doesn't see a tool that would reliably fail. Cloud-provider CDP routing is a follow-up. Kept in a thin wrapper so the registration statement stays at module top level (the tool-discovery AST scan only picks up top-level ``registry.register(...)`` calls). r)r!check_browser_requirementsz1browser_cdp check: browser_tool import failed: %sNF)r#r!r ImportErrorr&r'r)r!rr(s r_browser_cdp_checkrs"           H#NNNuuuuu & % ' 'u !!## $ $$s ;6;z browser-cdpc t|dd|d|d|d|dd|d S) Nr+r"r,r.rVr0r|rU)r+r,r.rVr0rU)rrI)argskws rr*ss{xx"%%xx!!((;''*%%D))y!!    rau🧪)rtoolsetschemahandlercheck_fnemoji)rr) r*rr+rr,r-r.r/r0r1rr-) rUrrVrr+rr,rWr0r1rr)NNNr|N)r+rr,rWr.r/rVr/r0r1rUr/rr)rr)!__doc__ __future__rr rAloggingostypingrrrtools.registryrr getLoggerrrr&rsr>websockets.exceptionsr rrr%rr)rTr{rr__annotations__rregisterrarrs #"""""  &&&&&&&&&&////////  8 $ $D 888888MMJ"MMM   *.W-W-W-W-@f3f3f3f3V(,#"! v3v3v3v3v3~ % &2% % % P!I!C!(,! ! 5 !? S0 0 bJg44U_&_&____D%%%%<      s A AA