>Mc@sGdZddlZddlZddlmZddlZddlmZddlmZddl m Z m Z ddl m Z ddlmZdd lmZdd lmZmZmZmZmZdd lmZdd lmZdd lmZmZmZddl m!Z!m"Z"m#Z#ddl$m%Z%ddlm&Z&m'Z'e j(de)ddZ*e#j+j,rvdZ-ne.Z-dej/fdYZ0dej1fdYZ2de j3fdYZ4de4fdYZ5de4fdYZ6de4fd YZ7d!e4fd"YZ8d#e8fd$YZ9d%e j3fd&YZ:d'ej1fd(YZ;d)e&j<fd*YZ=d+e j3fd,YZ>d-e j3fd.YZ?d/e j3fd0YZ@d1e j3fd2YZAd3e j3fd4YZBd5e j3fd6YZCd7e j3fd8YZDd9e j3fd:YZEd;e j3fd<YZFd=e j3fd>YZGd?fd@YZHdAe j3eHfdBYZIdCeJfdDYZKdEeJfdFYZLdGfdHYZMdIe j3eMfdJYZNdKfdLYZOdMfdNYZPdOe j3fdPYZQdS(Qs) FTP tests. Maintainer: Andrew Bennetts iN(tStringIO(t implements(t verifyClass(tunittesttutil(tinsecureRandom(tIRealm(tbasic(treactorttasktprotocoltdeferterror(t IConsumer(tUnauthorizedLogin(tportaltcheckerst credentials(tfailuretfilepathtruntime(t proto_helpers(tftptloopbacktcategorytmessagesbFTPClient\.changeDirectory is deprecated in Twisted 8\.2 and newer\. Use FTPClient\.cwd instead\.sCannot run on WindowstDummycBs;eZdZdZdZdZdZdZRS(cCsg|_g|_dS(N(tlinestrawData(tself((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt__init__.s cCs|j|_dS(N(tfactorytf(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytconnectionMade1scCs|jj|dS(N(Rtappend(Rtline((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt lineReceived3scCs|jj|dS(N(RR"(Rtdata((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytrawDataReceived5scCsdS(N((RR#((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytlineLengthExceeded7sN( t__name__t __module__tNonetlognameRR!R$R&R'(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR,s     t_BufferingProtocolcBs#eZdZdZdZRS(cCsd|_tj|_dS(Nt(tbufferR tDeferredtd(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR!<s cCs|j|7_dS(N(R.(RR%((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt dataReceived?scCs|jj|dS(N(R0tcallback(Rtreason((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytconnectionLostAs(R(R)R!R1R4(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR,;s  tFTPServerTestCasecBsJeZdZejZdZdZddZ dddZ dZ RS(sw Simple tests for an FTP server with the default settings. @ivar clientFactory: class used as ftp client. t anonymouscsOj_tjjtjj_tjt j j}|j t j tjt jd|dj_tjdjdd}j|jjjtjfd}|j_|jj}tjtj}|jd|}fd}|j |tj!|gS(NRt userAnonymousit interfaces 127.0.0.1csNj`|}|j_fd}j|jd|S(Ncs)jjdk r%jjjndS(N(tserverProtocolt transportR*tloseConnection((R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt cleanupServerhs(Rt buildProtocoltwrappedProtocolR9t addCleanupR2R*(taddrR R<(RR=td1(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt_rememberProtocolInstancebs     cs#|_jjjjdS(N(tclientR?R:R;(RC(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt gotClientts ("tmktempt directorytostmkdirRtFilePathtdirPathRtPortalRtFTPRealmtregisterCheckerRtAllowAnonymousAccessRt IAnonymoust FTPFactoryR7RRt listenTCPR?t stopListeningR=R R/tgetHosttportR t ClientCreatort clientFactoryt connectTCPt addCallbackt gatherResults(RtpRTRBtportNumt clientCreatortd2RD((RR=RAs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytsetUpOs(     cs@|dkrtjd}nfd}|j|S(sAsserts that a sending an FTP command receives the expected response. Returns a Deferred. Optionally accepts a deferred to chain its actions to. cs1jj}fd}|j|S(Ncsj|dS(N(t assertEquals(t responseLines(RtexpectedResponseLines(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt gotResponses(RCtqueueStringCommandRX(tignoredR0Rb(RRatcommand(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt queueCommandsN(R*R tsucceedRX(RReRat chainDeferredRf((RRaRes9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytassertCommandResponsezs cso|dkrtjd}nfd}|j|j|tjfd}|j|S(NcsjjS(N(RCRc(Rd(RRe(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRfscs*dk r&j|jdndS(Ni(R*tfailUnlessEqualtargs(t exception(texpectedResponseR(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytfaileds (R*R RgRXt assertFailureRt CommandFailed(RReRmRhRfRn((RReRms9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytassertCommandFaileds  cCs.|jddg}|jddgd|S(NsUSER anonymouss8331 Guest login ok, type your email address as password.sPASS test@twistedmatrix.coms2230 Anonymous login ok, access restrictions apply.Rh(Ri(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt_anonymousLogins  N( R(R)t__doc__RtFTPClientBasicRVR7R^R*RiRqRr(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR5Fs  ,  tFTPAnonymousTestCasecBseZdZdZdZRS(s Simple tests for an FTP server with different anonymous username. The new anonymous username used in this test case is "guest" tguestcCs.|jddg}|jddgd|S(s Tests whether the changing of the anonymous username is working or not. The FTP server should not comply about the need of password for the username 'guest', letting it login as anonymous asking just an email address as password. s USER guests8331 Guest login ok, type your email address as password.sPASS test@twistedmatrix.coms2230 Anonymous login ok, access restrictions apply.Rh(Ri(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_anonymousLogins  (R(R)RsR7Rw(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRustBasicFTPServerTestCasecBseZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZejeZdZdZdZdZRS(c sddddddddd d g }fd }g}xM|D]E}jj|}j|tj|j||j|q@Wtj|d t S( skWhen not logged in, all commands other than USER and PASS should get NOT_LOGGED_IN errors. tCDUPtCWDtLISTtMODEtPASVtPWDtRETRtSTRUtSYSTtTYPEcs9|jd}j|djdd|dfdS(Niit530s"Response didn't start with 530: %r(Rkt failUnlesst startswith(RltfailureResponseLines(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt checkResponses tfireOnOneErrback( RCRcRoRRpRXR"R t DeferredListtTrue(Rt commandListRt deferredsRetdeferred((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttestNotLoggedInReplys  cCs|jddgS(s.Issuing PASS before USER should give an error.sPASS foos=503 Incorrect sequence of commands: USER required before PASS(Rq(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttestPASSBeforeUSERscCs|jddgS(s2Issuing USER without a username is a syntax error.tUSERs,500 Syntax error: USER requires an argument.(Rq(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttestNoParamsForUSERscCs+|jjd}|jddgd|S(s2Issuing PASS without a password is a syntax error.sUSER footPASSs,500 Syntax error: PASS requires an argument.Rh(RCRcRq(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttestNoParamsForPASSs  cCs |jS(N(Rr(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttestAnonymousLoginscCs%|j}|jddgd|S(s)Issuing QUIT should return a 221 message.tQUITs 221 Goodbye.Rh(RrRi(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttestQuits   cCst|j_tj}|jjj|tj|j ddg}|j ddgd|}|j ddgd|}|S(NsUSER anonymouss$331 Password required for anonymous.sPASS test@twistedmatrix.coms!530 Sorry, Authentication failed.RhR~s$530 Please login with USER and PASS.( tFalseRtallowAnonymousRt'InMemoryUsernamePasswordDatabaseDontUseRRMRtIUsernamePasswordRiRq(RtdenyAlwaysCheckerR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttestAnonymousLoginDenieds         cCs%|j}|jddgd|S(s When an anonymous user attempts to edit the server-side filesystem, they will receive a 550 error with a descriptive message. s MKD newdirs:550 Anonymous users are forbidden to change the filesystemRh(RrRq(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_anonymousWriteDenieds   cCs%|j}|jddgd|S(Nt GIBBERISHs'502 Command 'GIBBERISH' not implementedRh(RrRq(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttestUnknownCommands   cCs%|j}|jddgd|S(NsRETR foosE503 Incorrect sequence of commands: PORT or PASV required before RETRRh(RrRq(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttestRETRBeforePORT"s   cCs%|j}|jddgd|S(NsSTOR foosE503 Incorrect sequence of commands: PORT or PASV required before STORRh(RrRq(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttestSTORBeforePORT*s   cCsB|j}|jddgd||jddgd||S(NsMODE zs&504 Not implemented for parameter 'z'.RhsSTRU Is&504 Not implemented for parameter 'I'.(RrRq(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttestBadCommandArgs2s   cCs|jtjddtd}xXtdD]J}t|}d||s   ccstj|j}|V|jtj|jjd}|V|j}tj|dd\}}|j||j j j j |j j jdS(NR}ii(R twaitForDeferredRrt getResultRCRcRRt assertEqualR9tdtpPortRSRTR:R;(RtwfdtpasvCmdR`thostRT((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttestPASVHs  cCs)|j}|jddgd||S(NRs215 UNIX Type: L8Rh(RrRi(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttestSYST[s cCs8d}||j_|jt|jjtjdS(s Exceptions other than L{error.CannotListenError} which are raised by C{listenFactory} should be raised to the caller of L{FTP.getDTPPort}. cSs tdS(N(t RuntimeError(t portNumberR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt listenFactorygsN(R9RRRt getDTPPortR tFactory(RR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_portRangeForwardErrorbs  cCsd}||j_|jjtj}|j|dtdd|j_|jjtj}|j|dtdd|j_|jt j |jjtjdS(s3 L{FTP.passivePortRange} should determine the ports which L{FTP.getDTPPort} attempts to bind. If no port from that iterator can be bound, L{error.CannotListenError} should be raised, otherwise the first successful result from L{FTP.listenFactory} should be returned. cSs(|dkr$tjd|dn|S(NiViViVt localhostR (iViViV(R tCannotListenError(RR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRvs iiViiVN( R9RRR RR_txrangetpassivePortRangeRR R(RRRT((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_portRangeos    cCsGtdd}||j_|jjd}|j||jjdS(s The L{FTP} instances created by L{ftp.FTPFactory.buildProtocol} have their C{passivePortRange} attribute set to the same object the factory's C{passivePortRange} attribute is set to. iiN(RRRR=R*RR>(Rt portRangeR ((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt"test_portRangeInheritedFromFactorys (R(R)RRRRRRRRRRRRRRR tdeferredGeneratorRRRR(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRxs&             tFTPServerTestCaseAdvancedClientcBs)eZdZejZdZdZRS(s: Test FTP server with the L{ftp.FTPClient} class. csGfd}jjd\}}|j|tj||gS(sl Try to make an STOR as anonymous, and check that we got a permission denied error. cs2|jtjj|jjddddS(Nis550 foo: Permission denied.(ttrapRRpR_tvalueRk(tres(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytebstfoo(RCt storeFilet addErrbackR RY(RRRAR]((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_anonymousSTORs csdtjfdYfd}jtjd|fd}jjd\}}|j|tj||gS(sj Any errors during writing a file inside a STOR should be returned to the client. tFailingFileWritercBseZdZRS(cSstjtjdS(Ntblah(R tfailRtIsNotADirectoryError(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytreceives(R(R)R(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRscstjdS(N(R RgR*(tatb(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt failingSTORstopenForWritingcs<j|jtjj|jjddddS(Nis'550 Cannot rmd, blah is not a directory(tflushLoggedErrorsRRRpR_RRk(R(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRs  t failing_file( Rt _FileWritertpatchtFTPAnonymousShellRCRRR RY(RRRRAR]((RRs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_STORwriteErrors (R(R)RsRt FTPClientRVRR(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRs  t#FTPServerPasvDataConnectionTestCasecBsVeZddZddZdZdZdZdZdZ dZ RS( cCs(|jjd}d}|j|S(NR}cSs?tj|dd\}}tjtt}|jd|S(Niis 127.0.0.1(RRR RURR,RW(R`RRTtcc((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytgotPASVs(RCRcRX(RRdR0R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt_makeDataConnections csc|dkrtjd}n|jjfd}|j|d}|j|S(Ncs.jj}|j}tj||gS(N(RCRcR0R RY(t downloaderRAR](RRe(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRfs cSs|\}}|jS(N(R.(t.0RdR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt downloadDones (R*R RgRXR(RReRhRfR((RRes9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt _downloads   cs;j}jdd|fd}|j|S(NR{Rhcsjd|dS(NR-(R(tresult(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt checkEmptys(RrRRX(RR0R((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt testEmptyLISTs cs"tjtjjjdtjtjjjdj}jdd|fd}|j|jdd|fd}|j|jdd|fd }|j|fd }|j|jdd|fd }|j|S( NRtbarR{Rhcs'jdt|d jddS(Niis (Rtlentsplit(tdownload(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt checkDownloadssNLST cs7|d jd}|jjddg|dS(Nis RR(RtsortR(Rt filenames(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRs sLIST foocsjd|dS(NR-(R(R(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRscsjjdS(NsCWD foo(RCRc(Rd(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytchdir scsjd|dS(NR-(R(R(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRs(RGRHtpathRRFRrRRX(RR0RR((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttestTwoDirLISTs"     csj}xtdddD]}ttjjjd|fd}|jd||jj d|fd||fd }|j |qW|S( Niiis%d.txttwbtxs RETR %d.txtRhcsj|t|dS(N(RR(Rtsize(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR!s( RrRtfileRGRRRFtwritetcloseRRX(RR0RtfObjR((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttestManyLargeDownloadss ( csgj}jjdjjjdjjdd|fd}|j|S(sp NLST with no argument returns the directory listing for the current working directory. stest.txtRsNLST Rhcs7|d jd}|jjddg|dS(Nis Rstest.txt(RRR_(RR(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR5s (RrRJtchildttouchtcreateDirectoryRRX(RR0R((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_NLSTEmpty's  cs;j}jdd|fd}|j|S(sH NLST on a non-existent file/directory returns nothing. sNLST nonexistent.txtRhcsjd|dS(NR-(R_(R(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRDs(RrRRX(RR0R((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_NLSTNonexistent<s csQj}jjdjjdd|fd}|j|S(sN NLST on an existent file returns only the path to that file. stest.txts NLST test.txtRhcs*|d jd}jdg|dS(Nis stest.txt(RR_(RR(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRTs(RrRJRRRRX(RR0R((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_NLSTOnPathToFileIs  N( R(R)R*RRRRRRRR(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRs  )   t#FTPServerPortDataConnectionTestCasecBs/eZdZddZdZdZRS(cCsg|_tj|S(N(t dataPortsRR^(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR^\s cstjdtjffdY}tjd|dd}|jj|dtj d|j j }|j j |S(Nt DataFactorycseZeZfdZRS(cs/tjj||}tjdj||S(Ni(R t ServerFactoryR=Rt callLaterR2(RR@RZ(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR=fs(R(R)R,R R=((R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRdsiR8s 127.0.0.1sPORT (R R/R RRRQRR"RtencodeHostPortRSRTRCRc(RRdRtdataPorttcmd((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR`s cCs]g|jD]}tj|j^q }tjtj|}|j|tj|dtS(NR( RR t maybeDeferredRRRttearDownR"RR(RRTtlR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR ps ( cs>j}d}|j|fd}|j|S(NcsStjdtjdd}|jj|j}|jfd|S(NiR8s 127.0.0.1csS(N((t_(R[(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyts(RRQR RRSRTRRRX(RdRTR0((R[s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytloggedIn}s   cs#jdtjd|dgS(NsPORT s 127.0.0.1s425 Can't open data connection.(RqRR (R[(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt gotPortNums(RrRX(RR0RR((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttestPORTCannotConnectws    N(R(R)R^R*RR R(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR[s   tDTPFactoryTestscBsMeZdZdZdZdZdZdZdZdZ RS(s& Tests for L{ftp.DTPFactory}. cCsStj|_dtfdY}||_tj|jd|j|_dS(sf Create a fake protocol interpreter and a L{ftp.DTPFactory} instance to test. tProtocolInterpretercBseZdZRS(N(R(R)R*t dtpInstance(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRsN( R tClockRtobjecttprotocolInterpreterRt DTPFactoryR*R(RR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR^s  cCsg}|j|jjtj}|j|j|jjd|jj d|j ||jj d|j ||j |jj dS(s L{ftp.DTPFactory.setTimeout} uses the reactor passed to its initializer to set up a timed event to time out the DTP setup after the specified number of seconds. iiiN( RoRRRtPortConnectionErrorRXR"t setTimeoutRtadvancet assertFalset assertTruetcalls(RtfinishedR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_setTimeouts  cCsE|jjd}|j|tj|j|jjdddS(s A L{ftp.DTPFactory} instance's C{buildProtocol} method can be used once to create a L{ftp.DTP} instance. N(RR=R*tassertIsInstanceRtDTPtassertIdentical(RR ((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_buildProtocolOncescCs9|jjd|jjd}|j|jjdS(s If a timeout has been set up using L{ftp.DTPFactory.setTimeout}, it is cancelled by L{ftp.DTPFactory.buildProtocol}. i N(RRR=R*RRR (RR ((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_timeoutAfterConnectionscCs[|j|jjtj}|jjd|jjd|j|jj dd|S(s If L{ftp.DTPFactory.buildProtocol} is called after the timeout specified by L{ftp.DTPFactory.setTimeout} has elapsed, C{None} is returned. i N( RoRRRRRRRR%R=R*(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_connectionAfterTimeouts cCsg}|j|jjtj}|j|j|jjd|j||jj dd|j ||j j d|S(s  L{ftp.DTPFactory.deferred} fails with L{PortConnectionError} when L{ftp.DTPFactory.clientConnectionFailed} is called. If the timeout specified with L{ftp.DTPFactory.setTimeout} expires after that, nothing additional happens. i N(RoRRRRRXR"RRtclientConnectionFailedR*RRR(RR!R0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt!test_timeoutAfterConnectionFaileds  cCs[|j|jjtj}|jjd|jjd|jjdt j d|S(s If L{ftp.DTPFactory.clientConnectionFailed} is called after the timeout specified by L{ftp.DTPFactory.setTimeout} has elapsed, nothing beyond the normal timeout before happens. i RN( RoRRRRRRRR)R*R t TimeoutError(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt!test_connectionFailedAfterTimeouts ( R(R)RsR^R"R&R'R(R*R,(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRs    t PrintLinescBs eZdZdZdZRS(s)Helper class used by FTPFileListingTests.cCs ||_dS(N(t_lines(RR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRscCs9x%|jD]}|jj|dq W|jjdS(Ns (R.R:RR;(RR#((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR! s(R(R)RsRR!(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR-s tMyFTPFileListProtocolcBseZdZdZRS(cCsg|_tjj|dS(N(totherRtFTPFileListProtocolR(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR's cCs|jj|dS(N(R0R"(RR#((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt unknownLine+s(R(R)RR2(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR/&s tFTPFileListingTestscBs5eZdZdZdZdZdZRS(cs;ttjt|}|jfd|S(NcsjjfS(N(tfilesR0(R(tfileList(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR3s(R/Rt loopbackAsyncR-RX(RRR0((R5s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytgetFilesForLines0s cs.d}fd}j|gj|S(Ns<-rw-r--r-- 1 root other 531 Jan 29 03:26 READMEcs|\\}}j|dt|j|ddkdj|ddkdj|dd kdj|d d kdj|d d kdj|ddkdj|ddkdj|ddkdj|dddS(Nsunexpect unparsable lines: %stfiletypet-smisparsed fileitemtpermss rw-r--r--smisparsed permstownertroottgroupR0Ritdates Jan 29 03:26tfilenametREADMEtnlinksismisparsed nlinkst linktargetsmisparsed linktarget(tfailIftreprR(RR0R(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytcheck9s (R7RX(RR#RE((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt testOneLine6s cs@d}d}d}fd}j|||gj|S(Ns7drw-r--r-- 2 root other 531 Jan 9 2003 As<lrw-r--r-- 1 root other 1 Jan 29 03:26 B -> Aswoohoo! cs|\\}}\}j|dkdj|ddkdj|ddkdj|d d kd j|d d kdj|ddkdj|ddkdj|ddkdj|ddkdj|ddj|ddkdj|ddkdj|d d kd j|d d kdj|ddkdj|ddkdj|dd kdj|ddkdj|ddkddS(!Ns woohoo! sincorrect other lineR8R0smisparsed fileitemR:s rw-r--r--smisparsed permsR;R<smisparsed ownerR=R0smisparsed groupRismisparsed sizeR>s Jan 9 2003smisparsed dateR?tAsmisparsed filenameRAismisparsed nlinksRBsmisparsed linktargetRis Jan 29 03:26tB(RRC(Rtfile1tfile2R0(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyREJs((R7RX(Rtline1tline2tline3RE((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttestVariantLinesFs cs+fd}jddgj|S(NcsF|\}}j|dj|ddgkdt|dS(Nsunexpected file entriessABC s not a file sincorrect unparsable lines: %s(RCRRD(RR4tothers(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyREcs tABCs not a file(R7RX(RRE((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttestUnknownLinebscsetjddtjffdY}fd}tj|}|j|S(Ns<-rw-r--r-- 1 root other 531 Jan 29 2003 README t PrintLinecseZfdZRS(cs!|jj|jjdS(N(R:RR;(R(t exampleLine(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR!os(R(R)R!((RS(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRRnscs_jd}j|ddkdj|ddkdj|ddkddS( NiRismisparsed fileitemR>s Jan 29 2003R?R@(R4R(RdR(RR5(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyREss (RR1R tProtocolRR6RX(RRRRER0((RSRR5s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttestYearis  (R(R)R7RFRNRQRU(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR3/s     tFTPClientTestscBseZdZdZRS(cstj}d|_tjd|dd}|j|j|jj}ddddd|d ?|d @fd gfd |_ t j d d}tj tt j d d}|j d|}d}|j||j|t jS(NiR8s 127.0.0.1s1220 ready, dude (vsFTPd 1.0.0: beat me, break me)s 331 Please specify the password.s230 Login successful. Have fun.s200 Binary it is, then.s+227 Entering Passive Mode (127,0,0,1,%d,%d)iis550 Failed to open file.cs tS(N(R-(R@(t responses(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRstpassiveicSstj}|jd|S(Ns/file/that/doesnt/exist(R RTt retrieveFile(RCRZ((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRDs (R RtnoisyRRQR?RRRSRTR=RRRURWRXRoRp(RR RTR[RCRR0RD((RWs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttestFailedRETRs&     cstj}tj}|j|||_|jdt}gfd}|j|ddl m }|j t j ||j|S(sl Test the ftp command errbacks when a connection lost happens during the operation. s some pathcsj|dS(N(R"R*(R(tm(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt_ebs i(tCONNECTION_LOST(RRRt StringTransportWithDisconnectiontmakeConnectionR RRRttwisted.internet.mainR^R4RtFailureR(Rt ftpClientttrR0R]R^((R\s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_errbacksUponDisconnects     (R(R)R[Re(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRV}s tFTPClientTestCasecBseZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZdZdZdZdZdZege_dZege_dZege_dZdZ dZ!dZ"dZ#d Z$d!Z%d"Z&d#Z'd$Z(d%Z)d&Z*d'Z+d(Z,RS()s, Test advanced FTP client commands. cCsDtj|_tj|_|jj|j|j|j_dS(sG Create a FTP client and connect it to fake transport. N(RRRCRR_R:R`R (R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR^scCs|jjtjdS(s Deliver disconnection notification to the client so that it can perform any cleanup which may be required. N(RCR4R tConnectionLost(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR scCs|j|jjd|jjd|j|jjd|jj|jjd|j|jjd|jj|jjddS(s& Test the login part. R-s8331 Guest login ok, type your email address as password.sUSER anonymous s2230 Anonymous login ok, access restrictions apply.sTYPE I s200 Type set to I.N(R_R:RRCR$tclear(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt _testLogins    cskfd}jjjj|}jjjdjjjjd|S(s Test the CDUP command. L{ftp.FTPClient.cdup} should return a Deferred which fires with a sequence of one element which is the string the server sent indicating that the command was executed successfully. (XXX - This is a bad API) csj|dddS(Nis&250 Requested File Action Completed OK(R_(R(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytcbCdupssCDUP s&250 Requested File Action Completed OK( RiRCtcdupRXR_R:RRhR$(RRjR0((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt test_CDUPs   cCsf|j|jj}|j|tj|j|jjd|jj |jj d|S(s Test L{ftp.FTPClient.cdup}'s handling of a failed CDUP command. When the CDUP command fails, the returned Deferred should errback with L{ftp.CommandFailed}. sCDUP s!550 ..: No such file or directory( RiRCRkRoRRpR_R:RRhR$(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_failedCDUPs  cs^fd}jjjj|}jjjdjjd|S(s Test the PWD command. L{ftp.FTPClient.pwd} should return a Deferred which fires with a sequence of one element which is a string representing the current working directory on the server. (XXX - This is a bad API) cs!jtj|dddS(Nis/bar/baz(R_RtparsePWDResponse(R(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytcbPwdssPWD s257 "/bar/baz"(RiRCtpwdRXR_R:RR$(RRoR0((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_PWDs  cCsY|j|jj}|j|tj|j|jjd|jj d|S(s Test a failure in PWD command. When the PWD command fails, the returned Deferred should errback with L{ftp.CommandFailed}. sPWD s'550 /bar/baz: No such file or directory( RiRCRpRoRRpR_R:RR$(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_failedPWDs  csafd}jjjdj|}jjjdjjd|S(s Test the CWD command. L{ftp.FTPClient.cwd} should return a Deferred which fires with a sequence of one element which is the string the server sent indicating that the command was executed successfully. (XXX - This is a bad API) csj|dddS(Nis&250 Requested File Action Completed OK(R_(R(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytcbCwd+ssbar/foos CWD bar/foo s&250 Requested File Action Completed OK(RiRCtcwdRXR_R:RR$(RRsR0((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_CWD!s  cCs\|j|jjd}|j|tj|j|jjd|jj d|S(s Test a failure in CWD command. When the PWD command fails, the returned Deferred should errback with L{ftp.CommandFailed}. sbar/foos CWD bar/foo s&550 bar/foo: No such file or directory( RiRCRtRoRRpR_R:RR$(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_failedCWD5s  csfd}fd}|j_jt}jjd|}|j||jjjdjj jj dt j ddfjjjdjj jj d |S( sN Test the RETR command in passive mode: get a file and verify its content. L{ftp.FTPClient.retrieveFile} should return a Deferred which fires with the protocol instance passed to it after the download has completed. (XXX - This API should be based on producers and consumers) csj|jdddS(NRi(R_R.(Rtproto(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytcbRetrOscsj|dj|d|j||f}|jtjjjd|jdd|jt j t j ddS(Ns 127.0.0.1i90s4150 File status okay; about to open data connection.RiR-( R_R=R`RtStringTransportRCR$R1R4RRbR tConnectionDone(RRTRRw(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt cbConnectRs tspamsPASV s227 Entering Passive Mode (%s).s 127.0.0.1i90s RETR spam s226 Transfer Complete.( RCtconnectFactoryRiR,RYRXR_R:RRhR$RR (RRxR{RwR0((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_passiveRETRDs       cstj_d}fd}|j_jt}jjd|}|j||jj j dt j ddfj j jjdjj j dj j jjd |S( s Test the RETR command in non-passive mode. Like L{test_passiveRETR} but in the configuration where the server establishes the data connection to the client, rather than the other way around. cSsldtjddf|_|jjtj|jjdd|jjt j t j ddS(NsPORT %ss 127.0.0.1i&RiR-( RR ttextR R`RRyR1R4RRbR Rz(tportCmd((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt generatePortus  csj|jdddS(NRi(R_R.(RRw(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRx|sR|s PORT %s s 127.0.0.1i&s 200 PORT OKs RETR spam s226 Transfer Complete.(RRCRXtgeneratePortCommandRiR,RYRXR_R:RRR RhR$(RRRxRwR0((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt test_RETRks        csfd}|j_jt}jjd|}j|tjjj j dj j jj dtj ddfjj j dj j jj d|S( s Try to RETR an unexisting file. L{ftp.FTPClient.retrieveFile} should return a Deferred which errbacks with L{ftp.CommandFailed} if the server indicates the file cannot be transferred for some reason. cs{j|dj|d|j||f}|jtjjjd|jtj t j ddS(Ns 127.0.0.1i90s4150 File status okay; about to open data connection.R-( R_R=R`RRyRCR$R4RRbR Rz(RRTRRw(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR{s R|sPASV s227 Entering Passive Mode (%s).s 127.0.0.1i90s RETR spam s#550 spam: No such file or directory(RCR}RiR,RYRoRRpR_R:RRhR$R (RR{RwR0((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_failedRETRs      cst|j_gfd}||j_|jt}|jjd|}|j|jj dt j ddf|jj |jj d|j|jj d|jdj|jj|j|t j|S( s Try a RETR, but disconnect during the transfer. L{ftp.FTPClient.retrieveFile} should return a Deferred which errbacks with L{ftp.ConnectionLost) csidtjddf|_tj}|jj||j|_|jjddj|dS(NsPORT %ss 127.0.0.1i&Ri( RR RRR_R R`R1R"(RRd(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRs   R|s PORT %s s 127.0.0.1i&s 200 PORT OKs RETR spam i(RRCRXRRiR,RYR_R:RRR RhR$tassert_R;RoRg(RRRwR0((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt test_lostRETRs"       cstjfd}fd}fd}|j_jjjd\}}|j||j|jjj djj jj dt j ddfjjj d jj jj d tj||gS( s Test the STOR command: send a file and verify its content. L{ftp.FTPClient.storeFile} should return a two-tuple of Deferreds. The first of which should fire with a protocol instance when the data connection has been established and is responsible for sending the contents of the file. The second of which should fire when the upload has completed, the data connection has been closed, and the server has acknowledged receipt of the file. (XXX - storeFile should take a producer as an argument, instead, and only return a Deferred which fires when the upload has succeeded or failed). csQjjd|jjdd|j|jtjtj ddS(Ns4150 File status okay; about to open data connection.RiR-( RCR$R:RtfinishR4RRbR Rz(tsender(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytcbStores   csjjdddS(NRi(R_R(tign(RRd(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytcbFinishscsFj|dj|d|j||f}|jdS(Ns 127.0.0.1i90(R_R=R`(RRTRRw(RRd(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR{sR|sPASV s227 Entering Passive Mode (%s).s 127.0.0.1i90s STOR spam s226 Transfer Complete.(RRyRCR}RiRRXR_R:RRhR$RR R RY(RRRR{RAR]((RRds9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_passiveSTORs"        cs tjfd}fd}|j_jjjd\}}|j|j|tj j j j dj j jjdtjddfj j j dj j jjd tj||gS( s Test a failure in the STOR command. If the server does not acknowledge successful receipt of the uploaded file, the second Deferred returned by L{ftp.FTPClient.storeFile} should errback with L{ftp.CommandFailed}. csQjjd|jjdd|j|jtjtj ddS(Ns4150 File status okay; about to open data connection.RiR-( RCR$R:RRR4RRbR Rz(R(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRs   csFj|dj|d|j||f}|jdS(Ns 127.0.0.1i90(R_R=R`(RRTRRw(RRd(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR{sR|sPASV s227 Entering Passive Mode (%s).s 127.0.0.1i90s STOR spam s.426 Transfer aborted. Data connection closed.(RRyRCR}RiRRXRoRRpR_R:RRhR$R R RY(RRR{RAR]((RRds9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_failedSTORs"        cstjtj_fd}fd}fd}|j_jjjd\}}|j||j|t j ||gS(s Test the STOR command in non-passive mode. Like L{test_passiveSTOR} but in the configuration where the server establishes the data connection to the client, rather than the other way around. cs-dtjdd|_|jjdS(NsPORT %ss 127.0.0.1i&(RR RR R`(R(Rd(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR/scsjjjdtjddfjjjjdjjjdjjjjd|jjdd|j |j t j t jd jjd dS( Ns PORT %s s 127.0.0.1i&s 200 PORT OKs STOR spam s4150 File status okay; about to open data connection.RiR-s226 Transfer Complete.(R_R:RRR RhRCR$RRR4RRbR Rz(R(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR3s    csjjdddS(NRi(R_R(R(RRd(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRAsR|( RRyRRCRXRRiRRXR RY(RRRRRAR]((RRds9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt test_STOR%s      csfd}fd}|j_jtj}jjd|j||}jjj djj jj dtj ddfjjj djj d |S( s{ Test the LIST command. L{ftp.FTPClient.list} should return a Deferred which fires with a protocol instance which was passed to list after the command has succeeded. (XXX - This is a very unfortunate API; if my understanding is correct, the results are always at least line-oriented, so allowing a per-line parser function to be specified would make this simpler, but a default implementation should really be provided which knows how to deal with all the formats used in real servers, so application developers never have to care about this insanity. It would also be nice to either get back a Deferred of a list of filenames or to be able to consume the files as they are received (which the current API does allow, but in a somewhat inconvenient fashion) -exarkun) csWg|jD]}|d^q }dddg}|j|jj||dS(NR?RRtbaz(R4RR_(RR5R tflstexpected(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytcbList_s    csj|dj|d|j||f}|jtjjjddddg}x|D]}|j|qnW|jt j t j ddS(Ns 127.0.0.1i90s4150 File status okay; about to open data connection.s8-rw-r--r-- 0 spam egg 100 Oct 10 2006 foo s8-rw-r--r-- 3 spam egg 100 Oct 10 2006 bar s8-rw-r--r-- 4 spam egg 100 Oct 10 2006 baz R-( R_R=R`RRyRCR$R1R4RRbR Rz(RRTRRwtsendingR(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR{fs   sfoo/barsPASV s227 Entering Passive Mode (%s).s 127.0.0.1i90sLIST foo/bar s226 Transfer Complete.( RCR}RiRR1RRXR_R:RRhR$R (RRR{R5R0((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_passiveLISTLs   !  cstj_fd}fd}|j_jtj}jjd|j||}j j j dtj ddfj j jjdj j j dj j jjd |S( s Test the LIST command in non-passive mode. Like L{test_passiveLIST} but in the configuration where the server establishes the data connection to the client, rather than the other way around. csdtjddf|_|jjtjjjddddg}x|D]}|jj |qXW|jj t j t jddS( NsPORT %ss 127.0.0.1i&s4150 File status okay; about to open data connection.s8-rw-r--r-- 0 spam egg 100 Oct 10 2006 foo s8-rw-r--r-- 3 spam egg 100 Oct 10 2006 bar s8-rw-r--r-- 4 spam egg 100 Oct 10 2006 baz R-(RR RR R`RRyRCR$R1R4RRbR Rz(RRR(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRs    csWg|jD]}|d^q }dddg}|j|jj||dS(NR?RRR(R4RR_(RR5R RR(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRs    sfoo/bars PORT %s s 127.0.0.1i&s 200 PORT OKsLIST foo/bar s226 Transfer Complete.(RRCRXRRiRR1RRXR_R:RR RhR$(RRRR5R0((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt test_LISTs    !  csfd}|j_jtj}jjd|}j|tjjj j dj j jj dtj ddfjj j djj d|S( s Test a failure in LIST command. L{ftp.FTPClient.list} should return a Deferred which fails with L{ftp.CommandFailed} if the server indicates the indicated path is invalid for some reason. cs{j|dj|d|j||f}|jtjjjd|jtj t j ddS(Ns 127.0.0.1i90s4150 File status okay; about to open data connection.R-( R_R=R`RRyRCR$R4RRbR Rz(RRTRRw(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR{s sfoo/barsPASV s227 Entering Passive Mode (%s).s 127.0.0.1i90sLIST foo/bar s&550 foo/bar: No such file or directory(RCR}RiRR1RRoRpR_R:RRhR$R (RR{R5R0((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_failedLISTs     cstj_fd}fd}|j_jt}jjd|j||}jj j dt j ddfj j jjdjj j djjd |S( s Test the NLST command in non-passive mode. L{ftp.FTPClient.nlst} should return a Deferred which fires with a list of filenames when the list command has completed. csdtjddf|_|jjtjjjd|jj d|jj d|jj d|jj t j t jddS( NsPORT %ss 127.0.0.1i&s4150 File status okay; about to open data connection.sfoo sbar sbaz R-(RR RR R`RRyRCR$R1R4RRbR Rz(R(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRs  csF|jj}dddg}|j|jj||dS(NRRR(R.t splitlinesRR_(RRwRR(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRs   sfoo/bars PORT %s s 127.0.0.1i&s 200 PORT OKsNLST foo/bar s226 Transfer Complete.(RRCRXRRiR,tnlstRXR_R:RRR RhR$(RRRtlstprotoR0((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt test_NLSTs     ! csfd}fd}|j_jt}jjd|j||}jjjdjj jj dt j ddfjjjdjj d |S( s Test the NLST command. Like L{test_passiveNLST} but in the configuration where the server establishes the data connection to the client, rather than the other way around. csF|jj}dddg}|j|jj||dS(NRRR(R.RRR_(RRwRR(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRs   csj|dj|d|j||f}|jtjjjd|jd|jd|jd|jt j t j ddS(Ns 127.0.0.1i90s4150 File status okay; about to open data connection.sfoo sbar sbaz R-( R_R=R`RRyRCR$R1R4RRbR Rz(RRTRRw(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR{s    sfoo/barsPASV s227 Entering Passive Mode (%s).s 127.0.0.1i90sNLST foo/bar s226 Transfer Complete.( RCR}RiR,RRXR_R:RRhR$RR (RRR{RR0((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_passiveNLSTs   !  cstjfd}|j_jt}jjd|}j|tj j j j dj j jjdtjddfj j j djjd|S( s Test a failure in NLST command. L{ftp.FTPClient.nlst} should return a Deferred which fails with L{ftp.CommandFailed} if the server indicates the indicated path is invalid for some reason. csuj|dj|d|j||f}|jjjd|jtjtj ddS(Ns 127.0.0.1i90s4150 File status okay; about to open data connection.R-( R_R=R`RCR$R4RRbR Rz(RRTRRw(RRd(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR{'s  sfoo/barsPASV s227 Entering Passive Mode (%s).s 127.0.0.1i90sNLST foo/bar s&550 foo/bar: No such file or directory(RRyRCR}RiR,RRoRRpR_R:RRhR$R (RR{RR0((RRds9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_failedNLSTs      cs?jjtdtfd}jjd|S(sw L{ftp.FTPClient.changeDirectory} is deprecated and the direct caller of it is warned of this. s]FTPClient.changeDirectory is deprecated in Twisted 8.2 and newer. Use FTPClient.cwd instead.csjjdS(Nt.(RCtchangeDirectory((R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRIss 250 success(Rit assertWarnstDeprecationWarningt__file__RCR$(RR0((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_changeDirectoryDeprecated>s csafd}jjjdj|}jjjdjjd|S(s Test the changeDirectory method. L{ftp.FTPClient.changeDirectory} should return a Deferred which fires with True if succeeded. csj|tdS(N(R_R(R(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytcbCdXssbar/foos CWD bar/foo s&250 Requested File Action Completed OK(RiRCRRXR_R:RR$(RRR0((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_changeDirectoryQs  cCs\|j|jjd}|j|tj|j|jjd|jj d|S(sx Test a failure in the changeDirectory method. The behaviour here is the same as a failed CWD. sbar/foos CWD bar/foo s&550 bar/foo: No such file or directory( RiRCRRoRRpR_R:RR$(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_failedChangeDirectorycs  cCs\|j|jjd}|j|tj|j|jjd|jj d|S(s Test a strange failure in changeDirectory method. L{ftp.FTPClient.changeDirectory} is stricter than CWD as it checks code 250 for success. sbar/foos CWD bar/foo s252 I do what I want !( RiRCRRoRRpR_R:RR$(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt!test_strangeFailedChangeDirectoryrs  cCs|j|jjdd}|j|jjd|jjd}|jj||j|jjdd}|jj||j|j|g|gf|S(s L{ftp.FTPClient.rename} issues I{RNTO} and I{RNFR} commands and returns a L{Deferred} which fires when a file has successfully been renamed. s/spams/hams RNFR /spam s8350 Requested file action pending further information. s RNTO /ham s&250 Requested File Action Completed OK( RiRCtrenameRR:RRhR$RX(RR0t fromResponset toResponse((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_renameFromTos  cCsf|jd}d}|jj|||jjd|jjd|j|jjddS(s L{ftp.FTPClient.rename} issues I{RNTO} and I{RNFR} commands with paths escaped according to U{http://cr.yp.to/ftp/filesystem.html}. s /foo/ba r/bazs/qu uxs350 s250 s!RNFR /foo/bar/baz RNTO /quux N(RiRCRR$RR:R(RtfromFilettoFile((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_renameFromToEscapesPathss  cCs|j|jjdd}|j|jjd|jj|jjd|j|jjd|j|t j S(s The L{Deferred} returned by L{ftp.FTPClient.rename} is errbacked with L{CommandFailed} if the I{RNFR} command receives an error response code (for example, because the file does not exist). s/spams/hams RNFR /spam s!550 Requested file unavailable. R-( RiRCRRR:RRhR$RoRRp(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt$test_renameFromToFailingOnFirstErrors  cCs|j|jjdd}|j|jjd|jj|jjd|j|jjd|jjd|j|t j S(s The L{Deferred} returned by L{ftp.FTPClient.rename} is errbacked with L{CommandFailed} if the I{RNTO} command receives an error response code (for example, because the destination directory does not exist). s/spams/hams RNFR /spam s8350 Requested file action pending further information. s RNTO /ham s!550 Requested file unavailable. ( RiRCRRR:RRhR$RoRRp(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt"test_renameFromToFailingOnRenameTos  cCs[|j|jjd}|j|jjd|jjd|j|jdgS(s L{ftp.FTPClient.makeDirectory} issues a I{MKD} command and returns a L{Deferred} which is called back with the server's response if the directory is created. s/spams MKD /spam s257 "/spam" created.( RiRCt makeDirectoryR_R:RR$RXR(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_makeDirectorys  cCsI|j|jjd}|j|jjd|jjd|S(s L{ftp.FTPClient.makeDirectory} escapes the path name it sends according to U{http://cr.yp.to/ftp/filesystem.html}. s/sp ams MKD /spam s257 win(RiRCRRR:RR$(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_makeDirectoryPathEscapes  cCsX|j|jjd}|j|jjd|jjd|j|tj S(s L{ftp.FTPClient.makeDirectory} returns a L{Deferred} which is errbacked with L{CommandFailed} if the server returns an error response code. s/spams MKD /spam s550 PERMISSION DENIED( RiRCRR_R:RR$RoRRp(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_failedMakeDirectorys  cs^fd}jjjj|}jjjdjjd|S(s Test the getDirectory method. L{ftp.FTPClient.getDirectory} should return a Deferred which fires with the current directory on the server. It wraps PWD command. csj|ddS(Ns/bar/baz(R_(R(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytcbGetssPWD s257 "/bar/baz"(RiRCt getDirectoryRXR_R:RR$(RRR0((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_getDirectorys  cCsY|j|jj}|j|tj|j|jjd|jj d|S(sj Test a failure in getDirectory method. The behaviour should be the same as PWD. sPWD s'550 /bar/baz: No such file or directory( RiRCRRoRRpR_R:RR$(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_failedGetDirectory s  cCsY|j|jj}|j|tj|j|jjd|jj d|S(s Test a different failure in getDirectory method. The response should be quoted to be parsed, so it returns an error otherwise. sPWD s 257 /bar/baz( RiRCRRoRRpR_R:RR$(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_anotherFailedGetDirectorys  cCsa|j|jjd}|j|jjdd}|jj||j|j|gS(s L{ftp.FTPClient.removeFile} sends a I{DELE} command to the server for the indicated file and returns a Deferred which fires after the server sends a 250 response code. s /tmp/testsDELE /tmp/test s*250 Requested file action okay, completed.( RiRCt removeFileR_R:RR$RXR(RR0tresponse((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_removeFile(s  cs}jjjd}jjjddjjj|tj }|j fd|S(s If the server returns a response code other than 250 in response to a I{DELE} sent by L{ftp.FTPClient.removeFile}, the L{Deferred} returned by C{removeFile} is errbacked with a L{Failure} wrapping a L{CommandFailed}. s /tmp/testsDELE /tmp/test s,501 Syntax error in parameters or arguments.csj|jgfS(N(RRk(texc(RR(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRCs( RiRCRR_R:RR$RoRRpRX(RR0((RRs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_failedRemoveFile6s csdjjjd}djjj|tj}|jfd|S(s If the server returns a response line which cannot be parsed, the L{Deferred} returned by L{ftp.FTPClient.removeFile} is errbacked with a L{BadResponse} containing the response. s /tmp/tests765 blah blah blahcsj|jgfS(N(RRk(R(RR(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRRs(RiRCRR$RoRt BadResponseRX(RR0((RRs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt!test_unparsableRemoveFileResponseGs cCsK|j|jjd}ddg}t|jj||j|jS(s If the server returns multiple response lines, the L{Deferred} returned by L{ftp.FTPClient.removeFile} is still fired with a true value if the ultimate response code is 250. s /tmp/tests250-perhaps a progress reports250 okay(RiRCRRR$RXR(RR0R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt test_multilineRemoveFileResponseVs   (-R(R)RsR^R RiRlRmRqRrRuRvR~RRRRRRRRRRRRRRt_changeDirectorySuppressiontsuppressRRRRRRRRRRRRRRRR(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRfsX         ' # " / & ' 7 -  ' (                 tFTPClientBasicTestscBs5eZdZdZdZdZdZRS(cCs3tj}|jd|jdg|jdS(Ns220 Imaginary FTP.(RRtR$Rjtgreeting(RRc((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt testGreetinggs  cCs3tj}|jd|jdg|jdS(Ns220 (RRtR$RjR(RRc((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttestResponseWithNoMessagems  cCsEtj}tj|_|jd|jd}g}|j|j|j |j |jd|j g||jd|j g||jd|j g||jd|j g||jd|j g||jd|j g||jd |j ddddddd g|d dS( Ns220 Imaginary FTP.tBLAHs210-First line.s123-Second line.sJust some text.tHiR-t321s 210 Done.i( RRtRRyR:R$RcRXR"RRRj(RRcRR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttestMultilineResponsets8         cCstj}tj|_|jd|jdd|jd|jj |jj |jd|jd|jj dS(sO Passing None as the password avoids sending the PASS command. s220 Welcome to Imaginary FTP.tbobs USER bob s200 Hello bob.R-N( RRtRRyR:R$t queueLoginR*R_RRh(RRc((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_noPasswordGivens    cCstj}tj|_|jd|jdd|jd|jj|jj |jd|jd|jjdS(sQ Receiving a 230 response to USER prevents PASS from being sent. s220 Welcome to Imaginary FTP.Rtsecrets USER bob s#230 Hello bob. No password needed.R-N( RRtRRyR:R$RR_RRh(RRc((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_noPasswordNeededs    (R(R)RRRRR(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRes    0 t PathHandlingcBseZdZRS(c Cs@xddgfddgfdgfddddgfddddgfddgfd dgfgD](\}}|jtjg||qdWxdddgfd ddgfd dgfd dgfd dddgfddddgfdddgfdddgfgD]+\}}|jtjdg||qWx`dgfddgfddgfdddgfgD](\}}|jtjg||quWxZdgfddgfddddgfgD]+\}}|jtjdg||qWxdgfdgfddgfdgfddgfddgfdddgfdddgfd dgfd!dgfd"gfd#gfg D]+\}}|jtjdg||qWxEddd$d%d&d'd(d)d*g D]"}|jtjtjg|qWx6d+d,d-gD]%}|jtjtjdg|qWdS(.NRs/at/sa/b/cRtcs/a/b/cs/a/sa/sb/s/bs/b/sb/csb/c/s/b/cs/b/c/s//s//asa//sa//bs//bsb//cs..s../sa/..Rs/a/..s/a/b/..s/a/b/../s /a/b/../cs /a/b/../c/s /a/b/../../cs /a/b/../../c/s/a/b/../../c/..s/a/b/../../c/../sa/../..sa/../../s/..s/../s/a/../..s /a/../../s /a/b/../../..s../..s../../s ../a/../..(R_Rt toSegmentsRt InvalidPath(Rtinptoutp((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttestNormalizersZ      #      "#         #   (R(R)R(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRstBaseFTPRealmTestscBs2eZdZdZdZdZdZRS(s Tests for L{ftp.BaseFTPRealm}, a base class to help define L{IFTPShell} realms with different user home directory policies. cCs|jtttjdS(s; L{ftp.BaseFTPRealm} implements L{IRealm}. N(RRRRt BaseFTPRealm(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_interfacescstj|jgdtjffdY}||j}|jddtj\}}}|j|tj |j |j dS(s L{ftp.BaseFTPRealm} calls its C{getHomeDirectory} method with the avatarId being requested to determine the home directory for that avatar. t TestRealmcseZfdZRS(csj|S(N(R"(RtavatarId(tavatarsR(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytgetHomeDirectorys (R(R)R((RR(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRssalice@example.comN( RRIRERRt requestAvatarR*t IFTPShellR#tFTPShellR_tfilesystemRoot(RRtrealmtifacetavatartlogout((RRs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_getHomeDirectorys"cCsr|j}tj|}|jtjdtj\}}}|j|tj |j |j t j |dS(sy L{ftp.BaseFTPRealm} returns an L{ftp.FTPAnonymousShell} instance for anonymous avatar requests. N(RERRRRt ANONYMOUSR*RR#RR_RRRI(RR6RRRR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_anonymous)s  cCs2tj|j}|jt|jtdS(s L{ftp.BaseFTPRealm.getHomeDirectory} should be overridden by a subclass and raises L{NotImplementedError} if it is not. N(RRRERtNotImplementedErrorRR(RR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_notImplemented6s(R(R)RsRRRR(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR s    tFTPRealmTestCasecBs eZdZdZdZRS(s$ Tests for L{ftp.FTPRealm}. cCsSd}tj|j|}|jd}|jtj|jd|dS(s L{ftp.FTPRealm} accepts an extra directory to its initializer and treats the avatarId passed to L{ftp.FTPRealm.getHomeDirectory} as a single path segment to construct a child of that directory. s /path/to/homesalice@example.comN(RRLRERR_RRIR(RtbaseRthome((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRDs cCsAtj|j}|jd}|jtjd|dS(s If no extra directory is passed to L{ftp.FTPRealm}, it uses C{"/home"} as the base directory containing all user home directories. salice@example.coms/home/alice@example.comN(RRLRERR_RRI(RRR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_defaultHomeDirectoryQs(R(R)RsRR(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR@s tSystemFTPRealmTestscBs&eZdZeZdZdZRS(s* Tests for L{ftp.SystemFTPRealm}. cCsktj}ddl}|j|j}tj|j}|j|}|j |t j |dS(s L{ftp.SystemFTPRealm.getHomeDirectory} treats the avatarId passed to it as a username in the underlying platform and returns that account's home directory. iN( tgetpasstgetuserRptgetpwnamtpw_dirRtSystemFTPRealmRERR_RRI(RtuserRpRRR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRbs   cCsDtdjd}tj|j}|jt|j|dS(s L{ftp.SystemFTPRealm.getHomeDirectory} raises L{UnauthorizedLogin} when passed a username which has no corresponding home directory in the system's accounts database. ithexN(RtencodeRRRERRR(RRR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_noSuchUservs(R(R)Rst nonPOSIXSkiptskipRR(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR\s tErrnoToFailureTestCasecBsMeZdZdZdZdZdZdZdZdZ RS(s9 Tests for L{ftp.errnoToFailure} errno checking. cCs(tjtjd}|j|tjS(sS C{errno.ENOENT} should be translated to L{ftp.FileNotFoundError}. R(RterrnoToFailureterrnotENOENTRotFileNotFoundError(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt test_notFoundscCs(tjtjd}|j|tjS(sV C{errno.EPERM} should be translated to L{ftp.PermissionDeniedError}. R(RRRtEPERMRotPermissionDeniedError(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_permissionDeniedscCs(tjtjd}|j|tjS(sW C{errno.EACCES} should be translated to L{ftp.PermissionDeniedError}. R(RRRtEACCESRoR(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_accessDeniedscCs(tjtjd}|j|tjS(sW C{errno.ENOTDIR} should be translated to L{ftp.IsNotADirectoryError}. R(RRRtENOTDIRRoR(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_notDirectoryscCs(tjtjd}|j|tjS(sQ C{errno.EEXIST} should be translated to L{ftp.FileExistsError}. R(RRRtEEXISTRotFileExistsError(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_fileExistsscCs(tjtjd}|j|tjS(sS C{errno.EISDIR} should be translated to L{ftp.IsADirectoryError}. R(RRRtEISDIRRotIsADirectoryError(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_isDirectoryscCs=ytdWn&tjdd}|j|tSXdS(s If an unknown errno is passed to L{ftp.errnoToFailure}, it should let the originating exception pass through. RiRN(RRRRo(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_passThroughs ( R(R)RsRRRRR RR(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRs      tAnonymousFTPShellTestCasecBseZdZdZRS(s* Test anynomous shell properties. cCs5tjd}|jd}|j|tj|S(st Check that L{ftp.FTPAnonymousShell} returns an error when trying to open it in write mode. R-R(sfoo(RRRRoR(RtshellR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_anonymousWrites(R(R)RsR(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRstIFTPShellTestsMixincBsCeZdZdZdZdZddZdZdZdZ d Z d Z d Z d Z d ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZ d Z!d!Z"d"Z#d#Z$RS($s7 Generic tests for the C{IFTPShell} interface. cCs tdS(s  Test if the directory exists at C{path}. @param path: the relative path to check. @type path: C{str}. @return: C{True} if C{path} exists and is a directory, C{False} if it's not the case @rtype: C{bool} N(R(RR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytdirectoryExistss cCs tdS(s Create a directory in C{path}. @param path: the relative path of the directory to create, with one segment. @type path: C{str} N(R(RR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRscCs tdS(s Test if the file exists at C{path}. @param path: the relative path to check. @type path: C{str}. @return: C{True} if C{path} exists and is a file, C{False} if it's not the case. @rtype: C{bool} N(R(RR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt fileExistss R-cCs tdS(s Create a file named C{path} with some content. @param path: the relative path of the file to create, without directory. @type path: C{str} @param fileContent: the content of the file. @type fileContent: C{str} N(R(RRt fileContent((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt createFile s cCs=|j|jd|jd|j|jddS(s C{directoryExists} should report correctly about directory existence, and C{createDirectory} should create a directory detectable by C{directoryExists}. RN(RRRR(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_createDirectory s cCs=|j|jd|jd|j|jddS(s C{fileExists} should report correctly about file existence, and C{createFile} should create a file detectable by C{fileExists}. sfile.txtN(RRRR(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_createFile s cs.jjd}fd}|j|S(sI Create a directory and check it ends in the filesystem. RcsjjddS(NR(RR(R(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytcb) s(sfoo(RRRX(RR0R((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR$ scCs2|jd|jjd}|j|tjS(sm Creating a directory that already exists should fail with a C{ftp.FileExistsError}. R(sfoo(RRRRoRR (RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_makeDirectoryError. s cs;jdjjd}fd}|j|S(sW Try to remove a directory and check it's removed from the filesystem. RcsjjddS(NR(RR(R(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR> s(sbar(RRtremoveDirectoryRX(RR0R((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_removeDirectory8 s cCs2|jd|jjd}|j|tjS(sn removeDirectory should not work in file and fail with a C{ftp.IsNotADirectoryError}. sfile.txt(sfile.txt(RRRRoRR(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_removeDirectoryOnFileC s cCs%|jjd}|j|tjS(sl Removing directory that doesn't exist should fail with a C{ftp.FileNotFoundError}. R(sbar(RRRoRR(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_removeNotExistingDirectoryM scs?jdjjd}fd}|j||S(sR Try to remove a file and check it's removed from the filesystem. sfile.txtcsjjddS(Nsfile.txt(RR(R(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR\ s(sfile.txt(RRRRX(RR0R((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRV s   cCs2|jd|jjd}|j|tjS(s: removeFile should not work on directory. tned(R (RRRRoRR (RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_removeFileOnDirectoryb s cCs%|jjd}|j|tjS(sl Try to remove a non existent file, and check it raises a L{ftp.FileNotFoundError}. R(sfoo(RRRoRR(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_removeNotExistingFilek scsHjdjdjjd}fd}|j|S(s6 Check the output of the list method. R sfile.txtRcs0|jj|dgfdgfgdS(Nsfile.txtR (RR_(R(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR{ s  (R(RRRRRX(RR0R((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt test_listt s   csKjdjdjjdd}fd}|j|S( s< Check the output of list with asked stats. R sfile.txtRRt permissionscs|jjt|dj|dddj|dddjt|dddjt|ddddS(Niisfile.txtiR (RR_R(R(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR s  (R(ssizeR$(RRRRRX(RR0R((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_listWithStat s    cCs2|jd|jjdd}|j|tS(sP Querying an invalid stat should result to a C{AttributeError}. R RRt whateverstat(R(ssizeR&(RRRRotAttributeError(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_listWithInvalidStat s cs;jdjjd}fd}|j|S(s@ Check the output of the list method on a file. sfile.txtcs'|jj|dgfgdS(Nsfile.txt(RR_(R(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR s  (sfile.txt(RRRRX(RR0R((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt test_listFile s cCs%|jjd}|j|tjS(sm list on a directory that doesn't exist should fail with a L{ftp.FileNotFoundError}. R(sfoo(RRRoRR(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_listNotExistingDirectory scCs#|jd|jjd}|S(s+ Try to access a resource. R (sned(RRtaccess(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt test_access s cCs%|jjd}|j|tjS(sF access should fail on a resource that doesn't exist. R(sfoo(RR+RoRR(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_accessNotFound scs?jdjjd}fd}|j||S(sY Check that openForReading returns an object providing C{ftp.IReadFile}. sfile.txtcsjtjj|dS(N(RRt IReadFilet providedBy(R(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR s(sfile.txt(RRtopenForReadingRX(RR0R((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_openForReading s   cCs%|jjd}|j|tjS(sr openForReading should fail with a C{ftp.FileNotFoundError} on a file that doesn't exist. R (sned(RR0RoRR(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_openForReadingNotFound scCs2|jd|jjd}|j|tjS(s> openForReading should not work on directory. R (sned(RRR0RoRR (RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_openForReadingOnDirectory s csDjjd}fd}fd|j||S(sZ Check that openForWriting returns an object providing C{ftp.IWriteFile}. Rcs,jtjj||jjS(N(RRt IWriteFileR/RRX(R(tcb2R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytcb1 scsjtj|dS(N(RR R/(R(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR5 s(sfoo(RRRX(RR0R6((R5Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_openForWriting s  cCs2|jd|jjd}|j|tjS(sd openForWriting should not be able to open a directory that already exists. R (sned(RRRRoRR (RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt$test_openForWritingExistingDirectory s cCs2|jd|jjd}|j|tjS(s openForWring should fail with a L{ftp.FileNotFoundError} if you specify a file in a directory that doesn't exist. R t idonotexistR(snedR9sfoo(RRRRoRR(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt)test_openForWritingInNotExistingDirectory s csNdjdjjdd}fd}|j||S(s@ Check the output of the stat method on a file. swobble sfile.txtRRFcs/j|dtj|ddS(Nii(R_RR(R(RR(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR s(sfile.txt(ssizes directory(RRtstatRX(RR0R((RRs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt test_statFile s  csBjdjjdd}fd}|j||S(sE Check the output of the stat method on a directory. R RRFcsj|ddS(Ni(R(R(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR s(sned(ssizes directory(RRR;RX(RR0R((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_statDirectory s   csBjdjjdd}fd}|j||S(s3 Check the owner and groups stats. R R;R=csjt|ddS(Ni(R_R(R(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR% s(sned(sownersgroup(RRR;RX(RR0R((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_statOwnerGroup s   cCs(|jjdd}|j|tjS(sf stat should fail with L{ftp.FileNotFoundError} on a file that doesn't exist. RRRF(sfoo(ssizes directory(RR;RoRR(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_statNotExisting+ scCs2|jd|jjdd}|j|tS(sP Querying an invalid stat should result to a C{AttributeError}. R RR&(sned(ssizes whateverstat(RRR;RoR'(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_invalidStat4 s cs>jdjjdd}fd}|j|S(s, Try to rename a directory. R Rcs0jjdjjddS(NRR (RRR(R(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRC s(sned(sfoo(RRRRX(RR0R((Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt test_rename= s cCs(|jjdd}|j|tjS(sl Renaming a directory that doesn't exist should fail with L{ftp.FileNotFoundError}. RR(sfoo(sbar(RRRoRR(RR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyttest_renameNotExistingI s(%R(R)RsRRRRRRRRRRRRR!R"R#R%R(R)R*R,R-R1R2R3R7R8R:R<R=R>R?R@RARB(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRsF         tFTPShellTestCasecBs>eZdZdZdZdZdZddZRS(s/ Tests for the C{ftp.FTPShell} object. cCs>tj|j|_|jjtj|j|_dS(sB Create a root directory and instantiate a shell. N(RRIRER<RRRR(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR^X s cCs|jj|jS(s: Test if the directory exists at C{path}. (R<Rtisdir(RR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRa scCs|jj|jS(s0 Create a directory in C{path}. (R<RR(RR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRh scCs|jj|jS(s5 Test if the file exists at C{path}. (R<Rtisfile(RR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRo sR-cCs|jj|j|S(s@ Create a file named C{path} with some content. (R<Rt setContent(RRR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRv s(R(R)RsR^RRRR(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRCS s    t TestConsumercBs9eZdZeedZdZdZdZ RS(s A simple consumer for tests. It only works with non-streaming producers. @ivar producer: an object providing L{twisted.internet.interfaces.IPullProducer}. cCs8|jdkstg|_||_|jjdS(sc Simple register of producer, checks that no register has happened before. N(tproducerR*tAssertionErrorR.tresumeProducing(RRHt streaming((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytregisterProducer s  cCs"|jdk std|_dS(sN Unregister the producer, it should be done after a register. N(RHR*RI(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytunregisterProducer scCs!|jj||jjdS(s) Save the data received. N(R.R"RHRJ(RR%((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR sN( R(R)RsRR R*RHRLRMR(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRG~ s   t TestProducercBs eZdZdZdZRS(s A dumb producer. cCs||_||_dS(s @param toProduce: data to write @type toProduce: C{str} @param consumer: the consumer of data. @type consumer: C{IConsumer} N(t toProducetconsumer(RRORP((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR s cCs|jj|jdS(s+ Send the data to consume. N(RPRRO(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytstart s(R(R)RsRRQ(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRN s tIReadWriteTestsMixincBs;eZdZdZdZdZdZdZRS(sJ Generic tests for the C{IReadFile} and C{IWriteFile} interfaces. cCs tdS(sY Return an object providing C{IReadFile}, ready to send data C{content}. N(R(Rtcontent((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt getFileReader scCs tdS(sR Return an object providing C{IWriteFile}, ready to receive data. N(R(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt getFileWriter scCs tdS(s6 Return the content of the file used. N(R(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytgetFileContent scsLdtfd}fdjj|S(s Test L{ftp.IReadFile}: the implementation should have a send method returning a C{Deferred} which fires when all the data has been sent to the consumer, and the data should be correctly send to the consumer. swobble cs|jjS(N(tsendRX(treader(tcbSendRP(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR scs jdjjdS(NR-(R_RR.(R(RSRRP(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRY s(RGRTRX(RR((RYRRSRPs9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt test_read s  csLdfd}fdfdjj|S(s Test L{ftp.IWriteFile}: the implementation should have a receive method returning a C{Deferred} which fires with a consumer ready to receive data to be written. It should also have a close() method that returns a Deferred. selbbow cs|jj|S(N(RRX(twriter(t cbReceive(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR scsFt|}|jdt|j|j|jjS(N(RNRLR*RRQRMRRX(RPR[RH(tcbCloseRS(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR\ s   csjjdS(N(R_RV(Rd(RSR(s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR] s(RURX(RR((RSRR\R]s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyt test_write s (R(R)RsRTRURVRZR^(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRR s     tFTPReadWriteTestCasecBs2eZdZdZdZdZdZRS(s Tests for C{ftp._FileReader} and C{ftp._FileWriter}, the objects returned by the shell in C{openForReading}/C{openForWriting}. cCsGtj|j|_|jjtj|j|_d|_dS(s5 Create a temporary file used later. sfile.txtN( RRIRER<RRRRR?(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR^ s cCs2|jj|jj||jj|jfS(sV Return a C{ftp._FileReader} instance with a file opened for reading. (R<RR?RFRR0(RRS((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRT scCs|jj|jfS(sV Return a C{ftp._FileWriter} instance with a file opened for writing. (RRR?(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRU scCs|jj|jjS(s; Return the content of the temporary file. (R<RR?t getContent(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRV s(R(R)RsR^RTRURV(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR_ s   tCloseTestWritercBs-eZeejeZdZdZRS(cCs+t|_tj|j}tj|S(N(RRRt FileConsumerR Rg(Rtfc((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR% s cCst|_|jS(N(Rt closeStartedR0(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR) s ( R(R)RRR4RRdRR(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRa" s  tCloseTestShellcBseZdZRS(cCstj|jS(N(R RgR[(Rtsegs((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR. s(R(R)R(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRe- st FTPCloseTestcBseZdZdZRS(s.Tests that the server invokes IWriteFile.closecCsetj}dg|_t|_t|j_tj|jj_ tj |_ d|j _ |jttj}tj||_ ||_|jdg}|jd}|j|j|j|jjjd|jd|j|jjjd|jd|j|jjjd|j||jjj jd|j||S( stConfirm that FTP uploads (i.e. ftp_STOR) correctly call and wait upon the IWriteFile object's close() methodR<Rsclose() called earlyssome data heresreason is ignoredsclose() not calledsallow close() to finishN(RtFTPtworkingDirectoryReRRaR[R R/R0RPRR*ttimeOutR`RR$RRtftp_STORRXR"RRdR1R4RR2(RR tdit stor_doneR0((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyR^4 s0           (R(R)RsR^(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pyRg1 s(RRsRGRRRtzope.interfaceRtzope.interface.verifyRt twisted.trialRRttwisted.python.randbytesRttwisted.cred.portalRttwisted.protocolsRttwisted.internetRR R R R ttwisted.internet.interfacesR ttwisted.cred.errorRt twisted.credRRRttwisted.pythonRRRt twisted.testRRRRRRtplatformt isWindowsRR*t LineReceiverRRTR,tTestCaseR5RuRxRRRRR-R1R/R3RVRfRRRRRRRRRCRRGRNRRR_RaReRg(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_ftp.pytsr   (    `15  N6m77&B+'?&