o
    4˜ŽjD`  ã                    @   sô  d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl	Z	ddl
mZmZ ddlmZmZ ddlmZ ddlmZmZmZmZmZmZmZ ddlmZmZ ddlmZ dd	lm Z m!Z! dd
l"m#Z# ddl$Z$ddl%m&Z&m'Z'm(Z(m)Z) ddl*m+Z+m,Z, ddl
m-Z- ddl.m/Z/ ddl0m1Z1 ddl2m3Z3 ddl4m5Z5m6Z6 ddl7m8Z8m9Z9 ddl:m;Z; ddl<m=Z=m>Z>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZE ddlFmGZG erÕddlHmIZI neZIejJdkräeräddlmKZK ejJdkrðddlmLZL neZLede=dƒZMede?d�ZNejOdk�oejPdkZQejRfd eSd!ejTd"ejfd#d$„ZUd eSd%eVd!ejTd"ejfd&d'„ZWd"eVfd(d)„ZXG d*d+„ d+eƒZYG d,d-„ d-eYƒZZG d.d/„ d/eYƒZ[G d0d1„ d1eeNeMf ƒZ\G d2d3„ d3eƒZ]d4ed5ed6ed"efd7d8„Z^eg ej_f Z`ejaejbd9fd:e`d;ecd"eej_ fd<d=„ƒZdejbfd:e`d"ej_fd>d?„Zed]d@ej_d;ecd"dfdAdB„Zfd"ejgfdCdD„Zhd^dEeIdB d"ejifdFdG„Zj	d^e3e5ddƒd9de3e3e3e8ddHdIdJœdKeSdLeSdMedNedOe5dPecdQedRedSedTedUe9dEeIdB dVeVd@ed"eAfdWdX„Zke3e3fdYedZed"efd[d\„ZldS )_zUtilities shared by tests.é    N)ÚABCÚabstractmethod)ÚCallableÚIterator)ÚTracebackType)ÚTYPE_CHECKINGÚAnyÚGenericÚLiteralÚTypeVarÚcastÚoverload)ÚIsolatedAsyncioTestCaseÚmock)ÚSignal)ÚCIMultiDictÚCIMultiDictProxy)ÚURL)Ú_BaseRequestContextManagerÚ_RequestContextManagerÚ_RequestOptionsÚ_WSRequestContextManageré   )ÚClientSessionÚhdrs)ÚAbstractCookieJar)ÚClientResponse)ÚClientWebSocketResponse)Úsentinel)ÚHttpVersionÚRawRequestMessage)ÚEMPTY_PAYLOADÚStreamReader)ÚStrOrURL)	ÚApplicationÚ	AppRunnerÚBaseRequestÚ
BaseRunnerÚRequestÚServerÚServerRunnerÚSockSiteÚUrlMappingMatchInfo)Ú_RequestHandler)Ú
SSLContext©é   é   )ÚUnpack)ÚSelfÚ_ApplicationNoneÚ_Request)ÚboundÚposixÚcygwinÚhostÚfamilyÚreturnc                 C   s   t | d|ƒS )Nr   )Úget_port_socket)r9   r:   © r=   úO/var/www/kodo/Anonymous/send/lib/python3.10/site-packages/aiohttp/test_utils.pyÚget_unused_port_socketF   s   r?   Úportc                 C   s6   t   |t j¡}tr| t jt jd¡ | | |f¡ |S )Nr   )ÚsocketÚSOCK_STREAMÚREUSE_ADDRESSÚ
setsockoptÚ
SOL_SOCKETÚSO_REUSEADDRÚbind)r9   r@   r:   Úsr=   r=   r>   r<   L   s
   r<   c                  C   sP   t   t jt j¡�} |  d¡ tt|  ¡ d ƒW  d  ƒ S 1 s!w   Y  dS )z1Return a port that is unused on the current host.)ú	127.0.0.1r   r   N)rA   ÚAF_INETrB   rG   r   ÚintÚgetsockname)rH   r=   r=   r>   Úunused_portY   s   
$þrM   c                   @   sV  e Zd ZdZdddddedœdedejdB ded	edB d
e	de
eeejgejf deddfdd„Z	d*dejdB deddfdd„Zededefdd„ƒZdedefdd„Zede	fdd„ƒZede	fdd„ƒZedefdd„ƒZd+dd„Zd+dd „Zd!ee dB d"edB d#edB ddfd$d%„Z d,d&d'„Z!d!ee dB d"edB d#edB ddfd(d)„Z"dS )-ÚBaseTestServerFÚ NrI   )ÚschemeÚloopr9   r@   Úskip_url_assertsÚsocket_factoryrP   rQ   r9   r@   rR   rS   Úkwargsr;   c                K   s:   || _ d | _d | _|| _|| _d| _|| _|| _|| _d S )NF)	Ú_loopÚrunnerÚ_rootr9   r@   Ú_closedrP   rR   rS   )ÚselfrP   rQ   r9   r@   rR   rS   rT   r=   r=   r>   Ú__init__c   s   
zBaseTestServer.__init__c           
      Ë   sj  �| j rd S || _| dd ¡| _| jdddi|¤ŽI d H | _ | j  ¡ I d H  | js,d| _| j}z	t 	| j¡j
}W n tyC   d}Y nw |dkrOd| j› d�}|dkrVtjntj}|  | j| j|¡}| ¡ d d	… \| _| _t| j || jd
�}| ¡ I d H  |j}|d us‡J ‚|j}	|	d us�J ‚|	d  ¡ d | _| js¤| jr¡dnd| _t| j› d|› d| j› �ƒ| _d S )NÚsslÚhandler_cancellationTr   é   é   ú[ú]é   )ÚsockÚssl_contextr   ÚhttpsÚhttpz://ú:r=   )rV   rU   ÚpopÚ_sslÚ_make_runnerÚsetupr@   r9   Ú	ipaddressÚ
ip_addressÚversionÚ
ValueErrorrA   ÚAF_INET6rJ   rS   rL   r+   ÚstartÚ_serverÚsocketsrP   r   rW   )
rY   rQ   rT   Úabsolute_hostrm   r:   Ú_sockÚsiteÚserverrr   r=   r=   r>   Ústart_serverz   s<   €ÿ"zBaseTestServer.start_serverc                 Ë   ó   �d S ©Nr=   ©rY   rT   r=   r=   r>   ri   š   s   €zBaseTestServer._make_runnerÚpathc                 C   sH   | j d usJ ‚t|ƒ}| js|jrJ ‚| j  |¡S tt| j ƒt|ƒ ƒS ry   )rW   r   rR   ÚabsoluteÚjoinÚstr)rY   r{   Úurlr=   r=   r>   Úmake_urlž   s   
zBaseTestServer.make_urlc                 C   s
   | j d uS ry   )rV   ©rY   r=   r=   r>   Ústarted§   s   
zBaseTestServer.startedc                 C   ó   | j S ry   )rX   r�   r=   r=   r>   Úclosed«   ó   zBaseTestServer.closedc                 C   s&   | j }|d us	J ‚|jd usJ ‚|jS ry   )rV   rv   )rY   rV   r=   r=   r>   Úhandler¯   s   zBaseTestServer.handlerc                 Ã   sJ   �| j r!| js#| jdusJ ‚| j ¡ I dH  d| _d| _d| _dS dS dS )a`  Close all fixtures created by the test client.

        After that point, the TestClient is no longer usable.

        This is an idempotent function: running close multiple times
        will not have any additional effects.

        close is also run when the object is garbage collected, and on
        exit when used as a context manager.

        NT)r‚   r„   rV   ÚcleanuprW   r@   rX   r�   r=   r=   r>   Úclose¸   s   €
ûzBaseTestServer.closec                 C   ó   t dƒ‚©NzUse async with instead©Ú	TypeErrorr�   r=   r=   r>   Ú	__enter__Ë   ó   zBaseTestServer.__enter__Úexc_typeÚ	exc_valueÚ	tracebackc                 C   ó   d S ry   r=   ©rY   r�   r�   r‘   r=   r=   r>   Ú__exit__Î   ó   zBaseTestServer.__exit__c                 Ã   s   �| j | jd�I d H  | S ©N©rQ   )rw   rU   r�   r=   r=   r>   Ú
__aenter__×   s   €zBaseTestServer.__aenter__c                 Ã   ó   �|   ¡ I d H  d S ry   ©rˆ   r“   r=   r=   r>   Ú	__aexit__Û   ó   €zBaseTestServer.__aexit__ry   ©r;   N)r;   rN   )#Ú__name__Ú
__module__Ú__qualname__Ú__test__r<   r~   ÚasyncioÚAbstractEventLooprK   Úboolr   rA   ÚAddressFamilyr   rZ   rw   r   r'   ri   r#   r   r€   Úpropertyr‚   r„   r)   r†   rˆ   r�   ÚtypeÚBaseExceptionr   r”   r˜   r›   r=   r=   r=   r>   rN   `   s‚    öýüûúùÿøõ
ôÿÿÿ
þ 	


þýü
û
	
þýüûrN   c                       sR   e Zd ZddddœdededededB d	ef
‡ fd
d„Zd	edefdd„Z	‡  Z
S )Ú
TestServerrO   rI   N©rP   r9   r@   ÚapprP   r9   r@   rT   c                   ó$   || _ tƒ jd|||dœ|¤Ž d S ©Nrª   r=   )r«   ÚsuperrZ   )rY   r«   rP   r9   r@   rT   ©Ú	__class__r=   r>   rZ   å   ó   	zTestServer.__init__r;   c                 Ë   s   �t | jfi |¤ŽS ry   )r%   r«   rz   r=   r=   r>   ri   ñ   s   €zTestServer._make_runner)rž   rŸ   r    r$   r~   rK   r   rZ   r'   ri   Ú__classcell__r=   r=   r¯   r>   r©   ä   s     úþüûúùr©   c                       s\   e Zd ZddddœdededededB d	ed
df‡ fdd„Zdded	ed
e	fdd„Z
‡  ZS )ÚRawTestServerrO   rI   Nrª   r†   rP   r9   r@   rT   r;   c                   r¬   r­   )Ú_handlerr®   rZ   )rY   r†   rP   r9   r@   rT   r¯   r=   r>   rZ   ö   r±   zRawTestServer.__init__TÚdebugc                 Ë   s0   �t | jf| j|dœ|¤Ž}t|fd|i|¤ŽS )N)rQ   rµ   rµ   )r)   r´   rU   r*   )rY   rµ   rT   Úsrvr=   r=   r>   ri     s   €zRawTestServer._make_runner)T)rž   rŸ   r    r-   r~   rK   r   rZ   r¤   r*   ri   r²   r=   r=   r¯   r>   r³   õ   s$    úþüûúùø r³   c                   @   s^  e Zd ZdZdZeddœdddededB d	ed
df
dd„ƒZ	eddœddde
dedB d	ed
df
dd„ƒZ	dddœde
dedB dejdB d	ed
df
dd„Z	d^dd„Zed
efdd„ƒZed
edB fdd„ƒZed
e
fdd„ƒZed
efdd„ƒZed
efdd„ƒZded
efdd „Zd!eded	ed
efd"d#„Zejd$k�r
e�r
d!eded	e e! d
e"fd%d&„Z#ded	e e! d
e"fd'd(„Z$ded	e e! d
e"fd)d*„Z%ded	e e! d
e"fd+d,„Z&ded	e e! d
e"fd-d.„Z'ded	e e! d
e"fd/d0„Z(ded	e e! d
e"fd1d2„Z)ded	e e! d
e"fd3d4„Z*nZd!eded	ed
e"fd5d&„Z#ded	ed
e"fd6d(„Z$ded	ed
e"fd7d.„Z'ded	ed
e"fd8d*„Z%ded	ed
e"fd9d,„Z&ded	ed
e"fd:d0„Z(ded	ed
e"fd;d2„Z)ded	ed
e"fd<d4„Z*ed=d>œded?e+d@ d	ed
dAfdBdC„ƒZ,eded?e+d d	ed
dDfdEdC„ƒZ,ed=d>œded?e-d	ed
dFfdGdC„ƒZ,d@d>œded?e-d	ed
dFfdHdC„Z,ed=d>œded?e+d@ d	ed
dIfdJdK„ƒZ.eded?e+d d	ed
dLfdMdK„ƒZ.ed=d>œded?e-d	ed
dNfdOdK„ƒZ.d@d>œded?e-d	ed
dNfdPdK„Z.d^dQdR„Z/d^dSdT„Z0dUe1e2 dB dVe2dB dWe3dB d
dfdXdY„Z4d
e5fdZd[„Z6dUe1e2 dB dVe2dB dWe3dB d
dfd\d]„Z7dS )_Ú
TestClientzb
    A test client implementation.

    To write functional tests for aiohttp based servers.

    FN)Ú
cookie_jarrY   z TestClient[Request, Application]rv   r¸   rT   r;   c                K   r’   ry   r=   ©rY   rv   r¸   rT   r=   r=   r>   rZ     r•   zTestClient.__init__zTestClient[_Request, None]c                K   r’   ry   r=   r¹   r=   r=   r>   rZ     r•   )r¸   rQ   rQ   c                K   sp   t |tƒstdt|ƒ ƒ‚|| _|| _|d u rtjd|d�}td||dœ|¤Ž| _	d| j	_
d| _g | _g | _d S )Nz2server must be TestServer instance, found type: %rT)ÚunsaferQ   )rQ   r¸   Fr=   )Ú
isinstancerN   rŒ   r§   rq   rU   ÚaiohttpÚ	CookieJarr   Ú_sessionÚ_retry_connectionrX   Ú
_responsesÚ_websockets)rY   rv   r¸   rQ   rT   r=   r=   r>   rZ   !  s   

ÿ
c                 Ã   s   �| j j| jd�I d H  d S r–   )rq   rw   rU   r�   r=   r=   r>   rw   7  s   €zTestClient.start_serverc                 C   ó   | j jS ry   )rq   r9   r�   r=   r=   r>   r9   :  ó   zTestClient.hostc                 C   rÂ   ry   )rq   r@   r�   r=   r=   r>   r@   >  rÃ   zTestClient.portc                 C   rƒ   ry   )rq   r�   r=   r=   r>   rv   B  r…   zTestClient.serverc                 C   s   t | jdd ƒS )Nr«   )Úgetattrrq   r�   r=   r=   r>   r«   F  s   zTestClient.appc                 C   rƒ   )zðAn internal aiohttp.ClientSession.

        Unlike the methods on the TestClient, client session requests
        do not automatically include the host in the url queried, and
        will require an absolute path to the resource.

        )r¾   r�   r=   r=   r>   ÚsessionJ  s   	zTestClient.sessionr{   c                 C   s   | j  |¡S ry   )rq   r€   )rY   r{   r=   r=   r>   r€   U  s   zTestClient.make_urlÚmethodc                 Ë   s4   �| j j||  |¡fi |¤ŽI d H }| j |¡ |S ry   )r¾   Úrequestr€   rÀ   Úappend)rY   rÆ   r{   rT   Úrespr=   r=   r>   Ú_requestX  s   €"zTestClient._requestr/   c                 K   r’   ry   r=   ©rY   rÆ   r{   rT   r=   r=   r>   rÇ   b  s   zTestClient.requestc                 K   r’   ry   r=   ©rY   r{   rT   r=   r=   r>   Úgetf  ó   zTestClient.getc                 K   r’   ry   r=   rÌ   r=   r=   r>   Úoptionsl  rÎ   zTestClient.optionsc                 K   r’   ry   r=   rÌ   r=   r=   r>   Úheadr  rÎ   zTestClient.headc                 K   r’   ry   r=   rÌ   r=   r=   r>   Úpostx  rÎ   zTestClient.postc                 K   r’   ry   r=   rÌ   r=   r=   r>   Úput~  rÎ   zTestClient.putc                 K   r’   ry   r=   rÌ   r=   r=   r>   Úpatch„  rÎ   zTestClient.patchc                 K   r’   ry   r=   rÌ   r=   r=   r>   ÚdeleteŠ  rÎ   zTestClient.deletec                 K   s   t | j||fi |¤ŽƒS )zäRoutes a request to tested http server.

            The interface is identical to aiohttp.ClientSession.request,
            except the loop kwarg is overridden by the instance used by the
            test server.

            )r   rÊ   rË   r=   r=   r>   rÇ   ’  s   
c                 K   ó   t | jtj|fi |¤ŽƒS )zPerform an HTTP GET request.)r   rÊ   r   ÚMETH_GETrÌ   r=   r=   r>   rÍ   ž  ó   c                 K   rÕ   )zPerform an HTTP POST request.)r   rÊ   r   Ú	METH_POSTrÌ   r=   r=   r>   rÑ   ¢  r×   c                 K   rÕ   )z Perform an HTTP OPTIONS request.)r   rÊ   r   ÚMETH_OPTIONSrÌ   r=   r=   r>   rÏ   ¦  ó   ÿc                 K   rÕ   )zPerform an HTTP HEAD request.)r   rÊ   r   Ú	METH_HEADrÌ   r=   r=   r>   rÐ   ¬  r×   c                 K   rÕ   )zPerform an HTTP PUT request.)r   rÊ   r   ÚMETH_PUTrÌ   r=   r=   r>   rÒ   °  r×   c                 K   rÕ   ©zPerform an HTTP PATCH request.)r   rÊ   r   Ú
METH_PATCHrÌ   r=   r=   r>   rÓ   ´  rÚ   c                 K   rÕ   rÝ   )r   rÊ   r   ÚMETH_DELETErÌ   r=   r=   r>   rÔ   º  rÚ   .)Údecode_textrà   TzB_BaseRequestContextManager[ClientWebSocketResponse[Literal[True]]]c                K   r’   ry   r=   ©rY   r{   rà   rT   r=   r=   r>   Ú
ws_connectÀ  ó   zTestClient.ws_connectzC_BaseRequestContextManager[ClientWebSocketResponse[Literal[False]]]c                K   r’   ry   r=   rá   r=   r=   r>   râ   Å  rã   z9_BaseRequestContextManager[ClientWebSocketResponse[bool]]c                K   r’   ry   r=   rá   r=   r=   r>   râ   Ê  rã   c                K   s   t | j|fd|i|¤ŽƒS )zjInitiate websocket connection.

        The api corresponds to aiohttp.ClientSession.ws_connect.

        rà   )r   Ú_ws_connectrá   r=   r=   r>   râ   Ï  s   ÿz&ClientWebSocketResponse[Literal[True]]c                Ë   rx   ry   r=   rá   r=   r=   r>   rä   Û  ó   €zTestClient._ws_connectz'ClientWebSocketResponse[Literal[False]]c                Ë   rx   ry   r=   rá   r=   r=   r>   rä   à  rå   zClientWebSocketResponse[bool]c                Ë   rx   ry   r=   rá   r=   r=   r>   rä   å  rå   c                Ë   s6   �| j j|  |¡fd|i|¤ŽI d H }| j |¡ |S )Nrà   )r¾   râ   r€   rÁ   rÈ   )rY   r{   rà   rT   Úwsr=   r=   r>   rä   ê  s   €ÿÿÿc                 Ã   sd   �| j s0| jD ]}| ¡  q| jD ]	}| ¡ I dH  q| j ¡ I dH  | j ¡ I dH  d| _ dS dS )aH  Close all fixtures created by the test client.

        After that point, the TestClient is no longer usable.

        This is an idempotent function: running close multiple times
        will not have any additional effects.

        close is also run on exit when used as a(n) (asynchronous)
        context manager.

        NT)rX   rÀ   rˆ   rÁ   r¾   rq   )rY   rÉ   ræ   r=   r=   r>   rˆ   ó  s   €



ùzTestClient.closec                 C   r‰   rŠ   r‹   r�   r=   r=   r>   r�     rŽ   zTestClient.__enter__r�   ÚexcÚtbc                 C   r’   ry   r=   ©rY   r�   rç   rè   r=   r=   r>   r”     r•   zTestClient.__exit__c                 Ã   s   �|   ¡ I d H  | S ry   )rw   r�   r=   r=   r>   r˜     s   €zTestClient.__aenter__c                 Ã   r™   ry   rš   ré   r=   r=   r>   r›     rœ   zTestClient.__aexit__r�   )8rž   rŸ   r    Ú__doc__r¡   r   r©   r   r   rZ   rN   r¢   r£   rw   r¦   r~   r9   rK   r@   rv   r4   r«   r   rÅ   r#   r   r€   r   rÊ   ÚsysÚversion_infor   r2   r   r   rÇ   rÍ   rÏ   rÐ   rÑ   rÒ   rÓ   rÔ   r
   râ   r¤   rä   rˆ   r�   r§   r¨   r   r”   r3   r˜   r›   r=   r=   r=   r>   r·     sæ   üÿþüûúüÿþüûúûþüûú
ù

ÿÿÿ
þÿÿÿ
þþý
üþý
üþý
üþý
üþý
üþý
üþýüÿÿÿ
þÿÿÿÿþÿÿÿþÿÿÿÿþÿÿÿÿ
þÿÿÿÿþÿÿÿþÿÿÿÿþÿÿÿÿ
þ
	

þýü
û	
þýüûr·   c                   @   s€   e Zd ZdZdefdd„Zdefdd„Zddd	„Zdd
d„Zddd„Z	ddd„Z
dedefdd„Zdedeeef fdd„ZdS )ÚAioHTTPTestCasea  A base class to allow for unittest web applications using aiohttp.

    Provides the following:

    * self.client (aiohttp.test_utils.TestClient): an aiohttp test client.
    * self.loop (asyncio.BaseEventLoop): the event loop in which the
        application and server are running.
    * self.app (aiohttp.web.Application): the application returned by
        self.get_application()

    Note that the TestClient's methods are asynchronous: you have to
    execute function on the test client using asynchronous methods.
    r;   c                 Ã   s
   �|   ¡ S )z‰Get application.

        This method should be overridden
        to return the aiohttp.web.Application
        object to test.
        )Úget_appr�   r=   r=   r>   Úget_application0  s   €zAioHTTPTestCase.get_applicationc                 C   r‰   )zqObsolete method used to constructing web application.

        Use .get_application() coroutine instead.
        z+Did you forget to define get_application()?)ÚRuntimeErrorr�   r=   r=   r>   rî   9  s   zAioHTTPTestCase.get_appNc                 Ã   s   �t  ¡ | _|  ¡ I d H S ry   )r¢   Úget_running_looprQ   Ú
setUpAsyncr�   r=   r=   r>   Ú
asyncSetUp@  s   €
zAioHTTPTestCase.asyncSetUpc                 Ã   sN   �|   ¡ I d H | _|  | j¡I d H | _|  | j¡I d H | _| j ¡ I d H  d S ry   )rï   r«   Ú
get_serverrv   Ú
get_clientÚclientrw   r�   r=   r=   r>   rò   D  s
   €zAioHTTPTestCase.setUpAsyncc                 Ã   s   �|   ¡ I d H S ry   )ÚtearDownAsyncr�   r=   r=   r>   ÚasyncTearDownK  s   €zAioHTTPTestCase.asyncTearDownc                 Ã   s   �| j  ¡ I d H  d S ry   )rö   rˆ   r�   r=   r=   r>   r÷   N  s   €zAioHTTPTestCase.tearDownAsyncr«   c                 Ã   ó   �t || jd�S )zReturn a TestServer instance.r—   )r©   rQ   )rY   r«   r=   r=   r>   rô   Q  ó   €zAioHTTPTestCase.get_serverrv   c                 Ã   rù   )zReturn a TestClient instance.r—   )r·   rQ   )rY   rv   r=   r=   r>   rõ   U  rú   zAioHTTPTestCase.get_clientr�   )rž   rŸ   r    rê   r$   rï   rî   ró   rò   rø   r÷   r©   rô   r·   r(   rõ   r=   r=   r=   r>   rí   !  s    	



rí   ÚfuncÚargsrT   c                 O   s   t jdtdd� | S )zw
    A decorator dedicated to use with asynchronous AioHTTPTestCase test methods.

    In 3.8+, this does nothing.
    zBDecorator `@unittest_run_loop` is no longer needed in aiohttp 3.8+ra   )Ú
stacklevel)ÚwarningsÚwarnÚDeprecationWarning)rû   rü   rT   r=   r=   r>   Úunittest_run_loopZ  s   ýr  FÚloop_factoryÚfastc                 c   s    � t | ƒ}|V  t||d� dS )zzA contextmanager that creates an event_loop, for test purposes.

    Handles the creation and cleanup of a test loop.
    )r  N)Úsetup_test_loopÚteardown_test_loop)r  r  rQ   r=   r=   r>   Úloop_contextk  s   €r  c                 C   s   | ƒ }t  |¡ |S )z”Create and return an asyncio.BaseEventLoop instance.

    The caller should also call teardown_test_loop,
    once they are done with the loop.
    )r¢   Úset_event_loop)r  rQ   r=   r=   r>   r  x  s   
r  rQ   c                 C   sB   |   ¡ }|s|  | j¡ |  ¡  |  ¡  |st ¡  t d¡ dS )z>Teardown and cleanup an event_loop created by setup_test_loop.N)	Ú	is_closedÚ	call_soonÚstopÚrun_foreverrˆ   ÚgcÚcollectr¢   r  )rQ   r  r„   r=   r=   r>   r  …  s   r  c                  C   sl   dt dtdt fdd„} dt dtdt dd fdd„}tjtd	�}i |_| |_||_d
|_t	|ƒ|_
|j
 ¡  |S )Nr«   Úkeyr;   c                 S   s
   | j | S ry   ©Ú
__app_dict)r«   r  r=   r=   r>   Úget_dict”  s   
z"_create_app_mock.<locals>.get_dictÚvaluec                 S   s   || j |< d S ry   r  )r«   r  r  r=   r=   r>   Úset_dict—  s   z"_create_app_mock.<locals>.set_dict)ÚspecF)r   r~   r   Ú	MagicMockr$   r  Ú__getitem__Ú__setitem__Ú_debugr   Úon_response_prepareÚfreeze)r  r  r«   r=   r=   r>   Ú_create_app_mock“  s   

r  Ú
sslcontextc                    s:   t  ¡ }dtdttttf B d B f‡ fdd„}||j_|S )Nr  r;   c                    s   | dkrˆ S | dkrdS d S )Nr  Úsockname)rI   éP   r=   )r  ©r  r=   r>   Úget_extra_info¨  s   z)_create_transport.<locals>.get_extra_info)r   ÚMockr~   r.   ÚtuplerK   r   Úside_effect)r  Ú	transportr   r=   r  r>   Ú_create_transport¥  s   &r%  i   .)Ú
match_inform   Úclosingr«   ÚwriterÚprotocolr$  Úpayloadr  Úclient_max_sizerQ   rÆ   r{   Úheadersr&  rm   r'  r«   r(  r)  r$  r*  r+  c                C   sü  t  ¡ }|du r zt ¡ }W n ty   t  ¡ }d|j_Y nw |tddƒk r)d}|r=tt	|ƒƒ}t
dd„ | ¡ D ƒƒ}ntt	ƒ ƒ}d}d| tjd¡ ¡ v }| tjd¡ ¡ d	koat| tj¡ƒ}t|  ¡ |||||d
||t|ƒƒ
}|d
u rztƒ }|	tu r‚t|ƒ}	|tu r·t  ¡ }d|_d|_d|_|	|_t j|	 d¡d�t|ƒ_ t j|	 d¡d�t|ƒ_!t j|d�t|ƒ_"|tu rÖt  ¡ }t#d
ƒ|_$t#d
ƒ|_%t#d
ƒ|_&t#d
ƒ|_'|	|_|	|_||_(t)||
|||||d�}t*|tu rîi n|t  ¡ ƒ}| +|¡ ||_,|S )z±Creates mocked web.Request testing purposes.

    Useful in unit tests, when spinning full web server is overkill or
    specific conditions and errors are hard to trigger.
    .r=   r   Tc                 s   s(   � | ]\}}|  d ¡|  d ¡fV  qdS )zutf-8N)Úencode)Ú.0ÚkÚvr=   r=   r>   Ú	<genexpr>Ø  s   € 
ÿz&make_mocked_request.<locals>.<genexpr>ÚchunkedrO   ÚupgradeNiþ  é€   Úpeername)Úreturn_valuer  )r+  )-r   r!  r¢   rñ   rð   Úcreate_futurer6  r   r   r   r"  ÚitemsrÍ   r   ÚTRANSFER_ENCODINGÚlowerÚ
CONNECTIONr¤   ÚUPGRADEr    Úupperr   r  r   r%  Úmax_field_sizeÚmax_line_lengthÚmax_headersr$  ÚPropertyMockr   r§   r5  r  rc   Úmake_mocked_coroÚwrite_headersÚwriteÚ	write_eofÚdrainr(  r(   r,   Úadd_appÚ_match_info)rÆ   r{   r,  r&  rm   r'  r«   r(  r)  r$  r*  r  r+  rQ   ÚtaskÚraw_hdrsr2  r3  ÚmessageÚreqr=   r=   r>   Úmake_mocked_request±  sˆ   þ
ÿ

ÿöÿÿ



ÿÿ
rM  r6  Úraise_exceptionc                    s(   dt dt dt f‡ ‡fdd„}tj|d�S )zCreates a coroutine mock.rü   rT   r;   c                  Ÿ   s*   �ˆ t urˆ ‚t ˆ¡sˆS ˆI d H  d S ry   )r   ÚinspectÚisawaitable)rü   rT   ©rN  r6  r=   r>   Ú	mock_coro!  s   €
z#make_mocked_coro.<locals>.mock_coro)Úwraps)r   r   r!  )r6  rN  rR  r=   rQ  r>   rB    s   rB  )Fry   )mrê   r¢   Ú
contextlibr  rO  rk   ÚosrA   rë   rþ   Úabcr   r   Úcollections.abcr   r   Útypesr   Útypingr   r   r	   r
   r   r   r   Úunittestr   r   Ú	aiosignalr   Ú	multidictr   r   Úyarlr   r¼   Úaiohttp.clientr   r   r   r   rO   r   r   r   Úclient_reqrepr   Ú	client_wsr   Úhelpersr   re   r   r    Ústreamsr!   r"   Útypedefsr#   Úwebr$   r%   r&   r'   r(   r)   r*   r+   r,   Úweb_protocolr-   r[   r.   rì   r2   r3   r4   r5   ÚnameÚplatformrC   rJ   r~   r¥   r?   rK   r<   rM   rN   r©   r³   r·   rí   r  r£   Ú_LOOP_FACTORYÚcontextmanagerÚnew_event_loopr¤   r  r  r  r  r  r!  r%  rM  rB  r=   r=   r=   r>   Ú<module>   s   $,
ÿÿÿ
þÿÿÿ
þ   9ÿÿÿþÿÿ
þýñÿþýûúùø	÷
öõôóòñ
ðlÿÿÿþ