hSrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK r SSK J r J r JrJr SSKJrJrJr SSKJrJrJrJr SSKJrJrJrJr SSKJr SSK J!r!J"r"J#r# SS K$J%r% "S S \RL5r'S r(S r)Sr*Sr+Sr,"SS5r-"SS\R\5r/\0"\/S\/Rb5 "SS\Rd5r2"SS\Rf5r4\5S:Xa\("5 gg)z0 Implementation module for the I{cftp} command. N)ListOptionalTextIOUnion)connectdefaultoptions)channelcommon connection filetransfer)deferreactorstdioutils)basic)failurelogusage)FilePathc\rSrSr%SrSr/SQ/SQ/SQ/SQ/r\\\\ \ \ 4\ S'\ R"S S 0\ R"5\ R "S S 9/S 9rSSjrSrg) 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 extraActionsNcSUS'SU;a+URSS5uoS'USRS5 XS'X S'g)N remotePath:/host localPath)splitrstrip)selfr.r/s a/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/conch/scripts/cftp.py parseArgsClientOptions.parseArgs5sM\ $;'+zz#q'9 $D|$   % %c *V %[N)__name__ __module__ __qualname____firstlineno__synopsislongdescr$rrrstrint__annotations__r CompletionsCompleteUserAtHost CompleteFilescompDatar4__static_attributes__r7r6r3rrsH  B WQVM <M4XeCHo678  "$RS  $ $ &   l 3 H&r6rcB[RSSnSU;a%URS5nXUS-U-nXS-US-2 [5nUR"U5 US(a@[Rn[R"[R5 U[l O[R"5 [U5 [R "5 g![ R a.n[SU-5 [R"S5 SnANSnAff=f)Nr,z-lz ERROR: %sr)sysargvindexr parseOptionsr UsageErrorprintexitstdoutr startLoggingstderr discardLogs doConnectrrun)argsir urealouts r3rVrV>s 88ABS:r?S;r@S<rAS=rBS>rCS?rDS@rEg)D StdioClientzcftp>  NcfXlSUlX lU(+=(a S=(d SUlg)Nr)r,r)clientcurrentDirectoryfileuseProgressBar)r2rrts r3rStdioClient.__init__s' " #$u{0qr6clURRS5RUR5 g)Nr))rrealPath addCallback _cbSetCurDirr2s r3connectionMadeStdioClient.connectionMades% R ,,T->->?r6c0XlUR5 gr8)r_newLiner2paths r3rStdioClient._cbSetCurDirs $ r6c[U[5(aURS5nURR U5$)Nutf-8) isinstancer?encode transportwrite)r2msgs r3_writeToTransportStdioClient._writeToTransports2 c3  **W%C~~##C((r6c*URRR(ag[U[5(aUR S5n[ R"SU-5 UR5nU(dUR5 gUR(a#URS5(a SUl USSnOSUl URU5nUb7URUR5 UR!UR"5 gg)Nrz got line %s-r,r)rr localClosedrbytesdecoderrlstriprr startswith ignoreErrors_dispatchCommandr _cbCommandrl _ebCommand)r2lineds r3 lineReceivedStdioClient.lineReceiveds ;; , ,  dE " ";;w'D  $%{{} MMO  99-- !D 8D !D   ! !$ ' = MM$// * LL ) r6cSU;a%URSS5up#UR5nOUSp2URS5(a&URnUSSS-U-R 5nO9UR 5n[ R"SU-5 [USU-S5nUb[R"XC5$SU-nUR[R"[U555 UR5 g)N r,r)!zlooking up cmd %szcmd_%szNo command called `%s')r0rrcmd_EXECstripupperrrrr maybeDeferredrrr`NotImplementedErrorr)r2rcommandrestrterrMsgs r3rStdioClient._dispatchCommands $; JJsA.MG;;=D "T   c " " AABK#%,335DmmoG GG''1 2h0$7A =&&q/ /-9F OOGOO,?,GH I MMOr6c.[R"U5 UR[[R [ [5nU[:Xa!URURS55 gU[R :XaASURRURR4-nURU5 gU[ [4;aASURRURR4-nURU5 gg)Nr)zremote error %i: %s zlocal error %i: %s )rrtraprr SFTPErrorOSErrorIOErrorrcmd_HELPrrcodemessageerrnostrerror)r2rters r3 _printFailureStdioClient._printFailures  FF& (>(> Q # #  " "4==#4 5 ,(( (, aggoo/NNF  " "6 * 7G$ $+qww}}agg>N>N.OOF  " "6 *%r6cURRR(agURUR5 SUlUR (awUR R5nU(d%URRR5 gURU5 URUR55 gg)Nr) rrrrpsrrreadlineloseConnectionrr)r2ls r3rStdioClient._newLines ;; , ,  tww' 99 ""$A %%446&&q)!!!''), r6cUb^[U[5(aURS5nURU5 UR S5(dURS5 UR 5 g)Nrr)rr?rrendswithr)r2results r3rStdioClient._cbCommandsW  &#&&w/  " "6 *??5))&&u- r6cURU5 UR(a5UR(d$URRR 5 UR 5 gr8)rrrrrrrrs r3rStdioClient._ebCommands> 1 99T.. KK ! ! 0 0 2 r6c|URU5upURS5(dUS- nU=(a* [RR UR U5=(d SnUR RU5nURUR5 URUR5 U$)Nr-r)) _getFilenamerosrjoinrr openDirectoryr_cbCdrlr)r2rrnewPathrs r3cmd_CDStdioClient.cmd_CDs&&t, }}S!! CKDD277<<(=(=tDJ KK % %g . djj! T__%r6cUR5 URRUR5nUR UR 5 U$r8)closerrnamer _cbCurDir)r2 directoryrs r3rStdioClient._cbCds9 KK  0 dnn%r6cXlgr8rrs r3rStdioClient._cbCurDirs $r6cURSS5up!URU5up1[U5nURR U5nUR UR X2S9 U$)Nr,)grpr0rr@rgetAttrsr _cbSetUsrGrp)r2rrrrs r3 cmd_CHGRPStdioClient.cmd_CHGRP ^JJtQ' &&t, #h KK  & d'' 7r6cURSS5up!URU5up1[US5nURR USU05nUR [ 5 U$)Nr, permissions)r0rr@rsetAttrsrrv)r2rmodrrs r3 cmd_CHMODStdioClient.cmd_CHMODs]JJtQ' &&t, #qk KK  s'; < gr6cURSS5up!URU5up1[U5nURR U5nUR UR X2S9 U$)Nr,)usrr)r2rrrrs r3 cmd_CHOWNStdioClient.cmd_CHOWNrr6c0nUSL=(a U=(d USUS'USL=(a U=(d USUS'URRX%5nUR[5 U$)Nuidgid)rrrrv)r2attrsrrrnewrs r3rStdioClient._cbSetUsrGrp"sbo.3>%,E o.3>%,E KK  + gr6c URU5up!SU;dSU;aqU(a9URU5up1[RRU5(dgOSnUR U5nUR UR U5 U$U(aURU5up1O"[RRU5Sn[R"X#45 [USS5n[UR5RU5nURRUR[ R"05nUR UR$U5 UR'UR(U5 U$)N*?z'Wildcard get with non-directory target.r6r,wbr)rrrisdir _remoteGlobr_cbGetMultipler0rropenrrchildropenFiler FXF_READ_cbGetOpenFilerl _ebCloseLf)r2rremotelocalrlfrs r3cmd_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)r6c&URSX5$r8)_cbGetMultipleNext)r2filesrs r3r StdioClient._cbGetMultipleBs&&tU::r6c[U[R5(aURU5 O?U(a8UR U5 UR S5(dUR S5 U(dgUR S5Sn[[RRU[RRU5S5SS5n[UR5RU5nURR!UR["R$05nUR'UR(U5 UR+UR,U5 UR/UR0X#5 U$)N rr,r )rrr`rrrpopr rrrr0rrrrrr rrrrlraddBothr)r2resrrrtrrrs r3rStdioClient._cbGetMultipleNextFs c7?? + +   s #   " "3 '<<%%&&t,  IIaLO "'',,ubggmmA&6q&9:D! D--.44Q7 KK L,A,A2 F d))2. T__b) $))58r6c&UR5 U$r8)r)r2rtrs r3rStdioClient._ebCloseLfXs  r6cVUR5RURX5$r8)rr_cbGetFileSize)r2rfrs r3rStdioClient._cbGetOpenFile\s!{{}(()<) %i)rrr`rrrEOFErrorrLr<lenr}rr|r_printProgressBarr@ readChunkrr/) r2datar&rr6startrr7reasonrXr>lengthrs r3r/StdioClient._cbGetReadst 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&Lr6c[R"S5 UR5 UR5 UR(aUR S5 SUR SUR 3$)Nzget doner Transferred  to )rrrrrrr2ignoredr&rs r3r2StdioClient._cbGetDonesR          " "4 (bggYd277)44r6cURU5up!SU;dSU;anU(a>URU5up1[RRURU5nOSn[ R "U5nUR XC5$U(aURU5up1O"[RRU5SnURX#5$)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} rrr)r,) rrrrrglob_putMultipleFilesr0_putSingleFile)r2rrrrs r3cmd_PUTStdioClient.cmd_PUTs''-  %<3%<#006 d&;&;VDIIe$E))%8 8#006 u-a0&&u5 5r6c(URSU/USS9$)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)r2rrs r3rUStdioClient._putSingleFiles &&teWfT&JJr6c&URSX5$)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. NrZ)r2rrs r3rTStdioClient._putMultipleFiless&&tU;;r6cL[U[R5(aURU5 OeU(a^[U[5(aUR S5nUR U5 URS5(dUR S5 SnU(a5U(d.URS5n[US5nU(a U(dM.U(dgU(aUnOY[RRU5Sn[RRX85n[R "XU45 UR#WU5n U R%UR&X#5 U $![a) UR[R"55 SnNf=f)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?rrrrr r^rrr0rrr_putRemoteFilerr[) r2previousResultrr*rY currentFile localStreamrrrs r3r[StdioClient._cbPutMultipleNextsA( ngoo 6 6   ~ . .#..!/!6!6w!?  " "> 2!**511&&u- K ##iil ";5 KK F77==-a0DWW\\*3F GGT:. /    V 4 $))5=#! #""7??#45"  #s(E000F#"F#cf[RRURU5n[R [R -[R-nURRX405nURURU5 URURU5 U$)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_cbPutOpenFilerlr)r2rdr*rflagsrs r3raStdioClient._putRemoteFilesd33Z@&&)?)??,BXBXX KK  3 d));7 T__k2r6cURRRRSnUR(a [ U5n/n/nUR R5n[U5H0nURSXXV5nU(dMURU5 M2 [R"USS9n U RURX5 U $)Nrr,r))rrrnr rrxrr-r. _cbPutWriter0rr1r _cbPutDone) r2r&rr4r5r6r7rXrr8s r3rjStdioClient._cbPutOpenFile+skk++0088D   RBLL((* {#A  rvAAq Q$   : t/ r6c`URU5nUupxURU5 URU5n UR(a/U=R[ U 5- slUR X55 U (a0URXy5n U RURX#XE5 U $gr8) r@r}readrr|rDrE writeChunkrrn) r2rPr&rr6r7r>rHrrGrs r3rnStdioClient._cbPutWrite:s""6*  wwt}    HHD !H  " "2 1  e*A MM$**BF FH r6cUR5 UR5 UR(aURS5 SURSUR3$)NrrMrN)rrrrrOs r3roStdioClient._cbPutDoneIsF        " "4 (bggYd277)44r6c0[R"U5 gr8)rchdirrs r3cmd_LCDStdioClient.cmd_LCDPs  r6c^TRU5up!TRU5up1[U4SjX#45up#TRRX#5R [ 5$)NcX>[RRTRU5$r8rrrrxr2s r3$StdioClient.cmd_LN..Wbggll4#8#8!T {{##H9EEgNNr6ch/nUR5nU(aUS(a|USSS:XapURS5SSnUH7nUS:XaUR"S5 MUS:XdM%UR"S5 M9 U(aUS(aUSSS:XaMpSRU5nUR U5upQU(dUR S -nO*[ RRUR U5nURU5nURURU5 U$) Nrrr,rverboseaallrr-) r0rr0rrrrrr r_cbDisplayFiles)r2rr optsorfullPathrs r3cmd_LSStdioClient.cmd_LS[s zz|tAw471:#488A;qr?D8NN9-#XNN5) tAw471:#4xx~&&t, ,,s2Hww||D$9$94@H   X & d**G4r6c4UR5 SU;a,UVs/sHo3SRS5(aMUPM! nnSU;aUVs/sHo3SPM nnOUVs/sHo3SPM nnU(dgSRU5$s snfs snfs snf)Nrr.rr,r)sortrr)r2rr rtliness r3rStdioClient._cbDisplayFilests   %C1qT__T-BQEC  #()5aqT5E)E#()5aqT5E)::e$ $D))sB B  B"BcURU5up[RRURU5nUR R U05R[5$r8) rrrrrr makeDirectoryrrvr2rrs r3 cmd_MKDIRStdioClient.cmd_MKDIRsP&&t, ww||D1148{{((r2>>wGGr6cURU5up[RRURU5nUR R U5R[5$r8) rrrrrrremoveDirectoryrrvrs r3 cmd_RMDIRStdioClient.cmd_RMDIRsN&&t, ww||D1148{{**40<[RRTRU5$r8r}r~s r3r(StdioClient.cmd_RENAME..rr6)rrr renameFilerrv)r2roldpathnewpaths` r3 cmd_RENAMEStdioClient.cmd_RENAMEs^))$/ ))$/  P {{%%g7CCGLLr6cLURRR5 gr8)rrrr2rPs r3cmd_EXITStdioClient.cmd_EXITs ,,.r6cSURR-n[U[5(aUR S5nU$)NzSFTP version %ir)rversionrr?r)r2rPrs r3 cmd_VERSIONStdioClient.cmd_VERSIONs6#dkk&9&99 gs # #nnW-Gr6cg)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'. r7rs r3rStdioClient.cmd_HELPsr6cUR$r8rrs r3cmd_PWDStdioClient.cmd_PWDs$$$r6c,[R"5$r8)rgetcwdrs r3cmd_LPWDStdioClient.cmd_LPWDsyy{r6cpUR(+UlSUR=(a S=(d S-$)Nz%ssing progess bar.UzNot u)rrs r3 cmd_PROGRESSStdioClient.cmd_PROGRESSs."&"5"55$(;(;(C(NwOOr6cURR[R"55SnU(dSnU(aSU/n[R "X#SS9$[ R"U5 g)zJ Run C{rest} using the user's shell (or /bin/sh if they do not have one). z/bin/shz-cr,)errortooN)_pwdgetpwnamrgrhrgetProcessOutputrr)r2rshellcmdss r3rStdioClient.cmd_EXECsW  ""7??#45a8E $ !  7 !566 7sAD A D D)rrrrrr8)NN)F)Fr9r:r;r<pwdrr delimiterrrrrrrrrrrrrrrrrrrrr rrrr%r@r/r2rVrUrTr[rarjrnroryrrrrrrrrrrcmd_QUITrrrrrrr rrrrrrErrFr7r6r3rrsO D BIG1 @) *(( + -  %0;$F& <56> K <3j&  5O2 %H F %A "M/H 6%P  "   1 +((T#"r6rzcmd_?c\rSrSrSrSrg)riiyc6UR[55 gr8) openChannel SSHSessionrs r3serviceStartedSSHConnection.serviceStartedzs &r6r7N)r9r:r;r<rrFr7r6r3ririys'r6ric\rSrSr%Sr\\S'\Rr\ \S'Sr Sr S\ S\S S 4S jr S rS rSrSrSrSrg )ri~ssessionrrSc[R"SUR-5 URRSR S5(aSnOSnURR X[R"URRS5SS9nURUR5 UR[5 g)Nzsession %s openr!r-execr,) wantReply) rridrnr r sendRequestr NSr _cbSubsystemrlrm)r2foorequestrs r3 channelOpenSSHSession.channelOpens !DGG+, 99  [ ) 4 4S 9 9G!G II ! ! 699TYY%6%6{%CDPQ "  d''( Wr6c[R"5UlURRU5 URRUlSnUR R S(a*UR R SnUS:wa [U5n[R"[URU55Ulg)Nrr) r FileTransferClientrmakeConnection dataReceivedrnr r r StandardIOr)r2rrtfns r3r!SSHSession._cbSubsystems"557  ""4( KK44  99  [ )"";/BSyH%%k$++q&AB r6rrGreturnNcU[R:Xah[R"S[ U5-5 UR R URSS55 UR R5 gg)Nzgot %s stderr datarbackslashreplace) r EXTENDED_DATA_STDERRrrrDrSrrflush)r2rrGs r3 extReceivedSSHSession.extReceiveds] // / GG(3t94 5l KK  dkk'3EF G KK   q 0r6cd[R"S5 URR5 g)Nzgot eof)rrrloseWriteConnectionrs r3 eofReceivedSSHSession.eofReceiveds   &&(r6cl[R"SU-5 URRU5 g)Nzremote side closed %s)rrrn sendClosers r3 closeReceivedSSHSession.closeReceiveds& '$./ D!r6cP[R"5 g![a gf=fr8)rr]r^rs r3closedSSHSession.closeds"  LLN   s  %%c8URR5 gr8)rpauseProducingrs r3 stopWritingSSHSession.stopWritings !!#r6c8URR5 gr8)rresumeProducingrs r3 startWritingSSHSession.startWritings ""$r6)rr)r)r9r:r;r<rrrArJrSrr$r!r@r2r6r:r=rArErFr7r6r3rr~sYD%ZZFF  C9 S9 9 $9 v)" $%r6r__main__)6__doc__rrrgrSrrr+rrJrtypingrrrrtwisted.conch.clientrrr twisted.conch.sshr r r r twisted.internetrrrrtwisted.protocolsrtwisted.pythonrrrtwisted.python.filepathr ConchOptionsrrVrarUrmrvrx LineReceiverrsetattrrri SSHChannelrr9r7r6r3rTs   00::GG99#..,&G((&D, G&   %%f "%$$f "R Wk223'J,,' h%##h%V zEr6