Submit
Path:
~
/
/
proc
/
thread-self
/
root
/
opt
/
alt
/
python35
/
lib64
/
python3.5
/
site-packages
/
aiohttp
/
__pycache__
/
File Content:
http_parser.cpython-35.pyc
���Z_ � @ s� d d l Z d d l Z d d l 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 d d l m Z m Z m Z m Z m Z m Z d d l m Z m Z d d l m Z d d l m Z m Z y d d l Z d Z Wn e k rd Z Yn Xd d d d d f Z e! e j" � Z# e j$ d � Z% e j$ d � Z& e j$ d � Z' e j( d d d d d d d d d d d g � Z) e j( d d d d! d d d d d d g � Z* Gd" d# � d# e � Z+ Gd$ d% � d% e � Z, Gd& d � d � Z- Gd' d( � d( e- � Z. Gd) d* � d* e- � Z/ Gd+ d, � d, � Z0 Gd- d. � d. � Z1 e. Z2 e/ Z3 y- d d/ l4 m5 Z5 m6 Z6 e r�e5 Z2 e6 Z3 Wn e k r�Yn Xd S)0� N)�IntEnum)� CIMultiDict)�URL� )�hdrs)� NO_EXTENSIONS)� BadStatusLine�ContentEncodingError�ContentLengthError� InvalidHeader� LineTooLong�TransferEncodingError)� HttpVersion� HttpVersion10)�internal_logger)� EMPTY_PAYLOAD� StreamReaderTF� HttpParser�HttpRequestParser�HttpResponseParser�RawRequestMessage�RawResponseMessagez [A-Z0-9$-_.]+zHTTP/(\d+).(\d+)s' [\x00-\x1F\x7F()<>@,;:\[\]={} \t\\\\\"]�method�path�version�headers� raw_headersZ should_close� compression�upgrade�chunkedZurl�code�reasonc @ s( e Z d Z d Z d Z d Z d Z d S)� ParseStater r � � N)�__name__� __module__� __qualname__� PARSE_NONE� PARSE_LENGTH� PARSE_CHUNKED�PARSE_UNTIL_EOF� r, r, �/http_parser.pyr" / s r" c @ s. e Z d Z d Z d Z d Z d Z d Z d S)� ChunkStater r r# r$ � N)r% r& r' �PARSE_CHUNKED_SIZE�PARSE_CHUNKED_CHUNK�PARSE_CHUNKED_CHUNK_EOF�PARSE_MAYBE_TRAILERS�PARSE_TRAILERSr, r, r, r- r. 7 s r. c @ s e Z d Z d d d d d d d d d d d d d d d � Z d d � Z d d e j e j e j d d � Z d d � Z d S)r Ni� i � FTc C s� | | _ | | _ | | _ | | _ | | _ | | _ | | _ | | _ | | _ | | _ | | _ | | _ g | _ d | _ d | _ d | _ d | _ | | _ d S)N� F)�protocol�loop� max_line_size� max_headers�max_field_size�timerr r �readall�payload_exception�response_with_body�read_until_eof�_lines�_tail� _upgradedZ_payload�_payload_parser�_auto_decompress)�selfr6 r7 r8 r9 r: r; r r r< r= r> r? �auto_decompressr, r, r- �__init__A s$ zHttpParser.__init__c C s� | j d k r( | j j � d | _ nu | j rD | j j | j � | j r� | j d d k rp | j j d � y | j | j � SWn t k r� d SYn Xd S)Nr z � ���)rC �feed_eofrA r@ �append� parse_message� Exception)rE r, r, r- rJ [ s zHttpParser.feed_eofs r5 c " C s� g } | j r& | j | d } | _ t | � } d } | j } xx| | k r�| j d k r�| j r�| j | | � } | | k r� | j r� | d } qD | | k r�| j j | | | � � | d } | j d | k r�z | j | j � } Wd | j j � X| j j | � } | d k roy t | � } Wn t k rVt | � � Yn X| d k rot | � � | | j k r�t | � � | j | _ t | d | j � } | d k r�| d k s�| j rW| j rWt | j d | j d | �} t | d | d | j d | d | j d | j d | j d | j d | j �} | j sn| | _ n| | k r�t | j d | j d | �} d | _ t | d | j d | j d d d | j �| _ n� t | d d � d k rh| d k rh| j rht | j d | j d | �} t | d | d | j d | d | j d | j d d d | j d | j �} | j sn| | _ n t } | j | | f � q�| | d � | _ | } PqD | j d k r�| j r�| j s�t � PqD | r�| | k r�| j s�t � y& | j j | | d � � \ } } Wnx t! k r�} zX | j" d k r^| j j# j$ | j" t% | � � � n | j j# j$ | � d } d } WYd d } ~ Xn X| r�d } t | � } d | _ qD qD PqD W| r�| | k r�| | d � } n | } | | j | f S)Nr5 r r# r r r; r7 �lengthr r r r< r> rF T�d �� rI )&rA �lenr7 rC rB �findr@ rK rL �clearr �get�int� ValueErrorr r �getattrr r r r6 r; �HttpPayloadParserr r r< r> rD �doner? r �AssertionError� feed_data� BaseExceptionr= �payload� set_exception�str)rE �data�SEPZEMPTY�CONTENT_LENGTH� METH_CONNECT�SEC_WEBSOCKET_KEY1ZmessagesZdata_lenZ start_posr7 �pos�msgrN r r] Zpayload_parser�eof�excr, r, r- r[ l s� zHttpParser.feed_datac C s" t � } g } d } | d } t | � } x�| r!t | � } y | j d d � \ } } Wn! t k r t | � d � Yn X| j d � } t j | � r� t | � � | d 7} | | } | o� | d d k } | r�| g } x� | r�| t | � 7} | | j k r2t d j | j d d � � | j � � | j | � | d 7} | | k rx| | } | r| d d k } q� d } Pq� Wd j | � } n6 | | j k r�t d j | j d d � � | j � � | j � } | j d d � } | j d d � } | j | | � | j | | f � q. Wd } d } d } d } t | � } | j t j � } | r�| j � } | d k rd } n' | d k r�d } n | d k r�d } | j t j � } | r�| j � } | d k r�| } | j t j � } | r d | j � k r d } | | | | | | f S)z�Parses RFC 5322 headers from a stream. Line continuations are supported. Returns list of header name and value pairs. Header name is in upper case. r � :Ns r � � zrequest header field {}�utf8�xmlcharrefreplacer5 zutf-8�surrogateescapeF�closeTz keep-aliver �gzip�deflate�brr )rj rk )rj rk )rp rq rr )r rQ �splitrV r �strip�HDRRE�searchr: r �format�decoderK �join�add�tuplerT r Z CONNECTION�lowerZCONTENT_ENCODINGZTRANSFER_ENCODING)rE �linesr r Z lines_idx�lineZ line_countZ header_lengthZbnameZbvalueZ continuation�name�valueZ close_conn�encodingr r �conn�v�encZter, r, r- � parse_headers� s� zHttpParser.parse_headers) r% r& r' rG rJ r rb rc rd r[ r� r, r, r, r- r ? s �c @ s" e Z d Z d Z d d � Z d S)�HttpRequestParserPyz�Read request status line. Exception .http_exceptions.BadStatusLine could be raised in case of any errors in status line. Returns RawRequestMessage. c C s� t | d � | j k r+ t d | j � � | d j d d � } y | j d d � \ } } } Wn! t k r� t | � d � Yn X| j � } t j | � s� t | � � y_ | j d � r� | d d � j d d � \ } } t t | � t | � � } n t | � � Wn t k r*t | � � Yn X| j | � \ } } } } } } | d k rs| t k rmd } n d } t | | | | | | | | | t | � � S) Nr zStatus line is too longzutf-8rn r# zHTTP/� �.r TF)rQ r8 r rx rs rV r �upper�METHRE�match� startswithr rU rM r� r r r )rE r} r~ r r r Zn1Zn2r r ro r r r r, r, r- rL _ s4 " ! z!HttpRequestParserPy.parse_messageN)r% r& r' �__doc__rL r, r, r, r- r� Y s r� c @ s" e Z d Z d Z d d � Z d S)�HttpResponseParserPyz�Read response status line and headers. BadStatusLine could be raised in case of any errors in status line. Returns RawResponseMessagec " C s� t | d � | j k r+ t d | j � � | d j d d � } y | j d d � \ } } Wn! t k r� t | � d � Yn8 Xy | j d d � \ } } Wn t k r� d } Yn Xt j | � } | d k r� t | � � t t | j d � � t | j d � � � } y t | � } Wn! t k r?t | � d � Yn X| d k rXt | � � | j | � \ } } } } } } | d k r�| t k } t | | | j � | | | | | | � S) Nr zStatus line is too longzutf-8rn r rH r# i� )rQ r8 r rx rs rV r �VERSREr� r rU �groupr� r r rt ) rE r} r~ r �statusr! r� r r ro r r r r, r, r- rL � s8 - ! z"HttpResponseParserPy.parse_messageN)r% r& r' r� rL r, r, r, r- r� � s r� c @ sR e Z d Z d d d d d d d d d d � Z d d � Z d d d d � Z d S) rX NFTc C s[ | | _ d | _ t j | _ t j | _ d | _ d | _ | | _ d | _ | rr | rr | j rr t | | � } | s� t j | _ | j � d | _ n� | r� t j | _ n� | d k r� t j | _ | | _ | j d k rN| j � d | _ nY | r| d k rt j | _ n8 | d k rNt j d � t j | _ | j � d | _ | | _ d S) Nr r5 FT�� �PUT�POSTz6Content-Length or Transfer-Encoding header is required)r� r� )r] �_lengthr" r( �_typer. r0 �_chunk� _chunk_size� _chunk_tailrD rY � DeflateBufferrJ r* r) r+ r �warning) rE r] rN r r r r r< r> rF r, r, r- rG � s> zHttpPayloadParser.__init__c C se | j t j k r" | j j � n? | j t j k rC t d � � n | j t j k ra t d � � d S)Nz2Not enough data for satisfy content length header.z3Not enough data for satisfy transfer length header.) r� r" r+ r] rJ r) r r* r )rE r, r, r- rJ � s zHttpPayloadParser.feed_eofs � ;c C s | j t j k r� | j } t | � } | | k rv | | | _ | j j | | � | j d k r� | j j � d Sqd | _ | j j | d | � | � | j j � d | | d � f SnG| j t j k r�| j r� | j | } d | _ x| r�| j t j k r)| j | � } | d k r | j | d | � } | d k r[| d | � } n | d | � } y t t | � d � } WnA t k r�t | d | � � } | j j | � | d � Yn X| | d d � } | d k r�t j | _ q)t j | _ | | _ | j j � n | | _ d S| j t j k r�| j } t | � } | | k r�| | | _ | j j | | � d Sd | _ | j j | d | � | � | | d � } t j | _ | j j � | j t j k r#| d d � | k r| d d � } t j | _ n | | _ d S| j t j k rx| d d � | k rl| j j � d | d d � f St j | _ | j t j k r� | j | � } | d k r�| | d d � } t j | _ q� | | _ d Sq� Wn+ | j t j k r| j j | t | � � d S) Nr Tr5 � r# F)Tr5 )FN)FN)FN)FN)FN)r� r" r) r� rQ r] r[ rJ r* r� r� r. r0 rR rU �bytesrV r r^ r3 r1 r� �begin_http_chunk_receivingr2 �end_http_chunk_receivingr4 r+ ) rE �chunkra Z CHUNK_EXTZrequiredZ chunk_lenre �i�sizerh r, r, r- r[ � s� zHttpPayloadParser.feed_data)r% r& r' rG rJ r[ r, r, r, r- rX � s * rX c @ s^ e Z d Z d Z d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d S)r� zDDeflateStream decompress stream and feed data into specified stream.c C s� | | _ d | _ | | _ d | _ | d k rT t sB t d � � t j � | _ n8 | d k rm d t j n t j } t j d | � | _ d S)Nr Frr zGCan not decode content-encoding: brotli (br). Please install `brotlipy`rp r� Zwbits) �outr� r� �_started_decoding� HAS_BROTLIr �brotliZ Decompressor� decompressor�zlib� MAX_WBITS� decompressobj)rE r� r� Z zlib_moder, r, r- rG a s #zDeflateBuffer.__init__c C s | j j | � d S)N)r� r^ )rE rh r, r, r- r^ r s zDeflateBuffer.set_exceptionc C s� | j | 7_ y | j j | � } Wn� t k r� | j r� | j d k r� t j � | _ y | j j | � } Wq� t k r� t d | j � � Yq� Xn t d | j � � Yn X| r� d | _ | j j | t | � � d S)Nrq z#Can not decode content-encoding: %sT) r� r� � decompressrM r� r� r� r� r r� r[ rQ )rE r� r� r, r, r- r[ u s zDeflateBuffer.feed_datac C sv | j j � } | s$ | j d k re | j j | t | � � | j d k re | j j re t d � � | j j � d S)Nr rr rq ) r� �flushr� r� r[ rQ r� rg r rJ )rE r� r, r, r- rJ � s zDeflateBuffer.feed_eofc C s | j j � d S)N)r� r� )rE r, r, r- r� � s z(DeflateBuffer.begin_http_chunk_receivingc C s | j j � d S)N)r� r� )rE r, r, r- r� � s z&DeflateBuffer.end_http_chunk_receivingN) r% r& r' r� rG r^ r[ rJ r� r� r, r, r, r- r� ^ s r� )�HttpRequestParserC�HttpResponseParserC)7� collections�re�stringr� �enumr Z multidictr Zyarlr rH r Zhelpersr Zhttp_exceptionsr r r r r r Z http_writerr r �logr Zstreamsr r r� r� � ImportError�__all__�set� printableZASCIISET�compiler� r� ru � namedtupler r r" r. r r� r� rX r� r r Z _http_parserr� r� r, r, r, r- �<module> s` . � 01�<
Submit
FILE
FOLDER
Name
Size
Permission
Action
__init__.cpython-35.opt-1.pyc
947 bytes
0644
__init__.cpython-35.pyc
947 bytes
0644
abc.cpython-35.opt-1.pyc
6230 bytes
0644
abc.cpython-35.pyc
6230 bytes
0644
client.cpython-35.opt-1.pyc
22636 bytes
0644
client.cpython-35.pyc
22636 bytes
0644
client_exceptions.cpython-35.opt-1.pyc
8233 bytes
0644
client_exceptions.cpython-35.pyc
8233 bytes
0644
client_proto.cpython-35.opt-1.pyc
5130 bytes
0644
client_proto.cpython-35.pyc
5130 bytes
0644
client_reqrep.cpython-35.opt-1.pyc
24121 bytes
0644
client_reqrep.cpython-35.pyc
24260 bytes
0644
client_ws.cpython-35.opt-1.pyc
8283 bytes
0644
client_ws.cpython-35.pyc
8283 bytes
0644
connector.cpython-35.opt-1.pyc
25549 bytes
0644
connector.cpython-35.pyc
25549 bytes
0644
cookiejar.cpython-35.opt-1.pyc
8597 bytes
0644
cookiejar.cpython-35.pyc
8597 bytes
0644
formdata.cpython-35.opt-1.pyc
4293 bytes
0644
formdata.cpython-35.pyc
4293 bytes
0644
frozenlist.cpython-35.opt-1.pyc
2796 bytes
0644
frozenlist.cpython-35.pyc
2796 bytes
0644
hdrs.cpython-35.opt-1.pyc
3809 bytes
0644
hdrs.cpython-35.pyc
3809 bytes
0644
helpers.cpython-35.opt-1.pyc
24585 bytes
0644
helpers.cpython-35.pyc
24585 bytes
0644
http.cpython-35.opt-1.pyc
1290 bytes
0644
http.cpython-35.pyc
1290 bytes
0644
http_exceptions.cpython-35.opt-1.pyc
3640 bytes
0644
http_exceptions.cpython-35.pyc
3640 bytes
0644
http_parser.cpython-35.opt-1.pyc
14443 bytes
0644
http_parser.cpython-35.pyc
14495 bytes
0644
http_websocket.cpython-35.opt-1.pyc
14253 bytes
0644
http_websocket.cpython-35.pyc
14345 bytes
0644
http_writer.cpython-35.opt-1.pyc
4160 bytes
0644
http_writer.cpython-35.pyc
4160 bytes
0644
locks.cpython-35.opt-1.pyc
1426 bytes
0644
locks.cpython-35.pyc
1426 bytes
0644
log.cpython-35.opt-1.pyc
409 bytes
0644
log.cpython-35.pyc
409 bytes
0644
multipart.cpython-35.opt-1.pyc
25740 bytes
0644
multipart.cpython-35.pyc
26208 bytes
0644
payload.cpython-35.opt-1.pyc
9513 bytes
0644
payload.cpython-35.pyc
9642 bytes
0644
payload_streamer.cpython-35.opt-1.pyc
2638 bytes
0644
payload_streamer.cpython-35.pyc
2638 bytes
0644
pytest_plugin.cpython-35.opt-1.pyc
9446 bytes
0644
pytest_plugin.cpython-35.pyc
9505 bytes
0644
resolver.cpython-35.opt-1.pyc
3411 bytes
0644
resolver.cpython-35.pyc
3411 bytes
0644
signals.cpython-35.opt-1.pyc
1263 bytes
0644
signals.cpython-35.pyc
1263 bytes
0644
streams.cpython-35.opt-1.pyc
16802 bytes
0644
streams.cpython-35.pyc
17141 bytes
0644
tcp_helpers.cpython-35.opt-1.pyc
1404 bytes
0644
tcp_helpers.cpython-35.pyc
1404 bytes
0644
test_utils.cpython-35.opt-1.pyc
18137 bytes
0644
test_utils.cpython-35.pyc
18187 bytes
0644
tracing.cpython-35.opt-1.pyc
11468 bytes
0644
tracing.cpython-35.pyc
11468 bytes
0644
web.cpython-35.opt-1.pyc
4758 bytes
0644
web.cpython-35.pyc
4758 bytes
0644
web_app.cpython-35.opt-1.pyc
10018 bytes
0644
web_app.cpython-35.pyc
10489 bytes
0644
web_exceptions.cpython-35.opt-1.pyc
12268 bytes
0644
web_exceptions.cpython-35.pyc
12268 bytes
0644
web_fileresponse.cpython-35.opt-1.pyc
5568 bytes
0644
web_fileresponse.cpython-35.pyc
5568 bytes
0644
web_middlewares.cpython-35.opt-1.pyc
2689 bytes
0644
web_middlewares.cpython-35.pyc
2689 bytes
0644
web_protocol.cpython-35.opt-1.pyc
13677 bytes
0644
web_protocol.cpython-35.pyc
13716 bytes
0644
web_request.cpython-35.opt-1.pyc
19624 bytes
0644
web_request.cpython-35.pyc
19624 bytes
0644
web_response.cpython-35.opt-1.pyc
17525 bytes
0644
web_response.cpython-35.pyc
18266 bytes
0644
web_runner.cpython-35.opt-1.pyc
9776 bytes
0644
web_runner.cpython-35.pyc
9776 bytes
0644
web_server.cpython-35.opt-1.pyc
2089 bytes
0644
web_server.cpython-35.pyc
2089 bytes
0644
web_urldispatcher.cpython-35.opt-1.pyc
38008 bytes
0644
web_urldispatcher.cpython-35.pyc
39070 bytes
0644
web_ws.cpython-35.opt-1.pyc
12822 bytes
0644
web_ws.cpython-35.pyc
12822 bytes
0644
worker.cpython-35.opt-1.pyc
6554 bytes
0644
worker.cpython-35.pyc
6554 bytes
0644
N4ST4R_ID | Naxtarrr
