j8K dZddlmZddlZddlZddlZddlmZddlm Z m Z m Z m Z ddl mZmZmZmZddlmZdd lmZdd lmZdd lmZmZdd lmZmZmZdd lm Z m!Z!ddlm"Z#ddl$m%Z%m&Z&Gddej'Z(ddl)m*Z*m+Z+m,Z,gdZ-dS)uAAsync Playwright façade - mirrors sync_api but with async/await.) annotationsN)Path)AnyDictOptionalUnion)BrowserBrowserContext Playwrightasync_playwright)page_number_reserved)_session)resolve_cursor_engine)Profilegenerate_profile) SessionLocalepersona_cookiesprepare_session_geo)assert_wire_versionresolve_executable)configure_proxy) SessionToken guard_forcjeZdZdZ d.ddddddddddddd d/d!Zd0d#Zd$Zd%Zd1d&Zd2d)Z d3d,Z d1d-Z dS)4InvisiblePlaywrightzZAsync context manager - see invisible_playwright.InvisiblePlaywright for the sync variant.NFTauto) pinheadlessproxy extra_argshumanizelocaletimezone extra_prefs binary_path profile_dirprep_recaptcha show_cursorseed Optional[int]rOptional[Dict[str, Any]]r boolr!Optional[Dict[str, str]]r"Optional[list[str]]r#Union[bool, float]r$strr%r&r' Optional[str]r(Optional[Union[str, Path]]r)r*Optional[bool]returnNonec |t|ntjd|_||_||_||_t|pg|_||_ t||_ | dnt| |_ ||_d|_||_| |_| |_| rt'| nd|_t| o|jdu|_t-|j|j|_d|_d|_d|_d|_t9|_t=|_d|_ d|_!d|_"d|_#dS)N)rgr)$intsecretsrandbitsr+_pin _headless_proxylist _extra_args _humanizer_cursor_enginer. _show_cursor_locale_requested_locale _timezone _extra_prefs _binary_pathr _profile_dir_prep_recaptchar_profile_pw_browser_persistent_context_virtual_displayr_session_tokenr_lifetime_guard_webrtc_egress_ip_srflx_declared_ultimo_controllo_uscita_uscite_non_misurabili)selfr+rr r!r"r#r$r%r&r'r(r)r*s NC:\Projects\Muse2API\.venv\Lib\site-packages\invisible_playwright/async_api.py__init__zInvisiblePlaywright.__init__se$'+&6TGT        { !% $4466((9:: ,,.. !!##24;FF*/11ooe$$# -//5577777777DH ,!''t'DDD2\1A1[ 2"%d&7"8"8$' OO(',*) 2 22244 2 2 , , , , , ,('')))''(@AAA//"&("2"9"9 #J$#(&% #:##DM  . . .  # # % % % %   .."" " " " " " " "   ((777  ...}s0C"H>A*H>>&I$g^@cK|jr|jsdStj}||jz |jkrdS||_t jdtj |j|jd{V\}}|tj kr tj d|jd|d|tj kr>|xjdz c_|j|jkrtjd|jzdSd|_dS)zRejects if the egress IP has changed since launch. See the sync twin in `launcher.py` for why it does not update on the fly.NzCthe proxy's egress IP changed during the session: at launch it was z , now it is a-. The WebRTC srflx candidate still declares the first one, so from this moment the page exits from one address and WebRTC announces another - the disagreement detectors look for. This proxy does not hold the session sticky for the required duration: use one that guarantees it, or shorten the session.ra0the egress IP could not be verified for %d checks in a row. It is not drift - the probe did not respond at all - but it is not agreement either: from here on the engine would be declaring an address on every page that nobody confirms anymore. Check that the proxy is reachable, then relaunch the session.r)r?rStime monotonicrU_INTERVALLO_CONTROLLO_USCITA_Sreget_running_looprun_in_executorregress_ancora_validoUSCITA_DERIVATAProxyEgressDriftedUSCITA_NON_MISURABILErV_MAX_USCITE_NON_MISURABILIProxyEgressNonVerificabile)rWnowoutcomecurrents rX_assert_uscita_invariataz,InvisiblePlaywright._assert_uscita_invariatasY{ $"8  Fn . .1T T T F(+%!(!9!;!;!K!K (/  ""$"$$$$$$$ h. . .--)))7774 5 5 5 h4 4 4  ' '1 , ' '*d.MMM9E 1 2333 F&'###rZbrowserr c jjj j fd  fd}|_j fd}|_dS)aBoth entry points, for the reason spelled out in the sync launcher: Playwright's `Browser.new_page` forwards to the IMPLEMENTATION object, whose own `new_page` calls `self.new_context` - itself - so a wrapper installed on the api object is never consulted, and `await browser.new_page()` opened a page with the stock viewport and colour scheme against a fingerprint claiming the profile's screen.cK |td{VdS#t$rYdSwxYwN) add_cookiesr Exception)ctxlocprofiles rX seed_cookieszEInvisiblePlaywright._patch_new_context_defaults..seed_cookiessb ooogs&C&CDDDDDDDDDDD    s )0 >>cK d{Vt}||di|d{Vrd{Vj fd}|_S)NcKtjj5d{Vdi|d{VcdddS#1swxYwYdSNrd)r _impl_objrNr)kw2 _new_page_ctxrrWs rX_new_page_guardedz[InvisiblePlaywright._patch_new_context_defaults..patched.._new_page_guardeds *#-*@AA6677999999999!.!5!5!5!5555555666666666666666666s(AAArd)rdictupdatenew_page) kwmergedrrrdefaultsoriginalpreprrWs @@rXpatchedz@InvisiblePlaywright._patch_new_context_defaults..patcheds//11 1 1 1 1 1 1 1(^^F MM"    **6********C ("l3''''''''' LM 6 6 6 6 6 6 6-CLJrZc0Ktj5 d{Vt}||di|d{V}dddn #1swxYwY|j}r|d{V|Sr)r rrrrcontext) rrpagerrr original_pagerrrWs rX patched_pagezEInvisiblePlaywright._patch_new_context_defaults..patched_page's %g&788 5 533555555555h b!!!*]44V44444444  5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 ,C ("l3'''''''''KsA A11A58A5N) new_contextrrrKrLrFr) rWrrrrrrrrrrs `` @@@@@@@rXrxz/InvisiblePlaywright._patch_new_context_defaultss&//11#-l               @&(           (rZexcrc>K|d{VdSr)rw)rWrs rX __aexit__zInvisiblePlaywright.__aexit__6s.nnrZcKddfd } |j/||jd{Vd|_|j/||jd{Vd|_|j/||jd{Vd|_|j2 |jn#t $rYnwxYwd|_|jrD |j |jn#t $rYnwxYwt|_nP#|jrD |j |jn#t $rYnwxYwt|_wxYwdS)uShut everything down, and finish doing it even while being cancelled. ⛔ `except Exception` DOES NOT CATCH A CANCELLATION, and that is the whole reason this is not four plain try/excepts any more. When the task running this is cancelled, the `await` below raises `asyncio.CancelledError`, which inherits from `BaseException` and not from `Exception` - so it escapes, teardown stops at whichever step it had reached, and everything after it is skipped. What survives is a browser nobody closes: the exact orphan this project has already measured twice, once as 88 stray firefox processes and once as 7,308 leftover profile directories. So a cancellation is CAUGHT, kept, and re-raised at the end - the cancellation still propagates, as asyncio requires, but only after every step has had its turn. Reported by DatGuy1 as #104 against the published `main` and fixed here in the same shape. ⛔ AND THE REAPING IS IN A `finally`, not last in the body: it is the one step that must run even if the loop above dies in a way this does not model. Nothing carrying this session's token may outlive it. Nsteprr6r7ctK |d{VdS#tj$r }|Yd}~dSd}~wt$rYdSwxYwr)reCancelledErrorr)rstop cancelleds rXclosez,InvisiblePlaywright._teardown..closeQsm  ) ! ! !     s7& 77)rrr6r7) rOrrNrMrrPrrQrRreapr)rWrrs @rXrwzInvisiblePlaywright._teardown9s,.2        5'3eD4::<<=========+/(}(eDM//11222222222 $ x#eDHMMOO,,,,,,,,,$0)..0000 D(,%" 5(--d.ABBBB D&2nn# " 5(--d.ABBBB D&2nn#4444  O ! sfB)D47CD4 CD4C D40D DD4F=EF E*'F)E**Fr)r+r,rr-r r.r!r/r"r0r#r1r$r2r%r2r&r-r'r3r(r4r)r.r*r5r6r7)r6r[)r6r7)rr r6r7)rrr6r7) __name__ __module__ __qualname____doc__rYr~rrrrxrrwrdrZrXrrsdd#M-)-*.*.'+04%)26$&*M-M-M-M-M-M-^JJJJb&+""#)()()()(VF(F(F(F(R<<<<<<rZr)ErrorTargetClosedError TimeoutError)rrrr).r __future__rrer;rpathlibrtypingrrrr"invisible_playwright._pw.async_apir r r r /invisible_playwright._pw._impl._browser_contextr rr_cursorrinvisible_core._fpforgerrinvisible_corerrr_enginerrrrk_reaperrr CommonLaunchr&invisible_playwright._pw._impl._errorsrrr__all__rdrZrXrsGG"""""" ------------ddddddddddddPPPPPP******========NNNNNNNNNN<<<<<<<<EEEEEE,,,,,,,,_____(/___V ,,,,,,,,,, P O OrZ