Server : Apache/2.4.52 (Ubuntu) System : Linux webserver 6.8.0-49-generic #49~22.04.1-Ubuntu SMP PREEMPT_DYNAMIC Wed Nov 6 17:42:15 UTC 2 x86_64 User : www-data ( 33) PHP Version : 8.1.2-1ubuntu2.21 Disable Function : NONE Directory : /lib/python3/dist-packages/twisted/conch/ssh/__pycache__/ |
o
�b�5 � @ s" d Z ddlZddlZddlZddlZddlmZ ddlmZm Z m
Z
ddl m Z m
Z
mZ ddlmZmZ ddlmZ ddlmZ e� ZG d d
� d
e j�ZG d d � d ej�ZG d
d� d�Zdd� Z dd� Z g d�Z eej �G dd� dej��Z G dd� dej!�Z"dd� Z#dd� Z$d d � Z%d d � Z&dS ) z�
This module contains the implementation of SSHSession, which (by default)
allows access to a shell and a python interpreter over SSH.
Maintainer: Paul Swartz
� N)� implementer)� EnvironmentVariableNotPermitted�ISession�ISessionSetEnv)�channel�common�
connection)�
interfaces�protocol)�Logger)�
networkStringc @ st e Zd ZdZdZdd� Zdd� Zdd� Zd d
� Zd d � Z d
d� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� ZdS ) �
SSHSessiona�
A generalized implementation of an SSH session.
See RFC 4254, section 6.
The precise implementation of the various operations that the remote end
can send is left up to the avatar, usually via an adapter to an
interface such as L{ISession}.
@ivar buf: a buffer for data received before making a connection to a
client.
@type buf: L{bytes}
@ivar client: a protocol for communication with a shell, an application
program, or a subsystem (see RFC 4254, section 6.5).
@type client: L{SSHSessionProcessProtocol}
@ivar session: an object providing concrete implementations of session
operations.
@type session: L{ISession}
s sessionc O s0 t jj| g|�R i |�� d| _d | _d | _d S �N� )r �
SSHChannel�__init__�buf�client�session)�self�args�kw� r �;/usr/lib/python3/dist-packages/twisted/conch/ssh/session.pyr 8 s
zSSHSession.__init__c C sn t �|�\}}tjd|d� | j�||�}|r0t| �}t|�}|�|� |�t |�� || _
dS t� d� dS )Nz"Asking for subsystem "{subsystem}")� subsystem� zFailed to get subsystemr ) r �getNS�log�info�avatar�lookupSubsystem�SSHSessionProcessProtocol�wrapProcessProtocol�makeConnection� wrapProtocolr �error)r �datar �ignoredr �pp�protor r r �request_subsystem> s
z SSHSession.request_subsystemc C s^ t �d� | jst| j�| _z t| �}| j�|� W n ty) t �d� Y dS w || _ dS )Nz
Getting shellzError getting shellr r )
r r r r r r! � openShell� Exception�failurer )r r& r( r r r �
request_shellM s
�zSSHSession.request_shellc C sv | j s t| j�| _ t�|�\}}tjd|d� z
t| �}| j �||� W n t y5 tj
d|d� Y dS w || _ dS )NzExecuting command "{f}")�fz Error executing command "{f}"r r ) r r r r r r r r! � execCommandr, r- r )r r& r/ r( r r r � request_exec[ s �zSSHSession.request_execc C sf | j s t| j�| _ t|�\}}}tjd||d� z | j �|||� W dS ty2 t�d� Y dS w )Nz-Handling pty request: {term!r} {windowSize!r})�term�
windowSizezError handling pty requestr r ) r r r �parseRequest_pty_reqr r �getPtyr, r- )r r& r2 r3 �modesr r r �request_pty_reqj s � �
�zSSHSession.request_pty_reqc C s� | j s t| j�| _ t�| j �stjd| j| j d� dS t�|d�\}}}z
| j � ||� W dS t
y8 Y dS t yH tj d|d� Y dS w )ag
Process a request to pass an environment variable.
@param data: The environment variable name and value, each encoded
as an SSH protocol string and concatenated.
@type data: L{bytes}
@return: A true value if the request to pass this environment
variable was accepted, otherwise a false value.
z�Can't handle environment variables for SSH avatar {avatar}: {session} does not provide ISessionSetEnv interface. It should be decorated with @implementer(ISession, ISessionSetEnv) to support env variables.)r r r � z)Error setting environment variable {name})�namer )
r r r r �
providedByr �warnr r �setEnvr r, r- )r r& r9 �valuer r r � request_env{ s&
� � �zSSHSession.request_envc C sL | j s t| j�| _ t|�}z | j �|� W dS ty% t�d� Y dS w )NzError changing window sizer r )r r r �parseRequest_window_change�
windowChangedr, r r- )r r& �winSizer r r �request_window_change� s �
�z SSHSession.request_window_changec C s* | j s | j|7 _d S | j j�|� d S �N)r r � transport�write�r r& r r r � dataReceived� s zSSHSession.dataReceivedc C sJ |t jkr | jrt| jjd�r| jj�|� d S d S d S tjd|d� d S )N�writeErrz Weird extended data: {dataType})�dataType)r �EXTENDED_DATA_STDERRr �hasattrrD rH r r; )r rI r& r r r � extReceived� s
�zSSHSession.extReceivedc C s. | j r
| j �� d S | jr| j�| � d S d S rC )r � eofReceivedr �conn� sendClose�r r r r rM � �
�zSSHSession.eofReceivedc C s. | j r
| j �� d S | jr| jj�� d S d S rC )r �closedr rD �loseConnectionrP r r r rR � rQ zSSHSession.closedc C s" | j r | j j�� tj�| � d S rC )r rD rS r r rP r r r rS � s zSSHSession.loseConnectionN)�__name__�
__module__� __qualname__�__doc__r9 r r* r. r1 r7 r> rB rG rL rM rR rS r r r r r
! s ! r
c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
S ) �_ProtocolWrapperzS
This class wraps a L{Protocol} instance in a L{ProcessProtocol} instance.
c C �
|| _ d S rC �r) �r r) r r r r � �
z_ProtocolWrapper.__init__c C � | j �� d S rC )r) �connectionMaderP r r r r^ � � z _ProtocolWrapper.connectionMadec C � | j �|� d S rC �r) rG rF r r r � outReceived� � z _ProtocolWrapper.outReceivedc C r` rC )r) �connectionLost�r �reasonr r r � processEnded� rc z _ProtocolWrapper.processEndedN)rT rU rV rW r r^ rb rg r r r r rX � s rX c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) �_DummyTransportc C rY rC rZ r[ r r r r � r\ z_DummyTransport.__init__c C s | j j�|� d S rC )r) rD rE rF r r r rG � � z _DummyTransport.dataReceivedc C r` rC ra rF r r r rE � rc z_DummyTransport.writec C s | � d�|�� d S r )rE �join�r �seqr r r �
writeSequence� � z _DummyTransport.writeSequencec C s | j �tj� d S rC )r) rd r
�connectionDonerP r r r rS � ri z _DummyTransport.loseConnectionN)rT rU rV r rG rE rm rS r r r r rh � s rh c C s t | tj�r
t| �S | S rC )�
isinstancer
�ProtocolrX )�instr r r r" � s r" c C s t | �S rC )rh rZ r r r r$ � s r$ )
�ABRT�ALRM�FPE�HUP�ILL�INT�KILL�PIPE�QUIT�SEGV�TERM�USR1�USR2c @ s� e Zd ZdZdZdd� Zdd� Zdd� Zd d
� Zd d � Z d
d� Z
d dd�Z dd� Z d dd�Z
dd� Zdd� Zdd� Zdd � Zd d � ZdS ) r! z�I am both an L{IProcessProtocol} and an L{ITransport}.
I am a transport to the remote endpoint and a process protocol to the
local subsystem.
Nc C s || _ d| _d S )NF)r �lostOutOrErrFlag)r r r r r r s
z"SSHSessionProcessProtocol.__init__c C s( | j jr| j�| j j� d | j _d S d S rC )r r rD rE rP r r r r^ s �z(SSHSessionProcessProtocol.connectionMadec C r` rC �r rE rF r r r rb ! rc z%SSHSessionProcessProtocol.outReceivedc C s | j �tj|� d S rC )r �
writeExtendedr rJ )r �errr r r � errReceived$ rn z%SSHSessionProcessProtocol.errReceivedc C s$ | j r
| jj�| j� dS d| _ dS )zW
EOF should only be sent when both STDOUT and STDERR have been closed.
TN)r� r rN �sendEOFrP r r r �outConnectionLost' s
z+SSHSessionProcessProtocol.outConnectionLostc C s | � � dS )z*
See outConnectionLost().
N)r� rP r r r �errConnectionLost0 s z+SSHSessionProcessProtocol.errConnectionLostc C r] rC �r rS re r r r rd 6 r_ z(SSHSessionProcessProtocol.connectionLostc C s� | j du rCi | _ tD ]}d| }tt|d�}|dur || j |< q
tj�� D ] \}}|�d�rB|�d�sB|| j vrB|d tj | j |< q%| j | S )z:
Get a signal name given a signal number.
N�SIG�SIG_�@) �_signalValuesToNames�SUPPORTED_SIGNALS�getattr�signal�__dict__�items�
startswith�sys�platform)r �signum�signame�sigvalue�k�vr r r �_getSignalName9 s
�
�
z(SSHSessionProcessProtocol._getSignalNamec
C s� |durs|j }|jdurW| �|j�}ttdd�dur*t�|j�r*tjd|d� d}n tjd|d� d}| j j
� | j dt �
t|d d� ��|rHd
nd t �
d � t �
d � � n |jdurstjd
|jd� | j j
� | j dt�d|j�� | j �� dS )z�
When we are told the process ended, try to notify the other side about
how the process ended using the exit-signal or exit-status requests.
Also, close the channel.
N� WCOREDUMPz#exitSignal: {signame} (core dumped))r� TzexitSignal: {}Fs exit-signal� � � r zexitCode: {exitCode!r})�exitCodes exit-status�>L)r= r� r� r� �osr� �statusr r r rN � sendRequestr �NSr r� �struct�packrS )r rf r� r� �
coreDumpedr r r rg M s8
�
����
�z&SSHSessionProcessProtocol.processEndedc C � | j jj�� S )z>
Return the host from my session's transport.
)r rN rD �getHostrP r r r r� n � z!SSHSessionProcessProtocol.getHostc C r� )z>
Return the peer from my session's transport.
)r rN rD �getPeerrP r r r r� t r� z!SSHSessionProcessProtocol.getPeerc C r` rC r� rF r r r rE z rc z SSHSessionProcessProtocol.writec C s | j �d�|�� d S r )r rE rj rk r r r rm } s z'SSHSessionProcessProtocol.writeSequencec C r] rC r� rP r r r rS � r_ z(SSHSessionProcessProtocol.loseConnectionrC )rT rU rV rW r� r r^ rb r� r� r� rd r� rg r� r� rE rm rS r r r r r! s"
! r! c @ s e Zd Zdd� ZdS )�SSHSessionClientc C s | j r | j �|� d S d S rC )rD rE rF r r r rG � s �z SSHSessionClient.dataReceivedN)rT rU rV rG r r r r r� � s r� c sx t �| �\}}t�d|dd� �\}}}}t �|dd� �\� }||||f}� fdd�tdt� �d d�D �� ||� fS ) z�Parse the data from a pty-req request into usable data.
@returns: a tuple of (terminal type, (rows, cols, xpixel, ypixel), modes)
�>4LN� c
s@ g | ] }t � ||d � �t�d� |d |d � �d f�qS )r r� � r )�ordr� �unpack)�.0�i�r6 r r �
<listcomp>� s 2��z(parseRequest_pty_req.<locals>.<listcomp>r r r� )r r r� r� �range�len) r& r2 �rest�cols�rows�xpixel�ypixelr' rA r r� r r4 � s
�
r4 c
C s> |\}}}}t �| �}t�d||||�}t �|�} || | S )z�
Pack a pty-req request so that it is suitable for sending.
NOTE: modes must be packed before being sent here.
@type geometry: L{tuple}
@param geometry: A tuple of (rows, columns, xpixel, ypixel)
r� )r r� r� r� )
r2 �geometryr6 r� r� r� r� �
termPacked�
winSizePacked� modesPackedr r r �packRequest_pty_req� s
r� c C s t �d| �\}}}}||||fS )zzParse the data from a window-change request into usuable data.
@returns: a tuple of (rows, cols, xpixel, ypixel)
r� )r� r� )r& r� r� r� r� r r r r? � s r? c C s | \}}}}t �d||||�S )z�
Pack a window-change request so that it is suitable for sending.
@type geometry: L{tuple}
@param geometry: A tuple of (rows, columns, xpixel, ypixel)
r� )r� r� )r� r� r� r� r� r r r �packRequest_window_change� s r� )'rW r� r� r� r� �zope.interfacer �twisted.conch.interfacesr r r �twisted.conch.sshr r r �twisted.internetr r
�twisted.loggerr �twisted.python.compatr r r r
�ProcessProtocolrX rh r" r$ r� �
ITransportr! rq r� r4 r� r? r� r r r r �<module> s4 +w