File: //usr/local/CyberCP/lib/python3.10/site-packages/websockets/__pycache__/cli.cpython-310.pyc
o
�h� � @ s� d dl mZ d dlZd dlZd dlZd dlZd dlmZ ddlm Z m
Z
ddl m Z ddl
mZ ddlmZ dd lmZ dd
lmZ d gZd$dd�Zd$dd�ZG dd� dej�Zd%dd�Zd&d d �Zd'd d �Z d(d)d#d �Z dS )*� )� annotationsN)� Generator� )�ClientConnection�connect)� SimpleQueue)�ConnectionClosed)�Close)� StreamReader)�version�main�string�str�return�Nonec C �" t j�d| � d�� t j�� d S )Nz 7
[A[Lz
8[B��sys�stdout�write�flush�r
� r �A/usr/local/CyberCP/lib/python3.10/site-packages/websockets/cli.py�print_during_input s ��r c C r )Nz
[K�
r r r r r �print_over_input( s ��r c @ sH e Zd Zddd�Zddd�Zdd
d �Zddd�Zddd�Zddd�ZdS ) � ReadLinesr r c C s t � | _t� | _d S �N)r
�readerr �messages��selfr r r �__init__5 s zReadLines.__init__�Generator[None, None, None]c c sF � t j�d� t j�� | j�t j�E d H }| j�|� � �
d�� q)NTz> z
) r r r r r � read_line�maxsizer �put�decode�rstrip)r" �liner r r �parse9 s �
�zReadLines.parse� transport�asyncio.BaseTransportc C s | � � | _t| j� d S r )r+ �parser�next)r" r, r r r �connection_made@ �
zReadLines.connection_made�data�bytesc C s | j �|� t| j� d S r )r � feed_datar/ r. )r" r2 r r r �
data_receivedD s zReadLines.data_receivedc C s | j �� d S r )r �feed_eofr! r r r � eof_receivedH s zReadLines.eof_received�exc�Exception | Nonec C s | j �� | j�� d S r )r �discardr �abort)r" r8 r r r �connection_lostL r1 zReadLines.connection_lostN)r r )r r$ )r, r- r r )r2 r3 r r )r8 r9 r r ) �__name__�
__module__� __qualname__r# r+ r0 r5 r7 r< r r r r r 4 s
r � websocketr c � sB �| 2 z3 d H W }t |t�rtd| � qtd|�� � q6 d S )Nz< z < (binary) )�
isinstancer r �hex)r@ �messager r r �print_incoming_messagesQ s �
�rD r �SimpleQueue[str]c � sX � z |� � I d H }W n
ty Y d S w z
| �|�I d H W n
ty* Y d S w qr )�get�EOFError�sendr )r@ r rC r r r �send_outgoing_messagesY s � � ��rI �uric
� s^ �z t | �I d H }W n" ty, } ztd| � d|� d�� t�d� W Y d }~n
d }~ww td| � d�� t�� }|�ttj �I d H \}}t�
t |��}t�
t ||j
��}z(ztj||gtjd�I d H W n
tjyo Y nw W |�� |�� |�� n
|�� |�� |�� w |�� I d H |jd ur�|jd us�J �t|j|j�}td|� d�� d S )NzFailed to connect to z: �.r z
Connected to )� return_whenzConnection closed: )r � Exception�printr �exit�asyncio�get_running_loop�connect_read_piper �stdin� create_taskrD rI r �wait�FIRST_COMPLETED�CancelledError�cancel�close�
close_code� close_reasonr r ) rJ r@ r8 �loopr, �protocol�incoming�outgoing� close_statusr r r �interactive_clienth sH ����
��
��
�
ra �argv�list[str] | Nonec C s� t jdddd�}|�� }|jddd� |jdd d
d � |�| �}|jr,td t� �� d S |jd u r:|� � t
� d
� t
j dkrDt
�d� zdd l}W n tyS Y nw z t�t|j�� W d S tyi Y d S w )N�
websocketsz Interactive WebSocket client.F)�prog� description�add_helpz --version�
store_true)�actionrJ z<uri>�?)�metavar�nargsz websockets � �win32� r )�argparse�ArgumentParser� add_mutually_exclusive_group� add_argument�
parse_argsr rN �websockets_versionrJ � print_usager rO �platform�os�system�readline� ImportErrorrP �runra �KeyboardInterrupt)rb r. �group�argsrz r r r r � s6 �
� �)r
r r r )r@ r r r )r@ r r rE r r )rJ r r r r )rb rc r r ) �
__future__r rp rP rx r �typingr �asyncio.clientr r �asyncio.messagesr �
exceptionsr �framesr �streamsr
r ru �__all__r r �Protocolr rD rI ra r r r r r �<module> s(
)