⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.91
Server IP:
57.129.66.90
Server:
Linux vps-7f548908 5.15.0-164-generic #174-Ubuntu SMP Fri Nov 14 20:25:16 UTC 2025 x86_64
Server Software:
LiteSpeed
PHP Version:
8.2.27
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
snap
/
core20
/
current
/
lib
/
python3.8
/
__pycache__
/
Edit File: mailbox.cpython-38.pyc
U >£hE3 ã @ sR d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Zddl Zddl Z ddl Z z 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.8/mailbox.pyÚ__init__$ s zMailbox.__init__c C s t dƒ‚dS )ú$Add message and return assigned key.ú&Method must be implemented by subclassN©ÚNotImplementedError©r Úmessager r r Úadd) s z Mailbox.addc C s t dƒ‚dS )ú=Remove the keyed message; raise KeyError if it doesn't exist.r" Nr# ©r Úkeyr r r Úremove- s zMailbox.removec C s | |¡ d S ©N)r+ r) r r r Ú __delitem__1 s zMailbox.__delitem__c C s( z| |¡ W n tk r" Y nX dS ©z'If the keyed message exists, remove it.N)r+ ÚKeyErrorr) r r r Údiscard4 s zMailbox.discardc C s t dƒ‚dS )ú>Replace the keyed message; raise KeyError if it doesn't exist.r" Nr# ©r r* r& r r r Ú __setitem__; s zMailbox.__setitem__c C s* z | |¡W S tk r$ | Y 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 sB | j s| |¡S t | |¡¡}| |¡W 5 Q R £ 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 r4 F s zMailbox.__getitem__c C s t dƒ‚dS )ú4Return a Message representation or raise a KeyError.r" Nr# r) r r r r7 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_bytesZ as_stringr) r r r Ú get_stringR s zMailbox.get_stringc C s t dƒ‚dS )z8Return a byte string representation or raise a KeyError.r" Nr# r) r r r r@ Y s zMailbox.get_bytesc C s t dƒ‚dS )ú6Return a file-like representation or raise a KeyError.r" Nr# r) r r r r: ] s zMailbox.get_filec C s t dƒ‚dS )ú Return an iterator over keys.r" Nr# ©r r r r Úiterkeysa s zMailbox.iterkeysc C s t | ¡ ƒS )zReturn a list of keys.)ÚlistrE rD r r r Úkeyse s z Mailbox.keysc c s> | ¡ D ]0}z | | }W n tk r0 Y qY nX |V qdS )z%Return an iterator over all messages.N©rE r/ ©r r* Úvaluer r r Ú itervaluesi s zMailbox.itervaluesc C s | ¡ S r, )rK rD r r r Ú__iter__r s zMailbox.__iter__c C s t | ¡ ƒS )z,Return a list of messages. Memory intensive.)rF rK rD r r r Úvaluesu s zMailbox.valuesc c sB | ¡ D ]4}z | | }W n tk r0 Y qY nX ||fV qdS )z.Return an iterator over (key, message) tuples.NrH rI r r r Ú iteritemsy s zMailbox.iteritemsc C s t | ¡ ƒS )z9Return a list of (key, message) tuples. Memory intensive.)rF rN rD r r r Úitems‚ s z Mailbox.itemsc C s t dƒ‚dS )ú9Return True if the keyed message exists, False otherwise.r" Nr# r) r r r Ú __contains__† s zMailbox.__contains__c C s t dƒ‚dS )ú*Return a count of messages in the mailbox.r" Nr# rD r r r Ú__len__Š s zMailbox.__len__c C s | ¡ D ]}| |¡ qdS )zDelete all messages.N)rG r0 r) r r r ÚclearŽ s z Mailbox.clearc C s4 z | | }W n t k r$ | Y S X | |¡ |S )z3Delete the keyed message and return it, or default.)r/ r0 )r r* r5 Úresultr r r Úpop“ s z Mailbox.popc C s* | ¡ D ]}|| |¡f S tdƒ‚dS )z6Delete an arbitrary (key, message) pair and return it.zNo messages in mailboxN)rE rV 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ƒ‚dS )z4Change the messages that correspond to certain keys.rN rO FTzNo message with key(s)N)ÚhasattrrN rO r/ )r ÚargÚsourceZbad_keyr* r& r r r Úupdate£ s zMailbox.updatec C s t dƒ‚dS )ú&Write any pending changes to the disk.r" Nr# rD r r r Úflush´ s z Mailbox.flushc C s t dƒ‚dS )úLock the mailbox.r" Nr# rD r r r Úlock¸ s z Mailbox.lockc C s t dƒ‚dS )ú#Unlock the mailbox if it is locked.r" Nr# rD r r r Úunlock¼ s zMailbox.unlockc C s t dƒ‚dS )ú Flush and close the mailbox.r" Nr# rD 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 )z%Dump message contents to target file.r ó ú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 insteadNó éþÿÿÿó éÿÿÿÿó From s >From é úInvalid message type: %s) Ú isinstancer> r& r ÚioÚBytesIOÚ generatorÚBytesGeneratorÚflattenÚseekrk ÚreplaceÚlinesepÚwriteÚ_append_newlineÚendswithÚstrÚbytesÚStringIOÚwarningsÚwarnÚDeprecationWarningÚgetvaluerg rX rl ÚreadlineÚ startswithÚ TypeErrorÚtype) r r& ÚtargetZ mangle_from_rl ÚgenÚdataZlastlineÚliner r r Ú _dump_messageÑ s` ÿ ÿ zMailbox._dump_message)NT)N)N)N)F)$Ú__name__Ú __module__Ú __qualname__Ú__doc__r r' r+ r- r0 r3 r6 r4 r7 rA r@ r: rE rG rK rL rM rN rO rQ rS rT rV rW r[ r] r_ ra rc rg r r 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¡ | j ¡ D ]}t |d¡ qln t | jƒ‚i | _ dddœ| _ d| _ d| _d S ) z Initialize a Maildir instance.ÚtmpÚnewÚcur)r– r— r˜ éÀ r )r˜ r— gš™™™™™¹?N)r r r r Újoinr Ú_pathsÚexistsÚmkdirrM 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 )r! Ú r— r z$Name clash with existing message: %sN) Ú _create_tmpr Ú BaseExceptionrc r r+ ÚnameÚ _sync_closeru 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| |¡¡¡ dS ©r( N)r r+ r rš r Ú_lookupr) r r r r+ K s zMaildir.removec C s, z| |¡ W n ttfk r& Y nX dS r. )r+ r/ ÚFileNotFoundErrorr) r r r r0 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 )r1 rq r£ N)r¼ r' ru r r r r¢ r© r¬ r0 rš r r r® r¯ r³ ) r r* r& Z old_subpathZtemp_keyZ temp_subpathZdominant_subpathr¶ r· Ztmp_pathÚnew_pathr r r r3 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 )r< Úrbrq )r¼ Úopenr r rš r r r r¬ Ú set_subdirr© Úset_infoÚset_dateÚgetmtime)r r* ZsubpathÚfÚmsgr¶ r¦ r r r r7 r s zMaildir.get_messagec C sD t tj | j| |¡¡dƒ }| ¡ td¡W 5 Q R £ S Q R X dS )ú2Return a bytes representation or raise a KeyError.r¿ rh N) rÀ r r rš r r¼ rk r| r} ©r r* rÅ r r r r@ s zMaildir.get_bytesc C s$ t tj | j| |¡¡dƒ}t|ƒS )rB r¿ )rÀ r r rš r r¼ Ú _ProxyFilerÈ r r r r: † s zMaildir.get_filec c sF | ¡ | jD ]2}z| |¡ W n tk r8 Y qY nX |V qdS ©rC N)Ú_refreshrž r¼ r/ r) r r r rE ‹ s zMaildir.iterkeysc C s | ¡ || jkS ©rP )rË rž r) r r r rQ • s zMaildir.__contains__c C s | ¡ t| jƒS ©rR )rË Úlenrž rD r r r rS š s zMaildir.__len__c C s dS )ú"Write any pending changes to disk.Nr rD r r r r] Ÿ s z Maildir.flushc C s dS )r^ Nr rD r r r r_ ¥ s z Maildir.lockc C s dS )r` Nr rD r r r ra © s zMaildir.unlockc C s dS ©rb Nr rD r r r rc s z Maildir.closec C s\ g }t | j¡D ]F}t|ƒdkr|d dkrt j t j | j|¡¡r| |dd… ¡ q|S )ú Return a list of folder names.é r Ú.N)r Úlistdirr rÎ r Úisdirrš Úappend©r rU Ú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 maildirfolderé¶ ) r r rš r r r rœ rc rÀ ÚO_CREATÚO_WRONLY)r rÜ r rU 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 ) ú-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Ø Ú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 dS )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|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 ) 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: %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 kr^d}| jD ]2}tj | j| ¡}|| j| krJd}|| j|< q"|s^dS i | _| jD ]^}| j| }t |¡D ]D}tj ||¡}tj |¡r¢q‚| | j ¡d }tj ||¡| j|< q‚qjt ¡ | _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€ 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 dS )z=Use TOC to return subpath for given key, or raise a KeyError.úNo message with key: %sN)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 dS tk rP Y qY qX qdS )z0Return the next message in a one-time iteration.Ú _onetime_keysN)rX rE rû ÚnextÚ StopIterationr/ rD r r r rü 1 s z Maildir.next)NT) r‘ r’ r“ r” r© r r' r+ r0 r3 r7 r@ r: rE rQ rS r] r_ ra rc 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 | |||¡ 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| _dS )z!Initialize a single-file mailbox.úrb+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 )r! rÒ T)r¼ Ú_append_messagerž r r r% r r r r' X s z_singlefileMailbox.addc C s | |¡ | j|= d| _dS )r( TN)r¼ rž r r) r r r r+ b s z_singlefileMailbox.removec C s$ | |¡ | |¡| j|< d| _dS )r1 TN)r¼ r rž r r2 r r r r3 h s z _singlefileMailbox.__setitem__c c s | ¡ | j ¡ E dH dS rÊ )r¼ rž rG rD r r r rE n s z_singlefileMailbox.iterkeysc C s | ¡ || jkS rÌ )r¼ rž r) r r r rQ s s z _singlefileMailbox.__contains__c C s | ¡ t| jƒS rÍ )r¼ rÎ rž rD r r r rS x s z_singlefileMailbox.__len__c C s | j st| jƒ d| _ dS )r^ TN)r Ú _lock_filer rD r r r r_ } s z_singlefileMailbox.lockc C s | j rt| jƒ d| _ dS ©r` FN)r Ú _unlock_filer rD r r r ra ƒ 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 ƒ}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 dS ) rÏ FNr r÷ z4Size of mailbox file changed (expected %i, found %i)é rÿ )Údotlock)!r r Ú _sync_flushr rž ÚAssertionErrorr{ Útellr r Ú_create_temporaryr Ú_pre_mailbox_hookÚsortedrG Ú_pre_message_hookrk Úminr~ Ú_post_message_hookrc r r+ r¦ r§ rô Úst_modeÚchmodr³ rö rÀ r r ) r Zcur_lenZnew_fileZnew_tocr* ÚstartÚstopZ new_startrl Úmoder r r r] ‰ sb þ ÿ z_singlefileMailbox.flushc C s dS )ú,Called before writing the mailbox to file f.Nr ©r rÅ r r r r É s z$_singlefileMailbox._pre_mailbox_hookc C s dS )ú-Called before writing each message to file f.Nr r r r r r Í s z$_singlefileMailbox._pre_message_hookc C s dS ©ú,Called after writing each message to file f.Nr r r r r r Ñ s z%_singlefileMailbox._post_message_hookc C s4 z | ¡ W 5 z| jr | ¡ W 5 | j ¡ X X dS rÐ )r rc r ra r] rD r r r rc Õ s z_singlefileMailbox.closec C sN | j dkr| ¡ |dk rJz | j | W S tk rH td| ƒd‚Y nX dS )z'Return (start, stop) or raise KeyError.Nrú )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 )z;Append message to mailbox and return (start, stop) offsets.r r÷ )r r{ r rÎ rž r r r Ú_install_messager r¥ Útruncater] r )r r& ZbeforeZoffsetsr r r r ê s z"_singlefileMailbox._append_message)NT)N)r‘ r’ r“ r” r r' r+ r3 rE rQ rS r_ ra r] r r r rc 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 )r< ó rh rs Nr ) r¼ r r{ rˆ r| r} rk r Ú_message_factoryÚset_fromÚdecode)r r* r r Ú from_lineÚstringrÆ r r r r7 s z_mboxMMDF.get_messageFc C s t | ||¡¡j|dS )ú3Return a string representation or raise a KeyError.)Úunixfromr= )r r* Úfrom_r r r rA s ÿÿz_mboxMMDF.get_stringc C sJ | |¡\}}| j |¡ |s(| j ¡ | j || j ¡ ¡}| td¡S )r, rh )r¼ r r{ rˆ rk r r| r} )r r* r. r r r+ r r r r@ s z_mboxMMDF.get_bytesc C s< | |¡\}}| j |¡ |s(| j ¡ t| j| j ¡ |ƒS )rB )r¼ r r{ rˆ Ú _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.Nrr rh rq rÒ r& r s From MAILER-DAEMON )ru r rg r‚ r‰ ÚfindÚ_mboxMMDFMessageÚget_fromrd r> r& r Ú get_unixfromrë ÚasctimeÚgmtimer r r~ r} r Ú _mangle_from_)r r& r* ÚnewlineZauthorr r r r r r# & s0 z_mboxMMDF._install_messageN)F)F)F) r‘ r’ r“ r” r6 r7 rA r@ 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 L s z mbox.__init__c C s | t¡ dS r ©r~ r} 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 ¡ | _ dS )ú0Generate key-to-(start, stop) table of contents.Fr rr TN)r r{ r rˆ r‰ rÎ rÖ r} Ú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” r6 r 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 z s z MMDF.__init__c C s | dt ¡ dS )r ó Nr8 r r r r r s zMMDF._pre_message_hookc C s | td t ¡ dS )r! r@ Nr8 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 ¡ | _ dS )r9 r r@ r÷ N)r r{ rˆ r r‰ r} 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 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.r™ ú .mh_sequencesi€ FN)r r r r rœ r r rc 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 )r! r rÒ FT)rG rÎ Úmaxr r rš r r rõ r§ r r r r r¥ r+ ru r Ú_dump_sequences)r r& rG 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 |¡ dS )r( rÿ rú N) r r rš r r rÀ r´ rµ r r/ rc 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 dS )r1 rÿ rú N)r r rš r r rÀ r´ rµ r r/ r§ r r r rc rá ÚO_TRUNCr ru r rE )r r* r& r rÅ rº r r r r3 ã 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 )r< rÿ r¿ rú N)r rÀ r r rš r r r´ rµ r r/ r r r Ú get_sequencesrO Ú add_sequence)r r* rÅ rº rÆ r¦ Úkey_listr r r r7 û 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 dS )rÇ rÿ r¿ rú Nrh )r rÀ r r rš r r r´ rµ r r/ r r rk r| r} ©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 )rB r¿ rú N) rÀ r r rš r r r´ rµ r r/ rÉ rK r r r r: ) s z MH.get_filec C s t tdd„ t | j¡D ƒƒƒS )rC c s s | ]}| ¡ rt|ƒV qd S r, )Úisdigitrñ )Ú.0rØ r r r Ú <genexpr>6 s ÿz MH.iterkeys.<locals>.<genexpr>)Úiterr r rÔ r rD r r r rE 4 s z MH.iterkeysc C s t j t j | jt|ƒ¡¡S rÌ )r r rœ rš r r r) r r r rQ 9 s zMH.__contains__c C s t t| ¡ ƒƒS rÍ )rÎ rF rE rD r r r rS = s z MH.__len__c C s2 | j s.ttj | jd¡dƒ| _t| jƒ d| _ dS )r^ rB rÿ TN)r rÀ r r rš r r r rD r r r r_ A s zMH.lockc C s( | j r$t| jƒ t| jƒ | `d| _ dS r )r r r r§ rD r r r ra H s z MH.unlockc C s dS )r\ Nr rD r r r r] P s zMH.flushc C s | j r| ¡ dS rÐ )r ra rD r r r rc 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 )z+Return an MH instance for the named folder.FrÚ ©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Þ rP 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 )rã rB zFolder 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| ¡ ƒ‰ |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 )z=Return a name-to-key-list dictionary to define each sequence.rB ÚrÚASCII©Úencodingr• c s s | ]}t |ƒV qd S r, )rñ )rM Úxr r r rN „ s z#MH.get_sequences.<locals>.<genexpr>ú-rÒ c s g | ]}|ˆ kr|‘qS r r )rM r* ©Zall_keysr r Ú <listcomp>† s ÿz$MH.get_sequences.<locals>.<listcomp>r z"Invalid sequence specification: %s)rÀ r r rš r ÚsetrG r¬ rL r' rñ r[ Úranger rÎ rf r Úrstrip) r ZresultsrÅ r r¦ ÚcontentsrG Úspecr r r rX r rH 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 dS )z:Set sequences using the given name-to-key-list dictionary.rB zr+rS rT r r• NFrÒ TrW z%s %sz %sÚ )rÀ r r rš r r§ rc r¦ rá rG rO rÎ r~ r rZ r )r Ú sequencesrÅ r¦ rG Ú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ödS | ¡ D ]0\}}|D ]"\}}||kr ||| |¡< q qþ| |¡ dS )z?Re-name messages to eliminate numbering gaps. Invalidates keys.r rÒ N)rH rE rÖ r r° r rš r r r± r² r³ Úunlinkr rÎ rO Úindexrb ) r r` ra Zchangesr* r¦ rJ Úoldr— r r r Úpack¬ s0 ÿÿ zMH.packc C st | ¡ }| ¡ }| ¡ D ]0\}}||kr4| |¡ q||kr|| |¡= q|D ]}||krN|g||< qN| |¡ dS )z;Inspect a new MHMessage and update sequences appropriately.N)rH rO rÖ rd rb )r r& r* Zpending_sequencesZ all_sequencesr¦ rJ Úsequencer r r rE Æ s zMH._dump_sequences)NT)r‘ r’ r“ r” r r' r+ r3 r7 r@ r: rE rQ rS r_ ra r] rc rÙ rÝ râ rê rH rb rf rE 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 Ú_labelsr r r r r Û s zBabyl.__init__c C s( t | |¡}t|tƒr$| ¡ | j|< |S )r! )rþ r' ru r Ú get_labelsrm )r r& r* r r r r' à s z Babyl.addc C s" t | |¡ || jkr | j|= dS r» )rþ r+ rm r) r r r r+ ç s z Babyl.removec C s* t | ||¡ t|tƒr&| ¡ | j|< dS )r1 N)rþ r3 ru r rn rm r2 r r r r3 í s zBabyl.__setitem__c C sþ | |¡\}}| j |¡ | j ¡ t ¡ }| j ¡ }|dt ks\|sHq\| | td¡¡ q,t ¡ }| j ¡ }|tks|s|q| | td¡¡ qd|| j ¡ }|dksªt ‚| j |¡}| td¡}t | ¡ | ƒ} | | ¡ ¡ || jkrú| | j| ¡ | S )r< ó *** EOOH ***rh r )r¼ r r{ rˆ rv rw r} r~ r| r r rk r r‡ Ú set_visiblerm Ú set_labels) r r* r r Úoriginal_headersr Zvisible_headersÚnZbodyrÆ r r r r7 ó s, zBabyl.get_messagec C s¸ | |¡\}}| j |¡ | j ¡ t ¡ }| j ¡ }|dt ks\|sHq\| | td¡¡ q,| j ¡ }|tksv|s\qvq\| ¡ }|| j ¡ }|dks˜t ‚| j |¡}| td¡}|| S )r, ro rh r ) r¼ r r{ rˆ rv rw r} r~ r| r‡ r r rk ) r r* r r rr r Zheadersrs rŽ r r r r@ s" zBabyl.get_bytesc C s t | |¡ dt¡¡S )rB rh )rv rw r@ r| r} r) r r r r: % s zBabyl.get_filec C s< | ¡ tƒ }| j ¡ D ]}| |¡ q| | j¡ t|ƒS )z4Return a list of user-defined labels in the mailbox.)r¼ rZ rm rM r[ Údifference_updateÚ_special_labelsrF )r ÚlabelsZ label_listr r r rn ) 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 ¡ | _dS ) r9 r s c S s g | ]}| ¡ r| ¡ ‘qS r )Ústrip©rM Úlabelr r r rY @ s þz'Babyl._generate_toc.<locals>.<listcomp>rÒ Nó ,ó r÷ )r r{ rˆ r r} rÎ rÖ r¬ r: r; r< rž rm r r )r r= r> rA Z label_listsr? r rv r r r r" 2 s4 ÿ 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, )rd rx r r r rN U s z*Babyl._pre_mailbox_hook.<locals>.<genexpr>s Labels:rz r{ N)r} rn rš r~ )r rÅ Zbabylrv r r r r P s zBabyl._pre_mailbox_hookc C s | dt ¡ dS )r ó Nr8 r r r r r Z s zBabyl._pre_message_hookc C s | td ¡ dS )r! r{ Nr8 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|dd… d }n | "d¡rˆ|dd… d }| j | d t ¡¡ |d ks¬|sF|rÚd}| j d t ¡ | | ¡ nqÚqF| ¡ }|sìqf| "d¡r |dd… t }n:| "d¡r(|dd… t }n | "d ¡rD|dd… t }| j |¡ qÚnt#dt$|ƒ ƒ‚| j ¡ }||fS )z0Write message contents and return (start, stop).ó 1s , s ,,ó rz s 1,,Fr rh ro r ri rj s r÷ rq Nrˆ rl rm Trn ro rp rt )%r r ru r rn ru rÖ r~ rd r} r> r& r rv rw rx ry rz r{ rˆ r| Ú get_visiblerk r‚ r rƒ r„ r… r† r‡ rg r0 rX rl r€ rŠ r‹ )r r& r Zspecial_labelsrv ry Z orig_bufferZorig_generatorr Z vis_bufferZ vis_generatorrl Z body_startZ original_posZ first_passr r r r r# b s¼ ÿ ÿ zBabyl._install_message)NT)r‘ r’ r“ r” Ú frozensetru r r' r+ r3 r7 r@ r: rn 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.rk Nrt )ru r> r& r Ú_become_messageÚcopyZdeepcopyÚ _explain_tor‚ r? r Zmessage_from_stringrv Ú TextIOWrapperZmessage_from_filerX Zmessage_from_binary_filer rŠ r‹ r% r r r r Ñ s zMessage.__init__c C s4 t |dg ƒ}|jD ] }||kr|j| | j|< qdS )z0Assume the non-format-specific state of message.Ú_type_specific_attributesN)ÚgetattrÚ__dict__)r r& Z type_specificr¦ r r r r ä 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)ru r rŠ r% r r r rƒ ë s zMessage._explain_to)N)r‘ r’ r“ r” r r rƒ 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)rˆ r‰ rë rŠ r r r% r r r r ø s zMaildirMessage.__init__c C s | j S )zReturn 'new' or 'cur'.)rˆ rD 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)rˆ rf )r r¶ r r r rÁ s zMaildirMessage.set_subdirc C s" | j d¡r| j dd… S dS dS )ú*Return as a string the flags that are set.ú2,r÷ Nr£ )r‰ r‰ rD 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š r r‰ )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©r rš rZ r ©r Úflagr r r Úadd_flag s zMaildirMessage.add_flagc C s, | ¡ r(| d t| ¡ ƒt|ƒ ¡¡ dS )ú7Unset the given string flag(s) without changing others.r£ N)r r rš rZ r“ r r r Ú remove_flag s zMaildirMessage.remove_flagc C s | j S )z<Return delivery date of message, in seconds since the epoch.)rŠ rD r r r r¯ s zMaildirMessage.get_datec C s6 zt |ƒ| _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)ÚfloatrŠ rf rŠ )r Údater r r rà " s zMaildirMessage.set_datec C s | j S )z%Get the message's "info" as a string.)r‰ rD 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)ru r r‰ 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|ƒ ƒ‚dS )z;Copy Maildir-specific state to message insofar as possible.ÚSÚRr˜ ÚOÚTÚDÚFÚAú MAILER-DAEMONrh ÚrepliedÚflaggedri rj ÚPrk ú$Cannot convert to specified type: %sN)ru r r r rÁ r¨ rà r¯ r1 rZ r• r( rë r5 r rI r Ú add_labelr rŠ r‹ )r r& r r r r rƒ 4 sP ÿzMaildirMessage._explain_to)N)r‘ r’ r“ r” r… r r¨ rÁ r r r• r— r¯ rà rª r rƒ 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 )r1 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.r¢ TNzFrom rs )r( ru r> r& r r3 r‰ 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¨ rD r r r r2 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ë r5 r4 r¨ )r r. Ztime_r r r r( r s z_mboxMMDFMessage.set_fromc C s | dd¡| dd¡ S )r‹ ÚStatusr£ úX-Status)r6 rD r r r r 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 dS )rŽ )r£ r£ )rœ r )rŸ r r¡ r£ rª r« N)rZ r+ rš r Úreplace_headerr/ Z add_header)r r Z status_flagsZ xstatus_flagsr” r r r r ~ s& z_mboxMMDFMessage.set_flagsc C s$ | d t| ¡ ƒt|ƒB ¡¡ dS r‘ r’ r“ r r r r• ” s z_mboxMMDFMessage.add_flagc C s4 d| ksd| kr0| d t| ¡ ƒt|ƒ ¡¡ dS )r– rª r« r£ Nr’ r“ 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 )zACopy mbox- or MMDF-specific state to message insofar as possible.r r˜ r r¡ rœ r› rŸ rž Zstatuszx-statusr© éûÿÿÿNz%a %b %d %H:%M:%S %Yrh r£ r¤ ri rj r¦ )ru r rZ r rÁ r• rš r2 r¬ rà ÚcalendarZtimegmrë Ústrptimerf Ú OverflowErrorr1 r r( r rI r r§ r rŠ r‹ )r r& r Z maybe_dater r r rƒ sb ÿ ÿz _mboxMMDFMessage._explain_to)N)N) r‘ r’ r“ r” r… r r2 r( r r r• r— rƒ r r r r r1 ` s r1 c @ s e Zd ZdZdS )r z&Message with mbox-specific properties.N©r‘ r’ r“ r” 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)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)r² rD r r r rH ß s zMHMessage.get_sequencesc C s t |ƒ| _dS )z3Set the list of sequences that include the message.N)rF r² )r r` r r r rb ã 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)ru r r² rÖ rŠ r‹ ©r rg r r r rI ç s zMHMessage.add_sequencec C s* z| j |¡ W n tk r$ Y nX dS )zARemove sequence from the list of sequences including the message.N)r² r+ rf 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 )z6Copy MH-specific state to message insofar as possible.rh r˜ r› r¤ r r£ rœ ÚROr r¡ rj r¦ N)ru r rZ rH rÁ r• r1 r rI r r§ r rŠ r‹ )r r& r` rg r r r rƒ ö sB ÿzMHMessage._explain_to)N) r‘ r’ r“ r” r… r rH rb rI r´ rƒ 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.rm Ú_visibleNc C s g | _ tƒ | _t | |¡ dS )z#Initialize a BabylMessage instance.N)rm r 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)rm rD r r r rn ( s zBabylMessage.get_labelsc C s t |ƒ| _dS )z&Set the list of labels on the message.N)rF rm )r rv r r r rq , 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)ru r rm rÖ rŠ r‹ ©r ry r r r r§ 0 s zBabylMessage.add_labelc C s* z| j |¡ W n tk r$ Y nX dS )z4Remove label from the list of labels on the message.N)rm r+ rf r· r r r Ú remove_label8 s zBabylMessage.remove_labelc C s t | jƒS )z3Return a Message representation of visible headers.©r r¶ rD r r r r ? s zBabylMessage.get_visiblec C s t |ƒ| _dS )z2Set the Message representation of visible headers.Nr¹ )r Zvisibler r r rp C s zBabylMessage.set_visiblec C sb | j ¡ D ](}|| kr*| j || | ¡ q | j |= q dD ]$}|| kr8|| j kr8| | | j |< q8dS )z9Update and/or sensibly generate a set of visible headers.)ZDateZFromzReply-ToZToZCCZSubjectN)r¶ rG 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|ƒ ƒ‚dS )z9Copy Babyl-specific state to message insofar as possible.rh r˜ r› rk rl r¥ rj rœ ri rž rµ r rŸ r¡ r£ r¦ N)ru r rZ rn rÁ r• r1 r rI r rp r r§ r rŠ r‹ )r r& rv ry r r r rƒ R sH ÿzBabylMessage._explain_to)N)r‘ r’ r“ r” r… r rn rq r§ r¸ r rp r» rƒ r r r r r s c @ s e Zd ZdZdS )r z&Message with MMDF-specific properties.Nr± 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 rk ©r Úsizer r r rk ‹ s z_ProxyFile.readc C s | || jj¡S r¾ )r¿ r Úread1rÀ r r r r s z_ProxyFile.read1c C s | || jj¡S )z Read a line.)r¿ r rˆ rÀ r r r rˆ “ s z_ProxyFile.readlinec C s< g }| D ].}| |¡ |dk r|t|ƒ8 }|dkr q8q|S )zRead multiple lines.Nr )rÖ rÎ )r ÚsizehintrU r r r r Ú readlines— s z_ProxyFile.readlinesc c s | ¡ }|sdS |V q dS )zIterate over lines.N)rˆ )r r r r r rL ¢ s z_ProxyFile.__iter__c C s | j S )zReturn the position.)r¼ rD r r r r ª s z_ProxyFile.tellr c C s4 |dkr| j | j¡ | j ||¡ | j ¡ | _dS )zChange position.rÒ N©r r{ r¼ r ©r ÚoffsetÚwhencer r r r{ ® s z_ProxyFile.seekc C s0 t | dƒr,zt | jdƒr"| j ¡ W 5 | `X dS )zClose the file.r rc N)rX r rc rD r r r rc µ s z_ProxyFile.closec C s2 |dkr d}| j | j¡ ||ƒ}| j ¡ | _|S )z"Read size bytes using read_method.Nrq rÅ )r rÁ Ú read_methodrU r r r r¿ ¾ s z_ProxyFile._readc C s | S )z$Context management protocol support.r rD r r r Ú __enter__Ç s z_ProxyFile.__enter__c G s | ¡ d S r, )rc )r Úexcr r r Ú__exit__Ë s z_ProxyFile.__exit__c C s | j ¡ S r, )r ÚreadablerD r r r rÍ Î s z_ProxyFile.readablec C s | j ¡ S r, )r ÚwritablerD r r r rÎ Ñ s z_ProxyFile.writablec C s | j ¡ S r, )r ÚseekablerD r r r rÏ Ô s z_ProxyFile.seekablec C s | j ¡ S r, )r r] rD r r r r] × s z_ProxyFile.flushc C s& t | dƒsdS t | jdƒs dS | jjS )Nr TrF F)rX r rF rD r r r rF Ú s z_ProxyFile.closed)N)N)N)N)N)r )r‘ r’ r“ r” r rk r rˆ rÄ rL r r{ rc r¿ rÊ rÌ rÍ rÎ rÏ r] ÚpropertyrF 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Ñ rD 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Ñ r¼ rÒ rÉ r{ rÆ 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Ò r¼ rÉ r¿ )r rÁ rÉ Z remainingr r r r¿ ú s z_PartialFile._readc C s t | dƒr| `d S )Nr )rX r rD r r r rc s z_PartialFile.close)NN)r ) r‘ r’ r“ r” r r r{ r¿ rc 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 dS ‚ 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 dS )z(Lock file f using lockf and dot locking.Fzlockf: lock unavailable: %sNú.lockTzdot lock unavailable: %s)ÚfcntlÚlockfZLOCK_EXZLOCK_NBr´ rµ ZEAGAINr r r r¦ r rc r r° r± r² r³ rc 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 ¡ dS )z*Unlock file f using lockf and dot locking.rÓ N)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 dS )zCCreate a file if it doesn't exist and open for reading and writing.rß rÿ N)r rÀ rà rC ÚO_RDWRrc )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)r] rX r rÚ Úfilenor× 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 rc r× r r r r§ O s r§ c @ s e Zd ZdZdS )r z"Raised for module-specific errors.Nr± 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.Nr± r r r r r X s c @ s e Zd ZdZdS )r z>The specified mailbox is not empty and deletion was requested.Nr± r r r r r [ s c @ s e Zd ZdZdS )r z)Another process caused an action to fail.Nr± r r r r r ^ s c @ s e Zd ZdZdS )r z)A file appears to have an invalid format.Nr± r r r r r a s )T)0r” r rë r® rï rµ r‚ r„ r> Z email.messageZemail.generatorrv r8 rÔ Ú ImportErrorÚ__all__r} rd r r rþ r% r r r r r& r r r1 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' *
Simpan