Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/prompt_toolkit/contrib/ssh/__pycache__/server.cpython-39.pyc
Ðазад
a d�h� � @ s� d Z ddlmZ ddlZddlZddlmZ ddlmZmZm Z m Z m Z ddl Z ddl mZmZ ddlmZ ddlmZmZ dd lmZ d d gZG d d � d e j�ZG d d � d e j�ZdS )zI Utility for running a prompt_toolkit application in an asyncssh server. � )� annotationsN)�get_running_loop)�Any�Callable� Coroutine�TextIO�cast)� AppSession�create_app_session)�Size)� PipeInput�create_pipe_input)� Vt100_Output�PromptToolkitSSHSession�PromptToolkitSSHServerc @ s� e Zd Zdddd�dd�Zdd�d d �Zd dd �d d�Zdd�dd�Zdd�dd�Zdd�dd�Zdddddd�dd�Z dddd�d d �Z d S ) r �>Callable[[PromptToolkitSSHSession], Coroutine[Any, Any, None]]�bool�None��interact� enable_cpr�returnc sN |� _ |� _d � _d � _d � _d � _d � _G � fdd�d�}tt|� �� _ d S )Nc sR e Zd Zddd�� fdd� Zdd�dd �Zdd�d d �Zedd�� fd d � �ZdS )z0PromptToolkitSSHSession.__init__.<locals>.Stdout�strr )�datar c s: z"� j d ur � j �|�dd�� W n ty4 Y n0 d S )N� z )�_chan�write�replace�BrokenPipeError)�sr ��self� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/prompt_toolkit/contrib/ssh/server.pyr , s z6PromptToolkitSSHSession.__init__.<locals>.Stdout.writer �r c S s dS �NTr" �r r" r" r# �isatty3 s z7PromptToolkitSSHSession.__init__.<locals>.Stdout.isattyc S s d S �Nr" r& r" r" r# �flush6 s z6PromptToolkitSSHSession.__init__.<locals>.Stdout.flushc s" � j d usJ �t� j j�� d �S )Nr )r r Z _orig_chanZ get_encodingr& r r" r# �encoding9 s z9PromptToolkitSSHSession.__init__.<locals>.Stdout.encodingN)�__name__� __module__� __qualname__r r' r) �propertyr* r" r r" r# �Stdout+ s r/ ) r r � interact_taskr � app_session�_input�_outputr r �stdout)r! r r r/ r" r r# �__init__ s z PromptToolkitSSHSession.__init__r r$ c C s8 | j du rtddd�S | j �� \}}}}t||d�S dS )zU Callable that returns the current `Size`, required by Vt100_Output. N� �O )�rows�columns)r r �get_terminal_size�r! �width�height�pixwidth� pixheightr" r" r# � _get_size@ s z!PromptToolkitSSHSession._get_sizer )�chanr c C s || _ d S r( )r )r! rA r" r" r# �connection_madeJ s z'PromptToolkitSSHSession.connection_madec C s dS r% r" r r" r" r# �shell_requestedM s z'PromptToolkitSSHSession.shell_requestedc C s t � �| �� �| _d S r( )r Z create_task� _interactr0 r r" r" r# �session_startedP s z'PromptToolkitSSHSession.session_startedc � s | j d u rtd��t| j d�r6| j jd ur6| j �d� | j �� }t| j| j|| j d�| _ t � ��| _ t | j | j d��v}|| _zHz| �| �I d H W n ty� t�� Y n0 W | j �� | j �� n| j �� | j �� 0 W d � n1 s�0 Y W d � n1 �s0 Y d S )Nz,`_interact` called before `connection_made`.� set_line_modeF)�termr )�input�output)r � Exception�hasattrZ_editorrF Zget_terminal_typer r4 r@ r r3 r r2 r r1 r � BaseException� traceback� print_exc�close)r! rG �sessionr" r" r# rD S s& � � z!PromptToolkitSSHSession._interact�int�object)r< r= r> r? r c C s | j r| j jr| j j�� d S r( )r1 ZappZ _on_resizer; r" r" r# �terminal_size_changedo s z-PromptToolkitSSHSession.terminal_size_changedr )r �datatyper c C s | j d u rd S | j �|� d S r( )r2 Z send_text)r! r rT r" r" r# � data_receivedv s z%PromptToolkitSSHSession.data_receivedN) r+ r, r- r5 r@ rB rC rE rD rS rU r" r" r" r# r s ) c @ sF e Zd ZdZdd�dddd�dd �Zd dd �d d �Zdd�dd�ZdS )r aZ Run a prompt_toolkit application over an asyncssh server. This takes one argument, an `interact` function, which is called for each connection. This should be an asynchronous function that runs the prompt_toolkit applications. This function runs in an `AppSession`, which means that we can have multiple UI interactions concurrently. Example usage: .. code:: python async def interact(ssh_session: PromptToolkitSSHSession) -> None: await yes_no_dialog("my title", "my text").run_async() prompt_session = PromptSession() text = await prompt_session.prompt_async("Type something: ") print_formatted_text('You said: ', text) server = PromptToolkitSSHServer(interact=interact) loop = get_running_loop() loop.run_until_complete( asyncssh.create_server( lambda: MySSHServer(interact), "", port, server_host_keys=["/etc/ssh/..."], ) ) loop.run_forever() :param enable_cpr: When `True`, the default, try to detect whether the SSH client runs in a terminal that responds to "cursor position requests". That way, we can properly determine how much space there is available for the UI (especially for drop down menus) to render. T�r r r r r c C s || _ || _d S r( )r r )r! r r r" r" r# r5 � s z PromptToolkitSSHServer.__init__r )�usernamer c C s dS )NFr" )r! rW r" r" r# � begin_auth� s z!PromptToolkitSSHServer.begin_authr r$ c C s t | j| jd�S )NrV )r r r r r" r" r# �session_requested� s z(PromptToolkitSSHServer.session_requestedN)r+ r, r- �__doc__r5 rX rY r" r" r" r# r ~ s )� ) rZ � __future__r �asynciorM r �typingr r r r r ZasyncsshZ"prompt_toolkit.application.currentr r Z prompt_toolkit.data_structuresr Zprompt_toolkit.inputr r Zprompt_toolkit.output.vt100r �__all__ZSSHServerSessionr Z SSHServerr r" r" r" r# �<module> s h
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка