Server : Apache/2.4.52 (Ubuntu) System : Linux webserver 6.8.0-49-generic #49~22.04.1-Ubuntu SMP PREEMPT_DYNAMIC Wed Nov 6 17:42:15 UTC 2 x86_64 User : www-data ( 33) PHP Version : 8.1.2-1ubuntu2.21 Disable Function : NONE Directory : /lib/python3.10/__pycache__/ |
o
�*�g�3 � @ s> d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Zddl
Zddl Z ddl Z ddl
mZ zddlZW n eyI dZY nw g d�Zej�d�ZG dd� d�ZG dd � d e�ZG d
d � d e�ZG d d
� d
e�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� dej j �Z G dd� de �Z G dd� de �Z G d d � d e �Z G d d � d e �Z!G d d!� d!e �Z"G d"d#� d#e �Z#G d$d%� d%�Z$G d&d'� d'e$�Z%d?d)d*�Z&d+d,� Z'd-d.� Z(d/d0� Z)d1d2� Z*d3d4� Z+G d5d6� d6e,�Z-G d7d8� d8e-�Z.G d9d:� d:e-�Z/G d;d<� d<e-�Z0G d=d>� d>e-�Z1dS )@zDRead/write support for Maildir, mbox, MH, Babyl, and MMDF mailboxes.� N)� GenericAlias)�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/� ZdDd0d1�Zd2d3� ZdDd4d5�Z d6d7� Z d8d9� Z d:d;� Z d<d=� Z d>d?� Z!d@Z"dEdAdB�Z#e$e%�Z&dS )Fr 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.10/mailbox.py�__init__% s
zMailbox.__init__c C � t d��)�$Add message and return assigned key.�&Method must be implemented by subclass��NotImplementedError�r �messager r r �add* � z Mailbox.addc C r" )�=Remove the keyed message; raise KeyError if it doesn't exist.r$ r% �r �keyr r r �remove. r* zMailbox.removec C s | � |� d S �N)r. r, r r r � __delitem__2 s zMailbox.__delitem__c C s& z| � |� W dS ty Y dS w �z'If the keyed message exists, remove it.N)r. �KeyErrorr, r r r �discard5 s
�zMailbox.discardc C r" )�>Replace the keyed message; raise KeyError if it doesn't exist.r$ r% �r r- r( r r r � __setitem__< r* zMailbox.__setitem__c C s$ z| � |�W S ty | Y S w )z9Return the keyed message, or default if it doesn't exist.)� __getitem__r2 )r r- �defaultr r r �get@ s
�z Mailbox.getc C sN | j s| �|�S t�| �|���
}| � |�W d � S 1 s w Y dS )z=Return the keyed message; raise KeyError if it doesn't exist.N)r � get_message�
contextlib�closing�get_file)r r- �filer r r r7 G s
$�zMailbox.__getitem__c C r" )�4Return a Message representation or raise a KeyError.r$ r% r, r r r r: O r* zMailbox.get_messagec C s t �| �|���� S )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_stringr, r r r �
get_stringS s zMailbox.get_stringc C r" )z8Return a byte string representation or raise a KeyError.r$ r% r, r r r rC Z r* zMailbox.get_bytesc C r" )�6Return a file-like representation or raise a KeyError.r$ r% r, r r r r= ^ r* zMailbox.get_filec C r" )� Return an iterator over keys.r$ r% �r r r r �iterkeysb r* zMailbox.iterkeysc C � t | �� �S )zReturn a list of keys.)�listrI rH r r r �keysf � z Mailbox.keysc c s: � | � � D ]}z| | }W n ty Y qw |V qdS )z%Return an iterator over all messages.N�rI r2 �r r- �valuer r r �
itervaluesj s � ��zMailbox.itervaluesc C s | � � S r/ )rQ rH r r r �__iter__s s zMailbox.__iter__c C rJ )z,Return a list of messages. Memory intensive.)rK rQ rH r r r �valuesv rM zMailbox.valuesc c s> � | � � D ]}z| | }W n ty Y qw ||fV qdS )z.Return an iterator over (key, message) tuples.NrN rO r r r � iteritemsz s � � �zMailbox.iteritemsc C rJ )z9Return a list of (key, message) tuples. Memory intensive.)rK rT rH r r r �items� rM z
Mailbox.itemsc C r" )�9Return True if the keyed message exists, False otherwise.r$ r% r, r r r � __contains__� r* zMailbox.__contains__c C r" )�*Return a count of messages in the mailbox.r$ r% rH r r r �__len__� r* zMailbox.__len__c C s | � � D ]}| �|� qdS )zDelete all messages.N)rL r3 r, r r r �clear� s �z
Mailbox.clearc C s2 z| | }W n t y | Y S w | �|� |S )z3Delete the keyed message and return it, or default.)r2 r3 )r r- r8 �resultr r r �pop� s �
z Mailbox.popc C s& | � � D ]
}|| �|�f S td��)z6Delete an arbitrary (key, message) pair and return it.zNo messages in mailbox)rI r\ r2 r, r r r �popitem� s zMailbox.popitemc C sp t |d�r
|�� }n t |d�r|�� }n|}d}|D ]\}}z|| |< W q ty/ d}Y qw |r6td��dS )z4Change the messages that correspond to certain keys.rT rU FTzNo message with key(s)N)�hasattrrT rU r2 )r �arg�source�bad_keyr- r( r r r �update� s
��zMailbox.updatec C r" )�&Write any pending changes to the disk.r$ r% rH r r r �flush� r* z
Mailbox.flushc C r" )�Lock the mailbox.r$ r% rH r r r �lock� r* z Mailbox.lockc C r" )�#Unlock the mailbox if it is locked.r$ r% rH r r r �unlock� r* zMailbox.unlockc C r" )� Flush and close the mailbox.r$ r% rH r r r �close� r* z
Mailbox.closec C s$ z|� d�W S ty td��w )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�r?t�� }tj�||d�}|�|� |� d� |�
� }|� dt �}|�
|� | jr;|�t �s=|�
t � d
S d
S d
S t |tttjf�r�t |tj�rYt�dtd� |�� }t |t�rc| �|�}|rk|� dd�}|� dt �}|�
|� | jr�|�t �s�|�
t � d
S d
S d
S t|d�r�t|d�r�t�d td� |j}d
} |�� }|�d �r�|d
d
� d }n
|�d�r�|d
d� d }|s�n |r�|�d�r�d|dd
� }|� dt �}|�
|� |}q�| jr�|r�|�t �s�|�
t � d
S d
S d
S d
S t dt |� ��)z%Dump message contents to target file.r �
�8Use of StringIO input is deprecated, use BytesIO instead� s
From s
>From �read�buffer�DUse of text mode files is deprecated, use a binary mode file insteadNT�
����
���� From s >From � �Invalid message type: %s) �
isinstancerA r( r �io�BytesIO� generator�BytesGenerator�flatten�seekrr �replace�linesep�write�_append_newline�endswith�str�bytes�StringIO�warnings�warn�DeprecationWarning�getvaluern r^ rs �readline�
startswith� TypeError�type) r r( �target� mangle_from_rs �gen�data�lastline�liner r r �
_dump_message� sf
� �
�
�
� �zMailbox._dump_message�NTr/ �F)'�__name__�
__module__� __qualname__�__doc__r! r) r. r0 r3 r6 r9 r7 r: rE rC r= rI rL rQ rR rS rT rU rW rY rZ r\ r] rb rd rf rh rj rn r� r� � classmethodr �__class_getitem__r r r r r " sF
6r c @ s� e Zd 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�sE|r@t�| jd� | j� � D ]}t�|d� q6nt
| 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�mkdirrS r �_toc� _toc_mtimes�
_last_read� _skewfactor)r �dirnamer r r r r r r! s ��
zMaildir.__init__c
C sf | � � }z| �||� W n ty |�� t�|j� � w t|� t|t �r;|�
� }| j |� � }|| j kr:d}nd}d}tj
�|j��| j �d }tj
�| j||| �}t|t �rlt�|jtj
�|j�|�� f� z'z t�|j|� W n ttfy� t�|j|� Y W |S w t�|j� W |S ty� } zt�|j� |jtjkr�t d| ��� d}~ww )r# � r� r z$Name clash with existing message: %sN) � _create_tmpr� �
BaseExceptionrj r r. �name� _sync_closer| r
�
get_subdir�colon�get_infor �basename�splitr� r �utime�getatime�get_date�link�AttributeError�PermissionError�rename�OSError�errno�EEXISTr )r r( �tmp_file�subdir�suffix�uniq�dest�er r r r) $ sR �
�
�
�� ���z Maildir.addc C s t �t j�| j| �|��� dS �r+ N)r r. r r� r �_lookupr, r r r r. N s zMaildir.removec C s* z| � |� W dS ttfy Y dS w r1 )r. r2 �FileNotFoundErrorr, r r r r3 R s
�zMaildir.discardc C s� | � |�}| �|�}| � |�}t|t�r|}n|}tj�|�}| j|v r0| j|�| j�d }nd}| � |� tj�
| j |�} tj�
| j ||| �}
t|t�r]t� | tj�
| �|�� f� t�| |
� dS )r4 rx r� N)r� r) r| r
r r r� r� r� r3 r� r r� r� r� r� ) r r- r( � old_subpath�temp_key� temp_subpath�dominant_subpathr� r� �tmp_path�new_pathr r r r6 Z s$
�zMaildir.__setitem__c C s� | � |�}ttj�| j|�d��}| jr| �|�}nt|�}W d � n1 s(w Y tj�|�\}}|� |� | j
|v rJ|� |�| j
�d � |� tj�
tj�| j|��� |S )r? �rbNrx )r� �openr r r� r r r
r� �
set_subdirr� �set_info�set_date�getmtime)r r- �subpath�f�msgr� r� r r r r: u s
� �
zMaildir.get_messagec C sP t tj�| j| �|��d��}|�� �td�W d � S 1 s!w Y dS )�2Return a bytes representation or raise a KeyError.r� ro N) r� r r r� r r� rr r� r� �r r- r� r r r rC � s $�zMaildir.get_bytesc C s$ t tj�| j| �|��d�}t|�S )rF r� )r� r r r� r r� �
_ProxyFiler� r r r r= � s zMaildir.get_filec c sB � | � � | jD ]}z| �|� W n ty Y qw |V qdS �rG N)�_refreshr� r� r2 r, r r r rI � s �
��zMaildir.iterkeysc C � | � � || jv S �rV )r� r� r, r r r rW � �
zMaildir.__contains__c C � | � � t| j�S �rX )r� �lenr� rH r r r rY � r� zMaildir.__len__c C � dS )�"Write any pending changes to disk.Nr rH r r r rd � s z
Maildir.flushc C r� )re Nr rH r r r rf � � z Maildir.lockc C r� )rg Nr rH r r r rh � r� zMaildir.unlockc C r� �ri Nr rH r r r rj � r� z
Maildir.closec C s\ g }t �| j�D ]#}t|�dkr+|d dkr+t j�t j�| j|��r+|�|dd� � q|S )� Return a list of folder names.� r �.N)r �listdirr r� r �isdirr� �append�r r[ �entryr r r � list_folders� s ��zMaildir.list_foldersc C s t tj�| jd| �| jdd�S )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�|�s,t �t �|t j t j
B d�� |S )z>Create a folder and return a Maildir instance representing it.r� �r �
maildirfolder� ) r r r� r r r r� rj r� �O_CREAT�O_WRONLY)r r� r r[ �maildirfolder_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 s,|d dkr2td| ��q t �|�D ]!}|dkrY|dkrY|dkrYt j�t j�||��rYtd||f ��q8t j|d d
�D ]#\}}}|D ] }t � t j�||�� qh|D ] }t �
t j�||�� qwqat �
|� d S ) �-Delete the named folder, which must be empty.r� r� r� r� r z Folder contains message(s): %sr� z%Folder contains subdirectory '%s': %sF)�topdownN) r r r� r r� r� r r� �walkr. �rmdir)r r� r r� �root�dirs�filesr r r �
remove_folder� s, � �����zMaildir.remove_folderc C sX t � � }t�tj�| jd��D ]}tj�| jd|�}|tj�|� dkr)t�|� qdS )zDelete old files in "tmp".r� i@� N)�timer r� r r� r r� r. )r �nowr� r r r r �clean� s
��z
Maildir.cleanr� c C s� t � � }t�� }d|v r|�dd�}d|v r |�dd�}dt|�t|d d �t�� tj|f }tj �
| j d|�}zt� |� W n! t
ya t jd7 _zt|�W Y S ty^ Y nw Y nw td | ��)
z=Create a file in the tmp subdirectory and open and return it.�/z\057r� z\072z%s.M%sP%sQ%s.%sr� g ��.Ar� z&Name clash prevented file creation: %s)r �socket� gethostnamer� �intr �getpidr �_countr r� r �statr� �_create_carefully�FileExistsErrorr )r r �hostnamer� r r r r r� � s0 � ���zMaildir._create_tmpc C s� t � � | j d| j kr/d}| jD ]}tj�| j| �}|| j| kr%d}|| j|< q|s/dS i | _| jD ]/}| j| }t� |�D ]"}tj�
||�}tj� |�rQqA|� | j
�d }tj�
||�| j|< qAq5t � � | _dS )z!Update table of contents mapping.� FTNr )r r� r� r� r r r� r� r� r� r� r� r� r� )r �refreshr� �mtimer r� �pr� r r r r� s(
�zMaildir._refreshc C st zt j�t j�| j| j| ��r| j| W S W n ty Y nw | �� z| j| W S ty9 td| �d�w )z=Use TOC to return subpath for given key, or raise a KeyError.�No message with key: %sN)r r r� r� r r� r2 r� r, r r r r� & s � � �zMaildir._lookupc C sL t | d�s
| �� | _ z| t| j� W S ty Y dS ty% Y q
w )z0Return the next message in a one-time iteration.�
_onetime_keysTN)r^ rI r �next�
StopIterationr2 rH r r r r 4 s
�z Maildir.nextr� ) r� r� r� r� r� r! r) r. r3 r6 r: rC r= rI rW rY rd rf rh rj r� r� r� r r r r� r� r� r r r r r r s8
*
$ r c @ s� e Zd ZdZd$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 n7 tyG } z+|jtjkr,|r't| jd�}nt| j��|jtjtj fv r<t| jd�}n� W Y d}~nd}~ww || _
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! D 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) [ s
z_singlefileMailbox.addc C s | � |� | j|= d| _dS )r+ TN)r� r� r# r, r r r r. e s
z_singlefileMailbox.removec C s$ | � |� | �|�| j|< d| _dS )r4 TN)r� r' r� r# r5 r r r r6 k s
z _singlefileMailbox.__setitem__c c s � | � � | j�� E dH dS r� )r� r� rL rH r r r rI q s �z_singlefileMailbox.iterkeysc C r� r� )r� r� r, r r r rW v r� z _singlefileMailbox.__contains__c C r� r� )r� r� r� rH r r r rY { r� z_singlefileMailbox.__len__c C s | j s
t| j� d| _ dS dS )re TN)r% �
_lock_filer! rH r r r rf � �
�z_singlefileMailbox.lockc C s | j r
t| j� d| _ dS dS �rg FN)r% � _unlock_filer! rH r r r rh � r) z_singlefileMailbox.unlockc
C s� | j s| jrt| j� d| _dS | jdusJ �| j�dd� | j�� }|| jkr1td| j|f ��t | j
�}zSi }| � |� t | j�
� �D ]=}| j| \}}| j�|� | �|� |�� } | j�td|| j�� ��}|son|�|� q^||�� f||< | �|� qE|�� | _W n |�� t�|j� � t|� | j�� t�| j
�j} t�|j| � z
t�|j| j
� W n t y� t�| j
� t�|j| j
� Y nw t | j
d�| _|| _d| _ d| _| j r�t | jdd � dS dS )
r� FNr r z4Size of mailbox file changed (expected %i, found %i)T� r )�dotlock) r# r$ � _sync_flushr! r� r� �tellr& r �_create_temporaryr �_pre_mailbox_hook�sortedrL �_pre_message_hookrr �minr� �_post_message_hookrj r r. r� r� r �st_mode�chmodr� r r� r% r( )
r �cur_len�new_file�new_tocr- �start�stop� new_startrs �moder r r rd � sj
�
�
�
��z_singlefileMailbox.flushc C r� )�,Called before writing the mailbox to file f.Nr �r r� r r r r1 � r� z$_singlefileMailbox._pre_mailbox_hookc C r� )�-Called before writing each message to file f.Nr r@ r r r r3 � r� z$_singlefileMailbox._pre_message_hookc C r� ��,Called after writing each message to file f.Nr r@ r r r r5 � r� z%_singlefileMailbox._post_message_hookc C s� z#| � � W z| jr| �� W | j�� dS W | j�� dS | j�� w z| jr3| �� W | j�� w W | j�� w | j�� w r� )rd r% rh r! rj rH r r r rj � s
��
�z_singlefileMailbox.closec C sH | j du r | �� |dur"z| j | W S ty! td| �d�w dS )z'Return (start, stop) or raise KeyError.Nr )r� �
_generate_tocr2 r, r r r r� � s
��z_singlefileMailbox._lookupc C s� | j �dd� | j �� }t| j�dkr | js | �| j � z| �| j � | �|�}| � | j � W n t
y= | j � |� � w | j � � | j �� | _
|S )z;Append message to mailbox and return (start, stop) offsets.r r )r! r� r/ r� r� r# r1 r3 �_install_messager5 r� �truncaterd r& )r r( �before�offsetsr r r r' � s
�
z"_singlefileMailbox._append_messager� r/ )r� r� r� r� r! r) r. r6 rI rW rY rf rh rd r1 r3 r5 rj r� r' r r r r r A 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? � ro rz Nr ) r� r! r� r� r� r� rr 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|d�S )�3Return a string representation or raise a KeyError.)�unixfromr@ )r r- �from_r r r rE s
��z_mboxMMDF.get_stringc C sJ | � |�\}}| j�|� |s| j�� | j�|| j�� �}|�td�S )rP ro )r� r! r� r� rr r/ r� r� )r r- rR r; r< rO r r r rC s
z_mboxMMDF.get_bytesc C s< | � |�\}}| j�|� |s| j�� t| j| j�� |�S )rF )r� r! r� r� � _PartialFiler/ )r r- rR r; r< r r r r= ! s
z_mboxMMDF.get_filec C s d}t |t�r | �|�}t |t�r3|�d�r3|�d�}|dkr.|d|� }||d d� }n*|}d}n%t |t�rD|�� �d�}d| }nt |t j
j �rX|� � }|durX|�d�}|du rgdt
�t
�� ��� }| j�� }| j�|t � | �|| j| j� | j�� }||fS ) z1Format a message and blindly write to self._file.Nry ro rx r� rJ r s From MAILER-DAEMON )r| r� rn r� r� �find�_mboxMMDFMessage�get_fromrk rA r( r � get_unixfromr �asctime�gmtimer! r/ r� r� r� �
_mangle_from_)r r( rN �newline�authorr; r< r r r rE ) s0
z_mboxMMDF._install_messageNr� )
r� r� r� r� rZ r: rE rC r= rE r r r r rI s
rI c @ s2 e Zd ZdZdZdZd
dd�Zdd� Zdd � ZdS ) r zA classic mbox mailbox.TNc C � t | _t�| |||� dS )zInitialize an mbox mailbox.N)r rK rI r! r r r r r! O � z
mbox.__init__c C s |� t� dS rB �r� r� r@ r r r r5 T � zmbox._post_message_hookc C s� g g }}d}| j �d� | j �� }| j �� }|�d�r>t|�t|�k r6|r1|�|tt� � n|�|� |�|� d}n |sR|rL|�|tt� � n|�|� n
|tkrYd}nd}qtt t
||���| _ t| j �| _ | j �� | _
dS )�0Generate key-to-(start, stop) table of contents.Fr Try N)r! r� r/ r� r� r� r� r� �dict� enumerate�zipr� r" r& )r �starts�stops�last_was_empty�line_posr� r r r rD X s2
� zmbox._generate_tocr� ) r� r� r� r� rZ r� r! r5 rD r r r r r F s
r c @ s2 e Zd ZdZd dd�Zdd� Zdd � Zd
d � ZdS )
r zAn MMDF mailbox.NTc C r] )zInitialize an MMDF mailbox.N)r rK rI r! r r r r r! } r^ z
MMDF.__init__c C � |� dt � dS )rA � Nr_ r@ r r r r3 � � zMMDF._pre_message_hookc C s |� td t � dS )rC rj Nr_ r@ r r r r5 � s zMMDF._post_message_hookc C s� g g }}| j �d� d} |}| j �� }| j �� }|�dt �rM|�|� |}| j �� }| j �� }|dt krC|�|tt� � n |sK|�|� nq'n|sPnqtt t
||���| _ t| j �| _ | j �dd� | j �� | _
dS )ra r Trj r N)r! r� r� r/ r� r� r� r� rb rc rd r� r" r& )r re rf �next_posrh r� r r r rD � s8
��
� zMMDF._generate_tocr� )r� r� r� r� r! r3 r5 rD r r r r r z s
r c @ s� e Zd 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�s5|r0t�| jd� t�t�tj� | jd�tj
tj B tj B d�� nt
| j��d| _dS )zInitialize an MH instance.r� �
.mh_sequencesi� FN)r r! r r r� r r� rj r� r� r� �O_EXCLr� r r% r r r r r! � s �
z MH.__init__c C s� | � � }t|�dkr
d}nt|�d }tj�| jt|��}t|�}d}zQ| j r+t
|� z7z| � ||� W n t yN | j rBt
|� t|� d}t�|� � w t|t�rZ| �||� W | j rbt
|� n | j rkt
|� w w W |sst|� |S |s|t|� w w )r# r r� FT)rL r� �maxr r r� r r� r r% r( r� r� r+ r� r. r| r �_dump_sequences)r r( rL �new_keyr� r� �closedr r r r) � sJ
�
���
���
�zMH.addc
C sl t j�| jt|��}zt|d�}W n ty* } z
|jtjkr%t d| ��� d}~ww |�
� t � |� dS )r+ r r N) r r r� r r� r� r� r� r r2 rj r. )r r- r r� r� r r r r. � s ��z MH.removec
C s� t j�| jt|��}zt|d�}W n ty* } z
|jtjkr%t d| ��� d}~ww z?| j
r3t |� z't � t �|t j
t jB �� | �||� t|t�rR| �||� W | j
rZt|� n | j
rct|� w w W t|� dS t|� w )r4 r r N)r r r� r r� r� r� r� r r2 r% r( rj r� �O_TRUNCr� r| r rp r+ r� )r r- r( r r� r� r r r r6 � s4 ��
���
��zMH.__setitem__c
C s z | j rttj�| jt|��d�}n
ttj�| jt|��d�}W n ty9 } z
|jtj kr4t
d| ��� d}~ww |�& | j rDt |� z
t |�}W | j rQt
|� n | j rZt
|� w w W d � n1 sew Y | �� �� D ]
\}}||v r}|�|� qp|S )r? r r� r N)r% r� r r r� r r� r� r� r r2 r( r r+ �
get_sequencesrU � add_sequence)r r- r� r� r� r� �key_listr r r r: � s: � ��
��
�� �
�zMH.get_messagec
C s� z | j rttj�| jt|��d�}n
ttj�| jt|��d�}W n ty9 } z
|jtj kr4t
d| ��� d}~ww |�) | j rDt |� z|� � �
td�W | j rTt|� W d � S | j rdt|� w w 1 shw Y dS )r� r r� r Nro )r% r� r r r� r r� r� r� r r2 r( rr r� r� r+ �r r- r� r� r r r rC s. � ���
��z MH.get_bytesc
C sX zt tj�| jt|��d�}W t
|�S ty+ } z
|jtjkr&t d| ��� d}~ww )rF r� r N) r� r r r� r r� r� r� r r2 r� rw r r r r= , s � ��z MH.get_filec C s t tdd� t�| j�D ���S )rG c s s � | ] }|� � rt|�V qd S r/ )�isdigitr
)�.0r� r r r � <genexpr>9 s � �z MH.iterkeys.<locals>.<genexpr>)�iterr2 r r� r rH r r r rI 7 s z MH.iterkeysc C s t j�t j�| jt|���S r� )r r r� r� r r� r, r r r rW < s zMH.__contains__c C s t t| �� ��S r� )r� rK rI rH r r r rY @ � z
MH.__len__c C s6 | j sttj�| jd�d�| _t| j� d| _ dS dS )re rm r TN)r% r� r r r� r r! r( rH r r r rf D s
�zMH.lockc C s, | j rt| j� t| j� | `d| _ dS dS r* )r% r+ r! r� rH r r r rh K s
�z MH.unlockc C r� )rc Nr rH r r r rd S r� zMH.flushc C s | j r | �� dS dS r� )r% rh rH r r r rj W s �zMH.closec C s< g }t �| j�D ]}t j�t j�| j|��r|�|� q|S )r� )r r� r r r� r� r� r� r r r r� \ s
�zMH.list_foldersc C s t tj�| j|�| jdd�S )z+Return an MH instance for the named folder.Fr� �r r r r� r r r� r r r r� d s �z
MH.get_folderc C s t tj�| j|�| jd�S )z:Create a folder and return an MH instance representing it.r� r} r� r r r r� i s �z
MH.add_folderc C s` t j�| j|�}t �|�}|dgkr t �t j�|d�� n |g kr"ntd| j ��t �|� dS )r� rm zFolder not empty: %sN)r r r� r r� r. r r )r r� r �entriesr r r r n s
zMH.remove_folderc
s i }t tj�| jd�ddd��p}t| �� �� |D ]^}zM|�d�\}}t� }|�� D ]$}|�� r7|� t
|�� q)dd� |�d�D �\}} |� t || d �� q)� fd
d �t
|�D �||< t|| �d krf||= W q tyv td
|�� ��w W d � |S 1 s�w Y |S )z=Return a name-to-key-list dictionary to define each sequence.rm �r�ASCII��encodingr� c s s � | ]}t |�V qd S r/ )r
)ry �xr r r rz � � � z#MH.get_sequences.<locals>.<genexpr>�-r� c s g | ]}|� v r|�qS r r )ry r- ��all_keysr r �
<listcomp>� s �z$MH.get_sequences.<locals>.<listcomp>r z"Invalid sequence specification: %sN)r� r r r� r �setrL r� rx r) r
rb �ranger2 r� rm r �rstrip)
r �resultsr� r� r� �contentsrL �specr; r< r r� r rt z s4 � ���
��zMH.get_sequencesc C s t tj�| jd�ddd�}zqt�t� |jtjtjB �� |� � D ]W\}}t
|�dkr+q |� |d � d}d}t t
|��D ])}|d |krN|sMd
}|� d � n|r\d}|� d ||f � n|� d
| � |}q<|rr|� t|�d � q |� d� q W t|� dS t|� w )z:Set sequences using the given name-to-key-list dictionary.rm zr+r� r� r r� NFr� Tr� z%s %sz %s�
)r� r r r� r rj r� r� rs rU r� r� r2 r� r� r� )r � sequencesr� r� rL �prev�
completingr- r r r �
set_sequences� s2
� �zMH.set_sequencesc
C s8 | � � }d}g }| �� D ]`}|d |krh|�||d f� zt�tj�| jt|��tj�| jt|d ��� W n# t t
fyZ t� tj�| jt|��tj�| jt|d ��� Y nw t� tj�| jt|��� |d7 }q |d | _
t|�dkrzdS |�� D ]\}}|D ]\}}||v r�|||�|�< q�q~| �|� dS )z?Re-name messages to eliminate numbering gaps. Invalidates keys.r r� N)rt rI r� r r� r r� r r� r� r� r� �unlinkr" r� rU �indexr� ) r r� r� �changesr- r� rv �oldr� r r r �pack� s6 ���
��zMH.packc C st |� � }| � � }|�� D ]\}}||v r|�|� q ||v r$||�|�= q |D ] }||vr2|g||< q'| �|� dS )z;Inspect a new MHMessage and update sequences appropriately.N)rt rU r� r� r� )r r( r- �pending_sequences�
all_sequencesr� rv �sequencer r r rp � s �
�zMH._dump_sequencesr� )r� r� r� r� r! r) r. r6 r: rC r= rI rW rY rf rh rd rj r� r� r� r rt r� r� rp r r r r r � s0
" r c @ s� e Zd ZdZeh d��Zd dd�Zdd� Zd d
� Zd d � Z d
d� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� Zdd � Zd d � ZdS ) r z An Rmail-style Babyl mailbox.> �filed�edited�resent�unseen�deleted�answered� forwardedNTc C s t �| |||� i | _dS )zInitialize a Babyl mailbox.N)r r! �_labelsr r r r r! � s
zBabyl.__init__c C s( t �| |�}t|t�r|�� | j|< |S )r# )r r) r| r
�
get_labelsr� )r r( r- r r r r) � s
z Babyl.addc C s& t �| |� || jv r| j|= dS dS r� )r r. r� r, r r r r. � s
�z Babyl.removec C s. t �| ||� t|t�r|�� | j|< dS dS )r4 N)r r6 r| r
r� r� r5 r r r r6 � s
�zBabyl.__setitem__c
C s | � |�\}}| j�|� | j�� t�� } | j�� }|dt ks$|s%n
|�|�td�� qt�� } | j�� }|tks?|s@n
|�|�td�� q4|| j� � }|dksWJ �| j�
|�}|�td�}t |� � | �} | �
|� � � || jv r| �| j| � | S )r? T� *** EOOH ***ro r )r� r! r� r� r} r~ r� r� r� r/ rr r
r� � set_visibler� �
set_labels)
r r- r; r< �original_headersr� �visible_headers�n�bodyr� r r r r: � s4
�
�
zBabyl.get_messagec C s� | � |�\}}| j�|� | j�� t�� } | j�� }|dt ks$|s%n
|�|�td�� q | j�� }|tks;|s<nq0|� � }|| j�
� }|dksNJ �| j� |�}|�td�}|| S )rP Tr� ro r ) r� r! r� r� r} r~ r� r� r� r� r/ rr ) r r- r; r< r� r� �headersr� r� r r r rC s*
�
� zBabyl.get_bytesc C s t �| �|��dt��S )rF ro )r} r~ rC r� r� r, r r r r= ( � zBabyl.get_filec C s< | � � t� }| j�� D ]}|�|� q |�| j� t|�S )z4Return a list of user-defined labels in the mailbox.)r� r� r� rS rb �difference_update�_special_labelsrK )r �labels�
label_listr r r r� , s zBabyl.get_labelsc C s< g g }}| j �d� d}g } |}| j �� }| j �� }|dt krOt|�t|�k r3|�|tt� � |�|� dd� | j �� dd� �d�D �}|�|� n(|d ksY|d t krkt|�t|�k rj|�|tt� � n |sw|�|tt� � nqtt t
||���| _ tt |��| _ t| j �| _
| j �dd
� | j �� | _dS ) ra r Ts c S s g | ]
}|� � r|� � �qS r )�strip�ry �labelr r r r� C s �z'Babyl._generate_toc.<locals>.<listcomp>r� N� ,� r )r! r� r� r/ r� r� r� r� rb rc rd r� r� r" r& )r re rf rl � label_listsrh r� r� r r r rD 5 s:
� �� zBabyl._generate_tocc C sV dt }|dt 7 }| �� }dd� |D �}|dd�|� t 7 }|d7 }|�|� dS ) r? s BABYL OPTIONS:s
Version: 5c s s � | ]}|� � V qd S r/ )rk r� r r r rz X r� z*Babyl._pre_mailbox_hook.<locals>.<genexpr>s Labels:r� r� N)r� r� r� r� )r r� �babylr� r r r r1 S s zBabyl._pre_mailbox_hookc C ri )rA � Nr_ r@ r r r r3 ] rk zBabyl._pre_message_hookc C s |� td � dS )rC r� Nr_ r@ r r r r5 a rk zBabyl._post_message_hookc C s` | j �� }t|t�rXg }g }|�� D ]}|| jv r |�|� q|�|� q| j �d� |D ] }| j �d|�� � q-| j �d� |D ]}| j �d|�� d � qB| j �t � n| j �dt � t|t
j j �r�t
�� }t
j�|dd�}|�|� |�d� |�� }| j �|�d
t �� |d
ks�|s�nq~| j �d t � t|t�r�t
�� } t
j�| dd�}
|
�|�� � | �� }| j �|�d
t �� |d
ks�|s�nq�n |�d� |�� }| j �|�d
t �� |d
ks�|s�nq� |�d �} | s�n | j �| �d
t �� q�n)t|ttt
jf��r{t|t
j��rt�d
t d� |� � }t|t��r%| � |�}|� d�d } | d dk�rf| 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��r t |d��r�t�dt d� |j!}|�� }
d } |�� }|�"d��r�|dd� d
}n|�"d��r�|dd� d
}| j �|�d
t �� |d
k�s�|�s�|�r�d}| j �d t � |�|
� nn�q� |�� }|�s�n4|�"d��r�|dd� t }n |�"d��r|dd� t }n|�"d
��r|dd� t }| j �|� �q�nt#dt$|� ��| j �� }||fS )z0Write message contents and return (start, stop).� 1s , s ,,� r� s 1,,Fr Tro r� r, rp rq s
r rx Nr� rs rt ru rv rw r{ )%r! r/ r| r
r� r� r� r� rk r� rA r( r r} r~ r r� r� r� r� r� � get_visiblerr r� r� r� r� r� r� r� rn rT r^ rs r� r� r� )r r( r; �special_labelsr� r� � orig_buffer�orig_generatorr� �
vis_buffer�
vis_generatorrs �
body_start� original_pos�
first_passr< r r r rE e s�
�
�
�
��
� � �
zBabyl._install_messager� )r� r� r� r� � frozensetr� r! r) r. r6 r: rC r= r� rD r1 r3 r5 rE r r r r r � s
r c @ s* e Zd ZdZd dd�Zdd� Zdd� ZdS )
r z0Message with mailbox-format-specific properties.Nc C s� t |tjj�r | �t�|�� t |t�r|�| � dS dS t |t�r,| �t� |�� dS t |t
�r;| �t� |�� dS t |t j
�rK| �t�|�� dS t|d�rZ| �t�|�� dS |du rgtjj�| � dS tdt|� ��)z Initialize a Message instance.rr Nr{ )r| rA r( r �_become_message�copy�deepcopy� _explain_tor� rB r� �message_from_stringr} �
TextIOWrapper�message_from_filer^ �message_from_binary_filer! r� r� r' r r r r! � s
�
zMessage.__init__c C s4 t |dg �}|jD ]}||vr|j| | j|< q dS )z0Assume the non-format-specific state of message.�_type_specific_attributesN)�getattr�__dict__)r r( �
type_specificr� r r r r� � s
��zMessage._become_messagec C s t |t�rdS td��)z:Copy format-specific state to message insofar as possible.Nz Cannot convert to specified type)r| r r� r' r r r r� � s
zMessage._explain_tor/ )r� r� r� r� r! r� r� r r r r r � s
r c @ sz e Zd ZdZg d�Zd dd�Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� ZdS ) r
z)Message with Maildir-specific properties.)�_subdir�_info�_dateNc C s& d| _ d| _t�� | _t�| |� dS )z%Initialize a MaildirMessage instance.r� r� N)r� r� r r� r r! r' r r r r! � s
zMaildirMessage.__init__c C � | j S )zReturn 'new' or 'cur'.)r� rH r r r r� � zMaildirMessage.get_subdirc C s& |dks|dkr
|| _ dS td| ��)z Set subdir to 'new' or 'cur'.r� r� z!subdir must be 'new' or 'cur': %sN)r� rm )r r� r r r r� s
zMaildirMessage.set_subdirc C s | j �d�r
| j dd� S dS )�*Return as a string the flags that are set.�2,r Nr� )r� r� rH r r r � get_flags
s zMaildirMessage.get_flagsc C s dd� t|�� | _dS )�)Set the given flags and unset all others.r� r� N)r� r2 r� )r �flagsr r r � set_flags r� zMaildirMessage.set_flagsc C �$ | � d�t| �� �t|�B �� dS �z.Set the given flag(s) without changing others.r� N�r� r� r� r� �r �flagr r r �add_flag � $zMaildirMessage.add_flagc C s0 | � � r| �d�t| � � �t|� �� dS dS )�7Unset the given string flag(s) without changing others.r� N)r� r� r� r� r� r r r � remove_flag s $�zMaildirMessage.remove_flagc C r� )z<Return delivery date of message, in seconds since the epoch.)r� rH r r r r� ! r� zMaildirMessage.get_datec C s. zt |�| _W dS ty td| �d�w )z9Set delivery date of message, in seconds since the epoch.zcan't convert to float: %sN)�floatr� rm r� )r �dater r r r� % s
�zMaildirMessage.set_datec C r� )z%Get the message's "info" as a string.)r� rH r r r r� , r� zMaildirMessage.get_infoc C s$ t |t�r
|| _dS tdt|� ��)z Set the message's "info" string.zinfo must be a string: %sN)r| r� r� r� r� )r �infor r r r� 0 s
zMaildirMessage.set_infoc C s� t |t�r |�| �� � |�| �� � |�| �� � dS t |t�rct | �� �}d|v r0|�
d� | �� dkr;|�
d� d|v rD|�
d� d|v rM|�
d� d|v rV|�
d� |� d t �
| �� �� dS t |t�r�t | �� �}d|vrw|�d
� d|v r�|�d � d|v r�|�d � dS dS t |t�r�t | �� �}d|vr�|�d
� d|v r�|�d
� d|v r�|�d� d|v r�|�d� dS dS t |t�r�dS tdt|� ��)z;Copy Maildir-specific state to message insofar as possible.�S�Rr� �O�T�D�F�A�
MAILER-DAEMONr� �replied�flaggedr� r� �Pr� �$Cannot convert to specified type: %sN)r| r
r� r� r� r� r� r� rU r� r� rL r rY r ru r
� add_labelr r� r� )r r( r� r r r r� 7 sT
�
�
�zMaildirMessage._explain_tor/ )r� r� r� r� r� r! r� r� r� r� r� r� r� r� r� r� r� r r r r r
� s
r
c @ sZ e Zd ZdZdgZddd�Zdd� Zddd �Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dS )rU z/Message with mbox- or MMDF-specific properties.�_fromNc C sV | � dd� t|tjj�r#|�� }|dur#|�d�r#| � |dd� � t�| |� dS )z'Initialize an mboxMMDFMessage instance.r� TNzFrom rz )rL r| rA r( r rW r� r! )r r( rQ r r r r! h s z_mboxMMDFMessage.__init__c C r� )z Return contents of "From " line.)r� rH r r r rV q r� z_mboxMMDFMessage.get_fromc C s4 |dur|du r t �� }|dt �|� 7 }|| _dS )z>Set "From " line, formatting and appending time_ if specified.NT� )r rY rX r� )r rR �time_r r r rL u s
z_mboxMMDFMessage.set_fromc C s | � dd�| � dd� S )r� �Statusr� �X-Status)r9 rH r r r r� } r� z_mboxMMDFMessage.get_flagsc C s� t |�}d\}}dD ]}||v r||7 }|�|� q
dD ]}||v r+||7 }|�|� q |d�t|��7 }z| �d|� W n tyL | �d|� Y nw z | �d|� W dS tyf | �d|� Y dS w )r� )r� r� )r� r� )r� r� r� r� r� r� N)r� r. r� r2 �replace_headerr2 �
add_header)r r� � status_flags�
xstatus_flagsr� r r r r� � s.
�
� � �z_mboxMMDFMessage.set_flagsc C r� r� r� r� r r r r� � r� z_mboxMMDFMessage.add_flagc C s8 d| v sd| v r| � d�t| �� �t|� �� dS dS )r� r� r� r� Nr� r� r r r r� � s $�z _mboxMMDFMessage.remove_flagc C s� t |t�rgt| �� �}d|v r|�d� d|v r |�d� d|v r&|�d� d|v r/|�d� d|v r8|�d� |d = |d
= d �| �� �� d d
� �}z|� t
� t �
|d��� W d
S ttfyf Y d
S w t |t�r||�| �� � |�| �� � d
S t |t�r�t| �� �}d|vr�|�d� d|v r�|�d� d|v r�|�d� |d = |d
= d
S t |t�r�t| �� �}d|vr�|�d� d|v r�|�d� d|v r�|�d� |d = |d
= d
S t |t�r�d
S tdt|� ��)zACopy mbox- or MMDF-specific state to message insofar as possible.r� r� r� r� r� r� r� r� �statuszx-statusr� ���Nz%a %b %d %H:%M:%S %Yr� r� r� r� r� r� )r| r
r� r� r� r� r� rV r� r� �calendar�timegmr �strptimerm �
OverflowErrorrU r� rL r ru r
r� r r� r� )r r( r� �
maybe_dater r r r� � sd
��
�z _mboxMMDFMessage._explain_tor/ )
r� r� r� r� r� r! rV rL r� r� r� r� r� r r r r rU c s
rU c @ � e Zd ZdZdS )r z&Message with mbox-specific properties.N�r� r� r� r� r r r r r � � r 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 � | j dd� S )z4Return a list of sequences that include the message.N)r rH r r r rt � r` zMHMessage.get_sequencesc C � t |�| _dS )z3Set the list of sequences that include the message.N)rK r )r r� r r r r� � r` zMHMessage.set_sequencesc C �8 t |t�r|| jvr| j�|� dS dS tdt|� ��)z8Add sequence to list of sequences including the message.z sequence type must be str: %sN)r| r� r r� r� r� �r r� r r r ru � �
�zMHMessage.add_sequencec C �( z | j �|� W dS ty Y dS w )zARemove sequence from the list of sequences including the message.N)r r. rm r
r r r �remove_sequence� �
�zMHMessage.remove_sequencec C sP t |t�r5t| �� �}d|v r|�d� n
|�d� |�d� d|v r(|�d� d|v r3|�d� d
S d
S t |t�ret| �� �}d|vrJ|�d� n|�d � d|v rX|�d� d|v rc|�d
� d
S d
S t |t�rx| �� D ]}|�|� qnd
S t |t �r�t| �� �}d|v r�|�
d� d|v r�|�
d � d
S d
S t |t �r�d
S t d t
|� ��)z6Copy MH-specific state to message insofar as possible.r� r� r� r� r� r� r� �ROr� r� r� r� N)r| r
r� rt r� r� rU r ru r
r� r r� r� )r r( r� r� r r r r� � sJ
�
�
�
�
�zMHMessage._explain_tor/ ) r� r� r� r� r� r! rt r� ru r r� r r r r r � s
r c @ sb e Zd 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 r r! r' r r r r! % s zBabylMessage.__init__c C r
)z'Return a list of labels on the message.N)r� rH r r r r� + r` zBabylMessage.get_labelsc C r )z&Set the list of labels on the message.N)rK r� )r r� r r r r� / r` zBabylMessage.set_labelsc C r )z+Add label to list of labels on the message.zlabel must be a string: %sN)r| r� r� r� r� r� �r r� r r r r� 3 r zBabylMessage.add_labelc C r )z4Remove label from the list of labels on the message.N)r� r. rm r r r r � remove_label; r zBabylMessage.remove_labelc C s
t | j�S )z3Return a Message representation of visible headers.�r r rH r r r r� B s
zBabylMessage.get_visiblec C r )z2Set the Message representation of visible headers.Nr )r �visibler r r r� F r` zBabylMessage.set_visiblec C sb | j �� D ]}|| v r| j �|| | � q| j |= qdD ]}|| v r.|| j vr.| | | j |< q dS )z9Update and/or sensibly generate a set of visible headers.)�Date�FromzReply-To�To�CC�SubjectN)r rL r� )r �headerr r r �update_visibleJ s
��zBabylMessage.update_visiblec C sx t |t�rBt| �� �}d|v r|�d� n
|�d� |�d� d|v s'd|v r,|�d� d|v r5|�d� d |v r@|�d
� dS dS t |t�rrt| �� �}d|vrW|�d � n|�d � d |v re|�d
� d|v rp|�d� dS dS t |t�r�t| �� �}d|v r�|�d� d|v r�|�d� dS dS t |t �r�|�
| � � � | �� D ]}|� |� q�dS t |t
�r�dS tdt|� ��)z9Copy Babyl-specific state to message insofar as possible.r� r� r� r� r� r� r� r� r� r� r r� r� r� r� r� N)r| r
r� r� r� r� rU r ru r
r� r� r� r r� r� )r r( r� r� r r r r� U sP
�
�
�
�
�zBabylMessage._explain_tor/ )r� r� r� r� r� r! r� r� r� r r� r� r r� r r r r r
s
r
c @ r )r z&Message with MMDF-specific properties.Nr r r r r r r r c @ s� e Zd ZdZd&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%� �Zee�ZdS )(r� z A read-only wrapper of a file.Nc C s& || _ |du r|�� | _dS || _dS )zInitialize a _ProxyFile.N)r! r/ �_pos)r r� �posr r r r! � s
z_ProxyFile.__init__c C � | � || jj�S �z Read bytes.)�_readr! rr �r �sizer r r rr � r| z_ProxyFile.readc C r! r" )r# r! �read1r$ r r r r& � r| z_ProxyFile.read1c C r! )z Read a line.)r# r! r� r$ r r r r� � r| z_ProxyFile.readlinec C s> g }| D ]}|� |� |dur |t|�8 }|dkr |S q|S )zRead multiple lines.Nr )r� r� )r �sizehintr[ r� r r r � readlines� s
� z_ProxyFile.readlinesc c s � | � � }|s
dS |V q)zIterate over lines.TN)r� )r r� r r r rR � s ��z_ProxyFile.__iter__c C r� )zReturn the position.)r rH r r r r/ � r� z_ProxyFile.tellr c C s4 |dkr | j �| j� | j �||� | j �� | _dS )zChange position.r� N�r! r� r r/ �r �offset�whencer r r r� � s z_ProxyFile.seekc C s@ t | d�r zt | jd�r| j�� W | `dS W | `dS | `w dS )zClose the file.r! rj N)r^ r! rj rH r r r rj � s
��z_ProxyFile.closec C s2 |du rd}| j �| j� ||�}| j �� | _|S )z"Read size bytes using read_method.Nrx r) )r r% � read_methodr[ r r r r# � s z_ProxyFile._readc C s | S )z$Context management protocol support.r rH r r r � __enter__� r� z_ProxyFile.__enter__c G s | � � d S r/ )rj )r �excr r r �__exit__� s z_ProxyFile.__exit__c C �
| j �� S r/ )r! �readablerH r r r r2 � �
z_ProxyFile.readablec C r1 r/ )r! �writablerH r r r r4 � r3 z_ProxyFile.writablec C r1 r/ )r! �seekablerH r r r r5 � r3 z_ProxyFile.seekablec C r1 r/ )r! rd rH r r r rd � r3 z_ProxyFile.flushc C s& t | d�sdS t | jd�sdS | jjS )Nr! Trr F)r^ r! rr rH r r r rr � s
z_ProxyFile.closedr/ �r )r� r� r� r� r! rr r& r� r( rR r/ r� rj r# r. r0 r2 r4 r5 rd �propertyrr r� r r� r r r r r� � s*
r� c @ s< e Zd ZdZddd�Zdd� Zddd �Zd
d � Zd d
� ZdS )rS z&A read-only wrapper of part of a file.Nc C s t �| ||� || _|| _dS )zInitialize a _PartialFile.N)r� r! �_start�_stop)r r� r; r< r r r r! � s
z_PartialFile.__init__c C s t �| �| j S )z*Return the position with respect to start.)r� r/ r8 rH r r r r/ � r| z_PartialFile.tellr c C s< |dkr | j | _d}n
|dkr| j| _d}t�| ||� dS )z8Change position, possibly with respect to start or stop.r r� r N)r8 r r9 r� r� r* r r r r� � s z_PartialFile.seekc C sB | j | j }|dkr dS |du s|dk s||kr|}t�| ||�S )z;Read size bytes using read_method, honoring start and stop.r rJ N)r9 r r� r# )r r% r- � remainingr r r r# � s z_PartialFile._readc C s t | d�r | `d S d S )Nr! )r^ r! rH r r r rj s
�z_PartialFile.close)NNr6 ) r� r� r� r� r! r/ r� r# rj r r r r rS � s
rS Tc
C s� d}z�t r1z t �| t jt jB � W n ty0 } z|jtjtjtjfv r+t d| j
��� d}~ww |r�z
t | j
d �}|� � W n ty^ } z|jtjtjfv rYW Y d}~W dS � d}~ww z4zt
�|j
| j
d � d}W n ttfy� t
�|j
| j
d � d}Y n w t
�|j
� W W dS W W dS ty� t
�|j
� t d| j
��w W dS t r�t �| t j� |r�t
�| j
d � � )z(Lock file f using lockf and dot locking.Fzlockf: lock unavailable: %sN�.lockTzdot lock unavailable: %s)�fcntl�lockf�LOCK_EX�LOCK_NBr� r� �EAGAINr r r r� r0 rj r r� r� r� r� r� r r. �LOCK_UN)r� r- � dotlock_doner� �pre_lockr r r r( s\ ��� ���� ���r( c C s< t r t �| t j� tj�| jd �r t�| jd � dS dS )z*Unlock file f using lockf and dot locking.r; N)r< r= rA r r r� r� r. �r� r r r r+ 9 s
�r+ c C s@ t �| t jt jB t jB d�}z t| d�W t �|� S t �|� w )zCCreate a file if it doesn't exist and open for reading and writing.r� r )r r� r� rn �O_RDWRrj )r �fdr r r r @ s
r c C s$ t d| tt�� �t�� t�� f �S )zBCreate a temp file based on path and open for reading and writing.z %s.%s.%s.%s)r r
r r r r r )r r r r r0 H s �r0 c C s( | � � ttd�rt�| �� � dS dS )z0Ensure changes to file f are physically on disk.�fsyncN)rd r^ r rG �filenorD r r r r. N s
�r. c C s t | � | �� dS )z:Close file f, ensuring all changes are physically on disk.N)r. rj rD r r r r� T s r� c @ r )r z"Raised for module-specific errors.Nr r r r r r Z r r c @ r )r z:The specified mailbox does not exist and won't be created.Nr r r r r r ] r r c @ r )r z>The specified mailbox is not empty and deletion was requested.Nr r r r r r ` r r c @ r )r z)Another process caused an action to fail.Nr r r r r r c r r c @ r )r z)A file appears to have an invalid format.Nr r r r r r f r r )T)2r� r r r r r� r� r� rA �
email.message�email.generatorr} r; �typesr r< � ImportError�__all__r� rk r r r rI r r r r r( r r
rU r r r
r r� rS r( r+ r r0 r. r� � Exceptionr r r r r r r r r �<module> sp � j 8 DB4- 3 z%mqH_e
'*