\dXXdZddgZddlZddlmZddlmZddlmZddl m Z ej d Z ej d Z ej d Zej d Zej d Zd ZdZeZGddeZGddZGddeZdS)aFeedParser - An email feed parser. The feed parser implements an interface for incrementally parsing an email message, line by line. This has advantages for certain applications, such as those reading email messages off a socket. FeedParser.feed() is the primary interface for pushing new data into the parser. It returns when there's nothing more it can do with the available data. When you have no more data to push into the parser, call .close(). This completes the parsing and returns the root message object. The other advantage of this parser is that it will never raise a parsing exception. Instead, when it finds something unexpected, it adds a 'defect' to the current message. Defects are just instances that live on the message object's .defects attribute. FeedParserBytesFeedParserN)errors)compat32)deque)StringIOz \r\n|\r|\nz (\r\n|\r|\n)z(\r\n|\r|\n)\Zz%^(From |[\041-\071\073-\176]*:|[\t ]) cNeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d S) BufferedSubFileakA file-ish object that can have new data loaded into it. You can also push and pop line-matching predicates onto a stack. When the current predicate matches the current line, a false EOF response (i.e. empty string) is returned instead. This lets the parser adhere to a simple abstraction -- it parses until EOF closes the current message. crtd|_t|_g|_d|_dS)Nr )newlineF)r_partialr_lines _eofstack_closedselfs !..\python\lib\email\feedparser.py__init__zBufferedSubFile.__init__5s3!,,, gg  c:|j|dSN)rappend)rpreds rpush_eof_matcherz BufferedSubFile.push_eof_matcher@s d#####rc4|jSr)rpoprs rpop_eof_matcherzBufferedSubFile.pop_eof_matcherCs~!!###rc|jd||j|jd|jd|_dS)NrT)rseek pushlines readlinestruncaterrs rclosezBufferedSubFile.closeFsm 1 t}..00111 1     rc|js|jrdStS|j}t |jD]*}||r|j|dS+|SNr )rr NeedMoreDatapopleftreversedr appendleft)rlineateofs rreadlinezBufferedSubFile.readlineNs{ | r {""$$dn--  EuT{{  &&t,,,rr  rcP|tusJ|j|dSr)r(rr+rr,s r unreadlinezBufferedSubFile.unreadline`s/<'''' t$$$$$rc|j|d|vrd|vrdS|jd|j}|jd|j|dds,|j|||dS)z$Push some new data into this object.r  Nr)rwriter!r#r$endswithrr")rdatapartss rpushzBufferedSubFile.pushes D!!! t  D 0 0 F 1 '')) 1    Ry!!$'' - M   , , , urc:|j|dSr)rextend)rliness rr"zBufferedSubFile.pushlineszs 5!!!!!rc|Srrs r__iter__zBufferedSubFile.__iter__}s rcH|}|dkrt|Sr')r. StopIterationr0s r__next__zBufferedSubFile.__next__s#}} 2::  rN)__name__ __module__ __qualname____doc__rrrr%r.r1r9r"r?rBr>rrr r -s   $$$$$$$%%% *"""rr cPeZdZdZd eddZdZdZdZdZ d Z d Z d Z d Z dS)rzA feed-style parser of email.Npolicycf||_d|_|"|jddlm}||_n>|j|_n1||_ ||jn#t $r d|_YnwxYwt|_g|_ | j |_ d|_ d|_d|_dS)a_factory is called with no arguments to create a new message obj The policy keyword specifies a policy object that controls a number of aspects of the parser's operation. The default policy maintains backward compatibility. FNr)MessagerHT)rI_old_style_factorymessage_factory email.messagerK_factory TypeErrorr _input _msgstack _parsegenrB_parse_cur_last _headersonly)rrOrIrKs rrzFeedParser.__init__s "'  %-111111 ' & 6 $DM / ,,,,, / / /*.''' /&'' nn&&/   !sA A! A!cd|_dS)NT)rWrs r_set_headersonlyzFeedParser._set_headersonlys rcb|j||dS)zPush more data into the parser.N)rQr9 _call_parse)rr7s rfeedzFeedParser.feeds0  rcR |dS#t$rYdSwxYwr)rTrArs rr[zFeedParser._call_parses:  KKMMMMM    DD s  &&cN|j||}|jrJ|dkrB|s.tj}|j |||S)z!!!  $ $ & &+ 5 5((** 6=??F K % %dF 3 3 3 rc|jr|}n||j}|jr2|jdkr|d|jr |jd||j|||_||_ dS)NrHzmultipart/digestzmessage/rfc822r4) rLrOrIrUget_content_typeset_default_typerRattachrrV)rmsgs r _new_messagezFeedParser._new_messages  " 4--//CC--t{-33C 9 333559KKK  !1 2 2 2 > + N2  % %c * * * c"""  rcz|j}|jr|jd|_nd|_|S)Nr4)rRrrU)rretvals rr`zFeedParser._pop_messages;##%% > r*DIIDI rc#K|g}|jD]}|tur tVt|sit |sMt j}|j |j ||j |n| || ||jrg} |j}|tur tV-|dkrn| |I|j t"|dS|j dkr |jt j|D]}|tur tV|}|j |j}|tur tV- |j}|tur tV- |dkrn|j |dS|j dkr@|D]}|tur tV|dS|j dkr |j }|t j}|j |j |g}|jD]*}|tur tV| |+|j t"|dSt7|j dddvr3t j}|j |j |d |z}t?j d t?j!|zd z} d} g} d } d } |j}|tur tV-|dkrn| |}|r|"d rd} |"d} n| r| rv| d}tF$|}|r.|dtK|"d | d<t"| |j _&d } |j | |j}|tur tV-| |}|s|j |n_|j| j|D]}|tur tV|j'dkru|j'j(}|dkr d|j'_(n|StF$|}|r7tK|"d}|d| |j'_(nt|j'j)}tU|t6rStF$|}|r7|dtK|"d }||j'_)|j||j |_'n| sJ| || rt j+}|j |j ||j t"| g}|jD]}|tur tVt"||j _(dS| s5t j,}|j |j |dS| rdg}ng}|jD]*}|tur tV| |+|rQ|d}tZ|}|r-|tK|"dd|d<t"||j _(dSg}|jD]*}|tur tV| |+|j t"|dS)NTr zmessage/delivery-statusmessager_zcontent-transfer-encoding8bit)7bitrqbinaryz--z(?Pz4)(?P--)?(?P[ \t]*)(?P\r\n|\r|\n)?$Fendlinesepr4r).rlrQr(headerREmatchNLCREr MissingHeaderBodySeparatorDefectrIrdrUr1r_parse_headersrWr. set_payload EMPTYSTRINGjoinrhrrSr`rra get_boundaryNoBoundaryInMultipartDefectstrgetlower-InvalidMultipartContentTransferEncodingDefectrecompileescapegroup NLCRE_eolsearchlenpreamblerVepilogue_payload isinstanceStartBoundaryNotFoundDefectCloseBoundaryNotFoundDefect NLCRE_bol)rheadersr,rfr<rnrkboundary separator boundaryrecapturing_preamblerruclose_boundary_seenmolastlineeolmorrtpayload firstlinebolmos rrSzFeedParser._parsegens  K ! !D|##"""">>$'' {{4((1#DFFFK--di@@@K**4000 NN4  G$$$   E #{++--<''&&&&2:: T""" # I ! !+"2"25"9"9 : : : F 9 % % ' '+D D D  - ,,U[999"nn..F--**** '')) ++--- ;//11D|++**** ;//11D|++**** 2:: &&t,,,? -@ F 9 ) ) + +y 8 8..**  \))&&&&       F 9 ) ) + +{ : :y--//H  ;== ))$)V<<< K''D|++**** LL&&&& %%k&6&6u&=&=>>>DIMM"=vFFGGMMOO566MOO ))$)V<<< xIRYy111GHIIJ"& HG"' O *{++--<''&&&&2::%%d++G* xx.2+"$((9"5"5) !#L(0|H$-$4$4X$>$>E$O/78M#ekk!nn:M:M9M8M/N 1<1A1A(1K1KDI.-2* ..t444 "#{3355<//"....$'--d33!" K224888!"K001ABBB"&.."2"2!\11"....$ z6688KGG#':#6#r>>26DJ//%1!*!1!1(!;!;B!F&)"((1++&6&66>uuo 3"&*"5%gs33>!*!1!1'!:!:B!>*12DC 4D4D3D2D*E6= 3K//111%%'''"&DJJ.---OOD)))_O *f" ;== ))$)V<<< %%k&6&6x&@&@AAA K!!D|++**** ,&1%5%5h%?%? "' ;== ))$)V<<< 4  & &<''&&&&%%%% B$QK ! 22B"+C A,?,?,@,@"AHQK!,!1!1(!;!;DI  FK  D|##"""" LL     k..u5566666rc@d}g}t|D]\}}|ddvrM|s5tj|}|j|j|G||]|r+|jj|j|dg}}| dr|dkrct |}|r+|dt| d }|j||t|dz kr|j|dStj|}|jj|p|d}|dkr5tjd}|jj||dks Jd|d|}|g}|r)|jj|j|dSdS) Nr rz zFrom :zMissing header name.z3_parse_headers fed line with no : and no leading WS) enumerater#FirstHeaderLineIsContinuationDefectrIrdrUrset_rawheader_source_parse startswithrrrr set_unixfromrQr1MisplacedEnvelopeHeaderDefectdefectsfindInvalidHeaderDefect) rr< lastheader lastvaluelinenor,rfris rrzzFeedParser._parse_headerss?  %e,,3 3 LFDAw%!$GMMFK--di@@@  &&& /! !4;#B#B9#M#MNN(*BI w'' Q;;"))$//B8#$6c"((1++&6&6%6$67I**4000s5zzA~--K**4000FF$A$GGFI%,,V444 #A Avv34JKK !((000Q333M333bqbJII  K DI t{>>yII J J J J K Krr)rCrDrErFrrrYr\r[r%rlr`rSrzr>rrrrs''"""""">!!!       {7{7{7z:K:K:K:K:Krc"eZdZdZfdZxZS)rz(Like FeedParser, but feed accepts bytes.crt|dddS)Nasciisurrogateescape)superr\decode)rr7 __class__s rr\zBytesFeedParser.feeds.  T[[*;<<=====r)rCrDrErFr\ __classcell__)rs@rrrs>22>>>>>>>>>r)rF__all__remailremail._policybaser collectionsriorrrxrr NLCRE_crackrvr|NLobjectr(r rrr>rrrs{ " * + &&&&&& =!! BJ ' ' BJ( ) ) bj))  2:> ? ?  vxx WWWWWfWWWvIKIKIKIKIKIKIKIKX >>>>>j>>>>>r