/snap/core22/2437/usr/lib/python3.10/__pycache__
Edit: /snap/core22/2437/usr/lib/python3.10/__pycache__/mailbox.cpython-310.pyc (60091B)
o
p̦i3 @ s> d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Zddl
Zddl Z ddl Z ddl
mZ zddlZW n eyI dZY nw g dZejdZG dd dZG dd d eZG d
d d eZG d d
d
eZG dd deZG dd deZG dd deZG dd deZG dd dej j Z G dd de Z G dd de Z G d d d e Z G d d d e Z!G d d! d!e Z"G d"d# d#e Z#G d$d% d%Z$G d&d' d'e$Z%d?d)d*Z&d+d, Z'd-d. Z(d/d0 Z)d1d2 Z*d3d4 Z+G d5d6 d6e,Z-G d7d8 d8e-Z.G d9d: d:e-Z/G d;d< d
d>e-Z1dS )@zDRead/write support for Maildir, mbox, MH, Babyl, and MMDF mailboxes. N) GenericAlias)MailboxMaildirmboxMHBabylMMDFMessageMaildirMessage mboxMessage MHMessage BabylMessage MMDFMessageErrorNoSuchMailboxError
NotEmptyErrorExternalClashError FormatErrorasciic @ s e Zd ZdZdCddZdd Zdd Zd
d Zd d
Zdd Z dDddZ
dd Z dd Z dd Z
dd Zdd Zd d Zd d Zd d! Zd"d# Zd$d% Zd&d' Zd(d) Zd*d+ Zd,d- Zd.d/ ZdDd0d1Zd2d3 ZdDd4d5Z d6d7 Z d8d9 Z d:d; Z dd? Z!d@Z"dEdAdBZ#e$e%Z&dS )Fr z*A group of messages in a particular place.NTc C s t jt j|| _|| _dS )z Initialize a Mailbox instance.N)ospathabspath
expanduser_path_factoryselfr factorycreate r /usr/lib/python3.10/mailbox.py__init__% s
zMailbox.__init__c C t d)$Add message and return assigned key.&Method must be implemented by subclassNotImplementedErrorr messager r r add* z Mailbox.addc C r" )=Remove the keyed message; raise KeyError if it doesn't exist.r$ r% r keyr r r remove. r* zMailbox.removec C s | | d S N)r. r, r r r __delitem__2 s zMailbox.__delitem__c C s& z| | W dS ty Y dS w z'If the keyed message exists, remove it.N)r. KeyErrorr, r r r discard5 s
zMailbox.discardc C r" )>Replace the keyed message; raise KeyError if it doesn't exist.r$ r% r r- r( r r r __setitem__< r* zMailbox.__setitem__c C s$ z| |W S ty | Y S w )z9Return the keyed message, or default if it doesn't exist.) __getitem__r2 )r r- defaultr r r get@ s
z Mailbox.getc C sN | j s| |S t| |
}| |W d S 1 s w Y dS )z=Return the keyed message; raise KeyError if it doesn't exist.N)r get_message
contextlibclosingget_file)r r- filer r r r7 G s
$zMailbox.__getitem__c C r" )4Return a Message representation or raise a KeyError.r$ r% r, r r r r: O r* zMailbox.get_messagec C s t | | 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_stringr, r r r
get_stringS s zMailbox.get_stringc C r" )z8Return a byte string representation or raise a KeyError.r$ r% r, r r r rC Z r* zMailbox.get_bytesc C r" )6Return a file-like representation or raise a KeyError.r$ r% r, r r r r= ^ r* zMailbox.get_filec C r" ) Return an iterator over keys.r$ r% r r r r iterkeysb r* zMailbox.iterkeysc C t | S )zReturn a list of keys.)listrI rH r r r keysf z Mailbox.keysc c s: | D ]}z| | }W n ty Y qw |V qdS )z%Return an iterator over all messages.NrI r2 r r- valuer r r
itervaluesj s zMailbox.itervaluesc C s | S r/ )rQ rH r r r __iter__s s zMailbox.__iter__c C rJ )z,Return a list of messages. Memory intensive.)rK rQ rH r r r valuesv rM zMailbox.valuesc c s> | D ]}z| | }W n ty Y qw ||fV qdS )z.Return an iterator over (key, message) tuples.NrN rO r r r iteritemsz s zMailbox.iteritemsc C rJ )z9Return a list of (key, message) tuples. Memory intensive.)rK rT rH r r r items rM z
Mailbox.itemsc C r" )9Return True if the keyed message exists, False otherwise.r$ r% r, r r r __contains__ r* zMailbox.__contains__c C r" )*Return a count of messages in the mailbox.r$ r% rH r r r __len__ r* zMailbox.__len__c C s | D ]}| | qdS )zDelete all messages.N)rL r3 r, r r r clear s z
Mailbox.clearc C s2 z| | }W n t y | Y S w | | |S )z3Delete the keyed message and return it, or default.)r2 r3 )r r- r8 resultr r r pop s
z Mailbox.popc C s& | D ]
}|| |f S td)z6Delete an arbitrary (key, message) pair and return it.zNo messages in mailbox)rI r\ r2 r, r r r popitem s zMailbox.popitemc C sp t |dr
| }n t |dr| }n|}d}|D ]\}}z|| |< W q ty/ d}Y qw |r6tddS )z4Change the messages that correspond to certain keys.rT rU FTzNo message with key(s)N)hasattrrT rU r2 )r argsourcebad_keyr- r( r r r update s
zMailbox.updatec C r" )&Write any pending changes to the disk.r$ r% rH r r r flush r* z
Mailbox.flushc C r" )Lock the mailbox.r$ r% rH r r r lock r* z Mailbox.lockc C r" )#Unlock the mailbox if it is locked.r$ r% rH r r r unlock r* zMailbox.unlockc C r" ) Flush and close the mailbox.r$ r% rH r r r close r* z
Mailbox.closec C s$ z| dW S ty tdw )Nr z?String input must be ASCII-only; use bytes or a Message instead)encode UnicodeError
ValueErrorr' r r r _string_to_bytes s
zMailbox._string_to_bytesFc C s t |tjjr?t }tj||d}|| | d |
}| dt }|
| | jr;|t s=|
t d
S d
S d
S t |tttjfrt |tjrYtdtd | }t |trc| |}|rk| dd}| dt }|
| | jr|t s|
t d
S d
S d
S t|drt|drtd td |j}d
} | }|d r|d
d
d }n
|dr|d
d d }|sn |r|drd|dd
}| dt }|
| |}q| jr|r|t s|
t d
S d
S d
S d
S t dt | )z%Dump message contents to target file.r
8Use of StringIO input is deprecated, use BytesIO instead s
From s
>From readbufferDUse of text mode files is deprecated, use a binary mode file insteadNT
From s >From Invalid message type: %s)
isinstancerA r( r ioBytesIO generatorBytesGeneratorflattenseekrr replacelinesepwrite_append_newlineendswithstrbytesStringIOwarningswarnDeprecationWarninggetvaluern r^ rs readline
startswith TypeErrortype) r r( target mangle_from_rs gendatalastlineliner r r
_dump_message sf
zMailbox._dump_messageNTr/ F)'__name__
__module__ __qualname____doc__r! r) r. r0 r3 r6 r9 r7 r: rE rC r= rI rL rQ rR rS rT rU rW rY rZ r\ r] rb rd rf rh rj rn r r classmethodr __class_getitem__r r r r r " sF
6r c @ s e Zd ZdZdZd6ddZdd Zd d
Zd d Zd
d Z dd Z
dd Z dd Z dd Z
dd Zdd Zdd Zd d Zd d Zd!d" Zd#d$ Zd%d& Zd'd( Zd)d* Zd+d, Zd-Zd.d/ Zd0d1 Zd2d3 Z d4d5 Z dS )7r z A qmail-style Maildir mailbox.:NTc C s t | ||| tj| jdtj| jdtj| jdd| _tj| jsE|r@t| jd | j D ]}t|d q6nt
| ji | _ ddd| _ d| _
d| _d S )
z Initialize a Maildir instance.tmpnewcur)r r r r )r r g?N)r r! r r joinr _pathsexistsmkdirrS r _toc _toc_mtimes
_last_read _skewfactor)r dirnamer r r r r r r! s
zMaildir.__init__c
C sf | }z| || W n ty | t|j w t| t|t r;|
}| j | }|| j kr:d}nd}d}tj
|j| j d }tj
| j||| }t|t rlt|jtj
|j| f z'z t|j| W n ttfy t|j| Y W |S w t|j W |S ty } zt|j |jtjkrt d| d}~ww )r# r r z$Name clash with existing message: %sN) _create_tmpr
BaseExceptionrj r r. name _sync_closer| r
get_subdircolonget_infor basenamesplitr r utimegetatimeget_datelinkAttributeErrorPermissionErrorrenameOSErrorerrnoEEXISTr )r r( tmp_filesubdirsuffixuniqdester r r r) $ sR
z Maildir.addc C s t t j| j| | dS r+ N)r r. r r r _lookupr, r r r r. N s zMaildir.removec C s* z| | W dS ttfy Y dS w r1 )r. r2 FileNotFoundErrorr, r r r r3 R s
zMaildir.discardc C s | |}| |}| |}t|tr|}n|}tj|}| j|v r0| j|| jd }nd}| | tj
| j |} tj
| j ||| }
t|tr]t | tj
| | f t| |
dS )r4 rx r N)r r) r| r
r r r r r r3 r r r r r r ) r r- r( old_subpathtemp_key temp_subpathdominant_subpathr r tmp_pathnew_pathr r r r6 Z s$
zMaildir.__setitem__c C s | |}ttj| j|d}| jr| |}nt|}W d n1 s(w Y tj|\}}| | | j
|v rJ| || j
d | tj
tj| j| |S )r? rbNrx )r openr r r r r r
r
set_subdirr set_infoset_dategetmtime)r r- subpathfmsgr r r r r r: u s
zMaildir.get_messagec C sP t tj| j| |d}| tdW d S 1 s!w Y dS )2Return a bytes representation or raise a KeyError.r ro N) r r r r r r rr r r r r- r r r r rC s $zMaildir.get_bytesc C s$ t tj| j| |d}t|S )rF r )r r r r r r
_ProxyFiler r r r r= s zMaildir.get_filec c sB | | jD ]}z| | W n ty Y qw |V qdS rG N)_refreshr r r2 r, r r r rI s
zMaildir.iterkeysc C | || jv S rV )r r r, r r r rW
zMaildir.__contains__c C | t| jS rX )r lenr rH r r r rY r zMaildir.__len__c C dS )"Write any pending changes to disk.Nr rH r r r rd s z
Maildir.flushc C r )re Nr rH r r r rf z Maildir.lockc C r )rg Nr rH r r r rh r zMaildir.unlockc C r ri Nr rH r r r rj r z
Maildir.closec C s\ g }t | jD ]#}t|dkr+|d dkr+t jt j| j|r+||dd q|S ) Return a list of folder names. r .N)r listdirr r r isdirr appendr r[ entryr r r list_folders s zMaildir.list_foldersc C s t tj| jd| | jddS )z/Return a Maildir instance for the named folder.r Fr r )r r r r r r r folderr r r
get_folder s zMaildir.get_folderc C s\ t j| jd| }t|| jd}t j|d}t j|s,t t |t j t j
B d |S )z>Create a folder and return a Maildir instance representing it.r r
maildirfolder ) r r r r r r r rj r O_CREATO_WRONLY)r r r r[ maildirfolder_pathr r r
add_folder s zMaildir.add_folderc C s t j| jd| }t t j|dt t j|d D ]}t|dk s,|d dkr2td| q t |D ]!}|dkrY|dkrY|dkrYt jt j||rYtd||f q8t j|d d
D ]#\}}}|D ] }t t j|| qh|D ] }t
t j|| qwqat
| d S ) -Delete the named folder, which must be empty.r r r r r z Folder contains message(s): %sr z%Folder contains subdirectory '%s': %sF)topdownN) r r r r r r r r walkr. rmdir)r r r r rootdirsfilesr r r
remove_folder s, zMaildir.remove_folderc C sX t }ttj| jdD ]}tj| jd|}|tj| dkr)t| qdS )zDelete old files in "tmp".r i@ N)timer r r r r r r. )r nowr r r r r clean s
z
Maildir.cleanr c C s t }t }d|v r|dd}d|v r |dd}dt|t|d d t tj|f }tj
| j d|}zt | W n! t
ya t jd7 _zt|W Y S ty^ Y nw Y nw td | )
z=Create a file in the tmp subdirectory and open and return it./z\057r z\072z%s.M%sP%sQ%s.%sr g .Ar z&Name clash prevented file creation: %s)r socket gethostnamer intr getpidr _countr r r statr _create_carefullyFileExistsErrorr )r r hostnamer r r r r r s0 zMaildir._create_tmpc C s t | j d| j kr/d}| jD ]}tj| j| }|| j| kr%d}|| j|< q|s/dS i | _| jD ]/}| j| }t |D ]"}tj
||}tj |rQqA| | j
d }tj
||| j|< qAq5t | _dS )z!Update table of contents mapping. FTNr )r r r r r r r r r r r r r r )r refreshr mtimer r pr r r r r s(
zMaildir._refreshc C st zt jt j| j| j| r| j| W S W n ty Y nw | z| j| W S ty9 td| dw )z=Use TOC to return subpath for given key, or raise a KeyError.No message with key: %sN)r r r r r r r2 r r, r r r r & s zMaildir._lookupc C sL t | ds
| | _ z| t| j W S ty Y dS ty% Y q
w )z0Return the next message in a one-time iteration.
_onetime_keysTN)r^ rI r next
StopIterationr2 rH r r r r 4 s
z Maildir.nextr ) r r r r r r! r) r. r3 r6 r: rC r= rI rW rY rd rf rh rj r r r r r r r r r r r r r r r s8
*
$ r c @ s e Zd ZdZd$ddZdd Zdd Zd
d Zd d
Zdd Z dd Z
dd Z dd Z dd Z
dd Zdd Zd d Zd d Zd%d d!Zd"d# ZdS )&_singlefileMailboxzA single-file mailbox.NTc
C s t | ||| zt| jd}W n7 tyG } z+|jtjkr,|r't| jd}nt| j|jtjtj fv rt|t|k r6|r1||tt n|| || d}n |sR|rL||tt n|| n
|tkrYd}nd}qtt t
||| _ t| j | _ | j | _
dS )0Generate key-to-(start, stop) table of contents.Fr Try N)r! r r/ r r r r r dict enumeratezipr r" r& )r startsstopslast_was_emptyline_posr r r r rD X s2
zmbox._generate_tocr ) r r r r rZ r r! r5 rD r r r r r F s
r c @ s2 e Zd ZdZd ddZdd Zdd Zd
d ZdS )
r zAn MMDF mailbox.NTc C r] )zInitialize an MMDF mailbox.N)r rK rI r! r r r r r! } r^ z
MMDF.__init__c C | dt dS )rA Nr_ r@ r r r r3 zMMDF._pre_message_hookc C s | td t dS )rC rj Nr_ r@ r r r r5 s zMMDF._post_message_hookc C s g g }}| j d d} |}| j }| j }|dt rM|| |}| j }| j }|dt krC||tt n |sK|| nq'n|sPnqtt t
||| _ t| j | _ | j dd | j | _
dS )ra r Trj r N)r! r r r/ r r r r rb rc rd r r" r& )r re rf next_posrh r r r r rD s8
zMMDF._generate_tocr )r r r r r! r3 r5 rD r r r r r z s
r c @ s e Zd ZdZd0ddZdd Zdd Zd
d Zd d
Zdd Z dd Z
dd Z dd Z dd Z
dd Zdd Zd d Zd d Zd d! Zd"d# Zd$d% Zd&d' Zd(d) Zd*d+ Zd,d- Zd.d/ ZdS )1r zAn MH mailbox.NTc C st t | ||| tj| js5|r0t| jd tttj | jdtj
tj B tj B d nt
| jd| _dS )zInitialize an MH instance.r
.mh_sequencesi FN)r r! r r r r r rj r r r O_EXCLr r r% r r r r r! s
z MH.__init__c C s | }t|dkr
d}nt|d }tj| jt|}t|}d}zQ| j r+t
| z7z| || W n t yN | j rBt
| t| d}t| w t|trZ| || W | j rbt
| n | j rkt
| w w W |sst| |S |s|t| w w )r# r r FT)rL r maxr r r r r r r% r( r r r+ r r. r| r _dump_sequences)r r( rL new_keyr r closedr r r r) sJ
zMH.addc
C sl t j| jt|}zt|d}W n ty* } z
|jtjkr%t d| d}~ww |
t | dS )r+ r r N) r r r r r r r r r r2 rj r. )r r- r r r r r r r. s z MH.removec
C s t j| jt|}zt|d}W n ty* } z
|jtjkr%t d| d}~ww z?| j
r3t | z't t |t j
t jB | || t|trR| || W | j
rZt| n | j
rct| w w W t| dS t| w )r4 r r N)r r r r r r r r r r2 r% r( rj r O_TRUNCr r| r rp r+ r )r r- r( r r r r r r r6 s4
zMH.__setitem__c
C s z | j rttj| jt|d}n
ttj| jt|d}W n ty9 } z
|jtj kr4t
d| d}~ww |& | j rDt | z
t |}W | j rQt
| n | j rZt
| w w W d n1 sew Y | D ]
\}}||v r}|| qp|S )r? r r r N)r% r r r r r r r r r r2 r( r r+
get_sequencesrU add_sequence)r r- r r r r key_listr r r r: s:
zMH.get_messagec
C s z | j rttj| jt|d}n
ttj| jt|d}W n ty9 } z
|jtj kr4t
d| d}~ww |) | j rDt | z|
tdW | j rTt| W d S | j rdt| w w 1 shw Y dS )r r r r Nro )r% r r r r r r r r r r2 r( rr r r r+ r r- r r r r r rC s.
z MH.get_bytesc
C sX zt tj| jt|d}W t
|S ty+ } z
|jtjkr&t d| d}~ww )rF r r N) r r r r r r r r r r2 r rw r r r r= , s z MH.get_filec C s t tdd t| jD S )rG c s s | ] }| rt|V qd S r/ )isdigitr
).0r r r r 9 s z MH.iterkeys..)iterr2 r r r rH r r r rI 7 s z MH.iterkeysc C s t jt j| jt|S r )r r r r r r r, r r r rW < s zMH.__contains__c C s t t| S r )r rK rI rH r r r rY @ z
MH.__len__c C s6 | j sttj| jdd| _t| j d| _ dS dS )re rm r TN)r% r r r r r r! r( rH r r r rf D s
zMH.lockc C s, | j rt| j t| j | `d| _ dS dS r* )r% r+ r! r rH r r r rh K s
z MH.unlockc C r )rc Nr rH r r r rd S r zMH.flushc C s | j r | dS dS r )r% rh rH r r r rj W s zMH.closec C s< g }t | jD ]}t jt j| j|r|| q|S )r )r r r r r r r r r r r r \ s
zMH.list_foldersc C s t tj| j|| jddS )z+Return an MH instance for the named folder.Fr r r r r r r r r r r r d s z
MH.get_folderc C s t tj| j|| jdS )z:Create a folder and return an MH instance representing it.r r} r r r r r i s z
MH.add_folderc C s` t j| j|}t |}|dgkr t t j|d n |g kr"ntd| j t | dS )r rm zFolder not empty: %sN)r r r r r r. r r )r r r entriesr r r r n s
zMH.remove_folderc
s i }t tj| jddddp}t| |D ]^}zM|d\}}t }| D ]$}| r7| t
| q)dd |dD \}} | t || d q) fd
d t
|D ||< t|| d krf||= W q tyv td
| w W d |S 1 sw Y |S )z=Return a name-to-key-list dictionary to define each sequence.rm rASCIIencodingr c s s | ]}t |V qd S r/ )r
)ry xr r r rz z#MH.get_sequences..-r c s g | ]}| v r|qS r r )ry r- all_keysr r
s z$MH.get_sequences..r z"Invalid sequence specification: %sN)r r r r r setrL r rx r) r
rb ranger2 r rm r rstrip)
r resultsr r r contentsrL specr; r< r r r rt z s4
zMH.get_sequencesc C s t tj| jdddd}zqtt |jtjtjB | D ]W\}}t
|dkr+q | |d d}d}t t
|D ])}|d |krN|sMd
}| d n|r\d}| d ||f n| d
| |}q<|rr| t|d q | d q W t| dS t| w )z:Set sequences using the given name-to-key-list dictionary.rm zr+r r r r NFr Tr z%s %sz %s
)r r r r r rj r r rs rU r r r2 r r r )r sequencesr r rL prev
completingr- r r r
set_sequences s2
zMH.set_sequencesc
C s8 | }d}g }| D ]`}|d |krh|||d f zttj| jt|tj| jt|d W n# t t
fyZ t tj| jt|tj| jt|d Y nw t tj| jt| |d7 }q |d | _
t|dkrzdS | D ]\}}|D ]\}}||v r||||< qq~| | dS )z?Re-name messages to eliminate numbering gaps. Invalidates keys.r r N)rt rI r r r r r r r r r r unlinkr" r rU indexr ) r r r changesr- r rv oldr r r r pack s6
zMH.packc C st | }| }| D ]\}}||v r|| q ||v r$|||= q |D ] }||vr2|g||< q'| | dS )z;Inspect a new MHMessage and update sequences appropriately.N)rt rU r r r )r r( r- pending_sequences
all_sequencesr rv sequencer r r rp s
zMH._dump_sequencesr )r r r r r! r) r. r6 r: rC r= rI rW rY rf rh rd rj r r r r rt r r rp r r r r r s0
" r c @ s e Zd ZdZeh dZd ddZdd Zd d
Zd d Z d
d Z
dd Z dd Z dd Z
dd Zdd Zdd Zdd Zd d ZdS ) r z An Rmail-style Babyl mailbox.> filededitedresentunseendeletedanswered forwardedNTc C s t | ||| i | _dS )zInitialize a Babyl mailbox.N)r r! _labelsr r r r r! s
zBabyl.__init__c C s( t | |}t|tr| | j|< |S )r# )r r) r| r
get_labelsr )r r( r- r r r r) s
z Babyl.addc C s& t | | || jv r| j|= dS dS r )r r. r r, r r r r. s
z Babyl.removec C s. t | || t|tr| | j|< dS dS )r4 N)r r6 r| r
r r r5 r r r r6 s
zBabyl.__setitem__c
C s | |\}}| j| | j t } | j }|dt ks$|s%n
||td qt } | j }|tks?|s@n
||td q4|| j }|dksWJ | j
|}|td}t | | } |
| || jv r| | j| | S )r? T *** EOOH ***ro r )r r! r r r} r~ r r r r/ rr r
r set_visibler
set_labels)
r r- r; r< original_headersr visible_headersnbodyr r r r r: s4
zBabyl.get_messagec C s | |\}}| j| | j t } | j }|dt ks$|s%n
||td q | j }|tks;|s.r N , r )r! r r r/ r r r r rb rc rd r r r" r& )r re rf rl label_listsrh r r r r r rD 5 s:
zBabyl._generate_tocc C sV dt }|dt 7 }| }dd |D }|dd| t 7 }|d7 }|| dS ) r? s BABYL OPTIONS:s
Version: 5c s s | ]}| V qd S r/ )rk r r r r rz X r z*Babyl._pre_mailbox_hook..s Labels:r r N)r r r r )r r babylr r r r r1 S s zBabyl._pre_mailbox_hookc C ri )rA Nr_ r@ r r r r3 ] rk zBabyl._pre_message_hookc C s | td dS )rC r Nr_ r@ r r r r5 a rk zBabyl._post_message_hookc C s` | j }t|trXg }g }| D ]}|| jv r || q|| q| j d |D ] }| j d| q-| j d |D ]}| j d| d qB| j t n| j dt t|t
j j rt
}t
j|dd}|| |d | }| j |d
t |d
ks|snq~| j d t t|trt
} t
j| dd}
|
| | }| j |d
t |d
ks|snqn |d | }| j |d
t |d
ks|snq |d } | sn | j | d
t qn)t|ttt
jfr{t|t
jrtd
t d | }t|tr%| |}| dd } | d dkrf| j |d| d
t | j d t | j |d| d
t | j || d d
t n| j d t t | j |d
t nt |dr t |drtdt d |j!}| }
d } | }|"dr|dd d
}n|"dr|dd d
}| j |d
t |d
ks|s|rd}| j d t ||
nnq | }|sn4|"dr|dd t }n |"dr|dd t }n|"d
r|dd t }| j | qnt#dt$| | j }||fS )z0Write message contents and return (start, stop). 1s , s ,, r s 1,,Fr Tro r r, rp rq s
r rx Nr rs rt ru rv rw r{ )%r! r/ r| r
r r r r rk r rA r( r r} r~ r r r r r r get_visiblerr r r r r r r r rn rT r^ rs r r r )r r( r; special_labelsr r orig_bufferorig_generatorr
vis_buffer
vis_generatorrs
body_start original_pos
first_passr< r r r rE e s
zBabyl._install_messager )r r r r frozensetr r! r) r. r6 r: rC r= r rD r1 r3 r5 rE r r r r r s
r c @ s* e Zd ZdZd ddZdd Zdd ZdS )
r z0Message with mailbox-format-specific properties.Nc C s t |tjjr | t| t |tr|| dS dS t |tr,| t | dS t |t
r;| t | dS t |t j
rK| t| dS t|drZ| t| dS |du rgtjj| dS tdt| )z Initialize a Message instance.rr Nr{ )r| rA r( r _become_messagecopydeepcopy _explain_tor rB r message_from_stringr}
TextIOWrappermessage_from_filer^ message_from_binary_filer! r r r' r r r r! s
zMessage.__init__c C s4 t |dg }|jD ]}||vr|j| | j|< q dS )z0Assume the non-format-specific state of message._type_specific_attributesN)getattr__dict__)r r(
type_specificr r r r r s
zMessage._become_messagec C s t |trdS td)z:Copy format-specific state to message insofar as possible.Nz Cannot convert to specified type)r| r r r' r r r r s
zMessage._explain_tor/ )r r r r r! r r r r r r r s
r c @ sz e Zd ZdZg dZd ddZdd Zdd Zd
d Zd d
Z dd Z
dd Z dd Z dd Z
dd Zdd Zdd ZdS ) r
z)Message with Maildir-specific properties.)_subdir_info_dateNc C s& d| _ d| _t | _t| | dS )z%Initialize a MaildirMessage instance.r r N)r r r r r r! r' r r r r! s
zMaildirMessage.__init__c C | j S )zReturn 'new' or 'cur'.)r rH r r r r zMaildirMessage.get_subdirc C s& |dks|dkr
|| _ dS td| )z Set subdir to 'new' or 'cur'.r r z!subdir must be 'new' or 'cur': %sN)r rm )r r r r r r s
zMaildirMessage.set_subdirc C s | j dr
| j dd S dS )*Return as a string the flags that are set.2,r Nr )r r rH r r r get_flags
s zMaildirMessage.get_flagsc C s dd t| | _dS ))Set the given flags and unset all others.r r N)r r2 r )r flagsr r r set_flags r zMaildirMessage.set_flagsc C $ | dt| t|B dS z.Set the given flag(s) without changing others.r Nr r r r r flagr r r add_flag $zMaildirMessage.add_flagc C s0 | r| dt| t| dS dS )7Unset the given string flag(s) without changing others.r N)r r r r r r r r remove_flag s $zMaildirMessage.remove_flagc C r )zSet "From " line, formatting and appending time_ if specified.NT )r rY rX r )r rR time_r r r rL u s
z_mboxMMDFMessage.set_fromc C s | dd| dd S )r Statusr X-Status)r9 rH r r r r } r z_mboxMMDFMessage.get_flagsc C s t |}d\}}dD ]}||v r||7 }|| q
dD ]}||v r+||7 }|| q |dt|7 }z| d| W n tyL | d| Y nw z | d| W dS tyf | d| Y dS w )r )r r )r r )r r r r r r N)r r. r r2 replace_headerr2
add_header)r r status_flags
xstatus_flagsr r r r r s.
z_mboxMMDFMessage.set_flagsc C r r r r r r r r r z_mboxMMDFMessage.add_flagc C s8 d| v sd| v r| dt| t| dS dS )r r r r Nr r r r r r s $z _mboxMMDFMessage.remove_flagc C s t |trgt| }d|v r|d d|v r |d d|v r&|d d|v r/|d d|v r8|d |d = |d
= d | d d
}z| t
t
|d W d
S ttfyf Y d
S w t |tr||| || d
S t |trt| }d|vr|d d|v r|d d|v r|d |d = |d
= d
S t |trt| }d|vr|d d|v r|d d|v r|d |d = |d
= d
S t |trd
S tdt| )zACopy mbox- or MMDF-specific state to message insofar as possible.r r r r r r r r statuszx-statusr Nz%a %b %d %H:%M:%S %Yr r r r r r )r| r
r r r r r rV r r calendartimegmr strptimerm
OverflowErrorrU r rL r ru r
r r r r )r r( r
maybe_dater r r r sd
z _mboxMMDFMessage._explain_tor/ )
r r r r r r! rV rL r r r r r r r r r rU c s
rU c @ e Zd ZdZdS )r z&Message with mbox-specific properties.Nr r r r r r r r r r c @ sH e Zd ZdZdgZdddZdd Zdd Zd
d Zd d
Z dd Z
dS )r z$Message with MH-specific properties.
_sequencesNc C s g | _ t| | dS )z!Initialize an MHMessage instance.N)r r r! r' r r r r! s zMHMessage.__init__c C | j dd S )z4Return a list of sequences that include the message.N)r rH r r r rt r` zMHMessage.get_sequencesc C t || _dS )z3Set the list of sequences that include the message.N)rK r )r r r r r r r` zMHMessage.set_sequencesc C 8 t |tr|| jvr| j| dS dS tdt| )z8Add sequence to list of sequences including the message.z sequence type must be str: %sN)r| r r r r r r r r r r ru
zMHMessage.add_sequencec C ( z | j | W dS ty Y dS w )zARemove sequence from the list of sequences including the message.N)r r. rm r
r r r remove_sequence
zMHMessage.remove_sequencec C sP t |tr5t| }d|v r|d n
|d |d d|v r(|d d|v r3|d d
S d
S t |tret| }d|vrJ|d n|d d|v rX|d d|v rc|d
d
S d
S t |trx| D ]}|| qnd
S t |t rt| }d|v r|
d d|v r|
d d
S d
S t |t rd
S t d t
| )z6Copy MH-specific state to message insofar as possible.r r r r r r r ROr r r r N)r| r
r rt r r rU r ru r
r r r r )r r( r r r r r r sJ
zMHMessage._explain_tor/ ) r r r r r r! rt r ru r r r r r r r s
r c @ sb e Zd ZdZddgZdddZdd Zd d
Zd d Zd
d Z dd Z
dd Z dd Z dd Z
dS )r
z'Message with Babyl-specific properties.r _visibleNc C s g | _ t | _t| | dS )z#Initialize a BabylMessage instance.N)r r r r! r' r r r r! % s zBabylMessage.__init__c C r
)z'Return a list of labels on the message.N)r rH r r r r + r` zBabylMessage.get_labelsc C r )z&Set the list of labels on the message.N)rK r )r r r r r r / r` zBabylMessage.set_labelsc C r )z+Add label to list of labels on the message.zlabel must be a string: %sN)r| r r r r r r r r r r r 3 r zBabylMessage.add_labelc C r )z4Remove label from the list of labels on the message.N)r r. rm r r r r remove_label; r zBabylMessage.remove_labelc C s
t | jS )z3Return a Message representation of visible headers.r r rH r r r r B s
zBabylMessage.get_visiblec C r )z2Set the Message representation of visible headers.Nr )r visibler r r r F r` zBabylMessage.set_visiblec C sb | j D ]}|| v r| j || | q| j |= qdD ]}|| v r.|| j vr.| | | j |< q dS )z9Update and/or sensibly generate a set of visible headers.)DateFromzReply-ToToCCSubjectN)r rL r )r headerr r r update_visibleJ s
zBabylMessage.update_visiblec C sx t |trBt| }d|v r|d n
|d |d d|v s'd|v r,|d d|v r5|d d |v r@|d
dS dS t |trrt| }d|vrW|d n|d d |v re|d
d|v rp|d dS dS t |trt| }d|v r|d d|v r|d dS dS t |t r|
| | D ]}| | qdS t |t
rdS tdt| )z9Copy Babyl-specific state to message insofar as possible.r r r r r r r r r r r r r r r r N)r| r
r r r r rU r ru r
r r r r r r )r r( r r r r r r U sP
zBabylMessage._explain_tor/ )r r r r r r! r r r r r r r r r r r r r
s
r
c @ r )r z&Message with MMDF-specific properties.Nr r r r r r r r c @ s e Zd ZdZd&ddZd&ddZd&ddZd&d d
Zd&d d Zd
d Z dd Z
d'ddZ dd Z dd Z
dd Zdd Zd d Zd d Zd d! Zd"d# Zed$d% ZeeZdS )(r z A read-only wrapper of a file.Nc C s& || _ |du r| | _dS || _dS )zInitialize a _ProxyFile.N)r! r/ _pos)r r posr r r r! s
z_ProxyFile.__init__c C | || jjS z Read bytes.)_readr! rr r sizer r r rr r| z_ProxyFile.readc C r! r" )r# r! read1r$ r r r r& r| z_ProxyFile.read1c C r! )z Read a line.)r# r! r r$ r r r r r| z_ProxyFile.readlinec C s> g }| D ]}| | |dur |t|8 }|dkr |S q|S )zRead multiple lines.Nr )r r )r sizehintr[ r r r r readlines s
z_ProxyFile.readlinesc c s | }|s
dS |V q)zIterate over lines.TN)r )r r r r r rR s z_ProxyFile.__iter__c C r )zReturn the position.)r rH r r r r/ r z_ProxyFile.tellr c C s4 |dkr | j | j | j || | j | _dS )zChange position.r Nr! r r r/ r offsetwhencer r r r s z_ProxyFile.seekc C s@ t | dr zt | jdr| j W | `dS W | `dS | `w dS )zClose the file.r! rj N)r^ r! rj rH r r r rj s
z_ProxyFile.closec C s2 |du rd}| j | j ||}| j | _|S )z"Read size bytes using read_method.Nrx r) )r r% read_methodr[ r r r r# s z_ProxyFile._readc C s | S )z$Context management protocol support.r rH r r r __enter__ r z_ProxyFile.__enter__c G s | d S r/ )rj )r excr r r __exit__ s z_ProxyFile.__exit__c C
| j S r/ )r! readablerH r r r r2
z_ProxyFile.readablec C r1 r/ )r! writablerH r r r r4 r3 z_ProxyFile.writablec C r1 r/ )r! seekablerH r r r r5 r3 z_ProxyFile.seekablec C r1 r/ )r! rd rH r r r rd r3 z_ProxyFile.flushc C s& t | dsdS t | jdsdS | jjS )Nr! Trr F)r^ r! rr rH r r r rr s
z_ProxyFile.closedr/ r )r r r r r! rr r& r r( rR r/ r rj r# r. r0 r2 r4 r5 rd propertyrr r r r r r r r r s*
r c @ s< e Zd ZdZdddZdd Zddd Zd
d Zd d
ZdS )rS z&A read-only wrapper of part of a file.Nc C s t | || || _|| _dS )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 S )z*Return the position with respect to start.)r r/ r8 rH r r r r/ r| z_PartialFile.tellr c C s< |dkr | j | _d}n
|dkr| j| _d}t| || dS )z8Change position, possibly with respect to start or stop.r r r N)r8 r r9 r r r* r r r r s z_PartialFile.seekc C sB | j | j }|dkr dS |du s|dk s||kr|}t| ||S )z;Read size bytes using read_method, honoring start and stop.r rJ N)r9 r r r# )r r% r- remainingr r r r# s z_PartialFile._readc C s t | dr | `d S d S )Nr! )r^ r! rH r r r rj s
z_PartialFile.close)NNr6 ) r r r r r! r/ r r# rj r r r r rS s
rS Tc
C s d}zt r1z t | t jt jB W n ty0 } z|jtjtjtjfv r+t d| j
d}~ww |rz
t | j
d }| W n ty^ } z|jtjtjfv rYW Y d}~W dS d}~ww z4zt
|j
| j
d d}W n ttfy t
|j
| j
d d}Y n w t
|j
W W dS W W dS ty t
|j
t d| j
w W dS t rt | t j |rt
| j
d )z(Lock file f using lockf and dot locking.Fzlockf: lock unavailable: %sN.lockTzdot lock unavailable: %s)fcntllockfLOCK_EXLOCK_NBr r EAGAINr r r r r0 rj r r r r r r r r. LOCK_UN)r r- dotlock_doner pre_lockr r r r( s\ r( c C s< t r t | t j tj| jd r t| jd dS dS )z*Unlock file f using lockf and dot locking.r; N)r< r= rA r r r r r. r r r r r+ 9 s
r+ c C s@ t | t jt jB t jB d}z t| dW t | S t | w )zCCreate a file if it doesn't exist and open for reading and writing.r r )r r r rn O_RDWRrj )r fdr r r r @ s
r c C s$ t d| tt t t 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 r0 H s r0 c C s( | ttdrt| dS dS )z0Ensure changes to file f are physically on disk.fsyncN)rd r^ r rG filenorD r r r r. N s
r. c C s t | | dS )z:Close file f, ensuring all changes are physically on disk.N)r. rj rD r r r r T s r c @ r )r z"Raised for module-specific errors.Nr r r r r r Z r r c @ r )r z:The specified mailbox does not exist and won't be created.Nr r r r r r ] r r c @ r )r z>The specified mailbox is not empty and deletion was requested.Nr r r r r r ` r r c @ r )r z)Another process caused an action to fail.Nr r r r r r c r r c @ r )r z)A file appears to have an invalid format.Nr r r r r r f r r )T)2r r r r r r r r rA
email.messageemail.generatorr} r; typesr r< ImportError__all__r rk r r r rI r r r r r( r r
rU r r r
r r rS r( r+ r r0 r. r Exceptionr r r r r r r r r sp j 8 DB4- 3 z%mqH_e
'*