i1UddlmZddlZddlmcmZddlZddl Z ddl Z ddl m Z m Z mZddlmZmZddlmZmZmZddlmZmZddlZddlmZmZddlmZdd lm Z dd l!m"Z"d d l#m$Z$d d l%m&Z&m'Z'm(Z(m)Z)d dl*m+Z+d dl,m-Z-e j\dkrddl/m0Z0da1de2d<da3de2d<da4d.dZ5e d/dZ6d0dZ7d1dZ8ejrdd2dZ:ejrd d3dZ;d4d Z<ejrdd5d!Z=ej|d"e$#d6d$Z?ej|d7d%Z@ej|d8d&ZAGd'd(ZBej|d)d9d*ZCej|d)d9d+ZDej|d:d,ZEej|d;d-ZFy)<) annotationsN)Callable GeneratorIterator) ExitStackcontextmanager)isasyncgenfunctioniscoroutinefunctionismethod)Anycast)FuncFixtureInfo SubRequest)Exit) CallSpec2)Scope)get_available_backends)current_async_libraryget_async_backendreset_current_async_libraryset_current_async_library)iterate_exceptions) TestRunner) )ExceptionGroupzTestRunner | None_current_runnerzExitStack | None _runner_stackct|tr|ifSt|tr^t|dk(rPt|dtr=t|dtr*t ttttt ff|Std)Nrrz@anyio_backend must be either a string or tuple of (string, dict)) isinstancestrtuplelendictr r TypeError)backends L/home/work/apex_v16/venv/lib/python3.12/site-packages/anyio/pytest_plugin.pyextract_backend_and_optionsr*#sq'3{ GU #G (9 gaj# &:gaj$+Gc4S>12G< < V WWc #Ktnt|}tat %t |}tj t||xsi}tj|j|atdz a ttdza tsd}t|u}|stjd|fdt|fdtjvstjtrtj tndtj |dz}dd|iz}t#tj$|dx}}tj'dxaayy#tdza tsd}t|u}|stjd|fdt|fdtjvstjtrtj tndtj |dz}dd|iz}t#tj$|dx}}tj'dxaawwxYww)Nr)is not)z%(py0)s is not %(py3)sr)py0py3zassert %(py5)spy5)rrrrrrcallbackr enter_contextcreate_test_runner_runner_leases @pytest_ar_call_reprcompare @py_builtinslocals_should_repr_global_name _safereprAssertionError_format_explanationclose) backend_namebackend_optionsasynclibtoken @py_assert2 @py_assert1 @py_format4 @py_format6s r) get_runnerrF-s $\2! " *.l;E  " "#> F)/R'55  ' ' 8 aN3!(, ,=, , , ,= , , , , , ,= , , ,= , , , , , , , , , ,    !.2 2MO !(, ,=, , , ,= , , , , , ,= , , ,= , , , , , , , , , ,    !.2 2MOs A>I E' CI 'CII c,|jdddy)N anyio_modestrictz-AnyIO plugin mode (either "strict" or "auto"))defaulthelp)addini)parsers r)pytest_addoptionrNKs MM <r+c|jdd|jddk(rW|jjdr;|jddk(r&|j t j ddyyyy) NmarkerszManyio: mark the (coroutine function) test to be run asynchronously via anyio.rHautoasyncio asyncio_modezlAnyIO auto mode has been enabled together with pytest-asyncio auto mode. This may cause unexpected behavior.r)addinivalue_linegetini pluginmanager has_pluginissue_config_time_warningpytestPytestConfigWarning)configs r)pytest_configurer\Ss W  l#v-  + +I 6 MM. )V 3((  & &<     4 7 .r+T) hookwrapperc#Kdfd }|jts tr~d|jvrp||_|j}d|jvxs|xjdz c_d|jvxs|xjdz c_ d|_||_SdS#|_||_wxYww)N anyio_backendrequestc;K|jr[trPtjt|jur&jj |j}n}t |\}}r||d< r||d<t||5}t|r|j||Ed{n|j||dddy7"#1swYyxYww)Nr_r`) instancer type__self____func____get__r*rFr run_asyncgen_fixture run_fixture) r_r`kwargs local_funcr>r?runnerfunchas_backend_arghas_request_args r)wrapperz%pytest_fixture_setup..wrapperhs   T]]#tG,<,<'==..w/?/?@JJ(CM(R% o &3F? #  'F9   o 6 =&!*-!66z6JJJ((V<<  = =J = =s0BC'!C6C7C C'CC$ C'r_r`)r_r r`rrir returnr )rlr r fixturenamesargnames) fixturedefr`rooriginal_argnamerlrmrns @@@r)pytest_fixture_setuprwfs=4 ??D$#6t#< g22 2%JO)22 '6*:M:M'MMOM##'99#'0J4G4G'GGOG##|3# 7"& &6 # N#' &6 #sBCB2C2CC)tryfirstcx|j||rt|dr|jjn|}t |rx|j j ddk(}|jd}t|dd}|s|std|Dr%tjjd|yyyy) N hypothesisrHrQanyio pytestmarkc3:K|]}|jdk(yw)r{N)name).0markers r) z,pytest_pycollect_makeitem..sH&v{{g-Hsr_) istestfunctionhasattrrz inner_testr r[rUget_closest_markergetattranyrYmark usefixtures) collectorrobj inner_funcanyio_auto_moder own_markerss r)pytest_pycollect_makeitemrsT*29#|2LS^^..RU z *'..55lCvMO11':F!#|R8KHKHH ''8=I ++r+sessionc Pttt|jD]\}}t |t j s"t|js8|jdJd|jvsYg} tjtDchc]}|j}}tt#D](\}}d|vr&td|id|idt$j&i|gg}n&tid|id|idt$j&i|gg}|j(} t| j*} d| vr| j-dt/| j0| j2| | j4} t j j7|j8|j:d|d||j<| |j>|j: } |j-| +||j||d zycc}w#t$rt!}YpwxYw) Nr{r_ _arg2scope)paramsindicesr_idlistmarks)funcargsrr arg2scopeidlistr)rt initialnames names_closurename2fixturedefs[])rcallspeccallobj fixtureinfokeywords originalnamer) reversedlist enumerateitemsr"rYFunctionr functionrrs dataclassesfieldsrrr'setrrModule _fixtureinforappendrrtrr from_parentparentrrr) riitem new_itemsf cs_fields param_indexr(rfinew_names_closurenew_fixtureinfonew_items r)pytest_collection_finishrs D7==!9:;614 tV__ -#DMM2''0<t'8'88I "-8-?-? -JKQVVK K)22H2J(K' +$ W9,( /9!0+ >$3U\\#B!(   H )!# /9!0+ >#2ELL"A 'y  H&&$()9)9$:!"*;;%,,_="1[[!#"3%'%8%8 # "??66KK --.ay:% HH /!]]!%!2!27  *O' +R(1GMM!a!e $m61L "E  "s$HH 2H HH%$H%c  d fd }|jjd}|rt|\ t|jdr`|jj j j|jk7r&t r||jj _yt|jrg|j}|jjDcic]}||| }}t 5} |j|j| dddyycc}w#t$r4}t|D] }t|t t"t$fs||d}~wwxYw#1swYyxYw)Nclt5}|j|dddy#1swYyxYwN)rFrun_test)rirkr>r? original_funcs r)run_with_hypothesisz/pytest_pyfunc_call..run_with_hypothesiss2  o 6 3& OOM6 2 3 3 3s*3r_rzT)rir rrNone)rgetr*rrrzr __qualname__r rrtrFrrrr"rKeyboardInterrupt SystemExit) pyfuncitemrr(rargtestargsrkexcgrpexcr>r?rs @@@r)pytest_pyfunc_callrsQ3!!%%o6G(CG(L% o :>>< 0&NN55@@M))-@-M-MM&}5;NJNN--8 z~~ .!**H6@6M6M6V6VWsXc]*WHWL/: fOOJNNH=  X&1&92%cD2CZ+PQ"%612  s6' D+E0D00 E-9)E(#E((E--E00E9module)scoperc|jSr)paramrqs r)r_r_s ==r+c0t|tr|S|dS)Nrr"r#rps r)anyio_backend_namer s-%Qr+c0t|triS|dS)Nrrrps r)anyio_backend_optionsrs-% Qr+c4eZdZdZddZeddZdd dZy) FreePortFactoryaO Manages port generation based on specified socket kind, ensuring no duplicate ports are generated. This class provides functionality for generating available free ports on the system. It is initialized with a specific socket kind and can generate ports for given address families while avoiding reuse of previously generated ports. Users should not instantiate this class directly, but use the ``free_tcp_port_factory`` and ``free_udp_port_factory`` fixtures instead. For simple uses cases, ``free_tcp_port`` and ``free_udp_port`` can be used instead. c>||_tt|_yr)_kindrint _generated)selfkinds r)__init__zFreePortFactory.__init__+s c(*r+c|jS)z The type of socket connection (e.g., :data:`~socket.SOCK_STREAM` or :data:`~socket.SOCK_DGRAM`) used to bind for checking port availability )r)rs r)rzFreePortFactory.kind/szzr+NcJ||g}n@tjg}tjr|jtj d}t 5}|D]r}|j tj||j}|tjk(rdnd} |j||f|r`|jd}t||jvr&|jj||cdddSddd#t$rYwxYw#1swYxYw)z Return an unbound port for the given address family. :param family: if omitted, both IPv4 and IPv6 addresses will be tried :return: a port number Nrz::1z 127.0.0.1r) socketAF_INEThas_ipv6rAF_INET6rr2rbindOSError getsocknameradd)rfamilyfamiliesportstacksockaddrs r)__call__zFreePortFactory.__call__8s   xH'H0D $& $F ..v}}VTZZ/PQD$*foo$=5;D 4,/ #//1!4 $4??2++D1# $ $ $#  $ $s7A D!D 4D7?D DDDDD")rsocket.SocketKindrrr)rrrr)rzsocket.AddressFamily | Nonerrr)__name__ __module__r__doc__rpropertyrrr}r+r)rrs% %$r+r)rc4ttjSr)rr SOCK_STREAMr}r+r)free_tcp_port_factoryrZs 6-- ..r+c4ttjSr)rr SOCK_DGRAMr}r+r)free_udp_port_factoryr_s 6,, --r+c|Srr})rs r) free_tcp_portrd ""r+c|Srr})rs r) free_udp_portrirr+)r(objectrrztuple[str, dict[str, Any]])r>r#r?dict[str, Any]rrzIterator[TestRunner])rMz pytest.Parserrrr)r[z pytest.Configrrr)rur r`r rrzGenerator[Any])rzpytest.Module | pytest.Classrr#rrrrr)rzpytest.Sessionrrr)rr rrz bool | None)r`r rrr )r_r rrr#)r_r rrr)rrr)rCallable[[], int]rrr)rrrrr)G __future__rbuiltinsr7_pytest.assertion.rewrite assertionrewriter5rrsyscollections.abcrrr contextlibrrinspectr r r typingr r rY_pytest.fixturesrr_pytest.outcomesr_pytest.pythonr _pytest.scoperr_core._eventlooprrrr_core._exceptionsrabcr version_infoexceptiongrouprr__annotations__rr4r*rFrNr\hookimplrwrrrfixturer_rrrrrrrr}r+r)rs" 990EE 8!$$ 2g-%)")"& &X33(6333: &T"-#-`$>+>36>=C> > >"71t$! !Hh'='?@A    :$:$zi /!/i .!.####r+