U &%e@sPUddlmZddlmZddlmZmZddlmZm Z m Z m Z m Z ddl Z ddlZddlmZmZddlmZdad ed <d d d ddZeddddddZdddddZddddddZe jddddddd d!d"Ze jdddd#d$d%d&Ze jed'ddd(d)d*Ze jddd+d,d-Ze jddd+d.d/Z dS)0) annotations)contextmanager)isasyncgenfunctioniscoroutinefunction)AnyDict GeneratorTuplecastN)get_all_backends get_asynclib) TestRunnerzTestRunner | None_current_runnerobjectztuple[str, dict[str, Any]])backendreturncCsjt|tr|ifSt|tr^t|dkr^t|dtr^t|dtr^ttttttff|St ddS)Nrr z@anyio_backend must be either a string or tuple of (string, dict)) isinstancestrtuplelendictr r rr TypeError)rrR/var/www/html/Darija-Ai-API/env/lib/python3.8/site-packages/anyio/pytest_plugin.pyextract_backend_and_optionss  rrzdict[str, Any]z#Generator[TestRunner, object, None]) backend_namebackend_optionsrc cstrtVdSt|}d}tjddkr6tj|}z.|p>i}|jf|}|a|VW5QRXW5da|rztj|XdSN)rr sniffioZcurrent_async_library_cvargetsetresetr)rrZasynclibtokenrunnerrrr get_runners r&rNone)configrcCs|dddS)NmarkerszManyio: mark the (coroutine function) test to be run asynchronously via anyio.)Zaddinivalue_line)r(rrrpytest_configure4sr*) fixturedefrequestrcsTfdd}|jts$trPd|jkrPd|jk||_sP|jd7_dS)Nc ?s\t|\}}r||d<t||0}tr@||EdHn||VW5QRXdS)N anyio_backend)rr&rZrun_asyncgen_fixtureZ run_fixture)r-argskwargsrrr%funcZhas_backend_argrrwrapper=s  z%pytest_fixture_setup..wrapperr-r-)r1rrZ fixturenamesargnames)r+r,r2rr0rpytest_fixture_setup<s   r5T)Ztryfirst) collectornameobjrcCsj|||rft|dr|jjn|}t|rf|d}t|dd}|sVtdd|Drftj d|dS)N hypothesisanyioZ pytestmarkrcss|]}|jdkVqdS)r:N)r7).0markerrrr Zsz,pytest_pycollect_makeitem..r-) Zistestfunctionhasattrr9 inner_testrZget_closest_markergetattranypytestmarkZ usefixtures)r6r7r8Z inner_funcr<Z own_markersrrrpytest_pycollect_makeitemSs   rDz bool | None) pyfuncitemrc sdddfdd }|jd}|rt|\t|jdrl|jjjj|jkrhtrh||jj_dSt|jr|jfdd |j j D}t }| |j|W5QRXd SdS) Nrr')r/rc s&t}||W5QRXdSr)r&run_test)r/r%)rr original_funcrrrun_with_hypothesis`s z/pytest_pyfunc_call..run_with_hypothesisr-r9csi|]}||qSrr)r;arg)funcargsrr ssz&pytest_pyfunc_call..T) rJr!rr>r8r9r? __qualname__rZ _fixtureinfor4r&rF)rErHrZtestargsr%r)rrrJrGrpytest_pyfunc_call^s"        rM)params)r,rcCs|jSr)param)r,rrrr-|sr-)r-rcCst|tr|S|dSdS)Nrrrr3rrranyio_backend_names rQcCst|triS|dSdS)Nr rPr3rrranyio_backend_optionss rR)! __future__r contextlibrinspectrrtypingrrrr r rBr Z_core._eventloopr r abcrr__annotations__rr&r*r5ZhookimplrDrMZfixturer-rQrRrrrrs0