Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/prompt_toolkit/contrib/telnet/__pycache__/server.cpython-39.pyc
Ðазад
a d�h�4 � @ sl d Z ddlmZ ddlZddlZddlZddlmZ ddlmZm Z m Z m Z m Z ddl mZmZ ddlmZ ddlmZ dd lmZmZ dd lmZmZ dd lmZ dd l m Z dd l m Z m Z ddl!m"Z" ddl#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0 dgZ1ddd�dd�Z2ddd�dd�Z3G d d � d �Z4G d d � d �Z5d dd�d d!�Z6G d"d� d�Z7dS )#z Telnet server. � )� annotationsN)�get_running_loop)�Any�Callable� Coroutine�TextIO�cast)�create_app_session�get_app)�run_in_terminal)�Size)�AnyFormattedText�to_formatted_text)� PipeInput�create_pipe_input)� Vt100_Output)�print_formatted_text)� BaseStyle� DummyStyle� )�logger) �DO�ECHO�IAC�LINEMODE�MODE�NAWS�SB�SE�SEND�SUPPRESS_GO_AHEAD�TTYPE�WILL�TelnetProtocolParser� TelnetServer�int�bytes)�number�returnc C s t | f�S �N)r& )r' � r* ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/prompt_toolkit/contrib/telnet/server.py�int2byte, s r, � socket.socket�None)� connectionr( c C s� t �d� | �tt t � | �tt t � | �tt t t t d� t t � | �tt t � | �tt t � | �tt t � | �tt t t t t � d S )Nz Initializing telnet connectionr )r �info�sendr r r r" r r r r, r r r r! r �r/ r* r* r+ �_initialize_telnet0 s &r3 c @ s� e Zd ZdZdddd�dd�Zddd�d d �Zd d �d d�Zdd �dd�Zdd �dd�Ze dd �dd��Z e dd �dd��Z dS )�_ConnectionStdoutzk Wrapper around socket which provides `write` and `flush` methods for the Vt100_Output output. r- �strr. )r/ �encodingr( c C s" || _ || _d| _g | _d| _d S )N�strictF)� _encoding� _connection�_errors�_buffer�_closed)�selfr/ r6 r* r* r+ �__init__S s z_ConnectionStdout.__init__��datar( c C s2 |� dd�}| j�|j| j| jd�� | �� d S )N� z )�errors)�replacer; �append�encoder8 r: �flush�r= r@ r* r* r+ �writeZ s z_ConnectionStdout.write�bool�r( c C s dS �NTr* �r= r* r* r+ �isatty_ s z_ConnectionStdout.isattyc C s^ z | j s | j�d�| j�� W n4 tyR } z t�d|� �� W Y d }~n d }~0 0 g | _d S )N� z Couldn't send data over socket: )r< r9 r1 �joinr; �OSErrorr �warning)r= �er* r* r+ rF b s &z_ConnectionStdout.flushc C s d| _ d S rK )r< rL r* r* r+ �closek s z_ConnectionStdout.closec C s | j S r) )r8 rL r* r* r+ r6 n s z_ConnectionStdout.encodingc C s | j S r) )r: rL r* r* r+ rB r s z_ConnectionStdout.errorsN) �__name__� __module__� __qualname__�__doc__r> rH rM rF rS �propertyr6 rB r* r* r* r+ r4 M s r4 c @ s� e Zd ZdZd%ddddddd d d d � d d�Zd d�dd�Zdd d�dd�Zd d�dd�Zdd d�dd�Zdd d�d d �Z d d d �d d!�Z d d�d"d#�Z d$S )&�TelnetConnectionz6 Class that represents one Telnet connection. Tr- ztuple[str, int]�7Callable[[TelnetConnection], Coroutine[Any, Any, None]]r$ r5 �BaseStyle | Noner rI r. ) �conn�addr�interact�serverr6 �style� vt100_input� enable_cprr( c s� |�_ |�_|�_|�_|�_|�_d�_t�� �_ |�_ � �_ d �_ t ddd��_t|� dd��fdd� �ttt||d ���_d d d ��fd d� } ddd d��fdd� } dd d�� ��fdd� } t| | | ��_d �_d S )NF�( �O ��rows�columnsr rJ c s � j S r) )�sizer* rL r* r+ �get_size� s z+TelnetConnection.__init__.<locals>.get_size)r6 r& r. r? c s � j �| � dS )z-TelnetProtocolParser 'data_received' callbackN)ra Z send_bytes�r@ rL r* r+ � data_received� s z0TelnetConnection.__init__.<locals>.data_receivedr% )rf rg r( c s2 t | |d�� _� jdur.� jr.� j�dd� � dS )z-TelnetProtocolParser 'size_received' callbackre Nc S s t � �� S r) )r Z _on_resizer* r* r* r+ �<lambda>� rN zBTelnetConnection.__init__.<locals>.size_received.<locals>.<lambda>)r rh � vt100_output�context�runre rL r* r+ � size_received� s z0TelnetConnection.__init__.<locals>.size_receivedr5 )�ttyper( c s" t �j�| � d��_�j�� dS )z.TelnetProtocolParser 'ttype_received' callback)�termrb N)r �stdoutrm �_ready�set)rq �rb ri r= r* r+ �ttype_received� s �z1TelnetConnection.__init__.<locals>.ttype_received)r\ r] r^ r_ r6 r` r< �asyncio�Eventrt ra rb rm r rh r3 r r r4 rs r# �parserrn ) r= r\ r] r^ r_ r6 r` ra rb rk rp rw r* rv r+ r> | s( zTelnetConnection.__init__rJ c � s� dd�� fdd� }t � }|�� j|� zf� j�� I dH t� j� jd��* t� � � _ � � � �I dH W d � n1 sx0 Y W � � � n � � � 0 dS )z" Run application. r. rJ c s: � j �d�} | r � �| � nt�dj� j� � � �� d S )Ni z&Connection closed by client. {!r} {!r})r\ �recv�feedr r0 �formatr] rS rj rL r* r+ �handle_incoming_data� s z>TelnetConnection.run_application.<locals>.handle_incoming_dataN)�input�output) r � add_readerr\ rt �waitr ra rm � contextvarsZ copy_contextrn r^ rS )r= r~ �loopr* rL r+ �run_application� s 0z TelnetConnection.run_applicationr& r? c C s | j �|� dS )zF Handler for incoming data. (Called by TelnetServer.) N)rz r| rG r* r* r+ r| � s zTelnetConnection.feedc C s< | j s8d| _ | j�� t� �| j� | j�� | j�� dS )z# Closed by client. TN)r< ra rS r � remove_readerr\ rs rL r* r* r+ rS � s zTelnetConnection.closer )�formatted_textr( c C s0 | j du rdS t|�}t| j || jp(t� � dS )z* Send text to the client. N)rm r r r` r �r= r� r* r* r+ r1 � s �zTelnetConnection.sendc s t � �� ��� �fdd��S )z\ Send text to the client. This is asynchronous, returns a `Future`. c s �� � �S r) )r1 r* �r� r= r* r+ rl � rN z4TelnetConnection.send_above_prompt.<locals>.<lambda>)r �_run_in_terminalr� r* r� r+ �send_above_prompt� s z"TelnetConnection.send_above_promptzCallable[[], None])�funcr( c C s" | j r| j �t|� ntd��d S )Nz2Called _run_in_terminal outside `run_application`.)rn ro r � RuntimeError)r= r� r* r* r+ r� � s z!TelnetConnection._run_in_terminalc C s4 | j du rdS | j �� | j �dd� | j �� dS )zB Erase the screen and move the cursor to the top. Nr )rm � erase_screenZ cursor_gotorF rL r* r* r+ r� � s z TelnetConnection.erase_screenN)T) rT rU rV rW r> r� r| rS r1 r� r� r� r* r* r* r+ rY w s � 7 rY c � s d S r) r* r2 r* r* r+ �_dummy_interact s r� c @ s� e Zd ZdZddedddfddd dd d d d �dd�Zedddd�dd��Zd dd d�dd�Zd d�dd�Z d d�dd �Z dd d �d d �Z dS )!r$ a� Telnet server implementation. Example:: async def interact(connection): connection.send("Welcome") session = PromptSession() result = await session.prompt_async(message="Say something: ") connection.send(f"You said: {result} ") async def main(): server = TelnetServer(interact=interact, port=2323) await server.run() z 127.0.0.1� zutf-8NTr5 r% rZ r[ rI r. )�host�portr^ r6 r` rb r( c C s< || _ || _|| _|| _|| _|| _d | _g | _t� | _ d S r) ) r� r� r^ r6 r` rb � _run_task�_application_tasksru � connections)r= r� r� r^ r6 r` rb r* r* r+ r> s zTelnetServer.__init__r- )r� r� r( c C s> t � t jt j�}|�t jt jd� |�||f� |�d� |S )Nr � )�socket�AF_INET� SOCK_STREAM� setsockopt� SOL_SOCKET� SO_REUSEADDR�bind�listen)�clsr� r� �sr* r* r+ �_create_socket2 s zTelnetServer._create_socketzCallable[[], None] | None)�ready_cbr( c � s� � � � j� j��t�d� j� j� t� ��� �fdd�� |rD|� zbt�� I dH W t� � �� �� � � j D ] }|� � qpt � j �dkr�tj� j dtjd�I dH nRt� � �� �� � � j D ] }|� � q�t � j �dkr�tj� j dtjd�I dH 0 dS )z� Run the telnet server, until this gets cancelled. :param ready_cb: Callback that will be called at the point that we're actually listening. z.Listening for telnet connections on %s port %rc s � � ��S r) )�_acceptr* �r= r� r* r+ rl H rN z"TelnetServer.run.<locals>.<lambda>Nr )�timeoutZ return_when)r� r� r� r r0 r r� rx �Futurer� rS r� �cancel�lenr� Z ALL_COMPLETED)r= r� �tr* r� r+ ro < s: � �� �zTelnetServer.runrJ c C s$ | j durdS t� �| �� �| _ dS )z} Deprecated: Use `.run()` instead. Start the telnet server (stop by calling and awaiting `stop()`). N)r� r � create_taskro rL r* r* r+ �startc s zTelnetServer.startc � s> | j dur:| j �� z| j I dH W n tjy8 Y n0 dS )z� Deprecated: Use `.run()` instead. Stop a telnet server that was started using `.start()` and wait for the cancellation to complete. N)r� r� rx ZCancelledErrorrL r* r* r+ �stopo s zTelnetServer.stop)� listen_socketr( c sT |� � \�� tjdg� �R � dd�� ���fdd� }t� �|� ���j��� dS )z1 Accept new incoming connection. zNew connection %r %rr. rJ c � sb �zLz�t � ��} t�� �j��j�j| �jd�}�j�|� tj dg� �R � z0|� � I d H W �j� |� tj dg� �R � n �j� |� tj dg� �R � 0 W d � n1 s�0 Y W n� t y� t� d� Y nf t y� t� d� Y nL t�y> } z2tdt|�j� �|� dd l}|�� W Y d }~n d }~0 0 W �j� �� n�j� �� 0 d S )N)r6 r` ra rb zStarting interaction %r %rzStopping interaction %r %rz)Unhandled EOFError in telnet application.z2Unhandled KeyboardInterrupt in telnet application.zGot r )r rY r^ r6 r` rb r� �addr r0 r� �remove�EOFError�KeyboardInterrupt� BaseException�print�typerT � traceback� print_excr� )ra r/ rR r� �r] r\ r= �taskr* r+ ro � s: � � 6 z!TelnetServer._accept.<locals>.runN)�acceptr r0 r r� r� rD )r= r� ro r* r� r+ r� } s &zTelnetServer._accept)N) rT rU rV rW r� r> � classmethodr� ro r� r� r� r* r* r* r+ r$ s � ' )8rW � __future__r rx r� r� r �typingr r r r r Z"prompt_toolkit.application.currentr r Z*prompt_toolkit.application.run_in_terminalr Z prompt_toolkit.data_structuresr Z prompt_toolkit.formatted_textr r Zprompt_toolkit.inputr r Zprompt_toolkit.output.vt100r Zprompt_toolkit.rendererr Zprompt_toolkit.stylesr r �logr �protocolr r r r r r r r r r r! r" r# �__all__r, r3 r4 rY r� r$ r* r* r* r+ �<module> s2 <� *
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка