h f.2 @ s0 d Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l
Z d d l Z d d l Z y d d l
Z
Wn e k
r d Z
Yn Xd d d d d d d d
d d d
d g Z e j j d Z Gd d d Z Gd d d e Z Gd d d e Z Gd d d e Z Gd d d e Z Gd d d e Z Gd d d e Z Gd d d e Z Gd d d e j j Z Gd d
d
e Z Gd d d e Z Gd d d e Z Gd d d e Z Gd d
d
e Z Gd! d d e Z! Gd" d# d# Z" Gd$ d% d% e" Z# d& d' d( Z$ d) d* Z% d+ d, Z& d- d. Z' d/ d0 Z( d1 d2 Z) Gd3 d4 d4 e* Z+ Gd5 d6 d6 e+ Z, Gd7 d8 d8 e+ Z- Gd9 d: d: e+ Z. Gd; d< d< e+ Z/ d S)=zDRead/write support for Maildir, mbox, MH, Babyl, and MMDF mailboxes. NMailboxMaildirmboxMHBabylMMDFMessageMaildirMessage mboxMessage MHMessage BabylMessage MMDFMessageasciic @ s e Z d Z d Z d d d d Z d d Z d d Z d
d Z d d
Z d d Z d 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 d, d- Z d. d/ Z d d0 d1 Z d2 d3 Z d d4 d5 Z d6 d7 Z d8 d9 Z d: d; Z d< d= Z d> d? Z! d@ Z" d@ dA dB Z# d S)Cr z*A group of messages in a particular place.NTc C s. t j j t j j | | _ | | _ d S)z Initialize a Mailbox instance.N)ospathabspath
expanduser_path_factory)selfr factorycreate r ,/opt/alt/python34/lib64/python3.4/mailbox.py__init__# s !zMailbox.__init__c C s t d d S)z$Add message and return assigned key.z&Method must be implemented by subclassN)NotImplementedError)r messager r r add( s z Mailbox.addc C s t d d S)z=Remove the keyed message; raise KeyError if it doesn't exist.z&Method must be implemented by subclassN)r )r keyr r r remove, s zMailbox.removec C s | j | d S)N)r )r r r r r __delitem__0 s zMailbox.__delitem__c C s* y | j | Wn t k
r% Yn Xd S)z'If the keyed message exists, remove it.N)r KeyError)r r r r r discard3 s
zMailbox.discardc C s t d d S)z>Replace the keyed message; raise KeyError if it doesn't exist.z&Method must be implemented by subclassN)r )r r r r r r __setitem__: s zMailbox.__setitem__c C s. y | j | SWn t k
r) | SYn Xd S)z9Return the keyed message, or default if it doesn't exist.N) __getitem__r! )r r defaultr r r get> s
z Mailbox.getc C sH | j s | j | St j | j | } | j | SWd QXd S)z=Return the keyed message; raise KeyError if it doesn't exist.N)r get_message
contextlibclosingget_file)r r filer r r r$ E s
zMailbox.__getitem__c C s t d d S)z4Return a Message representation or raise a KeyError.z&Method must be implemented by subclassN)r )r r r r r r' M s zMailbox.get_messagec C s t j | j | j S)zReturn a string representation or raise a KeyError.
Uses email.message.Message to create a 7bit clean string
representation of the message.)emailmessage_from_bytes get_bytes as_string)r r r r r
get_stringQ s zMailbox.get_stringc C s t d d S)z8Return a byte string representation or raise a KeyError.z&Method must be implemented by subclassN)r )r r r r r r. X s zMailbox.get_bytesc C s t d d S)z6Return a file-like representation or raise a KeyError.z&Method must be implemented by subclassN)r )r r r r r r* \ s zMailbox.get_filec C s t d d S)z Return an iterator over keys.z&Method must be implemented by subclassN)r )r r r r iterkeys` s zMailbox.iterkeysc C s t | j S)zReturn a list of keys.)listr1 )r r r r keysd s z Mailbox.keysc c sF x? | j D]1 } y | | } Wn t k
r8 w
Yn X| Vq
Wd S)z%Return an iterator over all messages.N)r1 r! )r r valuer r r
itervaluesh s
zMailbox.itervaluesc C s
| j S)N)r5 )r r r r __iter__q s zMailbox.__iter__c C s t | j S)z,Return a list of messages. Memory intensive.)r2 r5 )r r r r valuest s zMailbox.valuesc c sL xE | j D]7 } y | | } Wn t k
r8 w
Yn X| | f Vq
Wd S)z.Return an iterator over (key, message) tuples.N)r1 r! )r r r4 r r r iteritemsx s
zMailbox.iteritemsc C s t | j S)z9Return a list of (key, message) tuples. Memory intensive.)r2 r8 )r r r r items s z
Mailbox.itemsc C s t d d S)z9Return True if the keyed message exists, False otherwise.z&Method must be implemented by subclassN)r )r r r r r __contains__ s zMailbox.__contains__c C s t d d S)z*Return a count of messages in the mailbox.z&Method must be implemented by subclassN)r )r r r r __len__ s zMailbox.__len__c C s( x! | j D] } | j | q
Wd S)zDelete all messages.N)r3 r" )r r r r r clear s z
Mailbox.clearc C s8 y | | } Wn t k
r& | SYn X| j | | S)z3Delete the keyed message and return it, or default.)r! r" )r r r% resultr r r pop s
z Mailbox.popc C s7 x0 | j D] } | | j | f SWt d d S)z6Delete an arbitrary (key, message) pair and return it.zNo messages in mailboxN)r1 r> r! )r r r r r popitem s zMailbox.popitemc C s t | d r | j } n$ t | d r< | j } n | } d } x= | D]5 \ } } y | | | From readbufferzDUse of text mode files is deprecated, use a binary mode file insteadNs
s
s From s >From zInvalid message type: %s)
isinstancer, r r ioBytesIO generatorBytesGeneratorflattenseekrM replacelinesepwrite_append_newlineendswithstrbytesStringIOwarningswarnDeprecationWarninggetvaluerK r@ rN readline
startswith TypeErrortype) r r targetZ mangle_from_rN gendataZlastlineliner r r
_dump_message sZ
zMailbox._dump_message)$__name__
__module__ __qualname____doc__r r r r r" r# r& r$ r' r0 r. r* r1 r3 r5 r6 r7 r8 r9 r: r; r< r> r? rC rD rE rF rG rK r^ ro r r r r r sB c @ sH e Z d Z d Z d Z d d 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 d! d" Z d# d$ Z d% d& Z d' d( Z d) d* Z d+ d, Z d- Z d. d/ Z d0 d1 Z d2 d3 Z d4 d5 Z d S)6r z A qmail-style Maildir mailbox.:NTc C s
t j | | | | i t j j | j d d 6t j j | j d d 6t j j | j d d 6| _ t j j | j s | r t j | j d x9 | j j D] } t j | d q Wq t
| j n i | _ i d d 6d d 6| _ d | _
d | _ d S)z Initialize a Maildir instance.tmpnewcuri r g?N)r r r r joinr _pathsexistsmkdirr7 NoSuchMailboxError_toc _toc_mtimes
_last_read _skewfactor)r dirnamer r r r r r r s zMaildir.__init__c C s | j } y | j | | Wn/ t k
rQ | j t j | j Yn Xt | t | t r | j
} | j | j } | | j k r d } q n d } d } t j
j | j j | j d } t j
j | j | | | } t | t r5t j | j t j
j | j | j f n yL t t d rmt j | j | t j | j n t j | j | Wn] t k
r} z= t j | j | j t j k rt d | n WYd d } ~ Xn X| S)z$Add message and return assigned key. rv r linkz$Name clash with existing message: %sN) _create_tmpro
BaseExceptionrG r r name _sync_closerT r
get_subdircolonget_infor basenamesplitrx r utimegetatimeget_dater@ r renameOSErrorerrnoZEEXISTExternalClashError)r r Ztmp_filesubdirsuffixuniqdester r r r s@
% %
z Maildir.addc C s, t j t j j | j | j | d S)z=Remove the keyed message; raise KeyError if it doesn't exist.N)r r r rx r _lookup)r r r r r r I s zMaildir.removec C s0 y | j | Wn t t f k
r+ Yn Xd S)z'If the keyed message exists, remove it.N)r r! FileNotFoundError)r r r r r r" M s zMaildir.discardc C s$ | j | } | j | } | j | } t | t rE | } n | } t j j | } | j | k r | j | j | j d } n d } | j | t j j
| j | } t j j
| j | | | }
t | t rt j | t j j
| | j f n t j | |
d S)z>Replace the keyed message; raise KeyError if it doesn't exist.rP r NrS )r r rT r r r r r r r" rx r r r r r ) r r r Z old_subpathZtemp_keyZ temp_subpathZdominant_subpathr r Ztmp_pathnew_pathr r r r# U s"
"zMaildir.__setitem__c C s | j | } t t j j | j | d . } | j rN | j | } n t | } Wd QXt j j | \ } } | j | | j
| k r | j | j | j
d n | j t j j
t j j | j | | S)z4Return a Message representation or raise a KeyError.rbNrP rS )r openr r rx r r r r
set_subdirr set_infoset_dategetmtime)r r Zsubpathfmsgr r r r r r' p s $
+zMaildir.get_messagec
C sM t t j j | j | j | d } | j j t d SWd QXd S)z2Return a bytes representation or raise a KeyError.r s
N) r r r rx r r rM r[ r\ )r r r r r r r. s -zMaildir.get_bytesc C s4 t t j j | j | j | d } t | S)z6Return a file-like representation or raise a KeyError.r )r r r rx r r
_ProxyFile)r r r r r r r* s *zMaildir.get_filec c sP | j x? | j D]4 } y | j | Wn t k
rB w Yn X| Vq Wd S)z Return an iterator over keys.N)_refreshr} r r! )r r r r r r1 s
zMaildir.iterkeysc C s | j | | j k S)z9Return True if the keyed message exists, False otherwise.)r r} )r r r r r r: s
zMaildir.__contains__c C s | j t | j S)z*Return a count of messages in the mailbox.)r lenr} )r r r r r; s
zMaildir.__len__c C s d S)z"Write any pending changes to disk.Nr )r r r r rD s z
Maildir.flushc C s d S)zLock the mailbox.Nr )r r r r rE s z Maildir.lockc C s d S)z#Unlock the mailbox if it is locked.Nr )r r r r rF s zMaildir.unlockc C s d S)z Flush and close the mailbox.Nr )r r r r rG s z
Maildir.closec C s g } xz t j | j D]f } t | d k r | d d k r t j j t j j | j | r | j | d d q q W| S)z Return a list of folder names.rP r .N)r listdirr r r isdirrx append)r r= entryr r r list_folders s "$ zMaildir.list_foldersc C s/ t t j j | j d | d | j d d S)z/Return a Maildir instance for the named folder.r r r F)r r r rx r r )r folderr r r
get_folder s zMaildir.get_folderc C s t j j | j d | } t | d | j } t j j | d } t j j | s t j t j | t j t j
Bd n | S)z>Create a folder and return a Maildir instance representing it.r r Z
maildirfolderi ) r r rx r r r rz rG r O_CREATO_WRONLY)r r r r= Zmaildirfolder_pathr r r
add_folder s
zMaildir.add_folderc C s t j j | j d | } xw t j t j j | d t j t j j | d D]; } t | d k s | d d k rW t d | qW qW Wxu t j | D]d } | d k r | d k r | d k r t j j t j j | | r t d | | f q q Wx t j | d d
D]i \ } } } x* | D]" } t j t j j | | q:Wx* | D]" } t j
t j j | | qgWq$Wt j
| d S) z-Delete the named folder, which must be empty.r rv rw rP r z Folder contains message(s): %sru z%Folder contains subdirectory '%s': %stopdownFN) r r rx r r r
NotEmptyErrorr walkr rmdir)r r r r rootdirsfilesr r r
remove_folder s #"$!%
$zMaildir.remove_folderc C s t j } xp t j t j j | j d D]M } t j j | j d | } | t j j | d k r. t j | q. q. Wd S)zDelete old files in "tmp".ru i@ N)timer r r rx r r r )r nowr r r r r clean s
( z
Maildir.cleanrP c C s t j } t j } d | k r9 | j d d } n d | k rZ | j d d } n d t | t | d d t j t j | f } t j j
| j d | } y t j | WnD t
k
rt j d 7_ y t | SWn t k
r Yn XYn Xt d | d
S) z=Create a file in the tmp subdirectory and open and return it./z\057rt z\072z%s.M%sP%sQ%s.%srP g .Aru z&Name clash prevented file creation: %sN)r socket gethostnamer[ intr getpidr _countr rx r statr _create_carefullyFileExistsErrorr )r r Zhostnamer r r r r r s& &
zMaildir._create_tmpc C s? t j | j d | j k r d } xS | j D]H } t j j | j | } | | j | k rk d } n | | j | Replace the keyed message; raise KeyError if it doesn't exist.TN)r r r} r )r r r r r r r# f s
z _singlefileMailbox.__setitem__c c s | j | j j Dd Hd S)z Return an iterator over keys.N)r r} r3 )r r r r r1 l s
z_singlefileMailbox.iterkeysc C s | j | | j k S)z9Return True if the keyed message exists, False otherwise.)r r} )r r r r r r: q s
z _singlefileMailbox.__contains__c C s | j t | j S)z*Return a count of messages in the mailbox.)r r r} )r r r r r; v s
z_singlefileMailbox.__len__c C s& | j s" t | j d | _ n d S)zLock the mailbox.TN)r
_lock_filer )r r r r rE { s
z_singlefileMailbox.lockc C s& | j r" t | j d | _ n d S)z#Unlock the mailbox if it is locked.FN)r _unlock_filer )r r r r rF s
z_singlefileMailbox.unlockc
C s | j s/ | j r+ t | j d | _ n d S| j j d d | j j } | | j k r| t d | j | f n t | j } y i } | j
| x t | j j
D] } | j | \ } } | j j | | j | | j } xC | j j t d | | j j } | s.Pn | j | q W| | j f | | <| j | q W| j | _ Wn% | j t j | j Yn Xt | | j j t j | j j } t j | j | y t j | j | j Wn8 t k
r1t j | j t j | j | j Yn Xt | j d | _ | | _ d | _ d | _ | j rt | j d d n d S) z"Write any pending changes to disk.FNr rO z4Size of mailbox file changed (expected %i, found %i)i zrb+dotlock) r r _sync_flushr rZ tellr r _create_temporaryr _pre_mailbox_hooksortedr} r3 _pre_message_hookrM minr] _post_message_hookrG r r r r r st_modechmodr r r r r )
r Zcur_lenZnew_fileZnew_tocr startstopZ new_startrN moder r r rD s^
z_singlefileMailbox.flushc C s d S)z,Called before writing the mailbox to file f.Nr )r r r r r r s z$_singlefileMailbox._pre_mailbox_hookc C s d S)z-Called before writing each message to file f.Nr )r r r r r r s z$_singlefileMailbox._pre_message_hookc C s d S)z,Called after writing each message to file f.Nr )r r r r r r s z%_singlefileMailbox._post_message_hookc C sA z | j Wd z | j r* | j n Wd | j j XXd S)z Flush and close the mailbox.N)rD r rF r rG )r r r r rG s z_singlefileMailbox.closec C sc | j d k r | j n | d k r_ y | j | SWq_ t k
r[ t d | Yq_ Xn d S)z'Return (start, stop) or raise KeyError.NzNo message with key: %s)r}
_generate_tocr! )r r r r r r s
z_singlefileMailbox._lookupc C s | j j d d | j j } t | j d k rT | j rT | j | j n y3 | j | j | j | } | j | j Wn% t
k
r | j j | Yn X| j j | j j | _
| S)z;Append message to mailbox and return (start, stop) offsets.r rO )r rZ r r r} r r r _install_messager r truncaterD r )r r ZbeforeZoffsetsr r r r s
z"_singlefileMailbox._append_message)rp rq rr rs r r r r# r1 r: r; rE rF rD r r r rG r r r r r r r < s"
@
r c @ sa e Z d Z d Z d Z d d Z d d d Z d d d Z d d
d Z d d
Z d S) _mboxMMDFzAn mbox or MMDF mailbox.Tc C s | j | \ } } | j j | | j j j t d } | j j | | j j } | j | j t d } | j | d d j
d | S)z4Return a Message representation or raise a KeyError. s
rQ Nr ) r r rZ rg r[ r\ rM r _message_factoryset_fromdecode)r r r r from_linestringr r r r r' s z_mboxMMDF.get_messageFc C s" t j | j | j d | S)z3Return a string representation or raise a KeyError.unixfrom)r, r- r. r/ )r r from_r r r r0 s z_mboxMMDF.get_stringc C sj | j | \ } } | j j | | s; | j j n | j j | | j j } | j t d S)z3Return a string representation or raise a KeyError.s
)r r rZ rg rM r r[ r\ )r r r r r r r r r r. s z_mboxMMDF.get_bytesc C sW | j | \ } } | j j | | s; | j j n t | j | j j | S)z6Return a file-like representation or raise a KeyError.)r r rZ rg _PartialFiler )r r r r r r r r r* s
z_mboxMMDF.get_filec C s d } t | t r' | j | } n t | t r | j d r | j d } | d k r | d | } | | d d } q | } d } ns t | t r | j j d } d | } nB t | t j
j r | j } | d k r | j d } q n | d k r7d t
j t
j j } n | j j } | j j | t | j | | j | j | j j } | | f S) z1Format a message and blindly write to self._file.Ns From s
rP r r s From MAILER-DAEMON rS )rT r` rK ra rh find_mboxMMDFMessageget_fromrH r, r r get_unixfromr asctimegmtimer r r] r\ ro
_mangle_from_)r r r newlineZauthorr r r r r r $ s0
"z_mboxMMDF._install_messageN)
rp rq rr rs r r' r0 r. r* r r r r r r s
r c @ sL e Z d Z d Z d Z d Z d d d d Z d d Z d d Z d S)
r zA classic mbox mailbox.TNc C s# t | _ t j | | | | d S)zInitialize an mbox mailbox.N)r
r r r )r r r r r r r r J s z
mbox.__init__c C s | j t d S)z,Called after writing each message to file f.N)r] r\ )r r r r r r O s zmbox._post_message_hookc C sM g g } } d } | j j d x | j j } | j j } | j d r t | t | k r | r | j | t t q | j | n | j | d } q& | s | r | j | t t n
| j | Pq& | t k r d } q& d } q& Wt t t
| | | _ t | j | _ | j j | _
d S)z0Generate key-to-(start, stop) table of contents.Fr s From TN)r rZ r rg rh r r r\ dict enumeratezipr} r r )r startsstopsZlast_was_emptyline_posrn r r r r S s0
zmbox._generate_toc) rp rq rr rs r r^ r r r r r r r r A s c @ sL e Z d Z d Z d d d d Z d d Z d d Z d
d Z d S) r zAn MMDF mailbox.NTc C s# t | _ t j | | | | d S)zInitialize an MMDF mailbox.N)r
r r r )r r r r r r r r x s z
MMDF.__init__c C s | j d t d S)z-Called before writing each message to file f.s N)r] r\ )r r r r r r } s zMMDF._pre_message_hookc C s | j t d t d S)z,Called after writing each message to file f.s N)r] r\ )r r r r r r s zMMDF._post_message_hookc C sA g g } } | j j d d } x | } | j j } | j j } | j d t r | j | xw | } | j j } | j j } | d t k r | j | t t Pqm | sm | j | Pqm qm Wq& | s& Pq& q& Wt t t
| | | _ t | j | _ | j j d d | j j | _
d S)z0Generate key-to-(start, stop) table of contents.r s rO N)r rZ rg r rh r\ r r r r r r} r r )r r r next_posr rn r r r r s2
zMMDF._generate_toc)rp rq rr rs r r r r r r r r r u s
c @ s$ e Z d Z d Z d d 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 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 S)0r zAn MH mailbox.NTc C s t j | | | | t j j | j s | r t j | j d t j t j t j j | j d t j
t j Bt j Bd q t
| j n d | _ d S)zInitialize an MH instance.i z
.mh_sequencesi FN)r r r r rz r r{ rG r rx r O_EXCLr r| r )r r r r r r r r s !!z MH.__init__c C s; | j } t | d k r' d } n t | d } t j j | j t | } t | } d } z | j r t
| n z y | j | | WnH t k
r | j r t
| n t | d } t j | Yn Xt | t r| j | | n Wd | j r t
| n XWd | s6t | n X| S)z$Add message and return assigned key.r rP FTN)r3 r maxr r rx r r` r r r ro r r r r rT r _dump_sequences)r r r3 Znew_keyr r closedr r r r s6
zMH.addc C s t j j | j t | } y t | d } WnM t k
r } z- | j t j k rk t d | n WYd d } ~ Xn X| j
t j | d S)z=Remove the keyed message; raise KeyError if it doesn't exist.zrb+zNo message with key: %sN) r r rx r r` r r r r r! rG r )r r r r r r r r r s
z MH.removec C s t j j | j t | } y t | d } WnM t k
r } z- | j t j k rk t d | n WYd d } ~ Xn Xz | j
r t | n zY t j t j | t j
t j B | j | | t | t r | j | | n Wd | j
r t | n XWd t | Xd S)z>Replace the keyed message; raise KeyError if it doesn't exist.zrb+zNo message with key: %sN)r r rx r r` r r r r r! r r rG r O_TRUNCro rT r r r r )r r r r r r r r r r# s$
# zMH.__setitem__c C s> y^ | j r6 t t j j | j t | d } n' t t j j | j t | d } WnM t k
r } z- | j t j k r t
d | n WYd d } ~ Xn X| E | j r t | n z t | } Wd | j r t
| n XWd QXx< | j j D]( \ } } | | k r| j | qqW| S)z4Return a Message representation or raise a KeyError.zrb+r zNo message with key: %sN)r r r r rx r r` r r r r! r r r
get_sequencesr9 add_sequence)r r r r r r key_listr r r r' s& *+
zMH.get_messagec C s y^ | j r6 t t j j | j t | d } n' t t j j | j t | d } WnM t k
r } z- | j t j k r t
d | n WYd d } ~ Xn X| O | j r t | n z | j j
t d SWd | j r t | n XWd QXd S)z2Return a bytes representation or raise a KeyError.zrb+r zNo message with key: %sNs
)r r r r rx r r` r r r r! r rM r[ r\ r )r r r r r r r r. s *+
z MH.get_bytesc C s y+ t t j j | j t | d } WnM t k
rz } z- | j t j k re t d | n WYd d } ~ Xn Xt
| S)z6Return a file-like representation or raise a KeyError.r zNo message with key: %sN) r r r rx r r` r r r r! r )r r r r r r r r* ' s +z MH.get_filec C s) t t d d t j | j D S)z Return an iterator over keys.c s s' | ] } | j r t | Vq d S)N)isdigitr ).0r r r r 4 s z MH.iterkeys..)iterr r r r )r r r r r1 2 s z MH.iterkeysc C s( t j j t j j | j t | S)z9Return True if the keyed message exists, False otherwise.)r r rz rx r r` )r r r r r r: 7 s zMH.__contains__c C s t t | j S)z*Return a count of messages in the mailbox.)r r2 r1 )r r r r r; ; s z
MH.__len__c C sJ | j sF t t j j | j d d | _ t | j d | _ n d S)zLock the mailbox.z
.mh_sequenceszrb+TN)r r r r rx r r r )r r r r rE ? s $
zMH.lockc C s9 | j r5 t | j t | j | ` d | _ n d S)z#Unlock the mailbox if it is locked.FN)r r r r )r r r r rF F s
z MH.unlockc C s d S)z&Write any pending changes to the disk.Nr )r r r r rD N s zMH.flushc C s | j r | j n d S)z Flush and close the mailbox.N)r rF )r r r r rG R s zMH.closec C s[ g } xN t j | j D]: } t j j t j j | j | r | j | q q W| S)z Return a list of folder names.)r r r r r rx r )r r= r r r r r W s
$zMH.list_foldersc C s+ t t j j | j | d | j d d S)z+Return an MH instance for the named folder.r r F)r r r rx r r )r r r r r r _ s z
MH.get_folderc C s% t t j j | j | d | j S)z:Create a folder and return an MH instance representing it.r )r r r rx r r )r r r r r r d s z
MH.add_folderc C s t j j | j | } t j | } | d g k rU t j t j j | d n" | g k rd n t d | j t j | d S)z-Delete the named folder, which must be empty.z
.mh_sequenceszFolder not empty: %sN)r r rx r r r r r )r r r Zentriesr r r r i s zMH.remove_folderc
sb i } t t j j | j d d d d /} t | j x| D] } y | j d \ } } t } xr | j D]d } | j r | j t
| q} d d | j d D \ } } | j t | | d q} W f d
d t
| D | | .-rP c s" g | ] } | k r | q Sr r )r r )all_keysr r
s z$MH.get_sequences..r z"Invalid sequence specification: %sN)r r r rx r setr3 r r
r r rC ranger r rJ FormatErrorrstrip)
r Zresultsr rn r contentsr3 specr r r )r r r u s& *
" #
zMH.get_sequencesc C sk t t j j | j d d d d } z2t j t j | j t j t j B x| j D] \ } } t
| d k r q] n | j | d d } d } x t t
| D]r } | d | k r | s d
} | j d q n7 | r d } | j d | | f n | j d
| | } q W| rG| j t | d q] | j d q] WWd t | Xd S)z:Set sequences using the given name-to-key-list dictionary.z
.mh_sequenceszr+r r r rt NFrP Tr z%s %sz %s
)r r r rx r rG r r r r9 r r] r r r` r )r sequencesr r r3 prevZ
completingr r r r
set_sequences s. '&
zMH.set_sequencesc C s | j } d } g } x| j D] } | d | k r| j | | d f t t d r t j t j j | j t | t j j | j t | d t j
t j j | j t | qt j t j j | j t | t j j | j t | d n | d 7} q% W| d | _ t
| d k rEd SxS | j D]E \ } } x6 | D]. \ } } | | k re| | | j | Replace the keyed message; raise KeyError if it doesn't exist.N)r r# rT r r, r+ )r r r r r r r# s zBabyl.__setitem__c
C sd | j | \ } } | j j | | j j t j } xG | j j } | d t k sg | rk Pn | j | j t d qA Wt j } xC | j j } | t k s | r Pn | j | j t d q W| | j j } | j j
| } | j t d } t | j | } | j
| j | | j k r`| j | j | n | S)z4Return a Message representation or raise a KeyError.s *** EOOH ***s
)r r rZ rg rU rV r\ r] r[ r rM r rf set_visibler+
set_labels)
r r r r original_headersrn Zvisible_headersnZbodyr r r r r' s.
zBabyl.get_messagec C s | j | \ } } | j j | | j j t j } xG | j j } | d t k sg | rk Pn | j | j t d qA Wx* | j j } | t k s | r Pq q W| j } | | j j
} | j j | } | j t d } | | S)z3Return a string representation or raise a KeyError.s *** EOOH ***s
) r r rZ rg rU rV r\ r] r[ rf r rM ) r r r r r/ rn Zheadersr0 rm r r r r. s$
zBabyl.get_bytesc C s" t j | j | j d t S)z6Return a file-like representation or raise a KeyError.s
)rU rV r. r[ r\ )r r r r r r* " s zBabyl.get_filec C sT | j t } x$ | j j D] } | j | q# W| j | j t | S)z4Return a list of user-defined labels in the mailbox.)r r r+ r7 rC difference_update_special_labelsr2 )r labelsZ
label_listr r r r, & s
zBabyl.get_labelsc C s g g } } | j j d d } g } x(| } | j j } | j j } | d t k r t | t | k r | j | t t n | j | d d | j j d d j d D } | j | q, | d k s | d t k r/t | t | k rP| j | t t qPq, | s, | j | t t Pq, q, Wt t t
| | | _ t t | | _ t | j | _
| j j d d | j j | _ d S)
z0Generate key-to-(start, stop) table of contents.r s c S s( g | ] } | j r | j q Sr )strip)r labelr r r r = s z'Babyl._generate_toc..rP N ,s rO )r rZ rg r r\ r r r r r r r} r+ r r )r r r r Z label_listsr rn r3 r r r r / s4
& zBabyl._generate_tocc C sm d t } | d t 7} | j } d d | D } | d d j | t 7} | d 7} | j | d S) z,Called before writing the mailbox to file f.s BABYL OPTIONS:s
Version: 5c s s | ] } | j Vq d S)N)rH )r r5 r r r r R s z*Babyl._pre_mailbox_hook..s Labels:r6 s N)r\ r, rx r] )r r Zbabylr3 r r r r M s
zBabyl._pre_mailbox_hookc C s | j d t d S)z-Called before writing each message to file f.s N)r] r\ )r r r r r r W s zBabyl._pre_message_hookc C s | j t d d S)z,Called after writing each message to file f.s N)r] r\ )r r r r r r [ s zBabyl._post_message_hookc C s | j j } t | t r g } g } x@ | j D]2 } | | j k r\ | j | q7 | j | q7 W| j j d x( | D] } | j j d | j q W| j j d x, | D]$ } | j j d | j d q W| j j t n | j j d t t | t
j j rt
j } t
j j | d d } | j | | j d xC | j } | j j | j d t | d k s| rdPqdqdW| j j d
t t | t rJt
j } t
j j | d d }
|
j | j x | j } | j j | j d t | d k s?| rPqqWnS | j d xC | j } | j j | j d t | d k s| rZPqZqZWxX| j d } | sPn | j j | j d t qWn t | t t t
j f r/t | t
j r+t j d t d
| j } n t | t rL| j | } n | j d d } | d d k r| j j | d | j d t | j j d
t | j j | d | j d t | j j | | d j d t q| j j d
t t | j j | j d t nt | d rt | d rlt j d t d
| j! } n | j }
d } x | j } | j" d r| d d d } n& | j" d r| d d d } n | j j | j d t | d k s| r| r8d } | j j d
t | j |
q<PqqWx | j } | sYPn | j" d r| d d t } nL | j" d r| d d t } n& | j" d r| d d t } n | j j | qCWn t# d t$ | | j j } | | f S) z0Write message contents and return (start, stop). 1s , s ,, r6 s 1,,Fr s
s *** EOOH ***i z8Use of StringIO input is deprecated, use BytesIO insteadrL s
rO rP Nrg rN zDUse of text mode files is deprecated, use a binary mode file insteadTs
s
zInvalid message type: %srS rR rS rR rS rS )%r r rT r r, r2 r r] rH r\ r, r r rU rV rW rX rY rZ rg r[ get_visiblerM ra r` rb rc rd re rf rK r r@ rN r_ ri rj )r r r Zspecial_labelsr3 r5 Z orig_bufferZorig_generatorrn Z
vis_bufferZ
vis_generatorrN Z
body_startZ original_posZ
first_passr r r r r _ s
"
#
&&)
zBabyl._install_message)r$ r% r& r' r( r) r* )rp rq rr rs frozensetr2 r r r r# r' r. r* r, r r r r r r r r r r s
c @ s= e Z d Z d Z d d d Z d d Z d d Z d S) r z0Message with mailbox-format-specific properties.Nc C s, t | t j j rM | j t j | t | t r(| j | q(n t | t ru | j t j | n t | t
r | j t j | n t | t j
r | j t j | n` t | d r | j t j | n8 | d k rt j j j | n t d t | d S)z Initialize a Message instance.rM NzInvalid message type: %s)rT r, r r _become_messagecopydeepcopy _explain_tora r- r` Zmessage_from_stringrU
TextIOWrapperZmessage_from_filer@ Zmessage_from_binary_filer ri rj )r r r r r r s zMessage.__init__c C sM t | d g } x4 | j D]) } | | k r | j | | j | s zMessage._explain_to)rp rq rr rs r r; r> r r r r r s c @ s e Z d Z d Z d d d g Z d 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 S) r z)Message with Maildir-specific properties._subdir_info_dateNc C s5 d | _ d | _ t j | _ t j | | d S)z%Initialize a MaildirMessage instance.rv r N)rC rD r rE r r )r r r r r r s zMaildirMessage.__init__c C s | j S)zReturn 'new' or 'cur'.)rC )r r r r r s zMaildirMessage.get_subdirc C s8 | d k s | d k r$ | | _ n t d | d S)z Set subdir to 'new' or 'cur'.rv rw z!subdir must be 'new' or 'cur': %sN)rC rJ )r r r r r r s zMaildirMessage.set_subdirc C s+ | j j d r# | j d d Sd Sd S)z*Return as a string the flags that are set.z2,rO Nr )rD rh )r r r r get_flags s zMaildirMessage.get_flagsc C s d d j t | | _ d S)z)Set the given flags and unset all others.z2,r N)rx r rD )r flagsr r r set_flags s zMaildirMessage.set_flagsc C s0 | j d j t | j t | B d S)z.Set the given flag(s) without changing others.r N)rH rx r rF )r flagr r r add_flag s zMaildirMessage.add_flagc C s? | j r; | j d j t | j t | n d S)z7Unset the given string flag(s) without changing others.r N)rF rH rx r )r rI r r r remove_flag s zMaildirMessage.remove_flagc C s | j S)zn t d t | d S)z;Copy Maildir-specific state to message insofar as possible.SRrw OTDFAz
MAILER-DAEMONr$ repliedflaggedr% r' Pr( z$Cannot convert to specified type: %sN)rT r rH rF r r r r r r rJ r r r r r r add_labelr ri rj )r r rG r r r r> 1 sN " zMaildirMessage._explain_to)rp rq rr rs r@ r r r rF rH rJ rK r r r r r> r r r r r s c @ s e Z d Z d Z d g Z d d d Z d d Z d d d Z d
d Z d d
Z d d Z
d d Z d d Z d S)r z/Message with mbox- or MMDF-specific properties._fromNc C s} | j d d t | t j j ri | j } | d k ri | j d ri | j | d d qi n t j | | d S)z'Initialize an mboxMMDFMessage instance.z
MAILER-DAEMONTNzFrom rQ )r rT r, r r r rh r )r r r r r r r b s z_mboxMMDFMessage.__init__c C s | j S)z Return contents of "From " line.)rY )r r r r r k s z_mboxMMDFMessage.get_fromc C sN | d k rA | d k r' t j } n | d t j | 7} n | | _ d S)z>Set "From " line, formatting and appending time_ if specified.NT )r r r rY )r r Ztime_r r r r o s
z_mboxMMDFMessage.set_fromc C s | j d d | j d d S)z*Return as a string the flags that are set.Statusr zX-Status)r& )r r r r rF w s z_mboxMMDFMessage.get_flagsc C s t | } d
\ } } x4 d D], } | | k r | | 7} | j | q q Wx4 d D], } | | k rV | | 7} | j | qV qV W| d j t | 7} y | j d | Wn" t k
r | j d | Yn Xy | j d | Wn" t k
r| j d | Yn Xd S)
z)Set the given flags and unset all others.r rO rP rR rS rT r[ zX-StatusN)r r )rO rP )rR rS rT )r r rx r replace_headerr! Z
add_header)r rG Z status_flagsZ
xstatus_flagsrI r r r rH { s&
z_mboxMMDFMessage.set_flagsc C s0 | j d j t | j t | B d S)z.Set the given flag(s) without changing others.r N)rH rx r rF )r rI r r r rJ s z_mboxMMDFMessage.add_flagc C sK d | k s d | k rG | j d j t | j t | n d S)z7Unset the given string flag(s) without changing others.r[ zX-Statusr N)rH rx r rF )r rI r r r rK s z _mboxMMDFMessage.remove_flagc C s t | t r$t | j } d | k r= | j d n d | k rY | j d n d | k ru | j d n d | k r | j d n d | k r | j d n | d =| d
=d j | j j d d
} y& | j t
j t j
| d Wqt t f k
r YqXnlt | t r\| j | j | j | j n4t | t rt | j } d | k r| j d n d | k r| j d n d | k r| j d n | d =| d
=n t | t rht | j } d | k r | j d n d | k r;| j d n d | k rW| j d n | d =| d
=n( t | t rzn t d t | d
S)zACopy mbox- or MMDF-specific state to message insofar as possible.rP rw rS rT rO rN rR rQ Zstatuszx-statusrZ rQ Nz%a %b %d %H:%M:%S %Yr$ rU rV r% r' z$Cannot convert to specified type: %s)rT r r rF r rJ rx r r r calendarZtimegmr ZstrptimerJ
OverflowErrorr rH r r r r rX r ri rj )r r rG Z
maybe_dater r r r> s^ %
z _mboxMMDFMessage._explain_to)
rp rq rr rs r@ r r r rF rH rJ rK r> r r r r r ] s r c @ s e Z d Z d Z d S)r
z&Message with mbox-specific properties.N)rp rq rr rs r r r r r
s c @ sj e Z d Z d Z d g Z d d d Z d d Z d d Z d
d Z d d
Z d d Z
d S)r z$Message with MH-specific properties.
_sequencesNc C s g | _ t j | | d S)z!Initialize an MHMessage instance.N)r` r r )r r r r r r s zMHMessage.__init__c C s | j d d S)z4Return a list of sequences that include the message.N)r` )r r r r r s zMHMessage.get_sequencesc C s t | | _ d S)z3Set the list of sequences that include the message.N)r2 r` )r r r r r r s zMHMessage.set_sequencesc C sN t | t r4 | | j k rJ | j j | qJ n t d t | d S)z8Add sequence to list of sequences including the message.z sequence type must be str: %sN)rT r` r` r ri rj )r r# r r r r s zMHMessage.add_sequencec C s- y | j j | Wn t k
r( Yn Xd S)zARemove sequence from the list of sequences including the message.N)r` r rJ )r r# r r r remove_sequence s
zMHMessage.remove_sequencec C s t | t r t | j } d | k r= | j d n | j d | j d d | k rs | j d n d | k r| j d qn?t | t rt | j } d | k r | j d n
| j d d | k r | j d n d | k r| j d
qn t | t rMx | j D] } | j | q3Wn t | t rt | j } d | k r| j
d n d | k r| j
d qn( t | t rn t d t
| d
S)z6Copy MH-specific state to message insofar as possible.r$ rw rN rV rS rU rO ROrP rT r' z$Cannot convert to specified type: %sN)rT r r r r rJ r r r r rX r ri rj )r r r r# r r r r> s@
zMHMessage._explain_to) rp rq rr rs r@ r r r r ra r> r r r r r s c @ s e Z d Z d Z d d g Z d 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 S)r z'Message with Babyl-specific properties.r+ _visibleNc C s) g | _ t | _ t j | | d S)z$Initialize an BabylMessage instance.N)r+ r rc r )r r r r r r s zBabylMessage.__init__c C s | j d d S)z'Return a list of labels on the message.N)r+ )r r r r r, % s zBabylMessage.get_labelsc C s t | | _ d S)z&Set the list of labels on the message.N)r2 r+ )r r3 r r r r. ) s zBabylMessage.set_labelsc C sN t | t r4 | | j k rJ | j j | qJ n t d t | d S)z+Add label to list of labels on the message.zlabel must be a string: %sN)rT r` r+ r ri rj )r r5 r r r rX - s zBabylMessage.add_labelc C s- y | j j | Wn t k
r( Yn Xd S)z4Remove label from the list of labels on the message.N)r+ r rJ )r r5 r r r remove_label5 s
zBabylMessage.remove_labelc C s
t | j S)z3Return a Message representation of visible headers.)r rc )r r r r r9 < s zBabylMessage.get_visiblec C s t | | _ d S)z2Set the Message representation of visible headers.N)r rc )r Zvisibler r r r- @ s zBabylMessage.set_visiblec C s xG | j j D]6 } | | k r< | j j | | | q | j | =q Wx= d D]5 } | | k rQ | | j k rQ | | | j | O sF
zBabylMessage._explain_to)rp rq rr rs r@ r r, r. rX rd r9 r- rl r> r r r r r s c @ s e Z d Z d Z d S)r
z&Message with MMDF-specific properties.N)rp rq rr rs r r r r r
y s c @ s e Z d Z d Z d d d Z d d d Z d d d Z d d d
Z d d d Z d
d Z d d Z
d 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 e d$ d% Z d S)&r z A read-only wrapper of a file.Nc C s4 | | _ | d k r' | j | _ n | | _ d S)zInitialize a _ProxyFile.N)r r _pos)r r posr r r r s z_ProxyFile.__init__c C s | j | | j j S)z Read bytes.)_readr rM )r sizer r r rM s z_ProxyFile.readc C s | j | | j j S)z Read bytes.)ro r read1)r rp r r r rq s z_ProxyFile.read1c C s | j | | j j S)z Read a line.)ro r rg )r rp r r r rg s z_ProxyFile.readlinec C sW g } xJ | D]B } | j | | d k r
| t | 8} | d k rO PqO q
q
W| S)zRead multiple lines.Nr )r r )r sizehintr= rn r r r readlines s
z_ProxyFile.readlinesc c s+ x$ | j } | s t n | Vq Wd S)zIterate over lines.N)rg r )r rn r r r r6 s
z_ProxyFile.__iter__c C s | j S)zReturn the position.)rm )r r r r r s z_ProxyFile.tellr c C sK | d k r" | j j | j n | j j | | | j j | _ d S)zChange position.rP N)r rZ rm r )r offsetwhencer r r rZ s z_ProxyFile.seekc C s> t | d r: t | j d r1 | j j n | ` n d S)zClose the file.r rG N)r@ r rG )r r r r rG s z_ProxyFile.closec C sJ | d k r d } n | j j | j | | } | j j | _ | S)z"Read size bytes using read_method.NrP rS )r rZ rm r )r rp read_methodr= r r r ro s z_ProxyFile._readc C s | S)z$Context management protocol support.r )r r r r __enter__ s z_ProxyFile.__enter__c G s | j d S)N)rG )r excr r r __exit__ s z_ProxyFile.__exit__c C s
| j j S)N)r readable)r r r r rz s z_ProxyFile.readablec C s
| j j S)N)r writable)r r r r r{ s z_ProxyFile.writablec C s
| j j S)N)r seekable)r r r r r| s z_ProxyFile.seekablec C s
| j j S)N)r rD )r r r r rD s z_ProxyFile.flushc C s3 t | d s d St | j d s) d S| j j S)Nr Tr F)r@ r r )r r r r r s
z_ProxyFile.closed)rp rq rr rs r rM rq rg rs r6 r rZ rG ro rw ry rz r{ r| rD propertyr r r r r r } s$ r c @ s[ e Z d Z d Z d d d d Z d d Z d d d Z d
d Z d d
Z d S)r z&A read-only wrapper of part of a file.Nc C s) t j | | | | | _ | | _ d S)zInitialize a _PartialFile.N)r r _start_stop)r r r r r r r r s z_PartialFile.__init__c C s t j | | j S)z*Return the position with respect to start.)r r r~ )r r r r r s z_PartialFile.tellr c C sY | d k r! | j | _ d } n! | d k rB | j | _ d } n t j | | | d S)z8Change position, possibly with respect to start or stop.r rP rO N)r~ rm r r rZ )r rt ru r r r rZ s z_PartialFile.seekc C s` | j | j } | d k r d S| d k sD | d k sD | | k rM | } n t j | | | S)z;Read size bytes using read_method, honoring start and stop.r r N)r rm r ro )r rp rv Z remainingr r r ro s $ z_PartialFile._readc C s t | d r | ` n d S)Nr )r@ r )r r r r rG s z_PartialFile.close) rp rq rr rs r r rZ ro rG r r r r r s
r Tc - C s d } yt r y t j | t j t j B Wq t k
r } z? | j t j t j t j f k ry t d | j
n WYd d } ~ Xq Xn | ry! t | j
d } | j WnG t k
r} z' | j t j t j f k r d S WYd d } ~ Xn Xyf t
t d rHt j | j
| j
d d } t j | j
n t j | j
| j
d d } Wqt k
rt j | j
t d | j
YqXn WnD t rt j | t j n | rt j | j
d n Yn Xd S)z(Lock file f using lockf and dot locking.Fzlockf: lock unavailable: %sNz.lockr Tzdot lock unavailable: %s)fcntllockfZLOCK_EXZLOCK_NBr r ZEAGAINr r r r r rG r@ r r r r r r LOCK_UN)r r Z dotlock_doner Zpre_lockr r r r sF !
r c C sP t r t j | t j n t j j | j d rL t j | j d n d S)z*Unlock file f using lockf and dot locking.z.lockN)r r r r r rz r r )r r r r r . s r c C sL t j | t j t j Bt j Bd } z t | d SWd t j | Xd S)zCCreate a file if it doesn't exist and open for reading and writing.i zrb+N)r r r r O_RDWRrG )r fdr r r r 5 s &r c C s2 t d | t t j t j t j f S)zBCreate a temp file based on path and open for reading and writing.z %s.%s.%s.%s)r r r r r r r )r r r r r = s r c C s3 | j t t d r/ t j | j n d S)z0Ensure changes to file f are physically on disk.fsyncN)rD r@ r r fileno)r r r r r C s
r c C s t | | j d S)z:Close file f, ensuring all changes are physically on disk.N)r rG )r r r r r I s
r c @ s e Z d Z d Z d S)Errorz"Raised for module-specific errors.N)rp rq rr rs r r r r r O s r c @ s e Z d Z d Z d S)r| z:The specified mailbox does not exist and won't be created.N)rp rq rr rs r r r r r| R s r| c @ s e Z d Z d Z d S)r z>The specified mailbox is not empty and deletion was requested.N)rp rq rr rs r r r r r U s r c @ s e Z d Z d Z d S)r z)Another process caused an action to fail.N)rp rq rr rs r r r r r X s r c @ s e Z d Z d Z d S)r z)A file appears to have an invalid format.N)rp rq rr rs r r r r r [ s r )0rs r r r^ r r r< rc r, Z
email.messageZemail.generatorrU r( r ImportError__all__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 Exceptionr r| r r r r r r r sd
6B4- 1 %mqH_a')