/usr/lib/python3/dist-packages/twisted/conch/scripts/__pycache__
Edit: /usr/lib/python3/dist-packages/twisted/conch/scripts/__pycache__/conch.cpython-310.pyc (17071B)
o
bG @ s d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZm Z d dl
m Z m Z d dl
mZ d dlmZ d dlmZmZmZmZmZ d dlmZmZmZ d dlm Z m Z d d l m Z m Z G d
d d eZ!da"da#d a$da%d a&da'd d
Z(dd Z)dd Z*dd Z+dd Z,dd Z-dd Z.dd Z/d d Z0G d d d Z1G d d! d!ej2Z2G d"d# d#ej3Z4G d$d% d%ej5Z5G d&d' d'ej6Z6d(d) Z7d*d+ Z8e9d,kre( dS dS )- N)ListTuple)connectdefault) ConchOptions)
ConchError)channelcommon
connection
forwardingsession)reactorstdiotask)logusage)ioType
networkStringc @ s e Zd ZU dZdZg dg dg dgZg dg dg dg d g d
g d gZejd gej d
dej d
dde
ej ddej dddgdZ g Z e
eeeeef f ed< g Ze
eeeeef f ed< dd Zdd Zdd Zd d Zd S )
ClientOptionsz(Usage: conch [options] host [command]
zYconch is a SSHv2 client that allows logging into a remote machine and executing commands.)escapee~) localforwardLNz
opt_localforward] z ClientOptions.opt_localforwardc C r@ )zH
Forward remote port to local address (rport:host:port)
rA N)rB rC r0 rD )r; r rG connHostconnPortr= r= r> opt_remoteforwardf rI z ClientOptions.opt_remoteforwardc G s || d< d || d< d S )Nhost r) )join)r; rM r) r= r= r> parseArgso s zClientOptions.parseArgsN)__name__
__module__ __qualname__synopsislongdesc
optParametersoptFlagsr Completions CompleterCompleteUserAtHostcompDatar/ r r rC __annotations__r0 r? rH rL rP r= r= r= r> r s>
r c C s t jdd } d| v r#| d}| ||d | } | |d |d = | d d D ],}z!| |}|d d dkrK| |d d dkrKg | ||d < W q) tyU Y q)w t azt| W n# tjy } zt d| t
t d W Y d }~nd }~ww td rtd
rtd
dkrt j }n t
td
d }nt j}t j }t| |t _ nt t t j }zt|aW n ty d aY nw z ttjd d
}W n ty d }Y nw z0t W trt |tj t |rttj| td rtd s td sttj tj n.tr t |tj t |r)ttj| td r3td s8td sAttj tj w w t j ! rVtd sVt d"td t t# d S )Nr4 z-lr3 z-or -zERROR: r logfileza+c W s t dtS Nr )r
callLater reConnect)ar= r= r> s zrun..r) r r" zConnection to {} closed.rM )$r9 argvindex
ValueErrorr options parseOptionsr
UsageErrorprintopt_helpr: stdoutopenstderrr startLogging discardLogs doConnectstdinfilenor tcgetattrold
BaseExceptionsignalSIGUSR1r
run tcsetattrTCSANOWSIGWINCHSIG_DFLisattyformat
exitStatus)argsiargur realoutfdoldUSR1r= r= r> rz } s
$
rz c C s, ddl m} datdt t| )Nr failurer3 g{Gz?) twisted.pythonr r r
ra _stopReactorr errFailurer r= r= r> handleError s
r c C s$ zt W d S ty Y d S w N)r
stoprw r= r= r= r> r s
r c C s dt d v rt d dd\t d< t d< t js ddgt _t d } t d s*t t d< t d s3dt d< ntt d t d< t d } t d }tj}t d sRt| t t d < t t d t t
}t | |t || t
d S )
N@rM r4 userz
~/.ssh/id_rsaz
~/.ssh/id_dsaport zhost-key-algorithms)rh rB identitysgetpassgetuserrC r
verifyHostKeygetHostKeyAlgorithmsSSHUserAuthClient
SSHConnectionr
addErrback_ebExit)rM r vhkuaor= r= r> rr s"
rr c C s d| a tdt d S )Nzconch: exiting with error 皙?)r r
ra r )r r= r= r> r s
r c C s. t tjdr
tt tjr&tjD ]\} }t| t t|t
}tj | qtj rItj D ]\}}t
d| d| t|| q,tddt td rQtd rWtt td rt rdtd t td
D ](}zt| W ql ty } zd d l}|j|j kr W Y d }~qld }~ww d S d S ) N
sendIgnorez!asking for remote forwarding for rA beforeshutdownr$ agentr r ) hasattrconn transport
_KeepAliverh r/ r
listenTCPr SSHListenForwardingFactory SSHListenClientForwardingChannelrD r0 r msgrequestRemoteForwardingaddSystemEventTriggerbeforeShutdown openChannel
SSHSessionosr _exitsetsidrangecloseOSErrorerrnoEBADF)rE hostportr' rG r r r r= r= r> onConnect sD
r c C s t tjj d S r )r r r loseConnectionr= r= r= r> rb s rb c C s8 t j} | D ]\}}td| d| t| qd S )Nz cancelling rA )rh r0 r r r cancelRemoteForwarding)r0 rG r r= r= r> r s
r c C s t d s tdt d S d S )N reconnectr )rh r
ra r r= r= r= r> stopConnection s r c @ s, e Zd Zdd Zdd Zdd Zdd Zd S )
r c C s* || _ d | _t| j| _| jd d S )Ni, )r
globalTimeoutr LoopingCall
sendGloballcstart)r; r r= r= r> __init__ s z_KeepAlive.__init__c C s2 | j jdddd}|| j td| j| _d S )Ns" conch-keep-alive@twistedmatrix.com r4 wantReply )r sendGlobalRequestaddBoth _cbGlobalr
ra _ebGlobalr )r; dr= r= r> r ! s
z_KeepAlive.sendGlobalc C s | j r
| j d | _ d S d S r )r cancel)r; resr= r= r> r ( s
z_KeepAlive._cbGlobalc C s | j rd | _ | jj d S d S r )r r r r r; r= r= r> r - s z_KeepAlive._ebGlobalN)rQ rR rS r r r r r= r= r= r> r s
r c @ sL e Zd Zdd Zdd Zdd Zdd Zd d
Zd d Zd
d Z dd Z
dS )r c C s | a g | _i | _t d S r )r r/ r0 r r r= r= r> serviceStarted4 s
z SSHConnection.serviceStartedc C s( | j }g | _ |D ]}| qt d S r )r/ r r )r; lfr' r= r= r> serviceStopped; s
z SSHConnection.serviceStoppedc C sX t d|f}| jd|dd}td| d| || j|| || j|| d S )N0.0.0.0s
tcpip-forwardr4 r z requesting remote forwarding rA ) r packGlobal_tcpip_forwardr r r addCallback_cbRemoteForwardingr _ebRemoteForwarding)r; rG r datar r= r= r> r B s
z%SSHConnection.requestRemoteForwardingc C s4 t d| d| || j|< t t| j d S )Nzaccepted remote forwarding rA )r r r0 repr)r; resultrG r r= r= r> r I s
z!SSHConnection._cbRemoteForwardingc C s& t d| d| d t | d S )Nzremote forwarding rA z failedr r )r; r rG r r= r= r> r N s z!SSHConnection._ebRemoteForwardingc C s^ t d|f}| d| td| z| j|= W n ty$ Y nw tt| j d S )Nr s cancel-tcpip-forwardz cancelling remote forwarding )r r r r r r0 Exceptionr )r; rG r r= r= r> r R s z$SSHConnection.cancelRemoteForwardingc C s| t d| t|\}}t | j t | |d | jv r8| j|d }t d| t|||| dS ttjd)NzFTCP r4 zconnect forwarding ) remoteWindowremoteMaxPacketr zdon't know about that port) r r r unpackOpen_forwarded_tcpipr0 SSHConnectForwardingChannelr r
OPEN_CONNECT_FAILED)r;
windowSize maxPacketr remoteHPorigHP connectHPr= r= r> channel_forwarded_tcpip\ s
z%SSHConnection.channel_forwarded_tcpipc C sV t d| t | j t| jdkr t d t d S | jjd | | d S )Nzconnection closing r4 zstopping connectionr )r r channelsr6 r __class__ __bases__
channelClosed)r; r r= r= r> r l s
zSSHConnection.channelClosedN) rQ rR rS r r r r r r r r r= r= r= r> r 3 s
r c @ sp e Zd ZdZdd Zdd Zdd Zdd Zd
d Zd d
Z dd Z
dd Z dd Z dd Z
dd Zdd ZdS )r s sessionc s t d j d td r jj dddd}|dd td
r%d S td r-td s1td
s4t t }td rHtd
sHd _
j |_ n j
|_ fdd |_t| _d}td rn j dttd d S td rtd rtjd }t|tjd}td|}t||d} j d| t t j j j dttd d S td
stjd }t|tjd}td|}t||d} j d| t t j j j dd d S )Nzsession z openr s auth-agent-req@openssh.comr r4 r c S s
t | S r r xr= r= r> rd s
z(SSHSession.channelOpen..r$ r) r r" r c s S r )sendEOFr r r= r> rd s r r& s subsystemTERM123456784H s pty-reqs execs shell) r r idrh r sendRequestr
_enterRawModer SSHSessionClient
escapeMode handleInput dataReceivedwriteconnectionLostr
StandardIOr NSr environfcntlioctlr
TIOCGWINSZstructunpackpackRequest_pty_reqrx r} _windowResized) r; foor cr termwinszwinSize
ptyReqDatar= r r> channelOpen{ sJ
zSSHSession.channelOpenc C s& |dv rd| _ | | d S | j dkr |td kr d| _ d S | j dkrd| _ |dkr4td t d S |dkrDdd }td
| d S |d krUtd | jj
d S |d
kr| j d | jj
}| |D ]}| j td|| jj | qkd S | d| d S d
| _ | | d S )N)
r4 r r3 .zdisconnecting from escape c S s6 t tj tj tt tj t
d S r )
_leaveRawModer9 rm flushrs r killgetpidrx SIGTSTPr r= r= r= r> _ s
z!SSHSession.handleInput.._r Rzrekeying connection #s'
The following connections are open:
z
#{} {}
~)r r rh r r r r
ra r r sendKexInitr r keyssortr r )r; charr r channelIdr= r= r> r sF
zSSHSession.handleInputc C s | j | d S r )r r r; r r= r= r> r zSSHSession.dataReceivedc C sT |t jkr(tdt| d ttjtkr tjj
| d S tj
| d S d S )Nzgot z stderr data) r
EXTENDED_DATA_STDERRr r r6 r r9 ro strbufferr )r; r! r r= r= r> extReceived s
zSSHSession.extReceivedc C s t d | j d S )Nzgot eof)r r r loseWriteConnectionr r= r= r> eofReceived s
zSSHSession.eofReceivedc C s t d| | j| d S )Nzremote side closed )r r r sendCloser r= r= r>
closeReceived s zSSHSession.closeReceivedc C s& t d| t t| jj d S )Nzclosed )r r r r r r r= r= r> closed s zSSHSession.closedc C s( t td|d atdt d S )Nz>Lr z
exit status: )rC r r r r r r# r= r= r> request_exit_status s z SSHSession.request_exit_statusc C s | j | d S r )r r r r= r= r> r r$ zSSHSession.sendEOFc C | j d S r )r pauseProducingr r= r= r> stopWriting zSSHSession.stopWritingc C r/ r )r resumeProducingr r= r= r> startWriting r2 zSSHSession.startWritingc G sZ t dtjd}td|}|d |d |d |d f}| j| dtjdg|R d S ) Nr r r r4 r3 r s
window-changez!4L) r r r r r r r r pack)r; r r
r newSizer= r= r> r s "zSSHSession._windowResizedN)rQ rR rS namer r r r( r* r, r- r. r r1 r4 r r= r= r= r> r w s +- r c @ e Zd ZdS )r NrQ rR rS r= r= r= r> r r c @ r8 )r Nr9 r= r= r= r> r r: r c C s* t sd S tj } t| tjt da d S r` )
_inRawModer9 rs rt r r{ r|
_savedRawMode)r r= r= r> r s
r c C sV t rd S tj } z
t| }|d d }W n ty% td Y d S w |d tj B |d< |d tj
tj B tj B tj
B tjB tjB tjB @ |d< ttdrZ|d tj @ |d< |d tjtjB tjB tjB tjB tjB tjB @ |d< ttdr|d tj @ |d< |d tj @ |d< d|d tj< d|d tj < |a t | tj | da d S )Nznot a typewriter!r IUCLCr IEXTENr4 ) r; r9 rs rt r ru rw r r IGNPARISTRIPINLCRIGNCRICRNLIXONIXANYIXOFFr r= ISIGICANONECHOECHOEECHOKECHONLr> OPOSTVMINVTIMEr< r{ r| )r rv newr= r= r> r sd
r __main__):r r r rx r r9 r typingr r twisted.conch.clientr r twisted.conch.client.optionsr twisted.conch.errorr twisted.conch.sshr r r
r r twisted.internetr
r r r r r twisted.python.compatr r r rh r r rv r; r< rz r r rr r r rb r r r r
SSHChannelr r r r r rQ r= r= r= r> sT W<
$D
2