/usr/lib/python3/dist-packages/twisted/mail/__pycache__
Edit: /usr/lib/python3/dist-packages/twisted/mail/__pycache__/imap4.cpython-310.pyc (188717B)
o
¯bW: ã @ s
d Z ddlZddlZddlZddlZddlZddlZddlZddl Z ddl
Z
ddl Z ddl m
Z
mZ ddlmZ ddlmZ ddlmZmZmZ ddlmZ ddlmZ dd lm Z m Z dd
l m Z m 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;m
Z>m?Z@mAZBmCZDmEZFmGZHmIZJmKZLmMZNmOZOmPZQ ddlRmSZSmTZT ddlUmVZVmWZW ddlXmYZYmZZZm[Z[m\Z\m]Z] e^e_e`ddƒd a¡ ƒƒZbdd„ Zcdd„ ZdG dd„ dƒZeG dd „ d ƒZfG d d „ d ƒZgG d d „ d ƒZhG d!d"„ d"ƒZid#Zjekee`d$ƒe`d%d&ƒƒƒZld'ej el Zmem nd(¡Zoe pd)eo d* ¡Zqekd+d,„ e`d&ƒD ƒƒZreeFƒG d-d.„ d.eSjseTjtƒƒZue v¡ ZweeFƒG d/d0„ d0eSjseTjtƒƒZxdd1d2„Zyd3Zzd4Z{e|Z}džd5d6„Z~d7d8„ Zd9d:„ Z€dd;d<„Zd=d>„ Z‚d?d@„ ZƒdAdB„ Z„dŸdCdD„Z…dEdF„ Z†dGekdHekfdIdJ„Z‡G dKdL„ dLƒZˆdMZ‰dNdO„ ZŠdPdQ„ Z‹dRdS„ ZŒdTdU„ ZdVdW„ ZŽee=ƒG dXdY„ dYƒƒZeeOƒG dZd[„ d[eƒƒZd\d]d^d_d`daœZ‘dbdc„ Z’ddde„ Z“dfdg„ Z”dhdi„ Z•djdk„ Z–dldm„ Z—dndo„ Z˜G dpdq„ dqƒZ™G drds„ dse™ƒZšG dtdu„ duešƒZ›G dvdw„ dwešƒZœG dxdy„ dye™ƒZd d{d|„Zžd}d~„ ZŸdd€„ Z dd‚„ Z¡G dƒd„„ d„ƒZ¢G d…d†„ d†ƒZ£G d‡dˆ„ dˆƒZ¤d‰dŠ„ Z¥e¦e§d‹dŒd„ ƒZ¨dŽd„ Z©dd‘„ Zªdd’d“„Z«dd”d•„Z¬G d–d—„ d—ejƒZG d˜d™„ d™ej®ƒZ®e ¯e«e¬ee®¡Z°dšd›„ Z±e ²e±¡ g dœ¢Z³dS )¡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)ÚAnyÚListÚcast)Ú implementer)Ú credentials)ÚUnauthorizedLoginÚUnhandledCredentials)ÚdeferÚerrorÚ
interfaces)Ú
maybeDeferred)ÚCramMD5ClientAuthenticatorÚLOGINAuthenticatorÚLOGINCredentialsÚPLAINAuthenticatorÚPLAINCredentials)ÚIllegalClientResponseÚIllegalIdentifierErrorÚIllegalMailboxEncodingÚIllegalOperationÚIllegalQueryErrorÚIllegalServerResponseÚIMAP4ExceptionÚMailboxCollisionÚMailboxExceptionÚMismatchedNestingÚMismatchedQuotingÚNegativeResponseÚ
NoSuchMailboxÚNoSupportedAuthenticationÚReadOnlyMailboxÚUnhandledResponse) Ú IAccountIMAPÚIClientAuthenticationÚICloseableMailboxIMAPÚ IMailboxIMAPÚIMailboxIMAPInfoÚIMailboxIMAPListenerÚ IMessageIMAPÚIMessageIMAPCopierÚIMessageIMAPFileÚIMessageIMAPPartÚINamespacePresenterÚISearchableIMAPMailbox)ÚbasicÚpolicies)ÚlogÚtext)Ú_get_async_paramÚ_matchingStringÚ iterbytesÚ nativeStringÚ
networkStringé é
z/Jan Feb Mar Apr May Jun Jul Aug Sep Oct Nov Decc C s | |u r|S | 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}.
© )ÚthisÚthatÚifIsr= r= ú4/usr/lib/python3/dist-packages/twisted/mail/imap4.pyÚ_swap` s rB c s ‡ ‡fdd„| D ƒS )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}
c s( g | ]\}}t |ˆˆ ƒt |ˆˆ ƒf‘qS r= )rB )Ú.0ÚfirstÚsecond©r@ r? r= rA Ú
} s ÿz!_swapAllPairs..r= )Úofr? r@ r= rF rA Ú
_swapAllPairsn s ÿrI c @ sÌ e Zd ZU dZg Zee ed< edƒZ eefdd„Z
e dd„ ƒZ e j
dd„ ƒZ efd d
„Zd d „ Zd
d„ Zdd„ Zdd„ Zdd„ Zdd„ Zdd„ Zdd„ Zdefd d „Zdefd d „Zd edefd!d"„Z d#S )$Ú
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).
Ú_emptyÚinfc C sZ | j | _g | _dd„ | _|| j u rdS t|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 S s | d S ©Nr; r= ©Úxr= r= rA ÚË ó z%MessageSet.__init__..N)rK Ú_lastÚrangesÚgetnextÚ
isinstanceÚlistÚcleanÚadd©ÚselfÚstartÚendr= r= rA Ú__init__¿ s
zMessageSet.__init__c C s | j S )z{
The largest number in use.
This is undefined until it has been set by assigning to this property.
)rR ©rZ r= r= rA Úlast× s zMessageSet.lastc C sv | j | jur
tdƒ‚|| _ t| jƒD ]"\}\}}|du r |}|du r$|}||kr-||}}||f| j|< q| ¡ 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)rR rK Ú
ValueErrorÚ enumeraterS rW )rZ ÚvalueÚiÚlowÚhighr= r= rA r_ ß s
c C st || j u r|}| j| j ur|du r| j}|du r| j}t||gtjt| jddd\}}| 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.
N©r? r@ )Úkey) rK rR r_ ÚsortedÚ functoolsÚpartialrB Ú _infinityrS ÚappendrW rY r= r= rA rX ö s
ÿ zMessageSet.addc C sl t |tƒr| j|j }t|ƒS t| jƒ}| j| jur | j|_z|j|Ž W |S ty5 | |¡ Y |S w ©N)rU rJ rS r_ rK rX Ú TypeError)rZ ÚotherrS Úresr= r= rA Ú__add__ s
þ þzMessageSet.__add__c C sT t |tƒr| j |j¡ | ¡ | S z| j|Ž W | S ty) | |¡ Y | S w )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}
)rU rJ rS ÚextendrW rX rn ©rZ ro r= r= rA rr s
û ý ýzMessageSet.extendc C s” t t| j| jddƒ}tdƒtdƒfg}|D ]$\}}|d \}}||d k r.| ||f¡ qt||ƒt||ƒf|d< qt|dd… d| jd| _dS )z>
Clean ranges list, combining adjacent ranges
Nrf z-inféÿÿÿÿr; )rh rI rS rk Úfloatrl ÚminÚmax)rZ rS Ú mergedRangesrd re Ú previousLowÚ previousHighr= r= rA rW 0 s zMessageSet.cleanc C s | j d d du S )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.
rt N)rS r^ r= r= rA Ú
_noneInRangesD s zMessageSet._noneInRangesc C s@ | ¡ rtdƒ‚| jD ]\}}|| kr|kr dS q q dS )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)r{ rn rS )rZ rb rd re r= r= rA Ú __contains__e s ÿzMessageSet.__contains__c c sD | j D ]\}}| |d ¡}||kr |V | |¡}||ksqd S rM )rS rT )rZ ÚlÚhr= r= rA Ú _iteratorv s €
þ€þzMessageSet._iteratorc C s | ¡ rtdƒ‚| ¡ S )Nz!Can't iterate; last value not set)r{ rn r r^ r= r= rA Ú__iter__} s zMessageSet.__iter__c C sJ d}| j D ] \}}|d u r|d7 }q|d u rtdƒ‚||| d 7 }q|S )Nr r; z%Can't size object; last value not set)rS rn )rZ rp r} r~ r= r= rA Ú__len__ƒ s
zMessageSet.__len__Úreturnc C sv g }| j D ]0\}}||kr |d u r| d¡ q| t|ƒ¡ q|d u r,| d|f ¡ q| d||f ¡ qd |¡S )NÚ*z%d:*z%d:%dú,)rS rl ÚstrÚjoin)rZ Úprd re r= r= rA Ú__str__ s
zMessageSet.__str__c C s dt | ƒ› dS )Nz ©r… r^ r= r= rA Ú__repr__ ó zMessageSet.__repr__ro c C s t |tƒrtt| j|jkƒS tS rm )rU rJ r ÚboolrS ÚNotImplementedrs r= r= rA Ú__eq__ s
zMessageSet.__eq__N) Ú__name__Ú
__module__Ú __qualname__Ú__doc__rK r r Ú__annotations__ru rk r] Úpropertyr_ ÚsetterrX rq rr rW r{ r| r r€ r r… rˆ r‹ Úobjectr r r= r= r= rA rJ ‚ s*
9
! rJ c @ s$ e Zd Zdd„ Zdd„ Zdd„ ZdS )Ú
LiteralStringc C s || _ g | _|| _d S rm )ÚsizeÚdatar
©rZ r™ Údeferedr= r= rA r] § ó
zLiteralString.__init__c C ón | j t|ƒ8 _ d }| j dkr| j |¡ |S | j r+|d | j … || j d … }}nd}|r5| j |¡ |S ©Nr ó )r™ Úlenrš rl ©rZ rš Úpassonr= r= rA Úwrite¬ s
ù zLiteralString.writec C s | j d | j¡|f¡ dS )ú:
Call deferred with data and rest of line
r N)r
Úcallbackr† rš ©rZ Úliner= r= rA r¦ » s zLiteralString.callbackN)r r‘ r’ r] r¤ r¦ r= r= r= rA r˜ ¦ s r˜ c @ ó( e Zd ZdZdd„ Zdd„ Zdd„ ZdS ) Ú LiteralFileé c C s0 || _ || _|| jkrt ¡ | _d S tƒ | _d S rm )r™ r
Ú_memoryFileLimitÚtempfileÚ
TemporaryFilerš r r› r= r= rA r] Å s
zLiteralFile.__init__c C rž rŸ )r™ r¡ rš r¤ r¢ r= r= rA r¤ Í s
ú zLiteralFile.writec C s$ | j dd¡ | j | j |f¡ dS )r¥ r N)rš Úseekr
r¦ r§ r= r= rA r¦ Û s zLiteralFile.callbackN)r r‘ r’ r¬ r] r¤ r¦ r= r= r= rA rª Â s
rª c @ s* e Zd ZdZd
dd„Zdd„ Zdd„ Zd S ) Ú WriteBufferzU
Buffer up a bunch of writes before sending them all to a transport at once.
é c C s || _ || _d| _g | _d S ©Nr )Ú
bufferSizeÚ transportÚ_lengthÚ_writes)rZ r´ r™ r= r= rA r] è s
zWriteBuffer.__init__c C s: | j t|ƒ7 _ | j |¡ | j | jkr| ¡ d S d S rm )rµ r¡ r¶ rl r³ Úflush©rZ Úsr= r= rA r¤ î s
ÿzWriteBuffer.writec C s( | j r| j | j ¡ g | _ d| _d S d S r² )r¶ r´ Ú
writeSequencerµ r^ r= r= rA r· ô s
ýzWriteBuffer.flushN)r± )r r‘ r’ r“ r] r¤ r· r= r= r= rA r° ã s
r° c @ sJ e Zd ZdZdZdZdZ ddd„Zdefd d
„Z d d „ Z
d
d„ Z dS )ÚCommand)ó
CAPABILITYó FLAGSó LISTó LSUBó STATUSó SEARCHó NAMESPACE)ó EXISTSó EXPUNGEó FETCHó RECENT)ó UIDVALIDITYó UNSEENó
READ-WRITEó READ-ONLYó UIDNEXTó PERMANENTFLAGSNr= c s. || _ || _|| _‡ ‡‡fdd„| _g | _d S )Nc s ˆ| gˆ ¢R i ˆ¤ŽS rm r= rN ©ÚcontArgsÚcontKwÚ continuationr= rA rP ó z"Command.__init__..)ÚcommandÚargsÚ wantResponserÐ Úlines)rZ rÒ rÓ rÔ rÐ rÎ rÏ r= rÍ rA r] s
zCommand.__init__r‚ c C s d | j| j| j| j| j¡S )Nz()ÚformatrÒ rÓ rÔ rÐ rÕ r^ r= r= rA r‹ s ÿzCommand.__repr__c C s. | j d u r
d || jf¡S d || j| j f¡S ©Nó )rÓ r† rÒ ©rZ Útagr= r= rA rÖ $ s
zCommand.formatc C sÊ g }g }| j D ]E}t|ƒ}t|ƒ}|dkr |d | jv sA|dkr'|d | jv sA|dkrG|d dkrGt|d tƒrG|d d | jv rG| |¡ q| |¡ q| j d }| _ |
||f¡ |rc||ƒ d S d S )Nr; r é ó OK) rÕ ÚparseNestedParensr¡ Ú _1_RESPONSESÚ _2_RESPONSESrU rV Ú
_OK_RESPONSESrl r
r¦ ) rZ ÚlastLineÚunusedCallbackÚsendÚunuseÚLÚnamesÚNÚdr= r= rA Úfinish) s*
ÿ ÿzCommand.finish)Nr= N) r r‘ r’ rÞ rß rà r
r] r… r‹ rÖ ré r= r= r= rA r» û s
û r» rØ é! é€ é s ]\\(){%*"Úcharmapú[ú]c c s | ] }|t vr|V qd S rm )Ú
_nonAtomChars)rC Úchr= r= rA Ú R s € rò c @ s e Zd ZdZdZdZdZdZdZdZ dZ
dZ dZ dZ
dZdZdZh d£Zd Zd
ZdMd d „Zd
d„ Zdd„ Zdd„ Zdd„ Zdd„ ZdZdd„ Zdd„ Z dd „ Z d d „ Z dNd d „Z d!d"„ Z d#d$„ Z!d%d&„ Z"d'd(„ Z#d)d*„ Z$d+d,„ Z%d-d.„ Z&dOd/d0„Z'e( )d1e( *e+¡ d2 ¡Z,d3d4„ Z-d5d6„ Z.d7d8„ Z/d9d:„ Z0d;d<„ Z1d=d>„ Z2d?d@„ Z3dAdB„ Z4dCdD„ Z5dEdF„ Z6dGdH„ Z7dIdJ„ Z8dPdLdM„Z9dPdNdO„Z:dPdPdQ„Z;dNdRdS„Z<dQdUdV„Z=dWdX„ Z>dYdZ„ Z?d[d\„ Z@e@fZAeAZBeAZCeAZDd]d^„ ZEeEfZFeFZGeFZHeFZId_d`„ ZJeJfZKeKZLeKZMeKZNdadb„ ZOeOe-fZPdcdd„ ZQdedf„ ZRdgdh„ ZSdidj„ ZTdkdl„ ZUdmdn„ ZVdodp„ ZWeWfZXdqdr„ ZYeYe'e&fZZdsdt„ Z[dudv„ Z\dwdx„ Z]dydz„ Z^e^fZ_e_Z`d{d|„ Zad}d~„ Zbdd€„ Zceae'dd‚fZdedZeeae'dƒd„fZfefZgd…d†„ Zhd‡dˆ„ ZiehfZjejZkd‰dŠ„ Zlele&fZmemZnd‹dŒ„ Zoeoe&fZpepZqddŽ„ Zrere'e&fZsesZtdd„ Zueue&fZvevZwd‘d’„ Zxexe&fZyeyZzd“d”„ Z{d•d–„ Z|d—d˜„ Z}e{e'e'dƒd™fZ~e~Ze{e'e'ddšfZ€e€Zd›dœ„ Z‚ddž„ ZƒdŸd „ Z„e‚e'e.fZ…e…Z†d¡d¢„ Z‡d£d¤„ Zˆd¥d¦„ Z‰d§d¨„ ZŠd©dª„ Z‹e‰e'e5e6e/fZŒeŒZd«d¬„ ZŽdd®„ Zd¯d°„ ZefZ‘d±d²„ Z’d³d´„ Z“dµd¶„ Z”d·d¸„ Z•e•fZ–d¹dº„ Z—d»d¼„ Z˜d½d¾„ Z™e™fZšd¿dÀ„ Z›dÁd„ ZœdRdÃdÄ„Zee7e0fZždÅdÆ„ ZŸdNdÇdÈ„Z dÉdÊ„ Z¡dËdÌ„ Z¢dÍd΄ Z£dÏdЄ Z¤dÑdÒ„ Z¥dÓdÔ„ Z¦dÕdÖ„ Z§d×dØ„ Z¨dÙdÚ„ Z©dÛdÜ„ ZªdÝdÞ„ Z«dßdà„ Z¬dádâ„ Zdãdä„ Z®dådæ„ Z¯dçdè„ Z°dédê„ Z±dëdì„ Z²dídî„ Z³dïdð„ Z´dñdò„ Zµdódô„ Z¶dõdö„ Z·d÷dø„ Z¸dùdú„ Z¹dûdü„ Zºdýdþ„ Z»dÿd „ Z¼dd„ Z½dd„ Z¾dd„ Z¿dd„ ZÀd d
„ ZÁd d „ ZÂd
d„ ZÃdd„ ZÄdd„ ZÅdd„ ZÆdRdd„ZÇeÇe1e2fZÈdd„ ZÉdd„ ZÊdSdd „ZËdSd d „ZÌdSd d „ZÍdSd!d"„ZÎdSd#d$„ZÏdSd%d&„ZÐdSd'd(„ZÑdSd)d*„ZÒdSd+d,„ZÓdSd-d.„ZÔd/d0„ ZÕd1d2„ ZÖdRd3d4„Z×e×e1e-e3fZØd5d6„ ZÙd7d8„ ZÚdRd9d:„ZÛeÛe1e&fZÜd;d<„ ZÝd=d>„ ZÞd?d@„ ZßdAdB„ ZàdCdD„ ZádEdF„ Zâeâe-e4fZãdGdH„ ZädIdJ„ ZådKdL„ ZædS (T Ú IMAP4ServerzÀ
Protocol implementation for an IMAP4rev1 server.
The server can be in any of four states:
- Non-authenticated
- Authenticated
- Selected
- Logout
s Twisted IMAP4rev1 Readyé< i FNi > ó ORó NOTó UIDÚunauthrÒ c C s4 |d u ri }|| _ || _|d u rt}|| _g | _d S rm )Ú challengersÚctxÚiterateInReactorÚ
_schedulerÚ _queuedAsync)rZ ÚchalÚcontextFactoryÚ schedulerr= r= rA r] s
zIMAP4Server.__init__c C sZ dt | j ¡ ƒi}| jr#| jr#| js#t | jd ¡d u r#d |d< d |d< d |d< d |d< |S )Nó AUTHó
LOGINDISABLEDó STARTTLSr s IDLE) rV rù Úkeysrú Ú canStartTLSÚ
startedTLSr Ú
ISSLTransportr´ )rZ Úcapr= r= rA Ú capabilitiesš s ÿzIMAP4Server.capabilitiesc C s2 i | _ t | jd ¡d u| _| | j¡ | ¡ d S rm )Útagsr Ú
ITLSTransportr´ r Ú
setTimeoutÚtimeOutÚsendServerGreetingr^ r= r= rA ÚconnectionMade§ s zIMAP4Server.connectionMadec C s& | d ¡ | jr| ¡ d | _d S d S rm )r Ú _onLogout)rZ Úreasonr= r= rA ÚconnectionLost s
þzIMAP4Server.connectionLostc C s\ | d¡ | j ¡ | jr)| j | ¡ t| jd ƒ}|d ur&t|jƒ t j
¡ d | _d| _ d S )Ns* * BYE Autologout; connection idle too longÚtimeout) ÚsendLiner´ ÚloseConnectionÚmboxÚremoveListenerÚICloseableMailboxr ÚcloseÚ
addErrbackr4 ÚerrÚstate)rZ Úcmbxr= r= rA ÚtimeoutConnection³ s
z IMAP4Server.timeoutConnectionc C s. | ¡ | j |¡}|d ur| |¡ d S d S rm )Ú resetTimeoutÚ_pendingLiteralr¤ Ú setLineModer¢ r= r= rA ÚrawDataReceived¾ s
ÿzIMAP4Server.rawDataReceivedc C sV | j }d | _ |r | j d u r | | d¡¡ |r | j d u s
| j d ur)| j |¡ d S d S r² )ÚblockedÚ lineReceivedÚpoprr )rZ Úcommandsr= r= rA Ú_unblockÈ s ÿ
ÿzIMAP4Server._unblockc
C s† | j d ur
| j |¡ d S | ¡ t| d| j ƒ}z||ƒ W d S tyB } z| dtt|ƒƒ ¡ t
¡ W Y d }~d S d }~ww )NÚparse_s BAD Server error: ) r# rl r ÚgetattrÚ
parseStateÚ ExceptionÚsendUntaggedResponser: r… r4 r )rZ r¨ ÚfÚer= r= rA r$ Ð s
€þzIMAP4Server.lineReceivedc
C sB | d d¡}d }t|ƒdkr|\}}}n%t|ƒdkr |\}}nt|ƒdkr1|d }| |d¡ d S | d d¡ d S | ¡ }z| |||¡W S tyd } z| |dtt|ƒƒ ¡ W Y d }~d S d }~w ty‚ } z| |dtt|ƒƒ ¡ W Y d }~d S d }~w t
y } z| |d tt|ƒƒ ¡ W Y d }~d S d }~ww )
NrÛ é r; r s Missing commands Null commandó Illegal syntax: ó Illegal operation: ó Illegal mailbox name: ) Úsplitr¡ ÚsendBadResponseÚupperÚdispatchCommandr r: r… r ÚsendNegativeResponser )rZ r¨ rÓ ÚrestrÚ Úcmdr. r= r= rA Ú
parse_commandÝ s:
&€ÿ€ÿ€ÿzIMAP4Server.parse_commandc C s | j }d | _ d| _| |¡ d S )NrÒ )r r* r¦ )rZ r¨ rè r= r= rA Ú
parse_pendingú s zIMAP4Server.parse_pendingc C sN | |¡}|r |d }|dd … }| ||| |g|||¡ d S | |d¡ d S )Nr r; s Unsupported command)Ú
lookupCommandÚ_IMAP4Server__doCommandr4 )rZ rÚ r9 r8 Úuidr- ÚfnÚ parseargsr= r= rA r6 s
zIMAP4Server.dispatchCommandc C s t | d | jt| ¡ ƒf¡d ƒS )NÚ_)r) r† r r9 r5 )rZ r9 r= r= rA r< s zIMAP4Server.lookupCommandc C sœ t |ƒD ],\}}t|ƒr+||d d … }t|| |ƒ | j|||||¡ | j|¡ d S | |¡ q|r;tdt |ƒ ƒ‚|d urH||d|iŽ d S ||Ž d S )Nr; z Too many arguments for command: r> )
ra Úcallabler Ú addCallbackÚ_IMAP4Server__cbDispatchr Ú_IMAP4Server__ebDispatchrl r Úrepr) rZ rÚ ÚhandlerrÓ r@ r¨ r> rc Úargr= r= rA Ú __doCommand s ÿ zIMAP4Server.__doCommandc C s* |\}}| |¡ | ||||||¡ d S rm )rl r= ) rZ ÚresultrÚ r? rÓ r@ r> rH r8 r= r= rA Ú __cbDispatch s
zIMAP4Server.__cbDispatchc C s | t¡r| |dtt|jƒƒ ¡ d S | t¡r(| |dtt|jƒƒ ¡ d S | t¡r<| |dtt|jƒƒ ¡ d S | |dtt|jƒƒ ¡ t
|¡ d S )Nr0 r1 r2 ó Server error: ) Úcheckr r4 r: r… rb r r7 r r4 r ©rZ ÚfailurerÚ r= r= rA Ú __ebDispatch% s
ÿ
ÿ
ÿÿzIMAP4Server.__ebDispatchc C sR || j kr
td| j f ƒ‚t ¡ }d| _t||ƒ| _| td| ƒ¡ | ¡ |S )Nz,Literal too long! I accept at most %d octetsÚpendingzReady for %d octets of text)
Ú_literalStringLimitr r
ÚDeferredr* r˜ r ÚsendContinuationRequestr: Ú
setRawMode©rZ r™ rè r= r= rA Ú_stringLiteral8 s
ÿÿ
ÿzIMAP4Server._stringLiteralc C s8 t ¡ }d| _t||ƒ| _| td| ƒ¡ | ¡ |S )NrQ zReady for %d octets of data)r
rS r* rª r rT r: rU rV r= r= rA Ú _fileLiteralG s
ÿzIMAP4Server._fileLiteralc C s | j |ddS )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_astringr§ r= r= rA Úarg_finalastringQ s z IMAP4Server.arg_finalastringc C s | ¡ }|s
tdƒ‚d}d\}}|dd… dkr5z| dd¡\}}}|dd… }W n^ ty4 tdƒ‚w |dd… d krs|d
d… d krItd ƒ‚z
t|dd
… ƒ}W n tyf td
t|dd
… ƒ ƒ‚w |rm|smdS | |¡}n| 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 argumentN©NNr r; ó "rÛ zUnmatched quotesó {rt ó }úMalformed literalúBad literal size: )r r rØ r ) Ústripr r3 r` ÚintrF rW r¡ rl )rZ r¨ rY rè rH r8 Úspamr™ r= r= rA rZ c s8 ÿ ÿ
zIMAP4Server.arg_astrings
(?P[s ]+)( (?P.*$)|$)c C s8 |st dƒ‚| j |¡}|r| d¡| d¡fS t dƒ‚)z-
Parse an atom from the line
r\ Úatomr8 zMalformed ATOM)r ÚatomreÚmatchÚgroup)rZ r¨ Úmr= r= rA Úarg_atom– s zIMAP4Server.arg_atomc C s` |st dƒ‚|dd… dkrt dƒ‚| d¡}|dkr t dƒ‚t|d|… d ƒ||d
d… fS ) zG
Parse a (non-nested) parenthesised list from the line
r\ Nr; ó (zMissing parenthesisó )rt úMismatched parenthesisr rÛ )r ÚfindrÝ )rZ r¨ rc r= r= rA Ú arg_plist¢ s
"zIMAP4Server.arg_plistc C s€ |st dƒ‚|dd… dkrt dƒ‚|dd… dkr t dƒ‚z
t|dd… ƒ}W n ty: t d |dd… ›ƒ‚w | |¡S )
z/
Parse a literal from the line
r\ Nr; r_ zMissing literalrt r` ra rb )r rd r` rX )rZ r¨ r™ r= r= rA Ú arg_literal³ s ÿ
zIMAP4Server.arg_literalc C s t |ƒ}|dfS )z
searchkeys
r )rÝ )rZ r¨ Úqueryr= r= rA Úarg_searchkeysÇ s zIMAP4Server.arg_searchkeysc
C sd d}| dd¡}t|ƒdkr|d }|d }zt|ƒ|fW S ty1 } ztdt|ƒ ƒ‚d}~ww )z
sequence-set
r rØ r; rÛ r zBad message number N)r3 r¡ Ú parseIdListr r r… )rZ r¨ r8 rH r. r= r= rA Ú
arg_seqsetÐ s €ÿzIMAP4Server.arg_seqsetc C s t ƒ }| |¡ |jdfS )z
fetch-att
r )Ú _FetchParserÚ parseStringrJ )rZ r¨ r‡ r= r= rA Ú arg_fetchattß s
zIMAP4Server.arg_fetchattc C s g }|dd… dkr |dd… dkrt dƒ‚|dd… }|r]| j |¡}|s*t dƒ‚|dd… d krC| ¡ dkrC| d | d
¡ ¡ n| ¡ dkrR| | d
¡¡ nt dƒ‚| d ¡}|s |d fS )
z-
Flag part of store-att-flag
r r; rl rt Nrm rn zMalformed flagó \rf r8 r )r rg Úsearchr[ rl ri )rZ r¨ Úflagsrj r= r= rA Ú arg_flaglistç s"
ö zIMAP4Server.arg_flaglistc C s |dfS )z-
Command line of UID command
r r= r§ r= r= rA Úarg_lineÿ s zIMAP4Server.arg_linec C s | d¡r
| |¡S d|fS )z-
Optional parenthesised list
rl N)Ú
startswithrp r§ r= r= rA Ú opt_plist s
zIMAP4Server.opt_plistc C sP | d¡r$z | dd¡\}}}W n ty tdƒ‚w ||dd… fS d|fS )z+
Optional date-time string
r^ rÛ zMalformed date-timer; N)r~ r3 r` r )rZ r¨ re Údater8 r= r= rA Ú opt_datetime s
ÿzIMAP4Server.opt_datetimec C sd |dd… ¡ dkr.| dd¡}t|ƒdkrtdƒ‚t|ƒdkr%| d¡ |\}}}||fS d|fS ) z4
Optional charset of SEARCH command
Né s CHARSETrØ rÛ r; zMissing charset identifierr )r5 r3 r¡ r rl )rZ r¨ rH re r8 r= r= rA Ú opt_charset s
zIMAP4Server.opt_charsetc C s, dd | ¡ ¡ d | j }| j|d d S )Ns [CAPABILITY rØ ó ] )Úmessage)r† ÚlistCapabilitiesÚIDENTÚsendPositiveResponse©rZ Úmsgr= r= rA r * s z IMAP4Server.sendServerGreetingr c C ó | d||¡ d S )Nó BAD©Ú_respond©rZ rÚ r… r= r= rA r4 . ó zIMAP4Server.sendBadResponsec C r‹ )NrÜ r r r= r= rA rˆ 1 r z IMAP4Server.sendPositiveResponsec C r‹ )Nó NOr r r= r= rA r7 4 r z IMAP4Server.sendNegativeResponsec K s@ t |fi |¤Ž}|r| jd u r| |d d ¡ d S | j |¡ d S rm )r6 r# rŽ rý rl )rZ r… ÚisAsyncÚkwargsr= r= rA r, 7 s z IMAP4Server.sendUntaggedResponseó! Ready for additional command textc C s$ |r | d| ¡ d S | d¡ d S )Ns + ó +©r r‰ r= r= rA rT > s z#IMAP4Server.sendContinuationRequestc C sp |dv r| j r| j }g | _ |D ] }| |d d ¡ q|s d}|r,| d |||f¡¡ d S | d ||f¡¡ d S )N)rÜ r‘ rŒ ó *rØ )rý rŽ r r† )rZ r rÚ r… rÕ rŠ r= r= rA rŽ D s zIMAP4Server._respondc sT dg}| ¡ ¡ D ] \‰ }|d u r| ˆ ¡ q t|ƒr'| ‡ fdd„|D ƒ¡ q |S )Ns IMAP4rev1c s g | ]}ˆ d | ‘qS )ó =r= )rC r ©Úcr= rA rG W ó z0IMAP4Server.listCapabilities..)r Úitemsrl r¡ rr )rZ ÚcapsÚvr= r™ rA r† Q s €z IMAP4Server.listCapabilitiesc C s( | dd | ¡ ¡ ¡ | |d¡ d S )Ns CAPABILITY rØ s CAPABILITY completed)r, r† r† rˆ rÙ r= r= rA Ú
do_CAPABILITYZ s zIMAP4Server.do_CAPABILITYc C s$ | d¡ | |d¡ | j ¡ d S )Ns BYE Nice talking to yous LOGOUT successful)r, rˆ r´ r rÙ r= r= rA Ú do_LOGOUTc s
zIMAP4Server.do_LOGOUTc C s | |d¡ d S )Ns NOOP No operation performed©rˆ rÙ r= r= rA Údo_NOOPm rŒ zIMAP4Server.do_NOOPc C s> | ¡ ¡ }|| jvr| |d¡ d S | | j| ƒ |¡ d S )Ns AUTHENTICATE method unsupported)r5 rc rù r7 Ú authenticate)rZ rÚ rÓ r= r= rA Údo_AUTHENTICATEu s
zIMAP4Server.do_AUTHENTICATEc C s* | j d u r
| |d¡ d S | ||¡ d S )Ns Temporary authentication failure)Úportalr7 Ú_setupChallenge)rZ rþ rÚ r= r= rA r£ ~ s
zIMAP4Server.authenticatec
C sœ z| ¡ }W n ty% } z| |dtt|ƒƒ ¡ W Y d }~d S d }~ww t|ƒd d… }d| _t ¡ | _ |
|¡ | j | j ||¡ | j
| j|¡ d S )NrL rt rQ )Ú getChallenger+ r4 r: r… r r* r
rS r rT rC Ú_IMAP4Server__cbAuthChunkr Ú_IMAP4Server__ebAuthChunk)rZ rþ rÚ Ú challenger. Úcodedr= r= rA r¦ … s &€ÿ
zIMAP4Server._setupChallengec C st zt |ƒ}W n tjy tdƒ‚w | |¡ | ¡ r$| ||¡ d S | j |d t ¡
| j | j |fd |fd ¡ d S )Nz Malformed Response - not base64)
r ÚbinasciiÚErrorr Ú setResponseÚmoreChallengesr¦ r¥ ÚloginÚIAccountÚ addCallbacksÚ_IMAP4Server__cbAuthRespÚ_IMAP4Server__ebAuthResp)rZ rJ rþ rÚ Úuncodedr= r= rA Ú
__cbAuthChunk’ s ÿ
ÿzIMAP4Server.__cbAuthChunkc C sH |\}}}|t u s
J dƒ‚|| _d| _|| _| |d¡ | | j¡ d S )Nz(IAccount is the only supported interfaceÚauths Authentication successful)r± Úaccountr r rˆ r ÚPOSTAUTH_TIMEOUT©rZ rJ rÚ ÚifaceÚavatarÚlogoutr= r= rA Ú __cbAuthResp s
zIMAP4Server.__cbAuthRespc C sN | t¡r
| |d¡ d S | t¡r| |d¡ d S | |d¡ t |¡ d S )Ns# Authentication failed: unauthorizeds+ Authentication failed: server misconfigureds' Server error: login failed unexpectedly)rM r r7 r r4 r4 r rN r= r= rA Ú __ebAuthResp© s
ÿ zIMAP4Server.__ebAuthRespc C ó | |dtt|jƒƒ ¡ d S )Ns Authentication failed: )r7 r: r… rb rN r= r= rA Ú
__ebAuthChunk´ ó ÿzIMAP4Server.__ebAuthChunkc C sŽ | j r | |d¡ d S | jr?| jr?| |d¡ | j | j¡ d| _ | j ¡ | _d| jvr1t | jd< d| jvr=t
| jd< d S d S | |d¡ d S )Ns TLS already negotiateds Begin TLS negotiation nowTó LOGINs PLAINs TLS not available) r r7 rú r rˆ r´ ÚstartTLSrù Úcopyr r rÙ r= r= rA Ú do_STARTTLS¹ s
ÿzIMAP4Server.do_STARTTLSc C sB d| ¡ v r| |d¡ d S t| j||ƒ | j|¡ | j|¡ d S )Nr s! LOGIN is disabled before STARTTLS)r r4 r ÚauthenticateLoginrC Ú_IMAP4Server__cbLoginr Ú_IMAP4Server__ebLogin)rZ rÚ ÚuserÚpasswdr= r= rA Údo_LOGINÊ s ÿzIMAP4Server.do_LOGINc C s$ | j r| j t ||¡dt¡S tƒ ‚)a´
Lookup the account associated with the given parameters
Override this method to define the desired authentication behavior.
The default behavior is to defer authentication to C{self.portal}
if it is not None, or to deny the login otherwise.
@type user: L{str}
@param user: The username to lookup
@type passwd: L{str}
@param passwd: The password to login with
N)r¥ r° r
ÚUsernamePasswordr± r )rZ rÊ rË r= r= rA rÇ Õ s
ÿz IMAP4Server.authenticateLoginc C sb |\}}}|t ur| |d¡ t d|›d¡ d S || _|| _| |d¡ d| _| | j ¡ d S )Ns- Server error: login returned unexpected valuez__cbLogin called with z, IAccount expecteds LOGIN succeededr· )
r± r4 r4 r r¸ r rˆ r r r¹ rº r= r= rA Ú __cbLoginê s
zIMAP4Server.__cbLoginc C sB | t¡r
| |d¡ d S | |dtt|jƒƒ ¡ t |¡ d S )Ns LOGIN failedrL ) rM r r7 r4 r: r… rb r4 r rN r= r= rA Ú __ebLoginö s
ÿzIMAP4Server.__ebLoginc C s` d } }}t | jd ƒ}|d ur | ¡ }| ¡ }| ¡ }| dt|||gƒ ¡ | |d¡ d S )Ns
NAMESPACE s NAMESPACE command completed)r0 r¸ ÚgetPersonalNamespacesÚgetSharedNamespacesr, ÚcollapseNestedListsrˆ )rZ rÚ ÚpersonalÚpublicÚsharedÚnpr= r= rA Ú do_NAMESPACEÿ s ÿzIMAP4Server.do_NAMESPACEc C s| | j r"| j | ¡ t| j d ƒ}|d ur t|jƒ tj¡ d | _ d| _t |ƒ}t| j
j t |ƒ|ƒ | j
||¡ | j||¡ d S )Nr· )r r r r r r r4 r r Ú
_parseMboxr¸ ÚselectrC Ú
_cbSelectWorkÚ
_ebSelectWork)rZ rÚ ÚnameÚrwÚcmdNamer r= r= rA Ú _selectWork s ÿzIMAP4Server._selectWorkc C s | ||d ¡ t |¡ d S )Ns failed: Server error©r4 r4 r )rZ rO rÞ rÚ r= r= rA rÛ s zIMAP4Server._ebSelectWorkc C sì |d u r | |d¡ d S ddd„ | ¡ D ƒv r | |d¡ d S dd„ | ¡ D ƒ}| d| ¡ f ¡ | d| ¡ f ¡ | d d
|¡ d ¡ | d d | ¡ f ¡ | ¡ rYd
pZd}| | ¡ | |d| d | d ¡ d| _
|| _ d S )Ns No such mailboxz \noselectc S ó g | ]}| ¡ ‘qS r= )Úlower©rC r¹ r= r= rA rG $ ó z-IMAP4Server._cbSelectWork..zMailbox cannot be selectedc S ó g | ]}t |ƒ‘qS r= ©r: ©rC Úflagr= r= rA rG ( rä ó %d EXISTSó %d RECENTó FLAGS (rØ rm s [UIDVALIDITY %d]rÉ rÊ ó [r„ s successfulrÙ ) r7 ÚgetFlagsr, ÚgetMessageCountÚgetRecentCountr† rˆ ÚgetUIDValidityÚ isWriteableÚ addListenerr r )rZ r rÞ rÚ r{ r¹ r= r= rA rÚ s
zIMAP4Server._cbSelectWorkr; ó SELECTr ó EXAMINEc C s" | d ¡ || _| j| _d| _d S )NÚidle)rT ÚparseTagr* Ú lastStaterÙ r= r= rA Údo_IDLE: s
zIMAP4Server.do_IDLEc G s" | j | _| ` | | jd¡ | `d S )Ns IDLE terminated)r÷ r* rˆ rö )rZ rÓ r= r= rA Ú
parse_idle@ s zIMAP4Server.parse_idlec
C sž t |ƒ}z| j |¡}W n0 ty) } z| |tt|ƒƒ¡ W Y d }~d S d }~w ty< | |d¡ t
¡ Y d S w |rG| |d¡ d S | |d¡ d S )Ns/ Server error encountered while creating mailboxs Mailbox createds Mailbox not created) rØ r¸ Úcreater r7 r: r… Ú
BaseExceptionr4 r4 r rˆ )rZ rÚ rÜ rJ rš r= r= rA Ú do_CREATEI s "€ ÿüzIMAP4Server.do_CREATEc
C s¨ t |ƒ}| ¡ dkr| |d¡ d S z| j |¡ W n1 ty8 } z| |t|ƒ d¡¡ W Y d }~d S d }~w tyK | |d¡ t
¡ Y d S w | |d¡ d S )NÚinboxs You cannot delete the inboxú imap4-utf-7s/ Server error encountered while deleting mailboxs Mailbox deleted)
rØ râ r7 r¸ Údeleter r… Úencoderû r4 r4 r rˆ ©rZ rÚ rÜ rj r= r= rA Ú do_DELETE] s $€ ÿüzIMAP4Server.do_DELETEc
C sà dd„ ||fD ƒ\}}| ¡ dks| ¡ dkr | |d¡ d S z | j ||¡ W n? ty8 | |d¡ Y d S tyT } z| |tt|ƒƒ¡ W Y d }~d S d }~w t yg | |d¡ t
¡ Y d S w | |d¡ d S )Nc s ó | ]}t |ƒV qd S rm )rØ )rC Únr= r= rA rò r ó € z(IMAP4Server.do_RENAME..rý s@ You cannot rename the inbox, or rename another mailbox to inbox.s Invalid command syntaxs/ Server error encountered while renaming mailboxs Mailbox renamed)
râ r7 r¸ Úrenamern r4 r r: r… rû r4 r rˆ )rZ rÚ ÚoldnameÚnewnamerj r= r= rA Ú do_RENAMEq s( ÿ "€ ÿüzIMAP4Server.do_RENAMEc
C óŠ t |ƒ}z| j |¡ W n0 ty) } z| |tt|ƒƒ¡ W Y d }~d S d }~w ty< | |d¡ t
¡ Y d S w | |d¡ d S )Ns5 Server error encountered while subscribing to mailboxs
Subscribed) rØ r¸ Ú subscriber r7 r: r… rû r4 r4 r rˆ r r= r= rA Ú do_SUBSCRIBE‰ ó "€ ÿüzIMAP4Server.do_SUBSCRIBEc
C r
)Ns9 Server error encountered while unsubscribing from mailboxs Unsubscribed) rØ r¸ Ú unsubscriber r7 r: r… rû r4 r4 r rˆ r r= r= rA Údo_UNSUBSCRIBEš r
zIMAP4Server.do_UNSUBSCRIBEc C s< t |ƒ}t |ƒ}t| jj||ƒ | j|||¡ | j|¡ d S rm )rØ r r¸ Ú
listMailboxesrC Ú _cbListWorkr Ú _ebListWork)rZ rÚ Úrefr ÚsubrÞ r= r= rA Ú _listWork« s
ÿzIMAP4Server._listWorkc
C s| |D ]1\}}|r| j |¡r3dd„ | ¡ D ƒ}| ¡ d¡}t|ƒtt|ƒ|| d¡f} | t| ƒ¡ q| ||d ¡ d S )Nc S rå r= ræ rç r= r= rA rG µ rä z+IMAP4Server._cbListWork..rþ s
completed)
r¸ Ú isSubscribedrí ÚgetHierarchicalDelimiterr Ú DontQuoteMeÚmapr, rÒ rˆ )
rZ Ú mailboxesrÚ r rÞ rÜ Úboxr{ ÚdelimÚrespr= r= rA r ² s ü€zIMAP4Server._cbListWorkc C ó | |d¡ t |¡ d S )Ns1 Server error encountered while listing mailboxes.rà rN r= r= rA r À ó zIMAP4Server._ebListWorkr¾ r¿ c C sP g }|D ] }| t|ƒ¡ qt|ƒ}t| jj|dƒ | j|||¡ | j |¡ d S r² )
rl r9 rØ r r¸ rÙ rC Ú_cbStatusGotMailboxr Ú_ebStatusGotMailbox)rZ rÚ Úmailboxræ Ú nativeNamesrÜ r= r= rA Ú do_STATUSÊ s
ÿzIMAP4Server.do_STATUSc C s@ |rt |j|ƒ | j| j||fd ||fd ¡ d S | |d¡ d S )Ns Could not open mailbox)r Ú
requestStatusr² Ú_IMAP4Server__cbStatusÚ_IMAP4Server__ebStatusr7 )rZ r rÚ r" ræ r= r= rA r Õ s ú z IMAP4Server._cbStatusGotMailboxc C r ©Ns/ Server error encountered while opening mailbox.rà rN r= r= rA r! â r z IMAP4Server._ebStatusGotMailboxc C sL t d dd„ | ¡ D ƒ¡ƒ}| d| d¡ d | d ¡ | |d¡ d S ) Nú c S s g | ]}d | ‘qS )z%s %sr= ©rC rO r= r= rA rG ë rä z*IMAP4Server.__cbStatus..ó STATUS rþ ó (rm s STATUS complete)r: r† rœ r, r rˆ )rZ ÚstatusrÚ r r¨ r= r= rA Ú
__cbStatusé s
ÿzIMAP4Server.__cbStatusc C s& | |d| d tt|jƒƒ ¡ d S )Nr+ s failed: ©r4 r: r… rb )rZ rO rÚ r r= r= rA Ú
__ebStatusñ s ÿzIMAP4Server.__ebStatusc C s4 t |ƒ}t| jj|ƒ | j||||¡ | j|¡ d S rm )rØ r r¸ rÙ rC Ú_cbAppendGotMailboxr Ú_ebAppendGotMailbox)rZ rÚ r" r{ r€ r… r= r= rA Ú do_APPENDö ó
ÿzIMAP4Server.do_APPENDc C sR |s
| |d¡ d S dd„ |D ƒ}| |||¡}| | j||¡ | | j|¡ d S )Nz[TRYCREATE] No such mailboxc S rå r= ©r9 rç r= r= rA rG rä z3IMAP4Server._cbAppendGotMailbox..)r7 Ú
addMessagerC Ú_IMAP4Server__cbAppendr Ú_IMAP4Server__ebAppend)rZ r rÚ r{ r€ r… Ú decodedFlagsrè r= r= rA r1 ü s z IMAP4Server._cbAppendGotMailboxc C r r( rà rN r= r= rA r2 r z IMAP4Server._ebAppendGotMailboxc C s$ | d| ¡ f ¡ | |d¡ d S )Nré s APPEND complete)r, rî rˆ )rZ rJ rÚ r r= r= rA Ú
__cbAppend
s zIMAP4Server.__cbAppendc C rÀ )Ns APPEND failed: r/ rN r= r= rA Ú
__ebAppend r zIMAP4Server.__ebAppendc C s> | ¡ }|d u r| d |¡ d S |j| j| j|f|fd d S )N)Ú callbackArgsÚ errbackArgs)Ú
checkpointÚ_IMAP4Server__cbCheckr² Ú_IMAP4Server__ebCheck©rZ rÚ rè r= r= rA Údo_CHECK s
ÿzIMAP4Server.do_CHECKc C s | |d¡ d S )Ns CHECK completedr¡ ©rZ rJ rÚ r= r= rA Ú __cbCheck! rŒ zIMAP4Server.__cbCheckc C rÀ )Ns CHECK failed: r/ rN r= r= rA Ú __ebCheck$ ó zIMAP4Server.__ebCheckc C ó dS )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= r^ r= r= rA r> ' s zIMAP4Server.checkpointc sŒ d }| j ¡ r
t| j jƒ}t| j d ƒ‰ ˆ d ur*|d ur%| ‡ fdd„¡ ntˆ jƒ}|d ur>| | j| j |fd |fd ¡ d S | d |¡ d S )Nc ó ˆ ¡ S rm )r )rJ ©r r= rA rP 9 rQ z&IMAP4Server.do_CLOSE..)
r rñ r Úexpunger rC r r² Ú_IMAP4Server__cbCloseÚ_IMAP4Server__ebCloserA r= rI rA Údo_CLOSE2 s
zIMAP4Server.do_CLOSEc C s( | |d¡ | j | ¡ d | _d| _d S )Ns CLOSE completedr· )rˆ r r r rC r= r= rA Ú __cbCloseC s
zIMAP4Server.__cbClosec C rÀ )Ns CLOSE failed: r/ rN r= r= rA Ú __ebCloseI rF zIMAP4Server.__ebClosec C sB | j ¡ rt| j jƒ | j| j|fd |fd ¡ d S | |d¡ d S )Ns$ EXPUNGE ignored on read-only mailbox)r rñ r rJ r² Ú_IMAP4Server__cbExpungeÚ_IMAP4Server__ebExpunger7 rÙ r= r= rA Ú
do_EXPUNGEL s
ÿzIMAP4Server.do_EXPUNGEc C s* |D ]
}| d|f ¡ q| |d¡ d S )Ns
%d EXPUNGEs EXPUNGE completed)r, rˆ )rZ rJ rÚ r. r= r= rA Ú __cbExpungeV s zIMAP4Server.__cbExpungec C ó( | |dtt|jƒƒ ¡ t |¡ d S )Ns EXPUNGE failed: ©r4 r: r… rb r4 r rN r= r= rA Ú __ebExpunge[ ó ÿzIMAP4Server.__ebExpungec C s| t | jd ƒ}|d ur!t|j||d | j|| j|¡ | j|¡ d S tdƒ}t| jj ||d | j
|| j||¡ | j|¡ d S )N©r> s 1:*) ÚISearchableMailboxr r rz rC Ú_IMAP4Server__cbSearchr Ú_IMAP4Server__ebSearchrt ÚfetchÚ _IMAP4Server__cbManualSearch)rZ rÚ Úcharsetrr r> Úsmr¹ r= r= rA Ú do_SEARCHa s ÿÿzIMAP4Server.do_SEARCHc C sF |rt |j|ƒ}td dd„ |D ƒ¡ƒ}| d| ¡ | |d¡ d S )Nr) c S rå r= rŠ ©rC rc r= r= rA rG t rä z*IMAP4Server.__cbSearch..ó SEARCH ó SEARCH completed)r ÚgetUIDr: r† r, rˆ )rZ rJ rÚ r r> Úidsr= r= rA Ú
__cbSearchq s
zIMAP4Server.__cbSearchc
C sî |du rg }d}|o|d d }|o|d d ¡ } tttdƒ|ƒƒD ] \}\}
} | t |¡|
| || ¡rC| d|r>| ¡ n|
f ¡ q#|dkrcddlm } |
d| j t|dd… ƒ|||||¡ dS |ro| d d
|¡ ¡ | |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.
Nr rt r; é s %dé ©Úreactorrb rØ rc )rd rV ÚzipÚrangeÚ
_searchFilterrÅ Údeepcopyrl Útwisted.internetrj Ú callLaterr] r, r† rˆ )
rZ rJ rÚ r rr r> Ú
searchResultsrc ÚlastSequenceIdÚ
lastMessageIdÚmsgIdrŠ rj r= r= rA Ú__cbManualSearchx s4 ÿ € ø z IMAP4Server.__cbManualSearchc C s" |r| |||||¡s
dS |sdS )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)rZ rr ÚidrŠ rr rs r= r= rA rm ´ s
ÿüzIMAP4Server._searchFilterc C sº | d¡}t|tƒr| |||||¡sdS dS | ¡ }|dd… ¡ s,t||ƒ}||v S t| dt|ƒ dƒ} | du rBt dt|ƒ ƒ‚|| j
v rQ| |||||fƒ}
n| |||ƒ}
|
s[dS dS )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.
r FNr; Úsearch_zInvalid search command %sT) r% rU rV rm r5 Úisalphart r) r9 r Ú_requiresLastMessageInfo) rZ rr rt rŠ rr rs Úqrš Ú
messageSetr- rJ r= r= rA rw Ñ s(
ë
ÿ
z IMAP4Server._singleSearchStepc C rG )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= ©rZ rr rx rŠ r= r= rA Ú
search_ALL s zIMAP4Server.search_ALLc C ó d| ¡ v S )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}
ú \Answered©rí r~ r= r= rA Úsearch_ANSWERED s zIMAP4Server.search_ANSWEREDc C ó0 | dd¡ dd¡}| ¡ | d¡ ¡ ¡dkS )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}
FÚbccÚ r rt ©Ú
getHeadersÚgetrâ ro r% )rZ rr rx rŠ r… r= r= rA Ú
search_BCC s zIMAP4Server.search_BCCc C s& t | d¡ƒ}tj t| ¡ ƒ¡|k S r² )Ú parseTimer% ÚemailÚutilsÚ parsedater9 ÚgetInternalDate©rZ rr rx rŠ r€ r= r= rA Ú
search_BEFORE, s zIMAP4Server.search_BEFOREc C ó | d¡ ¡ }t || ¡ d¡S ©Nr F©r% râ r5 ÚstrFileÚ getBodyFile©rZ rr rx rŠ Úbodyr= r= rA Ú search_BODY0 s zIMAP4Server.search_BODYc C r„ )NFÚccr† r rt r‡ )rZ rr rx rŠ rš r= r= rA Ú search_CC4 ó zIMAP4Server.search_CCc C r€ ©Nz\Deletedr‚ r~ r= r= rA Úsearch_DELETED8 ó zIMAP4Server.search_DELETEDc C r€ ©Nz\Draftr‚ r~ r= r= rA Ú search_DRAFT; rŸ zIMAP4Server.search_DRAFTc C r€ ©Nz\Flaggedr‚ r~ r= r= rA Úsearch_FLAGGED> rŸ zIMAP4Server.search_FLAGGEDc C r„ )NFÚfromr† r rt r‡ )rZ rr rx rŠ Úfmr= r= rA Ú search_FROMA rœ zIMAP4Server.search_FROMc C s> | d¡ ¡ }| d|¡ |d¡}| ¡ | d¡ ¡ ¡dkS )Nr Fr† rt )r% râ rˆ r‰ ro )rZ rr rx rŠ Úhdrr= r= rA Ú
search_HEADERE s zIMAP4Server.search_HEADERc C ó | d¡ dS r“ ©r% r~ r= r= rA Úsearch_KEYWORDJ ó
zIMAP4Server.search_KEYWORDc C s t | d¡ƒ| ¡ k S r² ©rd r% ÚgetSizer~ r= r= rA Ú
search_LARGERN ó zIMAP4Server.search_LARGERc C s d| ¡ v o d| ¡ vS )Nú\Recentú\Seenr‚ r~ r= r= rA Ú
search_NEWQ s zIMAP4Server.search_NEWc C s |\}}| |||||¡ 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.
rv )rZ rr rx rŠ ÚlastIDsrr rs r= r= rA Ú
search_NOTT s zIMAP4Server.search_NOTc C ó d| ¡ vS ©Nr± r‚ r~ r= r= rA Ú
search_OLDj rŸ zIMAP4Server.search_OLDc C s" t | d¡ƒ}tj | ¡ ¡|kS r² ©r‹ r% rŒ r rŽ r r r= r= rA Ú search_ONm ó zIMAP4Server.search_ONc C s4 |\}}| |||||¡}| |||||¡}|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.
rv ) rZ rr rx rŠ r´ rr rs ÚaÚbr= r= rA Ú search_ORq s zIMAP4Server.search_ORc C r€ r· r‚ r~ r= r= rA Ú
search_RECENTŠ rŸ zIMAP4Server.search_RECENTc C r€ ©Nr² r‚ r~ r= r= rA Ú search_SEEN rŸ zIMAP4Server.search_SEENc C s2 | dd¡ dd¡}tj |¡}|t| d¡ƒk S )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}
Fr€ r† r ©rˆ r‰ rŒ r rŽ r‹ r% r r= r= rA Úsearch_SENTBEFORE s z IMAP4Server.search_SENTBEFOREc C sB | dd¡ dd¡}tj |¡}|dd… t| d¡ƒdd… kS )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}
Fr€ r† Nr/ r r r r= r= rA Ú
search_SENTON¢ s "zIMAP4Server.search_SENTONc C s2 | dd¡ dd¡}tj |¡}|t| d¡ƒkS )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}
Fr€ r† r r r r= r= rA Úsearch_SENTSINCE± s z IMAP4Server.search_SENTSINCEc C s" t | d¡ƒ}tj | ¡ ¡|kS r² r¹ r r= r= rA Ú search_SINCEÀ r» zIMAP4Server.search_SINCEc C s t | d¡ƒ| ¡ kS r² r r~ r= r= rA Úsearch_SMALLERÄ r° zIMAP4Server.search_SMALLERc C r„ )NFÚsubjectr† r rt r‡ )rZ rr rx rŠ Úsubjr= r= rA Úsearch_SUBJECTÇ rœ zIMAP4Server.search_SUBJECTc C r’ r“ r” r— r= r= rA Ú search_TEXTË s zIMAP4Server.search_TEXTc C r„ )NFÚtor† r rt r‡ )rZ rr rx rŠ rÌ r= r= rA Ú search_TOÐ rœ zIMAP4Server.search_TOc C s( |\}}| d¡}t||ƒ}| ¡ |v S )al
Returns C{True} if the message UID is in the range defined by the
search query.
@type query: A L{list} of L{bytes}
@param query: A list representing the parsed form of the search
query. Its first element should be a L{str} that can be interpreted
as a sequence range, for example '2:4,5:*'.
@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% rt rd ) rZ rr rx rŠ r´ rr rs rš rj r= r= rA Ú
search_UIDÔ s
zIMAP4Server.search_UIDc C r¶ )Nr r‚ r~ r= r= rA Úsearch_UNANSWEREDï rŸ z IMAP4Server.search_UNANSWEREDc C r¶ r r‚ r~ r= r= rA Úsearch_UNDELETEDò rŸ z IMAP4Server.search_UNDELETEDc C r¶ r r‚ r~ r= r= rA Úsearch_UNDRAFTõ rŸ zIMAP4Server.search_UNDRAFTc C r¶ r¢ r‚ r~ r= r= rA Úsearch_UNFLAGGEDø rŸ z IMAP4Server.search_UNFLAGGEDc C r© r“ rª r~ r= r= rA Úsearch_UNKEYWORDû r¬ z IMAP4Server.search_UNKEYWORDc C r¶ rÀ r‚ r~ r= r= rA Ú
search_UNSEENÿ rŸ zIMAP4Server.search_UNSEENc C rT )Ns SEARCH failed: rU rN r= r= rA Ú
__ebSearch rW zIMAP4Server.__ebSearchc C sT |r"| d ¡| _t| jj||d t¡ | j|||¡ | j |¡ d S |
|d¡ d S )NrX s FETCH complete) r Ú _oldTimeoutr r r\ rC ÚiterÚ_IMAP4Server__cbFetchr Ú_IMAP4Server__ebFetchrˆ )rZ rÚ Úmessagesrr r> r= r= rA Údo_FETCH s ÿÿzIMAP4Server.do_FETCHc sŒ ˆj d u rg ˆ_ ztˆƒ\}}W n ty, ˆ ˆj¡ ˆ`ˆ ˆd¡ ˆ ¡ Y d S w ˆ ||ˆ ˆ¡ ‡ ‡‡‡‡fdd„¡ ˆj
¡ d S )Ns FETCH completedc s ˆ ˆˆˆ ˆ¡S rm )rØ ©rA ©rr ÚresultsrZ rÚ r> r= rA rP 4 s z'IMAP4Server.__cbFetch..) r# ÚnextÚ
StopIterationr rÖ rˆ r' Ú spewMessagerC r Ú_IMAP4Server__ebSpewMessage)rZ rÞ rÚ rr r> rx rŠ r= rÝ rA Ú __cbFetch s
éÿzIMAP4Server.__cbFetchc C s t |¡ | j ¡ d S rm )r4 r r´ r ©rZ rO r= r= rA Ú__ebSpewMessage7 s
zIMAP4Server.__ebSpewMessagec C s* |d u r| j j}|dtt|ƒgƒ ƒ d S )Ns ENVELOPE )r´ r¤ rÒ Ú getEnvelope©rZ rx rŠ Ú_wÚ_fr= r= rA Ú
spew_envelope? s zIMAP4Server.spew_envelopec C s< |d u r| j j}dd„ | ¡ D ƒ}|dd |¡ d ƒ d S )Nc S rå r= ræ rç r= r= rA rG G rä z*IMAP4Server.spew_flags..rë rØ rm )r´ Úwritenrí r† )rZ rx rŠ rè ré Ú encodedFlagsr= r= rA Ú
spew_flagsD s zIMAP4Server.spew_flagsc
C sì |d u r| j j}| ¡ }tj t|ƒ¡}|d u r&t d|||f ¡ t dƒ‚t
d|d d… ¡}t |t
|d f ƒ}|d d u rF|d }n&|d dkrOd} nd } || d
t|d ƒd d t|d ƒd d
f }|dt|ƒ ƒ d S )Nz$%d:%r: unpareseable internaldate: %rz(Internal failure generating INTERNALDATEz%d-%%s-%Y %H:%M:%S é r; s +0000r r• ó -s %04di éd rô s
INTERNALDATE )r´ r¤ r rŒ r Ú parsedate_tzr9 r4 rŠ r ÚtimeÚstrftimer: Ú _MONTH_NAMESÚabsÚ_quote)
rZ rx rŠ rè ré ÚidateÚttupÚstrdateÚodateÚsignr= r= rA Úspew_internaldateJ s.
ÿ(ÿþÿz IMAP4Server.spew_internaldatec C s2 |d u r| j j}t| d¡ƒ}|dt|ƒ ƒ d S )NTs RFC822.HEADER )r´ r¤ Ú_formatHeadersrˆ Ú_literal)rZ rx rŠ rè ré Úhdrsr= r= rA Úspew_rfc822headere s z IMAP4Server.spew_rfc822headerc C s2 |d u r| j j}|dƒ |ƒ t| ¡ ƒ | j ¡S )Ns RFC822.TEXT )r´ r¤ Ú FileProducerr– ÚbeginProducingrç r= r= rA Úspew_rfc822textk s
zIMAP4Server.spew_rfc822textc C ó& |d u r| j j}|d| ¡ f ƒ d S )Ns RFC822.SIZE %d)r´ r¤ r® rç r= r= rA Úspew_rfc822sizer ó zIMAP4Server.spew_rfc822sizec C sZ |d u r| j j}|dƒ |ƒ t|d ƒ}|d ur"t| ¡ ƒ | j ¡S t|d | jƒ | j ¡S )Ns RFC822 )r´ r¤ Ú IMessageFiler Úopenr ÚMessageProducerrü )rZ rx rŠ rè ré Úmfr= r= rA Ú spew_rfc822w s
ÿzIMAP4Server.spew_rfc822c C r )Ns UID %d)r´ r¤ rd rç r= r= rA Úspew_uidƒ r zIMAP4Server.spew_uidc C s |dt t|dƒgƒ ƒ d S )Ns BODYSTRUCTURE T)rÒ ÚgetBodyStructurerç r= r= rA Úspew_bodystructureˆ s z IMAP4Server.spew_bodystructurec C sp |d u r| j j}|jD ]}| ¡ r| |¡}q |dkr tdƒ‚q |jrB|j|jjg|jj ¢R Ž }t
|ƒ}|| ¡ d t |ƒ ƒ d S |j
rZ|| ¡ d ƒ |ƒ t| ¡ ƒ | j ¡S |jrrt
| d¡ƒ}|| ¡ d t |ƒ ƒ d S |jr«|| ¡ d ƒ |ƒ |jrt| ¡ ƒ | j ¡S t|d ƒ}|d ur t| ¡ ƒ | j ¡S t|d | jƒ | j ¡S |dtt|ƒgƒ ƒ d S )Nr z*Requested subpart of non-multipart messagerØ Ts BODY )r´ r¤ ÚpartÚ isMultipartÚ
getSubPartrn Úheaderrˆ ÚnegateÚfieldsrý Ú __bytes__rþ r5 r r– r ÚmimeÚemptyr r r rü rÒ r
) rZ r rx rŠ rè ré r‡ rÿ r
r= r= rA Ú spew_body‹ s>
ý
ÿzIMAP4Server.spew_bodyc
sf t ˆjƒ}|j‰ |j‰‡‡ fdd„‰‡ fdd„‰ ‡ fdd„‰‡ ‡‡‡‡‡‡‡‡‡ f
dd„}ˆ |ƒ ¡S ) Nc s ˆdˆ f ƒ d S )Ns * %d FETCH (r= r= )rx r¤ r= rA r[ ¶ r z&IMAP4Server.spewMessage..startc ó ˆ dƒ d S )Ns )
r= r= ©r¤ r= rA ré ¹ rŸ z'IMAP4Server.spewMessage..finishc r r× r= r= r r= rA Úspace¼ rŸ z&IMAP4Server.spewMessage..spacec 3 s¦ d} ˆƒ ˆD ]2}|j dkrd} |j dkr!ˆ |ˆˆˆ ˆ¡V ntˆd|j ƒ}|ˆˆˆ ˆƒV |ˆd ur:ˆƒ qˆrK| sKˆƒ ˆ ˆˆˆ ˆ¡V ˆ ƒ ˆƒ d S )NFr> Tr˜ Úspew_rt )Útyper r) r )ÚseenUIDr r- ©
ré r· rx rŠ rr rZ r r[ r> r¤ r= rA Úspew¿ s$ €
€
z%IMAP4Server.spewMessage..spew)r° r´ r¤ r· rü )rZ rx rŠ rr r> Úwbufr r= r rA rá ± s
zIMAP4Server.spewMessagec C s8 | | j¡ | `t |¡ | |dtt|jƒƒ ¡ d S )Ns FETCH failed: )r rÖ r4 r r4 r: r… rb rN r= r= rA Ú __ebFetchÔ s
zIMAP4Server.__ebFetchc C s~ | ¡ }| d¡}| d¡rd}n
| d¡rd}nd}dd„ |D ƒ}t| jj||||d | j| j|| j||fd |fd ¡ d S )
Ns SILENTr• r; rï rt r c S rå r= r5 rç r= r= rA rG ä rä z(IMAP4Server.do_STORE..rX ) r5 Úendswithr~ r r Ústorer² Ú_IMAP4Server__cbStoreÚ_IMAP4Server__ebStore)rZ rÚ rÚ Úmoder{ r> Úsilentr= r= rA Údo_STOREÚ s
úzIMAP4Server.do_STOREc
C sl |r.|s.| ¡ D ]%\}}|rd| |¡f }nd}dd„ |D ƒ} | d|d | ¡|f ¡ q| |d¡ d S )Ns UID %dr c S rå r= ræ rç r= r= rA rG ø rä z)IMAP4Server.__cbStore..s %d FETCH (FLAGS (%b)%b)rØ s STORE completed)rœ rd r, r† rˆ )
rZ rJ rÚ r r> r( Úkrž Úuidstrr{ r= r= rA Ú __cbStoreð s ÿzIMAP4Server.__cbStorec C rÀ ©NrL r/ rN r= r= rA Ú __ebStoreþ rF zIMAP4Server.__ebStorec C s4 t |ƒ}t| jj|ƒ | j||||¡ | j|¡ d S rm )rØ r r¸ rÙ rC Ú_cbCopySelectedMailboxr Ú_ebCopySelectedMailbox)rZ rÚ rÚ r" r> r= r= rA Údo_COPY r4 zIMAP4Server.do_COPYc C sN |s | |d| ¡ d S t| jj||ƒ | j||¡ | j||¡ | j|¡ d S )NzNo such mailbox: ) r7 r r r\ rC Ú_IMAP4Server__cbCopyÚ_IMAP4Server__cbCopiedr Ú_IMAP4Server__ebCopy)rZ r rÚ rÚ r" r> r= r= rA r/ s ÿ z"IMAP4Server._cbCopySelectedMailboxc C rÀ r- r/ rN r= r= rA r0 rF z"IMAP4Server._ebCopySelectedMailboxc sÈ g }t ˆ d ƒ}|D ]U\}}|d ur t|j|ƒ}| |¡ q | ¡ } | ¡ }
t|d ƒ} | d ur;| ¡ } tˆ j| | |
ƒ}n dd„ ‰t
¡ }
t ||
| j ƒ
d ¡ |
| |
f‡ ‡fdd„ ¡}| |¡ q t |¡S )Nc S s | d¡ | S r² )r¯ ©r- r= r= rA Úrewind+ r¬ z$IMAP4Server.__cbCopy..rewindc s ˆ ˆ|ƒ||¡S rm )r6 )rA r½ r- rè ©r r6 r= rA rP 4 s
ÿz&IMAP4Server.__cbCopy..)ÚIMessageCopierr rÅ rl rí r r r r6 r r® r rü r rC r
Ú DeferredList)rZ rÚ rÚ r ÚaddedDeferredsÚ fastCopyMboxrx rŠ rè r{ r€ r˜ ÚbodyFileÚbufferr= r7 rA Ú__cbCopy s.
ÿý
zIMAP4Server.__cbCopyc C sV g }g }|D ]\}}|r| |¡ q| |j¡ q|r#| |d¡ d S | |d¡ d S )Nz%[ALERT] Some messages were not copieds COPY completed)rl rb r7 rˆ )rZ Ú deferredIdsrÚ r re Úfailuresr- rJ r= r= rA Ú
__cbCopied< s zIMAP4Server.__cbCopiedc C rT )Ns COPY failed:rU rN r= r= rA Ú__ebCopyI s zIMAP4Server.__ebCopyc C s. | ¡ }|dvr t|ƒ‚| j|||dd d S )N)ó COPYrÅ ó STORErÁ r; rX )r5 r r6 )rZ rÚ rÒ r¨ r= r= rA Údo_UIDM s zIMAP4Server.do_UIDc C s( |r | j ddd d S | j ddd d S )Ns [READ-WRITE]T)r… r’ s [READ-ONLY]©r, ©rZ Ú writeabler= r= rA Ú modeChangedZ s zIMAP4Server.modeChangedc C sD | ¡ D ]\}}dd„ |D ƒ}d|d |¡f }| j|dd qd S )Nc S rå r= ræ rç r= r= rA rG b rä z,IMAP4Server.flagsChanged..s %d FETCH (FLAGS (%b))rØ T©r’ )rœ r† r, )rZ ÚnewFlagsÚmIdr{ rì rŠ r= r= rA Ú flagsChanged` s
ýzIMAP4Server.flagsChangedc C s@ |d ur| j d|f dd |d ur | j d|f dd d S d S )Nré TrJ rê rF ©rZ ÚexistsÚrecentr= r= rA Ú newMessagesf s
ÿzIMAP4Server.newMessages©NNNrm ©F©Nr )r” ©r r] )çr r‘ r’ r“ r‡ r
r¹ r r r
r¥ r¸ r r r rR rù r{ r r* r] r r r r r" r# r' r$ r: r; r6 r< r= rD rE rW rX r[ rZ ÚreÚcompileÚescapeÚ
_atomCharsrg rk rp rq rs ru rx r| r} r r rƒ r r4 rˆ r7 r, rT rŽ r† rŸ Úunauth_CAPABILITYÚauth_CAPABILITYÚselect_CAPABILITYÚlogout_CAPABILITYr Ú
unauth_LOGOUTÚ auth_LOGOUTÚ
select_LOGOUTÚ
logout_LOGOUTr¢ Ú unauth_NOOPÚ auth_NOOPÚ select_NOOPÚ logout_NOOPr¤ Úunauth_AUTHENTICATEr£ r¦ r¨ r³ r´ r© rÆ Úunauth_STARTTLSrÌ Ú unauth_LOGINrÇ rÈ rÉ r× Úauth_NAMESPACEÚselect_NAMESPACErß rÛ rÚ Ú auth_SELECTÚ
select_SELECTÚ auth_EXAMINEÚselect_EXAMINErø rù Ú select_IDLEÚ auth_IDLErü Ú auth_CREATEÚ
select_CREATEr Ú auth_DELETEÚ
select_DELETEr Ú auth_RENAMEÚ
select_RENAMEr Úauth_SUBSCRIBEÚselect_SUBSCRIBEr Úauth_UNSUBSCRIBEÚselect_UNSUBSCRIBEr r r Ú auth_LISTÚ select_LISTÚ auth_LSUBÚ select_LSUBr$ r r! Ú auth_STATUSÚ
select_STATUSr& r' r3 r1 r2 Ú auth_APPENDÚ
select_APPENDr7 r8 rB Ú select_CHECKr? r@ r> rM Ú select_CLOSErK rL rR Úselect_EXPUNGErP rQ r` Ú
select_SEARCHrZ r] rm rw r rƒ rŠ r‘ r™ r› rž r¡ r£ r¦ r¨ r« r¯ r³ rµ r¸ rº r¾ r¿ rÁ rà rÄ rÅ rÆ rÇ rÊ rË rÍ rÎ rÏ rÐ rÑ rÒ rÓ rÔ r[ rÛ Ú select_FETCHrØ râ rê rí rü r r r r r r r rá rÙ r) Ú select_STOREr% r& r1 Ú select_COPYr/ r0 r2 r3 r4 rE Ú
select_UIDrI rM rQ r= r= r= rA ró U sÆ
/ÿ
< 0
" & #
(
ró c @ sJ e Zd ZdZdZdZdZdZdZdZ dZ
dZ dZ dZ
dZeeedœZdZdºd d
„Zd d „ Zd
d„ Zdd„ Zdd„ Zdd„ Zdd„ Zdd„ Zdd„ Zdd „ Zd d „ Z d d „ Z d!d"„ Z d#d$„ Z d%d&„ Z d'd(„ Z!d)d*„ Z"d+d,„ Z#d»d-d.„Z$d/d0„ Z%d1d2„ Z&d3d4„ Z'd5d6„ Z(d7d8„ Z)dºd9d:„Z*d;d<„ Z+d=d>„ Z,d?d@„ Z-dAdB„ Z.dCdD„ Z/dEdF„ Z0dGdH„ Z1dIdJ„ Z2dKdL„ Z3dMdN„ Z4dOdP„ Z5dQdR„ Z6dSdT„ Z7dUdV„ Z8dWdX„ Z9dYdZ„ Z:d[d\„ Z;d]d^„ Zdcdd„ Z?dedf„ Z@dgdh„ ZAdidj„ ZBdkdl„ ZCdmdn„ doD ƒZDdpdq„ ZEdrds„ ZFd¼dudv„ZGdwdx„ ZHdydz„ ZId{d|„ ZJd}d~„ ZKdd€„ ZLdd‚„ ZMddƒœd„d…„ZNd†d‡„ ZOd½dˆd‰„ZPd½dŠd‹„ZQd½dŒd„ZRd½dŽd„ZSd½dd‘„ZTd½d’d“„ZUd½d”d•„ZVd½d–d—„ZWd½d˜d™„ZXd½dšd›„ZYd½dœd„ZZd½dždŸ„Z[d½d d¡„Z\d¢d£„ Z]d¤d¥„ Z^ d¾d¦d§„Z_d½d¨d©„Z`d¿dªd«„Zad¿d¬d„Zbd¿d®d¯„Zcd°d±„ Zdd²d³„ Zed´dµ„ Zfd¶d·„ Zgd¸d¹„ ZhdS )ÀÚ IMAP4ClientzIMAP4 client protocol implementation
@ivar state: A string representing the state the connection is currently
in.
Nr; Fr r« )ÚOKÚNOÚBADÚPREAUTHÚBYE)ÚMESSAGESÚRECENTÚUNSEENc C s. i | _ g | _i | _|| _d | _d | _d | _d S rm )r
ÚqueuedÚauthenticatorsÚcontextÚ_tagÚ_partsÚ_lastCmd)rZ rÿ r= r= rA r] • s
zIMAP4Client.__init__c C s || 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)r• ÚgetNamer5 )rZ r· r= r= rA ÚregisterAuthenticatorŸ s z!IMAP4Client.registerAuthenticatorc C s¸ | j dkr | ¡ | jt|ƒ8 _| jdkr | j |¡ d S d}| jdk r5|d | j… || jd … }}| j |¡ | j}d | _d | _| dd¡ | j | ¡ ¡ |
| d¡¡ d S )Nr r ó
) r r Ú _pendingSizer¡ Ú_pendingBufferr¤ r¯ r˜ rl Úreadr! Úlstrip)rZ rš r£ r8 r= r= rA r" s
zIMAP4Client.rawDataReceivedc C sD | |¡| _|| _| jd u r|dg| _n| j |dg¡ | ¡ d S )Nrœ )Ú messageFilerž r r˜ rr rU )rZ r8 Úoctetsr= r= rA Ú_setupForLiteralÄ s
z IMAP4Client._setupForLiteralc C s | j dkr
| | j ¡ d S d S r² )r r r^ r= r= rA r Í s
ÿzIMAP4Client.connectionMadec C sŠ | j dkr
| d¡ | jdur | j}d| _|D ]}|j |¡ q| jdurA| j}d| _| ¡ D ]}|dur@|jdur@|j |¡ q/dS dS )z,
We are no longer connected
r N)r r r” r
Úerrbackr
Úvalues)rZ r r” r9 r
r= r= rA r Ñ s
€ûzIMAP4Client.connectionLostc C sð | j dkr | ¡ | d¡}|dkrN||d d… }| d¡rNz
t|dd… ƒ}W n ty4 t|ƒ‚w | jdu rD| dd¡\| _ }n|}|
||¡ dS | jdu rZ| |¡ dS | j |¡ | j d
| j¡}}d | _ | _| ||¡ dS )aF
Attempt to parse a single line from the server.
@type line: L{bytes}
@param line: The line from the server, without the line delimiter.
@raise IllegalServerResponse: If the line or some part of the line
does not represent an allowed message from the server at this time.
r r_ rt r; Nr` r )r r Úrfindr# rd r` r r˜ r3 r— r£ Ú_regularDispatchrl r† r6 )rZ r¨ ÚlastPartr¢ ÚpartsrÚ r8 r= r= rA r$ ã s,
ÿ
zIMAP4Client.lineReceivedc C sp | j r| j jd ur| j jd }| j _| t¡ | jr1| jD ]}|jd ur0|j|}|_| t¡ q | j ¡ d S rm )r™ r
r¤ Ú
TIMEOUT_ERRORr” r´ r )rZ rè r9 r= r= rA r
s
€z IMAP4Client.timeoutConnectionc C s: | d d¡}t|ƒdkr| d¡ |\}}| ||¡ d S )Nr; rÛ r )r3 r¡ rl r6 )rZ r¨ r© rÚ r8 r= r= rA r§
s
z IMAP4Client._regularDispatchc C s || j kr t ¡ S tƒ S )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
)r¬ r r® r )rZ r¢ r= r= rA r¡ !
s
zIMAP4Client.messageFilec C s" d| j d¡}| j d7 _ |S )Nz%0.4XÚasciir; )ÚtagIDr rÙ r= r= rA ÚmakeTag1
s zIMAP4Client.makeTagc C s | j d u r | j}n t| d| j ¡ d ƒ}|r2z|||ƒ W d S ty1 t ¡ | j ¡ Y d S w t d| j › d|›d|›¡ | j ¡ d S )NÚ response_zCannot dispatch: z, ) r Úresponse_UNAUTHr) r5 rû r4 r r´ r )rZ rÚ r8 r- r= r= rA r6 6
s
þ zIMAP4Client.dispatchCommandc C sÊ | j d u r]| d d¡\}}| ¡ dkrd| _ n| ¡ dkr!d| _ n
| j ¡ t|d | ƒ‚| d¡| d¡}}|d krV|d krV| | t ||d |… ƒgd f¡¡ d S | d ¡ d S |
||¡ d S )
Nr; rÜ rø s PREAUTHr· rØ rì ó ]rt ) r r3 r5 r´ r r ro ÚserverGreetingÚ _IMAP4Client__cbCapabilitiesrÝ Ú_defaultHandler)rZ rÚ r8 r- r½ r. r= r= rA r¯ E
s
ÿzIMAP4Client.response_UNAUTHc C s | ||¡ d S rm )r³ )rZ rÚ r8 r= r= rA Ú
response_AUTH\
rŒ zIMAP4Client.response_AUTHc C sæ |dks|dkr.| j s| t|ƒg¡ d S | j| j }|dkr&| |¡ d S |j |¡ d S z| j| }W n tyI | j ¡ t
|d | ƒ‚w | d d¡\}}|dkr^| || j¡ n|j
t|ƒ¡ | j|= d | _ | ¡ d S )Nr— r• rØ r; rÜ )ÚwaitingÚ
_extraInforÝ r
rÐ rÕ rl ÚKeyErrorr´ r r r3 ré r
r¤ r Ú _flushQueue)rZ rÚ r8 r9 r- r¨ r= r= rA r³ _
s(
ý zIMAP4Client._defaultHandlerc C sB | j r | j d¡}| ¡ }|| j|< | | |¡¡ || _d S d S r² )r” r% r r
r rÖ rµ ©rZ r9 Útr= r= rA r¸ {
s
ûzIMAP4Client._flushQueuec
C s6 i }d }}|D ]y}t |ƒ}|dkr |d dgkr | d¡ q|dkr0|d dgkr0| d¡ q|dkrA|d dkrAt|d ƒ}q|dkrR|d d krRt|d ƒ}q|d
kry|d d kryt|d ƒ}| |d ¡\}} | |g ¡ | d d
¡¡ qt d|› ¡ q|r‰| |¡ |d us‘|d ur™|
||¡ d S d S )Nr; r rÊ FrÉ TrÛ rà rÆ r/ rÅ ÚFLAGSr= z Unhandled unsolicited response: ) r¡ rI rd Ú_parseFetchPairsÚ
setdefaultrr r‰ r4 rŠ rM rQ )
rZ rÕ r{ rP rO ÚresponseÚelementsrL r¥ rA r= r= rA r¶ ƒ
s,
ÿzIMAP4Client._extraInfoc C sV t ¡ |_ | jr| j |¡ |j S | ¡ }|| j|< | | |¡¡ || _|| _ |j S rm )
r
rS rµ r” rl r r
r rÖ r™ r¹ r= r= rA Ú sendCommandŸ
s
zIMAP4Client.sendCommandc C sD |r
| j dur
t | j ¡S d}d}| t||d¡}| | 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¼ )r¼ ©rÔ )Ú _capCacher
ÚsucceedrÀ r» rC r² )rZ ÚuseCacher9 r rè r= r= rA ÚgetCapabilities«
s zIMAP4Client.getCapabilitiesc
C s” |\}}i }|D ],}|dd … D ]#}| dd¡}t|ƒdkr&|d d }} n|\}} | |g ¡ | ¡ qq|D ]
}|| d gkrDd ||< q7|| _|S )Nr; r˜ r )r3 r¡ r½ rl r )
rZ rJ rÕ Útagliner r8 r r© Úcategoryrb r= r= rA Ú__cbCapabilitiesÄ
s ú €z IMAP4Client.__cbCapabilitiesc C s" | tddd¡}| | j¡ |S )a*
Inform the server that we are done with the connection.
This command is allowed in any state of connection.
@rtype: L{Deferred}
@return: A deferred whose callback will be invoked with None
when the proper server acknowledgement has been received.
s LOGOUT)s BYErÁ )rÀ r» rC Ú_IMAP4Client__cbLogout©rZ rè r= r= rA r½ Ù
s
zIMAP4Client.logoutc C s |\}}| j ¡ d S rm )r´ r ©rZ rJ rÕ rÆ r= r= rA Ú
__cbLogoutç
s
zIMAP4Client.__cbLogoutc C s | tdƒ¡}| | j¡ |S )a
Perform no operation.
This command is allowed in any state of connection.
@rtype: L{Deferred}
@return: A deferred whose callback will be invoked with a list
of untagged status updates the server responds with.
s NOOP)rÀ r» rC Ú_IMAP4Client__cbNooprÊ r= r= rA Únoopí
s
zIMAP4Client.noopc C s |\}}|S rm r= rË r= r= rA Ú__cbNoopû
s zIMAP4Client.__cbNoopc s¢ ˆ j rJ dƒ‚|du rˆ ¡ }|du rt tdƒ¡S dˆ jvr&t tdƒ¡S t ˆ jd¡}|du r8t tdƒ¡S ˆ t
dƒ¡}| ˆ j |¡ | ‡ fdd„¡ |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 rH rm ©rÅ rÜ r^ r= rA rP 1 rQ z&IMAP4Client.startTLS..)
r Ú_getContextFactoryr
Úfailr r r r r´ rÀ r» rC Ú _startedTLS)rZ rÿ Útlsrè r= r^ rA rÄ s: ÿþÿÿ
ÿÿÿÿzIMAP4Client.startTLSc C s2 | j du r
| ¡ }nt | 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.
N)r rŠr
rà rC Ú _IMAP4Client__cbAuthenticate)rZ Úsecretrè r= r= rA r£ 4 s
zIMAP4Client.authenticatec s¦ | dd¡‰ ˆ D ]}| ¡ ˆjv r"td|dˆj||ƒ}ˆ |¡ S qˆjr1t t ˆ ˆj
¡ ƒ¡S ‡ ‡fdd„}ˆ ¡ }| |¡ |
‡fdd„¡ |
ˆj|¡ |S )Nr r= ó AUTHENTICATEc s | t¡ t tˆ ˆj ¡ ƒ¡S rm )Útrapr r
rÒ r# r• r )r ©ÚauthsrZ r= rA Ú
ebStartTLST s
ÿz0IMAP4Client.__cbAuthenticate..ebStartTLSc rH rm rÐ rÜ r^ r= rA rP ] rQ z.IMAP4Client.__cbAuthenticate..)r‰ r5 r• r» Ú _IMAP4Client__cbContinueAuthrÀ r r
rÒ r# r rÄ r rC Ú_IMAP4Client__cbAuthTLS)rZ r rÖ Úschemer9 rÛ rè r= rÙ rA Ú__cbAuthenticateE s$ ÿüÿ
z IMAP4Client.__cbAuthenticatec C s` zt |d ƒ}W n tjy | d¡ t|ƒ‚w | j| }| ||¡}| t|ƒ ¡ ¡ d S )Nó
r— ) r r¬ r r r r• ÚchallengeResponser rc )rZ r8 rÞ rÖ rþ r· r= r= rA Ú__cbContinueAutha s
þ
z IMAP4Client.__cbContinueAuthc C sV | dd¡}|D ]}| ¡ | jv r"td|d| j||ƒ}| |¡ S qt|| j ¡ ƒ‚)Nr r= r× )r‰ r5 r• r» rÜ rÀ r# r )rZ r rÖ rÚ rÞ r9 r= r= rA Ú __cbAuthTLSl s ÿüzIMAP4Client.__cbAuthTLSc C s t | 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.
)r rÅ rC Ú_IMAP4Client__cbLoginCaps)rZ ÚusernameÚpasswordrè r= r= rA r° v s
zIMAP4Client.loginc C rG )z¦
Called when the server has sent us a greeting.
@type caps: C{dict}
@param caps: Capabilities the server advertised in its greeting.
Nr= )rZ r r= r= rA r± ó zIMAP4Client.serverGreetingc C sL | j d ur| j S zddlm} W n
ty Y d S w | ¡ }|jj|_|S )Nr )Ússl)r– ro rè Ú ImportErrorÚClientContextFactoryÚSSLÚ TLSv1_METHODÚmethod)rZ rè r– r= r= rA rÑ — s
ÿ
z IMAP4Client._getContextFactoryc C s– d|v }t | jd ¡d u}t | jd ¡d u }| js1|r1|r1|r1| ¡ }|j| j| j||fd |S |r8t
d¡ d t |ƒt |ƒf¡}|
td|ƒ¡S )Nr )r< z5Server has no TLS support. logging in over cleartext!rØ rà )r r r´ r r rÄ r² Ú_IMAP4Client__cbLoginTLSÚ_IMAP4Client__ebLoginTLSr4 rŠ r† rö rÀ r» ) rZ r rå ræ ÚtryTLSÚtlsableTransportÚnontlsTransportrè rÓ r= r= rA Ú
__cbLoginCaps£ s ý
zIMAP4Client.__cbLoginCapsc C s | j |¡ d | _d| _|S )NT)r´ rÄ r r )rZ rJ r– r= r= rA rÓ ¼ s zIMAP4Client._startedTLSc C s& d t|ƒt|ƒf¡}| td|ƒ¡S )NrØ rà )r† rö rÀ r» )rZ rJ rå ræ rÓ r= r= rA Ú __cbLoginTLS s zIMAP4Client.__cbLoginTLSc C s t |¡ |S rm )r4 r rä r= r= rA Ú __ebLoginTLSÆ r¬ zIMAP4Client.__ebLoginTLSc C ó* d}d}| t||d¡}| | 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 )r rÁ )rÀ r» rC Ú_IMAP4Client__cbNamespace©rZ r9 r rè r= r= rA Ú namespaceÊ ó
zIMAP4Client.namespacec sd |\}}dd„ ‰ |D ] }t |ƒdkr'|d dkr'‡ fdd„|dd … D ƒ S q
t d ¡ g g g gS )
Nc S s dd„ | D ƒS )Nc S ó g | ]}| d ¡‘qS )rþ )Údecode)rC Úelementr= r= rA rG í rÑ zSIMAP4Client.__cbNamespace.._prepareNamespaceOrDelimiter..r= )Ú
namespaceListr= r= rA Ú _prepareNamespaceOrDelimiterì ó z?IMAP4Client.__cbNamespace.._prepareNamespaceOrDelimiterrh r r c s* g | ]}|d u r
g n‡ fdd„|D ƒ‘qS )Nc ó g | ]}ˆ |ƒ‘qS r= r= )rC rb ©rÿ r= rA rG ô rä z8IMAP4Client.__cbNamespace...r= )rC Ú
pairOrNoner r= rA rG ñ s þÿýz-IMAP4Client.__cbNamespace..r; z*No NAMESPACE response to NAMESPACE command)r¡ r4 r )rZ rJ rÕ r_ r© r= r rA Ú
__cbNamespaceß s
ü€
zIMAP4Client.__cbNamespacec C ó6 d}t |ƒ}d}| t|||d¡}| | 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.
ró )r» ÚEXISTSr’ r“ ÚPERMANENTFLAGSÚ UIDVALIDITYrÁ r; ©Ú_prepareMailboxNamerÀ r» rC Ú_IMAP4Client__cbSelect©rZ r" r9 rÓ r rè r= r= rA rÙ ú s zIMAP4Client.selectc C r )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.
rô )r½ rà rÆ rÈ rÌ rÇ rÁ r r r r= r= rA Úexamine# s zIMAP4Client.examinec C s" zt |ƒW S ty t|ƒ‚w )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.
)rd r` r )rZ rb Úphraser= r= rA Ú _intOrRaiseQ s
ÿzIMAP4Client._intOrRaisec C sê |\}}d|i}| t|ƒ¡ |D ]á}t|ƒdkr|d ¡ dkr|d }t|tƒr/|d }n|}| ¡ }|dkr>d|d< q|dkrGd|d< q|d krV| |d |¡|d
< q|d kre| |d |¡|d < q|d
krt| |d |¡|d< q|dkr†tdd„ |d D ƒƒ|d< qt d|› ¡ qt|ƒdkrê|d ¡ dkr«tdd„ |d D ƒƒ|d< qt|d t
ƒrá|d ¡ dkrÅ| |d |¡|d< q|d ¡ dkrØ| |d |¡|d< qt d |› ¡ qt d |› ¡ qt d |› ¡ q|S ) zy
Handle lines received in response to a SELECT or EXAMINE command.
See RFC 3501, section 6.3.1.
z
READ-WRITEr rÜ r; rÊ FrÉ TrÇ r rÈ r“ rË ÚUIDNEXTrÌ c s r rm r5 rç r= r= rA rò | s €
ÿz)IMAP4Client.__cbSelect..r z Unhandled SELECT response (2): rÛ r½ c s r rm r5 rç r= r= rA rò „ r r» rà r rÆ r’ z Unhandled SELECT response (0): z Unhandled SELECT response (1): z Unhandled SELECT response (4): ) rl rÝ r¡ r5 rU rV r Útupler4 r Úbytes) rZ rJ rÝ rÕ rÆ Údatumr3 Úcontentrg r= r= rA Ú
__cbSelect\ sJ
ÿ zIMAP4Client.__cbSelectc C ó | 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.
s CREATE©rÀ r» r
©rZ rÜ r= r= rA rú • ó
zIMAP4Client.createc C r )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.
s DELETEr r r= r= rA rÿ ¤ r zIMAP4Client.deletec C s* t |ƒ}t |ƒ}| tdd ||f¡ƒ¡S )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.
s RENAMErØ )r
rÀ r» r† )rZ r r r= r= rA r ³ s zIMAP4Client.renamec C r )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 SUBSCRIBEr r r= r= rA r Ç r zIMAP4Client.subscribec C r )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 UNSUBSCRIBEr r r= r= rA r Ö r zIMAP4Client.unsubscribec C sF d}d|› d|› d d¡}d}| t|||d¡}| | 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" "rþ )r¾ rÁ )r rÀ r» rC Ú_IMAP4Client__cbList)rZ Ú referenceÚwildcardr9 rÓ r rè r= r= rA rV å s zIMAP4Client.listc C sV d}| d¡}| d¡}d d|d|dg¡}d}| t|||d¡}| | 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.
r¿ r« rþ r r^ s " ")r¿ rÁ )r r† rÀ r» rC r ) rZ r r r9 ÚencodedReferenceÚencodedWildcardrÓ r rè r= r= rA Úlsub
s
ûÿ zIMAP4Client.lsubc C s† |\}}g }|D ]8}t |ƒdkr@|d |kr@tdd„ |d D ƒƒ|d< |d d¡|d< |d d¡|d< | t|dd … ƒ¡ q|S ) Nrh r c s r rm r5 rç r= r= rA rò +
r z'IMAP4Client.__cbList..r; rÛ rþ r/ )r¡ r rü rl )rZ rJ rÒ rÕ r_ rÞ r© r= r= rA Ú__cbList$
s
€zIMAP4Client.__cbListc C s i | ]}|| d ¡“qS )r« ©r ©rC rÜ r= r= rA Ú
?
s
ÿÿzIMAP4Client.©r‘ r’ r r r“ c sŽ d}t |ƒ}zd ‡ fdd„|D ƒ¡}W n ty) tdt|ƒtˆ jƒ ›ƒ‚w d |d|dg¡}d }ˆ t|||d
¡}| ˆ 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.
rÀ rØ c 3 s | ]}ˆ j | V qd S rm )Ú _statusNamesr# r^ r= rA rò c
s € z%IMAP4Client.status..zUnknown names: r r, rm )rÀ rÁ )
r
r† r· r` Úsetr& rÀ r» rC Ú_IMAP4Client__cbStatus)rZ r" ræ r9 ÚpreparedMailboxrÓ r rè r= r^ rA r- J
s ÿ zIMAP4Client.statusc
sô |\}}i }|D ]7}|d dkr?|d ‰ ‡ fdd„t dtˆ ƒdƒD ƒ‰ ˆ D ]\}}z||t|ƒ< W q% ty> ttˆ ƒƒ‚w q| ¡ D ]3}| j |¡}|rwz
||| ƒ||< W qD t yv } ztd| d || d t
| ƒ ƒ‚d } ~ ww qD|S ) Nr rÀ rÛ c s g | ]
}ˆ ||d … ‘qS )rÛ r= ra ©rœ r= rA rG s
ó z*IMAP4Client.__cbStatus..ú(r) z): ) rl r¡ r9 ÚUnicodeDecodeErrorr rF r ÚSTATUS_TRANSFORMATIONSr‰ r+ r… )
rZ rJ rÕ r_ r- r© r* rž rº r. r= r* rA r. m
s4 ÿ€ ÿ€ÿýzIMAP4Client.__cbStatusr= c C s~ | dd¡ | ¡ }| dd¡ |rtdt|ƒ ƒ}nd}dd„ |D ƒ}dt|ƒd |¡||f }| 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.
r rÛ z "%s"r c S rå r= ræ rç r= r= rA rG ¦
rä z&IMAP4Client.append..s %b (%b)%b {%d}rØ s APPENDr= ) r¯ Útellr: r9 r
r† rÀ r» Ú _IMAP4Client__cbContinueAppend) rZ r" r… r{ r€ rå rì r9 rè r= r= rA rl „
s" üÿzIMAP4Client.appendc C s t ¡ }| || jd ¡ | j¡S rm )r2 Ú
FileSenderÚbeginFileTransferr´ rC Ú _IMAP4Client__cbFinishAppend)rZ rÕ r… r¹ r= r= rA Ú__cbContinueAppend´
s ÿz IMAP4Client.__cbContinueAppendc C s | d¡ d S rT r– )rZ Úfoor= r= rA Ú__cbFinishAppendº
r z IMAP4Client.__cbFinishAppendc C ó | tdƒ¡S )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.
s CHECK©rÀ r» r^ r= r= rA rM ½
s
zIMAP4Client.checkc C r7 )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.
s CLOSEr8 r^ r= r= rA r É
s zIMAP4Client.closec C rö )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Ä )rÄ rÁ )rÀ r» rC Ú_IMAP4Client__cbExpungerø r= r= rA rJ Ù
rú zIMAP4Client.expungec C sH |\}}g }|D ]}t |ƒdkr!|d dkr!| | |d |¡¡ q|S )NrÛ r; rÄ r )r¡ rl r )rZ rJ rÕ r_ re r© r= r= rA rS î
s €zIMAP4Client.__cbExpungerX c G sJ dd„ |D ƒ}|r dnd}d |¡}| t|||fd¡}| | 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.
c S rû )rí r" )rC rr r= r= rA rG
rÑ z&IMAP4Client.search..s
UID SEARCHrÁ rØ rÁ )r† rÀ r» rC Ú_IMAP4Client__cbSearch)rZ r> Úqueriesr9 rÓ rè r= r= rA rz ö
s
zIMAP4Client.searchc sT |\}}g }|D ] ‰ t ˆ ƒdkr'ˆ d dkr'| ‡ ‡fdd„ˆ dd … D ƒ¡ q|S )Nr rÁ c s g | ]}ˆ |ˆ ¡‘qS r= )r ©rC r‡ ©r© rZ r= rA rG r› z*IMAP4Client.__cbSearch..r; )r¡ rr )rZ rJ rÕ r\ re r= r= rA rf s "€zIMAP4Client.__cbSearchc C ó | j ||ddS )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; )ÚuseUIDr> ©Ú_fetch©rZ rÚ r> r= r= rA ÚfetchUID ó zIMAP4Client.fetchUIDc C r> )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? r{ r@ rB r= r= rA Ú
fetchFlags. rD zIMAP4Client.fetchFlagsc C r> )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@ rB r= r= rA ÚfetchInternalDateB s z IMAP4Client.fetchInternalDatec C r> )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@ rB r= r= rA Ú
fetchEnvelopeW ó zIMAP4Client.fetchEnvelopec C r> )aÐ
Retrieve the structure of the body of 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 body structure
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 body structure data, or whose errback is invoked
if there is an error. Body structure data describes the MIME-IMB
format of a message and consists of a sequence of mime type, mime
subtype, parameters, content id, description, encoding, and size.
The fields following the size field are variable: if the mime
type/subtype is message/rfc822, the contained message's envelope
information, body structure data, and number of lines of text; if
the mime type is text, the number of lines of text. Extension fields
may also be included; if present, they are: the MD5 hash of the body,
body disposition, body language.
r; )r? Ú
bodystructurer@ rB r= r= rA ÚfetchBodyStructuret rJ z IMAP4Client.fetchBodyStructurec C r> )aÉ
Retrieve the simplified body structure 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: 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 dict mapping
message numbers to body data, or whose errback is invoked
if there is an error. The simplified body structure is the same
as the body structure, except that extension fields will never be
present.
r; )r? r˜ r@ rB r= r= rA ÚfetchSimplifiedBody‘ s z IMAP4Client.fetchSimplifiedBodyc C r> )a)
Retrieve one or more entire messages
This command is allowed in the Selected state.
@type messages: L{MessageSet} or L{str}
@param messages: A message sequence set
@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 L{Deferred} which will fire with a C{dict} mapping message
sequence numbers to C{dict}s giving message data for the
corresponding message. If C{uid} is true, the inner dictionaries
have a C{'UID'} key mapped to a L{str} giving the UID for the
message. The text of the message is a L{str} associated with the
C{'RFC822'} key in each dictionary.
r; )r? Úrfc822r@ rB r= r= rA Ú fetchMessage§ s zIMAP4Client.fetchMessagec C r> )a<
Retrieve headers 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 dicts of message headers, or whose errback is
invoked if there is an error.
r; )r? Ú rfc822headerr@ rB r= r= rA Ú fetchHeaders¿ rD zIMAP4Client.fetchHeadersc C r> )aL
Retrieve body text 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 file-like objects containing body text, or whose
errback is invoked if there is an error.
r; )r? Ú
rfc822textr@ rB r= r= rA Ú fetchBodyÓ rD zIMAP4Client.fetchBodyc C r> )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@ rB r= r= rA Ú fetchSizeç rD zIMAP4Client.fetchSizec C s | j ||ddddddS )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? r{ rF rT rH r˜ r@ rB r= r= rA Ú fetchFullû s ùzIMAP4Client.fetchFullc C s | j ||dddddS )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? r{ rF rT rH r@ rB r= r= rA ÚfetchAll s ÿzIMAP4Client.fetchAllc C s | j ||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}, 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? r{ rF rT r@ rB r= r= rA Ú fetchFast4 s zIMAP4Client.fetchFastc
sú ‡ fdd„‰ i }g }t |ƒ} zt|ƒ}W n ty! Y ||fS w zt|ƒ}W n ty4 td|ƒ‚w |dvr.nativeStringResponse..)rU r rü rV )ÚthingrZ r= rA r[ q s
ÿz:IMAP4Client._parseFetchPairs..nativeStringResponseTs Not enough arguments)ó BODYs BODY.PEEKFrÛ r c S rå r= r5 ©rC rž r= r= rA rG ¸ rä z0IMAP4Client._parseFetchPairs..c S rå r= r5 r^ r= r= rA rG ¾ rä r; ó <ó >rt )r× rß rà r rU rV r¡ r9 rl r r~ r# rd r` )
rZ ÚfetchResponseListr¥ Ú unstructuredÚ
responsePartsrg rb Ú
hasSectionÚ valueHeadÚ valueTailr= rZ rA r¼ K s~ & `Ÿ
ÿ
ÿÿ þ
ÿÿ
žz IMAP4Client._parseFetchPairsc C s„ |\}}i }|D ]-}t |ƒdkr5|d dkr5| |d |¡}||vr*|d g||< q|| d |d ¡ qi } i }
| ¡ D ]"\} } | | d ¡\}
}|
| g g¡d |¡ | | i ¡ |
¡ q>|
}i }t| ¡ ƒD ]I} | | } t| ¡ ƒD ]<}||vr³|dkr³| d || < t t || d ƒƒD ]}|| d | dkrª|| d ||d …= nq‘| d= | s³| | = qwqk|r¼|
|¡ |rÀ| S |S )Nr/ r; rÅ r rÛ r» ) r¡ r rr rœ r¼ r½ ÚupdaterV r rl rM )rZ rJ ÚrequestedPartsÚ
structuredrÕ r_ Úinfor© rx rÞ Ú decodedInfoÚ messageIdr¥ Ú
structuredMapÚunstructuredListÚ flagChangesr rc r= r= rA Ú_cbFetchá sJ € þ€ö
zIMAP4Client._cbFetchc C sø d} |du r d}
nt |tƒrt|ƒ}
nd tt|ƒ¡}
|du r"d} n |
r)d| } n|} | r@|dv r@|dur=dd |¡ } nd} nd} |du rId}
nd ||f }
|rSd
pTd }| ||r[d p\d|
| | |
f }| d
¡}| t||dd¡}| | 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)r) z ()z<%d.%d>ó UID FETCHrÅ z.PEEKrí ©rÅ rÁ r= F)
rU rd r… r† r r rÀ r» rC rp )rZ rÚ r> Ú
headerTypeÚ headerNumberÚ
headerArgsÚpeekÚoffsetÚlengthÚfmtÚnumberr ÚpayloadÚextrar\ r9 rè r= r= rA Ú
fetchSpecific s2 7
zIMAP4Client.fetchSpecificc K sÀ t |ƒ d¡}|r dp d}d|v r|d= d|d< d|v r#|d= d|d< d |v r.|d = d|d
< d d „ |D ƒ}|d
d dd „ |D ƒ¡ d }| t||dd¡}| | jdd „ | ¡ D ƒd¡ |S )Nr« rr rÅ rR Tú rfc822.textrT ú rfc822.sizerP ú
rfc822.headerc S rå r= ræ rã r= r= rA rG v rä z&IMAP4Client._fetch..r, rØ c S rá r= ©r5 rã r= r= rA rG w rä rm rs rÁ c S rá r= r‚ )rC rº r= r= rA rG z rä )r… r r† rÀ r» rC rp r )rZ rÚ r? Útermsr\ Ú encodedTermsr9 rè r= r= rA rA e s zIMAP4Client._fetchc C ó | |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½ ©Ú_store©rZ rÚ r{ r( r> r= r= rA ÚsetFlags} ó zIMAP4Client.setFlagsc C r… )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 +FLAGSr† rˆ r= r= rA ÚaddFlags˜ rŠ zIMAP4Client.addFlagsc C r… )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 -FLAGSr† rˆ r= r= rA Ú removeFlags³ rŠ zIMAP4Client.removeFlagsc C s† t |ƒ d¡}dd„ |D ƒ}|r|d }|rdpd}d ||dd |¡ d f¡}| t||d
d ¡} d }
|s9d
}
| | j|
d¡ | S )Nr« c S rå r= ræ rç r= r= rA rG Ð rä z&IMAP4Client._store..s .SILENTs UID STORErD rØ rl rm rs rÁ r= )r» T)r… r r† rÀ r» rC rp ) rZ rÚ r9 r( r{ r> rì r$ rÓ rè Úexpectedr= r= rA r‡ Î s zIMAP4Client._storec C s> t |ƒ d¡}|r d}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.
r« s UID COPYrC rØ )r… r r† r
rÀ r» )rZ rÚ r" r> r9 rÓ r= r= rA rÅ Ü s zIMAP4Client.copyc C rG ©z Override meNr= rG r= r= rA rI ü rç zIMAP4Client.modeChangedc C rG rŽ r= )rZ rK r= r= rA rM ÿ rç zIMAP4Client.flagsChangedc C rG rŽ r= rN r= r= rA rQ rç zIMAP4Client.newMessagesrm ©r; )r= NrU )r NNNNNN)r; r )ir r‘ r’ r“ r
rµ r” r¬ r r r r r¬ r• Ú STATUS_CODESrd r. r– r] r› r" r£ r r r$ r r§ r¡ r r6 r¯ r´ r³ r¸ r¶ rÀ rÅ r² r½ rÉ rÎ rÍ rÄ r£ rÕ rÜ rÝ r° r± rÑ rä rÓ rî rï rù r÷ rÙ r
r r rú rÿ r r r rV r r r& r- r( rl r0 r3 rM r rJ r9 rz r: rC rE rG rI rL rM rO rQ rS rU rV rW rX r¼ rp r~ rA r‰ r‹ rŒ r‡ rÅ rI rM rQ r= r= r= rA r‹ p sà
*
3
). 9# þ #
0
-
÷
Z
r‹ c C s6 t ƒ }| d¡}|D ]Ž}d|v rl| dd¡\}}zH|dkr d}nt|ƒ}|dkr+d}nt|ƒ}|| u r.c S s t d | ¡ƒS rT )r½ r† rÄ r= r= rA rP c s c S s d dd„ | D ƒ¡gS )Nr c S s g | ]}|d ‘qS rU r= ra r= r= rA rG d rä z5collapseStrings....)r† rÄ r= r= rA rP d rÑ )r r; )ra rU rV rr rà rl ÚcollapseStrings)rÞ rÅ ÚbegunÚpredÚtranrc rš r= r= rA rÅ Q s$
þ
€rÅ c C sÊ | ¡ } d}g g}zÀd}t| ƒ}||k rÈ| ||d … }|rG|dkr4|d | ||d … ¡ |d7 }q|dkr;| }|d |¡ |d7 }n}|dkrZ|d |¡ | }|d7 }nj|r‘|dkr‘| d|¡}|dkrntd ƒ‚t| |d |… ƒ}|d | |d
|d
| … f¡ |d
| }n3|d ks™|d kr£| g ¡ |d7 }n!|d
ks«|dkr¹|d | ¡ ¡ |d7 }n |d |¡ |d7 }||k sW n tyÔ t| ƒ‚w t|ƒdkrßt| ƒ‚t |d ƒS )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.
r r; ry rt rÛ r^ r_ r` ra r/ rl rì rm r° éþÿÿÿ)
rc r¡ rl ro r` rd r% Ú
IndexErrorr rÅ ) r¹ Ú
handleLiteralr· Ú contentStackrc rå rš r\ Ú literalSizer= r= rA rÝ s sX
$
ဠÿ rÝ c C s8 t d| ƒ}t d| ƒ}|| ||| ¡ ||| ¡ | S )Nr r² )r7 r¯ )r¹ r¹ rº r= r= rA rö s
$rö r¹ r‚ c C s dt | ƒ| f S )Ns {%d}
%b)r¡ ©r¹ r= r= rA rþ ³ rŒ rþ c @ s" e Zd Zdd„ Zdefdd„ZdS )r c C ó
|| _ d S rm )rb )rZ rb r= r= rA r] ¸ ó
zDontQuoteMe.__init__r‚ c C s
t | jƒS rm )r… rb r^ r= r= rA rˆ » rÐ zDontQuoteMe.__str__N)r r‘ r’ r] r… rˆ r= r= r= rA r · s r s (){ %*"c C sB | dkrdS t | ƒD ]}|dk s|dkr dS |tv r dS q
dS )Nr r; rØ ó r )r8 Ú_ATOM_SPECIALS)r¹ rš r= r= rA Ú _needsQuote s ÿrÓ c C s: t | tƒr| S z| d¡W S ty t ¡ t| ƒ‚w )Nrþ )rU r… rü rû r4 r r ©rÜ r= r= rA rØ Í s
þrØ c C s2 t | tƒs
| d¡} | d¡} t| ƒrt| ƒS | S )Nrí rþ )rU r… rü r rÓ rö rÔ r= r= rA r
× s
r
c C s0 t d| ƒ}t d| ƒ}|| v p|| v pt| ƒdkS )NÚ
ú
iè )r7 r¡ )r¹ ÚcrÚlfr= r= rA Ú
_needsLiteralà s
rÙ c C s g }| D ]€}t |tƒr| d¡}|du r | ddg¡ qt |tƒr-| dtt|ƒƒg¡ qt |tƒr;| d|jg¡ qt |tƒr^t |ƒrT| ddt
|ƒf t j |g¡ q| dt
|ƒg¡ qt|dƒrw| ¡ }| ddt
|ƒf t j |g¡ q| ddt|ƒ d g¡ qd |d
d… ¡S ) 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}
r« NrØ s NILs {%d}rŸ rl rm r r; )rU r… r rr rd r: r rb r rÙ r¡ ró Ú delimiterrö ÚhasattrrŸ rÒ r† )rœ Úpiecesrc rè r= r= rA rÒ ç s&
rÒ c @ s„ e Zd ZdZdZdZdd„ Zdd„ Zd dd„Zd d
„ Z d d „ Z
d dd„Z dd„ Z dd„ Z
dd„ Zdd„ Zdd„ Zdd„ Zd d „ ZdS ) Ú MemoryAccountWithoutNamespacesNr c C s || _ i | _g | _d S rm )rÜ r Ú
subscriptionsr r= r= rA r] r z'MemoryAccountWithoutNamespaces.__init__c C s | j }| j d7 _ |S rM )Útop_id)rZ rx r= r= rA Ú
allocateID# s z)MemoryAccountWithoutNamespaces.allocateIDc C sD t | ¡ ƒ}|| jv rt|ƒ‚|d u r| || ¡ ¡}|| j|< dS rM )rØ r5 r r Ú
_emptyMailboxrà )rZ rÜ r r= r= rA Ú
addMailbox+ s
z)MemoryAccountWithoutNamespaces.addMailboxc C s’ dd„ | d¡D ƒ}tdt|ƒƒD ]}z| d |d |… ¡¡ W q ty* Y qw z | d |¡¡ W dS tyH | d¡sEY dS Y dS w )Nc S s g | ]}|r|‘qS r= r= )rC Úpathr= r= rA rG 5 rä z9MemoryAccountWithoutNamespaces.create..ú/r; FT)r3 rl r¡ râ r† r r# )rZ ÚpathspecÚpathsÚaccumr= r= rA rú 4 s ÿ ý
ÿýz%MemoryAccountWithoutNamespaces.createc C s t ‚rm )ÚNotImplementedError)rZ rÜ rx r= r= rA rá B ó z,MemoryAccountWithoutNamespaces._emptyMailboxr; c C s | j t| ¡ ƒ¡S rm )r r‰ rØ r5 )rZ rÜ Ú readwriter= r= rA rÙ E s z%MemoryAccountWithoutNamespaces.selectc C s t | ¡ ƒ}| j |¡}|stdƒ‚d| ¡ v r-| j ¡ D ]}||kr,| |¡r,tdƒ‚q | ¡ t |
|¡ƒdkrBtd|› dƒ‚| j|= d S )NzNo such mailboxz \Noselectz.)rØ r5 r r" rì r )rZ r r Ú inferiorsÚoldÚnewr= rï rA r _ s
ÿ
þz%MemoryAccountWithoutNamespaces.renamec C s, g }| j ¡ D ] }| |¡r| |¡ q|S rm )r r r~ rl )rZ rÜ rñ Úinfnamer= r= rA rì p s
€z-MemoryAccountWithoutNamespaces._inferiorNamesc C s t | ¡ ƒ| jv S rm )rØ r5 rÞ r r= r= rA r w r z+MemoryAccountWithoutNamespaces.isSubscribedc C s* t | ¡ ƒ}|| jvr| j |¡ d S d S rm )rØ r5 rÞ rl r r= r= rA r z s
ÿz(MemoryAccountWithoutNamespaces.subscribec C s4 t | ¡ ƒ}|| jvrtd|› ƒ‚| j |¡ d S )Nz Not currently subscribed to )rØ r5 rÞ r Úremover r= r= rA r s
z*MemoryAccountWithoutNamespaces.unsubscribec s0 ˆ t| ¡ ƒ¡}tˆdƒ‰‡ ‡fdd„|D ƒS )Nrä c s$ g | ]}ˆ |¡r|ˆ j| f‘qS r= )rh r ra ©rZ r r= rA rG ˆ s $ z@MemoryAccountWithoutNamespaces.listMailboxes..)rì rØ r5 r± )rZ r r r= rö rA r … s
z,MemoryAccountWithoutNamespaces.listMailboxesrm r )r r‘ r’ r rÞ rß r] rà râ rú rá rÙ rÿ r rì r r r r r= r= r= rA rÝ s"
rÝ c @ s, e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zd S )
Ú
MemoryAccountc C s
ddggS )Nr ó /r= r^ r= r= rA rÐ rÐ z#MemoryAccount.getPersonalNamespacesc C ó d S rm r= r^ r= r= rA rÑ “ ré z!MemoryAccount.getSharedNamespacesc C rù rm r= r^ r= r= rA ÚgetOtherNamespaces– ré z MemoryAccount.getOtherNamespacesc C rù rm r= r^ r= r= rA ÚgetUserNamespaces™ s z MemoryAccount.getUserNamespacesN)r r‘ r’ rÐ rÑ rú rû r= r= r= rA r÷ ‹ s
r÷ rî rï Ú
getUIDNextrð ÚgetUnseenCountr% c C s* i }|D ]}t | t| ¡ ƒƒ ||< q|S rm )r) Ú_statusRequestDictr5 )r ræ Úrr r= r= rA ÚstatusRequestHelper§ s r c C s* | d u rdgS t j | g¡} dd„ | D ƒS )NrR c S s& g | ]\}}|p d d g| d¡ ‘qS )Nú@©r3 )rC r? Úaddressr= r= rA rG ´ s & z parseAddr..)rŒ r Ú getaddresses)Úaddrr= r= rA Ú parseAddr® s
ÿr c
C s² | d¡}| d¡}| d¡}| d¡}| d|¡}| d|¡}| d¡}| d¡}| d ¡} | d
¡}
| d ¡} ||t|ƒt|ƒ|oFt|ƒ|oKt|ƒ|oPt|ƒ| oUt| ƒ|
| f
S ) NTr€ rÈ r¤ Úsenderzreply-torÌ rš r… z in-reply-toz
message-id)rˆ r‰ r ) rŠ Úheadersr€ rÈ Úfrom_r Úreply_torÌ rš r… Ú in_reply_toÚmidr= r= rA ræ · s,
öræ c C s d}| ¡ D ]}|d7 }q|S r¾ )r– )rŠ rÕ rA r= r= rA Ú getLineCountÑ s
r
c C s2 | d | d krdkrn | S | dd… S | S )Nr rt r r; r= rÎ r= r= rA ÚunquoteÚ s ÿr c C s” d}| dd¡ dd¡}d | ¡ ¡}|rA| d¡}|d dd¡}t|ƒdkr/|d }d}n|\}}td d
„ |dd… D ƒƒ}nd }}|||fS ) zJ
Return a two-tuple of the main and subtype of the given message.
NFú content-typer† ú;r rä r; c s s$ | ]
}| ¡ ¡ d d¡V qdS )ú=r; N)rc râ r3 r* r= r= rA rò ð s €" z"_getContentType..)rˆ r‰ r† Ú
splitlinesr3 r¡ Údict)rŠ ÚattrsÚmmÚmimetyper ÚmajorÚminorr= r= rA Ú_getContentTypeà s
r c C s€ t | ƒ\}}}|dur| ¡ }|dur| ¡ }|dkr!t| ||ƒS ||fdkr.t| |||ƒS |dkr9t| |||ƒS t| |||ƒ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)r… rN r5 )r râ Ú_MultipartMessageStructureÚ_RFC822MessageStructureÚ_TextMessageStructureÚ_SinglepartMessageStructure)r… ÚmainÚsubtyper r= r= rA Ú_getMessageStructureö s r! c @ r© ) Ú_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 C s || _ || _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)r… r )rZ r… r r= r= rA r] s
z_MessageStructure.__init__c C sh |r2| d¡}t|ƒdkr|d ¡ df}|S t|ƒdkr0dd„ |dd… D ƒ}|d ¡ |g}|S dS )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; r Nc S s" g | ]
}| d d¡D ]}|‘q
qS ©r r; r )rC ÚparamrO r= r= rA rG 0 s " z2_MessageStructure._disposition..)r3 r¡ râ )rZ ÚdispÚparamsr= r= rA Ú _disposition" s
üz _MessageStructure._dispositionc C s0 | j rdd„ | j ¡ D ƒ}dd„ t|ƒD ƒS dS )zÕ
@return: The I{Content-Type} parameters, unquoted, as a flat list with
each Nth element giving a parameter name and N+1th element giving
the corresponding parameter value.
c S s g | ]
\}}|t |ƒf‘qS r= )r ©rC r* rž r= r= rA rG = r+ z4_MessageStructure._unquotedAttrs..c S s g | ] }|D ]}|‘qqS r= r= )rC rO Úyr= r= rA rG > ó N)r rœ rh )rZ Úunquotedr= r= rA Ú_unquotedAttrs6 s z _MessageStructure._unquotedAttrsN)r r‘ r’ r“ r] r' r, r= r= r= rA r" s
r" c @ s8 e Zd ZdZg d¢Zdd„ Zdd„ Zdd„ Zd d
„ Zd S ) r zn
L{_SinglepartMessageStructure} represents the message structure of a
non-I{multipart/*} message.
)ú
content-idúcontent-descriptionúcontent-transfer-encodingc C s$ t | ||¡ || _|| _|| _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" r] r r r )rZ r… r r r r= r= rA r] J s
z$_SinglepartMessageStructure.__init__c C sZ | j jdg| j¢R Ž }| j ¡ }| j| j}}| ¡ }|||| d¡| d¡| d¡|gS )zN
Return a list of the basic fields for a single-part message.
Fr- r. r/ )r… rˆ Ú_HEADERSr® r r r, r‰ )rZ r r™ r r Ú
unquotedAttrsr= r= rA Ú _basicFields] s
ùz(_SinglepartMessageStructure._basicFieldsc C s | ¡ }|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.
)r2 rr Ú _extended©rZ ÚextendedrJ r= r= rA r u s z"_SinglepartMessageStructure.encodec C sb g }| j ddddd¡}| | 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-md5úcontent-dispositionúcontent-languageúcontent-location)r… rˆ rl r‰ r' ©rZ rJ r r= r= rA r3 € s ûz%_SinglepartMessageStructure._extendedN) r r‘ r’ r“ r0 r] r2 r r3 r= r= r= rA r B s r c @ ó e Zd ZdZdd„ ZdS )r z_
L{_TextMessageStructure} represents the message structure of a I{text/*}
message.
c C s0 t | ¡}| 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.
)r r2 rl r
r… rr r3 r4 r= r= rA r ° s
z _TextMessageStructure.encodeN©r r‘ r’ r“ r r= r= r= rA r ª ó r c @ r: )r zi
L{_RFC822MessageStructure} represents the message structure of a
I{message/rfc822} message.
c C sH t | |¡}| j d¡}| 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.
r F)r r r… r rl ræ r
r
)rZ r5 rJ Ú containedr= r= rA r Ä s z _RFC822MessageStructure.encodeNr; r= r= r= rA r ¾ r< r c @ s0 e Zd ZdZdd„ Zdd„ Zdd„ Zdd „ Zd
S ) r zi
L{_MultipartMessageStructure} represents the message structure of a
I{multipart/*} message.
c C s t | ||¡ || _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" r] r )rZ r… r r r= r= rA r] Ù s
z#_MultipartMessageStructure.__init__c c s> d} z| j |¡}W n
ty Y dS w |V |d7 }q)zR
Return an iterator over all of the sub-messages of this message.
r Tr; N)r… r rÊ )rZ rc r r= r= rA Ú _getPartsç s € ÿùz$_MultipartMessageStructure._getPartsc s8 ‡ fdd„| ¡ D ƒ}| | j¡ ˆ r| | ¡ ¡ |S )zW
Encode each sub-message and added the additional I{multipart} fields.
c s g | ] }t |ƒ ˆ ¡‘qS r= ©r! r r< ©r5 r= rA rG ù r* z5_MultipartMessageStructure.encode..)r> rl r rr r3 r4 r= r@ rA r õ s
z!_MultipartMessageStructure.encodec C sb g }| j dddd¡}| | ¡ ¡ | | | 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].
Fr7 r8 r6 N)r… rˆ rl r, r' r‰ r9 r= r= rA r3 ÿ s ÿz$_MultipartMessageStructure._extendedN)r r‘ r’ r“ r] r> r r3 r= r= r= rA r Ó s
r Fc C s t | ƒ |¡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? )rŠ r5 r= r= rA r
" s ir
c C s( dd„ | ¡ D ƒ}d |¡d }t|ƒS )Nc S s, g | ]\}}d | ¡ d | ¡ ¡f¡‘qS )z: ú
)r† Útitler r( r= r= rA rG s ÿÿz"_formatHeaders..rA )rœ r† r: )r rÿ r= r= rA rý Ž s
þrý c c s4 d}z | |¡V |d7 }q ty Y d S w )Nr Tr; )r rÊ )rj rc r= r= rA Úsubparts˜ s € þ ÿrC c s2 ddl m‰ t ¡ ‰ ‡ ‡‡‡fdd„‰ˆdƒ ˆ S )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.
r ri c sr zt ˆƒ}W n ty ˆ | ¡ Y d S ty" ˆ ¡ Y d S w t|tjƒr0| ˆ¡ d S ˆ dˆ|¡ d S r² )
rß rà r¦ rû r¤ rU r
rS rC rp )r_ rÿ ©rè Úgorc rj r= rA rE ² s ÿ z iterateInReactor..goN)ro rj r
rS )rc r= rD rA rû ¢ s
rû c @ s4 e Zd ZdZeejƒZd dd„Zdd„ Z dd„ Z
dS )
r é Nc C s< || _ |du r t ¡ }|| _|du rt}|| _| 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)rŠ r r® r= rû r r¤ )rZ rŠ r= r r= r= rA r] Ç s zMessageProducer.__init__c C s || _ | | ¡ ¡S rm )Úconsumerr Ú_produce)rZ rG r= r= rA r Û s z MessageProducer.beginProducingc # s– ˆ j d¡}d }ˆ j ¡ rZ| d¡}dd„ | d¡dd … D ƒ}dd„ |D ƒ}| d ¡}|d u rFd
ˆ ¡ j› }|d d |› d 7 < n| d ¡rV| d ¡rV|dd
… }t |ƒ}ˆ
t |ƒ¡ ˆ
d¡ ˆ j ¡ r’t ˆ j ƒD ]}ˆ
d| d ¡ t
|ˆ jˆ jƒ d ¡V qpˆ
d| d ¡ nˆ j ¡ } | ˆ j¡}|rªˆ j
|¡ d V nnq˜ˆ jrɈ j dd¡ tˆ jƒ ˆ j¡ ‡ fdd„¡V d S d S )NTr c S s g | ]}| d d¡‘qS r# r r* r= r= rA rG ä r› z,MessageProducer._produce..r r; c S s i | ] \}}| ¡ ¡ |“qS r= )râ rc r( r= r= rA r$ å rð z,MessageProducer._produce..Úboundaryz----=z ; boundary="r rt rœ s
--s --
r c s ˆ S rm r= rÜ r^ r= rA rP rç z*MessageProducer._produce..)rŠ rˆ r r‰ r3 Ú_uuid4Úhexr~ r# r: r¤ rý rC r r= r r r– rŸ Ú
CHUNK_SIZErG r¯ r rC )rZ r rI r r© r‡ r- r½ r= r^ rA rH ß sJ €
ÿ
ú
ÿþzMessageProducer._producer] ) r r‘ r’ rL Ú staticmethodÚuuidÚuuid4rJ r] r rH r= r= r= rA r à s
r c
@ sz e Zd ZG dd„ dƒZG dd„ dƒZG dd„ dƒZG dd„ dƒZG d d
„ d
ƒZG d d „ d ƒZG d
d„ dƒZ G dd„ dƒZ
G dd„ dƒZ G dd„ dƒZ G dd„ dƒZ
G dd„ dƒZG dd„ dƒZdZd efd efd efd efd efd!efd"e fd#e
fd$e fg Zd%d&„ Zd'd(„ Zd)d*„ Zd+d,„ Zd-d.„ Zd/d0„ Zd1d2„ Zd3d4„ Zd5d6„ Ze d7¡Z d8d9„ Z d:d;„ Z dd?„ Z!d@dA„ Z"dS )Brv c @ r: )z_FetchParser.EnveloperH c C rG )NrH r= r^ r= r= rA rP rç z _FetchParser.Envelope.N©r r‘ r’ r rˆ r= r= r= rA ÚEnvelope
s rQ c @ r: )z_FetchParser.Flagsr{ c C rG )Nr{ r= r^ r= r= rA rP rç z_FetchParser.Flags.NrP r= r= r= rA ÚFlags ó rR c @ r: )z_FetchParser.InternalDaterF c C rG )NrF r= r^ r= r= rA rP rç z"_FetchParser.InternalDate.NrP r= r= r= rA Ú InternalDate rS rT c @ r: )z_FetchParser.RFC822HeaderrP c C rG )Nr r= r^ r= r= rA rP " rç z"_FetchParser.RFC822Header.NrP r= r= r= rA Ú RFC822Header rS rU c @ r: )z_FetchParser.RFC822TextrR c C rG )Nr r= r^ r= r= rA rP & rç z _FetchParser.RFC822Text.NrP r= r= r= rA Ú
RFC822Text$ rS rV c @ r: )z_FetchParser.RFC822SizerT c C rG )Nr€ r= r^ r= r= rA rP * rç z _FetchParser.RFC822Size.NrP r= r= r= rA Ú
RFC822Size( rS rW c @ r: )z_FetchParser.RFC822rN c C rG )NrN r= r^ r= r= rA rP . rç z _FetchParser.RFC822.NrP r= r= r= rA ÚRFC822, rS rX c @ r: )z_FetchParser.UIDr> c C rG )Nr> r= r^ r= r= rA rP 2 rç z_FetchParser.UID.NrP r= r= r= rA r¡ 0 rS r¡ c @ sL e Zd ZdZdZdZdZdZdZdZ dZ
dZ de fdd„Z
defdd „ZdS )
z_FetchParser.Bodyr˜ FNr= r‚ c C ó | ¡ d¡S ©Nr« ©r rü r^ r= r= rA rˆ ? r z_FetchParser.Body.__str__c C sÈ d}d}d}| j rd dd„ | j D ƒ¡}d}| jr,|d| | t| jƒ d¡ d 7 }n'| jr:|d| | d 7 }n| jrH|d| | d
7 }n | jrS|d| d 7 }| jd urb|d | j| j f 7 }|S ) Nr] r ó .c S s g | ] }t |d ƒ d¡‘qS )r; r« )r… r r* r= r= rA rG G rð z/_FetchParser.Body.__bytes__..rì r« r° s TEXT]s MIME]s <%d.%d>)
r r† r r… r r5 r r Ú partialBeginÚ
partialLength)rZ Úbaser Ú separatorr= r= rA r B s& ÿ
z_FetchParser.Body.__bytes__)r r‘ r’ r rw r r r5 r r r] r^ r… rˆ r r r= r= r= rA ÚBody4 s ra c @ r: )z_FetchParser.BodyStructurerK c C rG )NrK r= r^ r= r= rA rP [ rç z#_FetchParser.BodyStructure.NrP r= r= r= rA Ú
BodyStructureY rS rb c @ s4 e Zd ZdZdZdZdefdd„Zdefdd„Z dS )z_FetchParser.HeaderFNr‚ c C rY rZ r[ r^ r= r= rA rˆ c r z_FetchParser.Header.__str__c C s d}| j r4|d7 }| jr|d7 }g }| j D ]}| ¡ }t|ƒr#t|ƒ}| |¡ q|dd |¡ d 7 }| jrFd dd „ | jD ƒ¡d | }|S )
Ns HEADERs .FIELDSs .NOTr, rØ rm r\ c S s g | ]}|d ¡ ‘qS r )r r* r= r= rA rG v r› z1_FetchParser.Header.__bytes__..)r r rB rÓ rö rl r† r )rZ r_ r r- r= r= rA r f s
z _FetchParser.Header.__bytes__)
r r‘ r’ r r r r… rˆ r r r= r= r= rA ÚHeader^ s rc c @ ó e Zd ZdS )z_FetchParser.TextN©r r‘ r’ r= r= r= rA ÚTexty ó rf c @ rd )z_FetchParser.MIMENre r= r= r= rA ÚMIME| rg rh Ns envelopes flagss internaldates
rfc822.headers rfc822.texts rfc822.sizes rfc822s uids
bodystructurec C s dg| _ g | _d| _d S )NÚinitialr )r rJ Ú remainingr^ r= r= rA r] s
z_FetchParser.__init__c C s˜ | j | }zB|s | jrB| jstdƒ‚| j ¡ }z t| d| ƒ|ƒ}W n ty0 | j |¡ ‚ w ||d … }|s | js W || _ d S W || _ d S || _ w )NzInvalid ArgumentÚstate_)rj r r r% r) rû rl )rZ r¹ r Úusedr= r= rA rw ’ s"
þ ô
òz_FetchParser.parseStringc C sÔ |dkrdS | ¡ }| d¡r#| j | ¡ | ¡ | ¡ | ¡ f¡ dS | d¡r?| j | ¡ | ¡ | ¡ | ¡ | ¡ f¡ dS | d¡rU| j | ¡ | ¡ | ¡ f¡ dS | d¡rb| j d ¡ d
S | j
d ¡ dS ) Nr r s allr/ s fullrh s fastrl )Ú close_parenÚmaybe_fetch_attÚ fetch_attr; ro ) râ r~ rJ rr rR rT rW rQ ra r rl )rZ r¹ r} r= r= rA Ú
state_initial¥ s>
ÿ
ûÿ
ýÿ
z_FetchParser.state_initialc C s | d¡rdS tdƒ‚)Nrm r; z Missing )©r~ r+ r¸ r= r= rA Ústate_close_parenÎ s
z _FetchParser.state_close_parenc C sP |r
|dd… ¡ stdƒ‚d}tt|ƒƒD ]}|||d … ¡ s% |S q|S )Nr r; z Whitespace expected, none found)Úisspacer+ rl r¡ )rZ r¹ rc r= r= rA Ústate_whitespaceÕ s þz _FetchParser.state_whitespacec C s | d¡s | j d¡ dS )Nrm )rn ro rµ r ©r~ r rr r¸ r= r= rA Ústate_maybe_fetch_attß s
z"_FetchParser.state_maybe_fetch_attc C sŽ | ¡ }| jD ]\}}| |¡r | j |ƒ ¡ t|ƒ S q| ¡ }| d¡r-d|_d}n| d¡r5d}ntd|› ƒ‚|| _ | j
d¡ |S )Ns body.peekTrî s bodyrh z!Nothing recognized in fetch_att: )Úgot_bodyÚ
maybe_partialÚ
maybe_section) râ Ú_simple_fetch_attr~ rJ rl r¡ ra rw r+ Ú pending_bodyr rr )rZ r¹ r} rÜ Úclsr½ rl r= r= rA Ústate_fetch_attä s
þ
z _FetchParser.state_fetch_attc C s | j | j¡ | `dS r² )rJ rl r{ r¸ r= r= rA Ústate_got_bodyý s z_FetchParser.state_got_bodyc C s | d¡sdS | j d¡ dS )Nrì r )ÚsectionÚ part_numberr; ru r¸ r= r= rA Ústate_maybe_section s
z _FetchParser.state_maybe_sections (\d+(?:\.\d+)*)\.?c C sD | j |¡}|d ur dd„ | ¡ d d¡D ƒ| _| ¡ S g | _dS )Nc S s g | ]}t |ƒd ‘qS r )rd r< r= r= rA rG r› z2_FetchParser.state_part_number..r r\ )Ú _partExprrh Úgroupsr3 r© r\ )rZ r¹ rj r= r= rA Ústate_part_number s z _FetchParser.state_part_numberc C s | ¡ }d}| d¡rd| j_|d7 }nd| d¡r,| ¡ }| j_d|_d|_|d7 }nL| d¡r<| ¡ | j_ |d 7 }n<| d
¡rL|
¡ | j_ |d 7 }n,| ¡ }| d ¡r]d|_|d 7 }n| d
¡rg|d7 }nt d|›ƒ‚|| j_| j
d¡ t| jƒ| j_d | _|S )Nr r° Tr; s header]r= r‚ s text]rg s mime]s header.fields.noté s
header.fieldsr< z Unhandled section contents: )Úfinish_sectionÚ header_listrµ )râ r~ r{ r rc r r r rf r5 rh r r+ r rr r r© r )rZ r¹ r} rl r~ r= r= rA Ú
state_section s8
z_FetchParser.state_sectionc C s | d¡s tdƒ‚dS )Nr° zsection must end with ]r; rq r¸ r= r= rA Ústate_finish_section9 s
z!_FetchParser.state_finish_sectionc C sX | d¡s tdƒ‚| d¡}|dkrtdƒ‚|d|… ¡ }dd„ |D ƒ| jj_|d S ) Nrl z Header list must begin with (rm rt zHeader list must end with )r; c S rá r= r‚ )rC r~ r= r= rA rG F rä z2_FetchParser.state_header_list..)r~ r+ ro r3 r{ r r )rZ r¹ r\ r r= r= rA Ústate_header_list> s
z _FetchParser.state_header_listc C sz | d¡sdS | d¡}|dkrtdƒ‚|d|… }| dd¡}t|ƒdkr*td ƒ‚tt|ƒ\}}|| j_|| j_ |d S )
Nr_ r r` rt zFound < but not >r; r\ rÛ z>Partial specification did not include two .-delimited integers)
r~ ro r+ r3 r¡ r rd r{ r] r^ )rZ r¹ r\ rj r© Úbeginry r= r= rA Ústate_maybe_partialI s
ÿz _FetchParser.state_maybe_partial)#r r‘ r’ rQ rR rT rU rV rW rX r¡ ra rb rc rf rh r© rz r] rw rp rr rt rv r} r~ r rV rW r‚ r„ rˆ r‰ rŠ rŒ r= r= r= rA rv sP %÷ )
% rv c @ sD e Zd ZdZdZdd„ Zdd„ Zdd„ Zd d
„ Zd d „ Z d
d„ Z
dS )r rF Tc C rÏ rm r5 )rZ r- r= r= rA r] c rÐ zFileProducer.__init__c C s. || _ |j| _t ¡ }| _| j | d¡ |S )NF)rG r¤ Úproducer
rS Ú_onDoneÚregisterProducer)rZ rG rè r= r= rA r f s
zFileProducer.beginProducingc C sx d}| j rd| ¡ f }d| _ | jsd S || j | j¡ }|s5| j ¡ | j | ¡ d | _ | _| _d S | |¡ d S )Nr s {%d}
F)
Ú
firstWriteÚ_sizer- rŸ rL rG ÚunregisterProducerrŽ r¦ r )rZ r½ r= r= rA ÚresumeProducingm s
z FileProducer.resumeProducingc C rG )z9
Pause the producer. This does nothing.
Nr= r^ r= r= rA ÚpauseProducing| rç zFileProducer.pauseProducingc C rG )z8
Stop the producer. This does nothing.
Nr= r^ r= r= rA Ú
stopProducing rç zFileProducer.stopProducingc C s8 | j ¡ }| j dd¡ | j ¡ }| j |d¡ || S )Nr rÛ )r- r/ r¯ )rZ r½ r. r= r= rA r‘ † s
zFileProducer._sizeN) r r‘ r’ rL r r] r r“ r” r• r‘ r= r= r= rA r ^ s r c C sÆ g d¢}ddddœ}t d| | ¡}|std| ›ƒ‚| ¡ }z!d| |d ¡ ¡d
|d < t|d ƒ|d < t|d ƒ|d < W n tyN td| ›ƒ‚w t |d |d |d d
d
d
dddf ¡S )N)ÚjanÚfebÚmarÚaprÚmayÚjunÚjulÚaugÚsepÚoctÚnovÚdecÚjanuaryÚfebruaryÚmarchÚaprilrš ÚjuneÚjulyÚaugustÚ septemberÚoctoberÚnovemberÚdecemberz+(?P3[0-1]|[1-2]\d|0[1-9]|[1-9]| [1-9])z (?P\w+)z(?P\d\d\d\d))ÚdayÚmonÚyearz%(day)s-%(mon)s-%(year)szCannot parse time string r; r® é r¯ r r rt ) rV rh r` Ú groupdictÚindexrâ rd rò Ú struct_time)r¹ ÚmonthsÚexprrj rè r= r= rA r‹ Ž s" ý ÿ(r‹ r c G s | d S r² r= rN r= r= rA rP À rQ rP c C s | d¡}|dd… dd¡S )Núutf-7r; rt rø r‘ )r r¯ ©r¹ Ús_utf7r= r= rA Úmodified_base64Ã s
r¹ c C s d| dd¡ d }| d¡S )Nr• r‘ rø rï r¶ )r¯ rü r· r= r= rA Úmodified_unbase64È s
rº c C sâ t ƒ }g }ttttddƒƒƒdh }| D ]D}||v r6|r.|dtd |¡ƒ d 7 }|dd…= | t|ƒ¡ q|dkrS|rN|dtd |¡ƒ d 7 }|dd…= |d7 }q| |¡ q|ri| dtd |¡ƒ d ¡ t
|ƒ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.
é é ú&ó &r† rï Ns &-) Ú bytearrayr' r Úchrrl r¹ r† rl Úordrr r r¡ )r¹ Úerrorsrÿ Ú_inÚ valid_charsrš r= r= rA ÚencoderÍ s$
rÅ c C sÎ g }g }t t| ƒdƒ} | D ]@}|dkr|s| d¡ q
|dkr>|r>t|ƒdkr-| d¡ n| td |dd… ¡ƒ¡ g }q
|rF| |¡ q
| | ¡ ¡ q
|r^| td |dd… ¡ƒ¡ d |¡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.
rš r¾ rï r; r½ r Nr† )Ú memory_castÚ
memoryviewrl r¡ rº r† rü )r¹ r rÿ rü rš r= r= rA Údecoderï s"
rÈ c @ ó e Zd Zddd„ZdS )Ú StreamReaderÚstrictc C ó t |ƒS rm )rÈ ©rZ r¹ r r= r= rA rü ó zStreamReader.decodeN©rË )r r‘ r’ rü r= r= r= rA rÊ ó rÊ c @ rÉ )Ú StreamWriterrË c C rÌ rm )rÅ rÍ r= r= rA r rÎ zStreamWriter.encodeNrÏ )r r‘ r’ r r= r= r= rA rÑ rÐ rÑ c C s | dd¡dkr
tS d S )Nú-rA Ú imap4_utf_7)r¯ Ú
_codecInforÔ r= r= rA rÓ s ÿrÓ )(ró r‹ ÚIMailboxListenerr' r± ÚIMailboxr0 r Ú IMailboxInfoÚIMessager8 r rY Ú IMessagePartr r r r r% r! r# r r r r r r r r" r$ r r r r r r« r r¬ r÷ r rm rU r rS )´r“ r¬ ÚcodecsrÅ Ú email.utilsrŒ ri rV r´ r rò rN Úbase64r r Úior Ú itertoolsr Útypingr r r Úzope.interfacer Ú twisted.credr
Útwisted.cred.errorr r ro r
r r Útwisted.internet.deferr Útwisted.mail._credr r r r r Útwisted.mail._exceptr r r r r r r r r r r r! r" r# r$ r% Útwisted.mail.interfacesr& r± r' r( r r) rÖ r* r× r+ rÕ r, rØ r- r8 r. r r/ rÙ r0 r1 rY Útwisted.protocolsr2 r3 Útwisted.pythonr4 r5 Útwisted.python.compatr6 r7 r8 r9 r: r rk rl r3 rô rB rI rJ r˜ rª r° r» Ú_SPr Ú_CTLrð rü Ú_nativeNonAtomCharsrW r¨ rY Ú LineReceiverÚ TimeoutMixinró Ú TimeoutErrorrª r‹ rt r§ r© rh r¦ r« r¬ r r± r½ rà rÅ rÝ rö rþ r rÒ rÓ rØ r
rÙ rÒ rÝ r÷ rþ r r ræ r
r r r! r" r r r r r
rý rC rû r rv r r‹ r) rÇ rÆ r¹ rº rÅ rÈ rÊ rÑ Ú CodecInforÔ rÓ ÚregisterÚ__all__r= r= r= rA Ú s
H8 ÿ & !K
%
$9
A
":
1rû 2h
Ol
!F W02
""