U h<@sdZddlmZddlZddlmZddlmZddlm Z ddl m Z m Z ddl mZmZdd lmZmZmZmZmZd d ZGd d d eZGdddeZGdddZddZddZedZddZdS)zwHTTP Request Parser This server uses asyncore to accept connections and do initial processing but threads to do work. )BytesION)parse)unquote_to_bytes)OverflowableBuffer)ChunkedReceiverFixedStreamReceiver)HEADER_FIELD_RE ONLY_DIGIT_RE) BadRequestRequestEntityTooLargeRequestHeaderFieldsTooLargeServerNotImplementedfind_double_newlinecCst|dS)Nlatin-1)rdecode) bytestringrA/var/www/html/venv/lib/python3.8/site-packages/waitress/parser.pyunquote_bytes_to_wsgi$src@s eZdZdS) ParsingErrorN__name__ __module__ __qualname__rrrrr(src@s eZdZdS)TransferEncodingNotImplementedNrrrrrr,src@sleZdZdZdZdZdZdZdZdZ dZ dZ dZ dZ dZdZdZddZd d Zd d Zd dZddZdS)HTTPRequestParserzA structure that collects the HTTP request. Once the stream is completed, the instance is passed to a server task constructor. FrN1.0cCsi|_||_dS)z/ adj is an Adjustments object. N)headersadj)selfrrrr__init__HszHTTPRequestParser.__init__c Cs4|jr dSt|}|j}|dkr|jj}|j|}t|}d}|dkr`||_|t||}n|j|7_|}|j|kr|dt d||_ d|_|S|dkr|d|}| }|sd|_ d|_nz||Wnrt k r} zt| jd|_ d|_W5d} ~ XYntk rN} zt| jd|_ d|_W5d} ~ XYnHX|jdkrbd|_|jdkr|jj} |j| krtd| |_ d|_d|_|S||_|S||}|j|7_|jj} |j| krtd| |_ d|_n@|j r|j |_ d|_n(|jr,d|_|jr,t||jd<|SdS)z Receives the HTTP stream for one request. Returns the number of bytes consumed. Sets the completed flag once both the header and the body have been received. rNsGET / HTTP/1.0 zexceeds max_header of %sTzexceeds max_body of %sCONTENT_LENGTH) completedlenbody_rcvrZmax_request_header_size header_plusrheader_bytes_received parse_headerr errorlstripemptyrr argsrr content_lengthZmax_request_body_sizer headers_finishedreceivedbody_bytes_receivedchunkedstr__len__r) r dataZdatalenbrZ max_headersindexconsumedr&eZmax_bodyrrrr/Qs|           zHTTPRequestParser.receivedc Cs|d}|dkr4|d|}||dd}ntdd|ksLd|krTtd||_t|}|j}|D]}t|}|std |d d \}} d |krql| d } | dd  d} z|| d|  d7<Wqlt k r| d|| <YqlXqlt|\} } } | | kr8| kr8dkrDnntd| d|_| d} | d} | |_| |_t| \|_|_|_|_|_|jj|_|dd}| dkr|dkrd|_| dkrv|dd}dd|dD}|D]}|dkrtdq|r:|dd kr:d|_ t!|jj"}t#||_$n|rHtd|d!d}|d"k|_%|d#krvd|_|j s|d$d%}t&|'dstd&t(|}||_)|dkrt!|jj"}t*|||_$dS)'zp Parses the header_plus block of text (the headers plus the first line of the request).  rNzHTTP message header invalid  z#Bare CR or LF found in HTTP messagezInvalid headernamevalue_s -rs, rzStart line is invalidZ CONNECTIONrz keep-aliveTz1.1ZTRANSFER_ENCODINGcSsg|]}|r|dqS)z )striplower).0encodingrrr sz2HTTPRequestParser.parse_header..,>r1z-Transfer-Encoding requested is not supported.r1ZEXPECTz 100-continuecloser"0zContent-Length is invalid)+findrstripr first_lineget_header_linesrrmatchgrouprCupperreplacerKeyErrorcrack_first_line request_uricommandversion split_uri proxy_schemeZ proxy_netlocpathqueryfragmentr url_schemegetrDconnection_closepopsplitrr1rZinbuf_overflowrr%expect_continuer encodeintr-r)r r&r7rNheaderlinesrlinekeyr?key1rWurirX connectionte encodingsrFbufexpectclrrrr(s   (               zHTTPRequestParser.parse_headercCs |j}|dk r|StSdSN)r%getfilerr r%rrrget_body_streamNsz!HTTPRequestParser.get_body_streamcCs|j}|dk r|dSrr)r%ZgetbufrJrtrrrrJVszHTTPRequestParser.close)rrr__doc__r#r+rcr.r&r1r-r'r0r%rXr)r`r!r/r(rurJrrrrr0s( wrcCsd}}}}}|dddkrZ|}d|kr@|dd\}}d|kr|dd\}}n6zt|\}}}}}Wntk rtdYnX|d|dt||d|dfS) Nrr;s//#?zBad URIr)rbrurlsplit UnicodeErrorrrr)rkschemenetlocr[r\r]rrrrY]s" rYcCsg}|d}|D]h}|sqd|ks,d|kr>tdt|d|drp|s^tdt|d|d|7<q||q|S) zL Splits the header into lines, putting multi-line headers together. r:r<r=z'Bare CR or LF found in header line "%s"r)  zMalformed header line "%s"rI)rbrr2 startswithappend)rfrrgrhrrrrOs    rOs(?P[!#$%&'*+\-.^_`|~0-9A-Za-z]+) (?P(?:[^ :?#]+://[^ ?#/]*(?:[0-9]{1,5})?)?[^ ]+)(?: HTTP/(?P[0-9]\.[0-9]))?cCsZt|}|dkrdS|dp d}|d}|d}||krPtdt|d|||fS)N)rrrrXrmethodrkzMalformed HTTP method "%s"r) first_line_re fullmatchrRrr2)rhmrXrrkrrrrUs   rU) rviorreurllibr urllib.parserZwaitress.buffersrZwaitress.receiverrrZwaitress.rfc7230rr Zwaitress.utilitiesr r r r rr ExceptionrrrrYrOcompilerrUrrrrs(     /$