+ lHj <`Rt^RIHt^RIt^RIt^RIt^RIt^RIt^RIH t ^RI H t H t H t Ht^RIHtHt]P$!R4tRRltR R lt]!R R 04tR RltRtRtRt]!]]]04t]tRt^tRt R] R2t!Rt"] !RR44t#] !RR44t$!RR4t%R#)uTDialog capture + response half of the CDP supervisor. Two capture paths feed one ``PendingDialog`` queue: native ``Page.javascriptDialogOpening`` events (answered with ``Page.handleJavaScriptDialog``), and the injected *dialog bridge* — a page script rewriting alert/confirm/prompt into a sync XHR to a magic host we intercept via the CDP ``Fetch`` domain and answer with ``Fetch.fulfillRequest``. The bridge works on Browserbase (whose CDP proxy auto-dismisses native dialogs) because the native dialog never fires. ``DialogSupervisionMixin`` relies on state ``CDPSupervisor.__init__`` sets. ) annotationsN) dataclass)AnyCallableDictOptional)parse_qsurlparseztools.browser_supervisorc V^8dQhRRRR/#)valuestrreturn)formats"E/home/ubuntu/.hermes/hermes-agent/tools/browser_supervisor_dialogs.py __annotate__rs443434c"^RIHpV!VRR7#)zARedact page-originated text before exposing supervisor snapshots.)redact_sensitive_textT)force) agent.redactr)r rs& r_redact_supervisor_textrs2 d 33rc$V^8dQhRRRRRR/#)r eventslistkeepintrr)rs"rrr!s&@@t@3@4@rc>\V4V^,8dW)R#T#)zTCap a ring buffer at ``keep`` entries once it overflows to 2x (slack reduces churn).N)len)rrs&&r _trim_ringr !s" [4!836%&>??rmessagedefault_promptc$V^8dQhRRRRRR/#)r objrkeystuplerdict[str, Any]r)rs"rrr)s&uucuu>urc VUu/uF-q"V\9d\\W44M \W4bK/ up#uupi)zDSnapshot dict of ``keys`` with page-originated text fields redacted.)_REDACTED_FIELDSrgetattr)r$r%ks&& r _dialog_dictr,)s;os tosjk1@P;P&ws7V]^aVe eos tt ts3; must_respond auto_dismiss auto_acceptgr@zhermes-dialog-bridge.invalidzhttp://z/*a (() => { if (window.__hermesDialogBridgeInstalled) return; window.__hermesDialogBridgeInstalled = true; const ENDPOINT = "http://hermes-dialog-bridge.invalid/"; function ask(kind, message, defaultPrompt) { try { const xhr = new XMLHttpRequest(); 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; let parsed; try { parsed = JSON.parse(xhr.responseText || ""); } 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) { return null; } } 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); }; })(); c]tRt^nt$RtR]R&R]R&R]R&R]R&R]R&R]R &R tR ]R &R tR ]R &RRltRt R #) PendingDialogz3A JS dialog currently open on some frame's session.r idtyper!r"float opened_atcdp_session_idN Optional[str]frame_idbridge_request_idcV^8dQhRR/#r rr'r)rs"rrPendingDialog.__annotate__|shhhrc \VR4#)r2)r2r3r!r"r5r8r,selfs&rto_dictPendingDialog.to_dict|sD"fggrr) __name__ __module__ __qualname____firstlineno____doc____annotations__r8r9rA__static_attributes__rrrr1r1nsG= G I L"Hm"'+}+hhrr1cr]tRt^t$RtR]R&R]R&R]R&R]R&R]R&R]R &R tR ]R &R RltRtR #) DialogRecordzOA dialog that was opened and then handled (kept briefly in ``recent_dialogs``).r r2r3r!r4r5 closed_at closed_byNr7r8cV^8dQhRR/#r;r)rs"rrDialogRecord.__annotate__sppprc \VR4#)r2r2r3r!r5rLrMr8r>r?s&rrADialogRecord.to_dictsD"noorr) rCrDrErFrGrHr8rArIrrrrKrKs;Y G I LN"Hm"pprrKc]tRt^t$RtRRltRRltRRltRR ltR R /R R llt RRlt RRlt RRlt RRlt RRltRRltRRltR]R]R]/tR]R &R!tR #)"DialogSupervisionMixinzJDialog event handling for ``CDPSupervisor`` (all methods run on its loop).c 0V^8dQhRRRRRRRRR RR R /#) r methodr paramsr' session_idr7timeoutr4whatrNoner)rs"rr#DialogSupervisionMixin.__annotate__sB@@s@N@S`@"'@/2@7;@rc "VPWW4R7GRjxL R#L \d#p\PRYT4Rp?R#Rp?ii;i5i)zABest-effort CDP call: failures are logged at debug and swallowed.rXrYNz%s failed (%s): %s)_cdp Exceptionloggerdebug)r@rVrWrXrYrZes&&&$$$ r _cdp_quiet!DialogSupervisionMixin._cdp_quietsF @))Fz)S S S @ LL-vQ ? ? @s6A#!#A# AA A AAc V^8dQhRRRR/#)r rXr rr[r)rs"rrr\seeseterc "T;'gRR,pRR\RR/RRV 23R R R \R R /.RR/RRV 23RR\RR/RRV 233pVF"wrErgVPWEWVR7GRjxL K$ R#L 5i)a2Install the dialog-bridge init script + Fetch interceptor on a session. Idempotent at the CDP level (Chromium de-dupes identical add-script calls; Fetch.enable replaces prior patterns); the final Runtime.evaluate injects into the already-loaded document so existing pages pick up the override on reconnect.:NNz%Page.addScriptToEvaluateOnNewDocumentsourcerunImmediatelyT@zdialog bridge sid=z Fetch.enablepatterns urlPattern requestStageRequesthandleAuthRequestsFzRuntime.evaluate expression returnByValue@zdialog bridge inject sid=rXrYrZN)_DIALOG_BRIDGE_SCRIPTDIALOG_BRIDGE_URL_PATTERNrd)r@rXsidstepsrVrWrYrZs&& r_install_dialog_bridge-DialogSupervisionMixin._install_dialog_bridges R% 4xAVXhjn6o &se, . jL:SUcen+o*p2E;!D!D!F G!FQ!W!F G v))'155B3GXYX]X]^nprXs!JJy,AUXYcUd   Z Hs1A D6(D68D.95D6.D0%D6(AD60D6r9Nc4V^8dQhRRRRRRRRRRRRR R /#) r r3r r!r"rXr7r8r9rr[r)rs"rrr\sA  S 3  Yf - BO [_ rc  PaaS;P^, un\RSP 2YT\P!4T;'gSP;'gRWVR7o\R \ RV3/P SP4pVehSP;_uu_4SPSR4RRR4\P!SPSV^,V^,R74R#SP;_uu_4SSPSP&RRR4\P!4P!SP"VV3Rl4SP$SP&R# +'giL;i +'giLp;i) zCreate the dialog and apply the policy: auto-respond, or queue + arm the watchdog. Auto policies archive FIRST (tagged ``auto_policy``) so the ``closed`` event that follows our own response isn't re-archived as ``remote``.zd-rh)r2r3r!r"r5r6r8r9TN auto_policyaccept prompt_textcb<\P!SPSP44#N)asyncio create_task_dialog_timeout_expiredr2)dialogr@sr6DialogSupervisionMixin._admit_dialog..sG''(D(DVYY(OPr)Frh) _dialog_seqr1time_page_session_idDIALOG_POLICY_AUTO_DISMISSDIALOG_POLICY_AUTO_ACCEPTr dialog_policy _state_lock_archive_dialog_lockedrr_respond_quiet_pending_dialogsr2get_running_loop call_laterdialog_timeout_s_dialog_watchdogs) r@r3r!r"rXr8r9autors f$$$$$$ @rr$DialogSupervisionMixin._admit_dialogsI AD$$%&TSaiik*2[2[@U@U2[2[Y[  +K9RUY[iTjkoo      !!!++FMB"    3 3F47X\]^X_ 3 ` a     /5D ! !&)) ,,3,D,D,F,Q,Q  ! ! P- vyy) "! s,FF F  F% c(V^8dQhRRRRRRRR/# r rr1rboolrr7rr[r)rs"rrr\s0cc]ctcR_cdhcrc b"VP;'gRpVP'd\P!R\ V4RVP RVP R8Xd T;'gRMR/4P4pVPRRVPR ^R R R R R/R RR R/.R\P!V4P4/VRRVP 2R7GRjxL R#RV/pVeVP R8XdW6R&VPRWdRR7GRjxL R#LAL5i)uBridge-fulfill for XHR-captured dialogs (swallows failures so the page unblocks), else native CDP — ``promptText`` only for prompt dialogs when given; raises on CDP failure.Nr dialog_idrpromptrhzFetch.fulfillRequestr responseCoderesponseHeadersnamez Content-Typer zapplication/jsonzAccess-Control-Allow-Origin*bodyrlzbridge fulfill ru promptTextzPage.handleJavaScriptDialogr^) r6r9jsondumpsrr2r3encoderdbase64 b64encodedecoder_)r@rrrrXrrWs&&$$ r_respondDialogSupervisionMixin._respondsC**22d  # # #::xf{FII,V[[T\E\{/@/@bbdfggmgmgo //&f66"fngGY%Z&,.KWVY%Z%\))$/668:&s?699+9V "   "*F!3  "v{{h'>#.< ii5v^aibbb  cs0(D/AD/-A [||Y T=R=R T Iz2!!&D!III  Js(B<B'A-B< B:!B<' B7 2 B<c$V^8dQhRRRRRR/#)r rr rMrr[r)rs"rrr\s!rc ,VP;_uu_4VPPVR4pVeVPW24RRR4VPPVR4pVeVP 4R#R# +'giLD;i)zRRemove a pending dialog (archiving it with ``closed_by``) and cancel its watchdog.N)rrpoprrcancel)r@rrMrhandles&&& rr%DialogSupervisionMixin._retire_dialogsv    **..y$?F!++F>''++It<   MMO   s 2B B c$V^8dQhRRRRRR/#)r rr1rMr rr[r)rs"rrr\s&__]_s_t_rc  \VPVPVPVP\ P !4W!P R7p\.VPOVN\4VnR#)zNMove a pending dialog to the recent_dialogs ring buffer. Must hold state_lock.rQN) rKr2r3r!r5rr8r _recent_dialogsRECENT_DIALOGS_MAX)r@rrMrecords&&& rr-DialogSupervisionMixin._archive_dialog_lockedsZfnn`f`p`p(, ySbSbd)*ID,@,@*I&*IK]^rc$V^8dQhRRRRRR/#r}r)rs"rrr\$s"55n5-5\`5rc a"VP;_uu_4\V3RlVPP44R4pRRR4X'dVP VR4R#R# +'giL.;i5i)c3<"TF4pVPS8XgKVPeK&VPxK6 R#5ir)r6r9r2).0drXs& r ;DialogSupervisionMixin._on_dialog_closed..)s;a,Jq!"!1!1Z!?#DEDWDW#add,Js ? ??Nremote)rnextrvaluesr)r@rWrX candidates&&f r_on_dialog_closed(DialogSupervisionMixin._on_dialog_closed$sf   aD,A,A,H,H,JabfhI     8 4  s"B/A-BB- A= 8BzPage.javascriptDialogOpeningzPage.javascriptDialogClosedzFetch.requestPausedzdict[str, Callable[..., Any]]EVENT_HANDLERS)r)rCrDrErFrGrdrzrrrrrrrrrrrrHrIrrrrTrTsrT@e&  $ RV 8c,J4 J_ 5 '(:%'8/5N1rrT)&rG __future__rrrrloggingr dataclassesrtypingrrrr urllib.parserr getLoggerrarr frozensetr)r,DIALOG_POLICY_MUST_RESPONDrr_VALID_POLICIESDEFAULT_DIALOG_POLICYDEFAULT_DIALOG_TIMEOUT_Srrrwrvr1rKrTrrrrs#  !00+   5 64@ i)9:;u ,+)!;=VW3 4%&8%9< 'T hh h"  p p  pccr