hY SrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK J r J r SSKJr SSKJrJrJrJr SSKJrJrJrJrJr SSKJrJr SSKJrJ r J!r! S r"S r#S r$S r%S r&Sr'Sr(Sr)Sr*Sr+Sr,Sr-Sr.Sr/Sr0Sr1Sr2Sr3Sr4Sr5Sr6Sr7Sr8S r9S!r:S"r;S#rS&r?S'r@S(rAS)rBS*rCS+rDS,rES-rFS.rGS/rHS0rIS1rJS2rKS3rLS4rMS5rNS6rOS7rPS8rQS9rRS:rSS;rTSrWS?rXS@rYSArZSBr[SCr\SDr]SEr^0\"SF_\#SG_\$SH_\%SI_\&SJ_\'SK_\(SL_\)SM_\*SN_\+SO_\,SPSQ/_\-SR_\.SS_\/ST_\0SU_\2SV_\1SW_0\3SX_\4SY_\5SZ_\6S[_\7S\_\8S]_\9S^_\:S__\;S`_\Sc_\?Sd_\@Se_\ASf_\BSg_\CSh_E0\DSi_\ESj_\FSk_\GSl_\HSm_\ISn_\JSo_\KSp_\LSq_\MSr_\NSs_\OSt_\PSu_\QSv_\RSw_\SSx_\TSy_E\USz\VS{\WS|\XS}\ZS~\[S\YS\\S\]S\^S0 Er_Sr`Sra"SS\b5rcSrdSre\R"S5rgSSjrh"SS\b5ri"SS\i5rj"SS\i5rk"SS\i5rl"SS\i5rm"SS\i5rn"SS\i5ro"SS\i5rp"SS\i5rq"SS\i5rr"SS\i5rs"SS\i5rt"SS\b5ru"SS\b5rv"SS\i5rw"SS\i5rx"SS\i5rySrz/SQr{\ "\R5"SS\R55r~"SS\R5r"SS5r\ "\R5"SS55r"SS\GR5r"SS\GR\GR 5r"SS\GR5r"SS\ 5r"SS\ 5r"SS\ 5rSrSSjr\ "\5"SS55r\ "\5"SS55r"SS\5r\ "\5"SS55r\ "\GR$5"SS55r"SS\5r"SS\5r"SS\u5r"SS\u5r"SS\u5r"SS\u5r"SS\u5r"SS5r"SS\R5r"SS\R5r\ "\5"SS\R55rSrSrSrSr"SS\GRF5r"SS\GR5r"SS\R5r"SS\5r"SS\GR5rSrg!\ a S=r rGNf=f)z An FTP protocol implementation N) Interface implementer) copyright)checkers credentialserrorportal)deferr interfacesprotocolreactor)basicpolicies)failurefilepathlog100120125150z200.1z200.2z200.3z200.4202z211.1z211.2212213214215z220.1z220.2z221.1z221.2225z226.1z226.2227229z230.1z230.2250z257.1z257.2z331.1z331.2332350z421.1z421.2425426450451452500501z502.1z502.2z502.3503504522z530.1z530.2532z550.1z550.2z550.3z550.4z550.5z550.6z550.7551552553z110 MARK yyyy-mmmmz120 service ready in %s minutesz3125 Data connection already open, starting transferz4150 File status okay; about to open data connection.z200 Command OKz200 Type set to %s.z 200 PORT OKz200 EPSV ALL OKz5202 Command not implemented, superfluous at this sitez211 System status replyz 211-Features:z211 Endz212 %sz213 %sz 214 help: %sz215 UNIX Type: L8z220 %sz220 Service readyz&221 Service closing control connectionz 221 Goodbye.z1225 data connection open, no transfer in progressz226 Abort successfulz226 Transfer Complete.z227 Entering Passive Mode (%s).z,229 Entering Extended Passive Mode (|||%s|).z230 User logged in, proceedz2230 Anonymous login ok, access restrictions apply.z&250 Requested File Action Completed OKz257 "%s"z257 "%s" createdz331 Password required for %s.z8331 Guest login ok, type your email address as password.z332 Need account for login.z6350 Requested file action pending further information.z6421 Service not available, closing control connection.z9421 Too many users right now, try again in a few minutes.z425 Can't open data connection.z.426 Transfer aborted. Data connection closed.z/450 Requested action aborted. File unavailable.z8451 Requested action aborted. Local error in processing.z3452 Requested action aborted. Insufficient storage.z500 Syntax error: %sz#501 syntax error in argument(s) %s.z 502 Command '%s' not implementedz 502 Option '%s' not implemented.z3502 PASV available only for IPv4 (use EPSV instead)z&503 Incorrect sequence of commands: %sz'504 Not implemented for parameter '%s'.z,522 Network protocol not supported, use (%s)z$530 Please login with USER and PASS.z!530 Sorry, Authentication failed.z%532 Need an account for storing filesz"550 %s: No such file or directory.z550 %s: Permission denied.z:550 Anonymous users are forbidden to change the filesystemz%550 Cannot rmd, %s is not a directoryz550 %s: File existsz550 %s: is a directoryz"550 Requested action not taken: %sz551 Page type unknownzC552 Requested file action aborted, exceeded file storage allocationz5553 Requested action not taken, file name not allowedc\rSrSrSrSrg) InvalidPathzD Internal exception used to signify an error during parsing a path. N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r5\/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/protocols/ftp.pyr3r3sr<r3c2URS5(a/nOUSSnURS5HcnUS:XdUS:XaMUS:Xa$U(aUR5 M0[X5eSU;dSU;a [X5eUR U5 Me U$)zb Normalize a path, as represented by a list of strings each representing one segment of the path. /N...) startswithsplitpopr3append)cwdpathsegsss r= toSegmentsrLs  s1v ZZ_ 8qBw  $Y !#,, QY#(c( ( KKN Kr<cRU[R:Xa[R"[ U55$U[R :XdU[R :Xa[R"[U55$U[R:Xa[R"[U55$U[R:Xa[R"[U55$U[R:Xa[R"[U55$[R"5$)z7 Map C{OSError} and C{IOError} to standard FTP errors. )errnoENOENTr failFileNotFoundErrorEACCESEPERMPermissionDeniedErrorENOTDIRIsNotADirectoryErrorEEXISTFileExistsErrorEISDIRIsADirectoryError)erIs r=errnoToFailurer\s ELLzz+D122 ell a5;;.zz/566 emm zz.t455 ell zz/$/00 ell zz+D122zz|r<TESTcU(dgUSn[R"U5n[RSUS5nX2:Xagg)a} Helper for checking if a FTPShell `segments` contains a wildcard Unix expression. Only filename globbing is supported. This means that wildcards can only be presents in the last element of `segments`. @type segments: C{list} @param segments: List of path elements as used by the FTP server protocol. @rtype: Boolean @return: True if `segments` contains a globbing expression. Fr]r0T)fnmatch translate_testTranslationreplace)segments globCandidateglobTranslationsnonGlobTranslationss r=_isGlobbingExpressionrhsG RLM((7*226=!L.r<c$\rSrSrSrSrSrSrg) FTPCmdErroriz% Generic exception for FTP commands. c>[R"U/UQ76 XlgN) Exception__init__ errorMessage)selfmsgs r=rnFTPCmdError.__init__ s4&#&r<cB[URUR-$)z1 Generate a FTP response message for this error. )RESPONSE errorCoderorps r=responseFTPCmdError.response$s'$*;*;;;r<)roN)r6r7r8r9r:rnrwr;r5r<r=rjrjs  Raised when an unimplemented command is given to the server. r5N)r6r7r8r9r:CMD_NOT_IMPLMNTDrur;r5r<r=rrns!Ir<rc\rSrSrSr\rSrg)CmdNotImplementedForArgErrorivzY Raised when the handling of a parameter for a command is not implemented by the server. r5N)r6r7r8r9r:CMD_NOT_IMPLMNTD_FOR_PARAMrur;r5r<r=rrvs +Ir<rc\rSrSrSr\rSrg)PASVIPv6NotImplementedErroriz% Raised when PASV is used with IPv6. r5N)r6r7r8r9r:PASV_IPV6_NOT_IMPLEMENTEDrur;r5r<r=rrs*Ir<rc\rSrSrSrg)FTPErrorir5Nr6r7r8r9r;r5r<r=rrr<rc\rSrSrSrg)PortConnectionErrorir5Nrr5r<r=rrrr<rc\rSrSrSr\rSrg)BadCmdSequenceErrorizK Raised when a client sends a series of commands in an illogical sequence. r5N)r6r7r8r9r: BAD_CMD_SEQrur;r5r<r=rrrr<rc\rSrSrSr\rSrg)AuthorizationErroriz* Raised when client authentication fails. r5N)r6r7r8r9r: AUTH_FAILURErur;r5r<r=rrrr<rc\rSrSrSr\rSrg)UnsupportedNetworkProtocolErrorizB Raised when the client requests an unsupported network protocol. r5N)r6r7r8r9r:UNSUPPORTED_NETWORK_PROTOCOLrur;r5r<r=rrs-Ir<rcF[R"S[U5-SS9 g)NzdebugDeferred(): %sTdebug)rrqstr)rp_s r= debugDeferredrsGG !CF *$7r<) NJanFebMarAprMayJunJulAugSepOctNovDecc\rSrSrSrSrSrSrSrSr Sr Sr Sr S r S rS rS rS rSrSrSrSrSrSrSrg)DTPiFNlatin-1cjSUlURRRS5 /UlgNT) isConnectedfactorydeferredcallback_bufferrvs r=connectionMadeDTP.connectionMades) &&t, r<cdSUlURbURRS5 ggNF)r _onConnLostrrpreasons r=connectionLostDTP.connectionLosts/     '    % %d + (r<c@URRUS-5 g)zV Send a line to data channel. @param line: The line to be sent. @type line: L{bytes} s N transportwriterplines r=sendLine DTP.sendLines TG^,r<c Sn Sn U U=(a S=(d SUR5UUSSUSSUU "[R"U55S.-RUR5n X-$)a Helper method to format one entry's info into a text entry like: 'drwxrwxrwx 0 user group 0 Jan 01 1970 filename.txt' @param name: C{bytes} name of the entry (file or directory or link) @param size: C{int} size of the entry @param directory: evals to C{bool} - whether the entry is a directory @param permissions: L{twisted.python.filepath.Permissions} object representing that entry's permissions @param hardlinks: C{int} number of hardlinks @param modified: C{float} - entry's last modified time in seconds since the epoch @param owner: C{str} username of the owner @param group: C{str} group name of the owner @return: C{str} in the requisite format c[R"5n[URURUR UR URS.nUR UR :waSU-$SU-$)N)monthdayyearhourminutez%(month)s %(day)02d %(year)5dz+%(month)s %(day)02d %(hour)02d:%(minute)02d)timegmtime_monthstm_montm_mdaytm_yeartm_hourtm_min)mtimenowinfos r= formatDate.DTP._formatOneListResponse..formatDatesd++-C .}}  ,, D{{emm+6==DtKKr<zY%(directory)s%(permissions)s%(hardlinks)4d %(owner)-9s %(group)-9s %(size)15d %(date)12s d-N) directory permissions hardlinksownergroupsizedate) shorthandrrencode _encoding) rpnamerrrrmodifiedrrrformatrqs r=_formatOneListResponseDTP._formatOneListResponses* L =  &.35#*446&rr"4;;x#89  &  zr<cHURUR"U/UQ765 grl)rr)rprrws r=sendListResponseDTP.sendListResponses d11$BBCr<c8URRX5$rlrregisterProducerrpproducer streamings r=rDTP.registerProducers~~..xCCr<clURR5 URR5 grl)runregisterProducerloseConnectionrvs r=rDTP.unregisterProducers" ))+ %%'r<cpUR(aURRU5$[S5e)NzCrap damn crap damn crap damn)rrrrmrpdatas r=r DTP.writes,   >>''- -788r<cURRU5 g![a URR 5 gf=frl)_consr BaseExceptionrerrbackrpbytess r= _conswriteDTP._conswrite"s: ' JJ  U # '    $ $ & 's$AAcxURbURU5 gURRU5 grl)r rrrGrs r= dataReceivedDTP.dataReceived(s* :: ! OOE " LL   &r<cLURR5 SUlU?U$rl)r rrrpignoreds r=_unregConsumerDTP._unregConsumer.s$ %%'  r<cURbeXlURRUS5 URHnURU5 M SUlUR(a9[ R "5=UlnURUR5 U$URR5 SUl[ R"S5$r) r rrrrr DeferredraddBothrrsucceed)rpconschunkrs r=registerConsumerDTP.registerConsumer4szz!!!  ##D$/\\E OOE ""   #(>>#3 3D q IId)) *H JJ ) ) +DJ==& &r<c8URR5 grl)rresumeProducingrvs r=r$DTP.resumeProducingDs &&(r<c8URR5 grl)rpauseProducingrvs r=r'DTP.pauseProducingG %%'r<c8URR5 grl)r stopProducingrvs r=r+DTP.stopProducingJs $$&r<)rr rr)r6r7r8r9rr rrrrrrrrrrrrrrr!r$r'r+r;r5r<r=rrsiK EKGI , -4lDD(9 ' '  ' )('r<rcx\rSrSrSr\"5r\"5r\"5r\r Sr S Sjr Sr Sr SrS rS rS rS rg) DTPFactoryiNa Client factory for I{data transfer process} protocols. @ivar peerCheck: perform checks to make sure the ftp-pi's peer is the same as the dtp's @ivar pi: a reference to this factory's protocol interpreter @ivar _state: Indicates the current state of the DTPFactory. Initially, this is L{_IN_PROGRESS}. If the connection fails or times out, it is L{_FAILED}. If the connection succeeds before the timeout, it is L{_FINISHED}. @cvar _IN_PROGRESS: Token to signal that connection is active. @type _IN_PROGRESS: L{object}. @cvar _FAILED: Token to signal that connection has failed. @type _FAILED: L{object}. @cvar _FINISHED: Token to signal that connection was successfully closed. @type _FINISHED: L{object}. FNc|XlX l[R"5UlSUlUcSSKJn X0lg)z Constructor @param pi: this factory's protocol interpreter @param peerHost: if peerCheck is True, this is the tuple that the generated instance will use to perform security checks Nrr ) pipeerHostr rr delayedCalltwisted.internetr _reactor)rpr1r2r s r=rnDTPFactory.__init__os1 (  ? 0 r<c[R"SSS9 URURLagURUlUR 5 [ 5nXlURUlX Rl U$)NzDTPFactory.buildProtocolTr) rrq_state _IN_PROGRESS _FINISHED cancelTimeoutrrr1 dtpInstancerpaddrps r= buildProtocolDTPFactory.buildProtocolsc *$7 ;;d// /nn   E wwr<cN[R"SSS9 UR5 g)NzdtpFactory.stopFactoryTr)rrqr;rvs r= stopFactoryDTPFactory.stopFactorys (5 r<c[R"S5 URURLagURUlUR nSUlUR [[R"S555 g)Nz$timed out waiting for DTP connectionzDTPFactory timeout) rrqr8r9_FAILEDrrrr TimeoutError)rprs r=timeoutFactoryDTPFactory.timeoutFactorys] 67 ;;d// / ll MM  %e&8&89M&NOPr<cURbPURR5(a0[R"SSS9 URR 5 ggg)Nzcancelling DTP timeoutTr)r3activerrqcancelrvs r=r;DTPFactory.cancelTimeoutsL    'D,<,<,C,C,E,E GG,D 9    # # %-F 'r<c[R"SU-5 URRXR5Ulg)Nz'DTPFactory.setTimeout set to %s seconds)rrqr5 callLaterrHr3)rpsecondss r= setTimeoutDTPFactory.setTimeouts1 9GCD==227S0r?S1r@S2rAS3rBS4rCS5rDS6rES7rFS8rGU=rH$):FTPia  Protocol Interpreter for the File Transfer Protocol @ivar state: The current server state. One of L{UNAUTH}, L{INAUTH}, L{AUTHED}, L{RENAMING}. @ivar shell: The connected avatar @ivar binary: The transfer mode. If false, ASCII. @ivar dtpFactory: Generates a single DTP for this session @ivar dtpPort: Port returned from listenTCP @ivar listenFactory: A callable with the signature of L{twisted.internet.interfaces.IReactorTCP.listenTCP} which will be used to create Ports for passive connections (mainly for testing). @ivar _epsvAll: If true, "EPSV ALL" was received from the client, requiring the server to reject all data connection setup commands other than EPSV. See RFC 2428. @ivar _supportedNetworkProtocols: A collection of network protocol numbers supported by the EPRT and EPSV commands. @ivar passivePortRange: iterator used as source of passive port numbers. @type passivePortRange: C{iterator} @cvar UNAUTH: Command channel is not yet authenticated. @type UNAUTH: L{int} @cvar INAUTH: Command channel is in the process of being authenticated. @type INAUTH: L{int} @cvar AUTHED: Command channel was successfully authenticated. @type AUTHED: L{int} @cvar RENAMING: Command channel is between the renaming command sequence. @type RENAMING: L{int} F NTFEATQUIT)ryMDTMPASVSIZEzTYPE A;Irr0rc>[UU-nURU5 grl)rtr)rpkeyargsrqs r=reply FTP.reply ssmd" cr<c>[U[5(aURUR5n[TU]U5 g)zI (Private) Encodes and sends a line @param line: L{bytes} or L{unicode} N) isinstancerrrsuperr)rpr __class__s r=r FTP.sendLine$s1 dC ;;t~~.D r<cURUlURUR5 UR [ UR R5 grl)UNAUTHstaterQtimeOutr WELCOME_MSGrwelcomeMessagervs r=rFTP.connectionMade.s5[[   % ; ; ;->-J JJ     r<c8URR5 grlrrrvs r=timeoutConnectionFTP.timeoutConnection@r)r<c^^ TR5 TR5 URTR5nU U4SjnU4SjnU4SjnUR S5nUS:waUSUm XS-S4nOUm Sn[ R "TRT /UQ76nURX25 UR[R5 SS K J n UR"SURU5 g) Nc>^TR[5(a*TRTRR 55 gTR[ 5(a4[ U4SjS55(aTR[TS35 g[R"S5 [R"T5 TR[S5 g)Nc3\># UH!nUTRRS;v M# g7f)rN)valuer).0rqerrs r= :FTP.lineReceived..processFailed..Ks*.LCsyy~~a((Ls),)z takes exactlyzrequired positional argumentz requires an argument.zUnexpected FTP errorzinternal server error) checkrjrrrw TypeErroranyrrrrqrREQ_ACTN_NOT_TAKEN)rcmdrps`r= processFailed'FTP.lineReceived..processFailedHsyy%% cii00239%%#.L.++ :#.D'EF./  -/FGr<cz>[U[5(aTR"U6 gUbTRU5 ggrl)rtuplerresultrps r=processSucceeded*FTP.lineReceived..processSucceededUs3&%(( F## 6"$r<cJ>TR(dTR5 ggrl) disconnectedr$)rrps r=allDone!FTP.lineReceived..allDone[s$$$$&%r< r_r0r5rr0) resetTimeoutr'decoderfindr maybeDeferredprocessCommand addCallbacks addErrbackrrr4r rOr) rprrrr spaceIndexrrr rs ` @r= lineReceivedFTP.lineReceivedCs  {{4>>* H #  'YYs^  { #Ca)*,DCD    3 3S @4 @ '7 SWW -!QYY0r<c ^^UU4SjnUR5nUTR;aU"U5$TRTR:Xa)US:XaTR"T6$US:Xa[ S4$[ $TRTR:XaUS:XaTR"T6$[ S4$TRTR:XaU"U5$TRTR:XaUS:XaTR"T6$[ S4$g)Ncr>[TSU-S5nUbU"T6$[R"[U55$)Nftp_)getattrr rPr)commandmethodparamsrps r=call_ftp_command,FTP.processCommand..call_ftp_commandrs;T6G#3T:F!v&::4W=> >r<USERPASSzUSER required before PASSzPASS required after USERRNTOzRNTO required after RNFR) upperPUBLIC_COMMANDSrrftp_USERr NOT_LOGGED_ININAUTHftp_PASSAUTHEDRENAMINGftp_RNTO)rprrrs` ` r=rFTP.processCommandqs ? iik $&& &#C( ( ZZ4;; &f}}}f--"$???$$ ZZ4;; &f}}}f--"$>>> ZZ4;; &#C( ( ZZ4== (f}}}f--"$>>> )r<cURHnURX1US9nUs $ [R"SWSUR35e![Ra MVf=f)aN Return a port for passive access, using C{self.passivePortRange} attribute. @param factory: the protocol factory to connect to the port. @type factory: L{twisted.internet.protocol.ServerFactory} @param interface: the local IPv4 or IPv6 address to which to bind; defaults to "", i.e. all IPv4 addresses. @type interface: C{str}  interfacerAzNo port available in range )passivePortRange listenFactoryrCannotListenError)rprrportndtpPorts r= getDTPPortFTP.getDTPPortsz**E ,,Uy,Q +%% 4T5J5J4KL  **  sA  A$#A$cU(d[R"[S55$XlURUlUR R(a*URUR R:Xa[$[U4$)zK First part of login. Get the username the peer wants to authenticate as. zUSER requires an argument) r rPr_userrrrallowAnonymous userAnonymousGUEST_NAME_OK_NEED_EMAILUSR_NAME_OK_NEED_PASS)rpusernames r=r FTP.ftp_USERs_ ::n-HIJ J [[ << & &4::9S9S+S+ +)84 4r<c^^TRR(a@TRTRR:Xa[R "5n[ mO'[R"TRU5n[mT?UU4SjnU4SjnTRRUS[5nURX45 U$)zN Second part of login. Get the password the peer wants to authenticate with. c~>UupnU[LdS5eUTlUTl/TlTRTlT$)NzThe realm is busted, jerk.) IFTPShellrrworkingDirectoryrr)rravatarrrrps r=_cbLoginFTP.ftp_PASS.._cbLoginsG*0 'Y ) G+G G)DJ DK$&D !DJLr<c>UR"[R[R5 TRTl[ erl)trap cred_errorUnauthorizedLoginUnhandledCredentialsrrr)rrps r=_ebLoginFTP.ftp_PASS.._ebLogins. LL55z7V7V WDJ$ $r<N) rrrrr AnonymousGUEST_LOGGED_IN_PROCEEDUsernamePasswordUSR_LOGGED_IN_PROCEEDr loginrr)rppasswordcredsrrrrs` @r=r FTP.ftp_PASSs << & &4::9S9S+S))+E+E 00XFE)E J  % KK  eT9 5 x*r<c@UR(a[R"[S55$URR 5R n[R"U5nURb[UR5nO[R"[55$URbUR5 [US9Ul URR!UR"5 UR%UR5UlUR&R 5R(nUR+[,[/X55 URR0R3S5$![Ra Nf=f)ad Request for a passive connection from the rfc:: This command requests the server-DTP to "listen" on a data port (which is not its default data port) and to wait for a connection rather than initiate one upon receipt of a transfer command. The response to this command includes the host and port address this server is listening on. z may not send PASV after EPSV ALLr1cgrlr5igns r=FTP.ftp_PASV.. r<)rr rPrrgetHosthost ipaddress IPv6Address ipv4_mappedrrAddressValueErrorrrr.rQ dtpTimeoutrrportrENTERING_PASV_MODEencodeHostPortr addCallback)rpraddressr s r=ftp_PASV FTP.ftp_PASVs4 ==::12TUV V~~%%',, A++D1G"".7../zz"="?@@ ?? & OO $- ""4??3t7 ||##%** %~d'AB''334DEE7**   sFFFc[U5nXR;a+[ SR SUR555eg![a [U5ef=f)a: Validate the network protocol requested in an EPRT or EPSV command. For now we just hardcode the protocols we support, since this layer doesn't have a good way to discover that. @param protocol: An address family number. See RFC 2428 section 2. @type protocol: L{str} @raise FTPCmdError: If validation fails. ,c38# UHn[U5v M g7frl)r)rr?s r=r/FTP._validateNetworkProtocol.."sI)HAQ)HsN)int ValueErrorr_supportedNetworkProtocolsrjoin)rpr s r=_validateNetworkProtocolFTP._validateNetworkProtocol sd .8}H :: :1I)H)HII  ; .#H- - .s AAcnUS:Xa SUl[$U(aURU5 UR bUR5 [US9UlUR RUR5 U(a U[:XaSnOSnURUR US9Ul URR5RnUR!["U5 UR R$R'S5$![a [R "5s$f=f)a Extended request for a passive connection. As described by U{RFC 2428 section 3}:: The EPSV command requests that a server listen on a data port and wait for a connection. The EPSV command takes an optional argument. The response to this command includes only the TCP port number of the listening connection. The format of the response, however, is similar to the argument of the EPRT command. This allows the same parsing routines to be used for both commands. In addition, the format leaves a place holder for the network protocol and/or network address, which may be needed in the EPSV response in the future. ALLTrz::rArcgrlr5rs r=rFTP.ftp_EPSV..Nrr<)r EPSV_ALL_OKrrjr rPrrr.rQr  _AFNUM_IP6rrrr rENTERING_EPSV_MODErr)rpr rr s r=ftp_EPSV FTP.ftp_EPSV%s" u  DM   $--h7 ?? & OO $- ""4??38z1IIt)L ||##%** %t,''334DEE% $zz|# $sDD43D4cvUR(a[R"[S55$[ [ [ URS555nS[ USS5-nUSS-US-nURbUR5 [XRR5RS9UlURRUR5 [ R""X4UR5UlSnS nURR&R)XV5$) Nz may not send PORT after EPSV ALLrz %d.%d.%d.%drwrr1r2c[$rlENTERING_PORT_MODErs r= connectedFTP.ftp_PORT..connected`% %r<c8UR[5 [$rlrrCANT_OPEN_DATA_CNXrs r= connFailed FTP.ftp_PORT..connFailedc HH( )% %r<)rr rPrrmaprrErrr.rgetPeerrrQr r connectTCPrrr)rprr>ipr r-r4s r=ftp_PORT FTP.ftp_PORTPs ==::12TUV VSgmmC012 U48_ ,Aw!|d1g% ?? & OO $~~7M7M7O7T7TU ""4??3))"DOOD  & &''44YKKr<cUR(a[R"[S55$[ U5up#nU(aURU5 URbUR5 [XRR5RS9Ul URRUR 5 ["R$"X4UR5UlSnSnURR(R+XV5$![ a" [R"[ U55s$f=f![a [R"5s$f=f)a[ Extended request for a data connection. As described by U{RFC 2428 section 2}:: The EPRT command allows for the specification of an extended address for the data connection. The extended address MUST consist of the network protocol as well as the network and transport addresses. z may not send EPRT after EPSV ALLr(c[$rlr*r,s r=r-FTP.ftp_EPRT..connectedr/r<c8UR[5 [$rlr1r3s r=r4 FTP.ftp_EPRT..connFailedr6r<)rr rPrdecodeExtendedAddressrrrrjrrr.rr8rrQr r r9rrr)rpextendedAddressr r:r r-r4s r=ftp_EPRT FTP.ftp_EPRTis ==::12TUV V B!6!G H$  $--h7 ?? & OO $~~7M7M7O7T7TU ""4??3))"DOOD  & &''44YKK/ B::/@A A B  $zz|# $s#DE )EE E-,E-cR[U[5(aURS5$U$)a= Encode C{name} to be sent over the wire. This encodes L{unicode} objects as UTF-8 and leaves L{bytes} as-is. As described by U{RFC 3659 section 2.2}:: Various FTP commands take pathnames as arguments, or return pathnames in responses. When the MLST command is supported, as indicated in the response to the FEAT command, pathnames are to be transferred in one of the following two formats. pathname = utf-8-name / raw utf-8-name = raw = Which format is used is at the option of the user-PI or server-PI sending the pathname. @param name: Name to be encoded. @type name: L{bytes} or L{unicode} @return: Wire format of C{name}. @rtype: L{bytes} zutf-8)rrr)rprs r= _encodeNameFTP._encodeNames%6 dC ;;w' ' r<c^TRbTRR(d[R"[ S55$UR 5S;aSnU4Sjn[ TRU5nTRRUS5nURU5 U$![a" [R"[U55s$f=f)azThis command causes a list to be sent from the server to the passive DTP. If the pathname specifies a directory or other group of files, the server should transfer a list of files in the specified directory. If the pathname specifies a file then the server should send current information on the file. A null argument implies the user's current working or default directory. "must send PORT or PASV before RETR)z-az-lz-laz-alrAc>TR[5 UH1upTRU5nTRR X5 M3 TRR R 5 [4$rl)rDATA_CNX_ALREADY_OPEN_START_XFRrGr<rrrTXFR_COMPLETE_OK)resultsrattrsrps r= gotListing FTP.ftp_LIST..gotListingsc JJ6 7& ''-  11$> '    & & 5 5 7$& &r<)rrrrrrr) r<rr rPrlowerrLrr3rQrlistr)rprIrPrdrs` r=ftp_LIST FTP.ftp_LISTs    #4+;+;+G+G::12VWX X ::<5 5D ' 7!$"7"7>H JJOO    j!! 7::/56 6 7s&B++)CCc^TRbTRR(d[R"[ S55$[ TR U5nU4SjnU4Sjn[U5(aUR5nOSnTRRU5nURX55 URU5 U$![a" [R"[U55s$f=f)a This command causes a directory listing to be sent from the server to the client. The pathname should specify a directory or other system-specific file group descriptor. An empty path implies the current working directory. If the path is non-existent, send nothing. If the path is to a file, send only the file name. @type path: C{str} @param path: The path for which a directory listing should be returned. @rtype: L{Deferred} @return: a L{Deferred} which will be fired when the listing request is finished. NrJcL>TR[5 UH^up#U(a&U(dM[R"X!5(dM2TRU5nTRR U5 M` TRR R5 [4$)a5 Send, line by line, each matching file in the directory listing, and then close the connection. @type results: A C{list} of C{tuple}. The first element of each C{tuple} is a C{str} and the second element is a C{list}. @param results: The names of the files in the directory. @param glob: A shell-style glob through which to filter results (see U{http://docs.python.org/2/library/fnmatch.html}), or L{None} for no filtering. @type glob: L{str} or L{None} @return: A C{tuple} containing the status code for a successful transfer. @rtype: C{tuple} ) rrLr`rGr<rrrrM)rNglobrrrps r=cbListFTP.ftp_NLST..cbListsz$ JJ6 7!( )D)D++D1D$$--d3")    & & 5 5 7$& &r<cZ>TRRR5 [4$)a RFC 959 specifies that an NLST request may only return directory listings. Thus, send nothing and just close the connection. @type results: L{Failure} @param results: The L{Failure} wrapping a L{FileNotFoundError} that occurred while trying to list the contents of a nonexistent directory. @returns: A C{tuple} containing the status code for a successful transfer. @rtype: C{tuple} )r<rrrM)rNrps r=listErrFTP.ftp_NLST..listErrs&    & & 5 5 7$& &r<)r<rr rPrrLrr3rQrhrFrrSrr)rprIrdrYr\rXrs` r=ftp_NLST FTP.ftp_NLSTs    #4+;+;+G+G::12VWX X 7!$"7"7>H '4 '" ! * *<<>DD JJOOH % f# Ws 7::/56 6 7s C)C:9C:c^^[TRU5mUU4SjnTR RT5RU5$![a" [R"[ U55s$f=f)Nc >TTl[4$rl)rREQ_FILE_ACTN_COMPLETED_OK)rrdrps r= accessGranted"FTP.ftp_CWD..accessGranted6s$,D !.0 0r<) rLrr3r rPrQraccessr)rprIrcrds` @r=ftp_CWD FTP.ftp_CWD/sg 7!$"7"7>H  1zz  *66}EE 7::/56 6 7sA )A76A7c$URS5$)NrB)rfrvs r=ftp_CDUP FTP.ftp_CDUP<s||D!!r<cJ[SSRUR5-4$)Nr?) PWD_REPLYrrrvs r=ftp_PWD FTP.ftp_PWD?s!3$*?*?!@@AAr<c^^^^^ TRc [S5e[TRU5m TRS5 U4SjnTR(d[TR5mO TRmSmSmUUUU4SjnU 4SjnTRRT 5nURX45 URU5 U$![a" [ R "[U55s$f=f)aX This command causes the content of a file to be sent over the data transfer channel. If the path is to a folder, an error will be raised. @type path: C{str} @param path: The path to the file which should be transferred over the data transfer channel. @rtype: L{Deferred} @return: a L{Deferred} which will be fired when the transfer is done. Nz.PORT, PASV, EPRT, or EPSV required before RETRcR>TRTRR5 U$rlrQrrrs r= enableTimeout#FTP.ftp_RETR..enableTimeout\ OODLL00 1Mr<c[4$rlrMrs r=cbSentFTP.ftp_RETR..cbSentfs $& &r<c[R"S5 [R"U5 UR[5(aU$[ 4$)Nz7Unexpected error attempting to transmit file to client:)rrqrrrjCNX_CLOSED_TXFR_ABORTEDr3s r=ebSentFTP.ftp_RETR..ebSentis7 GGM N GGCLyy%% +- -r<c>TRR(aTR[5 OTR[5 UR T5nUR TT5 U$rl)r<rrrLFILE_STATUS_OK_OPEN_DATA_CNXsendr)filerrxrr|rps r=cbOpenedFTP.ftp_RETR..cbOpenedpsL++ :; 78 $A NN66 *Hr<cT>UR[[[5(d,[R "S5 [R "U5 UR[5(a'URRSRT54$[SRT54$)Nz:Unexpected error attempting to open file for transmission:r?) rrTrQrZrrqrrjrrurrzrnewsegss r=ebOpenedFTP.ftp_RETR..ebOpened{sx99%'8:KWX yy%% ++SXXg->??"CHHW$56 6r<)r<rrLrr3r rPrQrQbinaryrZropenForReadingrr) rprIrrrrrrxrr|rs ` @@@@r=ftp_RETR FTP.ftp_RETRBs    #%&VW W 7 !6!6=G   {{'(8(89D##D ' .   7 JJ % %g . x* - o 7::/56 6 7sC)C?>C?c^^^^^ TRc [S5e[TRU5m TRS5 U4SjnUUU4SjnU 4SjnU4SjmSmSmTRRT 5nURX45 URU5 U$![a" [ R "[U55s$f=f) a STORE (STOR) This command causes the server-DTP to accept the data transferred via the data connection and to store the data as a file at the server site. If the file specified in the pathname exists at the server site, then its contents shall be replaced by the data being transferred. A new file is created at the server site if the file specified in the pathname does not already exist. Nz.PORT, PASV, EPRT, or EPSV required before STORcR>TRTRR5 U$rlrqrs r=rr#FTP.ftp_STOR..enableTimeoutrtr<c>^TR5nURT5 URU4Sj5 URTT5 U$)zT File was open for reading. Launch the data transfer channel via the file consumer. c$>TR5$rl)rl)rrs r=r0FTP.ftp_STOR..cbOpened..s $**,r<)receiverr)rr cbConsumerrxr|s` r=rFTP.ftp_STOR..cbOpeneds<  A MM* % MM6 7 NN66 *Hr<c>[UR[5(a'URRSR T54$[ R "US5 [SR T54$)z Called when failed to open the file for reading. For known errors, return the FTP error code. For all other, return a file not found error. r?z-Unexpected error received while opening file:)rrrjrurrrrzrs r=rFTP.ftp_STOR..ebOpenedsW#))[11 ++SXXg->?? GGCH I"CHHW$56 6r<c>TR(d [U5nTRRU5nTRR(aTR [ 5 U$TR [5 U$)z Called after the file was opended for reading. Prepare the data transfer channel and send the response to the command channel. )rrZr<r!rrrLr)rrrps r=r FTP.ftp_STOR..cbConsumerse;;+D1  11$7A++ :;H 78Hr<c[4$)z3 Called from data transport when transfer is done. rvrws r=rxFTP.ftp_STOR..cbSents %& &r<cv[R"US5 UR[5(aU$[4$)zG Called from data transport when there are errors during the transfer. z*Unexpected error received during transfer:)rrrrjr{r3s r=r|FTP.ftp_STOR..ebSents0 GGCE Fyy%% +- -r<) r<rrLrr3r rPrQrQropenForWritingrr) rprIrrrrrrrxr|rs ` @@@@r=ftp_STOR FTP.ftp_STORs    #%&VW W 7 !6!6=G    7 ( '  . JJ % %g . x* - [ 7::/56 6 7sB%%)CCc[URU5nSnUR RUS5RU5$![a" [R"[ U55s$f=f)a File SIZE The FTP command, SIZE OF FILE (SIZE), is used to obtain the transfer size of a file from the server-FTP process. This is the exact number of octets (8 bit bytes) that would be transmitted over the data connection should that file be transmitted. This value will change depending on the current STRUcture, MODE, and TYPE of the data connection or of a data connection that would be created were one created now. Thus, the result of the SIZE command is dependent on the currently established STRU, MODE, and TYPE parameters. The SIZE command returns how many octets would be transferred if the file were to be transferred using the current transfer structure, mode, and type. This command is normally used in conjunction with the RESTART (REST) command when STORing a file to a remote server in STREAM mode, to determine the restart point. The server-PI might need to read the partially transferred file, do any appropriate conversion, and count the number of octets that would be generated when sending the file in order to correctly respond to this command. Estimates of the file transfer size MUST NOT be returned; only precise information is acceptable. http://tools.ietf.org/html/rfc3659 c,Uun[[U54$rl) FILE_STATUSr)rrs r=cbStatFTP.ftp_SIZE..cbStat sGTT+ +r<)r rLrr3r rPrQrstatrrprIrrs r=ftp_SIZE FTP.ftp_SIZEsf4 7 !6!6=G ,zzw 2>>vFF 7::/56 6 7A)A21A2c[URU5nSnUR RUS5RU5$![a" [R"[ U55s$f=f)a File Modification Time (MDTM) The FTP command, MODIFICATION TIME (MDTM), can be used to determine when a file in the server NVFS was last modified. This command has existed in many FTP servers for many years, as an adjunct to the REST command for STREAM mode, thus is widely available. However, where supported, the "modify" fact that can be provided in the result from the new MLST command is recommended as a superior alternative. http://tools.ietf.org/html/rfc3659 clUun[[R"S[R"U554$)Nz %Y%m%d%H%M%S)rrstrftimer)rrs r=rFTP.ftp_MDTM..cbStat#s( KX~t{{8?T!UV Vr<)rrrs r=ftp_MDTM FTP.ftp_MDTMsg 7 !6!6=G Wzzw 6BB6JJ 7::/56 6 7rcUR5nU(a2[USUS-S5nUb U"USS5$URU5$[4$)a REPRESENTATION TYPE (TYPE) The argument specifies the representation type as described in the Section on Data Representation and Storage. Several types take a second parameter. The first parameter is denoted by a single Telnet character, as is the second Format parameter for ASCII and EBCDIC; the second parameter for local byte is a decimal integer to indicate Bytesize. The parameters are separated by a (Space, ASCII code 32). type_rNr0)rr type_UNKNOWNr)rptyper?fs r=ftp_TYPE FTP.ftp_TYPE)sU JJL g!nd3A}12x$$Q' '}r<c|US:XdUS:XaSUl[SU-4$[R"[ U55$)NrANFAr TYPE_SET_OKr rPrrpcodes r=type_A FTP.type_A>s: 2:DKt, ,::/56 6r<cjUS:XaSUl[S4$[R"[ U55$)NrATIrrs r=type_I FTP.type_IEs0 2:DK% %::/56 6r<c@[R"[U55$rl)r rPrrs r=rFTP.type_UNKNOWNLszz6t<==r<c[$rl) NAME_SYS_TYPErvs r=ftp_SYST FTP.ftp_SYSTOsr<czUR5nUS:Xa[4$[R"[ U55$)NFrCMD_OKr rPr)rp structurer?s r=ftp_STRU FTP.ftp_STRURs2 OO  89 zz6yABBr<czUR5nUS:Xa[4$[R"[ U55$)NSr)rpmoder?s r=ftp_MODE FTP.ftp_MODEXs1 JJL 89 zz6t<==r<c^[URT5nUR RU5RU4Sj5$![a" [R"[ T55s$f=f)Nc>[T4$rl) MKD_REPLY)rrIs r=rFTP.ftp_MKD..ds D)r<) rLrr3r rPrQr makeDirectoryrrprIrs ` r=ftp_MKD FTP.ftp_MKD^sg 7 !6!6=Gzz''0<< )   7::/56 6 7sA)A32A3c[URU5nUR RU5RS5$![a" [R"[ U55s$f=f)Nc[4$rlrbrs r=rFTP.ftp_RMD..m35r<) rLrr3r rPrQrremoveDirectoryrrs r=ftp_RMD FTP.ftp_RMDgsf 7 !6!6=Gzz))'2>> 5   7::/56 6 7A)A/.A/c[URU5nUR RU5RS5$![a" [R"[ U55s$f=f)Nc[4$rlrrs r=rFTP.ftp_DELE..vrr<) rLrr3r rPrQr removeFilerrs r=ftp_DELE FTP.ftp_DELEpsf 7 !6!6=Gzz$$W-99 5   7::/56 6 7rc[4$rl)rrvs r=ftp_NOOP FTP.ftp_NOOPys yr<c>XlURUl[4$rl) _fromNamerr"REQ_FILE_ACTN_PENDING_FURTHER_INFO)rpfromNames r=ftp_RNFR FTP.ftp_RNFR|s!]] 244r<cNURnU?URUl[URU5n[URU5nURRX45RS5$![ a" [ R"[U55s$f=f)Nc[4$rlrrs r=rFTP.ftp_RNTO..rr<) rrrrLrr3r rPrQrrenamer)rptoNamerfromsegstosegss r=r FTP.ftp_RNTOs>> N[[  ;!$"7"7BH 5 5v>Fzz  2>> 5   ;::/9: : ;s,A88)B$#B$cUR[[S5 URHnURSU-5 M UR[[S5 g)zU Advertise the features supported by the server. http://tools.ietf.org/html/rfc2389 rrr0N)rrtFEAT_OKFEATURES)rpfeatures r=ftp_FEAT FTP.ftp_FEATsN hw'*+}}G MM#- (% hw'*+r<c.UR[U5$)zT Handle OPTS command. http://tools.ietf.org/html/draft-ietf-ftpext-utf-8-option-00 )rOPTS_NOT_IMPLEMENTED)rpoptions r=ftp_OPTS FTP.ftp_OPTSs zz.77r<cpUR[5 URR5 SUlgr)r GOODBYE_MSGrrrrvs r=ftp_QUIT FTP.ftp_QUITs& ; %%' r<c[R"SSS9 [R"UR5 URSsol[RR U5(aUR 5 O@[RR U5(aUR5 O SU<35eURR5 SUl URbSUl gg)z Call when DTP connection exits rTrNz>dtpPort should be an IListeningPort or IConnector, instead is ) rrqrr IListeningPort providedBy stopListening IConnector disconnectrrCr<)rprs r=rFTP.cleanupDTPs  D)   $ d  $ $ / / 8 8  ! ! #  " " - -g 6 6     #*- 5 ##%    '#D  (r<) rrrrrrr<rrrrrr)rA)Ir6r7r8r9r:rrangerrrrr r rrrr<rr _AFNUM_IPr"rrrrr listenTCPrrrrrrrrrrrrrrr$r;rDrGrTr^rfrirmrrrrrrrrrrrrrrrrrrr r rr; __classcell__)rs@r=rvrvsr!FL(-Qx$FFFHJ F EJGK FH"+Z!8v&O;HQ{%%MI= (,1\!?F . 5$B-F^0)FVL2(LT>+ZN` F"BHT^@#GJK0*77>C >    5   ,8! $$r<rvct\rSrSrSr\r\rSr Sr Sr S\ RS3r\"SS 5rSS jrS rS rSrg ) FTPFactoryia A factory for producing ftp protocol instances @ivar timeOut: the protocol interpreter's idle timeout time in seconds, default is 600 seconds. @ivar passivePortRange: value forwarded to C{protocol.passivePortRange}. @type passivePortRange: C{iterator} T anonymousiXzTwisted z FTP Serverrr0Nc*XlX l/Ulgrl)r r instances)rpr rs r=rnFTPFactory.__init__s *r<c[RRX5nUbQURURlUR URlUR URlU$rl)rLimitTotalConnectionsFactoryr@r wrappedProtocolrrr=s r=r@FTPFactory.buildProtocolsZ  1 1 ? ? K ='+{{A   $(, A   %151F1FA   .r<cURVs/sH"oRcMURS5PM$ n[RR U5 gs snfrl)rrrQrr!rC)rpr?s r=rCFTPFactory.stopFactorysD&*^^M^yy d ^M--99$? Ns AA)rr r)Nr)r6r7r8r9r:rvr rqoverflowProtocolrrrrversionrrrrnr@rCr;r5r<r=rrsTH*NMG 1 12+>NQ{ @r<rcV\rSrSrSrSrSrSrSrSr SS jr SS jr S r S r Srg )riz{ An abstraction of the shell commands used by the FTP protocol for a given user account. All path names must be absolute. cg)z Create a directory. @param path: The path, as a list of segments, to create @type path: C{list} of C{unicode} @return: A Deferred which fires when the directory has been created, or which fails if the directory cannot be created. Nr5rIs r=rIFTPShell.makeDirectoryr<cg)z Remove a directory. @param path: The path, as a list of segments, to remove @type path: C{list} of C{unicode} @return: A Deferred which fires when the directory has been removed, or which fails if the directory cannot be removed. Nr5r*s r=rIFTPShell.removeDirectoryr,r<cg)z Remove a file. @param path: The path, as a list of segments, to remove @type path: C{list} of C{unicode} @return: A Deferred which fires when the file has been removed, or which fails if the file cannot be removed. Nr5r*s r=rIFTPShell.removeFile r,r<cg)a8 Rename a file or directory. @param fromPath: The current name of the path. @type fromPath: C{list} of C{unicode} @param toPath: The desired new name of the path. @type toPath: C{list} of C{unicode} @return: A Deferred which fires when the path has been renamed, or which fails if the path cannot be renamed. Nr5)fromPathtoPaths r=rIFTPShell.renamer,r<cg)z Determine whether access to the given path is allowed. @param path: The path, as a list of segments @return: A Deferred which fires with None if access is allowed or which fails with a specific exception type if access is denied. Nr5r*s r=reIFTPShell.access#r,r<r5cg)zw Retrieve information about the given path. This is like list, except it will never return results about child paths. Nr5rIkeyss r=rIFTPShell.stat.r,r<cg)a Retrieve information about the given path. If the path represents a non-directory, the result list should have only one entry with information about that non-directory. Otherwise, the result list should have an element for each child of the directory. @param path: The path, as a list of segments, to list @type path: C{list} of C{unicode} or C{bytes} @param keys: A tuple of keys desired in the resulting dictionaries. @return: A Deferred which fires with a list of (name, list), where the name is the name of the entry as a unicode string or bytes and each list contains values corresponding to the requested keys. The following are possible elements of keys, and the values which should be returned for them: - C{'size'}: size in bytes, as an integer (this is kinda required) - C{'directory'}: boolean indicating the type of this entry - C{'permissions'}: a bitvector (see os.stat(foo).st_mode) - C{'hardlinks'}: Number of hard links to this entry - C{'modified'}: number of seconds since the epoch since entry was modified - C{'owner'}: string indicating the user owner of this entry - C{'group'}: string indicating the group owner of this entry Nr5r8s r=rSIFTPShell.list6r,r<cg)z @param path: The path, as a list of segments, to open @type path: C{list} of C{unicode} @rtype: C{Deferred} which will fire with L{IReadFile} Nr5r*s r=rIFTPShell.openForReading[r,r<cg)z @param path: The path, as a list of segments, to open @type path: C{list} of C{unicode} @rtype: C{Deferred} which will fire with L{IWriteFile} Nr5r*s r=rIFTPShell.openForWritingcr,r<Nr5)r6r7r8r9r:rrrrrerrSrrr;r5r<r=rrs5           # J  r<rc\rSrSrSrSrSrg) IReadFileilz( A file out of which bytes may be read. cg)z Produce the contents of the given path to the given consumer. This method may only be invoked once on each provider. @type consumer: C{IConsumer} @return: A Deferred which fires when the file has been consumed completely. Nr5)consumers r=rIReadFile.sendqr,r<r5N)r6r7r8r9r:rr;r5r<r=rCrCls   r<rCc$\rSrSrSrSrSrSrg) IWriteFilei}z) A file into which bytes may be written. cg)z Create a consumer which will write to this file. This method may only be invoked once on each provider. @rtype: C{Deferred} of C{IConsumer} Nr5r5r<r=rIWriteFile.receiver,r<cg)a- Perform any post-write work that needs to be done. This method may only be invoked once on each provider, and will always be invoked after receive(). @rtype: C{Deferred} of anything: the value is ignored. The FTP client will not see their upload request complete until this Deferred has been fired. Nr5r5r<r=rlIWriteFile.closer,r<r5N)r6r7r8r9r:rrlr;r5r<r=rHrH}s   r<rHc/n[R"U5nURUR5 [R "5H:nUR UR;dMURUR5 M< U$)zS Return the primary and supplementary groups for the given UID. @type uid: C{int} ) pwdgetpwuidrGpw_gidgrpgetgrallpw_namegr_memgr_gid)uidrpwentgrents r= _getgroupsrYs^ F LL E MM%,, ==ELL ( MM%,, '  Mr<c.US:XaA[Rn[Rn[Rn[R nOWUS:XaA[R n[Rn[Rn[RnO[SU<S35eSn[RRU5(a~US:XaSnOu[R"U5n XIR-(aX R:XaSnO:XYR-(aU[U5;aSnOXiR-(aSnU(aK[R "X'5(d0Sn["R$"SU[R&"54-5 U$) a checks to see if uid has proper permissions to access path with mode @type uid: C{int} @param uid: numeric user id @type gid: C{int} @param gid: numeric group id @type spath: C{str} @param spath: the path on the server to test @type mode: C{str} @param mode: 'r' or 'w' (read or write) @rtype: C{bool} @return: True if the given credentials have the specified form of access to the given path rwz Invalid mode z: must specify 'r' or 'w'FrTzUFilesystem grants permission to UID %d but it is inaccessible to me running as UID %d)rS_IRUSRS_IRGRPS_IROTHr]R_OKS_IWUSRS_IWGRPS_IWOTHW_OKrrIexistsst_modest_uidrYrerrqgetuid) rVgidspathrusrrQothamodererKs r=_testPermissionsrns ( s{llllll llllll=0IJKK F ww~~e !8FAYY3((?yySJsO%;yy yy&&F GG7:=ryy{9KL  Mr<c\rSrSrSrSrSrSrSrSr Sr S r S r S r S rSS jrSSjrSrSrSrSrSrSrSrSrSrg)FTPAnonymousShelliz An anonymous implementation of IFTPShell @type filesystemRoot: L{twisted.python.filepath.FilePath} @ivar filesystemRoot: The path which is considered the root of this shell. cXlgrlfilesystemRoot)rprss r=rnFTPAnonymousShell.__init__s,r<c8URRU5$rl)rs descendantrprIs r=_pathFTPAnonymousShell._paths""--d33r<c>[R"[55$rlr rPr|rws r=rFTPAnonymousShell.makeDirectoryzz-/00r<c>[R"[55$rlr{rws r=r!FTPAnonymousShell.removeDirectoryr}r<c>[R"[55$rlr{rws r=rFTPAnonymousShell.removeFiler}r<c>[R"[55$rlr{)rpr2r3s r=rFTPAnonymousShell.renamer}r<c`URU5n[R"[55$rl)rxr rPr|rws r=rFTPAnonymousShell.receives#zz$zz-/00r<cURU5nUR5(a[R"[ U55$UR S5n[R "[U55$![a n[URU5sSnA$SnAf[a [R"5s$f=f)a Open C{path} for reading. @param path: The path, as a list of segments, to open. @type path: C{list} of C{unicode} @return: A L{Deferred} is returned that will fire with an object implementing L{IReadFile} if the file is successfully opened. If C{path} is a directory, or if an exception is raised while trying to open the file, the L{Deferred} will fire with an error. r[N) rxisdirr rPrZopenr _FileReaderOSErrorr\rNr )rprIr?rr[s r=r FTPAnonymousShell.openForReadings JJt  7799::/56 6 1s A ==Q0 0  1!!''40 0 ::<  $A77 CBC"CCc@[R"[S55$)zI Reject write attempts by anonymous users with L{PermissionDeniedError}. zSTOR not allowed)r rPrTrws r=r FTPAnonymousShell.openForWritings zz/0BCDDr<ctURU5nUR5(d[R"[ U55$UR 5 [R "S5$![a n[URU5sSnA$SnAf[a [R"5s$f=frl) rxrer rPrQlistdirrrr\rNr rprIr?r[s r=reFTPAnonymousShell.access s JJt xxzz::/56 6 ' IIK ==& &  1!!''40 0 ::<  $A-- B77B B7"B76B7czURU5nUR5(a(URX25n[R"U5$URX5RS5$![ a n[ URU5sSnA$SnAf[a [R"5s$f=f)NcUSS$)Nrr0r5)ress r=r(FTPAnonymousShell.stat..<s Qr<) rxr _statNoder rrr\rNr rPrSr)rprIr9r? statResultr[s r=rFTPAnonymousShell.stat0s JJt  7799 1!^^A4 }}Z0099T(445JK K 5%aggt44  $zz|# $s#A00 B::BB:"B:9B:cURU5nUR5(a1UR5nUVs/sHoSRU5PM nnOoUR 5(a;[ R R"URUR56/nU/nO[R"[U55$/n[XF5HCup/n URX45 U(dM"U RUR!X255 ME [R*"U5$s snf!["a"n [%U R&U5sSn A s $Sn A f[(a [R"5ss $f=f)z Return the list of files at given C{path}, adding C{keys} stat informations if specified. @param path: the directory or file to check. @type path: C{str} @param keys: the list of desired metadata @type keys: C{list} of C{str} N)rxrrchildisfiler]rIr segmentsFromrsr rPrQziprGextendrrr\rNr r) rprIr9filePathentriesr? fileEntriesrNfileNameentr[s r=rSFTPAnonymousShell.list>s/::d# >>  &&(G6=>g>>!,gK>K __  ww||X%:%:4;N;N%OPQG#*K::/56 6"%g"; HC NNH? +t(JJt~~h=> #<}}W%%'?=)!''8<<$( ::<'(s)D17 D66 FEF"FFcxUR5 UVs/sHn[USU-5"U5PM sn$s snf)z Shortcut method to get stat info on a node. @param filePath: the node to stat. @type filePath: C{filepath.FilePath} @param keys: the stat keys to get. @type keys: C{iterable} _stat_)restatr)rprr9ks r=rFTPAnonymousShell._statNodeas6 ?CDt!hl+H5tDDDs7c"UR5$)zy Get the filepath's size as an int @param fp: L{twisted.python.filepath.FilePath} @return: C{int} representing the size )getsizerpfps r= _stat_sizeFTPAnonymousShell._stat_sizenszz|r<c"UR5$)z Get the filepath's permissions object @param fp: L{twisted.python.filepath.FilePath} @return: L{twisted.python.filepath.Permissions} of C{fp} )getPermissionsrs r=_stat_permissions#FTPAnonymousShell._stat_permissionsws  ""r<cDUR5$![a gf=f)av Get the number of hardlinks for the filepath - if the number of hardlinks is not yet implemented (say in Windows), just return 0 since stat-ing a file in Windows seems to return C{st_nlink=0}. (Reference: U{http://stackoverflow.com/questions/5275731/os-stat-on-windows}) @param fp: L{twisted.python.filepath.FilePath} @return: C{int} representing the number of hardlinks r)getNumberOfHardLinksNotImplementedErrorrs r=_stat_hardlinks!FTPAnonymousShell._stat_hardlinkss( **, ,"  s  c"UR5$)z Get the filepath's last modified date @param fp: L{twisted.python.filepath.FilePath} @return: C{int} as seconds since the epoch )getModificationTimers r=_stat_modified FTPAnonymousShell._stat_modifieds%%''r<cUR5n[b[R"U5S$[ U5$![a Nf=f![ a gf=f)aX Get the filepath's owner's username. If this is not implemented (say in Windows) return the string "0" since stat-ing a file in Windows seems to return C{st_uid=0}. (Reference: U{http://stackoverflow.com/questions/5275731/os-stat-on-windows}) @param fp: L{twisted.python.filepath.FilePath} @return: C{str} representing the owner's username r0) getUserIDrNrOKeyErrorrr)rpruserIDs r= _stat_ownerFTPAnonymousShell._stat_ownerse \\^F<</22v;   #   A> A  A  AAcUR5n[b[R"U5S$[ U5$![a Nf=f![ a gf=f)aR Get the filepath's owner's group. If this is not implemented (say in Windows) return the string "0" since stat-ing a file in Windows seems to return C{st_gid=0}. (Reference: U{http://stackoverflow.com/questions/5275731/os-stat-on-windows}) @param fp: L{twisted.python.filepath.FilePath} @return: C{str} representing the owner's group rr) getGroupIDrQgetgrgidrrr)rprgroupIDs r= _stat_groupFTPAnonymousShell._stat_groupse mmoG<<033w<   #  rc"UR5$)zj Get whether the filepath is a directory @param fp: L{twisted.python.filepath.FilePath} @return: C{bool} )rrs r=_stat_directory!FTPAnonymousShell._stat_directorysxxzr<rrNrA)r6r7r8r9r:rnrxrrrrrrrrerrSrrrrrrrrr;r5r<r=rprpso-41111112E' L!&F E#"(0 0r<rpc&\rSrSrSrSrSrSrg)ricXlSUlgr)rf_sendrgs r=rn_FileReader.__init__s  r<cHSUlURR5 U$r)rrfrl)rp passthroughs r=_close_FileReader._closes  r<cUR(aS5eSUl[R"5RURU5nUR UR 5 U$)Nz0Can only call IReadFile.send *once* per instanceT)rr FileSenderbeginFileTransferrfrr)rprErs r=r_FileReader.sendsO::QQQ~     0 0H E $++r<)rrfN)r6r7r8r9rnrrr;r5r<r=rrs r<rc6\rSrSrSrSrSrSrSrSr Sr g ) FTPShelliz2 An authenticated implementation of L{IFTPShell}. c URU5nUR5 [R"S5$![a n[ UR U5sSnA$SnAf[a [R"5s$f=frl) rxmakedirsr rrr\rNr rPrs r=rFTPShell.makeDirectorysf JJt  ' JJL ==& &  1!!''40 0 ::<  s!9 BAB"BBcURU5nUR5(a[R"[ U55$[ R "UR5 [R"S5$![a n[URU5sSnA$SnAf[a [R"5s$f=frl) rxrr rPrVr]rmdirrIrrr\rNr rs r=rFTPShell.removeDirectorys JJt  88::::2489 9 ' HHQVV  ==& &  1!!''40 0 ::<  s$ A== CB"C""CCctURU5nUR5(a[R"[ U55$UR 5 [R "S5$![a n[URU5sSnA$SnAf[a [R"5s$f=frl) rxrr rPrZremoverrr\rNr rs r=rFTPShell.removeFile s JJt  7799::/56 6 ' HHJ ==& &  1!!''40 0 ::<  rcdURU5nURU5n[R"URUR5 [R "S5$![ a n[URU5sSnA$SnAf[a [R"5s$f=frl) rxr]rrIr rrr\rNr rP)rpr2r3rtpr[s r=rFTPShell.rename s ZZ ! ZZ  ' IIbggrww ' ==& &  5!!''84 4 ::<  s#+A%% B//B B/ "B/.B/cURU5nUR5(a[R"[ U55$UR S5n[R"[U55$![ a n[URU5sSnA$SnAf[a [R"5s$f=f)a Open C{path} for writing. @param path: The path, as a list of segments, to open. @type path: C{list} of C{unicode} @return: A L{Deferred} is returned that will fire with an object implementing L{IWriteFile} if the file is successfully opened. If C{path} is a directory, or if an exception is raised while trying to open the file, the L{Deferred} will fire with an error. r\N) rxrr rPrZrrr\rNr r _FileWriter)rprIr?rfr[s r=rFTPShell.openForWriting# s JJt  7799::/56 6 66#;D }}[.//  1!!''40 0 ::<  rr5N) r6r7r8r9r:rrrrrr;r5r<r=rrs  '' ' '0r<rc&\rSrSrSrSrSrSrg)ri< cXlSUlgr)rf_receivergs r=rn_FileWriter.__init__> s  r<cUR(aS5eSUl[R"[UR55$)Nz4Can only call IWriteFile.receive *once* per instanceT)rr rrdrfrvs r=r_FileWriter.receiveB s4==X"XX  }}\$))455r<c.[R"S5$rl)r rrvs r=rl_FileWriter.closeH s}}T""r<)rrfN)r6r7r8r9rnrrlr;r5r<r=rr< s6 #r<rc*\rSrSrSrSrSrSrSrg) BaseFTPRealmiL zo Base class for simple FTP realms which provides an easy hook for specifying the home directory for each user. c:[R"U5Ulgrl)rFilePath anonymousRoot)rprs r=rnBaseFTPRealm.__init__S s%..}=r<c4[UR<S35e)z Return a L{FilePath} representing the home directory of the given avatar. Override this in a subclass. @param avatarId: A user identifier returned from a credentials checker. @type avatarId: C{str} @rtype: L{FilePath} z" did not override getHomeDirectory)rrrpavatarIds r=getHomeDirectoryBaseFTPRealm.getHomeDirectoryV s!"~~ B C  r<cUHfnU[LdMU[RLa[UR5nO[ UR U55n[U[USS54s $ [S5e)Nrcgrlr5r5r<r=r,BaseFTPRealm.requestAvatar..k sTr<z3Only IFTPShell interface is supported by this realm) rr ANONYMOUSrprrrrr)rprmindr ifacers r= requestAvatarBaseFTPRealm.requestAvatard skE !x111.t/A/ABF%d&;&;H&EFF!6768\+RSS  ""WXXr<)rN) r6r7r8r9r:rnrrr;r5r<r=rrL s >  Yr<rc(\rSrSrSrSSjrSrSrg)FTPRealmio a  @type anonymousRoot: L{twisted.python.filepath.FilePath} @ivar anonymousRoot: Root of the filesystem to which anonymous users will be granted access. @type userHome: L{filepath.FilePath} @ivar userHome: Root of the filesystem containing user home directories. cd[RX5 [R"U5Ulgrl)rrnrruserHome)rprr s r=rnFTPRealm.__init__y s"d2 ))(3 r<c8URRU5$)zj Use C{avatarId} as a single path segment to construct a child of C{self.userHome} and return that child. )r rrs r=rFTPRealm.getHomeDirectory} s }}""8,,r<)r N)z/home)r6r7r8r9r:rnrr;r5r<r=r r o s4-r<r c\rSrSrSrSrSrg)SystemFTPRealmi z L{SystemFTPRealm} uses system user account information to decide what the home directory for a particular avatarId is. This works on POSIX but probably is not reliable on Windows. c[RRSU-5nURS5(a[R "5e[ R"U5$)z` Return the system-defined home directory of the system user account with the name C{avatarId}. ~)r]rI expanduserrDrrrr)rprrIs r=rSystemFTPRealm.getHomeDirectory sK ww!!#.1 ??3  ..0 0  &&r<r5N)r6r7r8r9r:rr;r5r<r=rr s 'r<rc\rSrSrSrg)ConnectionLosti r5Nrr5r<r=rr rr<rc\rSrSrSrg) CommandFailedi r5Nrr5r<r=rr rr<rc\rSrSrSrg) BadResponsei r5Nrr5r<r=rr rr<rc\rSrSrSrg)UnexpectedResponsei r5Nrr5r<r=rr rr<rc\rSrSrSrg)UnexpectedDatai r5Nrr5r<r=rr rr<rc$\rSrSrSSjrSrSrg) FTPCommandi NclXl[R"5UlSUlX lSUlg)Nr0)textr rrreadypublictransferDeferred)rpr"r$s r=rnFTPCommand.__init__ s) (   $r<c^UR(aURRU5 ggrl)r$rr)rprs r=rPFTPCommand.fail s ;; MM ! !' * r<)rr$r#r"r%Nr)r6r7r8r9rnrPr;r5r<r=r r  s %+r<r c,\rSrSrSrSrSrSrSrg)ProtocolWrapperi cXlX lgrl)originalr)rpr-rs r=rnProtocolWrapper.__init__ s   r<c:URRU5 grl)r-makeConnectionrprs r=r0ProtocolWrapper.makeConnection s $$Y/r<c:URRU5 grl)r-rrs r=rProtocolWrapper.dataReceived s ""4(r<cpURRU5 URRS5 grl)r-rrrrs r=rProtocolWrapper.connectionLost s& $$V, t$r<)rr-N) r6r7r8r9rnr0rrr;r5r<r=r+r+ s!0)%r<r+c\rSrSrSrSrSrg)IFinishableConsumeri z5 A Consumer for producers that finish. @since: 11.0 cg)z& The producer has finished producing. Nr5r5r<r=finishIFinishableConsumer.finish r,r<r5N)r6r7r8r9r:r:r;r5r<r=r8r8 s   r<r8cD\rSrSrSrSrSrSrSrSr Sr S r S r g ) SenderProtocoli cl[R"5Ul[R"5Ulgrl)r rconnectedDeferredrrvs r=rnSenderProtocol.__init__ s!!&!1( r<c[S5e)Nzs r=r@ FTPDataPortFactory.buildProtocolF s( !%    "}}r<r5N)r6r7r8r9r:noisyr@r;r5r<r=rgrg= s Er<rgcl\rSrSrSrSrSrSrSrSr Sr S r S r S r SS jrS rSrSrSrSrg)FTPClientBasiciP z Foundations of an FTP client. Frc/UlSUl[R"5R UR 5UlUR RUR5 /Ul SUl gr)) actionQueuegreetingr rr _cb_greeting nextDeferredrrPrw_failedrvs r=rnFTPClientBasic.__init__X sW !NN,889J9JK $$TYY/  r<c&URU5 g)z( Give an error to any queued deferreds. N_failrprs r=rPFTPClientBasic.fail` s 5r<c UR(aU$SUlUR(a:URR[R"[ SU555 URH2nUR[R"[ SU555 M4 U$![ Ra NZf=f)z Errback all queued deferreds. r0zFTP connection lost) rrrqrrFailurerr AlreadyCalledErrorrnrP)rpr ftpCommands r=rvFTPClientBasic._failf s <<L    !!))OON3H%$PQ **J OO/De LM + ++  s9B**CCcXlgrl)ro)rpros r=rpFTPClientBasic._cb_greeting{ s r<cUcg[U[5(aURUR5n[R R X5 g)zb Sends a line, unless line is None. @param line: Line to send @type line: L{bytes} or L{unicode} N)rrrrr LineReceiverrrs r=rFTPClientBasic.sendLine~ s? <  c " ";;t~~.D ##D/r<cUR5nUcSUlgUR(dEURR SU5 [ R "SUR5 SUlgURS:XaURU5 UR(a#[R"SUR-5 URUlURUR5 g)z4 (Private) Processes the next command in the queue. Nrg?PORTz<-- %s)popCommandQueuerqr#rninsertr rOsendNextCommandr"generatePortCommandrrrqrrrpr|s r=rFTPClientBasic.sendNextCommand s))+   $D      # #Az 2   c4#7#7 8 $D   ??f $  $ $Z 0 :: GGHz. /&// joo&r<cURRU5 [UR5S:Xa-URbURcUR 5 gggg)z Add an FTPCommand object to the queue. If it's the only thing in the queue, and we are connected and we aren't waiting for a response of an earlier command, the command will be sent immediately. @param ftpCommand: an L{FTPCommand} r0N)rnrGr_rrqrrs r= queueCommandFTPClientBasic.queueCommand s\  +   !Q &*!!)  "*+ 'r<cR[X5nURU5 UR$)a= Queues a string to be issued as an FTP command @param command: string of an FTP command to queue @param public: a flag intended for internal use by FTPClient. Don't change it unless you know what you're doing. @return: a L{Deferred} that will be called when the response to the command has been received. )r rr)rprr$r|s r=queueStringCommand!FTPClientBasic.queueStringCommand s( 0  *%"""r<c\UR(aURRS5$g)zB Return the front element of the command queue, or None if empty. rN)rnrFrvs r=rFTPClientBasic.popCommandQueue s'   ##''* *r<ch^^/nTRSU-SS9nURU5 UbQ[SU-SS9mTRT5 URTR5 UU4SjnUR U5 UH0nUR TR5 UR S5 M2 g)z Login: send the username, send the password. If the password is L{None}, the PASS command won't be sent. Also, if the response to the USER command has a response code of 230 (User logged in), then PASS won't be sent either. zUSER rr$NzPASS cp>USRS5(aTRRT5 U$)Nr230)rDrnr)rw passwordCmdrps r=cancelPasswordIfNotNeeded.cancelPasswordIfNotNeeded s1A;))%00$$++K8r<cgrlr5rXs r=r+FTPClientBasic.queueLogin.. s$r<)rrGr rrrrrP)rprr deferreds userDeferredrrrs` @r= queueLoginFTPClientBasic.queueLogin s ..w/A!.L &  $Wx%7BK   k *   [11 2  $ $%> ?"H    *    / "r<c:URUR5nUR(a[R"SU-5 UR R U5 [R"SU5nU(dgUSSnUSS:XagURc%UR[UR 55 gUR n/UlUSS;aURRU5 OUSS;a9URR[R"[!U555 OQ[R"S U35 URR[R"[#U555 UR%5 g) z= (Private) Parses the response messages from the FTP server. z--> %sz\d{3} Nr1)23)45z"Server sent invalid response code )rrrrrqrwrGrSmatchrqrPrrrrrzrrr)rpr codeIsValidrrws r=rFTPClientBasic.lineReceived sA {{4>>* :: GGHtO $ T"hhy$/  Aay 7c>     $ II(7 8 ==  7j    & &x 0 !W "    % %goomH6M&N O GG8? @    % %gook(6K&L M r<c&URU5 grlrurs r=rFTPClientBasic.connectionLost s 6r<)rrrnrorqrwN)r0)r6r7r8r9r:rrrnrPrvrprrrrrrrrr;r5r<r=rlrlP sQ EI *! 0'0#$ #"0H-^r<rlc*\rSrSrSrSrSrSrSrg)_PassiveConnectionFactoryi$ FcXlgrl protoInstance)rprs r=rn"_PassiveConnectionFactory.__init__' s*r<c:XRlUR$rl)rrrs r=r@'_PassiveConnectionFactory.buildProtocol* s%)"!!!r<cf[SU5nURRRU5 g)NzConnection Failed)rrrr)rprTrr[s r=rU0_PassiveConnectionFactory.clientConnectionFailed. s) (& 1 ##++A.r<rN) r6r7r8r9rjrnr@rUr;r5r<r=rr$ s E+"/r<rc\rSrSrSr\R rSSjrSr Sr Sr Sr Sr S rS rSS jr\rSS jr\rS rSrSrSrSrSrSrSrSrSrSrSrg) FTPClienti3 a L{FTPClient} is a client implementation of the FTP protocol which exposes FTP commands as methods which return L{Deferred}s. Each command method returns a L{Deferred} which is called back when a successful response code (2xx or 3xx) is received from the server or which is error backed if an error response code (4xx or 5xx) is received from the server or if a protocol violation occurs. If an error response code is received, the L{Deferred} fires with a L{Failure} wrapping a L{CommandFailed} instance. The L{CommandFailed} instance is created with a list of the response lines received from the server. See U{RFC 959} for error code definitions. Both active and passive transfers are supported. @ivar passive: See description in __init__. c\[RU5 URX5 X0lg)a9 Constructor. I will login as soon as I receive the welcome message from the server. @param username: FTP username @param password: FTP password @param passive: flag that controls if I use active or passive data connections. You can also change this after construction by assigning to C{self.passive}. N)rlrnrpassive)rprrrs r=rnFTPClient.__init__J s# % + r<cZURR5 URU5 g)z= Disconnect, and also give an error to any queued deferreds. N)rrrvrws r=rPFTPClient.fail] s  %%' 5r<c[R"U5n[U[R"55nUR X5$)a Retrieves a file or listing generated by the given command, feeding it to the given protocol. @param commands: list of strings of FTP commands to execute then receive the results of (e.g. C{LIST}, C{RETR}) @param protocol: A L{Protocol} B{instance} e.g. an L{FTPFileListProtocol}, or something that can be adapted to one. Typically this will be an L{IConsumer} implementation. @return: L{Deferred}. )r IProtocolr+r r_openDataConnection)rpcommandsr wrappers r=receiveFromConnectionFTPClient.receiveFromConnectiond s8''1!(ENN,<=''::r<c[RXU5 URSSS9nURUR5 URS5 g)zO Login: send the username, send the password, and set retrieval mode to binary zTYPE Irrcgrlr5rs r=r&FTPClient.queueLogin.. str<N)rlrrrrP)rprrrs r=rFTPClient.queueLoginu sE !!$(;  # #HQ # 7 TYY ^$r<cT[5nURX5nURU4$)a XXX @return: A tuple of two L{Deferred}s: - L{Deferred} L{IFinishableConsumer}. You must call the C{finish} method on the IFinishableConsumer when the file is completely transferred. - L{Deferred} list of control-connection responses. )r=rr?)rprrKr[s r=sendToConnectionFTPClient.sendToConnection s-    $ $X 1##Q''r<c6^^^ UVs/sH n[USS9PM nn[R"UVs/sHoURPM snSSS9nUR [ 5 TR (aS/m U UU4Sjn[S5nTRU5 URRU5R TR5 XhRTR/n [R"U SSS9n U R [ 5 T 4Sjn U RU 5 O[S 5n TRU l TU l U RR U RR5 TRU 5 S U lS U l UR U 4S j5 XlRU R/n [R"U SSS9n U R [ 5 UHnTRU5 M U $s snfs snf) z% This method returns a DeferredList. r0rT)fireOnOneErrback consumeErrorsNcl>[USSS5up[T5nTRXU5TS'g)z5Connect to the port specified in the response to PASVr_rwNr)r\rconnectFactory)rwrr r_mutabler rps r= doPassive0FTPClient._openDataConnection..doPassive s:+HRL,<= -h7"11$a@ r<r|cDUS=(a USR5 U$r))r)rXms r=rl,FTPClient._openDataConnection..close s!*1*r<rcU$rlr5rws r=r/FTPClient._openDataConnection.. sFr<cU$rlr5)rs r=rr sr<c6URU5=(d U$rl)rP)r[pcs r=rr s"''!*//r<)r r DeferredListrrrerrrrPrr%r rr)rprr rcmdsr cmdsDeferredrpasvCmdrNrrlportCmdrs` ` @r=rFTPClient._openDataConnection s>FFX' 71-XF))%) *Tc\\T *TQU   12 <<vH A!(G   g &    ( ( 3 > >tyy I#%5%5x7H7HIG""7TQUVA LL* +$  IIe  !(G(0'8'8G $'G     ' '(@(@(H(H I   g & &;G ".GL  # #$I J#%5%5w7O7OPG""7TQUVA LL* +C   c "CG *s HHc.[5nURUl[R"SU5nX2lU4SjnXAlUR R5RnUR5RnS[XV5-Ul g)z7 (Private) Generates the text of a given PORT command. rcHUR(aUR5 U$rl)r-r)rlisteners r= listenerFail3FTPClient.generatePortCommand..listenerFail s!!'')Lr<zPORT N) rgr r rr rPrrrrr")rprrrrrr s r=rFTPClient.generatePortCommand s"%&"++$$Q0 *2  $ ~~%%',,!&&!;; r<c&URSS5$)z; Returns a FTP escaped path (replace newlines with nulls).  rC)rcrws r= escapePathFTPClient.escapePath s ||D$''r<cSURU5-/nU(aURSS[U5-5 URXB5$)ae Retrieve a file from the given path This method issues the 'RETR' FTP command. The file is fed into the given Protocol instance. The data connection will be passive if self.passive is set. @param path: path to file that you wish to receive. @param protocol: a L{Protocol} instance. @param offset: offset to start downloading from @return: L{Deferred} zRETR rREST )rrrr)rprIr offsetrs r= retrieveFileFTPClient.retrieveFile sE$//$//0  KKGc&k1 3))$99r<cSURU5-/nU(aURSS[U5-5 URU5$)aa Store a file at the given path. This method issues the 'STOR' FTP command. @return: A tuple of two L{Deferred}s: - L{Deferred} L{IFinishableConsumer}. You must call the C{finish} method on the IFinishableConsumer when the file is completely transferred. - L{Deferred} list of control-connection responses. zSTOR rr)rrrr)rprIrrs r= storeFileFTPClient.storeFile sE$//$//0  KKGc&k1 3$$T**r<cX^^^TRSTRU5-5nTRSTRU5-5n/m[R"5mTR U4Sj5 UU4SjnUR TR U5 URT5 T$)a Rename a file. This method issues the I{RNFR}/I{RNTO} command sequence to rename C{pathFrom} to C{pathTo}. @param pathFrom: the absolute path to the file to be renamed @type pathFrom: C{str} @param pathTo: the absolute path to rename the file to. @type pathTo: C{str} @return: A L{Deferred} which fires when the rename operation has succeeded or failed. If it succeeds, the L{Deferred} is called back with a two-tuple of lists. The first list contains the responses to the I{RNFR} command. The second list contains the responses to the I{RNTO} command. If either I{RNFR} or I{RNTO} fails, the L{Deferred} is errbacked with L{CommandFailed} or L{BadResponse}. @rtype: L{Deferred} @since: 8.2 zRNFR zRNTO c >TU4$rlr5) toResponse fromResponses r=r"FTPClient.rename..J s |Z.Hr<cH>TR5 TRU5 grl)rr)rrrps r=ebFrom FTPClient.rename..ebFromL s  " NN7 #r<)rrr rrrr chainDeferred)rppathFrompathTo renameFromrenameTorrrs` @@r=rFTPClient.rename) s0,,Wtx7P-PQ **7T__V5L+LM !HI $  3 3V< v& r<cVUcSnURSURU5-/U5$)a< Retrieve a file listing into the given protocol instance. This method issues the 'LIST' FTP command. @param path: path to get a file listing for. @param protocol: a L{Protocol} instance, probably a L{FTPFileListProtocol} instance. It can cope with most common file listing formats. @return: L{Deferred} rAzLIST rrrprIr s r=rSFTPClient.listY s2 <D))7T__T5J+J*KXVVr<cVUcSnURSURU5-/U5$)a Retrieve a short file listing into the given protocol instance. This method issues the 'NLST' FTP command. NLST (should) return a list of filenames, one per line. @param path: path to get short file listing for. @param protocol: a L{Protocol} instance. rAzNLST rrs r=nlstFTPClient.nlstj s2 <D))7T__T5J+J*KXVVr<cHURSURU5-5$)zk Issues the CWD (Change Working Directory) command. @return: a L{Deferred} that will be called when done. zCWD rrrws r=rH FTPClient.cwdy s# &&v0E'EFFr<cHURSURU5-5$)a Make a directory This method issues the MKD command. @param path: The path to the directory to create. @type path: C{str} @return: A L{Deferred} which fires when the server responds. If the directory is created, the L{Deferred} is called back with the server response. If the server response indicates the directory was not created, the L{Deferred} is errbacked with a L{Failure} wrapping L{CommandFailed} or L{BadResponse}. @rtype: L{Deferred} @since: 8.2 zMKD r rws r=rFTPClient.makeDirectory #$&&v0E'EFFr<cHURSURU5-5$)a Delete a file on the server. L{removeFile} issues a I{DELE} command to the server to remove the indicated file. Note that this command cannot remove a directory. @param path: The path to the file to delete. May be relative to the current dir. @type path: C{str} @return: A L{Deferred} which fires when the server responds. On error, it is errbacked with either L{CommandFailed} or L{BadResponse}. On success, it is called back with a list of response lines. @rtype: L{Deferred} @since: 8.2 zDELE r rws r=rFTPClient.removeFile s#$&&w1F'FGGr<cHURSURU5-5$)a Delete a directory on the server. L{removeDirectory} issues a I{RMD} command to the server to remove the indicated directory. Described in RFC959. @param path: The path to the directory to delete. May be relative to the current working directory. @type path: C{str} @return: A L{Deferred} which fires when the server responds. On error, it is errbacked with either L{CommandFailed} or L{BadResponse}. On success, it is called back with a list of response lines. @rtype: L{Deferred} @since: 11.1 zRMD r rws r=rFTPClient.removeDirectory rr<c$URS5$)zg Issues the CDUP (Change Directory UP) command. @return: a L{Deferred} that will be called when done. CDUPrrvs r=cdupFTPClient.cdup s &&v..r<c$URS5$)a0 Issues the PWD (Print Working Directory) command. The L{getDirectory} does the same job but automatically parses the result. @return: a L{Deferred} that will be called when done. It is up to the caller to interpret the response, but the L{parsePWDResponse} method in this module should work. PWDrrvs r=rN FTPClient.pwd s&&u--r<cFSnUR5RU5$)z Returns the current remote directory. @return: a L{Deferred} that will be called back with a C{str} giving the remote directory or which will errback with L{CommandFailed} if an error response is returned. c*[USRSS5S5S:wa[e[US5nUc[R "[ U55$U$![[4a" [R "[ U55s$f=f)Nrrr0i)rrEr IndexErrorrrzrparsePWDResponse)rrIs r=cbParse'FTPClient.getDirectory..cbParse s >vaysA.q12c9$$:$F1I.D|}V'<==K  + >}V'<== >s+A /BB)rNr)rprs r= getDirectoryFTPClient.getDirectory s  xxz%%g..r<c$URS5$)z Issues the I{QUIT} command. @return: A L{Deferred} that fires when the server acknowledges the I{QUIT} command. The transport should not be disconnected until this L{Deferred} fires. rzrrvs r=quitFTPClient.quit s&&v..r<)rN)rztwisted@twistedmatrix.comr0)r) r6r7r8r9r:r r9rrnrPrrrrrrrretrrstorrrSrrHrrrrrNr!r$r;r5r<r=rr3 s(''NST&;" % (EN! TARGET - filename: e.g. 'LINK' - linktarget: e.g. 'TARGET' -rw-r--r-- 1 root other 531 Jan 29 03:26 N S -> L S - filename: e.g. 'N S' - linktarget: e.g. 'L S' @ivar files: list of dicts describing the files in this listing z^(?P.)(?P.{9})\s+(?P\d*)\s*(?P\S+)\s+(?P\S+)\s+(?P\d+)\s+(?P...\s+\d+\s+[\d:]+)\s+(?P.{1,}?)( -> (?P[^\r]*))?\r?$ rc/Ulgrlfilesrvs r=rnFTPFileListProtocol.__init__' s  r<cURUR5nURU5nUcURU5 gUR U5 grl)rrparseDirectoryLine unknownLineaddFile)rprrs r=r FTPFileListProtocol.lineReceived* sB{{4>>*  # #D ) 9   T " LLOr<cURRU5nUcgUR5nUSRSS5US'[ US5US'[ US5US'US(aUSRSS5US'U$)z Return a dictionary of fields, or None if line cannot be parsed. @param line: line of text expected to contain a directory entry @type line: str @return: dict Nfilenamez\ rnlinksr linktarget)fileLinePatternr groupdictrcr)rprrrs r=r0&FTPFileListProtocol.parseDirectoryLine2 s$$**40 =!AjM11%=AjMak*AhKAfIAfI"#L/"9"9%"E,Hr<c:URRU5 g)aA Append file information dictionary to the list of known files. Subclasses can override or extend this method to handle file information differently without affecting the parsing of data from the server. @param info: dictionary containing the parsed representation of the file information @type info: dict N)r-rG)rprs r=r2FTPFileListProtocol.addFileG s $r<cg)z Deal with received lines which could not be parsed as file information. Subclasses can override this to perform any special processing needed. @param line: unparsable line as received @type line: str Nr5rs r=r1FTPFileListProtocol.unknownLineU s r<r,N)r6r7r8r9r:rScompiler8 delimiterrrnrr0r2r1r;r5r<r=r)r) sB'Rjj -O II*    r<r)cf[R"SU5nU(aUR5S$g)z Returns the path from a response to a PWD command. Responses typically look like:: 257 "/home/andrew" is current directory. For this example, I will return C{'/home/andrew'}. If I can't find the path, I return L{None}. z"(.*)"rN)rSsearchgroups)rwrs r=rrc s+ IIh )E ||~a  r<rl)r[)r:rNr`rr]rSrrrQrN ImportErrorzope.interfacerrtwistedr twisted.credrrrrr r4r r r r twisted.protocolsrrtwisted.pythonrrrRESTART_MARKER_REPLYSERVICE_READY_IN_N_MINUTESrLrrrr+r!CMD_NOT_IMPLMNTD_SUPERFLUOUSSYS_STATUS_OR_HELP_REPLYr DIR_STATUSrHELP_MSGrSVC_READY_FOR_NEW_USERrSVC_CLOSING_CTRL_CNXr  DATA_CNX_OPEN_NO_XFR_IN_PROGRESSCLOSING_DATA_CNXrMr r#rrrbrlrrrNEED_ACCT_FOR_LOGINrSVC_NOT_AVAIL_CLOSING_CTRL_CNXrsr2r{REQ_ACTN_ABRTD_FILE_UNAVAILREQ_ACTN_ABRTD_LOCAL_ERRREQ_ACTN_ABRTD_INSUFF_STORAGErrrrrrrrrrNEED_ACCT_FOR_STORrzrr}rrrr PAGE_TYPE_UNKEXCEEDED_STORAGE_ALLOCFILENAME_NOT_ALLOWEDrtrr"rmr3rLr\rarbrhrjrQr|rTrVrXrZrrrrrrrrrrrr IConsumerrDr ClientFactoryr.rZrdrrq TimeoutMixinrvr!rrrCrHrYrnrprrrIRealmrr rrrrrrr r+r8r=r\rrBre ServerFactoryrgrlrrr)rr5r<r=rbs    2KKHH-11 ""'$   $"        #( !"   "%*"!(#  %  # "$     R .R  A R  $& R !#R  R &R  R "R !#R  7!R " oy )#R $%R &'R ( n)R *&+R ,-R .//R 0E1R 23R 4%'5R 8,9R :.;R <9=R @FAR B8CR DTER H KIR JzKR L!MR P:QR RSR V6WR X')YR ^#%_R bcR f9gR hPiR j !UkR l!mR p"$qR v&wR x=yR z8{R |<}R ~TR @