tf8c dZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlmZddlmZddlmZmZddlmZddlZddlZddlZddlZddlZddlZddlZddl Zddl!Zddlm"Z"m#Z#ddl$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*dd l+m,Z,dd l-m.Z.m/Z/m0Z0m1Z1dd l2m3Z3m4Z4m5Z5dd l6m7Z7m8Z8dd l!m9Z9ddl:m;Z;ddlZ>m?Z?ddl@mAZAddlBmCZCmDZDddlEmFZFddlGmHZHddlImJZJeeHdkdGddeJZKeeHdkdGddeJZLeeHdkdGddeJZMeeHdkdGddeJZNeeHdkdGdd eJZOeeHdkdGd!d"eJZPeeHdkdGd#d$eJZQeeHdkdGd%d&e#jRjSZTGd'd(ZUeeHdkdGd)d*eJeUZVeeHdkdGd+d,eJeUZWeeHdkdGd-d.eJZXeeHdkdGd/d0eJZYeeHdkdGd1d2eJZZee#j#j[Gd3d4Z\eeHdkdGd5d6eJZ]eeHdkdGd7d8eJZ^Gd9d:e8j_Z`eeHdkdGd;deJZbGd?d@ZceeHdkdGdAdBeJZdeeHdkdGdCdDeJZeddEl:mfZfmgZgmhZhGdFdGegjiZjdHZkdIZleeHdkdGdJdKeJZmeeHdkdGdLdMeJZnGdNdOZoeeHdkdGdPdQeJZpGdRdSZqeeHdkdGdTdUeJZrGdVdWZsGdXdYe#jtjuZvGdZd[e#jtjwZxGd\d]ZyeeHdkdGd^d_eJZzGd`daZ{GdbdcZ|GdddeZ}eeHdkdGdfdgeJZ~dS)hz. Tests for large portions of L{twisted.mail}. N)md5)skipIf) Interface implementer) verifyClass)credmail)addressdefer interfacesprotocolreactortask)Deferred)CannotListenErrorDNSLookupError ProcessDoneProcessTerminated)LineSendingProtocolMemoryReactorClockStringTransport)pop3smtp)_AttemptManager)dns) Record_CNAME Record_MXRRHeader) DNSNameError)failurelog)FilePath) platformType)TestCaseposixz twisted.mail only works on posixcbeZdZeejdkddZdZdZdZ dZ dS) DomainWithDefaultsTestsnot ported to Python 3c  dtdD}tj|d}|t |d|t t |t td|t |t t |t |}| ||dtdDt | }| ||t tdd| }| ||dtdD| }| ||t tddtdD]d}||||dz|| ||dz|||ve|d=|d=|d =|t |d ||dd||dd||d d|dd d d |t |d||dd||dd ||dd ||t |d||ddd||dd||d|t |d|}||j|j||j|jdS)Nci|]}||dz S .0xs Z/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/twisted/mail/test/test_mail.py z7DomainWithDefaultsTests.testMethods..As * * *1QB * * *r.Defaultcg|] }||dzf Sr-r/r0s r3 z7DomainWithDefaultsTests.testMethods..J @ @ @!QV @ @ @r5cg|] }||dzf Sr-r/r0s r3r8z7DomainWithDefaultsTests.testMethods..Rr9r5r/*)abcrArBrCrkeyvalue)rDrE)ranger DomainWithDefaultDict assertEquallenlistiteriterkeys iteritemssort itervaluesitemsvaluesget assertTrueupdateclear setdefaultpopitemcopydomainsdefault)selfdrPrQr2dcopys r3 testMethodsz#DomainWithDefaultsTests.testMethods?s$ * *b * * * I + +Ay 9 9 Q$$$ d1ggU2YY888 ajjll++T$q'']];;;Q[[]]##   @ @eBii @ @ @AAAallnn%%  eBmm!4!4555    @ @eBii @ @ @AAA  eBmm!4!4555r $ $A   QqT1r6 * * *   QUU1XXq2v . . . OOAF # # # # aD!A$! Q### 1y))) 1y))) 1y))) t"3//000 Q$$$ 3&&& 3$$$ 3%%%   Q### eW55w??? 57+++ &6777 Q### EM222 EM22222r5ctjid}||jj||d|d<|t ddi||dS)a Assert that the class name of a L{mail.mail.DomainWithDefaultDict} instance and the string-formatted underlying domain dictionary both appear in the string produced by the given string-returning function. @type stringifier: one-argument callable @param stringifier: either C{str} or C{repr}, to be used to get a string to make assertions against. r6rErDN)r rGassertIn __class____name__str)r[ stringifierdomains r3_stringificationTestz,DomainWithDefaultsTests._stringificationTestwsy00Y?? f&/V1D1DEEEu  c5'*++[[-@-@AAAAAr5c:|tdS)z L{DomainWithDefaultDict.__str__} should return a string including the class name and the domain mapping held by the instance. N)rfrcr[s r3test_strz DomainWithDefaultsTests.test_strs !!#&&&&&r5c:|tdS)z L{DomainWithDefaultDict.__repr__} should return a string including the class name and the domain mapping held by the instance. N)rfreprrhs r3 test_reprz!DomainWithDefaultsTests.test_reprs !!$'''''r5ctjid}|dd}||jg}|dt ||t|dd|||dddS) z, has_key is now deprecated. r6anythingzotwisted.mail.mail.DomainWithDefaultDict.has_key was deprecated in Twisted 16.3.0. Use the `in` keyword instead.rcategorymessageN)r rGhas_key flushWarningstest_has_keyDeprecationrHrIDeprecationWarning)r[sutrqwarningss r3rtz/DomainWithDefaultsTests.test_has_keyDeprecationsi--b)<< J ? %%t'C&DEE CMM*** +Xa[-DEEE (1+i"899999r5N) rb __module__ __qualname__rsys version_infor^rfrirlrtr/r5r3r'r'=s VC  $&>??5353@?53n B B B'''(((:::::r5r'c&eZdZdZdZdZdZdS) BounceTestscLtj|_dSN)r BounceDomainrerhs r3setUpzBounceTests.setUpsi,,.. r5c\|tj|jjddS)Nzany user) assertRaisesr AddressErrorreexistsrhs r3 testExistszBounceTests.testExistss( $+T[-?LLLLLr5cd||jddddS)Nzrandom q emailerr F)rHre willRelayrhs r3 testRelayzBounceTests.testRelays2 ../A:NNPUVVVVVr5c|jdd|tj|jjddS)Nbobpassword)readdUserrr SMTPBadRcptrrhs r3 testAddUserzBounceTests.testAddUsers@ E:... $*DK,>FFFFFr5N)rbrxryrrrrr/r5r3r}r}s[///MMMWWWGGGGGr5r}ceZdZdZdZdS)BounceWithSMTPServerTestsz_ Tests for L{twisted.mail.mail.BounceDomain} with L{twisted.mail.smtp.SMTPServer}. ctj}tj}|d|tj|}|d}tj|dd}||_t}|j ||j d|j d|j d|j d| |j |jd||ddd dS) zo Incoming emails to a SMTP server with L{twisted.mail.mail.BounceDomain} are rejected. sfoo.comNs HELO baz.netsMAIL FROM:sRCPT TO:sQUITs s(550 Cannot receive for specified address)r MailServicer addDomain protocols SMTPFactory buildProtocolSMTPDomainDeliverydeliveryrmakeConnection lineReceivedrS disconnectingconnectionLostrHrEstripsplit)r[servicerefactoryr deliverer transports r3 test_rejectedz'BounceWithSMTPServerTests.test_rejectedsn )''))''))*f---.,,W55((..N55gtTJJ %#%%  ***o...67776777g&&&  /000%%%  OO   # # % % + +G 4 4R 8 7     r5N)rbrxry__doc__rr/r5r3rrs-      r5rc,eZdZdZdZdZdZdZdS)FileMessageTestscF||_||_t|jd|_||jjtj|j|j|j|_ dS)Nwb) mktempnamefinalopenf addCleanupcloser FileMessagefprhs r3rzFileMessageTests.setUpsnKKMM [[]] di&&  %%%)'' 4:FFr5cd|j|jSr)r eomReceived addCallback _cbFinalNamerhs r3 testFinalNamezFileMessageTests.testFinalNames'w""$$001BCCCr5c|||j||jj|t j|j dSr) rHrrSrclosed assertFalseospathrrr[results r3rzFileMessageTests._cbFinalNamesZ ,,,  &&&  2233333r5cJd}|D]}|j||jt |jd5}|||ddddS#1swxYwYdS)N"first line second line third line rb) splitlinesrrrrrrHread)r[contentsliners r3 testContentszFileMessageTests.testContentss;'')) ' 'D G  & & & &  $*d # # 1q   QVVXXx 0 0 0 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1s")BBBczd}|D]}|j||j|t j|j|t j|j dS)Nfirst line second line ) rrrrrrrrrrr[rrs r3testInterruptedz FileMessageTests.testInterrupteds/'')) ' 'D G  & & & &      22333  3344444r5N)rbrxryrrrrrr/r5r3rrseGGGDDD444 11155555r5rc0eZdZdZdZdZdZdZdZdS)MaildirMessageTestszL Tests for the file creating by the L{mail.maildir.MaildirMessage}. c`||_||_d|_t |jd|_||jjtj |j|j|j|j|_ dS)z3 Create and open a temporary file. suser@example.comrN) rrrr rrrrr maildirMaildirMessagerrhs r3rzMaildirMessageTests.setUpsKKMM [[]] * di&&  %%%,-- L$&$)TZ  r5cFtj|jddS)zk Search for the final file path. @rtype: L{str} @return: Final file path. z ,S=[0-9]*r)globrrhs r3 _finalNamezMaildirMessageTests._finalNames$yDJ11122155r5c||j}|||jdt j|||j j | t j |j dS)z Send the EOM to the message and check that the final file name contains the correct file size and the temporary file has been closed and removed. z,S=N)successResultOfrrrHrrrgetsizerSrrrrr)r[rs r3test_finalNamez"MaildirMessageTests.test_finalNames $$TW%8%8%:%:;; 4: J J"'//%2H2H J JKKK  &&&  2233333r5czd}|D]}|j|||j}t |d5}||d|j|fzddddS#1swxYwYdS)z Send a message contents and the EOM to the message and check that the final file contains the correct header and the message contents. rrsDelivered-To: %s %sN) rrrrrrrHrr )r[rrrrs r3 test_contentsz!MaildirMessageTests.test_contents%s <'')) ' 'D G  & & & &$$TW%8%8%:%:;; %   !   1T\84LL                     s03B00B47B4cLd}|D]}|j||j|t j|j| t|j dS)z Check that the interrupted message transfer removes the temporary file and a doesn't create a final file. rN) rrrrrrrrrr IndexErrorrrs r3test_interruptedz$MaildirMessageTests.test_interrupted3s 0'')) ' 'D G  & & & &      22333 *do66666r5N) rbrxryrrrrrrr/r5r3rrsi    666444    7 7 7 7 7r5rc eZdZdZdZdZdS)MailServiceTestscLtj|_dSr)r rrrhs r3rzMailServiceTests.setUpBsy,,.. r5c|j}|t|tj||dtj|j }|t|tj||dtj |j }|t|tj||dtj dS)N) 127.0.0.190)rgetPOP3FactoryrS isinstancer ServerFactoryrrPOP3getSMTPFactoryrSMTPgetESMTPFactoryESMTP)r[rs r3 testFactorieszMailServiceTests.testFactoriesEs L ' ' ) )  1h&<==>>> (<==tyIII L ' ' ) )  1h&<==>>> (<==tyIII L ( ( * *  1h&<==>>> (<==tzJJJJJr5c4t}t}||jjd<||jjd<||jd|u||j|udS)Nre)objectrportalsrS lookupPortal defaultPortal)r[o1o2s r3 testPortalszMailServiceTests.testPortalsRs XX XX)+ X&#% R   11(;;rABBB  2244:;;;;;r5N)rbrxryrrrr/r5r3rr@sD/// K K K<<<<tjgd}||dd||dd||dddS)z L{StringListMailbox.listMessages} returns the length of the message at the offset into the mailbox passed to it. )abcabrArr)ror<Nr rStringListMailboxrH listMessagesr[mailboxs r3test_listOneMessagez*StringListMailboxTests.test_listOneMessagecs ,001C1C1CDD --a00!444 --a00!444 --a00!44444r5ctjgd}||gddS)z L{StringListMailbox.listMessages} returns a list of the lengths of all messages if not passed an index. )rArr)ror)r<Nrrs r3test_listAllMessagesz+StringListMailboxTests.test_listAllMessagesmsL ,001C1C1CDD --//;;;;;r5r(r*ctjddg}||dddS)z L{StringListMailbox.getMessage} returns a file-like object from which the contents of the message at the given offset into the mailbox can be read. fooz real contentsroN)r rrrH getMessagerrs r3test_getMessagez&StringListMailboxTests.test_getMessageusT,00%1IJJ ++A..3355GGGGGr5ctjddg}||d|ddS)z L{StringListMailbox.getUidl} returns a unique identifier for the message at the given offset into the mailbox. rbarrroN)r rrassertNotEqualgetUidlrs r3 test_getUidlz#StringListMailboxTests.test_getUidlsQ ,00%@@ GOOA..0B0BCCCCCr5ctjdg}|d||dd||dgdS)z L{StringListMailbox.deleteMessage} marks a message for deletion causing further requests for its length to return 0. rrN)r rr deleteMessagerHrrs r3test_deleteMessagez)StringListMailboxTests.test_deleteMessages} ,00%99a    --a00!444 --//!55555r5c<tjdg}|d|||dd||dgdS)z L{StringListMailbox.undeleteMessages} causes any messages marked for deletion to be returned to their original state. rrr)N)r rrr undeleteMessagesrHrrs r3test_undeleteMessagesz,StringListMailboxTests.test_undeleteMessagess ,00%99a     """ --a00!444 --//!55555r5cdtjdg}|d||||dd||dgdS)zy L{StringListMailbox.sync} causes any messages as marked for deletion to be permanently deleted. rrN)r rrr syncrrHrrs r3 test_syncz StringListMailboxTests.test_syncs ,00%99a      """ --a00!444 --//!55555r5N)rbrxryrrrrrzr{rr r rrr/r5r3rr\s 555<<< VC  $&>??HH@?H VC  $&>??DD@?D666 6 6 6 6 6 6 6 6r5rc,eZdZdZdZdZdZdZdZdS)&FailingMaildirMailboxAppendMessageTaskTcp|jrtj|||SttjdNzFaked Permission Problem) _openstaterrOSErrorerrnoEPERM)r[fnattrmodes r3osopenz-FailingMaildirMailboxAppendMessageTask.osopens4 ? C72tT** *%+'ABB Br5cn|jrtj||Sttjd)NzFaked Space problem) _writestaterwriterrENOSPC)r[fhdatas r3oswritez.FailingMaildirMailboxAppendMessageTask.oswrites2   ?8B%% %%,(=>> >r5cn|jrtj||Sttjdr) _renamestaterrenamerrr)r[oldnamenewnames r3osrenamez/FailingMaildirMailboxAppendMessageTask.osrenames3   C9Wg.. .%+'ABB Br5N) rbrxryrr!r(rr&r,r/r5r3rrsZJKLCCC ??? CCCCCr5rceZdZdZdZdS)_AppendTestMixinz Mixin for L{MaildirMailbox.appendMessage} test cases which defines a helper for serially appending multiple messages to a mailbox. cgfd}tj|}|fd|S)z Deliver the given messages one at a time. Delivery is serialized to guarantee a predictable order in the mailbox (overlapped message deliver makes no guarantees about which message which appear first). c3|KD]5}|}|j|V6dSr) appendMessagerappend)mr\mboxmessagesresultss r3r2z0_AppendTestMixin._appendMessages..appendsR  &&q)) gn---  r5cSrr/)ignoredr6s r3z2_AppendTestMixin._appendMessages..sgr5)r cooperatewhenDoner)r[r4r5r2r\r6s `` @r3_appendMessagesz _AppendTestMixin._appendMessagesss         N6688 $ $ - - / / ----...r5N)rbrxryrr<r/r5r3r.r.s- r5r.cheZdZdZdZdZd dZeej dkddZ d Z dS) MaildirAppendStringTestsO Tests for L{MaildirMailbox.appendMessage} when invoked with a C{str}. c||_tj|jdSrrr\r rinitializeMaildirrhs r3rzMaildirAppendStringTests.setUp/ &&tv.....r5cb|d}||tS)NTEST)r1 assertFailure Exceptionr[r8r4r\s r3_appendz MaildirAppendStringTests._appends+   v & &!!!Y///r5Ncf|8|t|jd|jj||j_|8|t|jd|jj||j_|:|t|jd|jj||j_dSdS)a Change the behavior of future C{rename}, C{write}, or C{open} calls made by the mailbox C{mbox}. @param rename: If not L{None}, a new value for the C{_renamestate} attribute of the mailbox's append factory. The original value will be restored at the end of the test. @param write: Like C{rename}, but for the C{_writestate} attribute. @param open: Like C{rename}, but for the C{_openstate} attribute. Nr(r!r)rsetattr AppendFactoryr(r!r)r[r8r4r)r"rs r3 _setStatez"MaildirAppendStringTests._setStates   OO""/     /5D  +   OO"".     .3D  *   OO+\4;M;X   -1D  ) ) )  r5r(r*c6tj|j}t|_||dtddD}||j dgdz||j ||S) L{MaildirMailbox.appendMessage} returns a L{Deferred} which fires when the message has been added to the end of the mailbox. cg|]}d|zS)Xr/)r1is r3r8z8MaildirAppendStringTests.test_append..s'F'F'FAa'F'F'Fr5ro Nr.) r rMaildirMailboxr\rrLr<rFrrH _cbTestAppend)r[r4r\s r3 test_appendz$MaildirAppendStringTests.test_appends |**4622C  'F'Fq"'F'F'F G G d& 444 d($///r5c |td|fdtdDt tdd|dd|d}||jdd ||j||jdd ||j||jd |S) Check that the mailbox has the expected number (ten) of messages in it, and that each has the expected contents, and that they are in the same order as that in which they were appended. r.cxg|]6}t|7Sr/rIrrr1rRr4s r3r8z:MaildirAppendStringTests._cbTestAppend..%9 ? ? ?S##((** + + ? ? ?r5rorSNF)r)T)r)r")r"r)r)rHrIrrFrJrMrIrrHs ` r3rUz&MaildirAppendStringTests._cbTestAppends& T..00112666  ? ? ? ?U2YY ? ? ?eArllASAS    tT%000 LLt $ $ dnd4u EEE dlD))) dnd$U CCC dlD))) dnd 666r5)NNN) rbrxryrrrIrMrrzr{rVrUr/r5r3r>r>s///000!1!1!1!1F VC  $&>??  @? r5r>cZeZdZdZdZeejdkddZdZ dS)MaildirAppendFileTestsr?c||_tj|jdSrrArhs r3rzMaildirAppendFileTests.setUp8rCr5r(r*ctj|j}g}t ddD]r}t j}|d|z|dd| || |j s| ||}| |j||S)rOrorSrQr)r rrTr\rFtempfile TemporaryFiler"seekr2rrr<rrU)r[r4r5rRtempr\s r3rVz"MaildirAppendFileTests.test_append<s |**4622q" ( (A)++D JJsQw    IIaOOO OOD ! ! ! OODJ ' ' ' '  x 0 0 d($///r5c |td|fdtdDt tdddS)rXr.cxg|]6}t|7Sr/rZr[s r3r8z8MaildirAppendFileTests._cbTestAppend..Wr\r5rorSN)rHrIrrFrJ)r[rr4s `r3rUz$MaildirAppendFileTests._cbTestAppendOs T..00112666  ? ? ? ?U2YY ? ? ?eArllASAS     r5N) rbrxryrrrrzr{rVrUr/r5r3r^r^2sn/// VC  $&>??@?$      r5r^cbeZdZdZdZdZdZeej dkddZ dS) MaildirTestsc||_tj|jdSrrArhs r3rzMaildirTests.setUp]rCr5c8tj|jdSr)shutilrmtreer\rhs r3tearDownzMaildirTests.tearDownas dfr5cv|j}tj|d}|tj|otj||tjtj|d|tjtj|d|tjtj|d|tjtj|d|tjtj|d|tjtj|d|tjtj|d|tjtj|d|tjtj|d|tjtj|d|tjtj|d|tjtj|ddS)N.Trashnewcurtmp)r\rrjoinrSrisdir)r[r\trashs r3testInitializerzMaildirTests.testInitializerds F Q)) q))>bgmmA.>.>??? rw||Au'='=>>??? rw||Au'='=>>??? rw||Au'='=>>???  bgll1e&<&<==>>>  bgll1e&<&<==>>>  bgll1e&<&<==>>> rw||E5'A'ABBCCC rw||E5'A'ABBCCC rw||E5'A'ABBCCC  bgll5%&@&@AABBB  bgll5%&@&@AABBB  bgll5%&@&@AABBBBBr5c@tj}|dtj|}|}|d|}|||kdS)a Each call to L{_MaildirNameGenerator.generate} returns a unique string suitable for use as the basename of a new message file. The names are ordered such that those generated earlier sort less than those generated later. g?N)rClockadvancer r_MaildirNameGeneratorgeneraterS)r[clock generator firstName secondNames r3test_nameGeneratorzMaildirTests.test_nameGeneratorws  dL66u== &&((  d''))   J./////r5r(r*c x tjj tjj fddD}d}|D]V}t  |j|d5}|d|zdddn #1swxYwY|dz}Wtj |j}| | ttdd| | dd| | d d | |d d | |dd i}td D]3}||}|||vd||<4tj|d \}}|d | | d d|tj |jdd||tj |j|d || | d d |tj |jdd||tj |j|d dS)zb Exercise the methods of L{IMailbox} as implemented by L{MaildirMailbox}. c\g|](}tdD]}|)S))rF)r1rBr2jns r3r8z-MaildirTests.test_mailbox..s<DDDa588DDa!QQSS DDDDr5)rqrprowr2NrSr<rr>xxxxxxxxxr.rrorq)rrrsr r_generateMaildirNamerr\r"rTrHrrJrFrrr rrr rSrr) r[msgsrRrfObjmbr\uprrs @@r3 test_mailboxzMaildirTests.test_mailboxsd GL L -DDDDD>DDD   AaallC(( $D 37### $ $ $ $ $ $ $ $ $ $ $ $ $ $ $AAA \ ( ( 0 0 **Dq",>,>??? ++Q/// ++Q/// q))..00'::: q))..00'::: r  A 1 A   Q!V $ $ $AaDDw}}T!W%%1  ++Q/// qq5!'D'DEEFFF $&$q'(:(:;;<<<  ++Q/// $&(E1(E(EFFGGG qqa'9'9::;;;;;sA>>B B N) rbrxryrrmrvrrrzr{rr/r5r3rhrh[s///CCC&000" VC  $&>??(<(<@?(<(<(.ISomethingN)rbrxryr/r5r3 ISomethingrs Dr5ruserrNr)rror<) rrrrNotImplementedError requestAvatarrIMailboxrHrIrSr)r[rts r3test_requestAvatarz+MaildirDirdbmDomainTests.test_requestAvatars         vz***  !5vtZ    F t} = = Q### ! -...  00166777 !r5c|jdd|jd}tjdd}|tjj|j |tjdd}| | |ddS)a L{DirdbmDatabase.requestAvatarId} raises L{UnauthorizedLogin} if supplied with invalid user credentials. When called with valid credentials, L{requestAvatarId} returns the username associated with the supplied credentials. rrrwrong passwordN) rrrrrUsernamePasswordrerrorUnauthorizedLoginrequestAvatarIdrH)r[databasers r3test_requestAvatarIdz-MaildirDirdbmDomainTests.test_requestAvatarId s vz***6002215 11&:JKK $*68PRWXXX 11&*EE 11%88&AAAAAr5c |jdd||jdtj|jjdd|j_| |jddd|j_||jdtj|jjddS)a] L{MaildirDirdbmDomain.userDirectory} is supplied with a user name and returns the path to that user's maildir subdirectory. Calling L{MaildirDirdbmDomain.userDirectory} with a non-existent user returns the 'postmaster' directory if there is a postmaster or returns L{None} if there is no postmaster. rrFnouserNT postmaster) rrrH userDirectoryrrrsrootrassertIdenticalrhs r3test_userDirectoryz+MaildirDirdbmDomainTests.test_userDirectorys vz***  F  ( ("',,tv{F*K*K   " TV11(;;TBBB   F  * *BGLLl,S,S     r5N)rbrxryrrrmrrzr{rrrrrr/r5r3rrsBBB VC  $&>?? E E@? E     VC  $&>??@?0 VC  $&>??BB@?B  VC  $&>??  @?   r5rc,eZdZdZddZdZdZdZdS)StubAliasableDomainz> Minimal testable implementation of IAliasableDomain. Nctz{ No test coverage for invocations of this method on domain objects, so we just won't implement it. rr[rmemos r3rzStubAliasableDomain.exists; "###r5ctrr)r[rrs r3rzStubAliasableDomain.addUserBrr5cgS)a! This needs to succeed in order for other tests to complete successfully, but we don't actually assert anything about its behavior. Return an empty list. Sometime later we should return something else and assert that a portal got set up properly. r/rhs r3rz*StubAliasableDomain.getCredentialsCheckersIs  r5c||_dS)zG Just record the value so the test can check it later. N) aliasGroup)r[aliasess r3 setAliasGroupz!StubAliasableDomain.setAliasGroupRs"r5r)rbrxryrrrrrr/r5r3rr5s_$$$$$$$"""""r5rceZdZdZdZdZeejdkddZ eejdkddZ dZ d Z d Z d Zd S) ServiceDomainTestsctj|_tj|jd|_|j|j_d|j_d|j_| |_ tj |j|j }| dd|jd|dS)NrEhostnameuserpassword test.domain)r rrrDomainDeliveryBaserr protocolNamehostrtmpdirrrrrr[res r3rzServiceDomainTests.setUp[s&&((22464@@$  kkmm 11$&$+FFw ,,, /////r5c8tj|jdSrrkrlrrhs r3rmzServiceDomainTests.tearDowng dk"""""r5ct}t}||j_|jd|||j|dS)z Test that adding an IAliasableDomain to a mail service properly sets up alias group references and such. example.comN)rrrrrrr)r[rres r3testAddAliasableDomainz)ServiceDomainTests.testAddAliasableDomainjsX (($&&  /// V.88888r5r(r*c|jdtjddg}t j|}t j}| |}| t| d| d|dS)N) remotehostz123.232.101.234zzuser@host.nameroReceived)rreceivedHeaderrAddressioBytesIOemailparserParserparserHrIrPr`)r[hdrr emailParserr3s r3testReceivedHeaderz%ServiceDomainTests.testReceivedHeaderusf## - L. / /     Z__l))++   b ! ! QWWYY+++ j!$$$$$r5ctjdddd}tj|jj||jS)Nzuser@test.domainhelowherever@whatever)rUserr maybeDeferredr validateTor _cbValidateTor[rs r3testValidateToz!ServiceDomainTests.testValidateTosIy+VT;NOO"46#4d;;GG     r5cJ|t|dSr)rScallablers r3rz ServiceDomainTests._cbValidateTos" (()))))r5ctjdddd}|tj|jj|tjS)Nzresu@test.domainrrrrrFr rrrrrs r3testValidateToBadUsernamez,ServiceDomainTests.testValidateToBadUsernameKy+VT;NOO!!   14 8 8$:J   r5ctjdddd}|tj|jj|tjS)Nzuser@domain.testrrrrs r3testValidateToBadDomainz*ServiceDomainTests.testValidateToBadDomainrr5cd}tjd}||j|||ud}tjd}||j|||ud}tjd}||j|||u|tj|jjd|dS)N)rrz)r1.2.3.4z<>)rrrSr validateFromr SMTPBadSender)r[rorigins r3testValidateFromz#ServiceDomainTests.testValidateFroms(/00 ++D&99VCDDD&/00 ++D&99VCDDD&d## ++D&99VCDDD $,df.A4PPPPPr5N)rbrxryrrmrrrzr{rrrrr rr/r5r3rrYs 0 0 0### 9 9 9 VC  $&>?? % %@? % VC  $&>??  @? ***      Q Q Q Q Qr5rceZdZdZdZeejdkddZdZ eejdkddZ eejdkddZ eejdkdd Z d Z eejdkdd Zeejdkdd Zd S)VirtualPOP3Testsc||_tj|_tj|j|j|_|jdd|j d|jtj |j}t|j|j|x|jjd<|jjd<tj|_|j|j_d|j_dS)Nrrrrz)rrr rrrrrrrrportalPortalmapregisterCheckerrrr VirtualPOP3rrmagic)r[rs r3rzVirtualPOP3Tests.setUpskkmm &&((11$&$+FF w ,,, ///##DF++ F "DF$A$A$C$CDDD=CCrTV^M:++--* r5c8tj|jdSrrrhs r3rmzVirtualPOP3Tests.tearDownrr5r(r*ct|jjdz}|jd||jS)Nrr)rrr hexdigestauthenticateUserAPOPr_cbAuthenticateAPOPr[resps r3testAuthenticateAPOPz%VirtualPOP3Tests.testAuthenticateAPOPsT46<*,--7799v**6488DD  $   r5c(|t|d||dtj|tj|d|ddSNr)rror<rHrIrrrSrrs r3rz$VirtualPOP3Tests._cbAuthenticateAPOPs Va((( DM222  00;;<<<q r5ct|jjdz}||jd|t jjS)Nrresu) rrrrrFrrrrrs r3!testAuthenticateIncorrectUserAPOPz2VirtualPOP3Tests.testAuthenticateIncorrectUserAPOPsX46<*,--7799!! F ' ' 5 5tz7S   r5ctd}||jd|t jjS)Nz wrong digestr)rrrFrrrrrrs r3%testAuthenticateIncorrectResponseAPOPz6VirtualPOP3Tests.testAuthenticateIncorrectResponseAPOPsO>"",,..!! F ' ' 5 5tz7S   r5ch|jdd|jS)Nrr)rauthenticateUserPASSr_cbAuthenticatePASSrhs r3testAuthenticatePASSz%VirtualPOP3Tests.testAuthenticatePASSs2v**6:>>JJ  $   r5c(|t|d||dtj|tj|d|ddSr"r#rs r3r,z$VirtualPOP3Tests._cbAuthenticatePASSr$r5c~||jddtjjS)Nr&rrFrr+rrrrhs r3testAuthenticateBadUserPASSz,VirtualPOP3Tests.testAuthenticateBadUserPASSs7!! F ' ' ; ; J (   r5c~||jddtjjS)Nrrr0rhs r3testAuthenticateBadPasswordPASSz0VirtualPOP3Tests.testAuthenticateBadPasswordPASSs8!! F ' '0@ A A J (   r5N)rbrxryrrmrrzr{r rr'r)r-r,r1r3r/r5r3rrs| + + +### VC  $&>??  @?   VC  $&>??  @?  VC  $&>??  @?  VC  $&>??  @?   VC  $&>??  @?  VC  $&>??  @?   r5rceZdZdZdS)emptycdSrr/rhs r3__init__zempty.__init__s r5N)rbrxryr7r/r5r3r5r5s#     r5r5cJeZdZeejdkddZdS) RelayTestsr(r*cdtj}tj|}t jdt jdddg}t jdddt jdddg}|D]t}d |_d |_ t|_ t|j _ fd |j j _ | t|||D]t}d |_t|_ t|j _ fd |j j _ d|_ |t"j|j|dS)Nz/var/run/mail-relayTCPrrz 192.168.2.1>r iz user@hostz tsoh@resucSrr/peersr3r9z'RelayTests.testExists..dr5z some@placecSrr/r>sr3r9z'RelayTests.testExists..r@r5z who@cares)r rrelay DomainQueuerr UNIXAddress IPv4Addressr5origdestr rgetPeerrSrrrrr)r[rredoRelay dontRelayrr?s @r3rzRelayTests.testExistss)''))((11   5 6 6  {E : :   }b 9 9  y$ 7 7  ; ;D77D#DI#DI!GGDM&+ggDM #.:lllDM # + OOHV]]4%8%899 : : : : E ED77D$DI!GGDM&+ggDM #.:lllDM # +#DI   d. t D D D D E Er5N)rbrxryrrzr{rr/r5r3r9r9sI VC  $&>?? E E@? E E Er5r9c,eZdZdZdZdZdZdZdS) RelayerTestsc||_tj|jg|_t dD]}tj|jd|fz}t|dzd5}tj d|fzd|fzg|dddn #1swxYwYt|dzd}| || d d |j |tj|_|j|jdS) Nr.body-%d-Hrfrom-%dto-%d-Drr)rrrmkdir messageFilesrFrrsrpickledumpr"rcr2r rB RelayerMixinR loadMessages)r[rRrrs r3rzRelayerTests.setUps{kkmm  r + +A7<< Y!-=>>DdTk4(( CA Y!-w!~>BBB C C C C C C C C C C C C C C CTD[#&&A GGDMMM FF1aLLL   $ $T * * * *((** D-.....s B33B7 :B7 c8tj|jdSrrrhs r3rmzRelayerTests.tearDown0rr5c"tdD]Q}||jd|fz|jdddddR||jddS)Nr.rP)rFrHrX getMailFromsentMailr[rRs r3 testMailFromzRelayerTests.testMailFrom3sr 9 9A   TV//119t3C D D D FOOCtT4 8 8 8 8 ++--t44444r5c$tdD]R}||jd|fzg|jdddddS||jddS)Nr.rQr\)rFrHrX getMailTor^r_s r3 testMailTozRelayerTests.testMailTo9sr 9 9A   TV--//'QD.1A B B B FOOCtT4 8 8 8 8 ))++T22222r5ctdD]}tj|jd|fz}||j||j ddddd||jddS)Nr.rNr\) rFrrrsrrHrX getMailDatarr^)r[rRrs r3 testMailDatazRelayerTests.testMailData?sr 9 9A7<< Y!-=>>D   TV//116688$ ? ? ? FOOCtT4 8 8 8 8 ++--t44444r5N)rbrxryrrmr`rcrfr/r5r3rLrLs_///"###555 333 55555r5rLc&eZdZdZdZdZdZdS)Managerc0g|_g|_g|_dSr)successr donerhs r3r7zManager.__init__Hs   r5c>|j||fdSr)rjr2r[rrqs r3 notifySuccesszManager.notifySuccessM# Wg./////r5c>|j||fdSr)r r2rms r3 notifyFailurezManager.notifyFailurePror5c:|j|dSr)rkr2)r[rs r3 notifyDonezManager.notifyDoneSs !!!!!r5N)rbrxryr7rnrqrsr/r5r3rhrhGsP 000000"""""r5rhc&eZdZdZdZdZdZdS)ManagedRelayerTestscpt|_ttddd|_t |_tj |j|_ |jdd|j _|jdd|j _ |j|j _dS)Nrr:r<) rhmanagerrJrFr5rrr relaymanagerManagedRelayerMixinrBnamesrhs r3rzManagedRelayerTests.setUpYsyy U1b!__-- xx &::4<HH "mAAA. =+ !\ r5cjD] }jddddd!jjfdjDdS)Nr\c"g|] }j|f Sr/rr1r3r[s r3r8z>ManagedRelayerTests.testSuccessfulSentMail..g "L"L"LDL!#4"L"L"Lr5)r5rBr^rHrwrjr_s` r3testSuccessfulSentMailz*ManagedRelayerTests.testSuccessfulSentMailbx = =A J  T4t < < < <  L "L"L"L"Ldm"L"L"L     r5cjD] }jddddd!jjfdjDdS)Ni&c"g|] }j|f Sr/r}r~s r3r8z:ManagedRelayerTests.testFailedSentMail..orr5)r5rBr^rHrwr r_s` r3testFailedSentMailz&ManagedRelayerTests.testFailedSentMailjrr5c|jtjt ||jj|jgdSr) rBrr FailurerGrHrwrkrrhs r3testConnectionLostz&ManagedRelayerTests.testConnectionLostrsK !!'/)++">">??? *T\N;;;;;r5N)rbrxryrrrrr/r5r3ruruWsP***      <<<<g}|jD]/}||j|0|t dD]-}||dd|g.dS)Nrrr)rrr2 getEnveloperNrFrHpop)r[ envelopesrrRs r3 testEnvelopez DirectoryQueueTests.testEnvelopes :((** : :C   TZ33C88 9 9 9 9r > >A   Y]]1--!} = = = = > >r5N) rbrxryrrmrrzr{rrrrr/r5r3rrws # # #### VC  $&>?? ; ;@? ; VC  $&>?? ; ;@? ; VC  $&>?? 9 9@? 9>>>>>r5r)clientcommonserverceZdZdZddZdS) TestAuthoritycRtj|i|_dSr)r ResolverBaser7 addressesrhs r3r7zTestAuthority.__init__s$$$T***r5Nc ||jvr|tjkr}g}|j|D]V}tj|tjtjdtjd|}||Wtj|ggfStj tj tj |S)N<r) rrMXrINrr2r succeedfailr r DomainError)r[rclstypetimeoutr6rArs r3_lookupzTestAuthority._lookups 4> ! !dcfnnG^D) $ $l4S]1a=P=PQQs####='2r!233 3z'/#/$*?*?@@AAAr5r)rbrxryr7rr/r5r3rrs=BBBBBBr5rct|_tj|jg}t j|} t jd|d|_|j j} t j ||d|_ n*#t$r|j YnwxYwtjd|fg|_dS)Nrorr interface)servers)rauthrDNSServerFactoryrDNSDatagramProtocolr listenTCPportgetHost listenUDPudpPortr stopListeningrResolverresolver)r[rr portNumbers r3setUpDNSrsDI%tyk22G&w//H %aKHHH Y&&((-  ",H DL ! & & & I # # % % % % % & Ok:-F,GHHHDMMMs>B#CCcRg}|tj|jj|tj|jj |jjn#t$rYnwxYwtj |Sr) r2r rrrrr _parseCallcancel BaseException DeferredList)r[dls r3 tearDownDNSrs BIIe!$)"9::;;;IIe!$,"<==>>>   ''))))       b ! !!s&B BBceZdZdZdZdZdZeej dkddZ dZ d Z d Z d Zd Zd ZdZdZdZdZdZdZdZdZdZeej dkddZdZdZdZdZdS)MXTestsz6 Tests for L{mail.relaymanager.MXCalculator}. ct|tj|_tj|j|j|_dSr) rrrxr|r rx MXCalculatorrmxrhs r3rz MXTests.setUps<Z\\ #00 KKr5c t|Sr)rrhs r3rmzMXTests.tearDowns4   r5c|tj|jjt dS)zQ L{MXCalculator}'s default clock is C{twisted.internet.reactor}. N)rr rxrrr|rrhs r3test_defaultClockzMXTests.test_defaultClocksA    * *4= 9 9 ?     r5r(r*cdg|jjd<|jd|jS)Nthe.email.test.domainr)rrrgetMXr_cbSimpleSuccessrhs r3testSimpleSuccesszMXTests.testSimpleSuccesss9.E-F M*w}}]++778MNNNr5c||jd|t|jddS)Nrr)rH preferencercrr[rs r3rzMXTests._cbSimpleSuccesss? *** RW'>?????r5cd|j_||jdtS)NFr)rfallbackToDomainrFrIOErrorrhs r3testSimpleFailurezMXTests.testSimpleFailure s0#( !!$'-- ">">HHHr5ch||jdtSNr)rFrrrrhs r3testSimpleFailureWithFallbackz%MXTests.testSimpleFailureWithFallbacks&!!$'-- ">">OOOr5cGfdd}|j_j}fd}|||S)aZ Issue an MX request for the given domain and arrange for it to be responded to with the given records. Verify that the resulting mail exchange is the indicated host. @type domain: C{str} @type records: C{list} of L{RRHeader} @type correctMailExchange: C{str} @rtype: L{Deferred} ceZdZfdZdS),MXTests._exchangeTest..DummyResolverc|krtjggfStjtSr)r rrr)r[rrerecordss r3lookupMailExchangez?MXTests._exchangeTest..DummyResolver.lookupMailExchanges;6>> ='2r):;;;z,v"6"6777r5Nrbrxryr)rersr3 DummyResolverrs3 8 8 8 8 8 8 8 8r5rcXt|jdSrrHrcr)recordcorrectMailExchanger[s r3gotMailExchangez.MXTests._exchangeTest..gotMailExchange's*   S--/B C C C C Cr5)rrrr)r[rerrrr\rs```` r3 _exchangeTestzMXTests._exchangeTests 8 8 8 8 8 8 8 8 8 8 8 )=?? GMM& ! ! D D D D D D o&&&r5c 6d}d}d}t|tjtd|t|tjtd|t|tjtd|g}||||S)zh The MX record with the lowest preference is returned by L{MXCalculator.getMX}. rgood.example.combad.example.comrorrpayloadrr<)rrTYPErr[regoodbadrs r3test_mailExchangePreferencez#MXTests.test_mailExchangePreference-s ! &y~yC?P?P Q Q Q &y~yD?Q?Q R R R &y~yC?P?P Q Q Q  !!&'4888r5c d}d}d}t|tjtd|t|tjtd|g}|j|||||S)z L{MXCalculator.getMX} returns the MX record with the lowest preference which is not also marked as bad. rrrrrrorrrrmarkBadrrs r3test_badExchangeExcludedz MXTests.test_badExchangeExcluded=s ! &y~yC?P?P Q Q Q &y~yD?Q?Q R R R  !!&'4888r5c Ld}d}d}t|tjtd|t|tjtd|g}|j||j|||||S)z L{MXCalculator.getMX} returns the MX record with the lowest preference if all the MX records in the response have been marked bad. rrzworse.example.comrrror)r[rerworsers r3test_fallbackForAllBadExchangesz'MXTests.test_fallbackForAllBadExchangesMs # &y~yC?P?P Q Q Q &y~yE?R?R S S S   !!&'3777r5c `d}d}d}t|tjtd|t|tjtd|g}|j||j|jj||||S)z L{MXCalculator.getMX} returns the MX record with the lowest preference if it was last marked bad longer than L{MXCalculator.timeOutBadMX} seconds ago. rrrrrro) rrrrrr|ry timeOutBadMXrr[rer previouslyBadrs r3test_badExchangeExpireszMXTests.test_badExchangeExpires^s !)  ).)A}:U:U    &y~yD?Q?Q R R R    &&& 47/000!!&'=AAAr5c d}d}d}t|tjtd|t|tjtd|g}|j||j||j|jj| |||S)z L{MXCalculator.getMX} returns the MX record with the lowest preference if it was marked good after it was marked bad. rrrrrro) rrrrrmarkGoodr|ryr rr s r3test_goodExchangeUsedzMXTests.test_goodExchangeUsedrs !)  ).)A}:U:U    &y~yD?Q?Q R R R    &&& ''' 47/000!!&'=AAAr5cddGfdd}||j_|j}||jt |S)z If an MX lookup succeeds but the result set is empty, L{MXCalculator.getMX} should try to look up an I{A} record for the requested name and call back its returned Deferred with that address. r z example.orgc6eZdZdZgggfiZiZdZdZdS)9MXTests.test_successWithoutResults..DummyResolverah Fake resolver which will respond to an MX lookup with an empty result set. @ivar mx: A dictionary mapping hostnames to three-tuples of results to be returned from I{MX} lookups. @ivar a: A dictionary mapping hostnames to addresses to be returned from I{A} lookups. c@tj|j|Sr)r rrrs r3rzLMXTests.test_successWithoutResults..DummyResolver.lookupMailExchanges}TWV_555r5c@tj|j|Sr)r rrArs r3 getHostByNamezGMXTests.test_successWithoutResults..DummyResolver.getHostByNames}TVF^444r5N)rbrxryrrrArr)reipsr3rrsX  2r2,'B A 6 6 6 5 5 5 5 5r5rrrrrrrHr)r[rr\rers @@r3test_successWithoutResultsz"MXTests.test_successWithoutResultss 5 5 5 5 5 5 5 5 5 5 5*)=?? GMM& ! ! d& r(:(:(:;;;r5cGdd}||j_|jd}||jt d|S)a' Test that if the MX record lookup fails, fallback is enabled, and an A record is available for the name, then the Deferred returned by L{MXCalculator.getMX} ultimately fires with a Record_MX instance which gives the address in the A record for the name. ceZdZdZdZdZdS)AMXTests.test_failureWithSuccessfulFallback..DummyResolverzw Fake resolver which will fail an MX lookup but then succeed a getHostByName call. cBtjtSr)r rrrs r3rzTMXTests.test_failureWithSuccessfulFallback..DummyResolver.lookupMailExchangesz,..111r5c*tjdS)Nr )r rrs r3rzOMXTests.test_failureWithSuccessfulFallback..DummyResolver.getHostByNames}Y///r5N)rbrxryrrrr/r5r3rrs<    2 2 2 0 0 0 0 0r5rrer rr)r[rr\s r3"test_failureWithSuccessfulFallbackz*MXTests.test_failureWithSuccessfulFallbacksv 0 0 0 0 0 0 0 0)=?? GMM( # # d& y(A(A(ABBBr5cdddGfdd}||j_|j}||jt |S)z If an MX lookup returns a single CNAME record as a result, MXCalculator will perform an MX lookup for the canonical name indicated and return the MX record which results. alias.example.comcanonical.example.commail.example.comc"eZdZdZfdZdS);MXTests.test_cnameWithoutGlueRecords..DummyResolverz Fake resolver which will return a CNAME for an MX lookup of a name which is an alias and an MX for an MX lookup of the canonical name. c \|kr?tjt|tjtgggfS|kr@tjt|t jt dgggfStjt|S)Nrr)r rrrrrrr)r[realias canonicalexchanges r3rzNMXTests.test_cnameWithoutGlueRecords..DummyResolver.lookupMailExchangesU?? =!))/)5):,8,C,C!"!"!"    y(( =!))/)2,5a,B,B!"!"!"    !:l6&:&:;;;r5N)rbrxryrr)r)r*r+sr3rr'sB    < < < < < < < < .DummyResolverz Fake resolver which generates a CNAME chain of infinite length in response to MX lookups. rc |xjdz c_d|jfz}tjt|tjt |gggfS)Nrox-%d.example.comr) chainCounterr rrrr)r[rers r3rzAMXTests.test_cnameChain..DummyResolver.lookupMailExchangest!!Q&!!)T->,@@}%%+%1%6(4T(:(:    r5N)rbrxryrr2rr/r5r3rr/s4   L     r5rr)r%c|jdtddzfzjjjdzdS)Nrr1ro)rHargsrrrr2)r cnameLimitr[s r3cbChainTooLongz/MXTests.test_cnameChain..cbChainTooLongse    1 |,>*q.AR,RSS      TW-:JN K K K K Kr5) rrrrFtwistedr rxCanonicalNameChainTooLongr)r[rr\r6r5s` @r3test_cnameChainzMXTests.test_cnameChains        2 (=?? GMM,j 9 9 1gl7QRRR L L L L L L n%%%r5cgdddGfdd}||j_|j}||jt |S)z If an MX lookup returns a CNAME and the MX record for the CNAME, the L{Deferred} returned by L{MXCalculator.getMX} should be called back with the name from the MX record without further lookups being attempted. r#r$r%c eZdZfdZdS)8MXTests.test_cnameWithGlueRecords..DummyResolverc |ksrgggfStjttjttt jt gggfS)Nrr)r rrrrr)r[rer)r*r+lookedUps r3rzKMXTests.test_cnameWithGlueRecords..DummyResolver.lookupMailExchange3sU??h?B<'}%%*%1%6(4Y(?(? %%.%.^(1x(@(@(@ r5Nr)r)r*r+r>sr3rr<2s=          r5rrr)r[rr\r)r*r+r>s @@@@r3test_cnameWithGlueRecordsz!MXTests.test_cnameWithGlueRecords&s#+ %             2)=?? GMM%  d& x(@(@(@AAAr5cddGfdd}||j_|j}||tjjj|S)z If an MX lookup returns two CNAME records which point to each other, the loop should be detected and the L{Deferred} returned by L{MXCalculator.getMX} should be errbacked with L{CanonicalNameLoop}. zcname1.example.comzcname2.example.comceZdZfdZdS).DummyResolverc tjttjtttjtgggfS)Nr)r rrrr)r[re firstAlias secondAliass r3rzOMXTests.test_cnameLoopWithGlueRecords..DummyResolver.lookupMailExchangeZsy}%%/%1%6(4[(A(A %%0%1%6(4Z(@(@ r5Nr)rDrEsr3rrBYs3        r5r)rrrrFr7r rxCanonicalNameLoop)r[rr\rDrEs @@r3test_cnameLoopWithGlueRecordsz%MXTests.test_cnameLoopWithGlueRecordsPs * *            *)=?? GMM* % % 1gl7IJJJr5cgd|jjd<|jd|jS)N)zmx1.test.domainzmx2.test.domainzmx3.test.domainr)rrrrr_cbManyRecordsSuccessfulLookuprhs r3testManyRecordszMXTests.testManyRecordsssK. . .  M* w}}]++77  /   r5cF|t|jddddv|jt|j|jd|j|S)N.ror)mx1mx2mx3r) rSrcrrrrrr_cbManyRecordsDifferentResultrs r3rIz&MXTests._cbManyRecordsSuccessfulLookup~s BG **322159NNOOO BG %%%w}}]++77  .   r5c6|t|jt|j|jt|j|jd|j||Sr)rrcrrrrr_cbManyRecordsLastResult)r[nextMXrs r3rPz%MXTests._cbManyRecordsDifferentResultsx CLL#fk*:*:;;; FK(()))w}}]++77  )2v   r5c|t|jt|j|t|jt|j|jt|j|jt|j|jd|j|Sr) rrcrrrrrr"_cbManyRecordsRepeatSpecificResult)r[lastMXrrSs r3rRz MXTests._cbManyRecordsLastResults CLL#fk*:*:;;; C ,,c&+.>.>??? FK(())) V[))***w}}]++77  3V   r5cz|t|jt|jdSrr)r[againMXrSs r3rUz*MXTests._cbManyRecordsRepeatSpecificResults2 W\**C ,<,<=====r5N)rbrxryrrrmrrrzr{rrrrrrrr rrrr!r,r9r?rGrJrIrPrRrUr/r5r3rrsLLL !!!    VC  $&>??OO@?O@@@IIIPPP6999 999 888"BBB(BBB("""H2333j,,,\(((T!!!F VC  $&>??  @?           >>>>>r5rceZdZejeddZdZdZe e j dkddZ e e j dkddZ dS) LiveFireExerciseTestsNz1UDP support is required to determining MX recordsc6t|gd|_dS)N) domainDirinsertionDomaininsertionQueuedestinationDomaindestinationQueue)rtmpdirsrhs r3rzLiveFireExerciseTests.setUps$    r5c|jD]5}tj|rt j|6t |Sr)rarrrrkrlr)r[r\s r3rmzLiveFireExerciseTests.tearDownsH ! !Aw~~a   ! a   4   r5r(r*ctj}|jtjtj|d dd| d|j d|j d<t|j dj |tj||}t%jd|d_t+gd t-t/j}fd |_fd |_t%jdjj|fd }|S) Nr\rrrrrrr) HELO mesonzMAIL FROM: zRCPT TO: DATAThis is the messagerLQUITcSrr/rsr3r9z9LiveFireExerciseTests.testLocalDelivery..Vr5c.dSrcallbackr4rks r3r9z9LiveFireExerciseTests.testLocalDelivery..t}}T/B/Br5c$ddtjd}|d}|ddjSNrrorrf) rrrrrrfind smtpServerr)ignr4rrer[s r3finishedz9LiveFireExerciseTests.testLocalDelivery..finishedsu''dmDDQGD//!$$))++C   )> ? ? D D D?0022 2r5)r r smtpPortalrrrAllowAnonymousAccessrrrrrrrsetQueuerBrCrrrrtrrr ClientFactoryclientConnectionLost connectTCPrrr)r[rrrvrrerks` @@@r3testLocalDeliveryz'LiveFireExerciseTests.testLocalDeliverys)''))**4=+M+M+O+OPPP11';GGvz***-000%om< GOB  /1N1N1P1PQQQ0099:::  " " $ $!+AqKHHH$      zz  " $ $#^^^ !B!B!B!B;(?(?(A(A(FJJJ 3 3 3 3 3 3 """ r5c tj}|jtjtj|d| dtj d| tj d|jtj|tj |j xjdz c_tj  dtj j _dgjjd<|}t;jd|d _tj}|jtjtj|d  d d | dtj d | tj d tj  d!|}t;jd|d _"j"#j$ _%tMgdtOtQj)}fd|_(fd|_*t;j+dj#j$| fd},|S)Nr]zinsertion.domainr^)ztest.identity.hostnamerorzdestination.domainrrr_rrr`)rdzMAIL FROM: z"RCPT TO: rerfrLrgcSrr/risr3r9z9LiveFireExerciseTests.testRelayDelivery..rjr5c.dSrrlrns r3r9z9LiveFireExerciseTests.testRelayDelivery..ror5ch}fd}|||S)Ncddtjd}|d}|ddjj  dSrq) rrrrrrrs insServerr destServer stopService)rur4rrehelperr[s r3 deliveredzLLiveFireExerciseTests.testRelayDelivery..finished..delivereds++FD$-HHKooa((--//##CHH-B$C$CRHHH,,...--///""$$$$$r5) checkStater)rurrrerrwr[s r3rvz9LiveFireExerciseTests.testRelayDelivery..finishedsT))++H % % % % % % %   + + +Or5)-r rrwrrrrxrrrrrSryrxrrYsetDefaultDomainrBrCSmartHostSMTPRelayingManagerrfArgsRelayStateHelperrrmxcalcrrrrrrr startServicerrrPORTrrr rzr{r|r) r[insServrdestServrvrrerkrrws ` @@@@@r3testRelayDeliveryz'LiveFireExerciseTests.testRelayDeliverysE)''))**4=+M+M+O+OPPP11';LMM,f555 !"""*001ABBCCC(()@)@)I)IJJJ#@@OO 44 "33GQ??*77 FF5@M 01  " " $ $ *1a;GGG9((**++DM,N,N,P,PQQQ11((>(@(@(EqIII        " """ r5)rbrxryr IReactorUDPrskiprrmrrzr{r}rr/r5r3rZrZszgt,,4B   !!!  VC  $&>??))@?)V VC  $&>??KK@?KKKr5rZc&eZdZdZdZdZdZdS)LineBufferMessagec0g|_d|_d|_dS)NF)lineseomlostrhs r3r7zLineBufferMessage.__init__-s  r5c:|j|dSr)rr2)r[rs r3rzLineBufferMessage.lineReceived2s $r5c8d|_tjdS)NTz )rr rrhs r3rzLineBufferMessage.eomReceived5s}\***r5cd|_dS)NT)rrhs r3rz LineBufferMessage.connectionLost9s  r5N)rbrxryr7rrrr/r5r3rr,sP    +++r5rceZdZgdZdZeejdkddZdZ dZ eejdkddZ d Z d S) AliasTestsz First linez Next linerzAfter a blank linez Last linecLi}gd}|D]$}tj||dd%||dddg||ddg||dd g||d gd dS) N)zuser: another@host znextuser: |/bin/program zuser: me@again z"moreusers: :/etc/include/filename z3multiuser: first@host, second@host,last@anotherhostr$rz another@hostzme@againnextuserz |/bin/program moreusersz:/etc/include/filename multiuser)z first@hostz second@hostzlast@anotherhost)r r)handlerH)r[rrls r3 testHandlezAliasTests.testHandleAs    ; ;A J  faT : : : : .*)EFFF  +o->???  ,/G.HIII  ; !R!R!R     r5r(r*cdti}tj|t jt jd}| t|d|d}t|}dD]+}| | |d,| t|d|d }t|}d D]+}| | |d,| t|d|d }t|}| | d dd D]/}| | |dd|z0| t|ddS)Nra # Here's a comment # woop another one testuser: address1,address2, address3, continuation@address, |/bin/process/this usertwo:thisaddress,thataddress, lastaddress lastuser: :/includable, /filename, |/program, address )rr)testuser)address1address2address3zcontinuation@addressz/bin/process/thisrrrusertwo) thisaddress thataddress lastaddresslastuserz /includable)z /filenameprogramr z %s not found)rr r) loadAliasFilerrtextwrapdedentencoderHrIrcrrs)r[rYrgroupsrAs r3testFileLoaderzAliasTests.testFileLoaderUsvxx.)) z  &((  *  " Va(((z" JJ  / /A   q 2 . . . . UQ'''y! JJ> / /A   q 2 . . . . UQ'''z" JJ  ..3334 C CA   q 2~/A B B B B UQ'''''r5c*tttf}tj|}|jD]}||||j|Sr) rr r) MultiWrapperrrrr_cbMultiWrapper)r[rrLs r3testMultiWrapperzAliasTests.testMultiWrappers ""$5$7$79J9L9LLj%%d++  A   Q      ,,T-A4HHHr5c|D]V}||j||j||j|jWdSr)rSrrrrHr)r[r8rr3s r3rzAliasTests._cbMultiWrappersb 2 2A OOAE " " "   QV $ $ $   TZ 1 1 1 1 2 2r5c,|}tj|dd}|}|jD]}||||j |Sr) rr r) FileAliascreateMessageReceiverrrrr_cbTestFileAlias)r[tmpfilerAr3rs r3 testFileAliaszAliasTests.testFileAliass++-- J $ 5 5 # # % %  A NN1    }}**4+@'JJJr5ct|5}|}dddn #1swxYwY|d|D|jdS)Nc"g|] }|dd SNrrr/r1rs r3r8z/AliasTests._cbTestFileAlias..s 000Q!CRC&000r5r readlinesrHr)r[r8rrrs r3rzAliasTests._cbTestFileAliass ']] "aKKMME " " " " " " " " " " " " " " " 00%000$*=====s 155N) rbrxryrrrrzr{rrrrrr/r5r3rr=s N N NE   ( VC  $&>??,(,(@?,(\III222  VC  $&>??KK@?K>>>>>r5rc eZdZdZdZddZdS) DummyDomainz/ Test domain for L{AddressAliasTests}. c||_dSr)r )r[r s r3r7zDummyDomain.__init__s  r5NcT|rtjdfdS)a  @returns: When a C{memo} is passed in this will raise a L{smtp.SMTPBadRcpt} exception, otherwise a boolean indicating if the C{user} and string version of L{self.address} are equal or not. @rtype: C{bool} hamc4tjkSr)rcr rsr3r9z$DummyDomain.exists..sts4<000r5)r rrrs`` r3rzDummyDomain.existss6  /)''.. .000000r5r)rbrxryrr7rr/r5r3rrsA 1 1 1 1 1 1r5rc0eZdZdZdZdZdZdZdZdS)AddressAliasTestsz7 Tests for L{twisted.mail.alias.AddressAlias}. ctjd|_|jjt |ji}tj|j||j|_dS)z+ Setup an L{AddressAlias}. zfoo@barN)r rrr rerr) AddressAlias)r[rYs r3rzAddressAliasTests.setUpsWy((33 <& DL(A(ABZ,,T\7DLQQ r5c^||jdS)z L{createMessageReceiever} calls C{exists()} on the domain object which key matches the C{alias} passed to L{AddressAlias}. N)rSr)rrhs r3test_createMessageReceiverz,AddressAliasTests.test_createMessageReceivers*  88::;;;;;r5cV|t|jddS)zP The string presentation of L{AddressAlias} includes the alias. z
N)rHrcr)rhs r3rizAddressAliasTests.test_strs) TZ*=>>>>>r5cp||j|jdiddS)z L{resolve} will look for additional aliases when an C{aliasmap} dictionary is passed, and returns L{None} if none were found. rN)rHr)resolver rhs r3 test_resolvezAddressAliasTests.test_resolves7 ++T\5,ABBDIIIIIr5cb||jiddS)z L{resolve} returns L{None} when the alias could not be found in the C{aliasmap} and no L{mail.smtp.User} with this alias exists either. N)rHr)rrhs r3test_resolveWithoutAliasmapz-AddressAliasTests.test_resolveWithoutAliasmaps0 ++B//66666r5N) rbrxryrrrrirrr/r5r3rrsoRRR<<<??? JJJ77777r5rceZdZdgZdS) DummyProcessonEndN)rbrxry __slots__r/r5r3rrs IIIr5rceZdZdZdZdS)MockProcessAliaszD An alias processor that doesn't actually launch processes. cdS)z( Don't spawn a process. Nr/)r[protorrs r3 spawnProcesszMockProcessAlias.spawnProcessr5N)rbrxryrrr/r5r3rrs-     r5rceZdZdZeZdS)MockAliasGroupz3 An alias group using C{MockProcessAlias}. N)rbrxryrrprocessAliasFactoryr/r5r3rrs"+r5rc$eZdZdZdZdZdZdS) StubProcessz Fake implementation of L{IProcessTransport}. @ivar signals: A list of all the signals which have been sent to this fake process. cg|_dSr)signalsrhs r3r7zStubProcess.__init__s  r5cdS)z8 No-op implementation of disconnection. Nr/rhs r3loseConnectionzStubProcess.loseConnectionrr5c:|j|dS)zL Record a signal sent to this process for later inspection. N)rr2)r[signals r3 signalProcesszStubProcess.signalProcess s  F#####r5N)rbrxryrr7rrr/r5r3rrsK   $$$$$r5rc*eZdZdZejeddZgdZdZ dZ dZ dZ e ejd kd d Zd Zd ZdZdZdZe ejd kd dZe ejd kd dZdS)ProcessAliasTestsz% Tests for alias resolution. NzIReactorProcess not supportedrc|dzdz}|tj||tj|||tj||S)a Construct a status from the given exit code. @type code: L{int} between 0 and 255 inclusive. @param code: The exit status which the code will represent. @rtype: L{int} @return: A status integer for the given exit code. r)rSr WIFEXITEDrH WEXITSTATUSr WIFSIGNALED)r[codestatuss r3 exitStatuszProcessAliasTests.exitStatussr!)q  V,,--- //666 //000 r5c|}|tj||tj|||tj||S)a Construct a status from the given signal. @type signal: L{int} between 0 and 255 inclusive. @param signal: The signal number which the status will represent. @rtype: L{int} @return: A status integer for the given signal. )rSrrrHWTERMSIGrr)r[rrs r3 signalStatuszProcessAliasTests.signalStatus0sj v../// V,,f555 f--... r5c@tj|_dt_dS)zB Replace L{smtp.DNSNAME} with a well-known value. rN)rDNSNAMErhs r3rzProcessAliasTests.setUpHs|  r5c(|jt_dS)z@ Restore the original value of L{smtp.DNSNAME}. N)rrrhs r3rmzProcessAliasTests.tearDownOs| r5r(r*ct}|dtj|jdt j|jdd}| }j D]}| |fd}| |S)z Standard call to C{mail.alias.ProcessAlias}: check that the specified script is called, and that the input is correctly transferred to it. zX#!/bin/sh rm -f process.alias.out while read i; do echo $i >> process.alias.out doneiNctd5}|}dddn #1swxYwYd|DjdS)Nzprocess.alias.outc"g|] }|dd Srr/rs r3r8zPProcessAliasTests.test_processAlias.._cbProcessAlias..ns 444af444r5r)r8rrr[s r3_cbProcessAliasz._cbProcessAliasks)** &a  & & & & & & & & & & & & & & &   44e444dj A A A A As 266)r"r setContentrchmodrr r) ProcessAliasrrrrr)r[shrAr3rrs` r3test_processAliasz#ProcessAliasTests.test_processAliasUs dkkmm $ $      %   J # #BGT4 8 8 # # % %  A NN1     B B B B B }}**?;;;r5ctj}ttjtjd|}|}|j |j fd} |tjj | ||S)a  If the alias child process does not exit within a particular period of time, the L{Deferred} returned by L{MessageWrapper.eomReceived} should fail with L{ProcessAliasTimeout} and send the I{KILL} signal to the child process.. Ncjdgtt jdS)NKILL)rHr processEndedrrrSIGKILL)r8rr[rs r3timedOutz.timedOutsS   Y. 9 9 9   01B1B6>1R1RSS T T T T Tr5)rrxrr r)ProcessAliasProtocolrMessageWrapperrrycompletionTimeoutrFProcessAliasTimeoutr)r[rreceiverr\rrrs` @@r3test_processAliasTimeoutz*ProcessAliasTests.test_processAliasTimeoutrs*,,MM  //11 Y''':,,UD'BB  " "2333 U U U U U U U 1dj<=== hr5ctt}tj}|j|tj|dd}|jtjtd| | tS)z If the process associated with an L{mail.alias.MessageWrapper} exits before I{eomReceived} is called, the L{Deferred} returned by I{eomReceived} should fail. Nr) rr r)rrrrr rrrFr)r[rr rs r3test_earlyProcessTerminationz.ProcessAliasTests.test_earlyProcessTerminations  MM :2244 ***:,,XtTBBgok!nn==>>>!!("6"6"8"8+FFFr5ctt}tj}|j|tj|dd}|jtjt|| | tS)z Verify that if the process associated with an L{mail.alias.MessageWrapper} exits with the given status, the L{Deferred} returned by I{eomReceived} fails with L{ProcessTerminated}. N) rr r)rrrrr rrrFr)r[rrr rs r3_terminationTestz"ProcessAliasTests._terminationTests  MM :2244 ***:,,XtTBBgo.?.G.GHHIII!!("6"6"8"8:KLLLr5cR||dS)z If the process associated with an L{mail.alias.MessageWrapper} exits with a non-zero exit code, the L{Deferred} returned by I{eomReceived} should fail. ro)rrrhs r3test_errorProcessTerminationz.ProcessAliasTests.test_errorProcessTerminations$ $$T__Q%7%7888r5cf||tjS)z If the process associated with an L{mail.alias.MessageWrapper} exits because it received a signal, the L{Deferred} returned by I{eomReceived} should fail. )rrrSIGHUPrhs r3test_signalProcessTerminationz/ProcessAliasTests.test_signalProcessTerminations( $$T%6%6v}%E%EFFFr5c "i}dt|gdi}tgd|d}tddg|d}tjd|d}||||d ||}tt|j }| tttjd d d tj td tj d g}| |||||} tt| j } | tttjdd d tjdd d g}| || |||} tt| j } | tttjd d d tj td tj d g}| || |d S)a Check that the C{resolve} method of alias processors produce the correct set of objects: - direct alias with L{mail.alias.AddressAlias} if a simple input is passed - aliases in a file with L{mail.alias.FileWrapper} if an input in the format '/file' is given - aliases resulting of a process call wrapped by L{mail.alias.MessageWrapper} if the format is '|process' r)rrr)r|echo/filealias1rralias2alias3r%r&r'rNechor$) TestDomainrr r)rrTrrrcobjsrNrr FileWrapperrH) r[rreA1A2A3res1r1expectedres2r2res3r3s r3test_aliasResolutionz&ProcessAliasTests.test_aliasResolutionsj*E*E*EFFG 777 J J Wg. A A Z $ $Xvx @ @     zz'"" di     ''t<< )),..&AA &&w//      X&&&zz'"" di     ''t<< ''t<<      X&&&zz'"" di     ''t<< )),..&AA &&w//      X&&&&&r5ci}dt|gi}tjd|d}tjd|d}tjd|d}||||d||d|d||d|d||d|dtddg|d}||d<||}tt|j }| tttj td g} | ||| dS) zN Check that a cycle in alias resolution is correctly handled. rr&r%r'r(Nr#alias4r))r*r r)rrTrHrrrrcr+rNrr) r[rrer-r.r/A4resrr2s r3test_cyclicAliasz"ProcessAliasTests.test_cyclicAliass j"--. Z $ $Xvx @ @ Z $ $Xvx @ @ Z $ $Xvx @ @"bAABBB *227;;TBBB *227;;TBBB *227;;TBBB Wh/ B Bjj!! SX   sTZ66|~~vNNOPP  H%%%%%r5)rbrxryrr IReactorProcessrrrrrrrmrrzr{r rrrrr!r7r=r/r5r3rrsl"z!'4008. N N NE*0$$$  VC  $&>??<<@?<84 G G G M M M999GGG VC  $&>??>'>'@?>'@ VC  $&>??&&@?&&&r5rceZdZdZddZdS)r*c"||_||_dSr)rusers)r[rrAs r3r7zTestDomain.__init__ s  r5Ncjj|jvrfdS |j}||j|rfdSt j#t$rt jwxYw)NcFtjddSr)r r)r)rsr3r9z#TestDomain.exists.. s4:224tDDr5cSrr/)rsr3r9z#TestDomain.exists.." swr5)rGlocalrArrrrr)r[rrrArs ` @r3rzTestDomain.exists sy 4:  DDDD D ) T"Aii d33G '&&"4(( (  ) ) )"4(( ( )s A!!Br)rbrxryr7rr/r5r3r*r* s7 ) ) ) ) ) )r5r*c6eZdZdZdZdZdZdZdZdZ dS) DummyQueuez A fake relay queue to use for testing. This queue doesn't keep track of which messages are waiting to be relayed or are in the process of being relayed. @ivar directory: See L{__init__}. c||_dS)z @type directory: L{bytes} @param directory: The pathname of the directory holding messages in the queue. N) directory)r[rIs r3r7zDummyQueue.__init__0 s #r5ctj|}tj||dztj||dzdS)z Remove a message from the queue. @type message: L{bytes} @param message: The base filename of a message. rRrON)rrbasenameremovegetPathr[rqs r3rkzDummyQueue.done8 sa'""7++ $,,w''$./// $,,w''$./////r5cnttj|j|dzdS)z Get the envelope file for a message in the queue. @type message: L{bytes} @param message: The base filename of a message. @rtype: L{file} @return: The envelope file for the message. rOr)rrrrsrIrNs r3getEnvelopeFilezDummyQueue.getEnvelopeFileC s*BGLL4@@$GGGr5cLtj|j|S)z Return the full base pathname of a message in the queue. @type message: L{bytes} @param message: The base filename of a message. @rtype: L{bytes} @return: The full base pathname of the message. )rrrsrIrNs r3rMzDummyQueue.getPathO sw||DNG444r5ctjdt|}ttj|j|dzd}tj|j|dz}tj|j|dz}t|d}|tj|||fS)z Create a new message in the queue. @rtype: 2-L{tuple} of (E{1}) L{file}, (E{2}) L{FileMessage} @return: The envelope file and a message receiver for a new message in the queue. _rOrz-CrR) timeidrrrrsrIr r)r[fname headerFile tempFilename finalFilename messageFiles r3rzDummyQueue.createNewMessage[ s9;;++D++"',,t~ut|DDdKK w||DNEDLAA  T^UT\BB <.. 4900 }    r5cdS)z Ignore the request to mark a message as waiting to be relayed. @type message: L{bytes} @param message: The base filename of a message. Nr/rNs r3rzDummyQueue.setWaitingm s  r5N) rbrxryrr7rkrPrMrrr/r5r3rGrG& s{### 0 0 0 H H H 5 5 5   $     r5rGceZdZdZdZdS)!DummySmartHostSMTPRelayingManagera4 A fake smart host to use for testing. @type managed: L{dict} of L{bytes} -> L{list} of L{list} of L{bytes} @ivar managed: A mapping of a string identifying a managed relayer to filenames of messages the managed relayer is responsible for. @ivar queue: See L{__init__}. c"i|_||_dS)z Initialize the minimum necessary members of a smart host. @type queue: L{DummyQueue} @param queue: A queue that can be used for testing purposes. N)managedr)r[rs r3r7z*DummySmartHostSMTPRelayingManager.__init__ s  r5N)rbrxryrr7r/r5r3r]r]w s-  r5r]ceZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z eejd kd dZeejd kd dZdZdZdZdZdS)_AttemptManagerTestsa Test the behavior of L{_AttemptManager}. @type tmpdir: L{bytes} @ivar tmpdir: The path to a temporary directory holding the message files. @type reactor: L{MemoryReactorClock} @ivar reactor: The reactor used for test purposes. @type eventLog: L{None} or L{dict} of L{bytes} -> L{object} @ivar eventLog: Information about the last informational log message generated or none if no log message has been generated. @type noisyAttemptMgr: L{_AttemptManager} @ivar noisyAttemptMgr: An attempt manager which generates informational log messages. @type quietAttemptMgr: L{_AttemptManager} @ivar quietAttemptMgr: An attempt manager which does not generate informational log messages. @type noisyMessage: L{bytes} @ivar noisyMessage: The full base pathname of the message to be used with the noisy attempt manager. @type quietMessage: L{bytes} @ivar quietMessage: The full base pathname of the message to be used with the quiet. c||_tj|jt |_d|_tj|j ttt|jd|j|_ ttt|jd|j|_d}d}tj|j||_tj|j||_t'|jdzdt'|jdzd|g|j jjd<|g|jjjd <t'|jd zd 5}t/jd d g|dddn #1swxYwYt'|jd zd 5}t/jddg|ddddS#1swxYwYdS)a Set up a temporary directory for the queue, attempt managers with the noisy flag on and off, message files for use with each attempt manager, and a reactor. Also, register to be notified when log messages are generated. NTF noisyMessage quietMessagerRr noisyRelayer quietRelayerrOrzfrom-noisy@domainzto-noisy@domainzfrom-quiet@domainzto-quiet@domain)rrrrSrreventLogr! addObserver _logObserverrr]rGnoisyAttemptMgrquietAttemptMgrrrsrcrdrrrwr_rUrV)r[ noisyBaseName quietBaseNameenvelopes r3rz_AttemptManagerTests.setUp skkmm  )++   )***. -j.E.E F F  L   / -j.E.E F F  L   ' & GLLmDDGLLmDD T  %s++11333 T  %s++11333@M$,^<@M$,^< $#d*D 1 1 LX K,.?@( K K K L L L L L L L L L L L L L L L$#d*D 1 1 LX K,.?@( K K K L L L L L L L L L L L L L L L L L Ls$G,,G03G0H44H8;H8cjtj|jtj|jdS)zO Unregister for log events and remove the temporary directory. N)r!removeObserverrirkrlrrhs r3rmz_AttemptManagerTests.tearDown s0 4,--- dk"""""r5c||_dS)z A log observer. @type eventDict: L{dict} of L{bytes} -> L{object} @param eventDict: Information about the last informational log message generated. N)rg)r[ eventDicts r3riz!_AttemptManagerTests._logObserver s" r5cttt|j}||jdS)z When an attempt manager is created without the noisy parameter, the noisy instance variable should default to true. N)rr]rGrrSrr[ams r3test_initNoisyDefaultz*_AttemptManagerTests.test_initNoisyDefault s> >z$+?V?VWW X X !!!!!r5cD||jjdS)z When an attempt manager is created with the noisy parameter set to true, the noisy instance variable should be set to true. N)rSrjrrhs r3test_initNoisyz#_AttemptManagerTests.test_initNoisy s" ,233333r5cD||jjdS)z When an attempt manager is created with the noisy parameter set to false, the noisy instance variable should be set to false. N)rrkrrhs r3test_initQuietz#_AttemptManagerTests.test_initQuiet s$ -344444r5cttt|j}||jt dS)z When an attempt manager is created without the reactor parameter, the reactor instance variable should default to the global reactor. N)rr]rGrrHrrts r3test_initReactorDefaultz,_AttemptManagerTests.test_initReactorDefault sB >z$+?V?VWW X X W-----r5cP||jj|jdS)z When an attempt manager is created with a reactor provided, the reactor instance variable should default to that reactor. N)rHrjrrhs r3test_initReactorz%_AttemptManagerTests.test_initReactor s( -5t|DDDDDr5cz|jd|j||jdS)zw For an attempt manager with the noisy flag set, notifySuccess should result in a log message. reN)rjrnrcrSrgrhs r3test_notifySuccessNoisyz,_AttemptManagerTests.test_notifySuccessNoisy s: **>4;LMMM  &&&&&r5cz|jd|j||jdS)z| For an attempt manager with the noisy flag not set, notifySuccess should result in no log message. rfN)rkrnrdrrgrhs r3test_notifySuccessQuietz,_AttemptManagerTests.test_notifySuccessQuiet s< **>4;LMMM '''''r5r(r*cz|jd|j||jdS)zw For an attempt manager with the noisy flag set, notifyFailure should result in a log message. reN)rjrqrcrSrgrhs r3test_notifyFailureNoisyz,_AttemptManagerTests.test_notifyFailureNoisy! s: **>4;LMMM  &&&&&r5cz|jd|j||jdS)z| For an attempt manager with the noisy flag not set, notifyFailure should result in no log message. rfN)rkrqrdrrgrhs r3test_notifyFailureQuietz,_AttemptManagerTests.test_notifyFailureQuiet* s< **>4;LMMM '''''r5cn|jd||jdS)zt For an attempt manager with the noisy flag set, notifyDone should result in a log message. reN)rjrsrSrgrhs r3test_notifyDoneNoisyz)_AttemptManagerTests.test_notifyDoneNoisy3 s5 ''777  &&&&&r5cn|jd||jdS)zy For an attempt manager with the noisy flag not set, notifyDone should result in no log message. rfN)rkrsrrgrhs r3test_notifyDoneQuietz)_AttemptManagerTests.test_notifyDoneQuiet; s7 ''777 '''''r5c|jd||j|jddS)z| For an attempt manager with the noisy flag set, notifyNoConnection should result in a log message. rerN)rjnotifyNoConnectionrSrgrryrhs r3test_notifyNoConnectionNoisyz1_AttemptManagerTests.test_notifyNoConnectionNoisyC sK //???  &&& R     r5c|jd||j|jddS)z For an attempt manager with the noisy flag not set, notifyNoConnection should result in no log message. rfrN)rkrrrgrryrhs r3test_notifyNoConnectionQuietz1_AttemptManagerTests.test_notifyNoConnectionQuietL sM //??? ''' R     r5N)rbrxryrrrmrirvrxrzr|r~rrrrzr{rrrrrrr/r5r3rara s[<+L+L+LZ###""""""444555...EEE'''((( VC  $&>??''@?' VC  $&>??((@?('''(((!!!!!!!!r5ra)r email.messager email.parserrrrrrUrkrrzrarrThashlibrunittestrzope.interfacerrzope.interface.verifyrtwisted.cred.checkersr7twisted.cred.credentialstwisted.cred.portaltwisted.mail.aliastwisted.mail.mailtwisted.mail.maildirtwisted.mail.protocolstwisted.mail.relaytwisted.mail.relaymanagerrr twisted.internetr r r r rrtwisted.internet.deferrtwisted.internet.errorrrrrtwisted.internet.testingrrr twisted.mailrrr twisted.namesrtwisted.names.dnsrrrtwisted.names.errorrtwisted.pythonr r!twisted.python.filepathr"twisted.python.runtimer#twisted.trial.unittestr$r'r}rrrrrr _MaildirMailboxAppendMessageTaskrr.r>r^rhrrrrrrrr5r9rLrhrurrrrrrrrrrZrrrrrr)r r AliasGrouprrrr*rGr]rar/r5r3rsu   11111111------ PPPPPPPPPPPPPPPP++++++  $#######555555??????????,,,,,,'''''''',,,,,,//////++++++ !CDDe:e:e:e:e:he:e:EDe:P !CDD G G G G G( G GED G !CDD# # # # # # # ED# L !CDD55555x55ED5B !CDD=7=7=7=7=7(=7=7ED=7@ !CDD<<<< !CDDA>A>A>A>A>(A>A>EDA>H1000000000 B B B B BF' B B BIII&""" !CDDl>l>l>l>l>hl>l>EDl>^  !CDDLLLLLHLLEDL^" !CDDa>a>a>a>a>a>a>EDa>H11111111, !CDD&7&7&7&7&7&7&7ED&7R     tz.   +++++TZ*+++$$$$$$$$. !CDD~&~&~&~&~&~&~&ED~&B))))))))(N N N N N N N N b. !CDDD!D!D!D!D!8D!D!EDD!D!D!r5