ߎj6xUddlmZddlZddlmcmZddlZddl 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<da4dLdZ5edMd Z6dNd$Z7dOd'Z8ej9d()dPd.Z:ej9d(/dQd4Z;dRd7Z<ej9d(/dSd:Z=ej>d;e$<dTd=Z?ej>dUd?Z@ej>dVd@ZAGdAdBZBej>d5CdWdDZCej>d5CdWdEZDej>dXdIZEej>dYdKZFdS)Z) 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_stackbackendobjectreturntuple[str, dict[str, Any]]ct|tr|ifSt|trt|dkrot|dtrTt|dtr9t ttttt ff|Std)Nrrz@anyio_backend must be either a string or tuple of (string, dict)) isinstancestrtuplelendictr r TypeError)r s AC:\Projects\DSCons\.venv\Lib\site-packages\anyio\pytest_plugin.pyextract_backend_and_optionsr-#s'3={ GU # #=G (9(9 gaj# & & =:gaj$+G+G =c4S>12G<< < V W WW backend_namer'backend_optionsdict[str, Any]Iterator[TestRunner]c #Ktt|}tat /t |}tt||pi}t| |atdz a tVtdza tsd}t|u}|stj d|fdt|fdtjvstjtrtjtndtj|dz}dd|iz}t#tj|dx}}tdxaadSdS#tdza tsd}t|u}|stj d|fdt|fdtjvstjtrtjtndtj|dz}dd|iz}t#tj|dx}}tdxaawxYw)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)r/r0asynclibtoken @py_assert2 @py_assert1 @py_format4 @py_format6s r, get_runnerrK-s $\22! " " *.l;;E  " "#> F F F)/R'55  ' ' 8 8  aN3! 3(, ,=, , , , , , , , , ,= , , , , , , , , , , , ,= , , , , ,= , , , , , , , , , , , , , , , , , , , , , , , , , , , , , , ,    ! ! !.2 2MOOO 3 3 ! 3(, ,=, , , , , , , , , ,= , , , , , , , , , , , ,= , , , , ,= , , , , , , , , , , , , , , , , , , , , , , , , , , , , , , ,    ! ! !.2 2MO 2 2 2 2s FC'I9parser pytest.ParserNonec6|ddddS)N anyio_modestrictz-AnyIO plugin mode (either "strict" or "auto"))defaulthelp)addini)rLs r,pytest_addoptionrUKs0 MM <r.config pytest.Configc&|dd|ddkr]|jdrE|ddkr.|t jdddSdSdSdS) NmarkerszManyio: mark the (coroutine function) test to be run asynchronously via anyio.rPautoasyncio 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)rVs r,pytest_configurerdSs W  l##v--  + +I 6 6 . MM. ) )V 3 3((  &<         .--- 3 3r.T) hookwrapper fixturedefr requestGenerator[Any]c#TKd fd }|jtstrsd|jvrj||_|j}d|jvxs|xjdz c_d|jvxs|xjd z c_ dV|_||_S#|_||_wxYwdVS) N anyio_backendr rgrkwargsr"c;,K|jrWtrHtjt|jur j|j}n}t |\}}r||d< r||d<t||5}|rtdt|r| ||Ed{Vn| ||VddddS#1swxYwYdS)NrjrgzCannot schedule a coroutine in the test runner while another is already running; likely caused by request.getfixturevalue() on an async fixture.) instancer type__self____func____get__r-rK is_running RuntimeErrorr run_asyncgen_fixture run_fixture) rjrgrk local_funcr/r0runnerfunchas_backend_arghas_request_args r,wrapperz%pytest_fixture_setup..wrapperhs    T]##tG,<'='===..w/?@@JJJ(CM(R(R% o  4&3F? #  ( 'F9   o 6 6 =&  "" "V "*-- =!66z6JJJJJJJJJJ((V<<<<z,pytest_pycollect_makeitem..s)HH&v{g-HHHHHHr.rj) istestfunctionhasattrr inner_testr rVr^get_closest_markergetattranyrbmark usefixtures)rrr inner_funcanyio_auto_moder own_markerss r,pytest_pycollect_makeitemrsT** >29#|2L2LUS^..RU z * * >'.55lCCvMO11'::F!#|R88K > >HHKHHHHH >  ''88===== > > > > > >r.sessionpytest.Sessionc ttt|jD]\}}t |t jrt|jr| dd|j vrwg} dtj tD}n#t$rt}YnwxYwtt!D]\}}d|vr&td|id|idt"ji|gg}n&tid|id|idt"ji|gg}|j}t|j} d| vr| dt-|j|j| |j} t j|j|jd|d ||j| |j|j } || ||j||d z<dS) Nrrjch|] }|j Srr)rfs r, z+pytest_collection_finish..sKKKQVKKKr. _arg2scope)paramsindicesr_idlistmarks)funcargsrr arg2scopeidlistr)r initialnames names_closurename2fixturedefs[])rcallspeccallobj fixtureinfokeywords originalnamer)reversedlist enumerateitemsr&rbFunctionr functionrr~ dataclassesfieldsrr+setrrModule _fixtureinforappendrrrr from_parentparentrrr) riitem new_items cs_fields param_indexr rfinew_names_closurenew_fixtureinfonew_items r,pytest_collection_finishrsYD7=!9!9::;;61614 tV_ - -5 1#DM225 1''00<t'888I "KK[-? -J-JKKK  " " "EE  ")22H2J2J(K(K' +' +$ W9,,( /9!0+ >$3U\#B!(     HH )!# /9!0+ >#2EL"A 'y    H&$()9$:$:!"*;;;%,,_==="1[!#"3%'%8 ### "?66K -:::::% H /!]!%!27  ****'0GM!a!e) $m6161s#B,,CC pyfuncitem bool | Nonec  d  fd }|jd}|r/t|\t|jdrC|jjj j|jkr t r||jj_dSt|jr|j fd|j j D}t5} | |j|nJ#t$r=}t|D]'}t|t t"t$fr||(d}~wwxYw dddn #1swxYwYd SdS) Nrkr r"rNct5}||ddddS#1swxYwYdSN)rKrun_test)rkrwr/r0 original_funcs r,run_with_hypothesisz/pytest_pyfunc_call..run_with_hypothesiss  o 6 6 3& OOM6 2 2 2 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3s 6::rjrc"i|] }|| Srr)rargrs r, z&pytest_pyfunc_call..sWWWsXc]WWWr.T)rkr r"rN)rgetr-rrrr __qualname__r rrrKrrrr&rKeyboardInterrupt SystemExit) rrr testargsrwexcgrpexcr/r0rrs @@@@r,pytest_pyfunc_callrs33333333!%%o66G(CG(L(L% o :>< 0 0 &N5@M)-@-MMM&}55O;NJN-84 z~ . . !*HWWWWj6M6VWWWHL/:: fOOJNH====%1&9922%cD2CZ+PQQ2"%612 >               4 4s6E C54E 5 D<?8D77D<<E  EEmodule)scoperc|jSr)paramr}s r,rjrjs =r.rjc@t|tr|S|dS)Nrr&r'r|s r,anyio_backend_namers%-%% Qr.c@t|triS|dS)Nrrr|s r,anyio_backend_optionsr!s$-%%  Qr.c<eZdZdZd dZeddZddd ZdS)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. kindsocket.SocketKindr"rNcP||_tt|_dSr)_kindrint _generated)selfrs r,__init__zFreePortFactory.__init__7s 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;s zr.Nfamilysocket.AddressFamily | NonercL||g}n8tjg}tjr|tj d}t 5}|D]}|tj||j}|tjkrdnd} |||fn#t$rYnRwxYw|s| d}||j vr(|j ||cdddSdddn #1swxYwY)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 NTrz::1z 127.0.0.1r) socketAF_INEThas_ipv6rAF_INET6rr9rbindOSError getsocknameradd)rrfamiliesportstacksockaddrs r,__call__zFreePortFactory.__call__Ds  xHH'H 1000 $D $& $ $F ..v}VTZ/P/PQQD$*fo$=$=55;D 4,////" 5#//11!44?22++D111# $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s8ADB/.D/ B=9D<B==ADD!D)rrr"rN)r"rr)rrr"r)__name__ __module__r__doc__rpropertyrrrr.r,rr)sk  %%%%X$$$$$$$r.r)rc4ttjSr)rr SOCK_STREAMrr.r,free_tcp_port_factoryr fs 6- . ..r.c4ttjSr)rr SOCK_DGRAMrr.r,free_udp_port_factoryrks 6, - --r.r Callable[[], int]rc|Srr)r s r, free_tcp_portrp " ""r.rc|Srr)rs r, free_udp_portrurr.)r r!r"r#)r/r'r0r1r"r2)rLrMr"rN)rVrWr"rN)rfr rgr r"rh)rrrr'rr!r"rN)rrr"rN)rr r"r)rgr r"r )rjr r"r')rjr r"r1)r"r)r rr"r)rrr"r)G __future__rbuiltinsr>_pytest.assertion.rewrite assertionrewriter<rrsyscollections.abcrrr contextlibrrinspectr r r typingr r rb_pytest.fixturesrr_pytest.outcomesr_pytest.pythonr _pytest.scoperr_core._eventlooprrrr_core._exceptionsrabcr version_infoexceptiongrouprr__annotations__rr;r-rKrUrdhookimplrrrrfixturerjrrrr rrrrr.r,r,s0""""""" 999999999900000000EEEEEEEEEE 88888888!!!!!!$$$$$$$$$$$$ 211111g------%)))))"& &&&&XXXX3333:    &T"""999#"9x$>>> >"71717171t$!!! !Hh'='='?'?@@@A@        :$:$:$:$:$:$:$:$zi   ///! /i   ...! .##########r.