File: //usr/lib/python3.7/__pycache__/mailbox.cpython-37.pyc
B
îÇ{a>3 ã @ sR d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Zddl
Zddl Z ddl Z y ddl
Z
W n ek
rˆ dZ
Y nX ddddddd d
d d d
ddddddgZej d¡ZG dd„ dƒZG dd„ deƒZG dd„ deƒZG dd„ deƒZG dd„ deƒZG d d„ deƒZG d d„ deƒZG d d„ deƒZG d d „ d ejjƒZG 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
eƒZ G d&d„ de ƒZ!G d'd(„ d(ƒZ"G d)d*„ d*e"ƒZ#d=d,d-„Z$d.d/„ Z%d0d1„ Z&d2d3„ Z'd4d5„ Z(d6d7„ Z)G d8d„ de*ƒZ+G d9d„ de+ƒZ,G d:d„ de+ƒZ-G d;d„ de+ƒZ.G d<d„ de+ƒZ/dS )>zDRead/write support for Maildir, mbox, MH, Babyl, and MMDF mailboxes.é NÚMailboxÚMaildirÚmboxÚMHÚBabylÚMMDFÚMessageÚMaildirMessageÚ mboxMessageÚ MHMessageÚ BabylMessageÚ MMDFMessageÚErrorÚNoSuchMailboxErrorÚ
NotEmptyErrorÚExternalClashErrorÚ FormatErrorÚasciic @ s e Zd ZdZdCdd„Zdd„ Zdd „ Zd
d „ Zd d
„ Zdd„ Z dDdd„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/„ ZdEd0d1„Zd2d3„ ZdFd4d5„Z d6d7„ Z d8d9„ Z d:d;„ Z d<d=„ Z d>d?„ Z!d@Z"dGdAdB„Z#dS )Hr z*A group of messages in a particular place.NTc C s t j t j |¡¡| _|| _dS )z Initialize a Mailbox instance.N)ÚosÚpathÚabspathÚ
expanduserÚ_pathÚ_factory)Úselfr ÚfactoryÚcreate© r ú /usr/lib/python3.7/mailbox.pyÚ__init__$ s zMailbox.__init__c C s t dƒ‚dS )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ƒ‚dS )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 | |¡ d S )N)r$ )r r# r r r Ú __delitem__1 s zMailbox.__delitem__c C s( y| |¡ W n tk
r" Y nX dS )z'If the keyed message exists, remove it.N)r$ ÚKeyError)r r# r r r Údiscard4 s zMailbox.discardc C s t dƒ‚dS )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
| |¡S tk
r |S X dS )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 s6 | j s| |¡S t | |¡¡ }| |¡S Q R X dS )z=Return the keyed message; raise KeyError if it doesn't exist.N)r Ú get_messageÚ
contextlibÚclosingÚget_file)r r# Úfiler r r r) F s
zMailbox.__getitem__c C s t dƒ‚dS )z4Return a Message representation or raise a KeyError.z&Method must be implemented by subclassN)r )r r# r r r r, N s zMailbox.get_messagec C s t | |¡¡ ¡ S )zœReturn a string representation or raise a KeyError.
Uses email.message.Message to create a 7bit clean string
representation of the message.)ÚemailÚmessage_from_bytesÚ get_bytesÚ as_string)r r# r r r Ú
get_stringR s zMailbox.get_stringc C s t dƒ‚dS )z8Return a byte string representation or raise a KeyError.z&Method must be implemented by subclassN)r )r r# r r r r3 Y s zMailbox.get_bytesc C s t dƒ‚dS )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ƒ‚dS )z Return an iterator over keys.z&Method must be implemented by subclassN)r )r r r r Úiterkeysa s zMailbox.iterkeysc C s t | ¡ ƒS )zReturn a list of keys.)Úlistr6 )r r r r Úkeyse s z Mailbox.keysc c s@ x:| ¡ D ].}y | | }W n tk
r0 w
Y nX |V q
W dS )z%Return an iterator over all messages.N)r6 r& )r r# Úvaluer r r Ú
itervaluesi s zMailbox.itervaluesc C s | ¡ S )N)r: )r r r r Ú__iter__r s zMailbox.__iter__c C s t | ¡ ƒS )z,Return a list of messages. Memory intensive.)r7 r: )r r r r Úvaluesu s zMailbox.valuesc c sD x>| ¡ D ]2}y | | }W n tk
r0 w
Y nX ||fV q
W dS )z.Return an iterator over (key, message) tuples.N)r6 r& )r r# r9 r r r Ú iteritemsy s zMailbox.iteritemsc C s t | ¡ ƒS )z9Return a list of (key, message) tuples. Memory intensive.)r7 r= )r r r r Úitems‚ s z
Mailbox.itemsc C s t dƒ‚dS )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ƒ‚dS )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| ¡ D ]}| |¡ q
W dS )zDelete all messages.N)r8 r' )r r# r r r ÚclearŽ s z
Mailbox.clearc C s0 y | | }W n t k
r |S X | |¡ |S )z3Delete the keyed message and return it, or default.)r& r' )r r# r* Úresultr r r Úpop“ s
z Mailbox.popc C s* x$| ¡ D ]}|| |¡fS W tdƒ‚dS )z6Delete an arbitrary (key, message) pair and return it.zNo messages in mailboxN)r6 rC r& )r r# r r r Úpopitemœ s zMailbox.popitemc C sx t |dƒr| ¡ }nt |dƒr(| ¡ }n|}d}x6|D ].\}}y || |< W q6 tk
rb d}Y q6X q6W |rttdƒ‚dS )z4Change the messages that correspond to certain keys.r= r> FTzNo message with key(s)N)Úhasattrr= r> r& )r ÚargÚsourceZbad_keyr# r! r r r Úupdate£ s
zMailbox.updatec C s t dƒ‚dS )z&Write any pending changes to the disk.z&Method must be implemented by subclassN)r )r r r r Úflush´ s z
Mailbox.flushc C s t dƒ‚dS )zLock the mailbox.z&Method must be implemented by subclassN)r )r r r r Úlock¸ s z Mailbox.lockc C s t dƒ‚dS )z#Unlock the mailbox if it is locked.z&Method must be implemented by subclassN)r )r r r r Úunlock¼ s zMailbox.unlockc C s t dƒ‚dS )z Flush and close the mailbox.z&Method must be implemented by subclassN)r )r r r r ÚcloseÀ s z
Mailbox.closec C s, y
| d¡S tk
r& tdƒ‚Y nX d S )Nr z?String input must be ASCII-only; use bytes or a Message instead)ÚencodeÚ UnicodeErrorÚ
ValueError)r r! r r r Ú_string_to_bytesÄ s
zMailbox._string_to_bytesFc C sþ t |tjjƒrvt ¡ }tj ||d¡}| |¡ | d¡ |
¡ }| dt ¡}|
|¡ | jrr| t ¡sr|
t ¡ n„t |tttjfƒrt |tjƒr¬t dtd¡ | ¡ }t |tƒrÀ| |¡}|rÐ| dd¡}| dt ¡}|
|¡ | jrú| t ¡sú|
t ¡ nôt|dƒrêt|dƒr2t d td¡ |j}d
}xŒ| ¡ }| d ¡r^|d
d … d }n | d
¡rz|d
d… d }|s‚P |r¤| d¡r¤d|dd
… }| dt ¡}|
|¡ |}q8W | jrú|rú| t ¡sú|
t ¡ nt dt |ƒ ƒ‚d
S )z%Dump message contents to target file.r ó
z8Use of StringIO input is deprecated, use BytesIO insteadé s
From s
>From ÚreadÚbufferzDUse of text mode files is deprecated, use a binary mode file insteadNs
éþÿÿÿó
éÿÿÿÿs From s >From é zInvalid message type: %s) Ú
isinstancer1 r! r ÚioÚBytesIOÚ generatorÚBytesGeneratorÚflattenÚseekrS ÚreplaceÚlinesepÚwriteÚ_append_newlineÚendswithÚstrÚbytesÚStringIOÚwarningsÚwarnÚDeprecationWarningÚgetvaluerP rE rT ÚreadlineÚ
startswithÚ TypeErrorÚtype) r r! ÚtargetZ mangle_from_rT ÚgenÚdataZlastlineÚliner r r Ú
_dump_messageÑ sZ
zMailbox._dump_message)NT)N)N)N)F)$Ú__name__Ú
__module__Ú __qualname__Ú__doc__r r" r$ r% r' r( r+ r) r, r5 r3 r/ r6 r8 r: r; r< r= r> r? r@ rA rC rD rH rI rJ rK rL rP rc rt r r r r r ! sB
c @ sÚ e Zd ZdZdZd6dd„Zdd„ 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 | jd¡tj | jd¡tj | jd¡dœ| _tj | j¡sŽ|r„t | jd¡ x*| j ¡ D ]}t |d¡ qnW n
t
| jƒ‚i | _ dddœ| _ d| _
d| _d S )
z Initialize a Maildir instance.ÚtmpÚnewÚcur)rz r{ r| iÀ r )r| r{ gš™™™™™¹?N)r r r r Újoinr Ú_pathsÚexistsÚmkdirr< r Ú_tocÚ _toc_mtimesÚ
_last_readÚ _skewfactor)r Údirnamer r r r r r r
s
zMaildir.__init__c
C s~ | ¡ }y| ||¡ W n* tk
rB | ¡ t |j¡ ‚ Y nX t|ƒ t|t ƒr||
¡ }| j | ¡ }|| j kr„d}nd}d}tj
|j¡ | j ¡d }tj
| j||| ¡}t|t ƒrÞt |jtj
|j¡| ¡ f¡ yLyt |j|¡ W n( ttfk
r t |j|¡ Y nX t |j¡ W nN tk
rx } z.t |j¡ |jtjkrft d| ƒ‚n‚ W dd}~X Y nX |S )z$Add message and return assigned key.Ú r{ r z$Name clash with existing message: %sN) Ú _create_tmprt Ú
BaseExceptionrL r r$ ÚnameÚ _sync_closerY r Ú
get_subdirÚcolonÚget_infor ÚbasenameÚsplitr} r ÚutimeÚgetatimeÚget_dateÚlinkÚAttributeErrorÚPermissionErrorÚrenameÚOSErrorÚerrnoZEEXISTr )r r! Ztmp_fileÚsubdirÚsuffixÚuniqÚdestÚer r r r" ! sB
z Maildir.addc C s t t j | j| |¡¡¡ dS )z=Remove the keyed message; raise KeyError if it doesn't exist.N)r r$ r r} r Ú_lookup)r r# r r r r$ K s zMaildir.removec C s, y| |¡ W n ttfk
r& Y nX dS )z'If the keyed message exists, remove it.N)r$ r& ÚFileNotFoundError)r r# r r r r' O s zMaildir.discardc C sÊ | |¡}| |¡}| |¡}t|tƒr.|}n|}tj |¡}| j|kr`| j| | j¡d }nd}| |¡ tj
| j |¡} tj
| j ||| ¡}
t|tƒrºt | tj
| ¡| ¡ f¡ t | |
¡ dS )z>Replace the keyed message; raise KeyError if it doesn't exist.rW r† N)rž r" rY r r r r… rŒ r r' r} r r r‘ r’ r– ) r r# r! Z old_subpathZtemp_keyZ temp_subpathZdominant_subpathr™ rš Ztmp_pathÚnew_pathr r r r( W s"
zMaildir.__setitem__c C s¢ | |¡}ttj | j|¡dƒ }| jr4| |¡}nt|ƒ}W dQ R X tj |¡\}}| |¡ | j
|kr€| | | j
¡d ¡ | tj
tj | j|¡¡¡ |S )z4Return a Message representation or raise a KeyError.ÚrbNrW )rž Úopenr r r} r r r r Ú
set_subdirrŒ Úset_infoÚset_dateÚgetmtime)r r# ZsubpathÚfÚmsgr™ r‰ r r r r, r s
zMaildir.get_messagec C s8 t tj | j| |¡¡dƒ}| ¡ td¡S Q R X dS )z2Return a bytes representation or raise a KeyError.r¡ rQ N) r¢ r r r} r rž rS r` ra )r r# r§ r r r r3 s zMaildir.get_bytesc C s$ t tj | j| |¡¡dƒ}t|ƒS )z6Return a file-like representation or raise a KeyError.r¡ )r¢ r r r} r rž Ú
_ProxyFile)r r# r§ r r r r/ † s zMaildir.get_filec c sH | ¡ x:| jD ]0}y| |¡ W n tk
r8 wY nX |V qW dS )z Return an iterator over keys.N)Ú_refreshr rž r& )r r# r r r r6 ‹ s zMaildir.iterkeysc C s | ¡ || jkS )z9Return True if the keyed message exists, False otherwise.)rª r )r r# r r r r? • s zMaildir.__contains__c C s | ¡ 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 dS )z"Write any pending changes to disk.Nr )r r r r rI Ÿ s z
Maildir.flushc C s dS )zLock the mailbox.Nr )r r r r rJ ¥ s z Maildir.lockc C s dS )z#Unlock the mailbox if it is locked.Nr )r r r r rK © s zMaildir.unlockc C s dS )z Flush and close the mailbox.Nr )r r r r rL s z
Maildir.closec C s` g }xVt | j¡D ]F}t|ƒdkr|d dkrt j t j | j|¡¡r| |dd… ¡ qW |S )z Return a list of folder names.é r Ú.N)r Úlistdirr r« r Úisdirr} Úappend)r rB Ú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 F)r 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 |¡sXt t |t j t j
B d¡¡ |S )z>Create a folder and return a Maildir instance representing it.r )r Z
maildirfolderi¶ ) r r r} r r r r rL r¢ ÚO_CREATÚO_WRONLY)r r³ r rB Zmaildirfolder_pathr r r Ú
add_folderÀ s zMaildir.add_folderc C s, t j | jd| ¡}xTt t j |d¡¡t t j |d¡¡ D ](}t|ƒdk sZ|d dkr>td| ƒ‚q>W xPt |¡D ]B}|dkrv|dkrv|dkrvt j t j ||¡¡rvtd||f ƒ‚qvW x`t j|d d
D ]N\}}}x |D ]}t t j ||¡¡ qÜW x |D ]}t
t j ||¡¡ qþW qÌW t
|¡ d S ) z-Delete the named folder, which must be empty.r r{ r| r¬ r z Folder contains message(s): %srz z%Folder contains subdirectory '%s': %sF)ÚtopdownN) r r r} r r® r« r r¯ Úwalkr$ Úrmdir)r r³ r r± ÚrootÚdirsZfilesr r r Ú
remove_folderÊ s
zMaildir.remove_folderc C s\ t ¡ }xNt tj | jd¡¡D ]4}tj | jd|¡}|tj |¡ dkr t |¡ q W dS )zDelete old files in "tmp".rz 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|kr$| dd¡}d|kr8| dd¡}dt|ƒt|d d ƒt ¡ tj|f }tj
| j d|¡}yt |¡ W n@ t
k
rÀ t jd7 _yt|ƒS tk
rº Y nX Y nX td | ƒ‚d
S ) z=Create a file in the tmp subdirectory and open and return it.ú/z\057ry z\072z%s.M%sP%sQ%s.%sr¬ g €„.Arz z&Name clash prevented file creation: %sN)r¾ ÚsocketÚ gethostnamer` Úintr Úgetpidr Ú_countr r} r ÚstatrŸ Ú_create_carefullyÚFileExistsErrorr )r r¿ Zhostnamer› r r r r r‡ ç s& zMaildir._create_tmpc C sä t ¡ | j d| j krbd}x<| jD ]2}tj | j| ¡}|| j| krLd}|| j|< q$W |sbdS i | _xl| jD ]b}| j| }xRt |¡D ]D}tj
||¡}tj |¡rªqŠ| | j
¡d }tj
||¡| j|< qŠW qpW t ¡ | _dS )z!Update table of contents mapping.é FTNr )r¾ rƒ r„ r‚ r r r¦ r~ r r® r} r¯ r rŒ )r Zrefreshr™ Úmtimer r± Úpr› r r r rª ÿ s&
zMaildir._refreshc C s| y,t j t j | j| j| ¡¡r*| j| S W n tk
r@ Y nX | ¡ y
| j| S tk
rv td| ƒd‚Y nX dS )z=Use TOC to return subpath for given key, or raise a KeyError.zNo message with key: %sN)r r r r} r r r& rª )r r# r r r rž # s
zMaildir._lookupc C sV t | dƒs| ¡ | _x<y| t| jƒ S tk
r8 dS tk
rL wY qX qW dS )z0Return the next message in a one-time iteration.Ú
_onetime_keysN)rE r6 rÍ ÚnextÚ
StopIterationr& )r r r r rÎ 1 s
z Maildir.next)NT) ru rv rw rx rŒ r r" r$ r' r( r, r3 r/ r6 r? r@ rI rJ rK rL r² r´ r· r½ rÀ rÆ r‡ rª rž rÎ r r r r r s6
*
$c @ s” e Zd ZdZd$dd„Zdd„ 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 | |||¡ yt| jdƒ}W nn tk
rŽ } zP|jtjkr\|rPt| jdƒ}q~t| jƒ‚n"|jtjtj fkr|t| jdƒ}n‚ W dd}~X Y nX || _
d| _ d| _ d| _
d| _d| _d| _dS )z!Initialize a single-file mailbox.zrb+zwb+r¡ Nr F)r r r¢ r r— r˜ ÚENOENTr ÚEACCESÚEROFSÚ_filer Ú _next_keyÚ_pendingÚ
_pending_syncÚ_lockedÚ _file_length)r r r r r§ r r r r r A s$ z_singlefileMailbox.__init__c C s8 | ¡ | |¡| j| j< | jd7 _d| _| jd S )z$Add message and return assigned key.r¬ T)rž Ú_append_messager rÕ r× )r r! r r r r" X s
z_singlefileMailbox.addc C s | |¡ | j|= d| _dS )z=Remove the keyed message; raise KeyError if it doesn't exist.TN)rž r rÖ )r r# r r r r$ b s
z_singlefileMailbox.removec C s$ | |¡ | |¡| j|< d| _dS )z>Replace the keyed message; raise KeyError if it doesn't exist.TN)rž rÚ r rÖ )r r# r! r r r r( h s
z _singlefileMailbox.__setitem__c c s | ¡ | j ¡ E dH dS )z Return an iterator over keys.N)rž r r8 )r r r r r6 n s z_singlefileMailbox.iterkeysc C s | ¡ || jkS )z9Return True if the keyed message exists, False otherwise.)rž r )r r# r r r r? s s z _singlefileMailbox.__contains__c C s | ¡ t| jƒS )z*Return a count of messages in the mailbox.)rž r« r )r r r r r@ x s z_singlefileMailbox.__len__c C s | j st| jƒ d| _ dS )zLock the mailbox.TN)rØ Ú
_lock_filerÔ )r r r r rJ } s
z_singlefileMailbox.lockc C s | j rt| jƒ d| _ dS )z#Unlock the mailbox if it is locked.FN)rØ Ú _unlock_filerÔ )r r r r rK ƒ s
z_singlefileMailbox.unlockc
C sì | j s | jr t| jƒ d| _dS | jdk s.t‚| j dd¡ | j ¡ }|| jkrbt d| j|f ƒ‚t
| j ƒ}y¬i }| |¡ xŽt
| j ¡ ƒD ]|}| j| \}}| j |¡ | |¡ | ¡ }x0| j td|| j ¡ ƒ¡}|sàP | |¡ q¾W || ¡ f||< | |¡ qŒW | ¡ | _W n" | ¡ t |j¡ ‚ Y nX t|ƒ | j ¡ t | j ¡j} t |j| ¡ yt |j| j ¡ W n2 t k
r° t | j ¡ t |j| j ¡ Y nX t | j dƒ| _|| _d| _ d| _| j rèt | jdd dS ) z"Write any pending changes to disk.FNr rÊ z4Size of mailbox file changed (expected %i, found %i)i zrb+)Údotlock)!rÖ r× Ú _sync_flushrÔ r ÚAssertionErrorr_ ÚtellrÙ r Ú_create_temporaryr Ú_pre_mailbox_hookÚsortedr8 Ú_pre_message_hookrS Úminrb Ú_post_message_hookrL r r$ r‰ rŠ rÇ Úst_modeÚchmodr– rÉ r¢ rØ rÛ )
r Zcur_lenZnew_fileZnew_tocr# ÚstartÚstopZ new_startrT Úmoder r r rI ‰ s`
z_singlefileMailbox.flushc C s dS )z,Called before writing the mailbox to file f.Nr )r r§ r r r râ É s z$_singlefileMailbox._pre_mailbox_hookc C s dS )z-Called before writing each message to file f.Nr )r r§ r r r rä Í s z$_singlefileMailbox._pre_message_hookc C s dS )z,Called after writing each message to file f.Nr )r r§ r r r ræ Ñ s z%_singlefileMailbox._post_message_hookc C s4 z | ¡ W dz| jr | ¡ W d| j ¡ X X dS )z Flush and close the mailbox.N)rI rØ rK rÔ rL )r r r r rL Õ s z_singlefileMailbox.closec C sL | j dkr| ¡ |dk rHy
| j | S tk
rF td| ƒd‚Y nX dS )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 dd¡ | j ¡ }t| jƒdkr8| js8| | j ¡ y&| | j ¡ | |¡}| | j ¡ W n" t
k
r€ | j |¡ ‚ Y nX | j ¡ | j ¡ | _
|S )z;Append message to mailbox and return (start, stop) offsets.r rÊ )rÔ r_ rà r« r rÖ râ rä Ú_install_messageræ rˆ ÚtruncaterI rÙ )r r! ZbeforeZoffsetsr r r rÚ ê s
z"_singlefileMailbox._append_message)NT)N)ru rv rw rx r r" r$ r( r6 r? r@ rJ rK rI râ rä ræ rL rž rÚ r r r r rÐ > s"
@
rÐ c @ sB e Zd ZdZdZdd„ Zddd„Zddd „Zdd
d „Zd d
„ Z dS )Ú _mboxMMDFzAn mbox or MMDF mailbox.Tc C sp | |¡\}}| j |¡ | j ¡ td¡}| j || j ¡ ¡}| | td¡¡}| |dd…
d¡¡ |S )z4Return a Message representation or raise a KeyError.ó rQ rX Nr ) rž rÔ r_ rl r` ra rS rà Ú_message_factoryÚset_fromÚdecode)r r# ré rê Ú from_lineÚstringr¨ r r r r, s z_mboxMMDF.get_messageFc C s t | |¡¡j|dS )z3Return a string representation or raise a KeyError.)Úunixfrom)r1 r2 r3 r4 )r r# Úfrom_r r r r5 s z_mboxMMDF.get_stringc C sJ | |¡\}}| j |¡ |s(| j ¡ | j || j ¡ ¡}| td¡S )z3Return a string representation or raise a KeyError.rQ )rž rÔ r_ rl rS rà r` ra )r r# r÷ ré rê rõ r r r r3 s
z_mboxMMDF.get_bytesc C s< | |¡\}}| j |¡ |s(| j ¡ t| j| j ¡ |ƒS )z6Return a file-like representation or raise a KeyError.)rž rÔ r_ rl Ú _PartialFilerà )r r# r÷ ré rê r r r r/ s
z_mboxMMDF.get_filec C s d}t |tƒr| |¡}t |tƒrf| d¡rf| d¡}|dkr\|d|… }||d d… }q°|}d}nJt |tƒrˆ| ¡ d¡}d| }n(t |t j
j ƒr°| ¡ }|dk r°| d¡}|dkrÎdt
t
¡ ¡ ¡ }| j ¡ }| j |t ¡ | || j| j¡ | j ¡ }||fS ) z1Format a message and blindly write to self._file.Ns From rQ rW r¬ rð r s From MAILER-DAEMON )rY re rP rf rm ÚfindÚ_mboxMMDFMessageÚget_fromrM r1 r! r Ú get_unixfromr¾ ÚasctimeÚgmtimerÔ rà rb ra rt Ú
_mangle_from_)r r! rô ÚnewlineZauthorré rê r r r rí & s0
z_mboxMMDF._install_messageN)F)F)F)
ru rv rw rx rÿ r, r5 r3 r/ rí r r r r rï s
rï c @ s2 e Zd ZdZdZdZd
dd„Zdd„ Zdd „ ZdS ) r zA classic mbox mailbox.TNc C s t | _t | |||¡ dS )zInitialize an mbox mailbox.N)r
rñ rï r )r r r r r r r r L s z
mbox.__init__c C s | t¡ dS )z,Called after writing each message to file f.N)rb ra )r r§ r r r ræ Q s zmbox._post_message_hookc C sì g g }}d}| j d¡ x | j ¡ }| j ¡ }| d¡r|t|ƒt|ƒk rl|rb| |ttƒ ¡ n
| |¡ | |¡ d}q |s¦|r˜| |ttƒ ¡ n
| |¡ P q |tkr´d}q d}q W tt t
||ƒƒƒ| _ t| j ƒ| _ | j ¡ | _
dS )z0Generate key-to-(start, stop) table of contents.Fr s From TN)rÔ r_ rà rl rm r« r° ra ÚdictÚ enumerateÚzipr rÕ rÙ )r ÚstartsÚstopsZlast_was_emptyÚline_posrs r r r rì U s0
zmbox._generate_toc)NT) ru rv rw rx rÿ rc r ræ rì r r r r r C s
c @ s2 e Zd ZdZd dd„Zdd„ Zdd „ Zd
d „ ZdS )
r zAn MMDF mailbox.NTc C s t | _t | |||¡ dS )zInitialize an MMDF mailbox.N)r
rñ rï r )r r r r r r r r z s z
MMDF.__init__c C s | dt ¡ dS )z-Called before writing each message to file f.s N)rb ra )r r§ r r r rä s zMMDF._pre_message_hookc C s | td t ¡ dS )z,Called after writing each message to file f.s N)rb ra )r r§ r r r ræ ƒ s zMMDF._post_message_hookc C sæ g g }}| j d¡ d}xŒ|}| j ¡ }| j ¡ }| dt ¡rž| |¡ xV|}| j ¡ }| j ¡ }|dt krˆ| |ttƒ ¡ P qN|sN| |¡ P qNW q |s P q W tt t
||ƒƒƒ| _ t| j ƒ| _ | j dd¡ | j ¡ | _
dS )z0Generate key-to-(start, stop) table of contents.r s rÊ N)rÔ r_ rl rà rm ra r° r« r r r r rÕ rÙ )r r r Únext_posr rs r r r rì ‡ s2
zMMDF._generate_toc)NT)ru rv rw rx r rä ræ rì r r r r r w s
c @ s e Zd ZdZd0dd„Zdd„ 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 | j¡sj|r`t | jd¡ t t tj | jd¡tj
tj B tj B d¡¡ n
t
| jƒ‚d| _dS )zInitialize an MH instance.iÀ z
.mh_sequencesi€ FN)r r r r r r r€ rL r¢ r} rµ ÚO_EXCLr¶ r rØ )r r r r r r r r § s
z MH.__init__c C sä | ¡ }t|ƒdkrd}n t|ƒd }tj | jt|ƒ¡}t|ƒ}d}zŠ| j rVt
|ƒ zfy| ||¡ W n: t k
r¢ | j r†t
|ƒ t|ƒ d}t |¡ ‚ Y nX t|tƒrº| ||¡ W d| j rÌt
|ƒ X W d|sÞt|ƒ X |S )z$Add message and return assigned key.r r¬ FTN)r8 r« Úmaxr r r} r re rÈ rØ rÛ rt rˆ rÜ rŠ r$ rY r Ú_dump_sequences)r r! r8 Znew_keyr r§ Úclosedr r r r" ³ s6
zMH.addc
C sx t j | jt|ƒ¡}yt|dƒ}W n> tk
r` } z |jtjkrNt d| ƒ‚n‚ W dd}~X Y nX |
¡ t |¡ dS )z=Remove the keyed message; raise KeyError if it doesn't exist.zrb+zNo message with key: %sN) r r r} r re r¢ r— r˜ rÑ r& rL r$ )r r# r r§ r r r r r$ Õ s z MH.removec
C sÖ t j | jt|ƒ¡}yt|dƒ}W n> tk
r` } z |jtjkrNt d| ƒ‚n‚ W dd}~X Y nX zd| j
rrt |ƒ z@t t |t j
t jB ¡¡ | ||¡ t|tƒr°| ||¡ W d| j
rÂt|ƒ X W dt|ƒ X dS )z>Replace the keyed message; raise KeyError if it doesn't exist.zrb+zNo message with key: %sN)r r r} r re r¢ r— r˜ rÑ r& rØ rÛ rL r¶ ÚO_TRUNCrt rY r r
rÜ rŠ )r r# r! r r§ r r r r r( ã s$
zMH.__setitem__c
C sì y@| j r$ttj | jt|ƒ¡dƒ}nttj | jt|ƒ¡dƒ}W n> tk
r~ } z |jtj krlt
d| ƒ‚n‚ W dd}~X Y nX |2 | j r”t |ƒ z t |ƒ}W d| j r°t
|ƒ X W dQ R X x*| ¡ ¡ D ]\}}||krÊ| |¡ qÊW |S )z4Return a Message representation or raise a KeyError.zrb+r¡ zNo message with key: %sN)rØ r¢ r r r} r re r— r˜ rÑ r& rÛ r rÜ Ú
get_sequencesr> Ú add_sequence)r r# r§ r r¨ r‰ Úkey_listr r r r, û s& zMH.get_messagec
C sÄ y@| j r$ttj | jt|ƒ¡dƒ}nttj | jt|ƒ¡dƒ}W n> tk
r~ } z |jtj krlt
d| ƒ‚n‚ W dd}~X Y nX |6 | j r”t |ƒ z| ¡
td¡S | j r´t|ƒ X W dQ R X dS )z2Return a bytes representation or raise a KeyError.zrb+r¡ zNo message with key: %sNrQ )rØ r¢ r r r} r re r— r˜ rÑ r& rÛ rS r` ra rÜ )r r# r§ r r r r r3 s z MH.get_bytesc
C sf y t tj | jt|ƒ¡dƒ}W n> tk
r\ } z |jtjkrJt d| ƒ‚n‚ W dd}~X Y nX t
|ƒS )z6Return a file-like representation or raise a KeyError.r¡ zNo message with key: %sN) r¢ r r r} r re r— r˜ rÑ r& r© )r r# r§ r r r r r/ ) s z MH.get_filec C s t tdd„ t | j¡D ƒƒƒS )z Return an iterator over keys.c s s | ]}| ¡ rt|ƒV qd S )N)ÚisdigitrÄ )Ú.0r± r r r ú <genexpr>6 s z MH.iterkeys.<locals>.<genexpr>)Úiterrã r r® r )r r r r r6 4 s z MH.iterkeysc C s t j t j | jt|ƒ¡¡S )z9Return True if the keyed message exists, False otherwise.)r r r r} r re )r r# r r r r? 9 s zMH.__contains__c C s t t| ¡ ƒƒS )z*Return a count of messages in the mailbox.)r« r7 r6 )r r r r r@ = s z
MH.__len__c C s2 | j s.ttj | jd¡dƒ| _t| jƒ d| _ dS )zLock the mailbox.z
.mh_sequenceszrb+TN)rØ r¢ r r r} r rÔ rÛ )r r r r rJ A s
zMH.lockc C s( | j r$t| jƒ t| jƒ | `d| _ dS )z#Unlock the mailbox if it is locked.FN)rØ rÜ rÔ rŠ )r r r r rK H s
z MH.unlockc C s dS )z&Write any pending changes to the disk.Nr )r r r r rI P s zMH.flushc C s | j r| ¡ dS )z Flush and close the mailbox.N)rØ rK )r r r r rL T s zMH.closec C s@ g }x6t | j¡D ]&}t j t j | j|¡¡r| |¡ qW |S )z Return a list of folder names.)r r® r r r¯ r} r° )r rB r± r r r r² Y s
zMH.list_foldersc C s t tj | j|¡| jddS )z+Return an MH instance for the named folder.F)r r )r r r r} r r )r r³ r r r r´ a 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 )r r³ r r r r· f s z
MH.add_folderc C s` t j | j|¡}t |¡}|dgkr:t t j |d¡¡ n|g krDntd| j ƒ‚t |¡ dS )z-Delete the named folder, which must be empty.z
.mh_sequenceszFolder not empty: %sN)r r r} r r® r$ r rº )r r³ r Úentriesr r r r½ k s
zMH.remove_folderc
s i }t tj | jd¡dddä}t| ¡ ƒ‰ xÐ|D ]È}yž| d¡\}}tƒ }xT| ¡ D ]H}| ¡ rr| t
|ƒ¡ qVdd„ | d¡D ƒ\}} | t || d ƒ¡ qVW ‡ fd
d „t
|ƒD ƒ||< t|| ƒd krÒ||= W q2 tk
rø td
| ¡ ƒ‚Y q2X q2W W dQ R X |S )z=Return a name-to-key-list dictionary to define each sequence.z
.mh_sequencesÚrÚASCII)Úencodingry c s s | ]}t |ƒV qd S )N)rÄ )r Úxr r r r „ s z#MH.get_sequences.<locals>.<genexpr>ú-r¬ c s g | ]}|ˆ kr|‘qS r r )r r# )Úall_keysr r ú
<listcomp>† s z$MH.get_sequences.<locals>.<listcomp>r z"Invalid sequence specification: %sN)r¢ r r r} r Úsetr8 r r r" rÄ rH Úrangerã r« rO r Úrstrip)
r Zresultsr§ rs r‰ Úcontentsr8 Úspecré rê r )r r r
w s&
zMH.get_sequencesc C s
t tj | jd¡ddd}zàt t |jtjtjB ¡¡ x¾| ¡ D ]²\}}t
|ƒdkrXqB| |d ¡ d}d}xbt t
|ƒƒD ]R}|d |kr |sÊd
}| d ¡ n*|r¼d}| d ||f ¡ n| d
| ¡ |}q|W |rê| t|ƒd ¡ qB| d¡ qBW W dt|ƒ X dS )z:Set sequences using the given name-to-key-list dictionary.z
.mh_sequenceszr+r )r r ry NFr¬ Tr z%s %sz %sÚ
)r¢ r r r} r rL r‰ r¶ r r> r« rb rã r re rŠ )r Ú sequencesr§ r‰ r8 ÚprevZ
completingr# r r r Ú
set_sequences s. zMH.set_sequencesc
C sL | ¡ }d}g }xÎ| ¡ D ]Â}|d |krÔ| ||d f¡ y4t tj | jt|ƒ¡tj | jt|d ƒ¡¡ W nH t t
fk
r¸ t tj | jt|ƒ¡tj | jt|d ƒ¡¡ Y n X t tj | jt|ƒ¡¡ |d7 }qW |d | _
t|ƒdkrúdS xB| ¡ D ]6\}}x*|D ]"\}}||kr||| |¡< qW qW | |¡ dS )z?Re-name messages to eliminate numbering gaps. Invalidates keys.r r¬ N)r
r6 r° r r“ r r} r re r” r• r– ÚunlinkrÕ r« r> Úindexr$ ) r r" r# Zchangesr# r‰ r Úoldr{ r r r Úpack¬ s,
zMH.packc C s| | ¡ }| ¡ }x<| ¡ D ]0\}}||kr6| |¡ q||kr|| |¡= qW x |D ]}||krT|g||< qTW | |¡ dS )z;Inspect a new MHMessage and update sequences appropriately.N)r
r> r° r& r$ )r r! r# Zpending_sequencesZ
all_sequencesr‰ r Úsequencer r r r
Æ s
zMH._dump_sequences)NT)ru rv rw rx r r" r$ r( r, r3 r/ r6 r? r@ rJ rK rI rL r² r´ r· r½ r
r$ r( r
r r r r r ¤ s.
" c @ s e Zd ZdZedddddddhƒZd%d d „Zd
d„ Zdd„ Zdd„ Z dd„ Z
dd„ Z dd„ Z dd„ Z
dd „ Zd d „ Zd d „ Zd!d"„ Zd#d$„ Zd S )&r z An Rmail-style Babyl mailbox.ÚunseenÚdeletedZfiledÚansweredÚ forwardedZeditedÚresentNTc C s t | |||¡ i | _dS )zInitialize a Babyl mailbox.N)rÐ r Ú_labels)r r r r r r r r Û s zBabyl.__init__c C s( t | |¡}t|tƒr$| ¡ | j|< |S )z$Add message and return assigned key.)rÐ r" rY r Ú
get_labelsr/ )r r! r# r r r r" à s
z Babyl.addc C s" t | |¡ || jkr | j|= dS )z=Remove the keyed message; raise KeyError if it doesn't exist.N)rÐ r$ r/ )r r# r r r r$ ç s
z Babyl.removec C s* t | ||¡ t|tƒr&| ¡ | j|< dS )z>Replace the keyed message; raise KeyError if it doesn't exist.N)rÐ r( rY r r0 r/ )r r# r! r r r r( í s
zBabyl.__setitem__c
C s | |¡\}}| j |¡ | j ¡ t ¡ }x2| j ¡ }|dt ksH|sJP | | td¡¡ q.W t ¡ }x.| j ¡ }|tks€|s‚P | | td¡¡ qjW || j ¡ }|dks²t
‚| j |¡}| td¡}t |
¡ | ƒ} | |
¡ ¡ || jkr| | j| ¡ | S )z4Return a Message representation or raise a KeyError.s *** EOOH ***rQ r )rž rÔ r_ rl rZ r[ ra rb r` rà rß rS r rk Ú set_visibler/ Ú
set_labels)
r r# ré rê Úoriginal_headersrs Zvisible_headersÚnZbodyr¨ r r r r, ó s0
zBabyl.get_messagec C sÀ | |¡\}}| j |¡ | j ¡ t ¡ }x2| j ¡ }|dt ksH|sJP | | td¡¡ q.W x | j ¡ }|tksx|sbP qbW | ¡ }|| j
¡ }|dks t ‚| j |¡}| td¡}|| S )z3Return a string representation or raise a KeyError.s *** EOOH ***rQ r )
rž rÔ r_ rl rZ r[ ra rb r` rk rà rß rS ) r r# ré rê r3 rs Zheadersr4 rr r r r r3 s&
zBabyl.get_bytesc C s t | |¡ dt¡¡S )z6Return a file-like representation or raise a KeyError.rQ )rZ r[ r3 r` ra )r r# r r r r/ % s zBabyl.get_filec C s@ | ¡ tƒ }x | j ¡ D ]}| |¡ qW | | j¡ t|ƒS )z4Return a list of user-defined labels in the mailbox.)rž r r/ r< rH Údifference_updateÚ_special_labelsr7 )r ÚlabelsZ
label_listr r r r0 ) s zBabyl.get_labelsc C s> g g }}| j d¡ d}g }xÒ|}| j ¡ }| j ¡ }|dt kržt|ƒt|ƒk rf| |ttƒ ¡ | |¡ dd„ | j ¡ dd… d¡D ƒ}| |¡ q |dks²|dt krÖt|ƒt|ƒk rî| |ttƒ ¡ q |s | |ttƒ ¡ P q W tt t
||ƒƒƒ| _ tt |ƒƒ| _ t| j ƒ| _
| j dd ¡ | j ¡ | _dS )
z0Generate key-to-(start, stop) table of contents.r s c S s g | ]}| ¡ r| ¡ ‘qS r )Ústrip)r Úlabelr r r r @ s z'Babyl._generate_toc.<locals>.<listcomp>r¬ Nó ,ó rÊ )rÔ r_ rl rà ra r« r° r r r r r r/ rÕ rÙ )r r r r Z label_listsr rs r7 r r r rì 2 s4
zBabyl._generate_tocc C sV dt }|dt 7 }| ¡ }dd„ |D ƒ}|dd |¡ t 7 }|d7 }| |¡ dS ) z,Called before writing the mailbox to file f.s BABYL OPTIONS:s
Version: 5c s s | ]}| ¡ V qd S )N)rM )r r9 r r r r U s z*Babyl._pre_mailbox_hook.<locals>.<genexpr>s Labels:r: r; N)ra r0 r} rb )r r§ Zbabylr7 r r r râ P s zBabyl._pre_mailbox_hookc C s | dt ¡ dS )z-Called before writing each message to file f.ó N)rb ra )r r§ r r r rä Z s zBabyl._pre_message_hookc C s | td ¡ dS )z,Called after writing each message to file f.r; N)rb ra )r r§ r r r ræ ^ s zBabyl._post_message_hookc C s” | j ¡ }t|tƒr¼g }g }x0| ¡ D ]$}|| jkr@| |¡ q&| |¡ q&W | j d¡ x |D ]}| j d| ¡ ¡ q`W | j d¡ x$|D ] }| j d| ¡ d ¡ qŽW | j t ¡ n| j dt ¡ t|t
j j ƒr*t
¡ }t
j |dd¡}| |¡ | d¡ x4| ¡ }| j | d t ¡¡ |d ks6|s
P q
W | j d
t ¡ t|tƒr¸t
¡ } t
j | dd¡}
|
| ¡ ¡ xv| ¡ }| j | d t ¡¡ |d ks®|s‚P q‚W n@| d¡ x4| ¡ }| j | d t ¡¡ |d ksð|sÄP qÄW x,| d ¡} | s P | j | d t ¡¡ qúW nXt|ttt
jfƒr&t|t
jƒrbt d t d
¡ | ¡ }t|tƒrx| |¡}| d¡d } | d dkrú| j |d| … d t ¡¡ | j d
t ¡ | j |d| … d t ¡¡ | j || d… d t ¡¡ n(| j d
t t ¡ | j | d t ¡¡ n\t |dƒrrt |dƒrRt dt d
¡ |j!}| ¡ }
d}x”| ¡ }| "d¡r†|dd… d }n | "d¡r¢|dd… d }| j | d t ¡¡ |d ksÆ|s`|rìd}| j d
t ¡ | |
¡ nP q`W xŒ| ¡ }|sP | "d¡r$|dd… t }n:| "d¡rB|dd… t }n | "d ¡r^|dd… t }| j |¡ qöW nt#dt$|ƒ ƒ‚| j ¡ }||fS )z0Write message contents and return (start, stop).ó 1s , s ,,ó r: s 1,,Fr rQ s *** EOOH ***i z8Use of StringIO input is deprecated, use BytesIO insteadrR s
rÊ rW Nrl rT zDUse of text mode files is deprecated, use a binary mode file insteadTs
rU rV zInvalid message type: %s)%rÔ rà rY r r0 r6 r° rb rM ra r1 r! r rZ r[ r\ r] r^ r_ rl r` Ú get_visiblerS rf re rg rh ri rj rk rP rù rE rT rd rn ro )r r! ré Zspecial_labelsr7 r9 Z orig_bufferZorig_generatorrs Z
vis_bufferZ
vis_generatorrT Z
body_startZ original_posZ
first_passrê r r r rí b sÀ
zBabyl._install_message)NT)ru rv rw rx Ú frozensetr6 r r" r$ r( r, r3 r/ r0 rì râ rä ræ rí r r r r r Õ s
c @ s* e Zd ZdZd dd„Zdd„ Zdd„ ZdS )
r z0Message with mailbox-format-specific properties.Nc C sÒ t |tjjƒr4| t |¡¡ t |tƒrÎ| | ¡ nšt |tƒrP| t |¡¡ n~t |t
ƒrl| t |¡¡ nbt |t j
ƒrŠ| t |¡¡ nDt|dƒr¦| t |¡¡ n(|dkr¾tjj | ¡ ntdt|ƒ ƒ‚dS )z Initialize a Message instance.rS NzInvalid message type: %s)rY r1 r! r Ú_become_messageÚcopyZdeepcopyÚ _explain_torf r2 re Zmessage_from_stringrZ Ú
TextIOWrapperZmessage_from_filerE Zmessage_from_binary_filer rn ro )r r! r r r r Ñ s
zMessage.__init__c C s8 t |dg ƒ}x&|jD ] }||kr|j| | j|< qW dS )z0Assume the non-format-specific state of message.Ú_type_specific_attributesN)ÚgetattrÚ__dict__)r r! Z
type_specificr‰ r r r rA ä s zMessage._become_messagec C s t |tƒrdS tdƒ‚dS )z:Copy format-specific state to message insofar as possible.Nz Cannot convert to specified type)rY r rn )r r! r r r rC ë s
zMessage._explain_to)N)ru rv rw rx r rA rC r r r r r Î s
c @ s| e Zd ZdZdddgZd dd„Zdd „ Zd
d „ Zd d
„ Zdd„ Z dd„ Z
dd„ Z dd„ Z dd„ Z
dd„ Zdd„ Zd d „ 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)rH rI r¾ rJ r r )r r! r r r r ø s
zMaildirMessage.__init__c C s | j S )zReturn 'new' or 'cur'.)rH )r r r r r‹ ÿ s zMaildirMessage.get_subdirc C s( |dks|dkr|| _ n td| ƒ‚dS )z Set subdir to 'new' or 'cur'.r{ r| z!subdir must be 'new' or 'cur': %sN)rH rO )r r™ r r r r£ s zMaildirMessage.set_subdirc C s" | j d¡r| j dd… S dS dS )z*Return as a string the flags that are set.z2,rÊ Nr† )rI rm )r r r r Ú get_flags
s zMaildirMessage.get_flagsc C s dd t|ƒ¡ | _dS )z)Set the given flags and unset all others.z2,r† N)r} rã rI )r Úflagsr r r Ú set_flags s zMaildirMessage.set_flagsc C s$ | d t| ¡ ƒt|ƒB ¡¡ dS )z.Set the given flag(s) without changing others.r† N)rM r} r rK )r Úflagr r r Úadd_flag s zMaildirMessage.add_flagc C s, | ¡ r(| d t| ¡ ƒt|ƒ ¡¡ dS )z7Unset the given string flag(s) without changing others.r† N)rK rM r} r )r rN r r r Ú remove_flag s zMaildirMessage.remove_flagc C s | j S )z<Return delivery date of message, in seconds since the epoch.)rJ )r r r r r’ s zMaildirMessage.get_datec C s6 yt |ƒ| _W n" tk
r0 td| ƒd‚Y nX dS )z9Set delivery date of message, in seconds since the epoch.zcan't convert to float: %sN)ÚfloatrJ rO rn )r Zdater r r r¥ " s zMaildirMessage.set_datec C s | j S )z%Get the message's "info" as a string.)rI )r r r r r ) s zMaildirMessage.get_infoc C s& t |tƒr|| _ntdt|ƒ ƒ‚dS )z Set the message's "info" string.zinfo must be a string: %sN)rY re rI rn ro )r Úinfor r r r¤ - s
zMaildirMessage.set_infoc C s¤ t |tƒr8| | ¡ ¡ | | ¡ ¡ | | ¡ ¡ nht |tƒrÄt | ¡ ƒ}d|kr`|
d¡ | ¡ dkrv|
d¡ d|krˆ|
d¡ d|krš|
d¡ d|kr¬|
d¡ | d t
| ¡ ¡¡ nÜt |tƒrt | ¡ ƒ}d|krî| d
¡ d|kr| d ¡ d|kr | d ¡ nˆt |tƒr‚t | ¡ ƒ}d|krD| d
¡ d|krX| d
¡ d|krl| d¡ d|kr | d¡ n t |tƒrntdt|ƒ ƒ‚dS )z;Copy Maildir-specific state to message insofar as possible.ÚSÚRr| ÚOÚTÚDÚFÚAz
MAILER-DAEMONr* ÚrepliedÚflaggedr+ r, ÚPr- z$Cannot convert to specified type: %sN)rY r rM rK r£ r‹ r¥ r’ rú r rO rò r¾ rþ r r r Ú add_labelr rn ro )r r! rL r r r rC 4 sN
zMaildirMessage._explain_to)N)ru rv rw rx rE r r‹ r£ rK rM rO rP r’ r¥ r r¤ rC r r r r r ó s
c @ sZ e Zd ZdZdgZddd„Zdd„ Zddd „Zd
d „ Zd d
„ Z dd„ Z
dd„ Z dd„ Z dS )rú z/Message with mbox- or MMDF-specific properties.Ú_fromNc C sV | dd¡ t|tjjƒrF| ¡ }|dk rF| d¡rF| |dd… ¡ t | |¡ dS )z'Initialize an mboxMMDFMessage instance.z
MAILER-DAEMONTNzFrom rX )rò rY r1 r! r rü rm r )r r! rö r r r r e s z_mboxMMDFMessage.__init__c C s | j S )z Return contents of "From " line.)r^ )r r r r rû n s z_mboxMMDFMessage.get_fromc C s4 |dk r*|dkrt ¡ }|dt |¡ 7 }|| _dS )z>Set "From " line, formatting and appending time_ if specified.NTú )r¾ rþ rý r^ )r r÷ Ztime_r r r rò r s
z_mboxMMDFMessage.set_fromc C s | dd¡| dd¡ S )z*Return as a string the flags that are set.ÚStatusr† zX-Status)r+ )r r r r rK z s z_mboxMMDFMessage.get_flagsc C sÚ t |ƒ}d\}}x&dD ] }||kr||7 }| |¡ qW x&dD ] }||kr>||7 }| |¡ q>W |d t|ƒ¡7 }y| d|¡ W n tk
r¢ | d|¡ Y nX y| d|¡ W n tk
rÔ | d|¡ Y nX dS )z)Set the given flags and unset all others.)r† r† )rT rU )rW rX rY r† r` zX-StatusN)r r$ r} rã Úreplace_headerr& Z
add_header)r rL Z status_flagsZ
xstatus_flagsrN r r r rM ~ s&
z_mboxMMDFMessage.set_flagsc C s$ | d t| ¡ ƒt|ƒB ¡¡ dS )z.Set the given flag(s) without changing others.r† N)rM r} r rK )r rN r r r rO ” s z_mboxMMDFMessage.add_flagc C s4 d| ksd| kr0| d t| ¡ ƒt|ƒ ¡¡ dS )z7Unset the given string flag(s) without changing others.r` zX-Statusr† N)rM r} r rK )r rN r r r rP ˜ s z _mboxMMDFMessage.remove_flagc C sÞ t |tƒrÐt| ¡ ƒ}d|kr(| d¡ d|kr:| d¡ d|krL| d¡ d|kr^| d¡ d|krp| d¡ |d = |d
= d | ¡ ¡ d d
… ¡}y | t
t
|d¡¡¡ W n ttfk
rÊ Y nX n
t |tƒrø| | ¡ ¡ | | ¡ ¡ nât |tƒrZt| ¡ ƒ}d|kr$| d¡ d|kr8| d¡ d|krL| d¡ |d = |d
= n€t |tƒr¼t| ¡ ƒ}d|kr†| d¡ d|krš| d¡ d|kr®| d¡ |d = |d
= n t |tƒrÊntdt|ƒ ƒ‚d
S )zACopy mbox- or MMDF-specific state to message insofar as possible.rU r| rX rY rT rS rW rV Zstatuszx-statusr_ éûÿÿÿNz%a %b %d %H:%M:%S %Yr* rZ r[ r+ r, z$Cannot convert to specified type: %s)rY r r rK r£ rO r} rû r r¥ ÚcalendarZtimegmr¾ ZstrptimerO Ú
OverflowErrorrú rM rò r r r r] r rn ro )r r! rL Z
maybe_dater r r rC s^
z _mboxMMDFMessage._explain_to)N)N)
ru rv rw rx rE r rû rò rK rM rO rP rC r r r r rú ` s
rú c @ s e Zd ZdZdS )r
z&Message with mbox-specific properties.N)ru rv rw rx r r r r r
Ñ s c @ sH e Zd ZdZdgZddd„Zdd„ 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)re r r )r r! r r r r Ú s zMHMessage.__init__c C s | j dd… S )z4Return a list of sequences that include the message.N)re )r r r r r
ß s zMHMessage.get_sequencesc C s t |ƒ| _dS )z3Set the list of sequences that include the message.N)r7 re )r r" r r r r$ ã s zMHMessage.set_sequencesc C s6 t |tƒr"|| jkr2| j |¡ ntdt|ƒ ƒ‚dS )z8Add sequence to list of sequences including the message.z sequence type must be str: %sN)rY re re r° rn ro )r r) r r r r ç s
zMHMessage.add_sequencec C s* y| j |¡ W n tk
r$ Y nX dS )zARemove sequence from the list of sequences including the message.N)re r$ rO )r r) r r r Úremove_sequenceï s zMHMessage.remove_sequencec C sJ t |tƒrdt| ¡ ƒ}d|kr*| d¡ n| d¡ | d¡ d|krP| d¡ d|krb| d¡ nât |tƒr¾t| ¡ ƒ}d|krŽ| d¡ n
| d ¡ d|krª| d¡ d|kr¼| d
¡ nˆt |tƒræx|| ¡ D ]}| |¡ qÒW n`t |t ƒr(t| ¡ ƒ}d|kr|
d¡ d|krF|
d ¡ n t |t ƒr6nt d t
|ƒ ƒ‚d
S )z6Copy MH-specific state to message insofar as possible.r* r| rS r[ rX rZ rT ÚROrU rY r, z$Cannot convert to specified type: %sN)rY r r r
r£ rO rú r r r r] r rn ro )r r! r" r) r r r rC ö s@
zMHMessage._explain_to)N) ru rv rw rx rE r r
r$ r rf rC r r r r r Õ s
c @ sb e Zd ZdZddgZddd„Zdd„ 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 rh r )r r! r r r r " s zBabylMessage.__init__c C s | j dd… S )z'Return a list of labels on the message.N)r/ )r r r r r0 ( s zBabylMessage.get_labelsc C s t |ƒ| _dS )z&Set the list of labels on the message.N)r7 r/ )r r7 r r r r2 , s zBabylMessage.set_labelsc C s6 t |tƒr"|| jkr2| j |¡ ntdt|ƒ ƒ‚dS )z+Add label to list of labels on the message.zlabel must be a string: %sN)rY re r/ r° rn ro )r r9 r r r r] 0 s
zBabylMessage.add_labelc C s* y| j |¡ W n tk
r$ Y nX dS )z4Remove label from the list of labels on the message.N)r/ r$ rO )r r9 r r r Ú remove_label8 s zBabylMessage.remove_labelc C s
t | jƒS )z3Return a Message representation of visible headers.)r rh )r r r r r? ? s zBabylMessage.get_visiblec C s t |ƒ| _dS )z2Set the Message representation of visible headers.N)r rh )r Zvisibler r r r1 C s zBabylMessage.set_visiblec C sj x6| j ¡ D ](}|| kr,| j || | ¡ q | j |= q W x,dD ]$}|| kr>|| j kr>| | | j |< q>W dS )z9Update and/or sensibly generate a set of visible headers.)ZDateZFromzReply-ToZToZCCZSubjectN)rh r8 ra )r Úheaderr r r Úupdate_visibleG s
zBabylMessage.update_visiblec C sv t |tƒr~t| ¡ ƒ}d|kr*| d¡ n| d¡ | d¡ d|ksNd|krX| d¡ d|krj| d¡ d |kr|| d
¡ nôt |tƒrØt| ¡ ƒ}d|kr¨| d ¡ n
| d ¡ d |krÄ| d
¡ d|krÖ| d¡ nšt |tƒrt| ¡ ƒ}d|kr| d¡ d|krr| d¡ nXt |t ƒrT|
| ¡ ¡ x<| ¡ D ]}| |¡ q>W n t |t
ƒrbntdt|ƒ ƒ‚dS )z9Copy Babyl-specific state to message insofar as possible.r* r| rS r- r. r\ r, rT r+ rV rg rU rW rY rZ z$Cannot convert to specified type: %sN)rY r r r0 r£ rO rú r r r r1 r? r] r rn ro )r r! r7 r9 r r r rC R sF
zBabylMessage._explain_to)N)ru rv rw rx rE r r0 r2 r] ri r? r1 rk rC r r r r r s
c @ s e Zd ZdZdS )r
z&Message with MMDF-specific properties.N)ru rv rw rx r r r r r
| s c @ s¨ e Zd ZdZd&dd„Zd'dd„Zd(dd„Zd)d d
„Zd*d d „Zd
d„ Z dd„ Z
d+dd„Z dd„ Z dd„ Z
dd„ Zdd„ Zd d „ Zd d „ Zd d!„ Zd"d#„ Zed$d%„ ƒZdS ),r© z A read-only wrapper of a file.Nc C s$ || _ |dkr| ¡ | _n|| _dS )zInitialize a _ProxyFile.N)rÔ rà Ú_pos)r r§ Úposr r r r ƒ s z_ProxyFile.__init__c C s | || jj¡S )z Read bytes.)Ú_readrÔ rS )r Úsizer r r rS ‹ s z_ProxyFile.readc C s | || jj¡S )z Read bytes.)rn rÔ Úread1)r ro r r r rp s z_ProxyFile.read1c C s | || jj¡S )z Read a line.)rn rÔ rl )r ro r r r rl “ s z_ProxyFile.readlinec C s> g }x4| D ],}| |¡ |dk r
|t|ƒ8 }|dkr
P q
W |S )zRead multiple lines.Nr )r° r« )r ÚsizehintrB rs r r r Ú readlines— s
z_ProxyFile.readlinesc c s x| ¡ }|sdS |V qW dS )zIterate over lines.N)rl )r rs r r r r; ¢ s
z_ProxyFile.__iter__c C s | j S )zReturn the position.)rl )r r r r rà ª s z_ProxyFile.tellr c C s4 |dkr| j | j¡ | j ||¡ | j ¡ | _dS )zChange position.r¬ N)rÔ r_ rl rà )r ÚoffsetÚwhencer r r r_ ® s z_ProxyFile.seekc C s0 t | dƒr,zt | jdƒr"| j ¡ W d| `X dS )zClose the file.rÔ rL N)rE rÔ rL )r r r r rL µ s
z_ProxyFile.closec C s2 |dkr d}| j | j¡ ||ƒ}| j ¡ | _|S )z"Read size bytes using read_method.NrW )rÔ r_ rl rà )r ro Ú read_methodrB r r r rn ¾ 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 | ¡ d S )N)rL )r Úexcr r r Ú__exit__Ë s z_ProxyFile.__exit__c C s
| j ¡ S )N)rÔ Úreadable)r r r r ry Î s z_ProxyFile.readablec C s
| j ¡ S )N)rÔ Úwritable)r r r r rz Ñ s z_ProxyFile.writablec C s
| j ¡ S )N)rÔ Úseekable)r r r r r{ Ô s z_ProxyFile.seekablec C s
| j ¡ S )N)rÔ rI )r r r r rI × s z_ProxyFile.flushc C s& t | dƒsdS t | jdƒs dS | jjS )NrÔ Tr F)rE rÔ r )r r r r r Ú s
z_ProxyFile.closed)N)N)N)N)N)r )ru rv rw rx r rS rp rl rr r; rà r_ rL rn rv rx ry rz r{ rI Úpropertyr r r r r r© € s$
r© c @ s< e Zd ZdZddd„Zdd„ Zddd „Zd
d „ Zd d
„ ZdS )rø 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à r} )r r r r rà ì s 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)r} rl r~ r© r_ )r rs rt r r r r_ ð s z_PartialFile.seekc C sB | j | j }|dkrdS |dks0|dk s0||kr4|}t | ||¡S )z;Read size bytes using read_method, honoring start and stop.r rð N)r~ rl r© rn )r ro ru Z remainingr r r rn ú s z_PartialFile._readc C s t | dƒr| `d S )NrÔ )rE rÔ )r r r r rL s
z_PartialFile.close)NN)r ) ru rv rw rx r rà r_ rn rL r r r r rø ã s
rø Tc
C sž d}yZt rpyt | t jt jB ¡ W nJ tk
rn } z,|jtjtjtjfkr\t d| j
ƒ‚n‚ W dd}~X Y nX |r^yt | j
d ƒ}| ¡ W n: tk
rÊ } z |jtjtjfkr¸dS ‚ W dd}~X Y nX y`y t
|j
| j
d ¡ d}W n2 ttfk
r t
|j
| j
d ¡ d}Y nX t
|j
¡ W n0 tk
r\ t
|j
¡ t d| j
ƒ‚Y nX W n8 t r|t | t j¡ |r’t
| j
d ¡ ‚ Y nX dS )z(Lock file f using lockf and dot locking.Fzlockf: lock unavailable: %sNz.lockTzdot lock unavailable: %s)ÚfcntlÚlockfZLOCK_EXZLOCK_NBr— r˜ ZEAGAINrÒ rÓ r r‰ rá rL r r“ r” r• r– r% rÉ r$ ÚLOCK_UN)r§ rÝ Z dotlock_doner Zpre_lockr r r rÛ
sH
rÛ c C s8 t rt | t j¡ tj | jd ¡r4t | jd ¡ dS )z*Unlock file f using lockf and dot locking.z.lockN)r r€ r r r r r‰ r$ )r§ r r r rÜ 4 s rÜ c C s8 t | t jt jB t jB d¡}z
t| dƒS t |¡ X dS )zCCreate a file if it doesn't exist and open for reading and writing.i¶ zrb+N)r r¢ rµ r ÚO_RDWRrL )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 rá C s rá c C s$ | ¡ ttdƒr t | ¡ ¡ dS )z0Ensure changes to file f are physically on disk.ÚfsyncN)rI rE r r„ Úfileno)r§ r r r rÞ I s
rÞ c C s t | ƒ | ¡ dS )z:Close file f, ensuring all changes are physically on disk.N)rÞ rL )r§ r r r rŠ O s rŠ c @ s e Zd ZdZdS )r z"Raised for module-specific errors.N)ru rv rw rx r r r r r U s c @ s e Zd ZdZdS )r z:The specified mailbox does not exist and won't be created.N)ru rv rw rx r r r r r X s c @ s e Zd ZdZdS )r z>The specified mailbox is not empty and deletion was requested.N)ru rv rw rx r r r r r [ s c @ s e Zd ZdZdS )r z)Another process caused an action to fail.N)ru rv rw rx r r r r r ^ s c @ s e Zd ZdZdS )r z)A file appears to have an invalid format.N)ru rv rw rx r r r r r a s )T)0rx r r¾ rc r r˜ rB rh r1 Z
email.messageZemail.generatorrZ r- r Ú ImportErrorÚ__all__ra rM 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 Ú<module> sp
h 8 DB4- 3 z%mqH_c'
*