­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ U '7`+@sddlZddlZddlZddlmZddlZddlmZmZddl m Z ddl m Z m Z mZmZmZmZmZmZz ddlZWnek rdZYnXz ddlZWnek rdZYnXddZd d Zejd d Zejd dZejddZejd.ddZddZ ddZ!ddZ"ejddZ#ejddZ$ejddZejd d!Z%ejd"d#Z&ejd$d%Z'ejd&d'Z(ejd(d)Z)ejd*d+Z*ejd,d-Z+dS)/N)Callable)PY_37isasyncgenfunction) Application)BaseTestServer RawTestServer TestClient TestServer loop_contextsetup_test_loopteardown_test_loop unused_portcCs:|jddddd|jdddd d|jd ddd ddS) N--aiohttp-fast store_trueFz*run tests faster by disabling extra checks)actiondefaulthelpz--aiohttp-loopZstorepyloopz:run tests with specific loop: pyloop, uvloop, tokio or all--aiohttp-enable-loop-debugzenable event loop debug mode)Z addoption)parserrH/opt/alt/python38/lib64/python3.8/site-packages/aiohttp/pytest_plugin.pypytest_addoption!s$rcsb|jtrdntr$dndSdd|jkrH|jd7_dfdd}||_dS)zS Allow fixtures to be coroutines. Run coroutine fixtures in an event loop. TFNrequestrcsv|d}r|d=d|jkr$td|drb||fdd}||S||SdS)Nrloopz^Asynchronous fixtures must depend on the 'loop' fixture or be used in tests depending from it.cs*zWStk r$YnXdSN)run_until_complete __anext__StopAsyncIterationr_loopgenrr finalizer`sz8pytest_fixture_setup..wrapper..finalizer) fixturenames ExceptionZgetfixturevalueZ addfinalizerrr)argskwargsrr$funcZ is_async_genZ strip_requestr!rwrapperKs    z%pytest_fixture_setup..wrapper)r*rasyncioiscoroutinefunctionargnames)Z fixturedefr+rr)rpytest_fixture_setup6s   r/cCs |jdS)z--fast config optionrconfig getoptionrrrrfastnsr3cCs |jdS)z!--enable-loop-debug config optionrr0rrrr loop_debugtsr4c cs`tjddJ}dVdd|D}|rRtdt|t|dkrBdnd d |W5QRXdS) z Context manager which checks for RuntimeWarnings, specifically to avoid "coroutine 'X' was never awaited" warnings being missed. If RuntimeWarnings occur in the context a RuntimeError is raised. T)recordNcSs"g|]}|jtkrdj|dqS)z#{w.filename}:{w.lineno}:{w.message})w)categoryRuntimeWarningformat).0r6rrr s z,_runtime_warning_context..z{} Runtime Warning{}, {}rs )warningscatch_warnings RuntimeErrorr9lenjoin) _warningsZrwrrr_runtime_warning_contextzsrEFccs(|r |Vnt}|Vt||ddS)z{ setups and tears down a loop unless one is passed in via the loop argument when it's passed straight through. r3N)r r )rr3rrr_passthrough_loop_contexts rGcCs(||r$t|r$t|||SdS)z/ Fix pytest collecting for coroutines. N)Zfuncnamefilterr,r-listZ _genfunctions)Z collectornameobjrrrpytest_pycollect_makeitemsrKc sjd}tjrjdp0jdd}tFt||d.}fddj j D}| j f|W5QRXW5QRXdSdS) zL Run coroutines in an event loop instead of a normal function call. r proactor_looprNrFcsi|]}|j|qSr)funcargs)r:arg pyfuncitemrr sz&pytest_pyfunc_call..T) r1r2r,r-functionrMgetrErGZ _fixtureinfor.rrJ)rPr3Z existing_loopr"ZtestargsrrOrpytest_pyfunc_calls    &rTcCsd|jkrdS|jjj}dtji}tdk r4tj|d<tdk rFtj|d<|dkrRd}i}| dD]N}| d }| d }||kr|r`t d |t |fnq`||||<q`|jdt |t |d dS) N loop_factoryruvlooptokioallzpyloop,uvloop?,tokio?,?z ?z&Unknown loop '%s', available loops: %s)Zids)r%r1ZoptionZ aiohttp_loopr,ZDefaultEventLoopPolicyrVZEventLoopPolicyrWsplitendswithstrip ValueErrorrHkeysZ parametrizevalues)ZmetafuncZloopsZavail_factoriesZ factoriesrIZrequiredrrrpytest_generate_testss8        rac csH|}t|t|d$}|r*|dt||VW5QRXdS)z%Return an instance of the event loop.rFTN)r,set_event_loop_policyr Z set_debugset_event_loop)rUr3r4policyr"rrrrs    rc csRtst}tj|_nt}t|t|j}t ||VW5QRXdSr) rr,Zget_event_loop_policyZProactorEventLoopZ _loop_factoryZWindowsProactorEventLoopPolicyrbr Znew_event_looprc)rdr"rrrrLs    rLcCstjdtdd|S)Nz3Deprecated, use aiohttp_unused_port fixture instead stacklevelr?warnDeprecationWarning)aiohttp_unused_portrrrrs rcCstS)z1Return a port that is unused on the current host.) _unused_portrrrrrksrkc#s:gddfdd }|Vfdd}|dS)z^Factory to create a TestServer instance, given an app. aiohttp_server(app, **kwargs) Nportcs4t||d}|jfdi|IdH||SNrmr)r start_serverappend)Zapprnr(serverrserversrrgos  zaiohttp_server..gocsrIdHqdSrpopcloserrtrrfinalizesz aiohttp_server..finalizerrrurzrrsraiohttp_server s  r}cCstjdtdd|S)Nz.Deprecated, use aiohttp_server fixture insteadrerfrh)r}rrr test_server s r~c#s:gddfdd }|Vfdd}|dS)zpFactory to create a RawTestServer instance, given a web handler. aiohttp_raw_server(handler, **kwargs) Nrmcs4t||d}|jfdi|IdH||Sro)rrprq)handlerrnr(rrrsrrru2s  zaiohttp_raw_server..gocsrIdHqdSrrvrryrrrz:sz$aiohttp_raw_server..finalizer{r|rrsraiohttp_raw_server*s  rcCstjdtdd|S)Nz2Deprecated, use aiohttp_raw_server fixture insteadrerfrh)rrrrraw_test_serverAs rc#s:gddfdd }|Vfdd}|dS)zFactory to create a TestClient instance. aiohttp_client(app, **kwargs) aiohttp_client(server, **kwargs) aiohttp_client(raw_server, **kwargs) N) server_kwargscst|tr.t|ttfs.|f||}i}n |r:tdt|trv|pJi}t|fdi|}t|fdi|}n0t|trt|fdi|}ntdt|| IdH ||S)Nzargs should be emptyrzUnknown argument type: %r) isinstancerrrAssertionErrorr r r^typerprq)Z__paramrr'r(rrZclientclientsrrrruUs"     zaiohttp_client..gocsrIdHqdSrrvr)rrrrznsz aiohttp_client..finalizer{r|rrraiohttp_clientKs  rcCstjdtdd|S)Nz.Deprecated, use aiohttp_client fixture insteadrerfrh)rrrr test_clientus r)F),r, contextlibr?collections.abcrZpytestZaiohttp.helpersrrZ aiohttp.webrZ test_utilsrrr r r r r rrlrV ImportErrorrWrr/Zfixturer3r4contextmanagerrErGrKrTrarrLrkr}r~rrrrrrrrs`  (     8    "         )