]Y @ s d d g Z d d l Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m
Z
e j d Z e j d
Z
e j d Z e j d
Z e j d Z d
Z d Z e Z Gd d d e Z Gd d d Z Gd d d e Z d S)
FeedParserBytesFeedParser N)errors)message)compat32)deque)StringIOz
|
|
z(
|
|
)z
(
|
|
)\Zz%^(From |[\041-\071\073-\176]*:|[\t ])
c @ s e Z 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)BufferedSubFilec C s4 t d d | _ t | _ g | _ d | _ d S)Nnewliner F)r _partialr _lines _eofstack_closed)self r //opt/alt/python35/lib64/python3.5/feedparser.py__init__6 s zBufferedSubFile.__init__c C s | j j | d S)N)r append)r Zpredr r r push_eof_matcherA s z BufferedSubFile.push_eof_matcherc C s
| j j S)N)r pop)r r r r pop_eof_matcherD s z BufferedSubFile.pop_eof_matcherc C sP | j j d | j | j j | j j d | j j d | _ d S)Nr T)r
seek pushlines readlinestruncater )r r r r closeG s
zBufferedSubFile.closec C sg | j s | j r d St S| j j } x7 t | j D]& } | | r9 | j j | d Sq9 W| S)Nr )r r NeedMoreDatapopleftreversedr
appendleft)r lineZateofr r r readlineO s zBufferedSubFile.readlinec C s | j j | d S)N)r r! )r r" r r r
unreadlinea s zBufferedSubFile.unreadlinec C s | j j | d | k r, d | k r, d S| j j d | j j } | j j d | j j | d j d s | j j | j | j | d S)Nr
r )r
writer r r endswithr r )r datapartsr r r pushf s
zBufferedSubFile.pushc C s | j j | d S)N)r extend)r linesr r r r { s zBufferedSubFile.pushlinesc C s | S)Nr )r r r r __iter__~ s zBufferedSubFile.__iter__c C s" | j } | d k r t | S)Nr )r#
StopIteration)r r" r r r __next__ s zBufferedSubFile.__next__N)
__name__
__module__ __qualname__r r r r r# r$ r, r r/ r1 r r r r r . s r c @ s e Z d Z d d e 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 Npolicyc C s | | _ d | _ | d k rK | j t k r< t j | _ q t j | _ n; | | _ y | d | j Wn t k
r d | _ Yn Xt | _ g | _
| j j | _
d | _ d | _ d | _ d S)NFr5 T)r5 _old_style_factoryr r ZMessage_factoryZ EmailMessage TypeErrorr _input _msgstack _parsegenr1 _parse_cur_last _headersonly)r r7 r5 r r r r s"
zFeedParser.__init__c C s
d | _ d S)NT)r? )r r r r _set_headersonly s zFeedParser._set_headersonlyc C s | j j | | j d S)N)r9 r, _call_parse)r r* r r r feed s zFeedParser.feedc C s' y | j Wn t k
r" Yn Xd S)N)r< r0 )r r r r rA s
zFeedParser._call_parsec C se | j j | j | j } | j d k ra | j ra t j } | j j | | | S)N multipart)
r9 r rA _pop_messageget_content_maintypeZ is_multipartr Z!MultipartInvariantViolationDefectr5
handle_defect)r rootdefectr r r r s
zFeedParser.closec C s | j r | j } n | j d | j } | j rX | j j d k rX | j d | j ru | j d j | | j j | | | _ | | _ d S)Nr5 zmultipart/digestzmessage/rfc822r& r' )
r6 r7 r5 r= get_content_typeZset_default_typer: Zattachr r> )r msgr r r _new_message s
zFeedParser._new_messagec C s8 | j j } | j r+ | j d | _ n d | _ | S)Nr& r' )r: r r= )r retvalr r r rD s
zFeedParser._pop_messagec c s | j g } x | j D]x } | t k r4 t Vq t j | s t j | s t j } | j j | j
| | j j | P| j | q W| j
| | j rg } xA | j j } | t k r t Vq | d k r P| j | q W| j
j t j | d S| j
j d k rx | j j t j x) | j D] } | t k ret VqKPqKW| j } | j j x( | j j } | t k rt VqPqWx( | j j } | t k rt VqPqW| d k rP| j j | q+Wd S| j
j d k rMx) | j D] } | t k r:t Vq Pq W| j d S| j
j d k rv| j
j } | d k rt j } | j j | j
| g } x2 | j D]' } | t k rt Vq| j | qW| j
j t j | d S| j
j d d j d k r:t j } | j j | j
| d | } t j d
t j | d } d }
g } d
} d
}
x| j j } | t k rt Vq| d k rP| j | } | r| j! d rd }
| j! d } P|
rf| rM| d } t" j# | } | r8| d t$ | j! d | d <t j | | j
_% d
}
| j j | qxM | j j } | t k rt Vqi| j | } | si| j j | PqiW| j j | j x) | j D] } | t k rt VqPqW| j& j d k r| j& j' } | d k r1d | j& _' q| d k rt" j# | } | rt$ | j! d } | d | | j& _' n\ | j& j( } t) | t* rt" j# | } | r| d t$ | j! d } | | j& _( | j j | j | j
| _& q| j | qW|
rt j+ } | j j | j
| | j
j t j | g } x% | j D] } | t k ret VqeqeWt j | | j
_' d S|
st j, } | j j | j
| d S| rd g } n g } x2 | j D]' } | t k rt Vq| j | qW| r]| d } t- j | } | r]| t$ | j! d d | d <t j | | j
_' d Sg } x2 | j D]' } | t k rt Vq| j | qW| j
j t j | d S)Nr zmessage/delivery-statusr rC zcontent-transfer-encoding8bit7bitbinaryz--z(?P<sep>z4)(?P<end>--)?(?P<ws>[ \t]*)(?P<linesep>\r\n|\r|\n)?$TFendlinesepr& r )rN rM rO r' r' ).rK r9 r headerREmatchNLCREr Z MissingHeaderBodySeparatorDefectr5 rF r= r$ r _parse_headersr? r# Z set_payload EMPTYSTRINGjoinrI r r; rD r rE Z get_boundaryZNoBoundaryInMultipartDefectgetlowerZ-InvalidMultipartContentTransferEncodingDefectrecompileescapegroup NLCRE_eolsearchlenpreambler> epilogueZ_payload
isinstancestrZStartBoundaryNotFoundDefectZCloseBoundaryNotFoundDefect NLCRE_bol)r Zheadersr" rH r. rL rJ boundaryZ separatorZ
boundaryreZcapturing_preamblera rQ Zclose_boundary_seenmoZlastlineZeolmorb rP Zpayload firstlineZbolmor r r r; sf
$
# zFeedParser._parsegenc C s d } g } xt | D]\ } } | d d k rs | sc t j | } | j j | j | q | j | q | r | j j | j j | d g } } | j d rW| d k rt
j | } | r | d t | j
d } | j j | q nO | t | d k r2| j j | d St j | } | j j j | q | j d } | d k rt j d } | j j j | q | d | } | g } q W| r| j j | j j | d S)Nr r z zFrom r& :zMissing header name.) enumerater Z#FirstHeaderLineIsContinuationDefectr5 rF r= r Zset_rawZheader_source_parse
startswithr^ r_ r` r] Z set_unixfromr9 r$ Z MisplacedEnvelopeHeaderDefectZdefectsfindZInvalidHeaderDefect) r r. Z
lastheaderZ lastvaluelinenor" rH rg ir r r rU sF
zFeedParser._parse_headers)
r2 r3 r4 r r r@ rB rA r rK rD r; rU r r r r r s !
c s" e Z d Z f d d Z S)r c s t j | j d d d S)Nasciisurrogateescape)superrB decode)r r* ) __class__r r rB s zBytesFeedParser.feed)r2 r3 r4 rB r r )rs r r s )__all__rZ Zemailr r Zemail._policybaser collectionsr ior r[ rT re r^ Z NLCRE_crackrR rV NLobjectr r r r r r r r <module> s$ [