ÿØÿà JFIF      ÿÛ „ 	 ( %!1!%)+//.383,7(-.+



-%%-////---/-.+/--+------/------/--0+--/-/-----.-----ÿÀ  ¥2" ÿÄ               ÿÄ J  	     ! 1AQ"aq2‘#BR‚¡ÁÑ3br’¢±Âð$CSƒ²á4c“%DsÓñÿÄ              ÿÄ *        !1AQa‘"2q3±ð#b¡ÿÚ   ? ¼QxJQaÍuò¸Zö Úü8,ÐÚú
"SSn<rçù–´âE—^ªBÖ9À\†¸ÔÁT­ÃÛ5
ëd´³Í#Ý;Þ38œî ¶H£M:wÎ3…³…âpÔF&‚FK¸9„â4àGEõªfÿ ‘ñ(ßw­pŽF|È¥ù®häðÍÑ¶¹‘[ÒinÙW¶ùñY˜Q{›K"išÒ[Ú8žë\F¹@-?v"ÔU”,ìöžkÿ {I‡£šÍ?e
ríV
..............................................................................................................................................................................
.............................................................................                                                  
                                                                                                                                                                                     ÿØÿà JFIF      ÿÛ „ 	 ( %!1!%)+//.383,7(-.+



-%%-////---/-.+/--+------/------/--0+--/-/-----.-----ÿÀ  ¥2" ÿÄ               ÿÄ J  	     ! 1AQ"aq2‘#BR‚¡ÁÑ3br’¢±Âð$CSƒ²á4c“%DsÓñÿÄ              ÿÄ *        !1AQa‘"2q3±ð#b¡ÿÚ   ? ¼QxJQaÍuò¸Zö Úü8,ÐÚú
"SSn<rçù–´âE—^ªBÖ9À\†¸ÔÁT­ÃÛ5
ëd´³Í#Ý;Þ38œî ¶H£M:wÎ3…³…âpÔF&‚FK¸9„â4àGEõªfÿ ‘ñ(ßw­pŽF|È¥ù®häðÍÑ¶¹‘[ÒinÙW¶ùñY˜Q{›K"išÒ[Ú8žë\F¹@-?v"ÔU”,ìöžkÿ {I‡£šÍ?e
ríV
..............................................................................................................................................................................
.............................................................................                                                  
                                                                                                                                                                                     3

  \ 3                @   sN  d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl	Zd dl
Z
d dlZyd dlZW n ek
r   dZY nX dddddddd	d
ddddddddgZe jjdZG dd d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eZG dd deZG dd deZG dd dejj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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 de)Z*G d8d de*Z+G d9d de*Z,G d:d de*Z-G d;d de*Z.dS )=    NMailboxMaildirmboxMHBabylMMDFMessageMaildirMessagemboxMessage	MHMessageBabylMessageMMDFMessageErrorNoSuchMailboxErrorNotEmptyErrorExternalClashErrorFormatErrorasciic               @   s  e Zd ZdBddZdd Zdd Zd	d
 Zdd Zdd ZdCddZ	dd Z
dd Zdd Zdd Zdd Zdd Zdd Zdd  Zd!d" Zd#d$ Zd%d& Zd'd( Zd)d* Zd+d, Zd-d. ZdDd/d0Zd1d2 ZdEd3d4Zd5d6 Zd7d8 Zd9d: Zd;d< Zd=d> Z d?Z!dFd@dAZ"dS )Gr   NTc             C   s    t jjt jj|| _|| _d S )N)ospathabspath
expanduser_path_factory)selfr   factorycreate r   /usr/lib64/python3.6/mailbox.py__init__$   s    zMailbox.__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 )Nz&Method must be implemented by subclass)r    )r   keyr   r   r   remove-   s    zMailbox.removec             C   s   | j | d S )N)r$   )r   r#   r   r   r   __delitem__1   s    zMailbox.__delitem__c             C   s(   y| j | W n tk
r"   Y nX d S )N)r$   KeyError)r   r#   r   r   r   discard4   s    zMailbox.discardc             C   s   t dd S )Nz&Method must be implemented by subclass)r    )r   r#   r!   r   r   r   __setitem__;   s    zMailbox.__setitem__c             C   s$   y
| j |S  tk
r   |S X d S )N)__getitem__r&   )r   r#   defaultr   r   r   get?   s    
zMailbox.getc          	   C   s6   | j s| j|S tj| j|}| j |S Q R X d S )N)r   get_message
contextlibclosingget_file)r   r#   filer   r   r   r)   F   s    
zMailbox.__getitem__c             C   s   t dd S )Nz&Method must be implemented by subclass)r    )r   r#   r   r   r   r,   N   s    zMailbox.get_messagec             C   s   t j| j|j S )N)emailmessage_from_bytes	get_bytes	as_string)r   r#   r   r   r   
get_stringR   s    zMailbox.get_stringc             C   s   t dd S )Nz&Method must be implemented by subclass)r    )r   r#   r   r   r   r3   Y   s    zMailbox.get_bytesc             C   s   t dd S )Nz&Method must be implemented by subclass)r    )r   r#   r   r   r   r/   ]   s    zMailbox.get_filec             C   s   t dd S )Nz&Method must be implemented by subclass)r    )r   r   r   r   iterkeysa   s    zMailbox.iterkeysc             C   s   t | j S )N)listr6   )r   r   r   r   keyse   s    zMailbox.keysc             c   s@   x:| j  D ].}y| | }W n tk
r0   w
Y nX |V  q
W d S )N)r6   r&   )r   r#   valuer   r   r   
itervaluesi   s    zMailbox.itervaluesc             C   s   | j  S )N)r:   )r   r   r   r   __iter__r   s    zMailbox.__iter__c             C   s   t | j S )N)r7   r:   )r   r   r   r   valuesu   s    zMailbox.valuesc             c   sD   x>| j  D ]2}y| | }W n tk
r0   w
Y nX ||fV  q
W d S )N)r6   r&   )r   r#   r9   r   r   r   	iteritemsy   s    zMailbox.iteritemsc             C   s   t | j S )N)r7   r=   )r   r   r   r   items   s    zMailbox.itemsc             C   s   t dd S )Nz&Method must be implemented by subclass)r    )r   r#   r   r   r   __contains__   s    zMailbox.__contains__c             C   s   t dd S )Nz&Method must be implemented by subclass)r    )r   r   r   r   __len__   s    zMailbox.__len__c             C   s    x| j  D ]}| j| q
W d S )N)r8   r'   )r   r#   r   r   r   clear   s    zMailbox.clearc             C   s0   y| | }W n t k
r    |S X | j| |S )N)r&   r'   )r   r#   r*   resultr   r   r   pop   s    
zMailbox.popc             C   s*   x$| j  D ]}|| j|fS W tdd S )NzNo messages in mailbox)r6   rC   r&   )r   r#   r   r   r   popitem   s    zMailbox.popitemc             C   sx   t |dr|j }nt |dr(|j }n|}d}x6|D ].\}}y|| |< W q6 tk
rb   d}Y q6X q6W |rttdd S )Nr=   r>   FTzNo message with key(s))hasattrr=   r>   r&   )r   argsourceZbad_keyr#   r!   r   r   r   update   s    



zMailbox.updatec             C   s   t dd S )Nz&Method must be implemented by subclass)r    )r   r   r   r   flush   s    zMailbox.flushc             C   s   t dd S )Nz&Method must be implemented by subclass)r    )r   r   r   r   lock   s    zMailbox.lockc             C   s   t dd S )Nz&Method must be implemented by subclass)r    )r   r   r   r   unlock   s    zMailbox.unlockc             C   s   t dd S )Nz&Method must be implemented by subclass)r    )r   r   r   r   close   s    zMailbox.closec             C   s,   y
|j dS  tk
r&   tdY nX d S )Nr   z?String input must be ASCII-only; use bytes or a Message instead)encodeUnicodeError
ValueError)r   r!   r   r   r   _string_to_bytes   s    
zMailbox._string_to_bytesFc       	      C   s  t |tjjrxtj }tjj||d}|j| |j	d |j
 }|jdt}|j| | jrt|jt rt|jt nt |tttjfrt |tjrtjdtd |j }t |tr| j|}|r|jdd}|jdt}|j| | jo|jt r|jt nt|drt|dr4tjd	td |j}d }x|j }|jd
r`|d d d }n|jdr||d d d }|sP |r|jdrd|dd   }|jdt}|j| |}q:W | jr|r|jt r|jt ntdt| d S )Nr      
z8Use of StringIO input is deprecated, use BytesIO instead   s   
From s   
>From readbufferzDUse of text mode files is deprecated, use a binary mode file insteads   
         s   From s   >From    zInvalid message type: %s)
isinstancer1   r!   r   ioBytesIO	generatorBytesGeneratorflattenseekrS   replacelinesepwrite_append_newlineendswithstrbytesStringIOwarningswarnDeprecationWarninggetvaluerP   rE   rT   readline
startswith	TypeErrortype)	r   r!   targetZmangle_from_rT   gendataZlastlineliner   r   r   _dump_message   sZ    







zMailbox._dump_message)NT)N)N)N)F)#__name__
__module____qualname__r   r"   r$   r%   r'   r(   r+   r)   r,   r5   r3   r/   r6   r8   r:   r;   r<   r=   r>   r?   r@   rA   rC   rD   rH   rI   rJ   rK   rL   rP   re   rv   r   r   r   r   r   !   s@   

		
	
c               @   s   e Zd ZdZd5ddZdd Zdd	 Zd
d Zdd Zdd Z	dd Z
dd Zdd Zdd Zdd Zdd Zdd Zdd Zd d! Zd"d# Zd$d% Zd&d' Zd(d) Zd*d+ Zd,Zd-d. Zd/d0 Zd1d2 Zd3d4 ZdS )6r   :NTc             C   s   t j| ||| tjj| jdtjj| jdtjj| jdd| _tjj| js|rtj| jd x*| jj	 D ]}tj|d qnW n
t
| ji | _ddd| _d| _d| _d S )	Ntmpnewcur)r{   r|   r}   i  r   )r}   r|   g?)r   r   r   r   joinr   _pathsexistsmkdirr<   r   _toc_toc_mtimes
_last_read_skewfactor)r   dirnamer   r   r   r   r   r   r     s    
zMaildir.__init__c             C   s~  | j  }y| j|| W n* tk
rB   |j  tj|j  Y nX t| t|t	r||j
 }| j|j  }|| jkrd}nd}d}tjj|jj| jd }tjj| j||| }t|t	rtj|jtjj|j|j f yLytj|j| W n( ttfk
r   tj|j| Y nX tj|j W nN tk
rx } z0tj|j |jtjkrftd| n W Y d d }~X nX |S )N r|   r   z$Name clash with existing message: %s)_create_tmprv   BaseExceptionrL   r   r$   name_sync_closer[   r	   
get_subdircolonget_infor   basenamesplitr~   r   utimegetatimeget_datelinkAttributeErrorPermissionErrorrenameOSErrorerrnoZEEXISTr   )r   r!   Ztmp_filesubdirsuffixuniqdester   r   r   r"   !  sB    



zMaildir.addc             C   s    t jt jj| j| j| d S )N)r   r$   r   r~   r   _lookup)r   r#   r   r   r   r$   K  s    zMaildir.removec             C   s,   y| j | W n ttfk
r&   Y nX d S )N)r$   r&   FileNotFoundError)r   r#   r   r   r   r'   O  s    zMaildir.discardc             C   s   | j |}| j|}| j |}t|tr.|}n|}tjj|}| j|kr`| j|j| jd  }nd}| j	| tjj
| j|}	tjj
| j||| }
t|trtj|	tjj|	|j f tj|	|
 d S )NrW   r   rZ   )r   r"   r[   r	   r   r   r   r   r   r'   r~   r   r   r   r   r   )r   r#   r!   Zold_subpathZtemp_keyZtemp_subpathZdominant_subpathr   r   Ztmp_pathnew_pathr   r   r   r(   W  s"    






zMaildir.__setitem__c             C   s   | j |}ttjj| j|d }| jr4| j|}nt|}W d Q R X tjj|\}}|j	| | j
|kr|j|j| j
d  |jtjjtjj| j| |S )NrbrW   rZ   )r   openr   r   r~   r   r   r	   r   
set_subdirr   set_infoset_dategetmtime)r   r#   Zsubpathfmsgr   r   r   r   r   r,   r  s    


zMaildir.get_messagec          
   C   s8   t tjj| j| j|d}|j jtdS Q R X d S )Nr   rQ   )	r   r   r   r~   r   r   rS   rb   rc   )r   r#   r   r   r   r   r3     s    zMaildir.get_bytesc             C   s$   t tjj| j| j|d}t|S )Nr   )r   r   r   r~   r   r   
_ProxyFile)r   r#   r   r   r   r   r/     s    zMaildir.get_filec             c   sH   | j   x:| jD ]0}y| j| W n tk
r8   wY nX |V  qW d S )N)_refreshr   r   r&   )r   r#   r   r   r   r6     s    zMaildir.iterkeysc             C   s   | j   || jkS )N)r   r   )r   r#   r   r   r   r?     s    zMaildir.__contains__c             C   s   | j   t| jS )N)r   lenr   )r   r   r   r   r@     s    zMaildir.__len__c             C   s   d S )Nr   )r   r   r   r   rI     s    zMaildir.flushc             C   s   d S )Nr   )r   r   r   r   rJ     s    zMaildir.lockc             C   s   d S )Nr   )r   r   r   r   rK     s    zMaildir.unlockc             C   s   d S )Nr   )r   r   r   r   rL     s    zMaildir.closec             C   s`   g }xVt j| jD ]F}t|dkr|d dkrt jjt jj| j|r|j|dd   qW |S )NrW   r   .)r   listdirr   r   r   isdirr~   append)r   rB   entryr   r   r   list_folders  s    zMaildir.list_foldersc             C   s    t tjj| jd| | jddS )Nr   F)r   r   )r   r   r   r~   r   r   )r   folderr   r   r   
get_folder  s    zMaildir.get_folderc             C   s\   t jj| jd| }t|| jd}t jj|d}t jj|sXt jt j|t j	t j
B d |S )Nr   )r   Zmaildirfolderi  )r   r   r~   r   r   r   r   rL   r   O_CREATO_WRONLY)r   r   r   rB   Zmaildirfolder_pathr   r   r   
add_folder  s    zMaildir.add_folderc             C   s,  t jj| jd| }xTt jt jj|dt jt jj|d D ](}t|dk sZ|d dkr>td| q>W xPt j|D ]B}|dkrv|dkrv|dkrvt jjt jj||rvtd||f qvW x`t j|d	d
D ]N\}}}x |D ]}t j	t jj|| qW x |D ]}t j
t jj|| qW qW t j
| d S )Nr   r|   r}   rW   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     

zMaildir.remove_folderc             C   s\   t j  }xNtjtjj| jdD ]4}tjj| jd|}|tjj| dkr tj| q W d S )Nr{   i@ )timer   r   r   r~   r   r   r$   )r   nowr   r   r   r   r   clean  s
    zMaildir.cleanrW   c             C   s   t j  }tj }d|kr$|jdd}d|kr8|jdd}dt|t|d d tj tj|f }tj	j
| jd|}ytj| W n@ tk
r   t jd7  _yt|S  tk
r   Y nX Y nX td	| d S )
N/z\057rz   z\072z%s.M%sP%sQ%s.%srW   g    .Ar{   z&Name clash prevented file creation: %s)r   socketgethostnamerb   intr   getpidr   _countr   r~   r   statr   _create_carefullyFileExistsErrorr   )r   r   Zhostnamer   r   r   r   r   r     s&    zMaildir._create_tmpc             C   s   t j  | j d| j krbd}x<| jD ]2}tjj| j| }|| j| krLd}|| j|< q$W |sbd S i | _xl| jD ]b}| j| }xRtj	|D ]D}tjj
||}tjj|rq|j| jd }tjj
||| j|< qW qpW t j  | _d S )NrU   FTr   )r   r   r   r   r   r   r   r   r   r   r~   r   r   r   )r   Zrefreshr   mtimer   r   pr   r   r   r   r     s&    
zMaildir._refreshc             C   sz   y,t jjt jj| j| j| r*| j| S W n tk
r@   Y nX | j  y
| j| S  tk
rt   td| Y nX d S )NzNo message with key: %s)r   r   r   r~   r   r   r&   r   )r   r#   r   r   r   r   #  s    
zMaildir._lookupc             C   sV   t | ds| j | _x<y| t| j S  tk
r8   d S  tk
rL   wY qX qW d S )N_onetime_keys)rE   r6   r   nextStopIterationr&   )r   r   r   r   r   1  s    

zMaildir.next)NT)rw   rx   ry   r   r   r"   r$   r'   r(   r,   r3   r/   r6   r?   r@   rI   rJ   rK   rL   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r     s4   
*
	
$c               @   s   e Zd Zd#ddZdd Zdd Zd	d
 Zdd Zdd Zdd Z	dd Z
dd Zdd Zdd Zdd Zdd Zdd Zd$dd Zd!d" ZdS )%_singlefileMailboxNTc             C   s   t j| ||| yt| jd}W nn tk
r } zR|jtjkr\|rPt| jd}q~t| jn"|jtjtj	fkr|t| jd}n W Y d d }~X nX || _
d | _d| _d| _d| _d| _d | _d S )Nzrb+zwb+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|| j| j< |  jd7  _d| _| jd S )NrW   T)r   _append_messager   r   r   )r   r!   r   r   r   r"   X  s
    z_singlefileMailbox.addc             C   s   | j | | j|= d| _d S )NT)r   r   r   )r   r#   r   r   r   r$   b  s    
z_singlefileMailbox.removec             C   s$   | j | | j|| j|< d| _d S )NT)r   r   r   r   )r   r#   r!   r   r   r   r(   h  s    
z_singlefileMailbox.__setitem__c             c   s   | j   | jj E d H  d S )N)r   r   r8   )r   r   r   r   r6   n  s    z_singlefileMailbox.iterkeysc             C   s   | j   || jkS )N)r   r   )r   r#   r   r   r   r?   s  s    z_singlefileMailbox.__contains__c             C   s   | j   t| jS )N)r   r   r   )r   r   r   r   r@   x  s    z_singlefileMailbox.__len__c             C   s   | j st| j d| _ d S )NT)r   
_lock_filer   )r   r   r   r   rJ   }  s    
z_singlefileMailbox.lockc             C   s   | j rt| j d| _ d S )NF)r   _unlock_filer   )r   r   r   r   rK     s    
z_singlefileMailbox.unlockc       
      C   s  | j s | jrt| j d| _d S | jjdd | jj }|| jkrTtd| j|f t| j	}yi }| j
| xt| jj D ]|}| j| \}}| jj| | j| |j }x0| jjtd|| jj  }|sP |j| qW ||j f||< | j| q~W |j | _W n"   |j  tj|j  Y nX t| | jj  tj| j	j}	tj|j|	 ytj|j| j	 W n2 tk
r   tj| j	 tj|j| j	 Y nX t| j	d| _|| _d| _ d| _| jrt| jdd d S )NFr   rU   z4Size of mailbox file changed (expected %i, found %i)i   zrb+)dotlock) r   r   _sync_flushr   ra   tellr   r   _create_temporaryr   _pre_mailbox_hooksortedr   r8   _pre_message_hookrS   minrd   _post_message_hookrL   r   r$   r   r   r   st_modechmodr   r   r   r   r   )
r   Zcur_lenZnew_fileZnew_tocr#   startstopZ	new_startrT   moder   r   r   rI     s^    
	






z_singlefileMailbox.flushc             C   s   d S )Nr   )r   r   r   r   r   r     s    z$_singlefileMailbox._pre_mailbox_hookc             C   s   d S )Nr   )r   r   r   r   r   r     s    z$_singlefileMailbox._pre_message_hookc             C   s   d S )Nr   )r   r   r   r   r   r     s    z%_singlefileMailbox._post_message_hookc             C   s4   z| j   W d z| jr| j  W d | jj  X X d S )N)rI   r   rK   r   rL   )r   r   r   r   rL     s    z_singlefileMailbox.closec             C   sJ   | j d kr| j  |d k	rFy
| j | S  tk
rD   td| Y nX d S )NzNo message with key: %s)r   _generate_tocr&   )r   r#   r   r   r   r     s    

z_singlefileMailbox._lookupc             C   s   | j jdd | j j }t| jdkr:| j r:| j| j  y&| j| j  | j|}| j	| j  W n" t
k
r   | j j|  Y nX | j j  | j j | _|S )Nr   rU   )r   ra   r   r   r   r   r   r   _install_messager   r   truncaterI   r   )r   r!   ZbeforeZoffsetsr   r   r   r     s    


z"_singlefileMailbox._append_message)NT)N)rw   rx   ry   r   r"   r$   r(   r6   r?   r@   rJ   rK   rI   r   r   r   rL   r   r   r   r   r   r   r   >  s    

@

r   c               @   s>   e Zd ZdZdd ZdddZdddZdd	d
Zdd ZdS )	_mboxMMDFTc             C   sp   | j |\}}| jj| | jj jtd}| jj|| jj  }| j|jtd}|j	|dd  j
d |S )N    rQ   rX   r   )r   r   ra   rn   rb   rc   rS   r   _message_factoryset_fromdecode)r   r#   r   r   	from_linestringr   r   r   r   r,     s    z_mboxMMDF.get_messageFc             C   s   t j| j|j|dS )N)unixfrom)r1   r2   r3   r4   )r   r#   from_r   r   r   r5     s    z_mboxMMDF.get_stringc             C   sJ   | j |\}}| jj| |s(| jj  | jj|| jj  }|jtdS )NrQ   )r   r   ra   rn   rS   r   rb   rc   )r   r#   r   r   r   r   r   r   r   r3     s    
z_mboxMMDF.get_bytesc             C   s<   | j |\}}| jj| |s(| jj  t| j| jj |S )N)r   r   ra   rn   _PartialFiler   )r   r#   r   r   r   r   r   r   r/     s
    
z_mboxMMDF.get_filec             C   s  d }t |tr| j|}t |trf|jdrf|jd}|dkr\|d | }||d d  }q|}d}nJt |tr|j jd}d| }n(t |t	j
jr|j }|d k	r|jd}|d krdtjtj j  }| jj }| jj|t  | j|| j| j | jj }||fS )Ns   From rQ   rW   r   r   s   From MAILER-DAEMON rZ   )r[   rg   rP   rh   ro   find_mboxMMDFMessageget_fromrM   r1   r!   r   get_unixfromr   asctimegmtimer   r   rd   rc   rv   _mangle_from_)r   r!   r   newlineZauthorr   r   r   r   r   r   &  s0    







z_mboxMMDF._install_messageN)F)F)F)	rw   rx   ry   r   r,   r5   r3   r/   r   r   r   r   r   r     s   


	
r   c               @   s.   e Zd ZdZdZd	ddZdd Zdd ZdS )
r   TNc             C   s   t | _tj| ||| d S )N)r
   r   r   r   )r   r   r   r   r   r   r   r   L  s    zmbox.__init__c             C   s   |j t d S )N)rd   rc   )r   r   r   r   r   r   Q  s    zmbox._post_message_hookc             C   s   g g  }}d}| j jd x| j j }| j j }|jdr|t|t|k rl|rb|j|tt  n
|j| |j| d}q|s|r|j|tt  n
|j| P q|tkrd}qd}qW tt	t
||| _t| j| _| j j | _d S )NFr   s   From T)r   ra   r   rn   ro   r   r   rc   dict	enumeratezipr   r   r   )r   startsstopsZlast_was_emptyline_posru   r   r   r   r   U  s0    






zmbox._generate_toc)NT)rw   rx   ry   r   re   r   r   r   r   r   r   r   r   C  s
   
c               @   s.   e Zd ZdddZdd Zdd Zd	d
 ZdS )r   NTc             C   s   t | _tj| ||| d S )N)r   r   r   r   )r   r   r   r   r   r   r   r   z  s    zMMDF.__init__c             C   s   |j dt  d S )Ns   )rd   rc   )r   r   r   r   r   r     s    zMMDF._pre_message_hookc             C   s   |j td t  d S )Ns   )rd   rc   )r   r   r   r   r   r     s    zMMDF._post_message_hookc             C   s   g g  }}| j jd d}x|}| j j }| j j }|jdt r|j| xV|}| j j }| j j }|dt kr|j|tt  P qN|sN|j| P qNW q|sP qW tt	t
||| _t| j| _| j jdd | j j | _d S )Nr   s   rU   )r   ra   rn   r   ro   rc   r   r   r   r  r  r   r   r   )r   r  r  next_posr  ru   r   r   r   r     s2    






zMMDF._generate_toc)NT)rw   rx   ry   r   r   r   r   r   r   r   r   r   w  s   
c               @   s   e Zd Zd/ddZdd Zdd Zd	d
 Zdd Zdd Zdd Z	dd Z
dd Zdd Zdd Zdd Zdd Zdd Zdd  Zd!d" Zd#d$ Zd%d& Zd'd( Zd)d* Zd+d, Zd-d. ZdS )0r   NTc             C   st   t j| ||| tjj| jsj|r`tj| jd tjtjtjj	| jdtj
tjB tjB d n
t| jd| _d S )Ni  z.mh_sequencesi  F)r   r   r   r   r   r   r   rL   r   r~   r   O_EXCLr   r   r   )r   r   r   r   r   r   r   r     s    
zMH.__init__c             C   s   | j  }t|dkrd}nt|d }tjj| jt|}t|}d}z| j	rVt
| zfy| j|| W n: tk
r   | j	rt| t| d}tj|  Y nX t|tr| j|| W d | j	rt| X W d |st| X |S )Nr   rW   FT)r8   r   maxr   r   r~   r   rg   r   r   r   rv   r   r   r   r$   r[   r   _dump_sequences)r   r!   r8   Znew_keyr   r   closedr   r   r   r"     s6    


zMH.addc             C   sx   t jj| jt|}yt|d}W n> tk
r` } z"|jtjkrNt	d| n W Y d d }~X nX |j
  t j| d S )Nzrb+zNo message with key: %s)r   r   r~   r   rg   r   r   r   r   r&   rL   r$   )r   r#   r   r   r   r   r   r   r$     s    z	MH.removec             C   s   t jj| jt|}yt|d}W n> tk
r` } z"|jtjkrNt	d| n W Y d d }~X nX zd| j
rrt| z@t jt j|t jt jB  | j|| t|tr| j|| W d | j
rt| X W d t| X d S )Nzrb+zNo message with key: %s)r   r   r~   r   rg   r   r   r   r   r&   r   r   rL   r   O_TRUNCrv   r[   r   r	  r   r   )r   r#   r!   r   r   r   r   r   r   r(     s$    
zMH.__setitem__c              C   s   y@| j r$ttjj| jt|d}nttjj| jt|d}W n> tk
r~ } z"|jtj	krlt
d| n W Y d d }~X nX |2 | j rt| zt|}W d | j rt| X W d Q R X x*| j j D ]\}}||kr|j| qW |S )Nzrb+r   zNo message with key: %s)r   r   r   r   r~   r   rg   r   r   r   r&   r   r   r   get_sequencesr>   add_sequence)r   r#   r   r   r   r   key_listr   r   r   r,     s&    zMH.get_messagec              C   s   y@| j r$ttjj| jt|d}nttjj| jt|d}W n> tk
r~ } z"|jtj	krlt
d| n W Y d d }~X nX |6 | j rt| z|j jtdS | j rt| X W d Q R X d S )Nzrb+r   zNo message with key: %srQ   )r   r   r   r   r~   r   rg   r   r   r   r&   r   rS   rb   rc   r   )r   r#   r   r   r   r   r   r3     s    zMH.get_bytesc             C   sf   yt tjj| jt|d}W n> tk
r\ } z"|jtjkrJt	d| n W Y d d }~X nX t
|S )Nr   zNo message with key: %s)r   r   r   r~   r   rg   r   r   r   r&   r   )r   r#   r   r   r   r   r   r/   )  s    zMH.get_filec             C   s   t tdd tj| jD S )Nc             s   s   | ]}|j  rt|V  qd S )N)isdigitr   ).0r   r   r   r   	<genexpr>6  s    zMH.iterkeys.<locals>.<genexpr>)iterr   r   r   r   )r   r   r   r   r6   4  s    zMH.iterkeysc             C   s   t jjt jj| jt|S )N)r   r   r   r~   r   rg   )r   r#   r   r   r   r?   9  s    zMH.__contains__c             C   s   t t| j S )N)r   r7   r6   )r   r   r   r   r@   =  s    z
MH.__len__c             C   s2   | j s.ttjj| jdd| _t| j d| _ d S )Nz.mh_sequenceszrb+T)r   r   r   r   r~   r   r   r   )r   r   r   r   rJ   A  s    
zMH.lockc             C   s(   | j r$t| j t| j | `d| _ d S )NF)r   r   r   r   )r   r   r   r   rK   H  s
    

z	MH.unlockc             C   s   d S )Nr   )r   r   r   r   rI   P  s    zMH.flushc             C   s   | j r| j  d S )N)r   rK   )r   r   r   r   rL   T  s    zMH.closec             C   s@   g }x6t j| jD ]&}t jjt jj| j|r|j| qW |S )N)r   r   r   r   r   r~   r   )r   rB   r   r   r   r   r   Y  s
    zMH.list_foldersc             C   s   t tjj| j|| jddS )NF)r   r   )r   r   r   r~   r   r   )r   r   r   r   r   r   a  s    zMH.get_folderc             C   s   t tjj| j|| jdS )N)r   )r   r   r   r~   r   r   )r   r   r   r   r   r   f  s    zMH.add_folderc             C   s`   t jj| j|}t j|}|dgkr:t jt jj|d n|g krDntd| j t j| d S )Nz.mh_sequenceszFolder not empty: %s)r   r   r~   r   r   r$   r   r   )r   r   r   Zentriesr   r   r   r   k  s    

zMH.remove_folderc       
         s  i }t tjj| jdddd}t| j  x|D ]}y|jd\}}t }xT|j D ]H}|j rr|j	t
| qVdd |jdD \}}	|jt||	d	  qVW  fd
dt|D ||< t|| dkr||= W q2 tk
r   td|j  Y q2X q2W W d Q R X |S )Nz.mh_sequencesrASCII)encodingrz   c             s   s   | ]}t |V  qd S )N)r   )r  xr   r   r   r    s    z#MH.get_sequences.<locals>.<genexpr>-rW   c                s   g | ]}| kr|qS r   r   )r  r#   )all_keysr   r   
<listcomp>  s    z$MH.get_sequences.<locals>.<listcomp>r   z"Invalid sequence specification: %s)r   r   r   r~   r   setr8   r   r  r"   r   rH   ranger   r   rO   r   rstrip)
r   Zresultsr   ru   r   contentsr8   specr   r   r   )r  r   r  w  s&    

 zMH.get_sequencesc             C   s
  t tjj| jdddd}ztjtj |jtjtjB  x|j	 D ]\}}t
|dkrXqB|j|d  d }d}xbtt|D ]R}|d |kr|sd	}|jd
 n*|rd}|jd||f  n|jd|  |}q|W |r|jt|d  qB|jd qBW W d t| X d S )Nz.mh_sequenceszr+r  )r  r   rz   FrW   Tr  z%s %sz %s
)r   r   r   r~   r   rL   r   r   r  r>   r   rd   r   r  rg   r   )r   	sequencesr   r   r8   prevZ
completingr#   r   r   r   set_sequences  s.    zMH.set_sequencesc       	      C   sL  | j  }d}g }x| j D ]}|d |kr|j||d f y4tjtjj| jt|tjj| jt|d  W nH t	t
fk
r   tjtjj| jt|tjj| jt|d  Y nX tjtjj| jt| |d7 }qW |d | _t|dkrd S xB|j D ]6\}}x*|D ]"\}}||kr|||j|< qW qW | j| d S )Nr   rW   )r  r6   r   r   r   r   r~   r   rg   r   r   r   unlinkr   r   r>   indexr"  )	r   r   r!  Zchangesr#   r   r  oldr|   r   r   r   pack  s,     

zMH.packc             C   s|   |j  }| j  }x<|j D ]0\}}||kr6|j| q||kr||j|= qW x|D ]}||krT|g||< qTW | j| d S )N)r  r>   r   r$  r"  )r   r!   r#   Zpending_sequencesZall_sequencesr   r  sequencer   r   r   r	    s    
zMH._dump_sequences)NT)rw   rx   ry   r   r"   r$   r(   r,   r3   r/   r6   r?   r@   rJ   rK   rI   rL   r   r   r   r   r  r"  r&  r	  r   r   r   r   r     s,   
"c               @   s   e Zd ZedddddddhZd$d
dZdd Zdd Zdd Zdd Z	dd Z
dd Zdd Zdd Zdd Zdd Zd d! Zd"d# ZdS )%r   unseendeletedZfiledanswered	forwardedZeditedresentNTc             C   s   t j| ||| i | _d S )N)r   r   _labels)r   r   r   r   r   r   r   r     s    zBabyl.__init__c             C   s(   t j| |}t|tr$|j | j|< |S )N)r   r"   r[   r   
get_labelsr-  )r   r!   r#   r   r   r   r"     s    
z	Babyl.addc             C   s"   t j| | || jkr| j|= d S )N)r   r$   r-  )r   r#   r   r   r   r$     s    
zBabyl.removec             C   s*   t j| || t|tr&|j | j|< d S )N)r   r(   r[   r   r.  r-  )r   r#   r!   r   r   r   r(     s    
zBabyl.__setitem__c       
      C   s   | j |\}}| jj| | jj  tj }x4| jj }|dt ksJ| rLP |j|jtd q.W tj }x0| jj }|tks| rP |j|jtd qlW || jj	  }| jj
|}|jtd}t|j | }	|	j|j  || jkr|	j| j|  |	S )Ns   *** EOOH ***rQ   )r   r   ra   rn   r\   r]   rc   rd   rb   r   rS   r   rm   set_visibler-  
set_labels)
r   r#   r   r   original_headersru   Zvisible_headersnZbodyr   r   r   r   r,     s.    



zBabyl.get_messagec       	      C   s   | j |\}}| jj| | jj  tj }x4| jj }|dt ksJ| rLP |j|jtd q.W x| jj }|tks|| rdP qdW |j	 }|| jj
  }| jj|}|jtd}|| S )Ns   *** EOOH ***rQ   )r   r   ra   rn   r\   r]   rc   rd   rb   rm   r   rS   )	r   r#   r   r   r1  ru   Zheadersr2  rt   r   r   r   r3     s$    


zBabyl.get_bytesc             C   s   t j| j|jdtS )NrQ   )r\   r]   r3   rb   rc   )r   r#   r   r   r   r/   %  s    zBabyl.get_filec             C   s@   | j   t }x| jj D ]}|j| qW |j| j t|S )N)r   r  r-  r<   rH   difference_update_special_labelsr7   )r   labelsZ
label_listr   r   r   r.  )  s    zBabyl.get_labelsc             C   s>  g g  }}| j jd d}g }x|}| j j }| j j }|dt krt|t|k rf|j|tt  |j| dd | j j dd  jdD }|j| q |dks|dt krt|t|k r|j|tt  q |s |j|tt  P q W tt	t
||| _tt	|| _t| j| _| j jdd | j j | _d S )	Nr   s   c             S   s   g | ]}|j  r|j  qS r   )strip)r  labelr   r   r   r  @  s    z'Babyl._generate_toc.<locals>.<listcomp>rW      ,   rU   )r   ra   rn   r   rc   r   r   r   r   r  r  r   r-  r   r   )r   r  r  r  Zlabel_listsr  ru   r5  r   r   r   r   2  s4    



zBabyl._generate_tocc             C   sV   dt  }|dt  7 }| j }dd |D }|ddj| t  7 }|d7 }|j| d S )Ns   BABYL OPTIONS:s
   Version: 5c             s   s   | ]}|j  V  qd S )N)rM   )r  r7  r   r   r   r  U  s    z*Babyl._pre_mailbox_hook.<locals>.<genexpr>s   Labels:r8  r9  )rc   r.  r~   rd   )r   r   Zbabylr5  r   r   r   r   P  s    zBabyl._pre_mailbox_hookc             C   s   |j dt  d S )N   )rd   rc   )r   r   r   r   r   r   Z  s    zBabyl._pre_message_hookc             C   s   |j td  d S )Nr9  )rd   rc   )r   r   r   r   r   r   ^  s    zBabyl._post_message_hookc             C   s  | j j }t|trg }g }x0|j D ]$}|| jkr@|j| q&|j| q&W | j jd x |D ]}| j jd|j   q`W | j jd x$|D ]}| j jd|j  d  qW | j jt	 n| j jdt	  t|t
jjr0tj }t
jj|dd}|j| |jd x6|j }| j j|jd	t	 |d	ks8| r
P q
W | j jd
t	  t|trtj }	t
jj|	dd}
|
j|j  xz|	j }| j j|jd	t	 |d	ks| rP qW nB|jd x6|j }| j j|jd	t	 |d	ks| rP qW x,|jd}|sP | j j|jd	t	 q W nZt|tttjfr,t|tjrhtjdtd |j }t|tr~| j|}|jdd }|d dkr | j j|d | jd	t	 | j jd
t	  | j j|d | jd	t	 | j j||d  jd	t	 n(| j jd
t	 t	  | j j|jd	t	 n^t |drzt |drXtjdtd |j!}|j }d}x|j }|j"dr|d d d	 }n|j"dr|d d d	 }| j j|jd	t	 |d	ks| rf|rd}| j jd
t	  |j| nP qfW x|j }|sP |j"dr,|d d t	 }n:|j"drJ|d d t	 }n|j"d	rf|d d t	 }| j j| qW nt#dt$| | j j }||fS )N   1s   , s   ,,    r8  s   1,,Fr   rQ   s   *** EOOH ***i   z8Use of StringIO input is deprecated, use BytesIO insteadrR   s   

rU   rW   rn   rT   zDUse of text mode files is deprecated, use a binary mode file insteadTs   
rV   zInvalid message type: %srZ   rY   rZ   rY   rZ   rZ   )%r   r   r[   r   r.  r4  r   rd   rM   rc   r1   r!   r   r\   r]   r^   r_   r`   ra   rn   rb   get_visiblerS   rh   rg   ri   rj   rk   rl   rm   rP   r   rE   rT   rf   rp   rq   )r   r!   r   Zspecial_labelsr5  r7  Zorig_bufferZorig_generatorru   Z
vis_bufferZvis_generatorrT   Z
body_startZoriginal_posZ
first_passr   r   r   r   r   b  s    











zBabyl._install_message)NT)rw   rx   ry   	frozensetr4  r   r"   r$   r(   r,   r3   r/   r.  r   r   r   r   r   r   r   r   r   r     s   

	
c               @   s&   e Zd ZdddZdd Zdd ZdS )	r   Nc             C   s   t |tjjr4| jtj| t |tr|j|  nt |trP| jtj	| n~t |t
rl| jtj| nbt |tjr| jtj| nDt|dr| jtj| n(|d krtjjj|  ntdt| d S )NrS   zInvalid message type: %s)r[   r1   r!   r   _become_messagecopydeepcopy_explain_torh   r2   rg   Zmessage_from_stringr\   TextIOWrapperZmessage_from_filerE   Zmessage_from_binary_filer   rp   rq   )r   r!   r   r   r   r     s    



zMessage.__init__c             C   s8   t |dg }x&|jD ]}||kr|j| | j|< qW d S )N_type_specific_attributes)getattr__dict__)r   r!   Ztype_specificr   r   r   r   r?    s    zMessage._become_messagec             C   s   t |trd S tdd S )Nz Cannot convert to specified type)r[   r   rp   )r   r!   r   r   r   rB    s    
zMessage._explain_to)N)rw   rx   ry   r   r?  rB  r   r   r   r   r     s   
c               @   sx   e Zd ZdddgZdddZdd Zd	d
 Zdd Zdd Zdd Z	dd Z
dd Zdd Zdd Zdd Zdd ZdS )r	   _subdir_info_dateNc             C   s&   d| _ d| _tj | _tj| | d S )Nr|   r   )rG  rH  r   rI  r   r   )r   r!   r   r   r   r     s    
zMaildirMessage.__init__c             C   s   | j S )N)rG  )r   r   r   r   r     s    zMaildirMessage.get_subdirc             C   s(   |dks|dkr|| _ ntd| d S )Nr|   r}   z!subdir must be 'new' or 'cur': %s)rG  rO   )r   r   r   r   r   r     s    zMaildirMessage.set_subdirc             C   s"   | j jdr| j dd  S dS d S )Nz2,rU   r   )rH  ro   )r   r   r   r   	get_flags
  s    zMaildirMessage.get_flagsc             C   s   ddj t| | _d S )Nz2,r   )r~   r   rH  )r   flagsr   r   r   	set_flags  s    zMaildirMessage.set_flagsc             C   s$   | j djt| j t|B  d S )Nr   )rL  r~   r  rJ  )r   flagr   r   r   add_flag  s    zMaildirMessage.add_flagc             C   s,   | j  r(| jdjt| j  t|  d S )Nr   )rJ  rL  r~   r  )r   rM  r   r   r   remove_flag  s    zMaildirMessage.remove_flagc             C   s   | j S )N)rI  )r   r   r   r   r     s    zMaildirMessage.get_datec             C   s4   yt || _W n  tk
r.   td| Y nX d S )Nzcan't convert to float: %s)floatrI  rO   rp   )r   Zdater   r   r   r   "  s    zMaildirMessage.set_datec             C   s   | j S )N)rH  )r   r   r   r   r   )  s    zMaildirMessage.get_infoc             C   s&   t |tr|| _ntdt| d S )Nzinfo must be a string: %s)r[   rg   rH  rp   rq   )r   infor   r   r   r   -  s    
zMaildirMessage.set_infoc             C   s  t |tr8|j| j  |j| j  |j| j  nht |trt	| j }d|kr`|j
d | j dkrv|j
d d|kr|j
d d|kr|j
d d|kr|j
d |jd	tj| j  nt |trt	| j }d|kr|jd
 d|kr|jd d|kr|jd nt |trt	| j }d|krD|jd
 d|krX|jd d|krl|jd d|kr|jd nt |trntdt| d S )NSRr}   OTDFAzMAILER-DAEMONr(  repliedflaggedr)  r*  Pr+  z$Cannot convert to specified type: %s)r[   r	   rL  rJ  r   r   r   r   r   r  rN  r   r   r   r   r  r   	add_labelr   rp   rq   )r   r!   rK  r   r   r   rB  4  sN    

















zMaildirMessage._explain_to)N)rw   rx   ry   rD  r   r   r   rJ  rL  rN  rO  r   r   r   r   rB  r   r   r   r   r	     s   

c               @   sV   e Zd ZdgZdddZdd ZdddZd	d
 Zdd Zdd Z	dd Z
dd ZdS )r   _fromNc             C   sV   | j dd t|tjjrF|j }|d k	rF|jdrF| j |dd   tj| | d S )NzMAILER-DAEMONTzFrom rX   )r   r[   r1   r!   r   r   ro   r   )r   r!   r   r   r   r   r   e  s    z_mboxMMDFMessage.__init__c             C   s   | j S )N)r]  )r   r   r   r   r   n  s    z_mboxMMDFMessage.get_fromc             C   s4   |d k	r*|dkrt j }|dt j| 7 }|| _d S )NT )r   r   r   r]  )r   r   Ztime_r   r   r   r   r  s
    z_mboxMMDFMessage.set_fromc             C   s   | j dd| j dd S )NStatusr   zX-Status)r+   )r   r   r   r   rJ  z  s    z_mboxMMDFMessage.get_flagsc             C   s   t |}d	\}}x&d
D ]}||kr||7 }|j| qW x&dD ]}||kr>||7 }|j| q>W |djt|7 }y| jd| W n  tk
r   | jd| Y nX y| jd| W n  tk
r   | jd| Y nX d S )Nr   rS  rT  rV  rW  rX  r_  zX-Status)r   r   )rS  rT  )rV  rW  rX  )r  r$   r~   r   replace_headerr&   Z
add_header)r   rK  Zstatus_flagsZxstatus_flagsrM  r   r   r   rL  ~  s&    

z_mboxMMDFMessage.set_flagsc             C   s$   | j djt| j t|B  d S )Nr   )rL  r~   r  rJ  )r   rM  r   r   r   rN    s    z_mboxMMDFMessage.add_flagc             C   s4   d| ksd| kr0| j djt| j t|  d S )Nr_  zX-Statusr   )rL  r~   r  rJ  )r   rM  r   r   r   rO    s    z_mboxMMDFMessage.remove_flagc             C   s  t |trt| j }d|kr(|jd d|kr:|jd d|krL|jd d|kr^|jd d|krp|jd |d	= |d
= dj| j j dd  }y|j	t
jtj|d W n ttfk
r   Y nX n
t |tr|j| j  |j| j  nt |trZt| j }d|kr$|jd d|kr8|jd d|krL|jd |d	= |d
= nt |trt| j }d|kr|jd d|kr|jd d|kr|jd |d	= |d
= nt |trntdt| d S )NrT  r}   rW  rX  rS  rR  rV  rU  Zstatuszx-statusr^  rX   z%a %b %d %H:%M:%S %Yr(  rY  rZ  r)  r*  z$Cannot convert to specified type: %s)r[   r	   r  rJ  r   rN  r~   r   r   r   calendarZtimegmr   ZstrptimerO   OverflowErrorr   rL  r   r   r  r   r\  r   rp   rq   )r   r!   rK  Z
maybe_dater   r   r   rB    s^    



















z_mboxMMDFMessage._explain_to)N)N)rw   rx   ry   rD  r   r   r   rJ  rL  rN  rO  rB  r   r   r   r   r   `  s   
	
r   c               @   s   e Zd ZdS )r
   N)rw   rx   ry   r   r   r   r   r
     s   c               @   sD   e Zd ZdgZdddZdd Zdd Zd	d
 Zdd Zdd Z	dS )r   
_sequencesNc             C   s   g | _ tj| | d S )N)rd  r   r   )r   r!   r   r   r   r     s    zMHMessage.__init__c             C   s   | j d d  S )N)rd  )r   r   r   r   r    s    zMHMessage.get_sequencesc             C   s   t || _d S )N)r7   rd  )r   r   r   r   r   r"    s    zMHMessage.set_sequencesc             C   s6   t |tr"|| jkr2| jj| ntdt| d S )Nzsequence type must be str: %s)r[   rg   rd  r   rp   rq   )r   r'  r   r   r   r    s    

zMHMessage.add_sequencec             C   s*   y| j j| W n tk
r$   Y nX d S )N)rd  r$   rO   )r   r'  r   r   r   remove_sequence  s    zMHMessage.remove_sequencec             C   sJ  t |trdt| j }d|kr*|jd n|jd |jd d|krP|jd d|krb|jd nt |trt| j }d|kr|jd n
|jd	 d|kr|jd d|kr|jd
 nt |trx|| j D ]}|j| qW n`t |t	r(t| j }d|kr|j
d d|krF|j
d nt |tr6ntdt| d S )Nr(  r}   rR  rZ  rW  rY  rS  ROrT  rX  r*  z$Cannot convert to specified type: %s)r[   r	   r  r  r   rN  r   r   r  r   r\  r   rp   rq   )r   r!   r   r'  r   r   r   rB    s@    










zMHMessage._explain_to)N)
rw   rx   ry   rD  r   r  r"  r  re  rB  r   r   r   r   r     s   
c               @   s^   e Zd ZddgZdddZdd Zdd	 Zd
d Zdd Zdd Z	dd Z
dd Zdd ZdS )r   r-  _visibleNc             C   s   g | _ t | _tj| | d S )N)r-  r   rg  r   )r   r!   r   r   r   r   "  s    zBabylMessage.__init__c             C   s   | j d d  S )N)r-  )r   r   r   r   r.  (  s    zBabylMessage.get_labelsc             C   s   t || _d S )N)r7   r-  )r   r5  r   r   r   r0  ,  s    zBabylMessage.set_labelsc             C   s6   t |tr"|| jkr2| jj| ntdt| d S )Nzlabel must be a string: %s)r[   rg   r-  r   rp   rq   )r   r7  r   r   r   r\  0  s    

zBabylMessage.add_labelc             C   s*   y| j j| W n tk
r$   Y nX d S )N)r-  r$   rO   )r   r7  r   r   r   remove_label8  s    zBabylMessage.remove_labelc             C   s
   t | jS )N)r   rg  )r   r   r   r   r=  ?  s    zBabylMessage.get_visiblec             C   s   t || _d S )N)r   rg  )r   Zvisibler   r   r   r/  C  s    zBabylMessage.set_visiblec             C   sj   x6| j j D ](}|| kr,| j j|| |  q| j |= qW x,dD ]$}|| kr>|| j kr>| | | j |< q>W d S )NDateFromReply-ToToCCSubject)ri  rj  rk  rl  rm  rn  )rg  r8   r`  )r   headerr   r   r   update_visibleG  s    
zBabylMessage.update_visiblec             C   sv  t |tr~t| j }d|kr*|jd n|jd |jd d|ksNd|krX|jd d|krj|jd d	|kr||jd
 nt |trt| j }d|kr|jd n
|jd d	|kr|jd d|kr|jd nt |trt| j }d|kr|jd d|krr|jd nXt |t	rT|j
| j  x<| j D ]}|j| q>W nt |trbntdt| d S )Nr(  r}   rR  r+  r,  r[  r*  rS  r)  rU  rf  rT  rV  rX  rY  z$Cannot convert to specified type: %s)r[   r	   r  r.  r   rN  r   r   r  r   r/  r=  r\  r   rp   rq   )r   r!   r5  r7  r   r   r   rB  R  sF    










zBabylMessage._explain_to)N)rw   rx   ry   rD  r   r.  r0  r\  rh  r=  r/  rp  rB  r   r   r   r   r     s   
c               @   s   e Zd ZdS )r   N)rw   rx   ry   r   r   r   r   r   |  s   c               @   s   e Zd Zd%ddZd&ddZd'ddZd(dd	Zd)d
dZdd Zdd Z	d*ddZ
dd Zdd Zdd Zdd Zdd Zdd Zdd  Zd!d" Zed#d$ ZdS )+r   Nc             C   s$   || _ |d kr|j | _n|| _d S )N)r   r   _pos)r   r   posr   r   r   r     s    z_ProxyFile.__init__c             C   s   | j || jjS )N)_readr   rS   )r   sizer   r   r   rS     s    z_ProxyFile.readc             C   s   | j || jjS )N)rs  r   read1)r   rt  r   r   r   ru    s    z_ProxyFile.read1c             C   s   | j || jjS )N)rs  r   rn   )r   rt  r   r   r   rn     s    z_ProxyFile.readlinec             C   s>   g }x4| D ],}|j | |d k	r
|t|8 }|dkr
P q
W |S )Nr   )r   r   )r   sizehintrB   ru   r   r   r   	readlines  s    

z_ProxyFile.readlinesc             c   s    x| j  }|sd S |V  qW d S )N)rn   )r   ru   r   r   r   r;     s
    z_ProxyFile.__iter__c             C   s   | j S )N)rq  )r   r   r   r   r     s    z_ProxyFile.tellr   c             C   s4   |dkr| j j| j | j j|| | j j | _d S )NrW   )r   ra   rq  r   )r   offsetwhencer   r   r   ra     s    z_ProxyFile.seekc          
   C   s0   t | dr,zt | jdr"| jj  W d | `X d S )Nr   rL   )rE   r   rL   )r   r   r   r   rL     s
    
z_ProxyFile.closec             C   s2   |d krd}| j j| j ||}| j j | _|S )NrW   rZ   )r   ra   rq  r   )r   rt  read_methodrB   r   r   r   rs    s    z_ProxyFile._readc             C   s   | S )Nr   )r   r   r   r   	__enter__  s    z_ProxyFile.__enter__c             G   s   | j   d S )N)rL   )r   excr   r   r   __exit__  s    z_ProxyFile.__exit__c             C   s
   | j j S )N)r   readable)r   r   r   r   r~    s    z_ProxyFile.readablec             C   s
   | j j S )N)r   writable)r   r   r   r   r    s    z_ProxyFile.writablec             C   s
   | j j S )N)r   seekable)r   r   r   r   r    s    z_ProxyFile.seekablec             C   s
   | j j S )N)r   rI   )r   r   r   r   rI     s    z_ProxyFile.flushc             C   s&   t | dsdS t | jdsdS | jjS )Nr   Tr
  F)rE   r   r
  )r   r   r   r   r
    s
    
z_ProxyFile.closed)N)N)N)N)N)r   )rw   rx   ry   r   rS   ru  rn   rw  r;   r   ra   rL   rs  r{  r}  r~  r  r  rI   propertyr
  r   r   r   r   r     s"   





		r   c               @   s8   e Zd ZdddZdd ZdddZd	d
 Zdd ZdS )r   Nc             C   s   t j| || || _|| _d S )N)r   r   _start_stop)r   r   r   r   r   r   r   r     s    z_PartialFile.__init__c             C   s   t j| | j S )N)r   r   r  )r   r   r   r   r     s    z_PartialFile.tellr   c             C   s<   |dkr| j | _d}n|dkr*| j| _d}tj| || d S )Nr   rW   rU   )r  rq  r  r   ra   )r   rx  ry  r   r   r   ra     s    z_PartialFile.seekc             C   sB   | j | j }|dkrdS |d ks0|dk s0||kr4|}tj| ||S )Nr   r   )r  rq  r   rs  )r   rt  rz  Z	remainingr   r   r   rs    s    z_PartialFile._readc             C   s   t | dr| `d S )Nr   )rE   r   )r   r   r   r   rL     s    
z_PartialFile.close)NN)r   )rw   rx   ry   r   r   ra   rs  rL   r   r   r   r   r     s
   


	r   Tc          4   C   s  d}yZt rpyt j| t jt jB  W nJ tk
rn } z.|jtjtjtjfkr\t	d| j
 n W Y d d }~X nX |r^yt| j
d }|j  W n: tk
r } z|jtjtjfkrd S  W Y d d }~X nX y`ytj|j
| j
d  d}W n2 ttfk
r   tj|j
| j
d  d}Y nX tj|j
 W n0 tk
r\   tj|j
 t	d| j
 Y nX W n8   t r|t j| t j |rtj| j
d   Y nX d S )NFzlockf: lock unavailable: %sz.lockTzdot lock unavailable: %s)fcntllockfZLOCK_EXZLOCK_NBr   r   ZEAGAINr   r   r   r   r   rL   r   r   r   r   r   r#  r   r$   LOCK_UN)r   r   Zdotlock_doner   Zpre_lockr   r   r   r   
  sH    
r   c             C   s8   t rt j| t j tjj| jd r4tj| jd  d S )Nz.lock)r  r  r  r   r   r   r   r$   )r   r   r   r   r   4  s    r   c             C   s8   t j| t jt jB t jB d}z
t| dS t j| X d S )Ni  zrb+)r   r   r   r  O_RDWRrL   )r   fdr   r   r   r   ;  s    
r   c             C   s$   t d| ttj tj tj 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$   | j   ttdr tj| j  d S )Nfsync)rI   rE   r   r  fileno)r   r   r   r   r   I  s    
r   c             C   s   t |  | j  d S )N)r   rL   )r   r   r   r   r   O  s    r   c               @   s   e Zd ZdS )r   N)rw   rx   ry   r   r   r   r   r   U  s   c               @   s   e Zd ZdS )r   N)rw   rx   ry   r   r   r   r   r   X  s   c               @   s   e Zd ZdS )r   N)rw   rx   ry   r   r   r   r   r   [  s   c               @   s   e Zd ZdS )r   N)rw   rx   ry   r   r   r   r   r   ^  s   c               @   s   e Zd ZdS )r   N)rw   rx   ry   r   r   r   r   r   a  s   )T)/r   r   rb  r   r   r@  rj   r1   Zemail.messageZemail.generatorr\   r-   r  ImportError__all__rc   rM   r   r   r   r   r   r   r   r   r!   r   r	   r   r
   r   r   r   r   r   r   r   r   r   r   r   	Exceptionr   r   r   r   r   r   r   r   r   <module>	   sn   

 h  8 DB4-  3 z%mqH_c'
*