a
XC?hüX ã @ s² d dgZ ddlZddlmZ ddlmZ ddlmZ ddlm Z e
d¡Z e
d ¡Z e
d
¡Z
e
d ¡Ze
d ¡Zd Zd
Zeƒ ZG dd„ deƒZG dd „ d ƒZG dd„ deƒZdS )Ú
FeedParserÚBytesFeedParseré N)Úerrors)Úcompat32)Údeque)ÚStringIOz
\r\n|\r|\nz (\r\n|\r|\n)z(\r\n|\r|\n)\Zz%^(From |[\041-\071\073-\176]*:|[\t ])Ú Ú
c @ s\ e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zd d
„ Zd d „ Zd
d„ Z dd„ Z
dd„ Z dd„ Z dS )ÚBufferedSubFilec C s$ t dd| _tƒ | _g | _d| _d S )Nr )ÚnewlineF)r Ú_partialr Ú_linesÚ _eofstackÚ_closed©Úself© r ú5/opt/alt/python39/lib64/python3.9/email/feedparser.pyÚ__init__5 s zBufferedSubFile.__init__c C s | j |¡ d S ©N)r Úappend)r Zpredr r r Úpush_eof_matcher@ s z BufferedSubFile.push_eof_matcherc C s
| j ¡ S r )r Úpopr r r r Úpop_eof_matcherC s z BufferedSubFile.pop_eof_matcherc C s< | j d¡ | | j ¡ ¡ | j d¡ | j ¡ d| _d S )Nr T)r ÚseekÚ pushlinesÚ readlinesÚtruncater r r r r ÚcloseF s
zBufferedSubFile.closec C sL | j s| jrdS tS | j ¡ }t| jƒD ] }||ƒr(| j |¡ dS q(|S ©Nr )r
r Ú NeedMoreDataÚpopleftÚreversedr Ú
appendleft)r ÚlineZateofr r r ÚreadlineN s
zBufferedSubFile.readlinec C s | j |¡ d S r )r
r# ©r r$ r r r Ú
unreadline` s zBufferedSubFile.unreadlinec C sx | j |¡ d|vr d|vr d S | j d¡ | j ¡ }| j d¡ | j ¡ |d d¡sj| j | ¡ ¡ | |¡ d S )Nr ú
r éÿÿÿÿ)r Úwriter r r Úendswithr r )r ÚdataÚpartsr r r Úpushe s
zBufferedSubFile.pushc C s | j |¡ d S r )r
Úextend)r Úlinesr r r r z s zBufferedSubFile.pushlinesc C s | S r r r r r r Ú__iter__} s zBufferedSubFile.__iter__c C s | ¡ }|dkrt‚|S r )r% Ú
StopIterationr& r r r Ú__next__€ s zBufferedSubFile.__next__N)
Ú__name__Ú
__module__Ú __qualname__r r r r r% r' r. r r1 r3 r r r r r
- s r
c @ s\ e Zd Zdedœdd„Zdd„ Zdd„ Zd d
„ Zd d „ Zd
d„ Z dd„ Z
dd„ Z dd„ Z dS )r N©Úpolicyc C sœ || _ d| _|d u r<|jd u r2ddlm} || _ql|j| _n0|| _z|| j d W n tyj d| _Y n0 tƒ | _g | _ |
¡ j | _ d | _
d | _d| _d S )NFr )ÚMessager7 T)r8 Ú_old_style_factoryZmessage_factoryZ
email.messager9 Ú_factoryÚ TypeErrorr
Ú_inputÚ _msgstackÚ _parsegenr3 Ú_parseÚ_curÚ_lastÚ _headersonly)r r; r8 r9 r r r r ‹ s$
zFeedParser.__init__c C s
d| _ d S )NT)rC r r r r Ú_set_headersonlyª s zFeedParser._set_headersonlyc C s | j |¡ | ¡ d S r )r= r. Ú _call_parse©r r, r r r Úfeed s zFeedParser.feedc C s$ z | ¡ W n ty Y n0 d S r )r@ r2 r r r r rE ² s zFeedParser._call_parsec C sH | j ¡ | ¡ | ¡ }| ¡ dkrD| ¡ sDt ¡ }| j ||¡ |S )NÚ multipart)
r= r rE Ú _pop_messageÚget_content_maintypeZ is_multipartr Z!MultipartInvariantViolationDefectr8 Ú
handle_defect)r ÚrootÚdefectr r r r ¸ s
ÿzFeedParser.closec C sn | j r| ¡ }n| j| jd}| jr<| j ¡ dkr<| d¡ | jrR| jd |¡ | j |¡ || _|| _ d S )Nr7 zmultipart/digestzmessage/rfc822r) )
r: r; r8 rA Úget_content_typeZset_default_typer> Zattachr rB )r Úmsgr r r Ú _new_messageÅ s
zFeedParser._new_messagec C s( | j ¡ }| j r | j d | _nd | _|S )Nr) )r> r rA )r Úretvalr r r rI Ò s
zFeedParser._pop_messagec c s | ¡ g }| jD ]Z}|tu r&tV qt |¡sbt |¡s^t ¡ }| j | j
|¡ | j |¡ qn| |¡ q|
|¡ | jrÈg }| j ¡ }|tu rœtV q‚|dkr¦q²| |¡ q‚| j
t |¡¡ d S | j
¡ dkrŠ| j tj¡ | ¡ D ] }|tu rtV qî q qî| ¡ }| j ¡ | j ¡ }|tu rDtV q qDq | j ¡ }|tu rjtV qDqjqD|dkrxq†| j |¡ qØd S | j
¡ dkrÐ| ¡ D ] }|tu rºtV q¢ qÄq¢| ¡ d S | j
¡ dkrÔ| j
¡ }|d u rRt ¡ }| j | j
|¡ g }| jD ]$}|tu r.tV q| |¡ q| j
t |¡¡ d S t| j
dd¡ƒ ¡ dvr†t ¡ }| j | j
|¡ d| }t d t !|¡ d
¡} d }
g } d } d }
| j ¡ }|tu rÔtV q¶|dkrâqÂ| |¡}|r´| "d
¡rd }
| "d¡} qÂ|
rr| r^| d }t# $|¡}|rP|d t%| "d¡ƒ … | d< t | ¡| j
_&d }
| j |¡ q¶| j ¡ }|tu rtV qr| |¡}|sr| j |¡ q´qr| j | j¡ | ¡ D ] }|tu râtV qÊ qìqÊ| j' ¡ dkrT| j'j(}|dkrd | j'_(n:|d ur˜t# $|¡}|r˜t%| "d¡ƒ}|d | … | j'_(nD| j'j)}t*|tƒr˜t# $|¡}|r˜|d t%| "d¡ƒ … }|| j'_)| j ¡ | ¡ | j
| _'n
| |¡ q¶|
r*t +¡ }| j | j
|¡ | j
t | ¡¡ g }| jD ]}|tu rütV qüqüt |¡| j
_(d S |
sLt ,¡ }| j | j
|¡ d S | rZdg}ng }| jD ]$}|tu r|tV qd| |¡ qd|rÂ|d }t- |¡}|rÂ|t%| "d¡ƒd … |d< t |¡| j
_(d S g }| jD ]$}|tu rötV qÞ| |¡ qÞ| j
t |¡¡ d S )Nr zmessage/delivery-statusÚmessagerH zcontent-transfer-encodingÚ8bit)Z7bitrS Zbinaryz--z(?Pz4)(?P--)?(?P[ \t]*)(?P\r\n|\r|\n)?$TFÚendÚlinesepr) r ).rP r= r ÚheaderREÚmatchÚNLCREr Z MissingHeaderBodySeparatorDefectr8 rK rA r' r Ú_parse_headersrC r% Z set_payloadÚ EMPTYSTRINGÚjoinrN r r? rI r rJ Z get_boundaryZNoBoundaryInMultipartDefectÚstrÚgetÚlowerZ-InvalidMultipartContentTransferEncodingDefectÚreÚcompileÚescapeÚgroupÚ NLCRE_eolÚsearchÚlenÚpreamblerB ÚepilogueZ_payloadÚ
isinstanceZStartBoundaryNotFoundDefectZCloseBoundaryNotFoundDefectÚ NLCRE_bol)r Zheadersr$ rM r0 rQ rO ÚboundaryZ separatorZ
boundaryreZcapturing_preamblerf rU Zclose_boundary_seenÚmoZlastlineZeolmorg rT ZpayloadÚ firstlineZbolmor r r r? Ú s`
ÿ ÿÿ
zFeedParser._parsegenc C sX d}g }t |ƒD ]&\}}|d dv rR|sFt |¡}| j | j|¡ q| |¡ q|rt| jj| j |¡Ž dg }}| d¡rø|dkr¼t
|¡}|r¬|d t |
d¡ƒ … }| j |¡ qn<|t |ƒd krÞ| j |¡ d S t |¡}| jj |¡ q| d¡}|dkr&t d¡}| jj |¡ q|d |… }|g}q|rT| jj| j |¡Ž d S )Nr r z zFrom é ú:zMissing header name.)Ú enumerater Z#FirstHeaderLineIsContinuationDefectr8 rK rA r Zset_rawZheader_source_parseÚ
startswithrc rd re rb Z set_unixfromr= r' Z MisplacedEnvelopeHeaderDefectZdefectsÚfindZInvalidHeaderDefect) r r0 Z
lastheaderZ lastvalueÚlinenor$ rM rk Úir r r rY × sF
zFeedParser._parse_headers)N)
r4 r5 r6 r r rD rG rE r rP rI r? rY r r r r r ˆ s
~c s e Zd Z‡ fdd„Z‡ ZS )r c s t ƒ | dd¡¡ d S )NÚasciiÚsurrogateescape)ÚsuperrG ÚdecoderF ©Ú __class__r r rG s zBytesFeedParser.feed)r4 r5 r6 rG Ú
__classcell__r r rx r r s )Ú__all__r_ Zemailr Zemail._policybaser Ú collectionsr Úior r` rX ri rc Z NLCRE_crackrV rZ ÚNLÚobjectr r
r r r r r r Ú s&
[