tfdZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z m Z mZmZddlmZmZmZddlmZmZmZmZddlmZmZmZmZddlmZddl m!Z!m"Z"m#Z#dd l$m%Z%Gd d ej&Z'd Z(d Z)dZ*dZ+dZ,GddZ-Gddej.Z/e0e/de/j1Gddej2Z2Gddej3Z4e5dkr e(dSdS)z0 Implementation module for the I{cftp} command. N)ListOptionalTextIOUnion)connectdefaultoptions)channelcommon connection filetransfer)deferreactorstdioutils)basic)failurelogusage)FilePathceZdZUdZdZgdgdgdgdgZeeeee e fe d<e j dd ie je jd g ZddZd S) 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) buffersizeBiz0Size of the buffer to use for sending/receiving.) batchfilebNz-File to read commands from, or '-' for stdin.)requestsRz6Number of requests to make before waiting for a reply.) subsystemssftpz'Subsystem/server program to connect to. optParametersrz,Size of send/receive buffer (default: 32768)z local file)descr) descriptions extraActionsNcd|d<d|vr7|dd\}|d<|dd||d<||d<dS)N remotePath:/host localPath)splitrstrip)selfr-r.s Y/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/twisted/conch/scripts/cftp.py parseArgszClientOptions.parseArgs5sd\ $;;'+zz#q'9'9 $D$|$   % %c * * *V %[N)__name__ __module__ __qualname__synopsislongdescr#rrrstrint__annotations__r CompletionsCompleteUserAtHost CompleteFilescompDatar3r4r2rrsH  B WVVQQQVVVMMM <M4XeCHo678!u "$RS $E $ & & E l 3 3 3 H&&&&&&r4rcBtjdd}d|vr0|d}|||dz|z}||dz|dz=t} |j|nB#t j$r0}td|ztjdYd}~nd}~wwxYw|dr7tj }tj tj |t_ ntj t|tjdS)Nr+z-lz ERROR: %sr)sysargvindexr parseOptionsr UsageErrorprintexitstdoutr startLoggingstderr discardLogs doConnectrrun)argsir urealouts r2rRrR>s  8ABBd;Z?d<Z@d=ZAd>ZBd?ZCdS)C StdioClientzcftp>  NcH||_d|_||_| rdpd|_dS)Nr(r+r)clientcurrentDirectoryfileuseProgressBar)r1rrps r2r|zStdioClient.__init__s1 " #$u{0qr4cj|jd|jdS)Nr()rrealPath addCallback _cbSetCurDirr1s r2connectionMadezStdioClient.connectionMades/ R  ,,T->?????r4c<||_|dSr5)r_newLiner1paths r2rzStdioClient._cbSetCurDirs $ r4ct|tr|d}|j|S)Nutf-8) isinstancer;encode transportwrite)r1msgs r2_writeToTransportzStdioClient._writeToTransports; c3   &**W%%C~##C(((r4c |jjjrdSt|tr|d}t jd|z|}|s| dS|j r'| drd|_ |dd}nd|_ | |}|6||j||jdSdS)Nrz got line %s-r+r)rr localClosedrbytesdecoderrlstriprr startswith ignoreErrors_dispatchCommandr _cbCommandrh _ebCommand)r1lineds r2 lineReceivedzStdioClient.lineReceiveds ; ,  F dE " " (;;w''D  $%%%{{}}  MMOOO F 9 "-- " !D 8DD !D   ! !$ ' ' = MM$/ * * * LL ) ) ) ) ) =r4c6d|vr.|dd\}}|}n|d}}|dr*|j}|dddz|z}n?|}t jd|zt|d|zd}|tj ||Sd|z}| tj t||dS)N r+r(!zlooking up cmd %szcmd_%szNo command called `%s')r/rrcmd_EXECstripupperrrr~r maybeDeferredrrr\NotImplementedErrorr)r1rcommandrestrperrMsgs r2rzStdioClient._dispatchCommands  $;; JJsA..MGT;;==DD "TG   c " " 8 AABBK#%,3355DDmmooG G''1 2 2 2h0$77A =&q$// /-9F OOGO,?,G,GHH I I I MMOOOOOr4ctj||ttjt t}|tkr*|| ddS|tjkr2d|j j |j j fz}||dS|t tfvr2d|j j |j jfz}||dSdS)Nr(zremote error %i: %s zlocal error %i: %s )rrtraprr SFTPErrorOSErrorIOErrorrcmd_HELPrncodemessageerrnostrerror)r1rpers r2 _printFailurezStdioClient._printFailures  FF& (> Q Q # # #  " "4==#4#4 5 5 5 5 5 ,( ( (, ago/NNF  " "6 * * * * * 7G$ $ $+qw}ag>N.OOF  " "6 * * * * *% $r4cn|jjjrdS||jd|_|jry|j}|s |jjdS||| | dSdS)Nr) rrrrpsrrreadlineloseConnectionrr)r1ls r2rzStdioClient._newLines ; ,  F tw''' 9 - ""$$A - %4466666&&q)))!!!'')),,,,,  - -r4c|it|tr|d}|||ds|d|dS)Nrr)rr;rrendswithr)r1results r2rzStdioClient._cbCommandsx  &#&& 0w//  " "6 * * *??5)) .&&u--- r4c|||jr%|js|jj|dSr5)rrrrrrrr{s r2rzStdioClient._ebCommandsR 1 9 3T. 3 K ! 0 0 2 2 2 r4cX||\}}|ds|dz }|r%tj|j|pd}|j|}||j | |j |S)Nr,r() _getFilenamerosrjoinrr openDirectoryr_cbCdrhr)r1rrnewPathrs r2cmd_CDzStdioClient.cmd_CDs&&t,, d}}S!!  CKDD27<<(=tDDJ K % %g . . dj!!! T_%%%r4c||j|j}||j|Sr5)closerrnamer _cbCurDir)r1 directoryrs r2rzStdioClient._cbCdsB K  0 0 dn%%%r4c||_dSr5rrs r2rzStdioClient._cbCurDirs $r4c|dd\}}||\}}t|}|j|}||j|||S)Nr+)grpr/rr<rgetAttrsr _cbSetUsrGrp)r1rrrrs r2 cmd_CHGRPzStdioClient.cmd_CHGRP pJJtQ'' T&&t,, d#hh K  & & d'3 777r4c|dd\}}||\}}t|d}|j|d|i}|t |S)Nr+ permissions)r/rr<rsetAttrsrrr)r1rmodrrs r2 cmd_CHMODzStdioClient.cmd_CHMODspJJtQ'' T&&t,, d#qkk K  s'; < < gr4c|dd\}}||\}}t|}|j|}||j|||S)Nr+)usrr)r1rrrrs r2 cmd_CHOWNzStdioClient.cmd_CHOWNrr4ci}|dur|p|d|d<|dur|p|d|d<|j||}|t|S)Nuidgid)rrrrr)r1attrsrrrnewrs r2rzStdioClient._cbSetUsrGrp"sko.3>%,E o.3>%,E K s + + gr4c||\}}d|vsd|vrp|r:||\}}tj|sdSnd}||}||j||S|r||\}}n%tj|d}tj ||ft|dd}t|j  |}|j|jt ji}||j|||j||S)N*?z'Wildcard get with non-directory target.r4r+wbr)rrrisdir _remoteGlobr_cbGetMultipler/rropenrrchildropenFiler FXF_READ_cbGetOpenFilerh _ebCloseLf)r1rremotelocalrlfrs r2cmd_GETzStdioClient.cmd_GET*sn((..  &==C6MM "//55 tw}}U++EDDE  ((A MM$-u 5 5 5H  -++D11KE44GMM&))!,E    %q ! !-..44V<< K L,A2 F F d)2... T_b)))r4c0|d||Sr5)_cbGetMultipleNext)r1filesrs r2rzStdioClient._cbGetMultipleBs&&tUE:::r4ct|tjr||nA|r?|||ds|d|sdS|dd}ttj |tj |ddd}t|j |}|j|j t"ji}||j|||j|||j|||S)N rr+r)rrr\rrrpoprrrrr/rrrrrr rrrrhraddBothr)r1resrrrprrrs r2rzStdioClient._cbGetMultipleNextFsL c7? + + -   s # # # #  -  " "3 ' ' '<<%% -&&t,,,  F IIaLLO "',,ubgmmA&6&6q&9::D! D D-..44Q77 K L,A2 F F d)2... T_b))) $)5%888r4c.||Sr5)r)r1rprs r2rzStdioClient._ebCloseLfXs  r4c^||j||Sr5)rr_cbGetFileSize)r1rfrs r2rzStdioClient._cbGetOpenFile\s%{{}}(() HHJJJ HHJJJ3bg= =-[*/7 E k+08D L((** {##  ABFAz9MMA LLOOOO   : : : tB/// r4c\d}|D]a}|dkrdS||dkrB||}||||df||d|z fcS|d}bt|jjjjd}||||zf||fS)Nreofr+r)rHinsertr<rrrjr r)r1rendchunkrTbufSizes r2 _getNextChunkzStdioClient._getNextChunkrs  Ee||eAhLL'' a#uQx111U1X^,,,,(CCdk+08FGG sC'M*+++W~r4c |rt|tjritjd|z|}|t ||||zf} || =|| |dfn|rtjdt|z| || |t||krktjdt||fz||||zf} || =|| ||t|zf|xj t|z c_ |j r|||||} | sdS| \}} tjd||| zfz||| } | |j||||| || S)Nzget read err: %srzget read data: %iz#got less than we asked for: %i < %izasking for %i -> %i)rrr\rrrEOFErrorrHrlenrxrrwr_printProgressBarr! readChunkrr) r1datar rrstartrzrreasonrTrlengthrs r2rzStdioClient._cbGetReads  "JtW_55 " G&- . . .F KK ! ! ! eUT\233Aq MM!eU^ , , , ,  " G'#d))3 4 4 4 GGENNN HHTNNN4yyD  =TD@QQRRRLL%!6771I a%T):!;<<< HHD !HH   2  " "2y 1 1 1""6** " F!ME6 %(??@@@ LL ' ' $/2r65&)LLLr4ctjd|||jr|dd|jd|jS)Nzget doner Transferred  to )rrrrrrr1ignoredr rs r2rzStdioClient._cbGetDonese        )  " "4 ( ( (4bg4427444r4c||\}}d|vsd|vrl|r>||\}}tj|j|}nd}t j|}|||S|r||\}}n%tj|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} rrr(r+) rrrrrglob_putMultipleFilesr/_putSingleFile)r1rrrrs r2cmd_PUTzStdioClient.cmd_PUTs''-- t %<<3%<< #0066 d&;VDDIe$$E))%88 8 1#0066 u--a0&&uf55 5r4c6|d|g|dS)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)r1rrs r2r3zStdioClient._putSingleFiles#&&teWfT&JJJr4c0|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. Nr7)r1rrs r2r2zStdioClient._putMultipleFiless&&tUF;;;r4Fc<t|tjr||nk|rit|tr|d}|||ds|dd}|re|sc |d}t|d}n8#t$r+|tjd}YnwxYw|r|c|sdS|r|}n\tj |d}tj ||}tj|||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. rrNrrbr+)rrr\rr;rrrrrrZrrr/rrr_putRemoteFilerr8) r1previousResultrr)r6 currentFile localStreamrrrs r2r8zStdioClient._cbPutMultipleNexts( ngo 6 6 .   ~ . . . .  ..#.. @!/!6!6w!?!?  " "> 2 2 2!**511 .&&u---  #K # ##iill ";55   # # #""7?#4#4555"  #  #K # 4  0FF7==--a0DW\\*d33F GT6:. / / /    V 4 4 $)5*===s#%C 2C>=C>c@tj|j|}tjtjztjz}|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. )rrrrr FXF_WRITE FXF_CREAT FXF_TRUNCrrr_cbPutOpenFilerhr)r1r?r)rflagsrs r2r<zStdioClient._putRemoteFilesd3Z@@&)??,BXX K  3 3 d);777 T_k222r4c|jjjjd}|jrt |}g}g}|j}t|D]2}| d||||}|r| |3tj |d} | |j||| S)Nrr+r )rrrjr rrtrrr _cbPutWriterrrr _cbPutDone) r1r rrrrrrTrrs r2rDzStdioClient._cbPutOpenFile+sk+08D   !RBL((** {##  A  r2vyAAA  Q   : : : tB/// r4cr||}|\}}||||} |jr3|xjt | z c_|||| r6||| } | |j ||||| SdSr5) r!rxreadrrwr$r% writeChunkrrG) r1r/r rrrrr(rzr'rs r2rGzStdioClient._cbPutWrite:s""6** t wwt}}   2 HHD !HH  " "2y 1 1 1   eT**A MM$*BFI F F FH Fr4c|||jr|dd|jd|jS)Nrr,r-)rrrrr.s r2rHzStdioClient._cbPutDoneIsU      )  " "4 ( ( (4bg4427444r4c.tj|dSr5)rchdirrs r2cmd_LCDzStdioClient.cmd_LCDPs r4c|\}}|\}}tfd||f\}}j||t S)NcNtjj|Sr5rrrrxr1s r2z$StdioClient.cmd_LN..Wbgll4#8!<<r4)rmaprmakeLinkrrr)r1rlinkpath targetpaths` r2cmd_LNzStdioClient.cmd_LNSs**400$,,T22 D" < < < T  *{##Hj99EEgNNNr4c^g}|}|r|dr}|dddkrk|ddd}|D]/}|dkr|jd|dkr|jd0|r|dr|dddkkd|}||\}}|s |jd z}n%t j|j|}||}| |j ||S) Nrrr+rverboseaallrr,) r/rrrrrrrrr_cbDisplayFiles)r1rr optsorfullPathrs r2cmd_LSzStdioClient.cmd_LS[sI zz|| *tAw *471:#4#488A;;qrr?D * *88"GN9----#XX"GN5)))  *tAw *471:#4#4xx~~&&t,, d A,s2HHw||D$94@@H   X & & d*G444r4c|d|vr d|D}d|vr d|D}n d|D}|sdSd|S)Nr_cHg|]}|dd| S)r.)r.0rps r2 z/StdioClient._cbDisplayFiles..ws-CCC1QqT__T-B-BCQCCCr4r]cg|] }|d S)r+rBrhs r2rjz/StdioClient._cbDisplayFiles..y)))aQqT)))r4cg|] }|d SrrBrhs r2rjz/StdioClient._cbDisplayFiles..{rlr4r)sortr)r1rr liness r2r`zStdioClient._cbDisplayFilests   CCCCCE   ))5)))EE))5)))E %4::e$$ $r4c||\}}tj|j|}|j|itSr5) rrrrrr makeDirectoryrrrr1rrs r2 cmd_MKDIRzStdioClient.cmd_MKDIRsW&&t,, dw||D1488{((r22>>wGGGr4c||\}}tj|j|}|j|tSr5) rrrrrrremoveDirectoryrrrrss r2 cmd_RMDIRzStdioClient.cmd_RMDIRsU&&t,, dw||D1488{**400<.rVr4)rrWr renameFilerrr)r1roldpathnewpaths` r2 cmd_RENAMEzStdioClient.cmd_RENAMEs))$// ))$//  < < < P  {%%gw77CCGLLLr4cB|jjdSr5)rrrr1r/s r2cmd_EXITzStdioClient.cmd_EXITs ,,.....r4cxd|jjz}t|tr|d}|S)NzSFTP version %ir)rversionrr;r)r1r/rs r2 cmd_VERSIONzStdioClient.cmd_VERSIONs9#dk&99 gs # # .nnW--Gr4cdS)NaeAvailable 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'. rBrs r2rzStdioClient.cmd_HELPs r4c|jSr5rrs r2cmd_PWDzStdioClient.cmd_PWDs $$r4c(tjSr5)rgetcwdrs r2cmd_LPWDzStdioClient.cmd_LPWDsy{{r4c8|j |_d|jrdpdzS)Nz%ssing progess bar.UzNot u)rrs r2 cmd_PROGRESSzStdioClient.cmd_PROGRESSs("&"55$(;(C(NwOOr4c|jtjd}|sd}|rd|g}t j||dSt j|dS)zb Run C{rest} using the user's shell (or /bin/sh if they do not have one). z/bin/shz-cr+)errortooN)_pwdgetpwnamrcrdrgetProcessOutputrrz)r1rshellcmdss r2rzStdioClient.cmd_EXECsr  ""7?#4#455a8 E  $.s.$U$U$U11t9T9T$UQ$U$U$Ur4) rrr\rextendrJrrrr#r)r1r matchedFilesrr1rr)s ` r2rzStdioClient._cbReadFiles%11  +"t{7++##$U$U$U$U$U$U$UVVVV##E***  A IId& i F F FHF KK ! ! ! OO    r4c@gd}|D] \}}||krnd||z z|zS)N))l PB)lTB)i@GB)iMB)ikB)r+rz%.1frB)r1rz_abbrevsfactorsuffixs r2 _abbrevSizezStdioClient._abbrevSize sO   '  NFFf}}'&00r4c|dkr !sA;D2A#DD0r5)NN)F)Dr6r7r8pwdrr delimiterrr|rrrrrrrrrrrrrrrrrrrrrrr!rrr4r3r2r8r<rDrGrHrOr[rdr`rtrwr{r~rrrcmd_QUITrrrrrrrrrrrrr%rrBr4r2rrs D BIG1111 @@@))) ***(( + + + - - -  %%%0;;;$FFF&   <555666> K K K < < <3333j&      555OOO2 % % %HHH FFF %%%AAA """MMM///H 6%%%PPP    "     111 + + +((((((T#"#"#"#"#"r4rzcmd_?ceZdZdZdS)recH|tdSr5) openChannel SSHSessionrs r2serviceStartedzSSHConnection.serviceStartedzs  &&&&&r4N)r6r7r8rrBr4r2rereys#'''''r4recteZdZUdZeed<ejZeed<dZ dZ de dedd fd Z d Z d Zd ZdZdZd S)rssessionrrOcztjd|jz|jjddrd}nd}|j||tj|jjdd}| |j | tdS)Nzsession %s openr r,execr+) wantReply) rridrjr r sendRequestr NSr _cbSubsystemrhri)r1foorequestrs r2 channelOpenzSSHSession.channelOpens !DG+,,, 9 [ ) 4 4S 9 9 "GG!G I ! ! '69TY%6{%CDDPQ "   d'((( Wr4cZtj|_|j||jj|_d}|jjdr'|jjd}|dkrt|}tj t|j||_dS)Nrr) r FileTransferClientrmakeConnection dataReceivedrjr rr StandardIOr)r1rrpfns r2rzSSHSession._cbSubsystems"577  ""4((( K4  9 [ ) ";/BSyyHH%k$+q&A&ABB r4rr'returnNc|tjkrmtjdt |z|j|dd|jdSdS)Nzgot %s stderr datarbackslashreplace) r EXTENDED_DATA_STDERRrrr$rOrrflush)r1rr's r2 extReceivedzSSHSession.extReceivedsw / / / G(3t994 5 5 5l K  dkk'3EFF G G G K       q 0 /r4c`tjd|jdS)Nzgot eof)rrrloseWriteConnectionrs r2 eofReceivedzSSHSession.eofReceiveds,   &&(((((r4chtjd|z|j|dS)Nzremote side closed %s)rrrj sendClosers r2 closeReceivedzSSHSession.closeReceiveds4 '$./// D!!!!!r4cP tjdS#t$rYdSwxYwr5)rrYrZrs r2closedzSSHSession.closeds8  LNNNNN    DD s  %%c8|jdSr5)rpauseProducingrs r2 stopWritingzSSHSession.stopWritings !!#####r4c8|jdSr5)rresumeProducingrs r2 startWritingzSSHSession.startWritings ""$$$$$r4)r6r7r8rrr=rFrOrrrr<rrrrrrrBr4r2rr~sD%ZFF    C C C9 S9 9 $9 9 9 9 v)))""" $$$%%%%%r4r__main__)6__doc__rrrcr1rrr rrFrtypingrrrrtwisted.conch.clientrrr twisted.conch.sshr r r r twisted.internetrrrrtwisted.protocolsrtwisted.pythonrrrtwisted.python.filepathr ConchOptionsrrRr]rQrirrrt LineReceiverrsetattrrre SSHChannelrr6rBr4r2rs   000000000000::::::::::GGGGGGGGGGGG999999999999######..........,,,,,,&&&&&G(&&&D,   GGG&       %%%%%%%%f "f "f "f "f "%$f "f "f "R Wk2333'''''J,''' h%h%h%h%h%#h%h%h%V zCEEEEEr4