+ jRt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RI t ^RI t ^RI H t H t HtHt^RIHtHtHt^RIHtHtHtHt^RIHtHtHtHt^RIHt^RI H!t!H"t"H#t#^RI$H%t%!R R ]PL4t'R t(R t)R t*Rt+Rt,!RR4t-!RR]P\4t/]0!]/R]/Pb4!RR]Pd4t2!RR]Pf4t4]5R8Xd ](!4R#R#)z0 Implementation module for the I{cftp} command. N)ListOptionalTextIOUnion)connectdefaultoptions)channelcommon connection filetransfer)deferreactorstdioutils)basic)failurelogusage)FilePathca]tRt^toRtRt.R O.R O.RO.RO.t]P!RR/]P!4]P!RR7.R7t RR lt V3R lt R tVtR#) ClientOptionszUsage: 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 buffersizeNz,Size of send/receive buffer (default: 32768)z local file)descr) descriptions extraActionscRVR&RV9d0VPR^4wqR&VR,PR4WR&W R&R#) remotePath:/host localPathN)splitrstrip)selfr!r"s&&&s 88B (D99D>c^s\P!4\P !\ P!44h \dL7i;i)r+) exitStatusrstop BaseExceptionrerrrFailurer3r)r& handleErrorrfTsAJ  GGGOO      sA AAcRVR,9d#VR,PR^4wVR&VR&VR,pVR,'g\P!4VR&VR,'g^VR&M\VR,4VR&VR,pVR,p\ 4pWn\ Pp\ P!VR,W4p\P!WWV4P\4R#)@r!userportN) r#getpassgetuserr. SSHConnectionrr verifyHostKeySSHUserAuthClientr addErrback_ebExit)rr!rjconnvhkuaos& r&rZrZ_s gfo+26?+@+@a+H( 6?D 6??!//+ 6??gfo. 6?D 6?D ?DL   C  # #GFOW CC OODc2==gFr)c\VPR4'dVPPpM \V4p\V4\P !4R# \ dR#i;i)valueN)hasattrrvr-rTrrbrc)fr;s& r&rqrqrsPqww  GGMM F !H      s A"" A10A1cR#r=r3)r\s*r&_ignorerz~sr)c,a]tRt^toRtRtRtVtR#) FileWrappercnWnRVnVP^^4VP4VnR#)N)rxtotalseektellsizer%rxs&&r&__init__FileWrapper.__init__s(  q! FFH r)c.\VPV4#r=)getattrrx)r%attrs&&r& __getattr__FileWrapper.__getattr__stvvt$$r))rxrrN)r>r?r@rArrrIrJrKs@r&r|r|s %%r)r|ca]tRt^to]tRtRt]tR@Rlt Rt Rt Rt Rt R tR tR tR tR tRtRtRtRtRtRtRARltRtRtRtRtRtRtRt Rt!Rt"Rt#Rt$R t%RBR!lt&R"t'R#t(R$t)R%t*R&t+R't,R(t-R)t.R*t/R+t0R,t1R-t2R.t3R/t4R0t5]5t6R1t7R2t8R3t9R4t:R5t;R6tR9t?R:t@R;tAR<tBR=tCR>tDR?tEVtFR#)C StdioClientzcftp>  NclWnRVnW nV'*;'d ^;'g^VnR#rN)clientcurrentDirectoryfileuseProgressBar)r%rrxs&&&r&rStdioClient.__init__s, " #$u{{00qr)cnVPPR4PVP4R#r)rrealPath addCallback _cbSetCurDirr%s&r&connectionMadeStdioClient.connectionMades% R ,,T->->?r)c2WnVP4R#r=)r_newLiner%paths&&r&rStdioClient._cbSetCurDirs $ r)c\V\4'dVPR4pVPP V4#utf-8) isinstancer-encode transportwrite)r%msgs&&r&_writeToTransportStdioClient._writeToTransports2 c3  **W%C~~##C((r)cNVPPP'dR#\V\4'dVP R4p\ P!RV,4VP4pV'gVP4R#VP'd)VPR4'd^Vn VR,pM^Vn VPV4pVe9VPVP4VP!VP"4R#R#)Nrz got line %s-rM)rr localClosedrbytesdecoderrlstriprr startswith ignoreErrors_dispatchCommandr _cbCommandrp _ebCommand)r%lineds&& r& lineReceivedStdioClient.lineReceiveds ;; , , ,  dE " ";;w'D  $%{{} MMO  999-- !D 8D !D   ! !$ ' = MM$// * LL ) r)c:RV9d&VPR^4wr#VP4pMTRr2VPR4'd3VPpVR,R,V,P 4pMAVP 4p\ P!RV,4\VRV,R4pVe\P!WC4#RV,pVP\P!\V444VP4R#) r!rMzlooking up cmd %szcmd_%sNzNo command called `%s')r#rrcmd_EXECstripupperrrrr maybeDeferredrrreNotImplementedErrorr)r%rcommandrestrxerrMsgs&& r&rStdioClient._dispatchCommands $; JJsA.MG;;=D "T   c " " ABK#%,335DmmoG GG''1 2h0$7A =&&q/ /-9F OOGOO,?,GH I MMOr)cL\P!V4VP\\P \ \4pV\8Xd#VPVPR44R#V\P 8XdGRVPPVPP3,pVPV4R#V\ \39dGRVPPVPP3,pVPV4R#R#)rzremote error %i: %s zlocal error %i: %s N)rrtraprr SFTPErrorOSErrorIOErrorrcmd_HELPrvcodemessageerrnostrerror)r%rxers&& r& _printFailureStdioClient._printFailures  FF& (>(> Q # #  " "4==#4 5 ,(( (, aggoo/NNF  " "6 * 7G$ $+qww}}agg>N>N.OOF  " "6 *%r)cVPPP'dR#VPVP4^VnVP 'd{VP P4pV'g'VPPP4R#VPV4VPVP44R#R#r=) rrrrpsrrreadlineloseConnectionrr)r%ls& r&rStdioClient._newLines ;; , , ,  tww' 999 ""$A %%446&&q)!!!''), r)cVea\V\4'dVPR4pVPV4VP R4'gVPR4VP 4R#)Nrr)rr-rrendswithr)r%results&&r&rStdioClient._cbCommandsW  &#&&w/  " "6 *??5))&&u- r)cVPV4VP'd7VP'g%VPPP 4VP 4R#r=)rrrrrrrrs&&r&rStdioClient._ebCommandsC 1 999T... KK ! ! 0 0 2 r)cVPV4wrVPR4'g VR, pT;'d3\PP VP V4;'gRpVP PV4pVPVP4VPVP4V#)r r) _getFilenamerosrjoinrr openDirectoryr_cbCdrpr)r%rrnewPathrs&& r&cmd_CDStdioClient.cmd_CDs&&t, }}S!! CKDDD277<<(=(=tDJJ KK % %g . djj! T__%r)cVP4VPPVP4pVP VP 4V#r=)closerrnamer _cbCurDir)r% directoryrs&& r&rStdioClient._cbCds9 KK  0 dnn%r)cWnR#r=rrs&&r&rStdioClient._cbCurDirs $r)cVPR^4wr!VPV4wr1\V4pVPP V4pVP VP W2R7V#)N)grpr#rr.rgetAttrsr _cbSetUsrGrp)r%rrrrs&& r& cmd_CHGRPStdioClient.cmd_CHGRP ^JJtQ' &&t, #h KK  & d'' 7r)cVPR^4wr!VPV4wr1\V^4pVPP VRV/4pVP \ 4V#)N permissions)r#rr.rsetAttrsrrz)r%rmodrrs&& r& cmd_CHMODStdioClient.cmd_CHMODs]JJtQ' &&t, #qk KK  s'; < gr)cVPR^4wr!VPV4wr1\V4pVPP V4pVP VP W2R7V#)N)usrr)r%rrrrs&& r& cmd_CHOWNStdioClient.cmd_CHOWNrr)c/pVRJ;'d T;'g VR,VR&VRJ;'d T;'g VR,VR&VPPW%4pVP\4V#)Nuidgid)rrrrz)r%attrsrrrnewrs&&&&& r&rStdioClient._cbSetUsrGrp"sno..3>>%,E o..3>>%,E KK  + gr)cVPV4wr!RV9gRV9duV'd<VPV4wr1\PPV4'gR#MRpVP V4pVP VP V4V#V'dVPV4wr1M&\PPV4^,p\P!W#34\VR^4p\VP4PV4pVPPVP\ P"/4pVP VP$V4VP'VP(V4V#)*?z'Wildcard get with non-directory target.r)wb)rrrisdir _remoteGlobr_cbGetMultipler#rropenrrchildropenFiler FXF_READ_cbGetOpenFilerp _ebCloseLf)r%rremotelocalrlfrs&& r&cmd_GETStdioClient.cmd_GET*s3((.  &=C6M"//5 ww}}U++D,  (A MM$--u 5H ++D1KE4GGMM&)!,E  %q !--.44V< KK L,A,A2 F d))2. T__b)r)c&VPRW4#r=)_cbGetMultipleNext)r%filesrs&&&r&rStdioClient._cbGetMultipleBs&&tU::r)c(\V\P4'dVPV4MAV'd:VP V4VP R4'gVP R4V'gR#VP ^4^,p\\PPV\PPV4^,4R^4p\VP4PV4pVPP!VP\"P$/4pVP'VP(V4VP+VP,V4VP/VP0W#4V#) Nr )rrrerrrpoprrrrr#rrrrrr rrrrpraddBothr)r%resrrrxrrrs&&&& r&rStdioClient._cbGetMultipleNextFs c7?? + +   s #   " "3 '<<%%&&t,  IIaLO "'',,ubggmmA&6q&9:D! D--.44Q7 KK L,A,A2 F d))2. T__b) $))58r)c&VP4V#r=)r)r%rxrs&&&r&rStdioClient._ebCloseLfXs  r)cVVP4PVPW4#r=)rr_cbGetFileSize)r%rfrs&&&r&rStdioClient._cbGetOpenFile\s!{{}(()<) %i)rrrerrrEOFErrorrQr@lenrrrr_printProgressBarrD readChunkr"r2) r%datar)rr9startrr:reasonr]rBlengthrs &&&&&&&& r&r2StdioClient._cbGetReadsw JtW__55 GG&- .F KK ! eT\23A MM!U^ ,  GG'#d)3 4 GGEN HHTN4yD =TD@QQRLL%!67I aT):!;< HHD !H      " "2 1""6* !ME %(??@ LL ' $//26&Lr)c\P!R4VP4VP4VP'dVP R4RVP RVP 2#)zget doner  Transferred  to )rrrrrrr%ignoredr)rs&&&&r&r5StdioClient._cbGetDonesU           " "4 (bggYd277)44r)c VPV4wr!RV9gRV9dpV'd?VPV4wr1\PPVPV4pMRp\ P !V4pVP WC4#V'dVPV4wr1M&\PPV4^,pVPW#4#)z 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) rrrrrglob_putMultipleFilesr#_putSingleFile)r%rrrrs&& r&cmd_PUTStdioClient.cmd_PUTs''-  %<3%<#006 d&;&;VDIIe$E))%8 8#006 u-a0&&u5 5r)c .VPRV.VRR7#)a 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%rrs&&&r&rYStdioClient._putSingleFiles &&teWfT&JJr)c &VPRW4#)a 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%rrs&&&r&rXStdioClient._putMultipleFiless&&tU;;r)c P\V\P4'dVPV4MhV'da\V\4'dVP R4pVP V4VPR4'gVP R4RpV'd)V'g!VP^4p\VR4pK0V'gR#V'dTpM]\PPV4^,p\PPW84p\P !WV34VP#XV4p V P%VP&W#4V # \d,TP\P!44RpEKi;i)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. rrNrb)rrrerr-rrrr!rrcrrr#rrr_putRemoteFiler"r_) r%previousResultrrr] currentFile localStreamrrrs &&&&& r&r_StdioClient._cbPutMultipleNexts8( ngoo 6 6   ~ . .#..!/!6!6w!?  " "> 2!**511&&u- K ##iil ";5  F77==-a0DWW\\*3F GGT:. /    V 4 $))5=#! #""7??#45"  #s.E//1F%$F%c v\PPVPV4p\P \P ,\P,pVPPW4/4pVPVPV4VPVPV4V#)a 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. )rrrrr FXF_WRITE FXF_CREAT FXF_TRUNCrrr_cbPutOpenFilerpr)r%rhrrflagsrs&&& r&reStdioClient._putRemoteFilesd33Z@&&)?)??,BXBXX KK  3 d));7 T__k2r)cVPPPPR,pVP'd \ V4p.p.pVP P4p\V4F1pVPRWWV4pV'gK VPV4K3 \P!V^R7p V PVPW4V #)r7Nr,)rrrrrrr|rr0r1 _cbPutWriter3r r4r _cbPutDone) r%r)rr7r8r9r:r]rr;s &&& r&rnStdioClient._cbPutOpenFile+skk++0088D    RBLL((* {#A  rvAAq Q$   : t/ r)cnVPV4pVwrxVPV4VPV4p VP'd4V;P\ V 4, unVP W54V 'd1VPWy4p V PVPW#WE4V #R#r=) rDrreadrrrHrI writeChunkrrr) r%rTr)rr9r:rBrLrrKrs &&&&&& r&rrStdioClient._cbPutWrite:s""6*  wwt}     HHD !H  " "2 1  e*A MM$**BF FH r)cVP4VP4VP'dVPR4RVP RVP 2#)r rQrR)rrrrrSs&&&&r&rsStdioClient._cbPutDoneIsI         " "4 (bggYd277)44r)c2\P!V4R#r=)rchdirrs&&r&cmd_LCDStdioClient.cmd_LCDPs  r)caSPV4wr!SPV4wr1\V3RlW#34wr#SPPW#4P \ 4#)cX<\PPSPV4#r=rrrrxr%s&r&$StdioClient.cmd_LN..Wbggll4#8#8!T {{##H9EEgNNr)cb.pVP4pV'd~V^,'doV^,^,R8XdZVP^4R,pVF9pVR8XdVP!R4KVR8XgK'VP!R4K; KRPV4pVP V4wrQV'gVP R,pM*\ PPVP V4pVPV4pVPVPV4V#) r>rrMrverboseaallrr ) r#r!r3rrrrrrr_cbDisplayFiles)r%rroptsorfullPathrs&& r&cmd_LSStdioClient.cmd_LS[s zz|tAww471:#488A;r?D8NN9-#XNN5)  xx~&&t, ,,s2Hww||D$9$94@H   X & d**G4r)cPVP4RV9d1VUu.uF$q3^,PR4'dK"VNK& ppRV9dVUu.uF q3^,NK ppMVUu.uF q3^,NK ppV'gR#RPV4#uupiuupiuupi)r.rNr)sortrr)r%rrrxliness&&& r&rStdioClient._cbDisplayFilests   %C1qT__T-BQQEC  #()5aqTT5E)E#()5aqTT5E)::e$ $D))sBBB+B#cVPV4wr\PPVPV4pVP P V/4P\4#r=) rrrrrr makeDirectoryrrzr%rrs&& r& cmd_MKDIRStdioClient.cmd_MKDIRsP&&t, ww||D1148{{((r2>>wGGr)cVPV4wr\PPVPV4pVP P V4P\4#r=) rrrrrrremoveDirectoryrrzrs&& r& cmd_RMDIRStdioClient.cmd_RMDIRsN&&t, ww||D1148{{**40<.rr))rrr renameFilerrz)r%roldpathnewpathsf& r& cmd_RENAMEStdioClient.cmd_RENAMEs^))$/ ))$/  P {{%%g7CCGLLr)cNVPPP4R#r=)rrrr%rTs&&r&cmd_EXITStdioClient.cmd_EXITs ,,.r)cRVPP,p\V\4'dVP R4pV#)zSFTP version %ir)rversionrr-r)r%rTrs&& r& cmd_VERSIONStdioClient.cmd_VERSIONs6#dkk&9&99 gs # #nnW-Gr)cR#)aeAvailable 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'. r3rs&&r&rStdioClient.cmd_HELPsr)cVP#r=rrs&&r&cmd_PWDStdioClient.cmd_PWDs$$$r)c,\P!4#r=)rgetcwdrs&&r&cmd_LPWDStdioClient.cmd_LPWDsyy{r)c|VP'*VnRVP;'d R;'gR,#)z%ssing progess bar.UzNot u)rrs&&r& cmd_PROGRESSStdioClient.cmd_PROGRESSs4"&"5"55$(;(;(C(C(N(NwOOr)c VPP\P!44^,pV'gRpV'dRV.p\P !W#^R7#\ P!V4R#)zJ Run C{rest} using the user's shell (or /bin/sh if they do not have one). z/bin/shz-c)errortooN)_pwdgetpwnamrkrlrgetProcessOutputrr)r%rshellcmdss&& r&rStdioClient.cmd_EXECsW  ""7??#45a8E $ !  7 !566 7sA'D<AD<<E)rrrrrr=)NN)F)Gr>r?r@rApwdrr delimiterrrrrrrrrrrrrrrrrrrrrrrrr(rDr2r5rZrYrXr_rernrrrsr}rrrrrrrrrrcmd_QUITrrrrrrrrrrrrrIrrIrJrKs@r&rrsW D BIG1 @) *(( + -  %0;$F& <56> K <3j&  5O2 %H F %A "M/H 6%P  "   1 +((T#"#"r)rzcmd_?c&a]tRtRtoRtRtVtR#)rmiyc8VP\44R#r=) openChannel SSHSessionrs&r&serviceStartedSSHConnection.serviceStartedzs &r)r3N)r>r?r@rArrIrJrKs@r&rmrmys''r)rmca]tRtRtoRt]P tRtRtV3RlRlt Rt Rt R t R t R tV3R ltR tVtR#)ri~ssessionc\P!RVP,4VPPR,P R4'dRpMRpVPP W\P!VPPR,4^R7pVPVP4VP\4R#)zsession %s openr:r exec) wantReplyN) rridrrrr sendRequestr NSr _cbSubsystemrprq)r%foorequestrs&& r& channelOpenSSHSession.channelOpens !DGG+, 99  [ ) 4 4S 9 9G!G II ! ! 699TYY%6%6{%CDPQ "  d''( Wr)c\P!4VnVPPV4VPPVnRpVP P R,'d0VP P R,pVR8wd \V4p\P!\VPV44VnR#)Nr5r) r FileTransferClientrmakeConnection dataReceivedrrrrr StandardIOr)r%rrxfns&& r&r!SSHSession._cbSubsystems"557  ""4( KK44  99  [ ) )"";/BSyH%%k$++q&AB r)c*<V^8dQhRS[RS[RR/#)r+rrKreturnN)r.r)r/r0s"r&r1SSHSession.__annotate__s"9 9 S9 9 $9 r)c V\P8Xdn\P!R\ V4,4VP P VPRR44VP P4R#R#)zgot %s stderr datarbackslashreplaceN) r EXTENDED_DATA_STDERRrrrHrXrrflush)r%rrKs&&&r& extReceivedSSHSession.extReceiveds] // / GG(3t94 5l KK  dkk'3EF G KK   q 0r)cf\P!R4VPP4R#)zgot eofN)rrrloseWriteConnectionrs&r& eofReceivedSSHSession.eofReceiveds   &&(r)cv\P!RV,4VPPV4R#)zremote side closed %sN)rrrr sendClosers&r& closeReceivedSSHSession.closeReceiveds& '$./ D!r)cV\P!4R# \dR#i;ir=)rrbrcrs&r&closedSSHSession.closeds"  LLN   s  ((c:VPP4R#r=)rpauseProducingrs&r& stopWritingSSHSession.stopWritings !!#r)c:VPP4R#r=)rresumeProducingrs&r& startWritingSSHSession.startWritings ""$r)c2<V^8dQh/S[;R&S[;R&#)r+rrX)rr)r/r0s"r&r1r/~s  r))rr)rN)r>r?r@rArrOrXr$r!r4r8r<r?rCrGrHrIrJrKs@r&rr~sJDZZF  C9 9 v)" $%Or)r__main__)6__doc__rrrkrWrrr.rrOrtypingrrrrtwisted.conch.clientrrrtwisted.conch.sshr r r r twisted.internetr rrrtwisted.protocolsrtwisted.pythonrrrtwisted.python.filepathr ConchOptionsrr[rfrZrqrzr| LineReceiverrsetattrrrm SSHChannelrr>r3r)r&rWs   00::GG99#..,&G((&D, G&   %%f "%$$f "R Wk223'J,,' h%##h%V zEr)