tf9 ~dZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl m Z mZddlmZddlmZddlmZmZmZddlmZddlmZdd lmZmZdd lmZm Z m!Z!dd l"m#Z#dd l$m%Z%m&Z&m'Z'm(Z(m)Z)dd l*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:ddl;mZ>m?Z@mAZBmCZDmEZFmGZHmIZJmKZLmMZNmOZOmPZQddlRmSZSmTZTddlUmVZVmWZWddlXmYZYmZZZm[Z[m\Z\e]e^e_ddd`ZadZbdZcGddZdGddZeGddZfGddZgGdd Zhd!Ziejee_d"e_d#d$Zkd%eizekzZlelmd&Znejod'enzd(zZpejd)e_d$DZqeeFGd*d+eSjreTjsZte juZveeFGd,d-eSjreTjsZwdxd.Zxd/Zyd0Zze{Z|dyd1Z}d2Z~d3Zdxd4Zd5Zd6Zd7Zdzd8Zd9Zd:ejd;ejfd<ZGd=d>Zd?Zd@ZdAZdBZdCZdDZee=GdEdFZeeOGdGdHeZdIdJdKdLdMdNZdOZdPZdQZdRZdSZdTZdUZGdVdWZGdXdYeZGdZd[eZGd\d]eZGd^d_eZd{daZdbZdcZddZGdedfZGdgdhZGdidjZdkZeedldmZdnZdoZdxdpZdxdqZGdrdsejZGdtduejZejeeeeZdvZejegdwZdS)|a An IMAP4 protocol implementation @author: Jp Calderone To do:: Suspend idle timeout while server is processing Use an async message parser instead of buffering in memory Figure out a way to not queue multi-message client requests (Flow? A simple callback?) Clarify some API docs (Query, etc) Make APPEND recognize (again) non-existent mailboxes before accepting the literal N) decodebytes encodebytes)BytesIO)chain)AnyListcast) implementer) credentials)UnauthorizedLoginUnhandledCredentials)defererror interfaces) maybeDeferred)CramMD5ClientAuthenticatorLOGINAuthenticatorLOGINCredentialsPLAINAuthenticatorPLAINCredentials)IllegalClientResponseIllegalIdentifierErrorIllegalMailboxEncodingIllegalOperationIllegalQueryErrorIllegalServerResponseIMAP4ExceptionMailboxCollisionMailboxExceptionMismatchedNestingMismatchedQuotingNegativeResponse NoSuchMailboxNoSupportedAuthenticationReadOnlyMailboxUnhandledResponse) IAccountIMAPIClientAuthenticationICloseableMailboxIMAP IMailboxIMAPIMailboxIMAPInfoIMailboxIMAPListener IMessageIMAPIMessageIMAPCopierIMessageIMAPFileIMessageIMAPPartINamespacePresenterISearchableIMAPMailbox)basicpolicies)logtext)_matchingString iterbytes nativeString networkString z/Jan Feb Mar Apr May Jun Jul Aug Sep Oct Nov Decc||ur|n|S)z Swap C{this} with C{that} if C{this} is C{ifIs}. @param this: The object that may be replaced. @param that: The object that may replace C{this}. @param ifIs: An object whose identity will be compared to C{this}. )thisthatifIss Q/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/twisted/mail/imap4.py_swaprC_s4<<44T)c$fd|DS)a Swap each element in each pair in C{of} with C{that} it is C{ifIs}. @param of: A list of 2-L{tuple}s, whose members may be the object C{that} @type of: L{list} of 2-L{tuple}s @param ifIs: An object whose identity will be compared to members of each pair in C{of} @return: A L{list} of 2-L{tuple}s with all occurences of C{ifIs} replaced with C{that} cZg|]'\}}t|t|f(Sr>)rC).0firstsecondrAr@s rB z!_swapAllPairs..|sG   BO%udD ! !5t#<#<=   rDr>)ofr@rAs ``rB _swapAllPairsrLms4     SU   rDceZdZUdZgZeeed<edZ eefdZ e dZ e j dZ efdZdZd Zd Zd Zd Zd ZdZdZdefdZdefdZdedefdZdS) MessageSeta A set of message identifiers usable by both L{IMAP4Client} and L{IMAP4Server} via L{IMailboxIMAP.store} and L{IMailboxIMAP.fetch}. These identifiers can be either message sequence numbers or unique identifiers. See Section 2.3.1, "Message Numbers", RFC 3501. This represents the C{sequence-set} described in Section 9, "Formal Syntax" of RFC 3501: - A L{MessageSet} can describe a single identifier, e.g. C{MessageSet(1)} - A L{MessageSet} can describe C{*} via L{None}, e.g. C{MessageSet(None)} - A L{MessageSet} can describe a range of identifiers, e.g. C{MessageSet(1, 2)}. The range is inclusive and unordered (see C{seq-range} in RFC 3501, Section 9), so that C{Message(2, 1)} is equivalent to C{MessageSet(1, 2)}, and both describe messages 1 and 2. Ranges can include C{*} by specifying L{None}, e.g. C{MessageSet(None, 1)}. In all cases ranges are normalized so that the smallest identifier comes first, and L{None} always comes last; C{Message(2, 1)} becomes C{MessageSet(1, 2)} and C{MessageSet(None, 1)} becomes C{MessageSet(1, None)} - A L{MessageSet} can describe a sequence of single identifiers and ranges, constructed by addition. C{MessageSet(1) + MessageSet(5, 10)} refers the message identified by C{1} and the messages identified by C{5} through C{10}. B{NB: The meaning of * varies, but it always represents the largest number in use}. B{For servers}: Your L{IMailboxIMAP} provider must set L{MessageSet.last} to the highest-valued identifier (unique or message sequence) before iterating over it. B{For clients}: C{*} consumes ranges smaller than it, e.g. C{MessageSet(1, 100) + MessageSet(50, None)} is equivalent to C{1:*}. @type getnext: Function taking L{int} returning L{int} @ivar getnext: A function that returns the next message number, used when iterating through the L{MessageSet}. By default, a function returning the next integer is supplied, but as this can be rather inefficient for sparse UID iterations, it is recommended to supply one when messages are requested by UID. The argument is provided as a hint to the implementation and may be ignored if it makes sense to do so (eg, if an iterator is being used that maintains its own state, it is guaranteed that it will not be called out-of-order). _emptyinfc|j|_g|_d|_||jurdSt |t r%|dd|_|dS|||dS)z Create a new MessageSet() @type start: Optional L{int} @param start: Start of range, or only message number @type end: Optional L{int} @param end: End of range. c |dzSNr;r>xs rBz%MessageSet.__init__..s QrDN)rO_lastrangesgetnext isinstancelistcleanaddselfstartends rB__init__zMessageSet.__init__s}[  &  DK   F eT " " !(DK JJLLLLL HHUC rDc|jS)z{ The largest number in use. This is undefined until it has been set by assigning to this property. )rWr_s rBlastzMessageSet.lasts zrDc|j|jurtd||_t|jD]&\}\}}||}||}||kr||}}||f|j|<'|dS)z Replaces all occurrences of "*". This should be the largest number in use. Must be set before attempting to use the MessageSet as a container. @raises ValueError: if a largest value has already been set. zlast already setN)rWrO ValueError enumeraterXr\)r_valueilowhighs rBrezMessageSet.lasts :T[ ( (/00 0 ' 44 ) )NA{T{|Tzz #T!4[DKNN rDc&||jur|}|j|jur||j}||j}t||gt jt |jd\}}|j ||f| dS)z Add another range @type start: L{int} @param start: Start of range, or only message number @type end: Optional L{int} @param end: End of range. Nr@rA)key) rOrWresorted functoolspartialrC _infinityrXappendr\r^s rBr]zMessageSet.adds $+  C :T[ ( (} {i CLi/DNQUVVV   s E3<((( rDc*t|tr|j|jz}t|St|j}|j|jur |j|_ |j|n%#t $r||YnwxYw|SN)rZrNrXrerOr] TypeError)r_otherrXress rB__add__zMessageSet.__add__s eZ ( ( [5</Ff%% %T[))Cy ++9     Js# A..BBct|tr4|j|j|n1 |j|n%#t $r||YnwxYw|S)z Extend our messages with another message or set of messages. @param other: The messages to include. @type other: L{MessageSet}, L{tuple} of two L{int}s, or a single L{int} )rZrNrXextendr\r]rwr_rxs rBr|zMessageSet.extends eZ ( ( K  u| , , , JJLLLL %        s AA87A8ctt|j|jd}t dt dfg}|D]T\}}|d\}}||dz kr|||f1t ||t||f|d<Ut|ddd|j|_dS)z> Clean ranges list, combining adjacent ranges Nrnz-infr;)rprLrXrsfloatrtminmax)r_rX mergedRangesrkrl previousLow previousHighs rBr\zMessageSet.clean/s  dkTRRRSSvf 67  P PIC(4R(8 %KcAg%%##S$K000 #K 5 5s<7N7NOL  #L$44dnUUU rDc,|jddduS)a Is there a L{None} in our ranges? L{MessageSet.clean} merges overlapping or consecutive ranges. None is represents a value larger than any number. There are thus two cases: 1. C{(x, *) + (y, z)} such that C{x} is smaller than C{y} 2. C{(z, *) + (x, y)} such that C{z} is larger than C{y} (Other cases, such as C{y < x < z}, can be split into these two cases; for example C{(y - 1, y)} + C{(x, x) + (z, z + 1)}) In case 1, C{* > y} and C{* > z}, so C{(x, *) + (y, z) = (x, *)} In case 2, C{z > x and z > y}, so the intervals do not merge, and the ranges are sorted as C{[(x, y), (z, *)]}. C{*} is represented as C{(*, *)}, so this is the same as 2. but with a C{z} that is greater than everything. The result is that there is a maximum of two L{None}s, and one of them has to be the high element in the last tuple in C{self.ranges}. That means checking if C{self.ranges[-1][-1]} is L{None} suffices to check if I{any} element is L{None}. @return: L{True} if L{None} is in some range in ranges and L{False} if otherwise. rN)rXrds rB _noneInRangeszMessageSet._noneInRangesCs>{2r"d**rDc|rtd|jD]\}}||cxkr|krndSdS)z May raise TypeError if we encounter an open-ended range @param value: Is this in our ranges? @type value: L{int} z.Can't determine membership; last value not setTF)rrwrX)r_rirkrls rB __contains__zMessageSet.__contains__dsr      NLMM M  ICe####t#####tt$urDc#K|jD]B\}}||dz }||kr|V||}||kCdSrS)rXrY)r_lhs rB _iteratorzMessageSet._iteratorusgK $ $DAq QU##Aq&&LLOOq&& $ $rDcp|rtd|S)Nz!Can't iterate; last value not set)rrwrrds rB__iter__zMessageSet.__iter__|s6      A?@@ @~~rDcld}|jD])\}}||dz } |td|||z dzz }*|S)Nrr;z%Can't size object; last value not set)rXrw)r_ryrrs rB__len__zMessageSet.__len__sYK # #DAqyq GHHHA{" rDreturnc8g}|jD]|\}}||kr;||d#|t|F||d|fzb|d||fz}d|S)N*z%d:*z%d:%d,)rXrtstrjoin)r_prkrls rB__str__zMessageSet.__str__s  0 0ICd{{;HHSMMMMHHSXX&&&&3&))))C;.////xx{{rDc(dt|dS)Nz rrds rB__repr__zMessageSet.__repr__s*c$ii****rDrxct|tr#tt|j|jkSt Srv)rZrNr boolrXNotImplementedr}s rB__eq__zMessageSet.__eq__s3 eZ ( ( ;dkU\9:: :rDN)__name__ __module__ __qualname____doc__rOrr__annotations__rrsrbpropertyresetterr]rzr|r\rrrrrrrrobjectrrr>rDrBrNrNs77rFDIe I#!!!!0X [[,$2   &VVV(+++B"$$$          +#++++FtrDrNc eZdZdZdZdZdS) LiteralStringc0||_g|_||_dSrv)sizedatarr_rdefereds rBrbzLiteralString.__init__s   rDc|xjt|zc_d}|jdkr|j|nD|jr|d|j||jd}}nd}|r|j||SNrrD)rlenrrtr_rpassons rBwritezLiteralString.writes SYY  9q== I  T " " " "y #KdiK0$ty{{2Cf '   &&& rDcn|jd|j|fdS): Call deferred with data and rest of line rDN)rcallbackrrr_lines rBrzLiteralString.callbacks3 SXXdi00$788888rDN)rrrrbrrr>rDrBrrsA   99999rDrc$eZdZdZdZdZdZdS) LiteralFilec||_||_||jkrtj|_dSt |_dSrv)rr_memoryFileLimittempfile TemporaryFilerrrs rBrbzLiteralFile.__init__sA  $' ' ' .00DIII DIIIrDc|xjt|zc_d}|jdkr|j|nD|jr|d|j||jd}}nd}|r|j||Sr)rrrrrs rBrzLiteralFile.writes SYY  9q== IOOD ! ! ! !y #KdiK0$ty{{2Cf & %%% rDc~|jdd|j|j|fdS)rrN)rseekrrrs rBrzLiteralFile.callbacks= q! TY-.....rDN)rrrrrbrrr>rDrBrrsG'"""   /////rDrc&eZdZdZddZdZdZdS) WriteBufferzU Buffer up a bunch of writes before sending them all to a transport at once. c>||_||_d|_g|_dSNr) bufferSize transport_length_writes)r_rrs rBrbzWriteBuffer.__init__s""  rDc|xjt|z c_|j||j|jkr|dSdSrv)rrrrtrflushr_ss rBrzWriteBuffer.writesV A  A <$/ ) ) JJLLLLL * )rDcr|jr/|j|jg|_d|_dSdSr)rr writeSequencerrds rBrzWriteBuffer.flushs@ <  N ( ( 6 6 6DLDLLL  rDN)r)rrrrrbrrr>rDrBrrsP  rDrcDeZdZdZdZdZdZ d dZdefdZ d Z d Z dS) Command) CAPABILITYFLAGSLISTLSUBSTATUSSEARCH NAMESPACE)EXISTSEXPUNGEFETCHRECENT) UIDVALIDITYUNSEEN READ-WRITE READ-ONLYUIDNEXTPERMANENTFLAGSNr>c\||_||_||_fd|_g|_dS)Nc|gRiSrvr>)rUcontArgscontKw continuations rBrVz"Command.__init__..s!ll1&Jx&J&J&J6&J&JrD)commandargs wantResponserlines)r_rrrrrrs ```rBrbzCommand.__init__s?  (JJJJJJ rDrcfd|j|j|j|j|jS)Nz()formatrrrrrrds rBrzCommand.__repr__s19@@ L$)T%68I4:   rDc|jd||jfSd||j|jfSN )rrrr_tags rBrzCommand.format#s@ 9 99c4<011 1yy#t|TY7888rDcg}g}|jD]}t|}t|}|dkr|d|jvsW|dkr|d|jvsB|dkrR|ddkrFt |dt r+|dd|jvr|||||j dc}|_ | ||f|r ||dSdS)Nr;rOK) rparseNestedParensr _1_RESPONSES _2_RESPONSESrZr[ _OK_RESPONSESrtrr) r_lastLineunusedCallbacksendunuseLnamesNds rBfinishzCommand.finish(s' $ $A%a((EE AQ!H 11166!H 11166!H%%uQx..&!HQK4#555 E"""" U#### D 4: D(#$$$  " N5 ! ! ! ! ! " "rD)Nr>N) rrrrrrrrbrrrrr>rDrBrrsL@LM E      #    999 """""rDrr!s ]\\(){%*"charmap[]c#,K|]}|tv |VdSrv) _nonAtomChars)rGchs rB rQs,HH"-0G0G20G0G0G0GHHrDceZdZdZdZdZdZdZdZdZ dZ dZ dZ dZ dZdZdZhdZd Zd Zdd Zd Zd ZdZdZdZdZdZdZdZdZddZdZ dZ!dZ"dZ#dZ$dZ%dZ&ddZ'e(j)de(j*e+zdzZ,d Z-d!Z.d"Z/d#Z0d$Z1d%Z2d&Z3d'Z4d(Z5d)Z6d*Z7d+Z8dd-Z9dd.Z:dd/Z;dd0Zd4Z?d5Z@e@fZAeAZBeAZCeAZDd6ZEeEfZFeFZGeFZHeFZId7ZJeJfZKeKZLeKZMeKZNd8ZOeOe-fZPd9ZQd:ZRd;ZSd<ZTd=ZUd>ZVd?ZWeWfZXd@ZYeYe'e&fZZdAZ[dBZ\dCZ]dDZ^e^fZ_e_Z`dEZadFZbdGZceae'dHdIfZdedZeeae'dJdKfZfefZgdLZhdMZiehfZjejZkdNZlele&fZmemZndOZoeoe&fZpepZqdPZrere'e&fZsesZtdQZueue&fZvevZwdRZxexe&fZyeyZzdSZ{dTZ|dUZ}e{e'e'dJdVfZ~e~Ze{e'e'dHdWfZeZdXZdYZdZZee'e.fZeZd[Zd\Zd]Zd^Zd_Zee'e5e6e/fZeZd`ZdaZdbZefZdcZddZdeZdfZefZdgZdhZdiZefZdjZdkZddlZee7e0fZdmZddnZdoZdpZdqZdrZdsZdtZduZdvZdwZdxZdyZdzZd{Zd|Zd}Zd~ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZddZee1e2fZdZdZddZddZddZddZddZddZddZddZddZddZdZdZddZee1e-e3fZdZdZddZee1e&fZdZdZdZdZdZdZee-e4fZdZdZdZdS) IMAP4Serverz Protocol implementation for an IMAP4rev1 server. The server can be in any of four states: - Non-authenticated - Authenticated - Selected - Logout sTwisted IMAP4rev1 Ready<iFNi>ORNOTUIDunauthrcX|i}||_||_|t}||_g|_dSrv) challengersctxiterateInReactor _scheduler _queuedAsync)r_chalcontextFactory schedulers rBrbzIMAP4Server.__init__s; <D!  (I#rDcdt|ji}|jr2|jr+|js$t j|jd d|d<d|d<d|d<d|d<|S)NAUTH LOGINDISABLEDSTARTTLSrsIDLE) r[rkeysr canStartTLS startedTLSr ISSLTransportr)r_caps rB capabilitieszIMAP4Server.capabilitiessT-2244556 8 (( (O (,T^TBBJ(,$%#'K  LG  rDci|_tj|jddu|_||j|dSrv)tagsr ITLSTransportrr' setTimeouttimeOutsendServerGreetingrds rBconnectionMadezIMAP4Server.connectionMadesR %3DNDIIQUU  %%% !!!!!rDcx|d|jr|d|_dSdSrv)r/ _onLogout)r_reasons rBconnectionLostzIMAP4Server.connectionLostsC  > " NN   !DNNN " "rDcP|d|j|jri|j|t |jd}|1t |jtj d|_d|_ dS)Ns** BYE Autologout; connection idle too longtimeout) sendLinerloseConnectionmboxremoveListenerICloseableMailboxrclose addErrbackr5errstate)r_cmbxs rBtimeoutConnectionzIMAP4Server.timeoutConnections CDDD %%''' 9  I $ $T * * *$TY55Ddj))44SW===DI rDc||j|}|||dSdSrv) resetTimeout_pendingLiteralr setLineModers rBrawDataReceivedzIMAP4Server.rawDataReceivedsR %++D11     V $ $ $ $ $  rDc|j}d|_|r8|j1||d|r|j1|j|j|dSdSr)blocked lineReceivedpopr|)r_commandss rB_unblockzIMAP4Server._unblocksz<  /4</   hll1oo . . . /4</ < # L   ) ) ) ) ) $ #rDc v|j|j|dS|t|d|jz} ||dS#t $rP}|dtt|ztj Yd}~dSd}~wwxYw)Nparse_sBAD Server error: ) rJrtrEgetattr parseState ExceptionsendUntaggedResponser:rr5r@)r_rfes rBrKzIMAP4Server.lineReceiveds < # L   % % % F  D(T_4 5 5  AdGGGGG     % %&;mCPQFF>S>S&S T T T GIIIIIIIII s A B8(AB33B8c 4|dd}d}t|dkr|\}}}ndt|dkr|\}}nKt|dkr |d}||ddS|dddS|} ||||S#t $r>}||dt t|zYd}~dSd}~wt$r>}| |dt t|zYd}~dSd}~wt$r>}| |d t t|zYd}~dSd}~wwxYw) Nrr;rsMissing commands Null commandIllegal syntax: Illegal operation: Illegal mailbox name: ) splitrsendBadResponseupperdispatchCommandrr:rrsendNegativeResponser)r_rrrestrcmdrVs rB parse_commandzIMAP4Server.parse_commandszz$"" t99>>!NCdd YY!^^HC YY!^^q'C  &8 9 9 94   7 7 74iikk ''S$77 7$ S S S  &9M#a&&1B!""I   S"tSk9dC H H H H H  &< = = = = =rDc t|d|jt|fdS)N_)rQrrAr9r^)r_rbs rBrgzIMAP4Server.lookupCommands8tSXXtz< 3L3L&MNNPTUUUrDc t|D]\}}t|rW||dzd}t||||j||||||j|dS|||rtdt|z| ||d|idS||dS)Nr;z Too many arguments for command: ri) rhcallabler addCallback_IMAP4Server__cbDispatchr?_IMAP4Server__ebDispatchrtrrepr) r_rhandlerrrkrrirjargs rB __doCommandzIMAP4Server.__doCommand s ** ! !FAs}} !%a!egg. c4..::%sGT9c*T.444 C     Y'(JTRVZZ(WXX X ? Gd # # # # # # GTNNNNrDcn|\}}|||||||||dSrv)rtrh) r_resultrrjrrkriruras rB __cbDispatchzIMAP4Server.__cbDispatchsA d C b$ 4=====rDc |tr:||dtt |jzdS|t r:||dtt |jzdS|tr:||dtt |jzdS||dtt |jztj |dS)NrYrZr[Server error: ) checkrr]r:rrirr`rr5r@r_failurers rB __ebDispatchzIMAP4Server.__ebDispatch$sQ ==. / /   (=W]9K9K+L+LL     ]]+ , ,   % %+mC +-.  N  #,T155 $$ 7$> ? ?    rDctj}d|_t|||_|t d|z||S)NrzReady for %d octets of data)rrrRrrFrr:rrs rB _fileLiteralzIMAP4Server._fileLiteralFsh N  #*433 $$ 7$> ? ?    rDc0||dS)a Parse an astring from line that represents a command's final argument. This special case exists to enable parsing empty string literals. @param line: A line that contains a string literal. @type line: L{bytes} @return: A 2-tuple containing the parsed argument and any trailing data, or a L{Deferred} that fires with that 2-tuple @rtype: L{tuple} of (L{bytes}, L{bytes}) or a L{Deferred} @see: https://twistedmatrix.com/trac/ticket/9207 T)final) arg_astringrs rBarg_finalastringzIMAP4Server.arg_finalastringPs D111rDc |}|stdd}d\}}|dddkrC |dd\}}}|dd}n#t$rtdwxYw|ddd kr|d dd krtd  t |dd }n5#t$r(td t |dd zwxYw|r|sdS||}nC|dd}t|dkr|d|\}}|p||fS)a Parse an astring from the line, return (arg, rest), possibly via a deferred (to handle literals) @param line: A line that contains a string literal. @type line: L{bytes} @param final: Is this the final argument? @type final L{bool} @return: A 2-tuple containing the parsed argument and any trailing data, or a L{Deferred} that fires with that 2-tuple @rtype: L{tuple} of (L{bytes}, L{bytes}) or a L{Deferred} Missing argumentNNNrr;"rzUnmatched quotes{r}Malformed literalBad literal size: )rDrDrrD) striprr\rgintrsrrrt)r_rrrruraspamrs rBrzIMAP4Server.arg_astringbs"zz|| <'(:;; ;  T !9   @"&**T1"5"5c4ABBx @ @ @+,>??? @ !A#Y$  BCCyD  +,?@@@ U4": U U U+,@4QrT CSCS,STTT U "T "!z##D))AA**T1%%C3xx1}} 3ICS$Ks$A!!A;*C2C4s (?P[s]+)( (?P.*$)|$)c|std|j|}|r*|d|dfStd)z- Parse an atom from the line ratomrazMalformed ATOM)ratomrematchgroup)r_rms rBarg_atomzIMAP4Server.arg_atomsf <'(:;; ; K  d # #  :776??AGGFOO3 3'(899 9rDc|std|dddkrtd|d}|dkrtdt|d|d ||d zdfS) zG Parse a (non-nested) parenthesised list from the line rNr;(zMissing parenthesis)rMismatched parenthesisrr)rfindr)r_rrjs rB arg_plistzIMAP4Server.arg_plists <'(:;; ; 8t  '(=>> > IIdOO 77'(@AA A!$qs)Q//a!egg??rDcD|std|dddkrtd|dddkrtd t|dd}n(#t$rtd |ddwxYw||S) z/ Parse a literal from the line rNr;rzMissing literalrrrr)rrrgr)r_rrs rB arg_literalzIMAP4Server.arg_literals <'(:;; ; 8t  '(9:: : 9  '(;<< < MtAbDz??DD M M M'(KT!B$Z(K(KLL L M  &&&s A%%%B c(t|}|dfS)z searchkeys rD)r)r_rquerys rBarg_searchkeyszIMAP4Server.arg_searchkeyss"$''s|rDcd}|dd}t|dkr|d}|d} t||fS#t$r$}t dt |zd}~wwxYw)z sequence-set rDrr;rrzBad message number N)r\r parseIdListrrr)r_rrarurVs rB arg_seqsetzIMAP4Server.arg_seqsetsjjq!! s88q==q6D!f H$$d+ +% H H H'(=A(FGG G HsA A<A77A<cZt}|||jdfS)z fetch-att rD) _FetchParser parseStringrx)r_rrs rB arg_fetchattzIMAP4Server.arg_fetchatts+ NN d#rDcDg}|dddkr'|dddkrtd|dd}|r|j|}|std|ddd krD|dkr,|d |d znP|dkr)||d ntd|d }||d fS) z- Flag part of store-att-flag rr;rrNrrzMalformed flag\rrarD)rrsearchr`rtr)r_rflagsrs rB arg_flaglistzIMAP4Server.arg_flaglists* !9  BCCyD  +,DEEE":D # ""4((A >+,<===AaCyE!!aggii1nn UQWWV__45555a QWWV__----+,<===776??D #s|rDc |dfS)z- Command line of UID command rDr>rs rBarg_linezIMAP4Server.arg_linesc{rDc^|dr||Sd|fS)z- Optional parenthesised list rN) startswithrrs rB opt_plistzIMAP4Server.opt_plists4 ??4  >>$'' '$< rDc|drE |dd\}}}n#t$rtdwxYw||ddfSd|fS)z+ Optional date-time string rrzMalformed date-timer;N)rr\rgr)r_rrdateras rB opt_datetimezIMAP4Server.opt_datetime s ??4   C#'::dA#6#6 dDD C C C+,ABBB C$qrr(# #$< s 2A c|dddkrj|dd}t|dkrtdt|dkr|d|\}}}||fSd|fS) z4 Optional charset of SEARCH command NsCHARSETrrr;zMissing charset identifierrD)r^r\rrrt)r_rrurras rB opt_charsetzIMAP4Server.opt_charsets 8>>  z ) )**T1%%C3xx1}}+,HIII3xx1}} 3!OD#t; $< rDcdd|zdz|jz}||dS)Ns [CAPABILITY r] )message)rlistCapabilitiesIDENTsendPositiveResponser_msgs rBr1zIMAP4Server.sendServerGreeting)sM $*?*?*A*A B BBUJTZW !!#!.....rDrDc4|d||dS)NBAD_respondr_rrs rBr]zIMAP4Server.sendBadResponse-s fc7+++++rDc4|d||dS)Nrrrs rBrz IMAP4Server.sendPositiveResponse0 eS'*****rDc4|d||dS)NNOrrs rBr`z IMAP4Server.sendNegativeResponse3rrDc~|r|j||dddS|j|dSrv)rJrrrt)r_risAsyncs rBrTz IMAP4Server.sendUntaggedResponse6sJ .4</ MM'4 . . . . .   $ $W - - - - -rD!Ready for additional command textch|r|d|zdS|ddS)Ns+ +r9rs rBrz#IMAP4Server.sendContinuationRequest<s>  MM%#+ & & & & & MM$     rDc*|dvr1|jr*|j}g|_|D]}||dd|sd}|r-|d|||fdS|d||fdS)N)rrr*r)rrr9r)r_rArrrrs rBrzIMAP4Server._respondBs * * *t/@ *%E "D  / / c4.... C  3 MM$))S%$9:: ; ; ; ; ; MM$))S%L11 2 2 2 2 2rDcdg}|D]M\}||t|r!|fd|DN|S)Ns IMAP4rev1c g|] }dz|z S)=r>)rGr*cs rBrJz0IMAP4Server.listCapabilities..Us!;;;#a$hn;;;rD)r+itemsrtrr|)r_capsvrs @rBrzIMAP4Server.listCapabilitiesOs~%%''--// = =DAqy AQ = ;;;;;;;<<< rDc|dd|z||ddS)Ns CAPABILITY rsCAPABILITY completed)rTrrrrs rB do_CAPABILITYzIMAP4Server.do_CAPABILITYXsP !!.499T=R=R=T=T3U3U"UVVV !!#'>?????rDc|d||d|jdS)NsBYE Nice talking to yousLOGOUT successful)rTrrr:rs rB do_LOGOUTzIMAP4Server.do_LOGOUTasH !!"<=== !!#';<<< %%'''''rDc2||ddS)NsNOOP No operation performedrrs rBdo_NOOPzIMAP4Server.do_NOOPks !!#'EFFFFFrDc|}||jvr||ddS||j||dS)NsAUTHENTICATE method unsupported)r^rrr` authenticate)r_rrs rBdo_AUTHENTICATEzIMAP4Server.do_AUTHENTICATEssszz||!!## t' ' '  % %c+M N N N N N   4d.t466 < < < < }| |dtt|zYd}~dSd}~wwxYw)Nrrr{) getChallengerrRrrrFrrp_IMAP4Server__cbAuthChunkr?_IMAP4Server__ebAuthChunkrSr]r:r)r_rr challengecodedrVs rBrzIMAP4Server._setupChallenges E))++I **3B3/E'DO#(>#3#3D  ( ( / / /  , ,T-?s K K K  + +D,> D D D D D Q Q Q  &7-A:O:O&O P P P P P P P P P QsB$$ C,.3C''C,cx t|}n"#tj$rtdwxYw|||r|||dS|j|dt |j |j |fd|fddS)NzMalformed Response - not base64) rbinasciiErrorr setResponsemoreChallengesrrloginIAccount addCallbacks_IMAP4Server__cbAuthResp_IMAP4Server__ebAuthResp)r_rxrruncodeds rB __cbAuthChunkzIMAP4Server.__cbAuthChunks K!&))GG~ K K K'(IJJ J K !!!       s + + + + + K  dD( 3 3 @ @!4#4sfdSFD     s1c|\}}}|tus Jd||_d|_||_||d||jdS)Nz(IAccount is the only supported interfaceauthsAuthentication successful)raccountrAr4rr/POSTAUTH_TIMEOUTr_rxrifaceavatarlogouts rB __cbAuthRespzIMAP4Server.__cbAuthRespso"(   "L      !!#'CDDD -.....rDc"|tr||ddS|tr||ddS||dt j|dS)Ns#Authentication failed: unauthorizeds+Authentication failed: server misconfigureds'Server error: login failed unexpectedly)r|r r`r r]r5r@r}s rB __ebAuthRespzIMAP4Server.__ebAuthResps ==* + +   % %c+Q R R R R R ]]/ 0 0   % %C       &P Q Q Q GG     rDc v||dtt|jzdS)NsAuthentication failed: )r`r:rrir}s rB __ebAuthChunkzIMAP4Server.__ebAuthChunksA !! +mC > >DJ OOD1 2 2 2 2 2rDc |tr||ddS||dt t |jztj|dS)Ns LOGIN failedr{) r|r r`r]r:rrir5r@r}s rB __ebLoginzIMAP4Server.__ebLogins ==* + +   % %c? ; ; ; ; ;  &s7=7I7I)J)JJ    GG     rDc4dx}x}}t|jd}|<|}|}|}|dt |||gz||ddS)Ns NAMESPACE sNAMESPACE command completed)r1rgetPersonalNamespacesgetSharedNamespacesrTcollapseNestedListsr)r_rpersonalpublicsharednps rB do_NAMESPACEzIMAP4Server.do_NAMESPACEs%)))6F t 4 4 >//11H++--F++--F !! /660JKK K    !!#'EFFFFFrDc|jrp|j|t|jd}|1t|jt jd|_d|_t|}t|j j t|| |j |||j||dS)Nr)r;r<r=rr>r?r5r@rA _parseMboxrselectrp _cbSelectWork _ebSelectWork)r_rnamerwcmdNamerBs rB _selectWorkzIMAP4Server._selectWork s 9 I $ $T * * *$TY55Ddj))44SW===DIDJ$dl):d+;+;R@@LL    *T'# 6 6 6 6 6rDc`|||dztj|dS)Ns failed: Server errorr]r5r@)r_r~r0rs rBr-zIMAP4Server._ebSelectWorks4 S',D"DEEE rDc|||ddSdd|Dvr||ddSd|D}|d|fz|d|fz|dd |zd z|dd |fz|rd pd }| |||d|zdz|zdzd|_ ||_ dS)NsNo such mailboxz \noselectc6g|]}|Sr>)lowerrGrs rBrJz-IMAP4Server._cbSelectWork.."s ???!AGGII???rDzMailbox cannot be selectedc,g|]}t|Sr>r:rGflags rBrJz-IMAP4Server._cbSelectWork..&s AAAt$$AAArD %d EXISTS %d RECENTFLAGS (rrs[UIDVALIDITY %d]rr[rs successfulr+) r`getFlagsrTgetMessageCountgetRecentCountrrgetUIDValidity isWriteable addListenerrAr;)r_r;r0rrrs rBr,zIMAP4Server._cbSelectWorks <  % %c+= > > > F ??t}}??? ? ?  % %c+G H H H FAAAAA !!,$2F2F2H2H1J"JKKK !!,$2E2E2G2G1I"IJJJ !!*tyy/?/?"?$"FGGG !!$(;t?R?R?T?T>V(VWWW      0= @L  !!#tax%'7''AN'RSSS  rDr;SELECTrEXAMINEcd|d||_|j|_d|_dS)Nidle)rparseTagrR lastStaters rBdo_IDLEzIMAP4Server.do_IDLE8s1 $$T***  rDc\|j|_|`||jd|`dS)NsIDLE terminated)rKrRrrJ)r_rs rB parse_idlezIMAP4Server.parse_idle>s2. N !!$-1CDDD MMMrDc t|} |j|}|r||ddS||ddS#t $r;}||t t|Yd}~dSd}~wt$r-| |dtj YdSwxYw)NsMailbox createdsMailbox not createds/Server error encountered while creating mailbox) r*rcreaterr`rr:r BaseExceptionr]r5r@)r_rr.rxrs rB do_CREATEzIMAP4Server.do_CREATEGs $ G\((..F G))#/ABBBBB))#/EFFFFF  B B B  % %c=Q+@+@ A A A A A A A A A     G    GIIIIII  sA C'0B6CCct|}|dkr||ddS |j|||ddS#t $rA}||t|dYd}~dSd}~wt$r-| |dtj YdSwxYw)NinboxsYou cannot delete the inboxsMailbox deleted imap4-utf-7s/Server error encountered while deleting mailbox) r*r6r`rdeleterrrencoderQr]r5r@r_rr.rs rB do_DELETEzIMAP4Server.do_DELETE[s$ ::<<7 " "  % %c+I J J J F ? L   % % %  % %c+= > > > > >  I I I  % %c3q66==+G+G H H H H H H H H H     G    GIIIIII  sA33 C3=6B996C32C3c Zd||fD\}}|dks|dkr||ddS |j||||ddS#t $r||dYdSt$r;}||tt|Yd}~dSd}~wt$r-||dtj YdSwxYw)Nc34K|]}t|VdSrv)r*)rGns rBrz(IMAP4Server.do_RENAME..ps(FFaJqMMFFFFFFrDrTs@You cannot rename the inbox, or rename another mailbox to inbox.sMailbox renamedsInvalid command syntaxs/Server error encountered while renaming mailbox) r6r`rrenamerrwr]rr:rrQr5r@)r_roldnamenewnamers rB do_RENAMEzIMAP4Server.do_RENAMEoswFFGW3EFFF ==??g % %G)C)C  % %X    F ? L   1 1 1  % %c+= > > > > > A A A  &? @ @ @ @ @ @ B B B  % %c=Q+@+@ A A A A A A A A A     G    GIIIIII  s$B D*1 D*:0C006D*)D*c t|} |j|||ddS#t$r;}||t t|Yd}~dSd}~wt$r-| |dtj YdSwxYw)Ns Subscribeds5Server error encountered while subscribing to mailbox) r*r subscriberrr`r:rrQr]r5r@rXs rB do_SUBSCRIBEzIMAP4Server.do_SUBSCRIBEs$ : L " "4 ( ( (  % %c= 9 9 9 9 9  B B B  % %c=Q+@+@ A A A A A A A A A     M    GIIIIII  A B= 0B6B=<B=c t|} |j|||ddS#t$r;}||t t|Yd}~dSd}~wt$r-| |dtj YdSwxYw)Ns Unsubscribeds9Server error encountered while unsubscribing from mailbox) r*r unsubscriberrr`r:rrQr]r5r@rXs rBdo_UNSUBSCRIBEzIMAP4Server.do_UNSUBSCRIBEs$ < L $ $T * * *  % %c? ; ; ; ; ;  B B B  % %c=Q+@+@ A A A A A A A A A     Q    GIIIIII  rdct|}t|}t|jj|||j||||j|dSrv)r*rr listMailboxesrp _cbListWorkr? _ebListWork)r_rrefr;subr0s rB _listWorkzIMAP4Server._listWorkse$oodl0#t<<HH  c3  *T%s + + + + +rDc|D]\}}|r|j|rd|D}|d}t |t t |||df} |t| | ||dzdS)Nc,g|]}t|Sr>r9r:s rBrJz+IMAP4Server._cbListWork..s HHHt,,HHHrDrUs completed) r isSubscribedr@getHierarchicalDelimiterrW DontQuoteMemaprTr#r) r_ mailboxesrrmr0r.boxrdelimresps rBrjzIMAP4Server._cbListWorks" E EID# E$,33D99 EHHHHH4466==mLL(( U++KK ..  ))*=d*C*CDDD !!#w'>?????rDcZ||dtj|dS)Ns1Server error encountered while listing mailboxes.r3r}s rBrkzIMAP4Server._ebListWorks/ S"VWWW rDrrcg}|D]$}|t|%t|}t|jj|d|j||||j |dSr) rtr9r*rrr+rp_cbStatusGotMailboxr?_ebStatusGotMailbox)r_rmailboxr nativeNamesr.s rB do_STATUSzIMAP4Server.do_STATUSs  3 3D   |D11 2 2 2 2W%%dl)7A66BB  $c7K  *T-s 3 3 3 3 3rDc|r=t|j||j|j||fd||fddS||ddS)NsCould not open mailbox)r requestStatusr_IMAP4Server__cbStatus_IMAP4Server__ebStatusr`)r_r;rr}rs rBr{zIMAP4Server._cbStatusGotMailboxsw  F $,e 4 4 A Agg        % %c+D E E E E ErDcZ||dtj|dSNs/Server error encountered while opening mailbox.r3r}s rBr|zIMAP4Server._ebStatusGotMailbox/ S"TUUU rDctdd|D}|d|dzdz|zdz||ddS)N cg|]}d|zS)z%s %sr>rGrUs rBrJz*IMAP4Server.__cbStatus..s&K&K&Kqw{&K&K&KrDSTATUS rU (rsSTATUS complete)r:rrrTrWr)r_statusrrvrs rB __cbStatuszIMAP4Server.__cbStatussSXX&K&KFLLNN&K&K&KLLMM !! M22 2U :T AD H    !!#'9:::::rDc ||d|zdztt|jzdS)Nrs failed: r]r:rri)r_r~rrvs rB __ebStatuszIMAP4Server.__ebStatussJ  c!L0=W]ASAS3T3TT     rDct|}t|jj||j|||||j|dSrv)r*rrr+rp_cbAppendGotMailboxr?_ebAppendGotMailbox)r_rr}rrrs rB do_APPENDzIMAP4Server.do_APPENDsZW%%dl)733??  $c5$  *T-s 3 3 3 3 3rDc|s||ddSd|D}||||}||j||||j|dS)NzRYCREATE] No such mailboxc,g|]}t|Sr>r9r:s rBrJz3IMAP4Server._cbAppendGotMailbox..s ===t T**===rD)r` addMessagerp_IMAP4Server__cbAppendr?_IMAP4Server__ebAppend)r_r;rrrr decodedFlagsrs rBrzIMAP4Server._cbAppendGotMailboxs   % %c+H I I I F==u=== OOG\4 8 8 dosD111 T_c*****rDcZ||dtj|dSrr3r}s rBrzIMAP4Server._ebAppendGotMailboxrrDc|d|fz||ddS)Nr<sAPPEND complete)rTrAr)r_rxrr;s rB __cbAppendzIMAP4Server.__cbAppend sG !!,$2F2F2H2H1J"JKKK !!#'9:::::rDc v||dtt|jzdS)NsAPPEND failed: rr}s rB __ebAppendzIMAP4Server.__ebAppendsA  #mC 4F4F&G&GG     rDc|}||d|dS||j|j|f|fdS)N) callbackArgs errbackArgs) checkpoint_IMAP4Server__cbCheckr_IMAP4Server__ebCheck)r_rrs rBdo_CHECKzIMAP4Server.do_CHECKsh OO   9 NN4 % % % % % NNcVRUQW      rDc2||ddS)NsCHECK completedrr_rxrs rB __cbCheckzIMAP4Server.__cbChecks !!#'9:::::rDc v||dtt|jzdS)NsCHECK failed: rr}s rB __ebCheckzIMAP4Server.__ebCheck"6 S"3mC DVDV6W6W"WXXXXXrDcdS)ah Called when the client issues a CHECK command. This should perform any checkpoint operations required by the server. It may be a long running operation, but may not block. If it returns a deferred, the client will only be informed of success (or failure) when the deferred's callback (or errback) is invoked. Nr>rds rBrzIMAP4Server.checkpoint%s trDc|d}|jrt|jj}t |jd/||fdntj}|(||j|j |fd|fddS|d|dS)Nc,Srv)r>)rxrBs rBrVz&IMAP4Server.do_CLOSE..7sTZZ\\rD) r;rDrexpunger=rpr>r_IMAP4Server__cbClose_IMAP4Server__ebClose)r_rrrBs @rBdo_CLOSEzIMAP4Server.do_CLOSE0s  9 " " 1di/00A D11  } 9999::::!$*-- = NN4>4>C64#QU V V V V V NN4 % % % % %rDc||d|j|d|_d|_dS)NsCLOSE completedr)rr;r<rArs rB __cbClosezIMAP4Server.__cbCloseAsA !!#'9:::   &&&  rDc v||dtt|jzdS)NsCLOSE failed: rr}s rB __ebClosezIMAP4Server.__ebCloseGrrDc|jr?t|jj|j|j|fd|fddS||ddS)Ns$EXPUNGE ignored on read-only mailbox)r;rDrrr_IMAP4Server__cbExpunge_IMAP4Server__ebExpunger`rs rB do_EXPUNGEzIMAP4Server.do_EXPUNGEJs~ 9 " " T $)+ , , 9 9 $"2SFD3&$       % %c+R S S S S SrDcn|D]}|d|fz||ddS)Ns %d EXPUNGEsEXPUNGE completed)rTr)r_rxrrVs rB __cbExpungezIMAP4Server.__cbExpungeTsL < ")U 4 4 4 @ @di  j#.....F##A $)/1# 6 6 6 B B%sDIuc  j#.....rDc|rt|j|}tdd|D}|d|z||ddS)Nrc,g|]}t|Sr>rrGrjs rBrJz*IMAP4Server.__cbSearch..rs%=%=%=c!ff%=%=%=rDSEARCH SEARCH completed)rtgetUIDr:rrTr)r_rxrr;riidss rB __cbSearchzIMAP4Server.__cbSearchosy  .f--FCHH%=%=f%=%=%=>>?? !!*s"2333 !!#':;;;;;rDc |g}d}|o |dd}|o|dd} tttd|D]b\}\} } |t j|| | || r/|d|r| n| fzc|dkr>ddlm } | d|j t|dd|||||dS|r+| d d |z||d dS) aL Apply the search filter to a set of messages. Send the response to the client. @type result: L{list} of L{tuple} of (L{int}, provider of L{imap4.IMessage}) @param result: A list two tuples of messages with their sequence ids, sorted by the ids in descending order. @type tag: L{str} @param tag: A command tag. @type mbox: Provider of L{imap4.IMailbox} @param mbox: The searched mailbox. @type query: L{list} @param query: A list representing the parsed form of the search query. @param uid: A flag indicating whether the search is over message sequence numbers or UIDs. @type searchResults: L{list} @param searchResults: The search results so far or L{None} if no results yet. Nrrr;s%dreactorrrr)rr[ziprange _searchFilterrdeepcopyrttwisted.internetr callLaterrrTrr) r_rxrr;rri searchResultsrjlastSequenceId lastMessageIdmsgIdrrs rB__cbManualSearchzIMAP4Server.__cbManualSearchvs4  M  1F2JqM96":a=#7#7#9#9 #Ca&$9$9:: P POA|s!! e$$eS.- P$$Uc.Lcjjlllu-N%NOOO 66 0 0 0 0 0 0   %VABBZ        Q))*tyy7O7O*OPPP  % %c+> ? ? ? ? ?rDcD|r||||||sdS|dS)a Pop search terms from the beginning of C{query} until there are none left and apply them to the given message. @param query: A list representing the parsed form of the search query. @param id: The sequence number of the message being checked. @param msg: The message being checked. @type lastSequenceId: L{int} @param lastSequenceId: The highest sequence number of any message in the mailbox being searched. @type lastMessageId: L{int} @param lastMessageId: The highest UID of any message in the mailbox being searched. @return: Boolean indicating whether all of the query terms match the message. FT_singleSearchStep)r_ridrrrs rBrzIMAP4Server._searchFiltersG, ))r3  u   trDc|d}t|tr||||||sdSn|}|ddst ||}||vSt|dt|zd} | tdt|z||j vr| |||||f} n | |||} | sdSdS)a Pop one search term from the beginning of C{query} (possibly more than one element) and return whether it matches the given message. @param query: A list representing the parsed form of the search query. @param msgId: The sequence number of the message being checked. @param msg: The message being checked. @param lastSequenceId: The highest sequence number of any message in the mailbox being searched. @param lastMessageId: The highest UID of any message in the mailbox being searched. @return: Boolean indicating whether the query term matched the message. rFNr;search_zInvalid search command %sT) rLrZr[rr^isalpharrQr9r_requiresLastMessageInfo) r_rrrrrqr messageSetrUrxs rBrzIMAP4Server._singleSearchSteps"( IIaLL a   !%%a^]SS u  ARaR5==?? !)N;;  **D)l1oo"=tDD9+3l1ooE555QueS>=2QRRFFQueS11F! 5trDcdS)aS Returns C{True} if the message matches the ALL search key (always). @type query: A L{list} of L{str} @param query: A list representing the parsed query string. @type id: L{int} @param id: The sequence number of the message being checked. @type msg: Provider of L{imap4.IMessage} Tr>r_rrrs rB search_ALLzIMAP4Server.search_ALLs trDc.d|vS)aA Returns C{True} if the message has been answered. @type query: A L{list} of L{str} @param query: A list representing the parsed query string. @type id: L{int} @param id: The sequence number of the message being checked. @type msg: Provider of L{imap4.IMessage} \Answeredr@rs rBsearch_ANSWEREDzIMAP4Server.search_ANSWERED ss||~~--rDc|dddd}||ddkS)aR Returns C{True} if the message has a BCC address matching the query. @type query: A L{list} of L{str} @param query: A list whose first element is a BCC L{str} @type id: L{int} @param id: The sequence number of the message being checked. @type msg: Provider of L{imap4.IMessage} Fbccrr getHeadersgetr6rrL)r_rrrrs rB search_BCCzIMAP4Server.search_BCCs^nnUE**..ub99yy{{ ! 2 2 4 455;;rDct|d}tjt ||kSr) parseTimerLemailutils parsedater9getInternalDater_rrrrs rB search_BEFOREzIMAP4Server.search_BEFORE*sH1&&{$$\#2E2E2G2G%H%HIIDPPrDc|d}tj||dSNrFrLr6r6strFile getBodyFiler_rrrbodys rB search_BODYzIMAP4Server.search_BODY.s;yy||!!##|D#//"3"3U;;;rDc|dddd}||ddkS)NFccrrrr)r_rrrrs rB search_CCzIMAP4Server.search_CC2Z ^^E4 ( ( , ,T2 6 6xxzzuyy||113344::rDc.d|vSNz\Deletedrrs rBsearch_DELETEDzIMAP4Server.search_DELETED6cllnn,,rDc.d|vSNz\Draftrrs rB search_DRAFTzIMAP4Server.search_DRAFT9sCLLNN**rDc.d|vSNz\Flaggedrrs rBsearch_FLAGGEDzIMAP4Server.search_FLAGGED<rrDc|dddd}||ddkS)NFfromrrrr)r_rrrfms rB search_FROMzIMAP4Server.search_FROM?sZ ^^E6 * * . .vr : :xxzzuyy||113344::rDcD|d}|d||d}||ddkS)NrFrr)rLr6rrr)r_rrrhdrs rB search_HEADERzIMAP4Server.search_HEADERCswiill  ""nnUC((,,S"55yy{{ ! 2 2 4 455;;rDc0|ddSrrLrs rBsearch_KEYWORDzIMAP4Server.search_KEYWORDH ! urDcrt|d|kSrrrLgetSizers rB search_LARGERzIMAP4Server.search_LARGERL'599Q<<  3;;==00rDcZd|vod|vS)N\Recent\Seenrrs rB search_NEWzIMAP4Server.search_NEWOs'S\\^^+N 0NNrDc@|\}}|||||| S)a Returns C{True} if the message does not match the query. @type query: A L{list} of L{str} @param query: A list representing the parsed form of the search query. @type id: L{int} @param id: The sequence number of the message being checked. @type msg: Provider of L{imap4.IMessage} @param msg: The message being checked. @type lastIDs: L{tuple} @param lastIDs: A tuple of (last sequence id, last message id). The I{last sequence id} is an L{int} containing the highest sequence number of a message in the mailbox. The I{last message id} is an L{int} containing the highest UID of a message in the mailbox. r)r_rrrlastIDsrrs rB search_NOTzIMAP4Server.search_NOTRs-&+2'))%S.-XXXXrDc.d|vSNr,rrs rB search_OLDzIMAP4Server.search_OLDhs//rDct|d}tj||kSrrrLrrrrrs rB search_ONzIMAP4Server.search_ONks@1&&{$$S%8%8%:%:;;tCCrDcx|\}}||||||}||||||}|p|S)a Returns C{True} if the message matches any of the first two query items. @type query: A L{list} of L{str} @param query: A list representing the parsed form of the search query. @type id: L{int} @param id: The sequence number of the message being checked. @type msg: Provider of L{imap4.IMessage} @param msg: The message being checked. @type lastIDs: L{tuple} @param lastIDs: A tuple of (last sequence id, last message id). The I{last sequence id} is an L{int} containing the highest sequence number of a message in the mailbox. The I{last message id} is an L{int} containing the highest UID of a message in the mailbox. r) r_rrrr0rrabs rB search_ORzIMAP4Server.search_ORosM(+2'  " "5"c>= Q Q  " "5"c>= Q QvA rDc.d|vSr3rrs rB search_RECENTzIMAP4Server.search_RECENTsS\\^^++rDc.d|vSNr-rrs rB search_SEENzIMAP4Server.search_SEENs3<<>>))rDc|dddd}tj|}|t |dkS)a Returns C{True} if the message date is earlier than the query date. @type query: A L{list} of L{str} @param query: A list whose first element starts with a stringified date that is a fragment of an L{imap4.Query()}. The date must be in the format 'DD-Mon-YYYY', for example '03-March-2003' or '03-Mar-2003'. @type id: L{int} @param id: The sequence number of the message being checked. @type msg: Provider of L{imap4.IMessage} FrrrrrrrrrrLrs rBsearch_SENTBEFOREzIMAP4Server.search_SENTBEFOREsY~~eV,,00<<{$$T**i ! ----rDc|dddd}tj|}|ddt |dddkS)a Returns C{True} if the message date is the same as the query date. @type query: A L{list} of L{str} @param query: A list whose first element starts with a stringified date that is a fragment of an L{imap4.Query()}. The date must be in the format 'DD-Mon-YYYY', for example '03-March-2003' or '03-Mar-2003'. @type msg: Provider of L{imap4.IMessage} FrrNrXrrBrs rB search_SENTONzIMAP4Server.search_SENTONsj~~eV,,00<<{$$T**BQBx9UYYq\\222A2666rDc|dddd}tj|}|t |dkS)a Returns C{True} if the message date is later than the query date. @type query: A L{list} of L{str} @param query: A list whose first element starts with a stringified date that is a fragment of an L{imap4.Query()}. The date must be in the format 'DD-Mon-YYYY', for example '03-March-2003' or '03-Mar-2003'. @type msg: Provider of L{imap4.IMessage} FrrrrBrs rBsearch_SENTSINCEzIMAP4Server.search_SENTSINCEsY~~eV,,00<<{$$T**i ! ----rDct|d}tj||kSrr6rs rB search_SINCEzIMAP4Server.search_SINCEs@1&&{$$S%8%8%:%:;;dBBrDcrt|d|kSrr'rs rBsearch_SMALLERzIMAP4Server.search_SMALLERr*rDc|dddd}||ddkS)NFsubjectrrrr)r_rrrsubjs rBsearch_SUBJECTzIMAP4Server.search_SUBJECTs\~~eY//33IrBBzz||  1!3!3!5!566"<>11rDc.d|vSrrrs rBsearch_UNDELETEDzIMAP4Server.search_UNDELETED#,,..00rDc.d|vSrrrs rBsearch_UNDRAFTzIMAP4Server.search_UNDRAFTs ..rDc.d|vSrrrs rBsearch_UNFLAGGEDzIMAP4Server.search_UNFLAGGEDr[rDc0|ddSrr#rs rBsearch_UNKEYWORDzIMAP4Server.search_UNKEYWORDr%rDc.d|vSr?rrs rB search_UNSEENzIMAP4Server.search_UNSEENss||~~--rDc ||dtt|jzt j|dS)NsSEARCH failed: rr}s rB __ebSearchzIMAP4Server.__ebSearchsO  #mC 4F4F&G&GG    rDc>|r|d|_t|jj||t |j||||j |dS| |ddS)NrsFETCH complete) r/ _oldTimeoutrr;rrpiter_IMAP4Server__cbFetchr?_IMAP4Server__ebFetchr)r_rmessagesrris rBdo_FETCHzIMAP4Server.do_FETCHs  >#t44D  $)/8 = = = I I  k$.#uc::::<<<<<  % %c+< = = = = =rDcjg_ t\}}||fdjdS#t $rJj` d YdSwxYw)Nc4Srv)ri)rmrresultsr_rris rBrVz'IMAP4Server.__cbFetch..2s$..#ucBBrDsFETCH completed) rJnext spewMessagerpr?_IMAP4Server__ebSpewMessage StopIterationr/rgrrN)r_rorrrirrs````` rB __cbFetchzIMAP4Server.__cbFetchs < DL /7mmGB4   ReS 1 1 = =BBBBBBBB  j-.....7    OOD, - - -   % %c+= > > > MMOOOOOO/ sA33ACCc`tj||jdSrv)r5r@rr:r_r~s rB__ebSpewMessagezIMAP4Server.__ebSpewMessage5s.  %%'''''rDct| |jj}|dtt|gzdS)Ns ENVELOPE )rrr# getEnveloper_rr_w_fs rB spew_envelopezIMAP4Server.spew_envelope=s@ :%B <-{3/?/?.@AA ABBBBBrDc| |jj}d|D}|dd|zdzdS)Nc,g|]}t|Sr>r9r:s rBrJz*IMAP4Server.spew_flags..Es GGG d++GGGrDr>rr)rwritenr@r)r_rrr{r| encodedFlagss rB spew_flagszIMAP4Server.spew_flagsBsY :&BGG GGG   dii 55 5 <=====rDcp| |jj}|}tjt |}|)tjd|||fztdtj d|dd}t|t|dfz}|d|dz}nR|ddkrd} nd } || zd t|dd zd zt|dd zd zzfzz}|dt|zdS)Nz$%d:%r: unpareseable internaldate: %rz(Internal failure generating INTERNALDATEz%d-%%s-%Y %H:%M:%S r;s+0000rr-s%04didrs INTERNALDATE )rrrrr parsedate_tzr9r5rrtimestrftimer: _MONTH_NAMESabs_quote) r_rrr{r|idatettupstrdateodatesigns rBspew_internaldatezIMAP4Server.spew_internaldateHsN :%B##%%{'' U(;(;<< < G:b#u=MM N N N !KLL L- 5tBQBx@@gd1g)>(@@AA 7?H$EEAw!||QLLD(C/3tAw<<$3F22MMOPP   fUmm +,,,,,rDc| |jj}t|d}|dt |zdS)NTsRFC822.HEADER )rr_formatHeadersr_literal)r_rrr{r|hdrss rBspew_rfc822headerzIMAP4Server.spew_rfc822headercsL :%BcnnT2233  x~~ -.....rDc| |jj}|d|t||jS)Ns RFC822.TEXT )rr FileProducerr beginProducingrzs rBspew_rfc822textzIMAP4Server.spew_rfc822textisT :%B ? COO--..==dnMMMrDcd| |jj}|d|fzdS)NsRFC822.SIZE %d)rrr(rzs rBspew_rfc822sizezIMAP4Server.spew_rfc822sizeps8 :%B   / /00000rDc:| |jj}|d|t|d}|9t||jSt |d|j|jS)NsRFC822 )rr IMessageFileropenrMessageProducerr)r_rrr{r|mfs rB spew_rfc822zIMAP4Server.spew_rfc822us :%B :  #t $ $ > **99$.II IsD$/::II N   rDcd| |jj}|d|fzdS)NsUID %d)rrrrzs rBspew_uidzIMAP4Server.spew_uids6 :%B 9  &'''''rDc Z|dtt|dgzdS)NsBODYSTRUCTURE T)r#getBodyStructurerzs rBspew_bodystructurezIMAP4Server.spew_bodystructures5  24DS$4O4O3PQQ QRRRRRrDc8| |jj}|jD]A}|r||},|dkrt dB|jrc|j|jjg|jj R}t|}|| dzt|zdS|j rc|| dz|t||jS|jrTt|d}|| dzt|zdS|jr|| dz||jr9t||jSt'|d}|9t||jSt+|d|j|jS|dt/t1|gzdS)Nrz*Requested subpart of non-multipart messagerTsBODY )rrpart isMultipart getSubPartrwheaderrnegatefieldsr __bytes__rr6rr rmimeemptyrrrrr#r) r_rrrr{r|rrrs rB spew_bodyzIMAP4Server.spew_bodys :%B N NA   NnnQ''Q LMMM ; H!3>$+"4Jt{7IJJJD!$''D Bt~~$&$7 8 8 8 8 8 Y H Bt~~$& ' ' ' BDDD 1 122AA$.QQ Q Y H!#.."6"677D Bt~~$&$7 8 8 8 8 8 Z H Bt~~$& ' ' ' BDDDy #COO$5$566EEdnUUU!#t,,>' 22AA$.QQQ&sD$/BBQQN Bx-/?/D/D.EFFF G G G G GrDc  tj}|j |j fd fd fd   f d}|S)Nc&dfzdS)Ns * %d FETCH (r>)rrsrBr`z&IMAP4Server.spewMessage..starts E/RE) * * * * *rDcddS)Ns) r>rsrBrz'IMAP4Server.spewMessage..finishs E(OOOOOrDcddSrr>rsrBspacez&IMAP4Server.spewMessage..spaces E$KKKKKrDc3 Kd} D]r}|jdkrd}|jdkr| Vn(td|jz}| V|dur  s r&|s$  VdS)NFriTr spew_r)typerrQr) seenUIDrrUrrrrrr_rr`rirs rBspewz%IMAP4Server.spewMessage..spewsG EGGG  9%%"G9&&..r3uEEEEEEg &9::A!BUE22222uRy((EGGG ;7 ;mmBUE::::: FHHH EGGGGGrD)rrrrr) r_rrrriwbufrrrrr`rs ````` @@@@@rBrqzIMAP4Server.spewMessages4>**   + + + + + +                        &ttvv&&&rDc ||j|`tj|||dt t |jzdS)NsFETCH failed: )r/rgr5r@r]r:rrir}s rB __ebFetchzIMAP4Server.__ebFetchsa ()))    S"3mC DVDV6W6W"WXXXXXrDch|}|d}|drd}n|drd}nd}d|D}t|jj|||||j|j||j||fd|fddS) NsSILENTrr;rrrc,g|]}t|Sr>rr:s rBrJz(IMAP4Server.do_STORE..s 666d##666rDr) r^endswithrrr;storer_IMAP4Server__cbStore_IMAP4Server__ebStore)r_rrkmoderrisilents rBdo_STOREzIMAP4Server.do_STOREszz||y)) ??4  DD __T " " DDD66666diox#FFFSS N N $)S& )  F       rDc|rt|sr|D]]\}}|rd||fz}nd}d|D} |d|d| |fz^||ddS)Ns UID %drDc,g|]}t|Sr>r9r:s rBrJz)IMAP4Server.__cbStore..s ;;;t,,;;;rDs%d FETCH (FLAGS (%b)%b)rsSTORE completed)rrrTrr) r_rxrr;rirkruidstrrs rB __cbStorezIMAP4Server.__cbStores  &    1!'4;;q>>*;;FF F;;;;;)).!TYYu5E5Ev1NN !!#'9:::::rDc v||dtt|jzdSNr{rr}s rB __ebStorezIMAP4Server.__ebStorerrDct|}t|jj||j|||||j|dSrv)r*rrr+rp_cbCopySelectedMailboxr?_ebCopySelectedMailbox)r_rrkr}ris rBdo_COPYzIMAP4Server.do_COPYsZW%%dl)733??  'h  *T0# 6 6 6 6 6rDc|s||d|zdSt|jj|||j|||j|||j|dS)NzNo such mailbox: ) r`rr;rrp_IMAP4Server__cbCopy_IMAP4Server__cbCopiedr?_IMAP4Server__ebCopy)r_r;rrkr}ris rBrz"IMAP4Server._cbCopySelectedMailbox s U  % %c+>+H I I I I I $)/8S 9 9 E E sD  k$/355jjPS6T6T6T6T6TrDc v||dtt|jzdSrrr}s rBrz"IMAP4Server._ebCopySelectedMailbox rrDcjg}td}|D]\}}|+t|j|}||3|} |} t |d} | ,| } tj| | | }nZdtj } t|| |j  d| | | ffd }|| tj|S)Nc0|d|Sr)rrUs rBrewindz$IMAP4Server.__cbCopy..rewind) sFF1IIIHrDcD|||Srv)r)rmr:rUrr;rs rBrVz&IMAP4Server.__cbCopy..2 s$T__"F1IIq!>>rD)IMessageCopierrrrtr@rrrrrrrrrrpr DeferredList)r_rkrr;addedDeferreds fastCopyMboxrrrrrr bodyFilebufferrs ` @rB__cbCopyzIMAP4Server.__cbCopy sS%dD11  % %GB'!,"3S99%%a((( LLNNE&&((DT**D99;;!$/8UDII"/11#CAA#^D)) [$*et  ! !! $ $ $ $!.111rDcg}g}|D]7\}}|r||||j8|r||ddS||ddS)Nz%[ALERT] Some messages were not copiedsCOPY completed)rtrir`r)r_ deferredIdsrr;rfailuresrrxs rB __cbCopiedzIMAP4Server.__cbCopied: s) . .NFF . 6"""" ----  >  % %c+R S S S S S  % %c+< = = = = =rDc ||dtt|jzt j|dS)Ns COPY failed:rr}s rB__ebCopyzIMAP4Server.__ebCopyG sE S/M#gmBTBT4U4U"UVVV rDc|}|dvrt|||||ddS)N)COPYrSTORErr;r)r^rr_)r_rrrs rBdo_UIDzIMAP4Server.do_UIDK sL--// B B B'00 0 S'4Q77777rDcj|r|dddS|dddS)Ns [READ-WRITE]T)rrs [READ-ONLY]rTr_ writeables rB modeChangedzIMAP4Server.modeChangedX sI  L  % %ot % L L L L L  % %nd % K K K K KrDc|D]B\}}d|D}d|d|fz}||dCdS)Nc,g|]}t|Sr>r9r:s rBrJz,IMAP4Server.flagsChanged..` s BBBDM$//BBBrDs%d FETCH (FLAGS (%b))rTr)rrrT)r_newFlagsmIdrrrs rB flagsChangedzIMAP4Server.flagsChanged^ ss"..** 9 9JCBBEBBBL*c499\3J3J-KKC  % %c4 % 8 8 8 8 9 9rDc~||d|fzd||d|fzddSdS)Nr<Trr=rr_existsrecents rB newMessageszIMAP4Server.newMessagesd s\    % %lfY&> % M M M    % %lfY&> % M M M M M  rDNNNrvFNrD)rrr)rrrrrr0rr(r'r-rrr4r;rFrrrrArRrbr+r2r6rCrHrJrNrKrcrer_rgrhrqrrrrrrrecompileescape _atomCharsrrrrrrrrrrrrr1r]rr`rTrrrrunauth_CAPABILITYauth_CAPABILITYselect_CAPABILITYlogout_CAPABILITYr unauth_LOGOUT auth_LOGOUT select_LOGOUT logout_LOGOUTr unauth_NOOP auth_NOOP select_NOOP logout_NOOPrunauth_AUTHENTICATErrrrrrrunauth_STARTTLSr unauth_LOGINrrrr(auth_NAMESPACEselect_NAMESPACEr1r-r, auth_SELECT select_SELECT auth_EXAMINEselect_EXAMINErLrN select_IDLE auth_IDLErR auth_CREATE select_CREATErY auth_DELETE select_DELETEr` auth_RENAME select_RENAMErcauth_SUBSCRIBEselect_SUBSCRIBErgauth_UNSUBSCRIBEselect_UNSUBSCRIBErnrjrk auth_LIST select_LIST auth_LSUB select_LSUBrr{r| auth_STATUS select_STATUSrrrrr auth_APPEND select_APPENDrrr select_CHECKrrrr select_CLOSErrrselect_EXPUNGErrr select_SEARCHrrrrrrrrr rrrrrr!r$r)r.r1r4r7r;r=r@rCrErGrIrKrOrQrTrVrXrZr]r_rarcrrl select_FETCHrirrr}rrrrrrrrrrqrjr select_STORErrr select_COPYrrrrrr select_UIDrrrr>rDrBrrTs  'EGJK DFGI DOK 766 EJ   """ """   %%%G***   : >>>>VVV(>>> &   222$, , , , ^RZ  *---0HHF : : :@@@"'''( H H H0            ///,,,,++++++++....     3 3 3@@@'('O))((( LMK!M!MGGG*KIKK===+H5((( E E E   ///      A A A#nO***k+; > > >j,7L / / /D(((CCCC >>>> ----6//// NNNN1111     (((( SSSS$H$H$H$HL!'!'!'FYYY     (j(LAL ; ; ;YYY7777 J(89KUUUYYY&2&2&2P > > >888(H-J LLL 999 NNNNNrDrceZdZdZdZdZdZdZdZdZ dZ dZ dZ dZ dZeeedZdZdcd Zd Zd Zd Zd ZdZdZdZdZdZdZdZdZdZdZ dZ!dZ"dZ#dddZ$dZ%dZ&dZ'dZ(d Z)dcd!Z*d"Z+d#Z,d$Z-d%Z.d&Z/d'Z0d(Z1d)Z2d*Z3d+Z4d,Z5d-Z6d.Z7d/Z8d0Z9d1Z:d2Z;d3Zd6Z?d7Z@d8ZAd9ZBd:ZCd;dZFded@ZGdAZHdBZIdCZJdDZKdEZLdFZMddGdHZNdIZOdfdJZPdfdKZQdfdLZRdfdMZSdfdNZTdfdOZUdfdPZVdfdQZWdfdRZXdfdSZYdfdTZZdfdUZ[dfdVZ\dWZ]dXZ^ dgdYZ_dfdZZ`dhd[Zadhd\Zbdhd]Zcd^Zdd_Zed`ZfdaZgdbZhdS)i IMAP4ClientzIMAP4 client protocol implementation @ivar state: A string representing the state the connection is currently in. Nr;Frr)OKNOBADPREAUTHBYE)MESSAGESRECENTUNSEENchi|_g|_i|_||_d|_d|_d|_dSrv)r-queuedauthenticatorscontext_tag_parts_lastCmd)r_r s rBrbzIMAP4Client.__init__ s8   %    rDcb||j|<dS)a Register a new form of authentication When invoking the authenticate() method of IMAP4Client, the first matching authentication scheme found will be used. The ordering is that in which the server lists support authentication schemes. @type auth: Implementor of C{IClientAuthentication} @param auth: The object to use to perform the client side of this authentication scheme. N)rGgetNamer^)r_rs rBregisterAuthenticatorz!IMAP4Client.registerAuthenticator s+7;DLLNN0022333rDcT|jdkr||xjt|zc_|jdkr|j|dSd}|jdkr|d|j||jd}}|j||j}d|_d|_|dd|j| | | ddS)NrrD ) r8rE _pendingSizer_pendingBufferrrrJrtreadrGlstrip)r_rrras rBrHzIMAP4Client.rawDataReceived s" >HqLNN+H  && 6 #2#//FF!666/5556;&'+zz$':':$DIuu E%%eV444 ;   ! !$ ' ' ' ' ' K  t $ $ $ 388DK#8#8C&* *DI  d + + + + +s A66BcF|jr?|jj3|jjdc}|j_|t|jr:|jD]2}|j)|j|c}|_|t3|jdSrv)rKrr[ TIMEOUT_ERRORrFrr:)r_rrbs rBrCzIMAP4Client.timeoutConnection s = %T]0<%)]%8$ "At}" IIm $ $ $ ; -{ - -9(#&9aLAsyIIm,,, %%'''''rDc|dd}t|dkr|d|\}}|||dS)Nr;rrD)r\rrtr_)r_rrarras rBr_zIMAP4Client._regularDispatch s[ 4## u::?? LL    T S$'''''rDcZ||jkrtjStS)a8 Create a file to which an incoming message may be written. @type octets: L{int} @param octets: The number of octets which will be written to the file @rtype: Any object which implements C{write(string)} and C{seek(int, int)} @return: A file-like object )rrrr)r_rWs rBrVzIMAP4Client.messageFile s+ D) ) ))++ +99 rDc`d|jzd}|xjdz c_|S)Nz%0.4Xasciir;)tagIDrWrs rBmakeTagzIMAP4Client.makeTag/ s0#++G44 a  rDc|j|j}n+t|d|jzd}|rL |||dS#t$r0t j|jYdSwxYwt jd|jd|d||jdS)N response_zCannot dispatch: z, ) rAresponse_UNAUTHrQr^rQr5r@rr:)r_rrarUs rBr_zIMAP4Client.dispatchCommand4 s : $AAkDJ,<,<,>,>>EEA  , 0#t   0 0 0 --////// 0 GG GGcGGtGG H H H N ) ) + + + + +s A 6BBc t|j|dd\}}|dkrd|_nN|dkrd|_n.|jt |dz|z|d|d}}|d krK|d krE||t||dz|gdfdS|ddS| ||dS) Nr;rrsPREAUTHrrr?]r) rAr\r^rr:rrserverGreeting_IMAP4Client__cbCapabilitiesr_defaultHandler)r_rrarr:rVs rBrlzIMAP4Client.response_UNAUTHC s= : ::dA..LFD||~~&&% :--# --///+C$J,=>>>99T??DIIdOOqABww177##)),=d1q519o,N,N+OQU*VWW##D)))))  d + + + + +rDc2|||dSrv)rq)r_rras rB response_AUTHzIMAP4Client.response_AUTHZ s S$'''''rDc|dks|dkrw|js%|t|gdS|j|j}|dkr||dS|j|dS |j|}|dd\}}|dkr|||jn'|j t||j|=d|_| dS#t$r/|jt!|dz|zwxYw)Nrrr;rr)waiting _extraInforr-rrrtr\rrr[r _flushQueueKeyErrorrr:r)r_rrarbrrs rBrqzIMAP4Client._defaultHandler] sg $;;#++< +!24!8!8 9:::::i -$;;$$T*****I$$T***** #in $zz$22 U??JJtT_5555I%%nT&:&:;;;IcN#   """"" ? ? ?--///+C$J,=>>> ?s  D9Ec|jri|jd}|}||j|<|||||_dSdSr)rFrLrir-r9rrur_rbts rBrwzIMAP4Client._flushQueuey sh ; +//!$$C ADIaL MM#**Q-- ( ( (DLLL   rDci}dx}}|D]O}t|}|dkr#|ddgkr|d;|dkr#|ddgkr|dd|dkr"|ddkrt|d}|dkr"|dd krt|d}|d kr~|dd krrt|d}||d\}} ||g|d d 8tjd|Q|r| |||| ||dSdS)Nr;rrFrTrrrrXrFLAGSr>z Unhandled unsolicited response: ) rrr_parseFetchPairs setdefaultr|rr5rrr) r_rrrrresponseelementsrr\rms rBrvzIMAP4Client._extraInfo s G GH8}}H1}}!!>!>  ''''Q8A;=/#A#A  &&&&Q8A;)#;#;Xa[))Q8A;)#;#;Xa[))Q8A;(#:#:(1+&& 11(1+>>   b))00GR1H1HIIIIE8EEFFFF  %   e $ $ $  !3   VV , , , , ,"4!3rDc8tj|_|jr!|j||jS|}||j|<|||||_||_ |jSrv) rrrurFrtrir-r9rrKrzs rB sendCommandzIMAP4Client.sendCommand sN$$ <  K  s # # #9  LLNN !  cjjmm$$$  yrDc|r |jtj|jSd}d}|t ||}||j|S)av Request the capabilities available on this server. This command is allowed in any state of connection. @type useCache: C{bool} @param useCache: Specify whether to use the capability-cache or to re-retrieve the capabilities from the server. Server capabilities should never change, so for normal use, this flag should never be false. @rtype: L{Deferred} @return: A deferred whose callback will be invoked with a dictionary mapping capability types to lists of supported mechanisms, or to None if a support list is not applicable. Nr)rr) _capCachersucceedrrrprp)r_useCacherbrxrs rBgetCapabilitieszIMAP4Client.getCapabilities si"  12=00 0   WSt<<< = = d+,,,rDc8|\}}i}|D]q}|ddD]d}|dd}t|dkr |dd} }n|\}} ||g| er|D]}||dgkrd||<||_|S)Nr;rr)r\rrrtr) r_rxrtaglinerrar*racategoryris rB__cbCapabilitieszIMAP4Client.__cbCapabilities s! < rs rB__cbNoopzIMAP4Client.__cbNoop s" rDcjr Jd|}|!tjt dSdjvr!tjt dSt jjd}|!tjt dS td}| j || fd|S)a: Initiates a 'STARTTLS' request and negotiates the TLS / SSL Handshake. @param contextFactory: The TLS / SSL Context Factory to leverage. If the contextFactory is None the IMAP4Client will either use the current TLS / SSL Context Factory or attempt to create a new one. @type contextFactory: C{ssl.ClientContextFactory} @return: A Deferred which fires when the transport has been secured according to the given contextFactory, or which fails if the transport cannot be secured. z5Client and Server are currently communicating via TLSNzEIMAP4Client requires a TLS context to initiate the STARTTLS handshaker%z:Server does not support secure communication via TLS / SSLzAIMAP4Client transport does not implement interfaces.ITLSTransportc,Srvrrmr_s rBrVz&IMAP4Client.startTLS../ s 4 4 6 6rD) r(_getContextFactoryrfailrrrr.rrrrp _startedTLS)r_r tlsrs` rBrzIMAP4Client.startTLS s9" C C B C C C  !!4466N  !:6  dn , ,:S  &t~t<< ;:/    W[11 2 2 d&777 6666777rDc|j|}ntj|j}||j||S)a2 Attempt to enter the authenticated state with the server This command is allowed in the Non-Authenticated state. @rtype: L{Deferred} @return: A deferred whose callback is invoked if the authentication succeeds and whose errback will be invoked otherwise. )rrrrrp_IMAP4Client__cbAuthenticate)r_secretrs rBrzIMAP4Client.authenticate2 sL > !$$&&AA dn--A d+V444rDc |ddD]M}|jvr0td|dj||}|cSNjr9tjtj Sfd} }| || fd| j||S)Nr#r> AUTHENTICATEc|ttjt jSrv)traprrrr$rGr&)r@authsr_s rB ebStartTLSz0IMAP4Client.__cbAuthenticate..ebStartTLSR sE(((z-eT5H5M5M5O5OPPrDc,Srvrrs rBrVz.IMAP4Client.__cbAuthenticate..[ sD$8$8$:$:rD)rr^rGr_IMAP4Client__cbContinueAuthrr(rrr$r&rr?rp_IMAP4Client__cbAuthTLS)r_rrschemerbrrrs` @rB__cbAuthenticatezIMAP4Client.__cbAuthenticateC s0"%% - -F||~~!444#VR1FPV'',,,,, 5 ? :)%1D1I1I1K1KLL         A LL $ $ $ MM:::: ; ; ; MM$*F 3 3 3HrDcH t|dz}|j|}|||}|t |dS#t j$r%|dt|wxYw)N r) rrGchallengeResponser9rrrrr)r_rarrrrs rB__cbContinueAuthzIMAP4Client.__cbContinueAuth_ s 5te|,,D &v.D))&$77D MM+d++1133 4 4 4 4 4 ~ . . . MM$   '-- - .s A--4B!c |dd}|D]M}||jvr0td|d|j||}||cSNt ||j)Nr#r>r)rr^rGrrrr$r&)r_rrrrrbs rB __cbAuthTLSzIMAP4Client.__cbAuthTLSj s"%% - -F||~~!444#VR1FPV'',,,,, 5 (t/B/G/G/I/IJJJrDcft|j}||j|||S)a Authenticate with the server using a username and password This command is allowed in the Non-Authenticated state. If the server supports the STARTTLS capability and our transport supports TLS, TLS is negotiated before the login command is issued. A more secure way to log in is to use C{startTLS} or C{authenticate} or both. @type username: L{str} @param username: The username to log in with @type password: L{str} @param password: The password to log in with @rtype: L{Deferred} @return: A deferred whose callback is invoked if login is successful and whose errback is invoked otherwise. )rrrp_IMAP4Client__cbLoginCaps)r_usernamepasswordrs rBrzIMAP4Client.logint s2* $. / / d((H===rDcdS)z Called when the server has sent us a greeting. @type caps: C{dict} @param caps: Capabilities the server advertised in its greeting. Nr>)r_rs rBrozIMAP4Client.serverGreeting rDcv|j|jS ddlm}|S#t$rYdSwxYw)Nr)ssl)rHrrClientContextFactory ImportError)r_rs rBrzIMAP4Client._getContextFactory sa < #<  . , , , , , ,++-- -   44 s * 88cd|v}tj|jddu}tj|jddu}|js@|r>|r<|r:|}||j|j||f|S|rtj dd t|t|f}| td|S)Nr%)rz5Server has no TLS support. logging in over cleartext!rr)rr.rr)r(rr_IMAP4Client__cbLoginTLS_IMAP4Client__ebLoginTLSr5rrrrr) r_r+rrtryTLStlsableTransportnontlsTransportrrs rB __cbLoginCapszIMAP4Client.__cbLoginCaps s ,&3DNDIIQUU%24>4HHDP =6 =.> =? = A NN!!&1     H QOPPP99fX..x0@0@ABBD##GHd$;$;<< >$ 7 7888rDc.tj||Srv)r5r@rvs rB __ebLoginTLSzIMAP4Client.__ebLoginTLS s rDcd}d}|t||}||j|S)a Retrieve information about the namespaces available to this account This command is allowed in the Authenticated and Selected states. @rtype: L{Deferred} @return: A deferred whose callback is invoked with namespace information. An example of this information is:: [[['', '/']], [], []] which indicates a single personal namespace called '' with '/' as its hierarchical delimiter, and no shared or user namespaces. r)rr)rrrp_IMAP4Client__cbNamespacer_rbrxrs rB namespacezIMAP4Client.namespace sH   WSt<<< = = d()))rDc|\}}d|D]9}t|dkr$|ddkrfd|ddDcS:tjdggggS)Ncd|DS)Nc8g|]}|dS)rU)decode)rGelements rBrJzSIMAP4Client.__cbNamespace.._prepareNamespaceOrDelimiter.. s$OOOgGNN=11OOOrDr>) namespaceLists rB_prepareNamespaceOrDelimiterz?IMAP4Client.__cbNamespace.._prepareNamespaceOrDelimiter sOOOOO OrDrrrc4g|]}|gn fd|DS)Nc&g|] }|Sr>r>)rGrirs rBrJz8IMAP4Client.__cbNamespace... s%VVV%66u==VVVrDr>)rG pairOrNoners rBrJz-IMAP4Client.__cbNamespace.. sL#")BVVVV:VVVrDr;z*No NAMESPACE response to NAMESPACE command)rr5r@)r_rxrrerars @rB __cbNamespacezIMAP4Client.__cbNamespace s  P P P  E5zzQ58|#;#;',ABBi  <===B|rDcd}t|}d}|t|||}||jd|S)a Select a mailbox This command is allowed in the Authenticated and Selected states. @type mailbox: L{str} @param mailbox: The name of the mailbox to select @rtype: L{Deferred} @return: A deferred whose callback is invoked with mailbox information if the select is successful and whose errback is invoked otherwise. Mailbox information consists of a dictionary with the following L{str} keys and values:: FLAGS: A list of strings containing the flags settable on messages in this mailbox. EXISTS: An integer indicating the number of messages in this mailbox. RECENT: An integer indicating the number of "recent" messages in this mailbox. UNSEEN: The message sequence number (an integer) of the first unseen message in the mailbox. PERMANENTFLAGS: A list of strings containing the flags that can be permanently set on messages in this mailbox. UIDVALIDITY: An integer uniquely identifying this mailbox. rF)r}EXISTSrCrDPERMANENTFLAGS UIDVALIDITYrr;_prepareMailboxNamerrrp_IMAP4Client__cbSelectr_r}rbrrxrs rBr+zIMAP4Client.select s\@"7++X   WS$TBBB C C doq)))rDcd}t|}d}|t|||}||jd|S)a Select a mailbox in read-only mode This command is allowed in the Authenticated and Selected states. @type mailbox: L{str} @param mailbox: The name of the mailbox to examine @rtype: L{Deferred} @return: A deferred whose callback is invoked with mailbox information if the examine is successful and whose errback is invoked otherwise. Mailbox information consists of a dictionary with the following keys and values:: 'FLAGS': A list of strings containing the flags settable on messages in this mailbox. 'EXISTS': An integer indicating the number of messages in this mailbox. 'RECENT': An integer indicating the number of "recent" messages in this mailbox. 'UNSEEN': An integer indicating the number of messages not flagged \Seen in this mailbox. 'PERMANENTFLAGS': A list of strings containing the flags that can be permanently set on messages in this mailbox. 'UIDVALIDITY': An integer uniquely identifying this mailbox. rG)rrrrrrrrrrs rBexaminezIMAP4Client.examine s]@"7++    WS$TBBB C C doq)))rDc\ t|S#t$rt|wxYw)z Parse C{value} as an integer and return the result or raise L{IllegalServerResponse} with C{phrase} as an argument if C{value} cannot be parsed as an integer. )rrgr)r_riphrases rB _intOrRaisezIMAP4Client._intOrRaiseM s<  0u::  0 0 0'// / 0s+cR|\}}d|i}|t||D]w}t|dkr(|ddkr |d}t |t r |d}n|}|}|dkrd|d<~|dkrd|d<|d kr ||d||d <|d kr ||d||d <|d kr ||d||d<|dkr$td|dD|d<&tj d|?t|dkr |ddkr$td|dD|d<t |dtr|ddkr!||d||d<|ddkr!||d||d<.tj d|Gtj d|`tj d|y|S)zy Handle lines received in response to a SELECT or EXAMINE command. See RFC 3501, section 6.3.1. z READ-WRITErrr;rFrTrrrrDrUIDNEXTrc34K|]}t|VdSrvrr:s rBrz)IMAP4Client.__cbSelect..x s;44/3 T**444444rDrzUnhandled SELECT response (2): rrc34K|]}t|VdSrvrr:s rBrz)IMAP4Client.__cbSelect.. s**S*S$<+=+=*S*S*S*S*S*SrDr}rrrrCzUnhandled SELECT response (0): zUnhandled SELECT response (1): zUnhandled SELECT response (4): ) rtrrr^rZr[rtupler5r@bytes) r_rxr/rrdatumr\contentros rB __cbSelectzIMAP4Client.__cbSelectX s "r" &w//000+ C+ CE5zzA~~%(.."2"2e";";(gt,,"!!*CC"Ciikk,&&*/E,''M))*.E,''N**+/+;+;GAJ+N+NE-((I%%&*&6&6wqz5&I&IE(OOJ&&'+'7'7 E'J'JE)$$---.3447>qz444//E*++GEeEEFFFFUq8>>##x//%**S*S%PQ(*S*S*S%S%SE'NNa%00 GQx~~''944*.*:*:58U*K*Khq))Y66*.*:*:58U*K*Kh I% I IJJJJGEeEEFFFFA%AABBBB rDcb|tdt|S)a| Create a new mailbox on the server This command is allowed in the Authenticated and Selected states. @type name: L{str} @param name: The name of the mailbox to create. @rtype: L{Deferred} @return: A deferred whose callback is invoked if the mailbox creation is successful and whose errback is invoked otherwise. sCREATErrrr_r.s rBrPzIMAP4Client.create + 3Ft3L3L M MNNNrDcb|tdt|S)ak Delete a mailbox This command is allowed in the Authenticated and Selected states. @type name: L{str} @param name: The name of the mailbox to delete. @rtype: L{Deferred} @return: A deferred whose calblack is invoked if the mailbox is deleted successfully and whose errback is invoked otherwise. sDELETErrs rBrVzIMAP4Client.delete rrDc t|}t|}|tdd||fS)a Rename a mailbox This command is allowed in the Authenticated and Selected states. @type oldname: L{str} @param oldname: The current name of the mailbox to rename. @type newname: L{str} @param newname: The new name to give the mailbox. @rtype: L{Deferred} @return: A deferred whose callback is invoked if the rename is successful and whose errback is invoked otherwise. sRENAMEr)rrrr)r_r^r_s rBr]zIMAP4Client.rename sM &g..%g.. 499gw=O3P3P Q QRRRrDcb|tdt|S)a Add a mailbox to the subscription list This command is allowed in the Authenticated and Selected states. @type name: L{str} @param name: The mailbox to mark as 'active' or 'subscribed' @rtype: L{Deferred} @return: A deferred whose callback is invoked if the subscription is successful and whose errback is invoked otherwise. s SUBSCRIBErrs rBrbzIMAP4Client.subscribe s+ 6I$6O6O P PQQQrDcb|tdt|S)a{ Remove a mailbox from the subscription list This command is allowed in the Authenticated and Selected states. @type name: L{str} @param name: The mailbox to unsubscribe @rtype: L{Deferred} @return: A deferred whose callback is invoked if the unsubscription is successful and whose errback is invoked otherwise. s UNSUBSCRIBErrs rBrfzIMAP4Client.unsubscribe s+8KD8Q8Q R RSSSrDcd}d|d|dd}d}|t|||}||jd|S)ap List a subset of the available mailboxes This command is allowed in the Authenticated and Selected states. @type reference: L{str} @param reference: The context in which to interpret C{wildcard} @type wildcard: L{str} @param wildcard: The pattern of mailbox names to match, optionally including either or both of the '*' and '%' wildcards. '*' will match zero or more characters and cross hierarchical boundaries. '%' will also match zero or more characters, but is limited to a single hierarchical level. @rtype: L{Deferred} @return: A deferred whose callback is invoked with a list of L{tuple}s, the first element of which is a L{tuple} of mailbox flags, the second element of which is the hierarchy delimiter for this mailbox, and the third of which is the mailbox name; if the command is unsuccessful, the deferred's errback is invoked instead. B{NB}: the delimiter and the mailbox name are L{str}s. r"z" "rU)rr)rWrrrp_IMAP4Client__cbList)r_ referencewildcardrbrrxrs rBr[zIMAP4Client.list sq8-I--(---55mDD   WS$TBBB C C dmW---rDcd}|d}|d}dd|d|dg}d}|t|||}||jd|S) aa List a subset of the subscribed available mailboxes This command is allowed in the Authenticated and Selected states. The parameters and returned object are the same as for the L{list} method, with one slight difference: Only mailboxes which have been subscribed can be included in the resulting list. rrgrUrDrs" ")rr)rWrrrrpr) r_rrrbencodedReferenceencodedWildcardrrxrs rBlsubzIMAP4Client.lsub s$++G44"//-88xx        WS$TBBB C C dmW---rDcl|\}}g}|D]}t|dkr|d|krtd|dD|d<|dd|d<|dd|d<|t|dd|S)Nrrc34K|]}t|VdSrvrr:s rBrz'IMAP4Client.__cbList..' s* I Id!3!3 I I I I I IrDr;rrUrX)rrrrt)r_rxrrreroras rB__cbListzIMAP4Client.__cbList s  1 1E5zzQ58w#6#6 I Ia I I IIIa!8??=99a 8??=99auU122Y//000rDc:i|]}||dS)rgrW)rGr.s rB zIMAP4Client.; s6     dkk'""   rDrBrCrrrDcd}t|} dfd|D}nB#t$r5tdt |t jz wxYwd|d|dg}d}t||| }|j |S) a7 Retrieve the status of the given mailbox This command is allowed in the Authenticated and Selected states. @type mailbox: L{str} @param mailbox: The name of the mailbox to query @type names: L{bytes} @param names: The status names to query. These may be any number of: C{'MESSAGES'}, C{'RECENT'}, C{'UIDNEXT'}, C{'UIDVALIDITY'}, and C{'UNSEEN'}. @rtype: L{Deferred} @return: A deferred which fires with the status information if the command is successful and whose errback is invoked otherwise. The status information is in the form of a C{dict}. Each element of C{names} is a key in the dictionary. The value for each key is the corresponding response from the server. rrc32K|]}j|VdSrv) _statusNames)rGr.r_s rBrz%IMAP4Client.status.._ s+HH$d/5HHHHHHrDzUnknown names: rDrr)rr) rrrxrgsetr rrrp_IMAP4Client__cbStatus)r_r}rrbpreparedMailboxrrxrs` rBrzIMAP4Client.statusF s*-g66 XIIHHHH%HHHHHEE X X XVs5zzC@Q>   WS$TBBB C C do&&&s !6?A5c> |\}}i}|D]}|ddkrw|d fdtdt dD D]B\}} ||t|<#t$rt t wxYw|D]w}|j|}|rY |||||<4#t$r6} t d|zdz||zdzt| zd} ~ wwxYwx|S)Nrrrc*g|]}||dzS)rr>)rGrjrs rBrJz*IMAP4Client.__cbStatus..o s&KKKaq1q5y)KKKrD(rz): ) rrr9UnicodeDecodeErrorrrsr&STATUS_TRANSFORMATIONSrrSr) r_rxrrerrarrr{rVrs @rBrzIMAP4Client.__cbStatusi sy  A AEQx9$$aKKKK5CJJ3J3JKKK!AADAqA23|A//-AAA3DKK@@@A  A+//22A  !&) F1II /a# q 1E9CFFB  s$A&&'B C D#1DDr>c |dd|}|dd|r tdt|z}nd}d|D}dt |d|||fz}|td|d |j|}|S) a Add the given message to the given mailbox. This command is allowed in the Authenticated and Selected states. @type mailbox: L{str} @param mailbox: The mailbox to which to add this message. @type message: Any file-like object opened in B{binary mode}. @param message: The message to add, in RFC822 format. Newlines in this file should be \r\n-style. @type flags: Any iterable of L{str} @param flags: The flags to associated with this message. @type date: L{str} @param date: The date to associate with this message. This should be of the format DD-MM-YYYY HH:MM:SS +/-HHMM. For example, in Eastern Standard Time, on July 1st 2004 at half past 1 PM, "01-07-2004 13:30:00 -0500". @rtype: L{Deferred} @return: A deferred whose callback is invoked when this command succeeds or whose errback is invoked if it fails. rrz "%s"rDc,g|]}t|Sr>r9r:s rBrJz&IMAP4Client.append.. >>> d++>>>rDs%b (%b)%b {%d}rsAPPENDr>) rtellr:r9rrrr_IMAP4Client__cbContinueAppend) r_r}rrrrrrbrs rBrtzIMAP4Client.append s4  Q LLNN Q   <+=+=!=>>DDD>>>>>   ( ( IIl # #  #      IsB(? I I  rDctj}|||jd|jSrv)r3 FileSenderbeginFileTransferrrp_IMAP4Client__cbFinishAppend)r_rrrs rB__cbContinueAppendzIMAP4Client.__cbContinueAppend sB    ""7DNDAAMM  !   rDc0|ddSrr)r_foos rB__cbFinishAppendzIMAP4Client.__cbFinishAppend s crDcF|tdS)a Tell the server to perform a checkpoint This command is allowed in the Selected state. @rtype: L{Deferred} @return: A deferred whose callback is invoked when this command succeeds or whose errback is invoked if it fails. sCHECKrrrds rBr|zIMAP4Client.check s  1 1222rDcF|tdS)a Return the connection to the Authenticated state. This command is allowed in the Selected state. Issuing this command will also remove all messages flagged \Deleted from the selected mailbox if it is opened in read-write mode, otherwise it indicates success by no messages are removed. @rtype: L{Deferred} @return: A deferred whose callback is invoked when the command completes successfully or whose errback is invoked if it fails. sCLOSEr!rds rBr>zIMAP4Client.close s  1 1222rDcd}d}|t||}||j|S)a Return the connection to the Authenticate state. This command is allowed in the Selected state. Issuing this command will perform the same actions as issuing the close command, but will also generate an 'expunge' response for every message deleted. @rtype: L{Deferred} @return: A deferred whose callback is invoked with a list of the 'expunge' responses when this command is successful or whose errback is invoked otherwise. r)rr)rrrp_IMAP4Client__cbExpungers rBrzIMAP4Client.expunge sH   WSt<<< = = d&'''rDc|\}}g}|D]P}t|dkr;|ddkr/|||d|Q|S)Nrr;rr)rrtr)r_rxrrerras rBrzIMAP4Client.__cbExpunge sh  > >E5zzQ58z#9#9 4++E!He<<=== rDrcd|D}|rdnd}d|}|t|||f}||j|S)a Search messages in the currently selected mailbox This command is allowed in the Selected state. Any non-zero number of queries are accepted by this method, as returned by the C{Query}, C{Or}, and C{Not} functions. @param uid: if true, the server is asked to return message UIDs instead of message sequence numbers. @type uid: L{bool} @rtype: L{Deferred} @return: A deferred whose callback will be invoked with a list of all the message sequence numbers return by the search, or whose errback will be invoked if there is an error. c8g|]}|dS)r r)rGrs rBrJz&IMAP4Client.search..s$@@@u5<< **@@@rDs UID SEARCHrrr)rrrrp_IMAP4Client__cbSearch)r_riqueriesrbrrs rBrzIMAP4Client.search st(A@@@@"1mm yy!!   WS$cVDDD E E do&&&rDc|\}}g}|D]Ktdkr6ddkr*|fdddDL|S)Nrrc<g|]}|Sr>)r)rGrrar_s rBrJz*IMAP4Client.__cbSearch..s)JJJ1D,,Q66JJJrDr;)rr|)r_rxrrarras` @rBrzIMAP4Client.__cbSearchsx  L LE5zzA~~%(i"7"7 JJJJJabb JJJKKK rDc2|||dS)aV Retrieve the unique identifier for one or more messages This command is allowed in the Selected state. @type messages: L{MessageSet} or L{str} @param messages: A message sequence set @type uid: L{bool} @param uid: Indicates whether the message sequence set is of message numbers or of unique message IDs. @rtype: L{Deferred} @return: A deferred whose callback is invoked with a dict mapping message sequence numbers to unique message identifiers, or whose errback is invoked if there is an error. r;)useUIDri_fetchr_rkris rBfetchUIDzIMAP4Client.fetchUIDs${{8CQ{777rDc2|||dS)aH Retrieve the flags for one or more messages This command is allowed in the Selected state. @type messages: L{MessageSet} or L{str} @param messages: The messages for which to retrieve flags. @type uid: L{bool} @param uid: Indicates whether the message sequence set is of message numbers or of unique message IDs. @rtype: L{Deferred} @return: A deferred whose callback is invoked with a dict mapping message numbers to lists of flags, or whose errback is invoked if there is an error. r;)r-rr.r0s rB fetchFlagszIMAP4Client.fetchFlags*s${{8Cq{999rDc2|||dS)a Retrieve the internal date associated with one or more messages This command is allowed in the Selected state. @type messages: L{MessageSet} or L{str} @param messages: The messages for which to retrieve the internal date. @type uid: L{bool} @param uid: Indicates whether the message sequence set is of message numbers or of unique message IDs. @rtype: L{Deferred} @return: A deferred whose callback is invoked with a dict mapping message numbers to date strings, or whose errback is invoked if there is an error. Date strings take the format of "day-month-year time timezone". r;)r- internaldater.r0s rBfetchInternalDatezIMAP4Client.fetchInternalDate>s&{{8Ca{@@@rDc2|||dS)a Retrieve the envelope data for one or more messages This command is allowed in the Selected state. @type messages: L{MessageSet} or L{str} @param messages: The messages for which to retrieve envelope data. @type uid: L{bool} @param uid: Indicates whether the message sequence set is of message numbers or of unique message IDs. @rtype: L{Deferred} @return: A deferred whose callback is invoked with a dict mapping message numbers to envelope data, or whose errback is invoked if there is an error. Envelope data consists of a sequence of the date, subject, from, sender, reply-to, to, cc, bcc, in-reply-to, and message-id header fields. The date, subject, in-reply-to, and message-id fields are L{str}, while the from, sender, reply-to, to, cc, and bcc fields contain address data as L{str}s. Address data consists of a sequence of name, source route, mailbox name, and hostname. Fields which are not present for a particular address may be L{None}. r;)r-enveloper.r0s rB fetchEnvelopezIMAP4Client.fetchEnvelopeSs6{{8C!{<<>>rDc2|||dS)a6 Retrieve the size, in octets, of one or more messages This command is allowed in the Selected state. @type messages: L{MessageSet} or L{str} @param messages: A message sequence set @type uid: L{bool} @param uid: Indicates whether the message sequence set is of message numbers or of unique message IDs. @rtype: L{Deferred} @return: A deferred whose callback is invoked with a dict mapping message numbers to sizes, or whose errback is invoked if there is an error. r;)r- rfc822sizer.r0s rB fetchSizezIMAP4Client.fetchSizerHrDc :|||dddddS)aV Retrieve several different fields of one or more messages This command is allowed in the Selected state. This is equivalent to issuing all of the C{fetchFlags}, C{fetchInternalDate}, C{fetchSize}, C{fetchEnvelope}, and C{fetchSimplifiedBody} functions. @type messages: L{MessageSet} or L{str} @param messages: A message sequence set @type uid: L{bool} @param uid: Indicates whether the message sequence set is of message numbers or of unique message IDs. @rtype: L{Deferred} @return: A deferred whose callback is invoked with a dict mapping message numbers to dict of the retrieved data values, or whose errback is invoked if there is an error. They dictionary keys are "flags", "date", "size", "envelope", and "body". r;)r-rr5rJr8r r.r0s rB fetchFullzIMAP4Client.fetchFulls4,{{    rDc8|||ddddS)a. Retrieve several different fields of one or more messages This command is allowed in the Selected state. This is equivalent to issuing all of the C{fetchFlags}, C{fetchInternalDate}, C{fetchSize}, and C{fetchEnvelope} functions. @type messages: L{MessageSet} or L{str} @param messages: A message sequence set @type uid: L{bool} @param uid: Indicates whether the message sequence set is of message numbers or of unique message IDs. @rtype: L{Deferred} @return: A deferred whose callback is invoked with a dict mapping message numbers to dict of the retrieved data values, or whose errback is invoked if there is an error. They dictionary keys are "flags", "date", "size", and "envelope". r;)r-rr5rJr8r.r0s rBfetchAllzIMAP4Client.fetchAlls-*{{ SaRS   rDc6|||dddS)a Retrieve several different fields of one or more messages This command is allowed in the Selected state. This is equivalent to issuing all of the C{fetchFlags}, C{fetchInternalDate}, and C{fetchSize} functions. @type messages: L{MessageSet} or L{str} @param messages: A message sequence set @type uid: L{bool} @param uid: Indicates whether the message sequence set is of message numbers or of unique message IDs. @rtype: L{Deferred} @return: A deferred whose callback is invoked with a dict mapping message numbers to dict of the retrieved data values, or whose errback is invoked if there is an error. They dictionary keys are "flags", "date", and "size". r;)r-rr5rJr.r0s rB fetchFastzIMAP4Client.fetchFast0s!*{{8CqqUV{WWWrDc  fd i}g}t|} t|}n#t$rYnIwxYw t|}n#t$rtd|wxYw|dvrd}nPt |t sd}n8t |dkrd}n"|rt |dt rd}nd}t|}|||rqt |dkr3d|D}|||t|f}nQt|d}d |d D} ||| g||t| ff} t|}n#t$rtd|wxYw| d r| d r t|d d t|}||||fz} t|}n.#t$rtd|wxYw#t$rYnwxYw |}|||||<g||fS)a Given the result of parsing a single I{FETCH} response, construct a L{dict} mapping response keys to response values. @param fetchResponseList: The result of parsing a I{FETCH} response with L{parseNestedParens} and extracting just the response data (that is, just the part that comes after C{"FETCH"}). The form of this input (and therefore the output of this method) is very disagreeable. A valuable improvement would be to enumerate the possible keys (representing them as structured objects of some sort) rather than using strings and tuples of tuples of strings and so forth. This would allow the keys to be documented more easily and would allow for a much simpler application-facing API (one not based on looking up somewhat hard to predict keys in a dict). Since C{fetchResponseList} notionally represents a flattened sequence of pairs (identifying keys followed by their associated values), collapsing such complex elements of this list as C{["BODY", ["HEADER.FIELDS", ["SUBJECT"]]]} into a single object would also greatly simplify the implementation of this method. @return: A C{dict} of the response data represented by C{pairs}. Keys in this dictionary are things like C{"RFC822.TEXT"}, C{"FLAGS"}, or C{("BODY", ("HEADER.FIELDS", ("SUBJECT",)))}. Values are entirely dependent on the key with which they are associated, but retain the same structured as produced by L{parseNestedParens}. ct|tr|dSt|trfd|DSdS)Nr c&g|] }|Sr>r>)rGsubthingnativeStringResponses rBrJzNIMAP4Client._parseFetchPairs..nativeStringResponse..qs%MMM8,,X66MMMrD)rZrrr[)thingrVs rBrVz:IMAP4Client._parseFetchPairs..nativeStringResponsemsa%'' N||I...E4(( NMMMMuMMMM N NrDTsNot enough arguments)BODYs BODY.PEEKFrrc,g|]}t|Sr>rrGrs rBrJz0IMAP4Client._parseFetchPairs..s<<<\!__<<rrZs rBrJz0IMAP4Client._parseFetchPairs..s C C CQa C C CrDr;<>r)rhrprsrrZr[rr9rtrrrrrg) r_fetchResponseListr\ unstructured responsePartsrori hasSection valueHead valueTailrVs @rBr~zIMAP4Client._parseFetchPairsGsdL N N N N N  .// b  =))      X]++  X X X+,CEVWWW X4111# t,, "# Ua"  ":eAh55 "# " s##C    $ $ $# u::>><???E),<,< =>C //EE$//1B ##D))ennT.B.BE!B$K((( !-U 3 3$++E222!UHn$($7$7EE,"7 79J##&)(//E    & & &F3KEb H|##sA, ::AA)FF-I H--I IIc|\}}i}|D]u}t|dkr`|ddkrT||d|}||vr |dg||<N||d|dvi} i} |D]|\} } || d\} }| | ggd|| | i| }| }i}t| D]} | | } t| D]x}||vrr|dkrl| d|| <tt|| dD]0}|| d|dkr|| d||dz=n1| d=| s| | =y|r| ||r| S|S)NrXr;rrrr}) rrr|rr~rupdater[r&rr)r_rxrequestedParts structuredrreinforarro decodedInfo messageIdr\ structuredMapunstructuredList flagChangesrrjs rB_cbFetchzIMAP4Client._cbFetchsN  1 1E5zzQ58x#7#7%%eAh66T>> %azDHHHQK&&uQx000 !% D D Iv.2.C.CF1I.N.N +M+  " "9rd 3 3A 6 = =>N O O O   y" - - 4 4] C C C C gllnn-- / /IY'FV[[]]++ / /~--$'//-3G_K *"3tIq'9#:#:;;"" ?1-a0G;; $Y 21q1u9 =!E<w!/#I. /  +   k * * *  NKrDc d} |d} nMt|trt|} n(dt t|} |d} n | rd|z} n|} | r"|dvr|dd|z} nd} nd} |d} nd ||fz} |rd pd }| ||rd pd| | | | fz}|d }|t||d}||j dd|S)a^ Retrieve a specific section of one or more messages @type messages: L{MessageSet} or L{str} @param messages: A message sequence set @type uid: L{bool} @param uid: Indicates whether the message sequence set is of message numbers or of unique message IDs. @type headerType: L{str} @param headerType: If specified, must be one of HEADER, HEADER.FIELDS, HEADER.FIELDS.NOT, MIME, or TEXT, and will determine which part of the message is retrieved. For HEADER.FIELDS and HEADER.FIELDS.NOT, C{headerArgs} must be a sequence of header names. For MIME, C{headerNumber} must be specified. @type headerNumber: L{int} or L{int} sequence @param headerNumber: The nested rfc822 index specifying the entity to retrieve. For example, C{1} retrieves the first entity of the message, and C{(2, 1, 3}) retrieves the 3rd entity inside the first entity inside the second entity of the message. @type headerArgs: A sequence of L{str} @param headerArgs: If C{headerType} is HEADER.FIELDS, these are the headers to retrieve. If it is HEADER.FIELDS.NOT, these are the headers to exclude from retrieval. @type peek: C{bool} @param peek: If true, cause the server to not set the \Seen flag on this message as a result of this command. @type offset: L{int} @param offset: The number of octets at the beginning of the result to skip. @type length: L{int} @param length: The number of octets to retrieve. @rtype: L{Deferred} @return: A deferred whose callback is invoked with a mapping of message numbers to retrieved data, or whose errback is invoked if there is an error. z%s BODY%s[%s%s%s]%sNr.)z HEADER.FIELDSzHEADER.FIELDS.NOTz (%s)rz ()z<%d.%d> UID FETCHrz.PEEKr rrr>F) rZrrrrtrWrrrprn)r_rkri headerType headerNumber headerArgspeekoffsetlengthfmtnumberrpayloadextrarrbrs rB fetchSpecificzIMAP4Client.fetchSpecificsTn$  FF  c * * 6&&FFXXc#|4455F  FF  :%FFF  j$JJJ%!CHHZ$8$88G >EE 00E$ 0Xt/52vvwPUVVjj##   WUCkJJJ K K dmR///rDc t|d}|rdpd}d|vr|d=d|d<d|vr|d=d|d<d |vr|d =d|d <d |D}|d zd d|Dzdz}|t ||d}||jd|Dd|S)NrgrqrrFT rfc822.textrJ rfc822.sizerC rfc822.headerc,g|]}t|Sr>r9r7s rBrJz&IMAP4Client._fetch..rs 888Q a((888rDrrc6g|]}|Sr>r^r7s rBrJz&IMAP4Client._fetch..ss +L+L+L!AGGII+L+L+LrDrrrrc6g|]}|Sr>r)rGr{s rBrJz&IMAP4Client._fetch..vs %F%F%FAaggii%F%F%FrD)rrWrrrrprnr&)r_rkr-termsr encodedTermsrbrs rBr/zIMAP4Client._fetchasx==''00'<38 5 l##'E- 5 l##'E- U " "n%%)E/ " 98%888 +L+L|+L+L+L!M!MMPTT   WUCkJJJ K K dm%F%F%F%F%FMMMrDc4||d|||S)a  Set the flags for one or more messages. This command is allowed in the Selected state. @type messages: L{MessageSet} or L{str} @param messages: A message sequence set @type flags: Any iterable of L{str} @param flags: The flags to set @type silent: L{bool} @param silent: If true, cause the server to suppress its verbose response. @type uid: L{bool} @param uid: Indicates whether the message sequence set is of message numbers or of unique message IDs. @rtype: L{Deferred} @return: A deferred whose callback is invoked with a list of the server's responses (C{[]} if C{silent} is true) or whose errback is invoked if there is an error. r_storer_rkrrris rBsetFlagszIMAP4Client.setFlagsys2{{8XvucBBBrDc4||d|||S)a Add to the set flags for one or more messages. This command is allowed in the Selected state. @type messages: C{MessageSet} or L{str} @param messages: A message sequence set @type flags: Any iterable of L{str} @param flags: The flags to set @type silent: C{bool} @param silent: If true, cause the server to suppress its verbose response. @type uid: C{bool} @param uid: Indicates whether the message sequence set is of message numbers or of unique message IDs. @rtype: L{Deferred} @return: A deferred whose callback is invoked with a list of the server's responses (C{[]} if C{silent} is true) or whose errback is invoked if there is an error. s+FLAGSrrs rBaddFlagszIMAP4Client.addFlags2{{8YsCCCrDc4||d|||S)a Remove from the set flags for one or more messages. This command is allowed in the Selected state. @type messages: L{MessageSet} or L{str} @param messages: A message sequence set @type flags: Any iterable of L{str} @param flags: The flags to set @type silent: L{bool} @param silent: If true, cause the server to suppress its verbose response. @type uid: L{bool} @param uid: Indicates whether the message sequence set is of message numbers or of unique message IDs. @rtype: L{Deferred} @return: A deferred whose callback is invoked with a list of the server's responses (C{[]} if C{silent} is true) or whose errback is invoked if there is an error. s-FLAGSrrs rB removeFlagszIMAP4Client.removeFlagsrrDclt|d}d|D}|r|dz}|rdpd}d||dd|zdzf}|t ||d } d } |sd } | |j| d | S)Nrgc,g|]}t|Sr>r9r:s rBrJz&IMAP4Client._store..rrDs.SILENTs UID STORErrrrrrrr>)r}T)rrWrrrrprn) r_rkrbrrrirrrrexpecteds rBrzIMAP4Client._storesx==''00>>>>>  # "C$ 0yy(C ,0G0G)G$)NOPP   WUD{KKK L L "!H dmXt444rDct|d}|rd}nd}d|t|g}|t ||S)a Copy the specified messages to the specified mailbox. This command is allowed in the Selected state. @type messages: L{MessageSet} or L{str} @param messages: A message sequence set @type mailbox: L{str} @param mailbox: The mailbox to which to copy the messages @type uid: C{bool} @param uid: If true, the C{messages} refers to message UIDs, rather than message sequence numbers. @rtype: L{Deferred} @return: A deferred whose callback is invoked with a true value when the copy is successful, or whose errback is invoked if there is an error. rgsUID COPYrr)rrWrrrr)r_rkr}rirbrs rBrzIMAP4Client.copysn*x==''00  CCCyy($7$@$@ABBT 2 2333rDcdSz Override meNr>rs rBrzIMAP4Client.modeChangedrrDcdSrr>)r_rs rBrzIMAP4Client.flagsChangedrrDcdSrr>rs rBrzIMAP4Client.newMessagesrrDrvr;)r>Nr)rNNNNNN)r;r)irrrrr-rurFrhrAr(r8rrrG STATUS_CODESrrrHrbrNrHrXr2r6rKrCr_rVrir_rlrsrqrwrvrrrprrrrrrrrrrrorrrrrrrr+rrrrPrVr]rbrfr[rrr rr rtrrr|r>rr$rr(r1r3r6r9r<r>rArDrGrKrMrOrQr~rnr}r/rrrrrrrrr>rDrBr<r<n ss DG F E EJG I'N8L*-LLG ; ; ;555.***...$(,(,(,T ( ( ((((  , , ,,,,.(((###8---8   2*       1111f"8 5 5 5KKK2   ...===2 999*6'''R,,,\ 0 0 0777r O O O O O OSSS( R R R T T T!!!F86      L!!!F.....`    3 3 3333 *$)88888(::::(AAAA*====:BBBB:9999,;;;;0AAAA(????(????(    @    2XXXX.T$T$T$l(((Z  XXXXt0CCCC6DDDD6DDDD6   444@rDr<ct}|d}|D])}d|vr|dd\}} |dkrd}nt|}|dkrd}nt|}||cxurnnt|||dks||dkrt||p|}|p|}|||#t $rt|wxYw |dkrd}nt|}||dkrt|||p|#t $rt|wxYw|S)a Parse a message set search key into a C{MessageSet}. @type s: L{bytes} @param s: A string description of an id list, for example "1:3, 4:*" @type lastMessageId: L{int} @param lastMessageId: The last message sequence id or UID, depending on whether we are parsing the list in UID or sequence id context. The caller should pass in the correct value. @rtype: C{MessageSet} @return: A C{MessageSet} that contains the ids defined in the list ,:r;rNr)rNr\rrr]rgr|)rrryrarrkrls rBrrs ,,C GGDMME $/$/ 199a((IC 0$;;CCc((C4<<DDt99D$&&&&&&&&0333Oqd6F4ST990333,}*]T"""" 0 0 0,Q/// 0 /99AAAA=Q!VV0333 1- .... 0 0 0,Q/// 0 JsBCC(,/D44E)ALLANSWEREDDELETEDDRAFTFLAGGEDNEWOLDrCSEEN UNANSWERED UNDELETEDUNDRAFT UNFLAGGEDrD)LARGERSMALLERUIDc g}|}|rt|}|D]f}||}|}|tvr|r||@|dkr?||t |dt |dg|dks|dkr3td|}|||g|tvrOt|trd}nt|t rd}nd}||||fzgt|tr||d |fzgN|||ght|dkrd d |zd zSd |S) a Create a query string Among the accepted keywords are:: all : If set to a true value, search all messages in the current mailbox answered : If set to a true value, search messages flagged with \Answered bcc : A substring to search the BCC header field for before : Search messages with an internal date before this value. The given date should be a string in the format of 'DD-Mon-YYYY'. For example, '03-Mar-2003'. body : A substring to search the body of the messages for cc : A substring to search the CC header field for deleted : If set to a true value, search messages flagged with \Deleted draft : If set to a true value, search messages flagged with \Draft flagged : If set to a true value, search messages flagged with \Flagged from : A substring to search the From header field for header : A two-tuple of a header name and substring to search for in that header keyword : Search for messages with the given keyword set larger : Search for messages larger than this number of octets messages : Search only the given message sequence set. new : If set to a true value, search messages flagged with \Recent but not \Seen old : If set to a true value, search messages not flagged with \Recent on : Search messages with an internal date which is on this date. The given date should be a string in the format of 'DD-Mon-YYYY'. For example, '03-Mar-2003'. recent : If set to a true value, search for messages flagged with \Recent seen : If set to a true value, search for messages flagged with \Seen sentbefore : Search for messages with an RFC822 'Date' header before this date. The given date should be a string in the format of 'DD-Mon-YYYY'. For example, '03-Mar-2003'. senton : Search for messages with an RFC822 'Date' header which is on this date The given date should be a string in the format of 'DD-Mon-YYYY'. For example, '03-Mar-2003'. sentsince : Search for messages with an RFC822 'Date' header which is after this date. The given date should be a string in the format of 'DD-Mon-YYYY'. For example, '03-Mar-2003'. since : Search for messages with an internal date that is after this date.. The given date should be a string in the format of 'DD-Mon-YYYY'. For example, '03-Mar-2003'. smaller : Search for messages smaller than this number of octets subject : A substring to search the 'subject' header for text : A substring to search the entire message for to : A substring to search the 'to' header for uid : Search only the messages in the given message set unanswered : If set to a true value, search for messages not flagged with \Answered undeleted : If set to a true value, search for messages not flagged with \Deleted undraft : If set to a true value, search for messages not flagged with \Draft unflagged : If set to a true value, search for messages not flagged with \Flagged unkeyword : Search for messages without the given keyword set unseen : If set to a true value, search for messages not flagged with \Seen @type sorted: C{bool} @param sorted: If true, the output will be sorted, alphabetically. The standard does not require it, but it makes testing this function easier. The default is zero, and this should be acceptable for any application. @rtype: L{str} @return: The formatted query string HEADERrr;KEYWORD UNKEYWORDrz"%s"z"%d"z%drr))r&_sortedr^ _SIMPLE_BOOLrtr|r _nonAtomRErm _NO_QUOTESrZrNrrr)rpkwargrbr&rrrys rBQueryrQs\ C ::<)rs rBNotrs 5   rDc|dd}||dd}n+|ddtj|z}tj|tjS)Nrz(?:.*?)%z(?:(?:[^%s])*?))replacerrrI)rrws rBwildcardToRegexprslY//H }##C33##C):RYu=M=M)MNN :h % %%rDc6|}g}g}dx}}td|}td|}td|}td|}tt|D]E\} } | |kro| r;|| dz | |kr*|||I|sd}Nd}|||g}{|s>|s<| |tj dzvrd}|| |ro|sm| tj dvrL||} | |kr|d n|| g}d},|s|r|| G|rt||rF||} | |kr|d n|| |S) a Split a string into whitespace delimited tokens Tokens that would otherwise be separated but are surrounded by " remain as a single token. Any token that is not quoted and is equal to "NIL" is tokenized as L{None}. @type s: L{bytes} @param s: The string to be split @rtype: L{list} of L{bytes} @return: A list of the resulting tokens @raise MismatchedQuoting: Raised if an odd number of quotes are present Fr\rNILr;TrgN) rr7rhr8rLrtrstring whitespacerWr!) rrxwordinQuoteinWordquescrnilrjrws rB splitQuotedrsC  A F DGf a B &! $ $C B " "E % # #C)A,,''1 77 Qq1uqy\S((  B  ejj..///  " 1 8 8 A ABCCF KKNNNN  G V->-E-Eg-N-N(N(N 4  ACxx d#### a   DFF  w  KKNNN#"""  JJt   88 MM$     MM!    MrDc@g}||d}|dg}|ddD]R}||}||kr*|||||g}|}=||S|||||SNrr;)r|rt)sequence predicate transformersrxrtmprVrs rBsplitOnr=s F 9Xa[ ! !D A;-C abb\ IaLL 99 MM,,t,S11 2 2 2#CDD JJqMMMM MM$,t$S))*** MrDcbg}d}d}ddd}t|D]g\}}t|trI|)|jt |||||d}|jt |c||}h|'|jt ||d|||S)a{ Turns a list of length-one strings and lists into a list of longer strings and lists. For example, ['a', 'b', ['c', 'd']] is returned as ['ab', ['cd']] @type results: L{list} of L{bytes} and L{list} @param results: The list to be collapsed @rtype: L{list} of L{bytes} and L{list} @return: A new list which is the collapsed form of C{results} Nc,t|tSrv)rZrrVs rBrVz!collapseStrings..]sZ5))rDcFtd|Sr)rrrs rBrVz!collapseStrings.._s[!--rDcBdd|DgS)NrDcg|] }|d Srr>rs rBrJz5collapseStrings....`s000!000rD)rrs rBrVz!collapseStrings..`s$chh00a000112rD)rr;)rhrZr[r|rrtcollapseStrings)rorbegunpredtranrjrs rBrrMs D E ) )D - - 2 2  D'""1 a     GGE!G$4dDAABBB DK** + + + + ]E  GGEFFOT488999 KrDc^|}d}gg} d}t|}||kr|||dz}|r]|dkr,|d|||dz|dz }H|dkr| }|d||dz }n4|dkr%|d|| }|dz }n |r|dkr{|d|}|dkrt d t ||dz|}|d||d z|d z|zf|d z|z}n|d ks|d kr|g|dz }n_|d ks|dkr3|d||dz }n |d||dz }||kn#t$rt|wxYwt|dkrt|t|dS)ak Parse an s-exp-like string into a more useful data structure. @type s: L{bytes} @param s: The s-exp-like string to parse @rtype: L{list} of L{bytes} and L{list} @return: A list containing the tokens present in the input. @raise MismatchedNesting: Raised if the number or placement of opening or closing parenthesis is invalid. rr;rrrrrrrrXrr?rrn) rrrtrrgrrL IndexErrorr r) r handleLiteralr contentStackrjrrra literalSizes rBrros  AG4L$#  FF!ee!a!e) A :: $++Aa!a%iL999FA$YY")kGR ''***Q99 $++A...")kGFAA"qDyy&&q//Cbyy()<==="%aA n"5"5K $++QsQwq;9N/N-O,QRRRa+-AA$YY!t)) ''+++FAA$YY!t)) $++L,<,<,>,>???FAA $++A...FA?!ee@ ###"""# <A""" <? + ++s F?GG5ctd|}td|}|||||z|||zz|zS)Nrr)r7r)rrrs rBrrsV a B &! $ $C  #sSy))11"cBh?? ?" DDrDrrc*dt||fzS)Ns{%d} %b)rrs rBrrs CFFA; &&rDc eZdZdZdefdZdS)rsc||_dSrv)ri)r_ris rBrbzDontQuoteMe.__init__s  rDrc*t|jSrv)rrirds rBrzDontQuoteMe.__str__s4:rDN)rrrrbrrr>rDrBrsrss>rDrss(){ %*"cp|dkrdSt|D]}|dks|dkrdS|tvrdSdS)NrDr;rr)r8_ATOM_SPECIALS)rrs rB _needsQuotersYCxxq q\\ w;;!g++11   11  1rDct|tr|S |dS#t$r#t jt |wxYw)NrU)rZrrrQr5r@rr.s rBr*r*sd$ +{{=))) +++  $T***+s .-Act|ts|d}|d}t |rt |S|S)Nr rU)rZrrrWrrrs rBrrsW dC &{{9%% ;;} % %D4d|| KrDcxtd|}td|}||vp||vpt|dkS)N  i)r7r)rcrlfs rB _needsLiteralrsB q ! !B q ! !B 7 .bAg .Q$.rDc g}|D]}t|tr|d}||ddgGt|tr2|dt t|gt|t r|d|jgt|trkt|r6|ddt|fztj |g|dt|g@t|drJ|}|ddt|fztj |g|ddt!|zdzgd |d dS) a Turn a nested list structure into an s-exp-like string. Strings in C{items} will be sent as literals if they contain CR or LF, otherwise they will be quoted. References to None in C{items} will be translated to the atom NIL. Objects with a 'read' attribute will have it called on them with no arguments and the returned string will be inserted into the output as a literal. Integers will be converted to strings and inserted into the output unquoted. Instances of C{DontQuoteMe} will be converted to strings and inserted into the output unquoted. This function used to be much nicer, and only quote things that really needed to be quoted (and C{DontQuoteMe} did not exist), however, many broken IMAP4 clients were unable to deal with this level of sophistication, forcing the current behavior to be adopted for practical reasons. @type items: Any iterable @rtype: L{str} rgNrsNILs{%d}rSrrrDr;)rZrrWr|rr:rsrirrrr delimiterrhasattrrSr#r)rpiecesrjrs rBr#r#s,F HH a   "!!A 9 MM4. ) ) ) ) 3   H MM4s1vv!6!67 8 8 8 8 ; ' ' H MM4/ * * * * 5 ! ! HQ 1 tWAy%8+:OQRSTTTT tVAYY/0000 Q   HA MM4CFF9!4k6KQO P P P P MM4(;A(>(>!>!EF G G G G 88F122J  rDcleZdZdZdZdZdZdZddZdZ dZ dd Z d Z d Z d Zd ZdZdZdZdS)MemoryAccountWithoutNamespacesNrc0||_i|_g|_dSrv)r.ru subscriptionsrs rBrbz'MemoryAccountWithoutNamespaces.__init__s rDc4|j}|xjdz c_|SrS)top_id)r_rs rB allocateIDz)MemoryAccountWithoutNamespaces.allocateIDs [ q  rDct|}||jvrt||(|||}||j|<dSrS)r*r^rur _emptyMailboxr)r_r.r;s rB addMailboxz)MemoryAccountWithoutNamespaces.addMailbox'sg$**,,'' 4> ! !"4(( ( <%%dDOO,=,=>>D#tqrDcd|dD}tdt|D]C} |d|d|4#t $rY@wxYw |d|n(#t $r|dsYdSYnwxYwdS)Ncg|]}||Sr>r>)rGpaths rBrJz9MemoryAccountWithoutNamespaces.create..1s>>>$>>>>rD/r;FT)r\rrrrrr)r_pathspecpathsaccums rBrPz%MemoryAccountWithoutNamespaces.create0s>>(.."5"5>>>1c%jj))  E vv 7 78888#      OOCHHUOO , , , ,   $$S)) uu   ts$0A11 A>=A>(B++CCctrv)NotImplementedError)r_r.rs rBrz,MemoryAccountWithoutNamespaces._emptyMailbox>s!!rDr;ct|jt|Srv)rurr*r^)r_r. readwrites rBr+z%MemoryAccountWithoutNamespaces.selectAs(~!!*TZZ\\":":;;;rDct|}|j|}|st dd|vrF|jD],}||kr$||rt d-|t| |dkrt d|d|j|=dS)NzNo such mailboxz \Noselectz>f&7&7&=&=>*W  t""4(( ) )A - -"#SD#S#S#STT T N4 rDctt|jvrt|}fd|D}|D]\}}||jvrt ||D]"\}}|j||j|<|j|=#dS)NcBg|]}||dfSr)r)rGor_r^s rBrJz9MemoryAccountWithoutNamespaces.rename..bs.LLLQa7GQ778LLLrD)r*r^rur#rr)r_r^r_ inferiorsoldnews `` rBr]z%MemoryAccountWithoutNamespaces.rename[sW]]__--W]]__-- $. ( ((( (''00 LLLLL)LLL ! , ,HCdn$$&s+++%" $ $HC"&."5DN3 s## $ $rDcg}|jD],}||r||-|Srv)rur&rrt)r_r.rinfnames rBrz-MemoryAccountWithoutNamespaces._inferiorNameslsU ~**,, * *G!!$'' *  )))rDcRt||jvSrv)r*r^rrs rBrqz+MemoryAccountWithoutNamespaces.isSubscribedss $**,,''4+===rDct|}||jvr|j|dSdSrv)r*r^rrtrs rBrbz(MemoryAccountWithoutNamespaces.subscribevsJ$**,,'' t) ) )   % %d + + + + + * )rDct|}||jvrtd||j|dS)NzNot currently subscribed to )r*r^rrremovers rBrfz*MemoryAccountWithoutNamespaces.unsubscribe{sY$**,,'' t) ) )"#H$#H#HII I !!$'''''rDct|}tdfd|DS)Nr cXg|]&}||j|f'Sr>)rru)rGrjr_rs rBrJz@MemoryAccountWithoutNamespaces.listMailboxes..s6III1x~~a7H7HIDN1%&IIIrD)rr*r^r)r_rlrs` `rBriz,MemoryAccountWithoutNamespaces.listMailboxessS!!*SYY[["9"9::#Hc22IIIIIIIIIrDrvr)rrrrurrrbrrrPrr+rVr]rrqrbrfrir>rDrBrrsIM F      """<<<<!!!.$$$">>>,,, ((( JJJJJrDrc&eZdZdZdZdZdZdS) MemoryAccountc ddggS)NrD/r>rds rBr!z#MemoryAccount.getPersonalNamespacessd }rDcdSrvr>rds rBr"z!MemoryAccount.getSharedNamespacestrDcdSrvr>rds rBgetOtherNamespacesz MemoryAccount.getOtherNamespacesr)rDcdSrvr>rds rBgetUserNamespaceszMemoryAccount.getUserNamespacesstrDN)rrrr!r"r+r-r>rDrBr%r%sP rDr%rArB getUIDNextrCgetUnseenCountrci}|D]:}t|t|||<;|Srv)rQ_statusRequestDictr^)r;rrr\s rBstatusRequestHelperr3sF A >>;wt/ :;;==! HrDcd|dgStj|g}d|DS)NrcLg|]!\}}|pddg|dz"S)N@r\)rGrjaddresss rBrJzparseAddr..s6 L L L GRZ4 s!3!3 3 L L LrD)rr getaddresses)addrs rB parseAddrr;sA |    ; # #TF + +D L Lt L L LLrDc |d}|d}|d}|d}|d|}|d|}|d}|d}|d } |d } |d } ||t|t||ot||ot||ot|| ot| | | f S) NTrrMrsenderzreply-torSrrz in-reply-toz message-id)rrr;) rheadersrrMfrom_r=reply_torSrr in_reply_tomids rBryrys'nnT""G ;;v  Dkk)$$G KK  E [[5 ) )F{{:u--H T  B T  B ++e  C++m,,K ++l # #C %&(Yx(( y}} y}}  #   rDcBd}|D]}|dz }|Sr)r )rrrms rB getLineCountrDs2 E __     LrDcR|d|dcxkrdkr nn |ddS|S)Nrrrr;r>rs rBunquoterFs>tqu2w HrDcd}|dddd}d|}|rv|d}|ddd}t |dkr |d}d}n|\}}t d |ddD}ndx}}|||fS) zJ Return a two-tuple of the main and subtype of the given message. NF content-typer;rr r;c3K|]>}|ddV?dS)=r;N)rr6r\rs rBrz"_getContentType..sDKKQWWYY__&&,,S!44KKKKKKrD)rrr splitlinesr\rdict)rattrsmmmimetypermajorminors rB_getContentTyperSs E ~ . . 2 2>2 F FB  ! !B 88C=={  a(( t99>>GEEE LE5KKhqrrlKKKKK % rDc6t|\}}}||}||}|dkrt|||S||fdkrt||||S|dkrt ||||St ||||S)aE Construct an appropriate type of message structure object for the given message object. @param message: A L{IMessagePart} provider @return: A L{_MessageStructure} instance of the most specific type available for the given message, determined by inspecting the MIME type of the message. N multipart)rr@r6)rSr6_MultipartMessageStructure_RFC822MessageStructure_TextMessageStructure_SinglepartMessageStructure)rmainsubtyperNs rB_getMessageStructurer\s+733D'5 zz||--// {)'7EBBB 1 1 1&wguEEE $WdGUCCC*7D'5IIIrDc$eZdZdZdZdZdZdS)_MessageStructurez L{_MessageStructure} is a helper base class for message structure classes representing the structure of particular kinds of messages, as defined by their MIME type. c"||_||_dS)z @param message: An L{IMessagePart} provider which this structure object reports on. @param attrs: A C{dict} giving the parameters of the I{Content-Type} header of the message. N)rrN)r_rrNs rBrbz_MessageStructure.__init__s  rDc|r|d}t|dkr|ddf}nCt|dkr0d|ddD}|d|g}|SdS)a Parse a I{Content-Disposition} header into a two-sequence of the disposition and a flattened list of its parameters. @return: L{None} if there is no disposition header value, a L{list} with two elements otherwise. z; r;rNcDg|]}|ddD]}|SrKr;r7)rGparamrUs rBrJz2_MessageStructure._disposition..,s3OOO5;;sA;N;NOOa!OOOOrD)r\rr6)r_dispparamss rB _dispositionz_MessageStructure._dispositions  ::d##D4yyA~~Q .TQOOabbOOOQ 0K4rDc|jr)rFrGrrs rBrJz4_MessageStructure._unquotedAttrs..9s&IIIFQGAJJIIIrDcg|] }|D]}| Sr>r>)rGrUys rBrJz4_MessageStructure._unquotedAttrs..:s%;;;!;;AA;;;;rDN)rNrrp)r_unquoteds rB_unquotedAttrsz _MessageStructure._unquotedAttrs2sP : <IIdj6F6F6H6HIIIH;;vh//;;; ;trDN)rrrrrbrfrmr>rDrBr^r^ sK   (     rDr^c2eZdZdZgdZdZdZdZdZdS)rYzn L{_SinglepartMessageStructure} represents the message structure of a non-I{multipart/*} message. ) content-idcontent-descriptioncontent-transfer-encodingcht|||||_||_||_dS)a @param message: An L{IMessagePart} provider which this structure object reports on. @param main: A L{str} giving the main MIME type of the message (for example, C{"text"}). @param subtype: A L{str} giving the MIME subtype of the message (for example, C{"plain"}). @param attrs: A C{dict} giving the parameters of the I{Content-Type} header of the message. N)r^rbrZr[rN)r_rrZr[rNs rBrbz$_SinglepartMessageStructure.__init__Fs5 ""4%888   rDc,|jjdg|jR}|j}|j|j}}|}||||d|d|d|gS)zN Return a list of the basic fields for a single-part message. Frorprq)rr_HEADERSr(rZr[rmr)r_r>rrQrR unquotedAttrss rB _basicFieldsz(_SinglepartMessageStructure._basicFieldsYs*$,)%@$-@@@|##%%y$,u++--     KK % % KK- . . KK3 4 4   rDc|}|r'|||S)z Construct and return a list of the basic and extended fields for a single-part message. The list suitable to be encoded into a BODY or BODYSTRUCTURE response. )rvr| _extendedr_extendedrxs rBrWz"_SinglepartMessageStructure.encodeqs> ""$$  , MM$..** + + + rDcg}|jddddd}||d|||d||d||d|S)aw The extension data of a non-multipart body part are in the following order: 1. body MD5 A string giving the body MD5 value as defined in [MD5]. 2. body disposition A parenthesized list with the same content and function as the body disposition for a multipart body part. 3. body language A string or parenthesized list giving the body language value as defined in [LANGUAGE-TAGS]. 4. body location A string list giving the body content URI as defined in [LOCATION]. Fz content-md5content-dispositioncontent-languagecontent-location)rrrtrrfr_rxr>s rBrxz%_SinglepartMessageStructure._extended|s2,))   !       gkk-00111 d'' 4I(J(JKKLLL gkk"455666 gkk"455666 rDN) rrrrrtrbrvrWrxr>rDrBrYrY>sh RQQH&   0   '''''rDrYceZdZdZdZdS)rXz_ L{_TextMessageStructure} represents the message structure of a I{text/*} message. ct|}|t|j|r'|||S)a A body type of type TEXT contains, immediately after the basic fields, the size of the body in text lines. Note that this size is the size in its content transfer encoding and not the resulting size after any decoding. )rYrvrtrDrr|rxrys rBrWz_TextMessageStructure.encodes\-99$?? l4<00111  , MM$..** + + + rDNrrrrrWr>rDrBrXrXs-     rDrXceZdZdZdZdS)rWzi L{_RFC822MessageStructure} represents the message structure of a I{message/rfc822} message. c>t||}|jd}|t ||t |d|t||S)z A body type of type MESSAGE and subtype RFC822 contains, immediately after the basic fields, the envelope structure, body structure, and size in text lines of the encapsulated message. rF)rYrWrrrtryrrD)r_rzrx containeds rBrWz_RFC822MessageStructure.encodes-33D(CCL++A..  k),,--- &y%88999 l9--... rDNrr>rDrBrWrWs-     rDrWc*eZdZdZdZdZdZdZdS)rVzi L{_MultipartMessageStructure} represents the message structure of a I{multipart/*} message. cLt|||||_dS)aR @param message: An L{IMessagePart} provider which this structure object reports on. @param subtype: A L{str} giving the MIME subtype of the message (for example, C{"plain"}). @param attrs: A C{dict} giving the parameters of the I{Content-Type} header of the message. N)r^rbr[)r_rr[rNs rBrbz#_MultipartMessageStructure.__init__s' ""4%888 rDc#zKd} |j|}|V|dz }n#t$rYdSwxYw7)zR Return an iterator over all of the sub-messages of this message. rTr;N)rrr)r_rjrs rB _getPartsz$_MultipartMessageStructure._getPartssk   |..q11 Q      s + 99cfd|D}||jr'|||S)zW Encode each sub-message and added the additional I{multipart} fields. cTg|]$}t|%Sr>r\rW)rGrrzs rBrJz5_MultipartMessageStructure.encode..s0UUUq&q))00::UUUrD)rrtr[r|rxrys ` rBrWz!_MultipartMessageStructure.encodesfVUUUDNNDTDTUUU dl###  , MM$..** + + + rDcg}|jdddd}|||||d||dd||dd|S)af The extension data of a multipart body part are in the following order: 1. body parameter parenthesized list A parenthesized list of attribute/value pairs [e.g., ("foo" "bar" "baz" "rag") where "bar" is the value of "foo", and "rag" is the value of "baz"] as defined in [MIME-IMB]. 2. body disposition A parenthesized list, consisting of a disposition type string, followed by a parenthesized list of disposition attribute/value pairs as defined in [DISPOSITION]. 3. body language A string or parenthesized list giving the body language value as defined in [LANGUAGE-TAGS]. 4. body location A string list giving the body content URI as defined in [LOCATION]. Fr}r~r|N)rrrtrmrfrrs rBrxz$_MultipartMessageStructure._extendeds,,)) %'9;P    d))++,,, d'' 4I(J(JKKLLL gkk"4d;;<<< gkk"4d;;<<< rDN)rrrrrbrrWrxr>rDrBrVrVsZ           rDrVFcFt||S)ar RFC 3501, 7.4.2, BODYSTRUCTURE:: A parenthesized list that describes the [MIME-IMB] body structure of a message. This is computed by the server by parsing the [MIME-IMB] header fields, defaulting various fields as necessary. For example, a simple text message of 48 lines and 2279 octets can have a body structure of: ("TEXT" "PLAIN" ("CHARSET" "US-ASCII") NIL NIL "7BIT" 2279 48) This is represented as:: ["TEXT", "PLAIN", ["CHARSET", "US-ASCII"], None, None, "7BIT", 2279, 48] These basic fields are documented in the RFC as: 1. body type A string giving the content media type name as defined in [MIME-IMB]. 2. body subtype A string giving the content subtype name as defined in [MIME-IMB]. 3. body parameter parenthesized list A parenthesized list of attribute/value pairs [e.g., ("foo" "bar" "baz" "rag") where "bar" is the value of "foo" and "rag" is the value of "baz"] as defined in [MIME-IMB]. 4. body id A string giving the content id as defined in [MIME-IMB]. 5. body description A string giving the content description as defined in [MIME-IMB]. 6. body encoding A string giving the content transfer encoding as defined in [MIME-IMB]. 7. body size A number giving the size of the body in octets. Note that this size is the size in its transfer encoding and not the resulting size after any decoding. Put another way, the body structure is a list of seven elements. The semantics of the elements of this list are: 1. Byte string giving the major MIME type 2. Byte string giving the minor MIME type 3. A list giving the Content-Type parameters of the message 4. A byte string giving the content identifier for the message part, or None if it has no content identifier. 5. A byte string giving the content description for the message part, or None if it has no content description. 6. A byte string giving the Content-Encoding of the message body 7. An integer giving the number of octets in the message body The RFC goes on:: Multiple parts are indicated by parenthesis nesting. Instead of a body type as the first element of the parenthesized list, there is a sequence of one or more nested body structures. The second element of the parenthesized list is the multipart subtype (mixed, digest, parallel, alternative, etc.). For example, a two part message consisting of a text and a BASE64-encoded text attachment can have a body structure of: (("TEXT" "PLAIN" ("CHARSET" "US-ASCII") NIL NIL "7BIT" 1152 23)("TEXT" "PLAIN" ("CHARSET" "US-ASCII" "NAME" "cc.diff") "<960723163407.20117h@cac.washington.edu>" "Compiler diff" "BASE64" 4554 73) "MIXED") This is represented as:: [["TEXT", "PLAIN", ["CHARSET", "US-ASCII"], None, None, "7BIT", 1152, 23], ["TEXT", "PLAIN", ["CHARSET", "US-ASCII", "NAME", "cc.diff"], "<960723163407.20117h@cac.washington.edu>", "Compiler diff", "BASE64", 4554, 73], "MIXED"] In other words, a list of N + 1 elements, where N is the number of parts in the message. The first N elements are structures as defined by the previous section. The last element is the minor MIME subtype of the multipart message. Additionally, the RFC describes extension data:: Extension data follows the multipart subtype. Extension data is never returned with the BODY fetch, but can be returned with a BODYSTRUCTURE fetch. Extension data, if present, MUST be in the defined order. The C{extended} flag controls whether extension data might be returned with the normal data. r)rrzs rBrrs!R  $ $ + +H 5 55rDcd|D}d|dz}t|S)Nc g|]S\}}d|d|fTS)z:  )rtitlerLris rBrJz"_formatHeaders..sY    Q 17799fkk!,,..99:;;   rDr)rrr:)r>rs rBrrsN  mmoo   D ;;t  v %D   rDc#jKd} ||V|dz }#t$rYdSwxYw)NrTr;)rr)rrjs rBsubpartsrs] A  ,,q// ! ! ! FA       s $ 22cfddlmtjfddS)a Consume an interator at most a single iteration per reactor iteration. If the iterator produces a Deferred, the next iteration will not occur until the Deferred fires, otherwise the next iteration will be taken in the next reactor iteration. @rtype: C{Deferred} @return: A deferred which fires (with None) when the iterator is exhausted or whose errback is called if there is an exception. rrcD t}t|tjr|dSd|dS#t $r|YdSt$r YdSwxYwr) rprZrrrprrsrrQr[)rer2rgorjrs rBrziterateInReactor..gos ,QA !U^,, , b!!!!!!!!R+++++    JJt          IIKKKKKK sAB>BBN)rrrr)rjrrrs`@@@rBrrsc)((((( A , , , , , , , ,BtHHH HrDcFeZdZdZeejZddZdZ dZ dS)rNc||_|tj}||_|t}||_|jj|_dS)a Produce this message. @param msg: The message I am to produce. @type msg: L{IMessage} @param buffer: A buffer to hold the message in. If None, I will use a L{tempfile.TemporaryFile}. @type buffer: file-like N)rrrrrr!r)r_rrr!s rBrbzMessageProducer.__init__sG >+--F  (I"[& rDc^||_||Srv)consumerr!_produce)r_rs rBrzMessageProducer.beginProducings#  ~~dmmoo...rDc#6Kjd}d}jr|d}d|dddD}d|D}|d}|1dj}|dxxd |d z cc<n4|d r|d r |dd }t|} t| d jr~tjD]M} d |zd zt|jjdVN d |zdznWj} |j}|rj |dVnn=jrajddt-jjfdVdSdS)NTrHc:g|]}|ddSrbr7rs rBrJz,MessageProducer._produce..s$EEEQWWS!__EEErDrIr;cbi|],\}}||-Sr>)r6rris rBrz,MessageProducer._produce..s0>>>fq!QWWYY__&&>>>rDboundaryz----=z ; boundary="rrrPs --s-- rcSrvr>rs rBrVz*MessageProducer._produce..s$rD)rrrrr\_uuid4hexrrr:rrrrrr!rr rS CHUNK_SIZErrrrp)r_r>rrrarrUr:s` rBrzMessageProducer._produces(%%d++ 8   ! ! /kk.11GEEgmmC.@.@.DEEEE>>>>>Eyy,,H64;;==#466'''+E(+E+E+EE''''&&s++.0A0A#0F0F.'"~H$X..H >'**+++ 7 8   ! ! dh''   9x/'9:::%adnEETT JJy8+i7 8 8 8 8$$&&A FF4?++K%%a(((JJJJ   =  K  Q " " "t{++::4=IIUU       rDr) rrrr staticmethoduuiduuid4rrbrrr>rDrBrrs\J \$* % %F''''(///'''''rDrc eZdZGddZGddZGddZGddZGd d ZGd d ZGd dZ GddZ GddZ GddZ GddZ GddZGddZdZdefdefdefdefd efd!efd"e fd#e fd$e fg Zd%Zd&Zd'Zd(Zd)Zd*Zd+Zd,Zd-Zejd.Zd/Zd0Zd1Z d2Z!d3Z"dS)4rceZdZdZdZdS)_FetchParser.Enveloper8cdS)Nr8r>rds rBrVz_FetchParser.Envelope.szrDNrrrrrr>rDrBEnvelopers))rDrceZdZdZdZdS)_FetchParser.FlagsrcdS)Nrr>rds rBrVz_FetchParser.Flags.swrDNrr>rDrBFlagsrs&&rDrceZdZdZdZdS)_FetchParser.InternalDater5cdS)Nr5r>rds rBrVz"_FetchParser.InternalDate.s~rDNrr>rDrB InternalDaters--rDrceZdZdZdZdS)_FetchParser.RFC822HeaderrCcdS)Nrr>rds rBrVz"_FetchParser.RFC822Header.rDNrr>rDrB RFC822Headerrs..rDrceZdZdZdZdS)_FetchParser.RFC822TextrFcdS)Nrr>rds rBrVz _FetchParser.RFC822Text."}rDNrr>rDrB RFC822Textr ,,rDrceZdZdZdZdS)_FetchParser.RFC822SizerJcdS)Nrr>rds rBrVz _FetchParser.RFC822Size.&rrDNrr>rDrB RFC822Sizer$rrDrceZdZdZdZdS)_FetchParser.RFC822r@cdS)Nr@r>rds rBrVz_FetchParser.RFC822.*sxrDNrr>rDrBRFC822r(s''rDrceZdZdZdZdS)_FetchParser.UIDricdS)Nrir>rds rBrVz_FetchParser.UID..surDNrr>rDrBrr,s$$rDrcJeZdZdZdZdZdZdZdZdZ dZ dZ de fdZ defdZdS)_FetchParser.Bodyr FNr>rcP|dSNrgrrrds rBrz_FetchParser.Body.__str__; >>##**733 3rDcd}d}d}|jr&dd|jD}d}|jr7|d|z|zt|jdzdzz }n>|jr|d|z|zdzz }n(|jr|d|z|zd zz }n|jr |d|zdzz }|j|d |j|j fzz }|S) NrXrD.cXg|]'}t|dzd(S)r;rg)rrWrs rBrJz/_FetchParser.Body.__bytes__..Cs0!P!P!P#a!e**"3"3G"<") rrrrrWr6rr partialBegin partialLength)r_baser separators rBrz_FetchParser.Body.__bytes__>sDDIy !yy!P!Pdi!P!P!PQQ { +4K)+c$+.>.>.E.Eg.N.NNQUU +t i/(:: +t i/(:: +t d** , d&79K%LLLKrD)rrrrrvrrr6rrrrrrrrr>rDrBBodyr0sw   4S 4 4 4 4 u      rDrceZdZdZdZdS)_FetchParser.BodyStructurer;cdS)Nr;r>rds rBrVz#_FetchParser.BodyStructure.WrrDNrr>rDrB BodyStructurerUs..rDrc2eZdZdZdZdZdefdZdefdZ dS)_FetchParser.HeaderFNrcP|dSrrrds rBrz_FetchParser.Header.__str___rrDc~d}|jr|dz }|jr|dz }g}|jD]I}|}t|rt |}||J|dd|zdzz }|jr*dd|jDdz|z}|S) NsHEADERs.FIELDSs.NOTrrrrc<g|]}|dzSr)rrs rBrJz1_FetchParser.Header.__bytes__..rs(!I!I!I!1q5"3"3"5"5!I!I!IrD)rrrrrrtrr)r_rrrUs rBrz_FetchParser.Header.__bytes__bsD{ 9 ";$GOD%%A A"1~~&"1IIMM!$$$$ & 1 11D88y Yyy!I!Ity!I!I!IJJTQTXXKrD) rrrrrrrrrrr>rDrBHeaderrZsY 4S 4 4 4 4 u      rDrceZdZdS)_FetchParser.TextNrrrr>rDrBTextru rDrceZdZdS)_FetchParser.MIMENrr>rDrBMIMErxrrDrNsenvelopesflagss internaldates rfc822.headers rfc822.texts rfc822.sizesrfc822suids bodystructurec2dg|_g|_d|_dS)NinitialrD)rArx remainingrds rBrbz_FetchParser.__init__s[  rDcf|j|z} |s|jr|jstd|j} t |d|z|}||d}n)#t $r|j|wxYw||j||_dS#||_wxYw)NzInvalid Argumentstate_)rrArrLrQrQrt)r_rrAuseds rBrz_FetchParser.parseStrings NQ   !tz !zD/0BCCC ((!:74E)9::1==D $%%AA %J%%e,,, !tz !DNNNQDN    s#8B'A,! B',&B B'' B0c|dkrdS|}|drh|j||||fdS|dr{|j|||||fdS|drU|j|||fdS|dr|j d d S|j d dS) NrDrsallrXsfullrsfastr) close_parenmaybe_fetch_att fetch_attr;r) r6rrxr|rrrrrrArt)r_rrs rB state_initialz_FetchParser.state_initials 881 GGII <<    K  t0022DOO4E4Et}}W   1 <<  K  JJLL%%''OO%%MMOOIIKK    1 <<   K  JJLL%%''OO%%   1 <<    J  M N N N1 +&&&qrDcN|drdStd)Nrr;z Missing )rrSrs rBstate_close_parenz_FetchParser.state_close_parens+ <<   1 $$$rDc|r|ddstdd}tt|D]#}|||dzsn$|S)Nrr;zWhitespace expected, none found)isspacerSrr)r_rrjs rBstate_whitespacez_FetchParser.state_whitespaces ?!A#(( ?=>> > s1vv  AQQY<''))  rDcd|ds|jddS)Nr)rrrrrrAr|rs rBstate_maybe_fetch_attz"_FetchParser.state_maybe_fetch_atts3||D!! N J  L M M MqrDc|}|jD]M\}}||r3|j|t |cSN|}|dr d|_d}n*|drd}ntd|||_ |j d|S)Ns body.peekTrsbodyrz!Nothing recognized in fetch_att: )got_body maybe_partial maybe_section) r6_simple_fetch_attrrxrtrrrvrS pending_bodyrAr|)r_rrr.clsr:rs rBstate_fetch_attz_FetchParser.state_fetch_atts GGII/ ! !ID#||D!! ! ""3355)))4yy    ! IIKK << % % EAFDD \\' " " EDDCCCDD D HIII rDcH|j|j|`dSr)rxrtrrs rBstate_got_bodyz_FetchParser.state_got_bodys& 4,---  qrDch|dsdS|jddS)Nr?r)section part_numberr;rrs rBstate_maybe_sectionz _FetchParser.state_maybe_sections7||D!! 1 4555qrDs(\d+(?:\.\d+)*)\.?c|j|}|Pd|ddD|_|Sg|_dS)Nc2g|]}t|dz Sr)r)rGrs rBrJz2_FetchParser.state_part_number.. s"HHH#a&&1*HHHrDrr) _partExprrgroupsr\rara)r_rrs rBstate_part_numberz_FetchParser.state_part_numbersd N  # # =HHahhjjm.A.A$.G.GHHHDJ5577NDJ1rDcT|}d}|drd|j_|dz }nD|dr4|x}|j_d|_d|_|dz }n|dr$||j_ |d z }n|d r$| |j_ |d z }n|}|d r d|_|d z }n-|d r|dz }ntd|||j_|j dt|j|j_d|_|S)NrrnTr;sheader]r>rstext]rsmime]sheader.fields.nots header.fieldsr<zUnhandled section contents: )finish_section header_listr)r6rrrrrrrrr6rrrSrAr|rrar)r_rrrrs rB state_sectionz_FetchParser.state_sections GGII <<   O&*D  # AIDD \\* % % O+/;;== 8A!(AHAH AIDD \\( # # O%)YY[[D  " AIDD \\( # # O%)YY[[D  " AIDD A||011 F .// F  Dq D DEEE'(D  $ J  M N N N!&tz!2!2  rDcN|dstddS)Nrnzsection must end with ]r;rrs rBstate_finish_sectionz!_FetchParser.state_finish_section5s*||D!! 7566 6qrDc|dstd|d}|dkrtd|d|}d|D|jj_|dzS)NrzHeader list must begin with (rrzHeader list must end with )r;c6g|]}|Sr>r)rGrs rBrJz2_FetchParser.state_header_list..Bs *F*F*F17799*F*F*FrD)rrSrr\rrr)r_rrar>s rBstate_header_listz_FetchParser.state_header_list:s||D!! =;<< <ffTll "999:: :AcE(..""*F*Fg*F*F*F 'QwrDcr|dsdS|d}|dkrtd|d|}|dd}t |dkrtd t t |\}}||j_||j_ |dzS) Nr\rr]rzFound < but not >r;rrz>Partial specification did not include two .-delimited integers) rrrSr\rrtrrrr)r_rrarrrabeginrxs rBstate_maybe_partialz _FetchParser.state_maybe_partialEs||D!! 1ffTll "99/00 0AcE( dA&& u::??P C v).&*0'QwrD)#rrrrrrrrrrrrrrrrrarrbrrrrrrr rrrrrrrrr r>rDrBrrs] * * * * * * * *''''''''........////////----------------((((((((%%%%%%%%########J//////// 6                 E h 5 ,' <( $ $ F  =)  &'''R%%% 2  122I###J   rDrc:eZdZdZdZdZdZdZdZdZ dZ d S) rrTc||_dSrvr)r_rUs rBrbzFileProducer.__init___s rDc||_|j|_tjx}|_|j|d|S)NF)rrproducerr_onDoneregisterProducer)r_rrs rBrzFileProducer.beginProducingbsC  ~  >+++DL &&tU333rDcnd}|jrd|fz}d|_|jsdS||j|jz}|sJ|j|j|dx|_x|_|_dS| |dS)NrDs{%d} F) firstWrite_sizerUrSrrunregisterProducerr%rr$)r_r:s rBresumeProducingzFileProducer.resumeProducingis  ? $tzz||o-A#DOv  F  DO,, ,  M , , . . . L ! !$ ' ' '48 8DL 846DMMM LLOOOOOrDcdS)z9 Pause the producer. This does nothing. Nr>rds rBpauseProducingzFileProducer.pauseProducingxrrDcdS)z8 Stop the producer. This does nothing. Nr>rds rB stopProducingzFileProducer.stopProducing}rrDc|j}|jdd|j}|j|d||z S)Nrr)rUrr)r_r:rVs rBr)zFileProducer._sizesU FKKMM  Aq FKKMM  Aq1u rDN) rrrrr(rbrr+r-r/r)r>rDrBrrZsxJJ         rDrc gd}dddd}tjd|z|}|std||} d||d d zz|d <t |d |d <t |d |d <tj|d |d |d d d d dddf S#t$rtd|wxYw)N)janfebmaraprmayjunjulaugsepoctnovdecjanuaryfebruarymarchaprilr6junejulyaugust septemberoctobernovemberdecemberz+(?P3[0-1]|[1-2]\d|0[1-9]|[1-9]| [1-9])z (?P\w+)z(?P\d\d\d\d))daymonyearz%(day)s-%(mon)s-%(year)szCannot parse time string r;rJ rKrIrr) rrrg groupdictindexr6rr struct_time)rmonthsexprrrs rBrrs/F6>%  D +d2A66A <:Q::;;; AV QuX^^%5%566;<%& NN& qx==%6AeHah1aRQS TUUU <<<:Q::;;;r c|dSrr>rTs rBrVrVs QqTrDch|d}|ddddS)Nutf-7r;rr'r)rWrrs_utf7s rBmodified_base64rWs1 XXg  F !B$<  d + ++rDcdd|ddzdz}|dS)Nrrr'rrT)rrrUs rBmodified_unbase64rYs1 AIIdD)) )D 0F == ! !!rDc t}g}tttt dddhz }|D]}||vrU|r0|dt d|zdzz }|dd=|t|[|dkr8|r0|dt d|zdzz }|dd=|dz }|||r;| dt d|zdzt|t|fS) ap Encode the given C{unicode} string using the IMAP4 specific variation of UTF-7. @type s: C{unicode} @param s: The text to encode. @param errors: Policy for handling encoding errors. Currently ignored. @return: L{tuple} of a L{str} giving the encoded bytes and an L{int} giving the number of code units consumed from the input. &&rrNs&-) bytearrayr rtchrrrWrrtordr|rr)rerrorsr2_in valid_charsrs rBencoderresS  A Cc#uT4001122cU:K      TOBGGCLL999D@@F HHSVV     #XX TOBGGCLL999D@@F JAA JJqMMMM >  555<=== !HHc!ff rDc g}g}tt|d}|D]}|dkr|s|d |dkrk|rit|dkr|dn=|t d|ddg}|r|||||r=|t d|ddd|t|fS) aw Decode the given L{str} using the IMAP4 specific variation of UTF-7. @type s: L{str} @param s: The bytes to decode. @param errors: Policy for handling decoding errors. Currently ignored. @return: a L{tuple} of a C{unicode} string giving the text which was decoded and an L{int} giving the number of bytes consumed from the input. rr^rr;r]rDNr) memory_cast memoryviewrtrrYrr)rrbr2rrs rBdecoderrisE A FJqMM3''A  ! ! 99V9 MM$     $YY6Y6{{a *388F122J+?+?@@AAAFF  ! MM!     HHQXXZZ  : "388F122J#7#788999 GGAJJA rDceZdZddZdS) StreamReaderstrictc t|Srv)rir_rrbs rBrzStreamReader.decodeqzzrDNrl)rrrrr>rDrBrkrk (rDrkceZdZddZdS) StreamWriterrlc t|Srv)rerns rBrWzStreamWriter.encoderorDNrp)rrrrWr>rDrBrsrsrqrDrscH|dddkrtSdS)N-rm imap4_utf_7)r _codecInfors rBrwrws+ ||C../.rD)(rr<IMailboxListenerr(rIMailboxr1r= IMailboxInfoIMessagerrr IMessagePartrrrrr&r"r$rrrr r!rrr#r%rrrrrrrrr%r3rvrrr)rrcodecsr email.utilsrrqrrrrrbase64rrior itertoolsrtypingrrr zope.interfacer twisted.credr twisted.cred.errorr r rrrrtwisted.internet.deferrtwisted.mail._credrrrrrtwisted.mail._exceptrrrrrrrrrr r!r"r#r$r%r&twisted.mail.interfacesr'rr(r)r=r*rzr+r{r,ryr-r|r.rr/rr0r}r1r2rtwisted.protocolsr3r4twisted.pythonr5r6twisted.python.compatr7r8r9r:rMrrr\rrCrLrNrrrr_SPr_CTLrr_nativeNonAtomCharsrrr  LineReceiver TimeoutMixinr TimeoutErrorrcr<rrrrprrrrrrrrrrrrsrrr*rrr#rr%r1r3r;ryrDrFrSr\r^rYrXrWrVrrrrrrrrrQrhrgrWrYrerirkrs CodecInforxrwregister__all__r>rDrBrs      ++++++++""""""""""&&&&&&$$$$$$FFFFFFFF5555555555000000(                            .-------$$$$$$$$tCa GMMOOPP * * *(aaaaaaaaH 999999998////////B0D"D"D"D"D"D"D"D"V  uUU55;;dE 2 2 3 344$t+ $**955 RZ11C7 8 8 UHHe HHH H H   SNSNSNSNSN%$h&;SNSNSNl8#"$$   PPPPP%$h&;PPPf<6666r "* NNNNb 1 1 1 &&&&>>>B    D7,7,7,7,tEEE ''%''''   +++///. . . b XoJoJoJoJoJoJoJoJd  !!2"!&"#    MMM4   ,JJJ4////////deeeee"3eeeP7(9*LLLLL!2LLL^i6i6i6i6X      BCCCCCCCCLRRRRRRRRj --------`,V,V,Vdgj&//:: ,,, """ D    D6& 6& V gw l K K     / / / rD