| Server IP : 118.27.122.248 / Your IP : 216.73.216.63 Web Server : Apache System : Linux web0264.sh.tyo1 4.18.0-553.79.1.lve.el7h.x86_64 #1 SMP Wed Oct 15 16:34:46 UTC 2025 x86_64 User : c9415830 ( 11735) PHP Version : 8.4.17 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /opt/alt/python37/lib64/python3.7/site-packages/aiohttp/__pycache__/ |
Upload File : |
B
�Z�_ O � @ s d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl
m Z m Z ddl
mZ ddlmZmZmZmZmZmZmZmZ ddl mZ ddlmZmZ ddl m Z ddl Z dd l m Z m!Z!m"Z" d
d l#m$Z$m%Z% d
d l
m&Z& d
d
l'm Z d
dl(m)Z) d
dl*m+Z+ d
dl,m-Z-m.Z. d
dl/m0Z0 d
dl1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9 d
dl:m;Z; e�rxddl<m=Z= ndZ=ej>dk�o�ej?dkZ@eAejd�dd�ZBeAeCejd�dd �ZDeCd �d d �ZEG d d!� d!e �ZFG d"d#� d#eF�ZGG d$d%� d%eF�ZHG d&d'� d'�ZIG d(d)� d)e jJ�ZKeeeed*�d+d,�ZLeg ejMf ZNejOejPd-feNeQeejM d.�d/d0��ZRejPfeNejMd1�d2d3�ZSdEejMeQdd4�d5d6�ZTejUd �d7d8�ZVdFee= ejWd9�d:d;�ZXdGe+e-d
d
�d-de+e+e+e+dd<d=d>� eAeAeee-eQeeeeeee= eCee5d?�d@dA�ZYe+e+feeedB�dCdD�ZZdS )HzUtilities shared by tests.� N)�ABC�abstractmethod)�
TracebackType)�
TYPE_CHECKING�Any�Callable�Iterator�List�Optional�Type�Union)�mock)� CIMultiDict�CIMultiDictProxy)�URL)�ClientResponse�_RequestContextManager�_WSRequestContextManager� )�
ClientSession�hdrs)�AbstractCookieJar)r )�ClientWebSocketResponse)�sentinel)� HttpVersion�RawRequestMessage)�Signal)� Application� AppRunner�
BaseRunner�Request�Server� ServerRunner�SockSite�UrlMappingMatchInfo)�_RequestHandler)�
SSLContext�posix�cygwin)�host�returnc C s
t | d�S )Nr )�get_port_socket)r) � r, �E/opt/alt/python37/lib64/python3.7/site-packages/aiohttp/test_utils.py�get_unused_port_socket7 s r. )r) �portr* c C s8 t � t jt j�}tr&|�t jt jd� |�| |f� |S )Nr )�socket�AF_INET� SOCK_STREAM�
REUSE_ADDRESSZ
setsockoptZ
SOL_SOCKETZ SO_REUSEADDR�bind)r) r/ �sr, r, r- r+ ; s
r+ )r* c C s2 t � t jt j��} | �d� | �� d S Q R X dS )z1Return a port that is unused on the current host.)z 127.0.0.1r r N)r0 r1 r2 r4 � getsockname)r5 r, r, r- � unused_portF s
r7 c @ s0 e Zd ZdZeddddd�eeef ee j
eee e e
dd�dd�Zd#ee j
e
dd�d d
�Zee
ed �d d
��Zeed�dd�Zee d�dd��Zee d�dd��Zeed�dd��Zdd�dd�Zdd�dd�Zee e ee ee dd �d d �Z d d�d d �Z ee e ee ee dd �d!d"�Z!dS )$�BaseTestServerFNz 127.0.0.1)�scheme�loopr) r/ �skip_url_asserts)r9 r: r) r/ r; �kwargsr* c K s4 || _ d | _d | _|| _|| _d| _|| _|| _d S )NF)�_loop�runner�_rootr) r/ �_closedr9 r; )�selfr9 r: r) r/ r; r< r, r, r- �__init__P s
zBaseTestServer.__init__)r: r< r* c � s | j r
d S || _|�dd �| _| jf |�I d H | _ | j �� I d H | jsNd| _t| j| j�}|� � d d� \| _| _t
| j || jd�}|� � I d H |j }|d k s�t
�|j}|d k s�t
�|d � � d | _| jtkr�| jr�d}nd}|| _t| j� d| j� d | j� ��| _d S )
N�sslr � )ZsockZ ssl_contextr Zhttps�httpz://�:)r> r= �popZ_ssl� _make_runnerZsetupr/ r+ r) r6 r# �start�_server�AssertionError�socketsr9 r r r? )rA r: r< Z_sockZsite�serverrL r9 r, r, r- � start_serverc s.
zBaseTestServer.start_server)r< r* c � s d S )Nr, )rA r< r, r, r- rH s zBaseTestServer._make_runner)�pathr* c C sJ | j d k st�t|�}| js4|�� r(t�| j �|�S tt| j �| �S d S )N)r? rK r r; Z is_absolute�join�str)rA rO Zurlr, r, r- �make_url� s zBaseTestServer.make_url)r* c C s
| j d k S )N)r> )rA r, r, r- �started� s zBaseTestServer.startedc C s | j S )N)r@ )rA r, r, r- �closed� s zBaseTestServer.closedc C s& | j }|d k st�|jd k s t�|jS )N)r> rK rM )rA r> r, r, r- �handler� s zBaseTestServer.handlerc � s@ | j r<| js<| jdk st�| j�� I dH d| _d| _d| _dS )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)rS rT r> rK Zcleanupr? r/ r@ )rA r, r, r- �close� s zBaseTestServer.closec C s t d��d S )NzUse async with instead)� TypeError)rA r, r, r- � __enter__� s zBaseTestServer.__enter__)�exc_type� exc_value� tracebackr* c C s d S )Nr, )rA rY rZ r[ r, r, r- �__exit__� s zBaseTestServer.__exit__c � s | j | jd�I d H | S )N)r: )rN r= )rA r, r, r- �
__aenter__� s zBaseTestServer.__aenter__c � s | � � I d H d S )N)rV )rA rY rZ r[ r, r, r- � __aexit__� s zBaseTestServer.__aexit__)N)"�__name__�
__module__� __qualname__�__test__r r rQ �objectr
�asyncio�AbstractEventLoop�int�boolr rB rN r r rH r rR �propertyrS rT r! rU rV rX r �
BaseExceptionr r\ r] r^ r, r, r, r- r8 M s< "
r8 c sP e Zd Zeddd�eeeef eee e
d�� fdd�Z e
e d�dd �Z
� ZS )
�
TestServerz 127.0.0.1N)r9 r) r/ )�appr9 r) r/ r< c s$ || _ t� jf |||d�|�� d S )N)r9 r) r/ )rk �superrB )rA rk r9 r) r/ r< )� __class__r, r- rB � s zTestServer.__init__)r< r* c � s t | jf|�S )N)r rk )rA r< r, r, r- rH � s zTestServer._make_runner)r_ r` ra r r r rQ rc r
rf r rB r rH �
__classcell__r, r, )rm r- rj � s
rj c sV e Zd Zeddd�eeeef eee e
dd�� fdd�Z d e e
e
d�d d
�Z� ZS ) �
RawTestServerz 127.0.0.1N)r9 r) r/ )rU r9 r) r/ r< r* c s$ || _ t� jf |||d�|�� d S )N)r9 r) r/ )�_handlerrl rB )rA rU r9 r) r/ r< )rm r, r- rB � s zRawTestServer.__init__T)�debugr< r* c � s. t | jf| j|d�|��}t|fd|i|��S )N)r: rq rq )r! rp r= r" )rA rq r< Zsrvr, r, r- rH � s zRawTestServer._make_runner)T)r_ r` ra r r% r rQ rc r
rf r rB rg r" rH rn r, r, )rm r- ro � s ro c @ s� e Zd ZdZdZddd�eee eej e
dd�dd�Z dd�d d
�Z e
ed�d d ��Ze
ee d�d
d��Ze
ed�dd��Ze
ed�dd��Ze
ed�dd��Zeed�dd�Zeee
ed�dd�Zeee
ed�dd �Z ee
ed �d d �Z ee
ed �d d!�Z ee
ed �d"d#�Z ee
ed �d$d%�Z ee
ed �d&d'�Z!ee
ed �d(d)�Z"ee
ed �d*d+�Z#ee
e$d �d,d-�Z%ee
e&d �d.d/�Z'dd�d0d1�Z(dd�d2d3�Z)ee*e+ ee+ ee, dd4�d5d6�Z-d d�d7d8�Z.ee*e+ ee+ ee, dd4�d9d:�Z/dS );�
TestClientzb
A test client implementation.
To write functional tests for aiohttp based servers.
FN)�
cookie_jarr: )rM rs r: r< r* c K sh t |t�stdt|� ��|| _|| _|d kr<tjd|d�}tf ||d�|��| _ d| _
g | _ g | _ d S )Nz2server must be TestServer instance, found type: %rT)Zunsafer: )r: rs F)
�
isinstancer8 rW �typerJ r= �aiohttpZ CookieJarr �_sessionr@ �
_responses� _websockets)rA rM rs r: r< r, r, r- rB � s
zTestClient.__init__)r* c � s | j j| jd�I d H d S )N)r: )rJ rN r= )rA r, r, r- rN s zTestClient.start_serverc C s | j jS )N)rJ r) )rA r, r, r- r) s zTestClient.hostc C s | j jS )N)rJ r/ )rA r, r, r- r/ s zTestClient.portc C s | j S )N)rJ )rA r, r, r- rM s zTestClient.serverc C s t | jdd �S )Nrk )�getattrrJ )rA r, r, r- rk s zTestClient.appc C s | j S )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.
)rw )rA r, r, r- �session s zTestClient.session)rO r* c C s | j �|�S )N)rJ rR )rA rO r, r, r- rR ) s zTestClient.make_url)�methodrO r< r* c � s. | j j|| �|�f|�I d H }| j�|� |S )N)rw �requestrR rx �append)rA r| rO r< �respr, r, r- �_request, s zTestClient._requestc K s t | j||f|��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� )rA r| rO r< r, r, r- r} 2 s zTestClient.request)rO r< r* c K s t | jtj|f|��S )z Perform an HTTP GET request.)r r� r ZMETH_GET)rA rO r< r, r, r- �get< s zTestClient.getc K s t | jtj|f|��S )z Perform an HTTP POST request.)r r� r Z METH_POST)rA rO r< r, r, r- �post@ s zTestClient.postc K s t | jtj|f|��S )z Perform an HTTP OPTIONS request.)r r� r Z METH_OPTIONS)rA rO r< r, r, r- �optionsD s zTestClient.optionsc K s t | jtj|f|��S )z Perform an HTTP HEAD request.)r r� r Z METH_HEAD)rA rO r< r, r, r- �headH s zTestClient.headc K s t | jtj|f|��S )z Perform an HTTP PUT request.)r r� r ZMETH_PUT)rA rO r< r, r, r- �putL s zTestClient.putc K s t | jtj|f|��S )z Perform an HTTP PATCH request.)r r� r Z
METH_PATCH)rA rO r< r, r, r- �patchP s zTestClient.patchc K s t | jtj|f|��S )z Perform an HTTP PATCH request.)r r� r Z METH_DELETE)rA rO r< r, r, r- �deleteT s zTestClient.deletec K s t | j|f|��S )zjInitiate websocket connection.
The api corresponds to aiohttp.ClientSession.ws_connect.
)r � _ws_connect)rA rO r< r, r, r- �
ws_connectX s zTestClient.ws_connectc � s, | j j| �|�f|�I d H }| j�|� |S )N)rw r� rR ry r~ )rA rO r< �wsr, r, r- r� ` s zTestClient._ws_connectc � sf | j sbx| jD ] }|�� qW x | jD ]}|�� I dH q&W | j�� I dH | j�� I dH d| _ dS )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)r@ rx rV ry rw rJ )rA r r� r, r, r- rV e s zTestClient.closec C s t d��d S )NzUse async with instead)rW )rA r, r, r- rX z s zTestClient.__enter__)rY �exc�tbr* c C s d S )Nr, )rA rY r� r� r, r, r- r\ } s zTestClient.__exit__c � s | � � I d H | S )N)rN )rA r, r, r- r] � s zTestClient.__aenter__c � s | � � I d H d S )N)rV )rA rY r� r� r, r, r- r^ � s zTestClient.__aexit__)0r_ r` ra �__doc__rb r8 r
r rd re r rB rN rh rQ r) rf r/ rM r rk r r{ r rR r r� r r} r� r� r� r� r� r� r� r r� r r� rV rX r ri r r\ r] r^ r, r, r, r- rr � sP
rr c @ s� e Zd ZdZed�dd�Zed�dd�Zdd�dd �Zdd�d
d �Zdd�d d
�Z dd�dd�Z
ee d�dd�Z e e
d�dd�ZdS )�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 )zy
This method should be overridden
to return the aiohttp.web.Application
object to test.
)�get_app)rA r, r, r- �get_application� s z AioHTTPTestCase.get_applicationc C s t d��dS )zqObsolete method used to constructing web application.
Use .get_application() coroutine instead
z+Did you forget to define get_application()?N)� RuntimeError)rA r, r, r- r� � s zAioHTTPTestCase.get_appNc C sl t � | _| j�| �� �| _| j�| �| j��| _| j�| �| j��| _| j�| j� � � | j�| �
� � d S )N) �setup_test_loopr: �run_until_completer� rk �
get_serverrM �
get_client�clientrN �
setUpAsync)rA r, r, r- �setUp� s zAioHTTPTestCase.setUpc � s d S )Nr, )rA r, r, r- r� � s zAioHTTPTestCase.setUpAsyncc C s0 | j �| �� � | j �| j�� � t| j � d S )N)r: r� �
tearDownAsyncr� rV �teardown_test_loop)rA r, r, r- �tearDown� s zAioHTTPTestCase.tearDownc � s d S )Nr, )rA r, r, r- r� � s z AioHTTPTestCase.tearDownAsync)rk r* c � s t || jd�S )z Return a TestServer instance.)r: )rj r: )rA rk r, r, r- r� � s zAioHTTPTestCase.get_server)rM r* c � s t || jd�S )z Return a TestClient instance.)r: )rr r: )rA rM r, r, r- r� � s zAioHTTPTestCase.get_client)r_ r` ra r� r r� r� r� r� r� r� rj r� rr r� r, r, r, r- r� � s r� )�func�argsr< r* c s. t j� f|�|�ttttd�� fdd� �}|S )z�A decorator dedicated to use with asynchronous methods of an
AioHTTPTestCase.
Handles executing an asynchronous function, using
the self.loop of the AioHTTPTestCase.
)rA �
inner_args� inner_kwargsr* c s | j �� | f|�|��S )N)r: r� )rA r� r� )r� r, r- �new_func� s z#unittest_run_loop.<locals>.new_func)� functools�wrapsr )r� r� r< r� r, )r� r- �unittest_run_loop� s r� F)� loop_factory�fastr* c c s t | �}|V t||d� dS )zzA contextmanager that creates an event_loop, for test purposes.
Handles the creation and cleanup of a test loop.
)r� N)r� r� )r� r� r: r, r, r- � loop_context� s r� )r� r* c C s� | � }y|j j}d|k}W n tk
r2 d}Y nX t�|� tjdkr�|s�t�� }t�� }|� |� t
� t �� |�
|� W dQ R X |S )z�Create and return an asyncio.BaseEventLoop
instance.
The caller should also call teardown_test_loop,
once they are done with the loop.
ZuvloopTZwin32N)rm r` �AttributeErrorrd �set_event_loop�sys�platformZget_event_loop_policyZSafeChildWatcherZ attach_loop�
contextlib�suppress�NotImplementedErrorZset_child_watcher)r� r: �moduleZ skip_watcherZpolicyZwatcherr, r, r- r� � s
r� )r: r� r* c C sB | � � }|s(| �| j� | �� | �� |s4t�� t�d� dS )zHTeardown and cleanup an event_loop created
by setup_test_loop.
N) Z is_closedZ call_soon�stopZ run_foreverrV �gcZcollectrd r� )r: r� rT r, r, r- r� s r� c C s^ t tt d�dd�} t tt d d�dd�}t�� }i |_| |_||_d|_t|�|_ |j �
� |S )N)rk �keyr* c S s
| j | S )N)�
__app_dict)rk r� r, r, r- �get_dict s z"_create_app_mock.<locals>.get_dict)rk r� �valuer* c S s || j |< d S )N)r� )rk r� r� r, r, r- �set_dict! s z"_create_app_mock.<locals>.set_dictF) r rQ r
� MagicMockr� � __getitem__� __setitem__Z_debugr Zon_response_prepareZfreeze)r� r� rk r, r, r- �_create_app_mock s
r� )�
sslcontextr* c s, t �� }ttt d�� fdd� }||j_|S )N)r� r* c s | dkr � S d S d S )Nr� r, )r� )r� r, r- �get_extra_info2 s z)_create_transport.<locals>.get_extra_info)r
�MockrQ r
r& r� Z side_effect)r� � transportr� r, )r� r- �_create_transport/ s r� i .) �
match_info�version�closingrk �writer�protocolr� �payloadr� �client_max_sizer: )r| rO �headersr� r� r� rk r� r� r� r� r� r� r: r* c C st t �� }|
dkr t �� }
d|
j_|tdd�k r2d}|rZtt|��}tdd� |�� D ��}ntt� �}d}d|� t
j d�� � k}t
| |||||d d |t|��
}|d
kr�t� }| tkr�t| �} |tkr�t �� }| |_|tk�rt �� }td
�|_td
�|_td
�|_td
�|_| |_| |_||_|
tk�r.t �� }
t||
||||
| d �}t|tk�rTi 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 �fV qdS )zutf-8N)�encode)�.0�k�vr, r, r- � <genexpr>_ s z&make_mocked_request.<locals>.<genexpr>�chunked� FN)r� ) r
r� Z
create_future� return_valuer r r �tuple�itemsr� r ZTRANSFER_ENCODING�lowerr r r� r r� r� �make_mocked_coroZ
write_headers�writeZ write_eofZdrainr� r r$ Zadd_appZ _match_info)r| rO r� r� r� r� rk r� r� r� r� r� r� r: ZtaskZraw_hdrsr� �messageZreqr, r, r- �make_mocked_request< sb
r� )r� �raise_exceptionr* c s$ t t t d�� �fdd� }tj|d�S )zCreates a coroutine mock.)r� r< r* c � s( � t k r � �t���s�S �I d H d S )N)r �inspectZ isawaitable)r� r< )r� r� r, r- � mock_coro� s
z#make_mocked_coro.<locals>.mock_coro)r� )r r
r� )r� r� r� r, )r� r� r- r� � s r� )F)N)N)[r� rd r� r� r� r� �osr0 r� Zunittest�abcr r �typesr �typingr r r r r r
r r r
Z multidictr r Zyarlr rv Zaiohttp.clientr r r r� r r r Z
client_reqrepZ client_wsr Zhelpersr rE r r Zsignalsr Zwebr r r r r! r" r# r$ Z web_protocolr% rC r& �namer� r3 rQ r. rf r+ r7 r8 rj ro rr ZTestCaser� r� re Z
_LOOP_FACTORY�contextmanagerZnew_event_looprg r� r� r� r� r� r� r� r� r� r, r, r, r- �<module> s� ( (
| (@ &M