File manager



���]�Y�@s
dd
gZddl
Z
ddlmZ
ddlmZ
ddlmZ
ddlmZ
ddl	m
Z

e
jd	�
Ze
jd
�
Z
e
jd�
Ze
jd
�
Ze
jd�
Zd
ZdZe�ZGdd�de�ZGdd�d�ZGdd
�d
e�ZdS)�
FeedParser�BytesFeedParser�N)
�errors)
�message)
�compat32)
�deque)
�StringIOz
|
|
z(
|
|
)z
(
|
|
)\Zz%^(From |[\041-\071\073-\176]*:|[\t ])��

c@s�eZ
dZd
d�Zdd�Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	dd�Z
dd�Zdd�ZdS)�BufferedSubFilec

Cs4td
d�
|_
t�|_g|_d|_dS)N�newliner	F)r�_partialr�_lines�	_eofstack�_closed)
�self�r�//opt/alt/python35/lib64/python3.5/feedparser.py�__init__6s	zBufferedSubFile.__init__cCs|jj
|
�

dS)
N)r�append)rZpredrrr�push_eof_matcherAs
z BufferedSubFile.push_eof_matcherc


Cs
|jj
�S)
N)r�pop)
rrrr�pop_eof_matcherDs
zBufferedSubFile.pop_eof_matcherc

CsP|jj
d
�

|j|jj��

|jj
d
�

|jj�
d|_dS)NrT)r
�seek�	pushlines�	readlines�truncater)
rrrr�closeGs





zBufferedSubFile.closec
Csg|js|j
rd
StS|jj�}
x7t|j�
D]&}||
�
r9|jj|
�

d
Sq9W|
S)Nr	)rr�NeedMoreData�popleft�reversedr�
appendleft)r�lineZateofrrr�readlineOs
	
	




zBufferedSubFile.readlinecCs|jj
|
�

dS)
N)rr!)rr"rrr�
unreadlineaszBufferedSubFile.unreadlinecCs�|jj
|
�

d
|
kr,d|
kr,dS|jjd�

|jj�}|jjd�

|jj�
|djd
�
s�|jj
|j��

|j|�

dS)Nr
�

r�
���)r
�writerrr�endswithrr)r�data�partsrrr�pushfs






zBufferedSubFile.pushcCs|jj
|
�

dS)
N)r�extend)r�linesrrrr{s
zBufferedSubFile.pushlinesc


Cs|S)
Nr)
rrrr�__iter__~s
zBufferedSubFile.__iter__c
Cs"|j�}
|
d
krt
�
|
S)Nr	)r#�
StopIteration)rr"rrr�__next__�s



zBufferedSubFile.__next__N)
�__name__�
__module__�__qualname__rrrrr#r$r,rr/r1rrrrr.src@s�eZ
dZd
dedd�

Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	dd�Z
dd�Zdd�Zd
S)r
N�policyc
Cs�||_d
|_
|
dkrK|jtkr<tj|_q�tj|_n;|
|_y|
d|j�

Wntk
r�


d|_
Yn
Xt�|_	g|_
|j�j|_
d|_d|_d
|_dS)NFr5T)r5�_old_style_factoryrrZMessage�_factoryZEmailMessage�	TypeErrorr�_input�	_msgstack�	_parsegenr1�_parse�_cur�_last�_headersonly)rr7r5rrrr�s"	
	

	





	

	
	
zFeedParser.__init__c

Cs
d
|_dS)NT)
r?)
rrrr�_set_headersonly�s
zFeedParser._set_headersonlycCs|jj
|
�

|j�
dS)
N)r9r,�_call_parse)rr*rrr�feed�s
zFeedParser.feedc

Cs'y|j�
Wnt
k
r"


Yn
XdS)
N)r<r0)
rrrrrA�s




zFeedParser._call_parsec
Cse|jj
�
|j�
|j�}
|
j�d
kra|
j�ratj�}|jj	|
|�
|
S)N�	multipart)
r9rrA�_pop_message�get_content_maintypeZis_multipartrZ!MultipartInvariantViolationDefectr5�
handle_defect)r�root�defectrrrr�s








zFeedParser.closec
Cs�|jr|j
�}
n|j
d
|j�
}
|jrX|jj�dkrX|
jd�

|jru|jdj|
�

|jj|
�

|
|_|
|_	dS)Nr5zmultipart/digestzmessage/rfc822r&r')
r6r7r5r=�get_content_typeZset_default_typer:Zattachrr>)r�msgrrr�_new_message�s
	




	


	
zFeedParser._new_messagec
Cs8|jj
�}
|jr+|jd|_n	d|_|
S)Nr&r')r:rr=)r�retvalrrrrD�s


	
	
zFeedParser._pop_messagec
cs�|j�
g}
x�|j
D]x}|tkr4tV
qtj|�
s�tj|�
s�tj�}|jj	|j
|�
|j
j|�

P|
j|�

qW|j
|
�

|jr
g}xA|j
j�}|tkr�tV
q�|d
kr�P|j|�

q�W|j
jtj|�
�

dS|j
j�dkr�
x�|j
jtj�

x)|j�D]}|tkre
tV
qK
PqK
W|j�}|j
j�
x(|j
j�}|tkr�
tV
q�
Pq�
Wx(|j
j�}|tkr�
tV
q�
Pq�
W|d
kr�
P|j
j|�

q+
WdS|j
j�dkrMx)|j�D]}|tkr:tV
q Pq W|j�
dS|j
j�dkrv|j
j�}|dkr�tj�}|jj	|j
|�
g}x2|j
D]'}|tkr�tV
q�|j|�

q�W|j
jtj|�
�

dS|j
jdd�j�dkr:tj�}|jj	|j
|�
d	|}tjd
tj |�
d�
}	d}
g}d
}d
}
x�|j
j�}|tkr�tV
q|d
kr�P|	j|�
}|r|j!d�
r�d}
|j!d�
}P|
rf|rM|d}t"j#|�
}|r8|dt$|j!d�
�
�|d<tj|�
|j
_%d
}
|j
j|�

qxM|j
j�}|tkr�tV
qi|	j|�
}|si|j
j|�

PqiW|j
j|	j�

x)|j�D]}|tkr�tV
q�Pq�W|j&j�dkr�|j&j'}|d
kr1d|j&_'q�|dk	r�t"j#|�
}|r�t$|j!d�
�
}|d|�|j&_'n\|j&j(}t)|t*�r�t"j#|�
}|r�|dt$|j!d�
�
�}||j&_(|j
j�
|j�
|j
|_&q|j|�

qW|
r�tj+�}|jj	|j
|�
|j
jtj|�
�

g}x%|j
D]}|tkretV
qeqeWtj|�
|j
_'dS|
s�tj,�}|jj	|j
|�
dS|r�d
g
}ng}x2|j
D]'}|tkrtV
q�|j|�

q�W|r]|d}t-j|�
}|r]|t$|j!d�
�
d�|d<tj|�
|j
_'dSg}x2|j
D]'}|tkr�tV
q�|j|�

q�W|j
jtj|�
�

dS)Nr	zmessage/delivery-statusrrCzcontent-transfer-encoding�8bit�7bit�binaryz--z(?P<sep>z4)(?P<end>--)?(?P<ws>[ \t]*)(?P<linesep>\r\n|\r|\n)?$TF�end�linesepr&r)rNrMrOr'r').rKr9r�headerRE�match�NLCRErZ MissingHeaderBodySeparatorDefectr5rFr=r$r�_parse_headersr?r#Zset_payload�EMPTYSTRING�joinrIrr;rDrrEZget_boundaryZNoBoundaryInMultipartDefect�get�lowerZ-InvalidMultipartContentTransferEncodingDefect�re�compile�escape�group�	NLCRE_eol�search�len�preambler>�epilogueZ_payload�
isinstance�strZStartBoundaryNotFoundDefectZCloseBoundaryNotFoundDefect�	NLCRE_bol)rZheadersr"rHr.rLrJ�boundaryZ	separatorZ
boundaryreZcapturing_preamblerarQZclose_boundary_seen�moZlastlineZeolmorbrPZpayload�	firstlineZbolmorrrr;�sf













	
























































	





























$




























 




























#







zFeedParser._parsegenc	Cs�
d
}g}x�
t|
�
D]�
\}}|ddkrs|sct
j|�
}|jj|j|�
q|j|�

q|r�|jj|jj|�
�
d
g}}|j	d�
rW
|dkr
t
j|�
}|r�|dt|j
d�
�
�}|jj|�

qnO|t|
�
dkr2
|jj|�

dSt
j|�
}|jjj|�

q|jd�
}|dkr�
t
jd�
}|jjj|�

q|d|�}|g
}qW|r�
|jj|jj|�
�
dS)Nr	rz 	zFrom r&�
:zMissing header name.)�	enumeraterZ#FirstHeaderLineIsContinuationDefectr5rFr=rZset_rawZheader_source_parse�
startswithr^r_r`r]Zset_unixfromr9r$ZMisplacedEnvelopeHeaderDefectZdefects�findZInvalidHeaderDefect)	rr.Z
lastheaderZ	lastvalue�linenor"rHrg�
irrrrU�
sF














 











zFeedParser._parse_headers)
r2r3r4rrr@rBrArrKrDr;rUrrrrr
�s!

�cs"eZ
dZ�f
d
d�Z�S)rcs t�j
|
jd
d��

dS)N�ascii�surrogateescape)�superrB�decode)rr*)
�	__class__rrrBs
zBytesFeedParser.feed)r2r3r4rBrr)
rsrrs)�__all__rZZemailrrZemail._policybaser�collectionsr�iorr[rTrer^ZNLCRE_crackrRrV�NL�objectrrr
rrrrr�<module>s$








	[��