Submit
Path:
~
/
/
opt
/
alt
/
python37
/
lib64
/
python3.7
/
site-packages
/
aiohttp
/
__pycache__
/
File Content:
web_ws.cpython-37.pyc
B �k�akC � @ s\ U d dl Z d dlZd dlZd dlZd dlZd dlmZmZmZm Z m Z d dl Z d dl Z d dl mZ ddlmZ ddlmZ ddlmZmZ ddlmZmZmZmZmZm Z m Z m Z m Z m Z m!Z! dd l"m#Z# dd l$m%Z%m&Z& dd l'm(Z(m)Z)m*Z* dd l+m,Z,m-Z- dd l.m/Z/ ddl0m1Z1 dZ2dZ3e(e4 e5d< e j6dddd�G dd� d��Z7G dd� de1�Z8dS )� N)�Any�Iterable�Optional�Tuple�cast)� CIMultiDict� )�hdrs)�AbstractStreamWriter)� call_later� set_result) �WS_CLOSED_MESSAGE�WS_CLOSING_MESSAGE�WS_KEY�WebSocketError�WebSocketReader�WebSocketWriter� WSCloseCode� WSMessage� WSMsgType� ws_ext_gen� ws_ext_parse)� ws_logger)� EofStream�FlowControlDataQueue)�Final� JSONDecoder� JSONEncoder)�HTTPBadRequest� HTTPException)� BaseRequest)�StreamResponse)�WebSocketResponse�WebSocketReadyr � �THRESHOLD_CONNLOST_ACCESST)Z auto_attribs�frozen�slotsc @ s0 e Zd ZU eed< ee ed< ed�dd�ZdS )r# �ok�protocol)�returnc C s | j S )N)r( )�self� r, �A/opt/alt/python37/lib64/python3.7/site-packages/aiohttp/web_ws.py�__bool__1 s zWebSocketReady.__bool__N)�__name__� __module__� __qualname__�bool�__annotations__r �strr. r, r, r, r- r# , s r# c s� e Zd ZdZddddddddd�eee eeee ee ee dd� � fd d �Z dd �d d �Z dd �dd�Z dd �dd�Z dd �dd�Zeed�� fdd� Zeedeeef d�dd�Zeeeef d�dd�Zeeedd �d d �Zeed�d d �Zeed �d!d"��Zeee d �d#d$��Zeee d �d%d&��Z eed �d'd(��Z ee d �d)d*�Z dVe dd,�d-d.�Z!dWe dd,�d/d0�Z"dXeee dd1�d2d3�Z#dYe ee dd1�d4d5�Z$dZe%j&d6�e'ee e(dd7�d8d9�Z)dd �d:d;�Z*e+j,d+d<�e e ed=�d>d?�Z-d[ee e.d@�dAdB�Z/ddC�ee ed@�dDdE�Z0ddC�ee e d@�dFdG�Z1e%j2ddH�e3ee e'dI�dJdK�Z4e ddL�dMdN�Z5d d �dOdP�Z6e.d �dQdR�Z7e ddS�dTdU�Z8� Z9S )\r" Fg $@NTr, i @ )�timeout�receive_timeout� autoclose�autoping� heartbeat� protocols�compress� max_msg_size) r5 r6 r7 r8 r9 r: r; r< r* c s� t � jdd� || _d | _d | _d | _d| _d| _d| _d | _ d | _ d | _ d | _ || _ || _|| _|| _|| _d | _|d k r�|d | _d | _|| _|| _d S )N�e )ZstatusFr g @)�super�__init__� _protocols� _ws_protocol�_writer�_reader�_closed�_closing� _conn_lost� _close_code�_loop�_waiting� _exception�_timeout�_receive_timeout� _autoclose� _autoping� _heartbeat� _heartbeat_cb�_pong_heartbeat�_pong_response_cb� _compress� _max_msg_size) r+ r5 r6 r7 r8 r9 r: r; r< )� __class__r, r- r? 9 s. zWebSocketResponse.__init__)r* c C s8 | j d k r| j �� d | _ | jd k r4| j�� d | _d S )N)rR �cancelrP )r+ r, r, r- �_cancel_heartbeat] s z#WebSocketResponse._cancel_heartbeatc C s8 | � � | jd k r4| jd k s t�t| j| j| j�| _d S )N)rW rO rH �AssertionErrorr �_send_heartbeatrP )r+ r, r, r- �_reset_heartbeatf s z"WebSocketResponse._reset_heartbeatc C s\ | j d k rX| jsX| jd k s t�| j�| j�� � | jd k rD| j�� t | j | j | j�| _d S )N) rO rD rH rX Z create_taskrB �pingrR rV r �_pong_not_receivedrQ )r+ r, r, r- rY o s z!WebSocketResponse._send_heartbeatc C s> | j d k r:| j jd k r:d| _tj| _t�� | _| j j� � d S )NT) Z_req� transportrD r �ABNORMAL_CLOSURErG �asyncio� TimeoutErrorrJ �close)r+ r, r, r- r\ } s z$WebSocketResponse._pong_not_received)�requestr* c � s\ | j d k r| j S | �|�\}}t� �|�I d H }|d k s<t�| �|||� |�� I d H |S )N)�_payload_writer� _pre_startr> �preparerX � _post_start�drain)r+ rb r) �writerZpayload_writer)rU r, r- re � s zWebSocketResponse.preparezCIMultiDict[str]c C s� |j }d|�tjd��� �� kr8td�|�tj��d��d|�tjd��� krftd�|�tj��d��d }tj |kr�dd� |tj � d �D �}x,|D ]}|| j kr�|}P q�W t � d || j � |�tjd�}|d kr�td |� �d��|�tj�}y.|�r tt�|��d k�rtd|��d��W n* tjk �rF td|��d�d �Y nX t�t�|�� t ��� ��� }t tjdtjdtj |i�} d} d} | j �r�|�tj �} t | dd�\} } | �r�t!| d| d�} | | tj < |�r�|| tj < | || | fS )NZ websocket� z@No WebSocket UPGRADE hdr: {} Can "Upgrade" only to "WebSocket".)�textZupgradez No CONNECTION upgrade hdr: {}c S s g | ]}t |�� ��qS r, )r4 �strip)�.0�protor, r, r- � <listcomp>� s z0WebSocketResponse._handshake.<locals>.<listcomp>�,u8 Client protocols %r don’t overlap server-known ones %r)Z13�8�7zUnsupported version: � zHandshake error: Fr T)�isserver)r; rs Zserver_notakeover)"�headers�getr ZUPGRADE�lowerrk r �formatZ CONNECTIONZSEC_WEBSOCKET_PROTOCOL�splitr@ r ZwarningZSEC_WEBSOCKET_VERSIONZSEC_WEBSOCKET_KEY�len�base64Z b64decode�binascii�ErrorZ b64encode�hashlibZsha1�encoder Zdigest�decoder ZSEC_WEBSOCKET_ACCEPTrS ZSEC_WEBSOCKET_EXTENSIONSr r )r+ rb rt r) Z req_protocolsrm �version�keyZ accept_valZresponse_headers� notakeoverr; � extensionsZ enabledextr, r, r- � _handshake� sf z WebSocketResponse._handshakec C sl |j | _ | �|�\}}}}| �d� | j�|� | �� || _|jj}|d k sRt �t |j|||d�}||fS )Nr= )r; r� ) rH r� Z set_statusrt �updateZ force_closerS � _protocolr] rX r )r+ rb rt r) r; r� r] rh r, r, r- rd � s z WebSocketResponse._pre_start)rb r) rh r* c C sd || _ || _| �� | j}|d k s&t�t|jd|d�| _|j� t | j| j | j d�� |j� d� d S )Ni )�loop)r; F)rA rB rZ rH rX r r� rC r) Z set_parserr rT rS Z keep_alive)r+ rb r) rh r� r, r, r- rf � s z WebSocketResponse._post_startc C sR | j d k rtd��y| �|�\}}}}W n tk rB tdd �S X td|�S d S )NzAlready startedFT)rB � RuntimeErrorr� r r# )r+ rb �_r) r, r, r- � can_prepare s z WebSocketResponse.can_preparec C s | j S )N)rD )r+ r, r, r- �closed s zWebSocketResponse.closedc C s | j S )N)rG )r+ r, r, r- � close_code s z WebSocketResponse.close_codec C s | j S )N)rA )r+ r, r, r- � ws_protocol s z WebSocketResponse.ws_protocolc C s | j S )N)rS )r+ r, r, r- r; s zWebSocketResponse.compressc C s | j S )N)rJ )r+ r, r, r- � exception! s zWebSocketResponse.exception� )�messager* c � s( | j d krtd��| j �|�I d H d S )NzCall .prepare() first)rB r� r[ )r+ r� r, r, r- r[ $ s zWebSocketResponse.pingc � s( | j d krtd��| j �|�I d H d S )NzCall .prepare() first)rB r� �pong)r+ r� r, r, r- r� ) s zWebSocketResponse.pong)�datar; r* c � sH | j d krtd��t|t�s,tdt|� ��| j j|d|d�I d H d S )NzCall .prepare() firstz data argument must be str (%r)F)�binaryr; )rB r� � isinstancer4 � TypeError�type�send)r+ r� r; r, r, r- �send_str/ s zWebSocketResponse.send_strc � sN | j d krtd��t|tttf�s2tdt|� ��| j j|d|d�I d H d S )NzCall .prepare() firstz#data argument must be byte-ish (%r)T)r� r; ) rB r� r� �bytes� bytearray� memoryviewr� r� r� )r+ r� r; r, r, r- � send_bytes6 s z WebSocketResponse.send_bytes)�dumps)r� r; r� r* c � s | j ||�|d�I d H d S )N)r; )r� )r+ r� r; r� r, r, r- � send_json= s zWebSocketResponse.send_jsonc � s4 | j r d S | jd kr td��| �� I d H d| _ d S )Nz Response has not been startedT)Z _eof_sentrc r� ra )r+ r, r, r- � write_eofF s zWebSocketResponse.write_eof)�coder� )r� r� r* c � s� | j d krtd��| �� | j}|d k s,t�| jd k rT| jsT|�td� | jI d H | j�s�d| _y8| j � ||�I d H | j }|d k s�t�|� � I d H W nT t j t jfk r� tj| _� Y n0 tk r� } ztj| _|| _dS d }~X Y nX | jr�dS | j}|d k �st�y8t�| j�4 I d H � |�� I d H }W d Q I d H R X W nR t j k �rh tj| _� Y n2 tk �r� } ztj| _|| _dS d }~X Y nX |jtjk�r�|j | _dS tj| _t �� | _dS dS d S )NzCall .prepare() firstr TF) rB r� rW rC rX rI rD Z feed_datar ra rc rg r_ �CancelledErrorr` r r^ rG � ExceptionrJ rE � async_timeoutr5 rK �readr� r �CLOSEr� )r+ r� r� �readerrh �exc�msgr, r, r- ra O sV " zWebSocketResponse.close)r5 r* c � sn | j d krtd��| j}|d k s$t��xB| jd k r:td��| jrd| jd7 _| jtkr`td��tS | j rnt S yn|� � | _zFt � |p�| j�4 I d H � | j �� I d H }W d Q I d H R X | �� W d | j}t|d� d | _X W n� tjtjfk �r tj| _� Y n� tk �r8 tj| _| �� I d H tt j d d �S t k �r� } z*|j | _| j|j d�I d H tt j |d �S d }~X Y nP t!k �r� } z0|| _"d| _ tj| _| �� I d H tt j |d �S d }~X Y nX |j#t j$k�r d| _ |j%| _| j�sf| j&�rf| �� I d H nZ|j#t j'k�r"d| _ nD|j#t j(k�rN| j)�rN| �*|j%�I d H q(n|j#t j+k�rf| j)�rfq(|S d S )NzCall .prepare() firstz+Concurrent call to receive() is not allowedr z WebSocket connection is closed.T)r� ),rC r� rH rX rI rD rF r% r rE r Z create_futurer� r5 rL r� rZ r r_ r� r` r r^ rG r �OKra r r �CLOSEDr r� ZERRORr� rJ r� r� r� rM �CLOSINGZPINGrN r� ZPONG)r+ r5 r� r� Zwaiterr� r, r, r- �receive� sj zWebSocketResponse.receive)r5 c � s< | � |�I d H }|jtjkr0td�|j|j���tt|j�S )Nz.Received message {}:{!r} is not WSMsgType.TEXT) r� r� r ZTEXTr� rw r� r r4 )r+ r5 r� r, r, r- � receive_str� s z WebSocketResponse.receive_strc � sB | � |�I d H }|jtjkr6td|j� d|j�d���tt|j�S )NzReceived message �:z is not bytes)r� r� r ZBINARYr� r� r r� )r+ r5 r� r, r, r- � receive_bytes� s z WebSocketResponse.receive_bytes)�loadsr5 )r� r5 r* c � s | j |d�I d H }||�S )N)r5 )r� )r+ r� r5 r� r, r, r- � receive_json� s z WebSocketResponse.receive_json)r� r* c � s t d��d S )Nz"Cannot call .write() for websocket)r� )r+ r� r, r, r- �write� s zWebSocketResponse.writec C s | S )Nr, )r+ r, r, r- � __aiter__� s zWebSocketResponse.__aiter__c � s, | � � I d H }|jtjtjtjfkr(t�|S )N)r� r� r r� r� r� �StopAsyncIteration)r+ r� r, r, r- � __anext__� s zWebSocketResponse.__anext__)r� r* c C s | j d k r| j �|� d S )N)rC Z set_exception)r+ r� r, r, r- �_cancel� s zWebSocketResponse._cancel)r� )r� )N)N)N)N):r/ r0 r1 Z _length_check�floatr r2 r r4 �intr? rW rZ rY r\ r r re r r� r rd rf r# r� �propertyr� r� r� r; � BaseExceptionr� r� r[ r� r� r� �jsonr� r r r� r� r r� ra r r� r� r� r� r r� r� r� r� r� � __classcell__r, r, )rU r- r" 5 s` " S 7= r" )9r_ rz r{ r} r� �typingr r r r r r� �attrZ multidictr ri r �abcr Zhelpersr r Zhttpr r r r r r r r r r r �logr Zstreamsr r Ztypedefsr r r Zweb_exceptionsr r Z web_requestr Z web_responser! �__all__r% r� r3 �sr# r" r, r, r, r- �<module> s. 4
Edit
Rename
Chmod
Delete
FILE
FOLDER
Name
Size
Permission
Action
__init__.cpython-37.opt-1.pyc
3669 bytes
0644
__init__.cpython-37.pyc
3669 bytes
0644
abc.cpython-37.opt-1.pyc
8565 bytes
0644
abc.cpython-37.pyc
8565 bytes
0644
base_protocol.cpython-37.opt-1.pyc
2576 bytes
0644
base_protocol.cpython-37.pyc
2621 bytes
0644
client.cpython-37.opt-1.pyc
28771 bytes
0644
client.cpython-37.pyc
29075 bytes
0644
client_exceptions.cpython-37.opt-1.pyc
11353 bytes
0644
client_exceptions.cpython-37.pyc
11353 bytes
0644
client_proto.cpython-37.opt-1.pyc
6032 bytes
0644
client_proto.cpython-37.pyc
6032 bytes
0644
client_reqrep.cpython-37.opt-1.pyc
27322 bytes
0644
client_reqrep.cpython-37.pyc
27580 bytes
0644
client_ws.cpython-37.opt-1.pyc
8837 bytes
0644
client_ws.cpython-37.pyc
8837 bytes
0644
connector.cpython-37.opt-1.pyc
34764 bytes
0644
connector.cpython-37.pyc
34912 bytes
0644
cookiejar.cpython-37.opt-1.pyc
10562 bytes
0644
cookiejar.cpython-37.pyc
10594 bytes
0644
formdata.cpython-37.opt-1.pyc
4425 bytes
0644
formdata.cpython-37.pyc
4457 bytes
0644
hdrs.cpython-37.opt-1.pyc
5273 bytes
0644
hdrs.cpython-37.pyc
5273 bytes
0644
helpers.cpython-37.opt-1.pyc
25591 bytes
0644
helpers.cpython-37.pyc
25591 bytes
0644
http.cpython-37.opt-1.pyc
1229 bytes
0644
http.cpython-37.pyc
1229 bytes
0644
http_exceptions.cpython-37.opt-1.pyc
4281 bytes
0644
http_exceptions.cpython-37.pyc
4281 bytes
0644
http_parser.cpython-37.opt-1.pyc
17605 bytes
0644
http_parser.cpython-37.pyc
17720 bytes
0644
http_websocket.cpython-37.opt-1.pyc
14861 bytes
0644
http_websocket.cpython-37.pyc
14980 bytes
0644
http_writer.cpython-37.opt-1.pyc
5521 bytes
0644
http_writer.cpython-37.pyc
5521 bytes
0644
locks.cpython-37.opt-1.pyc
1593 bytes
0644
locks.cpython-37.pyc
1593 bytes
0644
log.cpython-37.opt-1.pyc
434 bytes
0644
log.cpython-37.pyc
434 bytes
0644
multipart.cpython-37.opt-1.pyc
25776 bytes
0644
multipart.cpython-37.pyc
26222 bytes
0644
payload.cpython-37.opt-1.pyc
13389 bytes
0644
payload.cpython-37.pyc
13389 bytes
0644
payload_streamer.cpython-37.opt-1.pyc
3193 bytes
0644
payload_streamer.cpython-37.pyc
3193 bytes
0644
pytest_plugin.cpython-37.opt-1.pyc
9825 bytes
0644
pytest_plugin.cpython-37.pyc
9877 bytes
0644
resolver.cpython-37.opt-1.pyc
3935 bytes
0644
resolver.cpython-37.pyc
3972 bytes
0644
streams.cpython-37.opt-1.pyc
18241 bytes
0644
streams.cpython-37.pyc
18533 bytes
0644
tcp_helpers.cpython-37.opt-1.pyc
1087 bytes
0644
tcp_helpers.cpython-37.pyc
1087 bytes
0644
test_utils.cpython-37.opt-1.pyc
21164 bytes
0644
test_utils.cpython-37.pyc
21312 bytes
0644
tracing.cpython-37.opt-1.pyc
15045 bytes
0644
tracing.cpython-37.pyc
15045 bytes
0644
typedefs.cpython-37.opt-1.pyc
1483 bytes
0644
typedefs.cpython-37.pyc
1483 bytes
0644
web.cpython-37.opt-1.pyc
9898 bytes
0644
web.cpython-37.pyc
9898 bytes
0644
web_app.cpython-37.opt-1.pyc
15073 bytes
0644
web_app.cpython-37.pyc
15119 bytes
0644
web_exceptions.cpython-37.opt-1.pyc
12658 bytes
0644
web_exceptions.cpython-37.pyc
12658 bytes
0644
web_fileresponse.cpython-37.opt-1.pyc
5898 bytes
0644
web_fileresponse.cpython-37.pyc
5942 bytes
0644
web_log.cpython-37.opt-1.pyc
7162 bytes
0644
web_log.cpython-37.pyc
7162 bytes
0644
web_middlewares.cpython-37.opt-1.pyc
3798 bytes
0644
web_middlewares.cpython-37.pyc
3865 bytes
0644
web_protocol.cpython-37.opt-1.pyc
15464 bytes
0644
web_protocol.cpython-37.pyc
15629 bytes
0644
web_request.cpython-37.opt-1.pyc
23739 bytes
0644
web_request.cpython-37.pyc
23849 bytes
0644
web_response.cpython-37.opt-1.pyc
20056 bytes
0644
web_response.cpython-37.pyc
21059 bytes
0644
web_routedef.cpython-37.opt-1.pyc
7848 bytes
0644
web_routedef.cpython-37.pyc
7848 bytes
0644
web_runner.cpython-37.opt-1.pyc
11549 bytes
0644
web_runner.cpython-37.pyc
11655 bytes
0644
web_server.cpython-37.opt-1.pyc
2692 bytes
0644
web_server.cpython-37.pyc
2692 bytes
0644
web_urldispatcher.cpython-37.opt-1.pyc
41441 bytes
0644
web_urldispatcher.cpython-37.pyc
42271 bytes
0644
web_ws.cpython-37.opt-1.pyc
13105 bytes
0644
web_ws.cpython-37.pyc
13285 bytes
0644
worker.cpython-37.opt-1.pyc
6905 bytes
0644
worker.cpython-37.pyc
6968 bytes
0644
N4ST4R_ID | Naxtarrr
