File: //lib64/python3.8/__pycache__/mailbox.cpython-38.opt-2.pyc
U
e5dE3 ã @ sN d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Zd dl
Z
d dl Z z d dl Z W n e
k
r„ dZ Y nX dddddddd d
d d d
dddddgZe j d¡ZG dd„ dƒZG dd„ deƒZG dd„ deƒZG dd„ deƒZG dd„ deƒZG dd„ deƒZG d d„ deƒZG d d„ deƒZG d d„ dejjƒZG d d „ d eƒ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'„ d'ƒZ!G d(d)„ d)e!ƒZ"d<d+d,„Z#d-d.„ Z$d/d0„ Z%d1d2„ Z&d3d4„ Z'd5d6„ Z(G d7d„ de)ƒZ*G d8d„ de*ƒZ+G d9d„ de*ƒZ,G d:d„ de*ƒZ-G d;d„ de*ƒZ.dS )=é NÚMailboxÚMaildirÚmboxÚMHÚBabylÚMMDFÚMessageÚMaildirMessageÚ mboxMessageÚ MHMessageÚ BabylMessageÚ MMDFMessageÚErrorÚNoSuchMailboxErrorÚ
NotEmptyErrorÚExternalClashErrorÚ FormatErrorÚasciic @ s e Zd ZdBdd„Zdd„ Zdd„ Zd d
„ Zd d „ Zd
d„ ZdCdd„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.„ ZdDd/d0„Zd1d2„ ZdEd3d4„Zd5d6„ Z d7d8„ Z d9d:„ Z d;d<„ Z d=d>„ Z d?Z!dFd@dA„Z"dS )Gr NTc C s t j t j |¡¡| _|| _d S ©N)ÚosÚpathÚabspathÚ
expanduserÚ_pathÚ_factory©Úselfr ÚfactoryÚcreate© r ú /usr/lib64/python3.8/mailbox.pyÚ__init__$ s zMailbox.__init__c C s t dƒ‚d S ©Nz&Method must be implemented by subclass©ÚNotImplementedError©r Úmessager r r Úadd) s z Mailbox.addc C s t dƒ‚d S r" r# ©r Úkeyr r r Úremove- s zMailbox.removec C s | |¡ d S r )r* r( r r r Ú __delitem__1 s zMailbox.__delitem__c C s( z| |¡ W n tk
r" Y nX d S r )r* ÚKeyErrorr( r r r Údiscard4 s zMailbox.discardc C s t dƒ‚d S r" r# ©r r) r& r r r Ú __setitem__; s zMailbox.__setitem__c C s* z | |¡W S tk
r$ | Y S X d S r )Ú __getitem__r, )r r) Údefaultr r r Úget? s z Mailbox.getc
C sB | j s| |¡S t | |¡¡}| |¡W 5 Q R £ S Q R X d S r )r Ú get_messageÚ
contextlibÚclosingÚget_file)r r) Úfiler r r r0 F s
zMailbox.__getitem__c C s t dƒ‚d S r" r# r( r r r r3 N s zMailbox.get_messagec C s t | |¡¡ ¡ S r ©ÚemailÚmessage_from_bytesÚ get_bytesZ as_stringr( r r r Ú
get_stringR s zMailbox.get_stringc C s t dƒ‚d S r" r# r( r r r r; Y s zMailbox.get_bytesc C s t dƒ‚d S r" r# r( r r r r6 ] s zMailbox.get_filec C s t dƒ‚d S r" r# ©r r r r Úiterkeysa s zMailbox.iterkeysc C s t | ¡ ƒS r )Úlistr> r= r r r Úkeyse s z Mailbox.keysc c s> | ¡ D ]0}z | | }W n tk
r0 Y qY nX |V qd S r ©r> r, ©r r) Úvaluer r r Ú
itervaluesi s
zMailbox.itervaluesc C s | ¡ S r )rD r= r r r Ú__iter__r s zMailbox.__iter__c C s t | ¡ ƒS r )r? rD r= r r r Úvaluesu s zMailbox.valuesc c sB | ¡ D ]4}z | | }W n tk
r0 Y qY nX ||fV qd S r rA rB r r r Ú iteritemsy s
zMailbox.iteritemsc C s t | ¡ ƒS r )r? rG r= r r r Úitems‚ s z
Mailbox.itemsc C s t dƒ‚d S r" r# r( r r r Ú __contains__† s zMailbox.__contains__c C s t dƒ‚d S r" r# r= r r r Ú__len__Š s zMailbox.__len__c C s | ¡ D ]}| |¡ qd S r )r@ r- r( r r r ÚclearŽ s z
Mailbox.clearc C s4 z | | }W n t k
r$ | Y S X | |¡ |S r )r, r- )r r) r1 Úresultr r r Úpop“ s
z Mailbox.popc C s* | ¡ D ]}|| |¡f S tdƒ‚d S )NzNo messages in mailbox)r> rM r, r( r r r Úpopitemœ s zMailbox.popitemc C st t |dƒr| ¡ }nt |dƒr(| ¡ }n|}d}|D ].\}}z || |< W q4 tk
r` d}Y q4X q4|rptdƒ‚d S )NrG rH FTzNo message with key(s))ÚhasattrrG rH r, )r ÚargÚsourceZbad_keyr) r& r r r Úupdate£ s
zMailbox.updatec C s t dƒ‚d S r" r# r= r r r Úflush´ s z
Mailbox.flushc C s t dƒ‚d S r" r# r= r r r Úlock¸ s z Mailbox.lockc C s t dƒ‚d S r" r# r= r r r Úunlock¼ s zMailbox.unlockc C s t dƒ‚d S r" r# r= r r r ÚcloseÀ s z
Mailbox.closec C s. z | d¡W S tk
r( tdƒ‚Y nX d S )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 |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 }| ¡ }| d
¡r\|d d … d }n | d ¡rx|d d
… d }|s‚qÂ|r¤| d¡r¤d|dd … }| dt ¡}|
|¡ |}q6| jrø|rø| t ¡sø|
t ¡ nt dt |ƒ ƒ‚d S )Nr ó
ú8Use of StringIO input is deprecated, use BytesIO insteadé s
From s
>From ÚreadÚbufferúDUse of text mode files is deprecated, use a binary mode file insteadó
éþÿÿÿó
éÿÿÿÿó From s >From é úInvalid message type: %s) Ú
isinstancer9 r& r ÚioÚBytesIOÚ generatorÚBytesGeneratorÚflattenÚseekr^ ÚreplaceÚlinesepÚwriteÚ_append_newlineÚendswithÚstrÚbytesÚStringIOÚwarningsÚwarnÚDeprecationWarningÚgetvaluerZ rO r_ ÚreadlineÚ
startswithÚ TypeErrorÚtype) r r& ÚtargetZ mangle_from_r_ ÚgenÚdataZlastlineÚliner r r Ú
_dump_messageÑ s`
ÿ
ÿ
zMailbox._dump_message)NT)N)N)N)F)#Ú__name__Ú
__module__Ú __qualname__r! r' r* r+ r- r/ r2 r0 r3 r< r; r6 r> r@ rD rE rF rG rH rI rJ rK rM rN rR rS rT rU rV rZ rr rƒ r r r r r ! s@
c @ sÖ e Zd ZdZd5dd„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,Zd-d.„ Zd/d0„ Zd1d2„ Zd3d4„ Z dS )6r ú:NTc C s¬ t | |||¡ tj | jd¡tj | jd¡tj | jd¡dœ| _tj | j¡sŠ|r€t | jd¡ | j ¡ D ]}t |d¡ qln
t
| jƒ‚i | _ dddœ| _ d| _
d| _d S ) NÚtmpÚnewÚcur)rˆ r‰ rŠ éÀ r )rŠ r‰ gš™™™™™¹?)r r! r r Újoinr Ú_pathsÚexistsÚmkdirrF r Ú_tocÚ _toc_mtimesÚ
_last_readÚ _skewfactor)r Údirnamer r r r r r r!
s ý
zMaildir.__init__c
C s~ | ¡ }z| ||¡ 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¡ zLzt |j|¡ W n( ttfk
r t |j|¡ Y nX t |j¡ W nN tk
rx } z.t |j¡ |jtjkrft d| ƒ‚n‚ W 5 d }~X Y nX |S )NÚ r‰ r z$Name clash with existing message: %s) Ú _create_tmprƒ Ú
BaseExceptionrV r r* ÚnameÚ _sync_closerh 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' ! sF
ÿ ÿz Maildir.addc C s t t j | j| |¡¡¡ d S r )r r* r rŒ r Ú_lookupr( r r r r* K s zMaildir.removec C s, z| |¡ W n ttfk
r& Y nX d S r )r* r, ÚFileNotFoundErrorr( 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 | |
¡ d S )Nrd r• )r r' rh 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 5 Q R X tj |¡\}}| |¡ | j
|kr€| | | j
¡d ¡ | tj
tj | j|¡¡¡ |S )NÚrbrd )r Úopenr r rŒ r r r rž Ú
set_subdirr› Úset_infoÚset_dateÚgetmtime)r r) ZsubpathÚfÚmsgr¨ r˜ r r r r3 r s
zMaildir.get_messagec
C sD t tj | j| |¡¡dƒ }| ¡ td¡W 5 Q R £ S Q R X d S )Nr° r[ ) r± r r rŒ r r r^ ro rp ©r r) r¶ r r r r; s zMaildir.get_bytesc C s$ t tj | j| |¡¡dƒ}t|ƒS )Nr° )r± r r rŒ r r Ú
_ProxyFiler¸ r r r r6 † s zMaildir.get_filec c sF | ¡ | jD ]2}z| |¡ W n tk
r8 Y qY nX |V qd S r )Ú_refreshr r r, r( r r r r> ‹ s
zMaildir.iterkeysc C s | ¡ || jkS r )rº r r( r r r rI • s zMaildir.__contains__c C s | ¡ t| jƒS r )rº Úlenr r= r r r rJ š s zMaildir.__len__c C s d S r r r= r r r rS Ÿ s z
Maildir.flushc C s d S r r r= r r r rT ¥ s z Maildir.lockc C s d S r r r= r r r rU © s zMaildir.unlockc C s d S r r r= r r r rV s z
Maildir.closec C s\ g }t | j¡D ]F}t|ƒdkr|d dkrt j t j | j|¡¡r| |dd … ¡ q|S )Né r Ú.)r Úlistdirr r» r ÚisdirrŒ Úappend©r rL Úentryr r r Ú list_folders± s ÿzMaildir.list_foldersc C s t tj | jd| ¡| jddS )Nr½ 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 )Nr½ ©r Z
maildirfolderé¶ ) r r rŒ r r r rŽ rV r± ÚO_CREATÚO_WRONLY)r rÆ r rL Zmaildirfolder_pathr r r Ú
add_folderÀ s ÿzMaildir.add_folderc C s t j | jd| ¡}t t j |d¡¡t t j |d¡¡ D ](}t|ƒdk sX|d dkr<td| ƒ‚q<t |¡D ]B}|dkrp|dkrp|dkrpt j t j ||¡¡rptd||f ƒ‚qpt j|d d
D ]F\}}}|D ]}t t j ||¡¡ qÐ|D ]}t
t j ||¡¡ qîqÂt
|¡ d S ) Nr½ r‰ rŠ r¼ r z Folder contains message(s): %srˆ z%Folder contains subdirectory '%s': %sF)Útopdown) r r rŒ r r¾ r» r r¿ Úwalkr* Úrmdir)r rÆ r r ÚrootÚdirsÚfilesr r r Ú
remove_folderÊ s& ÿÿÿzMaildir.remove_folderc C sX t ¡ }t tj | jd¡¡D ]4}tj | jd|¡}|tj |¡ dkr t |¡ q d S )Nrˆ i@ú )Ú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|¡}zt |¡ W nF t
k
rÆ t jd7 _zt|ƒW Y S tk
rÀ Y nX Y nX td | ƒ‚d S )
Nú/z\057r‡ z\072z%s.M%sP%sQ%s.%sr¼ g €„.Arˆ z&Name clash prevented file creation: %s)rÔ ÚsocketÚ gethostnamero Ú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 kr^d}| jD ]2}tj | j| ¡}|| j| krJd}|| j|< q"|s^d S i | _| jD ]^}| j| }t |¡D ]D}tj
||¡}tj |¡r¢q‚| | j
¡d }tj
||¡| j|< q‚qjt ¡ | _d S )Né FTr )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€ z.t j t j | j| j| ¡¡r,| j| W S W n tk
rB Y nX | ¡ z | j| W S tk
rz td| ƒd ‚Y nX d S ©NúNo message with key: %s)r r rŽ rŒ r r r, rº r( r r r r # s zMaildir._lookupc C sX t | dƒs| ¡ | _z| t| jƒ W S tk
r: Y d S tk
rP Y qY qX qd S )NÚ
_onetime_keys)rO r> rå ÚnextÚ
StopIterationr, r= r r r ræ 1 s
z Maildir.next)NT) r„ r… r† r› r! r' r* r- r/ r3 r; r6 r> rI rJ rS rT rU rV rà rÇ rÌ rÓ rÖ rÜ r– rº r ræ r r r r r s4
*
$c @ s e Zd Zd#dd„Zdd„ Zdd„ Zd d
„ Zd d „ Zd
d„ Zdd„ Z dd„ Z
dd„ Z dd„ Z dd„ Z
dd„ Zdd „ Zd d „ Zd$d d „Zd!d"„ ZdS )%Ú_singlefileMailboxNTc
C s¾ t | |||¡ zt| jdƒ}W nn tk
rŽ } zP|jtjkr\|rPt| jdƒ}q~t| jƒ‚n"|jtjtj fkr|t| jdƒ}n‚ W 5 d }~X Y nX || _
d | _ d| _ d| _
d| _d| _d | _d S )Núrb+zwb+r° r 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 )Nr¼ T)r Ú_append_messager rî rð r% r r r r' X s
z_singlefileMailbox.addc C s | |¡ | j|= d| _d S ©NT)r r rï r( r r r r* b s
z_singlefileMailbox.removec C s$ | |¡ | |¡| j|< d| _d S rô )r ró r rï r. r r r r/ h s
z _singlefileMailbox.__setitem__c c s | ¡ | j ¡ E d H d S r )r r r@ r= r r r r> n s z_singlefileMailbox.iterkeysc C s | ¡ || jkS r )r r r( r r r rI s s z _singlefileMailbox.__contains__c C s | ¡ t| jƒS r )r r» r r= r r r rJ x s z_singlefileMailbox.__len__c C s | j st| jƒ d| _ d S rô )rñ Ú
_lock_filerí r= r r r rT } s
z_singlefileMailbox.lockc C s | j rt| jƒ d| _ d S ©NF)rñ Ú _unlock_filerí r= r r r rU ƒ s
z_singlefileMailbox.unlockc
C sÖ | j s | jr t| jƒ d| _d S | j dd¡ | j ¡ }|| jkrTtd| j|f ƒ‚t| j ƒ}z¤i }|
|¡ t | j
¡ ƒD ]x}| j | \}}| j |¡ | |¡ | ¡ }| j td|| j ¡ ƒ¡}|sÎqÚ| |¡ q¬|| ¡ f||< | |¡ q|| ¡ | _W n" | ¡ t |j¡ ‚ Y nX t|ƒ | j ¡ t | j ¡j} t |j| ¡ zt |j| j ¡ W n2 t k
rš t | j ¡ t |j| j ¡ Y nX t | j dƒ| _|| _ d| _ d| _| j rÒt | jdd d S )NFr rà z4Size of mailbox file changed (expected %i, found %i)é ré )Údotlock) rï rð Ú _sync_flushrí rn Útellrò r Ú_create_temporaryr Ú_pre_mailbox_hookÚsortedr r@ Ú_pre_message_hookr^ Úminrq Ú_post_message_hookrV r r* r˜ r™ rÝ Úst_modeÚchmodr¥ rß r± rñ rõ )
r Zcur_lenZnew_fileZnew_tocr) ÚstartÚstopZ new_startr_ Úmoder r r rS ‰ s`
þ
ÿ
z_singlefileMailbox.flushc C s d S r r ©r r¶ r r r rý É s z$_singlefileMailbox._pre_mailbox_hookc C s d S r r r r r r rÿ Í s z$_singlefileMailbox._pre_message_hookc C s d S r r r r r r r Ñ s z%_singlefileMailbox._post_message_hookc C s4 z | ¡ W 5 z| jr | ¡ W 5 | j ¡ X X d S r )rí rV rñ rU rS r= r r r rV Õ s z_singlefileMailbox.closec C sN | j d kr| ¡ |d k rJz | j | W S tk
rH td| ƒd ‚Y nX d S rã )r Ú
_generate_tocr, r( r r r r à s
z_singlefileMailbox._lookupc C sœ | j dd¡ | j ¡ }t| jƒdkr8| js8| | j ¡ z&| | j ¡ | |¡}| | j ¡ W n" t
k
r€ | j |¡ ‚ Y nX | j ¡ | j ¡ | _
|S )Nr rà )rí rn rû r» r rï rý rÿ Ú_install_messager r— ÚtruncaterS rò )r r& ZbeforeZoffsetsr r r ró ê s
z"_singlefileMailbox._append_message)NT)N)r„ r… r† r! r' r* r/ r> rI rJ rT rU rS rý rÿ r rV r ró r r r r rè > s
@
rè c @ s> e Zd ZdZdd„ Zddd„Zddd„Zdd d
„Zd d „ Zd
S )Ú _mboxMMDFTc C sp | |¡\}}| j |¡ | j ¡ td¡}| j || j ¡ ¡}| | td¡¡}| |dd …
d¡¡ |S )Nó r[ rf r ) r rí rn r{ ro rp r^ rû Ú_message_factoryÚset_fromÚdecode)r r) r r Ú from_lineÚstringr· r r r r3 s z_mboxMMDF.get_messageFc C s t | ||¡¡j|dS )N)Úunixfromr8 )r r) Úfrom_r r r r< s
ÿÿz_mboxMMDF.get_stringc C sJ | |¡\}}| j |¡ |s(| j ¡ | j || j ¡ ¡}| td¡S ©Nr[ )r rí rn r{ r^ rû ro rp )r r) r r r r r r r r; s
z_mboxMMDF.get_bytesc C s< | |¡\}}| j |¡ |s(| j ¡ t| j| j ¡ |ƒS r )r rí rn r{ Ú _PartialFilerû )r r) r r r r r r r6 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°| ¡ }|d k r°| d¡}|d krÎdt
t
¡ ¡ ¡ }| j ¡ }| j |t ¡ | || j| j¡ | j ¡ }||fS )Nre r[ rd r¼ r r s From MAILER-DAEMON )rh rt rZ ru r| ÚfindÚ_mboxMMDFMessageÚget_fromrW r9 r& r Ú get_unixfromrÔ ÚasctimeÚgmtimerí rû rq rp rƒ Ú
_mangle_from_)r r& r ÚnewlineZauthorr r r r r r & s0
z_mboxMMDF._install_messageN)F)F)F) r„ r… r† r r3 r< r; r6 r r r r r r s
r c @ s. e Zd ZdZdZd dd„Zdd„ Zdd„ ZdS )
r TNc C s t | _t | |||¡ d S r )r
r
r r! r r r r r! L s z
mbox.__init__c C s | t¡ d S r ©rq rp r r r r r Q s zmbox._post_message_hookc C sè g g }}d}| j d¡ | j ¡ }| j ¡ }| d¡rzt|ƒt|ƒk rj|r`| |ttƒ ¡ n
| |¡ | |¡ d}q|s¤|r–| |ttƒ ¡ q¸| |¡ q¸q|tkr²d}qd}qtt t
||ƒƒƒ| _ t| j ƒ| _ | j ¡ | _
d S )NFr re T)rí rn rû r{ r| r» rÀ rp ÚdictÚ enumerateÚzipr rî rò )r ÚstartsÚstopsZlast_was_emptyÚline_posr‚ r r r r U s.
zmbox._generate_toc)NT)r„ r… r† r rr r! r r r r r r r C s
c @ s. e Zd Zd dd„Zdd„ Zdd„ Zd d
„ ZdS ) r NTc C s t | _t | |||¡ d S r )r
r
r r! r r r r r! z s z
MMDF.__init__c C s | dt ¡ d S ©Nó r r r r r rÿ s zMMDF._pre_message_hookc C s | td t ¡ d S r% r r r r r r ƒ s zMMDF._post_message_hookc C sÞ g g }}| j d¡ d}|}| j ¡ }| j ¡ }| dt ¡r˜| |¡ |}| j ¡ }| j ¡ }|dt kr„| |ttƒ ¡ qžqJ|sJ| |¡ qžqJq|sq qtt t
||ƒƒƒ| _ t| j ƒ| _ | j dd¡ | j ¡ | _
d S )Nr r& rà )rí rn r{ rû r| rp rÀ r» r r r! r rî rò )r r" r# Únext_posr$ r‚ r r r r ‡ s.
zMMDF._generate_toc)NT)r„ r… r† r! rÿ r r r r r r r w s
c @ s¾ e Zd Zd/dd„Zdd„ Zdd„ Zd d
„ 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.„ ZdS )0r NTc C st t | |||¡ tj | j¡sj|r`t | jd¡ t t tj | jd¡tj
tj B tj B d¡¡ n
t
| jƒ‚d| _d S )Nr‹ ú
.mh_sequencesi€ F)r r! r r rŽ r r rV r± rŒ rÊ ÚO_EXCLrË 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 |ƒ zfz|
||¡ W n: tk
r¢ | j
r†t |ƒ t |ƒ d}t |¡ ‚ Y nX t|tƒrº| ||¡ W 5 | j
rÌt |ƒ X W 5 |sÞt |ƒ X |S )Nr r¼ FT)r@ r» Úmaxr r rŒ r rt rÞ r™ rñ rõ r÷ rƒ r— r* rh r Ú_dump_sequences)r r& r@ Znew_keyr¯ r¶ Úclosedr r r r' ³ s6
zMH.addc
C sx t j | jt|ƒ¡}zt|dƒ}W n> tk
r` } z |jtjkrNt d| ƒ‚n‚ W 5 d }~X Y nX |
¡ t |¡ d S ©Nré rä ) r r rŒ r rt r± r¦ r§ rê r, rV r* )r r) r r¶ r¬ r r r r* Õ s z MH.removec
C sÖ t j | jt|ƒ¡}zt|dƒ}W n> tk
r` } z |jtjkrNt d| ƒ‚n‚ W 5 d }~X Y nX zd| j rrt |ƒ z@t t |t jt jB ¡¡ | ||¡ t|tƒr°| ||¡ W 5 | j rÂt
|ƒ X W 5 t
|ƒ X d S r- )r r rŒ r rt r± r¦ r§ rê r, r™ rñ rõ r÷ rV rË ÚO_TRUNCrƒ rh r r+ )r r) r& r r¶ r¬ r r r r/ ã s$
zMH.__setitem__c
C sè z@| j r$ttj | jt|ƒ¡dƒ}nttj | jt|ƒ¡dƒ}W n> tk
r~ } z |jtj krlt
d| ƒ‚n‚ W 5 d }~X Y nX |2 | j r”t |ƒ z t
|ƒ}W 5 | j r°t |ƒ X W 5 Q R X | ¡ ¡ D ]\}}||krÈ| |¡ qÈ|S )Nré r° rä )rñ r± r r rŒ r rt r¦ r§ rê r, rõ r÷ r Ú
get_sequencesrH Ú add_sequence)r r) r¶ r¬ r· r˜ Úkey_listr r r r3 û s& zMH.get_messagec
C sÔ z@| j r$ttj | jt|ƒ¡dƒ}nttj | jt|ƒ¡dƒ}W n> tk
r~ } z |jtj krlt
d| ƒ‚n‚ W 5 d }~X Y nX |F | j r”t |ƒ z |
¡ td¡W ¢W 5 Q R £ S | j rÄt |ƒ X W 5 Q R X d S )Nré r° rä r[ )rñ r± r r rŒ r rt r¦ r§ rê r, rõ r÷ r^ ro rp ©r r) r¶ r¬ r r r r; s z MH.get_bytesc
C sf z t tj | jt|ƒ¡dƒ}W n> tk
r\ } z |jtjkrJt d| ƒ‚n‚ W 5 d }~X Y nX t
|ƒS )Nr° rä ) r± r r rŒ r rt r¦ r§ rê r, r¹ r2 r r r r6 ) s z MH.get_filec C s t tdd„ t | j¡D ƒƒƒS )Nc s s | ]}| ¡ rt|ƒV qd S r )ÚisdigitrÚ )Ú.0r r r r Ú <genexpr>6 s ÿz MH.iterkeys.<locals>.<genexpr>)Úiterrþ r r¾ r r= r r r r> 4 s z MH.iterkeysc C s t j t j | jt|ƒ¡¡S r )r r rŽ rŒ r rt r( r r r rI 9 s zMH.__contains__c C s t t| ¡ ƒƒS r )r» r? r> r= r r r rJ = s z
MH.__len__c C s2 | j s.ttj | jd¡dƒ| _t| jƒ d| _ d S )Nr( ré T)rñ r± r r rŒ r rí rõ r= r r r rT A s
zMH.lockc C s( | j r$t| jƒ t| jƒ | `d| _ d S rö )rñ r÷ rí r™ r= r r r rU H s
z MH.unlockc C s d S r r r= r r r rS P s zMH.flushc C s | j r| ¡ d S r )rñ rU r= r r r rV T s zMH.closec C s< g }t | j¡D ]&}t j t j | j|¡¡r| |¡ q|S r )r r¾ r r r¿ rŒ rÀ rÁ r r r rà Y s
zMH.list_foldersc C s t tj | j|¡| jddS )NFrÄ ©r r r rŒ r r rÅ r r r rÇ a s ÿz
MH.get_folderc C s t tj | j|¡| jdS )NrÈ r7 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 |¡ d S )Nr( zFolder not empty: %s)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| ¡ ƒ‰ |D ]Ä}zš| d¡\}}tƒ }| ¡ D ]H}| ¡ rn| t
|ƒ¡ qRdd„ | d¡D ƒ\}} | t || d ƒ¡ qR‡ fd
d „t
|ƒD ƒ||< t|| ƒd krÌ||= W q0 tk
rò td
| ¡ ƒ‚Y q0X q0W 5 Q R X |S )Nr( ÚrÚASCII©Úencodingr‡ c s s | ]}t |ƒV qd S r )rÚ )r4 Úxr r r r5 „ s z#MH.get_sequences.<locals>.<genexpr>ú-r¼ c s g | ]}|ˆ kr|‘qS r r )r4 r) ©Zall_keysr r Ú
<listcomp>† s ÿz$MH.get_sequences.<locals>.<listcomp>r z"Invalid sequence specification: %s)r± r r rŒ r Úsetr@ rž r3 r' rÚ rR Úrangerþ r» rY r Úrstrip)
r Zresultsr¶ r‚ r˜ Úcontentsr@ Úspecr r r r? r r/ w s(
ÿzMH.get_sequencesc C s t tj | jd¡ddd}zØt t |jtjtj B ¡¡ |
¡ D ]®\}}t |ƒdkrVq@| |d ¡ d }d}t
t|ƒƒD ]R}|d |krœ|sÆd }| d
¡ n*|r¸d}| d ||f ¡ n| d | ¡ |}qx|rä| t|ƒd
¡ q@| d
¡ q@W 5 t|ƒ X d S )Nr( zr+r: r; r r‡ Fr¼ Tr> z%s %sz %sÚ
)r± r r rŒ r r™ rV r˜ rË r. rH r» rq rþ rA rt )r Ú sequencesr¶ r˜ r@ ÚprevZ
completingr) r r r Ú
set_sequences s. zMH.set_sequencesc
C s> | ¡ }d}g }| ¡ D ]Â}|d |krÒ| ||d f¡ z4t tj | jt|ƒ¡tj | jt|d ƒ¡¡ W nH t t
fk
r¶ t tj | jt|ƒ¡tj | jt|d ƒ¡¡ Y n X t tj | jt|ƒ¡¡ |d7 }q|d | _
t|ƒdkröd S | ¡ D ]0\}}|D ]"\}}||kr
||| |¡< q
qþ| |¡ d S )Nr r¼ )r/ r> rÀ r r¢ r rŒ r rt r£ r¤ r¥ Úunlinkrî r» rH ÚindexrI ) r rG rH Zchangesr) r˜ r1 Úoldr‰ r r r Úpack¬ s0 ÿÿ
zMH.packc C st | ¡ }| ¡ }| ¡ D ]0\}}||kr4| |¡ q||kr|| |¡= q|D ]}||krN|g||< qN| |¡ d S r )r/ rH rÀ rK rI )r r& r) Zpending_sequencesZ
all_sequencesr˜ r1 Úsequencer r r r+ Æ s zMH._dump_sequences)NT)r„ r… r† r! r' r* r/ r3 r; r6 r> rI rJ rT rU rS rV rà rÇ rÌ rÓ r/ rI rM r+ r r r r r ¤ s,
" c @ sŒ e Zd ZedddddddhƒZd$d
d „Zd d
„ Zdd„ Zdd„ Zdd„ Z dd„ Z
dd„ Z dd„ Z dd„ Z
d d „ Zd d „ Zd d!„ Zd"d#„ ZdS )%r ÚunseenÚdeletedZfiledÚansweredÚ forwardedZeditedÚresentNTc C s t | |||¡ i | _d S r )rè r! Ú_labelsr r r r r! Û s zBabyl.__init__c C s( t | |¡}t|tƒr$| ¡ | j|< |S r )rè r' rh r Ú
get_labelsrT )r r& r) r r r r' à s
z Babyl.addc C s" t | |¡ || jkr | j|= d S r )rè r* rT r( r r r r* ç s
z Babyl.removec C s* t | ||¡ t|tƒr&| ¡ | j|< d S r )rè r/ rh r rU rT r. r r r r/ í s
zBabyl.__setitem__c
C sò | |¡\}}| j |¡ | j ¡ t ¡ }| j ¡ }|dt ks\|sHq\| | td¡¡ q,t ¡ }| j ¡ }|tks|s|q| | td¡¡ qd|| j ¡ }| j
|¡}| td¡}t | ¡ | ƒ} |
| ¡ ¡ || jkrî| | j| ¡ | S ©Nó *** EOOH ***r[ )r rí rn r{ ri rj rp rq ro rû r^ r rz Ú set_visiblerT Ú
set_labels)
r r) r r Úoriginal_headersr‚ Zvisible_headersÚnZbodyr· r r r r3 ó s*
zBabyl.get_messagec C s¬ | |¡\}}| j |¡ | j ¡ t ¡ }| j ¡ }|dt ks\|sHq\| | td¡¡ q,| j ¡ }|tksv|s\qvq\| ¡ }|| j
¡ }| j |¡}| td¡}|| S rV ) r rí rn r{ ri rj rp rq ro rz rû r^ ) r r) r r rZ r‚ Zheadersr[ r r r r r; s
zBabyl.get_bytesc C s t | |¡ dt¡¡S r )ri rj r; ro rp r( r r r r6 % s zBabyl.get_filec C s< | ¡ tƒ }| j ¡ D ]}| |¡ q| | j¡ t|ƒS r )r rA rT rF rR Údifference_updateÚ_special_labelsr? )r ÚlabelsZ
label_listr r r rU ) s zBabyl.get_labelsc C s: g g }}| j d¡ d}g }|}| j ¡ }| j ¡ }|dt krœt|ƒt|ƒk rd| |ttƒ ¡ | |¡ dd„ | j ¡ dd … d¡D ƒ}| |¡ q |dks°|dt krÔt|ƒt|ƒk rì| |ttƒ ¡ q |s | |ttƒ ¡ qîq tt t
||ƒƒƒ| _ tt |ƒƒ| _ t| j ƒ| _
| j dd¡ | j ¡ | _d S ) Nr s c S s g | ]}| ¡ r| ¡ ‘qS r )Ústrip©r4 Úlabelr r r r@ @ s þz'Babyl._generate_toc.<locals>.<listcomp>r¼ ó ,ó rà )rí rn r{ rû rp r» rÀ rž r r r! r rT rî rò )r r" r# r' Z label_listsr$ r‚ r^ r r r r 2 s4
ÿ zBabyl._generate_tocc C sV dt }|dt 7 }| ¡ }dd„ |D ƒ}|dd |¡ t 7 }|d7 }| |¡ d S )Ns BABYL OPTIONS:s
Version: 5c s s | ]}| ¡ V qd S r )rW r` r r r r5 U s z*Babyl._pre_mailbox_hook.<locals>.<genexpr>s Labels:rb rc )rp rU rŒ rq )r r¶ Zbabylr^ r r r rý P s zBabyl._pre_mailbox_hookc C s | dt ¡ d S )Nó r r r r r rÿ Z s zBabyl._pre_message_hookc C s | td ¡ d S )Nrc r r r r r r ^ s zBabyl._post_message_hookc C sx | j ¡ }t|tƒr°g }g }| ¡ D ]$}|| jkr>| |¡ q$| |¡ q$| j d¡ |D ]}| j d| ¡ ¡ qZ| j d¡ |D ] }| j d| ¡ d ¡ q„| j t ¡ n| j dt ¡ t|t
j j ƒrt
¡ }t
j |dd¡}| |¡ | d¡ | ¡ }| j | d t ¡¡ |d ks,|süq,qü| j d
t ¡ t|tƒr¤t
¡ } t
j | dd¡}
|
| ¡ ¡ | ¡ }| j | d t ¡¡ |d ks¢|snqâqnn>| d¡ | ¡ }| j | d t ¡¡ |d ksâ|s®qâq®| d ¡} | söqf| j | d t ¡¡ qânTt|ttt
jfƒrt|t
jƒrJt d t d
¡ | ¡ }t|tƒr`| |¡}| 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 ¡¡ nXt |dƒrVt |dƒr:t dt d
¡ |j!}| ¡ }
d}| ¡ }| "d¡rl|d d… d }n | "d¡rˆ|d d… d }| j | d t ¡¡ |d ks¬|sF|rÚd}| j d
t ¡ | |
¡ nqÚqF| ¡ }|sìqf| "d¡r
|d d… t }n:| "d¡r(|d d… t }n | "d ¡rD|d d… t }| j |¡ qÚnt#dt$|ƒ ƒ‚| j ¡ }||fS )Nó 1s , s ,,ó rb s 1,,Fr r[ rW rø r\ r] s
rà rd r{ r_ r` Tra rb rc rg )%rí rû rh r rU r] rÀ rq rW rp r9 r& r ri rj rk rl rm rn r{ ro Ú get_visibler^ ru rt rv rw rx ry rz rZ r rO r_ rs r} r~ )r r& r Zspecial_labelsr^ ra Z orig_bufferZorig_generatorr‚ Z
vis_bufferZ
vis_generatorr_ Z
body_startZ original_posZ
first_passr r r r r b s¼
ÿ
ÿ
zBabyl._install_message)NT)r„ r… r† Ú frozensetr] r! r' r* r/ r3 r; r6 rU r rý rÿ r r r r r r r Õ s$
ÿ
c @ s& e Zd Zddd„Zdd„ Zdd„ ZdS ) r 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(|d kr¾tjj | ¡ ntdt|ƒ ƒ‚d S )Nr^ rg )rh r9 r& r Ú_become_messageÚcopyZdeepcopyÚ _explain_toru r: rt Zmessage_from_stringri Ú
TextIOWrapperZmessage_from_filerO Zmessage_from_binary_filer! r} r~ r% r r r r! Ñ s
zMessage.__init__c C s4 t |dg ƒ}|jD ] }||kr|j| | j|< qd S )NÚ_type_specific_attributes)ÚgetattrÚ__dict__)r r& Z
type_specificr˜ r r r ri ä s
zMessage._become_messagec C s t |tƒrd S tdƒ‚d S )Nz Cannot convert to specified type)rh r r} r% r r r rk ë s
zMessage._explain_to)N)r„ r… r† r! ri rk r r r r r Î s
c @ sx e Zd ZdddgZd dd„Zdd„ Zd d
„ Zd d „ Zd
d„ Zdd„ Z dd„ Z
dd„ Z dd„ Z dd„ Z
dd„ Zdd „ ZdS ) r Ú_subdirÚ_infoÚ_dateNc C s& d| _ d| _t ¡ | _t | |¡ d S )Nr‰ r• )rp rq rÔ rr r r! r% r r r r! ø s
zMaildirMessage.__init__c C s | j S r )rp r= r r r rš ÿ s zMaildirMessage.get_subdirc C s( |dks|dkr|| _ n td| ƒ‚d S )Nr‰ rŠ z!subdir must be 'new' or 'cur': %s)rp rY )r r¨ r r r r² s zMaildirMessage.set_subdirc C s" | j d¡r| j dd … S dS d S )Nú2,rà r• )rq r| r= r r r Ú get_flags
s zMaildirMessage.get_flagsc C s dd t|ƒ¡ | _d S )Nrs r• )rŒ rþ rq )r Úflagsr r r Ú set_flags s zMaildirMessage.set_flagsc C s$ | d t| ¡ ƒt|ƒB ¡¡ d S ©Nr• ©rv rŒ rA rt ©r Úflagr r r Úadd_flag s zMaildirMessage.add_flagc C s, | ¡ r(| d t| ¡ ƒt|ƒ ¡¡ d S rw )rt rv rŒ rA ry r r r Ú remove_flag s zMaildirMessage.remove_flagc C s | j S r )rr r= r r r r¡ s zMaildirMessage.get_datec C s6 zt |ƒ| _W n" tk
r0 td| ƒd ‚Y nX d S )Nzcan't convert to float: %s)Úfloatrr rY r} )r Údater r r r´ " s zMaildirMessage.set_datec C s | j S r )rq r= r r r rœ ) s zMaildirMessage.get_infoc C s& t |tƒr|| _ntdt|ƒ ƒ‚d S )Nzinfo must be a string: %s)rh rt rq r} r~ )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|ƒ ƒ‚d S )NÚSÚRrŠ ÚOÚTÚDÚFÚAú
MAILER-DAEMONrO ÚrepliedÚflaggedrP rQ ÚPrR ú$Cannot convert to specified type: %s)rh r rv rt r² rš r´ r¡ r rA r{ r rÔ r r r0 r Ú add_labelr r} r~ )r r& ru r r r rk 4 sP
ÿzMaildirMessage._explain_to)N)r„ r… r† rm r! rš r² rt rv r{ r| r¡ r´ rœ r³ rk r r r r r ó s
c @ sV e Zd ZdgZddd„Zdd„ Zddd„Zd d
„ Zd d „ Zd
d„ Z dd„ Z
dd„ Z dS )r Ú_fromNc C sV | dd¡ t|tjjƒrF| ¡ }|d k rF| d¡rF| |dd … ¡ t | |¡ d S )Nr‡ TzFrom rf )r rh r9 r& r r r| r! )r r& r r r r r! e s z_mboxMMDFMessage.__init__c C s | j S r )r r= r r r r n s z_mboxMMDFMessage.get_fromc C s4 |d k r*|dkrt ¡ }|dt |¡ 7 }|| _d S )NTú )rÔ r r r )r r Ztime_r r r r r s
z_mboxMMDFMessage.set_fromc C s | dd¡| dd¡ S )NÚStatusr• úX-Status)r2 r= r r r rt z s z_mboxMMDFMessage.get_flagsc C sÒ t |ƒ}d\}}dD ] }||kr||7 }| |¡ qdD ] }||kr8||7 }| |¡ q8|d t|ƒ¡7 }z| d|¡ W n tk
rš | d|¡ Y nX z| d|¡ W n tk
rÌ | d|¡ Y nX d S )N)r• r• )r r‚ )r„ r… r† r• r r )rA r* rŒ rþ Úreplace_headerr, Z
add_header)r ru Z status_flagsZ
xstatus_flagsrz r r r rv ~ s& z_mboxMMDFMessage.set_flagsc C s$ | d t| ¡ ƒt|ƒB ¡¡ d S rw rx ry r r r r{ ” s z_mboxMMDFMessage.add_flagc C s4 d| ksd| kr0| d t| ¡ ƒt|ƒ ¡¡ d S )Nr r r• rx ry r r r r| ˜ 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 … ¡}z | 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 )Nr‚ rŠ r… r† r r€ r„ rƒ Zstatuszx-statusrŽ éûÿÿÿz%a %b %d %H:%M:%S %YrO rˆ r‰ rP rQ r‹ )rh r rA rt r² r{ rŒ r rž r´ ÚcalendarZtimegmrÔ ÚstrptimerY Ú
OverflowErrorr rv r r r0 r rΠr r} r~ )r r& ru Z
maybe_dater r r rk sb
ÿ
ÿz _mboxMMDFMessage._explain_to)N)N) r„ r… r† rm r! r r rt rv r{ r| rk r r r r r ` s
r c @ s e Zd ZdS )r
N©r„ r… r† r r r r r
Ñ s c @ sD e Zd ZdgZddd„Zdd„ Zdd„ Zd d
„ Zd d „ Zd
d„ Z dS )r Ú
_sequencesNc C s g | _ t | |¡ d S r )r— r r! r% r r r r! Ú s zMHMessage.__init__c C s | j d d … S r )r— r= r r r r/ ß s zMHMessage.get_sequencesc C s t |ƒ| _d S r )r? r— )r rG r r r rI ã s zMHMessage.set_sequencesc C s6 t |tƒr"|| jkr2| j |¡ ntdt|ƒ ƒ‚d S )Nz sequence type must be str: %s)rh rt r— rÀ r} r~ ©r rN r r r r0 ç s
zMHMessage.add_sequencec C s* z| j |¡ W n tk
r$ Y nX d S r )r— r* rY r˜ r r r Úremove_sequenceï s zMHMessage.remove_sequencec C sF 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â| ¡ D ]}| |¡ qÐn`t |t ƒr$t| ¡ ƒ}d|kr|
d¡ d|krB|
d ¡ n t |t ƒr2nt d t
|ƒ ƒ‚d S )
NrO rŠ r€ r‰ r… rˆ r ÚROr‚ r† rQ r‹ )rh r rA r/ r² r{ r r r0 r rŒ r r} r~ )r r& rG rN r r r rk ö sB
ÿzMHMessage._explain_to)N)
r„ r… r† rm r! r/ rI r0 r™ rk r r r r r Õ s
c @ s^ e Zd ZddgZddd„Zdd„ Zdd „ Zd
d „ Zd d
„ Zdd„ Z dd„ Z
dd„ Z dd„ Z dS )r rT Ú_visibleNc C s g | _ tƒ | _t | |¡ d S r )rT r r› r! r% r r r r! " s zBabylMessage.__init__c C s | j d d … S r )rT r= r r r rU ( s zBabylMessage.get_labelsc C s t |ƒ| _d S r )r? rT )r r^ r r r rY , s zBabylMessage.set_labelsc C s6 t |tƒr"|| jkr2| j |¡ ntdt|ƒ ƒ‚d S )Nzlabel must be a string: %s)rh rt rT rÀ r} r~ ©r ra r r r rŒ 0 s
zBabylMessage.add_labelc C s* z| j |¡ W n tk
r$ Y nX d S r )rT r* rY rœ r r r Ú remove_label8 s zBabylMessage.remove_labelc C s
t | jƒS r ©r r› r= r r r rg ? s zBabylMessage.get_visiblec C s t |ƒ| _d S r rž )r Zvisibler r r rX C s zBabylMessage.set_visiblec C sb | j ¡ D ](}|| kr*| j || | ¡ q
| j |= q
dD ]$}|| kr8|| j kr8| | | j |< q8d S )N)ZDateZFromzReply-ToZToZCCZSubject)r› r@ r‘ )r Úheaderr r r Úupdate_visibleG s
zBabylMessage.update_visiblec C sr 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|krn| d¡ nTt |t ƒrP|
| ¡ ¡ | ¡ D ]}| |¡ q<n t |t
ƒr^ntdt|ƒ ƒ‚d S )NrO rŠ r€ rR rS rŠ rQ r rP rƒ rš r‚ r„ r† rˆ r‹ )rh r rA rU r² r{ r r r0 r rX rg rŒ r r} r~ )r r& r^ ra r r r rk R sH
ÿzBabylMessage._explain_to)N)
r„ r… r† rm r! rU rY rŒ r rg rX r rk r r r r r s
c @ s e Zd ZdS )r
Nr– r r r r r
| s c @ s¤ e Zd Zd%dd„Zd&dd„Zd'dd„Zd(dd „Zd)d
d „Zd d
„ Zdd„ Z d*dd„Z
dd„ Z dd„ Z dd„ Z
dd„ Zdd „ Zd d „ Zd d „ Zd!d"„ Zed#d$„ ƒZdS )+r¹ Nc C s$ || _ |d kr| ¡ | _n|| _d S r )rí rû Ú_pos)r r¶ Úposr r r r! ƒ s z_ProxyFile.__init__c C s | || jj¡S r )Ú_readrí r^ ©r Úsizer r r r^ ‹ s z_ProxyFile.readc C s | || jj¡S r )r£ rí Úread1r¤ r r r r¦ s z_ProxyFile.read1c C s | || jj¡S r )r£ rí r{ r¤ r r r r{ “ s z_ProxyFile.readlinec C s< g }| D ].}| |¡ |d k r|t|ƒ8 }|dkr q8q|S )Nr )rÀ r» )r ÚsizehintrL r‚ r r r Ú readlines— s
z_ProxyFile.readlinesc c s | ¡ }|sd S |V q d S r )r{ )r r‚ r r r rE ¢ s z_ProxyFile.__iter__c C s | j S r )r¡ r= r r r rû ª s z_ProxyFile.tellr c C s4 |dkr| j | j¡ | j ||¡ | j ¡ | _d S )Nr¼ ©rí rn r¡ rû ©r ÚoffsetÚwhencer r r rn ® s z_ProxyFile.seekc C s0 t | dƒr,zt | jdƒr"| j ¡ W 5 | `X d S )Nrí rV )rO rí rV r= r r r rV µ s
z_ProxyFile.closec C s2 |d kr d}| j | j¡ ||ƒ}| j ¡ | _|S )Nrd r© )r r¥ Ú read_methodrL r r r r£ ¾ s z_ProxyFile._readc C s | S r r r= r r r Ú __enter__Ç s z_ProxyFile.__enter__c G s | ¡ d S r )rV )r Úexcr r r Ú__exit__Ë s z_ProxyFile.__exit__c C s
| j ¡ S r )rí Úreadabler= r r r r± Î s z_ProxyFile.readablec C s
| j ¡ S r )rí Úwritabler= r r r r² Ñ s z_ProxyFile.writablec C s
| j ¡ S r )rí Úseekabler= r r r r³ Ô s z_ProxyFile.seekablec C s
| j ¡ S r )rí rS r= r r r rS × s z_ProxyFile.flushc C s& t | dƒsdS t | jdƒs dS | jjS )Nrí Tr, F)rO rí r, r= r r r r, Ú s
z_ProxyFile.closed)N)N)N)N)N)r )r„ r… r† r! r^ r¦ r{ r¨ rE rû rn rV r£ r® r° r± r² r³ rS Úpropertyr, r r r r r¹ € s$
r¹ c @ s8 e Zd Zd
dd„Zdd„ Zddd„Zd d
„ Zd d „ ZdS )r Nc C s t | ||¡ || _|| _d S r )r¹ r! Ú_startÚ_stop)r r¶ r r r r r r! æ s z_PartialFile.__init__c C s t | ¡| j S r )r¹ rû rµ r= r r r rû ì s z_PartialFile.tellr c C s< |dkr| j | _d}n|dkr*| j| _d}t | ||¡ d S )Nr r¼ rà )rµ r¡ r¶ r¹ rn rª r r r rn ð s z_PartialFile.seekc C sB | j | j }|dkrdS |d ks0|dk s0||kr4|}t | ||¡S )Nr r )r¶ r¡ r¹ r£ )r r¥ r Z remainingr r r r£ ú s z_PartialFile._readc C s t | dƒr| `d S )Nrí )rO rí r= r r r rV s
z_PartialFile.close)NN)r )r„ r… r† r! rû rn r£ rV r r r r r ã s
r Tc
C s¦ d}zbt rpzt | t jt jB ¡ W nJ tk
rn } z,|jtjtjtjfkr\t d| j
ƒ‚n‚ W 5 d }~X Y nX |rfzt | j
d ƒ}| ¡ W nB tk
rÒ } z$|jtjtjfkrÀW Y ¢ W d S ‚ W 5 d }~X Y nX z`z t
|j
| j
d ¡ d}W n2 ttfk
r$ t
|j
| j
d ¡ d}Y nX t
|j
¡ W n0 tk
rd t
|j
¡ t d| j
ƒ‚Y nX W n8 t r„t | t j¡ |ršt
| j
d ¡ ‚ Y nX d S )NFzlockf: lock unavailable: %sú.lockTzdot lock unavailable: %s)ÚfcntlÚlockfZLOCK_EXZLOCK_NBr¦ r§ ZEAGAINrë rì r r˜ rü rV r r¢ r£ r¤ r¥ rJ rß r* ÚLOCK_UN)r¶ rù Z dotlock_doner¬ Zpre_lockr r r rõ
sL ÿ
ÿrõ c C s8 t rt | t j¡ tj | jd ¡r4t | jd ¡ d S )Nr· )r¸ r¹ rº r r rŽ r˜ r* ©r¶ r r r r÷ 4 s r÷ c C s< t | t jt jB t jB d¡}zt| dƒW ¢S t |¡ X d S )NrÉ ré )r r± rÊ r) ÚO_RDWRrV )r Úfdr r r rÞ ; s rÞ c C s$ t d| tt ¡ ƒt ¡ t ¡ f ƒS )Nz %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 | ¡ ¡ d S )NÚfsync)rS rO r r¾ Úfilenor» r r r rú I s
rú c C s t | ƒ | ¡ d S r )rú rV r» r r r r™ O s r™ c @ s e Zd ZdS )r Nr– r r r r r U s c @ s e Zd ZdS )r Nr– r r r r r X s c @ s e Zd ZdS )r Nr– r r r r r [ s c @ s e Zd ZdS )r Nr– r r r r r ^ s c @ s e Zd ZdS )r Nr– r r r r r a s )T)/r rÔ r“ rØ r§ rj rw r9 Z
email.messageZemail.generatorri r4 r¸ Ú ImportErrorÚ__all__rp rW r r rè r r r r r r& r r r r
r r r
r¹ r rõ r÷ rÞ rü rú r™ Ú Exceptionr r r r r r r r r Ú<module> s€
ý h 8 DB4- 3 z%mqH_c'
*