߲j3 UdZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z ddl m Z ddlmZmZmZej$eZdZdedZd Zd Zd ZiZeed fed <ej:Ze Gdd Zde fdZ!deefdZ"de#fdZ$de fdZ%de fdZ&dZ'ejPddede)fdZ*dede fdZ+de,fdZ-d3dede.de)fdZ/d edefd!Z0d4d"ejbd#eddfd$Z2d%e#dee#fd&Z3d%e#ddfd'Z4d(eddfd)Z5d*d+ded,e)deeeeeffd-Z6dedeefd.Z7deddfd/Z8d5d0Z9d%e#de)fd1Z:de#fd2Z;y)6aLightpanda local engine for Browser Use mode. With ``browser.engine: lightpanda``, Browser Use mode spawns one ``lightpanda serve`` per browser session and points ``browser_exec`` at its CDP endpoint (``BU_CDP_URL``); the built-in ``browser_*`` tools keep going through ``agent-browser --engine lightpanda``. ``tools.browser_tool`` owns the session cache, inactivity reaper and atexit sweep. N) dataclass)Path)DictOptionalTuplez=https://lightpanda.io/docs/run-locally/installation/one-linerzInstall Lightpanda from z& and make sure `lightpanda` is on PATHg$@g?iLightpandaServer_serversceZdZUeed<eed<ejed<eed<dZe eed<e defdZ de fd Z y) r session_nameportproclog_pathN start_timereturnc d|jS)Nhttp://127.0.0.1:)r selfs =/home/ubuntu/.hermes/hermes-agent/tools/browser_lightpanda.pycdp_urlzLightpandaServer.cdp_url+s"499+..c:|jjduSN)r pollrs ris_alivezLightpandaServer.is_alive/syy~~4''r)__name__ __module__ __qualname__str__annotations__int subprocessPopenrrpropertyrboolrrrrr#sQ I   M $J $ ///($(rrctj}|dz dz |dz dz dz g} ddlm}|j t|dz dz |S#t $r!}t jd|Yd}~|Sd}~wwxYw)Nz .lightpanda lightpandaz.localbinrget_hermes_homez1hermes home unavailable for lightpanda lookup: %s)rhomehermes_constantsr+append Exceptionloggerdebug)r, candidatesr+es r_home_candidatesr43s 99;D&5th7NQ]7]^JM4$01E9LHI  M H!LL Ms+A BA;;Bcrtjdk(rtjdytjj dd} ddlm}||}tjd | xstd tDdS#t$r }tjd|Yd}~Xd}~wwxYw) zReturn the lightpanda executable, or None. Order: PATH (with agent-browser's Homebrew/managed-node fallbacks), then installer/agent-browser locations, then ``$HERMES_HOME/bin``. No Windows build.ntzLightpanda has no Windows buildNPATHr)_merge_browser_pathz"browser PATH merge unavailable: %sr(pathc3K|]E}|jstj|tjs9t |Gywr)is_fileosaccessX_OKr).0cs r z)find_lightpanda_binary..Ks-UAqyy{ryyBGG?TQUsA $A A ) r>namer0r1environgettools.browser_tool_installr9r/shutilwhichnextr4)path_envr9r3s rfind_lightpanda_binaryrL>s ww$ 67zz~~fb)H>B&x0 << 8 4 ]U)+UW[9]] > 91==>s B B6B11B6cJtjtjtj5}|jtjtj d|j dt|jdcdddS#1swYyxYw)N) 127.0.0.1r) socketAF_INET SOCK_STREAM setsockopt SOL_SOCKET SO_REUSEADDRbindr! getsockname)socks r_pick_free_loopback_portrYNsp v~~v'9'9 :*d ))6+>+>B "#4##%a()***s ABB"cjddlm}t|dz dz dz }|jdd|S)Nrr*cachez browser-user(Tparentsexist_ok)r-r+rmkdir)r+r;s r _state_dirr`Us60 ! "W ,} <| KDJJtdJ+ KrcFtdz }|jdd|S)a\Filesystem HTTP cache shared by every Lightpanda this Hermes spawns. Shared rather than per-session so a cached asset survives session churn. Lightpanda holds it in sqlite (WAL) with a best-effort write path, and ``--http-cache-entry-limit`` (upstream default 1000, not passed here) bounds it without Hermes managing eviction. z http-cacheTr\)r`r_r:s r_http_cache_dirrb\s% <, &DJJtdJ+ Krz--http-cache-dirrN)maxsizebinaryc tj|dgdddtj}t|jxsd|j xsdzvS#t $r }tjd|Yd}~yd}~wwxYw) a_True if ``lightpanda serve`` accepts ``--http-cache-dir``. The flag landed upstream in 0.3.x; older binaries fatally reject it ("unknown argument"), which would break every launch. Probing ``help`` output keeps working across future flag additions without parsing versions, and the lru_cache keeps it once per binary per process. helpTg@)capture_outputtexttimeoutstdinr8z4lightpanda http-cache probe failed (%s); assuming noNF) r"runDEVNULL_HTTP_CACHE_FLAGstdoutstderrr/r0r1)rdr r3s r_binary_supports_http_cacherplss ~~ V dC$$   T[[%6B4;;;L"$MNN  KQOsAA A<A77A<r c"t|dz S)N.json)r`r s r _record_pathrts <\N%0 00rc ddlm}|S#t$r>}tj d|t j jcYd}~Sd}~wwxYw)Nr)_build_browser_envz/credential-scrubbed browser env unavailable: %s)tools.browser_toolrvr/r0r1r>rEcopy)rvr3s r _browser_envrysC!9!## ! FJzz  !s  A3A AAurlric~ ddlm}|||S#t$r!}tj d||Yd}~yd}~wwxYw)Nr)is_browser_debug_readyriz%CDP readiness probe failed for %s: %sF)hermes_cli.browser_connectr|r/r0r1)rzrir|r3s r _cdp_readyrs;E%c7;;  .sPRXXZPs) r read_bytes_STDERR_TAIL_LIMITdecodeOSErrorrJreversedr splitlines)r;rhs r_read_log_tailrstDz$$&(:':';<CCGT]C^ Phtzz|'>'>'@APRT UU s2A,, A87A8r whatc |j$|j |jdyy#t$r|j YywxYw#t$r!}t j d||Yd}~yd}~wwxYw)zRpoll -> terminate -> wait(5) -> kill; shared with the real-profile Chrome cleanup.Nr}z%s terminate failed: %s)r terminatewaitr/killr0r1)r rr3s r _terminatersr9 99;  NN   ! $     9 .a889s2 A7AAAA BA;;BpidcP ddlm}|j|S#t$rYywxYw)NrProcessRegistry)tools.process_registryr_safe_host_start_timer/)rrs r_safe_start_timers-:44S99 s  %%c6ddlm}|j||y)zFTree-kill ``pid`` via ProcessRegistry, verifying its start time first.rr)expected_startN)rr_terminate_host_pid)rrrs r _tree_killrs6''N'Krserverc|jj|jtj|j t j d} t|jdz jtj|dy#t$r+}tjd|j|Yd}~yd}~wwxYw)N)rr owner_pidr started_atrrrencodingz,could not write lightpanda record for %s: %s)r rr r>getpidrtimer`r write_textjsondumpsrr0r1)rrecordr3s r _write_recordrs[[__fkk "--TYY[JF] 6../u5 5AA$**VBT_fAg ] CVEXEXZ[\\]s>B C !CC F)block_private_networksrc t}|s tjdk(ryddtdfSt }|dddd t |g}t |r|tt tgz }|r|jd t t|d z } t|d 5}tj|tjtj|td }dddd|} t%j&t(z} j+} | "t-|} dd| d| d| rd| fSdfSt/| rnkt%j&| k\r:t1|t-|} | rd| dnd} dd| dt3t(d| fSt%j4t6t9||||t;|j<}t?|t@5|tB|<dddtDjGd|j<|||dfS#1swYAxYw#t tj"f$r}dd|d|fcYd}~Sd}~wwxYw#1swYlxYw)zStart ``lightpanda serve`` on a free loopback port; ``(server, None)`` once ``/json/version`` answers, else ``(None, error)``. stderr goes to ``/.log`` so a chatty child never blocks on a pipe.r6)Nzzbrowser.engine is 'lightpanda' but Lightpanda has no Windows build. Set browser.engine to auto (or run Hermes under WSL2).Nzjbrowser.engine is 'lightpanda' but no lightpanda binary was found on PATH, ~/.lightpanda or ~/.local/bin. z , or set browser.engine to auto.servez--hostrOz--portz--block-private-networksz.logwbT)rjrnroenvstart_new_sessionz#Failed to launch lightpanda serve (z): rz"lightpanda serve exited with code z before z/json/version answeredz: r8z (last stderr line: )z lightpanda serve did not expose z/json/version within sz9Started lightpanda serve (pid %s, port %s) for session %s)$rLr>rDLIGHTPANDA_INSTALL_HINTrYrrprmrbr.r`openr"r#rlryrSubprocessErrorr monotonic_READY_TIMEOUT_Srrrrr!sleep_POLL_INTERVAL_Srrrr _servers_lockr r0info)r rrdr argvrlog_filer r3rzdeadlinerctaildetailrs rlaunch_lightpandars$ %F  77d?[**A)BBbde e $ %D GX{Hc$i HD"6* !3'8#9:: ./:<\N$"778HJ (D ! aX##D 0B0B:K]K]+3[_aD a dV $C~~"22H  YY[ >!(+D=bT#NdtxgijnioepeBCC CAeBCC C c?  >> x ' t !(+D7;+D63F;C5@UVYZjVkUllmntmuvv v #$ lD$BRSWS[S[B\ ]F& (!'( KKKTXXW[]ij 4<7 a a Z// 0J:6(#aSIIIJ*((sC H4(AH'(H4/ I$'H1,H44I! II!I!$I-cdt5tj|cdddS#1swYyxYwr)rr rFrss r get_serverrs& *||L)***s&/ct5tj|d}dddX|jrH t |j j |j |j jd t|dz jd|tjd |yy#1swYxYw#t$r@}tjd|j|t|j Yd}~d}~wwxYw#t$rt|j YwxYw#t $r!}tjd||Yd}~d}~wwxYw) zaStop the server for ``session_name`` (tree-kill, plain terminate on failure) and drop its record.Nz&lightpanda tree-kill failed for %s: %srr}rrT missing_okz-could not remove lightpanda record for %s: %sz'Stopped lightpanda serve for session %s)rr poprrr rrr/r0r1r rrr`unlinkr)r rr3s rstop_lightpandars- 2lD12 foo/ $ v{{(9(9 : $ KK  Q  'W <.. .66$6G > M!22  $ LLA6CVCVXY Z v{{ # # $  $ v{{ # $ W DlTUVVWsLB;*C$D D7;C D6D  DD43D47 E!EE!ct5tt}dddD]} t|y#1swYxYw#t$r!}t j d||Yd}~Cd}~wwxYw)zEStop every server this process started. Idempotent; safe from atexit.Nz!lightpanda stop failed for %s: %s)rlistr rr/r0r1)namesrDr3s rstop_all_lightpandarsi XG G D !G  G LLrrr r!rrr) state_dirr3rreaped record_pathr rrrs rreap_orphaned_lightpandar-s L .FinnX67, "''  ZZ 5 5w 5 GHFfd+ #?V @U@U?V!WXX, JJ{+  # 8+  +  ;s9~6 jj )#c(FJJv4F S_H`a U3s8VZZ %=>!  RTWYef d+1,2 ME  ;Q? $    $  /      U KSRSTT Us` FGAG G8>AH F>F99F> G  G !G54G58H  H/H**H/)g?)r()rN)<__doc__ functoolsrloggingr>rHrPr" threadingr dataclassesrpathlibrtypingrrr getLoggerrr0LIGHTPANDA_INSTALL_URLrrrrr rr Lockrrrr4rLr!rYr`rbrm lru_cacher%rprtrryfloatrrr#rrrrrrrrrrr&rrrsv   !((   8 $X45K4LLvv*,$s&& ',    ( (  ($ ] ] *#*D  &Q (1s1t1!d!C%$VVV 9Z%% 9S 9D 9#(3-LCLDL ]*]t]LQ.C.D.UZ[cdt[uwADxE\EVF.b*S*X.>%?* N#N$N,G$$'#'r