
    5j1                       % S SK Jr  S SKrS SKJs  Jr  S SKrS SK	r	S SK
r
S SKJrJrJr  S SKJrJr  S SKJrJrJr  S SKJrJr  S SKrS SKJrJr  S SKJr  S S	KJ r   S S
K!J"r"  SSK#J$r$  SSK%J&r&J'r'J(r(J)r)  SSK*J+r+  SSK,J-r-  \
R\                  S:  a  S SK/J0r0  Sq1S\2S'   Sq3S\2S'   S q4S.S jr5\      S/S j5       r6S0S jr7S1S jr8\Rr                  " SS9S2S j5       r:\Rr                  " SS9        S3S j5       r;S4S  jr<\Rr                  " SS9S5S! j5       r=\R|                  " S"\$" 5       S#9S6S$ j5       r?\R|                  S7S% j5       r@\R|                  S8S& j5       rA " S' S(5      rB\R|                  " SS)9S9S* j5       rC\R|                  " SS)9S9S+ j5       rD\R|                  S:S, j5       rE\R|                  S;S- j5       rFg)<    )annotationsN)Callable	GeneratorIterator)	ExitStackcontextmanager)isasyncgenfunctioniscoroutinefunctionismethod)Anycast)FuncFixtureInfo
SubRequest)Exit)	CallSpec2)Scope   )get_available_backends)current_async_libraryget_async_backendreset_current_async_libraryset_current_async_library)iterate_exceptions)
TestRunner)      )ExceptionGroupzTestRunner | None_current_runnerzExitStack | None_runner_stackc                F   [        U [        5      (       a  U 0 4$ [        U [        5      (       ai  [        U 5      S:X  aZ  [        U S   [        5      (       aB  [        U S   [        5      (       a*  [        [        [        [        [        [        4   4   U 5      $ [        S5      e)N   r   r   z@anyio_backend must be either a string or tuple of (string, dict))
isinstancestrtuplelendictr   r   	TypeError)backends    R/root/lseg-credit/backend/venv/lib/python3.13/site-packages/anyio/pytest_plugin.pyextract_backend_and_optionsr*   #   s}    '3{	GU	#	#G(9gaj#&&:gaj$+G+Gc4S>12G<<
V
WW    c           	   #    #    [         ct  [        U 5      n[        5       q[	        5       c%  [        U 5      n[        R                  [        U5        U=(       d    0 n[        R                  UR                  U5      5      q [        S-  q
 [         v   [        S-  q
[        (       d  S n[        ULoU(       d  [        R                  " SU4S[        U45      S[        R                  " 5       ;   d  [        R                  " [        5      (       a  [        R                   " [        5      OS[        R                   " U5      S.-  nSSU0-  n[#        [        R$                  " U5      5      eS =pT[        R'                  5         S =qq g g ! [        S-  q
[        (       d  S n[        ULoU(       d  [        R                  " SU4S[        U45      S[        R                  " 5       ;   d  [        R                  " [        5      (       a  [        R                   " [        5      OS[        R                   " U5      S.-  nSSU0-  n[#        [        R$                  " U5      5      eS =pT[        R'                  5         S =qq f f = f7f)Nr   )is not)z%(py0)s is not %(py3)sr   )py0py3zassert %(py5)spy5)r   r   r   r   r   r   callbackr   enter_contextcreate_test_runner_runner_leases
@pytest_ar_call_reprcompare@py_builtinslocals_should_repr_global_name	_safereprAssertionError_format_explanationclose)backend_namebackend_optionsasynclibtoken@py_assert2@py_assert1@py_format4@py_format6s           r)   
get_runnerrF   -   s    
 $\2! "* .l;E""#>F)/R'55''8
 aN3!~(,,=,,,,,=,,,,,,=,,,,=,,,,,,,,,,!.22MO  	!~(,,=,,,,,=,,,,,,=,,,,=,,,,,,,,,,!.22MO s    BI:F C3I:C4I77I:c                &    U R                  SSSS9  g )N
anyio_modestrictz-AnyIO plugin mode (either "strict" or "auto"))defaulthelp)addini)parsers    r)   pytest_addoptionrN   K   s    
MM<  r+   c                   U R                  SS5        U R                  S5      S:X  a^  U R                  R                  S5      (       a=  U R                  S5      S:X  a'  U R	                  [
        R                  " S5      S5        g g g g )	NmarkerszManyio: mark the (coroutine function) test to be run asynchronously via anyio.rH   autoasyncioasyncio_modezlAnyIO auto mode has been enabled together with pytest-asyncio auto mode. This may cause unexpected behavior.r   )addinivalue_linegetinipluginmanager
has_pluginissue_config_time_warningpytestPytestConfigWarning)configs    r)   pytest_configurer\   S   s    
W
 	l#v-  ++I66MM.)V3((&&< 	
 4 7 	.r+   T)hookwrapperc              #    ^^^#    SUUU4S jjnU R                   m[        T5      (       d  [        T5      (       a  SUR                  ;   az  X l         U R                  nSU R                  ;   =m(       d  U =R                  S-  sl        SU R                  ;   =m(       d  U =R                  S-  sl         S v TU l         X0l        $ S v $ ! TU l         X0l        f = f7f)Nanyio_backendrequestc              ;    >#    UR                   (       aa  [        T5      (       aQ  [        TR                  5      [        UR                   5      L a&  TR                  R                  UR                   5      nOTn[        U 5      u  pET(       a  XS'   T	(       a  XS'   [        XE5       n[        U5      (       a  UR                  X25       S h  vN   OUR                  X25      v   S S S 5        g  N!! , (       d  f       g = f7f)Nr_   r`   )instancer   type__self____func____get__r*   rF   r	   run_asyncgen_fixturerun_fixture)
r_   r`   kwargs
local_funcr>   r?   runnerfunchas_backend_arghas_request_args
          r)   wrapper%pytest_fixture_setup.<locals>.wrapperh   s      T]]#tG,<,<'==..w/?/?@JJ(CM(R%&3?# '96&!*--!66zJJJ((<<	 76J 76s0   B#D &%C/C-C/$	D -C//
C=9D r_   r`   )r_   r   r`   r   ri   r   returnr   )rl   r	   r
   fixturenamesargnames)
fixturedefr`   ro   original_argnamerl   rm   rn   s       @@@r)   pytest_fixture_setuprx   f   s     = =4 ??D$#6t#<#<g222%O)22'6*:M:M'MMOM##'99#'0J4G4G'GGOG##|3#7"&
&6#N #'
&6#s   B/C5C
 8C
CC)tryfirstc                   U R                  X!5      (       a  [        US5      (       a  UR                  R                  OUn[	        U5      (       a  U R
                  R                  S5      S:H  nU R                  S5      n[        USS5      nU(       d  U(       d  [        S U 5       5      (       a&  [        R                  R                  S5      " U5        g g g g )	N
hypothesisrH   rQ   anyio
pytestmark c              3  >   #    U  H  oR                   S :H  v   M     g7f)r|   N)name).0markers     r)   	<genexpr>,pytest_pycollect_makeitem.<locals>.<genexpr>   s     HK&{{g-Ks   r_   )istestfunctionhasattrr{   
inner_testr
   r[   rU   get_closest_markergetattranyrY   markusefixtures)	collectorr   obj
inner_funcanyio_auto_moder   own_markerss          r)   pytest_pycollect_makeitemr      s     **29#|2L2LS^^..RU
z**'..55lCvMO11':F!#|R8KHKHHH''8= I + +r+   sessionc                j   [        [        [        U R                  5      5      5       GH  u  p[	        U[
        R                  5      (       d  M'  [        UR                  5      (       d  MC  UR                  S5      c  MW  SUR                  ;  d  Mi  / n [        R                  " [        5       Vs1 s H  oDR                  iM     nn[        [#        5       5       GH   u  pgSU;   a#  [        SU0SU0S[$        R&                  0U// S9nO#[        0 SU0SU0S[$        R&                  0U// S9nUR(                  n	[        U	R*                  5      n
SU
;  a  U
R-                  S5        [/        U	R0                  U	R2                  U
U	R4                  S9n[
        R                  R7                  UR8                  UR:                   SU S3UUR<                  UUR>                  UR:                  S	9nUR-                  U5        GM#     X0R                  XS
-   & GM     g s  snf ! [         a    [!        5       n GNjf = f)Nr|   r_   
_arg2scope)paramsindicesr   _idlistmarks)funcargsr   r   	arg2scopeidlistr   )ru   initialnamesnames_closurename2fixturedefs[])r   callspeccallobjfixtureinfokeywordsoriginalnamer   ) reversedlist	enumerateitemsr"   rY   Functionr
   functionr   rt   dataclassesfieldsr   r   r'   setr   r   Module_fixtureinfor   appendr   ru   r   r   from_parentparentr   r   r   )r   iitem	new_itemsf	cs_fieldsparam_indexr(   r   finew_names_closurenew_fixtureinfonew_items                r)   pytest_collection_finishr      s   D7==!9:;tV__--#DMM22''0<t'8'88I"-8-?-?	-JK-JVV-J	K )22H2J(K$9,( /9!0+ >$3U\\#B!(	  H  )!# /9!0+ >#2ELL"A 'y  H &&$()9)9$:!"*;;%,,_="1[[!#"3%'%8%8	# "??66KK --.ay:% HH /!]]!%!2!2 7    *O )LR (1MM!!e$m < L "E	"s$   H0HHHH21H2c           	     >  ^	^
^ SU	U
U4S jjnU R                   R                  S5      nU(       Ga  [        U5      u  m	m
[        U R                  S5      (       ae  U R                  R
                  R                  mTR                  UR                  :w  a*  [        T5      (       a  XR                  R
                  l        g [        U R                  5      (       ah  U R                   nU R                  R                   Vs0 s H  oDX4   _M	     nn[        T	T
5       n UR                  U R                  U5         S S S 5        gg s  snf ! [         a:  n[        U5       H%  n[        U[         ["        [$        45      (       d  M%  Xe   e S nAff = f! , (       d  f       g= f)Nc                 v   > [        TT5       nUR                  TU 5        S S S 5        g ! , (       d  f       g = fN)rF   run_test)ri   rk   r>   r?   original_funcs     r)   run_with_hypothesis/pytest_pyfunc_call.<locals>.run_with_hypothesis   s)    o6&OOM62 766s   *
8r_   r{   T)ri   r   rs   None)r   getr*   r   r   r{   r   __qualname__r
   r   ru   rF   r   r   r   r"   r   KeyboardInterrupt
SystemExit)
pyfuncitemr   r(   r   argtestargsrk   excgrpexcr>   r?   r   s            @@@r)   pytest_pyfunc_callr      sV   3 3 !!%%o6G(CG(L%o:>><00&NN55@@M))-@-M-MM&}55;NNN--8z~~..!**H6@6M6M6V6VW6VsX]*6VHWL/:fOOJNNH= ;  X & 1&9%cD2CZ+PQQ"%1  :  ;: s6   =EFE
F,FFFF
Fmodule)scoper   c                    U R                   $ r   )paramrr   s    r)   r_   r_     s    ==r+   c                :    [        U [        5      (       a  U $ U S   $ )Nr   r"   r#   rq   s    r)   anyio_backend_namer     s     -%%Qr+   c                :    [        U [        5      (       a  0 $ U S   $ )Nr   r   rq   s    r)   anyio_backend_optionsr     s    -%%	Qr+   c                  D    \ rS rSrSrSS jr\S	S j5       rS
SS jjrSr	g)FreePortFactoryi  a+  
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                >    Xl         [        [           " 5       U l        g r   )_kindr   int
_generated)selfkinds     r)   __init__FreePortFactory.__init__+  s    
c(*r+   c                    U R                   $ )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   )r   s    r)   r   FreePortFactory.kind/  s     zzr+   Nc                x   Ub  U/nOE[         R                  /n[         R                  (       a  UR                  [         R                  5         Sn[        5        nU Hy  nUR                  [         R                   " XR                  5      5      nU[         R                  :X  a  SOSn UR                  Xc45        U(       a  Mf  UR                  5       S   nM{     X0R                  ;  a&  U R                  R                  U5        UsSSS5        $ SSS5        M  ! [         a       M  f = f! , (       d  f       N"= f)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

Nr   z::1z	127.0.0.1r   )socketAF_INEThas_ipv6r   AF_INET6r   r2   r   bindOSErrorgetsocknamer   add)r   familyfamiliesportstacksockaddrs          r)   __call__FreePortFactory.__call__8  s     xH'H0D&F ..v}}VZZ/PQD$*foo$=5;D		4,/  4#//1!4 ' ??2++D1#   #  s8   AD+(D:D+AD+
D(#D+'D((D++
D9)r   r   )r   socket.SocketKindrs   r   )rs   r   r   )r   zsocket.AddressFamily | Noners   r   )
__name__
__module__r   __firstlineno____doc__r   propertyr   r   __static_attributes__r~   r+   r)   r   r     s*    %  $ $r+   r   )r   c                 4    [        [        R                  5      $ r   )r   r   SOCK_STREAMr~   r+   r)   free_tcp_port_factoryr  Z  s    6--..r+   c                 4    [        [        R                  5      $ r   )r   r   
SOCK_DGRAMr~   r+   r)   free_udp_port_factoryr  _  s    6,,--r+   c                    U " 5       $ r   r~   )r  s    r)   free_tcp_portr  d       ""r+   c                    U " 5       $ r   r~   )r  s    r)   free_udp_portr	  i  r  r+   )r(   objectrs   ztuple[str, dict[str, Any]])r>   r#   r?   dict[str, Any]rs   zIterator[TestRunner])rM   zpytest.Parserrs   r   )r[   zpytest.Configrs   r   )rv   r   r`   r   rs   zGenerator[Any])r   zpytest.Module | pytest.Classr   r#   r   r
  rs   r   )r   zpytest.Sessionrs   r   )r   r   rs   zbool | None)r`   r   rs   r   )r_   r   rs   r#   )r_   r   rs   r  )rs   r   )r  Callable[[], int]rs   r   )r  r  rs   r   )G
__future__r   builtinsr7   _pytest.assertion.rewrite	assertionrewriter5   r   r   syscollections.abcr   r   r   
contextlibr   r   inspectr	   r
   r   typingr   r   rY   _pytest.fixturesr   r   _pytest.outcomesr   _pytest.pythonr   _pytest.scoper    r   _core._eventloopr   r   r   r   _core._exceptionsr   abcr   version_infoexceptiongroupr   r   __annotations__r   r4   r*   rF   rN   r\   hookimplrx   r   r   r   fixturer_   r   r   r   r  r  r  r	  r~   r+   r)   <module>r$     s   "      
 9 9 0 E E   8 ! $  $  2 g-%)" )"& &X 33(633 3:
& T"- #-` $>+>36>=C>	>  >"71t $!  !H h'='?@ A        :$ :$z i / !/ i . !. # # # #r+   