/usr/lib/python3/dist-packages/twisted/conch/scripts/__pycache__
Edit: /usr/lib/python3/dist-packages/twisted/conch/scripts/__pycache__/cftp.cpython-310.pyc (29757B)
o
¯b•z ã @ sz d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl
Z
ddl m Z m
Z
mZ ddlmZmZmZ ddlmZmZmZmZ ddlmZmZmZm Z ddl m Z ddl m Z m!Z!m"Z" dd l#m$Z$ G d
d „ d ej%ƒZ&d d
„ Z'dd„ Z(dd„ Z)dd„ Z*dd„ Z+G dd„ dƒZ,G dd„ de j-ƒZ.e/e.de.j0ƒ G dd „ d ej1ƒZ1G d d „ d ej2ƒZ3e4d kr»e'ƒ dS dS ) z0
Implementation module for the I{cftp} command.
é N)ÚListÚOptionalÚUnion)ÚconnectÚdefaultÚoptions)ÚchannelÚcommonÚ
connectionÚ filetransfer)ÚdeferÚreactorÚstdioÚutils)Úbasic)ÚfailureÚlogÚusage)ÚFilePathc @ sz e Zd ZU dZdZg d¢g d¢g d¢g d¢gZeeeee e
f e d< e j
dd ie ¡ e jd
d gd Zddd„Zd
S )Ú
ClientOptionszˆUsage: cftp [options] [user@]host
cftp [options] [user@]host[:dir[/]]
cftp [options] [user@]host[:file [localfile]]
zncftp is a client for logging into a remote machine and executing commands to send and receive file information)Ú
buffersizeÚBi € z0Size of the buffer to use for sending/receiving.)Ú batchfileÚbNz-File to read commands from, or '-' for stdin.)ÚrequestsÚRé z6Number of requests to make before waiting for a reply.)Ú subsystemÚsÚsftpz'Subsystem/server program to connect to.Ú
optParametersr z,Size of send/receive buffer (default: 32768)z
local file)Údescr)Ú descriptionsÚ extraActionsNc C sF d| d< d|v r| dd¡\}| d< | d d¡ || d< || d< d S )NÚ Ú
remotePathú:é ú/ÚhostÚ localPath)ÚsplitÚrstrip)Úselfr) r* © r. ú )Ú
exitStatusr
ÚstopÚ
BaseExceptionr Úerrr ÚFailurer. r. r. r/ Ú handleErrorU s ÿrV c C s¶ d| d v r| d dd¡\| d< | d< | d }| d s"t ¡ | d< | d s+d| d< nt| d ƒ| d< | d }| d }tƒ }| |_tj}t | d | |¡}t ||| ||¡
t ¡ d S )Nú@r) r' ÚuserÚporté ) r+ ÚgetpassÚgetuserr8 Ú
SSHConnectionr r Ú
verifyHostKeyÚSSHUserAuthClientr Ú
addErrbackÚ_ebExit)r r) rY ÚconnÚvhkÚuaor. r. r/ rK ` s
rK c C sJ t | jdƒr | jj}nt| ƒ}t|ƒ zt ¡ W d S ty$ Y d S w )NÚvalue)Úhasattrre r7 rE r
rR rS )Úfr r. r. r/ ra s s
ÿra c G s d S r1 r. )rM r. r. r/ Ú_ignore ó rh c @ s e Zd Zdd„ Zdd„ ZdS )Ú FileWrapperc C s& || _ d| _| dd¡ | ¡ | _d S )Nç r r> )rg ÚtotalÚseekÚtellÚsize©r- rg r. r. r/ Ú__init__„ s zFileWrapper.__init__c C s t | j|ƒS r1 )Úgetattrrg )r- Úattrr. r. r/ Ú __getattr__Š s zFileWrapper.__getattr__N)r2 r3 r4 rq rt r. r. r. r/ rj ƒ s rj c @ sþ e Zd ZeZdZdZeZd{dd„Zdd„ Z dd „ Z
d
d „ Z d d
„ Z dd„ Z
dd„ Zdd„ Zdd„ Zdd„ Zdd„ Zdd„ Zd d „ Zd d „ Zd d!„ Zd"d#„ Zd|d$d%„Zd&d'„ Zd(d)„ Zd*d+„ Zd,d-„ Z d.d/„ Z d0d1„ Z d2d3„ Z d4d5„ Z d6d7„ Z!d8d9„ Z"d:d;„ Z#d
dqdr„ Z?dsdt„ Z@dudv„ ZAdwdx„ ZBdydz„ ZCdS )~Ú StdioClientzcftp> ó
Nc C s& || _ d| _|| _| rdpd| _d S )Nr$ r' r )ÚclientÚcurrentDirectoryÚfileÚuseProgressBar)r- rw rg r. r. r/ rq — s zStdioClient.__init__c C s | j d¡ | j¡ d S )Nr$ )rw ÚrealPathÚ addCallbackÚ _cbSetCurDir©r- r. r. r/ ÚconnectionMade s zStdioClient.connectionMadec C s || _ | ¡ d S r1 )rx Ú_newLine©r- Úpathr. r. r/ r} s zStdioClient._cbSetCurDirc C s t |tƒr
| d¡}| j |¡S )Núutf-8)Ú
isinstancer7 ÚencodeÚ transportÚwrite)r- Úmsgr. r. r/ Ú_writeToTransport¤ s
z StdioClient._writeToTransportc C s¤ | j jjrd S t|tƒr| d¡}t d| ¡ | ¡ }|s$| ¡ d S | j
r6| d¡r6d| _ |dd … }nd| _ |
|¡}|d urP| | j¡ | | j¡ d S d S )Nrƒ z got line %sú-r' r )rw r† Ú localClosedr„ ÚbytesÚdecoder rˆ Úlstripr€ ry Ú
startswithÚ ignoreErrorsÚ_dispatchCommandr| Ú
_cbCommandr` Ú
_ebCommand)r- ÚlineÚdr. r. r/ Ú lineReceived© s$
þzStdioClient.lineReceivedc C s¸ d|v r| dd¡\}}| ¡ }n|d}}| d¡r+| j}|dd … d | ¡ }n| ¡ }t d| ¡ t| d| d ƒ}|d urHt
||¡S d| }| t
t|ƒ¡¡ | ¡ d S )Nú r' r$ ú!zlooking up cmd %szcmd_%szNo command called `%s')r+ rŽ r Úcmd_EXECÚstripÚupperr rˆ rr r Ú
maybeDeferredr“ r rU ÚNotImplementedErrorr€ )r- r” ÚcommandÚrestrg ÚerrMsgr. r. r/ r‘ ½ s
z StdioClient._dispatchCommandc C s– t |¡ | ttjtt¡}|tkr | | d¡¡ d S |tjkr2d|j
j |j
j f }| |¡ d S |ttfv rId|j
j
|j
jf }| |¡ d S d S )Nr$ zremote error %i: %s
zlocal error %i: %s
)r rˆ Útrapr r Ú SFTPErrorÚOSErrorÚIOErrorr‰ Úcmd_HELPre ÚcodeÚmessageÚerrnoÚstrerror)r- rg Úer r. r. r/ Ú
_printFailureÑ s
þzStdioClient._printFailurec C sd | j jjrd S | | j¡ d| _| jr0| j ¡ }|s"| j j ¡ d S | |¡ | |
¡ ¡ d S d S )Nr ) rw r† r‹ r‰ Úpsr ry ÚreadlineÚloseConnectionr– rš )r- Úlr. r. r/ r€ Ý s
úzStdioClient._newLinec C sF |d ur t |tƒr| d¡}| |¡ | d¡s | d¡ | ¡ d S )Nrƒ rv )r„ r7 r… r‰ Úendswithr€ )r- Úresultr. r. r/ r’ ê s
zStdioClient._cbCommandc C s. | |¡ | jr| js| jj ¡ | ¡ d S r1 )r« ry r rw r† r® r€ rp r. r. r/ r“ ó s
zStdioClient._ebCommandc C s` | |¡\}}| d¡s|d7 }|rtj | j|¡pd}| j |¡}| | j ¡ |
| j ¡ |S )Nr( r$ ) Ú _getFilenamer° Úosr‚ Újoinrx rw Ú
openDirectoryr| Ú_cbCdr` r“ )r- r‚ rŸ ÚnewPathr• r. r. r/ Úcmd_CDù s
zStdioClient.cmd_CDc C s& | ¡ | j |j¡}| | j¡ |S r1 )Úcloserw r{ Únamer| Ú _cbCurDir)r- Ú directoryr• r. r. r/ r¶ s zStdioClient._cbCdc C s
|| _ d S r1 ©rx r r. r. r/ r» s
zStdioClient._cbCurDirc C óH | d d¡\}}| |¡\}}t|ƒ}| j |¡}|j| j||d |S )Nr' )Úgrp©r+ r² r8 rw ÚgetAttrsr| Ú _cbSetUsrGrp)r- rŸ r¿ r‚ r• r. r. r/ Ú cmd_CHGRP ó zStdioClient.cmd_CHGRPc C sH | d d¡\}}| |¡\}}t|dƒ}| j |d|i¡}| t¡ |S )Nr' é Ú permissions)r+ r² r8 rw ÚsetAttrsr| rh )r- rŸ Úmodr‚ r• r. r. r/ Ú cmd_CHMOD s
zStdioClient.cmd_CHMODc C r¾ )Nr' )ÚusrrÀ )r- rŸ rÊ r‚ r• r. r. r/ Ú cmd_CHOWN rÄ zStdioClient.cmd_CHOWNc C sP i }|d ur|p |d |d< |d ur|p|d |d< | j ||¡}| t¡ |S )NÚuidÚgid)rw rÇ r| rh )r- Úattrsr‚ rÊ r¿ Únewr• r. r. r/ r $ s
zStdioClient._cbSetUsrGrpc C sä | |¡\}}d|v sd|v r1|r!| |¡\}}tj |¡s dS nd}| |¡}| | j|¡ |S |r;| |¡\}}ntj |¡d }t ||f¡ t
|ddƒ}t | j ƒ
|¡}| j |jtji ¡}| | j|¡ | | j|¡ |S )NÚ*ú?z'Wildcard get with non-directory target.ó r' Úwbr )r² r³ r‚ ÚisdirÚ _remoteGlobr| Ú_cbGetMultipler+ r rˆ Úopenr rx Úchildrw ÚopenFiler ÚFXF_READÚ_cbGetOpenFiler` Ú
_ebCloseLf)r- rŸ ÚremoteÚlocalr• Úlfr‚ r. r. r/ Úcmd_GET, s* ÿ
zStdioClient.cmd_GETc C s | d ||¡S r1 )Ú_cbGetMultipleNext)r- ÚfilesrÞ r. r. r/ rÖ D s zStdioClient._cbGetMultiplec C sÆ t |tjƒr | |¡ n|r | |¡ | d¡s | d¡ |s!d S | d¡d }ttj
|tj |¡d ¡ddƒ}t | j
ƒ |¡}| j |j tji ¡}| | j|¡ | | j|¡ | | j||¡ |S )NÚ
r r' rÓ )r„ r rU r« r‰ r° Úpopr× r³ r‚ r´ r+ r rx rØ rw rÙ r rÚ r| rÛ r` rÜ ÚaddBothrá )r- Úresrâ rÞ rg rß r‚ r• r. r. r/ rá H s
"z StdioClient._cbGetMultipleNextc C s | ¡ |S r1 )r¹ )r- rg rß r. r. r/ rÜ Z s zStdioClient._ebCloseLfc C s | ¡ | j||¡S r1 )rÁ r| Ú_cbGetFileSize)r- Úrfrß r. r. r/ rÛ ^ s zStdioClient._cbGetOpenFilec
C sº t |d ¡s| ¡ | ¡ d|j S |d |_| jjjjd }| jjjjd }d|_ g }g }| j
¡ }t |ƒD ]} |
d|||d||¡}
| |
¡ q9tj|d d
} | | j||¡ | S ) NrÆ z Can't get non-regular file: %sro r r rk r$ r r' ©ÚfireOnOneErrback)ÚstatÚS_ISREGr¹ rº ro rw r† rb r rl r
ÚsecondsÚrangeÚ
_cbGetReadÚappendr Ú DeferredListr| Ú
_cbGetDone) r- rÎ rè rß Ú
bufferSizeÚ numRequestsÚdListÚchunksÚ startTimerN r• Údlr. r. r/ rç a s"
zStdioClient._cbGetFileSizec C s d}|D ],}|dkr
d S ||d kr,| |¡}| |||d f¡ ||d | f S |d }qt| jjjjd ƒ}| ||| f¡ ||fS )Nr Úeofr' r )rB Úinsertr8 rw r† rb r rð )r- rö ÚendÚchunkrN ÚbufSizer. r. r/ Ú
_getNextChunkt s
zStdioClient._getNextChunkc
C sN |r+t |tjƒr+t d| ¡ |}| t¡ | ||| f¡} || = | | |df¡ nG|rrt dt |ƒ ¡ |
|¡ | |¡ t |ƒ|krit dt |ƒ|f ¡ | ||| f¡} || = | | ||t |ƒ f¡ | j t |ƒ7 _ | j
r{| ||¡ | |¡}
|
s„d S |
\}} t d||| f ¡ | || ¡} | | j||||| |¡ | S )Nzget read err: %srù zget read data: %iz#got less than we asked for: %i < %izasking for %i -> %i)r„ r rU r rˆ r¡ ÚEOFErrorrB rú Úlenrm r‡ rl rz Ú_printProgressBarrþ Ú readChunkrå rï )
r- Údatarè rß rö Ústartro r÷ ÚreasonrN rü Úlengthr• r. r. r/ rï ‚ s6
zStdioClient._cbGetReadc C s> t d¡ | ¡ | ¡ | jr| d¡ d|j› d|j› S )Nzget donerã ú Transferred ú to )r rˆ r¹ rz r‰ rº ©r- Úignoredrè rß r. r. r/ rò s
zStdioClient._cbGetDonec C sŒ | |¡\}}d|v sd|v r.|r!| |¡\}}tj | j|¡}nd}t |¡}| ||¡S |r8| |¡\}}ntj |¡d }| ||¡S )a#
Do an upload request for a single local file or a globing expression.
@param rest: Requested command line for the PUT command.
@type rest: L{str}
@return: A deferred which fires with L{None} when transfer is done.
@rtype: L{defer.Deferred}
rÐ rÑ r$ r' ) r² r³ r‚ r´ rx ÚglobÚ_putMultipleFilesr+ Ú_putSingleFile)r- rŸ rÞ rÝ râ r. r. r/ Úcmd_PUT¨ s
zStdioClient.cmd_PUTc C s | j d|g|ddS )aB
Perform an upload for a single file.
@param local: Path to local file.
@type local: L{str}.
@param remote: Remote path for the request relative to current working
directory.
@type remote: L{str}
@return: A deferred which fires when transfer is done.
NT)Úsingle©Ú_cbPutMultipleNext)r- rÞ rÝ r. r. r/ r
Ç s
zStdioClient._putSingleFilec C s | d||¡S )aV
Perform an upload for a list of local files.
@param files: List of local files.
@type files: C{list} of L{str}.
@param remote: Remote path for the request relative to current working
directory.
@type remote: L{str}
@return: A deferred which fires when transfer is done.
Nr )r- râ rÝ r. r. r/ r Ö s
z StdioClient._putMultipleFilesFc
C s t |tjƒr | |¡ n|r't |tƒr| d¡}| |¡ | d¡s'| d¡ d}|rP|sPz | d¡}t |dƒ}W n t
yK | t ¡ ¡ d}Y nw |rP|r-|sTdS |rY|}nt j
|¡d }t j ||¡}t |||f¡ | ||¡} | | j||¡ | S )aˆ
Perform an upload for the next file in the list of local files.
@param previousResult: Result form previous file form the list.
@type previousResult: L{str}
@param files: List of local files.
@type files: C{list} of L{str}
@param remotePath: Remote path for the request relative to current
working directory.
@type remotePath: L{str}
@param single: A flag which signals if this is a transfer for a single
file in which case we use the exact remote path
@type single: L{bool}
@return: A deferred which fires when transfer is done.
rƒ rv Nr Úrbr' )r„ r rU r« r7 r… r‰ r° rä r× rS r³ r‚ r+ r´ r rˆ Ú_putRemoteFilerå r )
r- ÚpreviousResultrâ r% r Ú currentFileÚ localStreamrÝ rº r• r. r. r/ r å s8
þü z StdioClient._cbPutMultipleNextc C sR t j | j|¡}tjtjB tjB }| j ||i ¡}|
| j |¡ | | j
|¡ |S )aW
Do an upload request.
@param localStream: Local stream from where data is read.
@type localStream: File like object.
@param remotePath: Remote path for the request relative to current working directory.
@type remotePath: L{str}
@return: A deferred which fires when transfer is done.
)r³ r‚ r´ rx r Ú FXF_WRITEÚ FXF_CREATÚ FXF_TRUNCrw rÙ r| Ú_cbPutOpenFiler` rÜ )r- r r% rÝ Úflagsr• r. r. r/ r s zStdioClient._putRemoteFilec
C s€ | j jjjd }| jrt|ƒ}g }g }| j ¡ }t|ƒD ]}| d ||||¡}|r.|
|¡ q t j |dd} |
| j||¡ | S )Nr r' ré )rw r† rb r rz rj r
rí rî Ú _cbPutWriterð r rñ r| Ú
_cbPutDone)
r- rè rß rô rõ rö r÷ rN r• rø r. r. r/ r - s
€zStdioClient._cbPutOpenFilec C sv | |¡}|\}}| |¡ | |¡} | jr%| jt| ƒ7 _| ||¡ | r9| || ¡}
|
| j ||||¡ |
S d S r1 )
rþ rm Úreadrz rl r r Ú
writeChunkr| r ) r- r
rè rß rö r÷ rü r ro r r• r. r. r/ r < s
zStdioClient._cbPutWritec C s4 | ¡ | ¡ | jr| d¡ d|j› d|j› S )Nrã r r )r¹ rz r‰ rº r r. r. r/ r K s
zStdioClient._cbPutDonec C s t |¡ d S r1 )r³ Úchdirr r. r. r/ Úcmd_LCDR ó zStdioClient.cmd_LCDc óJ ˆ |¡\}}ˆ |¡\}}t‡ fdd„||fƒ\}}ˆ j ||¡ t¡S )Nc ó t j ˆ j| ¡S r1 ©r³ r‚ r´ rx ©Úxr~ r. r/ ÚY ó z$StdioClient.cmd_LN..)r² Úmaprw ÚmakeLinkr| rh )r- rŸ ÚlinkpathÚ
targetpathr. r~ r/ Úcmd_LNU ó ÿzStdioClient.cmd_LNc C sÚ g }| ¡ }|rC|d rC|d d dkrC| d¡dd … }|D ]}|dkr+| d¡ q |dkr4| d¡ q |rC|d rC|d d dksd |¡}| |¡\}}|sW| jd }ntj | j|¡}| |¡}| | j
|¡ |S )
Nr rŠ r' r¯ ÚverboseÚaÚallr— r( ) r+ rä rð r´ r² rx r³ r‚ rÕ r| Ú_cbDisplayFiles)r- rŸ r ÚoptsÚor‚ ÚfullPathr• r. r. r/ Úcmd_LS] s&
€ ú
zStdioClient.cmd_LSc C sV | ¡ d|vrdd„ |D ƒ}d|v rdd„ |D ƒ}ndd„ |D ƒ}|s&d S d |¡S )Nr2 c S s g | ] }|d d¡s|‘qS )r ó .)r ©Ú.0rg r. r. r/ Ú
y s z/StdioClient._cbDisplayFiles..r0 c S ó g | ]}|d ‘qS )r' r. r9 r. r. r/ r; { ó c S r< ©r r. r9 r. r. r/ r; } r= rv )Úsortr´ )r- râ r Úlinesr. r. r/ r3 v s
zStdioClient._cbDisplayFilesc C s2 | |¡\}}tj | j|¡}| j |i ¡ t¡S r1 ) r² r³ r‚ r´ rx rw Ú
makeDirectoryr| rh ©r- r‚ rŸ r. r. r/ Ú cmd_MKDIRƒ s zStdioClient.cmd_MKDIRc C ó0 | |¡\}}tj | j|¡}| j |¡ t¡S r1 ) r² r³ r‚ r´ rx rw ÚremoveDirectoryr| rh rB r. r. r/ Ú cmd_RMDIRˆ ó zStdioClient.cmd_RMDIRc C ó t d| ¡ d S )Nzmkdir %s©r³ Úsystemr r. r. r/ Ú
cmd_LMKDIR ó zStdioClient.cmd_LMKDIRc C rD r1 ) r² r³ r‚ r´ rx rw Ú
removeFiler| rh rB r. r. r/ Úcmd_RM rG zStdioClient.cmd_RMc C rH )Nzls %srI )r- rŸ r. r. r/ Úcmd_LLS• rL zStdioClient.cmd_LLSc r# )Nc r$ r1 r% r& r~ r. r/ r( œ r) z(StdioClient.cmd_RENAME..)r² r* rw Ú
renameFiler| rh )r- rŸ ÚoldpathÚnewpathr. r~ r/ Ú
cmd_RENAME˜ r/ zStdioClient.cmd_RENAMEc C s | j j ¡ d S r1 )rw r† r® ©r- r
r. r. r/ Úcmd_EXIT ó zStdioClient.cmd_EXITc C s$ d| j j }t|tƒr| d¡}|S )NzSFTP version %irƒ )rw Úversionr„ r7 r… )r- r
rW r. r. r/ Ú cmd_VERSION¥ s
zStdioClient.cmd_VERSIONc C s dS )Nae Available commands:
cd path Change remote directory to 'path'.
chgrp gid path Change gid of 'path' to 'gid'.
chmod mode path Change mode of 'path' to 'mode'.
chown uid path Change uid of 'path' to 'uid'.
exit Disconnect from the server.
get remote-path [local-path] Get remote file.
help Get a list of available commands.
lcd path Change local directory to 'path'.
lls [ls-options] [path] Display local directory listing.
lmkdir path Create local directory.
ln linkpath targetpath Symlink remote file.
lpwd Print the local working directory.
ls [-l] [path] Display remote directory listing.
mkdir path Create remote directory.
progress Toggle progress bar.
put local-path [remote-path] Put local file.
pwd Print the remote working directory.
quit Disconnect from the server.
rename oldpath newpath Rename remote file.
rmdir path Remove remote directory.
rm path Remove remote file.
version Print the SFTP version.
? Synonym for 'help'.
r. rT r. r. r/ r¥ « ri zStdioClient.cmd_HELPc C s | j S r1 r½ rT r. r. r/ Úcmd_PWDÆ s zStdioClient.cmd_PWDc C s t ¡ S r1 )r³ ÚgetcwdrT r. r. r/ Úcmd_LPWDÉ s zStdioClient.cmd_LPWDc C s | j | _ d| j r dp d S )Nz%ssing progess bar.ÚUzNot u)rz rT r. r. r/ Ú cmd_PROGRESSÌ s
zStdioClient.cmd_PROGRESSc C sF | j t ¡ ¡d }|sd}|r d|g}tj||ddS t |¡ dS )zb
Run C{rest} using the user's shell (or /bin/sh if they do not have
one).
é z/bin/shz-cr' )ÚerrortooN)Ú_pwdÚgetpwnamr[ r\ r ÚgetProcessOutputr³ rJ )r- rŸ ÚshellÚcmdsr. r. r/ r™ Ð s zStdioClient.cmd_EXECc C sŒ t d| ¡ tj |¡\}}d|v sd|v rd}nd}|r7|s7| j |¡}| | jd¡ | | j
||¡ |S | j |¡}| | j|¡ |S )Nz
looking up %srÐ rÑ r' r r$ ) r rˆ r³ r‚ r+ rw rµ r| Ú _cbOpenListr` Ú_ebNotADirectory)r- r6 ÚheadÚtailr r• r. r. r/ rÕ à s þzStdioClient._remoteGlobc C s" g }| ¡ }| | j|||¡ |S r1 )r rå Ú _cbReadFile)r- r¼ r râ r• r. r. r/ re ñ s zStdioClient._cbOpenListc C s | j |¡}| | j|¡ |S r1 )rw rµ r| re )r- r r‚ r r• r. r. r/ rf ÷ s z StdioClient._ebNotADirectoryc sv t |tjƒs.ˆ rˆ d¡‰ | ‡ fdd„|D ƒ¡ n| |¡ | ¡ }| | j||ˆ ¡ |S |}| t ¡ |
¡ |S )Nrƒ c s g | ] }t |d ˆ ¡r|‘qS r> )Úfnmatchr9 ©r r. r/ r; s z+StdioClient._cbReadFile..) r„ r rU r… Úextendr rå ri r¡ rÿ r¹ )r- râ Ú matchedFilesr¼ r r• r r. rk r/ ri ü s
zStdioClient._cbReadFilec C s2 g d¢}|D ]
\}}||kr nqd|| | S )N))l ÚPB)l ÚTB)i @ÚGB)i ÚMB)i ÚkB)r' r z%.1fr. )r- ro Ú_abbrevsÚfactorÚsuffixr. r. r/ Ú _abbrevSize s ÿzStdioClient._abbrevSizec C sj |dkr#t |d ƒ}|d| 8 }t |d ƒ}|d| 8 }d|||f S t |d ƒ}|d| 8 }d||f S )Ni é< z %i:%02i:%02iz %02i:%02i)r8 )r- ÚtÚhoursÚminsr. r. r/ Ú _abbrevTime s zStdioClient._abbrevTimec
C sü | j ¡ | }|j}zt dt dtjd¡¡}W n
t y% ddg}Y nw |dkr-d}n|| }|r;|j
| | }nd}|j }|j
rK||j
d } nd} d| | |¡| |¡|
|¡f }
|d t|ƒt|
ƒ d d
} d |› | › |
› } | | ¡ dS ) aë
Update a console progress bar on this L{StdioClient}'s transport, based
on the difference between the start time of the operation and the
current time according to the reactor, and appropriate to the size of
the console window.
@param f: a wrapper around the file which is being written or read
@type f: L{FileWrapper}
@param startTime: The time at which the operation being tracked began.
@type startTime: L{float}
Ú4Hr Ú12345679NéP rk éd z%3i%% %s %sps %s r' r— ú
)r
rí rl ÚstructÚunpackÚfcntlÚioctlÚttyÚ
TIOCGWINSZr£ ro rº rv r{ r r‰ )
r- rg r÷ Údiffrl ÚwinSizeÚspeedÚtimeLeftÚfrontÚ
percentageÚbackÚspacesrž r. r. r/ r ( s4
ÿü z StdioClient._printProgressBarc C s | ¡ }|sdS |d dv rpg }t|ƒ}zPtdt|ƒƒD ]F}|| }||d kr=d |¡d ||d d… ¡ ¡ f W S |dkr[||= || dvrStd || › ƒ‚| || ¡ q | || ¡ q W n tyo td
ƒ‚w | dd¡}t|ƒdkr‚|d dfS |d |d fS ) aW
Parse line received as command line input and return first filename
together with the remaining line.
@param line: Arguments received from command line input.
@type line: L{str}
@return: Tupple with filename and rest. Return empty values when no path was not found.
@rtype: C{tupple}
)r$ r$ r z'"r' r$ Nú\z'"\z bad quote: \zunterminated quote) rš Úlistrî r r´ rŽ Ú
IndexErrorrð r+ )r- r” ÚretrN Úcr. r. r/ r² R s2 * ö ÿ zStdioClient._getFilenamer1 )NN)F)Dr2 r3 r4 Úpwdr` r¬ Ú delimiterr
rq r r} r‰ r– r‘ r« r€ r’ r“ r¸ r¶ r» rà rÉ rË r rà rÖ rá rÜ rÛ rç rþ rï rò r r
r r r r r r r! r. r7 r3 rC rF rK rN rO rS rU Úcmd_QUITrX r¥ rY r[ r] r™ rÕ re rf ri rv r{ r r² r. r. r. r/ ru Ž s‚
5
*ru zcmd_?c @ s e Zd Zdd„ ZdS )r] c C s | tƒ ¡ d S r1 )Ú openChannelÚ
SSHSessionr~ r. r. r/ ÚserviceStarted| rV z SSHConnection.serviceStartedN)r2 r3 r4 r™ r. r. r. r/ r] { s r] c @ sP e Zd ZdZdd„ Zdd„ Zdd„ Zdd „ Zd
d „ Zd d
„ Z dd„ Z
dd„ Z dS )r˜ s sessionc C sh t d| j ¡ | jjd d¡rd}nd}| jj| |t | jjd ¡dd}| | j
¡ | t ¡ d S )Nzsession %s openr r( Úexecr' )Ú wantReply)
r rˆ Úidrb r r Ú sendRequestr ÚNSr| Ú _cbSubsystemr` ra )r- ÚfooÚrequestr• r. r. r/ Ú channelOpen„ s ÿ zSSHSession.channelOpenc C sd t ¡ | _| j | ¡ | jj| _d }| jjd r&| jjd }|dkr&t|ƒ}t t
| j|ƒ¡| _d S )Nr rŠ ) r ÚFileTransferClientrw ÚmakeConnectionÚ dataReceivedrb r r× r Ú
StandardIOru )r- r± rg Úfnr. r. r/ rŸ s
zSSHSession._cbSubsystemc C s: |t jkrt dt|ƒ ¡ tj |¡ tj ¡ d S d S )Nzgot %s stderr data) r
ÚEXTENDED_DATA_STDERRr rˆ r r@ rI r‡ Úflush)r- rx 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 %s)r rˆ rb Ú sendCloser~ r. r. r/ Ú
closeReceived¥ s zSSHSession.closeReceivedc C s$ zt ¡ W d S ty Y d S w r1 )r
rR rS r~ r. r. r/ Úclosed© s
ÿzSSHSession.closedc C ó | j ¡ d S r1 )r ÚpauseProducingr~ r. r. r/ Ú stopWriting¯ r" zSSHSession.stopWritingc C r° r1 )r ÚresumeProducingr~ r. r. r/ Ú startWriting² r" zSSHSession.startWritingN) r2 r3 r4 rº r¢ rŸ rª r¬ r® r¯ r² r´ r. r. r. r/ r˜ € s r˜ Ú__main__)5Ú__doc__rƒ rj r[ r r³ r” rë r r@ r… Útypingr r r Útwisted.conch.clientr r r Útwisted.conch.sshr r r
r Útwisted.internetr r
r r Útwisted.protocolsr Útwisted.pythonr r r Útwisted.python.filepathr Ú ConchOptionsr rL rV rK ra rh rj Ú LineReceiverru Úsetattrr¥ r] Ú
SSHChannelr˜ r2 r. r. r. r/ Ú sJ # o6
ÿ