Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/tornado/__pycache__/websocket.cpython-39.pyc
Ðазад
a _�hD� � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddlZ ddl Z ddl m Z ddl Z ddlmZmZ ddlmZmZmZ ddl mZmZmZ ddlmZmZ ddlmZm Z dd l m Z m Z dd l m Z dd l!m"Z" dd l#m$Z$ dd l%m&Z& ddl'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2 ddl3m4Z4 e(�rzddl5m6Z6 G dd� de6�Z7G dd� de6�Z8G dd� de6�Z9dZ:G dd� de;�Z<G dd� de<�Z=G d d � d e;�Z>G d d � d e?�Z@G d d!� d!e jAjB�ZCe*e*dd"�d#d$�ZDG d%d&� d&ejE�ZFG d'd(� d(e?�ZGG d)d*� d*e?�ZHG d+d,� d,eF�ZIG d-d.� d.e jJ�ZKdddddde:dfe-eLejMf e0d/gdf eNe0e-deLeOf gdf e,eLe*f eNeNePe.eL d0d1� d2d3�ZQdS )4a� Implementation of the WebSocket protocol. `WebSockets <http://dev.w3.org/html5/websockets/>`_ allow for bidirectional communication between the browser and server. WebSockets are supported in the current versions of all major browsers, although older versions that do not support WebSockets are still in use (refer to http://caniuse.com/websockets for details). This module implements the final version of the WebSocket protocol as defined in `RFC 6455 <http://tools.ietf.org/html/rfc6455>`_. Certain browser versions (notably Safari 5.x) implemented an earlier draft of the protocol (known as "draft 76") and are not compatible with this module. .. versionchanged:: 4.0 Removed support for the draft 76 protocol version. � N)�urlparse)�Future�"future_set_result_unless_cancelled)�utf8� native_str� to_unicode)�gen� httpclient�httputil)�IOLoop�PeriodicCallback)�StreamClosedError�IOStream)�gen_log�app_log)�simple_httpclient)�Queue)� TCPClient)�_websocket_mask) � TYPE_CHECKING�cast�Any�Optional�Dict�Union�List� Awaitable�Callable�Tuple�Type)� TracebackType)�Protocolc @ s, e Zd Zeed�dd�Zeed�dd�ZdS )� _Compressor��data�returnc C s d S �N� ��selfr$ r' r' ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/tornado/websocket.py�compress? s z_Compressor.compress)�moder% c C s d S r& r' )r) r, r' r' r* �flushB s z_Compressor.flushN)�__name__� __module__� __qualname__�bytesr+ �intr- r' r' r' r* r" > s r" c @ s" e Zd ZdZeeed�dd�ZdS )� _Decompressor� )r$ � max_lengthr% c C s d S r& r' )r) r$ r5 r' r' r* � decompressH s z_Decompressor.decompressN)r. r/ r0 �unconsumed_tailr1 r2 r6 r' r' r' r* r3 E s r3 c @ s� e Zd Zdeedd�dd�Zeeef ed d�dd�Z edd �d d �Z edd �d d �Z ee e ee ee dd�dd�ZdS )�_WebSocketDelegateN�� close_code� close_reasonr% c C s d S r& r' �r) r: r; r' r' r* �on_ws_connection_closeO s z)_WebSocketDelegate.on_ws_connection_closezAwaitable[None]��messager% c C s d S r& r' �r) r? r' r' r* � on_messageT s z _WebSocketDelegate.on_messager# c C s d S r& r' r( r' r' r* �on_pingW s z_WebSocketDelegate.on_pingc C s d S r& r' r( r' r' r* �on_pongZ s z_WebSocketDelegate.on_pong��typ�value�tbr% c C s d S r& r' �r) rE rF rG r' r' r* � log_exception] s z _WebSocketDelegate.log_exception)NN)r. r/ r0 r2 �strr= r r1 r rA rB rC r � BaseExceptionr rI r' r' r' r* r8 K s �� �r8 i � c @ s e Zd ZdS )�WebSocketErrorN�r. r/ r0 r' r' r' r* rL i s rL c @ s e Zd ZdZdS )�WebSocketClosedErrorzLRaised by operations on a closed connection. .. versionadded:: 3.2 N)r. r/ r0 �__doc__r' r' r' r* rN m s rN c @ s e Zd ZdS )�_DecompressTooLargeErrorNrM r' r' r' r* rP v s rP c @ s4 e Zd Zddedfeeeeeef dd�dd�Z dS )�_WebSocketParamsN)� ping_interval� ping_timeout�max_message_size�compression_optionsr% c C s || _ || _|| _|| _d S r& �rR rS rT rU )r) rR rS rT rU r' r' r* �__init__{ s z_WebSocketParams.__init__) r. r/ r0 �_default_max_message_size�floatr2 r rJ r rW r' r' r' r* rQ z s � �rQ c s e Zd ZdZejjeje dd�� fdd� Z e e dd�dd�Z dZ e ee d �d d ��Ze ee d �d d ��Ze ed �dd��ZdBeeeeee f f edd�dd�Zee ee d�dd�Ze ee d �dd��Z eeee f d �dd�Z eeee d d�d d �Z eeef ee d d �d d �Z dCeeef dd"�d#d$�Z!edd"�d%d&�Z"edd"�d'd(�Z#dd �d)d*�Z$dDeedd+�d,d-�Z%eed.�d/d0�Z&edd1�d2d3�Z'dd �d4d5�Z(dEeedd6�d7d8�Z)dd �� fd9d:� Z*e e dd�� fd;d<� Z+ed= d �d>d?�Z,e-d �d@dA�Z.� Z/S )F�WebSocketHandlera� Subclass this class to create a basic WebSocket handler. Override `on_message` to handle incoming messages, and use `write_message` to send messages to the client. You can also override `open` and `on_close` to handle opened and closed connections. Custom upgrade response headers can be sent by overriding `~tornado.web.RequestHandler.set_default_headers` or `~tornado.web.RequestHandler.prepare`. See http://dev.w3.org/html5/websockets/ for details on the JavaScript interface. The protocol is specified at http://tools.ietf.org/html/rfc6455. Here is an example WebSocket handler that echos back all received messages back to the client: .. testcode:: class EchoWebSocket(tornado.websocket.WebSocketHandler): def open(self): print("WebSocket opened") def on_message(self, message): self.write_message(u"You said: " + message) def on_close(self): print("WebSocket closed") .. testoutput:: :hide: WebSockets are not standard HTTP connections. The "handshake" is HTTP, but after the handshake, the protocol is message-based. Consequently, most of the Tornado HTTP facilities are not available in handlers of this type. The only communication methods available to you are `write_message()`, `ping()`, and `close()`. Likewise, your request handler class should implement `open()` method rather than ``get()`` or ``post()``. If you map the handler above to ``/websocket`` in your application, you can invoke it in JavaScript with:: var ws = new WebSocket("ws://localhost:8888/websocket"); ws.onopen = function() { ws.send("Hello, world"); }; ws.onmessage = function (evt) { alert(evt.data); }; This script pops up an alert box that says "You said: Hello, world". Web browsers allow any site to open a websocket connection to any other, instead of using the same-origin policy that governs other network access from javascript. This can be surprising and is a potential security hole, so since Tornado 4.0 `WebSocketHandler` requires applications that wish to receive cross-origin websockets to opt in by overriding the `~WebSocketHandler.check_origin` method (see that method's docs for details). Failure to do so is the most likely cause of 403 errors when making a websocket connection. When using a secure websocket connection (``wss://``) with a self-signed certificate, the connection from a browser may fail because it wants to show the "accept this certificate" dialog but has nowhere to show it. You must first visit a regular HTML page using the same certificate to accept it before the websocket connection will succeed. If the application setting ``websocket_ping_interval`` has a non-zero value, a ping will be sent periodically, and the connection will be closed if a response is not received before the ``websocket_ping_timeout``. Messages larger than the ``websocket_max_message_size`` application setting (default 10MiB) will not be accepted. .. versionchanged:: 4.5 Added ``websocket_ping_interval``, ``websocket_ping_timeout``, and ``websocket_max_message_size``. N)� application�request�kwargsr% c s< t t| �j||fi |�� d | _d | _d | _d | _d| _d S �NF)�superrZ rW � ws_connectionr: r; �stream�_on_close_called)r) r[ r\ r] �� __class__r' r* rW � s zWebSocketHandler.__init__��argsr] r% c � sF || _ || _| jj�dd��� dkrJ| �d� d}| �|� t� |� d S | jj}t dd� |�dd�� d ��}d |vr�| �d� d }| �|� t� |� d S d | jjv r�| jj�d �}n| jj�d d �}|d u�r| � |��s| �d� d}| �|� t� |� d S | � � | _| j�r*| j�| �I d H n| �dd� | �dd� d S )N�Upgrade� � websocket� z"Can "Upgrade" only to "WebSocket".c S s | � � �� S r& )�strip�lower)�sr' r' r* �<lambda>� r4 z&WebSocketHandler.get.<locals>.<lambda>� Connection�,�upgradez "Connection" must be "Upgrade".ZOriginzSec-Websocket-Origini� z#Cross origin websockets not allowedi� zUpgrade Required�Sec-WebSocket-Versionz7, 8, 13)� open_args� open_kwargsr\ �headers�getrl � set_status�finishr �debug�map�split� check_origin�get_websocket_protocolr` �accept_connection� set_header)r) rf r] �log_msgru � connection�originr' r' r* rv � s@ � zWebSocketHandler.get�r% c C s | j �dd�S )zpThe interval for websocket keep-alive pings. Set websocket_ping_interval = 0 to disable pings. Zwebsocket_ping_intervalN��settingsrv �r) r' r' r* rR s z WebSocketHandler.ping_intervalc C s | j �dd�S )z�If no ping is received in this many seconds, close the websocket connection (VPNs, etc. can fail to cleanly close ws connections). Default is max of 3 pings or 30 seconds. Zwebsocket_ping_timeoutNr� r� r' r' r* rS % s z WebSocketHandler.ping_timeoutc C s | j �dt�S )z�Maximum allowed message size. If the remote peer sends a message larger than this, the connection will be closed. Default is 10MiB. Zwebsocket_max_message_size)r� rv rX r� r' r' r* rT - s �z!WebSocketHandler.max_message_sizeF� Future[None]�r? �binaryr% c C s@ | j du s| j �� rt� �t|t�r0tj�|�}| j j||d�S )aH Sends the given message to the client of this Web Socket. The message may be either a string or a dict (which will be encoded as json). If the ``binary`` argument is false, the message will be sent as utf8; in binary mode any byte string is allowed. If the connection is already closed, raises `WebSocketClosedError`. Returns a `.Future` which can be used for flow control. .. versionchanged:: 3.2 `WebSocketClosedError` was added (previously a closed connection would raise an `AttributeError`) .. versionchanged:: 4.3 Returns a `.Future` which can be used for flow control. .. versionchanged:: 5.0 Consistently raises `WebSocketClosedError`. Previously could sometimes raise `.StreamClosedError`. N�r� ) r` � is_closingrN � isinstance�dict�tornado�escapeZ json_encode� write_message�r) r? r� r' r' r* r� : s z WebSocketHandler.write_message)� subprotocolsr% c C s dS )a� Override to implement subprotocol negotiation. ``subprotocols`` is a list of strings identifying the subprotocols proposed by the client. This method may be overridden to return one of those strings to select it, or ``None`` to not select a subprotocol. Failure to select a subprotocol does not automatically abort the connection, although clients may close the connection if none of their proposed subprotocols was selected. The list may be empty, in which case this method must return None. This method is always called exactly once even if no subprotocols were proposed so that the handler can be advised of this fact. .. versionchanged:: 5.1 Previously, this method was called with a list containing an empty string instead of an empty list if no subprotocols were proposed by the client. Nr' )r) r� r' r' r* �select_subprotocolX s z#WebSocketHandler.select_subprotocolc C s | j dusJ �| j jS )zYThe subprotocol returned by `select_subprotocol`. .. versionadded:: 5.1 N)r` �selected_subprotocolr� r' r' r* r� q s z%WebSocketHandler.selected_subprotocolc C s dS )a� Override to return compression options for the connection. If this method returns None (the default), compression will be disabled. If it returns a dict (even an empty one), it will be enabled. The contents of the dict may be used to control the following compression options: ``compression_level`` specifies the compression level. ``mem_level`` specifies the amount of memory used for the internal compression state. These parameters are documented in details here: https://docs.python.org/3.6/library/zlib.html#zlib.compressobj .. versionadded:: 4.1 .. versionchanged:: 4.5 Added ``compression_level`` and ``mem_level``. Nr' r� r' r' r* �get_compression_optionsz s z(WebSocketHandler.get_compression_optionsc O s dS )a� Invoked when a new WebSocket is opened. The arguments to `open` are extracted from the `tornado.web.URLSpec` regular expression, just like the arguments to `tornado.web.RequestHandler.get`. `open` may be a coroutine. `on_message` will not be called until `open` has returned. .. versionchanged:: 5.1 ``open`` may be a coroutine. Nr' �r) rf r] r' r' r* �open� s zWebSocketHandler.openr> c C s t �dS )z�Handle incoming messages on the WebSocket This method must be overridden. .. versionchanged:: 4.5 ``on_message`` can be a coroutine. N��NotImplementedErrorr@ r' r' r* rA � s zWebSocketHandler.on_messager4 r# c C s2 t |�}| jdu s | j�� r"t� �| j�|� dS )a� Send ping frame to the remote end. The data argument allows a small amount of data (up to 125 bytes) to be sent as a part of the ping message. Note that not all websocket implementations expose this data to applications. Consider using the ``websocket_ping_interval`` application setting instead of sending pings manually. .. versionchanged:: 5.1 The data argument is now optional. N)r r` r� rN � write_pingr( r' r' r* �ping� s zWebSocketHandler.pingc C s dS )z6Invoked when the response to a ping frame is received.Nr' r( r' r' r* rC � s zWebSocketHandler.on_pongc C s dS )z*Invoked when the a ping frame is received.Nr' r( r' r' r* rB � s zWebSocketHandler.on_pingc C s dS )a` Invoked when the WebSocket is closed. If the connection was closed cleanly and a status code or reason phrase was supplied, these values will be available as the attributes ``self.close_code`` and ``self.close_reason``. .. versionchanged:: 4.0 Added ``close_code`` and ``close_reason`` attributes. Nr' r� r' r' r* �on_close� s zWebSocketHandler.on_close��code�reasonr% c C s | j r| j �||� d| _ dS )aC Closes this Web Socket. Once the close handshake is successful the socket will be closed. ``code`` may be a numeric status code, taken from the values defined in `RFC 6455 section 7.4.1 <https://tools.ietf.org/html/rfc6455#section-7.4.1>`_. ``reason`` may be a textual message about why the connection is closing. These values are made available to the client, but are not otherwise interpreted by the websocket protocol. .. versionchanged:: 4.0 Added the ``code`` and ``reason`` arguments. N)r` �close�r) r� r� r' r' r* r� � s zWebSocketHandler.close)r� r% c C s, t |�}|j}|�� }| jj�d�}||kS )a� Override to enable support for allowing alternate origins. The ``origin`` argument is the value of the ``Origin`` HTTP header, the url responsible for initiating this request. This method is not called for clients that do not send this header; such requests are always allowed (because all browsers that implement WebSockets support this header, and non-browser clients do not have the same cross-site security concerns). Should return ``True`` to accept the request or ``False`` to reject it. By default, rejects all requests with an origin on a host other than this one. This is a security protection against cross site scripting attacks on browsers, since WebSockets are allowed to bypass the usual same-origin policies and don't use CORS headers. .. warning:: This is an important security measure; don't disable it without understanding the security implications. In particular, if your authentication is cookie-based, you must either restrict the origins allowed by ``check_origin()`` or implement your own XSRF-like protection for websocket connections. See `these <https://www.christian-schneider.net/CrossSiteWebSocketHijacking.html>`_ `articles <https://devcenter.heroku.com/articles/websocket-security>`_ for more. To accept all cross-origin traffic (which was the default prior to Tornado 4.0), simply override this method to always return ``True``:: def check_origin(self, origin): return True To allow connections from any subdomain of your site, you might do something like:: def check_origin(self, origin): parsed_origin = urllib.parse.urlparse(origin) return parsed_origin.netloc.endswith(".mydomain.com") .. versionadded:: 4.0 �Host)r �netlocrl r\ ru rv )r) r� Z parsed_origin�hostr' r' r* r| � s /z WebSocketHandler.check_origin�rF r% c C s | j dusJ �| j �|� dS )a1 Set the no-delay flag for this stream. By default, small messages may be delayed and/or combined to minimize the number of packets sent. This can sometimes cause 200-500ms delays due to the interaction between Nagle's algorithm and TCP delayed ACKs. To reduce this delay (at the expense of possibly increasing bandwidth usage), call ``self.set_nodelay(True)`` once the websocket connection is established. See `.BaseIOStream.set_nodelay` for additional details. .. versionadded:: 3.1 N)r` � set_nodelay�r) rF r' r' r* r� # s z WebSocketHandler.set_nodelayc C s6 | j r| j �� d | _ | js2d| _| �� | �� d S )NT)r` �on_connection_closerb r� � _break_cyclesr� r' r' r* r� 4 s z$WebSocketHandler.on_connection_closer9 c C s || _ || _| �� d S r& �r: r; r� r< r' r' r* r= = s z'WebSocketHandler.on_ws_connection_closec s$ | � � dks| jr tt| ��� d S �N�e )Z get_statusrb r_ rZ r� r� rc r' r* r� D s z WebSocketHandler._break_cyclesc s0 | j d u r"tt| �j|i |�� n | j �� d S r& )ra r_ rZ � send_errorr� r� rc r' r* r� M s zWebSocketHandler.send_error�WebSocketProtocolc C s@ | j j�d�}|dv r<t| j| j| j| �� d�}t| d|�S d S )Nrr )�7�8�13rV F) r\ ru rv rQ rR rS rT r� �WebSocketProtocol13)r) Zwebsocket_version�paramsr' r' r* r} W s � z'WebSocketHandler.get_websocket_protocolc C s dD ]}t | |t� q| �� S )N)�write�redirectr � set_cookierw r- rx )�setattr�#_raise_not_supported_for_websockets�detach)r) �methodr' r' r* �_detach_streamc s z WebSocketHandler._detach_stream)F)r4 )NN)NN)0r. r/ r0 rO r� �web� Applicationr ZHTTPServerRequestr rW rv ra �propertyr rY rR rS r2 rT r r1 rJ r �boolr� r r� r� r� r r� rA r� rC rB r� r� r| r� r� r= r� r� r} r r� � __classcell__r' r' rc r* rZ � sT S� 4 �� 8 �� rZ re c O s t d��d S )Nz$Method not supported for Web Sockets)� RuntimeError)rf r] r' r' r* r� r s r� c @ sH e Zd ZdZddd�dd�Zeeedd�d d �Zdd �d d �Zdd �dd�Z e j d+e e dd�dd��Ze j ed �dd��Ze j edd�dd��Ze j d,ee ef edd�dd��Zee j ee d �d d ���Ze j edd �d d ��Ze j ee ef ejdd!�d"d#��Z e j dd �d$d%��Z e j dd �d&d'��Z e j edd(�d)d*��Z dS )-r� z0Base class for WebSocket protocol versions. r8 N��handlerr% c C s || _ d | _d| _d| _d S r^ )r� ra �client_terminated�server_terminated�r) r� r' r' r* rW z s zWebSocketProtocol.__init__zOptional[Future[Any]])�callbackrf r] r% c O s| z||i |��}W n, t y> | jjt�� � | �� Y dS 0 |durtt�|�}| jdus`J �| jj � |dd� � |S dS )z�Runs the given callback with exception handling. If the callback is a coroutine, returns its Future. On error, aborts the websocket connection and returns None. Nc S s | � � S r& )�result��fr' r' r* rn � r4 z1WebSocketProtocol._run_callback.<locals>.<lambda>) � Exceptionr� rI �sys�exc_info�_abortr Zconvert_yieldedra �io_loop� add_future)r) r� rf r] r� r' r' r* � _run_callback� s z WebSocketProtocol._run_callbackr� c C s | � � d S r& )r� r� r' r' r* r� � s z%WebSocketProtocol.on_connection_closec C s, d| _ d| _| jdur | j�� | �� dS )z?Instantly aborts the WebSocket connection by closing the socketTN)r� r� ra r� r� r' r' r* r� � s zWebSocketProtocol._abortr� c C s t � �d S r& r� r� r' r' r* r� � s zWebSocketProtocol.closec C s t � �d S r& r� r� r' r' r* r� � s z WebSocketProtocol.is_closingc � s t � �d S r& r� r� r' r' r* r~ � s z#WebSocketProtocol.accept_connectionFr� r� c C s t � �d S r& r� r� r' r' r* r� � s z WebSocketProtocol.write_messagec C s t � �d S r& r� r� r' r' r* r� � s z&WebSocketProtocol.selected_subprotocolr# c C s t � �d S r& r� r( r' r' r* r� � s z WebSocketProtocol.write_ping��keyru r% c C s t � �d S r& r� )r) r� ru r' r' r* �_process_server_headers� s z)WebSocketProtocol._process_server_headersc C s t � �d S r& r� r� r' r' r* � start_pinging� s z WebSocketProtocol.start_pingingc � s t � �d S r& r� r� r' r' r* �_receive_frame_loop� s z%WebSocketProtocol._receive_frame_loop��xr% c C s t � �d S r& r� �r) r� r' r' r* r� � s z WebSocketProtocol.set_nodelay)NN)F) r. r/ r0 rO rW r r r� r� r� �abc�abstractmethodr2 rJ r� r� r� rZ r~ r r1 r� r� r r� r� r � HTTPHeadersr� r� r� r� r' r' r' r* r� v sD � � ��r� c @ sL e Zd Zd eee eeef dd�dd�Z dd�dd�Z e e d �d d �Z dS ) � _PerMessageDeflateCompressorN)� persistent� max_wbitsrU r% c C s� |d u rt j}d| kr$t jks4n td|t j��|| _|d u sJd|vrXtjjj| _n |d | _|d u srd|vrzd| _ n |d | _ |r�| � � | _ nd | _ d S )N� �.Invalid max_wbits value %r; allowed range 8-%dZcompression_levelZ mem_level) �zlib� MAX_WBITS� ValueError� _max_wbitsr� r� ZGZipContentEncodingZ GZIP_LEVEL�_compression_level� _mem_level�_create_compressor� _compressor)r) r� r� rU r' r' r* rW � s* ��� z%_PerMessageDeflateCompressor.__init__r" r� c C s t �| jt j| j | j�S r& )r� � compressobjr� �DEFLATEDr� r� r� r' r' r* r� � s �z/_PerMessageDeflateCompressor._create_compressorr# c C s> | j p | �� }|�|�|�tj� }|�d�s2J �|d d� S )N� �����)r� r� r+ r- r� � Z_SYNC_FLUSH�endswith)r) r$ Z compressorr' r' r* r+ � s z%_PerMessageDeflateCompressor.compress)N) r. r/ r0 r� r r2 r rJ r rW r� r1 r+ r' r' r' r* r� � s � � #r� c @ sN e Zd Zd eee eeeef dd�dd�Z dd�dd�Z e e d �d d �Z dS ) � _PerMessageDeflateDecompressorN)r� r� rT rU r% c C sZ || _ |d u rtj}d| kr*tjks:n td|tj��|| _|rP| �� | _nd | _d S )Nr� r� )�_max_message_sizer� r� r� r� �_create_decompressor� _decompressor)r) r� r� rT rU r' r' r* rW s ��z'_PerMessageDeflateDecompressor.__init__r3 r� c C s t �| j �S r& )r� � decompressobjr� r� r' r' r* r� s z3_PerMessageDeflateDecompressor._create_decompressorr# c C s0 | j p | �� }|�|d | j�}|jr,t� �|S )Nr� )r� r� r6 r� r7 rP )r) r$ Z decompressorr� r' r' r* r6 s �z)_PerMessageDeflateDecompressor.decompress)N) r. r/ r0 r� r r2 r rJ r rW r� r1 r6 r' r' r' r* r� s � � r� c @ sf e Zd ZdZdZdZdZdZeeB eB ZdZ dZ de e dd �d d �Z eee d �d d��Zejee dd�dd��Zedd�dd�Zedd�dd�Zeeeef ed�dd��Zeed�dd�Zedd�dd �Ze j e e ee eef f d �d d �Z!eeef e j dd �d!d"�Z"dOee ee#f e ee#f e ee#f d#�d$d%�Z$dPee ee#f e ee#f dd#�d&d'�Z%dQe e&ee&d)d*�d+d,�Z'dReeef e d)d.�d/d0�Z(edd1�d2d3�Z)dd �d4d5�Z*e&ed6�d7d8�Z+dd �d9d:�Z,e&ed;d<�d=d>�Z-dSe&edd?�d@dA�Z.e d �dBdC�Z/eee0 d �dDdE��Z1eee0 d �dFdG��Z2dd �dHdI�Z3dd �dJdK�Z4e ddL�dMdN�Z5dS )Tr� z�Implementation of the WebSocket protocol from RFC 6455. This class supports versions 7 and 8 of the protocol in addition to the final version 13. � �@ � � � Nr8 )r� � mask_outgoingr� r% c C s� t �| |� || _|| _d| _d | _d | _d | _d | _d | _ d | _ d | _ |j | _ d | _d | _d | _d| _d| _d| _d| _d | _d| _d| _d | _d | _d S )NFr g )r� rW r� r� Z _final_frameZ _frame_opcodeZ _masked_frame� _frame_mask� _frame_length�_fragmented_message_buffer�_fragmented_message_opcode�_waitingrU �_compression_optionsr� r� �_frame_compressed�_message_bytes_in�_message_bytes_out�_wire_bytes_in�_wire_bytes_out� ping_callback� last_ping� last_pongr: r; )r) r� r� r� r' r' r* rW 9 s0 z WebSocketProtocol13.__init__r� c C s | j S r& �Z_selected_subprotocolr� r' r' r* r� ^ s z(WebSocketProtocol13.selected_subprotocolr� c C s || _ d S r& r r� r' r' r* r� b s r� c � s� z| � |� W n6 tyD |�d� d}|�|� t�|� Y d S 0 z| �|�I d H W nF tjyx | � � Y d S ty� tjddd� | � � Y d S 0 d S )Nrj �!Missing/Invalid WebSocket headersz$Malformed WebSocket request receivedT�r� ) �_handle_websocket_headersr� rw rx r ry �_accept_connection�asyncioZCancelledErrorr� )r) r� r� r' r' r* r~ f s" z%WebSocketProtocol13.accept_connectionc s& d}t t� fdd�|��s"td��dS )z�Verifies all invariant- and required headers If a header is missing or have an incorrect value ValueError will be raised )r� �Sec-Websocket-KeyzSec-Websocket-Versionc s � j j�| �S r& )r\ ru rv r� �r� r' r* rn � r4 z?WebSocketProtocol13._handle_websocket_headers.<locals>.<lambda>r N)�allrz r� )r) r� �fieldsr' r r* r z s z-WebSocketProtocol13._handle_websocket_headers)r� r% c C s2 t �� }|�t| �� |�d� tt�|�� ��S )zoComputes the value for the Sec-WebSocket-Accept header, given the value for Sec-WebSocket-Key. s$ 258EAFA5-E914-47DA-95CA-C5AB0DC85B11)�hashlib�sha1�updater r �base64� b64encode�digest)r� r r' r' r* �compute_accept_value� s z(WebSocketProtocol13.compute_accept_valuec C s t �tt|jj�d���S )Nr )r� r r rJ r\ ru rv r� r' r' r* �_challenge_response� s �z'WebSocketProtocol13._challenge_responsec � s� |j j�d�}|r(dd� |�d�D �}ng }|�|�| _| jrZ| j|v sLJ �|�d| j� | �|j j�}|D ]p}|d dkrl| jd url| � d|d | j� d |d v r�|d d d u r�|d d = |�d t � d|d �� q�ql|� d � |� d � |�d d� |�dd � |�d| �|�� |�� |�� | _| �� z,|j|ji |j��}|d u�r`|I d H W n, t�y� |jt�� � | �� Y d S 0 | �� I d H d S )N�Sec-WebSocket-Protocolc S s g | ] }|� � �qS r' )rk )�.0rm r' r' r* � <listcomp>� r4 z:WebSocketProtocol13._accept_connection.<locals>.<listcomp>rp r �permessage-deflate�server� �client_max_window_bits�Sec-WebSocket-Extensionsz Content-Typer� rg ri ro zSec-WebSocket-Accept) r\ ru rv r{ r� r� r �_parse_extensions_headerr �_create_compressorsr Z_encode_headerZ clear_headerrw r rx r� ra r� r� rs rt r� rI r� r� r� r� )r) r� Zsubprotocol_headerr� � extensions�extZ open_resultr' r' r* r � sN �� � z&WebSocketProtocol13._accept_connection)ru r% c C s( |� dd�}|r$dd� |�d�D �S g S )Nr" rh c S s g | ]}t �|�� ��qS r' )r Z _parse_headerrk )r �er' r' r* r � r4 z@WebSocketProtocol13._parse_extensions_header.<locals>.<listcomp>rp )rv r{ )r) ru r% r' r' r* r# � s z,WebSocketProtocol13._parse_extensions_headerr� c C s� |d � � dksJ �|d � � dks(J �| �|�}|d |ksBJ �| �|�}|D ]6}|d dkr|| jdur|| �d |d � qPtd |��qP|�d d�| _dS ) z�Process the headers sent by the server to this client connection. 'key' is the websocket handshake challenge/response key. rg ri ro rq zSec-Websocket-Acceptr r N�clientr zunsupported extension %rr )rl r r# r r$ r� rv r� )r) r� ru �acceptr% r& r' r' r* r� � s z+WebSocketProtocol13._process_server_headers)�side�agreed_parametersrU r% c C sN t |d |vd�}|�|d d�}|du r6tj|d< n t|�|d< ||d< |S )zlConverts a websocket agreed_parameters set to keyword arguments for our compressor objects. Z_no_context_takeover)r� Z_max_window_bitsNr� rU )r� rv r� r� r2 )r) r* r+ rU �optionsZ wbits_headerr' r' r* �_get_compressor_options� s � z+WebSocketProtocol13._get_compressor_optionsc C sz t g d��}|D ]}||vrtd| ��q|dkr6dnd}tf i | �|||���| _tf d| jji| �|||���| _d S )N)Zserver_no_context_takeoverZclient_no_context_takeoverZserver_max_window_bitsr! z$unsupported compression parameter %rr r( rT ) �setr� r� r- r� r� r� rT r� )r) r* r+ rU Z allowed_keysr� Z other_sider' r' r* r$ � s" � ����z'WebSocketProtocol13._create_compressorsr r� )�fin�opcoder$ �flagsr% c C s� t |�}|d@ r,|s td��|dkr,td��|r8| j}nd}t�d||B |B �}| jr\d}nd}|dk r~|t�d||B �7 }n6|d kr�|t�d d|B |�7 }n|t�d d |B |�7 }| jr�t�d �} | t| |� }||7 }| j t |�7 _ | j � |�S )Nr� z$control frames may not be fragmented�} z/control frame payloads may not exceed 125 bytesr �Br� �~ i�� z!BHz!BQ� � ) �lenr� �FIN�struct�packr� �os�urandomr r ra r� ) r) r/ r0 r$ r1 Zdata_lenZfinbit�frameZmask_bit�maskr' r' r* � _write_frame s0 z WebSocketProtocol13._write_frameFr� c s� |r d}nd}t j�|�}t|t�s(J �| jt|�7 _d}| jrZ| j�|�}|| j O }z| j d|||d�� W n t y� t � �Y n0 dd�� fdd � }t �|� �S ) z9Sends the given message to the client of this Web Socket.� r r T)r1 Nr� c � s, z� I d H W n t y& t� �Y n0 d S r& )r rN r' �Zfutr' r* �wrapperN s z2WebSocketProtocol13.write_message.<locals>.wrapper)r� r� r r� r1 r r7 r� r+ �RSV1r? r rN r � ensure_future)r) r? r� r0 r1 rB r' rA r* r� 5 s z!WebSocketProtocol13.write_messager# c C s t |t�sJ �| �dd|� dS )zSend ping frame.T� N)r� r1 r? r( r' r' r* r� V s z WebSocketProtocol13.write_pingc � sL z| j s| �� I d H qW n ty4 | �� Y n0 | j�| j| j� d S r& )r� �_receive_framer r� r� r= r: r; r� r' r' r* r� [ s z'WebSocketProtocol13._receive_frame_loop)�nr% c � s$ | j �|�I d H }| j|7 _|S r& )ra � read_bytesr )r) rG r$ r' r' r* � _read_bytesc s z WebSocketProtocol13._read_bytesc � sZ | � d�I d H }t�d|�\}}|| j@ }|| j@ }|| j@ }|d@ }| jd urt|dkrtt|| j@ �| _ || j M }|r�| � � d S t|d@ �}|d@ } |r�| dkr�| � � d S | dk r�| | _ nT| dkr�| � d�I d H }t�d|�d } n*| dk�r| � d�I d H }t�d |�d } | } | j d u�r2| t | j �7 } | | jjk�rX| �d d � | � � d S |�rp| � d �I d H | _| � | �I d H }|�r�| jd u�s�J �t| j|�}|�r�|�s0| � � d S nt|dk�r| j d u �r�| � � d S | j |7 _ |�r0| j}| j }d | _ n*| j d u�r | � � d S |�s0|| _|| _ |�rV| �||�} | d u�rV| I d H d S ) Nr@ �BBr� r r� r5 r4 z!Hz!Q�� zmessage too bigr6 )rI r9 �unpackr8 �RSV_MASK� OPCODE_MASKr� r� rC r r� r� r� r7 r� rT r� r� r r� �_handle_message) r) r$ �headerZmask_payloadlenZis_final_frameZ reserved_bitsr0 Zopcode_is_controlZ is_maskedZ payloadlenZnew_lenZhandled_futurer' r' r* rF h sz z"WebSocketProtocol13._receive_framezOptional[Future[None]])r0 r$ r% c C s� | j r dS | jrX| jdus J �z| j�|�}W n( tyV | �dd� | �� Y dS 0 |dkr�| jt|�7 _z|� d�}W n t y� | �� Y dS 0 | � | j j |�S |dkr�| jt|�7 _| � | j j |�S |dk�r>d| _ t|�dk�rt�d |dd� �d | _t|�dk�r0t|dd� �| _| �| j� n||d k�r�z| �dd |� W n t�yv | �� Y n0 | � | j j|� n0|d k�r�t�� �� | _| � | j j|�S | �� dS ) z>Execute on_message, returning its Future if it is a coroutine.NrK z#message too big after decompressionr zutf-8r@ r� T�>Hr rE � )r� r r� r6 rP r� r� r r7 �decode�UnicodeDecodeErrorr� r� rA r9 rL r: r r; r? r rB r �current�timer rC )r) r0 r$ �decodedr' r' r* rO � sN z#WebSocketProtocol13._handle_messager� c C s� | j s�| j�� s�|du r$|dur$d}|du r2d}n t�d|�}|durR|t|�7 }z| �dd|� W n ty~ | �� Y n0 d| _ | j r�| j dur�| jj � | j � d| _ | j� � n*| j du r�| jj �| jj �� d | j�| _ dS )z Closes the WebSocket connection.N�� r4 rQ Tr� � )r� ra �closedr9 r: r r? r r� r� r� r� �remove_timeoutr� Z add_timeoutrV )r) r� r� Z close_datar' r' r* r� � s. �zWebSocketProtocol13.closec C s | j �� p| jp| jS )z�Return ``True`` if this connection is closing. The connection is considered closing if either side has initiated its closing handshake or if the stream has been shut down uncleanly. )ra rZ r� r� r� r' r' r* r� s z WebSocketProtocol13.is_closingc C s | j j}|d ur|S dS )Nr )r� rR )r) �intervalr' r' r* rR s z!WebSocketProtocol13.ping_intervalc C s2 | j j}|d ur|S | jd us"J �td| j d�S )N� � )r� rS rR �max)r) �timeoutr' r' r* rS s z WebSocketProtocol13.ping_timeoutc C sN | j dusJ �| j dkrJt�� �� | _| _t| j| j d �| _| j� � dS )z9Start sending periodic pings to keep the connection aliveNr rX ) rR r rU rV r r r � periodic_pingr �startr� r' r' r* r� # s �z!WebSocketProtocol13.start_pingingc C s� | � � r | jdur | j�� dS t�� �� }|| j }|| j }| jdusNJ �| j dus\J �|d| j k r�|| j kr�| � � dS | � d� || _dS )z�Send a ping to keep the websocket alive Called periodically if the websocket_ping_interval is set and non-zero. Nr@ r4 ) r� r �stopr rU rV r r rR rS r� r� )r) �nowZsince_last_pongZsince_last_pingr' r' r* ra - s �� z!WebSocketProtocol13.periodic_pingr� c C s | j �|� d S r& )ra r� r� r' r' r* r� H s z WebSocketProtocol13.set_nodelay)N)N)r )F)NN)6r. r/ r0 rO r8 rC ZRSV2ZRSV3rM rN ra r� rQ rW r� r rJ r� �setterrZ r~ r � staticmethodr r1 r r r r r� r r r r# r� r r- r$ r2 r? r� r� r� rI rF rO r� r� rY rR rS r� ra r� r' r' r' r* r� ( s� � % 4� � � � � � �� " � � !S3 r� c s� e Zd ZdZdZddddeg fejee de e f gdf e e e f eeeeee dd�� fdd� Zd3ee dd�dd�Zdd �� fd d � Zd4ee dd �d d�Zejdd�dd�Ze ejejf ejdd�� fdd� Z d5e e e f e dd�dd�Z d6edgdf e e de e f d�d d �Z e e e f ee d d �d d �Z!e de e f ee d d �d!d"�Z"d7e dd$�d%d&�Z#e dd$�d'd(�Z$e dd$�d)d*�Z%e&d �d+d,�Z'e(ee d �d-d.��Z)d/ee* ee+ dd0�d1d2�Z,� Z-S )8�WebSocketClientConnectionz�WebSocket client connection. This class should not be instantiated directly; use the `websocket_connect` function instead. N)r\ �on_message_callbackrU rR rS rT r� r% c s� t � | _td�| _t�t�d��| _|| _ d | _ d | _ t ||||d�| _ |j�d�\}} } ddd�| }|| | |_|j�dd | jd d �� |d ur�d �|�|jd < |d ur�d|jd< t� | _tt| ��d |dd� | jd| jdd� d S )Nr r� rV �:�http�https)�ws�wssri rg r� )rg ro zSec-WebSocket-Keyrr rp r z*permessage-deflate; client_max_window_bitsr" c S s d S r& r' r' r' r' r* rn � r4 z4WebSocketClientConnection.__init__.<locals>.<lambda>i @i )r �connect_futurer � read_queuer r r; r< r� �_on_message_callbackr: r; rQ r� �url� partitionru r �joinr � tcp_clientr_ rg rW �_on_http_response) r) r\ rh rU rR rS rT r� �scheme�sep�restrc r' r* rW U sP ����� �z"WebSocketClientConnection.__init__r� c C s" | j dur | j �||� d| _ dS )z�Closes the websocket connection. ``code`` and ``reason`` are documented under `WebSocketHandler.close`. .. versionadded:: 3.2 .. versionchanged:: 4.0 Added the ``code`` and ``reason`` arguments. N)�protocolr� r� r' r' r* r� � s z WebSocketClientConnection.closer� c s> | j �� s| j �t� � | �d � | j�� tt| �� � d S r& ) rn �done� set_exceptionr � _on_messagert r� r_ rg r� r� rc r' r* r� � s z-WebSocketClientConnection.on_connection_closer9 c C s || _ || _| �� d S r& r� r< r' r' r* r= � s z0WebSocketClientConnection.on_ws_connection_close)�responser% c C s4 | j �� s0|jr | j �|j� n| j �td�� d S )NzNon-websocket response)rn rz �errorr{ rL )r) r} r' r' r* ru � s �z+WebSocketClientConnection._on_http_response)� start_lineru r% c � s� t |tj�sJ �|jdkr6tt| ��||�I d H d S | jd urT| j� | j� d | _|| _ | � � | _ | j � | j| j � | j�� | j _t�� �| j j� | j �� d | _t| j| � d S r� )r� r �ResponseStartLiner� r_ rg �headers_received�_timeoutr� r[ ru r} ry r� r� r� r� ra r rU Z add_callbackr� r� Zfinal_callbackr rn )r) r ru rc r' r* r� � s" � z*WebSocketClientConnection.headers_receivedFr� r� c C s | j j||d�S )aJ Sends a message to the WebSocket server. If the stream is closed, raises `WebSocketClosedError`. Returns a `.Future` which can be used for flow control. .. versionchanged:: 5.0 Exception raised on a closed stream changed from `.StreamClosedError` to `WebSocketClosedError`. r� )ry r� r� r' r' r* r� � s z'WebSocketClientConnection.write_messagez Future[Union[None, str, bytes]])r� r% c C s* | j �� }|dur&| j�t�|�|� |S )ax Reads a message from the WebSocket server. If on_message_callback was specified at WebSocket initialization, this function will never return messages Returns a future whose result is the message, or None if the connection is closed. If a callback argument is given it will be called with the future when it is ready. N)ro rv r� r� r rD )r) r� Z awaitabler' r' r* � read_message� s z&WebSocketClientConnection.read_messager> c C s | � |�S r& )r| r@ r' r' r* rA � s z$WebSocketClientConnection.on_messagec C s$ | j r| � |� d S | j�|�S d S r& )rp ro �putr@ r' r' r* r| � s z%WebSocketClientConnection._on_messager4 r# c C s( t |�}| jdu rt� �| j�|� dS )a� Send ping frame to the remote end. The data argument allows a small amount of data (up to 125 bytes) to be sent as a part of the ping message. Note that not all websocket implementations expose this data to applications. Consider using the ``ping_interval`` argument to `websocket_connect` instead of sending pings manually. .. versionadded:: 5.1 N)r ry rN r� r( r' r' r* r� s z WebSocketClientConnection.pingc C s d S r& r' r( r' r' r* rC s z!WebSocketClientConnection.on_pongc C s d S r& r' r( r' r' r* rB s z!WebSocketClientConnection.on_pingc C s t | d| jd�S )NT)r� r� )r� r� r� r' r' r* r} s z0WebSocketClientConnection.get_websocket_protocolc C s | j jS )zOThe subprotocol selected by the server. .. versionadded:: 5.1 )ry r� r� r' r' r* r� s z.WebSocketClientConnection.selected_subprotocolz Optional[Type[BaseException]]rD c C s2 |d us J �|d usJ �t jd||||fd� d S )NzUncaught exception %sr )r r~ rH r' r' r* rI ' s z'WebSocketClientConnection.log_exception)NN)NN)F)N)r4 ).r. r/ r0 rO ry rX r � HTTPRequestr r rJ r1 r r rY r2 r r rW r� r� r= � HTTPResponseru r ZRequestStartLiner� r� r� r� r� r r� rA r| r� rC rB r� r} r� r� rK r rI r� r' r' rc r* rg L sn � �: �� �! � � � � � �rg z!Future[WebSocketClientConnection]z$Awaitable[WebSocketClientConnection]) rq r� �connect_timeoutrh rU rR rS rT r� r% c C s� t | tj�r,|du sJ �| } t�| j�| _ntj| |d�} ttjt�| tjj��} t | ||||||d�} |dur�t � � � | j |� | j S )a Client-side websocket support. Takes a url and returns a Future whose result is a `WebSocketClientConnection`. ``compression_options`` is interpreted in the same way as the return value of `.WebSocketHandler.get_compression_options`. The connection supports two styles of operation. In the coroutine style, the application typically calls `~.WebSocketClientConnection.read_message` in a loop:: conn = yield websocket_connect(url) while True: msg = yield conn.read_message() if msg is None: break # Do something with msg In the callback style, pass an ``on_message_callback`` to ``websocket_connect``. In both styles, a message of ``None`` indicates that the connection has been closed. ``subprotocols`` may be a list of strings specifying proposed subprotocols. The selected protocol may be found on the ``selected_subprotocol`` attribute of the connection object when the connection is complete. .. versionchanged:: 3.2 Also accepts ``HTTPRequest`` objects in place of urls. .. versionchanged:: 4.1 Added ``compression_options`` and ``on_message_callback``. .. versionchanged:: 4.5 Added the ``ping_interval``, ``ping_timeout``, and ``max_message_size`` arguments, which have the same meaning as in `WebSocketHandler`. .. versionchanged:: 5.0 The ``io_loop`` argument (deprecated since version 4.1) has been removed. .. versionchanged:: 5.1 Added the ``subprotocols`` argument. N)r� )rh rU rR rS rT r� )r� r r� r r� ru r Z _RequestProxyZ _DEFAULTSrg r rU r� rn ) rq r� r� rh rU rR rS rT r� r\ �connr' r' r* �websocket_connect2 s* 6 �� r� )RrO r� r r r r; r� r9 Ztornado.escaper� Z tornado.web� urllib.parser r� Ztornado.concurrentr r r r r r r r Ztornado.ioloopr r Ztornado.iostreamr r Z tornado.logr r r Ztornado.queuesr Ztornado.tcpclientr Z tornado.utilr �typingr r r r r r r r r r r �typesr �typing_extensionsr! r" r3 r8 rX r� rL rN rP �objectrQ r� ZRequestHandlerrZ r� �ABCr� r� r� r� �_HTTPConnectionrg rJ r� rY r1 r2 r� r' r' r' r* �<module> s� 4 m\0& ( i� �
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка