$%h$"UddlmZddlZddlZddlmZmZmZddlm Z m Z ddl m Z m Z mZddlmZmZddlZddlZddlmZddlmZd d lmZmZd d lmZd d lmZej>d krddl m!Z!da"de#d<da$de#d<da%d)dZ&e d*dZ'd+dZ(ejRdd,dZ*ejRdd-dZ+ejRdd.dZ,ejZded/dZ.ejZd0dZ/ejZd1d Z0Gd!d"Z1ejZd#$d2d%Z2ejZd#$d2d&Z3ejZd3d'Z4ejZd4d(Z5y)5) annotationsN)Callable GeneratorIterator) ExitStackcontextmanager)isasyncgenfunctioniscoroutinefunctionismethod)Anycast) SubRequest)Exit)get_all_backendsget_async_backend)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 Q/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/anyio/pytest_plugin.pyextract_backend_and_optionsr$sq'3{ GU #G (9 gaj# &:gaj$+Gc4S>12G< < V WWc#\Ktt|}tatj j dMtj j|}tjtj j||xsi}tj|j|atdz a ttdza ts!tJtjdxaayy#tdza ts!tJtjdxaawwxYwwNr)rrrrsniffiocurrent_async_library_cvargetsetcallbackreset enter_contextcreate_test_runner_runner_leasesclose) backend_namebackend_optionsasynclibtokens r# get_runnerr6%s $\2!  - - 1 1$ 7 ?66::<HE  " "7#E#E#K#KU S)/R'55  ' ' 8 aN3! , ,,    !.2 2MO ! , ,,    !.2 2MOsB;D,>C71D,72D))D,c(|jddy)NmarkerszManyio: mark the (coroutine function) test to be run asynchronously via anyio.)addinivalue_line)configs r#pytest_configurer;Cs Wr%T) hookwrapperc#K dfd }|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$r6r run_asyncgen_fixture run_fixture) r>r?argskwargs local_funcr2r3runnerfunchas_backend_arghas_request_args r#wrapperz%pytest_fixture_setup..wrapperLs   T]]#tG,<,<'==..w/?/?@JJ(CM(R% o &3F? #  'F9   o 6 =&!*-!66z6JJJ((V<<  = =J = =s0BC'!C6C7C C'CC$ C'r>r?) rHr r>r r?rrIr returnr )rLr r fixturenamesargnames) fixturedefr?rOoriginal_argnamerLrMrNs @@@r#pytest_fixture_setuprWJs==#&=1;=GJ= =8 ??D$#6t#< g22 2%JO)22 '6*:M:M'MMOM##'99#'0J4G4G'GGOG##|3# 7"& &6 # N#' &6 #sB C&B<)C<C  C)tryfirstc8|j||rt|dr|jjn|}t |rX|j d}t |dd}|std|Dr%tjjd|yyyy)N hypothesisanyio pytestmarkc3:K|]}|jdk(yw)r[N)name).0markers r# z,pytest_pycollect_makeitem..sNV[[G3Nsr>) istestfunctionhasattrrZ inner_testr get_closest_markergetattranypytestmark usefixtures) collectorr_obj inner_funcra own_markerss r#pytest_pycollect_makeitemrp}sT*29#|2LS^^..RU z *11':F!#|R8KN+NN ''8=O ++r%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)r6run_test)rIrKr2r3 original_funcs r#run_with_hypothesisz/pytest_pyfunc_call..run_with_hypothesiss2  o 6 3& OOM6 2 3 3 3s*3r>rZT)rIr rRNone)funcargsr*r$rdrmrZre __qualname__r _fixtureinforTr6rtrrrrKeyboardInterrupt SystemExit) pyfuncitemrvr"rxargtestargsrKexcgrpexcr2r3rus @@@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)scopeparamsc|jSrs)paramrQs r#r>r>s ==r%c0t|tr|S|dS)NrrrrPs r#anyio_backend_namers-%Qr%c0t|triS|dSr'rrPs 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|_yrs)_kindr+int _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.kindszzr%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_ipv6appendAF_INET6rr.rbindOSError getsocknameradd)rfamilyfamiliesportstacksockaddrs r#__call__zFreePortFactory.__call__s   xH'H0D $& $F ..v}}VTZZ/PQD$*foo$=5;D 4,/ #//1!4 $4??2++D1# $ $ $#  $ $s7A D!D 4D7?D DDDDD")rsocket.SocketKindrRrw)rRrrs)rzsocket.AddressFamily | NonerRr)__name__ __module__ry__doc__rpropertyrrr]r%r#rrs% %$r%rsession)rc4ttjSrs)rr SOCK_STREAMr]r%r#free_tcp_port_factoryrs 6-- ..r%c4ttjSrs)rr SOCK_DGRAMr]r%r#free_udp_port_factoryrs 6,, --r%c|Srsr])rs r# free_tcp_portr  ""r%c|Srsr])rs r# free_udp_portrrr%)r"objectrRztuple[str, dict[str, Any]])r2rr3dict[str, Any]rRzIterator[TestRunner])r:r rRrw)rUr r?r rRzGenerator[Any])rlr r_r rmr rRrw)r}r rRz bool | None)r?r rRr )r>r rRr)r>r rRr)rRr)rCallable[[], int]rRr)rrrRr)6 __future__rrsyscollections.abcrrr contextlibrrinspectr r r typingr r rir(_pytest.fixturesr_pytest.outcomesr_core._eventlooprr_core._exceptionsrabcr version_infoexceptiongrouprr__annotations__rr0r$r6r;hookimplrWrprfixturer>rrrrrrrr]r%r#rs" 990EE '!A1g-%)")"& &X33(6333:T"/#/d$> >$! !Hh'7'9:;    :$:$zi /!/i .!.####r%