i]$dZddlmZddlZddlZddlZddlZddlZddlm Z ddl m Z m Z m Z mZmZddlZddlmZejeZdZdZd ZeeeehZeZd Zd Zd Zd ZdZ dZ!de!dZ"dZ#e GddZ$e GddZ%e GddZ&e GddZ'e dGddZ(Gdd Z)Gd!d"Z*e*Z+gd#Z,dS)$uPersistent CDP supervisor for browser dialog + frame detection. One ``CDPSupervisor`` runs per Hermes ``task_id`` that has a reachable CDP endpoint. It holds a single persistent WebSocket to the backend, subscribes to ``Page`` / ``Runtime`` / ``Target`` events on every attached session (top-level page and every OOPIF / worker target that auto-attaches), and surfaces observable state — pending dialogs and frame tree — through a thread-safe snapshot object that tool handlers consume synchronously. The supervisor is NOT in the agent's tool schema. Its output reaches the agent via two channels: 1. ``browser_snapshot`` merges supervisor state into its return payload (see ``tools/browser_tool.py``). 2. ``browser_dialog`` tool responds to a pending dialog by calling ``respond_to_dialog()`` on the active supervisor. Design spec: ``website/docs/developer-guide/browser-supervisor.md``. ) annotationsN) dataclass)AnyDictListOptionalTuple)ClientConnection must_respond auto_dismiss auto_acceptgr@2zhermes-dialog-bridge.invalidzhttp://z/*u. (() => { if (window.__hermesDialogBridgeInstalled) return; window.__hermesDialogBridgeInstalled = true; const ENDPOINT = "http://hermes-dialog-bridge.invalid/"; function ask(kind, message, defaultPrompt) { try { const xhr = new XMLHttpRequest(); // Use GET with query params so we don't need to worry about request // body encoding in the Fetch interceptor. const params = new URLSearchParams({ kind: String(kind || ""), message: String(message == null ? "" : message), default_prompt: String(defaultPrompt == null ? "" : defaultPrompt), }); xhr.open("GET", ENDPOINT + "?" + params.toString(), false); // sync xhr.send(null); if (xhr.status !== 200) return null; const body = xhr.responseText || ""; let parsed; try { parsed = JSON.parse(body); } catch (e) { return null; } if (kind === "alert") return undefined; if (kind === "confirm") return Boolean(parsed && parsed.accept); if (kind === "prompt") { if (!parsed || !parsed.accept) return null; return parsed.prompt_text == null ? "" : String(parsed.prompt_text); } return null; } catch (e) { // If the bridge is unreachable, fall back to the native call so the // page still sees *some* behavior (the backend will auto-dismiss). return null; } } const realAlert = window.alert; const realConfirm = window.confirm; const realPrompt = window.prompt; window.alert = function(message) { ask("alert", message, ""); }; window.confirm = function(message) { const r = ask("confirm", message, ""); return r === null ? false : Boolean(r); }; window.prompt = function(message, def) { const r = ask("prompt", message, def == null ? "" : def); return r === null ? null : String(r); }; // onbeforeunload — we can't really synchronously prompt the user from this // event without racing navigation. Leave native behavior for now; the // supervisor's native-dialog fallback path still surfaces them in // recent_dialogs. })(); cteZdZUdZded<ded<ded<ded<ded<ded <d Zd ed <d Zd ed <ddZd S) PendingDialogz3A JS dialog currently open on some frame's session.stridtypemessagedefault_promptfloat opened_atcdp_session_idN Optional[str]frame_idbridge_request_idreturnDict[str, Any]cP|j|j|j|j|j|jdS)Nrrrrrrr"selfs =/home/ubuntu/.hermes/hermes-agent/tools/browser_supervisor.pyto_dictzPendingDialog.to_dicts0'I|"1    rr )__name__ __module__ __qualname____doc____annotations__rrr&r'r%rrs== GGG IIILLL"H""""(,++++      r'rcfeZdZUdZded<ded<ded<ded<ded<ded <d Zd ed <ddZd S) DialogRecordaA historical record of a dialog that was opened and then handled. Retained in ``recent_dialogs`` for a short window so agents on backends that auto-dismiss dialogs server-side (Browserbase) can still observe that a dialog fired, even though they couldn't respond to it. rrrrrr closed_at closed_byNrrrr c\|j|j|j|j|j|j|jdS)Nrrrrr1r2rr4r#s r%r&zDialogRecord.to_dicts4'I|    r'r()r)r*r+r,r-rr&r.r'r%r0r0s GGG IIILLLNNN"H""""       r'r0cjeZdZUdZded<ded<ded<ded<ded <d Zded <d Zded <ddZd S) FrameInfoa One frame in the page's frame tree. ``is_oopif`` means the frame has its own CDP target (separate process, reachable via ``cdp_session_id``). Same-origin / srcdoc iframes share the parent process and have ``is_oopif=False`` + ``cdp_session_id=None``. rrurloriginrparent_frame_idboolis_oopifNrnamerr c|j|j|j|jd}|jr |j|d<|jr |j|d<|jr |j|d<|S)N)rr7r8r; session_idr9r=)rr7r8r;rr9r=)r$ds r%r&zFrameInfo.to_dictsn 8k      2"1AlO   8#'#7A 9 " AfIr'r()r)r*r+r,r-rr=r&r.r'r%r6r6sMMM HHHKKK""""NNN$(N((((DNNNN      r'r6c@eZdZUdZded<ded<ded<dZded <dS) ConsoleEventz2Ring buffer entry for console + exception traffic.rtsrleveltextNrr7)r)r*r+r,r-r7r.r'r%rBrBsD<< IIIJJJ IIICr'rBT)frozencbeZdZUdZded<ded<ded<ded <d ed <d ed <d ed<ddZdS)SupervisorSnapshotzRead-only snapshot of supervisor state. Frozen dataclass so tool handlers can freely dereference without worrying about mutation under their feet. zTuple[PendingDialog, ...]pending_dialogszTuple[DialogRecord, ...]recent_dialogsr frame_treezTuple[ConsoleEvent, ...]console_errorsr:activercdp_urltask_idrcnd|jD|jd}|jrd|jD|d<|S)z7Serialize for inclusion in ``browser_snapshot`` output.c6g|]}|Sr.r&.0r@s r% z.SupervisorSnapshot.to_dict..s JJJ JJJr')rIrKc6g|]}|Sr.rRrSs r%rUz.SupervisorSnapshot.to_dict..s $N$N$NQQYY[[$N$N$Nr'rJ)rIrKrJ)r$outs r%r&zSupervisorSnapshot.to_dictsY KJT5IJJJ/     O$N$N$:M$N$N$NC ! r'Nr()r)r*r+r,r-r&r.r'r%rHrHs /...,,,,,,,,LLLLLLLLLr'rHceZdZdZeedd?d Zd@dAdZdBdAdZdCdZ dddddDdZ dEdZ dEdZ dEdZ dFd Z dGddd!dHd%ZdEd&ZdId'ZdJd(ZdKd-ZdLd.ZdMd0ZdKd1ZdJd2ZdJd3ZdKd4ZdJd5ZdJd6ZdJd7ZdNd8ZdOd:ZdNd;ZdPd=Z dQd>Z!dS)R CDPSupervisoruOne supervisor per (task_id, cdp_url) pair. Lifecycle: * ``start()`` — kicked off by ``SupervisorRegistry.get_or_start``; spawns a daemon thread running its own asyncio loop, connects the WebSocket, attaches to the first page target, enables domains, starts auto-attaching to child targets. * ``snapshot()`` — sync, thread-safe, called from tool handlers. * ``respond_to_dialog(action, ...)`` — sync bridge; schedules a coroutine on the supervisor's loop and waits (with timeout) for the CDP ack. * ``stop()`` — cancels task, closes WebSocket, joins thread. All CDP I/O lives on the supervisor's own loop. External callers never touch the loop directly; they go through the sync API above. ) dialog_policydialog_timeout_srOrrNrZr[rrNonec|tvr'td|dtt||_||_||_t ||_tj |_ i|_ g|_ i|_ g|_d|_d|_d|_tj|_d|_d|_d|_i|_d|_d|_i|_i|_d|_dS)NzInvalid dialog_policy z; must be one of Fr)_VALID_POLICIES ValueErrorsortedrOrNrZrr[ threadingLock _state_lock_pending_dialogs_recent_dialogs_frames_console_events_active_loop_threadEvent _ready_event _start_error_stop_requested _next_call_id_pending_calls_ws_page_session_id_child_sessions_dialog_watchdogs _dialog_seq)r$rOrNrZr[s r%__init__zCDPSupervisor.__init__s  / /<<<"("9"9<<   * %&6 7 7%>++:<35-/ 35 ;? 37 %O--59$9;/3/3:<BDr'.@timeoutc|jr|jrdS|jd|_d|_t j|jd|j d|_|j |j |s7| td|d|jdd d |j|j}| |dS) u[Launch the background loop and wait until attachment is complete. Raises whatever exception attach failed with (connect error, bad WebSocket URL, CDP domain enable failure, etc.). On success, the supervisor is fully wired up — pending-dialog events will be captured as of the moment ``start()`` returns. NFzcdp-supervisor-T)targetr=daemonryz%CDP supervisor did not attach within z s (cdp_url=Pz...))rkis_alivermclearrnrorbThread _thread_mainrOstartwaitstop TimeoutErrorrN)r$ryerrs r%rzCDPSupervisor.startCs( < DL1133  F !!! $ '$14<11     %%g%66  IIKKK444 L"-444    (#C IIKKKI ) (r'@cd_j}|p|r\fd} tj||} |dn#t $rYnwxYwn#t$rYnwxYwjj |j 5d_ ddddS#1swxYwYdS)z/Cancel the supervisor task and join the thread.TNcKj}d_|. |d{VdS#t$rYdSwxYwdSN)rrclose Exception)wsr$s r% _close_wsz%CDPSupervisor.stop.._close_wsisnX> hhjj((((((((($">s 1 ??g@r}F) rorj is_runningasynciorun_coroutine_threadsaferesultr RuntimeErrorrkjoinrdri)r$rylooprfuts` r%rzCDPSupervisor.stopasO#z   1 1       6yy{{DIIJJsJ++++ D     < # L  g  . . .   ! ! DL ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! !sGA2 A! A2! A.+A2-A..A22 A?>A?+CCCrHc |j5t|j}t|jt d}|}t|jt d}|j }dddn #1swxYwYt||||||j |j S)z.Return an immutable snapshot of current state.N)rIrJrKrLrMrNrO) rdtuplerevaluesrfRECENT_DIALOGS_MAX_build_frame_tree_lockedrhCONSOLE_HISTORY_MAXrirHrNrO)r$dialogsrecent frames_treeconsolerMs r%snapshotzCDPSupervisor.snapshots   " "D188::;;G4/1C0C0D0DEFFF7799KD02E1E1F1FGHHG\F  " " " " " " " " " " " " " " " "#!""LL    sBBB!BN$@) prompt_text dialog_idryactionrrrr cR dvrdddSj5jsdddcdddStj}|sdddcdddS|rGj|}|*dd|d t jd dcdddSnHt|d kr-dt|d d |DdcdddS|d}| dddn #1swxYwYj}|dddS fd} tj ||} | |n3#t$r&} dt| jd| dcYd} ~ Sd} ~ wwxYwd dS)aAccept/dismiss a pending dialog. Sync bridge onto the supervisor loop. Returns ``{"ok": True, "dialog": {...}}`` on success, ``{"ok": False, "error": "..."}`` on a recoverable error (no dialog, ambiguous dialog_id, supervisor inactive). )acceptdismissFz*action must be 'accept' or 'dismiss', got )okerrorzsupervisor is not activeNzno dialog is currently openz dialog_id z not found (known: )r^z1 pending dialogs; specify dialog_id. Candidates: cg|] }|j Sr.)rrSs r%rUz3CDPSupervisor.respond_to_dialog..s'>'>'>'>'>'>r'rzsupervisor loop is not runningcPKdkpdd{VS)Nrr<rr)_handle_dialog_cdp)rrr$ snapshot_copysr% _do_respondz4CDPSupervisor.respond_to_dialog.._do_respondsT00v'9 HYWY1 r'r}: T)rdialog)rdrilistrergetralenrjrrrrrr)r&) r$rrrrypendingrrrrers ``` @r%respond_to_dialogzCDPSupervisor.respond_to_dialogs, . . .*aW]*a*abb b   # #< J#.HII # # # # # # # #407799::G M#.KLL  # # # # # # # #  $.229==>#"Di"D"D#)$*?#@#@"D"D"D # # # # # # # #" W!!w<<AA'>'>g'>'>'>AA # # # # # # # #.!"M1 # # # # # # # # # # # # # # #4z <*JKK K          F2;;==$GGC JJwJ ' ' ' ' F F FT!WW-=*D*D*D*DEE E E E E E E Fm&;&;&=&=>>>sF D ,D *;D 24D 3 D  D D +3E F)F F Fc tj}||_ tj|||nr#t $re}|js!||_ |j n!t d|j |Yd}~nd}~wwxYw dtj|D}|D]}||r$|tj|ddin#t"$rYnwxYw |n#t"$rYnwxYw|j5d|_ddddS#1swxYwYdS# dtj|D}|D]}||r$|tj|ddin#t"$rYnwxYw |n#t"$rYnwxYw|j5d|_dddw#1swxYwYwxYw)z2Entry point for the supervisor's dedicated thread.zCDP supervisor %s crashed: %sNc:g|]}||Sr.)donerTts r%rUz.CDPSupervisor._thread_main..s%NNNQVVXXN1NNNr'return_exceptionsTF)rnew_event_looprjset_event_looprun_until_complete_run BaseExceptionrmis_setrnsetloggerwarningrO all_taskscancelgatherrrrdri)r$rrrrs r%rzCDPSupervisor._thread_mains-%''  %  "4 ( ( (  # #DIIKK 0 0 0 0 Q Q Q$++-- Q$%!!%%''''> aPPP  Q NNg&7&=&=NNN AHHJJJJ^++GNG,\W[,\,\]]]          ! % %$  % % % % % % % % % % % % % % % % % % NNg&7&=&=NNN AHHJJJJ^++GNG,\W[,\,\]]]          ! % %$  % % % % % % % % % % % % % % % %s;AF C"AC=FCF AD)) D65D6:E EE&E;;E?E?I AG('I( G52I4G55I9H I HIH I%H9- I9H= =IH= Ic Kd}d}d}|js tjtj|jddd{V|_n#t$r}|d z }|j s&||_ |j Yd}~dSt d |j||tjt!|dd{Vt!|d zd}Yd}~d}~wwxYwtj|d } d|_|j|d{V|j5d|_dddn #1swxYwYt3j}d}|j s|j |d{Vn#t4$rz}|j s!||_ |j t d|jt3j|z |Yd}~nd}~wwxYw|j5d|_dddn #1swxYwY|s:| |d{Vn#tjtf$rYnwxYwt=|j D]}||j|j}d|_|. |!d{Vn#t$rYnwxYwn #|j5d|_dddn #1swxYwY|s:| |d{Vn#tjtf$rYnwxYwt=|j D]}||j|j}d|_|, |!d{Vw#t$rYwwxYwwxYw|jrdSt"d|j|tj|d{Vt!|d zd}|jdSdS)uTop-level supervisor coroutine. Holds a reconnecting loop so we survive the remote closing the WebSocket — Browserbase in particular tears down the CDP socket every time a short-lived client (e.g. agent-browser's per-command CDP client) disconnects. We drop our state snapshot keys that depend on specific CDP session ids, re-attach, and keep going. rgg?i )max_sizerr}Nr^z2CDP supervisor %s: connect failed (attempt %s): %srz cdp-reader)r=Tz2CDP supervisor %s: session dropped after %.1fs: %sFz+CDP supervisor %s: reconnecting in %.1fs...)#rorwait_for websocketsconnectrNrrrrmrrnrrrrOsleepmin create_task _read_looprsrtr_attach_initial_pagerdritimerrrCancelledErrorrrurrdebug)r$attemptlast_success_atbackoffr reader_taskhandlers r%rzCDPSupervisor._runs&R - !(!1&t|>NOOO """   1 (//11()D%%))+++FFFFFHL'1mC$6$6777777777gk400 "-doo.?.?lSSSK2 )-%$**,,,//111111111%((#'DL((((((((((((((("&)++(//11,%))+++!!!!!!!!!   (//11()D%%))+++HLIKK/1  %))#(DL)))))))))))))))"''))&&((()))))))))#2I>"4#9#@#@#B#BCC$$FMMOOOO&,,...X> hhjj(((((((($"%))#(DL)))))))))))))))"''))&&((()))))))))#2I>"4#9#@#@#B#BCC$$FMMOOOO&,,...X> hhjj(((((((($" #  LL=t|W   -(( ( ( ( ( ( ( ('A+t,,Ge&R -R -R -R -R -s:A D>C=AC==D.AG/F7 GFG F AGM/ I"(A0IM/I""M/,JJJ4J==KKM M*)M*/Q77N ? Q7 N Q7N +Q7?OQ7O!Q7 O!!A)Q7 Q&%Q7& Q30Q72Q33Q7cK|dd{V}|didg}td|Dd}|-|dddid{V}|dd }n|d }|d |d d d{V}|dd |_|d|jd{V|d|jd{V|dd dd d|jd{V||jd{VdS)zTFind a page target, attach flattened session, enable domains, install dialog bridge.zTarget.getTargetsNr targetInfosc3LK|]}|ddk|V dS)rpageNrrs r% z5CDPSupervisor._attach_initial_page..Qs6JJ!!%%--62I2IA2I2I2I2IJJr'zTarget.createTargetr7z about:blanktargetIdzTarget.attachToTargetT)rflatten sessionId Page.enable)r?Runtime.enableTarget.setAutoAttachF autoAttachwaitForDebuggerOnStartr)_cdprnextrs_install_dialog_bridge)r$resptargets page_targetcreated target_idattachs r%rz"CDPSupervisor._attach_initial_pageMsYY233333333((8R((,,]B??JJwJJJDQQ   II&;e]=STTTTTTTTG)*5II#J/Iyy #"t 4 4        !'x 0 =ii $2GiHHHHHHHHHii(T5JiKKKKKKKKKii "5T R R,         ))$*?@@@@@@@@@@@r'r?cK |dtdd|dd{Vn=#t$r0}td|pddd |Yd}~nd}~wwxYw |d t d d gd d|dd{Vn=#t$r0}td|pddd |Yd}~nd}~wwxYw |dtdd|dd{VdS#t$rYdSwxYw)uInstall the dialog-bridge init script + Fetch interceptor on a session. Two CDP calls: 1. ``Page.addScriptToEvaluateOnNewDocument`` — the JS override runs in every frame before any page script. Replaces alert/confirm/ prompt with a sync XHR to our bridge URL. 2. ``Fetch.enable`` scoped to the bridge URL — we catch those XHRs, surface them as pending dialogs, then fulfill once the agent responds. Idempotent at the CDP level: Chromium de-duplicates identical add-script calls by source, and Fetch.enable replaces prior patterns. z%Page.addScriptToEvaluateOnNewDocumentT)sourcerunImmediatelyrr?ryNzDdialog bridge: addScriptToEvaluateOnNewDocument failed on sid=%s: %sr<z Fetch.enableRequest) urlPattern requestStageF)patternshandleAuthRequestsz0dialog bridge: Fetch.enable failed on sid=%s: %szRuntime.evaluate) expression returnByValue@)r_DIALOG_BRIDGE_SCRIPTrrrDIALOG_BRIDGE_URL_PATTERN)r$r?rs r%rz$CDPSupervisor._install_dialog_bridgejs ))70DII%              LLV!r3B3'           ))+D,5! +0&              LLB!r3B3'          ))"4tLL%               DD s>', A&&A!!A&*+B C &C  C'C== D  D rmethodparamsOptional[Dict[str, Any]]cK|jtd|j}|xjdz c_||d}|r||d<|r||d<tj}||j|<|jtj |d{V tj ||d{V |j |dS#|j |dwxYw)z*Send a CDP command and await its response.Nz%supervisor WebSocket is not connectedr^)rrrrr}) rrrrprget_running_loop create_futurerqsendjsondumpsrpop)r$rrr?rycall_idpayloadrs r%rzCDPSupervisor._cdps+ 8 FGG G$ a)0F"C"C  ' &GH   .#-GK %688FFHH'*G$hmmDJw//000000000 3 )#w????????? ?   # #GT 2 2 2 2D  # #GT 2 2 2 2s %CC:c K|jJ |j23d{V}|jrdS tj|}n*#t$rt dYMwxYwd|vr|j|dd}|b| sNd|vr5| td|dd|d| |d|vrJ| |d|di|d d{V+6dS#t$r&}t d |Yd}~dSd}~wwxYw) z*Continuously dispatch incoming CDP frames.Nz&CDP supervisor: non-JSON frame droppedrrzCDP error on id=rrrrzCDP read loop exited: %s)rrror loadsrrrrqrr set_exceptionr set_result _on_eventr)r$rawmsgrrs r%rzCDPSupervisor._read_loopsx### 8!X e e e e e e ec'EE*S//CC LL!IJJJH3;;-11#d)TBBCsxxzz"c>>-- ,-[D -[-[SQX\-[-[ \ \ NN3///__..X"8M8MswwWbOcOcddddddddd%&XX& 8 8 8 LL3Q 7 7 7 7 7 7 7 7 7 8sBED? E;E$A"E!A""CE E2 E--E2cK|dkr|||d{VdS|dkr|||d{VdS|dkr|||d{VdS|dkr|||dS|dkr|||dS|dkr|||dS|dkr||d{VdS|dkr||dS|d kr||d dS|d kr||d dSdS)NzPage.javascriptDialogOpeningzPage.javascriptDialogClosedzFetch.requestPausedzPage.frameAttachedzPage.frameNavigatedzPage.frameDetachedzTarget.attachedToTargetzTarget.detachedFromTargetzRuntime.consoleAPICalledapi) level_fromzRuntime.exceptionThrown exception) _on_dialog_opening_on_dialog_closed_on_fetch_paused_on_frame_attached_on_frame_navigated_on_frame_detached_on_target_attached_on_target_detached _on_console)r$rrr?s r%rzCDPSupervisor._on_events 3 3 3))&*== = = = = = = = = = 4 4 4((<< < < < < < < < < < , , ,'' ;; ; ; ; ; ; ; ; ; ; + + +  # #FJ 7 7 7 7 7 , , ,  $ $VZ 8 8 8 8 8 + + +  # #FJ 7 7 7 7 7 0 0 0**622 2 2 2 2 2 2 2 2 2 2 2 2  $ $V , , , , , 1 1 1   V  6 6 6 6 6 0 0 0   V  < < < < <1 0r'c <Kxjdz c_tdjt|dpdt|dpdt|dpdt j|pjpd|djtkraj5 d dddn #1swxYwYtj d d dSjtkrfj5 d dddn #1swxYwYtj d j dSj5jj<dddn #1swxYwYtj}|jfd }|jj<dS)Nr^d-rr<r defaultPromptframeId)rrrrrrr auto_policyFrTc\tjjSrrr_dialog_timeout_expiredrrr$sr%z2CDPSupervisor._on_dialog_opening.."+D,H,H,S,STTr')rvrrrrrsrZDIALOG_POLICY_AUTO_DISMISSrd_archive_dialog_lockedrr_auto_handle_dialogDIALOG_POLICY_AUTO_ACCEPTrrerr  call_laterr[ru)r$rr?rrrs` @r%rz CDPSupervisor._on_dialog_openings A&D$&&VZZ''-2.. 9--344vzz/::@bAAikk%D)>D"ZZ **     !; ; ;! C C++FMBBB C C C C C C C C C C C C C C C  ((2(NN      #< < <! C C++FMBBB C C C C C C C C C C C C C C C  ((4V5J)     ! : :39%fi0 : : : : : : : : : : : : : : :+--D__%TTTTTF17D "69 - - -s6DDDE11E58E54GGGrrrr:cKd|i}|jdkr||d< |d||jpddd{VdS#t$r,}td|j|Yd}~dSd}~wwxYw) zSend handleJavaScriptDialog for auto_dismiss/auto_accept. Dialog has already been archived by the caller (``_on_dialog_opening``); this just fires the CDP call so the page unblocks. rprompt promptTextPage.handleJavaScriptDialogNrrz&auto-handle CDP call failed for %s: %s)rrrrrrr)r$rrrrrs r%r3z!CDPSupervisor._auto_handle_dialogs#+F!3 ;( " "#.F<  Q))-!08D            Q Q Q LLA69a P P P P P P P P P Qs&A A6 !A11A6cK|j5|j|}dddn #1swxYwY|dStd|j||j|j |j5||jvr1|j|d| |ddddn #1swxYwY|j r | |ddd{VdS| dddi|j pdd d{VdS#t$r'}td ||Yd}~dSd}~wwxYw) NzBCDP supervisor %s: dialog %s (%s) auto-dismissed after %ss timeoutwatchdogFr<rr9rrrzauto-dismiss failed for %s: %s)rdrerrrrOrr[rr2r_fulfill_bridge_requestrrrr)r$rrrs r%r-z%CDPSupervisor._dialog_timeout_expired1sM   : :*..y99F : : : : : : : : : : : : : : : > F P L  K  !     I! D D 555)--i>>>// CCC D D D D D D D D D D D D D D D ' 226%UW2XXXXXXXXXXXii1u%%4<    I I I LL99a H H H H H H H H H IsN155.D5;B<0 D<CDC(D.(D E "EE r2c 2t|j|j|j|jt j||j}|j|t|jtdzkr|jt d|_dSdS)zNMove a pending dialog to the recent_dialogs ring buffer. Must hold state_lock.r4rN) r0rrrrrrrfappendrr)r$rr2records r%r2z$CDPSupervisor._archive_dialog_lockedQsyN&ikk_    ##F+++ t# $ $'9A'= = =#'#79K8K8L8L#MD  > =r'cK|jrZ ||||d{V|j5|j|jvr6|j|jd||ddddn #1swxYwY|j|jd}||n#|j5|j|jvr6|j|jd||ddddn #1swxYwY|j|jd}||wwxYwdSd|i}|j dkr||d< | d||j pdd d{V|j5|j|jvr6|j|jd||ddddn #1swxYwY|j|jd}||dSdS#|j5|j|jvr6|j|jd||ddddn #1swxYwY|j|jd}||wwxYw) zSend the Page.handleJavaScriptDialog CDP command (agent path only). Routes to the bridge-fulfill path when the dialog was captured via the injected XHR override (see ``_on_fetch_paused``). rNagentrr7r8r9rr) rr<rdrrerr2rurrrr)r$rrrrrs r%rz CDPSupervisor._handle_dialog_cdp`sy  #  $226{3%EEyD$999-11&)TBBB33FGDDDEEEEEEEEEEEEEEE/33FItDD%MMOOO %EEyD$999-11&)TBBB33FGDDDEEEEEEEEEEEEEEE/33FItDD%MMOOOO& F"*F!3 ;( " "#.F<  ))-!08D        ! A A9 555)--fi>>>//@@@ A A A A A A A A A A A A A A A+// 4@@F! "! ! A A9 555)--fi>>>//@@@ A A A A A A A A A A A A A A A+// 4@@F! "sCABB BE  AD E D! !E $D! %;E :&H='AG88G<?G<=KAJ KJ KJ ;KcrK|j5fd|jD}|rl|d}|j|d}|||d|j|d}||ddddS#1swxYwYdS)NcBg|]}|jkr|j|jSr)rrr)rTr@r?s r%rUz3CDPSupervisor._on_dialog_closed..s@#z11'/  0//r'rremote)rdrerrr2rur)r$rr? candidate_idsdidrrs ` r%rzCDPSupervisor._on_dialog_closeds   $ $.5577M $#A&.223==%//AAA/33C>>%MMOOO# $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $sBB,,B03B0c 6 Kt|didpd}|d}|sdSt|vr5 dd|i|dd{Vn#t$rYnwxYwdSd d lm}m}|||jdfd }|dpd}|d} |d} xj dz c_ tdj || | tj |pj pd|dt| j tkraj5 ddddn #1swxYwYt#j dddSj t(kraj5 ddddn #1swxYwYt#j d| dSj5 j j<dddn #1swxYwYt#j} | j fd} | j j<dS)u Bridge XHR captured mid-flight — materialize as a pending dialog. The injected script (``_DIALOG_BRIDGE_SCRIPT``) fires a synchronous XHR to ``DIALOG_BRIDGE_HOST`` whenever page code calls alert/confirm/ prompt. We catch it via Fetch.enable pattern; the page's JS thread is blocked on the XHR's response until we call Fetch.fulfillRequest (which happens from ``respond_to_dialog``) or until the watchdog fires (at which point we fulfill with a cancel response). requestr7r< requestIdNzFetch.continueRequestrrr)urlparseparse_qsr=rrcJ|dg}|r|dndS)Nr<rr)r=vqs r%_qz*CDPSupervisor._on_fetch_paused.._qs+dRD!!A$1Q44" $r'kindalertrrr^r'r))rrrrrrrrr*FrTc\tjjSrr,r.sr%r/z0CDPSupervisor._on_fetch_paused..r0r')r=rrr)rrDIALOG_BRIDGE_HOSTrr urllib.parserJrKqueryrvrrrsrZr1rdr2rrr<r4rerr r5r[ru)r$rr?r7 request_idrJrKrOrPrrrrrrNs` @@r%rzCDPSupervisor._on_fetch_pauseds-&**Y++//66<"==ZZ ,,   F S ( ( ii+k:-F)3      F 43333333 HXXc]]( ) ) % % % % % %r&zz$W"Y--,-- A&D$&&)ikk%D)>D"ZZ **!*oo      !; ; ;! C C++FMBBB C C C C C C C C C C C C C C C  ,,VEr,RR      #< < <! C C++FMBBB C C C C C C C C C C C C C C C  ,,4^-     ! : :39%fi0 : : : : : : : : : : : : : : :+--D__%TTTTTF17D "69 - - -sH!!B BBFF FG33G7:G71I  IIc K|jsdSt||jdkr|nd|jd}t j|} ddl}|d|jddd d d d d g| | d |j pddd{VdS#t$r,}td|j|Yd}~dSd}~wwxYw)zCResolve a bridge XHR via Fetch.fulfillRequest so the page unblocks.Nr7r<)rrrrzFetch.fulfillRequestz Content-Typezapplication/json)r=valuezAccess-Control-Allow-Origin*)rI responseCoderesponseHeadersbodyrrz bridge fulfill failed for %s: %s)rr:rrr rencodebase64r b64encodedecoderrrr)r$rrrrr]_b64rs r%r<z%CDPSupervisor._fulfill_bridge_requestsf'  F6ll*0+*A*A;;r   z'""))++ K ! ! ! !))&!'!9$'!/:LMM!>MM(!NN4007799"08D            K K K LL;VY J J J J J J J J J KsA!B;; C1!C,,C1c |d}|sdS|j5t|dd|dd||j|<ddddS#1swxYwYdS)Nr)r< parentFrameIdF)rr7r8r9r;r)rrdr6rg)r$rr?rs r%r z CDPSupervisor._on_frame_attacheds::i((  F    %.! & ? ; ;) &&&DL "                  s1AA#&A#c|dpi}|d}|sdS|j5|j|}t|t |dpdt |dp|dpd|dp |r|jndt |r|jnd|r|jn|t |d p |r|j nd }||j|<ddddS#1swxYwYdS) Nframerr7r<securityOriginr8parentIdFr=rr7r8r9r;rr=) rrdrgr6rr9r:r;rr=)r$rr?rfrexistinginfos r%r!z!CDPSupervisor._on_frame_navigated)s 7##)r99T??  F   * *|''11H! %((.B//599%566S%))H:M:MSQSTT % * 5 5 iV^:h(:R:Rdh8Fh//GG:BRx66 6**Q/Px}}bRRD&*DL " * * * * * * * * * * * * * * * * * *sC> V   F   - -|''11H  H- (2I  - - - - - - - - L  Xt , , , - - - - - - - - - - - - - - - - - -s,CCCCcK|dpi}|d}|d}|r|dvrdS||d|j|<|dkr|d}|j5|j|}t |t |dpd d |r|jndd |t |d p |r|jnd  |j|<dddn #1swxYwYtj | |dS) N targetInforr)iframeworker)rkrrsrr7r<Ttitleri) rrtrdrgr6rr9r=rr_enable_child_domains)r$rrksid target_typerrjs r%r#z!CDPSupervisor._on_target_attachedbszz,''-2jj%%hhv&&  k)=== F-1;$G$GS! ( " ",,I!  <++I66*3&DHHUOO1r22AI%SX%=%=t!#&TXXg..UH3T8==RTVV+++ Y'                D66s;;<<<<>CCrc|dkru|dpi}t|dpd}|d}ttjd||}nt|dpd}|d vrd n |d krd nd}|d pg} g} | dd D]c} t | t rL| t| dp| dpddttj|d| }|j5|j |t|j tdzkr|j t d|_ ddddS#1swxYwYdS)NrexceptionDetailsrEr<r7)rCrDrEr7rlog)rassertrrargsrY description )rCrDrEr) rrrBr isinstancedictr>rrdrhrr) r$rrdetailsrEr7event raw_levelrDrpartsas r%r%zCDPSupervisor._on_consoles,  $ $jj!344:Gw{{6**0b11D++e$$C DIKK{SVWWWEEFJJv..7%88I(,???GG&)33  ::f%%+D!E"1"X T Ta&&TLLQUU7^^%Qquu]7K7K%Qr!R!RSSS DIKKu388E??SSSE   S S  ' ' . . .4'((+>+BBB'+';=P.s DDDa!2CDDDDr'c3(K|] }|j |VdSr)r;rs r%rz9CDPSupervisor._build_frame_tree_locked..s)66!1:6A666666r'rc8g|]}|jjk|dfS)r^)r9r)rTrrs r%rUz:CDPSupervisor._build_frame_tree_locked..s3. . . q/@CL/P/PQF/P/P/Pr'Tr^) rgrrrrFRAME_TREE_MAX_ENTRIESraddr;FRAME_TREE_MAX_OOPIF_DEPTHr>r&r9) r$framestopsrrqueuevisitedrfdepthrrs @r%rz&CDPSupervisor._build_frame_tree_lockeds EReDD DED6==??DDD66t66648QQTRR*, ;ReDD D. . . . "MMOO. . . !\N 1H (>>> 99Q<>>  I;;== "   r') rOrrNrrZrr[rrr\)rx)ryrrr\)r)rrH) rrrrrrryrrr rr\)r?rrr\r) rrrrr?rryrrr )rrrr r?rrr\)rr r?rrr\)rrrr:rrrr\)rrrr\)rrr2rrr\)rr rr\)rwrrr\)rr rrrr\r()"r)r*r+r,DEFAULT_DIALOG_POLICYDEFAULT_DIALOG_TIMEOUT_Srwrrrrrrrrrrrrr3r-r2rrrr<r r!r"r#rvr$r%rr.r'r%rYrYs*3": ++++++^<!!!!!<    ,&*#' 9?9?9?9?9?9?z%%%%>^-^-^-^-@AAAA:8888z,03 %) 333333488888====0(7(7(7(7TQQQQ*IIII@ N N N N* * * * X$$$$:M7M7M7M7^KKKKB ****(#-#-#-#-J====8////(@SSSS2( ( ( ( ( ( r'rYcDeZdZdZddZddZeed d ddZddZ ddZ dS)_SupervisorRegistryuProcess-global (task_id → supervisor) map with idempotent start/stop. One instance, exposed as ``SUPERVISOR_REGISTRY``. Safe to call from any thread — mutations go through ``_lock``. rr\cDtj|_i|_dSr)rbrc_lock_by_taskr#s r%rwz_SupervisorRegistry.__init__s^%% 24 r'rOrOptional[CDPSupervisor]cx|j5|j|cdddS#1swxYwYdS)z@Return the supervisor for ``task_id`` if running, else ``None``.N)rrr)r$rOs r%rz_SupervisorRegistry.gets Z . .=$$W-- . . . . . . . . . . . . . . . . . .s /33rx)rZr[ start_timeoutrNrZr[rrrYc|j5|j|}|||j|krV|jduo|j}|jduo|j}|r|r|cdddS|j|ddddn #1swxYwY|| t||||} | ||j5|j|} | -| j|kr"| | cdddS| |j|<dddn #1swxYwY| S)zIdempotently ensure a supervisor is running for ``(task_id, cdp_url)``. If a supervisor exists for this task but was bound to a different ``cdp_url``, the old one is stopped and a fresh one is started. N)rOrNrZr[r}) rrrrNrkrrjrrrrYr) r$rOrNrZr[rrj thread_okloop_ok supervisoralreadys r% get_or_startz _SupervisorRegistry.get_or_start sAZ 1 1}((11H##w.. ( 0 < \AQAZAZA\A\I&nD8XX^=V=V=X=XG (W(' 1 1 1 1 1 1 1 1 !!'4000 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1   MMOOO"'-    /// Z 0 0m''00G"w''A'A!!!  0 0 0 0 0 0 0 0 &0DM' "  0 0 0 0 0 0 0 0 0 0 0 0 0 0 0s0A1B-B--B14B1>=E EE"%E"c|j5|j|d}dddn #1swxYwY||dSdS)z=Stop and discard the supervisor for ``task_id`` if it exists.N)rrrr)r$rOrs r%rz_SupervisorRegistry.stop5s Z : :**7D99J : : : : : : : : : : : : : : :  ! OO      " !s 044c|j5t|j}|jdddn #1swxYwY|D]\}}|dS)zrs(#"""""  !!!!!!33333333333333666666  8 $ $ ,+))!;=VW3   4<&8<<<3r          4          8  @   $:p p p p p p p p lIIIIIIIIX*)++   r'